From 7324598fd7d9441f640e114ed1824e1ada8bdff9 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=82=B9=E5=AE=97=E6=A5=A0?= Date: Wed, 24 Jul 2024 09:53:36 +0800 Subject: [PATCH] 1 --- business/jxstore/cms/sync.go | 3 +++ business/jxstore/cms/sync_store_sku.go | 14 ++++++++++++++ 2 files changed, 17 insertions(+) diff --git a/business/jxstore/cms/sync.go b/business/jxstore/cms/sync.go index 3d5a61f63..cebf32c92 100644 --- a/business/jxstore/cms/sync.go +++ b/business/jxstore/cms/sync.go @@ -769,6 +769,9 @@ func (v *VendorSync) LoopStoresMap2(ctx *jxcontext.Context, parentTask tasksch.I } vendorStoreMap := make(map[int][]*model.StoreMap) for _, v := range storeMapList { + if v.StoreID == 666900 { + globals.SugarLogger.Debugf("===========store:%d", v.VendorID) + } vendorStoreMap[v.VendorID] = append(vendorStoreMap[v.VendorID], v) } loopInfoList := make([]*LoopStoreMapInfo, len(vendorStoreMap)) diff --git a/business/jxstore/cms/sync_store_sku.go b/business/jxstore/cms/sync_store_sku.go index 4891e6a03..d19666208 100644 --- a/business/jxstore/cms/sync_store_sku.go +++ b/business/jxstore/cms/sync_store_sku.go @@ -750,6 +750,17 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, causeFlag } } + if storeDetail.ID == 666900 { + globals.SugarLogger.Debugf("========createList := %s", utils.Format4Output(createList, false)) + globals.SugarLogger.Debugf("========updateList := %s", utils.Format4Output(updateList, false)) + globals.SugarLogger.Debugf("========deleteList := %s", utils.Format4Output(deleteList, false)) + globals.SugarLogger.Debugf("========stockList := %s", utils.Format4Output(stockList, false)) + globals.SugarLogger.Debugf("========onlineList := %s", utils.Format4Output(onlineList, false)) + globals.SugarLogger.Debugf("========offlineList := %s", utils.Format4Output(offlineList, false)) + globals.SugarLogger.Debugf("========priceList := %s", utils.Format4Output(priceList, false)) + globals.SugarLogger.Debugf("========updateItems := %s", utils.Format4Output(updateItems, false)) + globals.SugarLogger.Debugf("========reorderSkuMap := %s", utils.Format4Output(reorderSkuMap, false)) + } task := tasksch.NewParallelTask("syncStoreSkuNew", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(isContinueWhenError2), ctx, func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { @@ -868,6 +879,9 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, causeFlag if len(statusList) > 0 { _, err = putils.FreeBatchStoreSkuInfo(name, func(task tasksch.ITask, batchedStoreSkuList []*partner.StoreSkuInfo) (result interface{}, successCount int, err error) { var failedList []*partner.StoreSkuInfoWithErr + if storeDetail.ID == 666900 { + globals.SugarLogger.Debugf("========== %s ,%s, %s", storeDetail.VendorOrgCode, vendorStoreID, utils.Format4Output(batchedStoreSkuList, false)) + } failedList, err = storeSkuHandler.UpdateStoreSkusStatus(ctx, storeDetail.VendorOrgCode, storeID, vendorStoreID, batchedStoreSkuList, status) failedList, err = buildFailedListAndErr(failedList, err, batchedStoreSkuList, nil, storeID, vendorID, "更新门店商品状态") if len(failedList) > 0 {