From fdbf6d14bcd7578070c1a3c868df6995329ae763 Mon Sep 17 00:00:00 2001
From: aozhiwei <aozhiwei@kingsome.cn>
Date: Mon, 29 Jul 2024 09:40:59 +0800
Subject: [PATCH] 1

---
 server/backtask/task/recharge.go | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/server/backtask/task/recharge.go b/server/backtask/task/recharge.go
index 228195da..9a950a08 100644
--- a/server/backtask/task/recharge.go
+++ b/server/backtask/task/recharge.go
@@ -29,11 +29,12 @@ func (this *recharge) process() {
 		func (lastIdx int64, maxIdx int64) (string, []string) {
 			sql := fmt.Sprintf(`
 SELECT * FROM t_recharge
-WHERE idx > %d AND idx <= %d AND status = 0
+WHERE idx > %d AND idx <= %d AND status = %d
 ORDER BY idx LIMIT 1000
 `,
 				lastIdx,
-				maxIdx)
+				maxIdx,
+				jccommon.RECHARGE_ORDER_STATUS_PENDING)
 			params := []string{
 			}
 			return sql, params
@@ -61,6 +62,7 @@ func (this *recharge) deliverGoods(ds *f5.DataSet) bool {
 				result = this.markStatus(idx, jccommon.RECHARGE_ORDER_STATUS_SENT) == nil
 				return
 			}
+			result = this.markStatus(idx, jccommon.RECHARGE_ORDER_STATUS_SENT) == nil
 		})
 	return result
 }