From 7834d87d14cbb1b982a51f592894781c082ad9bc Mon Sep 17 00:00:00 2001
From: aozhiwei <aozhiwei@kingsome.cn>
Date: Wed, 24 Jul 2024 10:00:29 +0800
Subject: [PATCH] 1

---
 server/light_backtask/task/chain_activity.go | 19 +++++++++++++++++--
 third_party/q5                               |  2 +-
 2 files changed, 18 insertions(+), 3 deletions(-)

diff --git a/server/light_backtask/task/chain_activity.go b/server/light_backtask/task/chain_activity.go
index 3e6511a2..3fa8aa16 100644
--- a/server/light_backtask/task/chain_activity.go
+++ b/server/light_backtask/task/chain_activity.go
@@ -88,10 +88,14 @@ func (this* chainActivity) saveToDb(ds *f5.DataSet) bool {
 	returnValues := ds.GetByName("return_values")
 	createTime := ds.GetByName("createtime")
 	modifyTime := ds.GetByName("modifytime")
+	itemId := 0
+	quality := 0
+
 	if eventName == "Lock" {
 		p := new(lockReturnValues)
 		if q5.DecodeJson(returnValues, p) == nil {
 			for _, tokenId := range p.TokenIds {
+				var dbErr error
 				f5.GetGoStyleDb().Upsert(
 					constant.BCEVENT_DB,
 					"t_chain_activity",
@@ -116,12 +120,17 @@ func (this* chainActivity) saveToDb(ds *f5.DataSet) bool {
 						{"src_idx", idx},
 						{"sender_address", strings.ToLower(p.Sender)},
 						{"to_address", strings.ToLower(p.To)},
+						{"item_id", q5.ToString(itemId)},
+						{"quality", q5.ToString(quality)},
 						{"createtime", createTime},
 						{"modifytime", modifyTime},
 					},
 					func (err error, lastInsertId int64, rowsAffected int64) {
-
+						dbErr = err
 					})
+				if dbErr != nil {
+					return false
+				}
 			}
 		}
 	} else if eventName == "UnLock" {
@@ -135,6 +144,7 @@ func (this* chainActivity) saveToDb(ds *f5.DataSet) bool {
 				if nft[2].(bool) {
 					isMint = 1
 				}
+				var dbErr error
 				f5.GetGoStyleDb().Upsert(
 					constant.BCEVENT_DB,
 					"t_chain_activity",
@@ -159,13 +169,18 @@ func (this* chainActivity) saveToDb(ds *f5.DataSet) bool {
 						{"src_idx", idx},
 						{"sender_address", strings.ToLower(sender)},
 						{"to_address", strings.ToLower(to)},
+						{"item_id", q5.ToString(itemId)},
+						{"quality", q5.ToString(quality)},
 						{"is_mint", q5.ToString(isMint)},
 						{"createtime", createTime},
 						{"modifytime", modifyTime},
 					},
 					func (err error, lastInsertId int64, rowsAffected int64) {
-
+						dbErr = err
 					})
+				if dbErr != nil {
+					return false
+				}
 			}
 		}
 	} else {
diff --git a/third_party/q5 b/third_party/q5
index ad5656a0..d40b258a 160000
--- a/third_party/q5
+++ b/third_party/q5
@@ -1 +1 @@
-Subproject commit ad5656a00af63ca9da8e4dc20d75c9f9a3324786
+Subproject commit d40b258a47c4fd8f74a2afe6b856827a3cd3253b