using iWareCc.Conveyor.Entity;
using iWareCc.Conveyor.EnumType;
using iWareCc.DecomposeTask.Entity;
using iWareCc.Properties;
using iWareCommon.Common.Entity;
using iWareCommon.Common.EnumType;
using iWareCommon.Utils;
using iWareDataCore.ORM;
using iWareDataCore.TASK.Entity;
using iWareDataCore.TASK.EnumType;
using iWareLog.ORM;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace iWareCc.DoConveyorTaskAuto.Chain
{
   public class 选择一个未执行的输送机的任务 : IHandler
    {
        /// <summary>
        /// 该节点的下一个节点
        /// </summary>
        private IHandler nextHandler = null;
        public IHandler NextHandler
        {
            set { nextHandler = value; }
        }

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

        private ConveyorEntity Conveyor;


        /// <summary>
        /// 构造函数
        /// </summary>
        /// <param name="resultContainer">结果容器</param>
        /// <param name="decompositionTaskContainer">WIP任务容器</param>
        public 选择一个未执行的输送机的任务(ConveyorEntity c, PartTaskContainer decompositionTaskContainer)
        {
            this.Conveyor = c;
            this.DecompositionTaskContainer = decompositionTaskContainer;
        }


        public void Handle()
        {

            using (var dbModel = new DbModelCore())
            {
                try
                {
                    var task = dbModel.TASKPartTasks.OrderBy(x=>x.handletimes).FirstOrDefault(x => x.type == (int)EPartTaskType.输送机任务 && x.isreleased == (int)EYesOrNo.否 && x.isfinished == (int)EYesOrNo.否 && x.equipid == Conveyor.Equipment.Id);
                    var gate=Conveyor.Gates.FirstOrDefault(x=>x.Place.PlaceTypeName=="gate11");
                    var alarm=Conveyor.Gates.FirstOrDefault(x=>x.Place.PlaceTypeName=="alarm");
                    var sc = Conveyor.Gates.FirstOrDefault(x => x.Place.PlaceTypeName == "sc");
                    if (task == null)
                    {
                        LogTextHelper.WriteLine(Resources.LogDir + @"/自动执行输送机任务流程/" + Conveyor.Equipment.EquipName, "选择一个未执行的输送机的任务:{0}", "未找到相应的输送机任务");
                        return;
                    }

                    task.handletimes += 1;
                    if (task.handletimes >= 200)
                    {
                        task.handletimes = 0;
                    }
                    dbModel.SaveChanges();
                    if (gate != null && gate.Place.Id == task.sourceplaceid && !string.IsNullOrEmpty(sc.RCheckMaterialCode) && !string.IsNullOrWhiteSpace(sc.RCheckMaterialCode) && !sc.RCheckMaterialCode.Contains("ERROR"))
                    {
                        var material = dbModel.BASEMaterialViews.FirstOrDefault(x => x.code == sc.RCheckMaterialCode.Trim());
                        //判断物料是否入库，如果入库直接发送入库任务，不入库生成退库记录
                        if (material != null)
                        {
                            LogTextHelper.WriteLine(Resources.LogDir + @"/物料码信息/", "接收的物料号：{0}", sc.RCheckMaterialCode);
                            var tasknew = dbModel.TASKPartTasks.FirstOrDefault(x => x.type == (int)EPartTaskType.输送机任务 && x.isreleased == (int)EYesOrNo.否 && x.isfinished == (int)EYesOrNo.否 && x.equipid == Conveyor.Equipment.Id && x.materialcode == material.code && x.sourceplaceid == gate.Place.Id);
                            if (tasknew != null)
                            {
                                LogTextHelper.WriteLine(Resources.LogDir + @"/物料码信息/", "发送的物料：{0};任务号;{1}", sc.RCheckMaterialCode, tasknew.id);
                                if (double.Parse(material.wide) >= 250)//退库
                                {
                                    if (gate.RIsEmpty && !gate.ROccupied)//端口有货才发送退库任务
                                    {
                                        LogTextHelper.WriteLine(Resources.LogDir + @"/自动执行输送机任务流程/" + Conveyor.Equipment.EquipName, "获取需要执行任务的输送机:输送机端口{0}上没有检测到物料", gate.Place.PlaceTypeName);
                                        return;
                                    }
                                    int i = 0;
                                    using (var dbModelLog = new DbModelLog())
                                    {
                                        InOutStorageDetail iosd = new InOutStorageDetail()
                                        {
                                            fromplacecode = tasknew.sourceplace,
                                            formplaceid = tasknew.sourceplaceid,
                                            toplacecode = tasknew.toplace,
                                            toplaceid = tasknew.toplaceid,
                                            equipid = tasknew.equipid,
                                            equipname = tasknew.equipname,
                                            updatetime = DateTime.Now,
                                            createtime = tasknew.createtime,
                                            materialcode = tasknew.materialcode,
                                            materialid = material.id,
                                            type = (int)EMainTaskType.退库任务
                                        };
                                        dbModelLog.InOutStorageDetails.Add(iosd);
                                        i = dbModelLog.SaveChanges();
                                    }
                                    if (i > 0)
                                    {
                                        var flag = gate.SendNotIngGateTask();
                                        if (!flag)
                                        {
                                            gate.WPutFinishSymbol = false;
                                            LogTextHelper.WriteLine(Resources.LogDir + @"/自动执行输送机任务流程/" + Conveyor.Equipment.EquipName, "发送输送机退库任务:{0}失败！", tasknew.id, flag);
                                            gate.SendNotIngGateTask();//发送失败，再发一次
                                        }
                                        dbModel.TASKPartTasks.Remove(tasknew);
                                        dbModel.SaveChanges();
                                        sc.RCheckMaterialCode = "";
                                    
                                    }
                             
                                    return;
                                }
                                else//入库
                                {
                                    task = tasknew;

                                }
                                gate.RCheckMaterialCode = "";
                            }
                            else 
                            {
                                alarm.SendGateAlarmTask((int)ESendCode.物料不在入库清单中);
                                LogTextHelper.WriteLine(Resources.LogDir + @"/自动执行输送机任务流程/" + Conveyor.Equipment.EquipName, "选择一个未执行的输送机的任务:{0}", "扫描的物料号在入库任务清单中不存在！");
                                return;
                            }
                        }
                        else 
                        {
                            alarm.SendGateAlarmTask((int)ESendCode.物料不存在);
                            LogTextHelper.WriteLine(Resources.LogDir + @"/自动执行输送机任务流程/" + Conveyor.Equipment.EquipName, "选择一个未执行的输送机的任务:{0}", "没有收到扫描的物料号");
                            return;
                        }
                    }

                 
                    var fromgate = Conveyor.Gates.FirstOrDefault(x => x.Place.Id == task.sourceplaceid);
                    var togate = Conveyor.Gates.FirstOrDefault(x => x.Place.Id == task.toplaceid);

                    if (fromgate == null || togate==null)
                    {
                        LogTextHelper.WriteLine(Resources.LogDir + @"/自动执行输送机任务流程/" + Conveyor.Equipment.EquipName, "选择一个未执行的输送机的任务:未找到名称为{0}的输送机端口", task.sourceplaceid);
                        return;
                    }
                    //确定当前到位的端口上有物料
                    if (fromgate.RIsEmpty || !fromgate.ROccupied)
                    {
                        LogTextHelper.WriteLine(Resources.LogDir + @"/自动执行输送机任务流程/" + Conveyor.Equipment.EquipName, "获取需要执行任务的输送机:输送机端口{0}上没有检测到物料", fromgate.Place.PlaceTypeName);
                        return;
                    }
                    //确定下一个到位的端口上没有物料
                    //if (togate.Place.PlaceTypeName!="gate22")
                    //{
                      if (!togate.RIsEmpty || togate.ROccupied)
                    {
                        LogTextHelper.WriteLine(Resources.LogDir + @"/自动执行输送机任务流程/" + Conveyor.Equipment.EquipName, "获取需要执行任务的输送机:输送机目标端口{0}上有物料", togate.Place.PlaceTypeName);
                        return;
                    }
                    //}
             
                    DecompositionTaskContainer.PartTask = new PartTaskEntity(task);

                    LogTextHelper.WriteLine(Resources.LogDir + @"/自动执行输送机任务流程/" + Conveyor.Equipment.EquipName, "选择一个未执行的输送机的任务:{0}", DecompositionTaskContainer.PartTask.Id);


                    if (nextHandler != null)
                    {
                        fromgate.RIsEmpty = true;
                        fromgate.ROccupied = false;

                        nextHandler.Handle();
                    }

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


        }
    }
}