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 15:59:02 +08:00
parent ebc26e5c82
commit f4047b724c
2 changed files with 18 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
business/jxstore/cms/store.go
View File

@@ -624,7 +624,6 @@ func GetStores(ctx *jxcontext.Context, keyword string, params map[string]interfa
}
}
}
globals.SugarLogger.Debugf("-----params2 :%s", utils.Format4Output(params, false))
sql, sqlParams, _, _, err := getStoresSql(ctx, keyword, params, orderTimeFrom, orderTimeTo)
if err != nil {
return nil, err

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

@@ -719,22 +719,24 @@ func FullSyncVendorStuff(ctx *jxcontext.Context, parentTask tasksch.ITask, store
if multiStoreHandler == nil {
return "", fmt.Errorf("vendorID:%d不是多门店平台", vendorID)
}
task := tasksch.NewParallelTask("FullSyncStoreSkuNew", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(false), ctx,
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
step := batchItemList[0].(int)
switch step {
case 0:
_, err = amendAndPruneVendorStuff(ctx, task, storeID, vendorID, vendorOrgCode, false, isContinueWhenError, AmendPruneAll, false)
case 1:
_, err = SyncCategories(ctx, task, []int{vendorID}, []string{vendorOrgCode}, nil, false)
globals.SugarLogger.Debugf("--------err1 := %v", err)
case 2:
globals.SugarLogger.Debugf("--------storeID := %d", storeID)
_, err = SyncSkus(ctx, task, []int{vendorID}, []string{vendorOrgCode}, nil, nil, false)
globals.SugarLogger.Debugf("--------err := %v", err)
}
return retVal, err
}, []int{0, 1, 2})
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)
globals.SugarLogger.Debugf("--------step := %d", step)
switch step {
case 0:
_, err = amendAndPruneVendorStuff(ctx, task, storeID, vendorID, vendorOrgCode, false, isContinueWhenError, AmendPruneAll, false)
case 1:
_, err = SyncCategories(ctx, task, []int{vendorID}, []string{vendorOrgCode}, nil, false)
globals.SugarLogger.Debugf("--------err1 := %v", err)
case 2:
globals.SugarLogger.Debugf("--------storeID := %d", storeID)
_, err = SyncSkus(ctx, task, []int{vendorID}, []string{vendorOrgCode}, nil, nil, false)
globals.SugarLogger.Debugf("--------err := %v", err)
}
return retVal, err
}
task := tasksch.NewParallelTask("FullSyncStoreSkuNew", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(false), ctx, worker, []int{0, 1, 2})
tasksch.HandleTask(task, parentTask, true).Run()
if !isAsync {
_, err = task.GetResult(0)