yyfbaloot/servers/fishhall/gatesink/user_coupontask.go

package gatesink

import (
	"bet24.com/log"
	"bet24.com/servers/coreservice/client"
	"bet24.com/servers/fishhall/protocol"
	game "bet24.com/servers/micros/game/proto"
	"encoding/json"
	"fmt"
)

// 用户券任务
func (this *user) getCouponTask(msg, data string) {
	resp := client.GetUserCouponTask(this.getUserId())
	if resp.List != nil {
		for _, v := range resp.List {
			if info := game.GetGame(v.GameId); info != nil {
				v.ChineseName = info.ChineseName
			}
		}
	}

	buf, _ := json.Marshal(resp)
	this.WriteMsg(msg, string(buf))
}

// 领取奖励
func (this *user) awardCouponTask(msg, data string) {
	var req protocol.AwardCouponTask_req
	if err := json.Unmarshal([]byte(data), &req); err != nil {
		retData := fmt.Sprintf("awardCouponTask Unmarshal data failed %v", data)
		log.Error(retData)
		this.WriteMsg(msg, retData)
		return
	}

	resp := client.AwardCouponTask(this.getUserId(), req.UserTaskId)
	if resp.RetCode != 1 {
		log.Debug("user.awardCouponTask failed %v", resp)
	}
	this.WriteMsg(msg, resp.Data)
}

// 修改临时上限
func (this *user) updateCouponTaskTmpLimit(msg, data string) {
	resp := client.UpdateCouponTaskTmpLimit(this.getUserId())
	if resp.RetCode != 1 {
		log.Debug("user.updateCouponTaskTmpLimit failed %v", resp)
	}
	this.WriteMsg(msg, resp.Data)
}