diff --git a/business/model/dao/dao_utils.go b/business/model/dao/dao_utils.go index c09777970..8b3c70c7f 100644 --- a/business/model/dao/dao_utils.go +++ b/business/model/dao/dao_utils.go @@ -168,3 +168,7 @@ func value2Value(srcValue, dstValue reflect.Value, copyType int) { // func ObjNull2Normal(src, dst interface{}) { // copyBetweenNoramAndNullObj(src, dst, 2) // } + +func IsVendorThingIDEmpty(vendorThingID string) bool { + return vendorThingID == "" || vendorThingID == "0" +} diff --git a/business/partner/purchase/mtwm/store_sku.go b/business/partner/purchase/mtwm/store_sku.go index f42eeff25..e86cb9ff9 100644 --- a/business/partner/purchase/mtwm/store_sku.go +++ b/business/partner/purchase/mtwm/store_sku.go @@ -257,13 +257,13 @@ func (p *PurchaseHandler) SyncStoreSkus(ctx *jxcontext.Context, parentTask tasks storeSkuBind := &model.StoreSkuBind{} storeSkuBind.ID = skuItem.BindID if skuItem.NameID == 0 || skuItem.StoreSkuSyncStatus&model.SyncFlagDeletedMask != 0 { - if skuItem.StoreSkuSyncStatus&model.SyncFlagNewMask == 0 && !isVendorSkuIDEmpty(skuItem.VendorSkuID) { + if skuItem.StoreSkuSyncStatus&model.SyncFlagNewMask == 0 && !dao.IsVendorThingIDEmpty(skuItem.VendorSkuID) { err = ignoreNoAppFoodErr(api.MtwmAPI.RetailDelete(vendorStoreID, skuItem.VendorSkuID)) } if err == nil { storeSkuBind.DeletedAt = time.Now() updateFields = append(updateFields, model.FieldDeletedAt) - if !isVendorSkuIDEmpty(skuItem.VendorSkuID) { + if !dao.IsVendorThingIDEmpty(skuItem.VendorSkuID) { storeSkuBind.MtwmID = 0 updateFields = append(updateFields, model.FieldMtwmID) } @@ -523,10 +523,6 @@ func (p *PurchaseHandler) GetStoresSku(ctx *jxcontext.Context, parentTask tasksc return storeSkuList, err } -func isVendorSkuIDEmpty(vendorSkuID string) bool { - return vendorSkuID == "" || vendorSkuID == "0" -} - func ignoreNoAppFoodErr(err error) error { if err != nil { if codeErr, ok := err.(*utils.ErrorWithCode); ok {