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

刷京西价

Browse Source
This commit is contained in:
苏尹岚
2020-06-02 14:56:05 +08:00
parent c5e842c5a5
commit 172d7fba6f
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
business/jxstore/tempop/tempop.go
View File

@@ -1629,10 +1629,10 @@ func RefreshJXPriceChange(ctx *jxcontext.Context) (hint string, err error) {
sql := ` sql := `
SELECT * SELECT *
FROM store FROM store
WHERE deleted_at = ? AND status <> ? AND pay_percentage = ? WHERE deleted_at = ? AND status <> ?
AND id = ? 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) err = dao.GetRows(db, &stores, sql, sqlParams)
task := tasksch.NewParallelTask("刷新门店价格", tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError), ctx, task := tasksch.NewParallelTask("刷新门店价格", tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError), ctx,
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {