package app

import (
	"fmt"
	"gitee.com/liuxuezhan/mylib/Protocol"
	"gitee.com/liuxuezhan/mylib/conf/ConfigServer"
	. "gitee.com/liuxuezhan/mylib/log"
	"gitee.com/liuxuezhan/mylib/rsa-go"
	"time"
)

func C_Reconnect(message MPB.Message, ctx interface{}) {
	req := message.(*MPB.C_Reconnect)
	sess := ctx.(*Session)
	go func() {
		// 认证
		ec := (MPB.RetType_OK)
		func() {
			if sess.GetId() == uint64(req.SessionKey) {
				Log.Warning("[reconnect] save session id")
				ec = MPB.RetType_Failed
				return
			}
			sign := rsa_go.GetMd5Hash(fmt.Sprintf("%d%s%s", req.SessionKey, req.UserId, ConfigServer.GetConf("auth", "token")))
			if req.SessionToken != sign {
				Log.Warning("[reconnect] sign err")
				ec = MPB.RetType_Failed
				return
			}
			user := Center_GetUserInfoById(req.UserId)
			if user == nil {
				ec = MPB.RetType_Failed
				return
			}
			// 检查是否封号
			if user.BanTs.After(time.Now()) {
				ec = MPB.RetType_Login_UserBanned
				return
			}
			// then -> reconnect player: 通知到 GS
			ec = sess.ReconnectPlayer(uint64(req.SessionKey), &MPB.GW_UserReconnect{
				Sid:    sess.GetId(),
				UserId: user.UserId,
			})
		}()
		sess.SendMsg(&MPB.GW_Reconnect_R{
			ErrorCode: ec,
		})
	}()
}