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:
邹宗楠
2023-01-12 14:47:13 +08:00
parent 10b7a6a2a7
commit 70ca31010d
2 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
business/jxstore/cms/store_sku.go
View File

@@ -1974,10 +1974,7 @@ func updateStoresSkusWithoutSync(ctx *jxcontext.Context, db *dao.DaoDB, storeIDs
FOR UPDATE` FOR UPDATE`
sqlParams = append(sqlParams, utils.DefaultTimeValue) sqlParams = append(sqlParams, utils.DefaultTimeValue)
// globals.SugarLogger.Debug(sql) // globals.SugarLogger.Debug(sql)
globals.SugarLogger.Debug("==========sql %s", sql)
globals.SugarLogger.Debug("==========sqlParams %s", utils.Format4Output(sqlParams, false))
if err = dao.GetRows(db, &allBinds, sql, sqlParams...); err == nil { if err = dao.GetRows(db, &allBinds, sql, sqlParams...); err == nil {
globals.SugarLogger.Debug("==========allBinds %s", utils.Format4Output(allBinds, false))
if len(allBinds) > 0 { if len(allBinds) > 0 {
inSkuBinsMap := make(map[int]*StoreSkuBindSkuInfo, len(inSkuBinds)) inSkuBinsMap := make(map[int]*StoreSkuBindSkuInfo, len(inSkuBinds))
for _, v := range inSkuBinds { for _, v := range inSkuBinds {

5
business/jxstore/cms/sync_store_sku.go
View File

@@ -474,6 +474,8 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, causeFlag
} else { } else {
skus, err = dao.GetStoreSkus(db, vendorID, storeID, skuIDs) skus, err = dao.GetStoreSkus(db, vendorID, storeID, skuIDs)
} }
globals.SugarLogger.Debug("==========skus %s", utils.Format4Output(skus, false))
if err != nil || len(skus) == 0 { if err != nil || len(skus) == 0 {
return err return err
} }
@@ -700,6 +702,9 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, causeFlag
// api.JdShop2API.SetCookieWithStr(configs[0].Value) // api.JdShop2API.SetCookieWithStr(configs[0].Value)
// } // }
} }
globals.SugarLogger.Debug("==========createList %s", utils.Format4Output(createList, false))
globals.SugarLogger.Debug("==========updateList %s", utils.Format4Output(updateList, false))
task := tasksch.NewParallelTask("syncStoreSkuNew", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(isContinueWhenError2), ctx, task := tasksch.NewParallelTask("syncStoreSkuNew", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(isContinueWhenError2), ctx,
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
step := batchItemList[0].(int) step := batchItemList[0].(int)