using IWareCC.CacheInfo;
using IWareCC.CacheInfo.Container;
using IWareCC.Conveyor.Entity;
using IWareCC.ORM;
using IWareCC.Properties;
using IWareCommon.Enum.Common;
using IWareCommon.Help;
using IWareCommon.Util;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

namespace IWareCC.Conveyor.Handle.FinishConveyorTaskAuto
{
    public class 等待输送线完成任务 : IHandler
    {
        /// <summary>
        /// 该节点的下一个节点
        /// </summary>
        private IHandler nextHandler = null;
        public IHandler NextHandler
        {
            set { nextHandler = value; }
        }

        private ConveyorEntity Conveyor;

        /// <summary>
        /// 任务容器
        /// </summary>
        private PartTaskContainer DecompositionTaskContainer;


        public 等待输送线完成任务(PartTaskContainer decompositionTaskContainer)
        {

            this.DecompositionTaskContainer = decompositionTaskContainer;
        }


        public void Handle()
        {
            using (var dbModel = new DbModel())
            {
                try
                {
                    string toname = "";

                    if (DecompositionTaskContainer.DecompositionTask.sourceplace == "1008" || DecompositionTaskContainer.DecompositionTask.sourceplace == "1003" || DecompositionTaskContainer.DecompositionTask.sourceplace == "1001")
                    {
                        toname = "Line" + DecompositionTaskContainer.DecompositionTask.sourceplace;
                    }
                    else
                    {
                        if (DecompositionTaskContainer.DecompositionTask.toplace == "1011" || DecompositionTaskContainer.DecompositionTask.toplace == "1005")//此两处要判断的是后一位的位置的光电信号
                        {
                            toname = "Line" + (int.Parse(DecompositionTaskContainer.DecompositionTask.toplace) + 1).ToString();
                        }
                        else
                        {
                            toname = "Line" + DecompositionTaskContainer.DecompositionTask.toplace;
                        }
                    }
                    var TConveyor = CacheEntity.Conveyors.FirstOrDefault(x => x.ConveyorName == toname);
                    if (TConveyor != null)
                    {
                        Conveyor = TConveyor;
                    }
                    else
                    {
                        return;
                    }


                    bool flag1 = false;
                    if ((DecompositionTaskContainer.DecompositionTask.toplace == DecompositionTaskContainer.DecompositionTask.sourceplace) || (DecompositionTaskContainer.DecompositionTask.toplace == "1007" && DecompositionTaskContainer.DecompositionTask.sourceplace == "1008") || (DecompositionTaskContainer.DecompositionTask.toplace == "1002" && DecompositionTaskContainer.DecompositionTask.sourceplace == "1003"))
                    {
                        flag1 = true;
                    }
                    else
                    {
                        if (Conveyor != null && (Conveyor.RPh1 == 1 && Conveyor.RPh2 == 1))//传感器已检测到有小托盘
                        {
                            flag1 = true;
                        }
                        LogTextHelper.WriteLine(Resources.LogDir + @"/完成输送线任务/" + Conveyor.ConveyorName, "等待输送线完成任务:获取到光电1{0},光电2{2}", Conveyor.RPh1, Conveyor.RPh2);
                    }
                    if (!flag1)
                    {
                        LogTextHelper.WriteLine(Resources.LogDir + @"/完成输送线任务/" + Conveyor.ConveyorName, "等待输送线完成任务:{0}", "发送OPC失败");
                        string msg = String.Format("未检测到广电到位,获取到光电1{0},光电2{2}", Conveyor.RPh1, Conveyor.RPh2);
                        if (DecompositionTaskContainer.DecompositionTask.filereason != msg)
                        {
                            DecompositionTaskContainer.DecompositionTask.filereason = msg;
                            dbModel.SaveChanges();
                        }
                        return;
                    }
                    ///测试任务号是否匹配
                    if (TConveyor.ConveyorName != "Line1003" && TConveyor.ConveyorName != "Line1008")
                    {
                        if (Conveyor.RTaskNo != int.Parse(DecompositionTaskContainer.DecompositionTask.taskcode))
                        {
                            LogTextHelper.WriteLine(Resources.LogDir + @"/完成输送线任务/" + Conveyor.ConveyorName, "等待输送线完成任务WCSId={0},STAKERID={1}:{2}", DecompositionTaskContainer.DecompositionTask.taskcode, Conveyor.RTaskNo, "任务号不匹配");
                            string msg = String.Format("任务号不一致:发送任务号{0},收到任务号{2}", DecompositionTaskContainer.DecompositionTask.taskcode, Conveyor.RTaskNo);
                            if (DecompositionTaskContainer.DecompositionTask.filereason != msg)
                            {
                                DecompositionTaskContainer.DecompositionTask.filereason = msg;
                                dbModel.SaveChanges();
                            }

                            return;
                        }
                    }

                    LogTextHelper.WriteLine(Resources.LogDir + @"/完成输送线任务/" + Conveyor.ConveyorName, "等待输送线完成任务:{0}，收到任务号:{1},本任务号:{2}", "任务已完成", Conveyor.RTaskNo, DecompositionTaskContainer.DecompositionTask.taskcode);
                    if (Conveyor.ConveyorName == "Line1027" || Conveyor.ConveyorName == "Line1022")
                    {
                        if (Conveyor.RHeight != 0)
                        {
                            DecompositionTaskContainer.DecompositionTask.heighttype = Conveyor.RHeight;
                            LogTextHelper.WriteLine(Resources.LogDir + @"/完成输送线任务/" + Conveyor.ConveyorName, "等待输送线完成任务:获取获取高度{0}", Conveyor.RHeight);
                        }
                        else
                        {
                            LogTextHelper.WriteLine(Resources.LogDir + @"/完成输送线任务/" + Conveyor.ConveyorName, "等待输送线完成任务:获取获取高度不正确{0}", Conveyor.ConveyorType);
                            string msg = String.Format("高度检测未反馈正确值:收到高度{0}", Conveyor.RHeight);
                            if (DecompositionTaskContainer.DecompositionTask.filereason != msg)
                            {
                                DecompositionTaskContainer.DecompositionTask.filereason = msg;
                                dbModel.SaveChanges();
                            }

                            return;
                        }
                    }


                    if (nextHandler != null)
                    {
                        nextHandler.Handle();
                    }
                }
                catch (Exception ex)
                {
                    LogTextHelper.WriteLog(Resources.LogDir, this.ToString(), "Handle", ex.Message);
                }
            }
        }
    }
}