From 92b7b8a9bd11904e1ae9a0a52714401a223b3f0c Mon Sep 17 00:00:00 2001 From: gazebo Date: Thu, 9 May 2019 11:53:34 +0800 Subject: [PATCH] - SetStoreSkuSyncStatus2 --- business/jxstore/cms/sku.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/business/jxstore/cms/sku.go b/business/jxstore/cms/sku.go index 66b3904a5..0aa192ecf 100644 --- a/business/jxstore/cms/sku.go +++ b/business/jxstore/cms/sku.go @@ -122,7 +122,7 @@ func UpdateCategory(ctx *jxcontext.Context, categoryID int, payload map[string]i if valid["mtwmCategoryID"] != nil { vendorIDs = append(vendorIDs, model.VendorIDMTWM) } - SetStoreSkuSyncStatus2(db, -1, vendorIDs, skuIDs, model.SyncFlagModifiedMask) + SetStoreSkuSyncStatus2(db, nil, vendorIDs, skuIDs, model.SyncFlagModifiedMask) } } _, err = CurVendorSync.SyncCategory(ctx, db, categoryID, false, userName) @@ -638,7 +638,7 @@ func UpdateSkuName(ctx *jxcontext.Context, nameID int, payload map[string]interf if err == nil { skuIDs, err2 := dao.GetSkuIDByNames(db, []int{nameID}) if err = err2; err == nil && len(skuIDs) > 0 { - _, err = SetStoreSkuSyncStatus2(db, -1, CurVendorSync.SingleStoreVendorIDs, skuIDs, model.SyncFlagModifiedMask) + _, err = SetStoreSkuSyncStatus2(db, nil, CurVendorSync.SingleStoreVendorIDs, skuIDs, model.SyncFlagModifiedMask) } if err == nil { dao.Commit(db) @@ -651,7 +651,7 @@ func UpdateSkuName(ctx *jxcontext.Context, nameID int, payload map[string]interf return num, err } -func SetStoreSkuSyncStatus2(db *dao.DaoDB, storeID int, vendorIDs, skuIDs []int, syncStatus int) (num int64, err error) { +func SetStoreSkuSyncStatus2(db *dao.DaoDB, storeIDs []int, vendorIDs, skuIDs []int, syncStatus int) (num int64, err error) { dao.Begin(db) defer func() { if r := recover(); r != nil || err != nil { @@ -662,7 +662,7 @@ func SetStoreSkuSyncStatus2(db *dao.DaoDB, storeID int, vendorIDs, skuIDs []int, } }() for _, vendorID := range vendorIDs { - num2, err2 := dao.SetStoreSkuSyncStatus(db, vendorID, []int{storeID}, skuIDs, syncStatus) + num2, err2 := dao.SetStoreSkuSyncStatus(db, vendorID, storeIDs, skuIDs, syncStatus) if err = err2; err != nil { return 0, err } @@ -766,7 +766,7 @@ func UpdateSku(ctx *jxcontext.Context, skuID int, payload map[string]interface{} `, utils.DefaultTimeValue, skuID, model.SpecialUnit); err != nil { return 0, err } - if _, err = SetStoreSkuSyncStatus2(db, -1, CurVendorSync.SingleStoreVendorIDs, []int{skuID}, model.SyncFlagModifiedMask); err == nil { + if _, err = SetStoreSkuSyncStatus2(db, nil, CurVendorSync.SingleStoreVendorIDs, []int{skuID}, model.SyncFlagModifiedMask); err == nil { dao.Commit(db) _, err = CurVendorSync.SyncSku(ctx, db, -1, sku.ID, false, false, userName) }