diff --git a/business/jxstore/tempop/tempop.go b/business/jxstore/tempop/tempop.go index ae8bdad66..25f9606c8 100644 --- a/business/jxstore/tempop/tempop.go +++ b/business/jxstore/tempop/tempop.go @@ -1629,10 +1629,10 @@ func RefreshJXPriceChange(ctx *jxcontext.Context) (hint string, err error) { sql := ` SELECT * FROM store - WHERE deleted_at = ? AND status <> ? AND pay_percentage = ? - AND id = ? + WHERE deleted_at = ? AND status <> ? + AND id in (?,?,?) ` - sqlParams := []interface{}{utils.DefaultTimeValue, model.StoreStatusDisabled, 80, 100118} + sqlParams := []interface{}{utils.DefaultTimeValue, model.StoreStatusDisabled, 100118, 100205, 100274} err = dao.GetRows(db, &stores, sql, sqlParams) task := tasksch.NewParallelTask("刷新门店价格", tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError), ctx, func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {