From 04aa588ab58d421eb05c4b3c5aec032d3e76c2f0 Mon Sep 17 00:00:00 2001
From: aozhiwei <aozhiwei@kingsome.cn>
Date: Sat, 17 Aug 2024 15:20:48 +0800
Subject: [PATCH] 1

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

diff --git a/server/backtask/task/recharge.go b/server/backtask/task/recharge.go
index f97d3ae2..3a508662 100644
--- a/server/backtask/task/recharge.go
+++ b/server/backtask/task/recharge.go
@@ -47,11 +47,14 @@ func (this *recharge) deliverGoods(ds *f5.DataSet) bool {
 	orderId := ds.GetByName("order_id")
 	shortOrderId := q5.ToInt64(ds.GetByName("short_order_id"))
 	passportAddress := ds.GetByName("passport_address")
-	diamond := q5.ToInt64(ds.GetByName("diamond"))
+	srcDiamond := q5.ToInt64(ds.GetByName("diamond"))
+	presentDiamond := q5.ToInt64(ds.GetByName("present_diamond"))
 	returnContribution := q5.ToFloat64(ds.GetByName("return_contribution"))
 	netId := q5.ToInt32(ds.GetByName("net_id"))
 	payTime := q5.ToInt32(ds.GetByName("pay_time"))
 	email := ds.GetByName("lower_case_email")
+
+	diamond := srcDiamond + presentDiamond
 	accountId := ""
 	userIdentity := ""
 	if email != "" {
@@ -100,5 +103,20 @@ func (this *recharge) markOk(idx int64, deliveryAccountId string) error {
 
 func (this *recharge) returnContribution(netId int32, shortOrderId int64,
 	userIdentity string, contribution float64, payTime int32) error {
-	return nil
+	var resultErr error
+	f5.GetGoStyleDb().Upsert(
+		constant.BCNFT_DB,
+		"t_recharge_return_contribution",
+		[][]string{
+		},
+		[][]string{
+		},
+		[][]string{
+			{"delivery_status", q5.ToString(jccommon.RECHARGE_ORDER_DELIVERY_STATUS_OK)},
+			{"delivery_time", q5.ToString(f5.GetApp().GetRealSeconds())},
+		},
+		func (err error, lastInsertId int64, rowsAffected int64) {
+			resultErr = err
+		})
+	return resultErr
 }