using OnlineStore.Common;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Runtime.Serialization;

namespace CtuDeviceLib.manager
{
    public class HttpManager
    {

        static string agvLibUrl = ConfigAppSettings.GetValue("AGVLibService_BaseAddr", "http://127.0.0.1:9901");

        static string addr_requestLimitArea = "/agv/requestLimitArea";
        /// <summary>
        /// 请求限制区域
        /// </summary>
        /// <param name="agvName"></param>
        /// <param name="robotType"></param>
        /// <param name="areaName"></param>
        /// <param name="desc"></param>
        /// <returns></returns>
        public static bool RequestLimitArea(string agvName, int robotType, string areaName, string desc = "")
        {
            try
            {
                Dictionary<string, string> paramMap = new Dictionary<string, string>
                {
                    { "AreaName", areaName },
                    { "RobotType", robotType.ToString() },
                      { "AGVName", agvName },
                        { "Desc", desc },
                };
                DateTime startTime = DateTime.Now;
                string resultStr = HttpHelper.Post(agvLibUrl + addr_requestLimitArea, JsonHelper.SerializeObject(paramMap));
                // 返回: { "code": 0, "msg":"ok", "data":""}
                Result serverResult = JsonHelper.DeserializeJsonToObject<Result>(resultStr);
                if (serverResult == null)
                {
                    //msg = deviceName + " UpdateTrayLoc【" + barcode + "】【" + status + "】【" + locInfo + "】没有收到服务器反馈";
                    return false;
                }
                else if (serverResult.code.Equals(0).Equals(true))
                {
                    // code: 0为正常,其他为异常, msg: 消息, data: 为空
                    return true;
                }
                else
                    return false;
            }
            catch (Exception ex)
            {
                LogUtil.error($"RequestLimitArea [{areaName}]error ", ex);
            }
            return false;
        }
        static string addr_releaseLimitArea = "/agv/releaseLimitArea";
        /// <summary>
        /// 释放限制区域
        /// </summary>
        /// <param name="agvName"></param>
        /// <param name="areaName"></param>
        /// <returns></returns>
        public static bool ReleaseLimitArea(string agvName, string areaName)
        {
            try
            {
                Dictionary<string, string> paramMap = new Dictionary<string, string>
                {
                    { "AreaName", areaName },
                    { "AGVName", agvName },
                    { "RobotType", MushinyManager.CurRobotType.ToString() }
                };
                DateTime startTime = DateTime.Now;
                string resultStr = HttpHelper.Post(agvLibUrl + addr_releaseLimitArea, JsonHelper.SerializeObject(paramMap));
                // 返回: { "code": 0, "msg":"ok", "data":""}
                Result serverResult = JsonHelper.DeserializeJsonToObject<Result>(resultStr);
                if (serverResult == null)
                {
                    //msg = deviceName + " UpdateTrayLoc【" + barcode + "】【" + status + "】【" + locInfo + "】没有收到服务器反馈";
                    return false;
                }
                else if (serverResult.code.Equals(0).Equals(true))
                {
                    // code: 0为正常,其他为异常, msg: 消息, data: 为空
                    return true;
                }
                else
                    return false;
            }
            catch (Exception ex)
            {
                LogUtil.error($"ReleaseLimitArea [{areaName}]error ", ex);
            }
            return false;
        }

        static string addr_requestChargeStation = "/agv/requestChargeStation";
        public static bool RequestChargeStation(string agvName, out string chargeName)
        {
            chargeName = "";
            try
            {
                Dictionary<string, string> paramMap = new Dictionary<string, string>
                {
                      { "AGVName", agvName },
                };
                DateTime startTime = DateTime.Now;
                string resultStr = HttpHelper.Post(agvLibUrl + addr_requestChargeStation, JsonHelper.SerializeObject(paramMap));
                // 返回: { "code": 0, "msg":"ok", "data":""}
                Result serverResult = JsonHelper.DeserializeJsonToObject<Result>(resultStr);
                if (serverResult == null)
                {
                    //msg = deviceName + " UpdateTrayLoc【" + barcode + "】【" + status + "】【" + locInfo + "】没有收到服务器反馈";
                    return false;
                }
                else if (serverResult.code.Equals(0).Equals(true))
                {
                    chargeName = serverResult.data;
                    // code: 0为正常,其他为异常, msg: 消息, data: 为空
                    return true;
                }
                else
                    return false;
            }
            catch (Exception ex)
            {
                LogUtil.error($"[{agvName}] RequestChargeStation error ", ex);
            }
            return false;
        }
        static string addr_releaseChargeStation = "/agv/releaseChargeStation";
        public static bool ReleaseChargeStation(string agvName, string chargeStation)
        {
            try
            {
                Dictionary<string, string> paramMap = new Dictionary<string, string>
                {
                    { "ChargeStationName", chargeStation },
                      { "AGVName", agvName },
                };
                DateTime startTime = DateTime.Now;
                string resultStr = HttpHelper.Post(agvLibUrl + addr_releaseChargeStation, JsonHelper.SerializeObject(paramMap));
                // 返回: { "code": 0, "msg":"ok", "data":""}
                Result serverResult = JsonHelper.DeserializeJsonToObject<Result>(resultStr);
                if (serverResult == null)
                {
                    //msg = deviceName + " UpdateTrayLoc【" + barcode + "】【" + status + "】【" + locInfo + "】没有收到服务器反馈";
                    return false;
                }
                else if (serverResult.code.Equals(0).Equals(true))
                {
                    // code: 0为正常,其他为异常, msg: 消息, data: 为空
                    LogUtil.info($"【{agvName}】释放充电桩 【{chargeStation}】成功 ");
                    return true;
                }
                else
                    return false;
            }
            catch (Exception ex)
            {
                LogUtil.error($"ReleaseChargeStation [{chargeStation}]error ", ex);
            }
            return false;
        }

        static string addr_getLimitAreas = "/agv/getLimitAreas";

        /// <summary>
        /// 获取限制区
        /// </summary>
        /// <param name="limitAreaInfos"></param>
        /// <returns></returns>
        public static bool GetLimitAreas(out List<LimitAreaInfo> limitAreaInfos)
        {
            limitAreaInfos = null;
            try
            {
                DateTime startTime = DateTime.Now;
                string resultStr = HttpHelper.Get(agvLibUrl + addr_getLimitAreas);
                // 返回: { "code": 0, "msg":"ok", "data":""}
                var serverResult = JsonHelper.DeserializeJsonToList<LimitAreaInfo>(resultStr);
                if (serverResult == null)
                {
                    return false;
                }
                else
                {
                    limitAreaInfos = serverResult.ToList();
                    return true;
                }
            }
            catch (Exception ex)
            {
                LogUtil.error($"GetLimitAreas error ", ex);
            }
            return false;
        }

        static string addr_UploadAgvState = "/agv/uploadAgvState";
        public static bool UploadAgvState(RobotStatus robotStatus)
        {
            try
            {
                DateTime startTime = DateTime.Now;
                string resultStr = HttpHelper.Post(agvLibUrl + addr_UploadAgvState, JsonHelper.SerializeObject(robotStatus), 2000);
                // 返回: { "code": 0, "msg":"ok", "data":""}
                Result serverResult = JsonHelper.DeserializeJsonToObject<Result>(resultStr);
                if (serverResult == null)
                {
                    //msg = deviceName + " UpdateTrayLoc【" + barcode + "】【" + status + "】【" + locInfo + "】没有收到服务器反馈";
                    return false;
                }
                else if (serverResult.code.Equals(0).Equals(true))
                {
                    // code: 0为正常,其他为异常, msg: 消息, data: 为空
                    return true;
                }
                else
                    return false;
            }
            catch (Exception ex)
            {
                LogUtil.error($"UploadAgvState [{robotStatus?.Name}]error ", ex);
            }
            return false;
        }

        /// <summary>
        /// L1:是否可以放料箱
        /// </summary>
        static string addr_CanPutBox = "/HsdServer/BatchFeeder/SendDataL1";
        /// <summary>
        /// L2:放料箱完成
        /// </summary>
        static string addr_PutBoxFinish = "/HsdServer/BatchFeeder/SendDataL2";
        /// <summary>
        /// L3:是否可以取料箱
        /// </summary>
        static string addr_CanGetBox = "/HsdServer/BatchFeeder/SendDataL3";
        /// <summary>
        /// L4:取料箱完成
        /// </summary>
        static string addr_GettBoxFinish = "/HsdServer/BatchFeeder/SendDataL4";
        /// <summary>
        /// 到达伸缩轨道，请求开门
        /// </summary>
        static string addr_arriveShensuo = "/HsdServer/BatchFeeder/Arrive";
        /// <summary>
        /// 离开伸缩机，请求关门
        /// </summary>
        static string addr_leaveShensuo = "/HsdServer/BatchFeeder/Leave";
        /// <summary>
        /// 询问是否可以放料箱
        /// </summary>
        /// <param name="baseServer"></param>
        /// <param name="lineNo"></param>
        /// <returns></returns>
        public static bool CanPutBoxToManualLine(string baseServer, string lineNo, string boxCode, out string msg)
        {
            msg = "";
            try
            {
                DateTime startTime = DateTime.Now;
                var para = new Dictionary<string, string>() {
                    {"lineNo",lineNo },
                    {"boxCode",boxCode}
                };
                string inData = JsonHelper.SerializeObject(para);
                string resultStr = HttpHelper.Post(baseServer + addr_CanPutBox, inData, 2000);
                // 返回: { "code": 0, "msg":"ok", "data":""}
                LogUtil.info($"【{baseServer + addr_CanPutBox}】【{inData}】【{resultStr}】");
                var serverResult = JsonHelper.DeserializeJsonToObject<Result1>(resultStr);
                if (serverResult == null)
                {
                    msg = $"未收到是否可放料箱反馈:{resultStr}";
                    return false;
                }
                else if (serverResult.code.Equals(0).Equals(true))
                {
                    // code: 0为正常,其他为异常, msg: 消息, data: 为空
                    return true;
                }
                else
                {
                    msg = $"不允许放料箱，原因：{resultStr}";
                    return false;
                }

            }
            catch (Exception ex)
            {
                LogUtil.error($"[{baseServer}][{lineNo}][{boxCode}]请求放箱异常 ", ex);
            }
            msg = "处理异常";
            return false;
        }

        /// <summary>
        /// 在手动线放料箱完成通知
        /// </summary>
        /// <param name="baseServer"></param>
        /// <param name="lineNo"></param>
        /// <param name="boxCode"></param>
        /// <param name="msg"></param>
        /// <returns></returns>
        public static bool PutBoxToManualLineFinish(string baseServer, string lineNo, string boxCode, out string msg)
        {
            msg = "";
            try
            {
                DateTime startTime = DateTime.Now;
                var para = new Dictionary<string, string>() {
                    {"lineNo",lineNo },
                    {"boxCode",boxCode}
                };
                string inData = JsonHelper.SerializeObject(para);
                string resultStr = HttpHelper.Post(baseServer + addr_PutBoxFinish, inData, 2000);
                // 返回: { "code": 0, "msg":"ok", "data":""}
                LogUtil.info($"【{baseServer + addr_PutBoxFinish}】【{inData}】【{resultStr}】");
                var serverResult = JsonHelper.DeserializeJsonToObject<Result1>(resultStr);
                if (serverResult == null)
                {
                    msg = $"未收到放料箱完成反馈:{resultStr}";
                    return false;
                }
                else if (serverResult.code.Equals(0).Equals(true))
                {
                    // code: 0为正常,其他为异常, msg: 消息, data: 为空
                    return true;
                }
                else
                {
                    msg = $"未收到回复放料箱完成，原因：{resultStr}";
                    return false;
                }

            }
            catch (Exception ex)
            {
                LogUtil.error($"[{baseServer}][{lineNo}][{boxCode}]放箱完成通知异常", ex);
            }
            msg = "处理异常";
            return false;
        }

        /// <summary>
        /// 询问是否可以取料箱
        /// </summary>
        /// <param name="baseServer"></param>
        /// <param name="lineNo"></param>
        /// <returns></returns>
        public static bool CanGetBoxFromManualLine(string baseServer, string lineNo, string boxCode, out string msg)
        {
            msg = "";
            try
            {
                DateTime startTime = DateTime.Now;
                var para = new Dictionary<string, string>() {
                    {"lineNo",lineNo },
                    {"boxCode",boxCode}
                };
                string inData = JsonHelper.SerializeObject(para);
                string resultStr = HttpHelper.Post(baseServer + addr_CanGetBox, inData, 2000);
                // 返回: { "code": 0, "msg":"ok", "data":""}
                LogUtil.info($"【{baseServer + addr_CanGetBox}】【{inData}】【{resultStr}】");
                var serverResult = JsonHelper.DeserializeJsonToObject<Result1>(resultStr);
                if (serverResult == null)
                {
                    msg = $"未收到是否可取料箱反馈:{resultStr}";
                    return false;
                }
                else if (serverResult.code.Equals(0).Equals(true))
                {
                    // code: 0为正常,其他为异常, msg: 消息, data: 为空
                    return true;
                }
                else
                {
                    msg = $"不允许取料箱，原因：{resultStr}";
                    return false;
                }

            }
            catch (Exception ex)
            {
                LogUtil.error($"[{baseServer}][{lineNo}][{boxCode}]请求取箱异常 ", ex);
            }
            msg = "处理异常";
            return false;
        }

        /// <summary>
        /// 在手动线取料箱完成通知
        /// </summary>
        /// <param name="baseServer"></param>
        /// <param name="lineNo"></param>
        /// <param name="boxCode"></param>
        /// <param name="msg"></param>
        /// <returns></returns>
        public static bool GetBoxFromManualLineFinish(string baseServer, string lineNo, string boxCode, out string msg)
        {
            msg = "";
            try
            {
                DateTime startTime = DateTime.Now;
                var para = new Dictionary<string, string>() {
                    {"lineNo",lineNo },
                    {"boxCode",boxCode}
                };
                string inData = JsonHelper.SerializeObject(para);
                string resultStr = HttpHelper.Post(baseServer + addr_GettBoxFinish, inData, 2000);
                var serverResult = JsonHelper.DeserializeJsonToObject<Result1>(resultStr);
                LogUtil.info($"【{baseServer + addr_GettBoxFinish}】【{inData}】【{resultStr}】");
                if (serverResult == null)
                {
                    msg = $"未收到取料箱完成反馈:{resultStr}";
                    return false;
                }
                else if (serverResult.code.Equals(0).Equals(true))
                {
                    // code: 0为正常,其他为异常, msg: 消息, data: 为空
                    return true;
                }
                else
                {
                    msg = $"未收到回复取料箱完成，原因：{resultStr}";
                    return false;
                }

            }
            catch (Exception ex)
            {
                LogUtil.error($"[{baseServer}][{lineNo}][{boxCode}]取箱完成通知异常", ex);
            }
            msg = "处理异常";
            return false;
        }
        /// <summary>
        /// 请求伸缩轨道开门
        /// </summary>
        /// <param name="baseServer"></param>
        /// <param name="requestMsg"></param>
        /// <param name="msg"></param>
        /// <returns></returns>
        public static bool ArriveShensuoguidao( string requestMsg, out string msg)
        {
            string baseServer=ConfigAppSettings.GetValue("Shensuoguidao_ServerBase", "http://localhost:8080");
            msg = "";
            try
            {
                DateTime startTime = DateTime.Now;
                //var para = new Dictionary<string, object>() {
                //    {"Arrive",true},
                //    {"msg",requestMsg}
                //};
                var para = new Dictionary<string, string>() {
                    {"ctuNo",requestMsg}
                };
                string inData = JsonHelper.SerializeObject(para);
                string resultStr = HttpHelper.Post(baseServer + addr_arriveShensuo, inData, 2000);
                var serverResult = JsonHelper.DeserializeJsonToObject<shensuoResult>(resultStr);
                LogUtil.info($"【{baseServer + addr_arriveShensuo}】【{inData}】【{resultStr}】");
                if (serverResult == null)
                {
                    msg = $"未收到伸缩轨道开门反馈:{resultStr}";
                    return false;
                }
                else if (serverResult.code.Equals(0))
                {
                    msg = resultStr;
                    return true;
                }
                else
                {
                    msg = $"未收到伸缩轨道允许开门反馈，原因：{resultStr}";
                    return false;
                }

            }
            catch (Exception ex)
            {
                LogUtil.error($"[{baseServer}][{requestMsg}]伸缩轨道开门请求", ex);
            }
            msg = "处理异常";
            return false;
        }

        /// <summary>
        /// 离开伸缩轨道，请求关门
        /// </summary>
        /// <param name="baseServer"></param>
        /// <param name="requestMsg">CTU编号</param>
        /// <param name="msg"></param>
        /// <returns></returns>
        public static bool LeaveShensuoguidao(string requestMsg, out string msg)
        {
            string baseServer = ConfigAppSettings.GetValue("Shensuoguidao_ServerBase", "http://localhost:8080");
            msg = "";
            try
            {
                DateTime startTime = DateTime.Now;
                //var para = new Dictionary<string, object>() {
                //    {"Arrive",false},
                //    {"msg",requestMsg}
                //};
                var para = new Dictionary<string, string>() {
                    {"ctuNo",requestMsg}
                };
                string inData = JsonHelper.SerializeObject(para);
                string resultStr = HttpHelper.Post(baseServer + addr_leaveShensuo, inData, 2000);
                var serverResult = JsonHelper.DeserializeJsonToObject<shensuoResult>(resultStr);
                LogUtil.info($"【{baseServer + addr_arriveShensuo}】【{inData}】【{resultStr}】");
                if (serverResult == null)
                {
                    msg = $"未收到伸缩轨道关门反馈:{resultStr}";
                    return false;
                }
                else if (serverResult.code.Equals(0))
                {
                    msg=resultStr;
                    return true;
                }
                else
                {
                    msg = $"未收到伸缩轨道允许关门反馈，原因：{resultStr}";
                    return false;
                }

            }
            catch (Exception ex)
            {
                LogUtil.error($"[{baseServer}][{requestMsg}]伸缩轨道关门请求", ex);
            }
            msg = "处理异常";
            return false;
        }

    }

    class Result
    {
        /// <summary>
        /// 状态码，0为正常
        /// </summary>
        [DataMember]
        public int code { get; set; } = 0;
        /// <summary>
        /// 返回数据
        /// </summary>
        [DataMember]
        public string data { get; set; }
        /// <summary>
        /// 提示信息
        /// </summary>
        [DataMember]
        public string msg { get; set; } = "ok";

    }
    class Result1
    {
        /// <summary>
        /// 状态码，0为正常
        /// </summary>
        [DataMember]
        public int code { get; set; } = 0;
        /// <summary>
        /// 返回数据
        /// </summary>
        [DataMember]
        public Object data { get; set; }
        /// <summary>
        /// 提示信息
        /// </summary>
        [DataMember]
        public string msg { get; set; } = "ok";

    }
    class shensuoResult
    {
        /// <summary>
        /// 状态码，0为正常
        /// </summary>
        [DataMember]
        public int code { get; set; } = 0;
        /// <summary>
        /// 返回数据
        /// </summary>
        [DataMember]
        public Object data { get; set; }
        /// <summary>
        /// 提示信息
        /// </summary>
        [DataMember]
        public string msg { get; set; } = "ok";

    }
    class Allow
    {
        public bool allow { get; set; }
    }
}