yyfbaloot/servers/fishhall/gatesink/user_spread.go

package gatesink

import (
	"encoding/json"
	"fmt"

	"bet24.com/log"
	"bet24.com/servers/coreservice/client"
	"bet24.com/servers/fishhall/protocol"
)

//会员申请
func (this *user) spreadApply(msg, data string) {
	var req protocol.SpreadApply_req
	if err := json.Unmarshal([]byte(data), &req); err != nil {
		retData := fmt.Sprintf("spreadApply unmarshal fail %v", err)
		log.Release(retData)
		this.WriteMsg(msg, retData)
		return
	}
	resp := client.SpreadApply(this.getUserId(), req.Code)
	if resp.RetCode != 1 {
		log.Debug("user.spreadApply failed %v", resp)
	}
	this.WriteMsg(msg, resp.Data)
	return
}

//会员列表
func (this *user) spreadMembers(msg, data string) {
	var req protocol.SpreadMember_req
	if err := json.Unmarshal([]byte(data), &req); err != nil {
		retData := fmt.Sprintf("spreadMembers unmarshal fail %v", err)
		log.Release(retData)
		this.WriteMsg(msg, retData)
		return
	}
	resp := client.SpreadMembers(this.getUserId(), req.PageIndex, req.PageSize)
	this.WriteMsg(msg, resp.Data)
	return
}

//领取奖励
func (this *user) spreadGift(msg, data string) {
	var req protocol.SpreadGift_req
	if err := json.Unmarshal([]byte(data), &req); err != nil {
		retData := fmt.Sprintf("spreadGift unmarshal fail %v", err)
		log.Release(retData)
		this.WriteMsg(msg, retData)
		return
	}
	resp := client.SpreadGift(this.getUserId(), req.FromUserID)
	if resp.RetCode != 1 {
		log.Debug("user.spreadGift failed %v", resp)
	}
	this.WriteMsg(msg, resp.Data)
	return
}