From 4073bcc6e43f8f72945da396915f32d9d986967c Mon Sep 17 00:00:00 2001
From: yanjinhui <3306209981@qq.com>
Date: 星期三, 26 三月 2025 10:15:51 +0800
Subject: [PATCH] 11
---
项目代码/WIDESEAWCS_Server 正式/WIDESEAWCS_Tasks/SerialPort/SerialPortJob.cs | 303 ++++++++++++++++++++++++++++++++++++++++++-------
1 files changed, 256 insertions(+), 47 deletions(-)
diff --git "a/\351\241\271\347\233\256\344\273\243\347\240\201/WIDESEAWCS_Server \346\255\243\345\274\217/WIDESEAWCS_Tasks/SerialPort/SerialPortJob.cs" "b/\351\241\271\347\233\256\344\273\243\347\240\201/WIDESEAWCS_Server \346\255\243\345\274\217/WIDESEAWCS_Tasks/SerialPort/SerialPortJob.cs"
index d4f798f..cab0415 100644
--- "a/\351\241\271\347\233\256\344\273\243\347\240\201/WIDESEAWCS_Server \346\255\243\345\274\217/WIDESEAWCS_Tasks/SerialPort/SerialPortJob.cs"
+++ "b/\351\241\271\347\233\256\344\273\243\347\240\201/WIDESEAWCS_Server \346\255\243\345\274\217/WIDESEAWCS_Tasks/SerialPort/SerialPortJob.cs"
@@ -5,16 +5,28 @@
using System.Linq;
using System.Net.WebSockets;
using System.Text;
+using System.Text.RegularExpressions;
using System.Threading.Tasks;
+using AutoMapper;
using HslCommunication.WebSocket;
using Newtonsoft.Json;
+using Newtonsoft.Json.Linq;
+using OfficeOpenXml.FormulaParsing.Excel.Functions.Logical;
+using OfficeOpenXml.FormulaParsing.Excel.Functions.Math;
using Quartz;
using SqlSugar;
using StackExchange.Profiling.Internal;
using WIDESEA_ISerialPortRepository;
+using WIDESEA_SerialPortRepository;
+using WIDESEAWCS_Core;
+using WIDESEAWCS_Core.BaseRepository;
+using WIDESEAWCS_DTO.SerialPort;
+using WIDESEAWCS_ITaskInfoService;
using WIDESEAWCS_Model.Models;
using WIDESEAWCS_QuartzJob;
using WIDESEAWCS_QuartzJob.DTO;
+using WIDESEAWCS_TaskInfoService;
+using WIDESEAWCS_Tasks.SerialPort;
namespace WIDESEAWCS_Tasks
{
@@ -42,14 +54,21 @@
private readonly IPutakeRepository _putakeRepository;
private readonly IProcessRepository _processRepository;
private readonly ITorqueOpRepository _orqueOpRepository;
- private WebSocketServer _webSocketContext;
- public SerialPortJob(IPutakeRepository putakeRepository, IProcessRepository processRepository, ITorqueOpRepository torqueOpRepository, WebSocketServer webSocketContext)
+ private WebSocketServer _webSocketContext;
+ private readonly IProcessServer _processServer;
+ private readonly IPutakeServer _putakeServer;
+ private readonly ITorqueOpServer _torqueOpServer;
+
+ public SerialPortJob(ITorqueOpServer torqueOpServer,IPutakeServer putakeServer,IProcessServer processServer, IPutakeRepository putakeRepository, IProcessRepository processRepository, ITorqueOpRepository torqueOpRepository, WebSocketServer webSocketContext)
{
_putakeRepository = putakeRepository;
_processRepository = processRepository;
_orqueOpRepository = torqueOpRepository;
_webSocketContext = webSocketContext;
+ _processServer = processServer;
+ _putakeServer = putakeServer;
+ _torqueOpServer= torqueOpServer;
}
public Task Execute(IJobExecutionContext context)
@@ -59,7 +78,6 @@
SerialPortDevice serialPortDevice = (SerialPortDevice)context.JobDetail.JobDataMap.Get("JobParams");
if (serialPortDevice != null)
{
-
List<DeviceProDTO> deviceProDTOs = serialPortDevice.DeviceProDTOs;
foreach (var item in deviceProDTOs)
{
@@ -68,21 +86,13 @@
DeviceProtocolDetailDTO? deviceProtocolDetail = serialPortDevice.DeviceProtocolDetailDTOs.FirstOrDefault(x => x.DeviceProParamName == nameof(CommandType) && x.ProtocolDetailType == nameof(CommandType.Set));
if (deviceProtocolDetail != null)
{
- # region Setvalue
string group = item.DeviceProDataBlock;
- if (group == "鐢垫皵")
+
+ if (group == "鐢垫皵" || group == "鍦版矡" || group == "鏈烘")
{
- //鏌ョ湅姝ラ
- var com = item.DeviceChildCode + deviceProtocolDetail.ProtocalDetailValue.Replace("[setNum]", (5 * 1000).ToString().PadLeft(7, '0'))+"\r";
- serialPortDevice.Communicator.Write(com+"\r");
- //鎵撳紑涓插彛鏃跺厛璁惧��
-
-
+ ProcessElectricTask(group, serialPortDevice, item, deviceProtocolDetail);
}
- #endregion
- item.DeviceProParamName = CommandType.Set.ToString();
-
-
+ item.DeviceProParamName = CommandType.None.ToString();
}
}
@@ -93,37 +103,25 @@
if (deviceProtocolDetail != null)
{
serialPortDevice.Communicator.Write(item.DeviceChildCode + deviceProtocolDetail.ProtocalDetailValue, "\r");//鎵撳紑涓插彛鏃跺厛璁惧��
+
+ WriteDebug("鍐欏叆", item.DeviceChildCode + deviceProtocolDetail.ProtocalDetailValue);
}
}
- else if (CommandType.Set.ToString() == item.DeviceProParamName)
- {
- DeviceProtocolDetailDTO? deviceProtocolDetail = serialPortDevice.DeviceProtocolDetailDTOs.FirstOrDefault(x => x.DeviceProParamName == nameof(CommandType) && x.ProtocolDetailType == nameof(CommandType.Set));
- //璁惧��
- if (deviceProtocolDetail != null)
- {
- serialPortDevice.Communicator.Write(item.DeviceChildCode + deviceProtocolDetail.ProtocalDetailValue, "\r");//鎵撳紑涓插彛鏃跺厛璁惧��
- }
- }
-
-
if (serialPortDevice.Communicator.Buffers.Count > 0)
{
string? receiveData = serialPortDevice.Communicator.ToString(Encoding.Default);
if (!string.IsNullOrEmpty(receiveData))
{
- Console.WriteLine(DateTime.Now.ToString("HH:mm:ss.fff") + receiveData);
+ Console.WriteLine("serialPortDevice:" + DateTime.Now.ToString("HH:mm:ss.fff") + receiveData);
- if (item.DeviceProParamName == CommandType.Set.ToString())
+ if (item.DeviceProParamName == CommandType.Set.ToString() || item.DeviceProParamName == CommandType.None.ToString())
{
DeviceProtocolDetailDTO? deviceProtocolDetail = serialPortDevice.DeviceProtocolDetailDTOs.FirstOrDefault(x => x.DeviceProParamName == nameof(CommandResult) && x.ProtocolDetailType == nameof(CommandResult.SetOK));
//parseok
if (deviceProtocolDetail != null && receiveData.Contains(item.DeviceChildCode + deviceProtocolDetail.ProtocalDetailValue))
{
item.DeviceProParamName = CommandType.Get.ToString();
-
-
-
}
}
@@ -133,32 +131,30 @@
//03鎴愬姛
if (deviceProtocolDetail != null && receiveData.Contains(item.DeviceChildCode + deviceProtocolDetail.ProtocalDetailValue))
{
-
+ //鎶婅繖鏉℃暟鎹彃鍏p琛ㄤ腑
string group = item.DeviceProDataBlock; // 璁惧鎵�灞炵粍鍒�
- if (group == "鐢垫皵")
+ string devicecode = item.DeviceChildCode;//璁惧缂栧彿
+ string torqueValue = ExtractTorqueValue(receiveData);//璋冪敤杞�兼柟娉�
+ if (group == "鐢垫皵" || group == "鍦版矡" || group == "鏈烘")
{
-
- item.DeviceProParamName = CommandType.Set.ToString();
+ SaveTorqueOpData(group, devicecode, torqueValue);
+ item.DeviceProParamName = CommandType.None.ToString();
}
- else if (item.DeviceProParamName == CommandType.Get.ToString())
- {
- //DeviceProtocolDetailDTO? deviceProtocolDetail = serialPortDevice.DeviceProtocolDetailDTOs.FirstOrDefault(x => x.DeviceProParamName == nameof(CommandResult) && x.ProtocolDetailType == nameof(CommandResult.GetError));
- //if (deviceProtocolDetail != null && receiveData.Contains(item.DeviceChildCode + deviceProtocolDetail.ProtocalDetailValue))
- //{
- // item.DeviceProParamName = CommandType.Set.ToString();
+ }
-
- //}
- }
+ DeviceProtocolDetailDTO? deviceProtocolDetail2 = serialPortDevice.DeviceProtocolDetailDTOs.FirstOrDefault(x => x.DeviceProParamName == nameof(CommandResult) && x.ProtocolDetailType == nameof(CommandResult.GetError));
+ if (deviceProtocolDetail2 != null && receiveData.Contains(item.DeviceChildCode + deviceProtocolDetail2.ProtocalDetailValue))
+ {
+ item.DeviceProParamName = CommandType.None.ToString();
}
}
}
//寤轰竴涓璞″皢鍏朵紶缁欏墠绔�
- string data = JsonConvert.SerializeObject(serialPortDevice);//杩欓噷serialPortDevice鏄亣璁炬湁杩欎釜瀵硅薄
- _webSocketContext.PublishAllClientPayload(data);
+ //string data = JsonConvert.SerializeObject(serialPortDevice);//杩欓噷serialPortDevice鏄亣璁炬湁杩欎釜瀵硅薄
+ //_webSocketContext.PublishAllClientPayload(data);
}
}
@@ -171,8 +167,221 @@
WriteDebug("CommonConveyorLineJob", "test");
return Task.CompletedTask;
}
-
+
+ /// <summary>
+ /// 灏�0004000杞负4.0
+ /// 0004500杞负4.5
+ /// </summary>
+ /// <param name="data"></param>
+ /// <returns></returns>
+ private string ExtractTorqueValue(string data)
+ {
+ string[] parts = data.Split(','); // 鎸夐�楀彿鍒嗗壊鏁版嵁
+ if (parts.Length > 1) // 纭繚鑷冲皯鏈変袱涓儴鍒�
+ {
+ //杩斿洖鐨勬槸涓�涓被浼间簬82407024103,+0005433,0004500,1702485619
+ string targetValue = parts[1].TrimStart('+'); // 绉婚櫎鍓嶅 '+'
+ if (Regex.IsMatch(targetValue, @"^\d+$")) // 纭繚鏄函鏁板瓧
+ {
+ return (double.Parse(targetValue) / 1000.0).ToString("0.###"); // 闄や互 1000锛屼繚鐣欐渶澶� 3 浣嶅皬鏁�
+ }
+ }
+ return "0.000"; // 瑙ｆ瀽澶辫触杩斿洖 0.000
+ }
+
+
+ /// <summary>
+ /// 澶勭悊鐢垫皵浠诲姟閫昏緫锛屽彂閫佹壄鐭╂寚浠ゅ埌璁惧
+ /// </summary>
+ /// <param name="group">浠诲姟鍒嗙粍</param>
+ /// <param name="serialPortDevice">涓插彛璁惧</param>
+ /// <param name="item">璁惧淇℃伅</param>
+ /// <param name="deviceProtocolDetail">璁惧鍗忚璇︽儏</param>
+ private void ProcessElectricTask(string group, SerialPortDevice serialPortDevice, DeviceProDTO item, DeviceProtocolDetailDTO deviceProtocolDetail)
+ {
+ //1.鑾峰彇褰撳墠浠诲姟鍙� //IPutakeServer閲岄潰鐨勫緟鎵ц鐨勭涓�鏉′换鍔★紱
+ //var take = _putakeRepository.QueryData(x => x.Grouptype == group)
+ // .OrderBy(x => x.Dispatchtime)
+ // .FirstOrDefault();
+ var takeResponse = _putakeServer.PerformTasks(group);
+ if (takeResponse == null || !takeResponse.Status)
+ {
+ Console.WriteLine($"浠诲姟鍒嗙骇琛ㄦ帴鍙ｉ敊璇細{takeResponse?.Message}");
+ }
+
+ var take = JsonConvert.DeserializeObject<Dt_Putake>(JsonConvert.SerializeObject(takeResponse.Data)); // 纭繚杞崲姝ｇ‘
+ var takeid = take?.Njtakeid;//鎷垮埌浠诲姟鍙�
+
+ //2.璋冪敤Getcircuit鎷垮埌褰撳墠姝ラ
+ var process = _processServer.Getcircuit(group, takeid);
+
+ if (process != null && process.Status)
+ {
+ var list = JsonConvert.SerializeObject(process.Data);
+ var data = JsonConvert.DeserializeObject<ProcessData>(list);
+
+ if (data?.proNow != null)
+ {
+
+ int setpNum = data.proNow.SetpNum;
+ int sum = data.proNow.TorqueSum;
+ double torqueone = data.proNow.TorqueOne;
+ double torquetwo = data.proNow.TorqueTwo;
+
+ int onequantity = data.proNow.TorqueOneQuantity;
+ int towquantity = data.proNow.TorqueTwoQuantity;
+
+
+ //鍒ゆ柇op琛ㄤ腑杩欎釜鍊兼槸鍚︽湁璇ユ潯浠诲姟鐨勬暟鎹�
+ //var op = _orqueOpRepository.QueryData(x => x.TakeId == takeid && x.GroupOp == group && x.ProcessSte == setpNum);
+ // 3. 鏌ヨ鎵煩璁板綍
+ var opResponse = _torqueOpServer.WhetherSaveValueData(takeid, group, setpNum);
+ if (opResponse == null || !opResponse.Status || opResponse.Data == null)
+ {
+ Console.WriteLine($"WhetherSaveValueData鎺ュ彛閿欒锛歿opResponse?.Message}");
+ return;
+ }
+
+ var op = JsonConvert.DeserializeObject<List<Dt_TorqueOp>>(JsonConvert.SerializeObject(opResponse.Data)); // 纭繚杞崲姝ｇ‘
+
+
+ if (op.Any())//鍒ゆ柇鏄惁鏈夋暟鎹�
+ {
+ //鎵惧埌浜嗗氨瑕佸姣旂幇鍦╫p琛ㄤ腑鏈夊灏戞潯锛屾槸鍚﹀拰宸ヨ壓琛ㄤ腑鐨勭洰鏍囦竴鑷�
+
+ // 璁＄畻绗竴涓壄鐭╃殑鏁伴噺锛堝湪 卤1 璇樊鑼冨洿鍐咃級//Math.Abs(5.2 - 4.5) = 0.7 // 璁″叆 Math.Abs(6.0 - 4.5) = 1.5 涓嶈鍏�
+ var oponecount = op.Count(x => Math.Abs(x.TorqueSize - torqueone) <= 1);
+
+ int times = 0;
+ if (op.Count() > onequantity)
+ {
+ times = onequantity;//濡傛灉绗竴鏉′互鍙婃弧瓒冲氨绉婚櫎onequantity鏁伴噺鐨勬暟鎹�
+ }
+ else
+ {
+ times = op.Count();//娌℃湁婊¤冻灏辩Щ闄ゅ綋鍓嶇殑鏁版嵁鏁版嵁
+ }
+
+ for (int i = 0; i < times; i++)
+ {
+ //绉婚櫎绗竴娆″�肩殑褰卞搷锛堜互涓烘湁鍙兘淇╀釜鐩爣鍊肩浉杩戣�屼骇鐢熻鍒わ級
+ op.RemoveAt(0); //绉婚櫎 op 鍒楄〃鐨� 绗竴涓厓绱狅紙鍗虫渶鏃╁瓨鍏ョ殑璁板綍锛�
+
+ }
+
+ // 璁＄畻绗簩涓壄鐭╃殑鏁伴噺锛堝湪 卤1 璇樊鑼冨洿鍐咃級
+ var optowcount = op.Count(x => Math.Abs(x.TorqueSize - torquetwo) <= 1);
+ sum = oponecount + optowcount;
+ //绗竴绉嶏紝绗竴涓壄鍔涘�兼病鏈夋壄瀹�
+ if (oponecount < onequantity && torqueone != 0)
+ {
+ //璁惧��
+ //var com = item.DeviceChildCode + deviceProtocolDetail.ProtocalDetailValue
+ // .Replace("[setNum]", (torqueone * 1000).ToString().PadLeft(7, '0')) + "\r";
+ var com = item.DeviceChildCode + deviceProtocolDetail.ProtocalDetailValue
+ .Replace("[setNum]", Math.Round(torqueone * 1000).ToString().PadLeft(7, '0')) + "\r";
+ //鏍煎紡鍖栨垚鏁存暟
+
+ serialPortDevice.Communicator.Write(com);
+ //WriteDebug("鍐欏叆", com);
+ }
+ //绗簩绉嶏紝绗竴涓�兼壄瀹屼簡锛岀浜屼釜娌℃湁鎵畬
+ if (oponecount == onequantity && optowcount < towquantity && torquetwo != 0)
+ {
+ //璁惧��
+ var com = item.DeviceChildCode + deviceProtocolDetail.ProtocalDetailValue
+ .Replace("[setNum]", Math.Round(torquetwo * 1000).ToString().PadLeft(7, '0')) + "\r";
+ serialPortDevice.Communicator.Write(com);
+ }
+ }
+ //杩欓噷杩欎釜浠诲姟绗竴娆℃墽琛岋紝op琛ㄤ腑鑲畾鏄病鏈夋暟鎹殑锛屾墍鏈夌涓�娆″氨瑕佹妸宸ヨ壓琛ㄤ腑鐨勫�肩粰瀹�
+ else if(!op.Any()&& torqueone!=0)//闃叉姝ラ涓�涓璽orqueone鐨勫�间负0瀵艰嚧鎶ラ敊
+ {
+ //璁惧��
+ var com = item.DeviceChildCode + deviceProtocolDetail.ProtocalDetailValue
+ .Replace("[setNum]", Math.Round(torqueone * 1000).ToString().PadLeft(7, '0')) + "\r";
+ serialPortDevice.Communicator.Write(com);
+ }
+
+ }
+ else
+ {
+ Console.WriteLine("proNow 涓虹┖");
+ }
+ }
+ else
+ {
+ Console.WriteLine($"Getcireit鎺ュ彛閿欒锛歿process?.Message}");
+ }
+ }
+
+ /// <summary>
+ /// 鍙戦�佹壄鐭╂寚浠ゅ埌璁惧
+ /// </summary>
+ /// <param name="serialPortDevice">涓插彛璁惧</param>
+ /// <param name="item">璁惧淇℃伅</param>
+ /// <param name="deviceProtocolDetail">璁惧鍗忚璇︽儏</param>
+ /// <param name="torqueValue">鎵煩鍊�</param>
+ private void SendTorqueCommand(SerialPortDevice serialPortDevice, DeviceProDTO item, DeviceProtocolDetailDTO deviceProtocolDetail, double torqueValue)
+ {
+ var com = item.DeviceChildCode + deviceProtocolDetail.ProtocalDetailValue
+ .Replace("[setNum]", Math.Round(torqueValue * 1000).ToString().PadLeft(7, '0')) + "\r";
+ serialPortDevice.Communicator.Write(com);
+ }
+
+
+ /// <summary>
+ /// 瀛樺偍鎵煩鏁版嵁鍒� `op` 琛�
+ /// </summary>
+ private void SaveTorqueOpData(string group, string devicecode, string torqueValue)
+ {
+ //var take = _putakeRepository.QueryData(x => x.Grouptype == group)
+ // .OrderBy(x => x.Dispatchtime)
+ // .FirstOrDefault();
+ //var takeid = take?.Njtakeid;//鎷垮埌浠诲姟鍙�
+ var takeResponse = _putakeServer.PerformTasks(group);
+ if (takeResponse == null || !takeResponse.Status)
+ {
+ Console.WriteLine($"浠诲姟鍒嗙骇琛ㄦ帴鍙ｉ敊璇細{takeResponse?.Message}");
+ }
+
+ var take = JsonConvert.DeserializeObject<Dt_Putake>(JsonConvert.SerializeObject(takeResponse.Data)); // 纭繚杞崲姝ｇ‘
+ var takeid = take?.Njtakeid;//鎷垮埌浠诲姟鍙�
+
+ //璋冪敤Getcircuit鎷垮埌褰撳墠姝ラ
+ var process = _processServer.Getcircuit(group, takeid);
+
+ if (process != null && process.Status)
+ {
+ var list = JsonConvert.SerializeObject(process.Data);
+ var dataz = JsonConvert.DeserializeObject<ProcessData>(list);
+
+ if (dataz?.proNow != null)
+ {
+
+ int setpNum = dataz.proNow.SetpNum;
+ int sum = dataz.proNow.TorqueSum;
+ double torqueone = dataz.proNow.TorqueOne;
+ int onequantity = dataz.proNow.TorqueOneQuantity;
+ int towquantity = dataz.proNow.TorqueTwoQuantity;
+ double torquetwo = dataz.proNow.TorqueTwo;
+ Dt_TorqueOp Addop = new Dt_TorqueOp()
+ {
+ DeviceCode = devicecode,
+ TakeId = takeid,
+ GroupOp = group,
+ ProcessSte = setpNum,
+ TorqueSize = float.TryParse(torqueValue, out float torque) ? torque : 0.0f, // 杩欓噷杩涜瀛楃涓插埌float鐨勮浆鎹�
+ CreateDate = DateTime.Now,
+ };
+ //_orqueOpRepository.AddData(Addop);
+ _torqueOpServer.AddData(Addop);
+
+
+ }
+ }
+ }
}
}
--
Gitblit v1.9.3