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.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
                {
                  
                    var task = dbModel.PartTasks.OrderBy(x=>x.finishtimes).FirstOrDefault(x =>  x.isreleased == (int)EYesOrNo.是 && x.isfinished == (int)EYesOrNo.否 && x.eqtype == (int)EPartTaskType.输送线任务);

                    if (task == null)
                    {
                       // LogTextHelper.WriteLine(Resources.LogDir + @"/完成输送线任务/", "获取当前的输送线任务:{0}", "没有找到待完成的任务");
                        return;
                    }
                    string name = "Line" + task.sourceplace;
                    var conveyor = CacheEntity.Conveyors.FirstOrDefault(x => x.ConveyorName == name);
                    Conveyor = conveyor;

                    //if (!Conveyor.RAck && !Conveyor.WSTP && task.voidlabel < 3)
                    //{
                    //    string msg = "";
                    //    var flag = Conveyor.SendTask(Conveyor.DeviceId, int.Parse(task.taskcode), task.toplace, task.heighttype, out msg);
                    //    if (flag)
                    //    {
                    //        if (Conveyor.WriteValue(Conveyor.OpcWriteItems.STP, 1))
                    //        {
                    //            task.voidlabel += 1;
                    //            dbModel.SaveChanges();
                    //        }
                    //    }
                    //    LogTextHelper.WriteLine(Resources.LogDir + @"/完成输送线任务/" + Conveyor.ConveyorName, "选择一个未执行的输送线的任务:输送线{0}已在任务中，任务发送成功，但设备未接收到，重新发送", Conveyor.ConveyorName);
                    //    return;
                    //}
                    //else if (!Conveyor.RAck && !Conveyor.WSTP && task.voidlabel > 3)
                    //{
                    //    LogTextHelper.WriteLine(Resources.LogDir + @"/完成输送线任务/" + Conveyor.ConveyorName, "选择一个未执行的输送线的任务:输送线{0}已在任务中，任务发送失败，但设备未接收任务已达3次，重新发送", Conveyor.ConveyorName);
                    //}
            
                    if (Conveyor.RAck && Conveyor.WSTP)
                    {
                        if (!Conveyor.WriteValue(Conveyor.OpcWriteItems.STP, 0)) 
                        {
                            Conveyor.WriteValue(Conveyor.OpcWriteItems.STP, 0);
                        }
                        LogTextHelper.WriteLine(Resources.LogDir + @"/完成输送线任务/" + Conveyor.ConveyorName, "选择一个未执行的输送线的任务:输送线{0}已在任务中，不能下发任务", Conveyor.ConveyorName);
                        return;
                    }
                

                    task.finishtimes += 1;

                    dbModel.SaveChanges();
                     
                
                    DecompositionTaskContainer.DecompositionTask = task;
                    LogTextHelper.WriteLine(Resources.LogDir + @"/完成输送线任务/" + Conveyor.ConveyorName, "获取当前的输送线任务:{0}", DecompositionTaskContainer.DecompositionTask.id);

                    if (nextHandler != null)
                    {
                        nextHandler.Handle();
                    }

                }
                catch (Exception ex)
                {
                    LogTextHelper.WriteLog(Resources.LogDir, this.ToString(), "Handle", ex.Message);
                }
            }
        }
    }
}