using iWareCommon.Common.Globle;
using iWareCommon.Utils;
using iWareModel;
using iWareSql;
using iWareSql.DBModel;
using iWareSql.Entity.ViewMode;
using iWareSql.Orm;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using XiGang.Core.Model;

namespace iWareSql.DataAccess
{
    /// <summary>
    /// 设备任务处理类
    /// </summary>
    public class PartTaskHandler
    {

        /// <summary>
        /// 获取设备任务
        /// </summary>
        /// <returns></returns>
        public static Task_Part GetPartTask(DbModel edm, string taskId)
        {
            return edm.Task_Part.Where(x => x.Id == taskId).FirstOrDefault();
        }

        /// <summary>
        /// 获取当前正在执行的设备任务
        /// </summary>
        /// <returns></returns>
        public static Task_Part GetCurrentDoingTask(int deviceId)
        {
            using (DbModel edm = new DbModel())
            {
                return edm.Task_Part.Where(x => x.TaskState == (int)DeviceTaskStatusEnum.已下发 && x.DeviceId == deviceId).FirstOrDefault();
            }
        }

        /// <summary>
        /// 是否存在 托盘 有任务占用
        /// </summary>
        /// <param name="edm"></param>
        /// <param name="salverCode">托盘号</param>
        /// <returns></returns>
        public static bool IsExistOtherTaskDoingForSalverCode(string salverCode)
        {
            using (DbModel edm = new DbModel())
            {
                int num = edm.Task_Part.Where(x =>
                      (x.TaskState == (int)DeviceTaskStatusEnum.未开始 || x.TaskState == (int)DeviceTaskStatusEnum.已下发)
                      && (x.SalverCode == salverCode )
                    ).Count();
                return num > 0 ? true : false;
            }
        }

        /// <summary>
        /// 是否存在其他设备任务在占用该站点
        /// </summary>
        /// <param name="edm"></param>
        /// <param name="stationCode">站点编号</param>
        /// <returns></returns>
        public static bool IsExistOtherTaskDoing(string stationCode)
        {
            using (DbModel edm = new DbModel())
            {
                int num = edm.Task_Part.Where(x =>
                      (x.TaskState == (int)DeviceTaskStatusEnum.未开始 || x.TaskState == (int)DeviceTaskStatusEnum.已下发)
                      && (x.RealToPlace == stationCode || x.RealSourcePlace == stationCode)
                    ).Count();
                return num > 0 ? true : false;
            }
        }

        /// <summary>
        /// 是否存在其他设备任务在占用该站点
        /// </summary>
        /// <param name="edm"></param>
        /// <param name="stationCode">站点编号</param>
        /// <returns></returns>
        public static bool IsExistOtherTaskDoing(int stationId)
        {
            using (DbModel edm = new DbModel())
            {
                int num = edm.Task_Part.Where(x =>
                      (x.TaskState == (int)DeviceTaskStatusEnum.未开始 || x.TaskState == (int)DeviceTaskStatusEnum.已下发)
                    && (x.SourcePlace == stationId || x.ToPlace == stationId)
                    ).Count();
                return num > 0 ? true : false;
            }
        }

        /// <summary>
        /// 是否存在其他设备任务在占用该站点
        /// </summary>
        /// <param name="edm"></param>
        /// <param name="placeId"></param>
        /// <returns></returns>
        public static bool IsExistOtherTaskDoing(DbModel edm, int placeId)
        {
            int num = edm.Task_Part.Where(x =>
                  (x.TaskState == (int)DeviceTaskStatusEnum.未开始 || x.TaskState == (int)DeviceTaskStatusEnum.已下发)
                  && (x.SourcePlace == placeId || x.ToPlace == placeId)
                ).Count();
            return num > 0 ? true : false;
        }

        /// <summary>
        /// 是否存在其他设备任务(根据任务类型)
        /// </summary>
        /// <param name="edm"></param>
        /// <param name="_deviceTaskTypeEnum"></param>
        /// <returns>true:有任务占用，false：没有任务占用</returns>
        public static bool IsExistOtherTaskDoingForDeviceTaskTypeEnum(DeviceTaskTypeEnum _deviceTaskTypeEnum)
        {
            using (DbModel edm = new DbModel())
            {
                var queryTaskType = (int)_deviceTaskTypeEnum;
                int num = edm.Task_Part.Where(x =>
                      (x.TaskState == (int)DeviceTaskStatusEnum.未开始 || x.TaskState == (int)DeviceTaskStatusEnum.已下发)
                      && (x.TaskType == queryTaskType)
                    ).Count();
                return num > 0 ? true : false;
            }
        }





        /// <summary>
        /// 创建一个设备任务
        /// </summary>
        /// <param name="edm"></param>
        /// <param name="deviceType"></param>
        /// <param name="userName"></param>
        /// <param name="taskSequence"></param>
        /// <param name="_DeviceTaskTypeEnum"></param>
        /// <param name="mainTask"></param>
        /// <param name="salver"></param>
        /// <param name="sourcePlace"></param>
        /// <param name="toPlace"></param>
        /// <param name="description"></param>
        /// <returns></returns>
        public static FunRetEntity CreatePartTask(DateTime createTime, string plcTaskNo, DbModel edm,
            EDeviceType deviceType,
            string userName,
             int taskSequence,
            DeviceTaskTypeEnum _DeviceTaskTypeEnum,
             Task_Main mainTask,
           Base_Salver salver, Base_Station sourcePlace, Base_Station toPlace, string description)
        {
            var validate_deviceByPlace = "";
            switch (_DeviceTaskTypeEnum)
            {
                case DeviceTaskTypeEnum.出库:
                case DeviceTaskTypeEnum.立库空托到拆盘机入口:
                    validate_deviceByPlace = sourcePlace.SrmStationCode;
                    break;
                case DeviceTaskTypeEnum.组盘入库:
                case DeviceTaskTypeEnum.空托转运到立体库:
                    validate_deviceByPlace = toPlace.SrmStationCode;
                    break;
            }
            EDevice device = BusinessHelper.GetDeviceByPlaceNo(deviceType, validate_deviceByPlace);
            var sourcePlaceNo = StationHandler.GetStationCodeByDeviceType(sourcePlace, deviceType);
            var toPlaceNo = StationHandler.GetStationCodeByDeviceType(toPlace, deviceType);

            FunRetEntity fre = new FunRetEntity();
            fre.result = true;
            var isEquipmentBreakdown1 = Wms_EquipmentSituationHandler.IsEquipmentBreakdown((int)device);
            if (isEquipmentBreakdown1.result)
            {//如果设备已经设定为 故障状态，不允许下发任务！！！ [EditBy shaocx,2020-12-07]
                fre.result = false;
                fre.resMsg = isEquipmentBreakdown1.resMsg;
                return fre;
            }

            StationHandler.SetPlaceLockStatus(true, userName, ref sourcePlace, description);
            StationHandler.SetPlaceLockStatus(true, userName, ref toPlace, description);
            StationHandler.SetPlaceTaskDoingStatus(true, userName, ref sourcePlace, description);
            StationHandler.SetPlaceTaskDoingStatus(true, userName, ref toPlace, description);
            Task_Part tsk = new Task_Part()
            {
                Id = Guid.NewGuid().ToString(),

                InOutFlag = mainTask.InOutFlag,
                InOutFlagName = mainTask.InOutFlagName,

                DeviceType = (int)deviceType,
                DeviceTypeName = deviceType.ToString(),
                DeviceId = Convert.ToInt16(device),
                DeviceName = Convert.ToString(device),

                TaskSequence = taskSequence,
                MainTaskSequence = mainTask.TaskSequence,//增加主任务优先级
                TaskDescribe = description,
                MainTaskId = mainTask.Id,
                MainTaskNo = mainTask.TaskNo,
                MaterialId = mainTask.MaterialId,
                Qty = mainTask.Qty,//增加数量 【EditBy shaocx,2022-05-01】

                //增加 订货号和序列号的赋值 [Editby shaocx,2022-04-21]
                SerialNumber = mainTask.SerialNumber,
                OrderNo = mainTask.OrderNo,

                //ToNumber = toNumber,
                //TaskGuid = taskGuid,
                //MatID = MatID,
                //MatName = MatName,
                //Remark = "手动入库创建设备任务" + description,
                //Creator = "手动入库创建设备任务" + "," + Dns.GetHostName(),
                //UpdateUser = "手动入库创建设备任务" + "," + Dns.GetHostName(),
                CreateTime = createTime,
                ModifyTime = createTime,

                PlcTaskId = plcTaskNo,
                //ContainerId = ctn.ContainerId,
                SalverId = salver.Id,
                SalverCode = salver.SalverCode,

                SourcePlace = sourcePlace.Id,
                ToPlace = toPlace.Id,
                RealSourcePlace = sourcePlaceNo,
                RealToPlace = toPlaceNo,

                TaskName = string.Format("(来源:id-{0} no-{1},目标:id-{2} no-{3})", sourcePlace.Id, sourcePlaceNo,
                            toPlace.Id, toPlaceNo),

                IsReleased = false,
                // IsCurrentTask = 0,
                IsFinished = false,
                //IsLastTask = 0,
                //Void = 0,
                TaskState = (int)DeviceTaskStatusEnum.未开始,
                TaskStateName = DeviceTaskStatusEnum.未开始.ToString(),
                TaskType = (int)_DeviceTaskTypeEnum,
                TaskTypeName = _DeviceTaskTypeEnum.ToString(),

                //增加物料类型 【EditBy shaocx,2022-05-04】
                MaterialType = mainTask.MaterialType,
                MaterialTypeName = mainTask.MaterialTypeName,
            };

            DoCreateSrmTask(edm, tsk);
            return fre;
        }


        private static bool DoCreateSrmTask(DbModel edm, Task_Part tsk)
        {
            edm.Task_Part.Add(tsk);
            return true;
        }


        /// <summary>
        /// 移除30天前的任务
        /// </summary>
        /// <param name="edm"></param>
        public static void DeletePartTask(DbModel edm)
        {
            var queryTime = DateTime.Now.AddDays(-30);
            var queryTaskStaus1 = (int)DeviceTaskStatusEnum.已完成;
            var queryTaskStaus2 = (int)DeviceTaskStatusEnum.已取消;
            var removeList = edm.Task_Part.Where(x => x.CreateTime <= queryTime && (x.TaskState == queryTaskStaus1 || x.TaskState == queryTaskStaus2)).ToList();
            if (removeList != null && removeList.Count > 0)
            {
                edm.Task_Part.RemoveRange(removeList);
            }
            var removeRecordList = edm.Task_RequestLog.Where(x => x.CreateTime <= queryTime).ToList();
            if (removeRecordList != null && removeRecordList.Count > 0)
            {
                edm.Task_RequestLog.RemoveRange(removeRecordList);
            }
        }

        #region 更新 OperationRemark


        /// <summary>
        /// 表PartTask写入OperationRemark
        /// </summary>
        /// <param name="partTaskId"></param>
        /// <param name="errMsg"></param>
        public static void WriteOperationRemarkForPartTask(string partTaskId, string errMsg)
        {
            try
            {
                using (DbModel edm = new DbModel())
                {
                    var item = edm.Task_Part.Where(x => x.Id == partTaskId).FirstOrDefault();
                    if (item != null)
                    {
                        item.OperationRemark = errMsg;
                        item.ModifyTime = DateTime.Now;
                        item.ModifyBy = SysGloble.WCSSystem;

                        edm.SaveChanges();
                    }
                }
            }
            catch (Exception)
            {

                throw;
            }
        }

        ///// <summary>
        ///// 表PartTask写入OperationRemark
        ///// </summary>
        ///// <param name="partTaskId"></param>
        ///// <param name="errMsg"></param>
        //private void WriteOperationRemarkForPartTaskList(string errMsg)
        //{
        //    try
        //    {
        //        using (DbModel edm = new DbModel())
        //        {
        //            var queryLesTaskStatus = Convert.ToInt16(LesTaskStatusEnum.新建任务);
        //            var pisList = edm.Task_Part.Where(x =>
        //                x.LesTaskStatus == queryLesTaskStatus).ToList();
        //            if (pisList != null && pisList.Count > 0)
        //            {
        //                foreach (var item in pisList)
        //                {
        //                    item.OperationRemark = errMsg;
        //                    item.ModifyTime = DateTime.Now;
        //                    item.ModifyBy = SysGloble.WCSSystem;
        //                }
        //                edm.SaveChanges();
        //            }
        //        }
        //    }
        //    catch (Exception)
        //    {

        //        throw;
        //    }
        //}

        #endregion

    }
}