using Hanhe.iWCS.Business;
using Hanhe.iWCS.Common;
using Hanhe.iWCS.MData;
using Hanhe.iWCS.Model;
using MongoDB.Bson;
using MongoDB.Driver;
using MongoDB.Driver.Builders;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Linq;
using static Hanhe.iWCS.TaizhouGEMTwoProtocol.PLCControl;
using static Hanhe.iWCS.TaizhouGEMTwoProtocol.ProcessHelper;

namespace Hanhe.iWCS.TaizhouGEMTwoProtocol
{
    /// <summary>
    /// ams接口辅助类
    /// </summary>
    public class ApiHelper
    {
        private static ICallTaskProcessing callTaskProcessing = new ICallTaskProcessing();
        static ApiHelper()
        {

        }

        internal static SimpleResult SendTask(AddTaskModel model)
        {
            SimpleResult result = new SimpleResult();
            if (model.taskType == 1)
            {
                //PLan A.当WMS调AMS生成空托出库任务时，直接拦截存入中间表，待到线程循环读取推送电梯一段任务时，优先推送
                //MongoDBSingleton.Instance.Insert<ElevatorTask>(new ElevatorTask { taskNo = DateTime.Now.ToString(), wmsTaskNo = DateTime.Now.ToString(), startBit = model.startBit, endBit = PLCControl.DeviceBit8(), wmsEndBit = model.endBit, startFloor = 1, endFloor = 3, sendFlag = 0, create = DateTime.Now.ToString() });

                //Plan B.当WMS调AMS生成空托出库任务时，接受并创建空托出库任务，待到任务推送时，根据任务类型进行拦截
                var r = AMSHelper.CreateTask(DateTime.Now.ToString(), model.startBit, model.endBit, "空托出库", 1);
                result.success = r.success;
            }
            else if (model.taskType == 2)
            {
                //1楼成品货架区到1楼出库缓存位       --此任务需要添加虚拟终点，根据1楼出库缓存位的广电信号来分配AGV一个终点（四个点位，空的则可以入）
                //WMS不需要传输终点，终点由AMS根据光电PLC信号，判断哪个信号是空的，再通知AGV终点，在此之前先使用虚拟终点
                var r = AMSHelper.CreateTask(DateTime.Now.ToString(), model.startBit, model.endBit, "成品出库", 1);
                result.success = r.success;
            }
            else if (model.taskType == 3)
            {
                //PDA：1楼空托线边区到1楼成品空托位   ——应该有起点和终点位，直接推送——需反馈WMS任务状态
                var r = AMSHelper.CreateTask(DateTime.Now.ToString(), model.startBit, model.endBit, "空托线边", 1);
                result.success = r.success;
            }
            return result;
        }
        public class AddTaskModel
        {
            /// <summary>
            /// 任务起点
            /// </summary>
            public string startBit { get; set; }
            /// <summary>
            /// 任务终点
            /// </summary>
            public string endBit { get; set; }
            /// <summary>
            /// 任务类别    1.1楼成品空托区到3楼补给成品空托区
            ///             2.1楼成品货架区到1楼出库缓存位
            ///             3.PDA：1楼空托线边区到1楼成品空托位
            /// </summary>
            public int taskType { get; set; }
        }
        public class SimpleResult
        {
            public bool success { get; set; }
            public int errCode { get; set; }
            public string errMsg { get; set; }
        }

        #region   NG任务设备状态

        internal static SimpleResult NgTask(NgTaskModel model)
        {
            SimpleResult result = new SimpleResult();
            if (model.fcBit == 0)
            {
                var setus = MongoDBSingleton.Instance.FindOne<NgTaskModel>(Query.EQ("bzBit", model.bzBit), "NgTaskModel");
                if (setus == null)
                {
                    MongoDBSingleton.Instance.Insert<NgTaskModel>(new NgTaskModel { fcBit = model.fcBit, fcSetus = model.fcSetus, bzBit = model.bzBit, bzSetus = model.bzSetus });
                }
                else
                {
                    var updateBuider = Update.Set("fcBit", model.fcBit).Set("fcSetus", model.fcSetus).Set("bzBit", model.bzBit).Set("bzSetus", model.bzSetus);
                    MongoDBSingleton.Instance.Update<NgTaskModel>(Query.EQ("bzBit", model.bzBit), updateBuider, UpdateFlags.None);
                }
            }
            else
            {
                var setus = MongoDBSingleton.Instance.FindOne<NgTaskModel>(Query.EQ("fcBit", model.fcBit), "NgTaskModel");
                if (setus == null)
                {
                    //SecondWeighState
                    MongoDBSingleton.Instance.Insert<NgTaskModel>(new NgTaskModel { fcBit = model.fcBit, fcSetus = model.fcSetus, bzBit = model.bzBit, bzSetus = model.bzSetus });
                    MongoDBSingleton.Instance.Update<SecondWeighState>(Query.EQ("location", GetSecondWeighBit()), Update.Set("ng", 2), UpdateFlags.None);
                }
                else
                {
                    var updateBuider = Update.Set("fcBit", model.fcBit).Set("fcSetus", model.fcSetus).Set("bzBit", model.bzBit).Set("bzSetus", model.bzSetus);
                    MongoDBSingleton.Instance.Update<NgTaskModel>(Query.EQ("fcBit", model.fcBit), updateBuider, UpdateFlags.None);
                    MongoDBSingleton.Instance.Update<SecondWeighState>(Query.EQ("location", GetSecondWeighBit()), Update.Set("ng", model.fcSetus), UpdateFlags.None);
                }
            }

            return result;
        }

        public class NgTaskModel
        {
            /// <summary>
            /// 默认情况下全都都传0
            /// </summary>
            public ObjectId _id { get; set; }
            /// <summary>
            /// 复称平台点位  复称平台有问题，就传值1
            /// </summary>
            public int fcBit { get; set; }
            /// <summary>
            /// 复称平台状态  复称平台有问题的情况下，传值2
            /// </summary>
            public int fcSetus { get; set; }
            /// <summary>
            /// 包装点位    包装机有问题，传包装机数字编号，例如1~9
            /// </summary>
            public int bzBit { get; set; }
            /// <summary>
            /// 包装状态    包装机有问题的情况下，传值2
            /// </summary>
            public int bzSetus { get; set; }
        }

        #endregion

        #region   MES接口模拟测试
        internal static MESData MESTest(MESSendData model)
        {
            MESData result = new MESData();

            var mesRequst = MongoDBSingleton.Instance.FindOne<MESReSult>(Query.EQ("machineNo", model.machineNo), "MESReSult");
            if (mesRequst != null)
            {
                result.machineNo = mesRequst.machineNo;
                result.lotNo = mesRequst.lotNo;
                result.bagNo = mesRequst.bagNo;
                result.productType = mesRequst.productType;
                result.materialCode = mesRequst.materialCode;
                result.overlappingLayers = mesRequst.overlappingLayers;
            }
            else
            {
                MongoDBSingleton.Instance.Insert<MESReSult>(new MESReSult { machineNo = "T1" });
            }
            return result;
        }
        public class MESSendData
        {
            /// <summary>
            /// 包装机号
            /// </summary>
            public string machineNo { get; set; }
        }
        public class MESReSult
        {
            public ObjectId _id { get; set; }
            /// <summary>
            /// mes返回的包装机号（T1，T2，......，T9）
            /// </summary>
            public string machineNo { get; set; }
            /// <summary>
            /// mes返回的成品批次号
            /// </summary>
            public string lotNo { get; set; }
            /// <summary>
            /// mes返回的袋号
            /// </summary>
            public string bagNo { get; set; }
            /// <summary>
            /// mes返回的产品型号
            /// </summary>
            public string productType { get; set; }
            /// <summary>
            /// mes返回的物料编码
            /// </summary>
            public string materialCode { get; set; }
            /// <summary>
            /// mes返回的叠包层数  （例1,2,3：1代表不叠包，2代表叠2层，3代表叠3层）
            /// </summary>
            public string overlappingLayers { get; set; }
        }
        public class MESData
        {
            /// <summary>
            /// mes返回的包装机号（T1，T2，......，T9）
            /// </summary>
            public string machineNo { get; set; }
            /// <summary>
            /// mes返回的成品批次号
            /// </summary>
            public string lotNo { get; set; }
            /// <summary>
            /// mes返回的袋号
            /// </summary>
            public string bagNo { get; set; }
            /// <summary>
            /// mes返回的产品型号
            /// </summary>
            public string productType { get; set; }
            /// <summary>
            /// mes返回的物料编码
            /// </summary>
            public string materialCode { get; set; }
            /// <summary>
            /// mes返回的叠包层数  （例1,2,3：1代表不叠包，2代表叠2层，3代表叠3层）
            /// </summary>
            public string overlappingLayers { get; set; }
        }
        #endregion

        #region   Json数据写入写出中间表测试
        public static int[] machinedown = new int[16];
        internal static JsonData Json(JsonData model)
        {
            JsonData result = new JsonData();



            for (int i = 0; i <= 15; i++)
            {
                machinedown[i] = i;
            }
            var json = JsonConvert.SerializeObject(machinedown);

            Console.WriteLine("json数据" + json);
            var jsonMachine = MongoDBSingleton.Instance.FindOne<JsonDataMod>(Query.EQ("order", model.order), "JsonDataMod");
            var arr = JsonConvert.DeserializeObject(jsonMachine.jsonOne);
            Console.WriteLine("var数据" + arr);
            if (jsonMachine != null)
            {
                result.jsonOne = jsonMachine.jsonOne;
                result.jsonTwo = jsonMachine.jsonTwo;
                result.jsonThree = jsonMachine.jsonThree;
            }
            else
            {
                MongoDBSingleton.Instance.Insert<JsonDataMod>(new JsonDataMod { order = model.order, jsonOne = json });
            }
            var arr1 = JsonConvert.DeserializeObject<List<int>>(jsonMachine.jsonOne);
            Console.WriteLine("数组数据：" + arr1);
            for (int i = 0; i <= 15; i++)
            {
                Console.WriteLine($"循环打印数组单个数据{arr1[i]}");
            }

            return result;
        }
        public class JsonData
        {
            public int order { get; set; }
            public string jsonOne { get; set; }
            public JsonConverter jsonTwo { get; set; }
            public JsonData jsonThree { get; set; }
        }
        public class JsonDataMod
        {
            public ObjectId _id { get; set; }
            public int order { get; set; }
            public string jsonOne { get; set; }
            public JsonConverter jsonTwo { get; set; }
            public JsonData jsonThree { get; set; }
        }
        #endregion

        #region   教称流程，人工PDA返回复称平台，包装机复称信息

        internal static SimpleResult SecondResult(secondResultCache model)
        {
            SimpleResult result = new SimpleResult();
            var weigh = MongoDBSingleton.Instance.FindOne<secondResult>(Query.EQ("Bit", model.Bit), "secondResult");
            if (weigh != null)
            {
                MongoDBSingleton.Instance.Update<secondResult>(Query.EQ("Bit", model.Bit), Update.Set("Bit", model.Bit).Set("Status", model.Status), UpdateFlags.None);
                result.success = true;
                CMMLog.Info($"返回状态接口调用成功，当前点位：{model.Bit},点位状态：{model.Status}");
                Console.WriteLine($"返回状态接口调用成功，当前点位：{model.Bit},点位状态：{model.Status}");
            }
            else
            {
                MongoDBSingleton.Instance.Insert<secondResult>(new secondResult { Bit = model.Bit, Status = model.Status });
                result.success = true;
                CMMLog.Info($"返回状态接口调用成功，当前点位：{model.Bit},点位状态：{model.Status}");
                Console.WriteLine($"返回状态接口调用成功，当前点位：{model.Bit},点位状态：{model.Status}");
            }
            if(model.Bit == GetSecondWeighBit())
            {
                int i = model.Status == "OK" ? 1 : 2;
                MongoDBSingleton.Instance.Update<SecondWeighState>(Query.EQ("location", GetSecondWeighBit()), Update.Set("secondNg", i));
            }
            return result;
        }
        public class secondResultCache
        {
            /// <summary>
            /// 教称点位
            /// </summary>
            public string Bit { get; set; }
            /// <summary>
            /// 教称点位状态
            /// </summary>
            public string Status { get; set; }
        }
        public class secondResult
        {
            public ObjectId _id { get; set; }
            /// <summary>
            /// 教称点位
            /// </summary>
            public string Bit { get; set; }
            /// <summary>
            /// 教称点位状态
            /// </summary>
            public string Status { get; set; }
        }

        #endregion


        /// <summary>
        /// AGV状态处理
        /// </summary>
        /// <param name="a"></param>
        internal static void AGVDeviceReceiveSet(AgvDeviceStatus a)
        {
            if (!string.IsNullOrEmpty(a.forkliftNo))
            {
                a.xPos = string.IsNullOrEmpty(a.xPos) ? "0" : a.xPos;
                a.yPos = string.IsNullOrEmpty(a.yPos) ? "0" : a.yPos;
                a.Degree = string.IsNullOrEmpty(a.Degree) ? "0" : a.Degree;

                var agvStateInfo = MongoDBSingleton.Instance.FindOne<AGV_STATE>(Query.EQ("forkliftNo", a.forkliftNo), "AGV_STATE");
                if (agvStateInfo != null)
                {
                    var query1 = Query.EQ("forkliftNo", a.forkliftNo);
                    UpdateBuilder updateBuider = Update.Set("forkliftNo", a.forkliftNo).
                            Set("errCode", a.errCode).Set("errCode2", a.errCode2).
                            Set("faildCode", a.faildCode).Set("xPos", a.xPos).
                            Set("yPos", a.yPos).Set("battery", a.battery).Set("detail", a.detail).Set("goods_visible", a.goods_visible).
                            Set("Degree", a.Degree);
                    MongoDBSingleton.Instance.Update<AGV_STATE>(query1, updateBuider, "AGV_STATE", UpdateFlags.None);
                }
                else
                {
                    MongoDBSingleton.Instance.Insert<AGV_STATE>(new AGV_STATE 
                    { 
                        forkliftNo = a.forkliftNo, 
                        errCode = a.errCode, 
                        errCode2 = a.errCode2, 
                        faildCode = a.faildCode, 
                        xPos = a.xPos, 
                        yPos = a.yPos, 
                        battery = a.battery, 
                        detail = a.detail, 
                        goods_visible = a.goods_visible, 
                        Degree = a.Degree 
                    }, "AGV_STATE");
                }
            }
        }

        /// <summary>
        /// 库位相机处理
        /// </summary>
        /// <param name="a"></param>
        internal static SimpleResult CameraInfo(cameraModel a)
        {
            SimpleResult result = new SimpleResult();

            var cameraInfo = MongoDBSingleton.Instance.FindOne<CameraTable>(Query.EQ("site", a.PointCode), "CameraTable");
            if (cameraInfo != null)
            {
                if (cameraInfo.site == a.PointCode && cameraInfo.state == a.PointStatus)
                {
                    cameraInfo.time += 1;
                    MongoDBSingleton.Instance.Update<CameraTable>(Query.EQ("site", a.PointCode), Update.Set("time", cameraInfo.time), UpdateFlags.None);
                }
                else
                {
                    MongoDBSingleton.Instance.Remove<CameraTable>(Query.EQ("site", a.PointCode), RemoveFlags.Single);
                }
            }
            else
            {
                if (a.PointStatus == 0)
                {
                    MongoDBSingleton.Instance.Insert<CameraTable>(new CameraTable
                    {
                        site = a.PointCode,
                        state = a.PointStatus,
                        time = 1
                    }, "CameraTable");
                }
            }

            try
            {
                var cameraInfoList = MongoDBSingleton.Instance.FindAll<CameraTable>("CameraTable");
                if (cameraInfoList.Count > 0)
                {
                    cameraInfoList.ForEach(it => {
                        if (it.time > 10)
                        {
                            CMMLog.Info("CameraTable表大于10次的数据：" + JsonConvert.SerializeObject(cameraInfoList));

                            //调用wms解绑接口
                            result.success = WMSHelper.WMSEmptyUnbind(it.site);

                            if (result.success)
                            {
                                MongoDBSingleton.Instance.Remove<CameraTable>(Query.EQ("site", it.site), RemoveFlags.Single);
                                result.errCode = 0;
                            }
                            CMMLog.Info($"发货货架解绑成功，货位号：{it.site}");

                        }
                    });
                }
            }
            catch (Exception ex)
            {
                CMMLog.Error(ex.Message, ex);
            }

            return result;
        }

        internal static SimpleResult OutWareMode(OutWareModel models)
        {
            SimpleResult result = new SimpleResult() { success = false, errCode = 0 };
            var modeInfo = MongoDBSingleton.Instance.FindOne<ModeList>("ModeList");
            if (modeInfo != null)
            {
                MongoDBSingleton.Instance.Update<ModeList>(Query.EQ("_id", modeInfo._id), Update.Set("Mode", models.model), UpdateFlags.None);
                result.success = true;
                result.errCode = 0;
            }
            
            return result;
        }

        public class CameraTable
        {
            public ObjectId _id { get; set; }
            /// <summary>
            /// 点位
            /// </summary>
            public string site { get; set; }
            /// <summary>
            /// 状态
            /// </summary>
            public int state { get; set; }
            /// <summary>
            /// 接收到了数据次数
            /// </summary>
            public int time { get; set; }
        }

        public class AGV_STATE
        {
            public ObjectId _id { get; set; }
            public string forkliftNo { get; set; }
            /// <summary>
            /// 停止状态码
            /// </summary>
            public string errCode { get; set; } = "";
            /// <summary>
            /// 停止状态码2
            /// </summary>
            public string errCode2 { get; set; } = "";
            /// <summary>
            /// 失败状态码
            /// </summary>
            public string faildCode { get; set; } = "";
            /// <summary>
            /// 车辆X坐标（CM）
            /// </summary>
            public string xPos { get; set; } = "0";
            /// <summary>
            /// 车辆Y坐标（Y）
            /// </summary>
            public string yPos { get; set; } = "0";
            /// <summary>
            /// 电池电量
            /// </summary>
            public string battery { get; set; } = "";

            public string detail { get; set; } = "";
            /// <summary>
            /// 是否有货状态码
            /// </summary>
            public string goods_visible { get; set; } = "";
            /// <summary>
            /// 方向
            /// </summary>
            public string Degree { get; set; } = "0";
        }

        /// <summary>
        /// hosttoagv上报车辆状态（参数在hosttoagv服务配置，可修改）
        /// </summary>
        public class AgvDeviceStatus
        {
            public string infoType { get; set; } = "";
            public string inMapRoute { get; set; } = "";
            //public string detail { get; set; }
            public string CumInfo { get; set; } = "";
            public string forkliftNo { get; set; } = "";
            /// <summary>
            /// 停止状态码
            /// </summary>
            public string errCode { get; set; } = "";
            /// <summary>
            /// 停止状态码2
            /// </summary>
            public string errCode2 { get; set; } = "";
            /// <summary>
            /// 失败状态码
            /// </summary>
            public string faildCode { get; set; } = "";
            /// <summary>
            /// 车辆X坐标（CM）
            /// </summary>
            public string xPos { get; set; } = "0";
            /// <summary>
            /// 车辆Y坐标（Y）
            /// </summary>
            public string yPos { get; set; } = "0";
            /// <summary>
            /// 电池电量
            /// </summary>
            public string battery { get; set; } = "";

            public string detail { get; set; } = "";
            /// <summary>
            /// 是否有货状态码
            /// </summary>
            public string goods_visible { get; set; } = "";
            /// <summary>
            /// 方向
            /// </summary>
            public string Degree { get; set; } = "0";
        }

        public class ReturnResult
        {
            public int ResultCode { get; set; }
            public string ResultMsg { get; set; }
        }

        public class cameraModel
        {
            /// <summary>
            /// 点位
            /// </summary>
            public string PointCode { get; set; }
            /// <summary>
            /// 状态  0 - 无货 1 - 有货 3 - 异常
            /// </summary>
            public int PointStatus { get; set; }
        }

        public class OutWareModel
        {
            /// <summary>
            /// 模式（入库模式  出库模式）
            /// </summary>
            public string model { get; set; }
        }
    }
}