using log4net;
using OnlineStore.Common;
using OnlineStore.LoadCSVLibrary;
using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.IO;
using System.IO.Ports;
using System.Linq;
using System.Text;
using System.Threading;
using System.Windows.Forms;

namespace OnlineStore.DeviceLibrary
{
    public class StoreManager
    { 
         
        public static DUOStoreBean Store = null;
        public static Store_Config Config = null;
        public static Dictionary<int, BaseConfig> allConfigMap = null;
        private static bool isInit = false;
        public static bool IsConnectServer = !ConfigAppSettings.GetValue(Setting_Init.http_server).Equals("");

        public static string LastVisualRfid = "";
        public static bool ShelfNeedOut = false;


        public static bool FrontDoorOpen = false;

        public static DateTime AgvNeedEmptyTime = DateTime.Now;

        static StoreManager()
        {
            //var CurrShelfNum = Properties.Settings1.Default.CurrShelfNum;
            //Properties.Settings1.Default.CurrShelfNum = "12";
            //Properties.Settings1.Default.Save();

            //CurrShelfNum = Properties.Settings1.Default.CurrShelfNum;
        }

        #region 配置文件加载更新
        public static void CheckEnum(Type type)
        {
            if (type.IsEnum)
            {
                List<int> valueList = new List<int>();
                foreach (int item in Enum.GetValues(type))
                {
                    if (valueList.Contains(item))
                    {
                        LogUtil.error(type.Name + "枚举值：" + item + "重复存在，请检查代码，即将 退出程序！");
                        MessageBox.Show(type.Name + "枚举值：" + item + "重复存在，请检查代码，即将 退出程序！");
                        Application.Exit();
                        break;
                    }
                    valueList.Add(item);
                }
            }
        }
        public static DUOStoreBean InitStore()
        {
            try
            {
                allConfigMap = new Dictionary<int, BaseConfig>();
                BaseConfig.ProIOIpMap = new Dictionary<string, string>();
                if (!isInit)
                {
                    string server = ConfigAppSettings.GetValue(Setting_Init.http_server);
                    if (server.Equals(""))
                    {
                        IsConnectServer = false;
                    }
                    else
                    {
                        //IsConnectServer = true;
                    }
                    CheckEnum(typeof(StoreMoveStep));
                    CheckEnum(typeof(StoreStatus));
                    CheckEnum(typeof(StoreRunStatus));

                    isInit = true;
                    string storeType = ConfigAppSettings.GetValue(Setting_Init.Store_Type);
                    int count = ConfigAppSettings.GetIntValue(Setting_Init.store_count);
                    LogUtil.info("配置的料仓 类型=" + storeType + "，开始加载料仓配置");
                    string appPath = Application.StartupPath;
                    string CID = ConfigAppSettings.GetValue(Setting_Init.Store_CID);
                    Dictionary<int, BOX_Config> storeConfig = new Dictionary<int, BOX_Config>();
                    if (storeType == StoreType.RC_AC_PA)
                    {

                        string linefilePath = appPath + ConfigAppSettings.GetValue(Setting_Init.Store_ConfigPath);
                        Config = CSVConfigReader.LoadLineConfig(0, CID, "Line", linefilePath);
                        allConfigMap.Add(0, Config);

                        string moveEquipConfig = ConfigAppSettings.GetValue(Setting_Init.BOX_ConfigPath);
                        for (int i = 1; i <= count; i++)
                        {
                            string nameStr = i.ToString().PadLeft(1, '0');
                            string config = appPath + moveEquipConfig.Replace(".csv", "_" + nameStr + ".csv");
                            string storeIdConfig = Setting_Init.Store_CID + "_" + i;
                            string boxCid = ConfigAppSettings.GetValue(storeIdConfig);
                            BOX_Config moveConfig = CSVConfigReader.LoadBoxConfig(i, boxCid, "BOX", config);
                            moveConfig.SetIO(i);
                            allConfigMap.Add(i, moveConfig);
                            storeConfig.Add(i, moveConfig);
                        }
                        string positionConfigFile = appPath + ConfigAppSettings.GetValue(Setting_Init.Store_Position_Config);
                        if (count > 1 || (!File.Exists(positionConfigFile)))
                        {
                            for (int i = 1; i <= count; i++)
                            {
                                string nameStr = i.ToString().PadLeft(1, '0');
                                string fileN = positionConfigFile.Replace(".csv", "_" + nameStr + ".csv");
                                CSVPositionReader<ACBoxPosition>.AddCSVFile(fileN, i);
                            }
                        }
                        else
                        {
                            CSVPositionReader<ACBoxPosition>.AddCSVFile(positionConfigFile);
                        }
                        CSVPositionReader<ACBoxPosition>.AddCSVFile(Path.Combine(appPath, @"StoreConfig\FixPositions.csv"));
                        //AgvClient.Init();
                        LogUtil.info("加载料仓完成！");

                    }
                    Store = new DUOStoreBean(Config, storeConfig);
                }
            }
            catch (Exception ex)
            {
                LogUtil.error("出错：" + ex.ToString());
                MessageBox.Show(ex.ToString(), "加载配置错误（请检查配置）");
                Application.Exit();
            }
            return Store;
        } 
        public static bool UpdateBoxConfig(BOX_Config storeConfig)
        {
            try
            {
                //位置配置到文件中
                string appPath = Application.StartupPath;
                string configFile = appPath + ConfigAppSettings.GetValue(Setting_Init.BOX_ConfigPath);
                if (!Directory.Exists(configFile))
                { 
                    configFile = configFile.Replace(".csv", "_" + storeConfig.Id + ".csv");
                }
                bool result = CSVConfigReader.SaveBoxPosition(configFile, storeConfig);

                if (!result)
                {
                    LogUtil.error("保存配置文件失败：" + configFile);
                }
                allConfigMap[storeConfig.Id] = storeConfig;
                Store.BoxConfigMap[storeConfig.Id] = storeConfig;
                Store.BoxMap[storeConfig.Id].Config = storeConfig;
                Store.BoxMap[storeConfig.Id].MoveAxisConfig();
                return true;
            }
            catch (Exception ex)
            {
                LogUtil.error("出错：" + ex.ToString());
            }
            return false;
        }
        public static bool UpdateStoreConfig(Store_Config storeConfig)
        {
            try
            {
                //位置配置到文件中
                string appPath = Application.StartupPath;
                string configFile = appPath + ConfigAppSettings.GetValue(Setting_Init.Store_ConfigPath);
                if (!File.Exists(configFile))
                {
                    configFile = configFile.Replace(".csv", "_" + storeConfig.Id + ".csv");
                }
                bool result = CSVConfigReader.SaveBoxPosition(configFile, storeConfig);

                if (!result)
                {
                    LogUtil.error("保存配置文件失败：" + configFile);
                }
                StoreManager.Config = storeConfig;
                StoreManager.Store.Config = storeConfig;
                return true;
            }
            catch (Exception ex)
            {
                LogUtil.error("出错：" + ex.ToString());
            }
            return false;
        }

        #endregion

        #region 位置加载

        public static bool LoadInoutParam(InOutParam param, MoveType movetype, bool needCheckShelf, BoxBean box)
        {
            if (param == null)
            {
                return false;
            }
            //加载位置
            if (param.MoveP == null)
            {
                LineMoveP p = new LineMoveP();

                p.ComPress_P1 = box.Config.CompAxis_P1;
                p.InOut_P1 = box.Config.InOutAxis_P1;
                p.Middle_P1 = box.Config.MiddleAxis_P1;

                p.InOut_P2 = box.Config.InOutAxis_P2;
                p.UpDown_P1 = box.Config.UpDownAxis_P1;
                //  p.UpDown_P8 = box.Config.UpDownAxis_DoorIBPosition_P8;
                p.UpDown_P2 = box.Config.UpDownAxis_P2;
                //  p.UpDown_P7 = box.Config.UpDownAxis_DoorOBPosition_P7;


                p.ComPress_P2 = box.Config.GetComP2(param.PlateH);
                p.ComPress_P3 = box.Config.CompAxis_P1;

                ACBoxPosition position = CSVPositionReader<ACBoxPosition>.GetPositon(param.PosID);
                if (position == null)
                {
                    if (movetype.Equals(MoveType.InStore) && param.TargetPosition.Equals(1))
                    {
                        param.MoveP = p;
                        return true;
                    }
                    LogUtil.error(box.Name + "GetPositon[" + param.PosID + "]=null,没有库位不能执行出入库");
                    return false;
                }
                if (param.PlateH <= 0)
                {
                    param.PlateH = position.BagHigh;
                }
                if (param.PlateW <= 0)
                {
                    param.PlateW = position.BagWidth;
                }
                //p.ComPress_P2 = box.Config.GetComP2(position.BagHigh);
                //p.ComPress_P3 = box.Config.CompAxis_P3;

                p.ComPress_P3 = position.ComAxis_P3;
                p.InOut_P3 = position.InoutAxis_P3;
                p.Middle_P2 = position.MiddleAxis_P2;
                p.UpDown_P3 = position.UpdownAxis_IH_P3;
                p.UpDown_P4 = position.UpdownAxis_IL_P4;
                p.UpDown_P5 = position.UpdownAxis_OH_P5;
                p.UpDown_P6 = position.UpdownAxis_OL_P6;

                param.MoveP = p;


                return true;
            }
            return true;
        }

        #endregion


        private static string api_communication = "service/store/communication";    //流水线状态通信接口 
        public static string GetPostApi(string host)
        {
            if (host == "")
            {
                host = ConfigAppSettings.GetValue(Setting_Init.http_server);
            }
            if (!host.StartsWith("http://"))
            {
                host = "http://" + host;
            }
            if (!host.EndsWith("/"))
            {
                host = host + "/";
            }
            return host + api_communication;
        }
        private static string GetAddr(string addr, Dictionary<string, string> paramsMap)
        {
            string server = ConfigAppSettings.GetValue(Setting_Init.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 ProcessCode(int LastWidth, int LastHeight, List<string> LastScanCodes)
        {
            string message = "";
            string spiltStr = "##";
            string codeSize = LastWidth + "x" + LastHeight;
            foreach (string str in LastScanCodes)
            {
                if (str.Trim().Equals(""))
                {
                    continue;
                }
                string code = "=1+0x0-" + codeSize + "=" + str.Trim();

                if (!String.IsNullOrEmpty(code))
                {
                    message = message + code + spiltStr;
                }
            }
            return message;
        }
         
         
        //        取消任务地址:   /cancelPutInTask      //参数: barcode
        private static string Addr_cancelPutInTask = "/service/store/cancelPutInTask";
        public static string cancelPutInTask(string deviceName, string barcode)
        {
            string msg = "";
            try
            {

                Dictionary<string, string> paramMap = new Dictionary<string, string>();
                paramMap.Add("barcode", barcode);

                string server = GetAddr(Addr_cancelPutInTask, paramMap);
                DateTime startTime = DateTime.Now;
                string resultStr = HttpHelper.Post(server, "");
                LogUtil.info(deviceName + "cancelPutInTask    " + FormUtil.GetSpanStr(DateTime.Now - startTime) + "  【" + server + "】【" + resultStr + "】");

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

                if (data == null)
                {
                    return msg = deviceName + " cancelPutInTask【 " + barcode + "】 没有收到服务器反馈";
                }
                else if (data.code.Equals(0).Equals(false))
                {
                    return msg = deviceName + " cancelPutInTask【 " + barcode + "】   ：" + data.msg;
                }

                return "";
            }
            catch (Exception ex)
            {
                LogUtil.error(deviceName + " " + ex.ToString());
            }
            return msg;
        }
        private static string spiltStr = "##";
        private static string Addr_PosForPutin = "/service/store/emptyPosForPutin";
        private static bool r=false;
        public static GetPosResult GetPosId(string deviceName, List<string> codeList, int height, int width, string  shelfNum)
        {
            GetPosResult result = new GetPosResult();
            try
            {
                string codeStr = "";
                List<string> list = new List<string>();
                foreach (string str in codeList)
                {
                    if (list.Contains(str.Trim()) || String.IsNullOrEmpty(str.Trim()))
                    {
                        continue;
                    }
                    list.Add(str.Trim());
                    string code = "=" + width + "x" + height + "=" + str.Trim();
                    codeStr = codeStr + code + spiltStr;
                }
                codeStr = CodeManager.ReplaceCode(codeStr);
                //http://localhost/myproject/service/store/emptyPosForPutin
                // 参数：cids: 多个 cid
                //code: 条码内容
                Dictionary<string, string> paramMap = new Dictionary<string, string>();
                List<string> cids = new List<string>();
                foreach(int k in Store.BoxMap.Keys)
                {
                    if (!Store.BoxMap[k].IsDebug && !Store.BoxMap[k].Disabled && Store.BoxMap[k].runStatus > StoreRunStatus.Wait)
                    {
                        cids.Add(Store.BoxMap[k].CID);
                    }
                }
                if (r)
                {
                    r = false;
                    cids.Reverse();
                }
                else
                    r = true;
                paramMap.Add("cids", string.Join(",",cids.ToArray()));
                paramMap.Add("code", codeStr);
                paramMap.Add(ParamDefine.rfid, shelfNum);

                string server = GetAddr(Addr_PosForPutin, paramMap);
                DateTime startTime = DateTime.Now;
                LogUtil.info(deviceName + "【" + shelfNum + "】【 " + codeStr + "】 ，获取入库库位：");

                string resultStr = HttpHelper.Post(server, "", Encoding.UTF8, 3500, out result.IsTimeOut);

                LogUtil.info(deviceName + "CodeReceived " + FormUtil.GetSpanStr(DateTime.Now - startTime) + " 【" + server + "】【" + resultStr + "】");
                if (result.IsTimeOut)
                {
                    return result;
                }
                //{"result":"0","msg":"","pos":"11#AC1_18_4_28","barcode":"R506072019102200414","cid":"line-ac-11"}
                LineOperation serverResult = JsonHelper.DeserializeJsonToObject<LineOperation>(resultStr);

                if (serverResult == null)
                {
                    result.Msg = deviceName + "  【" + codeStr + "】结果：没有收到服务器反馈，调用 cancelPutInTask ";
                    cancelPutInTask(deviceName, codeStr);
                    result.Param = new InOutParam( MoveType.InStore, codeStr, "", width,height,1, shelfNum, true, "没有收到服务器反馈"); 
                    return result;
                }
                else if ((!string.IsNullOrEmpty(serverResult.msg)) || serverResult.result.Equals(0).Equals(false))
                {
                    result.Result = serverResult.result;
                    result.Msg = deviceName + "  【" + codeStr + "】结果：" + serverResult.msg;
                    result.Param = new InOutParam(MoveType.InStore, codeStr, "", width, height, 1, shelfNum, true, serverResult.msg);
                     
                    return result;
                }
                result.Result = serverResult.result;
                if (!serverResult.pos.Equals(""))
                { 
                    string posId = serverResult.pos;

                    //根据库位号查找移栽
                    //  判断PosID是否已经在入库或者在排队列表中，如果已经存在，加入列表失败     
                    result.Param = new InOutParam(MoveType.InStore, serverResult.barcode, posId,  width, height,0, shelfNum, false,""); 
                    int storeId = result.Param.GetStoreId();
                    if (Store.BoxMap.ContainsKey(storeId))
                    {
                        BoxBean box = Store.BoxMap[storeId];
                        LogUtil.info(deviceName + "收到入库命令： " + result.Param.ToStr() + "  ");
                        result.Param.InStoreNg = false;
                        result.Msg = "";
                        return result;
                    }
                    else
                    {
                        result.Param.InStoreNg = true;
                        result.Param.NgMsg = "未找到料仓[" + storeId + "]";
                        result.Msg = deviceName + ("收到入库命令：" + "未找到料仓[" + storeId + "]： " + result.Param.ToStr() + " ，入库失败！");
                        return result;
                    }
                }
            }
            catch (Exception ex)
            {
                LogUtil.error(deviceName + " ", ex);
            }
            return result;
        }

        private static readonly string Addr_putShelfFinished = "/rest/api/dcs/device/putShelfFinished";
        public static string putShelfFinished(string deviceName,string shelfNum, string rfidLoc, string barcode)
        {
            retry:
            string msg = "";
            try
            {
                Dictionary<string, string> paramMap = new Dictionary<string, string>();
                paramMap.Add("rfid", shelfNum);
                paramMap.Add("rfidLoc", rfidLoc);
                paramMap.Add("barcode", barcode);

                string server = GetAddr(Addr_putShelfFinished, paramMap);
                DateTime startTime = DateTime.Now;
                string resultStr = HttpHelper.Post(server, "");
                LogUtil.info(deviceName + "putShelfFinished" + FormUtil.GetSpanStr(DateTime.Now - startTime) + " 【" + server + "】【" + resultStr + "】");

                var data = JsonHelper.DeserializeJsonToObject<CommData<string>>(resultStr);

                if (data == null)
                {
                    Thread.Sleep(1000);
                    goto retry;
                    //return msg = deviceName + " putShelfFinished【 " + barcode + "】 没有收到服务器反馈";
                }
                else if (data.code.Equals(0).Equals(false))
                {
                    return msg = deviceName + " putShelfFinished【 " + barcode + "】   ：" + data.msg;
                }

                return "";
            }
            catch (Exception ex)
            {
                LogUtil.error(deviceName + " " + ex.ToString());
                Thread.Sleep(1000);
                goto retry;
            }
            return msg;
        }

        private static readonly string Addr_unfinishedTaskCount = "/rest/api/dcs/device/unfinishedTaskCount";
        public static int unfinishedTaskCount(string deviceName, string shelfNum)
        {
            try
            {
                string cids = "";
                foreach (int k in Store.BoxMap.Keys)
                {
                    cids += Store.BoxMap[k].CID + ",";
                }
                cids = cids.TrimEnd(',');
                Dictionary<string, string> paramMap = new Dictionary<string, string>();
                paramMap.Add("rfid", shelfNum);
                paramMap.Add("cids", cids);

                string server = GetAddr(Addr_unfinishedTaskCount, paramMap);
                DateTime startTime = DateTime.Now;
                string resultStr = HttpHelper.Post(server, "");
                LogUtil.info(deviceName + "unfinishedTaskCount" + FormUtil.GetSpanStr(DateTime.Now - startTime) + " 【" + server + "】【" + resultStr + "】");

                var data = JsonHelper.DeserializeJsonToObject<CommData<int>>(resultStr);

                if (data == null)
                {
                    LogUtil.info(deviceName + "unfinishedTaskCount 没有收到服务器反馈");
                    return 99999;
                }
                else if (data.code.Equals(0).Equals(false))
                {
                    LogUtil.info(deviceName + " unfinishedTaskCount【 " + shelfNum + cids + "】   ：" + data.msg);
                    return 99999;
                }

                return data.data;
            }
            catch (Exception ex)
            {
                LogUtil.error(deviceName + " " + ex.ToString());
            }
            return 0;
        }

        //public static void SendPosToStoreCheck(string deviceName, InOutParam param)
        //{
        //    if (param == null || param.InStoreNg)
        //    {
        //        return;
        //    }
        //    int storeId = param.GetStoreId();
        //    BoxBean  moveEquip = Store.BoxMap[storeId];
        //    if (LineServer.BoxCanInStore(moveEquip.DeviceID))
        //    {
        //        LineServer.CheckInStorePos(storeId, param);
        //    }
        //    else
        //    {
        //        //等待3秒后重发验证
        //        Task.Factory.StartNew(delegate
        //        {
        //            LogUtil.error(deviceName + "[" + moveEquip.Name + " ]入库命令： " + param.ToStr() + " 给料仓发送验证失败，等待3秒后重发 ");
        //            Thread.Sleep(3000);
        //            LineServer.CheckInStorePos(storeId, param);
        //        });
        //    }
        //    lock (moveEquip.waitInListLock)
        //    {
        //        //如果当前正在出入库中，需要记录下来，等待空闲时执行
        //        LogUtil.info(deviceName + "[" + moveEquip.Name + " ]入库命令： " + param.ToStr() + "加入等待列表中！");
        //        moveEquip.waitInStoreList.Add(param);
        //    }
        //}  
        public static bool checkWatch(Stopwatch watch, int targetMs, bool isStop = true)
        {
            if (!watch.IsRunning)
            {
                watch.Restart();
                return false;
            }
            else if (watch.ElapsedMilliseconds >= targetMs)
            {
                if (isStop)
                {
                    watch.Stop();
                }
                return true;
            }
            return false;
        }
    }
    public class GetPosResult
    {
        public string Msg = "";
        /// <summary>
        /// 99:暂时不能入库，需要重新获取库位。100：服务器需要更新，需要重新获取库位
        /// </summary>
        public int Result = 0;
        /// <summary>
        /// 获取超时，需要重新获取库位
        /// </summary>
        public bool IsTimeOut = false;
        public InOutParam Param = null;
    }
     
    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 CommData<T>
    {
        //{"code":0,"msg":"ok","data":"7"} 
        public int code { get; set; }

        public string msg { get; set; }

        public T data { get; set; }
    }
    public class LineOperation
    {
        //  //{"result":"0","msg":"","pos":"11#AC1_18_4_28","barcode":"R506072019102200414","cid":"line-ac-11"}
        //    返回: {"code": 0, "msg":"ok", data:7}
        /// <summary>
        /// 0=成功
        /// </summary>
        public int result;
        public string cid;
        public string msg = "";
        public string pos = "";
        public string barcode = "";

    }

}