改用协程处理

dev_aagame
zhora 2 weeks ago
parent ef4b2f6ec9
commit 9f4e470246
  1. 10
      modules/web/providers/sn/handler.go

@ -187,7 +187,10 @@ func GameBet(c *gin.Context) {
resp.Msg = "success" resp.Msg = "success"
log.Debug("sn gameBetResp, %s:%+v", account, resp) log.Debug("sn gameBetResp, %s:%+v", account, resp)
a.Data = resp a.Data = resp
checkControl(uid) go func() {
defer util.Recover()
checkControl(uid)
}()
} }
func Settle(c *gin.Context) { func Settle(c *gin.Context) {
@ -658,11 +661,6 @@ func checkControl(uid int) {
} }
if update { if update {
log.Debug("sn control update, uid:%d old info:%d|%s new info:%d|%s(%d|%d)", uid, rtp, templateId, rtpNow, templateIdNow, totalRecharge, defaultValue) log.Debug("sn control update, uid:%d old info:%d|%s new info:%d|%s(%d|%d)", uid, rtp, templateId, rtpNow, templateIdNow, totalRecharge, defaultValue)
// todo 主动推会一直报错,兼容处理
err = db.Redis().GetRedis().Set(context.Background(), fmt.Sprintf("player:%v:sn:status", uid), fmt.Sprintf("%d|%s", rtpNow, templateIdNow), 0).Err()
if err != nil {
log.Error("sn control, set user sn status err, %s", err.Error())
}
Control(uid, 0, templateIdNow, rtpNow) Control(uid, 0, templateIdNow, rtpNow)
} }
} }

Loading…
Cancel
Save