diff --git a/business/jxstore/cms/sync_store_sku.go b/business/jxstore/cms/sync_store_sku.go index 1f5e18885..dd21af398 100644 --- a/business/jxstore/cms/sync_store_sku.go +++ b/business/jxstore/cms/sync_store_sku.go @@ -70,7 +70,7 @@ func SyncStorCategories(ctx *jxcontext.Context, parentTask tasksch.ITask, vendor tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError), ctx, func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { updateFields := []string{dao.GetSyncStatusStructField(model.VendorNames[vendorID])} - syncStatusFieldName := dao.GetVendorThingIDStructField(model.VendorNames[vendorID]) + idFieldName := dao.GetVendorThingIDStructField(model.VendorNames[vendorID]) catInfo := batchItemList[0].(*dao.SkuStoreCatInfo) storeCatMap := &model.StoreSkuCategoryMap{} storeCatMap.ID = catInfo.MapID @@ -90,18 +90,18 @@ func SyncStorCategories(ctx *jxcontext.Context, parentTask tasksch.ITask, vendor } } if err == nil { - updateFields = append(updateFields, syncStatusFieldName) + updateFields = append(updateFields, idFieldName) } } else if model.IsSyncStatusUpdate(catInfo.StoreCatSyncStatus) { // 修改 if err = handler.UpdateStoreCategory(ctx, storeID, vendorStoreID, catInfo); err == nil { - updateFields = append(updateFields, syncStatusFieldName) + updateFields = append(updateFields, idFieldName) } } if err == nil { if vendorID == model.VendorIDMTWM { - refutil.SetObjFieldByName(storeCatMap, syncStatusFieldName, catInfo.VendorCatID) + refutil.SetObjFieldByName(storeCatMap, idFieldName, catInfo.VendorCatID) } else { - refutil.SetObjFieldByName(storeCatMap, syncStatusFieldName, utils.Str2Int64WithDefault(catInfo.VendorCatID, 0)) + refutil.SetObjFieldByName(storeCatMap, idFieldName, utils.Str2Int64WithDefault(catInfo.VendorCatID, 0)) } _, err = dao.UpdateEntity(db, storeCatMap, updateFields...) }