This commit is contained in:
aozhiwei 2024-07-29 09:40:59 +08:00
parent 2d47880e59
commit fdbf6d14bc

View File

@ -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
}