lyfz_repos/铂金版源码/LYFZ.Network/CloudServer/CloudServerClient.cs

using HPSocketCS.Extended;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;

namespace LYFZ.Network.CloudServer
{
    /// <summary>
    /// 云服务器网络处理
    /// </summary>
    public class CloudServerClient
    {
        public CloudServerClient()
        {

        }
        public CloudServerClient(string eID, string installationCode, string dongleDomain, ushort cloudLoginPort)
        {
            this.Initialization(eID, installationCode, dongleDomain, cloudLoginPort);

        }

        public void Initialization(string eID, string installationCode, string dongleDomain, ushort cloudLoginPort)
        {
            this._EnterpriseID = eID;
            HPSocketCS.TcpServer.EnterpriseID = this._EnterpriseID;
            if (!String.IsNullOrEmpty(installationCode))
            {
                this._InstallationCode = installationCode;
            }
            this._DongleDomain = dongleDomain;
            this._CloudLoginServerPort = cloudLoginPort;
        }
        /// <summary>
        /// 设置网络连接
        /// </summary>
        /// <param name="client"></param>
        public void SetNetworkClient(LYFZ.Network.TCPNetworkClient.TCP_NetworkClient client)
        {
            this.tcpClient = client;
        }

        string _EnterpriseID = "";

        public string EnterpriseID
        {
            get { return _EnterpriseID; }
            set { _EnterpriseID = value; }
        }
        string _InstallationCode = "auto";
        /// <summary>
        /// 安装验证码
        /// </summary>
        public string InstallationCode
        {
            get { return _InstallationCode; }
            set { _InstallationCode = value; }
        }
        string _DongleDomain = "";
        /// <summary>
        /// 加密锁域名
        /// </summary>
        public string DongleDomain
        {
            get { return _DongleDomain; }
            set { _DongleDomain = value; }
        }


        ushort _CloudLoginServerPort = 8000;
        /// <summary>
        /// 云登录服务端口
        /// </summary>
        public ushort CloudLoginServerPort
        {
            get { return _CloudLoginServerPort; }
            set { _CloudLoginServerPort = value; }
        }

        CloudLoginInfo cLoginServer = new CloudLoginInfo();
        /// <summary>
        /// 云服务器信息
        /// </summary>
        public CloudLoginInfo CLoginServer
        {
            get { return cLoginServer; }
            set { cLoginServer = value; }
        }

        /// <summary>
        /// 发送请求命令到云服务器端
        /// </summary>
        /// <param name="_hpClient"></param>
        /// <param name="command"></param>
        /// <param name="reqParameters"></param>
        /// <returns></returns>
        public static HPSocketCS.Extended.ReturnData SendCommandToCloudServer(HPSocketCS.TcpPackClient _hpClient, HPSocketCS.Extended.TransferRequestCommand command, HPSocketCS.Extended.RequestParameters reqParameters)
        {
            HPSocketCS.Extended.RequestData requestData = new HPSocketCS.Extended.RequestData((int)command);
            requestData.AttachedData = reqParameters.ToBytes();
            return HPSocketCS.Extended.SerializerDataProcessed.HP_SendSerializerCommandToServer(_hpClient, requestData);
        }

        private LYFZ.Network.TCPNetworkClient.TCP_NetworkClient tcpClient = new Network.TCPNetworkClient.TCP_NetworkClient();
        /// <summary>
        /// 客户端网络连接对象
        /// </summary>
        public LYFZ.Network.TCPNetworkClient.TCP_NetworkClient TcpClient
        {
            get { return tcpClient; }
        }

        string _ReturnMessage = "";
        /// <summary>
        /// 反回消息
        /// </summary>
        public string ReturnMessage
        {
            get { return _ReturnMessage; }
            set { _ReturnMessage = value; }
        }

        void ClearReturnMessage()
        {
            this.ReturnMessage = "";
        }

        /// <summary>
        /// 连接服务器
        /// </summary>
        /// <returns></returns>
        public bool ConnectServer()
        {
            try
            {
                this.ClearReturnMessage();
                if (this.tcpClient.AppState == AppState.Started)
                {
                    return true;
                }
                
                if (String.IsNullOrEmpty(this.cLoginServer.CloudServerIP))
                {
                    if (!String.IsNullOrEmpty(this._EnterpriseID))
                    {
                        if (VerifyEnterpriseID(this._EnterpriseID))
                        {
                            CloudLoginServerClient cLoginClient = new CloudLoginServerClient(this._EnterpriseID, this._CloudLoginServerPort);

                            if (cLoginClient.ConnectServer())
                            {
                                HPSocketCS.Extended.ReturnData returnData = cLoginClient.GetCloudServerInfo(this._EnterpriseID);
                                if (returnData.ReturnStatus)
                                {
                                    this.cLoginServer = cLoginClient.GetCloudLoginInfo(returnData.DataByteToModelObject<string>());
                                    if (this._InstallationCode == "auto")
                                    {
                                        this._InstallationCode = this.cLoginServer.VerificationCode;
                                    }
                                    cLoginClient.CloseConnect();
                                }
                                else
                                {
                                    this._ReturnMessage = returnData.ReturnMessage;
                                    return false;
                                }
                            }
                            else
                            {
                                this._ReturnMessage = "连接登录服务器失败";
                                return false;
                            }
                        }
                        else {
                            this._ReturnMessage = "企业ID不正确";
                            return false;
                        }
                    }
                    else {
                        this._ReturnMessage = "企业ID不能为空";
                        return false;
                    }
                }
                HPSocketCS.TcpServer.EnterpriseID = this.EnterpriseID;
                HPSocketCS.TcpServer.VerificationCode = this.InstallationCode;
                return this.tcpClient.ConnectionServer(this.cLoginServer.CloudServerIP, this.cLoginServer.SeverPort);
            }
            catch (Exception ex)
            {
                this._ReturnMessage = "连接服务器失败：" + ex.Message;
                return false;
            }
        }

        public bool ConnectServer(string cServerIP, ushort cSeverPort)
        {
            try
            {
                this.ClearReturnMessage();
                if (this.tcpClient.AppState == AppState.Started)
                {
                    return true;
                }

                this.cLoginServer.CloudServerIP = cServerIP;
                this.cLoginServer.SeverPort = cSeverPort;
                HPSocketCS.TcpServer.EnterpriseID = this.EnterpriseID;
                HPSocketCS.TcpServer.VerificationCode = this.InstallationCode;
                return this.tcpClient.ConnectionServer(this.cLoginServer.CloudServerIP, this.cLoginServer.SeverPort);
            }
            catch (Exception ex)
            {
                this._ReturnMessage = "连接服务器失败：" + ex.Message;
                return false;
            }
        }

        bool VerifyEnterpriseID(string eID)
        {
            if ("E6051908401744|E6051806481742|E6041618381744".ToLower().Contains(eID.ToLower()))
            {
                return true;
            }
            else
            {
                if (eID.ToLower().IndexOf("e") == 0 && eID.Length == 18)
                {
                    return true;
                }
                else
                {
                    return false;
                }
            }
        }


        /// <summary>
        /// 关闭连接
        /// </summary>
        public void CloseConnect()
        {
            this.cLoginServer.CloudServerIP = "";
            this.tcpClient.CloseConnected();
        }
        #region 云服务器相关通信处理

        /// <summary>
        /// 注册云版APP
        /// </summary>
        /// <returns></returns>
        public bool RegistrationWebAPP(bool _APPType,string appWebUrl)
        {
            try
            {
                HPSocketCS.Extended.RequestParameters reqParameters = new HPSocketCS.Extended.RequestParameters();
                reqParameters.SetRequsetEnterpriseIDParameter(this._EnterpriseID);
                reqParameters.SetRequsetErpInstallationVerificationCodeParameter(this._InstallationCode);
                reqParameters.SetRequestParameter<bool>("APPType", _APPType);
                reqParameters.SetRequestParameter<string>("AppWebUrl", appWebUrl);
                HPSocketCS.Extended.ReturnData returnData = CloudServerClient.SendCommandToCloudServer(tcpClient.Client, HPSocketCS.Extended.TransferRequestCommand.InstallCloudWebAPI, reqParameters);
                if (returnData.ReturnStatus)
                {
                    this.ReturnMessage = returnData.ReturnMessage;
                    return true;
                }
                else
                {
                    this.ReturnMessage = returnData.ReturnMessage;
                    return false;
                }
            }
            catch (Exception ex)
            {
                this.ReturnMessage = "数据库安装失败:" + ex.Message;
                return false;
            }
        }

        /// <summary>
        /// 安装云数据库
        /// </summary>
        /// <returns></returns>
        public bool InstallationDatabase()
        {
            try
            {
                HPSocketCS.Extended.RequestParameters reqParameters = new HPSocketCS.Extended.RequestParameters();
                reqParameters.SetRequsetEnterpriseIDParameter(this._EnterpriseID);
                reqParameters.SetRequsetErpInstallationVerificationCodeParameter(this._InstallationCode);

                HPSocketCS.Extended.ReturnData returnData = CloudServerClient.SendCommandToCloudServer(tcpClient.Client, HPSocketCS.Extended.TransferRequestCommand.InstallationDatabase, reqParameters);
                if (returnData.ReturnStatus)
                {
                    return true;
                }
                else
                {
                    this.ReturnMessage = returnData.ReturnMessage;
                    return false;
                }
            }
            catch (Exception ex)
            {
                this.ReturnMessage = "数据库安装失败:" + ex.Message;
                return false;
            }
        }


        /// <summary>
        /// 升级云数据库
        /// </summary>
        /// <returns></returns>
        public bool UpgradeDatabase()
        {
            try
            {
                HPSocketCS.Extended.RequestParameters reqParameters = new HPSocketCS.Extended.RequestParameters();
                reqParameters.SetRequsetEnterpriseIDParameter(this._EnterpriseID);
                reqParameters.SetRequsetErpInstallationVerificationCodeParameter(this._InstallationCode);

                HPSocketCS.Extended.ReturnData returnData = CloudServerClient.SendCommandToCloudServer(tcpClient.Client, HPSocketCS.Extended.TransferRequestCommand.UpgradeDatabase, reqParameters);
                if (returnData.ReturnStatus)
                {
                    return true;
                }
                else
                {
                    this.ReturnMessage = returnData.ReturnMessage;
                    return false;
                }
            }
            catch (Exception ex)
            {
                this.ReturnMessage = "数据库安装失败:" + ex.Message;
                return false;
            }
        }

        /// <summary>
        /// 备份云数据库
        /// </summary>
        /// <returns></returns>
        public bool BackupDatabase()
        {
            try
            {
                HPSocketCS.Extended.RequestParameters reqParameters = new HPSocketCS.Extended.RequestParameters();
                reqParameters.SetRequsetEnterpriseIDParameter(this._EnterpriseID);
                reqParameters.SetRequsetErpInstallationVerificationCodeParameter(this._InstallationCode);

                HPSocketCS.Extended.ReturnData returnData = CloudServerClient.SendCommandToCloudServer(tcpClient.Client, HPSocketCS.Extended.TransferRequestCommand.BackupDatabase, reqParameters);
                if (returnData.ReturnStatus)
                {
                    return true;
                }
                else
                {
                    this.ReturnMessage = returnData.ReturnMessage;
                    return false;
                }
            }
            catch (Exception ex)
            {
                this.ReturnMessage = "备份库安装失败:" + ex.Message;
                return false;
            }
        }

        /// <summary>
        /// 获取总店软件信息
        /// </summary>
        /// <param name="dongleDomain"></param>
        /// <returns></returns>
        public ReturnData GetMainServerSoftwareInfo()
        {
            HPSocketCS.Extended.RequestParameters reqParameters = new HPSocketCS.Extended.RequestParameters();
            reqParameters.SetRequsetEnterpriseIDParameter(this._EnterpriseID);
            reqParameters.SetRequsetErpInstallationVerificationCodeParameter(this._InstallationCode);
            reqParameters.SetRequsetErpDongleDomainParameter("main");
            HPSocketCS.Extended.ReturnData returnData = CloudServerClient.SendCommandToCloudServer(tcpClient.Client, HPSocketCS.Extended.TransferRequestCommand.GetMainStoreServerSoftwareInfo, reqParameters);
            return returnData;
        }

        /// <summary>
        /// 获取软件信息
        /// </summary>
        /// <param name="dongleDomain"></param>
        /// <returns></returns>
        public ReturnData GetServerSoftwareInfo(string dongleDomain)
        {
            HPSocketCS.Extended.RequestParameters reqParameters = new HPSocketCS.Extended.RequestParameters();
            reqParameters.SetRequsetEnterpriseIDParameter(this._EnterpriseID);
            reqParameters.SetRequsetErpInstallationVerificationCodeParameter(this._InstallationCode);
            reqParameters.SetRequsetErpDongleDomainParameter(dongleDomain);
            HPSocketCS.Extended.ReturnData returnData = CloudServerClient.SendCommandToCloudServer(tcpClient.Client, HPSocketCS.Extended.TransferRequestCommand.GetServerSoftwareInfo, reqParameters);
            return returnData;
        }

        /// <summary>
        /// 获取云服务器数据库连接信息
        /// </summary>
        /// <returns></returns>
        public ReturnData GetCloudServerDbConnInfo()
        {
            HPSocketCS.Extended.RequestParameters reqParameters = new HPSocketCS.Extended.RequestParameters();
            reqParameters.SetRequsetEnterpriseIDParameter(this._EnterpriseID);
            reqParameters.SetRequsetErpInstallationVerificationCodeParameter(this._InstallationCode);
            HPSocketCS.Extended.ReturnData returnData = CloudServerClient.SendCommandToCloudServer(tcpClient.Client, HPSocketCS.Extended.TransferRequestCommand.GetDataConne, reqParameters);
            return returnData;
        }
        /// <summary>
        /// 提交软件信息
        /// </summary>
        /// <param name="softwareInfo"></param>
        /// <param name="compInfo"></param>
        /// <param name="isIsHeadquarters"></param>
        /// <param name="orderQuantity"></param>
        /// <param name="versionNumber"></param>
        /// <returns></returns>
        public ReturnData SubmitSoftwareInfo(LYFZ.Model.Model_SoftwareInfo softwareInfo, LYFZ.Model.Model_ErpCompanyInfo compInfo, bool isIsHeadquarters, int orderQuantity, string versionNumber, bool isSubmit = true)
        {
            HPSocketCS.Extended.RequestParameters reqParameters = new HPSocketCS.Extended.RequestParameters();
            reqParameters.SetRequsetEnterpriseIDParameter(this._EnterpriseID);
            reqParameters.SetRequsetErpInstallationVerificationCodeParameter(this._InstallationCode);
            reqParameters.SetRequsetErpDongleDomainParameter(this.DongleDomain);

            reqParameters.SetRequestParameter<string>("StoreID", compInfo.Company_DividedShop);
            reqParameters.SetRequestParameter<string>("StoreName", compInfo.Company_Name);
            reqParameters.SetRequestParameter<string>("StoreManager", compInfo.Company_Manager);
            reqParameters.SetRequestParameter<string>("Telephone", compInfo.Company_Telephone);
            reqParameters.SetRequestParameter<string>("StoreAddress", compInfo.Company_Address);
            reqParameters.SetRequsetErpServerPortParameter(0);
            reqParameters.SetRequestParameter<long>("BusinessType", softwareInfo.BusinessType);
            reqParameters.SetRequestParameter<long>("FeatureType", softwareInfo.FunctionType);
            if (isIsHeadquarters)
            {
                reqParameters.SetRequestParameter<int>("IsHeadquarters", 1);
            }
            else
            {
                reqParameters.SetRequestParameter<int>("IsHeadquarters", 0);
            }

            reqParameters.SetRequestParameter<string>("VersionNumber", versionNumber);
            reqParameters.SetRequestParameter<int>("Seats", softwareInfo.RegConnCount);
            reqParameters.SetRequestParameter<int>("OrderQuantity", orderQuantity);

            reqParameters.SetRequestParameter<string>("DongleInformation", softwareInfo.ToString());
            if (!isSubmit)
            {
                reqParameters.SetRequestParameter<string>("DongleInformation", "");
                reqParameters.SetRequestParameter<int>("IsHeadquarters", -1);
            }

            HPSocketCS.Extended.ReturnData returnData = CloudServerClient.SendCommandToCloudServer(tcpClient.Client, HPSocketCS.Extended.TransferRequestCommand.SubmitSoftwareInfo, reqParameters);
            return returnData;
        }

        #endregion

    }

    /// <summary>
    /// 登录处理
    /// </summary>
   public class CloudLoginServerClient
   {
       public CloudLoginServerClient(string eID, ushort port)
       {
           this._EnterpriseID = eID;
           this._Port = port;
       }
       string _EnterpriseID = "";

       public string EnterpriseID
       {
           get { return _EnterpriseID; }
           set { _EnterpriseID = value; }
       }
# if DEBUG
      // string _ServerIP = "192.168.1.12";
       string _ServerIP = "bjb.lyfz.net";
#else
       string _ServerIP = "bjb.lyfz.net";
#endif
       public string ServerIP
       {
           get { return _ServerIP; }
           set { _ServerIP = value; }
       }

       ushort _Port = 8000;

       public ushort Port
       {
           get { return _Port; }
           set { _Port = value; }
       }

       

       private LYFZ.Network.TCPNetworkClient.TCP_NetworkClient tcpClient = new Network.TCPNetworkClient.TCP_NetworkClient();
       /// <summary>
       /// 客户端网络连接对象
       /// </summary>
       public LYFZ.Network.TCPNetworkClient.TCP_NetworkClient TcpClient
       {
           get { return tcpClient; }
       }
       /// <summary>
       /// 连接服务器
       /// </summary>
       /// <returns></returns>
       public bool ConnectServer()
       {
          return this.tcpClient.ConnectionServer(this.ServerIP,this.Port);
       }
       /// <summary>
       /// 获取云服务器信息
       /// </summary>
       /// <returns></returns>
       public HPSocketCS.Extended.ReturnData GetCloudServerInfo(string eID)
       {
           HPSocketCS.Extended.RequestParameters reqParameters = new HPSocketCS.Extended.RequestParameters();
           reqParameters.SetRequsetEnterpriseIDParameter(eID);
           return CloudServerClient.SendCommandToCloudServer(tcpClient.Client, HPSocketCS.Extended.TransferRequestCommand.CloudLoginIP, reqParameters);
       }
       /// <summary>
       /// 获取云服务器信息
       /// </summary>
       /// <param name="jsonData"></param>
       /// <returns></returns>
       public CloudLoginInfo GetCloudLoginInfo(string jsonData)
       {
           return Newtonsoft.Json.JsonConvert.DeserializeObject<CloudLoginInfo>(jsonData);
       }

       /// <summary>
       /// 关闭连接
       /// </summary>
       public void CloseConnect()
       {
           this.tcpClient.CloseConnected();
       }
   }
}