using System;
using System.Collections;
using System.Collections.Generic;
using Fantasy;
using Fantasy.Async;
using Fantasy.Network;
using UnityEngine;
using UnityEngine.UI;

public class Entry : MonoBehaviour
{
    private Scene _scene;
    private Session _session;

    public Button LoginButton;
    public Button ExitButton;
    public Button SendTestButton;
    public Button GetHaveMailButton;
    public Button OpenMailButton;
    public Button ReceiveMailButton;
    public Button RemoveMailButton;
    public Button SendMailButton;
    public InputField LoginUserName;
    public InputField MailId;
    public InputField MailTitle;
    public InputField MailUserName;
    public InputField MailContent;
    void Start()
    {
        LoginButton.onClick.RemoveAllListeners();
        LoginButton.onClick.AddListener(OnLoginButtonClick);
        ExitButton.onClick.RemoveAllListeners();
        ExitButton.onClick.AddListener(OnExitButtonClick);
        SendTestButton.onClick.RemoveAllListeners();
        SendTestButton.onClick.AddListener(() =>
        {
            OnSendTestButtonClick().Coroutine();
        });
        GetHaveMailButton.onClick.RemoveAllListeners();
        GetHaveMailButton.onClick.AddListener(() =>
        {
            OnGetHaveMailButtonClick().Coroutine();
        });
        OpenMailButton.onClick.RemoveAllListeners();
        OpenMailButton.onClick.AddListener(() =>
        {
            OnOpenMailButtonClick().Coroutine();
        });
        ReceiveMailButton.onClick.RemoveAllListeners();
        ReceiveMailButton.onClick.AddListener(() =>
        {
            OnReceiveMailButtonClick().Coroutine();
        });
        RemoveMailButton.onClick.RemoveAllListeners();
        RemoveMailButton.onClick.AddListener(() =>
        {
            OnRemoveMailButtonClick().Coroutine();
        });
        SendMailButton.onClick.RemoveAllListeners();
        SendMailButton.onClick.AddListener(() =>
        {
            OnSendMailButtonClick().Coroutine();
        });
        StartAsync().Coroutine();
    }

    private async FTask StartAsync()
    {
        Fantasy.Platform.Unity.Entry.Initialize(GetType().Assembly);
        _scene = await Scene.Create(SceneRuntimeType.MainThread);
    }

    private void OnLoginButtonClick()
    {
        // 1、判定用户输入的用户名是否为空，如果是空，则提示用户输入用户名。
        
        if (string.IsNullOrEmpty(LoginUserName.text))
        {
            Log.Error("用户名不可以为空!");
            return;
        }
        
        // 2、首先创建一个连接，并且设置连接成功和失败的回调。
        _session = _scene.Connect("127.0.0.1:20000", NetworkProtocolType.KCP, () =>
        {
            Log.Debug("连接成功");
            // 首先要判定一下。当前的Session是否被断开或销毁了
            if (_session.IsDisposed)
            {
                return;
            }
            // 添加一个心跳组件，用来跟服务器保持心跳
            _session.AddComponent<SessionHeartbeatComponent>().Start(2000);
            // 执行登陆请求
            LoginRequest().Coroutine();
        }, () =>
        {
            Log.Debug("连接失败");
        }, () =>
        {
            // 能触发到连接断开的委托的时候只有如下两种情况:
            // 1、服务器主动跟客户端断开连接。
            // 2、客户端主动跟服务器断开连接。
            Log.Debug("断开连接");
        }, false, 3000);
    }
    
    private void OnApplicationQuit()
    {
        _scene.Dispose();
    }

    private async FTask LoginRequest()
    {
        var userName = LoginUserName.text;
        var response = (G2C_LoginResponse)await _session.Call(new C2G_LoginRequest()
        {
            Name = userName
        });
        if (response.ErrorCode != 0)
        {
            Log.Error($"登陆时发生错误。ErrorCode:{response.ErrorCode}");
            return;
        }
        Log.Debug($"登陆成功，UserName:{userName}");
    }

    private void OnExitButtonClick()
    {
        if (_session == null || _session.IsDisposed)
        {
            return;
        }
        
        _session.Send(new C2G_Exit());
        Log.Debug("已经跟服务器发送了断开的协议！");
    }
    
    private async FTask OnSendTestButtonClick()
    {
        var userName = LoginUserName.text;
        var response = (Mail2C_TestResponse)await _session.Call(new C2Mail_TestRequest()
        {
            Tag = userName
        });
        if (response.ErrorCode != 0)
        {
            Log.Error($"测试时发生错误。ErrorCode:{response.ErrorCode}");
            return;
        }
        Log.Debug($"接收到服务器发送来的自定义Route协议，Tag:{response.Tag}");
    }

    private async FTask OnGetHaveMailButtonClick()
    {
        var response = (Mail2C_GetHaveMailResposne)await _session.Call(new C2Mail_GetHaveMailRequest());
        if (response.ErrorCode != 0)
        {
            Log.Error($"获取邮件时发生错误。ErrorCode:{response.ErrorCode}");
            return;
        }
        foreach (var mailSimplifyInfo in response.Mails)
        {
            MailId.text = mailSimplifyInfo.MailId.ToString();
            Log.Debug($"获取到邮件，MailId:{mailSimplifyInfo.MailId}，MailType:{mailSimplifyInfo.MailType} 标题:{mailSimplifyInfo.Title}");
        }
        
        Log.Debug($"获取到邮件数量:{response.Mails.Count}");
    }

    private async FTask OnOpenMailButtonClick()
    {
        var response = (Mail2C_OpenMailResposne)await _session.Call(new C2Mail_OpenMailRequest()
        {
            MailId = long.Parse(MailId.text), ReturnMailInfo = true
        });
        if (response.ErrorCode != 0)
        {
            Log.Error($"打开邮件时发生错误。ErrorCode:{response.ErrorCode}");
            return;
        }
        Log.Debug($"打开邮件成功，邮件Id:{response.MailInfo.MailId} 标题:{response.MailInfo.Title} 内容:{response.MailInfo.Content}");
    }

    private async FTask OnReceiveMailButtonClick()
    {
        var response = (Mail2C_ReceiveMailResponse)await _session.Call(new C2Mail_ReceiveMailRequest()
        {
            MailId = long.Parse(MailId.text)
        });
        if (response.ErrorCode != 0)
        {
            Log.Error($"领取邮件时发生错误。ErrorCode:{response.ErrorCode}");
            return;
        }
        Log.Debug($"领取邮件附件成功");
    }

    private async FTask OnRemoveMailButtonClick()
    {
        var response = (Mail2C_RemoveMailResponse)await _session.Call(new C2Mail_RemoveMailRequest()
        {
            MailId = long.Parse(MailId.text)
        });
        if (response.ErrorCode != 0)
        {
            Log.Error($"删除邮件时发生错误。ErrorCode:{response.ErrorCode}");
            return;
        }
        Log.Debug($"删除邮件成功");
    }
    
    private async FTask OnSendMailButtonClick()
    {
        var response = (Mail2C_SendMailResponse)await _session.Call(new C2Mail_SendMailRequest()
        {
            UserName = MailUserName.text,
            Title = MailTitle.text,
            Content = MailContent.text,
            Money = 100
        });
        if (response.ErrorCode != 0)
        {
            Log.Error($"发送邮件时发生错误。ErrorCode:{response.ErrorCode}");
            return;
        }
        Log.Debug($"发送邮件成功");
    }
}