From 172d7fba6fc2cad708a5f9415df7d3d221c22361 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com>
Date: Tue, 2 Jun 2020 14:56:05 +0800
Subject: [PATCH] =?UTF-8?q?=E5=88=B7=E4=BA=AC=E8=A5=BF=E4=BB=B7?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 business/jxstore/tempop/tempop.go | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

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) {