From 557f02072fa311eefe3123aa44afebac22adc465 Mon Sep 17 00:00:00 2001
From: xiaojiao <xiaojiao@kaokeziliao.com>
Date: 星期五, 24 四月 2026 17:24:43 +0800
Subject: [PATCH] 4-24
---
项目代码/WCS/WIDESEA_WCSServer/WIDESEA_WCS/Jobs/ConveyorLine/InboundArea/OutboundStationAction.cs | 46 +++++++++++++++++++++++++++++++++++++++++-----
1 files changed, 41 insertions(+), 5 deletions(-)
diff --git "a/\351\241\271\347\233\256\344\273\243\347\240\201/WCS/WIDESEA_WCSServer/WIDESEA_WCS/Jobs/ConveyorLine/InboundArea/OutboundStationAction.cs" "b/\351\241\271\347\233\256\344\273\243\347\240\201/WCS/WIDESEA_WCSServer/WIDESEA_WCS/Jobs/ConveyorLine/InboundArea/OutboundStationAction.cs"
index 546a8e1..db13faf 100644
--- "a/\351\241\271\347\233\256\344\273\243\347\240\201/WCS/WIDESEA_WCSServer/WIDESEA_WCS/Jobs/ConveyorLine/InboundArea/OutboundStationAction.cs"
+++ "b/\351\241\271\347\233\256\344\273\243\347\240\201/WCS/WIDESEA_WCSServer/WIDESEA_WCS/Jobs/ConveyorLine/InboundArea/OutboundStationAction.cs"
@@ -1,11 +1,14 @@
锘縰sing HslCommunication;
using System;
using System.Collections.Generic;
+using System.Linq;
using System.Text;
using System.Threading;
using WIDESEA_Common;
+using WIDESEA_Common.LogEnum;
using WIDESEA_Common.TaskEnum;
using WIDESEA_Common.Tools;
+using WIDESEA_Core.Extensions;
using WIDESEA_Core.Utilities;
using WIDESEA_Entity.DomainModels;
using WIDESEA_Services;
@@ -13,12 +16,15 @@
using WIDESEA_Services.Repositories;
using WIDESEA_Services.Services;
using WIDESEA_WCS.WCSClient;
+using static System.Collections.Specialized.BitVector32;
namespace WIDESEA_WCS.Jobs.ConveyorLine.InboundArea
{
public partial class InboundAreaDispatch
{
- public static string[] OutboundStationNo = new string[] { "50101", "50102", "50103", "50104", "50105", "50106", "50107", "50108" };
+ public static string[] OutboundStationNo = new string[] { "50101", "50102", "50103", "50104", "50105", "50106", "50107" };
+
+ //姝e父妯″紡涓嬬殑鍐呭
public static void OutboundStationAction(IDt_TaskWCSinfoRepository taskWCSinfoRepository, IDt_TaskRGVinfoRepository taskRGVinfoRepository, PLCClient client)
{
foreach (var item in OutboundStationNo)
@@ -30,6 +36,34 @@
}
}
+ // 鍐欎竴涓惊鐜� 褰撴墭鐩樻斁鍒板嚭搴撳尯鐨勫嚭搴撶紦瀛樻灦鐨勬椂鍊欙紝灏卞啓鍏ユ墭鐩樺彿鍜屼换鍔″彿
+ public static void Synchronizetraynumber(IDt_TaskWCSinfoRepository taskWCSinfoRepository, IDt_TaskRGVinfoRepository taskRGVinfoRepository, PLCClient client)
+ {
+ List<Dt_TaskWCSinfo> taskWCSinfo = taskWCSinfoRepository.Find(x =>
+ (x.wcstask_type == TaskType.TaskType_Empty_Pallet_Outbound.ToString() || x.wcstask_type == TaskType.TaskType_Box_Pallet_Outbound.ToString()
+ || x.wcstask_type == TaskType.TaskType_CheckOutbound.ToString())
+ && x.wcstask_state == TaskState.TaskState_RGV_Finished.ToString()
+ && x.wcstask_endPoint == 20101.ToString()).ToList();
+
+ foreach (var item in taskWCSinfo)
+ {
+ bool LoadSleep = bool.Parse(client.ReadValue(CLineInfoDBName.R_Line_LoadSleep.ToString(), item.wcstask_startPoint.ToString()).ToString());
+ int ReadNumber = int.Parse(client.ReadValue(CLineInfoDBName.R_Line_TaskNumber.ToString(), item.wcstask_startPoint.ToString()).ToString());
+ int ReadBarcode = int.Parse(client.ReadValue(CLineInfoDBName.R_Line_Barcode.ToString(), item.wcstask_startPoint.ToString()).ToString());
+ if (LoadSleep && ReadBarcode == 0)
+ {
+
+ //鍐欏叆鎵樼洏鏉$爜
+ bool writeTaskNumber = client.WriteValue(CLineInfoDBName.W_Line_TaskNumber.ToString(), item.wcstask_startPoint, item.wcstask_taskNumber);
+ bool writeBarcode = client.WriteValue(CLineInfoDBName.W_Line_Barcode.ToString(), item.wcstask_startPoint, item.wcstask_barcode);
+ string str = $"鍏ュ簱鍖哄煙鍑哄簱锛屽啓鍏ョ紦瀛樻灦瀛愬悓姝ユ墭鐩樺彿鍜屼换鍔″彿 {DateTime.Now} {item.ToJson()}";
+ LogRecord.WriteLog(LogEnum.OutBound, str.ToString());
+ }
+ }
+ }
+
+
+ //搴旀�ユā寮忎笅鐨勫唴瀹�
public static void OutboundStationAction_YJ(IDt_TaskWCSinfoRepository taskWCSinfoRepository, IDt_TaskRGVinfoRepository taskRGVinfoRepository,
PLCClient client, bool leftState)
{
@@ -76,6 +110,8 @@
(x.wcstask_type == TaskType.TaskType_Empty_Pallet_Outbound.ToString() || x.wcstask_type == TaskType.TaskType_Box_Pallet_Outbound.ToString()
|| x.wcstask_type == TaskType.TaskType_CheckOutbound.ToString()) &&
x.wcstask_state == TaskState.TaskState_RGV_Finished.ToString() && x.wcstask_startPoint.Contains(station));
+
+
if (null == taskWCSinfo)
{
ChangeLayerAction(taskWCSinfoRepository, taskRGVinfoRepository, client, station, yjState);
@@ -125,10 +161,10 @@
taskWCSinfo.wcstask_dispatcherTime = DateTime.Now;
taskWCSinfoRepository.Update(taskWCSinfo, true);
- str = $" { DateTime.Now }涓婃姤WMS鏇存柊浠诲姟鐘舵�佹垚鍔焮state}锛屾墭鐩樺彿:{taskWCSinfo.wcstask_barcode},浠诲姟鍙凤細{ taskWCSinfo.wcstask_taskNumber}";
+ str = $" {DateTime.Now}涓婃姤WMS鏇存柊浠诲姟鐘舵�佹垚鍔焮state}锛屾墭鐩樺彿:{taskWCSinfo.wcstask_barcode},浠诲姟鍙凤細{taskWCSinfo.wcstask_taskNumber}";
}
else
- str = $" { DateTime.Now }涓婃姤WMS鏇存柊浠诲姟鐘舵�佸け璐state}锛屾墭鐩樺彿:{taskWCSinfo.wcstask_barcode},浠诲姟鍙凤細{ taskWCSinfo.wcstask_taskNumber},鍘熷洜:{content.Message}";
+ str = $" {DateTime.Now}涓婃姤WMS鏇存柊浠诲姟鐘舵�佸け璐state}锛屾墭鐩樺彿:{taskWCSinfo.wcstask_barcode},浠诲姟鍙凤細{taskWCSinfo.wcstask_taskNumber},鍘熷洜:{content.Message}";
WriteLog.Info(station).Write(str, station);
@@ -137,7 +173,7 @@
}
catch (Exception ex)
{
- WriteLog.Info(station).Write($"{ DateTime.Now }鍑哄簱绔欏彴璋冨害澶辫触:{ex.Message}", station);
+ WriteLog.Info(station).Write($"{DateTime.Now}鍑哄簱绔欏彴璋冨害澶辫触:{ex.Message}", station);
}
}
@@ -200,7 +236,7 @@
}
catch (Exception ex)
{
- WriteLog.Info(station).Write($"{ DateTime.Now }绉诲簱鍑哄簱绔欏彴璋冨害澶辫触:{ex.Message}", station);
+ WriteLog.Info(station).Write($"{DateTime.Now}绉诲簱鍑哄簱绔欏彴璋冨害澶辫触:{ex.Message}", station);
}
}
}
--
Gitblit v1.9.3