yichael_smartbow/Assets/BowArrow/Scripts/Network/UserPlayer.cs

using System.Collections;
using System.Collections.Generic;
using UnityEngine;
using JCEngineCore;
using UnityEngine.SceneManagement;
using DG.Tweening;
using JCUnityLib;
/* Socket组件-玩家业务 */
public class UserPlayer : JCEntity
{
    public static UserPlayer ins;
    public UserPlayer() {
        ins = this;
        components.Add("PKComp", PKComp.Instance);
        components.Add("UserComp", UserComp.Instance);
    }
    public static void ConnectServer() {
        if (ins != null) return;
        if (AuthLoginMask.ins) AuthLoginMask.ins.SetVisiable(true);
        if (CommonConfig.businessServerWsURL != null) {
            JCEngine.boot(CommonConfig.businessServerWsURL, new UserPlayer());
        } else {
           LoginByToken();
        }
    }
    private static int _RetryLoginByTokenCount = -1;
    public static void LoginByToken()
    {
        if (++_RetryLoginByTokenCount > 0) 
            AuthLoginMask.ins?.SetRetryCount(_RetryLoginByTokenCount);
        CoroutineStarter.Start(LoginController.Instance.LoginByToken((res) => {
            if (res.code == 0) {
                _RetryLoginByTokenCount = -1;
                string loginToken = (string)res.data;
                CommonConfig.businessServerWsURL = loginToken.Split('&')[2];
                PlayerPrefs.SetString(LoginMgr.LoginTokenKey, loginToken);
                JCEngine.boot(CommonConfig.businessServerWsURL, new UserPlayer());
            } else if (res.code == -9999) { 
                if (_RetryLoginByTokenCount < 3) {
                    LoginByToken();
                } else {
                    _RetryLoginByTokenCount = -1;
                    AuthLoginMask.ins?.SetAutoRetryFail();
                }
            } else {
                _RetryLoginByTokenCount = -1;
                handleAuthExpire();
            }
        }));
    }
    //之所以做成协程延迟触发，是因为用编辑器调试时，停止运行后会触发断线重连，就会造成游戏停止调试了，但socket还连接的现象。
    IEnumerator ReconnenctServer() {
        yield return new WaitForSecondsRealtime(0.1f);
        JCEngine.reboot(this);
    }

    bool canReconnnect = true;

    public override void onLoad() {
        Debug.Log("UserPlayer onLoad()");
        authToken();
    }

    public override void onReload() {
        Debug.Log("UserPlayer onReload()");
        authToken();
    }

    public override void onDestroy() {
        Debug.Log("UserPlayer onDestroy()");
        if (canReconnnect) {
            JCUnityLib.CoroutineStarter.Start(ReconnenctServer());
        }
    }

    public override void onMiss() {
        Debug.Log("UserPlayer onMiss()");
        if (canReconnnect) {
            JCUnityLib.CoroutineStarter.Start(ReconnenctServer());
        }
    }

    public void Close() {
        LoginMgr.myUserInfo.id = 0;
        if (ins == this) ins = null;
        this.canReconnnect = false;
        this.channel.close();
        Debug.Log("user player close");
    }

    //向服务端发送的请求
    public void authToken() {
        string p0 = PlayerPrefs.GetString(LoginMgr.LoginTokenKey, "");
        string p1 = SceneManager.GetActiveScene().name;
        call("authToken2", p0, p1);
    }
    
    //被服务端调用的函数
    public void onAuthRes(bool res) {
        Debug.Log("onAuthRes," + res);
        if (res) {
            JCUnityLib.CoroutineStarter.Start(RequestUserInfoAvoidFail());
        } else {
            handleAuthExpire();
        }
    }
    public void RetryRequestUserInfoAvoidFail()
    {
        _hasExecuteRequestUserInfoAvoidFail = false;
        _getUserInfoRetryCount = -1;
        _getUserInfoFailed = false;
        JCUnityLib.CoroutineStarter.Start(RequestUserInfoAvoidFail());
    }
    //获取用户信息，超时了就重试
    private bool _hasExecuteRequestUserInfoAvoidFail = false;
    private int _getUserInfoRetryCount = -1;
    private bool _getUserInfoFailed = false;
    IEnumerator RequestUserInfoAvoidFail()
    {
        if (_hasExecuteRequestUserInfoAvoidFail) yield break;
        _hasExecuteRequestUserInfoAvoidFail = true;
        while (!_hasGetUserInfo && ins == this) {
            if (++_getUserInfoRetryCount <= 3) {
                UserComp.Instance.getUserInfo(DoAfterGetUserInfo);
                if (_getUserInfoRetryCount > 0) 
                    AuthLoginMask.ins?.SetRetryCount(_getUserInfoRetryCount); 
                yield return new WaitForSeconds(3.3f);
            } else {
                _getUserInfoFailed = true;
                AuthLoginMask.ins?.SetAutoRetryFail();
                yield break;
            }
        }
    }
    private bool _hasGetUserInfo = false;
    private void DoAfterGetUserInfo(UserInfo userInfo)
    {
        if (_getUserInfoFailed) return; //主要是为了避免提示了（网络异常后请稍后再试）,又突然可以了
        if (_hasGetUserInfo) return;
        _hasGetUserInfo = true;
        LoginMgr.myUserInfo = userInfo;

        if (HomeView.ins) {
            HomeView.ins.RenderMyAvatarSprite();
            HomeView.ins.RenderNameOrGender();
            HomeView.ins.RenderDeviceNames();
        }
        if (AuthLoginMask.ins) AuthLoginMask.ins.SetVisiable(false);
        if (SceneManager.GetActiveScene().name.Equals("Home") && !LoginMgr.myUserInfo.IsGuideFinish(0)) {
            NewUserGuiderManager.ins?.ReviewNewUserGuide();
        }
        if (SceneManager.GetActiveScene().name.Equals("Home")) {
            if (LoginMgr.myUserInfo.nickname == "test10086") InitLogReporter();
        }
        if (SceneManager.GetActiveScene().name.Equals("Home")) {
            System.Action eOnAgree = () => {
                GPSTool.GetAddress((address) => {
                    if (address != null) {
                        Debug.Log("登陆时获取地理位置成功：" + string.Join(" ", address));
                        if (LoginMgr.myUserInfo.country == address[0]
                            && LoginMgr.myUserInfo.state == address[1]
                            && LoginMgr.myUserInfo.city == address[2]
                        ) return;
                        LoginMgr.myUserInfo.country = address[0];
                        LoginMgr.myUserInfo.state = address[1];
                        LoginMgr.myUserInfo.city = address[2];
                        LoginMgr.myUserInfo.Save();
                    }
                });
            };
            if (!HomeView.ShowProminentBeforeConnectBLE(eOnAgree)) eOnAgree.Invoke();
        }
    }

    //控制台
    private static bool s_LogReporterInited = false;
    public static void InitLogReporter()
    {
        if (s_LogReporterInited) return;
        s_LogReporterInited = true;
        Object.Instantiate(Resources.Load("Prefabs/LogReporter"));
        Debug.LogWarning("在屏幕上画个圈即可打开控制台");
    } 

    private static void handleAuthExpire()
    {
        //tip
        if (AuthLoginMask.ins && AuthLoginMask.ins.IsVisiable()) {
            AuthLoginMask.ins.SetText(TextAutoLanguage2.GetTextByCNKey("登录认证过期"));
        } else {
            PopupMgr.ins.ShowTip(TextAutoLanguage2.GetTextByCNKey("登录认证过期"));
        }
        //delay back login
        Sequence seq = DOTween.Sequence();
        seq.AppendInterval(1.5f);
        seq.AppendCallback(() => {
            if (SceneManager.GetActiveScene().name.Equals("Home")) {
                SceneManager.LoadScene("Login", LoadSceneMode.Single);
            } else {
                Application.Quit(); //不是Home场景，就关闭游戏
            }
        });
        //close userplayer
        PlayerPrefs.DeleteKey(LoginMgr.LoginTokenKey);
        ins?.Close();
    }

    public void onAnyMessage(string msg)
    {
        SideTipView.ShowTip(msg, msg.EndsWith("失败") ? Color.yellow : Color.white);
    }

    public void onRequestAddFriend() {
        PopupMgr.ins.ShowTipTop(TextAutoLanguage2.GetTextByKey("tip_friend-receive-request"));
        tempData.hasFriendRequest = true;
    }

    public void onHasFriendTip() {
        tempData.hasFriendRequest = true;
    }

    public TempData tempData = new TempData();
    public class TempData {
        public System.Action onUpdate;
        private bool _hasFriendRequest;
        public bool hasFriendRequest {
            get {
                return _hasFriendRequest;
            }
            set {
                _hasFriendRequest = value;
                onUpdate?.Invoke();
            }
        }
    }
}