diff --git a/business/jxstore/cms/sync2.go b/business/jxstore/cms/sync2.go index 0ad5643e8..4385394ac 100644 --- a/business/jxstore/cms/sync2.go +++ b/business/jxstore/cms/sync2.go @@ -538,7 +538,6 @@ func updateThingMapEntity(db *dao.DaoDB, thingMap *model.ThingMap) { } func amendAndPruneVendorStuff(ctx *jxcontext.Context, parentTask tasksch.ITask, storeID, vendorID int, vendorOrgCode string, isAsync, isContinueWhenError bool, opType int, isForceUpdate bool) (hint string, err error) { - defer globals.SugarLogger.Debugf("amendAndPruneVendorStuff err := %s", err) handler, _ := partner.GetPurchasePlatformFromVendorID(vendorID).(partner.IMultipleStoresHandler) if handler == nil { return "", fmt.Errorf("平台:%s不支持此操作", model.VendorChineseNames[vendorID]) @@ -625,6 +624,7 @@ func amendAndPruneVendorStuff(ctx *jxcontext.Context, parentTask tasksch.ITask, } } } + globals.SugarLogger.Debugf("case 0 err %s", err) case 1: // if (opType == AmendPruneOnlyPrune || opType == AmendPruneAll) && len(sku2Delete) > 0 { // _, err = putils.FreeBatchStoreSkuInfo("删除商品", func(task tasksch.ITask, batchedStoreSkuList []*partner.StoreSkuInfo) (result interface{}, successCount int, err error) { @@ -635,6 +635,7 @@ func amendAndPruneVendorStuff(ctx *jxcontext.Context, parentTask tasksch.ITask, // }, ctx, task, sku2Delete, 1, isContinueWhenError) // } sku2Delete = nil + globals.SugarLogger.Debugf("case 1 err %s", err) case 2: localCatList, err := dao.GetSkuCategoryWithVendor(db, []int{vendorID}, []string{vendorOrgCode}, -1, nil, false) globals.SugarLogger.Debugf("localCatList 2 err := %s", err) @@ -685,6 +686,7 @@ func amendAndPruneVendorStuff(ctx *jxcontext.Context, parentTask tasksch.ITask, } } } + globals.SugarLogger.Debugf("case 2 err %s", err) case 3: if (opType == AmendPruneOnlyPrune || opType == AmendPruneAll) && len(cat2Delete) > 0 { for i := 0; i < 2; i++ { @@ -709,6 +711,7 @@ func amendAndPruneVendorStuff(ctx *jxcontext.Context, parentTask tasksch.ITask, } cat2Delete = nil } + globals.SugarLogger.Debugf("case 3 err %s", err) return nil, err }, []int{0, 1, 2, 3}) tasksch.HandleTask(task, parentTask, true).Run() @@ -718,6 +721,7 @@ func amendAndPruneVendorStuff(ctx *jxcontext.Context, parentTask tasksch.ITask, } else { hint = task.ID } + globals.SugarLogger.Debugf("amendAndPruneVendorStuff err := %s", err) return hint, err } @@ -732,7 +736,7 @@ func FullSyncVendorStuff(ctx *jxcontext.Context, parentTask tasksch.ITask, store switch step { case 0: _, err = amendAndPruneVendorStuff(ctx, task, storeID, vendorID, vendorOrgCode, false, isContinueWhenError, AmendPruneAll, false) - globals.SugarLogger.Debugf("========err 1 %s", err) + globals.SugarLogger.Debugf("=== =====err 1 %s", err) case 1: _, err = SyncCategories(ctx, task, []int{vendorID}, []string{vendorOrgCode}, nil, false) globals.SugarLogger.Debugf("========err 2 %s", err)