| | |
| | | using WIDESEAWCS_QuartzJob.DTO; |
| | | using WIDESEAWCS_QuartzJob; |
| | | using WIDESEAWCS_Core; |
| | | using Newtonsoft.Json; |
| | | using WIDESEAWCS_Core.Helper; |
| | | using WIDESEAWCS_DTO.WMSInfo; |
| | | using WIDESEAWCS_Tasks.ShuttleCarJob; |
| | | |
| | | namespace WIDESEAWCS_Tasks |
| | | { |
| | | partial class CommonShuttleCarJob |
| | | { |
| | | private object _CarTaskObject = new object(); |
| | | #region å åæºç§»è½¦å®æ |
| | | /// <summary> |
| | | /// è·åå åæºç§»è½¦/ç§»åºå®æä»»å¡ |
| | | /// </summary> |
| | | public void GetSC_CarFinish() |
| | | { |
| | | Dt_Task dt_Task = GetTask(TaskCarStatusEnum.SC_CarFinish.ObjToInt(), TaskOtherTypeEnum.RelocationCar.ObjToInt());//ç§»è½¦ä»»å¡ |
| | | if (dt_Task != null) |
| | | { |
| | | UpdateShuttleCar(dt_Task.ShuttleCarCode, dt_Task.CurrentAddress); |
| | | _taskService.AddTask_Hty(dt_Task, TaskOperateTypeEnum.AutoComplete); |
| | | } |
| | | dt_Task = GetTask(CarChargingTaskEnum.SC_CarFinish.ObjToInt(), TaskOtherTypeEnum.RelocationCarCharging.ObjToInt());//移车å
çµä»»å¡ |
| | | if (dt_Task != null) |
| | | { |
| | | UpdateShuttleCar(dt_Task.ShuttleCarCode, dt_Task.CurrentAddress); |
| | | SendTask(dt_Task);//ä¸åå
çµä»»å¡ |
| | | } |
| | | dt_Task = GetTask(TaskRelocationStatusEnum.SC_RelocationFinish.ObjToInt(), TaskRelocationTypeEnum.Relocation.ObjToInt());//ç§»åºä»»å¡ |
| | | if (dt_Task != null) |
| | | SendTask(dt_Task); |
| | | } |
| | | #endregion |
| | | /// <summary> |
| | | /// ä¿®æ¹ç©¿æ¢è½¦ä½ç½®ä¿¡å· |
| | | /// </summary> |
| | | /// <param name="ShuttleCarCode">ç©¿æ¢è½¦å·</param> |
| | | /// <param name="Address">ä½ç½®</param> |
| | | public void UpdateShuttleCar(string ShuttleCarCode, string Address) |
| | | { |
| | | var ShuttleCar = QueryCode(ShuttleCarCode); |
| | | string[] targetCodes = Address.Split("-"); |
| | | var Row = Convert.ToInt16(targetCodes[0]); |
| | | if (Row == 3) |
| | | { |
| | | ShuttleCar.ShuttleCarPosition = Address; |
| | | ShuttleCar.ShuttleCarPosition1 = Address; |
| | | } |
| | | else |
| | | { |
| | | var a = Row == 1 ? 2.ToString("000") : 1.ToString("000"); |
| | | ShuttleCar.ShuttleCarPosition = Address; |
| | | ShuttleCar.ShuttleCarPosition1 = a + "-" + targetCodes[1] + "-" + targetCodes[2]; |
| | | } |
| | | _shuttleCarService.UpdateData(ShuttleCar); |
| | | } |
| | | #region è·åç§»è½¦ä»»å¡ |
| | | /// <summary> |
| | | /// è·å移车任å¡/åºå
¥åºä»»å¡ |
| | | /// </summary> |
| | | public void Get_CarTask(ShuttleCar shuttleCar, ShuttleCarTaskCommandR command) |
| | | { |
| | | lock (_CarTaskObject) |
| | | { |
| | | #region è·åæ°å»ºç§»è½¦ä»»å¡ |
| | | Dt_Task dt_Task = GetTask((int)TaskCarStatusEnum.CarNew, (int)TaskOtherTypeEnum.RelocationCar); |
| | | if (dt_Task != null) |
| | | { |
| | | if (string.IsNullOrEmpty(dt_Task.SourceAddress)) |
| | | { |
| | | (bool, Dt_ShuttleCar) result = GetSourceTask(shuttleCar, command); |
| | | if (result.Item1) |
| | | UpdateSource(ref dt_Task, result.Item2); |
| | | else |
| | | GetShuttleCar(ref dt_Task, shuttleCar);//è·åå¦å¤ä¸ä¸ªç©¿æ¢è½¦ä¿¡æ¯ |
| | | } |
| | | else if (string.IsNullOrEmpty(dt_Task.TargetAddress)) |
| | | { |
| | | #region åWMSç³è¯· |
| | | WebResponseContent content = new WebResponseContent(); |
| | | var ResultData = HttpHelper.PostAsync(WMSInterfaceAddress.GetPosition + $"?position={dt_Task.SourceAddress}", "", headers: new Dictionary<string, string>()); |
| | | if (ResultData.Result != null) |
| | | { |
| | | content = JsonConvert.DeserializeObject<WebResponseContent>(ResultData.Result); |
| | | if (content != null && content.Status) |
| | | { |
| | | dt_Task.TargetAddress = content.Message; |
| | | dt_Task.NextAddress = dt_Task.TargetAddress; |
| | | _taskService.UpdateData(dt_Task); |
| | | _taskExecuteDetailService.AddTaskExecuteDetail(dt_Task.TaskNum, "æ´æ°ç§»è½¦ä»»å¡ç®æ å°å"); |
| | | } |
| | | } |
| | | #endregion |
| | | } |
| | | //ç©¿æ¢è½¦ç§»è½¦ä»»å¡ä¸å |
| | | if (!string.IsNullOrEmpty(dt_Task.SourceAddress) && !string.IsNullOrEmpty(dt_Task.TargetAddress) && !string.IsNullOrEmpty(dt_Task.ShuttleCarCode)) |
| | | { |
| | | SendTask(dt_Task); |
| | | } |
| | | } |
| | | #endregion |
| | | |
| | | #region ç©¿æ¢è½¦ä»»å¡ |
| | | else |
| | | { |
| | | var task = _taskService.ShuttleCarRelocationTask(shuttleCar.DeviceCode);//è·åç©¿æ¢è½¦ç§»åºä»»å¡ |
| | | if (task != null) |
| | | { |
| | | if (!task.SourceIsPickPlace) |
| | | SendTask(task); |
| | | } |
| | | else |
| | | { |
| | | task = _taskService.QueryShuttleCarTask(shuttleCar.DeviceCode); |
| | | if (task != null) |
| | | { |
| | | if (task.TaskType == (int)TaskOutboundTypeEnum.Outbound && !task.SourceIsPickPlace) |
| | | { |
| | | var ShuttleCar = _shuttleCarService.QueryShuttleCar(task.SourceAddress);//åºåºä»»å¡å¤æèµ·ç¹æ¯å¦æç©¿æ¢è½¦ |
| | | if (ShuttleCar != null) SendTask(task); |
| | | else _taskService.AddRelocationCarTask("", task.SourceAddress); |
| | | } |
| | | else |
| | | SendTask(task); |
| | | } |
| | | } |
| | | } |
| | | #endregion |
| | | } |
| | | } |
| | | #endregion |
| | | |
| | | #region æ´æ°ç§»è½¦ä»»å¡èµ·å§å°å |
| | | /// <summary> |
| | | /// æ´æ°ç§»è½¦ä»»å¡èµ·å§å°å |
| | | /// </summary> |
| | | /// <param name="dt_Task"></param> |
| | | /// <param name="shuttleCar"></param> |
| | | /// <param name="command"></param> |
| | | public void UpdateSource(ref Dt_Task dt_Task, Dt_ShuttleCar _ShuttleCar) |
| | | { |
| | | dt_Task.SourceAddress = _ShuttleCar.ShuttleCarPosition; |
| | | dt_Task.CurrentAddress = dt_Task.SourceAddress; |
| | | dt_Task.ShuttleCarCode = _ShuttleCar.ShuttleCarCode; |
| | | _taskService.UpdateData(dt_Task); |
| | | _taskExecuteDetailService.AddTaskExecuteDetail(dt_Task.TaskNum, "æ´æ°ç§»è½¦ä»»å¡èµ·å§å°å"); |
| | | } |
| | | #endregion |
| | | /// <summary> |
| | | /// 夿å½åç©¿æ¢è½¦æ¯å¦å¯ä»¥æ§è¡ç§»åº |
| | | /// </summary> |
| | | /// <param name="shuttleCar"></param> |
| | | /// <param name="command"></param> |
| | | /// <returns></returns> |
| | | public (bool, Dt_ShuttleCar) GetSourceTask(ShuttleCar shuttleCar, ShuttleCarTaskCommandR command) |
| | | { |
| | | Dt_ShuttleCar _ShuttleCar = QueryCode(shuttleCar.DeviceCode); |
| | | bool ok = false; |
| | | if (command.Status == (short)ShuttleCarStatus.Standby && command.TaskTypeComplete == (short)ShuttleCarTaskComplete.Standby && command.Err_Status == (short)ShuttleCarErr.Normal) |
| | | { |
| | | #region 夿å½åç©¿æ¢è½¦æ¯å¦åå¨ä»»å¡ |
| | | Dt_Task? _Task = _taskRepository.QueryFirst(x => |
| | | x.SourceAddress == _ShuttleCar.ShuttleCarPosition || |
| | | x.TargetAddress == _ShuttleCar.ShuttleCarPosition || |
| | | x.SourceAddress == _ShuttleCar.ShuttleCarPosition1 || |
| | | x.TargetAddress == _ShuttleCar.ShuttleCarPosition1); |
| | | #endregion |
| | | ok = _Task == null; |
| | | } |
| | | if (!ok) |
| | | { |
| | | if (command.Status == (short)ShuttleCarStatus.Charging && command.ElectricQuantity >= 50)//éåºå
çµ |
| | | { |
| | | ok = shuttleCar.SetValue(ShuttleCarDBName.TaskType, (short)ShuttleCarStatus.QuitCharging); |
| | | } |
| | | } |
| | | return (ok, _ShuttleCar); |
| | | } |
| | | |
| | | /// <summary> |
| | | /// è·åå¦å¤ä¸ä¸ªç©¿æ¢è½¦ä¿¡æ¯ |
| | | /// </summary> |
| | | public void GetShuttleCar(ref Dt_Task dt_Task, ShuttleCar shuttleCar) |
| | | { |
| | | Dt_ShuttleCar _ShuttleCar = _shuttleCarService.QueryNoCode(shuttleCar.DeviceCode); |
| | | ShuttleCar shuttleCar1 = Storage.Devices.Where(x => x.DeviceCode.Equals(_ShuttleCar.ShuttleCarCode)).FirstOrDefault() as ShuttleCar; |
| | | ShuttleCarTaskCommandR command = ReadCustomer<ShuttleCarTaskCommandR>(shuttleCar1, shuttleCar1.DeviceCode);//读åç©¿æ¢è½¦ä¿¡æ¯ |
| | | (bool, Dt_ShuttleCar) result = GetSourceTask(shuttleCar1, command); |
| | | if (result.Item1) UpdateSource(ref dt_Task, result.Item2); |
| | | } |
| | | |
| | | #region ä¸åç©¿æ¢è½¦ä»»å¡ |
| | | /// <summary> |
| | | /// ä¸åç©¿æ¢è½¦ä»»å¡ |
| | | /// </summary> |
| | | /// <param name="task"></param> |
| | | private void SendTask(Dt_Task task) |
| | | { |
| | | ShuttleCar shuttleCar = Storage.Devices.FirstOrDefault(x => x.DeviceCode == task.ShuttleCarCode) as ShuttleCar; |
| | | if (shuttleCar != null) |
| | | { |
| | | ShuttleCarTaskCommandR command = ReadCustomer<ShuttleCarTaskCommandR>(shuttleCar, shuttleCar.DeviceCode);//读åç©¿æ¢è½¦ä¿¡æ¯ |
| | | if (command != null && command.Status == (short)ShuttleCarStatus.Standby && command.TaskTypeComplete == (short)ShuttleCarTaskComplete.Standby && command.Err_Status == (short)ShuttleCarErr.Normal) |
| | | { |
| | | #region 夿å°è½¦ä½ç½®æ ABé¢ä¸ä¸åä»»å¡ |
| | | short Position = 0; |
| | | if (shuttleCar.GetValue<ShuttleCarDBName, bool>(ShuttleCarDBName.DirectionA)) Position = 1; |
| | | if (shuttleCar.GetValue<ShuttleCarDBName, bool>(ShuttleCarDBName.DirectionB)) Position = 2; |
| | | if (Position != 1 && Position != 2) |
| | | { |
| | | var Message = $"{shuttleCar.DeviceName}æ ABé¢"; |
| | | if (task.ExceptionMessage != Message) |
| | | _taskService.UpdateData(task); |
| | | return; |
| | | } |
| | | #endregion |
| | | //ä»»å¡è½¬æ¢ |
| | | shuttleCar.SetValue(ShuttleCarDBName.Direction, Position);//åå
¥è½¦ä½æ¹å |
| | | ShuttleCarTaskCommandW shuttleCarTaskCommand = new ShuttleCarTaskCommandW(); |
| | | shuttleCarTaskCommand.Direction = Position; |
| | | shuttleCarTaskCommand.TaskNum = task.TaskNum; |
| | | if (task.TaskType == (int)TaskOtherTypeEnum.RelocationCar)//移车 |
| | | { |
| | | if (task.TaskState == (int)TaskCarStatusEnum.CarNew) |
| | | { |
| | | //if (task.Remark == ShuttleCarTaskType.ExitCharge.ToString()) shuttleCarTaskCommand.TaskType = (short)GetCarTaskType(task.Remark); |
| | | //else |
| | | shuttleCarTaskCommand.TaskType = (short)GetCarTaskType(task.TaskType, shuttleCarTaskCommand.Direction); |
| | | } |
| | | else if (task.TaskState == (int)TaskCarStatusEnum.SC_CarFinish) |
| | | { |
| | | if (task.Remark == ShuttleCarTaskType.Charging.ToString()) shuttleCarTaskCommand.TaskType = (short)GetCarTaskType(task.Remark); |
| | | //else |
| | | // shuttleCarTaskCommand.TaskType = (short)GetCarTaskType(task.TaskType, shuttleCarTaskCommand.Direction); |
| | | } |
| | | } |
| | | else |
| | | shuttleCarTaskCommand.TaskType = (short)GetCarTaskType(task.TaskType, shuttleCarTaskCommand.Direction); |
| | | //shuttleCarTaskCommand.TaskType = string.IsNullOrEmpty(task.Remark) ? (short)GetCarTaskType(task.TaskType, shuttleCarTaskCommand.Direction) : (short)GetCarTaskType(task.Remark); |
| | | //ä»»å¡ä¸å |
| | | if (shuttleCarTaskCommand.TaskType != null)//0 |
| | | { |
| | | if (shuttleCar.SendCommand(shuttleCarTaskCommand, shuttleCar.DeviceCode)) |
| | | { |
| | | if (!string.IsNullOrEmpty(task.Remark)) task.Remark = task.Remark + "å·²ä¸å"; |
| | | task.TaskState = GetTaskState(task.TaskType); |
| | | _taskService.UpdateData(task); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | } |
| | | #endregion |
| | | |
| | | |
| | | /// <summary> |
| | | /// æ ¹æ®ä»»å¡ç¶æãç±»åè·åä»»å¡ |
| | | /// </summary> |
| | |
| | | taskType = ShuttleCarTaskType.Out; |
| | | break; |
| | | case (int)TaskOtherTypeEnum.RelocationCar: |
| | | case (int)TaskOtherTypeEnum.RelocationCarCharging: |
| | | taskType = Direction == 1 ? ShuttleCarTaskType.ZeroA : ShuttleCarTaskType.ZeroB; |
| | | break; |
| | | default: |