| | |
| | | try |
| | | { |
| | | Dt_ApiInfo? apiInfo = _apiInfoService.Repository.QueryFirst(x => x.ApiCode == nameof(FOURBOTnewMovePodTask)) ?? throw new Exception("æªæ¾å°åå车任å¡ä¸åæ¥å£é
置信æ¯ï¼è¯·æ£æ¥æ¥å£é
ç½®"); |
| | | int i = 0; |
| | | foreach (var task in tasks) |
| | | { |
| | | i++; |
| | | fOURBOTnewMovePodTask = new() |
| | | { |
| | | priority = task.Grade, |
| | |
| | | task.RGVTaskId = fOURBO.taskID; |
| | | task.ExceptionMessage = ""; |
| | | task.TaskState = (int)TaskStatusEnum.Execut; |
| | | task.Dispatchertime=DateTime.Now; |
| | | task.Dispatchertime = DateTime.Now; |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | task.ExceptionMessage = ex.Message; |
| | | content.Error(ex.Message); |
| | | } |
| | | finally |
| | | { |
| | | _trackloginfoService.AddTrackLog(fOURBOTnewMovePodTask, content, "ä¸ååå车æ°å»ºå
¥åºä»»å¡", "", ""); |
| | | } |
| | | } |
| | | var uptasks = tasks.Where(task => string.IsNullOrEmpty(task.ExceptionMessage)).ToList(); |
| | |
| | | { |
| | | foreach (var item in errortasks) |
| | | { |
| | | Thread.Sleep(500); |
| | | _taskService.ErrorTaskFeedback(item, true); |
| | | } |
| | | } |
| | |
| | | catch (Exception ex) |
| | | { |
| | | content.Error(ex.Message); |
| | | } |
| | | finally |
| | | { |
| | | _trackloginfoService.AddTrackLog(fOURBOTnewMovePodTask, content, "ä¸ååå车æ°å»ºå
¥åºä»»å¡", "", ""); |
| | | } |
| | | } |
| | | |
| | |
| | | }; |
| | | requestData = request; // ä¿åè¯·æ±æ°æ®ç¨äºæ¥å¿ |
| | | //content.candidatePodIDs = tasks.Select(x => x.PalletCode).ToList(); |
| | | string response = HttpHelper.Post(apiInfo.ApiAddress, request.Serialize()); |
| | | string response = HttpHelper.Post("http://127.0.0.1:4523/m2/6165241-5857331-default/440906899?apifoxApiId=440906899", request.Serialize()); |
| | | |
| | | //string response = HttpHelper.Post(apiInfo.ApiAddress, request.Serialize()); |
| | | FOURBOTReturn fOURBOTReturn = response.DeserializeObject<FOURBOTReturn>(); |
| | | content.OK(data: fOURBOTReturn); |
| | | if (fOURBOTReturn.returnCode == 0) |
| | |
| | | { |
| | | foreach (var item in tasks) |
| | | { |
| | | var takes = _taskService.Repository.QueryFirst(x => x.Roadway == item.Roadway && x.TaskType == (int)TaskTypeEnum.CPMoveInventory); |
| | | var takes = _taskService.Repository.QueryFirst(x => x.Roadway == item.Roadway && x.TaskType == (int)TaskTypeEnum.CPMoveInventory && (x.TaskState == (int)TaskStatusEnum.RGV_NewMoveTask || x.TaskState == (int)TaskStatusEnum.RGV_MoveTaskSend)); |
| | | if (takes == null) |
| | | { |
| | | item.TaskState = (int)TaskStatusEnum.RGV_WaitSend; |