From 0875bfa35d389e238ae82142ce45b71c9715133b Mon Sep 17 00:00:00 2001
From: yanjinhui <3306209981@qq.com>
Date: 星期五, 17 四月 2026 17:37:39 +0800
Subject: [PATCH] Merge branch 'master' of http://115.159.85.185:8098/r/RuiShengZhiNeng/GaoPuLiTiKu
---
代码管理/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/TaskMethods.cs | 31 ++++++++-------
代码管理/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/Task/RGVTaskExtend.cs | 64 +++++++++++++++++++++++++-------
代码管理/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/TestExtend.cs | 7 +++
代码管理/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/TaskService.cs | 2
4 files changed, 75 insertions(+), 29 deletions(-)
diff --git "a/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/TaskMethods.cs" "b/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/TaskMethods.cs"
index 7f50277..6d7749c 100644
--- "a/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/TaskMethods.cs"
+++ "b/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/TaskMethods.cs"
@@ -168,7 +168,7 @@
task.ExceptionMessage = $"銆恵task.SourceAddress}銆戝啓鍏�3妤煎嚭搴撶鏀惧埌浣嶅け璐ex.Message}";
task.Remark = $"{device.DeviceCode}_Outboundboxon_{1}_{task.SourceAddress}"; throw;
}
-
+
}
BaseDal.UpdateData(task);
}
@@ -204,7 +204,7 @@
task.ExceptionMessage = $"銆恵task.TargetAddress}銆戝啓鍏�4妤肩┖绠辨斁鍒颁綅澶辫触{ex.Message}";
task.Remark = $"{device.DeviceCode}_Emptyboxplacedinposition_{1}_{task.TargetAddress}";
}
-
+
}
BaseDal.UpdateData(task);
}
@@ -240,7 +240,7 @@
task.ExceptionMessage = $"銆恵task.SourceAddress}銆戝啓鍏�4妤煎嚭搴撳彇绠卞畬鎴愬け璐ex.Message}";
task.Remark = $"{device.DeviceCode}_Outboundboxretrievalcompleted_{1}_{task.SourceAddress}";
}
-
+
}
BaseDal.UpdateData(task);
}
@@ -277,7 +277,7 @@
task.ExceptionMessage = $"銆恵Address}銆戝叧闂姹傝繘鍏ュけ璐ワ紒{ex.Message}";
task.Remark = $"{device.DeviceCode}_RequestToEnter_{false}_{Address}";
}
-
+
}
BaseDal.UpdateData(task);
}
@@ -321,7 +321,7 @@
task.ExceptionMessage = $"銆怲SJR3F銆�3妤艰鐮佽Е鍙戝け璐ワ紒{ex.Message}";
task.Remark = $"{device.DeviceCode}_Codereadingtriggered_{1}_TSJR3F";
}
-
+
}
task.TaskState = (int)TaskStatusEnum.CheckPalletCodeing;
BaseDal.UpdateData(task);
@@ -378,7 +378,7 @@
var task = BaseDal.QueryFirst(x => x.PalletCode == Rgv.content.podID);
if (task == null) throw new Exception($"鏈壘鍒颁换鍔�,浠诲姟缂栧彿銆恵Rgv.content.taskID}銆�");
//绉诲簱
- if (task.TaskType == TaskTypeEnum.CPMoveInventory.ObjToInt())
+ if (task.TaskType == TaskTypeEnum.CPMoveInventory.ObjToInt() && string.IsNullOrEmpty(task.WMSTaskNum))
{
if (Rgv.messageType == 72)
{
@@ -422,15 +422,18 @@
if (task.TaskType == (int)TaskTypeEnum.CPInbound && task.TaskState == (int)TaskStatusEnum.Execut)
{
task.TaskState = (int)TaskStatusEnum.WaiCheckShape;
- //BaseDal.UpdateData(task);//缁欒川妫�闂ㄥ啓鍏ュ惎鍔ㄤ俊鍙�
- var device = Storage.Devices.FirstOrDefault(x => x.DeviceCode == "F1") as OtherDevice;
- if (device == null) task.ExceptionMessage = "鏈壘鍒�1妤艰川妫�闂ㄨ澶囦俊鎭�";
- else
+ if (task.SourceAddress != "OUT-01")
{
- if (device.IsConnected)
- device.SetValue(QualityInspectionCommandEnum.StartqualityInspection, true, task.SourceAddress);
+ //BaseDal.UpdateData(task);//缁欒川妫�闂ㄥ啓鍏ュ惎鍔ㄤ俊鍙�
+ var device = Storage.Devices.FirstOrDefault(x => x.DeviceCode == "F1") as OtherDevice;
+ if (device == null) task.ExceptionMessage = "鏈壘鍒�1妤艰川妫�闂ㄨ澶囦俊鎭�";
else
- task.ExceptionMessage = "1妤艰川妫�闂ㄨ澶囪繛鎺ュけ璐�";
+ {
+ if (device.IsConnected)
+ device.SetValue(QualityInspectionCommandEnum.StartqualityInspection, true, task.SourceAddress);
+ else
+ task.ExceptionMessage = "1妤艰川妫�闂ㄨ澶囪繛鎺ュけ璐�";
+ }
}
TaskFeedback(task, 4);
}
@@ -687,7 +690,7 @@
{
if (locationStatusEnum == LocationStatusEnum.Free) //濡傛灉璧风偣瀹屾垚灏辩粰璐т綅璧嬪�兼墭鐩樺彿
{
- stationManger.Remark ="";
+ stationManger.Remark = "";
stationManger.IsOccupied = LocationStatusEnum.Free.ObjToInt();
}
else
diff --git "a/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/TaskService.cs" "b/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/TaskService.cs"
index b039aac..35f50a3 100644
--- "a/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/TaskService.cs"
+++ "b/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/TaskService.cs"
@@ -1406,6 +1406,7 @@
{
stationManger.IsOccupied = LocationStatusEnum.Free.ObjToInt();
stationManger.Remark = "";
+ _stationMangerService.UpdateData(stationManger);
FOURBOToccupyStation fOURBOToccupyStation = new FOURBOToccupyStation()
{
stationCode = wMSContainerFlow.slotCode,
@@ -1414,7 +1415,6 @@
FOURBOTReturn fOURBOTReturn = response.DeserializeObject<FOURBOTReturn>();
content.OK(data: fOURBOTReturn);
if (fOURBOTReturn.returnCode != 0) throw new Exception(fOURBOTReturn.returnUserMsg);
- _stationMangerService.UpdateData(stationManger);
}
return content.OK();
}
diff --git "a/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/Task/RGVTaskExtend.cs" "b/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/Task/RGVTaskExtend.cs"
index aff1ab6..9c6fff4 100644
--- "a/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/Task/RGVTaskExtend.cs"
+++ "b/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/Task/RGVTaskExtend.cs"
@@ -4,6 +4,7 @@
using System.Collections;
using System.Collections.Generic;
using System.Linq;
+using System.Net.NetworkInformation;
using System.Text;
using System.Threading.Tasks;
using WIDESEAWCS_Common;
@@ -164,7 +165,7 @@
WebResponseContent content = new WebResponseContent();
try
{
- List<Dt_Task> dt_Tasks = new List<Dt_Task>();
+ //List<Dt_Task> dt_Tasks = new List<Dt_Task>();
var PalletCodes = tasks.Select(x => x.PalletCode).ToList();
var request = new GetBlockPodContentListDto
{
@@ -221,34 +222,69 @@
_taskService.UpdateData(tasks);
return;
}
- foreach (var Result in getBlockPod.Result)
+ #region 鍒ゆ柇鏄惁闇�瑕佺Щ搴�
+ foreach (var task in tasks)
{
- foreach (var item in Result.outPods)
+ var item = getBlockPod.Result[0].outPods.FirstOrDefault(x => x.outPod == task.PalletCode);
+ if (item != null)
{
- var task = tasks.First(x => x.PalletCode == item.outPod);
if (item.blockPods != null && item.blockPods.Count > 0)
item.blockPods = item.blockPods.Except(PalletCodes).ToList();
if (item.blockPods != null && item.blockPods.Count > 0)
{
- #region 鍒ゆ柇闃荤鎵樻槸鍚︿负鍑哄簱浠诲姟
- //var except = item.blockPods.Except(PalletCodes).ToList();
- #endregion
var responseContent = AddMoveTask(item.blockPods, task);//娣诲姞绉诲簱浠诲姟
if (!responseContent.Status) task.ExceptionMessage = responseContent.Message;
- else
- {
- task.TaskState = (int)TaskStatusEnum.RGV_WaitMoveToExecute;
- }
- dt_Tasks.Add(task);
+ else task.TaskState = (int)TaskStatusEnum.RGV_WaitMoveToExecute;
+ #region 绉诲簱鐘舵�佸弽棣堢粰WMS
+ WMSInOutBoundCompleteFeedback boundCompleteFeedback = new WMSInOutBoundCompleteFeedback();
+ boundCompleteFeedback.taskCode = task.WMSTaskNum;
+ boundCompleteFeedback.containerCode = task.PalletCode;
+ boundCompleteFeedback.fromStationCode = task.SourceAddress;
+ boundCompleteFeedback.toLocationCode = task.TargetAddress;
+ boundCompleteFeedback.status = 5;
+ boundCompleteFeedback.custStatus = "";
+ _apiInfoService.PostInterfaceRequest(nameof(WMSInOutBoundCompleteFeedback), boundCompleteFeedback.Serialize(), "鎴愬搧鍑哄簱浠诲姟绛夊緟绉诲簱涓婃姤WMS");
+ #endregion
}
else
{
task.TaskState = (int)TaskStatusEnum.RGV_WaitSend;
- dt_Tasks.Add(task);
}
}
+ else task.ExceptionMessage = $"RCS鏈弽棣堛�恵task.PalletCode}銆戝彲鍑哄簱鎵樼洏淇℃伅,璇︽儏璇锋煡鐪嬫壒閲忚幏鍙栭樆纰嶆墭鐩樺叧绯绘帴鍙ｆ棩蹇楋紒";
}
- _taskService.UpdateData(dt_Tasks);
+ _taskService.Repository.UpdateData(tasks);
+ #endregion
+ #region MyRegion
+ //foreach (var Result in getBlockPod.Result)
+ //{
+ // foreach (var item in Result.outPods)
+ // {
+ // var task = tasks.First(x => x.PalletCode == item.outPod);
+ // if (item.blockPods != null && item.blockPods.Count > 0)
+ // item.blockPods = item.blockPods.Except(PalletCodes).ToList();
+ // if (item.blockPods != null && item.blockPods.Count > 0)
+ // {
+ // #region 鍒ゆ柇闃荤鎵樻槸鍚︿负鍑哄簱浠诲姟
+ // //var except = item.blockPods.Except(PalletCodes).ToList();
+ // #endregion
+ // var responseContent = AddMoveTask(item.blockPods, task);//娣诲姞绉诲簱浠诲姟
+ // if (!responseContent.Status) task.ExceptionMessage = responseContent.Message;
+ // else
+ // {
+ // task.TaskState = (int)TaskStatusEnum.RGV_WaitMoveToExecute;
+ // }
+ // dt_Tasks.Add(task);
+ // }
+ // else
+ // {
+ // task.TaskState = (int)TaskStatusEnum.RGV_WaitSend;
+ // dt_Tasks.Add(task);
+ // }
+ // }
+ //}
+ //_taskService.UpdateData(dt_Tasks);
+ #endregion
content.OK();
}
}
diff --git "a/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/TestExtend.cs" "b/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/TestExtend.cs"
index 8a46ed1..c5af701 100644
--- "a/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/TestExtend.cs"
+++ "b/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/TestExtend.cs"
@@ -26,6 +26,13 @@
//浠诲姟鐨勭洰鏍囧湴鍧�瀵逛簬绔欏彴鍙凤紱
foreach (var task in taskList)
{
+ if (task.SourceAddress == "OUT-01")
+ {
+ task.TaskState = TaskStatusEnum.CheckShapeingOk.ObjToInt();
+ task.ExceptionMessage = "";
+ Uptasks.Add(task);
+ continue;
+ }
if (device.GetValue<QualityInspectionCommandEnum, bool>(QualityInspectionCommandEnum.R_QualityInspection, task.SourceAddress))
{
device.SetValue(QualityInspectionCommandEnum.StartqualityInspection, false, task.SourceAddress);
--
Gitblit v1.9.3