- 营销活动API临时版本

business/jxstore/act/act.go

@@ -0,0 +1,319 @@
+package act
+
+import (
+	"fmt"
+	"time"
+
+	"git.rosy.net.cn/jx-callback/globals"
+
+	"git.rosy.net.cn/baseapi/utils"
+	"git.rosy.net.cn/jx-callback/business/jxutils"
+	"git.rosy.net.cn/jx-callback/business/partner"
+
+	"git.rosy.net.cn/jx-callback/business/jxutils/jxcontext"
+	"git.rosy.net.cn/jx-callback/business/jxutils/tasksch"
+	"git.rosy.net.cn/jx-callback/business/model"
+	"git.rosy.net.cn/jx-callback/business/model/dao"
+)
+
+type ActOrderRuleParam struct {
+	SalePrice   int64 `orm:"" json:"salePrice"`   // 满的价格
+	DeductPrice int64 `orm:"" json:"deductPrice"` // 减的价格
+}
+
+type ActStoreSkuParam struct {
+	Action int // -1删除，1修改，2新增
+
+	StoreID int `orm:"column(store_id)" json:"storeID"`
+	SkuID   int `orm:"column(sku_id)" json:"skuID"`
+
+	PricePercentage int   `orm:"" json:"pricePercentage"` // 单品级活动用，SKU级的价格比例，非0覆盖Act中的PricePercentage
+	ActPrice        int64 `orm:"" json:"actPrice"`        // 单品级活动用，SKU级指定的价格，非0覆盖CustomPricePercentage与Act中的PricePercentage
+
+	Stock int `orm:"" json:"stock"` // 订单级活动用
+}
+
+type ActDetail struct {
+	model.Act2
+}
+
+func ActStoreSkuParam2Map(actStoreSku []*ActStoreSkuParam) (actStoreSkuMap map[int][]*ActStoreSkuParam) {
+	if len(actStoreSku) > 0 {
+		for _, v := range actStoreSku {
+			actStoreSkuMap[v.StoreID] = append(actStoreSkuMap[v.StoreID], v)
+		}
+	}
+	return actStoreSkuMap
+}
+
+func genStoreSkuMapKey(storeID, skuID int) int64 {
+	return int64(storeID) + int64(skuID)*1000000
+}
+
+func ActStoreSkuParam2Model(ctx *jxcontext.Context, act *model.Act, vendorIDs []int, actStoreSku []*ActStoreSkuParam) (actMapList []*model.ActMap, actStoreMapList []*model.ActStoreMap, actStoreSkuList []*model.ActStoreSku, actStoreSkuMapList []*model.ActStoreSkuMap, err error) {
+	if len(actStoreSku) > 0 {
+		storeIDMap := make(map[int]int)
+		skuIDMap := make(map[int]int)
+		storeSkuParamMap := make(map[int][]*ActStoreSkuParam)
+		for _, v := range actStoreSku {
+			storeIDMap[v.StoreID] = 1
+			skuIDMap[v.SkuID] = 1
+			storeSkuParamMap[v.StoreID] = append(storeSkuParamMap[v.StoreID], v)
+		}
+		db := dao.GetDB()
+
+		storeSkuList, err2 := dao.GetStoresSkusInfo(db, jxutils.IntMap2List(storeIDMap), jxutils.IntMap2List(skuIDMap))
+		if err = err2; err != nil {
+			return nil, nil, nil, nil, err
+		}
+		storeSkuMap := make(map[int64]*model.StoreSkuBind)
+		for _, v := range storeSkuList {
+			storeSkuMap[genStoreSkuMapKey(v.StoreID, v.SkuID)] = v
+		}
+
+		wholeValidVendorMap := make(map[int]int)
+		for storeID, oneStoreSkuParam := range storeSkuParamMap {
+			validVendorMap := make(map[int]int)
+			validSkuMap := make(map[int]int)
+			for _, vendorID := range vendorIDs {
+				storeDetail, err2 := dao.GetStoreDetail(db, storeID, vendorID)
+				if err = err2; err == nil {
+					for _, v := range oneStoreSkuParam {
+						if storeSkuInfo := storeSkuMap[genStoreSkuMapKey(v.StoreID, v.SkuID)]; storeSkuInfo != nil {
+							validVendorMap[vendorID] = 1
+							validSkuMap[v.SkuID] = 1
+							actSkuMap := &model.ActStoreSkuMap{
+								ActID:    act.ID,
+								StoreID:  storeID,
+								SkuID:    v.SkuID,
+								VendorID: vendorID,
+
+								SyncStatus: model.SyncFlagNewMask,
+							}
+							if v.ActPrice != 0 {
+								actSkuMap.ActualActPrice = v.ActPrice
+							} else {
+								percentage := act.PricePercentage
+								if v.PricePercentage != 0 {
+									percentage = v.PricePercentage
+								}
+								percentage = percentage * int(storeDetail.PricePercentage) / 100
+								actSkuMap.ActualActPrice = int64(jxutils.CaculateSkuVendorPrice(storeSkuInfo.Price, percentage, 0))
+							}
+							dao.WrapAddIDCULDEntity(actSkuMap, ctx.GetUserName())
+							actStoreSkuMapList = append(actStoreSkuMapList, actSkuMap)
+						}
+					}
+				} else if !dao.IsNoRowsError(err) {
+					return nil, nil, nil, nil, err
+				} else {
+					err = nil
+				}
+			}
+
+			for _, v := range oneStoreSkuParam {
+				if validSkuMap[v.SkuID] == 1 {
+					if storeSkuInfo := storeSkuMap[genStoreSkuMapKey(v.StoreID, v.SkuID)]; storeSkuInfo != nil {
+						storeSku := &model.ActStoreSku{
+							ActID:           act.ID,
+							StoreID:         v.StoreID,
+							SkuID:           v.SkuID,
+							OriginalPrice:   int64(storeSkuInfo.Price),
+							PricePercentage: v.PricePercentage,
+							ActPrice:        v.ActPrice,
+							Stock:           v.Stock,
+						}
+						dao.WrapAddIDCULDEntity(storeSku, ctx.GetUserName())
+						actStoreSkuList = append(actStoreSkuList, storeSku)
+					}
+				}
+			}
+			for vendorID := range validVendorMap {
+				wholeValidVendorMap[vendorID] = 1
+				actStoreMap := &model.ActStoreMap{
+					ActID:    act.ID,
+					StoreID:  storeID,
+					VendorID: vendorID,
+
+					SyncStatus: model.SyncFlagNewMask,
+				}
+				dao.WrapAddIDCULDEntity(actStoreMap, ctx.GetUserName())
+				actStoreMapList = append(actStoreMapList, actStoreMap)
+			}
+		}
+		for vendorID := range wholeValidVendorMap {
+			actMap := &model.ActMap{
+				ActID:    act.ID,
+				VendorID: vendorID,
+
+				SyncStatus: model.SyncFlagNewMask,
+			}
+			dao.WrapAddIDCULDEntity(actMap, ctx.GetUserName())
+			actMapList = append(actMapList, actMap)
+		}
+	}
+	return actMapList, actStoreMapList, actStoreSkuList, actStoreSkuMapList, err
+}
+
+func CreateAct(ctx *jxcontext.Context, act *model.Act, vendorIDs []int, actRules []*ActOrderRuleParam, actStoreSku []*ActStoreSkuParam) (actID int, err error) {
+	vendorIDMap := make(map[int]bool)
+	for _, v := range vendorIDs {
+		vendorIDMap[v] = true
+	}
+	db := dao.GetDB()
+	dao.WrapAddIDCULDEntity(act, ctx.GetUserName())
+	dao.Begin(db)
+	defer func() {
+		if r := recover(); r != nil || err != nil {
+			dao.Rollback(db)
+			if r != nil {
+				panic(r)
+			}
+		}
+	}()
+	err = dao.CreateEntity(db, act)
+	if err != nil {
+		return 0, err
+	}
+	actMapList, actStoreMapList, actStoreSkuList, actStoreSkuMapList, err := ActStoreSkuParam2Model(ctx, act, vendorIDs, actStoreSku)
+	if err != nil {
+		return 0, err
+	}
+	isEmptyAct := true
+	for _, list := range []interface{}{
+		actMapList, actStoreMapList, actStoreSkuList, actStoreSkuMapList,
+	} {
+		if len(utils.Interface2Slice(list)) > 0 {
+			err = dao.CreateMultiEntities(db, list)
+			if err != nil {
+				return 0, err
+			}
+			isEmptyAct = false
+		}
+	}
+	if isEmptyAct {
+		return 0, fmt.Errorf("没有门店及SKU满足需求，空操作")
+	}
+	dao.Commit(db)
+	return actID, err
+}
+
+func QueryActs(ctx *jxcontext.Context, actID int, keyword string, statusList []int, actTypeList []int, storeID, skuID int, beginAt, endAt time.Time) (actList []*model.Act, err error) {
+	return actList, err
+}
+
+func GetActDetail(ctx *jxcontext.Context, actID int) (actDetail *ActDetail, err error) {
+	return actDetail, err
+}
+
+// func GetAcVendorInfo(ctx *jxcontext.Context, actID int) (err error) {
+// 	return err
+// }
+
+// func GetAcStoresVendorInfo(ctx *jxcontext.Context, actID int, storeIDs []int) (err error) {
+// 	return err
+// }
+
+// func GetAcStoresSkusVendorInfo(ctx *jxcontext.Context, actID int, storeIDs, skuIDs []int) (err error) {
+// 	return err
+// }
+
+func UpdateAct(ctx *jxcontext.Context, act *model.Act, actRules []*ActOrderRuleParam, actStoreSku []*ActStoreSkuParam) (err error) {
+	return err
+}
+
+func DeleteAct(ctx *jxcontext.Context, actID int) (err error) {
+	return err
+}
+
+func SyncAct(ctx *jxcontext.Context, actID int, vendorIDs, storeIDs, skuIDs []int) (err error) {
+	var actOrderRules []*model.ActOrderRule
+	db := dao.GetDB()
+	actMap, err := dao.GetActVendorInfo(db, actID, vendorIDs)
+	if err != nil {
+		return err
+	}
+	actStoreMap, err := dao.GetActStoreVendorInfo(db, actID, vendorIDs, storeIDs)
+	if err != nil {
+		return err
+	}
+	actStoreSkuMap, err := dao.GetActStoreSkuVendorInfo(db, actID, vendorIDs, storeIDs, skuIDs)
+	if err != nil {
+		return err
+	}
+	var realVendorIDs []int
+	for vendorID := range actMap {
+		realVendorIDs = append(realVendorIDs, vendorID)
+	}
+
+	task := tasksch.NewParallelTask("SyncAct", nil, ctx,
+		func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
+			vendorID := batchItemList[0].(int)
+			handler := partner.GetPurchasePlatformFromVendorID(vendorID)
+			if handler == nil {
+				err = fmt.Errorf("不被支持的vendorID:%d", vendorID)
+			} else {
+				act := actMap[vendorID]
+				actStore := actStoreMap[vendorID]
+				actStoreSku := actStoreSkuMap[vendorID]
+				// globals.SugarLogger.Debugf("%s", utils.Format4Output(act, false))
+				// globals.SugarLogger.Debugf("%s", utils.Format4Output(actStore, false))
+				// globals.SugarLogger.Debugf("%s", utils.Format4Output(actStoreSku, false))
+				if act != nil && actStore != nil && actStoreSku != nil {
+					if model.IsSyncStatusNeedDelete(act.SyncStatus) {
+						if !dao.IsVendorThingIDEmpty(act.VendorActID) {
+						}
+					} else if model.IsSyncStatusNeedCreate(act.SyncStatus) {
+						globals.SugarLogger.Debug("fuck")
+						err = handler.CreateAct(ctx, task, act, actOrderRules, actStore, actStoreSku)
+					} else /*if model.IsSyncStatusNeedUpdate(act.SyncStatus)*/ {
+						actStoreMap2Remove, actStoreMap2Add, actStoreMap2Update := splitActStore(actStore)
+						err = handler.UpdateAct(ctx, task, act, actOrderRules, actStoreMap2Remove, actStoreMap2Add, actStoreMap2Update, actStoreSku)
+					}
+					if err == nil {
+						actMap := &model.ActMap{}
+						actMap.ID = act.MapID
+						dao.UpdateEntityLogically(db, actMap, map[string]interface{}{
+							model.FieldSyncStatus:  0,
+							model.FieldVendorActID: act.VendorActID,
+						}, ctx.GetUserName(), nil)
+						for _, v := range actStore {
+							storeMap := model.ActStoreMap{}
+							storeMap.ID = v.MapID
+							dao.UpdateEntityLogically(db, storeMap, map[string]interface{}{
+								model.FieldSyncStatus:  0,
+								model.FieldVendorActID: v.VendorActID,
+							}, ctx.GetUserName(), nil)
+						}
+						for _, v := range actStoreSku {
+							storeSkuMap := model.ActStoreSkuMap{}
+							storeSkuMap.ID = v.MapID
+							dao.UpdateEntityLogically(db, storeSkuMap, map[string]interface{}{
+								model.FieldSyncStatus:  0,
+								model.FieldVendorActID: v.VendorActID,
+							}, ctx.GetUserName(), nil)
+						}
+					}
+				}
+			}
+			return nil, err
+		}, realVendorIDs)
+	tasksch.ManageTask(task).Run()
+	_, err = task.GetResult(0)
+	return err
+}
+
+func splitActStore(actStore []*model.ActStore2) (actStoreMap2Remove, actStoreMap2Add, actStoreMap2Update []*model.ActStore2) {
+	for _, v := range actStore {
+		if model.IsSyncStatusNeedDelete(v.SyncStatus) {
+			if !dao.IsVendorThingIDEmpty(v.VendorActID) {
+				actStoreMap2Remove = append(actStoreMap2Remove, v)
+			}
+		} else if model.IsSyncStatusNeedCreate(v.SyncStatus) {
+			actStoreMap2Add = append(actStoreMap2Add, v)
+		} else if model.IsSyncStatusNeedUpdate(v.SyncStatus) {
+			actStoreMap2Update = append(actStoreMap2Update, v)
+		}
+	}
+	return actStoreMap2Remove, actStoreMap2Add, actStoreMap2Update
+}

business/jxstore/act/act_test.go

@@ -0,0 +1,61 @@
+package act
+
+import (
+	"testing"
+
+	"git.rosy.net.cn/jx-callback/business/jxutils/jxcontext"
+	"git.rosy.net.cn/jx-callback/business/model/dao"
+	"git.rosy.net.cn/jx-callback/globals/testinit"
+
+	"git.rosy.net.cn/jx-callback/business/model"
+	"git.rosy.net.cn/jx-callback/globals"
+
+	_ "git.rosy.net.cn/jx-callback/business/partner/purchase/ebai"
+	_ "git.rosy.net.cn/jx-callback/business/partner/purchase/jd"
+	_ "git.rosy.net.cn/jx-callback/business/partner/purchase/mtwm"
+)
+
+func init() {
+	testinit.Init()
+}
+
+func TestInitDb(t *testing.T) {
+	dao.ExecuteSQL(dao.GetDB(), `
+	DROP TABLE IF EXISTS act,act_map, act_order_rule, act_store_map, act_store_sku, act_store_sku_map;
+	`)
+}
+
+func TestCreateAct(t *testing.T) {
+	actID, err := CreateAct(jxcontext.AdminCtx, &model.Act{
+		Name:            "测试活动2",
+		PricePercentage: 80,
+	}, []int{0, 1, 3}, nil, []*ActStoreSkuParam{
+		&ActStoreSkuParam{
+			StoreID: 100119,
+			SkuID:   30828,
+		},
+		&ActStoreSkuParam{
+			StoreID: 100119,
+			SkuID:   30827,
+		},
+		&ActStoreSkuParam{
+			StoreID: 100118,
+			SkuID:   30592,
+		},
+		&ActStoreSkuParam{
+			StoreID: 100118,
+			SkuID:   30565,
+		},
+	})
+	if err != nil {
+		t.Fatal(err)
+	}
+	globals.SugarLogger.Debug(actID)
+}
+
+func TestSyncAct(t *testing.T) {
+	err := SyncAct(jxcontext.AdminCtx, 1, nil, nil, nil)
+	if err != nil {
+		t.Fatal(err)
+	}
+}

business/model/act.go

@@ -0,0 +1,129 @@
+package model
+
+import "time"
+
+const (
+	ActSkuDirectDown = 1
+	ActSkuSecKill    = 2
+
+	ActOrderBegin               = 10
+	ActOrderMoneyOff            = 11
+	ActOrderMoneyOffCoupon      = 12
+	ActOrderReduceFreight       = 13
+	ActOrderReduceFreightCoupon = 14
+)
+
+type Act struct {
+	ModelIDCULD
+
+	Name            string    `orm:"size(64)" json:"name"`
+	Advertising     string    `orm:"size(255)" json:"advertising"`
+	Type            int       `json:"type"`
+	Status          int       `json:"status"`
+	LimitDevice     int       `json:"limitDevice"`
+	LimitPin        int       `json:"limitPin"`
+	LimitDaily      int       `json:"limitDaily"`
+	LimitCount      int       `json:"limitCount"`
+	Source          string    `orm:"size(255)" json:"source"`
+	CreateType      int       `json:"createType"`
+	PricePercentage int       `json:"pricePercentage"` // 单品级活动才有效
+	BeginAt         time.Time `orm:"type(datetime);index;null" json:"beginAt"`
+	EndAt           time.Time `orm:"type(datetime);index;null" json:"endAt"`
+}
+
+type ActMap struct {
+	ModelIDCULD
+
+	ActID    int `orm:"column(act_id)" json:"actID"`
+	VendorID int `orm:"column(vendor_id)" json:"vendorID"`
+
+	VendorActID string `orm:"column(vendor_act_id);size(48)" json:"vendorActID"`
+	SyncStatus  int    `orm:"default(2)" json:"syncStatus"`
+}
+
+type Act2 struct {
+	MapID int `orm:"column(map_id)"`
+
+	Act
+	VendorID int `orm:"column(vendor_id)" json:"vendorID"`
+
+	VendorActID string `orm:"column(vendor_act_id);size(48)" json:"vendorActID"`
+	SyncStatus  int    `orm:"default(2)" json:"syncStatus"`
+}
+
+type ActOrderRule struct {
+	ModelIDCULD
+
+	ActID       int   `orm:"column(act_id)" json:"actID"`
+	SalePrice   int64 `orm:"" json:"salePrice"`   // 满的价格
+	DeductPrice int64 `orm:"" json:"deductPrice"` // 减的价格
+}
+
+// type ActStore struct {
+// 	ModelIDCULD
+
+// 	ActID   int `orm:"column(act_id)" json:"actID"`
+// 	StoreID int `orm:"column(store_id)" json:"storeID"`
+// }
+
+type ActStoreMap struct {
+	ModelIDCULD
+
+	ActID    int `orm:"column(act_id)" json:"actID"`
+	StoreID  int `orm:"column(store_id)" json:"storeID"`
+	VendorID int `orm:"column(vendor_id)" json:"vendorID"`
+
+	VendorActID string `orm:"column(vendor_act_id);size(48)" json:"vendorActID"`
+	SyncStatus  int    `orm:"default(2)" json:"syncStatus"`
+}
+
+type ActStore2 struct {
+	MapID int `orm:"column(map_id)"`
+
+	ActStoreMap
+
+	VendorStoreID string `orm:"column(vendor_store_id)" json:"vendorStoreID"`
+}
+
+type ActStoreSku struct {
+	ModelIDCULD
+
+	ActID   int `orm:"column(act_id)" json:"actID"`
+	StoreID int `orm:"column(store_id)" json:"storeID"`
+	SkuID   int `orm:"column(sku_id)" json:"skuID"`
+
+	// LocalStatus  int // 这个状态是多个平台的
+	// RemoteStatus int // 这个状态是多个平台的
+	OriginalPrice   int64 `orm:"" json:"originalPrice"`   // 单品级活动用，创建活动时商品的原始京西价
+	PricePercentage int   `orm:"" json:"pricePercentage"` // 单品级活动用，SKU级的价格比例，非0覆盖Act中的PricePercentage
+	ActPrice        int64 `orm:"" json:"actPrice"`        // 单品级活动用，SKU级指定的价格，非0覆盖CustomPricePercentage与Act中的PricePercentage
+
+	Stock int `orm:"" json:"stock"` // 订单级活动用
+}
+
+type ActStoreSkuMap struct {
+	ModelIDCULD
+
+	ActID    int `orm:"column(act_id)" json:"actID"`
+	StoreID  int `orm:"column(store_id)" json:"storeID"`
+	SkuID    int `orm:"column(sku_id)" json:"skuID"`
+	VendorID int `orm:"column(vendor_id)" json:"vendorID"`
+
+	VendorActID    string `orm:"column(vendor_act_id);size(48)" json:"vendorActID"`
+	SyncStatus     int    `orm:"default(2)" json:"syncStatus"`
+	ActualActPrice int64  `orm:"" json:"actualActPrice"` // 单品级活动用，创建活动时商品的活动价格
+}
+
+type ActStoreSku2 struct {
+	MapID int `orm:"column(map_id)"`
+
+	ActStoreSku
+	VendorID int `orm:"column(vendor_id)" json:"vendorID"`
+
+	VendorActID    string `orm:"column(vendor_act_id);size(48)" json:"vendorActID"`
+	SyncStatus     int    `orm:"default(2)" json:"syncStatus"`
+	ActualActPrice int64  `orm:"" json:"actualActPrice"` // 单品级活动用，创建活动时商品的活动价格
+
+	VendorStoreID string `orm:"column(vendor_store_id)" json:"vendorStoreID"`
+	VendorSkuID   string `orm:"column(vendor_sku_id)" json:"vendorSkuID"`
+}

business/model/dao/act.go

@@ -0,0 +1,117 @@
+package dao
+
+import (
+	"git.rosy.net.cn/baseapi/utils"
+	"git.rosy.net.cn/jx-callback/business/model"
+)
+
+func GetActVendorInfo(db *DaoDB, actID int, vendorIDs []int) (actMap map[int]*model.Act2, err error) {
+	sql := `
+	SELECT t1.*,
+	t2.id map_id, t2.vendor_id, t2.vendor_act_id, t2.sync_status
+	FROM act t1
+	JOIN act_map t2 ON t2.act_id = t1.id AND t2.deleted_at = ?
+	WHERE t1.deleted_at = ? AND t1.id = ?
+	`
+	sqlParams := []interface{}{
+		utils.DefaultTimeValue,
+		utils.DefaultTimeValue,
+		actID,
+	}
+	if len(vendorIDs) > 0 {
+		sql += " AND t2.vendor_id IN (" + GenQuestionMarks(len(vendorIDs)) + ")"
+		sqlParams = append(sqlParams, vendorIDs)
+	}
+	var actList []*model.Act2
+	if err = GetRows(db, &actList, sql, sqlParams...); err == nil {
+		actMap = make(map[int]*model.Act2)
+		for _, v := range actList {
+			actMap[v.VendorID] = v
+		}
+	}
+	return actMap, err
+}
+
+func GetActStoreVendorInfo(db *DaoDB, actID int, vendorIDs, storeIDs []int) (actStoreMap map[int][]*model.ActStore2, err error) {
+	sql := `
+	SELECT t1.*,
+	t1.id map_id,
+	t2.vendor_store_id
+	FROM act_store_map t1
+	JOIN store_map t2 ON t2.store_id = t1.store_id AND t2.vendor_id = t1.vendor_id AND t2.deleted_at = ?
+	WHERE t1.deleted_at = ? AND t1.act_id = ?
+	`
+	sqlParams := []interface{}{
+		utils.DefaultTimeValue,
+		utils.DefaultTimeValue,
+		actID,
+	}
+	if len(vendorIDs) > 0 {
+		sql += " AND t1.vendor_id IN (" + GenQuestionMarks(len(vendorIDs)) + ")"
+		sqlParams = append(sqlParams, vendorIDs)
+	}
+	if len(storeIDs) > 0 {
+		sql += " AND t1.store_id IN (" + GenQuestionMarks(len(storeIDs)) + ")"
+		sqlParams = append(sqlParams, storeIDs)
+	}
+	var actStoreList []*model.ActStore2
+	if err = GetRows(db, &actStoreList, sql, sqlParams...); err == nil {
+		actStoreMap = make(map[int][]*model.ActStore2)
+		for _, v := range actStoreList {
+			actStoreMap[v.VendorID] = append(actStoreMap[v.VendorID], v)
+		}
+	}
+	return actStoreMap, err
+}
+
+func GetActStoreSkuVendorInfo(db *DaoDB, actID int, vendorIDs, storeIDs, skuIDs []int) (actStoreSkuMap map[int][]*model.ActStoreSku2, err error) {
+	sql := `
+	SELECT t1.*,
+	t2.id map_id, t2.vendor_id, t2.vendor_act_id, t2.sync_status,
+	t3.vendor_store_id,
+	CASE t2.vendor_id
+		WHEN 0 THEN
+			t4.jd_id
+		WHEN 1 THEN
+			t5.mtwm_id
+		WHEN 3 THEN
+			t5.ebai_id
+		ELSE
+			''
+	END vendor_sku_id
+	FROM act_store_sku t1
+	JOIN act_store_sku_map t2 ON t2.act_id = t1.act_id AND t2.sku_id = t1.sku_id AND t2.store_id = t1.store_id AND t2.deleted_at = ?
+	JOIN store_map t3 ON t3.store_id = t1.store_id AND t3.vendor_id = t2.vendor_id AND t3.deleted_at = ?
+	JOIN sku t4 ON t4.id = t1.sku_id AND t4.deleted_at = ?
+	JOIN store_sku_bind t5 ON t5.sku_id = t1.sku_id AND t5.store_id = t1.store_id AND t5.deleted_at = ?
+	WHERE t1.deleted_at = ? AND t1.act_id = ?
+	`
+	sqlParams := []interface{}{
+		utils.DefaultTimeValue,
+		utils.DefaultTimeValue,
+		utils.DefaultTimeValue,
+		utils.DefaultTimeValue,
+		utils.DefaultTimeValue,
+		actID,
+	}
+	if len(vendorIDs) > 0 {
+		sql += " AND t2.vendor_id IN (" + GenQuestionMarks(len(vendorIDs)) + ")"
+		sqlParams = append(sqlParams, vendorIDs)
+	}
+	if len(storeIDs) > 0 {
+		sql += " AND t1.store_id IN (" + GenQuestionMarks(len(storeIDs)) + ")"
+		sqlParams = append(sqlParams, storeIDs)
+	}
+	if len(skuIDs) > 0 {
+		sql += " AND t1.sku_id IN (" + GenQuestionMarks(len(skuIDs)) + ")"
+		sqlParams = append(sqlParams, skuIDs)
+	}
+	var actStoreSkuList []*model.ActStoreSku2
+	if err = GetRows(db, &actStoreSkuList, sql, sqlParams...); err == nil {
+		actStoreSkuMap = make(map[int][]*model.ActStoreSku2)
+		for _, v := range actStoreSkuList {
+			actStoreSkuMap[v.VendorID] = append(actStoreSkuMap[v.VendorID], v)
+		}
+	}
+	return actStoreSkuMap, err
+}

business/partner/partner.go

@@ -172,6 +172,7 @@ type IStoreManager interface {
 // 所有非以Sync，Refresh开头的函数不用自己清理sync_status标记（VendorSync统一处理）
 
 type IPurchasePlatformHandler interface {
+	// IPurchasePlatformPromotionHandler
 	GetVendorID() int
 
 	GetStatusFromVendorStatus(vendorStatus string) int

business/partner/partner_act.go

@@ -0,0 +1,23 @@
+package partner
+
+import (
+	"git.rosy.net.cn/jx-callback/business/jxutils/jxcontext"
+	"git.rosy.net.cn/jx-callback/business/jxutils/tasksch"
+	"git.rosy.net.cn/jx-callback/business/model"
+)
+
+type IPurchasePlatformPromotionHandler interface {
+	// 如果是单品级活动，actOrderRules为空
+	// 如果是订单级活动，actStoreSku可以为空（表示不限制SKU）
+	CreateAct(ctx *jxcontext.Context, parentTask tasksch.ITask, act *model.Act2, actOrderRules []*model.ActOrderRule, actStoreMap []*model.ActStore2, actStoreSku []*model.ActStoreSku2) (err error)
+	UpdateAct(ctx *jxcontext.Context, parentTask tasksch.ITask, act *model.Act2, actOrderRules []*model.ActOrderRule, actStoreMap2Remove, actStoreMap2Add, actStoreMap2Update []*model.ActStore2, actStoreSku []*model.ActStoreSku2) (err error)
+	DeleteAct(ctx *jxcontext.Context, parentTask tasksch.ITask, act *model.Act2, actStoreMap []*model.ActStore2, actStoreSku []*model.ActStoreSku2) (err error)
+}
+
+func ActStoreSku2Map(actStoreSku []*model.ActStoreSku2) (actStoreSkuMap map[int][]*model.ActStoreSku2) {
+	actStoreSkuMap = make(map[int][]*model.ActStoreSku2)
+	for _, storeSku := range actStoreSku {
+		actStoreSkuMap[storeSku.StoreID] = append(actStoreSkuMap[storeSku.StoreID], storeSku)
+	}
+	return actStoreSkuMap
+}

business/partner/purchase/ebai/act.go

@@ -0,0 +1,184 @@
+package ebai
+
+import (
+	"git.rosy.net.cn/baseapi/platformapi/ebaiapi"
+	"git.rosy.net.cn/baseapi/utils"
+	"git.rosy.net.cn/jx-callback/business/jxutils"
+	"git.rosy.net.cn/jx-callback/business/jxutils/jxcontext"
+	"git.rosy.net.cn/jx-callback/business/jxutils/tasksch"
+	"git.rosy.net.cn/jx-callback/business/model"
+	"git.rosy.net.cn/jx-callback/business/partner"
+	"git.rosy.net.cn/jx-callback/globals"
+	"git.rosy.net.cn/jx-callback/globals/api"
+)
+
+func actType2Ebai(actType int) int {
+	if actType < model.ActOrderBegin {
+		return ebaiapi.ActivityTypeDirectDown
+	}
+	return ebaiapi.ActivityTypeFullDiscount
+}
+
+func actOrderRules2Ebai(actOrderRules []*model.ActOrderRule) (ebaiRules []*ebaiapi.ActivityRule) {
+	for _, v := range actOrderRules {
+		ebaiRules = append(ebaiRules, &ebaiapi.ActivityRule{
+			Accords: int(jxutils.IntPrice2Standard(v.SalePrice)),
+			Sale:    int(jxutils.IntPrice2Standard(v.DeductPrice)),
+		})
+	}
+	return ebaiRules
+}
+
+func actStoreSu2Ebai4Add(oneStoreActSku []*model.ActStoreSku2) (skus []*ebaiapi.ActivitySkuInfo4Add) {
+	for _, v := range oneStoreActSku {
+		if model.IsSyncStatusNeedCreate(v.SyncStatus) {
+			skus = append(skus, &ebaiapi.ActivitySkuInfo4Add{
+				SkuID:        v.VendorSkuID,
+				SpecialPrice: v.ActPrice,
+			})
+		}
+	}
+	return skus
+}
+
+func actStoreSu2Ebai4Update(oneStoreActSku []*model.ActStoreSku2) (skus []*ebaiapi.ActivitySkuInfo4Update) {
+	for _, v := range oneStoreActSku {
+		if model.IsSyncStatusNeedUpdate(v.SyncStatus) {
+			skus = append(skus, &ebaiapi.ActivitySkuInfo4Update{
+				ShopID:       utils.Int2Str(v.StoreID),
+				SkuID:        v.VendorSkuID,
+				SpecialPrice: v.ActPrice,
+			})
+		}
+	}
+	return skus
+}
+
+func actStoreSu2Ebai4Delete(oneStoreActSku []*model.ActStoreSku2) (skus []string) {
+	for _, v := range oneStoreActSku {
+		if model.IsSyncStatusNeedDelete(v.SyncStatus) {
+			skus = append(skus, v.VendorSkuID)
+		}
+	}
+	return skus
+}
+
+func act2EbaiActivity(act *model.Act2, actOrderRules []*model.ActOrderRule) (activity *ebaiapi.ActivityInfo) {
+	activity = &ebaiapi.ActivityInfo{
+		ActivityName:     act.Name,
+		ActivityType:     actType2Ebai(act.Type),
+		StartTime:        act.BeginAt.Unix(),
+		EndTime:          act.EndAt.Unix(),
+		ActivityDesc:     act.Advertising,
+		ShowCategory:     act.Name,
+		PromotionSkuDesc: act.Name,
+		Rule:             actOrderRules2Ebai(actOrderRules),
+	}
+	return activity
+}
+
+func createOneShopAct(shopID string, activity *ebaiapi.ActivityInfo, oneStoreActSku []*model.ActStoreSku2) (ebaiActIDStr string, err error) {
+	if globals.EnableEbaiStoreWrite {
+		ebaiActID, err := api.EbaiAPI.ActivityCreate(shopID, 0, 0, activity)
+		if err == nil {
+			ebaiActIDStr = utils.Int64ToStr(ebaiActID)
+			_, err = ActivitySkuAddBatch(ebaiActID, shopID, 0, activity.ActivityType, actStoreSu2Ebai4Add(oneStoreActSku), false)
+		}
+	} else {
+		ebaiActIDStr = utils.Int64ToStr(jxutils.GenFakeID())
+	}
+	return ebaiActIDStr, err
+}
+
+func ActivitySkuAddBatch(activityID int64, shopID string, baiduShopID int64, activityType int, skuList []*ebaiapi.ActivitySkuInfo4Add, isSkuIDCustom bool) (successIDs []string, err error) {
+	return api.EbaiAPI.ActivitySkuAddBatch(activityID, shopID, baiduShopID, activityType, skuList, isSkuIDCustom)
+}
+
+func ActivitySkuDeleteBatch(activityID int64, shopID string, baiduShopID int64, skuIDs []string, isSkuIDCustom bool) (successIDs []string, err error) {
+	return api.EbaiAPI.ActivitySkuDeleteBatch(activityID, shopID, baiduShopID, skuIDs, isSkuIDCustom)
+}
+
+func ActivitySkuUpdateBatch(activityID int64, actSkuInfoList []*ebaiapi.ActivitySkuInfo4Update) (faildInfoList []string, err error) {
+	return api.EbaiAPI.ActivitySkuUpdateBatch(activityID, actSkuInfoList)
+}
+
+func (c *PurchaseHandler) CreateAct(ctx *jxcontext.Context, parentTask tasksch.ITask, act *model.Act2, actOrderRules []*model.ActOrderRule, actStoreMap []*model.ActStore2, actStoreSku []*model.ActStoreSku2) (err error) {
+	activity := act2EbaiActivity(act, actOrderRules)
+	if act.Type < model.ActOrderBegin {
+		actStoreSkuMap := partner.ActStoreSku2Map(actStoreSku)
+		task := tasksch.NewParallelTask("ebai CreateAct", nil, ctx,
+			func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
+				store := batchItemList[0].(*model.ActStore2)
+				store.VendorActID, err = createOneShopAct(utils.Int2Str(store.StoreID), activity, actStoreSkuMap[store.StoreID])
+				return nil, err
+			}, actStoreMap)
+		tasksch.HandleTask(task, parentTask, true).Run()
+		_, err = task.GetResult(0)
+	} else {
+
+	}
+	return err
+}
+
+func (c *PurchaseHandler) UpdateAct(ctx *jxcontext.Context, parentTask tasksch.ITask, act *model.Act2, actOrderRules []*model.ActOrderRule, actStoreMap2Remove, actStoreMap2Add, actStoreMap2Update []*model.ActStore2, actStoreSku []*model.ActStoreSku2) (err error) {
+	if act.Type < model.ActOrderBegin {
+		actStoreSkuMap := partner.ActStoreSku2Map(actStoreSku)
+		if len(actStoreMap2Remove) > 0 {
+			if err = c.DeleteAct(ctx, parentTask, act, actStoreMap2Remove, nil); err != nil {
+				return err
+			}
+			for _, v := range actStoreMap2Remove {
+				delete(actStoreSkuMap, v.StoreID)
+			}
+		}
+		if len(actStoreMap2Add) > 0 {
+			if err = c.CreateAct(ctx, parentTask, act, actOrderRules, actStoreMap2Add, actStoreSku); err != nil {
+				return err
+			}
+			for _, v := range actStoreMap2Add {
+				delete(actStoreSkuMap, v.StoreID)
+			}
+		}
+		task := tasksch.NewParallelTask("ebai UpdateAct", nil, ctx,
+			func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
+				v := batchItemList[0].(*model.ActStore2)
+				if storeSkus := actStoreSkuMap[v.StoreID]; storeSkus != nil {
+					if list := actStoreSu2Ebai4Delete(storeSkus); len(list) > 0 {
+						if _, err = ActivitySkuDeleteBatch(utils.Str2Int64(v.VendorActID), utils.Int2Str(v.StoreID), 0, list, false); err != nil {
+							return nil, err
+						}
+					}
+					if list := actStoreSu2Ebai4Add(storeSkus); len(list) > 0 {
+						if _, err = ActivitySkuAddBatch(utils.Str2Int64(v.VendorActID), utils.Int2Str(v.StoreID), 0, actType2Ebai(act.Type), list, false); err != nil {
+							return nil, err
+						}
+					}
+					if list := actStoreSu2Ebai4Update(storeSkus); len(list) > 0 {
+						if _, err = ActivitySkuUpdateBatch(utils.Str2Int64(v.VendorActID), list); err != nil {
+							return nil, err
+						}
+					}
+				}
+				return nil, err
+			}, actStoreMap2Update)
+		tasksch.HandleTask(task, parentTask, true).Run()
+		_, err = task.GetResult(0)
+	} else {
+
+	}
+	return err
+}
+
+func (c *PurchaseHandler) DeleteAct(ctx *jxcontext.Context, parentTask tasksch.ITask, act *model.Act2, actStoreMap []*model.ActStore2, actStoreSku []*model.ActStoreSku2) (err error) {
+	if act.Type < model.ActOrderBegin {
+		task := tasksch.NewParallelTask("ebai DeleteAct", nil, ctx,
+			func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
+				v := batchItemList[0].(*model.ActStore2)
+				err = api.EbaiAPI.ActivityDisable(utils.Str2Int64(v.VendorActID), utils.Int2Str(v.StoreID), 0, 0)
+				return nil, err
+			}, actStoreMap)
+		tasksch.HandleTask(task, parentTask, true).Run()
+		_, err = task.GetResult(0)
+	}
+	return err
+}

business/partner/purchase/elm/act.go

@@ -0,0 +1,19 @@
+package elm
+
+import (
+	"git.rosy.net.cn/jx-callback/business/jxutils/jxcontext"
+	"git.rosy.net.cn/jx-callback/business/jxutils/tasksch"
+	"git.rosy.net.cn/jx-callback/business/model"
+)
+
+func (c *PurchaseHandler) CreateAct(ctx *jxcontext.Context, parentTask tasksch.ITask, act *model.Act2, actOrderRules []*model.ActOrderRule, actStoreMap []*model.ActStore2, actStoreSku []*model.ActStoreSku2) (err error) {
+	return err
+}
+
+func (c *PurchaseHandler) UpdateAct(ctx *jxcontext.Context, parentTask tasksch.ITask, act *model.Act2, actOrderRules []*model.ActOrderRule, actStoreMap2Remove, actStoreMap2Add, actStoreMap2Update []*model.ActStore2, actStoreSku []*model.ActStoreSku2) (err error) {
+	return err
+}
+
+func (c *PurchaseHandler) DeleteAct(ctx *jxcontext.Context, parentTask tasksch.ITask, act *model.Act2, actStoreMap []*model.ActStore2, actStoreSku []*model.ActStoreSku2) (err error) {
+	return err
+}

business/partner/purchase/jd/act.go

@@ -0,0 +1,183 @@
+package jd
+
+import (
+	"time"
+
+	"git.rosy.net.cn/jx-callback/business/jxutils"
+
+	"git.rosy.net.cn/jx-callback/globals"
+	"git.rosy.net.cn/jx-callback/globals/api"
+
+	"git.rosy.net.cn/baseapi/platformapi/jdapi"
+	"git.rosy.net.cn/baseapi/utils"
+	"git.rosy.net.cn/jx-callback/business/jxutils/jxcontext"
+	"git.rosy.net.cn/jx-callback/business/jxutils/tasksch"
+	"git.rosy.net.cn/jx-callback/business/model"
+)
+
+func CreatePromotionInfos(promotionType int, name string, beginDate, endDate time.Time, outInfoId, advertising, traceId string) (infoId int64, err error) {
+	if globals.EnableJdStoreWrite {
+		if promotionType == model.ActSkuDirectDown {
+			return api.JdAPI.CreatePromotionInfosSingle(name, beginDate, endDate, outInfoId, advertising, traceId)
+		} else {
+			return api.JdAPI.CreatePromotionInfosLimitTime(name, beginDate, endDate, outInfoId, advertising, traceId)
+		}
+	} else {
+		infoId = jxutils.GenFakeID()
+	}
+	return infoId, err
+}
+
+func CreatePromotionRules(promotionType int, infoId int64, outInfoId string, limitDevice, limitPin, limitCount, limitDaily int, traceId string) (err error) {
+	if globals.EnableJdStoreWrite {
+		if promotionType == model.ActSkuDirectDown {
+			return api.JdAPI.CreatePromotionRulesSingle(infoId, outInfoId, limitDevice, limitPin, limitCount, limitDaily, traceId)
+		} else {
+			return api.JdAPI.CreatePromotionRulesLimitTime(infoId, outInfoId, limitDevice, limitPin, limitCount, limitDaily, traceId)
+		}
+	}
+	return err
+}
+
+func CreatePromotionSku(promotionType int, infoId int64, outInfoId string, skus []*jdapi.PromotionSku, traceId string) (skusResult []*jdapi.PromotionSku, err error) {
+	if globals.EnableJdStoreWrite {
+		if promotionType == model.ActSkuDirectDown {
+			return api.JdAPI.CreatePromotionSkuSingle(infoId, outInfoId, skus, traceId)
+		} else {
+			return api.JdAPI.CreatePromotionSkuLimitTime(infoId, outInfoId, skus, traceId)
+		}
+	}
+	return skusResult, err
+}
+
+func CancelPromotionSku(promotionType int, infoId int64, outInfoId string, skus []*jdapi.PromotionSku, traceId string) (err error) {
+	if globals.EnableJdStoreWrite {
+		if promotionType == model.ActSkuDirectDown {
+			return api.JdAPI.CancelPromotionSkuSingle(infoId, outInfoId, skus, traceId)
+		} else {
+			return api.JdAPI.CancelPromotionSkuLimitTime(infoId, outInfoId, skus, traceId)
+		}
+	}
+	return err
+}
+
+func ConfirmPromotion(promotionType int, infoId int64, outInfoId, traceId string) (err error) {
+	if globals.EnableJdStoreWrite {
+		if promotionType == model.ActSkuDirectDown {
+			return api.JdAPI.ConfirmPromotionSingle(infoId, outInfoId, traceId)
+		} else {
+			return api.JdAPI.ConfirmPromotionLimitTime(infoId, outInfoId, traceId)
+		}
+	}
+	return err
+}
+
+func CancelPromotion(promotionType int, infoId int64, outInfoId, traceId string) (err error) {
+	if globals.EnableJdStoreWrite {
+		if promotionType == model.ActSkuDirectDown {
+			return api.JdAPI.CancelPromotionSingle(infoId, outInfoId, traceId)
+		} else {
+			return api.JdAPI.CancelPromotionLimitTime(infoId, outInfoId, traceId)
+		}
+	}
+	return err
+}
+
+func AdjustPromotionTime(promotionType int, infoId int64, outInfoId string, endDate time.Time, traceId string) (err error) {
+	if globals.EnableJdStoreWrite {
+		if promotionType == model.ActSkuDirectDown {
+			return api.JdAPI.AdjustPromotionTimeSingle(infoId, outInfoId, endDate, traceId)
+		} else {
+			return api.JdAPI.AdjustPromotionTimeLimitTime(infoId, outInfoId, endDate, traceId)
+		}
+	}
+	return err
+}
+
+func AdjustPromotionSku(promotionType int, infoId int64, outInfoId string, skus []*jdapi.PromotionSku, traceId string) (skusResult []*jdapi.PromotionSku, err error) {
+	if globals.EnableJdStoreWrite {
+		if promotionType == model.ActSkuDirectDown {
+			return api.JdAPI.AdjustPromotionSkuSingle(infoId, outInfoId, skus, traceId)
+		} else {
+			return api.JdAPI.AdjustPromotionSkuLimitTime(infoId, outInfoId, skus, traceId)
+		}
+	}
+	return skusResult, err
+}
+
+func getTraceID(ctx *jxcontext.Context) (traceID string) {
+	traceID = ctx.GetUserName() + utils.GetUUID()
+	return traceID
+}
+
+func storeSku2Jd(actStoreSku []*model.ActStoreSku2, handler func(syncStatus int) bool) (jdActStoreSku []*jdapi.PromotionSku) {
+	for _, v := range actStoreSku {
+		if handler(v.SyncStatus) {
+			jdActStoreSku = append(jdActStoreSku, &jdapi.PromotionSku{
+				StationNo:      utils.Str2Int64(v.VendorStoreID),
+				SkuID:          utils.Str2Int64(v.VendorSkuID),
+				PromotionPrice: v.ActPrice,
+				// LimitSkuCount:0,
+			})
+		}
+	}
+	return jdActStoreSku
+}
+
+func (c *PurchaseHandler) CreateAct(ctx *jxcontext.Context, parentTask tasksch.ITask, act *model.Act2, actOrderRules []*model.ActOrderRule, actStoreMap []*model.ActStore2, actStoreSku []*model.ActStoreSku2) (err error) {
+	traceID := getTraceID(ctx)
+	if act.Type < model.ActOrderBegin {
+		outInfoID := utils.Int2Str(act.ID)
+		infoID, err2 := CreatePromotionInfos(act.Type, act.Name, act.BeginAt, act.EndAt, outInfoID, act.Advertising, traceID)
+		if err = err2; err == nil {
+			act.VendorActID = utils.Int64ToStr(infoID)
+			if err = CreatePromotionRules(act.Type, infoID, "", act.LimitDevice, act.LimitPin, act.LimitCount, act.LimitDaily, traceID); err == nil {
+				if _, err = CreatePromotionSku(act.Type, infoID, "", storeSku2Jd(actStoreSku, model.IsSyncStatusNeedCreate), traceID); err == nil {
+					err = ConfirmPromotion(act.Type, infoID, "", traceID)
+				}
+			}
+		}
+	} else {
+
+	}
+	return err
+}
+
+func (c *PurchaseHandler) UpdateAct(ctx *jxcontext.Context, parentTask tasksch.ITask, act *model.Act2, actOrderRules []*model.ActOrderRule, actStoreMap2Remove, actStoreMap2Add, actStoreMap2Update []*model.ActStore2, actStoreSku []*model.ActStoreSku2) (err error) {
+	traceID := getTraceID(ctx)
+	if act.Type < model.ActOrderBegin {
+		outInfoID := utils.Int2Str(act.ID)
+		if !utils.IsTimeZero(act.EndAt) {
+			if err = AdjustPromotionTime(act.Type, 0, outInfoID, act.EndAt, traceID); err != nil {
+				return err
+			}
+		}
+		if toBeDeleted := storeSku2Jd(actStoreSku, model.IsSyncStatusNeedDelete); len(toBeDeleted) > 0 {
+			if err = CancelPromotionSku(act.Type, 0, outInfoID, toBeDeleted, traceID); err != nil {
+				return err
+			}
+		}
+		// if toBeAdded := storeSku2Jd(actStoreSku, model.IsSyncStatusNeedDelete); len(toBeAdded) > 0 {
+		// 	if _, err = CreatePromotionSku(act.Type, 0, outInfoID, toBeAdded, traceID); err != nil {
+		// 		return err
+		// 	}
+		// }
+		// if toBeUpdated := storeSku2Jd(actStoreSku, model.IsSyncStatusNeedDelete); len(toBeUpdated) > 0 {
+		// 	if _, err = AdjustPromotionSku(act.Type, 0, outInfoID, toBeUpdated, traceID); err != nil {
+		// 		return err
+		// 	}
+		// }
+	} else {
+
+	}
+	return err
+}
+
+func (c *PurchaseHandler) DeleteAct(ctx *jxcontext.Context, parentTask tasksch.ITask, act *model.Act2, actStoreMap []*model.ActStore2, actStoreSku []*model.ActStoreSku2) (err error) {
+	traceID := getTraceID(ctx)
+	if act.Type < model.ActOrderBegin {
+		outInfoID := utils.Int2Str(act.ID)
+		err = CancelPromotion(act.Type, 0, outInfoID, traceID)
+	}
+	return err
+}

business/partner/purchase/mtwm/act.go

@@ -0,0 +1,167 @@
+package mtwm
+
+import (
+	"git.rosy.net.cn/baseapi/platformapi/mtwmapi"
+	"git.rosy.net.cn/baseapi/utils"
+	"git.rosy.net.cn/jx-callback/business/jxutils"
+	"git.rosy.net.cn/jx-callback/business/jxutils/jxcontext"
+	"git.rosy.net.cn/jx-callback/business/jxutils/tasksch"
+	"git.rosy.net.cn/jx-callback/business/model"
+	"git.rosy.net.cn/jx-callback/business/partner"
+	"git.rosy.net.cn/jx-callback/globals"
+	"git.rosy.net.cn/jx-callback/globals/api"
+)
+
+func actOrderRules2Mtwm(actOrderRules []*model.ActOrderRule) (actDetails []*mtwmapi.FullDiscountActDetail) {
+	for _, v := range actOrderRules {
+		actDetails = append(actDetails, &mtwmapi.FullDiscountActDetail{
+			OriginalPrice: jxutils.IntPrice2Standard(v.SalePrice),
+			ActPrice:      jxutils.IntPrice2Standard(v.DeductPrice),
+		})
+	}
+	return actDetails
+}
+
+func storeSku2ActData(act *model.Act2, actStoreSku []*model.ActStoreSku2, handler func(int) bool) (actData []*mtwmapi.RetailDiscountActData) {
+	for _, v := range actStoreSku {
+		if handler == nil || handler(v.SyncStatus) {
+			actData = append(actData, &mtwmapi.RetailDiscountActData{
+				AppFoodCode: utils.Int2Str(v.SkuID),
+				// UserType:    0,
+				StartTime:  act.BeginAt.Unix(),
+				EndTime:    act.EndAt.Unix(),
+				OrderLimit: act.LimitCount,
+				DayLimit:   act.LimitDaily,
+				// Period:     "",
+				// WeeksTime: "",
+				SettingType: mtwmapi.SettingTypeAsPrice,
+				ActPrice:    jxutils.IntPrice2Standard(v.ActPrice),
+				// DiscountCoefficient: 0,
+				Sequence: int(v.ActPrice),
+				ItemID:   utils.Str2Int64WithDefault(v.VendorActID, 0),
+			})
+		}
+	}
+	return actData
+}
+
+func storeSku2ActData4Delete(actStoreSku []*model.ActStoreSku2, handler func(int) bool) (actIDList []string) {
+	for _, v := range actStoreSku {
+		if handler == nil || handler(v.SyncStatus) {
+			if v.VendorActID != "" {
+				actIDList = append(actIDList, v.VendorActID)
+			}
+		}
+	}
+	return actIDList
+}
+
+func isCreateOrUpdate(syncStatus int) bool {
+	return model.IsSyncStatusNeedCreate(syncStatus) || model.IsSyncStatusNeedUpdate(syncStatus)
+}
+
+func createOneShopAct(act *model.Act2, storeMap *model.ActStore2, actStoreSku []*model.ActStoreSku2) (err error) {
+	actData := storeSku2ActData(act, actStoreSku, isCreateOrUpdate)
+	if len(actData) > 0 {
+		if globals.EnableMtwmStoreWrite {
+			actResult, err2 := api.MtwmAPI.RetailDiscountBatchSave(storeMap.VendorStoreID, actData)
+			if err = err2; err != nil {
+				return err
+			}
+			actResultMap := make(map[string]*mtwmapi.RetailDiscountActResult)
+			for _, v := range actResult {
+				actResultMap[v.AppFoodCode] = v
+			}
+			for _, v := range actStoreSku {
+				if result := actResultMap[utils.Int2Str(v.SkuID)]; result != nil {
+					v.VendorActID = utils.Int64ToStr(result.ActID)
+				}
+			}
+		} else {
+			for _, v := range actStoreSku {
+				v.VendorActID = utils.Int64ToStr(jxutils.GenFakeID())
+			}
+		}
+	}
+	return err
+}
+
+func (c *PurchaseHandler) CreateAct(ctx *jxcontext.Context, parentTask tasksch.ITask, act *model.Act2, actOrderRules []*model.ActOrderRule, actStoreMap []*model.ActStore2, actStoreSku []*model.ActStoreSku2) (err error) {
+	globals.SugarLogger.Debugf("mtwm CreateAct actID:%d", act.ID)
+	if act.Type < model.ActOrderBegin {
+		actStoreSkuMap := partner.ActStoreSku2Map(actStoreSku)
+		task := tasksch.NewParallelTask("mtwm CreateAct", nil, ctx,
+			func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
+				store := batchItemList[0].(*model.ActStore2)
+				err = createOneShopAct(act, store, actStoreSkuMap[store.StoreID])
+				return nil, err
+			}, actStoreMap)
+		tasksch.HandleTask(task, parentTask, true).Run()
+		_, err = task.GetResult(0)
+	} else {
+
+	}
+	return err
+}
+
+func (c *PurchaseHandler) UpdateAct(ctx *jxcontext.Context, parentTask tasksch.ITask, act *model.Act2, actOrderRules []*model.ActOrderRule, actStoreMap2Remove, actStoreMap2Add, actStoreMap2Update []*model.ActStore2, actStoreSku []*model.ActStoreSku2) (err error) {
+	if act.Type < model.ActOrderBegin {
+		actStoreSkuMap := partner.ActStoreSku2Map(actStoreSku)
+		if len(actStoreMap2Remove) > 0 {
+			if err = c.DeleteAct(ctx, parentTask, act, actStoreMap2Remove, nil); err != nil {
+				return err
+			}
+			for _, v := range actStoreMap2Remove {
+				delete(actStoreSkuMap, v.StoreID)
+			}
+		}
+		if len(actStoreMap2Add) > 0 {
+			if err = c.CreateAct(ctx, parentTask, act, actOrderRules, actStoreMap2Add, actStoreSku); err != nil {
+				return err
+			}
+			for _, v := range actStoreMap2Add {
+				delete(actStoreSkuMap, v.StoreID)
+			}
+		}
+		task := tasksch.NewParallelTask("mtwm UpdateAct", nil, ctx,
+			func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
+				v := batchItemList[0].(*model.ActStore2)
+				if storeSkus := actStoreSkuMap[v.StoreID]; storeSkus != nil {
+					if list := storeSku2ActData4Delete(storeSkus, model.IsSyncStatusNeedDelete); len(list) > 0 {
+						if err = api.MtwmAPI.RetailDiscountDelete(v.VendorStoreID, list); err != nil {
+							return nil, err
+						}
+					}
+					if err = createOneShopAct(act, v, actStoreSkuMap[v.StoreID]); err != nil {
+						return nil, err
+					}
+				}
+				return nil, err
+			}, actStoreMap2Update)
+		tasksch.HandleTask(task, parentTask, true).Run()
+		_, err = task.GetResult(0)
+	} else {
+
+	}
+	return err
+}
+
+func (c *PurchaseHandler) DeleteAct(ctx *jxcontext.Context, parentTask tasksch.ITask, act *model.Act2, actStoreMap []*model.ActStore2, actStoreSku []*model.ActStoreSku2) (err error) {
+	if act.Type < model.ActOrderBegin {
+		actStoreSkuMap := partner.ActStoreSku2Map(actStoreSku)
+		task := tasksch.NewParallelTask("mtwm DeleteAct", nil, ctx,
+			func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
+				v := batchItemList[0].(*model.ActStore2)
+				actIDList := storeSku2ActData4Delete(actStoreSkuMap[v.StoreID], nil)
+				if len(actIDList) > 0 {
+					err = api.MtwmAPI.RetailDiscountDelete(v.VendorStoreID, actIDList)
+				}
+				return nil, err
+			}, actStoreMap)
+		tasksch.HandleTask(task, parentTask, true).Run()
+		_, err = task.GetResult(0)
+	} else {
+
+	}
+	return err
+}

business/partner/purchase/weimob/wsc/act.go

@@ -0,0 +1,19 @@
+package wsc
+
+import (
+	"git.rosy.net.cn/jx-callback/business/jxutils/jxcontext"
+	"git.rosy.net.cn/jx-callback/business/jxutils/tasksch"
+	"git.rosy.net.cn/jx-callback/business/model"
+)
+
+func (c *PurchaseHandler) CreateAct(ctx *jxcontext.Context, parentTask tasksch.ITask, act *model.Act2, actOrderRules []*model.ActOrderRule, actStoreMap []*model.ActStore2, actStoreSku []*model.ActStoreSku2) (err error) {
+	return err
+}
+
+func (c *PurchaseHandler) UpdateAct(ctx *jxcontext.Context, parentTask tasksch.ITask, act *model.Act2, actOrderRules []*model.ActOrderRule, actStoreMap2Remove, actStoreMap2Add, actStoreMap2Update []*model.ActStore2, actStoreSku []*model.ActStoreSku2) (err error) {
+	return err
+}
+
+func (c *PurchaseHandler) DeleteAct(ctx *jxcontext.Context, parentTask tasksch.ITask, act *model.Act2, actStoreMap []*model.ActStore2, actStoreSku []*model.ActStoreSku2) (err error) {
+	return err
+}

globals/beegodb/beegodb.go

@@ -45,6 +45,8 @@ func Init() {
 
 	// 如下语句建表时要出错（INDEX名字太长了），暂时放一下，必须放最后一句
 	orm.RegisterModel(&model.OrderFinancial{}, &model.AfsOrder{}, &model.OrderDiscountFinancial{}, &model.OrderSkuFinancial{})
+	// orm.RegisterModel(&model.Act{}, &model.ActOrderRule{}, &model.ActStoreSku{})
+	// orm.RegisterModel(&model.ActMap{}, &model.ActStoreMap{}, &model.ActStoreSkuMap{})
 	// create table
 	orm.RunSyncdb("default", false, true)
 }