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 }