RoServer/RO_Server_Trunk-branch_0.1.39/roserver/auth/model/auth_proc.go

package model

import (
	"rocommon"
	"rocommon/rpc"
	"rocommon/service"
	"rocommon/util"
	"roserver/baseserver/model"
	"roserver/serverproto"
)

const (
	PlatformOpenIdConnectInfoPrefix  = "pp_conn_" //openid对应的连接信息
	PlatformOpenIdConnectInfoPrefix2 = "xiaoqi_"  //openid对应的连接信息
)

// 透传给client
func LoginRet(ev rocommon.ProcEvent, ret int32) {
	loginAck := &serverproto.SCLoginAck{
		Error: ret,
	}
	model.ServiceReplay(ev, loginAck)
}

// sdk返回以后的透传client操作
func LoginRetSDK(session rocommon.Session, clientId uint64, ret int32) {
	loginAck := &serverproto.SCLoginAck{
		Error: ret,
	}
	data, info, err := rpc.EncodeMessage(loginAck)
	if err != nil {
		util.ErrorF("replay msg encode err=%v", err)
		return
	}
	//透传给gate服务器，然后再发送给客户端
	session.Send(&serverproto.ServiceTransmitAck{
		MsgId:    uint32(info.ID),
		MsgData:  data,
		ClientId: clientId,
	})
}

// sdk返回以后的透传client操作
func LoginRetSDK2(session rocommon.Session, clientId uint64, ret int32, guid string) {
	loginAck := &serverproto.SCLoginAck{
		Error:           ret,
		UnisdkLoginJson: guid,
	}
	data, info, err := rpc.EncodeMessage(loginAck)
	if err != nil {
		util.ErrorF("replay msg encode err=%v", err)
		return
	}
	//透传给gate服务器，然后再发送给客户端
	session.Send(&serverproto.ServiceTransmitAck{
		MsgId:    uint32(info.ID),
		MsgData:  data,
		ClientId: clientId,
	})
}

func checkOpenIdValid(openId string) bool {
	if openId == "" {
		return false
	}
	return true
}

func checkServerStatus() int32 {
	return int32(serverproto.ErrorCode_ERROR_OK)
}

func initUserConnInfo(connInfo *serverproto.UserConnectInfo, openId, platform string) bool {
	// 区分不同平台
	openId = model.ConvertPlatform(openId, platform)
	keyStr := PlatformOpenIdConnectInfoPrefix + openId
	ret, err := service.GetRedis().Exists(keyStr).Result()
	if err != nil && err != service.NIL {
		util.InfoF("initUserConnInfo openid=%v err=%v", openId, err)
		return false
	}

	if ret != 0 {
		err := model.GetMessageFromRedis(PlatformOpenIdConnectInfoPrefix, openId, connInfo)
		if err != nil {
			util.WarnF("initUserConnInfo openid=%v err=%v", openId, err)
			return false
		}
	}
	return true
}

func saveUserConnInfo(connInfo *serverproto.UserConnectInfo, openId, platform, sdkjson string) {
	// 区分不同平台
	openId = model.ConvertPlatform(openId, platform)
	err := model.SetMessageToRedis(PlatformOpenIdConnectInfoPrefix, openId, connInfo)
	if err != nil {
		util.WarnF("[initUserConnInfo] save userConnectionInfo err:%v", err)
	}
	ret, err := service.GetRedis().Set(PlatformOpenIdConnectInfoPrefix2+openId, sdkjson, 0).Result()
	if err != nil {
		util.ErrorF("SetMessageToRedis err=%v ret=%v", PlatformOpenIdConnectInfoPrefix2+openId, ret)

	}
}

func checkAuthMode(activeCode string) {

}