using HH.WCS.JingyuNongfu.process;
using HH.WCS.JingyuNongfu.wms;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Reflection;
using System.Text;
using System.Xml;

namespace HH.WCS.JingyuNongfu.dispatch
{
    public class NDC
    {
        private HostToAGV callClient = null;
        public NDC(string url) {
            callClient = new HostToAGV();
            //10.122.160.200
            //callClient.Url = "http://10.122.160.200:9989/HostToAGV.cgi";
            Console.WriteLine($"NDCurl:{url}");
            callClient.Url = url;
        }

        private static string GetReqStr(int ts, Dictionary<string, string> param) {
            //< Order  TS = '60'  Pri = '" + mst.CN_N_PRIORITY.ToString() + "' From = '" + start.CN_N_AGV_LOCATION + "' To = '" + end.CN_N_AGV_LOCATION + "'  No = '" + mst.S_TASK_NO + "_1' Ext1 = '1' Ext2 = '" + Constants.TN_MID_COMMANDEQ_CALLAGVOrderCommandType + "'  N_CNTR_COUNT = ''   FRow = '" + sFloor + "'  TRow = '" + eFloor + "' />
            var sb = new StringBuilder();
            sb.Append($"<Req><Order ");
            if (ts != 0) {
                sb.Append($"TS='{ts}'");
            }
            foreach (var kv in param) {
                sb.Append($" {kv.Key}='{kv.Value}'");
            }
            sb.Append("/></Req>");
            return sb.ToString();
        }
        private static string GetReqStrNew(int ts, int pri, string taskNo, Dictionary<string, string> param) {
            /*<Req>
              <Order TS='5' Pri='80' No='666' NoCallback='0' Ext1='' Ext2='' Ext3=''>
                <Param Name='From' Value='10' />
                <Param Name='To' Value='20' />
                <Param Name='FRow' Value='1' />
                <Param Name='TRow' Value='7' />
                <Param Name='DispInfo' Value='1' />
                <Param Name='CtrlVal' Value='12' />
                <Param Name='ChgTo' Value='2' />
                <Param Name='Flow' Value='111' />
                <Param Name='Tlow' Value='222' />
              </Order>
            </Req>*/
            var sb = new StringBuilder();
            sb.Append($"<Req><Order TS='{ts}' Pri='{pri}' No='{taskNo}'>");

            foreach (var kv in param) {
                sb.Append($"<Param Name='{kv.Key}' Value='{kv.Value}'/>");
            }
            sb.Append("</Order></Req>");
            return sb.ToString();
        }
        public AGVResult AddNewOrderNew(int ts, int pri, string taskNo, Dictionary<string, string> param) {
            //< Req >< Order TS = '1' Pri = '1' No = 'TN2302020001' Ext1 = '' Ext2 = '' N_CNTR_COUNT = '' >< Param Name = 'From' Value = '2' />< Param Name = 'To' Value = '1' /></ Order ></ Req >

            var bufin = GetReqStrNew(ts, pri, taskNo, param);

            try {

                var result = callClient.OrderAdd(bufin);
                LogHelper.Info($"任务下发结果 OrderAdd req={bufin} res={result}","任务");
                Console.WriteLine($"任务下发结果 OrderAdd req={bufin} res={result}");
                //LogHelper.Info(result.bufout, "ts");
                return GetResult(result);
            }
            catch (Exception e) {
                LogHelper.Info($"任务下发失败 OrderAdd req={bufin} res={e.Message}", "任务");
                //Console.WriteLine($"任务下发失败 AddNewOrder req={bufin} res={e.Message}");
                return new AGVResult { Res = new Res { ErrCode = -1, ErrInfo = e.Message } };
            }

        }
        public AGVResult AddNewOrder(int ts, Dictionary<string, string> param) {
            //< Req >< Order TS = '1' Pri = '1' No = 'TN2302020001' Ext1 = '' Ext2 = '' N_CNTR_COUNT = '' >< Param Name = 'From' Value = '2' />< Param Name = 'To' Value = '1' /></ Order ></ Req >

            var bufin = GetReqStr(ts, param);

            try {

                var result = callClient.AddNewOrder(bufin);
                LogHelper.Info($"任务下发结果 AddNewOrder req={bufin} res={result}", "任务");
                Console.WriteLine($"任务下发结果 AddNewOrder req={bufin} res={result}");
                //LogHelper.Info(result.bufout, "ts");
                return GetResult(result);
            }
            catch (Exception e) {
                LogHelper.Info($"任务下发失败 AddNewOrder req={bufin} res={e.Message}", "任务");
                //Console.WriteLine($"任务下发失败 AddNewOrder req={bufin} res={e.Message}");
                return new AGVResult { Res = new Res { ErrCode = -1, ErrInfo = e.Message } };
            }

        }
        public AGVResult CancelOrder(int ts, Dictionary<string, string> param) {
            //< Req >< Order No = 'TN2302020001' >< Param Name = 'IsForce' Value = '1' /></ Order ></ Req >
            var bufin = GetReqStr(ts, param);
            try {
                LogHelper.Info($"任务取消请求发给hosttoagv");
                var result = callClient.CancelOrder(bufin);
                LogHelper.Info($"CancelOrder req={bufin} res={result}");

                var taskNo = param["No"];
                var wmsTask = TaskHelper.GetTask(taskNo);
                //指定任务已经完成或取消，无法再处理。
                var flag = GetResult(result);
                if (flag.Res.ErrInfo == "指定任务已经完成或取消，无法再处理。")
                {
                    TaskProcess.OperateStatus(wmsTask, 7, taskNo);
                    //TaskHelper.Fail(wmsTask);
               }

                
                
                return GetResult(result);
            }
            catch (Exception e) {
                LogHelper.Info($"CancelOrder req={bufin} res={e.Message}");
                return new AGVResult {
                    Res = new Res {
                        ErrCode = -1,
                        ErrInfo = e.Message
                    }
                };
            }

        }
        public AGVResult StartNewOrderWithQCmd(int ts, Dictionary<string, string> param) {
            //lpn:      <Order TS='41' Pri='' ExtDeviceNo='{0}' CtrlVal='{1}' DispInfo='{2}' No='{3}' Ext1='' Ext2='' N_CNTR_COUNT='' />
            //traccif:  <Order TS='164' From='2' To='2' ExtDeviceNo='" + lockNo + "' No='" + DateTime.Now.Ticks.ToString() + "' />
            //lock:     <Order TS='170'  CtrlVal='" + CtrlVal + "' ExtDeviceNo='" + roadway + "' No='" + DateTime.Now.Ticks.ToString() + "' />
            var bufin = GetReqStr(ts, param);
            try {
                var r = callClient.StartNewOrderWithQCmd(bufin);
                //Console.WriteLine($"交管占用成功 StartNewOrderWithQCmd req={bufin} res={r}");
                LogHelper.Info($"交管占用成功 StartNewOrderWithQCmd req={bufin} res={r}", "任务");
                return GetResult(r);
            }
            catch (Exception e) {
                //Console.WriteLine($"交管占用失败 StartNewOrderWithQCmd req={bufin} res={e.Message}");
                LogHelper.Info($"交管占用失败 StartNewOrderWithQCmd req={bufin} res={e.Message}", "任务");
                return new AGVResult {
                    Res = new Res {
                        ErrCode = -1,
                        ErrInfo = e.Message
                    }
                };
            }
        }
        public AGVResult ChangeOrder(Dictionary<string, string> param) {
            //< Req >< Order No = 'TN2302020002' ParamNo = '1' Param1 = '1' /></ Req >
            var bufin = GetReqStr(0, param);
            try {
                var r = callClient.ChangeOrder(bufin);
                LogHelper.Info($"ChangeOrder req={bufin} res={r}");
                return GetResult(r);
            }
            catch (Exception e) {
                LogHelper.Info($"ChangeOrder req={bufin} res={e.Message}");
                return new AGVResult {
                    Res = new Res {
                        ErrCode = -1,
                        ErrInfo = e.Message
                    }
                };
            }
        }
        private static AGVResult GetResult(string bufout) {
            //<Res><ErrCode>0</ErrCode><Result>11</Result></Res>
            XmlDocument xml = new XmlDocument();
            xml.LoadXml(bufout);
            var json = JsonConvert.SerializeXmlNode(xml);
            return JsonConvert.DeserializeObject<AGVResult>(json);
        }
        public class AGVResult
        {
            public Res Res { get; set; }
        }
        public class Res
        {
            public int ErrCode { get; set; }
            public string ErrInfo { get; set; }
        }
    }
}