| | |
| | | using Mapster; |
| | | using Microsoft.AspNetCore.Components.Routing; |
| | | using Newtonsoft.Json; |
| | | using Oracle.ManagedDataAccess.Types; |
| | | using SqlSugar; |
| | | using System.Diagnostics.CodeAnalysis; |
| | | using System.Threading.Tasks; |
| | |
| | | using WIDESEAWCS_QuartzJob.Models; |
| | | using WIDESEAWCS_QuartzJob.Repository; |
| | | using WIDESEAWCS_QuartzJob.Service; |
| | | using WIDESEAWCS_TaskInfo_HtyRepository; |
| | | using WIDESEAWCS_TaskInfoRepository; |
| | | |
| | | namespace WIDESEAWCS_TaskInfoService |
| | |
| | | if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.OutbondGroup) |
| | | { |
| | | // 判断任务目标地址和路径是否满足特定条件 |
| | | if (task.TargetAddress == "002-021-001" && task.Roadway.Contains("JZ") && task.TaskType == (int)TaskOutboundTypeEnum.OutTray) |
| | | if ((task.TargetAddress == "002-021-001" || task.TargetAddress == "001-021-001") && task.Roadway.Contains("JZ")) |
| | | { |
| | | // 设置任务状态为出库新建 |
| | | task.TaskState = (int)TaskOutStatusEnum.OutNew; |
| | |
| | | // 判断任务类型是否为入库任务 |
| | | else if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.InboundGroup) |
| | | { |
| | | var value = _sys_ConfigService.GetByConfigKey(CateGoryConst.CONFIG_SYS_InStation, SysConfigKeyConst.JZNGInBoundStation).ConfigValue; |
| | | var valueList = value.Split(',').ToList(); |
| | | // 判断源地址是否不等于"1359-4" |
| | | if (task.SourceAddress != "1359-4") |
| | | //if (task.SourceAddress != "1359-4" && task.SourceAddress != "1357-4") |
| | | if (!valueList.Contains(task.SourceAddress)) |
| | | { |
| | | // 查询从源地址到目标地址的路由 |
| | | List<Dt_Router> routers = _routerService.QueryNextRoutes(item.SourceAddress, item.TargetAddress); |
| | |
| | | } |
| | | else |
| | | { |
| | | // 设置当前地址为"002-021-001" |
| | | task.CurrentAddress = "002-021-001"; |
| | | task.CurrentAddress = string.Empty; |
| | | if (task.SourceAddress == "1325-6") |
| | | // 设置当前地址为"001-021-001" |
| | | task.CurrentAddress = "001-021-001"; |
| | | else |
| | | // 设置当前地址为"002-021-001" |
| | | task.CurrentAddress = "002-021-001"; |
| | | // 设置下一个地址为目标地址 |
| | | task.NextAddress = item.TargetAddress; |
| | | } |
| | |
| | | } |
| | | return wcsBasez + address; |
| | | } |
| | | #region 重写方法 |
| | | |
| | | public override WebResponseContent DeleteData(object[] key) |
| | | { |
| | | foreach (var item in key) |
| | | { |
| | | var task = BaseDal.QueryFirst(x => x.TaskId == Convert.ToInt32(item)); |
| | | var taskHty = task.Adapt<Dt_Task_Hty>(); |
| | | taskHty.Creater = App.User.UserName != null ? App.User.UserName : "System"; |
| | | _taskHtyRepository.AddData(taskHty); |
| | | } |
| | | return base.DeleteData(key); |
| | | } |
| | | |
| | | #endregion |
| | | } |
| | | } |