From 46e98339480d853fc78a014c34d7ff9fcaf13890 Mon Sep 17 00:00:00 2001
From: dengjunjie <dengjunjie@hnkhzn.com>
Date: 星期四, 05 十二月 2024 14:09:02 +0800
Subject: [PATCH] 产线协议
---
项目代码/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/PartialTaskService_Line.cs | 58 ++++++++++++++++++++++++++--------------------------------
1 files changed, 26 insertions(+), 32 deletions(-)
diff --git "a/\351\241\271\347\233\256\344\273\243\347\240\201/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/PartialTaskService_Line.cs" "b/\351\241\271\347\233\256\344\273\243\347\240\201/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/PartialTaskService_Line.cs"
index 34617b2..c5fa9ab 100644
--- "a/\351\241\271\347\233\256\344\273\243\347\240\201/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/PartialTaskService_Line.cs"
+++ "b/\351\241\271\347\233\256\344\273\243\347\240\201/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/PartialTaskService_Line.cs"
@@ -24,44 +24,38 @@
public WebResponseContent RequestWMSTask(ConveyorLineDTO lineDTO)
{
WebResponseContent content = new WebResponseContent();
- try
+
+ #region 鍚慦MS鐢宠
+ var ResultData = HttpHelper.PostAsync(WMSInterfaceAddress.ConveyorLineRequestInbound, lineDTO.ToJson(), headers: new Dictionary<string, string>());
+ if (ResultData.Result == null) throw new Exception($"鍚慦MS璇锋眰鍏ュ簱瓒呮椂");
+
+ content = JsonConvert.DeserializeObject<WebResponseContent>(ResultData.Result);
+
+ #endregion
+
+ #region 浜х嚎鐢宠鍏ュ簱浠诲姟
+ if (content != null && content.Status)//浠诲姟杞崲
{
- #region 鍚慦MS鐢宠
- var ResultData = HttpHelper.PostAsync(WMSInterfaceAddress.ConveyorLineRequestInbound, lineDTO.ToJson(), headers: new Dictionary<string, string>());
- if (ResultData.Result == null) throw new Exception($"鍚慦MS璇锋眰鍏ュ簱瓒呮椂");
-
- content = JsonConvert.DeserializeObject<WebResponseContent>(ResultData.Result);
-
- #endregion
-
- #region 浜х嚎鐢宠鍏ュ簱浠诲姟
- if (content != null && content.Status)//浠诲姟杞崲
+ var task = JsonConvert.DeserializeObject<Dt_Task>(content.Data.ToJson());
+ if (task != null)
{
- var task = JsonConvert.DeserializeObject<Dt_Task>(content.Data.ToJson());
- if (task != null)
+ List<int> TaskNums = new List<int>();
+ List<Dt_Router> routers = _routerService.QueryNextRoutes(task.CurrentAddress, task.TargetAddress);
+ if (routers.Count > 0)
{
- List<int> TaskNums = new List<int>();
- List<Dt_Router> routers = _routerService.QueryNextRoutes(task.CurrentAddress, task.TargetAddress);
- if (routers.Count > 0)
- {
- task.NextAddress = routers.FirstOrDefault().ChildPosi;
- }
- task.WMSId = task.TaskId;
- task.Creater = "WMS";
- task.Dispatchertime = null;
- task.CreateDate = DateTime.Now;
- BaseDal.AddData(task);
- TaskNums.Add(task.TaskNum);
- _taskExecuteDetailService.AddTaskExecuteDetail(TaskNums, "鎺ユ敹WMS浠诲姟");
+ task.NextAddress = routers.FirstOrDefault().ChildPosi;
}
+ task.WMSId = task.TaskId;
+ task.Creater = "WMS";
+ task.Dispatchertime = null;
+ task.CreateDate = DateTime.Now;
+ BaseDal.AddData(task);
+ TaskNums.Add(task.TaskNum);
+ _taskExecuteDetailService.AddTaskExecuteDetail(TaskNums, "鎺ユ敹WMS浠诲姟");
}
- #endregion
+ }
+ #endregion
- }
- catch (Exception ex)
- {
- content = WebResponseContent.Instance.Error(ex.Message);
- }
return content;
}
--
Gitblit v1.9.3