liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

- SetStoreSkuSyncStatus2

Browse Source
This commit is contained in:
gazebo
2019-05-09 11:53:34 +08:00
parent 618dcb9c66
commit 92b7b8a9bd
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
business/jxstore/cms/sku.go
View File

@@ -122,7 +122,7 @@ func UpdateCategory(ctx *jxcontext.Context, categoryID int, payload map[string]i
if valid["mtwmCategoryID"] != nil { if valid["mtwmCategoryID"] != nil {
vendorIDs = append(vendorIDs, model.VendorIDMTWM) 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) _, 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 { if err == nil {
skuIDs, err2 := dao.GetSkuIDByNames(db, []int{nameID}) skuIDs, err2 := dao.GetSkuIDByNames(db, []int{nameID})
if err = err2; err == nil && len(skuIDs) > 0 { 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 { if err == nil {
dao.Commit(db) dao.Commit(db)
@@ -651,7 +651,7 @@ func UpdateSkuName(ctx *jxcontext.Context, nameID int, payload map[string]interf
return num, err 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) dao.Begin(db)
defer func() { defer func() {
if r := recover(); r != nil || err != nil { 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 { 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 { if err = err2; err != nil {
return 0, err 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 { `, utils.DefaultTimeValue, skuID, model.SpecialUnit); err != nil {
return 0, err 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) dao.Commit(db)
_, err = CurVendorSync.SyncSku(ctx, db, -1, sku.ID, false, false, userName) _, err = CurVendorSync.SyncSku(ctx, db, -1, sku.ID, false, false, userName)
} }