diamond query

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)
+}

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)
 }