From 7b345d134b480939c54f095765b26fe49a90802c Mon Sep 17 00:00:00 2001
From: aozhiwei <aozhiwei@kingsome.cn>
Date: Tue, 3 Sep 2024 16:31:17 +0800
Subject: [PATCH] 1

---
 server/light_backtask/task/stacking_go.go | 51 ++++++++++++++++-------
 1 file changed, 35 insertions(+), 16 deletions(-)

diff --git a/server/light_backtask/task/stacking_go.go b/server/light_backtask/task/stacking_go.go
index b967aff0..7387a969 100644
--- a/server/light_backtask/task/stacking_go.go
+++ b/server/light_backtask/task/stacking_go.go
@@ -140,28 +140,47 @@ func (this *stackingCec) apply(idx int64, eventName string,
 	} else {
 		return false
 	}
-	dbErr, ds := f5.GetGoStyleDb().NewOrmSelect(
-		constant.BCNFT_DB,
-		"t_staking_cec",
-		[][]string{
-			{"account_address", strings.ToLower(p.Account)},
-			{"token_address", strings.ToLower(p.Token)},
-		},
-	)
-	if dbErr != nil {
-		return false
-	}
 	srcAmount := "0"
-	if ds.Next() {
-		if idx <= q5.ToInt64(ds.GetByName("last_apply_record_idx")) {
-			return true
+	{
+		dbErr, ds := f5.GetGoStyleDb().NewOrmSelect(
+			constant.BCNFT_DB,
+			"t_staking_cec",
+			[][]string{
+				{"account_address", strings.ToLower(p.Account)},
+				{"token_address", strings.ToLower(p.Token)},
+			},
+		)
+		if dbErr != nil {
+			return false
+		}
+		if ds.Next() {
+			if idx <= q5.ToInt64(ds.GetByName("last_apply_record_idx")) {
+				return true
+			}
+			srcAmount = ds.GetByName("amount")
 		}
-		srcAmount = ds.GetByName("amount")
 	}
 	bnNewAmount, ok := new(big.Int).SetString(srcAmount, 10)
 	if !ok {
 		return false
 	}
 	bnNewAmount.Add(bnNewAmount, bnAmount)
-	return true
+	{
+		nowTime := f5.GetApp().GetRealSeconds()
+		dbErr, _, _ := f5.GetGoStyleDb().NewUpsert(
+			constant.BCNFT_DB,
+			"t_staking_cec",
+			[][]string{
+				{"account_address", strings.ToLower(p.Account)},
+				{"token_address", strings.ToLower(p.Token)},
+			},
+			[][]string{},
+			[][]string{
+				{"account_address", strings.ToLower(p.Account)},
+				{"token_address", strings.ToLower(p.Token)},
+				{"createtime", q5.ToString(nowTime)},
+				{"modifytime", q5.ToString(nowTime)},
+			})
+		return dbErr == nil
+	}
 }