diff --git a/business/jxstore/cms/store.go b/business/jxstore/cms/store.go index ffbcb936a..1bdc89d63 100644 --- a/business/jxstore/cms/store.go +++ b/business/jxstore/cms/store.go @@ -778,7 +778,7 @@ func UpdateStore(ctx *jxcontext.Context, storeID int, payload map[string]interfa } notifyStoreOperatorChanged(store, valid["operatorPhone"]) if valid["openTime1"] != 0 || valid["closeTime1"] != 0 || valid["openTime2"] != 0 || valid["closeTime2"] != 0 { - err = CurVendorSync.ChangeStoreSkuSaleStatus(ctx, true, false, storeID) + err = CurVendorSync.ChangeStoreSkuSaleStatus(ctx, storeID, true, false) } } } else { diff --git a/business/jxstore/cms/sync.go b/business/jxstore/cms/sync.go index 5e54a5a35..33c10fdf4 100644 --- a/business/jxstore/cms/sync.go +++ b/business/jxstore/cms/sync.go @@ -654,7 +654,7 @@ func (v *VendorSync) SyncSkuNames(ctx *jxcontext.Context, nameIDs []int, isForce return v.SyncSkus(ctx, db, nameIDs, nil, isAsync, isContinueWhenError, ctx.GetUserName()) } -func (v *VendorSync) ChangeStoreSkuSaleStatus(ctx *jxcontext.Context, isAsync, isContinueWhenError bool, storeID int) (err error) { +func (v *VendorSync) ChangeStoreSkuSaleStatus(ctx *jxcontext.Context, storeID int, isAsync, isContinueWhenError bool) (err error) { var ( storeIDs []int skuIDs []int @@ -669,7 +669,7 @@ func (v *VendorSync) ChangeStoreSkuSaleStatus(ctx *jxcontext.Context, isAsync, i skuIDs = append(skuIDs, v.SkuID) } vendorIDs := partner.GetPurchasePlatformVendorIDs() - dao.UpdateStoreSkuBindSyncStatus(db, vendorIDs) + dao.UpdateStoreSkuBindSyncStatus(db, vendorIDs, storeID) v.SyncStoresSkus(ctx, db, vendorIDs, storeIDs, skuIDs, false, isAsync, isContinueWhenError) if err != nil { return err diff --git a/business/jxstore/misc/misc.go b/business/jxstore/misc/misc.go index 504976fe4..b6b83280b 100644 --- a/business/jxstore/misc/misc.go +++ b/business/jxstore/misc/misc.go @@ -134,7 +134,7 @@ func Init() { "04:05:06", }) ScheduleTimerFunc("ChangeStoreSkuSaleStatus", func() { - cms.CurVendorSync.ChangeStoreSkuSaleStatus(jxcontext.AdminCtx, true, false, 0) + cms.CurVendorSync.ChangeStoreSkuSaleStatus(jxcontext.AdminCtx, 0, true, false) }, ChangeStoreSkuSaleStatusList) } } diff --git a/business/model/dao/store_sku.go b/business/model/dao/store_sku.go index 9d3496866..a8fcb9fe0 100644 --- a/business/model/dao/store_sku.go +++ b/business/model/dao/store_sku.go @@ -609,7 +609,7 @@ func GetStoresSkusInfoBySaleTime(db *DaoDB, storeID int) (storeSkuBindList []*mo return storeSkuBindList, err } -func UpdateStoreSkuBindSyncStatus(db *DaoDB, vendorIDs []int) (num int64, err error) { +func UpdateStoreSkuBindSyncStatus(db *DaoDB, vendorIDs []int, storeID int) (num int64, err error) { sql := ` UPDATE store_sku_bind SET @@ -634,5 +634,9 @@ func UpdateStoreSkuBindSyncStatus(db *DaoDB, vendorIDs []int) (num int64, err er AND status_sale_end <> 0 ` sqlParams = append(sqlParams, model.StoreSkuBindStatusNormal, utils.DefaultTimeValue) + if storeID > 0 { + sql += ` AND store_id = ?` + sqlParams = append(sqlParams, storeID) + } return ExecuteSQL(db, sql, sqlParams...) }