using System;
using System.Collections.Generic;
using System.Globalization;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using AGVControl;
using BLL;
using RestSharp;

namespace AGVControl
{
    public class AGVManager
    {
        private static string Addr_CurSO = "/rest/api/qisda/device/currentOutLine";
        /// <summary>
        /// 查询当前出料工单信息
        /// </summary>
        /// <returns></returns>
        public static bool FindCurSO(out WOData woData)
        {
            woData = null;
            try
            {
                Dictionary<string, string> paramMap = new Dictionary<string, string>();
                //paramMap.Add("deviceAlarmList", msgListStr);
                string server = GetAddr(Addr_CurSO, paramMap);
                DateTime startTime = DateTime.Now;
                string resultStr = HttpHelper.Get(server);
                Common.log.Debug("当前正在出工单料信息【" + server + "】【" + resultStr + "】");

                WorkOrder workOrder = JsonHelper.DeserializeJsonToObject<WorkOrder>(resultStr);

                if (workOrder == null)
                {
                    return false;
                }
                else
                {
                    if (workOrder.data == null)
                    {
                        return false;
                    }
                    else
                    {
                        if (workOrder.data.line != null)
                        {
                            string tempLocation = workOrder.data.line;
                            if (workOrder.data.line.Equals("Feeder"))
                            {
                                tempLocation = "FeederIn";
                            }
                            else if (workOrder.data.line.Equals("4CFeeder"))
                            {
                                tempLocation = "4CFeederIn";
                            }
                            workOrder.data.line = tempLocation;
                            woData = workOrder.data;
                            return true;
                        }

                    }

                }

            }
            catch (Exception ex)
            {
                Common.log.Error(ex);
                return false;
            }
            return false;
        }
        /// <summary>
        /// 当前正在出的工单信息
        /// </summary>
        public class WorkOrder
        {
            //{"code":0,"msg":"ok","data":{"hSerial":"32622","line":null,"so":"2506287"}}
            //{"code":0,"msg":"ok","data":{"hSerial":"32651","line":"D2","so":"2508551"}}
            public int code { get; set; }
            public string msg { get; set; }
            public WOData data { get; set; }

        }
        public class WOData
        {
            public string hSerial { get; set; }
            public string line { get; set; }
            public string so { get; set; }

            public string ToTxt(string nodeName)
            {
                return string.Format("[hSerial={0}，line={1}[{3}]，so={2}]", hSerial, line, so, nodeName);
            }
        }
        public static string A6_Target = "";
        /// <summary>
        /// 查找满料架目的地
        /// </summary>
        /// <param name="rfid"></param>
        /// <param name="dest"></param>
        /// <returns></returns>
        public static bool FindFullShelfTarget(string rfid, out BoxDestInfo dest)
        {
            dest = null;
            A6_Target = "";
            try
            {
                if (rfid.Equals("") || rfid.Equals("00"))
                    return false;
                string url = Common.itsHttp + rfid;
                var client = new RestClient(url) { Timeout = -1 };
                var request = new RestRequest(Method.GET);
                //request.AddHeader("Host", "10.85.17.233");
                IRestResponse response = client.Execute(request);
                string json = response.Content;
                json = json.Replace("\r", "");
                json = json.Replace("\n", "");
                json = json.Replace(" ", "");
                Common.log.Debug("ITS URL: " + url + " Return: " + json);

                if (string.IsNullOrWhiteSpace(json)) return false;
                List<BoxDestInfo> res = JsonHelper.DeserializeJsonToList<BoxDestInfo>(json);
                A6_Target = json;
                //JavaScriptSerializer serializer = new JavaScriptSerializer();
                if (res == null || res.Count == 0)
                    return false;
                string tempLocation = res[0].location;
                if (res[0].id == rfid)
                {
                    if (res[0].location.Equals("Feeder"))
                    {
                        tempLocation = "FeederIn";
                    }
                    else if (res[0].location.Equals("4CFeeder"))
                    {
                        tempLocation = "4CFeederIn";
                    }
                    else if(res[0].location.Equals("3DFeeder") || res[0].location.StartsWith("S"))
                    {
                        tempLocation = "S0";
                    }
                    if (Common.GetNodeNameByLineName(tempLocation, out string loc))
                    {
                        int i = Common.FindNode(loc);
                        if (i > -1)
                        {
                            #region 检查是否有空料架要出，有则先出空料架
                            //foreach (var item in Common.missionManager.missionList)
                            //{
                            //    if (loc.Equals(item.NodeName))
                            //    {
                            //        Common.LogInfo("节点[" + loc + "]当前有空架任务，延迟A6出满料架任务[" + rfid + "]", false);
                            //        return false;
                            //    }
                            //}

                            //if (Common.nodeInfo[i].AgvName.Equals("").Equals(false))//有小车在目标任务点(限制4C车间)，等待结束后再接任务
                            //{
                            //    Common.LogInfo("节点[" + loc + "]当前有任务，延迟A6出满料架任务[" + rfid + "]", false);
                            //    return false;
                            //}

                            //检查是否有车接到满料架任务，有则不再重复分配
                            //int id = Common.agvInfo.FindIndex(s => s.RFID == rfid);
                            //if (id > -1)
                            //{
                            //    Common.LogInfo(Common.agvInfo[i].Name + " 正在执行满料架任务：目的地为 " + loc + " [产线名 " + res[0].location + "]，不可重复分配小车");
                            //    return false;
                            //}
                            #endregion
                            res[0].location = loc;
                            dest = res[0];
                            Common.GetLineNameByNodeName(loc, out string line);
                            A6_Target = res[0].ShowInfo(line);
                            Common.log.Debug("查找满料架任务[RFID=" + rfid + "]：目的地为 " + loc + " [产线名 " + line + "]");
                            return true;
                        }
                        else
                        {
                            Common.LogInfo("节点[" + loc + "]不存在或者未开启调用");
                            return false;
                        }

                    }
                }
                //[{"msg":"0料车已解绑或未发新料"}]
                return false;
            }
            catch (Exception ex)
            {
                Common.log.Error("FindA6Destination", ex);
                return false;
            }
        }

        public class BoxDestInfo
        {
            /// <summary>
            /// RFID
            /// </summary>
            public string id { get; set; }

            public string SO { get; set; }
            public string location { get; set; }

            public string ShowInfo(string loc)
            {
                return string.Format("RFID={0},SO={1},location={2}[{3}]", id, SO, loc, location);
            }
        }


        /// <summary>
        /// 物料到产线状态上报
        /// </summary>
        /// <param name="rfid"></param>
        /// <param name="lineName"></param>
        /// <returns></returns>
        public static bool UpdateStatus(string rfid, string nodeName)
        {
            //GET /ESMTCommonInterface/CommonService.asmx/UpdateStatusBy?id=string&location=string HTTP/1.1
            //Host: 10.85.17.233

            Common.GetLineNameByNodeName(nodeName, out string lineName);
            if (lineName.Equals("FeederIn"))
            {
                lineName = "Feeder";
            }
            else if (lineName.Equals("4CFeederIn"))
            {
                lineName = "4CFeeder";
            }
            string addr = "http://10.85.17.233/ESMTCommonInterface/CommonService.asmx/UpdateStatusBy?id=" + rfid + "&location=" + lineName;
            //[{"msg":"1更新成功"}]
            try
            {
                string result = HttpHelper.Get(addr);
                Common.LogInfo(string.Format("[{0}] [{1}]", addr, result));
                if (!result.Equals(""))
                {
                    List<Msg> msgs = JsonHelper.DeserializeJsonToList<Msg>(result);
                    if (msgs == null || msgs.Count == 0)
                        return false;
                    bool resRtn = int.TryParse(msgs[0].msg.Substring(0, 1), out int resCode);
                    if (resRtn)
                    {
                        if (resCode.Equals(1))
                        {
                            Common.LogInfo(string.Format("产线{0} 物料状态更新成功[{1}]", lineName, rfid));
                            return true;
                        }

                        else
                            return false;
                    }
                    return false;
                }
            }
            catch { return false; }
            return false;
        }
        /// <summary>
        /// 获取大料架解绑情况
        /// </summary>
        /// <param name="rfid"></param>
        /// <param name="lineName">产线名称</param>
        /// <returns></returns>
        public static bool GetRackBy(string rfid, out string lineName)
        {
            lineName = "";
            //GET /ESMTCommonInterface/CommonService.asmx/GetRackBy?id=string HTTP/1.1
            //Host: 10.85.17.233
            string addr = "http://10.85.17.233/ESMTCommonInterface/CommonService.asmx/GetRackBy?id=" + rfid;
            //[{"msg":"1OKD1"}]
            //[{"msg":"0NGFeeder"}]
            try
            {
                string result = HttpHelper.Get(addr);
                if (!result.Equals(""))
                {
                    List<Msg> msgs = JsonHelper.DeserializeJsonToList<Msg>(result);
                    if (msgs == null || msgs.Count == 0)
                        return false;
                    int.TryParse(msgs[0].msg.Substring(0, 1), out int resCode);
                    string resStr = msgs[0].msg.Substring(1, 2);
                    lineName = msgs[0].msg.Substring(3);
                    Common.log.Debug(string.Format("[{0}] [{1}]", addr, result));
                    if (lineName.Equals("").Equals(true))
                        return false;
                    if (resStr.Equals("OK") || resCode.Equals(1))
                        return true;
                    else
                        return false;
                }
            }
            catch (Exception ex)
            {
                Common.log.Error(ex.Message);
                return false;
            }
            return false;
        }
        public static string GetRackBy(string rfid)
        {
            //GET /ESMTCommonInterface/CommonService.asmx/GetRackBy?id=string HTTP/1.1
            //Host: 10.85.17.233
            string addr = "http://10.85.17.233/ESMTCommonInterface/CommonService.asmx/GetRackBy?id=" + rfid;
            //[{"msg":"1OKD1"}]
            //[{"msg":"0NGFeeder"}]
            try
            {
                string result = HttpHelper.Get(addr);
                if (!result.Equals(""))
                {
                    List<Msg> msgs = JsonHelper.DeserializeJsonToList<Msg>(result);
                    if (msgs == null || msgs.Count == 0)
                        return "";
                    return result;

                }
            }
            catch (Exception ex)
            {
                Common.log.Error(ex.Message);
                return "";
            }
            return "";
        }
        /// <summary>
        /// 大料架接口回复
        /// </summary>
        public class Msg
        {
            public string msg { get; set; }
        }
        public class Msg1
        {
            //{"Code":0,"Msg":"D14,,D7,D33"}
            public int Code { get; set; }
            public string Msg { get; set; }
        }
        private static string Addr_updateDeviceAlarmMsg = "/rest/api/qisda/device/updateDeviceAlarmMsg";
        /// <summary>
        /// 异常看板
        /// </summary>
        /// <param name="msgList"></param>
        /// <returns></returns>
        public static string updateDeviceAlarmMsg(List<AlarmMsg> msgList)
        {
            string msg = "";
            try
            {
                Common.log.Debug(msgList.ToArray());
                Dictionary<string, string> paramMap = new Dictionary<string, string>();
                string msgListStr = JsonHelper.SerializeObject(msgList);
                paramMap.Add("deviceAlarmList", msgListStr);
                string server = GetAddr(Addr_updateDeviceAlarmMsg, paramMap);
                DateTime startTime = DateTime.Now;
                string resultStr = HttpHelper.Post(server, "");
                Common.log.Debug("异常看板【" + server + "】【" + resultStr + "】");

                RfidData data = JsonHelper.DeserializeJsonToObject<RfidData>(resultStr);

                if (data == null)
                {
                    return msg = " updateDeviceAlarmMsg 没有收到服务器反馈";
                }
                else if (data.code.Equals(0).Equals(false))
                {
                    return msg = "【" + server + "】【" + resultStr + "】" + data.msg;
                }
                return "";
            }
            catch (Exception ex)
            {
                Common.log.Error(ex);
            }
            return msg;
        }
        private static string GetAddr(string addr, Dictionary<string, string> paramsMap)
        {
            string server = ConfigAppSettings.GetValue("http.server");
            if (server.EndsWith("/"))
            {
                server = server.Substring(0, server.Length - 1);
            }
            string path = server + addr.Trim() + "?";
            foreach (string paramName in paramsMap.Keys)
            {
                string par = System.Web.HttpUtility.UrlEncode(paramsMap[paramName], System.Text.Encoding.UTF8);
                path += paramName + "=" + par + "&";
            }
            path = path.Substring(0, path.Length - 1);
            return path;
        }

        public static string Add_emptyMsg = "http://10.85.199.1/BenQMIR/Webservice/AGVService.asmx/CreateEmptyRecycleTask";//"http://localhost:11111/BenQMIR/Webservice/AGVService.asmx/CreateEmptyRecycleTask";//
        public static string CreateEmptyTask()
        {
            try
            {
                Dictionary<string, string> paramMap = new Dictionary<string, string>();
                paramMap.Add("emptyStation", "D1");
                string path = Add_emptyMsg + "?";
                foreach (string paramName in paramMap.Keys)
                {
                    string par = System.Web.HttpUtility.UrlEncode(paramMap[paramName], System.Text.Encoding.UTF8);
                    path += paramName + "=" + par + "&";
                }
                path = path.Substring(0, path.Length - 1);

                string resultStr = HttpHelper.Post(path, "");
                Common.log.Debug("【" + path + "】【" + resultStr + "】");

                Result data = JsonHelper.DeserializeJsonToObject<Result>(resultStr);

                if (data == null)
                {
                    return " updateDeviceAlarmMsg 没有收到服务器反馈";
                }
                else
                {
                    return data.Succeed.ToString();
                }
            }
            catch (Exception e)
            {
                return e.ToString();
            }
        }

        /// <summary>
        /// 获取接驳台料架情况
        /// </summary>
        /// <param name="lineName"></param>
        /// <returns></returns>
        public static string GetRFIDs(string lineName)
        {
            string addr = "";
            if (lineName.StartsWith(SettingString.D4_Name_Prefix))
            {

                addr = string.Format("http://{0}/LineGetRFID?line={1}", ConfigAppSettings.GetValue(SettingString.IP_4D_Light), lineName);
            }
            else if (lineName.StartsWith(SettingString.C4_Name_Prefix))
            {
                addr = string.Format("http://{0}/LineGetRFID?line={1}", ConfigAppSettings.GetValue(SettingString.IP_4C_Light), lineName);
            }
            try
            {
                string result = HttpHelper.Get(addr);
                if (!result.Equals(""))
                {
                    Msg1 msgs = JsonHelper.DeserializeJsonToObject<Msg1>(result);
                    if (msgs == null)
                        return ",,,";
                    else
                    {
                        Common.log.Debug(string.Format("{0}接驳台状态：{1}", lineName, msgs.Msg));
                        return msgs.Msg;
                    }

                }
            }
            catch (Exception ex)
            {
                Common.log.Error(ex.Message);
                return ",,,";
            }
            return ",,,";
        }

        /// <summary>
        /// 获取接驳台最外面料架
        /// </summary>
        /// <param name="lineName"></param>
        /// <returns></returns>
        public static string GetFirstRFID(string lineName)
        {
            string addr = "";
            if (lineName.StartsWith(SettingString.D4_Name_Prefix))
            {

                addr = string.Format("http://{0}/LineGetRFID?line={1}", ConfigAppSettings.GetValue(SettingString.IP_4D_Light), lineName);
            }
            else if (lineName.StartsWith(SettingString.C4_Name_Prefix))
            {
                addr = string.Format("http://{0}/LineGetRFID?line={1}", ConfigAppSettings.GetValue(SettingString.IP_4C_Light), lineName);
            }
            try
            {
                string result = HttpHelper.Get(addr);
                if (!result.Equals(""))
                {
                    Msg1 msgs = JsonHelper.DeserializeJsonToObject<Msg1>(result);
                    if (msgs == null)
                        return "";
                    else
                    {
                        Common.log.Debug(string.Format("{0}接驳台状态：{1}", lineName, msgs.Msg));
                        string rfid = "";
                        foreach (string item in msgs.Msg.Split(','))
                        {
                            if (!item.Equals(""))
                            {
                                rfid = item;
                            }
                        }
                        return rfid;
                    }

                }
            }
            catch (Exception ex)
            {
                Common.log.Error(ex.Message);
                return "";
            }
            return "";
        }
        /// <summary>
        /// 删除接驳台料架
        /// </summary>
        /// <param name="lineName"></param>
        /// <param name="rfid"></param>
        /// <returns></returns>
        public static bool ClearRFID(string lineName, string rfid)
        {
            string addr = "";
            if (lineName.StartsWith(SettingString.D4_Name_Prefix))
            {

                addr = string.Format("http://{0}/LineClearRFID?line={1}&rfid={2}", ConfigAppSettings.GetValue(SettingString.IP_4D_Light), lineName, rfid);
            }
            else if (lineName.StartsWith(SettingString.C4_Name_Prefix))
            {
                addr = string.Format("http://{0}/LineClearRFID?line={1}&rfid={2}", ConfigAppSettings.GetValue(SettingString.IP_4C_Light), lineName, rfid);
            }
            try
            {
                string result = HttpHelper.Get(addr);
                if (!result.Equals(""))
                {
                    Msg1 msgs = JsonHelper.DeserializeJsonToObject<Msg1>(result);
                    if (msgs == null)
                        return false;
                    else
                    {
                        Common.log.Info(string.Format("删除{0}接驳台料架{1}:{2}", lineName, rfid, msgs.Msg));
                        return true;
                    }

                }
            }
            catch (Exception ex)
            {
                Common.log.Error(ex.Message);
                return false;
            }
            return false;
        }

        private static string Addr_agvRemoveRfid = "/rest/api/qisda/device/agvRemoveRfid";
        /// <summary>
        /// 根据RFID清理料架的缓存信息
        /// </summary>
        /// <param name="rfid"></param>
        /// <returns></returns>
        public static bool AgvRemoveRfid(string rfid)
        {
            try
            {
                Dictionary<string, string> paramMap = new Dictionary<string, string>();
                paramMap.Add("rfid", rfid.ToUpper());
                string server = GetAddr(Addr_agvRemoveRfid, paramMap);
                DateTime startTime = DateTime.Now;
                string resultStr = HttpHelper.Get(server);
                Common.log.Info("清理料架的缓存信息【" + server + "】【" + resultStr + "】");
                //清理料架的缓存信息【http://10.85.199.25/myproject/rest/api/qisda/device/agvRemoveRfid?rfid=C2】【{"code":0,"msg":"ok","data":"料架放上AGV时,清理[C2]的缓存信息成功"}】
                RfidData1 rfidData = JsonHelper.DeserializeJsonToObject<RfidData1>(resultStr);

                if (rfidData == null)
                {
                    return false;
                }
                else
                {

                    if (rfidData.code.Equals(0))
                    {
                        return true;
                    }
                }

            }
            catch (Exception ex)
            {
                Common.log.Error(ex);
                return false;
            }
            return false;
        }
    }
    public class ShelfLockInfo
    {
        //返回: {"code":0,"msg":"ok","data":
        //[{"barcode":"S20052301213","cid":"packing-20","rfid":"A12","rfidLoc":"3","lockPos":"4D2001AA0006","lockPosId":"1231"}]}
        /// <summary>
        /// 返回码，0为正常,其他为异常
        /// </summary>
        public int code { get; set; }
        /// <summary>
        /// 消息
        /// </summary>
        public string msg { get; set; }

        public List<ShelfLockData> data { get; set; }
    }

    public class ShelfLockData
    {
        /// <summary>
        /// 库位中料盘的条码
        /// </summary>
        public string barcode { get; set; }
        /// <summary>
        /// 库位中料盘的锁定库位对应的料仓编
        /// </summary>
        public string cid { get; set; }
        /// <summary>
        /// 料架RFID
        /// </summary>
        public string rfid { get; set; }
        /// <summary>
        /// 料架的库位
        /// </summary>
        public int rfidLoc { get; set; }
        /// <summary>
        /// 库位中料盘的锁定库位
        /// </summary>
        public string lockPos { get; set; }
        /// <summary>
        /// 料架出库的剩余数量
        /// </summary>
        public int taskCount { get; set; }

    }

    /// <summary>
    /// 获取料架中的任务数
    /// </summary>
    public class ShelfTaskCount
    {
        // {"code":0,"msg":"ok","data":{"taskCount":0,"rfid":"A2"}}
        /// <summary>
        /// 0为正常,其他为异常
        /// </summary>
        public int code { get; set; }
        /// <summary>
        /// 消息
        /// </summary>
        public string msg { get; set; }

        public ShelfTaskData shelfTaskData { get; set; }
    }

    public struct ShelfTaskData
    {
        /// <summary>
        /// 当前料架剩余任务数(即还有几盘料没放上去)
        /// </summary>
        public int taskCount { get; set; }
        /// <summary>
        /// 料架RFID
        /// </summary>
        public string rfid { get; set; }
    }

    public class AlarmMsg
    {

        //>>>name :  异常位置名称
        public string name = "";
        //>>>msgKey :  异常信息唯一标识
        public string msgKey = "";
        //>>>msgValue :  异常信息
        public string msgValue = "";
        //0:异常；1：正常显示
        public int type = 0;

        /// <summary>
        /// 异常信息
        /// </summary>
        /// <param name="name">异常位置名称</param>
        /// <param name="key">异常信息唯一标识</param>
        /// <param name="value">异常信息</param>
        public AlarmMsg(string name, string key, string value, int type = 0)
        {
            this.name = name;
            this.msgKey = key;
            this.msgValue = value;
            this.type = type;
        }
        public override string ToString()
        {
            return string.Format("{0},{1},{2},{3}",name,msgKey,msgValue,type); ;
        }
    }
    public class RfidData
    {
        //{"code":0,"msg":"ok","data":"7"} 
        public int code { get; set; }

        public string msg { get; set; }

        public Dictionary<string, string> data { get; set; }
    }
    public class RfidData1
    {
        //{"code":0,"msg":"ok","data":"7"} 
        public int code { get; set; }

        public string msg { get; set; }

        public string data { get; set; }
    }
    /// <summary>
    /// Mir位置
    /// </summary>
    public class MirPosition
    {
        /// <summary>
        /// 位置名称
        /// </summary>
        public string name { get; set; }
        /// <summary>
        /// X轴方位
        /// </summary>
        public double orientation { set; get; }

        /// <summary>
        /// x轴
        /// </summary>
        public double pos_x { get; set; }

        public double pos_y { get; set; }
    }
}