using HH.WCS.Mobox3.pinggao.device;
using HH.WCS.Mobox3.pinggao.dispatch;
using HH.WCS.Mobox3.pinggao.util;
using HH.WCS.Mobox3.pinggao.wms;
using S7.Net;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading;

namespace HH.WCS.Mobox3.pinggao.process
{
    /// <summary>
    /// 设备信号处理，主要是tcp信号，我们做server被动接收信号来处理，根据项目定制的
    /// </summary>
    internal class DeviceProcess
    {
        internal static void Analysis(string data, string ip)
        {
            if (data.Length >= 6)
            {
                //去掉消息头3F 00
                data = data.Substring(4);
                //Console.WriteLine($"{ip}-{data}");
                var plc = Settings.deviceInfos.Where(a => a.address == ip && a.enable == 1).FirstOrDefault();
                if (plc != null)
                {
                    if (plc.deviceType == 1)
                    {
                        AnalysisBottleCapmolding(data, plc);
                    }
                }
                else
                {
                    Console.WriteLine($"TCP信号处理：未查询到IP为{ip}的数据，请检查deviceInfo配置中心是否存在该IP的数据！");
                }
            }

        }

        internal static void Traffic(string forkliftNo, string lockNo, bool v)
        {
        }


        /// <summary>
        /// 接收PLC注塑机信号
        /// </summary>
        /// <param name="data"></param>
        /// <param name="plc"></param>
        private static void AnalysisBottleCapmolding(string data, Settings.deviceInfo plc)
        {
            LogHelper.Info($"{plc.deviceName}--IP={plc.address}--msg={data}", "注塑机");
            //下满框信号生成下满框任务 待取货完成解绑起点货位 生成送空任务
            if (data.Substring(0, 2) == "11")
            {
                if (moldingFull(plc, plc.location[0]))
                {
                    LogHelper.Info($"{plc.deviceName}--IP={plc.address}--msg=注塑机A口生成取满任务", "注塑机");
                }
            }
            if (data.Substring(2, 2) == "21")
            {
                if (moldingFull(plc, plc.location[1]))
                {
                    LogHelper.Info($"{plc.deviceName}--IP={plc.address}--msg=注塑机B口生成取满任务", "注塑机");
                }
            }

        }

        private static bool moldingFull(Settings.deviceInfo plc, string location)
        {
            //通过站点编号查询工单
            //通过工单获取物料编码、批号(前期富勒没上线批号自行编写)
            var result = false;

            var db = new SqlHelper<object>().GetInstance();
            if (location != "")
            {
                if (LocationHelper.CheckLocFree(location))
                {
                    LogHelper.Info($"2{plc.deviceName}--IP={location})");
                    
                    var workOrder = db.Queryable<WorkOrder>().Where(a => a.S_BP_CODE == plc.deviceName).First();
                    if (workOrder != null)
                    {
                        LogHelper.Info($"查到了工单{workOrder.S_WOB_CODE} 工单状态为: {workOrder.S_WOB_STATE} 即产即用={workOrder.S_USING_NOW} 连接区域={workOrder.S_LINKLINENO}", "瓶盖机");
                        if (workOrder.S_WOB_STATE.Trim() == "执行中")
                        {
                            LogHelper.Info($"查询当前货位 托盘数量 货位编码={location}");
                            var trayInfo = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE == location).ToList();
                            if (trayInfo.Count() > 0)
                            {
                                LogHelper.Info($"当前货位托盘数量大于0");
                                var trayNo = trayInfo[0].S_CNTR_CODE;
                                ProduceTask(plc, location, db, workOrder, trayNo);
                            }
                            else
                            {
                                LogHelper.Info($"瓶盖机：{plc.deviceName} 下线信号：{location} 该站点没有托盘无法取满", "瓶盖机");
                            }
                        }
                    }
                    else
                    {
                        LogHelper.Info($"瓶盖机：{plc.deviceName} 下线信号：{location} 未找到工单", "瓶盖机");
                    }
                }
                else
                {
                    LogHelper.Info($"瓶盖机：{plc.deviceName} 当前位置{location}有任务，不可触发满托下线", "瓶盖机");
                }
            }
            return result;
        }

        internal static void TaskState(WCSTask mst, int state)
        {
            LogHelper.Info($"车辆回报完后调用空框上线");
            if (mst.S_OP_NAME == "注塑机下线" && state == 6)
            {
                KKoutTask(mst);
            }
        }

        private static void KKoutTask(WCSTask mst)
        {
            var db = new SqlHelper<object>().GetInstance();
            try
            {
                //卸货完成生成上空任务
                var deviceInfo = Settings.deviceInfos.Where(a => a.location.Contains(mst.S_START_LOC)).FirstOrDefault();
                if (deviceInfo != null)
                {
                    //查找对应产线的工单是否执行
                    var workInfo = db.Queryable<WorkOrder>().Where(a => a.S_BP_CODE == deviceInfo.deviceName && a.S_WOB_STATE == "执行中").First();
                    if (workInfo != null)
                    {
                        //查找产线对应的空框库区配置
                        var prodectArea = Settings.connectAreas.Where(a => a.deviceName == deviceInfo.deviceName && a.locAttribute == "空").FirstOrDefault();
                        if (prodectArea != null)
                        {
                            //查询库区是否有空框使用
                            Location startLoc = null;
                            string trayNo = "";
                            for (int i = 0; i < prodectArea.connectAreaList.Length; i++)
                            {
                                LogHelper.Info($"伪长度{i}");
                                var startArea = prodectArea.connectAreaList[i];
                                startLoc = db.Queryable<Location>().Where(a => a.S_AREA_CODE == startArea && a.N_CURRENT_NUM > 0 && a.N_LOCK_STATE == 0).Includes(a => a.LocCntrRel).First();//a.S_ATTRIBUTE=="空" &&
                                if (startLoc!=null)
                                {
                                    LogHelper.Info($"S_CODE{startLoc.S_CODE}");
                                    if (startLoc.LocCntrRel != null)
                                    {
                                        trayNo = startLoc.LocCntrRel.S_CNTR_CODE;
                                        break;
                                    }
                                }
                                LogHelper.Info($"trayNo{trayNo}");
                               
                            }
                            LogHelper.Info($"进来了");
                            if (startLoc != null && !string.IsNullOrEmpty(trayNo))
                            {
                                var endLoc = db.Queryable<Location>().Where(a => a.S_CODE == mst.S_START_LOC).First();
                                WMSHelper.CreatOpenation(startLoc, endLoc, trayNo, "注塑机上线", 2);
                            }
                        }
                    }
                }
            }
            catch (Exception ex) 
            {
                LogHelper.Error($"注塑上线异常 任务号{mst.S_CODE} 异常信息{ex.Message}", ex);
            }
        }

        private static void ProduceTask(Settings.deviceInfo plc, string location, SqlSugar.SqlSugarClient db, WorkOrder workOrder, string trayNo)
        {
            var startLoc = db.Queryable<Location>().Where(a => a.S_CODE == location).First();
            Location endLoc = null;
            try
            {
                var connectArea = Settings.connectAreas.Where(a => a.deviceName == plc.deviceName && a.locAttribute == "满").FirstOrDefault();
                if (connectArea != null)
                {
                    for (int i = 0; i < connectArea.connectAreaList.Length; i++)
                    {
                        var endArea = connectArea.connectAreaList[i];

                        LogHelper.Info($"库区：{endArea} ");
                        endLoc = db.Queryable<Location>()
                            .Where(a =>
                            a.S_AREA_CODE == endArea &&
                            //a.S_ATTRIBUTE == "满" &&
                            a.N_CURRENT_NUM == 0 &&
                            a.N_LOCK_STATE == 0)
                            .First();
                        if (endLoc != null)
                        {
                            break;
                        }
                        else
                        {
                            LogHelper.Info($"库区：{endArea}没有找到可用库位");
                        }
                    }

                    if (startLoc != null && endLoc != null)
                    {
                        //创建任务
                        var res = WMSHelper.CreatOpenation(startLoc, endLoc, trayNo, "注塑机下线", 1);
                        if (res)
                        {
                            //将托盘绑定物料
                            var itemInfo = db.Queryable<CntrItemRel>()
                                .Where(a =>
                                a.S_ITEM_CODE == workOrder.S_ITEM_CODE &&
                                a.S_BP_CODE == workOrder.S_BP_CODE &&
                                a.S_BATCH_NO==workOrder.S_BATCH_NO &&
                                a.S_CNTR_CODE == trayNo)
                                .First();
                            if (itemInfo == null)
                            {
                                //新增
                                itemInfo = new CntrItemRel { S_ITEM_CODE = workOrder.S_ITEM_CODE, S_BP_CODE = workOrder.S_BP_CODE, S_CNTR_CODE = trayNo ,S_BATCH_NO=workOrder.S_BATCH_NO};
                                db.Insertable(itemInfo).ExecuteCommand();
                            }
                        }
                    }else
                        LogHelper.Info($"生成任务失败，没有找到可用库位");
                }
            }
            catch (Exception ex)
            {
                LogHelper.Error($"注塑机下线算取满框缓存位异常 异常信息{ex.Message}", ex);
            }
        }
    }
}