feat: reward verify is ready

api/handler/chat_handler.go

@@ -152,7 +152,7 @@ func (h *ChatHandler) sendMessage(ctx context.Context, session types.ChatSession
 	}
 
 	if userVo.Calls <= 0 && userVo.ChatConfig.ApiKey == "" {
-		replyMessage(ws, "您的对话次数已经用尽，请联系管理员充值！")
+		replyMessage(ws, "您的对话次数已经用尽，请联系管理员或者点击左下角菜单加入众筹获得100次对话！")
 		replyMessage(ws, "![](/images/wx.png)")
 		return nil
 	}

api/handler/reward_handler.go

@@ -24,7 +24,7 @@ func NewRewardHandler(server *core.AppServer, db *gorm.DB) *RewardHandler {
 // Verify 打赏码核销
 func (h *RewardHandler) Verify(c *gin.Context) {
 	var data struct {
-		TxId string
+		TxId string `json:"tx_id"`
 	}
 	if err := c.ShouldBindJSON(&data); err != nil {
 		resp.ERROR(c, types.InvalidArgs)
@@ -34,12 +34,12 @@ func (h *RewardHandler) Verify(c *gin.Context) {
 	var item model.Reward
 	res := h.db.Where("tx_id = ?", data.TxId).First(&item)
 	if res.Error != nil {
-		resp.ERROR(c, "无效的打赏交易流水号！")
+		resp.ERROR(c, "无效的众筹交易流水号！")
 		return
 	}
 
 	if item.Status {
-		resp.ERROR(c, "当前打赏交易流水号已经被核销，请不要重复核销！")
+		resp.ERROR(c, "当前众筹交易流水号已经被核销，请不要重复核销！")
 		return
 	}
 
@@ -50,7 +50,7 @@ func (h *RewardHandler) Verify(c *gin.Context) {
 	}
 
 	tx := h.db.Begin()
-	calls := (item.Amount + 0.01) * 10
+	calls := (item.Amount + 0.1) * 10
 	res = h.db.Model(&user).UpdateColumn("calls", gorm.Expr("calls + ?", calls))
 	if res.Error != nil {
 		resp.ERROR(c, "更新数据库失败！")

api/main.go

@@ -107,7 +107,9 @@ func main() {
 		fx.Invoke(func(bot *wexin.WeChatBot) {
 			go func() {
 				err := bot.Login()
-				log.Fatal(err)
+				if err != nil {
+					log.Fatal(err)
+				}
 			}()
 		}),
 
@@ -188,7 +190,7 @@ func main() {
 		}),
 		fx.Invoke(func(s *core.AppServer, h *handler.RewardHandler) {
 			group := s.Engine.Group("/api/reward/")
-			group.GET("verify", h.Verify)
+			group.POST("verify", h.Verify)
 		}),
 
 		// 管理后台控制器