using AutoMapper; using HslCommunication; using Newtonsoft.Json; using OfficeOpenXml.Drawing.Chart; using OfficeOpenXml.FormulaParsing.Excel.Functions.Text; using Quartz; using System; using System.Collections.Generic; using System.ComponentModel; using System.Linq; using System.Reflection; using System.Text; using System.Threading.Tasks; using WIDESEAWCS_Common.ShuttleCarEnum; using WIDESEAWCS_Common.TaskEnum; using WIDESEAWCS_Core; using WIDESEAWCS_Core.Caches; using WIDESEAWCS_Core.Helper; using WIDESEAWCS_DTO.System; using WIDESEAWCS_DTO.TaskInfo; using WIDESEAWCS_DTO.WMSInfo; using WIDESEAWCS_IShuttleCar; using WIDESEAWCS_ITaskInfoRepository; using WIDESEAWCS_ITaskInfoService; using WIDESEAWCS_Model.Models; using WIDESEAWCS_QuartzJob; using WIDESEAWCS_QuartzJob.DTO; using WIDESEAWCS_QuartzJob.Service; using WIDESEAWCS_QuartzJob.StackerCrane.Enum; using WIDESEAWCS_TaskInfoService; using WIDESEAWCS_Tasks.ConveyorLineJob; using WIDESEAWCS_Tasks.ShuttleCarJob; using WIDESEAWCS_Tasks.StackerCraneJob; namespace WIDESEAWCS_Tasks { [DisallowConcurrentExecution] partial class CommonShuttleCarJob : JobBase, IJob { private readonly ITaskService _taskService; private readonly ITaskRepository _taskRepository; private readonly ITaskHtyService _taskHtyService; private readonly WIDESEAWCS_IShuttleCar.IShuttleCarService _shuttleCarService; private readonly ITaskExecuteDetailService _taskExecuteDetailService; private readonly IRouterService _routerService; private readonly ICacheService _cacheService; private readonly IMapper _mapper; public CommonShuttleCarJob(ITaskService taskService, ITaskRepository taskRepository, ITaskHtyService taskHtyService, WIDESEAWCS_IShuttleCar.IShuttleCarService shuttleCarService, ITaskExecuteDetailService taskExecuteDetailService, IRouterService routerService, ICacheService cacheService, IMapper mapper) { _taskService = taskService; _taskRepository = taskRepository; _taskHtyService = taskHtyService; _shuttleCarService = shuttleCarService; _taskExecuteDetailService = taskExecuteDetailService; _routerService = routerService; _cacheService = cacheService; _mapper = mapper; } public Task Execute(IJobExecutionContext context) { try { ShuttleCar shuttleCar = (ShuttleCar)context.JobDetail.JobDataMap.Get("JobParams"); if (shuttleCar != null) { shuttleCar.Communicator.IsReadAfterWrite = false; ShuttleCarTaskCommandR command = ReadCustomer(shuttleCar, shuttleCar.DeviceCode);//读取穿梭车信息 _cacheService.AddOrUpdate(shuttleCar.DeviceCode, command); if (command != null && command.JoinStatus == 1) { #region 穿梭车任务完成 var complete = shuttleCar.GetValue(ShuttleCarDBName.TaskComplete); if (complete && command.TaskTypeComplete > (short)ShuttleCarTaskComplete.Standby) { #region 日志记录 FieldInfo? fieldInfo = typeof(ShuttleCarTaskComplete).GetField(((ShuttleCarTaskComplete)command.TaskTypeComplete).ToString()); DescriptionAttribute? description = fieldInfo.GetCustomAttribute(); var type = description?.Description ?? ((ShuttleCarTaskComplete)command.TaskTypeComplete).ToString(); WriteDebug($"{shuttleCar.DeviceName}任务完成", $"任务号【{command.number}】,完成类型【{type}】"); #endregion _taskService.ShuttleCarTaskCompleted(command.number, command.TaskTypeComplete); shuttleCar.SetValue(ShuttleCarDBName.ConfirmComplete, true, shuttleCar.DeviceCode); } #endregion GetSC_CarFinish();//堆垛机完成移车/移车充电/移库/入库任务 #region 创建移车充电任务 if (command.Err_Status == (short)ShuttleCarErr.LowBattery || command.ElectricQuantity <= (short)ShuttleCarErr.LowBattery) { var ShuttleCar = QueryCode(shuttleCar.DeviceCode); #region 判断穿梭车当前位置是否有任务 if (_taskRepository.QueryFirst(x => x.SourceAddress == ShuttleCar.ShuttleCarPosition || x.TargetAddress == ShuttleCar.ShuttleCarPosition) == null) { Dt_Task _Task = _taskRepository.QueryFirst(x => x.TaskType == TaskOtherTypeEnum.RelocationCarCharging.ObjToInt()); if (_Task != null) { if (_Task.ShuttleCarCode != shuttleCar.DeviceCode) { ShuttleCar shuttleCar1 = Storage.Devices.Where(x => x.DeviceCode.Equals(_Task.ShuttleCarCode)).FirstOrDefault() as ShuttleCar; ShuttleCarTaskCommandR command1 = ReadCustomer(shuttleCar1, shuttleCar1.DeviceCode);//读取穿梭车信息 if (command1 != null && command1.JoinStatus == 1) { if (command1.Status == (short)ShuttleCarStatus.Charging && command1.ElectricQuantity >= 50) { shuttleCar1.SetValue(ShuttleCarDBName.TaskType, (short)ShuttleCarStatus.QuitCharging); } } } } else { string CarChargingStation = AppSettings.Configuration[nameof(CarChargingStation)];//判断充电位是否有车 var ShuttleCar1 = _shuttleCarService.QueryShuttleCar(CarChargingStation); if (ShuttleCar1 != null && ShuttleCar1.ShuttleCarCode != shuttleCar.DeviceCode) { #region 判断是否存在新建移车任务 if (_taskRepository.QueryFirst(x => x.ShuttleCarCode == ShuttleCar1.ShuttleCarCode) == null) { var dt_Task = GetTask((int)TaskCarStatusEnum.CarNew, (int)TaskOtherTypeEnum.RelocationCar); if (dt_Task != null && string.IsNullOrEmpty(dt_Task.SourceAddress)) { dt_Task.SourceAddress = ShuttleCar1.ShuttleCarPosition; dt_Task.CurrentAddress = dt_Task.SourceAddress; dt_Task.ShuttleCarCode = ShuttleCar1.ShuttleCarCode; _taskService.UpdateData(dt_Task); _taskExecuteDetailService.AddTaskExecuteDetail(dt_Task.TaskNum, "更新移车任务起始地址"); } else _taskService.AddRelocationCarTask(ShuttleCar1.ShuttleCarPosition, "", ShuttleCar1.ShuttleCarCode); } #endregion } else { _taskService.AddRelocationCarTask(ShuttleCar.ShuttleCarPosition, CarChargingStation, ShuttleCar.ShuttleCarCode, ShuttleCarTaskType.Charging.ToString()); } } } #endregion } #endregion #region 获取移车/出入库任务 if (command != null && (command.Status == (short)ShuttleCarStatus.Standby || command.Status == (short)ShuttleCarStatus.Charging) && command.TaskTypeComplete == (short)ShuttleCarTaskComplete.Standby && (command.Err_Status == (short)ShuttleCarErr.Normal || command.Err_Status == (short)ShuttleCarErr.LowBattery)) { //Get_CarTask(shuttleCar, command); GetShuttleCarTask(shuttleCar, command); } #endregion } } } catch (Exception ex) { //Console.Out.WriteLine(nameof(CommonShuttleCarJob) + ":" + ex.ToString()); } return Task.CompletedTask; } } }