From dd08c3721baedbdb1e49dfa66a370afac31ab8f0 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=82=B9=E5=AE=97=E6=A5=A0?= Date: Fri, 7 Feb 2025 13:54:59 +0800 Subject: [PATCH] 1 --- business/jxstore/cms/sync_store_sku.go | 8 ++++++++ business/model/dao/store_sku.go | 2 ++ 2 files changed, 10 insertions(+) diff --git a/business/jxstore/cms/sync_store_sku.go b/business/jxstore/cms/sync_store_sku.go index 015ddc3f3..9fe406684 100644 --- a/business/jxstore/cms/sync_store_sku.go +++ b/business/jxstore/cms/sync_store_sku.go @@ -535,6 +535,7 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, causeFlag } else { skus, err = dao.GetStoreSkus(db, vendorID, storeID, skuIDs) } + globals.SugarLogger.Debugf("----------len %d", len(skus)) if err != nil || len(skus) == 0 { return err @@ -755,6 +756,12 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, causeFlag } + globals.SugarLogger.Debugf("-----------stock list := %d", len(stockList)) + globals.SugarLogger.Debugf("-----------updateList list := %d", len(updateList)) + globals.SugarLogger.Debugf("-----------deleteList list := %d", len(deleteList)) + globals.SugarLogger.Debugf("-----------onlineList list := %d", len(onlineList)) + globals.SugarLogger.Debugf("-----------offlineList list := %d", len(offlineList)) + globals.SugarLogger.Debugf("-----------priceList list := %d", len(priceList)) 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) @@ -867,6 +874,7 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, causeFlag } case 3: // for k, list := range [][]*partner.StoreSkuInfo{stockList /*, onlineList*/} { + globals.SugarLogger.Debugf("----------len := %d", len(stockList)) if len(stockList) > 0 { _, err = putils.FreeBatchStoreSkuInfo("更新门店商品库存", func(task tasksch.ITask, batchedStoreSkuList []*partner.StoreSkuInfo) (result interface{}, successCount int, err error) { var failedList []*partner.StoreSkuInfoWithErr diff --git a/business/model/dao/store_sku.go b/business/model/dao/store_sku.go index 8f8504629..83213e2db 100644 --- a/business/model/dao/store_sku.go +++ b/business/model/dao/store_sku.go @@ -699,6 +699,8 @@ func GetStoreSkus2(db *DaoDB, vendorID, storeID int, skuIDs []int, mustDirty boo } sql = fmt.Sprintf(sql, fmtParams...) sql += " ORDER BY t1.price" + globals.SugarLogger.Debugf("---------sql := %s", sql) + globals.SugarLogger.Debugf("---------sql := %s", utils.Format4Output(sqlParams, false)) if err = GetRows(db, &skus, sql, sqlParams...); err != nil { return nil, err }