From 82ea4ac5f0ec6940cc50b37b416b9b230e24fba3 Mon Sep 17 00:00:00 2001
From: aozhiwei <aozhiwei@kingsome.cn>
Date: Tue, 3 Sep 2024 15:30:26 +0800
Subject: [PATCH] 1

---
 server/light_backtask/task/stacking_go.go | 18 +++++++++++-------
 1 file changed, 11 insertions(+), 7 deletions(-)

diff --git a/server/light_backtask/task/stacking_go.go b/server/light_backtask/task/stacking_go.go
index cffb7d49..ff0e955a 100644
--- a/server/light_backtask/task/stacking_go.go
+++ b/server/light_backtask/task/stacking_go.go
@@ -70,7 +70,7 @@ func (this *stackingCec) saveToDb(ds *f5.DataSet) bool {
 		ds.GetByName("idx"),
 		ds.GetByName("contract_name"),
 		ds.GetByName("event_name"))
-	idx := ds.GetByName("idx")
+	idx := q5.ToInt64(ds.GetByName("idx"))
 	txhash := ds.GetByName("txhash")
 	logIndex := ds.GetByName("log_index")
 	netId := ds.GetByName("net_id")
@@ -99,7 +99,7 @@ func (this *stackingCec) saveToDb(ds *f5.DataSet) bool {
 				{"log_index", logIndex},
 				{"net_id", netId},
 				{"contract_address", strings.ToLower(contractAddress)},
-				{"src_idx", idx},
+				{"src_idx", q5.ToString(idx)},
 				{"event_name", eventName},
 				{"account_address", p.Account},
 				{"token_address", p.Token},
@@ -111,9 +111,13 @@ func (this *stackingCec) saveToDb(ds *f5.DataSet) bool {
 			return false
 		}
 		if eventName == EVENT_NAME_STAKE_CEC {
-			this.applyStake(p)
+			if !this.applyStake(idx, p) {
+				return false
+			}
 		} else if eventName == EVENT_NAME_UNSTAKE_CEC {
-			this.applyUnstake(p)
+			if !this.applyUnstake(idx, p) {
+				return false
+			}
 		} else {
 			return false
 		}
@@ -124,17 +128,17 @@ func (this *stackingCec) saveToDb(ds *f5.DataSet) bool {
 				"param1": txhash,
 				"param2": netId,
 				"param3": eventName,
-				"param4": idx,
+				"param4": q5.ToString(idx),
 				"param5": contractAddress,
 			})
 	}
 	return true
 }
 
-func (this *stackingCec) applyStake(p *jccommon.ContractStakeAndUnstakeCecPo) bool {
+func (this *stackingCec) applyStake(idx int64, p *jccommon.ContractStakeAndUnstakeCecPo) bool {
 	return true
 }
 
-func (this *stackingCec) applyUnstake(p *jccommon.ContractStakeAndUnstakeCecPo) bool {
+func (this *stackingCec) applyUnstake(idx int64, p *jccommon.ContractStakeAndUnstakeCecPo) bool {
 	return true
 }