diff --git a/business/jxstore/cms/store_sku.go b/business/jxstore/cms/store_sku.go index 48fbaa035..43b26257f 100644 --- a/business/jxstore/cms/store_sku.go +++ b/business/jxstore/cms/store_sku.go @@ -1974,10 +1974,7 @@ func updateStoresSkusWithoutSync(ctx *jxcontext.Context, db *dao.DaoDB, storeIDs FOR UPDATE` sqlParams = append(sqlParams, utils.DefaultTimeValue) // 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 { - globals.SugarLogger.Debug("==========allBinds %s", utils.Format4Output(allBinds, false)) if len(allBinds) > 0 { inSkuBinsMap := make(map[int]*StoreSkuBindSkuInfo, len(inSkuBinds)) for _, v := range inSkuBinds { diff --git a/business/jxstore/cms/sync_store_sku.go b/business/jxstore/cms/sync_store_sku.go index bc445f14f..3390c3d2f 100644 --- a/business/jxstore/cms/sync_store_sku.go +++ b/business/jxstore/cms/sync_store_sku.go @@ -474,6 +474,8 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, causeFlag } else { skus, err = dao.GetStoreSkus(db, vendorID, storeID, skuIDs) } + globals.SugarLogger.Debug("==========skus %s", utils.Format4Output(skus, false)) + if err != nil || len(skus) == 0 { return err } @@ -700,6 +702,9 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, causeFlag // 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, func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { step := batchItemList[0].(int)