RoServer/RO_Server_Trunk-branch_0.1.39/roserver/game/model/role.go

package model

import (
	"crypto/md5"
	"encoding/hex"
	"encoding/json"
	"errors"
	"fmt"
	"math"
	"math/rand"
	"reflect"
	_ "rocommon/rpc"
	"rocommon/service"
	"rocommon/util"
	"roserver/baseserver/model"
	"roserver/serverproto"
	"sort"
	"strconv"
	"strings"
	"time"
	"unicode/utf8"
)

var TmpLeaseId int64 = 0

type RoleOuter interface {
	model.StateMachine
	ReqAckConfirm(msgId, seqId uint32)
	SetOpenId(openId string)
	GetOpenId() string
	SetSelectZone(selectZone int32) //玩家当前选择的服务器，用户合服操作
	GetSelectZone() int32
	SetCliID(cId model.ClientID)
	SetCliIDSessionID(sessionID uint64)
	ReplayGate(msg interface{}, transmit bool) int
	GetUUid() uint64
	GetNickName() string
	GetImageId() int32
	KickNotSave(err int32)
	KickWithSave(err int32)
	LoginAck(err serverproto.ErrorCode)
	Load(role *serverproto.Role) error
	LoadOther(msg interface{}) error //load加载之后加载数据
	Update(ms uint64)
	DailyReset(notify bool)
	SetUpdateDailyReset(ms uint64, bReset bool)
	CliID() model.ClientID
	SetCreateData(msg *serverproto.CSCreateRoleReq)
	IsLogout(ms uint64) bool
	Logout()
	Save()
	SetReLogin(re bool)
	BanRole(isBan bool, banTime uint64, cheatType int32)
	BanRoleChat(isBan bool, banTime uint64, cheatType int32)
	SetPlatform(platform string)
	GetPlatform() string
	SetSubPlatform(subPlatform string)
	GetSubPlatform() string
	SetClientParam(clientInfo *serverproto.ClientParamInfo)
	GetClientParam() *NeteaseLogCommonInfo
	SetClientIP(ip string)
	GetClientIP() string
	GetHardFight() int
	SetHardFight(b int)
	SetYuanRankScore()
	SetSdkJson(a string)
	SetSdkJson2(a string)
	GetSdkJson() string
}

// 逻辑操作主接口(可以按照每个系统设定一个接口)
type RoleLogicOuter interface {
	AddMoney(st AddItemST, add bool)
	AddBaseExp(st AddItemST) bool
	AddJobExp(st AddItemST) bool
	AddHeroExp(st AddItemST, add bool) bool
	AddAttrPoint(heroID int32, point interface{})
	AddRes(resType int32, st AddItemST, add bool)
	//AddItem(configId int32, count int32, addFrom int32)
	ResetAttrPoint(heroID int32)
	ActiveHead(headId int32)
	SetRoleHeadPic(headId int32)
	HeadInfoReq()
	SetRoleHeadFrameId(frameId int32)
	GetRoleHeadFrameInfo()
	UseHeadFrameItem(itemId uint64, itemNum uint32)
	ChangeRoleName(name string)
	SetRoleGuide(guideId int32)
	SetRoleStory(story *serverproto.KeyValueType)
	SetMapCartoon(id, status int32)
	OnAddQualityPoint(msg *serverproto.CSAddQualityPointReq)
	//hero
	AddHero(configId int32) bool
	HeroLevelUp(id int32) bool
	HeroAdvance(id int32) bool
	HeroBattle(id int32, isBattle bool)
	HeroStrength(id int32) bool
	HeroChangeJob(heroId int32, jobId int32) bool
	HeroRecruit(configId int32)
	FightPowerReq(heroId int32)
	HeroReplaceJob(heroId int32, replaceJob int32)
	//equip
	EquipForge(equipId, once, equipType, subEquipType int32)
	AddEquip(configId, num int32, notify bool, ignore bool)
	EquipUp(heroId, slotType, equipId int32)
	EquipDown(heroId int32, subIndex int32)
	EquipLevelUpAll(heroId int32)
	EquipSlotLevelUp(heroId, subSlotIndex int32)
	ComposeChip(configId int32)
	ChipDecompose(cardList []*serverproto.KeyValueType, cardType []int32)

	//skill equip
	SkillEquipSlotLevelUp(heroId, subIndex int32)
	SkillEquipStarLevelUp(heroId int32, skillEquipId uint32, cost []uint32)
	SkillEquipUp(heroId int32, skillEquipId uint32, slotIndex int32)
	SkillEquipDown(heroId int32, slotIndex int32)
	SkillEquipDecompose(skillEquipIds []uint32)
	SkillEquipRemade(skillEquipId uint32)
	GetSkillEquipPool()
	SkillEquipShift(msg *serverproto.CSSkillEquipShiftReq)

	//card
	CardMount(heroId, subSlotIndex, cardSlotIndex, cardCfgId int32)
	CardDown(heroId, subSlotIndex, cardSlotIndex int32)
	CardMountAll(msg *serverproto.CSCardEquipAllReq)
	CardDownAll(heroId int32)
	CardUpGradeAll(msg *serverproto.CSCardUpGradeAllReq)
	CardCollect()
	CardCollectReward(cardId, level int32)
	CardCompose(cardList []int32)
	CardDecompose(cardList []*serverproto.KeyValueType, cardType int32)
	CardUpGrade(msg *serverproto.CSCardUpGradeReq)
	CardLevelExchange(sourceCardId, targetCardId int32)
	//skill
	SkillReplace(heroId, idx, replaceSkillId int32)
	ActiveSkill(heroId int32, skillId int32)
	SwapSkill(heroId, firstSlotId, secondSlotId int32)
	SetSkillList(heroId int32, skillList []int32)
	SkillLevelUp(heroId int32, skillId int32)
	ResetSkillLevel(heroId int32, bsuper bool)
	ConverSkillExp(msg *serverproto.CSConverSkillExpReq)
	//fashion
	FashionUp(fashionCfgId []int32)
	FashionDown(fashionCfgId []int32)
	FashionCompose(paperCfgId int32)
	FashionPaperDecompose(paperCfgId int32)
	FashionResetAttr(fashionId int32, enter bool)
	FashionUpLvl(fashionId int32)
	//商店
	BuyItem(shopId, goodsId, goodsNum int32)
	ShopInfoReq(goodsType int32)
	ShopRefresh(goodsType int32)
	RedBagShopExchange()

	//task
	GetTaskReward(taskId uint32)
	GetTaskScoreReward(rewardType, rewardIdx int32)

	//item
	UseItem(itemId uint64, itemNum uint32, itemIdxList []int32, bForceItemId bool)
	DelItemByList(itemId []uint64, delFrom AddFromType)

	//chat
	CheckChatInvalid(targetId uint64, msgType int32, msg *serverproto.CSChatMessageReq) bool
	GetOfflineMsg(targetId uint64)

	//英灵殿
	GetArena()
	ArenaMatch(heroList []int32)
	ArenaResult(result int32)
	ArenaByCount(buyCount int32)
	ArenaRankList(rankType, startIdx int32)
	SetArenaRank(rankIdx int32, notify bool)

	//mail
	GetMailIst()
	MailRead(idList []int32)
	MailReward(idList []int32)
	MailDelRead()
	AddMail(configId int32, mailType serverproto.MailType, itemList map[int32]int32, paramList []int32,
		title, content string)
	AddMail1(configId int32, mailType int32, itemList []*serverproto.KeyValueType, paramList []int32,
		title, content string)

	//competition
	GetCompetition(competitionId int32)                       //competitionId为0表示获得当前正在进行的赛季
	CompetitionAddScore(itemList []*serverproto.KeyValueType) //上交道具获取积分

	VoteIdol(uid uint64, ticketCount int32)
	CheckInSeason() (serverproto.ErrorCode, int32)
	GetSelfVoteData(ackMsg *serverproto.SCCompetitionFansRewardRankAck)
	CheckFansReward(uid uint64, rewardLevel int32) serverproto.ErrorCode
	GetFansReward(idolUid uint64, rewardLevel int32, boxCount int32)

	CompulsoryGuidance(storyId, status int32) //强制引导
	//ClimbingTower 爬塔/无尽试炼
	ClimbingTowerInfoReq()
	GetFriendTowerInfo(begin, end int32)
	ClimbingTowerBegin(towerLevel int32)
	ClimbingTowerEnd(towerLevel, loadingTime int32, recordTimeStamp uint64)
	GetFriendBriefFromDB(final bool, begin int32, end int32, briefs []*serverproto.CommonPlayerBriefInfo)
	ClimbingTowerWjBegin(towerLevel int32)
	ClimbingTowerWjBuff(buff1, buff2, buff3 int32)
	ClimbingTowerWjEnd(towerLevel, loadingTime int32, recordTimeStamp uint64)

	//冲榜相关
	GetTowerFightCountReward(rushRound int32, rewardType int32)
	GetRushTowerInfo(ackMsg *serverproto.SCTowerActivityAck, curRushRound int32)
	GetRushTowerRankReward(ssAck *serverproto.SSGetRushRewardAck)

	GetArenaFightCountReward(rushRound int32, rewardType int32)
	GetRushArenaInfo(ackMsg *serverproto.SCArenaActivityAck, curRushRound int32)
	GetRushArenaRankReward(ssAck *serverproto.SSGetRushRewardAck)

	GetRushMapLevelReward(rushRound int32, rewardType int32)
	GetRushMapInfo(ackMsg *serverproto.SCMapActivityAck, curRushRound int32)
	GetRushMapRankReward(ssAck *serverproto.SSGetRushRewardAck)

	GetPetFightCountReward(rushRound int32, rewardType int32)
	GetRushPetInfo(ackMsg *serverproto.SCPetActivityAck, curRushRound int32)
	GetRushPetRankReward(ssAck *serverproto.SSGetRushRewardAck)

	GetFightCountReward(rushRound int32, rushType int32, rewardType int32)
	GetRushInfo(ackMsg *serverproto.SCRushActivityAck, curRushRound int32)
	GetRushRankReward(ssAck *serverproto.SSGetRushRewardAck)

	GetRushShopInfo(ackMsg *serverproto.SSGetRushShopInfoAck)
	//guild公会相关操作
	CheckBuildGuild(guildName string, guildBadge int32) serverproto.ErrorCode
	CheckApplyGuild(guildId uint64) bool
	CheckApplyInfo(msg *serverproto.CSApplyInfoHandleReq) serverproto.ErrorCode
	CheckGuildModifyInfo(msg *serverproto.CSSetGuildInfoReq) serverproto.ErrorCode
	CheckGuildRename(guildName string) serverproto.ErrorCode
	CheckGuildRenotice(notice string) serverproto.ErrorCode
	OnChangeGuileNameSuccess()
	CheckGuildBossChallenge(bossId uint32, damage uint32, fightTime uint32) serverproto.ErrorCode
	GetRoleGuildId() uint64
	GuildDemonBuyFightCount(buyCount int32)

	PackRoleViewInfo(info *serverproto.ViewRoleInfo)

	//获取战斗记录
	GetBattleRecord(recordType int32, paramList []uint32)

	//宠物
	PetLevelUp(petId uint32)
	PetAdvance(petId uint32, petList []uint32)
	PetManualReward(petCfgId, petId, advLevel int32)
	PetSkillLevelUp(petId uint32, costPetId uint32)
	PetDecompose(petIdList []uint32)
	PetBattle(battleList []*serverproto.KeyValueType)
	PetBondListGet()
	PetAssist(petIdList []uint32)
	PetBondAssistListGet(bondCfgId int32)
	PetBondActive(bondData []*serverproto.PetBondData)
	PetAdvAchievement(petCfgId int32)
	PetEquipLevelUp(petEquipId uint32)
	PetEquipUp(petId uint32, slotIndexList []*serverproto.KeyValueType)
	PetEquipDown(petId uint32, slotIndex int32)
	PetGetPetDetailInfo(petIdList []uint32)
	PetQiyueUnlock(heroId int32)
	PetQiyueSlotIn(heroId, slotIdx int32, petId uint32)
	PetQiyueSlotOut(heroId, slotIdx int32)
	PetQiyueBattlePetAttr()

	//精彩活动Activities
	ActivitiesReward(activityId, param, rewardNum int32)
	ActivitiesScoreReward(activityId, boxId int32)
	ActivitiesFirstChargeReward()
	ActivitiesExchange(msg *serverproto.CSActivitiesExchangeReq)
	ActivityWheelRefresh(activityId int32)
	ActivityWheelOpenReward(activityId int32)
	ActivityWheelReward(activityId int32, rewardAll bool)
	ActivityWheelClose(activityId int32)
	ActivitySummon(activityId, summonCount int32)
	ActivitySignIn(activityId int32)
	SetCollectionNotice(activityId int32, CollectId int32, notice bool)
	ActivitySmashEggs(activityId, drawType, drawCount int32)
	ActivitySmashEggsMsg(activityId, drawType int32)

	//invitation
	InvitationNumberGet()
	InvitationNumberUserInfoGet(number uint64)
	InvitationBeToMember(number, uid uint64)
	InvitationReward(taskIdList []uint32)
	InvitationClick(memberUidList []uint64)
	InvitationClickReplay(replayMasterUid uint64)
	InvitationDelMember(memberUidList []uint64)

	//vip等级获取
	GetRoleVipLevel() int32

	//pay
	CheckRushShopInfoGet(goodsType, goodsId, count int32) bool
	PayInfoGet(goodsType, goodsId, count int32, rushStage, rushRound int32, cpOrderId uint64, sdkOrderId string)
	OnPayCallback(payRewardInfo *serverproto.PayOrderSaveInfo, bSave bool, bAck, bcash bool)
	OnPayCallback2(cpOrderId uint64)
	CheckOrderInfo(payRewardInfo *serverproto.PayOrderSaveInfo) bool

	//卢恩商会
	GetRuneShopInfo(shopType int32, subShop int32)
	OnRuneExploreInfo()
	OnRuneMaxLvlAward()
	OnRuneReward(msg *serverproto.CSExploreRewardReq)

	//抽卡
	OnDrawReq(drawType int32, drawCount int32)

	GetResNotice(resType int32) serverproto.ErrorCode

	//百人道场
	GetDaoChang100SelfPosInfo(msg *serverproto.CSDaoChang100PlayerInfoReq)
	GetDaoChang100PosInfo(posIdxList []int32)
	GetDaoChang100Log(beginTime uint64)
	DaoChang100ChallengeReq(posIdx int32)
	DaoChang100TimeRewardReq()
	DaoChang100ChallengeResultReq(msg *serverproto.CSDaoChang100ChallengeResultReq)
	DaoChang100BuyChallengeCount()
	DaoChang100SetTips(tipDesc string)

	OnAntiCheatReq(cheatType int32)
	GiftReward(ackMsg *serverproto.SCGiftRewardAck)

	//问卷奖励获取
	QuestionReward()

	GetKeepSake()
	KeepSakeLevelUp(keepSakeId int32)

	// 称号操作
	OnHeadOperate(*serverproto.CSHeadOperateReq)
	OnHeadData(req *serverproto.CSHeadDataReq)

	// 许愿箱
	OnWishUse(*serverproto.CSWishBoxUseReq)
	OnWishSlotUnlock(*serverproto.CSWishUnlockSlotReq)
	OnWishSlotAction(req *serverproto.CSWishSlotReq)

	GetCombineServerInfo()
}

type BattleLogicOuter interface {
	//income
	Income()
	OnlineTimeReward() //累计在线时间奖励获取
	BossReward(challengeTime uint32, mapId, mapLevel uint32, recordTimeStamp uint64)
	BattleBossReq()

	//mapRank
	SetMapRank(selfRank, totalRanks uint32, topRankList []*serverproto.RankPlayerInfo, addSystemMsg bool)
	GetMapRank()

	GetQuickBattleReward()

	//Evil
	BattleEvilRefresh(bForce bool)
	BattleEvilChallenge(posIdx int32)

	//expedition
	ExpeditionChallengePre(expeditionType int32)
	ExpeditionChallenge(expeditionType, battleLevel int32, heroInfoList []*serverproto.BattleExpeditionActor,
		bossChangeHpList []*serverproto.BattleExpeditionActor, battleTime int32, bossIdx, flag int32)
	ExpeditionBuffSelect(selectBuf int32)
	ExpeditionReward(expeditionType, boxIdx int32)
	ExpeditionBattleHero(battleHeroList []int32)
	ExpeditionCallForHelp(assistHelpUid uint64)
	ExpeditionHelp(beHelpedUid uint64, msgType int32, helpMsgSendTime uint64)
	ExpeditionScoreRankList(startIdx int32)

	//actor attr(获取英雄属性，宠物属性)
	GetActorAttr(reqMsg *serverproto.CSActorAttrGetReq)
}

type CrossLogicOuter interface {
	//远航试炼
	YuanHangTrialViewList()
	//刷新远航试炼品质
	RefreshYuanHangTrialType(force bool)
	//发起远航试炼
	YuanHangTrial()
	YuanHangTrialReward()
	YuanHangTrialChallenge(challengeUid, challengeUidEndTime uint64)
	YuanHangTrialChallengeBuy()
	YuanHangTrialChallengeResult(msg *serverproto.CSCrossYuanHangTrialChallengeResultReq)
	YuanHangTrialInfoQuery(trialUid, trialEndTime uint64)
	YuanHangTrialLog(logTime uint64)
	//from router
	OnYuanHangTrialChallengeResult(msg *serverproto.SSCrossYuanHangTrialChallengeResultAck)
	YuanHangTrialRankList(startIdx int32)

	//巅峰之塔
	//获取挑战列表
	TopTowerFightListReq()
	//战斗结果通知
	TopTowerChallengeResultReq(bWin bool, fightIdx int32)
	//买路操作(直接胜利)
	TopTowerForceWinReq(fightIdx int32)
}

// //全局跨服地图相关
type RoleCrossMapRouter interface {
	PlayerEnterMap(msg *serverproto.CSGCrossPlayerEnterMapReq)
	PlayerLeave(msg *serverproto.CSGCrossPlayerLeaveMapReq)
	PlayerMoveSync(msg *serverproto.CSGCrossPlayerMapSyncPosReq)
	PlayerSyncParam(msg *serverproto.CSGCrossPlayerMapSyncParamReq)

	//获取玩家地图展示信息
	GetPlayerMapShowInfo() *serverproto.PlayerShowInfo
}

// // bt服务器版本使用
type RoleBTRouter interface {
	// 充值钱包商店购买(假钱购买)
	PayInfoGetForCreditRecharge(goodsId, count int32)
	// 特权卡商店每日礼包领取
	SpecialPrivilegeReward()
	// 充值钱包商店,Ro币礼包商店
	GetBTShopInfo(shopType int32, subShop int32)
	// Ro币礼包商店购买(消耗RO币)
	PayInfoGetForRoCoin(goodsId, count int32)

	// 获取爬塔馈赠奖励
	GetTowerLevelDayReward()

	// 波利商城
	BoliShopInfo()
	BoliLevelUp(num int32)
	BoliReward(RewardLevel, idx int32)
	BoliShopBuy(goodsId, num int32)

	//超值首充 & 百元大礼包
	FirstRechargeReward(rewardIdx int32)
	Recharge100Reward()
}

type RoleSaveObject interface {
	Load(msg interface{}) bool
	Save()
	IsDirty() bool
	SetDirty(b bool)
}

const (
	SLOT_NUM                  = 4 //4个上阵位置
	SLOT_TYPE_NUM             = Equip_Type_Max - 1
	SKILL_EQUIP_SLOT_TYPE_NUM = Skill_Equip_Type_Max - 1
)

// 任务唯一id
var timeWheelKeyUid uint64 = 1

type SaveObject struct {
	isDirty bool
	role    *Role
}

func (this *SaveObject) IsDirty() bool {
	return this.isDirty
}
func (this *SaveObject) SetDirty(b bool) {
	if this.isDirty == b {
		return
	}
	this.isDirty = b
	if this.isDirty {
		if this.role.twTask == nil {
			timeWheelKeyUid++
			this.role.twTask = &util.TWTask{
				Uid:          this.role.GetUUid(),
				Key:          timeWheelKeyUid,       //任务唯一id
				CallbackType: util.TWTASK_TYPE_Save, //表示save操作
				Delay:        20,
			}
		}
		RoleMag.tw.AddTask(this.role.twTask)
	}
}

type Role struct {
	model.StateMachineCore
	soList []RoleSaveObject
	//在upate中标记是否需要重置，随后再每个玩家自身的update中进行reset操作，降低
	//同一时间的reset操作次数
	dailyResetTimer   util.OnceTimer
	twTask            *util.TWTask
	mysqlLogList      []*serverproto.SSRoleLogData //mysql数据保存
	mysqlLogSaveTimer util.DurationTimer

	reqAckConfirmList map[uint32][]uint32
	cliID             model.ClientID //在Gate上的信息
	dbNode            string         //选择处理信息的db节点
	socialNode        string         //选择处理信息的social节点
	//aoiNode           string         //aoi服务器节点(工会主城只会有一个)
	bossNode  string //BattleBoss服务器节点
	rankNode  string //Rank服务器节点
	guildNode string //Guild服务器接点

	platform        string                //平台
	subPlatform     string                //平台对应不同分发媒体
	clientParamInfo *NeteaseLogCommonInfo //客户端上报信息
	clientIp        string                //客户端IP
	tmpState        bool                  //临时控制使用

	selectZone   int32                               ////玩家当前选择的服务器，用户合服操作
	uuid         uint64                              //Role的用户ID
	openId       string                              //平台账号
	RegisterTime uint64                              //注册时间
	UuidList     []uint64                            //用户拥有的所有角色ID
	UuidRoleList map[uint64]*serverproto.AccountRole //用户拥有的所有角色数据AccountRole
	SelectedUuid uint64                              //用户选择的角色ID
	reLogin      bool                                //是否是重新登陆
	isLoad       bool                                //是否已经加载过
	activeCode   string                              //激活码
	isHardFight  int                                 //是否是困难模式 //0普通.1困难,2噩梦
	Guid         string                              //小七uid
	Guid2        string                              //小七uid

	base            *RoleBase    //角色基础信息
	roleHero        *RoleHero    //伙伴信息
	roleBag         *RoleBag     //角色背包信息
	roleEquip       *RoleEquip   //装备信息
	roleChip        *RoleChip    //英雄碎片信息
	roleMap         *RoleMap     //地图信息
	roleSkill       *RoleSkill   //技能信息
	roleCard        *RoleCard    //卡片系统
	roleFashion     *RoleFashion //时装
	roleBattle      *RoleBattle  //战斗相关信息
	roleTask        *RoleTask    //任务系统
	roleChat        *RoleChat
	roleArena       *RoleArena       //竞技场
	roleRed         *RoleRed         //小红点
	roleMail        *RoleMail        //邮件
	roleShop        *RoleShop        //
	roleCompetition *RoleCompetition //赛季
	roleSocial      *RoleSocial      //social相关(friend)
	roleActivity    *RoleActivity    //活动信息
	roleTower       *RoleTower       //爬塔
	roleGuild       *RoleGuild       //公会
	rolePet         *RolePet         //宠物
	roleInvitation  *RoleInvitation  //邀请码功能
	roleDraw        *RoleDraw        //抽取系统
	roleRune        *RoleRune        //卢恩商店
	roleDaoChang100 *RoleDaoChang100 //百人道场
	roleStatistic   *RoleStatistic   //统计数据
	roleKeepSake    *RoleKeepSake
	roleSkillEquip  *RoleSkillEquip //神器系统
	roleCross       *RoleCross      //跨服数据
	roleRush        *RoleRush       //跨服数据
	roleBattleAttr  *RoleBattleAttr //战斗属性计算，每个玩法的属性都放到该类中处理
	roleHead        *RoleHead       // 称号数据
	roleWish        *RoleWishBox    // 许愿箱
	roleBT          *RoleBT         // bt版本数据
	delete          bool
	delete1         bool
	delete2         bool

	saveTimer    util.DurationTimer //保存数据定时器
	offlineTimer util.OnceTimer     //离线定时器

	lastProcessTime uint64 //无数据操作
}

var roleSaveTimeout time.Duration = 500               //保存数据的间隔时间
var roleOfflineTimeout time.Duration = 30 * 60 * 1000 //
var mysqlSaveTimeout time.Duration = 2000

func NewRole(cId model.ClientID) RoleOuter {
	role := &Role{
		reqAckConfirmList: map[uint32][]uint32{},
		cliID:             cId,
		uuid:              0,
		reLogin:           false,
	}
	//初始化角色信息
	role.Init()

	return role
}

func (this *Role) Init() {
	this.UuidRoleList = map[uint64]*serverproto.AccountRole{}
	//初始化角色状态机
	this.InitState()
	this.RegisterState(int32(ROLE_STATE_PULLING_LIST), pullingRoleList)
	this.RegisterState(int32(ROLE_STATE_PULLED_LIST), pulledRoleList)
	this.RegisterState(int32(ROLE_STATE_CREATE), createRole)
	this.RegisterState(int32(ROLE_STATE_DB_ADD_ROLE_SUCCESS), createDbRoleSuccess)
	this.RegisterState(int32(ROLE_STATE_DB_ADD_ROLE_FAILURE), createDbRoleFailure)
	this.RegisterState(int32(ROLE_STATE_SELECT_ROLE), SelectingRole)
	this.RegisterState(int32(ROLE_STATE_SELECT_ROLE_SUCCESS), SelectRoleSuccess)
	this.RegisterState(int32(ROLE_STATE_ONLINE), RoleOnline)
	this.RegisterState(int32(ROLE_STATE_OFFLINE), RoleOffline)

	this.roleBattleAttr = newRoleBattleAttr(this)

	//this.base = roleBasePool.Get().(*RoleBase)
	this.base = newRoleBase()
	this.base.role = this

	this.roleHero = newRoleHero(this)
	this.roleBag = newRoleBag(this)
	this.roleEquip = newRoleEquip(this)
	this.roleChip = newRoleChip(this)
	this.roleMap = newRoleMap(this)
	this.roleSkill = newRoleSkill(this)
	this.roleCard = newRoleCard(this)
	this.roleFashion = newRoleFashion(this)
	this.roleBattle = newRoleBattle(this)
	this.roleTask = newRoleTask(this)
	//this.roleFightPower = newRoleFightPower(this)
	this.roleChat = newRoleChat(this)
	this.roleArena = newRoleArena(this)
	this.roleMail = newRoleMail(this)
	this.roleRed = newRoleRed(this)
	this.roleShop = newRoleShop(this)
	this.roleCompetition = newRoleCompetition(this)
	this.roleSocial = newRoleSocial(this)
	this.roleActivity = newRoleActivity(this)
	this.roleTower = newRoleTower(this)
	this.roleGuild = newRoleGuild(this)
	this.rolePet = newRolePet(this)
	this.roleInvitation = newRoleInvitation(this)
	this.roleDraw = newRoleDraw(this)
	this.roleRune = newRoleRune(this)
	this.roleDaoChang100 = newRoleDaoChang100(this)
	this.roleStatistic = newRoleStatistic(this)
	this.roleKeepSake = newRoleKeepSake(this)
	this.roleCross = newRoleCross(this)
	this.roleRush = newRoleRush(this)
	this.roleSkillEquip = newRoleSkillEquip(this)
	this.roleHead = newRoleHead(this)
	this.roleWish = newRoleWish(this)
	this.roleBT = newRoleBT(this)

	this.soList = append(this.soList,
		this.base,
		this.roleHero,
		this.roleBag,
		this.roleCard,
		this.roleEquip,
		this.roleChip,
		this.roleMap,
		this.roleMap,
		this.roleSkill,
		this.roleFashion,
		this.roleBattle,
		this.roleTask,
		this.roleChat,
		this.roleArena,
		this.roleMail,
		this.roleRed,
		this.roleShop,
		this.roleCompetition,
		this.roleSocial,
		this.roleActivity,
		this.roleTower,
		this.roleGuild,
		this.rolePet,
		this.roleInvitation,
		this.roleDraw,
		this.roleRune,
		this.roleDaoChang100,
		this.roleStatistic,
		this.roleKeepSake,
		this.roleRush,
		this.roleCross,
		this.roleSkillEquip,
		this.roleHead,
		this.roleWish,
		this.roleBT,
	)
}

//func (this *Role) SetIsChallenge(b bool) {
//	this.isChallenge = b
//}
//
//func (this *Role) GetIsChallenge() bool {
//	return this.isChallenge
//}

func (this *Role) ReqAckConfirm(msgId, seqId uint32) {
	this.reqAckConfirmList[msgId] = append(this.reqAckConfirmList[msgId], seqId)
}

func (this *Role) SetOpenId(openId string) {
	this.openId = openId
}
func (this *Role) GetOpenId() string {
	return this.openId
}

func (this *Role) GetHardFight() int {
	return this.isHardFight
}
func (this *Role) GetSdkJson() string {
	return this.Guid
}
func (this *Role) SetSdkJson(a string) {
	this.Guid = a
}
func (this *Role) SetSdkJson2(a string) {
	this.Guid2 = a
}
func (this *Role) SetSelectZone(selectZone int32) {
	if selectZone <= 0 {
		this.selectZone = int32(service.GetServiceConfig().Node.Zone)
	} else {
		this.selectZone = selectZone
	}
}
func (this *Role) GetSelectZone() int32 {
	return this.selectZone
}
func (this *Role) SetPlatform(platform string) {
	this.platform = platform
}

func (this *Role) SetHardFight(b int) {
	this.isHardFight = b
}
func (this *Role) SetYuanRankScore() {
	this.roleCross.roleCrossInfo.Yuanhangtrial.TrialScore = 0
	this.roleCross.selfRank = 0
	this.roleCross.selfScore = 0
	this.roleCross.totalRank = 0
}
func (this *Role) GetPlatform() string {
	return this.platform
}
func (this *Role) SetSubPlatform(subPlatform string) {
	this.subPlatform = subPlatform
}
func (this *Role) GetSubPlatform() string {
	return this.subPlatform
}
func (this *Role) SetClientParam(clientInfo *serverproto.ClientParamInfo) {
	if clientInfo == nil {
		return
	}
	if this.clientParamInfo == nil {
		this.clientParamInfo = &NeteaseLogCommonInfo{}
	}
	this.clientParamInfo.DeviceModel = clientInfo.DeviceModel
	this.clientParamInfo.DeviceHeight = int(clientInfo.DeviceHeight)
	this.clientParamInfo.DeviceWidth = int(clientInfo.DeviceWidth)
	this.clientParamInfo.OsName = clientInfo.OsName
	this.clientParamInfo.OsVer = clientInfo.OsVer
	this.clientParamInfo.MacAddr = clientInfo.MacAddr
	this.clientParamInfo.Udid = clientInfo.Udid
	this.clientParamInfo.Isp = clientInfo.Isp
	this.clientParamInfo.Network = clientInfo.Network
	this.clientParamInfo.AppChannel = clientInfo.AppChannel
	this.clientParamInfo.AppVer = clientInfo.AppVer
	this.clientParamInfo.TransId = clientInfo.TransId
	this.clientParamInfo.UnisdkDeviceId = clientInfo.UnisdkDeviceid
	this.clientParamInfo.IsEmulator = int(clientInfo.IsEmulator)
	this.clientParamInfo.IsRoot = int(clientInfo.IsRoot)
	this.clientParamInfo.AccountId = clientInfo.AccountId
	this.clientParamInfo.OldAccountId = clientInfo.OldAccountid
	this.clientParamInfo.IMEI = clientInfo.IMEI
	this.clientParamInfo.CountryCode = clientInfo.CountryCode
	this.clientParamInfo.EnterSN = clientInfo.EnterSn
	this.clientParamInfo.OAid = clientInfo.Oaid
	this.clientParamInfo.EngineVer = clientInfo.EngineVer
	this.clientParamInfo.Server = service.GetServiceConfig().Node.Zone*100 + service.GetServiceConfig().Node.Id
}
func (this *Role) GetClientParam() *NeteaseLogCommonInfo {
	return this.clientParamInfo
}
func (this *Role) SetClientIP(ip string) {
	this.clientIp = ip

	if this.clientParamInfo == nil {
		this.clientParamInfo = &NeteaseLogCommonInfo{}
	}

	ipStr := this.GetClientIP()
	//先区分是否是IPV6
	strList := strings.Split(ipStr, ":")
	if len(strList) == 2 {
		this.clientParamInfo.IPv4 = strList[0]
	} else if len(strList) > 2 {
		position := strings.LastIndex(ipStr, ":")
		this.clientParamInfo.Ipv6 = ipStr[1 : position-1]
	}
}
func (this *Role) GetClientIP() string {
	return this.clientIp
}
func (this *Role) DBNode() string {
	return this.dbNode
}

func (this *Role) SocialNode() string {
	return this.socialNode
}
func (this *Role) AoiNode() string {
	//return this.aoiNode
	return ""
}
func (this *Role) BossNode() string {
	return this.bossNode
}
func (this *Role) RankNode() string {
	return this.rankNode
}
func (this *Role) GuildNode() string {
	return this.guildNode
}
func (this *Role) CliID() model.ClientID {
	return this.cliID
}
func (this *Role) SetCliID(cId model.ClientID) {
	this.cliID = cId
}
func (this *Role) SetCliIDSessionID(sessionID uint64) {
	this.cliID.SessID = sessionID
}
func (this *Role) setUUid(id uint64) {
	this.uuid = id
}
func (this *Role) GetUUid() uint64 {
	return this.uuid
}
func (this *Role) GetNickName() string {
	return this.GetRoleBase().GetRoleName()
}
func (this *Role) GetImageId() int32 {
	return this.GetRoleBase().RoleData().HeadId
}
func (this *Role) SetSelectUUid(id uint64) {
	this.SelectedUuid = id
	if data, ok := this.UuidRoleList[id]; ok {
		this.RegisterTime = data.RegisterTime
	}
}
func (this *Role) SetReLogin(re bool) {
	this.reLogin = re
	if re {
		this.isHardFight = 0
	}
}
func (this *Role) GetRoleBase() *RoleBase {
	return this.base
}
func (this *Role) GetRoleBag() *RoleBag {
	return this.roleBag
}
func (this *Role) GetRoleEquip() *RoleEquip {
	return this.roleEquip
}
func (this *Role) GetRoleHero() *RoleHero {
	return this.roleHero
}
func (this *Role) GetRoleChip() *RoleChip {
	return this.roleChip
}
func (this *Role) GetRoleMap() *RoleMap {
	return this.roleMap
}
func (this *Role) GetRoleSkill() *RoleSkill {
	return this.roleSkill
}
func (this *Role) GetRoleSkillEquip() *RoleSkillEquip {
	return this.roleSkillEquip
}
func (this *Role) GetRoleCard() *RoleCard {
	return this.roleCard
}
func (this *Role) GetRoleFashion() *RoleFashion {
	return this.roleFashion
}
func (this *Role) GetRoleBattle() *RoleBattle {
	return this.roleBattle
}
func (this *Role) GetRoleChat() *RoleChat {
	return this.roleChat
}
func (this *Role) GetRoleArena() *RoleArena {
	return this.roleArena
}
func (this *Role) GetRoleRed() *RoleRed {
	return this.roleRed
}
func (this *Role) GetRoleMail() *RoleMail {
	return this.roleMail
}
func (this *Role) GetRoleCompetition() *RoleCompetition {
	return this.roleCompetition
}

func (this *Role) GetRoleShop() *RoleShop {
	return this.roleShop
}

func (this *Role) GetRoleSocial() *RoleSocial {
	return this.roleSocial
}
func (this *Role) GetRoleTask() *RoleTask {
	return this.roleTask
}

//	func (this *Role) GetRoleFightPower1() *RoleFightPower {
//		return this.roleFightPower
//	}
func (this *Role) GetRoleActivity() *RoleActivity {
	return this.roleActivity
}
func (this *Role) GetRoleTower() *RoleTower {
	return this.roleTower
}
func (this *Role) GetRoleGuild() *RoleGuild {
	return this.roleGuild
}
func (this *Role) GetRolePet() *RolePet {
	return this.rolePet
}
func (this *Role) GetRoleInvitation() *RoleInvitation {
	return this.roleInvitation
}
func (this *Role) GetRoleDraw() *RoleDraw {
	return this.roleDraw
}
func (this *Role) GetRoleRune() *RoleRune {
	return this.roleRune
}
func (this *Role) GetRoleDaoChang100() *RoleDaoChang100 {
	return this.roleDaoChang100
}
func (this *Role) GetRoleStatistic() *RoleStatistic {
	return this.roleStatistic
}

func (this *Role) GetRoleKeepSake() *RoleKeepSake {
	return this.roleKeepSake
}

func (this *Role) GetRoleCross() *RoleCross {
	return this.roleCross
}
func (this *Role) GetRoleRush() *RoleRush {
	return this.roleRush
}
func (this *Role) GetRoleBT() *RoleBT {
	return this.roleBT
}

func (this *Role) SetCreateData(msg *serverproto.CSCreateRoleReq) {
	this.base.roleBase.Sex = msg.Sex
	this.base.roleBase.Country = msg.Country

	//JobId
	this.base.roleBase.RoleData.HeroData.ConfigId = msg.JobId

	this.base.roleBase.FashionData.Hair = msg.Hair
	this.base.roleBase.FashionData.HairAvatar = msg.HairAvatar
	this.base.roleBase.FashionData.Eye = msg.Eye
	if msg.Head != 0 {
		this.base.roleBase.FashionData.FashionUpList =
			append(this.base.roleBase.FashionData.FashionUpList, msg.Head)
	}

	this.activeCode = msg.ActiveCode
}

func (this *Role) IsLogout(ms uint64) bool {
	return this.offlineTimer.IsStart() && this.offlineTimer.IsExpired(ms)
}

func (this *Role) isBan() uint64 {
	if this.GetRoleBase().roleBase != nil && this.GetRoleBase().roleBase.BanTime > uint64(util.GetTimeSeconds()) {
		delTime := this.GetRoleBase().roleBase.BanTime - uint64(util.GetTimeSeconds())
		return delTime
	}
	return 0
}
func (this *Role) BanRole(isBan bool, banTime uint64, cheatType int32) {
	if this.GetRoleBase().roleBase == nil {
		util.InfoF("BanRole isBan=%v err=rolebase is nil", isBan)
		return
	}
	if banTime <= 0 {
		banTime = 24 * 60 * 60
	}
	if isBan {
		this.GetRoleBase().roleBase.BanTime = uint64(util.GetTimeSeconds()) + banTime
		this.GetRoleBase().roleBase.BanType = cheatType
		this.GetRoleBase().SetDirty(true)

		//作弊方式封号
		ssMsg := &serverproto.SSGameBanRoleNtf{
			BanUid:     this.GetUUid(),
			BanEndTime: this.GetRoleBase().roleBase.BanTime,
			BanType:    1, //1封号，2禁言
		}
		this.SendDb(ssMsg)

		errCode := this.roleStatistic.GetCheatErrorCode(cheatType)
		this.KickWithSaveAndBan(errCode, banTime)
	} else {
		if this.GetRoleBase().roleBase.BanTime > 0 {
			this.GetRoleBase().roleBase.BanTime = 0
			this.GetRoleBase().roleBase.BanType = 0
			this.GetRoleBase().SetDirty(true)
			//清空作弊数据
			if this.GetRoleStatistic() != nil {
				this.GetRoleStatistic().ClearCheatData()
			}
		}
	}
}

// 禁言
func (this *Role) BanRoleChat(isBan bool, banTime uint64, cheatType int32) {
	if this.GetRoleBase().roleBase == nil {
		util.InfoF("BanRole isBan=%v err=rolebase is nil", isBan)
		return
	}

	if banTime <= 0 {
		banTime = 24 * 60 * 60
	}

	if isBan {
		this.GetRoleBase().roleBase.ChatBanTime = uint64(util.GetTimeSeconds()) + banTime
		this.GetRoleBase().roleBase.ChatBanType = cheatType
		this.GetRoleBase().SetDirty(true)

		//禁言
		ssMsg := &serverproto.SSGameBanRoleNtf{
			BanUid:     this.GetUUid(),
			BanEndTime: this.GetRoleBase().roleBase.BanTime,
			BanType:    2, //1封号，2禁言
		}
		this.SendDb(ssMsg)

		util.InfoF("uid=%v BanRoleChat endtime=%v", this.GetUUid(), this.GetRoleBase().roleBase.ChatBanTime)
	} else {
		if this.GetRoleBase().roleBase.ChatBanTime > 0 {
			this.GetRoleBase().roleBase.ChatBanTime = 0
			this.GetRoleBase().roleBase.ChatBanType = 0
			this.GetRoleBase().SetDirty(true)
			//清空作弊数据
			if this.GetRoleStatistic() != nil {
				this.GetRoleStatistic().ClearCheatData()
			}
		}
	}
}

// 来自gmweb的删除背包道具操作
func (this *Role) WebGMDelItem(delItemList []*serverproto.KeyValueType) {
	util.InfoF("uid=%v WebGMDelItem delitemlist=%v", this.uuid, delItemList)

	for idx := 0; idx < len(delItemList); idx++ {
		this.GetRoleBag().DelItem(delItemList[idx].Key, delItemList[idx].Value, AddItemST{
			AddFrom: AddFrom_System,
		})
	}
}

func (this *Role) KickNotSave(err int32) {
	//通知gate踢人，并且不再反向通知logic服务器
	kickNtf := &serverproto.SSUserKickNtf{
		Error:    err,
		ClientId: this.CliID().SessID,
	}
	this.ReplayGate(kickNtf, false)
	util.InfoF("uid=%v sessionID=%v KickNotSave game kick user err=%v", this.GetUUid(), this.CliID().SessID, err)

	this.SwitchState(ROLE_STATE_ZOMBIE, nil)
}

func (this *Role) KickWithSave(err int32) {
	//通知gate踢人，并且不再反向通知logic服务器
	kickNtf := &serverproto.SSUserKickNtf{
		Error:    err,
		ClientId: this.CliID().SessID,
	}
	this.ReplayGate(kickNtf, false)
	util.InfoF("uid=%v sessionID=%v KickWithSave game kick user err=%v", this.GetUUid(), this.CliID().SessID, err)

	this.SwitchState(ROLE_STATE_OFFLINE, nil)
}

func (this *Role) KickWithSaveAndBan(err int32, banEndTime uint64) {
	//通知gate踢人，并且不再反向通知logic服务器
	kickNtf := &serverproto.SSUserKickNtf{
		Error:      err,
		ClientId:   this.CliID().SessID,
		BanEndTime: banEndTime,
	}
	this.ReplayGate(kickNtf, false)
	util.InfoF("uid=%v sessionID=%v KickWithSaveAndBan game kick user", this.GetUUid(), this.CliID().SessID)

	this.SwitchState(ROLE_STATE_OFFLINE, nil)
}

func (this *Role) Load(role *serverproto.Role) error {
	if this.reLogin && this.isLoad {
		//已经加载过
		return nil
	}
	//每个系统类型信息加载
	for _, data := range this.soList {
		if !data.Load(role) {
			return errors.New(fmt.Sprintf("uid=%v load savedObject module=%v failed",
				this.GetUUid(), reflect.TypeOf(data).Elem().Name()))
		}
	}
	this.isLoad = true

	return nil
}

func (this *Role) LoadOther(msg interface{}) error {
	//主角基本数据还未加载
	if !this.isLoad {
		return nil
	}

	switch m := msg.(type) {
	//在登陆流程中
	case *serverproto.SSLoadArenaNtf:
		if this.roleArena != nil {
			if !this.roleArena.LoadOther(m.RoleArena) {
				return errors.New(fmt.Sprintf("uid=%v load SSLoadArenaNtf failed", this.GetUUid()))
			}
		}
	case *serverproto.SSLoadMailNtf:
		if this.roleMail != nil {
			if !this.roleMail.LoadOther(m.Mail) {
				return errors.New(fmt.Sprintf("uid=%v load SSLoadMailNtf failed", this.GetUUid()))
			}
		}
	case *serverproto.SSLoadFriendDataNtf:
		if this.roleSocial != nil {
			if !this.roleSocial.LoadOther(m.Friend) {
				return errors.New(fmt.Sprintf("uid=%v SSLoadFriendDataNtf failed", this.GetUUid()))
			}
		}
	case *serverproto.SSLoadPetNtf:
		if this.rolePet != nil {
			if !this.rolePet.LoadOther(m) {
				return errors.New(fmt.Sprintf("uid=%v SSLoadPetNtf failed", this.GetUUid()))
			}
		}
	case *serverproto.SSLoadInvitationDataNtf:
		if this.roleInvitation != nil {
			if !this.roleInvitation.LoadOther(m.InvitationInfo) {
				return errors.New(fmt.Sprintf("uid=%v SSLoadInvitationDataNtf failed", this.GetUUid()))
			}
		}
	case *serverproto.SSLoadCrossDataNtf:
		if this.roleCross != nil {
			if !this.roleCross.LoadOther(m.LoadData) {
				return errors.New(fmt.Sprintf("uid=%v SSLoadCrossDataNtf failed", this.GetUUid()))
			}
		}
	default:
		return errors.New(fmt.Sprintf("uid=%v load unkonw model !!!", this.GetUUid()))
		//不在登陆流程中，后续通过协议主动获取
	}

	return nil
}

func (this *Role) Save() {
	if !this.isLoad {
		return
	}

	bSave := false
	if this.GetState() == ROLE_STATE_ONLINE || this.GetState() == ROLE_STATE_OFFLINE {
		for _, data := range this.soList {
			//data.(*SaveObject).IsDirty()
			if data.IsDirty() {
				data.Save()
				bSave = true
			}
		}
	}
	if bSave {
		//最后save时间戳
		this.lastProcessTime = util.GetTimeMilliseconds()
	}
}

func (this *Role) Update(ms uint64) {
	if this.GetState() == ROLE_STATE_ZOMBIE {
		return
	}
	//放到time wheel中处理
	//if this.saveTimer.IsStart() && this.saveTimer.IsExpired(ms) {
	//	this.Save()
	//}

	//活动数据更新定时器相关代码
	if this.dailyResetTimer.IsStart() && this.dailyResetTimer.IsExpired(ms) {
		//update过程中玩家已经通过上下线进行了重置操作
		this.DailyReset(true)
		ResetCount++
		this.dailyResetTimer.Cancel()
	}

	this.roleArena.Update(ms)
	this.roleMail.Update(ms)
	if this.base == nil {
		util.WarnF("uid=%v Role.Update skip: base==nil", this.GetUUid())
	} else {
		this.GetRoleBase().Update(ms)
	}
	this.roleTower.Update(ms)
	this.roleRune.Update(ms)
	this.roleHead.Update(ms)
	this.roleWish.Update(ms)

	if this.mysqlLogSaveTimer.IsStart() && this.mysqlLogSaveTimer.IsExpired(ms) {
		this.saveMysqlLog()
	}

	////1小时无任何保存操作，直接设置成离线状态
	//if ms > this.lastProcessTime && this.lastProcessTime > 0 && ms-this.lastProcessTime > 60*60*1000 {
	//	if this.GetState() == ROLE_STATE_ONLINE {
	//		this.SwitchState(ROLE_STATE_OFFLINE, nil)
	//		util.DebugF("uid=%v online->offline", this.GetUUid())
	//	}
	//}
}

func (this *Role) isDailyReset() bool {
	if this.GetRoleBase().roleBase.DailyResetTimeStamp <= 0 {
		this.GetRoleBase().roleBase.DailyResetTimeStamp = this.GetRoleBase().RoleData().LastLoginTime
	}
	return model.IsDailyResetHour5(this.GetRoleBase().roleBase.DailyResetTimeStamp)

	//return model.IsDailyResetHour5(this.GetRoleBase().RoleData().LastLoginTime)
}

func (this *Role) DailyReset(notify bool) {
	//加载完成后做重置操作
	util.ErrorF("uid=%v daily reset nickname=%s", this.GetUUid(), this.GetNickName())
	oldDailyResetTimeStamp := this.GetRoleBase().roleBase.DailyResetTimeStamp
	this.roleArena.DailyReset(notify)

	//this.roleTower.DailyReset(notify)

	this.roleBattle.DailyReset(notify)

	this.roleMap.DailyReset(notify)

	this.roleTask.DailyReset(notify, oldDailyResetTimeStamp)

	this.roleSkill.DailyReset(notify)

	this.roleGuild.DailyReset(notify)

	this.roleShop.DailyReset(notify)

	this.roleActivity.DailyReset(notify)

	this.roleInvitation.DailyReset(notify)

	this.roleRune.DailyReset(notify)

	this.roleDaoChang100.DailyReset(notify)

	this.roleCross.DailyReset(notify, oldDailyResetTimeStamp)

	this.roleHead.DailyReset(notify)

	this.roleCompetition.DailyReset(notify)

	this.roleBT.DailyReset(notify, oldDailyResetTimeStamp)
	//最后重置，切记!
	this.GetRoleBase().DailyReset(notify)
}
func (this *Role) SetUpdateDailyReset(ms uint64, bReset bool) {
	//已经重置不需要再次重置
	if !this.isDailyReset() {
		return
	}

	randNum := rand.Int31n(3000)
	this.dailyResetTimer.Reset(ms, time.Duration(randNum), false)
}

func (this *Role) FuncDisable() bool {
	//RobotMode 1:机器人模式 2:无法注册 3:关闭付费功能
	if service.GetServiceConfig().Node.RobotMode == 3 {
		return true
	}
	return false
}

// 推送客户端启动时需要的信息，例如基本信息，背包信息等
func (this *Role) StartupProto() {
	// todo 测试使用
	time.Sleep(200 * time.Millisecond)
	nowTime := util.GetTimeMilliseconds()
	startUpTime := service.GetServiceStartupTime()
	ntfMsg := &serverproto.SCStartupInfoNtf{
		ServerTime:       nowTime,
		CreateTime:       this.RegisterTime,
		FuncDisable:      this.FuncDisable(),
		ServiceStartTime: startUpTime,
	}
	//角色基础信息
	ntfMsg.RoleBase = &serverproto.RoleBase{}
	this.GetRoleBase().CopyData(ntfMsg.RoleBase)
	//小红点信息
	ntfMsg.RoleRed = this.roleRed.redInfo

	//伙伴
	ntfMsg.RoleHero = &serverproto.RoleHero{}
	this.roleHero.CopyData(ntfMsg.RoleHero)

	//背包
	ntfMsg.RoleBag = &serverproto.RoleBag{}
	this.roleBag.CopyData(ntfMsg.RoleBag)

	// 许愿箱
	ntfMsg.RoleWishBox = &serverproto.RoleWish{}
	this.roleWish.CopyData(ntfMsg.RoleWishBox)

	// 特殊处理
	ntfMsg.RoleBase.BtJiaDayRecharge = int32(float32(ntfMsg.RoleBase.BtJiaDayRecharge) * BTJiaChangeDollar)
	ntfMsg.RoleBase.BtJiaTotalRecharge = uint64(float32(ntfMsg.RoleBase.BtJiaTotalRecharge) * BTJiaChangeDollar)

	//分成多条协议进行发送
	sendLen := this.ReplayGate(ntfMsg, true)
	ntfMsg = &serverproto.SCStartupInfoNtf{
		ServerTime:       nowTime,
		CreateTime:       this.RegisterTime,
		FuncDisable:      this.FuncDisable(),
		ServiceStartTime: startUpTime,
	}

	//碎片
	ntfMsg.RoleChip = &serverproto.RoleChip{}
	this.roleChip.CopyData(ntfMsg.RoleChip)

	//时装
	ntfMsg.RoleFashion = &serverproto.RoleFashion{}
	//this.roleFashion.CopyDatatmp(ntfMsg.RoleFashion)
	this.roleFashion.CopyData(ntfMsg.RoleFashion)

	//战斗数据
	ntfMsg.RoleBattle = &serverproto.RoleBattle{}
	this.roleBattle.CopyData(ntfMsg.RoleBattle)

	//私聊消息列表
	ntfMsg.RoleChat = &serverproto.RoleChat{}
	this.roleChat.CopyData(ntfMsg.RoleChat)

	//rolemap
	ntfMsg.RoleMap = this.roleMap.CopyData()

	ntfMsg.RoleTower = &serverproto.RoleTower{}
	this.roleTower.CopyData(ntfMsg.RoleTower)

	//任务模块
	ntfMsg.RoleTask = this.roleTask.CopyData()

	ntfMsg.RoleDraw = &serverproto.RoleDraw{}
	this.roleDraw.CopyData(ntfMsg.RoleDraw)

	//赛季玩法数据
	ntfMsg.RoleCompetition = &serverproto.RoleCompetition{}
	this.roleCompetition.CopyData(ntfMsg.RoleCompetition)

	//百人道场
	ntfMsg.RoleDaochang100 = &serverproto.RoleDaoChang100{}
	this.roleDaoChang100.CopyData(ntfMsg.RoleDaochang100)

	//战斗力值
	ntfMsg.RoleFightpower = &serverproto.FightPowerData{}
	//this.roleFightPower.CopyData(ntfMsg.RoleFightpower)
	this.roleBattleAttr.CopyData(ntfMsg.RoleFightpower)

	// BT
	ntfMsg.RoleBt = &serverproto.RoleBT{}
	this.roleBT.CopyData(ntfMsg.RoleBt)

	//RobotMode 1:机器人模式 2:无法注册 3:关闭付费功能
	ntfMsg.FuncDisable = this.FuncDisable()

	//分成多条协议进行发送
	sendLen = this.ReplayGate(ntfMsg, true) + sendLen
	ntfMsg = &serverproto.SCStartupInfoNtf{
		ServerTime:       nowTime,
		CreateTime:       this.RegisterTime,
		FuncDisable:      this.FuncDisable(),
		ServiceStartTime: startUpTime,
	}
	//跨服个人数据
	ntfMsg.RoleCross = &serverproto.RoleCross{}
	this.roleCross.CopyData(ntfMsg.RoleCross)

	ntfMsg.RoleSkillEquip = &serverproto.RoleSkillEquip{}
	this.roleSkillEquip.CopyData(ntfMsg.RoleSkillEquip)

	sendLen = this.ReplayGate(ntfMsg, true) + sendLen
	this.tmpState = false
	util.DebugF("uid=%v StartupProto ntfMsgLen=%v", this.GetUUid(), sendLen)

	storyNtf := &serverproto.SCRoleStoryNtf{}
	this.GetRoleBase().CopyStoryData(storyNtf)
	this.ReplayGate(storyNtf, true)

	//通知最近世界聊天信息
	if this.roleChat != nil {
		this.roleChat.WorldMsgNtf()
	}

	//走马灯公告
	RoleMag.NoticeInfoNtf(this)

	//装备
	equipNtfMsg := &serverproto.SCStartupInfoEquipNtf{
		RoleEquipInfo: &serverproto.RoleEquip{},
	}
	this.roleEquip.CopyData(equipNtfMsg.RoleEquipInfo)
	sendLen = this.ReplayGate(equipNtfMsg, true)
	util.DebugF("uid=%v StartupProto ntfMsgLen=%v equip", this.GetUUid(), sendLen)

	//卡片
	cardNtfMsg := &serverproto.SCStartupInfoCardNtf{
		RoleCardInfo: &serverproto.RoleCard{},
	}
	this.roleCard.CopyData(cardNtfMsg.RoleCardInfo)
	sendLen = this.ReplayGate(cardNtfMsg, true)
	util.DebugF("uid=%v StartupProto ntfMsgLen=%v card", this.GetUUid(), sendLen)

	//pet
	this.rolePet.StartupNtf()

	//精彩活动
	this.roleActivity.StartupNtf()

	//邀请码系统
	this.roleInvitation.StartupNtf()

	//初始化结束函数标志
	endMsgNtf := &serverproto.SCStartupInfoEndNtf{}
	this.ReplayGate(endMsgNtf, true)

	this.GetRoleRune().GetFreeGoodsData()

	this.CombineServerNtf()
}

// 上线处理
func (this *Role) onlineProcess(bRelogin bool) {
	//清空缓存列表
	this.reqAckConfirmList = map[uint32][]uint32{}

	this.GetRoleBase().OnlineProcess()

	if this.roleArena != nil {
		this.roleArena.OnlineProcess()
	}

	if this.roleCross != nil {
		this.roleCross.OnlineProcess()
	}
	if this.roleTower != nil {
		this.roleTower.OnlineProcess()
	}
	if this.roleBattle != nil {
		this.roleBattle.OnlineProcess()
	}
	if this.rolePet != nil {
		this.rolePet.OnlineProcess()
	}
	if this.roleRush != nil {
		this.roleRush.OnlineProcess()
	}
	if this.roleTask != nil {
		this.roleTask.OnlineProcess()
	}

	if this.roleActivity != nil {
		this.roleActivity.OnlineProcess()
	}

	if this.roleHead != nil {
		this.roleHead.OnlineProcess()
	}

	// 上线获取赛季奖励处理
	if this.roleCompetition != nil {
		this.roleCompetition.OnlineGetCompetitionReward()
	}
	//上线日志记录
	model.ElasticPutLogInfo(&model.ElasticLogST{
		Uid:      this.GetUUid(),
		NickName: this.GetNickName(),
		OpenId:   this.GetOpenId(),
		LogType:  "RoleOnline",
		LogDesc:  "RoleOnline",
	})

	this.MysqlLogNtf(serverproto.MysqlLogType_LType_Online, nil, 0)

	//更新简介信息中的离线时间(上线时也进行一次时间更新)
	this.GetRoleBase().UpdatePlayerBriefInfo(false)

	//获取离线信息玩家列表
	ssOfflineMsg := &serverproto.SSChatOfflinePlayerReq{}
	this.SendDb(ssOfflineMsg)

	//后续功能往后加，，尽量不要影响上面的逻辑
	this.GetRoleGuild().GuildBattleOnline()
}

func (this *Role) Logout() {
	this.Save()

	//清空角色信息数据
	if this.base != nil {
		//roleBasePool.Put(this.base)
		this.base = nil

		//删除连接信息
		delConnInfo := &serverproto.SSSaveUserConnectInfo{
			OpenId:   this.GetOpenId(),
			Platform: this.GetPlatform(),
		}
		this.SendDb(delConnInfo)
	}

	this.roleHero = nil
	this.roleBag = nil
	this.roleChip = nil
	this.roleEquip = nil
	this.roleMap = nil
	this.roleSkill = nil
	this.roleCard = nil
	this.roleFashion = nil
	this.roleBattle = nil

	this.soList = this.soList[:0]
}

func (this *Role) BaseChangeNtf() {
	this.base.BaseChangeNtf()
}
func (this *Role) MysqlLogNtf(logType serverproto.MysqlLogType, paramList []int32, subType int32) {
	logData := &serverproto.SSRoleLogData{
		Uid:       this.GetUUid(),
		Type:      int32(logType),
		SubType:   subType,
		ParamList: paramList, //oldval,newval,delval,param
	}

	if logType == serverproto.MysqlLogType_LType_Online {
		if this.GetClientParam() != nil {
			logData.StrList = append(logData.StrList, this.GetClientParam().DeviceModel)
		}
		logData.StrList = append(logData.StrList, this.GetClientIP())
	}

	this.mysqlLogList = append(this.mysqlLogList, logData)

	//mysqlNtf := &serverproto.SSRoleLogNtf{}
	//mysqlNtf.LogList = append(mysqlNtf.LogList, logData)
	//
	//this.SendDb(mysqlNtf)
}
func (this *Role) AddMysqlLog(logData *serverproto.SSRoleLogData) {
	this.mysqlLogList = append(this.mysqlLogList, logData)
}
func (this *Role) saveMysqlLog() {
	if len(this.mysqlLogList) > 0 {
		mysqlNtf := &serverproto.SSRoleLogNtf{}
		mysqlNtf.LogList = append(mysqlNtf.LogList, this.mysqlLogList...)

		this.SendDb(mysqlNtf)

		this.mysqlLogList = this.mysqlLogList[:0]
	}
}
func (this *Role) AddRmb(st AddItemST, add bool) {
	this.base.AddRMB(st, add)
}
func (this *Role) GetRmb() uint32 {
	return this.base.GetRmb()
}
func (this *Role) AddMoney(st AddItemST, add bool) {
	this.base.AddMoney(st, add)
}
func (this *Role) GetMoney() uint64 {
	return this.base.GetMoney()
}
func (this *Role) AddHeroExp(st AddItemST, add bool) bool {
	this.base.AddHeroExp(st, add)
	return true
}
func (this *Role) AddCruise(st AddItemST, add bool) bool {
	this.base.AddCruise(st, add)
	return true
}

// 增加角色基础经验
func (this *Role) AddBaseExp(st AddItemST) bool {
	//添加属性涉及到升级操作(自动升级)
	this.base.AddBaseExp(st)
	return true
}

// 增加职业经验
func (this *Role) AddJobExp(st AddItemST) bool {
	this.base.AddJobExp(st)
	return false
}
func (this *Role) GetRoleLevel() int32 {
	return this.GetRoleBase().GetRoleLevel()
}
func (this *Role) GetJobLevel() int32 {
	return this.GetRoleBase().GetRoleJobLevel()
}

// 创建角色开始的累计充值
func (this *Role) GetTotalRecharge() float32 {
	return this.GetRoleBase().GetRoleTotalRecharge()
}

// 每日累计充值
func (this *Role) GetDayRecharge() float32 {
	return this.GetRoleBase().roleBase.DayRecharge
}

// bt每日累计充值(真累计充值+假累计充值)
func (this *Role) GetBTDayRecharge() float32 {
	return this.GetBTZhenDayRecharge() + this.GetBTJiaDayRecharge()
}
func (this *Role) GetBTZhenDayRecharge() float32 {
	return this.GetRoleBase().roleBase.BtZhenDayRecharge
}
func (this *Role) GetBTJiaDayRecharge() float32 {
	return float32(this.GetRoleBase().roleBase.BtJiaDayRecharge) * BTJiaChangeDollar
}
func (this *Role) GetBTJiaTotalRecharge() float32 {
	return float32(this.GetRoleBase().roleBase.BtJiaTotalRecharge) * BTJiaChangeDollar
}

// 添加通用资源
func (this *Role) addCommonRes(resType int32, st AddItemST, add bool) {
	this.base.AddCommonRes(resType, st, add)
}
func (this *Role) getCommonResNum(resType int32) int32 {
	return this.base.GetCommonRes(resType)
}
func (this *Role) getChipResNum(resType int32) uint32 {
	return this.roleChip.getChipResNum(resType)
}

func (this *Role) AddRes(resType int32, st AddItemST, add bool) {
	switch serverproto.ResType(resType) {
	case serverproto.ResType_Res_Coin:
		this.AddMoney(st, add)
	case serverproto.ResType_Res_Rmb:
		this.AddRmb(st, add)
	case serverproto.ResType_Res_RoleBaseExp:
		this.AddBaseExp(st)
	case serverproto.ResType_Res_RoleJobExp:
		this.AddJobExp(st)
	case serverproto.ResType_Res_HeroBaseExp:
		this.AddHeroExp(st, add)
	case serverproto.ResType_Res_Cruise:
		this.AddCruise(st, add)
	//添加通用资源
	case serverproto.ResType_Res_Sprite:
		fallthrough
	case serverproto.ResType_Res_Reslove:
		fallthrough
	case serverproto.ResType_Res_EvilExp:
		fallthrough
	case serverproto.ResType_Res_Guild:
		fallthrough
	case serverproto.ResType_Res_DaoChang100:
		fallthrough
	case serverproto.ResType_Res_VipExp:
		fallthrough
	case serverproto.ResType_Res_Guild_Battle:
		fallthrough
	case serverproto.ResType_Res_PetCoin:
		fallthrough
	case serverproto.ResType_Res_PetExp:
		fallthrough
	case serverproto.ResType_Res_HightSkillExp:
		fallthrough
	case serverproto.ResType_Res_PetLevelUP_Exp:
		fallthrough
	case serverproto.ResType_Res_CreditRecharge:
		fallthrough
	case serverproto.ResType_Res_ROCoin:
		fallthrough
	case serverproto.ResType_Res_BoliShopExp:
		this.addCommonRes(resType, st, add)

	case serverproto.ResType_Res_RushMap:
		this.GetRoleBattle().OnRushMapScoreChange(st.ItemCount, 0)
	default:
	}
	this.GetRoleBase().SetDirty(true)
}

func (this *Role) GetResNum(resId int32) uint64 {
	cfgData, ok := serverproto.ItemCfgLoader[resId]
	if !ok {
		util.InfoF("uid=%v item cfg data not found resid=%v", this.GetUUid(), resId)
		return 0
	}
	switch serverproto.ResType(cfgData.ResType) {
	case serverproto.ResType_Res_Coin:
		return this.GetMoney()
	case serverproto.ResType_Res_Rmb:
		return uint64(this.GetRmb())
	case serverproto.ResType_Res_RoleBaseExp:
		return uint64(this.GetRoleBase().GetRoleBaseExp())
	case serverproto.ResType_Res_HeroBaseExp:
		return uint64(this.GetRoleBase().GetHeroBaseExp())
	case serverproto.ResType_Res_RoleJobExp:
		return uint64(this.GetRoleBase().GetRoleJobExp())
	case serverproto.ResType_Res_Cruise:
		return uint64(this.GetRoleBase().GetCruise())
	case serverproto.ResType_Res_Sprite:
		fallthrough
	case serverproto.ResType_Res_Reslove:
		fallthrough
	case serverproto.ResType_Res_EvilExp:
		fallthrough
	case serverproto.ResType_Res_Guild:
		fallthrough
	case serverproto.ResType_Res_DaoChang100:
		fallthrough
	case serverproto.ResType_Res_VipExp:
		fallthrough
	case serverproto.ResType_Res_Guild_Battle:
		fallthrough
	case serverproto.ResType_Res_PetCoin:
		fallthrough
	case serverproto.ResType_Res_PetExp:
		fallthrough
	case serverproto.ResType_Res_HightSkillExp:
		fallthrough
	case serverproto.ResType_Res_PetLevelUP_Exp:
		fallthrough
	case serverproto.ResType_Res_CreditRecharge:
		fallthrough
	case serverproto.ResType_Res_ROCoin:
		fallthrough
	case serverproto.ResType_Res_BoliShopExp:
		return uint64(this.getCommonResNum(resId))
	//背包中
	case serverproto.ResType_Res_SkillBook:
		fallthrough
	case serverproto.ResType_Res_Item:
		fallthrough
	case serverproto.ResType_Res_HeadFrame:
		fallthrough
	case serverproto.ResType_Res_QuickBattle:
		fallthrough
	case serverproto.ResType_Res_CashTicket:
		fallthrough
	case serverproto.ResType_Res_Gift:
		return uint64(this.GetItemNum(resId))
	case serverproto.ResType_Res_Chip:
		return uint64(this.getChipResNum(resId))
	case serverproto.ResType_Res_Equip:
		fallthrough
	case serverproto.ResType_Res_Fashion:
		fallthrough
	case serverproto.ResType_Res_Skill_Equip:
		fallthrough
	default:
		return 0
	}
}

func (this *Role) CheckResNum(resTypeList map[int32]int32) (bool, int32) {
	for resType, resValue := range resTypeList {
		if this.GetResNum(resType) < uint64(resValue) {
			return false, resType
		}
	}
	return true, 0
}

func (this *Role) CheckResLitNum(resTypeList map[int32]int32) bool {
	for resType, resValue := range resTypeList {
		if this.GetResNum(resType) < uint64(resValue) {
			return false
		}
	}
	return true
}

func (this *Role) CanAddItemList(resTypeList map[int32]int32) serverproto.ErrorCode {
	if this.GetRoleBag() != nil {
		return this.GetRoleBag().CanAddItemList(resTypeList)
	}
	return serverproto.ErrorCode_ERROR_FAIL
}
func (this *Role) AddItemList(resTypeList map[int32]int32, addFrom AddFromType, notify bool) {
	if this.GetRoleBag() != nil {
		this.GetRoleBag().AddItemList(resTypeList, AddItemST{AddFrom: addFrom, Notify: notify})
	}
}

func (this *Role) AddItem(configId int32, count int32, addFrom AddFromType) {
	if this.roleBag != nil {
		this.roleBag.AddItem(configId, count, AddItemST{AddFrom: addFrom, Notify: true})
	}
}
func (this *Role) DelItemList(resTypeList map[int32]int32, delFrom AddItemST) {
	if this.GetRoleBag() != nil {
		this.GetRoleBag().DelItemList(resTypeList, delFrom)
	}
}
func (this *Role) DelItem(configId int32, count int32, delFrom AddItemST) {
	if this.roleBag != nil {
		this.roleBag.DelItem(configId, count, delFrom)
	}
}

// 根据给定的道具动态ID(创建道具时生成的唯一ID)做删除操作
func (this *Role) DelItemByList(itemIdList []uint64, delFrom AddFromType) {
	if this.roleBag == nil {
		return
	}
	util.InfoF("uid=%v DelItem  itemlist=%v ", this.GetUUid(), itemIdList)

	ackMsg := &serverproto.SCDelItemAck{
		Error: int32(serverproto.ErrorCode_ERROR_OK),
	}
	for idx := 0; idx < len(itemIdList); idx++ {
		itemData := this.GetRoleBag().getItemById(itemIdList[idx])
		if itemData != nil && itemData.Num > 0 {
			this.GetRoleBag().DelItemById(itemIdList[idx], int32(itemData.Num), delFrom)

			ackMsg.DelCfgIdList = append(ackMsg.DelCfgIdList, itemData.ConfigId)
		}
	}

	this.ReplayGate(ackMsg, true)
}

func (this *Role) GetItemNum(configId int32) uint32 {
	if this.roleBag != nil {
		return this.roleBag.getItemNum(configId)
	}
	return 0
}

func (this *Role) UseItem(itemId uint64, itemNum uint32, itemIdxList []int32, bForceItemId bool) {
	if this.roleBag != nil {
		//默认使用一个
		if itemNum == 0 {
			itemNum = 1
		}

		err := this.roleBag.UseItem(itemId, itemNum, itemIdxList, bForceItemId)
		if err != serverproto.ErrorCode_ERROR_OK {
			ackMsg := &serverproto.SCUseItemAck{
				Error: int32(err),
			}
			this.ReplayGate(ackMsg, true)
		}
	}
}

func (this *Role) OnlineTimeReward() {
	err := this.GetRoleBase().OnlineTimeReward()
	if err != serverproto.ErrorCode_ERROR_OK {
		ackMsg := &serverproto.SCOnlineTimeRewardAck{
			Error: int32(err),
		}
		this.ReplayGate(ackMsg, true)
	}
}

// 获取当前累计充值所属档位
// 玩家累计充值金额档位1:[0-100] 2:(100,1000] 3:(1000,10000]
func (this *Role) GetTotalRechargeTap() int32 {
	var tmpTap int32 = 0
	tmpTotalRecharge := int32(this.GetTotalRecharge())
	for idx := 0; idx < len(model.GlobalTotalRechargeList); idx++ {
		if tmpTotalRecharge < model.GlobalTotalRechargeList[idx].Value {
			return model.GlobalTotalRechargeList[idx].Key
		}
		tmpTap = model.GlobalTotalRechargeList[idx].Key
	}
	return tmpTap
}

func (this *Role) GetRoleBriefInfo(briefInfo *serverproto.CommonPlayerBriefInfo) {
	briefInfo.Uid = this.GetUUid()
	briefInfo.NickName = this.GetNickName()
	briefInfo.Gender = this.GetRoleBase().GetRoleSex()
	briefInfo.ImgId = this.GetImageId()
	briefInfo.Level = this.GetRoleLevel()
	briefInfo.ConfigId = this.GetRoleBase().RoleData().HeroData.ConfigId
	briefInfo.FightPower = int32(this.roleBattleAttr.curTotalFightPower)
	//briefInfo.FightPower = int32(this.GetRoleFightPower().TotalFightPower) //(this.GetRoleBase().RoleData().FightPower)
	briefInfo.TowerLevel = this.GetRoleTower().nowTowerLevel
	briefInfo.TowerTime = uint64(this.GetRoleTower().nowTowerPassTime)
	briefInfo.HeadFrameId = this.GetRoleBase().RoleData().HeadFrameId
	briefInfo.VipLevel = this.GetRoleVipLevel()
	briefInfo.HeadId = this.GetHeadId()
	briefInfo.TowerWjLevel = this.GetRoleTower().nowTowerWjLevel - 1
	//1000层默认置为-1但是客户端显示需要1000
	if this.GetRoleTower().nowTowerWjLevel == -1 {
		briefInfo.TowerWjLevel = 1000
	}
	briefInfo.TowerWjTime = uint64(this.GetRoleTower().nowTowerWjPassTime)
	if this.GetState() == ROLE_STATE_ONLINE {
		briefInfo.OnlineState = true
	} else {
		briefInfo.OnlineTime = this.GetRoleBase().GetLastLoginTime()
	}
}

func (this *Role) GetRoleFightInfo(fightInfo *serverproto.FightRoleInfo, isMainRole bool) {
	fightInfo.IsRobot = false
	fightInfo.BriefInfo = &serverproto.CommonPlayerBriefInfo{
		Uid:         this.GetUUid(),
		NickName:    this.GetNickName(),
		Gender:      this.GetRoleBase().GetRoleSex(),
		ImgId:       this.GetImageId(),
		HeadFrameId: this.GetRoleBase().RoleData().HeadFrameId,
		VipLevel:    this.GetRoleVipLevel(),
		SelectZone:  this.GetSelectZone(),
		ConfigId:    this.GetRoleHero().GetMainHero().ConfigId,
		Level:       this.GetRoleLevel(),
	}
	fightInfo.JobLevel = this.GetJobLevel()
	//后续需要处理
	fightInfo.AttrList = this.GetRoleHero().GetMainHero().AttrList
	fightInfo.FashionData = this.GetRoleBase().roleBase.FashionData
	//技能竞技压制
	fightInfo.RepressSkillPvpVal = this.GetRoleBase().roleBase.RepressSkillPvpVal
	fightInfo.MaxFightPower = int32(this.GetRoleBase().RoleData().FightPower)

	//世界boss，只上阵主角
	mainHeroData := this.GetRoleBase().RoleData().HeroData
	fightInfo.HeroDataList = append(fightInfo.HeroDataList, this.GetRoleBase().RoleData().HeroData)
	if mainHeroData.BattlePetId > 0 && this.GetRolePet() != nil {
		battlePetInfo := this.GetRolePet().getPet(mainHeroData.BattlePetId)
		if battlePetInfo != nil {
			fightInfo.BattlePetList = append(fightInfo.BattlePetList, battlePetInfo)
		}
	}
	if !isMainRole {
		//其他上阵伙伴
		for _, data := range this.GetRoleHero().heroList {
			if data.IsBattle {
				fightInfo.HeroDataList = append(fightInfo.HeroDataList, data)
				if data.BattlePetId > 0 && this.GetRolePet() != nil {
					battlePetInfo := this.GetRolePet().getPet(data.BattlePetId)
					if battlePetInfo != nil {
						fightInfo.BattlePetList = append(fightInfo.BattlePetList, battlePetInfo)
					}
				}
			}
		}
	}
}

type AddSystemMsg struct {
	ParamId      int32
	ParamCount   int32
	AddFromType  int32
	UseItemCfgId int32
	ParamList    []int32
	ParaStr      string
}

func (this *Role) GenSystemMessage(sType SystemMessageType, st AddSystemMsg) *serverproto.SystemMessage {
	ssMsgNtf := &serverproto.SSSystemMessageNtf{}
	sysMsg := &serverproto.SystemMessage{
		Type:     int32(sType),
		NickName: this.GetNickName(),
		SendTime: util.GetTimeMilliseconds(),
	}
	if st.ParamId > 0 {
		sysMsg.ParamId = append(sysMsg.ParamId, st.ParamId) //id
	}
	if st.ParamCount > 0 {
		sysMsg.ParamId = append(sysMsg.ParamId, st.ParamCount) //count
	}
	if st.AddFromType > 0 {
		sysMsg.ParamId = append(sysMsg.ParamId, st.AddFromType) //AddFromType
	}
	if st.UseItemCfgId > 0 {
		sysMsg.ParamId = append(sysMsg.ParamId, st.UseItemCfgId) //UseItemCfgId
	}
	if len(st.ParamList) > 0 {
		sysMsg.ParamId = append(sysMsg.ParamId, st.ParamList...)
	}
	if sType == SystemmessageType_GuildDemon {
		sysMsg.NickName = st.ParaStr
	}

	ssMsgNtf.SysMsg = append(ssMsgNtf.SysMsg, sysMsg)

	//util.InfoF("uid=%v GenSystemMessage type=%v param=%v", this.GetUUid(), sysMsg.Type, sysMsg.ParamId)
	return sysMsg
}

func (this *Role) AddSystemMessage(sType SystemMessageType, st AddSystemMsg) {
	ssMsgNtf := &serverproto.SSSystemMessageNtf{}
	sysMsg := &serverproto.SystemMessage{
		Type:     int32(sType),
		NickName: this.GetNickName(),
		SendTime: util.GetTimeMilliseconds(),
	}
	if st.ParamId > 0 {
		sysMsg.ParamId = append(sysMsg.ParamId, st.ParamId) //id
	}
	if st.ParamCount > 0 {
		sysMsg.ParamId = append(sysMsg.ParamId, st.ParamCount) //count
	}
	if st.AddFromType > 0 {
		sysMsg.ParamId = append(sysMsg.ParamId, st.AddFromType) //AddFromType
	}
	if st.UseItemCfgId > 0 {
		sysMsg.ParamId = append(sysMsg.ParamId, st.UseItemCfgId) //UseItemCfgId
	}
	if len(st.ParamList) > 0 {
		sysMsg.ParamId = append(sysMsg.ParamId, st.ParamList...)
	}
	if sType == SystemmessageType_GuildDemon {
		sysMsg.NickName = st.ParaStr
	}

	ssMsgNtf.SysMsg = append(ssMsgNtf.SysMsg, sysMsg)

	this.SendSocial(ssMsgNtf)
}

// 分配属性点
func (this *Role) AddAttrPoint(heroID int32, point interface{}) {
	ret := this.GetRoleHero().AddAttrPoint(heroID, point)
	if ret != serverproto.ErrorCode_ERROR_OK {
		ackMsg := &serverproto.SCAddAttrPointAck{
			Error:  int32(ret),
			HeroId: heroID,
		}
		this.ReplayGate(ackMsg, true)
	}
}

// 分配属性点
func (this *Role) ReduceAttrPoint(count, itemid int32) {
	this.GetRoleHero().ReduceAttrPoint(count, itemid)
}

// 重置属性点
func (this *Role) ResetAttrPoint(heroID int32) {
	this.GetRoleHero().ResetAttrPoint(heroID, false)
}

// 增加素质点
func (this *Role) OnAddQualityPoint(msg *serverproto.CSAddQualityPointReq) {
	if msg == nil {
		return
	}
	ackMsg := &serverproto.SCAddQualityPointAck{}
	ackMsg.HeroId = msg.HeroId
	ackMsg.ItemId = msg.ItemId
	ackMsg.Error = int32(this.GetRoleHero().UseQualityItem(msg.HeroId, msg.ItemId))
	this.ReplayGate(ackMsg, true)
}

// 激活头像
func (this *Role) ActiveHead(headId int32) {
	ackMsg := &serverproto.SCActiveHeadAck{
		HeadId: headId,
	}
	bRet := this.base.ActiveHead(headId)
	ackMsg.Error = int32(bRet)
	this.ReplayGate(ackMsg, true)
}

// 设置头像
func (this *Role) SetRoleHeadPic(headId int32) {
	ackMsg := &serverproto.SCSetHeadIdAck{
		HeadId: headId,
	}
	bRet := this.GetRoleBase().SetRoleHeadPic(headId)
	ackMsg.Error = int32(bRet)
	this.ReplayGate(ackMsg, true)

	//更新玩家简介信息
	if bRet == serverproto.ErrorCode_ERROR_OK {
		this.GetRoleBase().UpdatePlayerBriefInfo(false)
	}
}

func (this *Role) SetRoleHeadFrameId(frameId int32) {
	ackMsg := &serverproto.SCChangeHeadFrameAck{
		Error:       int32(serverproto.ErrorCode_ERROR_FAIL),
		HeadFrameId: frameId,
	}
	bRet := this.GetRoleBase().SetHeadFrameId(frameId)
	ackMsg.Error = int32(bRet)
	this.ReplayGate(ackMsg, true)
}

func (this *Role) UseHeadFrameItem(itemId uint64, itemNum uint32) {
	ackMsg := &serverproto.SCUseHeadFrameItemAck{
		Error: int32(serverproto.ErrorCode_ERROR_FAIL),
	}
	bRet, res_list := this.GetRoleBag().UseHeadFrameItem(itemId, itemNum)
	ackMsg.Error = int32(bRet)
	ackMsg.ItemList = res_list
	this.ReplayGate(ackMsg, true)
}

func (this *Role) GetRoleHeadFrameInfo() {
	ackMsg := &serverproto.SCHeadFrameInfoAck{
		Error: int32(serverproto.ErrorCode_ERROR_FAIL),
	}
	bRet := this.GetRoleBase().PackHeadFrameInfo(ackMsg)
	ackMsg.Error = int32(bRet)
	this.ReplayGate(ackMsg, true)
}

// 请求头像信息
func (this *Role) HeadInfoReq() {
	this.base.HeadInfoReq()
}

func (this *Role) ChangeRoleName(name string) {
	ackMsg := &serverproto.SCRenameAck{
		Name: name,
	}
	bRet := this.base.ChangeRoleName(name)
	ackMsg.Error = int32(bRet)
	this.ReplayGate(ackMsg, true)

	//更新玩家简介信息
	if bRet == serverproto.ErrorCode_ERROR_OK {
		this.GetRoleBase().UpdatePlayerBriefInfo(false)
	}
}

func (this *Role) SetRoleGuide(guideId int32) {
	this.GetRoleBase().SetGuideId(guideId)
}

func (this *Role) SetRoleStory(story *serverproto.KeyValueType) {
	nRet := this.GetRoleBase().SetStoryId(story)
	ackMsg := &serverproto.SCRoleStoryAck{
		Error:   int32(nRet),
		StoryId: story,
	}
	this.ReplayGate(ackMsg, true)
}

func (this *Role) SetMapCartoon(id, status int32) {
	bRet := this.GetRoleBase().SetNewMapCartoonId(id, status)
	ackMsg := &serverproto.SCNewMapCartoonAck{
		Error: int32(bRet),
		MapCart: &serverproto.KeyValueType{
			Key:   id,
			Value: status,
		},
	}
	this.ReplayGate(ackMsg, true)
}

// /hero/partner
// 添加伙伴
func (this *Role) AddHero(configId int32) bool {
	if this.roleHero != nil {
		return this.roleHero.AddHero(configId)
	}
	return false
}
func (this *Role) HeroLevelUp(id int32) bool {
	if this.roleHero != nil {
		return this.roleHero.LevelUp(id)
	}
	return false
}
func (this *Role) HeroAdvance(id int32) bool {
	if this.roleHero != nil {
		ret := this.roleHero.Advance(id)

		if ret == serverproto.ErrorCode_ERROR_OK {
			////进阶重新处理属性
			//this.roleFightPower.onFighterAttrChange(id)
		} else {
			ackMsg := &serverproto.SCHeroAdvanceAck{
				Error: int32(ret),
			}
			this.ReplayGate(ackMsg, true)
		}
		return ret == serverproto.ErrorCode_ERROR_OK
	}
	return false
}

func (this *Role) HeroStrength(id int32) bool {
	if this.roleHero != nil {
		ret := this.roleHero.HeroStrength(id)
		return ret
	}
	return false
}

func (this *Role) HeroChangeJob(heroId int32, jobId int32) bool {
	ackMsg := &serverproto.SCHeroChangeJobAck{
		Error:  int32(serverproto.ErrorCode_ERROR_OK),
		HeroId: heroId,
	}

	if this.roleHero != nil {
		ret := this.roleHero.HeroChangeJob(heroId, jobId)
		if ret == serverproto.ErrorCode_ERROR_OK {
			////转职重新处理属性 后续重新开发
			//this.roleFightPower.onFighterAttrChange(heroId)
		}
		ackMsg.Error = int32(ret)
		this.ReplayGate(ackMsg, true)
		return true
	}
	return false
}

func (this *Role) HeroRecruit(configId int32) {
	ackMsg := &serverproto.SCHeroActiveAck{
		HeroId: configId,
		Error:  int32(serverproto.ErrorCode_ERROR_FAIL),
	}
	if this.roleHero != nil {
		nRet := this.roleHero.RecruitHero(configId)
		ackMsg.Error = int32(nRet)
	}
	this.ReplayGate(ackMsg, true)
}

func (this *Role) FightPowerReq(heroId int32) {
	ackMsg := &serverproto.SCHeroFighPowerAck{
		Error:  int32(serverproto.ErrorCode_ERROR_OK),
		HeroId: heroId,
	}
	//this.roleFightPower.calcHeroFightPower(heroId)

	this.ReplayGate(ackMsg, true)
}

func (this *Role) HeroBattle(heroId int32, isBattle bool) {
	if this.roleHero != nil {
		ret := this.roleHero.HeroBattle(heroId, isBattle)
		ackMsg := &serverproto.SCHeroBattleAck{
			Error: int32(ret),
		}
		this.ReplayGate(ackMsg, true)
	}
}

func (this *Role) ComposeChip(configId int32) {
	if this.roleChip != nil && this.roleHero != nil {
		ret := this.roleChip.ComposeChip(configId)
		if ret != serverproto.ErrorCode_ERROR_OK {
			util.DebugF("uid=%v ComposeChip err=%v", this.GetUUid(), ret)
		}
		ackMsg := &serverproto.SCChipComposeAck{
			Error: int32(ret),
		}
		this.ReplayGate(ackMsg, true)
	}
}

func (this *Role) ChipDecompose(chipList []*serverproto.KeyValueType, heroChipType []int32) {
	if this.roleChip != nil {
		ret := this.roleChip.ChipDecompose(chipList, heroChipType)
		if ret != serverproto.ErrorCode_ERROR_OK {
			ackMsg := &serverproto.SCHeroChipDecomposeAck{
				Error: int32(ret),
			}
			this.ReplayGate(ackMsg, true)
		}
	}
}

// /equip
func (this *Role) EquipForge(equipConfigId int32, once int32, equipType, subEquipType int32) {
	if this.roleEquip != nil {
		this.roleEquip.EquipForge(equipConfigId, once, equipType, subEquipType)
	}
}

func (this *Role) AddEquip(configId int32, num int32, notify bool, ignore bool) {
	if this.roleEquip != nil {
		addEquip, _ := this.roleEquip.AddEquip(configId, num)
		if addEquip != nil {
			if notify {
				ntfMsg := &serverproto.SCEquipChangeNtf{
					Ignore: ignore,
				}
				ntfMsg.EquipList = append(ntfMsg.EquipList, addEquip.(*serverproto.EquipData))
				this.ReplayGate(ntfMsg, true)
			}
			util.InfoF("uid=%v AddEquip id=%v now=%v num=%v", this.GetUUid(), configId,
				addEquip.(*serverproto.EquipData).Num, num)
		}
	}
}

func (this *Role) AddSkillEquip(configId int32, num int32, notify bool, ignore bool) {
	if this.roleSkillEquip != nil {

		changeIdList := map[uint32]int32{}
		var i int32 = 0
		for ; i < num; i++ {
			addSkillEquip, _ := this.roleSkillEquip.AddSkillEquip(configId, 0)
			if addSkillEquip != nil {
				detail, ok := addSkillEquip.(*serverproto.SkillEquipData)
				if !ok {
					continue
				}
				changeIdList[detail.Id] = detail.ConfigId
			}
		}
		this.roleSkillEquip.ChangeNtf(changeIdList, ignore)
	}
}

func (this *Role) EquipUp(heroId int32, slotIndex int32, equipId int32) {
	if this.roleEquip != nil && this.roleHero != nil &&
		heroId > 0 && slotIndex >= 0 && equipId >= 0 {
		ret := this.base.EquipUp(heroId, slotIndex, equipId)

		ackMsg := &serverproto.SCEquipUpAck{
			Error: int32(ret),
		}
		this.ReplayGate(ackMsg, true)
	} else {
		ackMsg := &serverproto.SCEquipUpAck{
			Error: int32(serverproto.ErrorCode_ERROR_FAIL),
		}
		this.ReplayGate(ackMsg, true)
	}
}

func (this *Role) EquipDown(heroId int32, subIndex int32) {
	if this.roleEquip != nil && this.roleHero != nil {
		this.base.EquipDown(heroId, subIndex)
	}
}

func (this *Role) EquipLevelUpAll(heroId int32) {
	if this.roleEquip != nil && this.roleHero != nil {
		this.base.EquipLevelUpAll(heroId)
	}
}

func (this *Role) EquipSlotLevelUp(heroId int32, subSlotIndex int32) {
	if this.roleEquip != nil {
		ret := this.base.EquipSlotLevelUp(heroId, subSlotIndex)
		util.DebugF("uid=%v [EquipSlotLevelUp] err=%v", this.GetUUid(), ret)
		ackMsg := &serverproto.SCEquipSlotLevelUpAck{
			Error: int32(ret),
		}
		this.ReplayGate(ackMsg, true)
	}
}

// 神器槽位升级
func (this *Role) SkillEquipSlotLevelUp(heroId, subIndex int32) {
	if this.roleSkillEquip != nil && this.roleHero != nil {
		slotData := this.base.getSkillEquipSlotData(heroId)
		ret := this.roleSkillEquip.SkillEquipSlotLevelUp(slotData, heroId, subIndex)
		util.DebugF("uid=%v [EquipSlotLevelUp] err=%v", this.GetUUid(), ret)
		ackMsg := &serverproto.SCSkillEquipSlotLevelUpAck{
			Error: int32(ret),
		}
		this.ReplayGate(ackMsg, true)
	}
}

// 神器升星
func (this *Role) SkillEquipStarLevelUp(heroId int32, skillEquipId uint32, cost []uint32) {
	if this.roleSkillEquip != nil && this.roleHero != nil {
		slotData := this.base.getSkillEquipSlotData(heroId)
		ret := this.roleSkillEquip.SkillEquipStarLevelUp(heroId, slotData, skillEquipId, cost)
		util.DebugF("uid=%v [SkillEquipStarLevelUp] err=%v", this.GetUUid(), ret)
		ackMsg := &serverproto.SCSkillEquipLevelUpAck{
			Error: int32(ret),
		}
		this.ReplayGate(ackMsg, true)
	}
}

// 神器转移
func (this *Role) SkillEquipShift(msg *serverproto.CSSkillEquipShiftReq) {
	if msg == nil {
		return
	}

	ret := this.roleSkillEquip.SkillEquipShift(msg.SrcId, msg.DstId)
	util.DebugF("uid=%v [SkillEquipShift] err=%v", this.GetUUid(), ret)
	ackMsg := &serverproto.SCSkillEquipShiftAck{
		Error: int32(ret),
	}
	this.ReplayGate(ackMsg, true)

}

// 佩戴替换神器
func (this *Role) SkillEquipUp(heroId int32, skillEquipId uint32, slotIndex int32) {
	if this.roleSkillEquip != nil && this.roleHero != nil {
		slotData := this.base.getSkillEquipSlotData(heroId)

		ret := this.roleSkillEquip.SkillEquipUp(heroId, slotData, skillEquipId, slotIndex)
		util.DebugF("uid=%v [SkillEquipUp] err=%v", this.GetUUid(), ret)
		ackMsg := &serverproto.SCSkillEquipUpAck{
			Error: int32(ret),
		}
		this.ReplayGate(ackMsg, true)
	}
}

// 卸下神器
func (this *Role) SkillEquipDown(heroId int32, slotIndex int32) {
	if this.roleSkillEquip != nil && this.roleHero != nil {
		slotData := this.base.getSkillEquipSlotData(heroId)
		ret := this.roleSkillEquip.SkillEquipDown(heroId, slotData, slotIndex)
		util.DebugF("uid=%v [SkillEquipDown] err=%v", this.GetUUid(), ret)
		ackMsg := &serverproto.SCSkillEquipDownAck{
			Error: int32(ret),
		}
		this.ReplayGate(ackMsg, true)
	}
}

// 分解神器
func (this *Role) SkillEquipDecompose(skillEquipIds []uint32) {
	if this.roleSkillEquip != nil && this.roleHero != nil {

		reward, ret := this.roleSkillEquip.SkillEquipDecompose(skillEquipIds)
		util.DebugF("uid=%v [SkillEquipDecompose] err=%v", this.GetUUid(), ret)
		ackMsg := &serverproto.SCSkillEquipDecomposeAck{
			Error: int32(ret),
		}

		if reward != nil && len(reward) > 0 {
			for k, v := range reward {
				ackMsg.ItemList = append(ackMsg.ItemList, &serverproto.KeyValueType{
					Key:   k,
					Value: v,
				})
			}
		}

		this.ReplayGate(ackMsg, true)
	}
}

func (this *Role) SkillEquipRemade(skillEquipId uint32) {
	if this.roleSkillEquip != nil && this.roleHero != nil {
		ackMsg := &serverproto.SCSkillEquipRemadeAck{
			OldId: skillEquipId,
		}
		ret, newId := this.roleSkillEquip.SkillEquipReforge(skillEquipId)
		ackMsg.Error = int32(ret)
		ackMsg.NewId = newId
		this.ReplayGate(ackMsg, true)
	}
}
func (this *Role) GetSkillEquipPool() {
	if this.roleSkillEquip != nil {
		ackMsg := &serverproto.SCSkillEquipPoolAck{}
		ret := this.roleSkillEquip.GetSkillEquipPool(ackMsg)
		ackMsg.Error = int32(ret)
		this.ReplayGate(ackMsg, true)
	}
}

// /card
func (this *Role) CardMount(heroId, subSlotIndex, cardSlotIndex, cardCfgId int32) {
	if this.roleEquip != nil && this.roleCard != nil {
		ret := this.base.SlotCardMount(heroId, subSlotIndex, cardSlotIndex, cardCfgId)
		util.DebugF("uid=%v CardMount err=%v", this.GetUUid(), ret)
		ackMsg := &serverproto.SCCardMountAck{
			Error: int32(ret),
		}
		this.ReplayGate(ackMsg, true)
	}
}

func (this *Role) CardDown(heroId, subSlotIndex, cardSlotIndex int32) {
	if this.roleCard != nil {
		ret := this.base.SlotCardDown(heroId, subSlotIndex, cardSlotIndex)
		util.DebugF("uid=%v CardDown err=%v", this.GetUUid(), ret)
		ackMsg := &serverproto.SCCardDownAck{
			Error: int32(ret),
		}
		this.ReplayGate(ackMsg, true)
	}
}

func (this *Role) CardMountAll(msg *serverproto.CSCardEquipAllReq) {
	if msg == nil || len(msg.EqiupSlotData) <= 0 {
		return
	}

	if this.roleEquip != nil && this.roleCard != nil {
		ret := this.base.SlotCardMountAll(msg)
		util.DebugF("uid=%v CardMountAll err=%v", this.GetUUid(), ret)
		ackMsg := &serverproto.SCCardEquipAllAck{
			Error: int32(ret),
		}
		this.ReplayGate(ackMsg, true)
	}
}

func (this *Role) CardDownAll(heroId int32) {
	if this.roleEquip != nil && this.roleCard != nil {
		ret := this.base.SlotCardDownAll(heroId)
		util.DebugF("uid=%v CardDownAll err=%v", this.GetUUid(), ret)
		ackMsg := &serverproto.SCCardEquipDownAck{
			Error:  int32(ret),
			HeroId: heroId,
		}
		this.ReplayGate(ackMsg, true)
	}
}

func (this *Role) CardUpGradeAll(msg *serverproto.CSCardUpGradeAllReq) {
	if this.roleCard != nil {
		ret := this.base.SlotCardUpGradeAll(msg)
		util.DebugF("uid=%v CardUpGradeAll err=%v", this.GetUUid(), ret)
		ackMsg := &serverproto.SCCardUpGradeAllAck{
			Error:  int32(ret),
			HeroId: msg.HeroId,
		}
		this.ReplayGate(ackMsg, true)
	}
}

func (this *Role) CardLevelExchange(sourceCardId, targetCardId int32) {
	ackMsg := &serverproto.SCCardLevelExchangeAck{
		Error: int32(serverproto.ErrorCode_ERROR_FAIL),
	}
	if this.roleCard != nil {
		ret := this.roleCard.CardExchange(sourceCardId, targetCardId, ackMsg)
		ackMsg.Error = int32(ret)
	}
	this.ReplayGate(ackMsg, true)
}

func (this *Role) CardCollect() {
	if this.roleCard != nil {
		ackMsg := &serverproto.SCCardCollectInfoAck{
			Error: int32(serverproto.ErrorCode_ERROR_OK),
		}

		this.GetRoleCard().GetCardCollect(ackMsg)

		this.ReplayGate(ackMsg, true)
	}
}

func (this *Role) CardCollectReward(cardId, level int32) {
	if this.roleCard != nil {
		ackMsg := &serverproto.SCCardCollectRewardAck{
			Error: int32(serverproto.ErrorCode_ERROR_FAIL),
		}

		ret := this.GetRoleCard().GetCollectReward(cardId, level, ackMsg)
		ackMsg.Error = int32(ret)
		ackMsg.CardId = cardId
		ackMsg.Level = level

		this.ReplayGate(ackMsg, true)
	}
}

func (this *Role) CardCompose(cardList []int32) {
	if this.roleCard != nil {
		ret, newCardId := this.roleCard.CardCompose(cardList)
		util.DebugF("uid=%v CardCompose err=%v", this.GetUUid(), ret)
		ackMsg := &serverproto.SCCardComposeAck{
			Error:     int32(ret),
			NewCardId: newCardId,
		}
		this.ReplayGate(ackMsg, true)
	}
}

func (this *Role) CardDecompose(cardList []*serverproto.KeyValueType, cardType int32) {
	if this.roleCard != nil {
		this.roleCard.CardDecompose(cardList, cardType)
	}
}

func (this *Role) CardUpGrade(msg *serverproto.CSCardUpGradeReq) {
	ackMsg := &serverproto.SCCardUpGradeAck{
		Error: int32(serverproto.ErrorCode_ERROR_FAIL),
	}
	if this.roleCard != nil && len(msg.ConfigIds) > 0 {
		this.roleCard.BagCardUpGrade(msg, ackMsg)
	}
	this.ReplayGate(ackMsg, true)
}

// /skill
func (this *Role) SkillReplace(heroId, idx, replaceSkillId int32) {
	if this.roleSkill != nil {
		ret := this.roleSkill.SkillReplace(heroId, idx, replaceSkillId, true, true)
		util.DebugF("uid=%v SkillReplace] err=%v", this.GetUUid(), ret)
		this.ReplayGate(&serverproto.SCReplaceSkillAck{Error: int32(ret)}, true)
	}
}

func (this *Role) ActiveSkill(heroId int32, skillId int32) {
	if this.roleSkill != nil {
		ret := this.roleSkill.ActiveSkill(heroId, skillId)
		util.DebugF("uid=%v ActiveSkill err=%v heroid=%v skillid=%v", this.GetUUid(), ret, heroId, skillId)
		this.ReplayGate(&serverproto.SCActiveSkillAck{Error: int32(ret)}, true)
	}
}

func (this *Role) SwapSkill(heroId, firstSlotId, secondSlotId int32) {
	if this.roleSkill != nil {
		ret := this.roleSkill.SwapSkill(heroId, firstSlotId, secondSlotId)
		util.DebugF("uid=%v SwapSkill err=%v s1=%v s2=%v", this.GetUUid(), ret, firstSlotId, secondSlotId)
		this.ReplayGate(&serverproto.SCSwapSkillAck{Error: int32(ret)}, true)
	}
}

func (this *Role) SetSkillList(heroId int32, skillList []int32) {
	ackMsg := &serverproto.SCSetSkillListAck{
		HeroId: heroId,
	}
	if this.roleSkill != nil {
		ret := this.roleSkill.SetSkillList(heroId, skillList)
		ackMsg.Error = int32(ret)
	}
	this.ReplayGate(ackMsg, true)
}

func (this *Role) SkillLevelUp(heroId int32, skillId int32) {
	ackMsg := &serverproto.SCSkillLevelUpAck{
		Error:   int32(serverproto.ErrorCode_ERROR_FAIL),
		SkillId: skillId,
		HeroId:  heroId,
	}

	if this.roleHero == nil {
		this.ReplayGate(ackMsg, true)
		return
	}
	heroData := this.roleHero.GetHero(heroId)
	if heroData == nil {
		this.ReplayGate(ackMsg, true)
		return
	}

	bRet := this.roleSkill.SkillLevelUp(heroData, skillId)
	ackMsg.Error = int32(bRet)
	this.ReplayGate(ackMsg, true)
}

// 兑换高级技能经验
func (this *Role) ConverSkillExp(msg *serverproto.CSConverSkillExpReq) {
	ackMsg := &serverproto.SCConverSkillExpAck{}
	ackMsg.Error = int32(this.roleSkill.ConverSkillExp(msg.Cnt))
	this.ReplayGate(ackMsg, true)
}

func (this *Role) ResetSkillLevel(heroId int32, bsuper bool) {
	if this.roleHero == nil {
		return
	}
	heroData := this.roleHero.GetHero(heroId)
	if heroData == nil {
		return
	}
	ackMsg := &serverproto.SCResetSkillLevelAck{
		Error:  int32(serverproto.ErrorCode_ERROR_FAIL),
		HeroId: heroId,
	}
	bRet := this.roleSkill.ResetSkillLevel(heroId, bsuper)
	ackMsg.Error = int32(bRet)
	ackMsg.ResetCount = this.GetRoleBase().RoleData().SkillResetCount
	this.ReplayGate(ackMsg, true)
}

// /card 相关
func (this *Role) FashionUp(fashionCfgIdList []int32) {
	if this.roleFashion != nil {
		ackMsg := &serverproto.SCFashionUpAck{}
		for _, data := range fashionCfgIdList {
			if ret := this.roleFashion.FashionUp(data); ret == serverproto.ErrorCode_ERROR_OK {
				ackMsg.Error = int32(ret)
			}
		}
		this.roleFashion.SetFashion()
		this.ReplayGate(ackMsg, true)
	}
}

func (this *Role) FashionDown(fashionCfgIdList []int32) {
	if this.roleFashion != nil {
		ackMsg := &serverproto.SCFashionDownAck{}
		for _, data := range fashionCfgIdList {
			if ret := this.roleFashion.FashionDown(data); ret == serverproto.ErrorCode_ERROR_OK {
				ackMsg.Error = int32(ret)
			}
		}
		this.roleFashion.SetFashion()
		this.ReplayGate(ackMsg, true)
	}
}

func (this *Role) FashionCompose(paperCfgId int32) {
	if this.roleFashion != nil {
		ret := this.roleFashion.FashionCompose(paperCfgId)
		this.ReplayGate(&serverproto.SCFashionComposeAck{Error: int32(ret)}, true)
	}
}

func (this *Role) FashionPaperDecompose(paperCfgId int32) {
	if this.roleFashion != nil {
		ret := this.roleFashion.FashionPaperDecompose(paperCfgId)
		if ret != serverproto.ErrorCode_ERROR_OK {
			this.ReplayGate(&serverproto.SCFashionPaperDecomposeAck{Error: int32(ret)}, true)
		}
	}
}

func (this *Role) FashionResetAttr(fashionId int32, enter bool) {
	if this.roleFashion == nil {
		return
	}
	ret, _ := this.roleFashion.FashionResetAttr(fashionId, enter)
	this.roleFashion.FashionChangeNtf([]int32{fashionId})
	this.ReplayGate(&serverproto.SCFashionResetAttrAck{Error: int32(ret)}, true)
}

func (this *Role) FashionUpLvl(fashionId int32) {
	if this.roleFashion == nil {
		return
	}
	ret := this.roleFashion.FashionUpLvl(fashionId)
	this.roleFashion.FashionChangeNtf([]int32{fashionId})
	this.ReplayGate(&serverproto.SCFashionUpLvlAck{Error: int32(ret)}, true)
}

func (this *Role) BuyItem(shopId, goodsId, goodsNum int32) {
	ackMsg := &serverproto.SCShopBuyItemAck{
		Error:     int32(serverproto.ErrorCode_ERROR_FAIL),
		GoodsType: shopId,
		GoodsId:   goodsId,
	}
	if this.roleBag != nil && goodsNum > 0 {
		bRet, buyTime, buyNum := this.roleShop.BuyItem(shopId, goodsId, goodsNum, ackMsg)
		ackMsg.Error = int32(bRet)
		ackMsg.CurNum = buyNum
		ackMsg.CurBuyTime = buyTime
	}
	this.ReplayGate(ackMsg, true)
}

func (this *Role) ShopInfoReq(goodsType int32) {
	ackMsg := &serverproto.SCShopInfoAck{
		Error: int32(serverproto.ErrorCode_ERROR_FAIL),
	}

	if this.roleBag != nil {
		shopTypeData, ok := serverproto.ShopTypeCfgLoader[goodsType]
		if ok {
			if shopTypeData.ShopType == 2 {
				bRet := this.roleShop.GetSpecialShopInfo(goodsType, ackMsg)
				ackMsg.Error = int32(bRet)
			} else {
				bRet := this.roleShop.GetShopInfo(goodsType, ackMsg)
				ackMsg.Error = int32(bRet)
			}
		}

	}
	util.DebugF("send ackMsg msg=%v", ackMsg)
	this.ReplayGate(ackMsg, true)
}

func (this *Role) ShopRefresh(goodsType int32) {
	ackMsg := &serverproto.SCShopRefreshAck{
		Error: int32(serverproto.ErrorCode_ERROR_FAIL),
	}
	if this.roleBag != nil {
		bRet := this.roleShop.HandleSpecialShopRefresh(goodsType, ackMsg)
		ackMsg.Error = int32(bRet)
	}
	this.ReplayGate(ackMsg, true)
}

func (this *Role) RedBagShopExchange() {
	ackMsg := &serverproto.SCRedBagExchangeAck{
		Error: int32(serverproto.ErrorCode_ERROR_FAIL),
	}
	if this.roleBag != nil {
		bRet := this.roleShop.ExchangeRedBagTicket(ackMsg)
		ackMsg.Error = int32(bRet)
	}
	this.ReplayGate(ackMsg, true)
}

// /social相关
func (this *Role) playerSocialOnline() {
	ntfMsg := &serverproto.SSPlayerOnlineNtf{
		BriefInfo: &serverproto.PlayerBriefInfo{
			Uid:      this.GetUUid(),
			NickName: this.GetRoleBase().roleBase.NickName,
		},
	}
	ntfMsg.ServiceNode = service.GetLocalServiceID()
	this.SendAllSocial(ntfMsg)
}

func (this *Role) playerSocialOffline() {
	ntfMsg := &serverproto.SSPlayerOfflineNtf{
		Uid: this.GetUUid(),
	}
	this.SendAllSocial(ntfMsg)
}

func (this *Role) playerGuildOnline(changeType int32) {
	ntfMsg := &serverproto.SSPlayerStateChangeNtf{
		Uid:            this.GetUUid(),
		GuildId:        this.GetRoleGuildId(),
		ChangeType:     changeType,
		DemonFightTime: this.GetRoleGuild().GetDemonFightTime(),
	}
	if changeType == 2 {
		ntfMsg.DemonFightTime = 0
	}
	this.SendGuild(ntfMsg)
}

func (this *Role) PlayerBattleBossOffline() {
	if this.roleMap.ChallengeBossId > 0 {
		ntfMsg := &serverproto.SSPlayerOfflineNtf{
			Uid: this.GetUUid(),
		}
		this.SendBattleBoss(ntfMsg)
		this.roleMap.ChallengeBossId = 0
	}
}
func (this *Role) playerMapOffline() {
	if this.roleCross != nil {
		this.roleCross.PlayerLeave(nil)
	}
}

func (this *Role) playerBattleOffline() {
	if this.roleBattle != nil {
		this.roleBattle.FastBattleTimeOffline()
	}
}

func (this *Role) SetMapRank(selfRank, totalRanks uint32, topRankList []*serverproto.RankPlayerInfo, addSystemMsg bool) {
	if this.roleBattle != nil {
		this.roleBattle.SetMapRank(selfRank, totalRanks, topRankList, addSystemMsg)
	}
}

func (this *Role) GetMapRank() {
	if this.roleBattle != nil {
		this.roleBattle.GetMapRank()
	}
}

func (this *Role) GetQuickBattleReward() {
	if this.roleBattle != nil {
		this.roleBattle.GetQuickBattleReward()
	}
}

// chat
func (this *Role) CheckChatInvalid(targetId uint64, msgType int32, msg *serverproto.CSChatMessageReq) bool {
	if this.roleChat != nil {
		ret := this.roleChat.CheckChatInvalid(targetId, msgType, msg)
		if ret != serverproto.ErrorCode_ERROR_OK {
			ackMsg := &serverproto.SCChatMessageAck{
				Error: int32(ret),
			}
			this.ReplayGate(ackMsg, true)
			return false
		}

		//发送消息
		this.roleChat.SendMsg(targetId, msgType, msg, false)
	}
	return true
}

func (this *Role) GetOfflineMsg(targetId uint64) {
	if this.roleChat != nil {
		ret := this.roleChat.GetOfflineMsg(targetId)
		if ret != serverproto.ErrorCode_ERROR_OK {
			ackMsg := &serverproto.SCChatOfflineMsgAck{
				Error: int32(ret),
			}
			this.ReplayGate(ackMsg, true)
		}
	}
}

// mail
// 添加邮件
type AddMailST struct {
	ConfigId  int32
	MailType  serverproto.MailType
	ItemList  map[int32]int32
	ParamList []int32
	Title     string
	Content   string
}

func (this *Role) AddMail(configId int32, mailType serverproto.MailType, itemList map[int32]int32, paramList []int32, title, content string) {
	if this.roleMail != nil {
		this.roleMail.AddMail(configId, mailType, itemList, paramList, title, content)
	}
}
func (this *Role) AddMailByST(st *AddMailST) {
	if this.roleMail != nil {
		this.roleMail.AddMail(st.ConfigId, st.MailType, st.ItemList, st.ParamList, st.Title, st.Content)
	}
}
func (this *Role) AddMail1(configId int32, mailType int32, itemList []*serverproto.KeyValueType, paramList []int32, title, content string) {
	if this.roleMail != nil {
		this.roleMail.AddMail1(configId, serverproto.MailType(mailType), itemList, paramList,
			title, content)
	}
}

func (this *Role) GetMailIst() {
	if this.roleMail != nil {
		this.roleMail.GetMailList()
	}
}
func (this *Role) MailRead(idList []int32) {
	if this.roleMail != nil {
		ret := this.roleMail.MailRead(idList)
		ackMsg := &serverproto.SCMailReadAck{
			Error: int32(ret),
		}
		this.ReplayGate(ackMsg, true)
	}
}
func (this *Role) MailDelRead() {
	if this.roleMail != nil {
		ret := this.roleMail.MailDelRead()
		ackMsg := &serverproto.SCMailDelReadAck{
			Error: int32(ret),
		}
		this.ReplayGate(ackMsg, true)
	}
}
func (this *Role) MailReward(idList []int32) {
	if this.roleMail != nil {
		ret := this.roleMail.MailReward(idList)
		if ret != serverproto.ErrorCode_ERROR_OK {
			ackMsg := &serverproto.SCMailRewardAck{
				Error: int32(ret),
			}
			this.ReplayGate(ackMsg, true)
		}
	}
}

// 打包数据
func (this *Role) PackRoleViewInfo(info *serverproto.ViewRoleInfo) {
	info.Id = this.uuid
	info.Brief = &serverproto.CommonPlayerBriefInfo{
		Uid:         this.GetUUid(),
		NickName:    this.GetNickName(),
		Gender:      this.GetRoleBase().GetRoleSex(),
		ImgId:       this.GetImageId(),
		FightPower:  int32(this.GetRoleBase().RoleData().FightPower),
		HeadFrameId: this.GetRoleBase().RoleData().HeadFrameId,
		ConfigId:    this.GetRoleBase().RoleData().HeroData.ConfigId,
		VipLevel:    this.GetRoleVipLevel(),
		HeadId:      this.GetHeadId(),
	}
	//这里也是有问题的，后续需要处理
	info.AttrList = this.GetRoleHero().GetMainHero().AttrList
	info.FashionData = this.GetRoleBase().roleBase.FashionData

	info.DanScore = this.GetRoleArena().arenaInfo.Score
	//世界boss，只上阵主角
	info.RoleHero = this.GetRoleBase().RoleData().HeroData
	info.Hero = &serverproto.RoleHero{}
	for _, data := range this.GetRoleHero().heroList {
		info.Hero.HeroData = append(info.Hero.HeroData, data)
	}
	info.Fashion = &serverproto.RoleFashion{}
	//for _, data := range this.roleFashion.fashionData {
	//info.Fashion.FashionList = append(info.Fashion.FashionList, data.id)
	this.roleFashion.CopyData(info.Fashion)

	//}
	for _, data := range this.roleFashion.fashionData {
		info.Fashion.FashionList = append(info.Fashion.FashionList, data.id)
	}

	if this.GetRoleGuild().roleGuild.GuildId != 0 {
		info.GuildName = this.GetRoleGuild().roleGuild.GuildName
	}
	if this.GetRolePet() != nil {
		if info.RoleHero.BattlePetId != 0 {
			pet := this.GetRolePet().getPet(info.RoleHero.BattlePetId)
			if pet != nil {
				info.PetList = append(info.PetList, pet)
			}
		}
		for _, hero := range info.Hero.HeroData {
			if hero.BattlePetId != 0 {
				pet := this.GetRolePet().getPet(hero.BattlePetId)
				if pet != nil {
					info.PetList = append(info.PetList, pet)
				}
			}
		}
	}
}

func (this *Role) GetSignUpInfo() {
	ackMsg := &serverproto.SCSignUpInfoAck{
		Error: int32(serverproto.ErrorCode_ERROR_FAIL),
	}

	if this.roleActivity != nil {
		//检查是否大周期重置
		this.roleActivity.CheckNewCircle()
		ackMsg.Error = int32(serverproto.ErrorCode_ERROR_OK)
		ackMsg.SignInfo = this.roleActivity.signInfo
		ackMsg.CurSignDay = this.roleActivity.GetCurSignDay()
		ackMsg.NextSignTime = this.roleActivity.signInfo.CurSignInfo.LastSign
	}

	this.ReplayGate(ackMsg, true)
}

func (this *Role) OnSignUp() {
	ackMsg := &serverproto.SCSignUpAck{
		Error: int32(serverproto.ErrorCode_ERROR_FAIL),
	}
	if this.roleActivity != nil {
		bRet := this.roleActivity.SignUp(ackMsg)
		ackMsg.Error = int32(bRet)
		ackMsg.NextSignTime = int64(util.GetLatest5Hour())
		ackMsg.SignInfo = this.roleActivity.signInfo
		ackMsg.CurSignDay = this.roleActivity.GetCurSignDay()
	}
	this.ReplayGate(ackMsg, true)
}

// 强制引导
func (this *Role) CompulsoryGuidance(storyId, status int32) {
	ackMsg := &serverproto.SCCompulsoryGuidanceAck{
		Error: int32(serverproto.ErrorCode_ERROR_FAIL),
	}
	if this.GetRoleBase() != nil {
		//设置强制引导
		nRet := this.GetRoleBase().SetCompulsoryId(storyId, status)
		ackMsg.StoryId = storyId
		ackMsg.Status = status
		ackMsg.Error = int32(nRet)
	}
	this.ReplayGate(ackMsg, true)
}

// 爬塔功能信息
// 请求个人的爬塔信息
func (this *Role) ClimbingTowerInfoReq() {
	if this.roleTower != nil {
		this.roleTower.GetClimbingTowerInfo()
	}
}

// 获取试炼馈赠
func (this *Role) GetTowerLevelDayReward() {
	if this.roleTower != nil {
		ret := this.roleTower.GetTowerLevelDayReward()
		if ret != serverproto.ErrorCode_ERROR_OK {
			ackMsg := &serverproto.SCClimbingTowerDayRewardAck{
				Error: int32(ret),
			}
			this.ReplayGate(ackMsg, true)
		}
	}
}

// 查找好友数据
func (this *Role) GetFriendTowerInfo(begin, end int32) {
	if this.roleTower != nil {
		this.roleTower.GetFriendTowerRange(begin, end)
	}
}

// 爬塔开始
func (this *Role) ClimbingTowerBegin(towerLevel int32) {
	ackMsg := &serverproto.SCClimbingTowerBeginAck{
		Error:      int32(serverproto.ErrorCode_ERROR_FAIL),
		TowerLevel: towerLevel,
	}
	if this.roleTower != nil {
		nRet, factorList := this.roleTower.OnTowerFightBegin(towerLevel)
		ackMsg.Error = int32(nRet)
		ackMsg.FactorList = factorList
	}
	this.ReplayGate(ackMsg, true)
}

// 爬塔开始
func (this *Role) ClimbingTowerWjBegin(towerLevel int32) {
	ackMsg := &serverproto.SCClimbingTowerWjBeginAck{
		Error:      int32(serverproto.ErrorCode_ERROR_FAIL),
		TowerLevel: towerLevel,
	}
	if this.roleTower != nil {
		nRet := this.roleTower.OnTowerWjFightBegin(towerLevel)
		ackMsg.Error = int32(nRet)
	}
	this.ReplayGate(ackMsg, true)
}

func (this *Role) ClimbingTowerWjBuff(buff1, buff2, buff3 int32) {
	ackMsg := &serverproto.SCClimbingTowerWjBuffAck{
		Error: int32(serverproto.ErrorCode_ERROR_FAIL),
	}
	if this.roleTower != nil {
		var nRet serverproto.ErrorCode
		ackMsg.Buff1, ackMsg.Buff2, ackMsg.Buff3, nRet = this.roleTower.OnTowerWjFightBuff(buff1, buff2, buff3)
		ackMsg.Error = int32(nRet)
	}
	this.ReplayGate(ackMsg, true)
}

// 爬塔结束
func (this *Role) ClimbingTowerWjEnd(towerLevel, loadingTime int32, recordTimeStamp uint64) {
	ackMsg := &serverproto.SCClimbingTowerWjEndAck{
		Error: int32(serverproto.ErrorCode_ERROR_FAIL),
	}

	if this.roleTower != nil {
		nRet := this.roleTower.OnTowerWjFightEnd(towerLevel, loadingTime, recordTimeStamp, ackMsg)
		ackMsg.Error = int32(nRet)
		//打包newTowerLevel=2的所有好友的数据
		//this.roleTower.PackFriendFightTower(towerLevel, ackMsg)
	}

	this.ReplayGate(ackMsg, true)
}

// 爬塔结束
func (this *Role) ClimbingTowerEnd(towerLevel, loadingTime int32, recordTimeStamp uint64) {
	ackMsg := &serverproto.SCClimbingTowerEndAck{
		Error: int32(serverproto.ErrorCode_ERROR_FAIL),
	}

	if this.roleTower != nil {
		nRet := this.roleTower.OnTowerFightEnd(towerLevel, loadingTime, recordTimeStamp, ackMsg)
		ackMsg.Error = int32(nRet)
		//打包newTowerLevel=2的所有好友的数据
		this.roleTower.PackFriendFightTower(towerLevel, ackMsg)
	}

	this.ReplayGate(ackMsg, true)
}

func (this *Role) GetFriendBriefFromDB(final bool, begin int32, end int32, briefs []*serverproto.CommonPlayerBriefInfo) {
	if this.roleTower != nil {
		this.roleTower.SetFriendBriefInfo(briefs)
		//同时返回数据到客户端
		if final == true {
			this.roleTower.SendClimbingTowerInfo(begin, end)
		}
	}
}

func (this *Role) GetTowerFightCountReward(rushRound int32, rewardType int32) {
	ackMsg := &serverproto.SCRushActivityRewardAck{
		Error:      int32(serverproto.ErrorCode_ERROR_FAIL),
		RewardType: rewardType,
		RushType:   model.Rush_Type_Tower,
	}
	if this.GetRoleTower() != nil {
		nRet := this.GetRoleTower().GetRushTowerBaseReward(ackMsg, rushRound)
		ackMsg.Error = int32(nRet)
	}
	this.ReplayGate(ackMsg, true)
}

func (this *Role) GetRushTowerInfo(ackMsg *serverproto.SCTowerActivityAck, curRushRound int32) {
	if this.GetRoleTower() != nil {
		this.GetRoleTower().GetRushTowerInfo(ackMsg, curRushRound)
	}
}

func (this *Role) GetRushTowerRankReward(ssAck *serverproto.SSGetRushRewardAck) {
	ackMsg := &serverproto.SCRushActivityRewardAck{
		Error:      int32(serverproto.ErrorCode_ERROR_FAIL),
		RewardType: model.Rush_Reward_Type_Rank,
		RushType:   model.Rush_Type_Tower,
	}
	if this.GetRoleTower() != nil {
		nRet := this.GetRoleTower().GetRushTowerRankReward(ssAck)
		if nRet == serverproto.ErrorCode_ERROR_OK {
			ackMsg.ItemList = ssAck.ItemList
		}
		ackMsg.Error = int32(nRet)
	}
	this.ReplayGate(ackMsg, true)
}

// 英灵殿冲榜
func (this *Role) GetArenaFightCountReward(rushRound int32, rewardType int32) {
	ackMsg := &serverproto.SCRushActivityRewardAck{
		Error:      int32(serverproto.ErrorCode_ERROR_FAIL),
		RewardType: rewardType,
		RushType:   model.Rush_Type_Arena,
	}
	if this.GetRoleArena() != nil {
		nRet := this.GetRoleArena().GetRushArenaBaseReward(ackMsg, rushRound)
		ackMsg.Error = int32(nRet)
	}
	this.ReplayGate(ackMsg, true)
}

func (this *Role) GetRushArenaInfo(ackMsg *serverproto.SCArenaActivityAck, curRushRound int32) {
	if this.GetRoleArena() != nil {
		this.GetRoleArena().GetRushArenaInfo(ackMsg, curRushRound)
	}
}

func (this *Role) GetRushArenaRankReward(ssAck *serverproto.SSGetRushRewardAck) {
	ackMsg := &serverproto.SCRushActivityRewardAck{
		Error:      int32(serverproto.ErrorCode_ERROR_FAIL),
		RewardType: model.Rush_Reward_Type_Rank,
		RushType:   model.Rush_Type_Arena,
	}
	if this.GetRoleArena() != nil {
		nRet := this.GetRoleArena().GetRushArenaRankReward(ssAck)
		if nRet == serverproto.ErrorCode_ERROR_OK {
			ackMsg.ItemList = ssAck.ItemList
		}
		ackMsg.Error = int32(nRet)
	}
	this.ReplayGate(ackMsg, true)
}

// 宠物冲榜
func (this *Role) GetPetFightCountReward(rushRound int32, rewardType int32) {
	ackMsg := &serverproto.SCRushActivityRewardAck{
		Error:      int32(serverproto.ErrorCode_ERROR_FAIL),
		RewardType: rewardType,
		RushType:   model.Rush_Type_Pet,
	}
	if this.GetRolePet() != nil {
		nRet := this.GetRolePet().GetBaseScoreReward(ackMsg, rushRound)
		ackMsg.Error = int32(nRet)
	}
	this.ReplayGate(ackMsg, true)
}

func (this *Role) GetRushPetRankReward(ssAck *serverproto.SSGetRushRewardAck) {
	ackMsg := &serverproto.SCRushActivityRewardAck{
		Error:      int32(serverproto.ErrorCode_ERROR_FAIL),
		RewardType: model.Rush_Reward_Type_Rank,
		RushType:   model.Rush_Type_Pet,
	}
	if this.GetRolePet() != nil {
		nRet := this.GetRolePet().GetRushPetRankReward(ssAck)
		if nRet == serverproto.ErrorCode_ERROR_OK {
			ackMsg.ItemList = ssAck.ItemList
		}
		ackMsg.Error = int32(nRet)
	}
	this.ReplayGate(ackMsg, true)
}
func (this *Role) GetRushPetInfo(ackMsg *serverproto.SCPetActivityAck, curRushRound int32) {
	if this.GetRolePet() != nil {
		this.GetRolePet().GetRushPetInfo(ackMsg, curRushRound)
	}
}

// 英灵殿冲榜
func (this *Role) GetFightCountReward(rushRound int32, rushType int32, rewardType int32) {
	ackMsg := &serverproto.SCRushActivityRewardAck{
		Error:      int32(serverproto.ErrorCode_ERROR_FAIL),
		RewardType: rewardType,
		RushType:   rushType,
	}
	if this.GetRoleRush() != nil {
		nRet := this.GetRoleRush().GetBaseReward(ackMsg, rushType, rushRound)
		ackMsg.Error = int32(nRet)
	}
	this.ReplayGate(ackMsg, true)
}

func (this *Role) GetRushInfo(ackMsg *serverproto.SCRushActivityAck, curRushRound int32) {
	if this.GetRoleRush() != nil {
		this.GetRoleRush().GetRushInfo(ackMsg, curRushRound)
	}
}

func (this *Role) GetRushRankReward(ssAck *serverproto.SSGetRushRewardAck) {
	ackMsg := &serverproto.SCRushActivityRewardAck{
		Error:      int32(serverproto.ErrorCode_ERROR_FAIL),
		RewardType: model.Rush_Reward_Type_Rank,
		RushType:   ssAck.RushType,
	}
	if this.GetRoleRush() != nil {
		nRet := this.GetRoleRush().GetRushRankReward(ssAck)
		if nRet == serverproto.ErrorCode_ERROR_OK {
			ackMsg.ItemList = ssAck.ItemList
		}
		ackMsg.Error = int32(nRet)
	}
	this.ReplayGate(ackMsg, true)
}

//1:bossReward 2:pvp
func (this *Role) GetBattleRecord(recordType int32, paramList []uint32) {
	if len(paramList) <= 0 {
		ackMsg := &serverproto.SCPlayerBattleRecordAck{
			Error: int32(serverproto.ErrorCode_ERROR_FAIL),
		}
		this.ReplayGate(ackMsg, true)
		return
	}

	msgReq := &serverproto.CSPlayerBattleRecordReq{
		RecordType: recordType,
		ParamList:  paramList,
	}
	this.SendRank(msgReq)
}

func (this *Role) OnGetBattleRecordAck(ssMsg *serverproto.SCPlayerBattleRecordAck) {
	ackMsg := &serverproto.SCPlayerBattleRecordAck{}
	for idx := 0; idx < len(ssMsg.RecordList); idx++ {
		levelCfgData, ok := serverproto.LevelCfgLoader[ssMsg.RecordList[idx].MapLevelId]
		if !ok || levelCfgData.Version > ssMsg.RecordList[idx].BattleVersion {
			continue
		}
		ackMsg.RecordList = append(ackMsg.RecordList, ssMsg.RecordList[idx])
	}

	this.ReplayGate(ackMsg, true)
}

// ////////////////////////////       公会功能        //////////////////////////////////////
// 创建工会
func (this *Role) CheckBuildGuild(guildName string, guildBadge int32) serverproto.ErrorCode {
	//检查是否有公会，有就据掉，没有就转GuildServer
	bRet := this.GetRoleGuild().CanBuildGuild(guildName)
	if bRet != serverproto.ErrorCode_ERROR_OK { //有工会不能创建
		ackMsg := &serverproto.SCBuildGuildAck{
			Error: int32(bRet),
		}
		this.ReplayGate(ackMsg, true)
		return bRet
	}
	return serverproto.ErrorCode_ERROR_OK
}

func (this *Role) CheckApplyGuild(guildId uint64) bool {
	//检查是否有公会，有就据掉，没有就转GuildServer
	//检查是否在被拒绝列表中
	bRet := this.GetRoleGuild().CheckApply(guildId)
	if bRet != serverproto.ErrorCode_ERROR_OK {
		ackMsg := &serverproto.SCApplyGuildAck{
			Error: int32(bRet),
		}
		this.ReplayGate(ackMsg, true)
		return false
	}
	return true
}

// 申请处理
func (this *Role) CheckApplyInfo(msg *serverproto.CSApplyInfoHandleReq) serverproto.ErrorCode {
	if this.GetRoleGuild().roleGuild.GuildId == 0 {
		ackMsg := &serverproto.SCApplyInfoHandleAck{
			Error: int32(serverproto.ErrorCode_ERROR_GUILD_NOT_IN_GUILD),
		}
		this.ReplayGate(ackMsg, true)
		return serverproto.ErrorCode_ERROR_GUILD_NOT_IN_GUILD
	}
	return serverproto.ErrorCode_ERROR_OK
}

func (this *Role) CheckGuildModifyInfo(msg *serverproto.CSSetGuildInfoReq) serverproto.ErrorCode {
	if this.GetRoleGuildId() == 0 {
		return serverproto.ErrorCode_ERROR_GUILD_NOT_IN_GUILD
	}
	//公告长度
	lenData, ok1 := serverproto.GlobalCfgLoader[int32(serverproto.GlobalType_Global_Guild_Recruit_Max_Len)]
	if !ok1 {
		return serverproto.ErrorCode_ERROR_FAIL
	}
	noticeLen := utf8.RuneCountInString(msg.RecruitNotice)
	if int32(noticeLen) > lenData.IVal {
		return serverproto.ErrorCode_ERROR_GUILD_NOTICE_LEN
	}
	//检查敏感字
	bSensitive := SensitiveUtil.IsMatch(msg.RecruitNotice)
	if bSensitive == true {
		return serverproto.ErrorCode_ERROR_GUILD_NAME_SENSITIVE
	}
	//校验徽章是否存在，
	_, ok := serverproto.GuildBadgeCfgLoader[msg.GuildBadge]
	if ok == false {
		return serverproto.ErrorCode_ERROR_GUILD_CONFIG_NOT_FOUND
	}
	//校验入会等级是否合理
	globalData, ok := serverproto.GlobalCfgLoader[int32(serverproto.GlobalType_Global_Guild_Apply_Level)]
	if !ok {
		return serverproto.ErrorCode_ERROR_GUILD_CONFIG_NOT_FOUND
	}
	levelRes := strings.Split(globalData.SVal, ":")
	if len(levelRes) >= 2 {
		minLevel, _ := model.Str2Num(levelRes[0])
		maxLevel, _ := model.Str2Num(levelRes[1])
		if int32(minLevel) > msg.JoinLevel || msg.JoinLevel > int32(maxLevel) {
			return serverproto.ErrorCode_ERROR_GUILD_OUT_APPLY_LEVEL
		}
	}

	return serverproto.ErrorCode_ERROR_OK
}

func (this *Role) CheckGuildRename(guildName string) serverproto.ErrorCode {
	if this.GetRoleGuildId() == 0 {
		return serverproto.ErrorCode_ERROR_GUILD_NOT_IN_GUILD
	}
	nameLen := utf8.RuneCountInString(guildName)
	if int32(nameLen) < model.GlobalGuildMinNameStringLen || int32(nameLen) > model.GlobalGuildMaxNameStringLen {
		return serverproto.ErrorCode_ERROR_GUILD_NAME_LEN
	}
	//检查敏感字
	bSensitive := SensitiveUtil.IsMatch(guildName)
	if bSensitive == true {
		return serverproto.ErrorCode_ERROR_GUILD_NAME_SENSITIVE
	}
	//校验消耗
	globalData, ok := serverproto.GlobalCfgLoader[int32(serverproto.GlobalType_Global_Guild_Rename_Cost)]
	if !ok {
		return serverproto.ErrorCode_ERROR_GUILD_CONFIG_NOT_FOUND
	}
	var costItemList = map[int32]int32{}
	costRes := strings.Split(globalData.SVal, ":")
	if len(costRes) >= 2 {
		itemId, _ := model.Str2Num(costRes[0])
		itemNum, _ := model.Str2Num(costRes[1])
		costItemList[int32(itemId)] += int32(itemNum)
	}
	bRet := this.CheckResLitNum(costItemList)
	if bRet == false {
		return serverproto.ErrorCode_ERROR_RES_NOT_ENOUGH
	}

	return serverproto.ErrorCode_ERROR_OK
}

func (this *Role) CheckGuildRenotice(notice string) serverproto.ErrorCode {
	globalData, ok := serverproto.GlobalCfgLoader[int32(serverproto.GlobalType_Global_Guild_Notice_Max_Len)]
	if !ok {
		return serverproto.ErrorCode_ERROR_FAIL
	}
	if this.GetRoleGuildId() == 0 {
		return serverproto.ErrorCode_ERROR_GUILD_NOT_IN_GUILD
	}
	//检查敏感字
	bSensitive := SensitiveUtil.IsMatch(notice)
	if bSensitive == true {
		return serverproto.ErrorCode_ERROR_GUILD_NAME_SENSITIVE
	}

	noticeLen := utf8.RuneCountInString(notice)
	if int32(noticeLen) > globalData.IVal {
		return serverproto.ErrorCode_ERROR_GUILD_NOTICE_LEN
	}
	return serverproto.ErrorCode_ERROR_OK
}

func (this *Role) CheckGuildBossChallenge(bossId uint32, damage uint32, fightTime uint32) serverproto.ErrorCode {
	//检查是否有公会，
	guildId := this.GetRoleGuildId()
	if guildId == 0 {
		return serverproto.ErrorCode_ERROR_GUILD_NOT_IN_GUILD
	}
	bRet := this.GetRoleGuild().CheckBossFight(bossId, damage, fightTime)

	return bRet
}

func (this *Role) OnChangeGuileNameSuccess() {
	//扣除消耗
	globalData, ok := serverproto.GlobalCfgLoader[int32(serverproto.GlobalType_Global_Guild_Rename_Cost)]
	if !ok {
		return
	}
	var costItemList = map[int32]int32{}
	costRes := strings.Split(globalData.SVal, ":")
	if len(costRes) >= 2 {
		itemId, _ := model.Str2Num(costRes[0])
		itemNum, _ := model.Str2Num(costRes[1])
		costItemList[int32(itemId)] += int32(itemNum)
	}
	bRet := this.CheckResLitNum(costItemList)
	if bRet == false {
		return
	}
	this.DelItemList(costItemList, AddItemST{AddFrom: AddFrom_Guild})
}

func (this *Role) GetRoleGuildId() uint64 {
	if this.GetRoleGuild() == nil {
		return 0
	}
	return this.GetRoleGuild().roleGuild.GuildId
}

func (this *Role) GuildDemonBuyFightCount(buyCount int32) {
	if this.GetRoleGuild() != nil {
		ackMsg := &serverproto.SCGuildDemonBuyFightCountAck{}

		err, leftUseCount, leftBuyCount := this.GetRoleGuild().BuyDemonFightCount(buyCount)

		ackMsg.Error = int32(err)
		ackMsg.LeftFightCount = leftUseCount
		ackMsg.LeftBuyCount = leftBuyCount
		this.ReplayGate(ackMsg, true)
	}
}

func (this *Role) GetRoleVipLevel() int32 {
	if this.GetRoleBase() != nil {
		return this.GetRoleBase().roleBase.VipLevel
	}
	return 0
}

func (this *Role) GetHeadId() int32 {
	if this.roleHead != nil {
		return this.roleHead.GetHeadIdIng()
	}
	return 0
}

func (this *Role) GetHeadMag() *RoleHead {
	return this.roleHead
}

func (this *Role) OnDrawReq(drawType int32, drawCount int32) {
	ackMsg := &serverproto.SCDrawCardAck{
		DrawType:  drawType,
		DrawCount: drawCount,
	}
	if this.roleDraw != nil {
		bRet := this.GetRoleDraw().DrawReq(drawType, drawCount, ackMsg)
		ackMsg.Error = int32(bRet)
	}
	this.ReplayGate(ackMsg, true)
}

func (this *Role) CheckRushShopInfoGet(goodsType, goodsId, count int32) bool {
	reqMsg := &serverproto.SSGetRushShopBuyReq{}

	switch (serverproto.PayGoodsType)(goodsType) {
	case serverproto.PayGoodsType_EPayType_RushTower:
		reqMsg.RushType = model.Rush_Type_Tower
	case serverproto.PayGoodsType_EPayType_RushArena:
		reqMsg.RushType = model.Rush_Type_Arena
	case serverproto.PayGoodsType_EPayType_RushMap:
		reqMsg.RushType = model.Rush_Type_Map
	case serverproto.PayGoodsType_EPayType_RushPet:
		reqMsg.RushType = model.Rush_Type_Pet
	case serverproto.PayGoodsType_EPayType_RushSkill:
		reqMsg.RushType = model.Rush_Type_Skill
	default:
		return false
	}

	reqMsg.Uid = this.GetUUid()
	reqMsg.ShopType = goodsType
	reqMsg.GoodsId = goodsId
	reqMsg.GoodsNum = count
	this.SendRank(reqMsg)
	return true
}

func (this *Role) OnPayCallback2(cpOrderId uint64) {
	msg33 := &serverproto.SSPayOrderDbReq{
		Uid:       this.GetUUid(),
		CpOrderId: cpOrderId,
	}
	this.SendDb(msg33)
}

func (this *Role) CheckOrderInfo(payRewardInfo *serverproto.PayOrderSaveInfo) bool {
	if payRewardInfo == nil {
		return false
	}
	if this.roleBag.CanDelItem(40001, int32(payRewardInfo.Amount*100)) {
		this.DelItem(40001, int32(payRewardInfo.Amount*100), AddItemST{
			AddFrom: AddFrom_Activities,
		})
		util.ErrorF("uid:%v use cash buy :%v", this.GetUUid(), payRewardInfo.CpOrderId)
		return true
	}
	return false
}

func (this *Role) PayInfoGet(goodsType, goodsId, count int32, rushStage, rushRound int32, cpOrderId uint64, sdkOrderId string) {
	//合服期间，无法进行飞艇探索
	if goodsType == int32(serverproto.PayGoodsType_EPayType_RuneExplore) {
		bRet := this.CheckInCombinedService()
		if bRet == true {
			ackMsg := &serverproto.SCPayInfoGetAck{
				Error:     int32(serverproto.ErrorCode_ERROR_RUNE_EXPLORE_ON_COMBINE_SERVER),
				GoodsType: goodsType,
				GoodsId:   goodsId,
				Count:     count,
			}
			this.ReplayGate(ackMsg, true)
			return
		}
	}

	ret, payOrderInfo := this.payInfoGet(goodsType, goodsId, count, rushStage, rushRound, cpOrderId)

	ackMsg := &serverproto.SCPayInfoGetAck{
		Error:     int32(ret),
		GoodsType: goodsType,
		GoodsId:   goodsId,
		Count:     count,
	}
	msg33 := &serverproto.SSGetServerPayMailReq{
		Uid: this.GetUUid(),
		//ZoneId:    int32(service.GetServiceConfig().Node.Zone),
	}
	this.SendDb(msg33)
	if ret == serverproto.ErrorCode_ERROR_OK {
		// 如果是免费或者价格为0时直接购买成功
		if payOrderInfo.Amount <= 0 {
			ntfMsg := &serverproto.SCPayForGoodsNtf{}
			ntfMsg.GoodsId = goodsId
			ntfMsg.ItemList = payOrderInfo.RewardList
			ntfMsg.GoodsType = goodsType
			ntfMsg.GoodsNum = count
			ntfMsg.CpOrderId = 0
			ackMsg.Error = int32(serverproto.ErrorCode_ERROR_PAY_GOOD_PRICE_FREE)
			this.ReplayGate(ackMsg, true)
			this.ReplayGate(ntfMsg, true)

			util.InfoF("uid=%v free: shop:%v id:%v, count:%v", this.GetUUid(), payOrderInfo.GoodsType, payOrderInfo.GoodsId, payOrderInfo.Count)
			return
		}
		calCeilAmount := math.Ceil(float64(payOrderInfo.Amount))
		// 按照配置比例获取RO币
		if model.GlobalRoCoinFactor > 0 {
			tmpRoCoin := calCeilAmount * float64(model.GlobalRoCoinFactor)
			//util.ErrorF("ro1111:%v  ,%v   ,%v", tmpRoCoin, calCeilAmount, model.GlobalRoCoinFactor)
			payOrderInfo.RewardList = append(payOrderInfo.RewardList, &serverproto.KeyValueType{
				Key:   int32(serverproto.ResType_Res_ROCoin),
				Value: int32(tmpRoCoin),
			})
		}
		//给VIP经验
		if model.GlobalRMBToVipExpRMB > 0 {
			vipExp := float32(calCeilAmount) * model.GlobalRMBToVipExpVip / float32(model.GlobalRMBToVipExpRMB)
			payOrderInfo.RewardList = append(payOrderInfo.RewardList, &serverproto.KeyValueType{
				Key:   int32(serverproto.ResType_Res_VipExp),
				Value: int32(vipExp),
			})
			//this.role.AddRes(int32(serverproto.ResType_Res_VipExp), AddItemST{ItemCount: int32(vipExp)}, true)
		}

		if service.GetServiceConfig().Node.AuthMode == AUTHMODE_PC {
			//内网PC模式下直接购买成功
			ackMsg.Error = int32(serverproto.ErrorCode_ERROR_PAY_PRODUCTION_MODE)
			this.ReplayGate(ackMsg, true)
			this.OnPayCallback(payOrderInfo, false, false, false)
			util.InfoF("uid=%v pc mode: shop:%v id:%v, count:%v, price:%v", this.GetUUid(), payOrderInfo.GoodsType, payOrderInfo.GoodsId, payOrderInfo.Count, payOrderInfo.Amount)
			return
		} else if service.GetServiceConfig().Node.AuthMode == AUTHMODE_ACTIVE {
			//激活码模式下提示充值功能未开放
			ackMsg.Error = int32(serverproto.ErrorCode_ERROR_PAY_NOT_OPEN)
			this.ReplayGate(ackMsg, true)
			util.InfoF("uid=%v pc mode: shop:%v id:%v, count:%v, price:%v", this.GetUUid(), payOrderInfo.GoodsType, payOrderInfo.GoodsId, payOrderInfo.Count, payOrderInfo.Amount)
			return
		}
		server := int(payOrderInfo.SId / 2)
		corderid := strconv.FormatUint(payOrderInfo.CpOrderId, 10)
		price := fmt.Sprintf("%.2f", payOrderInfo.Amount)
		guid, _ := strconv.Atoi(this.Guid2)
		name := this.GetNickName()
		if name == "" {
			name = "Player"
		}
		ordeinfo := OrderRequest{
			GameArea:          strconv.Itoa(server),
			GameLevel:         strconv.Itoa(int(this.GetRoleLevel())),
			GameOrderId:       corderid,
			GameCurrency:      "USD",
			GamePrice:         price,
			GameRoleId:        strconv.Itoa(int(this.GetUUid())),
			GameRoleName:      name,
			GameGuid:          guid,
			NotifyId:          service.GetServiceConfig().Node.PayCallBack,
			Subject:           price + " Pack",
			GameAccessVersion: "2507",
		}
		extra := &Extras{
			ServerId:  server,
			Platform:  this.platform,
			CpOrderId: corderid,
		}
		v, _ := json.Marshal(extra)
		ordeinfo.ExtendsInfoData = string(v)

		payOrderInfo.SdkOrderId = sdkOrderId
		//保存订单信息到数据库
		ackMsg.Amount = payOrderInfo.Amount
		ackMsg.CpOrderId = payOrderInfo.CpOrderId
		//ackMsg.GoodsName = payOrderInfo.GoodsName
		info, err := GenerateGameSign(ordeinfo, "MIGfMA0GCSqGSIb3DQEBAQUAA4GNADCBiQKBgQDCfYd3FqSaWqCpWLSktBSSgAelt0F6T+tO4C25YKR/6X/sPacDBbX662/0fW+H+YbXigHWFB/yangkhiZTpD/VmiOo5lISX6L0/m+13ti9b8jzTZcfVngfLsP+Ztbk81N1Jk0gWF4bndZxREJ3IxcEDHnIrwXgLGA2GJ89kdgudwIDAQAB")
		if err != nil {
			ackMsg.Error = int32(serverproto.ErrorCode_ERROR_PAY_NOT_OPEN)
			this.ReplayGate(ackMsg, true)
			util.ErrorF("uid=%v GenerateGameSign err:%v", this.GetUUid(), err)
			return
		}
		ordeinfo.GameSign = info
		b, _ := json.Marshal(ordeinfo)
		payOrderInfo.GoodsName = string(b)

		util.ErrorF("uid:%v pay info platform:%v order:%v", this.GetUUid(), this.platform, payOrderInfo)
		ssSaveReqMsg := &serverproto.SSPayInfoSaveReq{
			PayOrderInfo: payOrderInfo,
			SaveNotify:   true,
		}
		this.SendDb(ssSaveReqMsg)
	} else {
		this.ReplayGate(ackMsg, true)
	}
}

func GenerateGameSign(params interface{}, rsaPublicKey string) (string, error) {
	// 1. 将结构体转换为 map
	paramsMap, err := structToMap(params)
	if err != nil {
		return "", err
	}

	// 2. 过滤掉 game_sign 字段
	delete(paramsMap, "game_sign")

	// 3. 获取所有 key 并排序（字典序）
	keys := make([]string, 0, len(paramsMap))
	for k := range paramsMap {
		keys = append(keys, k)
	}
	sort.Strings(keys)

	// 4. 按顺序构建 QueryString
	var queryParts []string
	for _, k := range keys {
		v := paramsMap[k]
		// 跳过空值或零值（根据实际需求调整）
		if v == "" || v == nil {
			continue
		}
		// 将值转换为字符串
		strValue := fmt.Sprintf("%v", v)
		queryParts = append(queryParts, fmt.Sprintf("%s=%s", k, strValue))
	}
	queryString := strings.Join(queryParts, "&")

	// 5. 在 QueryString 后面拼接 RSA 公钥
	stringToSign := queryString + rsaPublicKey

	// 6. 计算 MD5
	hash := md5.Sum([]byte(stringToSign))
	sign := hex.EncodeToString(hash[:])

	return sign, nil
}

// structToMap 将结构体转换为 map[string]interface{}
// 使用 json tag 作为 key
func structToMap(obj interface{}) (map[string]interface{}, error) {
	result := make(map[string]interface{})

	v := reflect.ValueOf(obj)
	t := reflect.TypeOf(obj)

	// 如果是指针，获取其指向的值
	if v.Kind() == reflect.Ptr {
		v = v.Elem()
		t = t.Elem()
	}

	// 确保是结构体类型
	if v.Kind() != reflect.Struct {
		return nil, fmt.Errorf("expected struct, got %v", v.Kind())
	}

	for i := 0; i < v.NumField(); i++ {
		field := t.Field(i)
		value := v.Field(i)

		// 获取 json tag
		jsonTag := field.Tag.Get("json")
		if jsonTag == "" || jsonTag == "-" {
			continue
		}

		// 处理 omitempty（去除后面的,omitempty）
		jsonTag = strings.Split(jsonTag, ",")[0]

		// 获取字段值
		if value.Kind() == reflect.Ptr && value.IsNil() {
			result[jsonTag] = nil
		} else {
			result[jsonTag] = value.Interface()
		}
	}

	return result, nil
}

type OrderRequest struct {
	// 訂單擴展數據，支持JSON或QueryString格式
	ExtendsInfoData string `json:"extends_info_data"` // 最大128字符

	// 角色所在的遊戲區，須與X7game平台上傳的開服表信息中的支付顯示區服欄位一致
	GameArea string `json:"game_area"` // 最大20字符，必填

	// 用戶遊戲中角色等級
	GameLevel string `json:"game_level"` // 最大30字符，必填

	// 遊戲訂單號
	GameOrderId string `json:"game_orderid"` // 最大100字符，必填

	// 貨幣單位，可用值：CNY,USD,HKD,VND,KRW (game_access_version=7.98時新增)
	GameCurrency string `json:"game_currency"` // 最大10字符，必填

	// 商品價格，保留小數點後兩位
	GamePrice string `json:"game_price"` // 格式：10,2，必填

	// 用戶遊戲中角色id信息
	GameRoleId string `json:"game_role_id"` // 最大30字符，必填

	// 用戶遊戲中角色名稱
	GameRoleName string `json:"game_role_name"` // 最大30字符，必填

	// 用戶遊戲小號的唯一標識
	GameGuid int `json:"game_guid"` // 最大12位整數，必填

	// 支付回調通知id，可設置為-1，但不允許為0
	NotifyId string `json:"notify_id"` // 最大11字符，必填

	// 道具簡介
	Subject string `json:"subject"` // 最大100字符，必填

	// 簽名，將其他所有字段按字典序生成QueryString後拼接小7RSA公鑰，再MD5
	GameSign string `json:"game_sign"` // 最大32字符，必填

	// 接入簽名方式版本，新遊戲接入選擇 '2507'
	GameAccessVersion string `json:"game_access_version"` // 最大10字符，必填
}

type Extras struct {
	ServerId    int    `json:"serverId"`
	Platform    string `json:"platform"`
	SubPlatform string `json:"subPlatform"`
	Bima        string `json:"bima"`
	CpOrderId   string `json:"cpOrderId"`
}

func (this *Role) payInfoGet(goodsType, goodsId, count int32, rushStage, rushRound int32, cpOrderId uint64) (serverproto.ErrorCode, *serverproto.PayOrderSaveInfo) {
	if count <= 0 {
		return serverproto.ErrorCode_ERROR_PAY_ITEM_NO, nil
	}
	payRewardInfo := &serverproto.PayOrderSaveInfo{
		OrderState: int32(serverproto.PayOrderState_EPayOrderState_Gen),
		GoodsId:    goodsId,
		GoodsType:  goodsType,
		//早期uid生成规则修改过一次，老的uid无法通过uid来获取到zoneid
		//CpOrderId:        model.GenerateUidByZone(int(this.GetSelectZone())),
		Uid:              this.GetUUid(),
		OrderProcessTime: util.GetTimeMilliseconds(),
		SId:              int32(service.GetServiceConfig().Node.Zone),
	}

	if cpOrderId > 0 {
		payRewardInfo.CpOrderId = cpOrderId
	} else {
		payRewardInfo.CpOrderId = model.GenerateUidByZone(int(this.GetSelectZone()))
	}

	// 根据goodsType查找对应系统物品是否存在，并获得价格，物品
	// for test
	//payRewardInfo.Count = count
	//payRewardInfo.Amount = 1
	//payRewardInfo.GoodsName = "testgoods"
	//payRewardInfo.RewardList = append(payRewardInfo.RewardList, &serverproto.KeyValueType{Key: 1, Value: 1000})
	switch (serverproto.PayGoodsType)(goodsType) {
	case serverproto.PayGoodsType_EPayType_Discount: //超值礼包购买
		if !this.roleActivity.PayInfoGetDiscount(payRewardInfo) {
			return serverproto.ErrorCode_ERROR_PAY_ITEM_NO, nil
		}
	case serverproto.PayGoodsType_EPayType_MonthCard:
		bRet := this.roleRune.BuyMonthCardShopItem(payRewardInfo)
		if bRet != serverproto.ErrorCode_ERROR_OK {
			return bRet, nil
		}
	case serverproto.PayGoodsType_EPayType_NormalBag:
		bRet := this.roleRune.BuyBagShopItem(payRewardInfo)
		if bRet != serverproto.ErrorCode_ERROR_OK {
			return bRet, nil
		}
	case serverproto.PayGoodsType_EPayType_LimitBag:
		bRet := this.roleRune.BuyLimitShopItem(payRewardInfo)
		if bRet != serverproto.ErrorCode_ERROR_OK {
			return bRet, nil
		}
	case serverproto.PayGoodsType_EPayType_RushTower:
		bRet := this.roleRune.BuyRushTowerShopItem(payRewardInfo, rushStage, rushRound)
		if bRet != serverproto.ErrorCode_ERROR_OK {
			return bRet, nil
		}
	case serverproto.PayGoodsType_EPayType_RushArena:
		bRet := this.roleRune.BuyRushArenaShopItem(payRewardInfo, rushStage, rushRound)
		if bRet != serverproto.ErrorCode_ERROR_OK {
			return bRet, nil
		}
	case serverproto.PayGoodsType_EPayType_RushMap:
		bRet := this.roleRune.BuyRushMapShopItem(payRewardInfo, rushStage, rushRound)
		if bRet != serverproto.ErrorCode_ERROR_OK {
			return bRet, nil
		}
	case serverproto.PayGoodsType_EPayType_GuildBattle:
		bRet := this.roleRune.BuyGuildBattleShopItem(payRewardInfo)
		if bRet != serverproto.ErrorCode_ERROR_OK {
			return bRet, nil
		}
	case serverproto.PayGoodsType_EPayType_RuneExplore:
		bRet := this.roleRune.BuyRuneExplore(payRewardInfo)
		if bRet != serverproto.ErrorCode_ERROR_OK {
			return bRet, nil
		}
	case serverproto.PayGoodsType_EPayType_RushPet:
		bRet := this.roleRune.BuyRushPetShopItem(payRewardInfo, rushStage, rushRound)
		if bRet != serverproto.ErrorCode_ERROR_OK {
			return bRet, nil
		}
	case serverproto.PayGoodsType_EPayType_RushSkill:
		bRet := this.roleRune.BuyRushSkillShopItem(payRewardInfo, rushStage, rushRound)
		if bRet != serverproto.ErrorCode_ERROR_OK {
			return bRet, nil
		}
	case serverproto.PayGoodsType_EPayType_RushIdol:
		bRet := this.roleRune.BuyIdolSeasonShopItem(payRewardInfo)
		if bRet != serverproto.ErrorCode_ERROR_OK {
			return bRet, nil
		}
	case serverproto.PayGoodsType_EPayType_SpecialPrivilege:
		// 特权卡商店
		bRet := this.roleRune.BuySpecialPrivilegeShopItem(payRewardInfo)
		if bRet != serverproto.ErrorCode_ERROR_OK {
			return bRet, nil
		}
	case serverproto.PayGoodsType_EPayType_PassCheck:
		// RO通行证
		bRet := this.roleRune.BuyPassCheck(payRewardInfo)
		if bRet != serverproto.ErrorCode_ERROR_OK {
			return bRet, nil
		}
	case serverproto.PayGoodsType_EPayType_BTRecharge100:
		// bt百元大礼包充值
		bRet := this.roleBT.BuyRecharge100(payRewardInfo)
		if bRet != serverproto.ErrorCode_ERROR_OK {
			return bRet, nil
		}
	default:
		return serverproto.ErrorCode_ERROR_FAIL, nil
	}

	//payRewardInfo.GoodsName = service.GetServiceConfig().Node.PayCallBack
	//util.ErrorF("uid:%v pay info platform:%v order:%v", this.GetUUid(), this.platform, payRewardInfo)
	//if this.platform == SDKPlatform_YouYi_IOS || this.platform == "PC" {
	//	payRewardInfo.GoodsName += ",1"
	//}
	return serverproto.ErrorCode_ERROR_OK, payRewardInfo
}

func (this *Role) OnPayCallback(payRewardInfo *serverproto.PayOrderSaveInfo, bSave bool, bAck, bCash bool) {
	//获取充值奖励
	var addItemList = map[int32]int32{}
	for idx := 0; idx < len(payRewardInfo.RewardList); idx++ {
		if bCash && (payRewardInfo.RewardList[idx].Key == int32(serverproto.ResType_Res_ROCoin) || payRewardInfo.RewardList[idx].Key == int32(serverproto.ResType_Res_VipExp)) {
			continue
		}
		addItemList[payRewardInfo.RewardList[idx].Key] += payRewardInfo.RewardList[idx].Value
	}
	if this.GetRoleBag().CanAddItemList(addItemList) == serverproto.ErrorCode_ERROR_OK {
		if payRewardInfo.GoodsType == int32(serverproto.PayGoodsType_EPayType_MonthCard) ||
			payRewardInfo.GoodsType == int32(serverproto.PayGoodsType_EPayType_NormalBag) ||
			payRewardInfo.GoodsType == int32(serverproto.PayGoodsType_EPayType_LimitBag) ||
			payRewardInfo.GoodsType == int32(serverproto.PayGoodsType_EPayType_RushTower) ||
			payRewardInfo.GoodsType == int32(serverproto.PayGoodsType_EPayType_RushMap) ||
			payRewardInfo.GoodsType == int32(serverproto.PayGoodsType_EPayType_RushPet) ||
			payRewardInfo.GoodsType == int32(serverproto.PayGoodsType_EPayType_RushSkill) ||
			payRewardInfo.GoodsType == int32(serverproto.PayGoodsType_EPayType_RushArena) ||
			payRewardInfo.GoodsType == int32(serverproto.PayGoodsType_EPayType_RushIdol) {
			this.AddItemList(addItemList, AddFrom_Rune, true)
		} else {
			this.AddItemList(addItemList, AddFrom_Pay, true)
		}
	} else {
		mailST := &AddMailST{
			ConfigId: model.GlobalMailIdPayReward,
			MailType: serverproto.MailType_MailType_Pay,
			ItemList: addItemList,
		}
		this.AddMailByST(mailST)
		util.InfoF("uid=%v OnPayCallback add bag error, use mail payRewardInfo=%v", this.GetUUid(), payRewardInfo)
	}

	if bAck {
		ackMsg := &serverproto.SCPayInfoOrderOKListGetAck{}
		for k, v := range addItemList {
			ackMsg.RewardItemList = append(ackMsg.RewardItemList, &serverproto.KeyValueType{Key: k, Value: v})
		}
		this.ReplayGate(ackMsg, true)
	}

	//根据各个系统处理不同情况
	switch (serverproto.PayGoodsType)(payRewardInfo.GoodsType) {
	case serverproto.PayGoodsType_EPayType_Discount: //超值礼包购买
		this.roleActivity.OnPayInfoGetDiscount(payRewardInfo)
	case serverproto.PayGoodsType_EPayType_MonthCard: //
		this.GetRoleRune().OnBuyMonthCardShopItem(payRewardInfo)
	case serverproto.PayGoodsType_EPayType_NormalBag: //
		fallthrough
	case serverproto.PayGoodsType_EPayType_LimitBag: //
		this.GetRoleRune().OnBuyItemSuccess(payRewardInfo)
	case serverproto.PayGoodsType_EPayType_RushTower: //
		fallthrough
	case serverproto.PayGoodsType_EPayType_RushMap: //
		fallthrough
	case serverproto.PayGoodsType_EPayType_RushPet: //
		fallthrough
	case serverproto.PayGoodsType_EPayType_RushSkill: //
		fallthrough
	case serverproto.PayGoodsType_EPayType_RushArena: //
		this.GetRoleRune().OnBuyRushShopSuccess(payRewardInfo)
	case serverproto.PayGoodsType_EPayType_GuildBattle:
		this.GetRoleRune().OnBuyGuildBattleSuccess(payRewardInfo)
	case serverproto.PayGoodsType_EPayType_RuneExplore:
		this.GetRoleRune().RuneUnlock()
	case serverproto.PayGoodsType_EPayType_RushIdol:
		this.GetRoleRune().OnBuyIdolSeasonSuccess(payRewardInfo)
	case serverproto.PayGoodsType_EPayType_SpecialPrivilege:
		// 特权卡商店
		this.GetRoleRune().OnBuySpecialPrivilege(payRewardInfo)
	case serverproto.PayGoodsType_EPayType_PassCheck:
		// RO通行证
		this.GetRoleRune().OnBuyPassCheck(payRewardInfo)
	case serverproto.PayGoodsType_EPayType_BTRecharge100:
		// bt百元大礼包充值
		this.roleBT.OnBuyRecharge100(payRewardInfo)
	default:
	}

	ntfMsg := &serverproto.SCPayForGoodsNtf{}
	ntfMsg.GoodsId = payRewardInfo.GoodsId
	ntfMsg.ItemList = payRewardInfo.RewardList
	ntfMsg.GoodsType = payRewardInfo.GoodsType
	ntfMsg.GoodsNum = payRewardInfo.Count
	ntfMsg.CpOrderId = payRewardInfo.CpOrderId
	this.ReplayGate(ntfMsg, true)

	//充值金额 payRewardInfo.Amount
	// 充值成功后的系统相关处理,代金券购买的不计入
	if bCash {
		this.GetRoleBase().AddPayRecharge(payRewardInfo)
	}
	////////
	if bSave {
		payRewardInfo.OrderState = int32(serverproto.PayOrderState_EPayOrderState_PayOkReward)
		ssSaveReqMsg := &serverproto.SSPayInfoSaveReq{
			PayOrderInfo: payRewardInfo,
		}
		this.SendDb(ssSaveReqMsg)
	}
}

func (this *Role) PayInfoGetForCreditRecharge(goodsId, count int32) {
	err := this.roleRune.BuyCreditRechargeShopItem(goodsId, count)
	if err != serverproto.ErrorCode_ERROR_OK {
		ackMsg := &serverproto.SCCreditRechargeShopItemBuyAck{
			Error:   int32(err),
			GoodsId: goodsId,
		}
		this.ReplayGate(ackMsg, true)
	}
}

// 领取特权卡奖励
func (this *Role) SpecialPrivilegeReward() {
	err := this.roleRune.SpecialPrivilegeReward()
	if err != serverproto.ErrorCode_ERROR_OK {
		ackMsg := &serverproto.SCRuneSpecialPrivilegeRewardAck{
			Error: int32(err),
		}
		this.ReplayGate(ackMsg, true)
	}
}
func (this *Role) PayInfoGetForRoCoin(goodsId, count int32) {
	err := this.roleRune.PayInfoGetForRoCoin(goodsId, count)
	if err != serverproto.ErrorCode_ERROR_OK {
		ackMsg := &serverproto.SCBTRoCoinShopItemBuyAck{
			GoodsType: Rune_Shop_Type_Bag,
			SubType:   Rune_BagShop_Type_ROCoin,
			Error:     int32(err),
		}
		this.ReplayGate(ackMsg, true)
	}
}

// GM充值
func (this *Role) GMPay(amount float32) {
	payRewardInfo := &serverproto.PayOrderSaveInfo{
		Amount:           amount,
		OrderProcessTime: util.GetTimeMilliseconds(),
	}
	this.OnPayCallback(payRewardInfo, false, false, false)
}

func (this *Role) GMCalAttr() {
	//var heroList []*serverproto.HeroData
	//heroList = append(heroList, this.roleHero.GetMainHero())
	this.roleBattleAttr.AttrChange(AttrChangeST{
		ChangeType:     Attr_Change_None,
		ChangeHeroData: this.roleHero.GetMainHero(),
	})
	for _, val := range this.roleHero.heroList {
		//heroList = append(heroList, val)

		this.roleBattleAttr.AttrChange(AttrChangeST{
			ChangeType:     Attr_Change_None,
			ChangeHeroData: val,
		})
		//this.roleBattleAttr.calcAttrHero(val, AttrChangeST{})
	}

}

func (this *Role) GetRuneShopInfo(shopType int32, subShop int32) {
	//冲榜卢恩商店流程
	if shopType == Rune_Shop_Type_RushTower ||
		shopType == Rune_Shop_Type_RushArena ||
		shopType == Rune_Shop_Type_RushMap ||
		shopType == Rune_Shop_Type_RushSkill ||
		shopType == Rune_Shop_Type_RushPet {

		reqMsg := &serverproto.SSGetRushShopInfoReq{}
		reqMsg.Uid = this.GetUUid()
		if shopType == Rune_Shop_Type_RushTower {
			reqMsg.RushType = model.Rush_Type_Tower
		} else if shopType == Rune_Shop_Type_RushArena {
			reqMsg.RushType = model.Rush_Type_Arena
		} else if shopType == Rune_Shop_Type_RushMap {
			reqMsg.RushType = model.Rush_Type_Map
		} else if shopType == Rune_Shop_Type_RushPet {
			reqMsg.RushType = model.Rush_Type_Pet
		} else if shopType == Rune_Shop_Type_RushSkill {
			reqMsg.RushType = model.Rush_Type_Skill
		}
		reqMsg.ShopType = shopType
		reqMsg.SubShopId = subShop
		this.SendRank(reqMsg)
		return
	}

	//其他商店
	ackMsg := &serverproto.SCRuneShopInfoAck{
		ShopType: shopType,
		SubShop:  subShop,
	}
	if this.GetRoleRune() != nil {
		this.GetRoleRune().GetShopInfo(shopType, subShop, ackMsg)
	}

	util.InfoF("[role.go] GetRuneShopInfo:%+v", *ackMsg)

	this.ReplayGate(ackMsg, true)
}

func (this *Role) GetBTShopInfo(shopType int32, subShop int32) {
	util.InfoF("[GetBTShopInfo] shopType=%v subShop:%v", shopType, subShop)
	// 100充值钱包商店
	// RO币礼包商店
	ackMsg := &serverproto.SCBTShopInfoAck{
		ShopType: shopType,
		SubShop:  subShop,
	}
	switch shopType {
	case Rune_Shop_Type_CreditRecharge: // 充值钱包商店
		fallthrough
	case Rune_Shop_Type_Bag: // RO币礼包商店
		if this.GetRoleRune() != nil {
			this.GetRoleRune().GetBTShopInfo(shopType, subShop, ackMsg)
		}
		this.ReplayGate(ackMsg, true)
	}
}

func (this *Role) GetRushShopInfo(msg *serverproto.SSGetRushShopInfoAck) {
	ackMsg := &serverproto.SCRuneShopInfoAck{
		ShopType: msg.ShopType,
		SubShop:  msg.SubShopId,
	}
	if this.GetRoleRune() != nil {
		this.GetRoleRune().GetRuneShopInfo(msg, ackMsg)
	}

	this.ReplayGate(ackMsg, true)
}

func (this *Role) OnRuneExploreInfo() {
	ackMsg := &serverproto.SCExploreInfoAck{}
	if this.GetRoleRune() != nil {
		this.GetRoleRune().runeExplore.ConvertMsg(ackMsg)
	}
	this.ReplayGate(ackMsg, true)
}

func (this *Role) OnRuneMaxLvlAward() {
	var ackMsg *serverproto.SCExploreExtraRewardAck = nil
	if this.GetRoleRune() != nil {
		ackMsg = this.GetRoleRune().MaxLvlAward()
	}
	this.ReplayGate(ackMsg, true)
}

func (this *Role) OnRuneReward(msg *serverproto.CSExploreRewardReq) {
	if msg == nil {
		return
	}
	var ret *serverproto.SCExploreRewardAck = nil
	if rune := this.GetRoleRune(); rune != nil {
		//领取类型：1表示普通奖励，2高级奖励
		ret = rune.OnRuneReward(msg.Level, msg.RewardType)
		//if msg.RewardType == 1 {
		//	ret = this.GetRoleRune().RuneReward(msg.Level)
		//} else if msg.RewardType == 2 {
		//	ret = this.GetRoleRune().RuneCashReward(msg.Level)
		//}
	}
	this.ReplayGate(ret, true)
}

func (this *Role) GetResNotice(resType int32) serverproto.ErrorCode {
	switch serverproto.ResType(resType) {
	case serverproto.ResType_Res_Coin:
		return serverproto.ErrorCode_ERROR_MONEY_NOT_ENOUGH
	case serverproto.ResType_Res_Rmb:
		return serverproto.ErrorCode_ERROR_RMB_NOT_ENOUGH
	case serverproto.ResType_Res_Cruise:
		return serverproto.ErrorCode_ERROR_SHOP_RESOURCE_NOT_NEOUGH_CRUISE
	case serverproto.ResType_Res_SkillBook:
		return serverproto.ErrorCode_ERROR_SHOP_RESOURCE_NOT_NEOUGH_SKILLBOOK
	case serverproto.ResType_Res_Sprite:
		return serverproto.ErrorCode_ERROR_SHOP_RESOURCE_NOT_NEOUGH_SPRITE
	case serverproto.ResType_Res_PetCoin:
		return serverproto.ErrorCode_ERROR_SHOP_RESOURCE_NOT_NEOUGH_PETPIECE
	case serverproto.ResType_Res_Guild:
		return serverproto.ErrorCode_ERROR_SHOP_RESOURCE_NOT_NEOUGH_GUILD
	case serverproto.ResType_Res_HightSkillExp:
		return serverproto.ErrorCode_ERROR_SHOP_RESOURCE_NOT_NEOUGH_SKILLBOOK
	}
	return serverproto.ErrorCode_ERROR_SHOP_RESOURCE_NOT_NEOUGH
}

func (this *Role) OnAntiCheatReq(cheatType int32) {
	if this.GetRoleStatistic() != nil {
		this.GetRoleStatistic().RecordCheatData(cheatType)

		ackMsg := &serverproto.SCAntiCheatAck{}
		this.ReplayGate(ackMsg, true)
	}
}

func (this *Role) GiftReward(ackMsg *serverproto.SCGiftRewardAck) {
	if ackMsg == nil {
		return
	}
	if ackMsg.Error == 0 {
		if len(ackMsg.RewardList) <= 0 {
			util.DebugF("uid=%v gift code item empty uid=%v", this.GetUUid())
		} else {
			totalItemList := make(map[int32]int32)
			for _, data := range ackMsg.RewardList {
				totalItemList[data.Key] += data.Value
			}
			this.AddItemList(totalItemList, AddFrom_GiftCode, true)
		}
	} else if ackMsg.Error == 1 {
		ackMsg.Error = int32(serverproto.ErrorCode_ERROR_GIFT_CODE_USED)
	} else if ackMsg.Error == 2 {
		ackMsg.Error = int32(serverproto.ErrorCode_ERROR_GIFT_CODE_OUTDATE)
	} else if ackMsg.Error == 3 {
		ackMsg.Error = int32(serverproto.ErrorCode_ERROR_GIFT_CODE_NOT_FOUND)
	} else if ackMsg.Error == 4 {
		ackMsg.Error = int32(serverproto.ErrorCode_ERROR_GIFT_CODE_FORBID)
	} else if ackMsg.Error == int32(serverproto.ErrorCode_ERROR_GIFT_CODE_USE_FAIL) {
		ackMsg.Error = int32(serverproto.ErrorCode_ERROR_GIFT_CODE_USE_FAIL)
	} else if ackMsg.Error == 5 {
		ackMsg.Error = int32(serverproto.ErrorCode_ERROR_GIFT_CODE_REUSE)
	} else {
		ackMsg.Error = int32(serverproto.ErrorCode_ERROR_FAIL)
	}
}

func (this *Role) QuestionReward() {
	//model.GlobalQuestionRewardList
	ackMsg := &serverproto.SCQuestionRewardAck{
		Error: int32(serverproto.ErrorCode_ERROR_FAIL),
	}
	if this.base.roleBase.QuestionReward <= 0 {
		ret := this.CanAddItemList(model.GlobalQuestionRewardList)
		ackMsg.Error = int32(ret)
		if ret == serverproto.ErrorCode_ERROR_OK {
			this.AddItemList(model.GlobalQuestionRewardList, AddFrom_QuestionReward, true)

			this.base.roleBase.QuestionReward = 1
			this.GetRoleBase().SetDirty(true)
		}
	} else {
		ackMsg.Error = int32(serverproto.ErrorCode_ERROR_QUESTION_REWARDED)
	}
	this.ReplayGate(ackMsg, true)
}

func (this *Role) GetKeepSake() {
	ackMsg := &serverproto.SCOnlineGetKeepSakeAck{}
	if this.GetRoleKeepSake() != nil {
		ackMsg.RoleKeepSake = &serverproto.RoleKeepSake{}
		this.GetRoleKeepSake().GetKeepSakeData(ackMsg.RoleKeepSake)
	}
	this.ReplayGate(ackMsg, true)
}

func (this *Role) KeepSakeLevelUp(keepSakeId int32) {
	ackMsg := &serverproto.SCKeepSakeLevelUpAck{
		Error: int32(serverproto.ErrorCode_ERROR_FAIL),
	}

	if this.GetRoleKeepSake() != nil {
		nRet := this.GetRoleKeepSake().KeepSakeLevelUp(keepSakeId)
		ackMsg.Error = int32(nRet)
	}
	this.ReplayGate(ackMsg, true)
}

func (this *Role) OnHeadOperate(msg *serverproto.CSHeadOperateReq) {
	if msg == nil {
		return
	}
	ackMsg := &serverproto.SCHeadOperateAck{
		Error:       int32(serverproto.ErrorCode_ERROR_FAIL),
		HeadId:      msg.HeadId,
		OperateType: msg.OperateType,
	}
	head := this.roleHead.GetHeadByHeadId(msg.HeadId)
	if head != nil {
		if head.State == int32(Head_Not_Activate) {
			ackMsg.Error = int32(this.roleHead.HeadActivate(msg.HeadId))
		} else if head.State == int32(Head_Wear) {
			ackMsg.Error = int32(this.roleHead.HeadUnload(msg.HeadId))
		} else if head.State == int32(Head_Unload) {
			ackMsg.Error = int32(this.roleHead.HeadWear(msg.HeadId))
		}
	}
	this.ReplayGate(ackMsg, true)
}

func (this *Role) OnHeadData(req *serverproto.CSHeadDataReq) {
	ackMsg := &serverproto.SCHeadDataAck{}
	this.roleHead.SendAllHeadData()
	this.ReplayGate(ackMsg, true)
}

func (this *Role) OnWishUse(msg *serverproto.CSWishBoxUseReq) {
	ackMsg := &serverproto.SCWishBoxUseAck{}
	error, index := this.roleWish.OnWishBoxUse(msg.ItemId, msg.SelectItem)
	ackMsg.Error, ackMsg.Index = int32(error), index
	this.ReplayGate(ackMsg, true)
}

func (this *Role) OnWishSlotUnlock(msg *serverproto.CSWishUnlockSlotReq) {
	ackMsg := &serverproto.SCWishUnlockSlotAck{}
	ackMsg.Error = int32(this.roleWish.OnUnlockWishSlot())
	this.ReplayGate(ackMsg, true)
}

func (this *Role) OnWishSlotAction(req *serverproto.CSWishSlotReq) {
	error, awardItem, luckyItem := this.roleWish.OnWishRewardGet(req.Index)
	ackMsg := &serverproto.SCWishSlotReqAck{Error: int32(error), AwardItem: awardItem, LuckyItem: luckyItem}
	this.ReplayGate(ackMsg, true)
}

// 检查是否在合服期间
func (this *Role) CheckInCombinedService() bool {
	bRet, _ := model.CheckInCombined(this.GetSelectZone())

	return bRet
}

func (this *Role) CombineServerNtf() {
	ntfMsg := &serverproto.SCCombineServerOnlineNtf{}

	ntfMsg.CombineTime = 0
	data, ok := model.ConvertCombineServerData[1]
	if ok {
		zoneId := this.GetSelectZone()

		for _, server := range data.ServerList {
			if server.Key <= zoneId && zoneId <= server.Value {
				ntfMsg.CombineTime = data.CombineTime
				break
			}
		}
	}
	this.ReplayGate(ntfMsg, true)
}

func (this *Role) GetCombineServerInfo() {
	ntfMsg := &serverproto.SCCombineServerInfoAck{}

	bFind := false
	data, ok := model.ConvertCombineServerData[1]
	if ok {
		zoneId := this.GetSelectZone()

		for _, server := range data.ServerList {
			if server.Key <= zoneId && zoneId <= server.Value {
				ntfMsg.Error = int32(serverproto.ErrorCode_ERROR_OK)
				ntfMsg.CombineTime = data.CombineTime
				ntfMsg.Notice = data.Notice
				bFind = true
				break
			}
		}
	}

	if bFind == false {
		ntfMsg.Error = int32(serverproto.ErrorCode_ERROR_COMBINE_SERVER_NOT_IN_STATE)
		ntfMsg.CombineTime = 0
	}

	this.ReplayGate(ntfMsg, true)
}

func (this *Role) GMSetCombineServerFinish() {
	model.ConvertCombineServerData = make(map[int32]*model.CombineServer)

	util.InfoF("ConvertCombineServerData len:%v", len(model.ConvertCombineServerData))
}