liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

- act.SyncAct中，当前逻辑要求传入活动的全部SKU信息（以便低层做一些判断，比如全部删除时要取消，所以暂时删除storeIDs与skuIDs这两个参数

Browse Source
This commit is contained in:
gazebo
2019-08-19 18:58:08 +08:00
parent 9c825058c8
commit 3b38645c71
2 changed files with 11 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
business/jxstore/act/act.go
View File

@@ -409,7 +409,7 @@ func CreateAct(ctx *jxcontext.Context, act *model.Act, vendorIDs []int, actRules
} }
dao.Commit(db) dao.Commit(db)
hint, err = SyncAct(ctx, nil, act.ID, nil, nil, nil, isAsync) hint, err = SyncAct(ctx, nil, act.ID, nil, isAsync)
if !isAsync { if !isAsync {
hint = utils.Int2Str(act.ID) hint = utils.Int2Str(act.ID)
} }
@@ -564,7 +564,7 @@ func CancelAct(ctx *jxcontext.Context, actID int) (err error) {
if err = DeleteActStoreSkuBind(ctx, db, actID, nil); err != nil { if err = DeleteActStoreSkuBind(ctx, db, actID, nil); err != nil {
return err return err
} }
_, err = SyncAct(ctx, nil, actID, nil, nil, nil, false) _, err = SyncAct(ctx, nil, actID, nil, false)
return err return err
} }
@@ -677,13 +677,14 @@ func DeleteActStoreSkuBind(ctx *jxcontext.Context, db *dao.DaoDB, actID int, act
return err return err
} }
func SyncAct(ctx *jxcontext.Context, parentTask tasksch.ITask, actID int, vendorIDs, storeIDs, skuIDs []int, isAsync bool) (hint string, err error) { // todo 当前逻辑要求传入活动的全部SKU信息（以便低层做一些判断，比如全部删除时要取消，所以暂时删除storeIDs与skuIDs这两个参数
func SyncAct(ctx *jxcontext.Context, parentTask tasksch.ITask, actID int, vendorIDs /*, storeIDs, skuIDs */ []int, isAsync bool) (hint string, err error) {
db := dao.GetDB() db := dao.GetDB()
actMap, err := dao.GetActVendorInfo(db, actID, vendorIDs) actMap, err := dao.GetActVendorInfo(db, actID, vendorIDs)
if err != nil { if err != nil {
return "", err return "", err
} }
actStoreSkuMap, err := dao.GetActStoreSkuVendorInfo(db, actID, nil, storeIDs, skuIDs) actStoreSkuMap, err := dao.GetActStoreSkuVendorInfo(db, actID, nil, nil, nil)
if err != nil { if err != nil {
return "", err return "", err
} }
@@ -825,7 +826,7 @@ func DeleteSkusFromAct(ctx *jxcontext.Context, vendorID int, skuIDs []int, isAsy
if err = err2; err != nil { if err = err2; err != nil {
return "", err return "", err
} }
globals.SugarLogger.Debug(utils.Format4Output(pagedInfo, false)) // globals.SugarLogger.Debug(utils.Format4Output(pagedInfo, false))
for _, v := range pagedInfo.Data { for _, v := range pagedInfo.Data {
actMap[v.Act.ID] = &v.Act actMap[v.Act.ID] = &v.Act
} }
@@ -858,7 +859,7 @@ func DeleteSkusFromAct(ctx *jxcontext.Context, vendorID int, skuIDs []int, isAsy
if len(deleteList) > 0 { if len(deleteList) > 0 {
// globals.SugarLogger.Debug(utils.Format4Output(deleteList, false)) // globals.SugarLogger.Debug(utils.Format4Output(deleteList, false))
if err = DeleteActStoreSkuBind(ctx, db, actID, deleteList); err == nil { if err = DeleteActStoreSkuBind(ctx, db, actID, deleteList); err == nil {
if _, err = SyncAct(ctx, task, actID, nil, nil, skuIDs, false); err == nil { if _, err = SyncAct(ctx, task, actID, nil, false); err == nil {
retVal = deleteList retVal = deleteList
} }
} }

10
controllers/act.go
View File

@@ -193,17 +193,15 @@ func (c *ActController) GetActStoreSkuInfo() {
// @Param token header string true "认证token" // @Param token header string true "认证token"
// @Param actID formData int true "活动id" // @Param actID formData int true "活动id"
// @Param vendorIDs formData string false "厂商ID列表" // @Param vendorIDs formData string false "厂商ID列表"
// @Param storeIDs formData string false "门店ID列表"
// @Param skuIDs formData string false "商品列表"
// @Param isAsync formData bool false "是否异步" // @Param isAsync formData bool false "是否异步"
// @Success 200 {object} controllers.CallResult // @Success 200 {object} controllers.CallResult
// @Failure 200 {object} controllers.CallResult // @Failure 200 {object} controllers.CallResult
// @router /SyncAct [put] // @router /SyncAct [put]
func (c *ActController) SyncAct() { func (c *ActController) SyncAct() {
c.callSyncAct(func(params *tActSyncActParams) (retVal interface{}, errCode string, err error) { c.callSyncAct(func(params *tActSyncActParams) (retVal interface{}, errCode string, err error) {
var vendorIDs, storeIDs, skuIDs []int var vendorIDs /*, storeIDs, skuIDs*/ []int
if err = jxutils.Strings2Objs(params.VendorIDs, &vendorIDs, params.StoreIDs, &storeIDs, params.SkuIDs, &skuIDs); err == nil { if err = jxutils.Strings2Objs(params.VendorIDs, &vendorIDs /*, params.StoreIDs, &storeIDs, params.SkuIDs, &skuIDs*/); err == nil {
retVal, err = act.SyncAct(params.Ctx, nil, params.ActID, vendorIDs, storeIDs, skuIDs, params.IsAsync) retVal, err = act.SyncAct(params.Ctx, nil, params.ActID, vendorIDs, params.IsAsync)
} }
return retVal, "", err return retVal, "", err
}) })
@@ -249,7 +247,7 @@ func (c *ActController) UpdateActStoreSkuBind() {
dao.Commit(db) dao.Commit(db)
}() }()
if err == nil { if err == nil {
retVal, err = act.SyncAct(params.Ctx, nil, params.ActID, nil, nil, nil, params.IsAsync) retVal, err = act.SyncAct(params.Ctx, nil, params.ActID, nil, params.IsAsync)
} }
} }
} }