1

server/backtask/task/recharge.go

@@ -7,7 +7,7 @@ import (
 	"fmt"
 	//"mt"
 	//"strings"
-	//"jccommon"
+	"jccommon"
 )
 
 type recharge struct {
@@ -55,11 +55,29 @@ func (this *recharge) deliverGoods(ds *f5.DataSet) bool {
 				result = false
 				return
 			}
+			idx := q5.ToInt64(ds.GetByName("idx"))
 			status := q5.ToInt32(ds.GetByName("stauts"))
 			if status != 0 {
-				result = true
+				result = this.markStatus(idx, jccommon.RECHARGE_ORDER_STATUS_SENT) == nil
 				return
 			}
 		})
 	return result
 }
+
+func (this *recharge) markStatus(idx int64, status int32) error {
+	var resultErr error
+	f5.GetGoStyleDb().Update(
+		constant.BCEVENT_DB,
+		"t_recharge",
+		[][]string{
+			{"idx", q5.ToString(idx)},
+		},
+		[][]string{
+			{"status", q5.ToString(status)},
+		},
+		func (err error, lastInsertId int64, rowsAffected int64) {
+			resultErr = err
+		})
+	return resultErr
+}

server/jccommon/constant.go

@@ -102,6 +102,11 @@ const (
 	MAP_MODE_BOUNTY = 301
 )
 
+const (
+	RECHARGE_ORDER_STATUS_PENDING = 0
+	RECHARGE_ORDER_STATUS_SENT =1
+)
+
 const (
 	BC_CURRENCY_NAME_ETHEREUM = "Ethereum"
 	BC_CURRENCY_NAME_USDC = "USDC"