- part of jd promotion apis

platformapi/ebaiapi/shop_sku_test.go

@@ -72,7 +72,7 @@ func TestSkuCreate(t *testing.T) {
 		"photos": []map[string]interface{}{
 			map[string]interface{}{
 				"is_master": true,
-				"url":       "http://image.jx.scaqda.com/8536c76779333f53517006f88ea7174c.jpg?imageView2/1/w/80/h/80",
+				"url":       "http://image.jxc4.com/8536c76779333f53517006f88ea7174c.jpg?imageView2/1/w/80/h/80",
 			},
 		},
 	})

platformapi/jdapi/jdapi_test.go

@@ -21,9 +21,9 @@ func init() {
 	baseapi.Init(sugarLogger)
 
 	// sandbox
-	//jdapi = New("c8854ef2-f80a-45ee-aceb-dc8014d646f8", "06692746f7224695ad4788ce340bc854", "d6b42a35a7414a5490d811654d745c84")
+	jdapi = New("c8854ef2-f80a-45ee-aceb-dc8014d646f8", "06692746f7224695ad4788ce340bc854", "d6b42a35a7414a5490d811654d745c84")
 	// prod
-	jdapi = New("91633f2a-c5f5-4982-a925-a220d19095c3", "1dba76d40cac446ca500c0391a0b6c9d", "a88d031a1e7b462cb1579f12e97fe7f4")
+	// jdapi = New("91633f2a-c5f5-4982-a925-a220d19095c3", "1dba76d40cac446ca500c0391a0b6c9d", "a88d031a1e7b462cb1579f12e97fe7f4")
 }
 
 func TestTest(t *testing.T) {

platformapi/jdapi/promotion.go

@@ -0,0 +1,157 @@
+package jdapi
+
+import (
+	"crypto/md5"
+	"fmt"
+	"time"
+
+	"git.rosy.net.cn/baseapi/utils"
+)
+
+const (
+	KeyStationNo      = "stationNo"
+	KeyOutStationNo   = "outStationNo"
+	KeyPromotionPrice = "promotionPrice"
+	KeyLimitSkuCount  = "limitSkuCount"
+
+	KeyInfoId    = "infoId"
+	KeyOutInfoId = "outInfoId"
+)
+
+const (
+	MaxPromotionSkuCount = 200
+)
+
+// 单品直降添加主活动信息接口
+// https://opendj.jd.com/staticnew/widgets/resources.html?groupid=178&apiid=ee8685c9be9b4aa5bdc41468c5ebc33b
+func (a *API) CreatePromotionInfosSingle(name string, beginDate, endDate time.Time, outInfoId, advertising string) (infoId int64, err error) {
+	return a.createPromotionInfos(PromotionTypeDirectDown, name, beginDate, endDate, outInfoId, advertising)
+}
+
+// 单品直降添加活动商品信息接口
+// 最多200条
+// https://opendj.jd.com/staticnew/widgets/resources.html?groupid=178&apiid=0ad0715e0aaa42489cbeac36398e916d
+func (a *API) CreatePromotionSkuSingle(infoId int64, outInfoId string, skus []map[string]interface{}) (skusResult []map[string]interface{}, err error) {
+	return a.createPromotionSku(PromotionTypeDirectDown, infoId, outInfoId, skus)
+}
+
+// 单品直降活动提交保存接口
+// https://opendj.jd.com/staticnew/widgets/resources.html?groupid=178&apiid=b84e14eb341e470db8ed9b60f78edb16
+func (a *API) ConfirmPromotionSingle(infoId int64, outInfoId string) (err error) {
+	return a.confirmPromotion(PromotionTypeDirectDown, infoId, outInfoId)
+}
+
+// 限时抢添加活动主信息接口
+// https://opendj.jd.com/staticnew/widgets/resources.html?groupid=184&apiid=7d8b7ff86c9e457bb8a46963cb575769
+func (a *API) CreatePromotionInfosLimitTime(name string, beginDate, endDate time.Time, outInfoId, advertising string) (infoId int64, err error) {
+	return a.createPromotionInfos(PromotionTypeLimitedTime, name, beginDate, endDate, outInfoId, advertising)
+}
+
+// 限时抢添加活动规则信息接口（直降也是调用此接口）
+// https://opendj.jd.com/staticnew/widgets/resources.html?groupid=184&apiid=e80674791d3542f0a87502753c0d0592
+func (a *API) CreatePromotionRules(infoId int64, outInfoId string, limitDevice, limitPin, limitCount, limitDaily int) (err error) {
+	jdParams := map[string]interface{}{
+		"limitDevice": limitDevice,
+		"limitPin":    limitPin,
+		"limitCount":  limitCount,
+		"limitDaily":  limitDaily,
+		"timeStamp":   utils.GetCurTimeStr(),
+	}
+	if infoId != 0 {
+		jdParams[KeyInfoId] = infoId
+	} else {
+		jdParams[KeyOutInfoId] = outInfoId
+	}
+	_, err = a.AccessAPINoPage("limitTime/createPromotionRules", jdParams, nil, nil, genNoPageResultParser("errorCode", "errorInfos", "data", "0"))
+	return err
+}
+
+// 限时抢添加活动商品信息接口
+// 最多200条
+// https://opendj.jd.com/staticnew/widgets/resources.html?groupid=184&apiid=65fecef4883c40c6b23bbdb6123f5d80
+func (a *API) CreatePromotionSkuLimitTime(infoId int64, outInfoId string, skus []map[string]interface{}) (skusResult []map[string]interface{}, err error) {
+	return a.createPromotionSku(PromotionTypeLimitedTime, infoId, outInfoId, skus)
+}
+
+// 限时抢活动提交保存接口
+// https://opendj.jd.com/staticnew/widgets/resources.html?groupid=184&apiid=3991063e2f0d435094e9fe44754f3490
+func (a *API) ConfirmPromotionLimitTime(infoId int64, outInfoId string) (err error) {
+	return a.confirmPromotion(PromotionTypeLimitedTime, infoId, outInfoId)
+}
+
+func (a *API) createPromotionInfos(promotionType int, name string, beginDate, endDate time.Time, outInfoId, advertising string) (infoId int64, err error) {
+	if outInfoId == "" {
+		outInfoId = fmt.Sprintf("%X", md5.Sum([]byte(name)))
+	}
+	jdParams := map[string]interface{}{
+		"promotionName": name,
+		"beginDate":     utils.Time2Str(beginDate),
+		"endDate":       utils.Time2Str(endDate),
+		"advertising":   advertising,
+		"promotionType": promotionType,
+		"timeStamp":     utils.GetCurTimeStr(),
+		KeyOutInfoId:    outInfoId,
+	}
+	cmd := ""
+	if promotionType == PromotionTypeDirectDown {
+		cmd = "singlePromote/createPromotionInfos"
+	} else if promotionType == PromotionTypeLimitedTime {
+		cmd = "limitTime/createPromotionInfos"
+	} else {
+		panic("unknow promotionType!")
+	}
+	result, err := a.AccessAPINoPage(cmd, jdParams, nil, nil, genNoPageResultParser("errorCode", "errorInfos", "data", "0"))
+	if err == nil {
+		return utils.MustInterface2Int64(result), nil
+	}
+	return 0, err
+}
+
+func (a *API) createPromotionSku(promotionType int, infoId int64, outInfoId string, skus []map[string]interface{}) (skusResult []map[string]interface{}, err error) {
+	jdParams := map[string]interface{}{
+		"skus":      skus,
+		"timeStamp": utils.GetCurTimeStr(),
+	}
+	if infoId != 0 {
+		jdParams[KeyInfoId] = infoId
+	} else {
+		jdParams[KeyOutInfoId] = outInfoId
+	}
+	cmd := ""
+	if promotionType == PromotionTypeDirectDown {
+		cmd = "singlePromote/createPromotionSku"
+	} else if promotionType == PromotionTypeLimitedTime {
+		cmd = "limitTime/createPromotionSku"
+	} else {
+		panic("unknow promotionType!")
+	}
+	result, err := a.AccessAPINoPage(cmd, jdParams, nil, nil, genNoPageResultParser("errorCode", "errorInfos", "data", "0"))
+	if err == nil {
+		if result != nil {
+			return utils.Slice2MapSlice(result.([]interface{})), nil
+		}
+		return nil, nil
+	}
+	return nil, err
+}
+
+func (a *API) confirmPromotion(promotionType int, infoId int64, outInfoId string) (err error) {
+	jdParams := map[string]interface{}{
+		"timeStamp": utils.GetCurTimeStr(),
+	}
+	if infoId != 0 {
+		jdParams[KeyInfoId] = infoId
+	} else {
+		jdParams[KeyOutInfoId] = outInfoId
+	}
+	cmd := ""
+	if promotionType == PromotionTypeDirectDown {
+		cmd = "singlePromote/confirmPromotion"
+	} else if promotionType == PromotionTypeLimitedTime {
+		cmd = "limitTime/confirmPromotion"
+	} else {
+		panic("unknow promotionType!")
+	}
+	_, err = a.AccessAPINoPage(cmd, jdParams, nil, nil, genNoPageResultParser("errorCode", "errorInfos", "data", "0"))
+	return err
+}

platformapi/jdapi/promotion_test.go

@@ -0,0 +1,62 @@
+package jdapi
+
+import (
+	"testing"
+	"time"
+)
+
+func TestCreatePromotionSingle(t *testing.T) {
+	infoId, err := jdapi.CreatePromotionInfosSingle("测试1", time.Now(), time.Now().Add(24*time.Hour), "", "")
+	if err != nil {
+		t.Fatal(err)
+	}
+	t.Log(infoId)
+	err = jdapi.CreatePromotionRules(infoId, "", 1, 1, 1, 1)
+	if err != nil {
+		t.Fatal(err)
+	}
+	skuInfos, err := jdapi.CreatePromotionSkuSingle(infoId, "", []map[string]interface{}{
+		{
+			KeyOutSkuId:       "2216",
+			KeyStationNo:      11682042,
+			KeyPromotionPrice: 500,
+			KeyLimitSkuCount:  2,
+		},
+	})
+	if err != nil {
+		t.Fatal(err)
+	}
+	t.Log(skuInfos)
+	err = jdapi.ConfirmPromotionSingle(infoId, "")
+	if err != nil {
+		t.Fatal(err)
+	}
+}
+
+func TestCreatePromotionLimitTime(t *testing.T) {
+	infoId, err := jdapi.CreatePromotionInfosLimitTime("测试1", time.Now(), time.Now().Add(24*time.Hour), "", "")
+	if err != nil {
+		t.Fatal(err)
+	}
+	t.Log(infoId)
+	err = jdapi.CreatePromotionRules(infoId, "", 1, 1, 5, 1)
+	if err != nil {
+		t.Fatal(err)
+	}
+	skuInfos, err := jdapi.CreatePromotionSkuLimitTime(infoId, "", []map[string]interface{}{
+		{
+			KeyOutSkuId:       "2216",
+			KeyStationNo:      11682042,
+			KeyPromotionPrice: 300,
+			KeyLimitSkuCount:  2,
+		},
+	})
+	if err != nil {
+		t.Fatal(err)
+	}
+	t.Log(skuInfos)
+	err = jdapi.ConfirmPromotionLimitTime(infoId, "")
+	if err != nil {
+		t.Fatal(err)
+	}
+}