diff --git a/business/partner/purchase/mtwm/store_sku.go b/business/partner/purchase/mtwm/store_sku.go index d4e0df19a..4fbab416a 100644 --- a/business/partner/purchase/mtwm/store_sku.go +++ b/business/partner/purchase/mtwm/store_sku.go @@ -173,25 +173,30 @@ func (p *PurchaseHandler) SyncLocalStoreCategory(ctx *jxcontext.Context, db *dao if err = dao.CreateEntity(db, catMap); err != nil { return "", err } - } else if isCheckRemote { - catMap := &model.StoreSkuCategoryMap{ - MtwmSyncStatus: model.SyncFlagNewMask, + } else { + if v.VendorCatID == "" || v.VendorCatID == "0" { + num++ } - updateFields := []string{ - model.FieldUpdatedAt, - model.FieldLastOperator, - model.FieldMtwmSyncStatus, - } - if identityCatMap[v.MapID] == 1 { // 如果一样,则要刷新ID(对于MTWM其实就是名字) - catMap.MtwmID = v.Name - catMap.MtwmSyncStatus = 0 - updateFields = append(updateFields, model.FieldMtwmID) - } - catMap.ID = v.MapID - num++ - dao.WrapUpdateULEntity(catMap, ctx.GetUserName()) - if _, err = dao.UpdateEntity(db, catMap, updateFields...); err != nil { - return "", err + if isCheckRemote { + catMap := &model.StoreSkuCategoryMap{ + MtwmSyncStatus: model.SyncFlagNewMask, + } + updateFields := []string{ + model.FieldUpdatedAt, + model.FieldLastOperator, + model.FieldMtwmSyncStatus, + } + if identityCatMap[v.MapID] == 1 { // 如果一样,则要刷新ID(对于MTWM其实就是名字) + catMap.MtwmID = v.Name + catMap.MtwmSyncStatus = 0 + updateFields = append(updateFields, model.FieldMtwmID) + } + catMap.ID = v.MapID + num++ + dao.WrapUpdateULEntity(catMap, ctx.GetUserName()) + if _, err = dao.UpdateEntity(db, catMap, updateFields...); err != nil { + return "", err + } } } } @@ -219,7 +224,7 @@ func (p *PurchaseHandler) SyncStoreSkus(ctx *jxcontext.Context, parentTask tasks if hint, err = p.SyncLocalStoreCategory(ctx, db, storeID, false, skuIDs); err != nil { return "", err } - if true { //hint != "0" { + if hint != "0" { if hint, err = p.SyncStoreCategory(ctx, parentTask, storeID, false); err != nil { return "", err }