From 32a0445b1ff04077a59258f2caa7b7fc5cbf509b Mon Sep 17 00:00:00 2001
From: yangduo <yangduo@kingsome.cn>
Date: Fri, 2 Aug 2024 15:35:03 +0800
Subject: [PATCH] diamond query

---
 .../marketserver/api/v1/activity/stacking.go  | 41 +++++++++++++++++++
 .../marketserver/router/activity/stacking.go  |  2 +
 2 files changed, 43 insertions(+)

diff --git a/server/marketserver/api/v1/activity/stacking.go b/server/marketserver/api/v1/activity/stacking.go
index 5f015acc..4d327f9c 100644
--- a/server/marketserver/api/v1/activity/stacking.go
+++ b/server/marketserver/api/v1/activity/stacking.go
@@ -125,3 +125,44 @@ func (sa *StackingApi) ContributionQuery(c *gin.Context) {
 	}
 	c.JSON(200, rspObj)
 }
+
+func (sa *StackingApi) DiamondRecordQuery(c *gin.Context) {
+	accountAddress := strings.ToLower(c.Param("account_address"))
+	rspObj := struct {
+		ErrCode int32         `json:"errcode"`
+		ErrMsg  string        `json:"errmsg"`
+		Rows    []interface{} `json:"rows"`
+	}{}
+
+	{
+		sql := `SELECT * FROM t_diamond WHERE account_address = ? ORDER BY createtime DESC`
+		params := []string{
+			accountAddress,
+		}
+
+		f5.GetGoStyleDb().RawQuery(
+			constant.BCNFT_DB,
+			sql,
+			params,
+			func(err error, ds *f5.DataSet) {
+				if err != nil {
+					return
+				}
+
+				obj := struct {
+					Date   int32  `json:"date"`
+					Amount string `json:"amount"`
+					Type   int32  `json:"type"`
+				}{}
+
+				for ds.Next() {
+					obj.Date = q5.SafeToInt32(ds.GetByName("createtime"))
+					obj.Amount = ds.GetByName("amount")
+					obj.Type = q5.SafeToInt32(ds.GetByName("type"))
+					rspObj.Rows = append(rspObj.Rows, obj)
+				}
+			})
+	}
+
+	c.JSON(200, rspObj)
+}
diff --git a/server/marketserver/router/activity/stacking.go b/server/marketserver/router/activity/stacking.go
index b07b9197..ae90debf 100644
--- a/server/marketserver/router/activity/stacking.go
+++ b/server/marketserver/router/activity/stacking.go
@@ -13,4 +13,6 @@ func (this *StackingRouter) InitRouter() {
 		api.StackingApi.ExpectedDaily)
 	f5.GetApp().GetGinEngine().GET("/api/activity/stacking/history/:account_address",
 		api.StackingApi.ContributionQuery)
+	f5.GetApp().GetGinEngine().GET("/api/activity/diamond/history/:account_address",
+		api.StackingApi.DiamondRecordQuery)
 }