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

1

Browse Source
This commit is contained in:
邹宗楠
2025-03-27 16:02:43 +08:00
parent f4047b724c
commit c3564df925
1 changed files with 1 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
business/jxstore/cms/sync2.go
View File

@@ -720,19 +720,14 @@ func FullSyncVendorStuff(ctx *jxcontext.Context, parentTask tasksch.ITask, store
return "", fmt.Errorf("vendorID:%d不是多门店平台", vendorID) return "", fmt.Errorf("vendorID:%d不是多门店平台", vendorID)
} }
worker := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { worker := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
globals.SugarLogger.Debugf("--------batchItemList := %s", utils.Format4Output(batchItemList, false))
step := batchItemList[0].(int) step := batchItemList[0].(int)
globals.SugarLogger.Debugf("--------step := %d", step)
switch step { switch step {
case 0: case 0:
_, err = amendAndPruneVendorStuff(ctx, task, storeID, vendorID, vendorOrgCode, false, isContinueWhenError, AmendPruneAll, false) _, err = amendAndPruneVendorStuff(ctx, task, storeID, vendorID, vendorOrgCode, false, isContinueWhenError, AmendPruneAll, false)
case 1: case 1:
_, err = SyncCategories(ctx, task, []int{vendorID}, []string{vendorOrgCode}, nil, false) //_, err = SyncCategories(ctx, task, []int{vendorID}, []string{vendorOrgCode}, nil, false)
globals.SugarLogger.Debugf("--------err1 := %v", err)
case 2: case 2:
globals.SugarLogger.Debugf("--------storeID := %d", storeID)
_, err = SyncSkus(ctx, task, []int{vendorID}, []string{vendorOrgCode}, nil, nil, false) _, err = SyncSkus(ctx, task, []int{vendorID}, []string{vendorOrgCode}, nil, nil, false)
globals.SugarLogger.Debugf("--------err := %v", err)
} }
return retVal, err return retVal, err
} }