From 72942308915441381c5753057585677ce22b8032 Mon Sep 17 00:00:00 2001
From: qiuyao <qiuyao@hnkhzn.com>
Date: 星期一, 24 三月 2025 17:44:21 +0800
Subject: [PATCH] a
---
项目代码/WIDESEAWCS_Server 正式/SerialPortService/NjTaskServer.cs | 80 ++++++++++---------
项目代码/WIDESEAWCS_Server 正式/WIDESEAWCS_Model/Models/SerialPort/Dt_ArticleInfom.cs | 2
项目代码/WIDESEAWCS_Server 正式/WIDESEAWCS_Server/appsettings.json | 63 ++++++++-------
项目代码/WIDESEAWCS_Server 正式/WIDESEAWCS_Tasks/SerialPort/SerialPortJob.cs | 44 +++++------
4 files changed, 94 insertions(+), 95 deletions(-)
diff --git "a/\351\241\271\347\233\256\344\273\243\347\240\201/WIDESEAWCS_Server \346\255\243\345\274\217/SerialPortService/NjTaskServer.cs" "b/\351\241\271\347\233\256\344\273\243\347\240\201/WIDESEAWCS_Server \346\255\243\345\274\217/SerialPortService/NjTaskServer.cs"
index a205430..6abd063 100644
--- "a/\351\241\271\347\233\256\344\273\243\347\240\201/WIDESEAWCS_Server \346\255\243\345\274\217/SerialPortService/NjTaskServer.cs"
+++ "b/\351\241\271\347\233\256\344\273\243\347\240\201/WIDESEAWCS_Server \346\255\243\345\274\217/SerialPortService/NjTaskServer.cs"
@@ -248,43 +248,44 @@
// 鎻掑叆鍒颁换鍔″巻鍙茶〃
- var history = new Dt_NJtakeHistory
- {
- taskID = task.id,
- trainKind = task.trainKind,
- TakeName = task.TakeName,
- trainNum = task.trainNum,
- track = task.track,
- coachNum = task.coachNum,
- bogie = task.bogie,
- processDept = task.processDept,
- jiShuYuan = task.jiShuYuan,
- zhiJianYuan_LC = task.zhiJianYuan_LC,
- zhiJianYuan_DG = task.zhiJianYuan_DG,
- zhiJianYuan_DQ = task.zhiJianYuan_DQ,
- gongZhang = task.gongZhang,
- liJu_LC = task.liJu_LC,
- liJu_DG = task.liJu_DG,
- liJu_DQ = task.liJu_DQ,
- fuZhu_LC = task.fuZhu_LC,
- fuZhu_DQ = task.fuZhu_DQ,
- fuZhu_DG = task.fuZhu_DG,
- createTime = (DateTime)task.createTime,
- dispatchTime = (DateTime)task.dispatchTime,
- startTime = (DateTime)task.startTime,
- startTime_LC = (DateTime)task.startTime_LC,
- endTime_LC = (DateTime)task.endTime_LC,
- startTime_DG = (DateTime)task.startTime_DG,
- endTime_DG = (DateTime)task.endTime_DG,
- startTime_DQ = (DateTime)task.startTime_DQ,
- endTime_DQ = (DateTime)task.endTime_DQ,
- endTime = (DateTime)task.endTime,
- confirmTime_JS = (DateTime)task.confirmTime_JS,
- confirmTime_GZ = (DateTime)task.confirmTime_GZ,
- confirmTime_LC = (DateTime)task.confirmTime_LC,
- confirmTime_DG = (DateTime)task.confirmTime_DG,
- confirmTime_DQ = (DateTime)task.confirmTime_DQ
- };
+ //var history = new Dt_NJtakeHistory
+ //{
+ // taskID = task.id,
+ // trainKind = task.trainKind,
+ // TakeName = task.TakeName,
+ // trainNum = task.trainNum,
+ // track = task.track,
+ // coachNum = task.coachNum,
+ // bogie = task.bogie,
+ // processDept = task.processDept,
+ // jiShuYuan = task.jiShuYuan,
+ // zhiJianYuan_LC = task.zhiJianYuan_LC,
+ // zhiJianYuan_DG = task.zhiJianYuan_DG,
+ // zhiJianYuan_DQ = task.zhiJianYuan_DQ,
+ // gongZhang = task.gongZhang,
+ // liJu_LC = task.liJu_LC,
+ // liJu_DG = task.liJu_DG,
+ // liJu_DQ = task.liJu_DQ,
+ // fuZhu_LC = task.fuZhu_LC,
+ // fuZhu_DQ = task.fuZhu_DQ,
+ // fuZhu_DG = task.fuZhu_DG,
+ // createTime = (DateTime)task.createTime,
+ // dispatchTime = (DateTime)task.dispatchTime,
+ // startTime = (DateTime)task.startTime,
+ // startTime_LC = (DateTime)task.startTime_LC,
+ // endTime_LC = (DateTime)task.endTime_LC,
+ // startTime_DG = (DateTime)task.startTime_DG,
+ // endTime_DG = (DateTime)task.endTime_DG,
+ // startTime_DQ = (DateTime)task.startTime_DQ,
+ // endTime_DQ = (DateTime)task.endTime_DQ,
+ // endTime = (DateTime)task.endTime,
+ // confirmTime_JS = (DateTime)task.confirmTime_JS,
+ // confirmTime_GZ = (DateTime)task.confirmTime_GZ,
+ // confirmTime_LC = (DateTime)task.confirmTime_LC,
+ // confirmTime_DG = (DateTime)task.confirmTime_DG,
+ // confirmTime_DQ = (DateTime)task.confirmTime_DQ
+
+ //};
@@ -314,7 +315,8 @@
Grouptype = g.Grouptype,
Pustatus = g.Pustatus,
Dispatchtime = task.dispatchTime,
-
+ Creater="",
+ CreateDate=new DateTime()
});
}
@@ -324,7 +326,7 @@
BaseDal.UpdateData(task);//灏嗘ā鏉胯〃涓慨鏀圭殑鎻掑叆杩涗换鍔¤〃涓�
// db.Insertable(history).ExecuteCommand();
- _nJtakeHistoryRepository.AddData(history);// 鎻掑叆鍘嗗彶璁板綍
+ //_nJtakeHistoryRepository.AddData(history);// 鎻掑叆鍘嗗彶璁板綍
_putakeRepository.AddData(listp);//涓嬪彂涓夋潯浠诲姟鍒嗚В琛ㄦ暟鎹�
// return new WebResponseContent { Status = true, Message = "涓嬪彂浜嗕换鍔″苟淇濆瓨浜嗘ā鏉�"};
diff --git "a/\351\241\271\347\233\256\344\273\243\347\240\201/WIDESEAWCS_Server \346\255\243\345\274\217/WIDESEAWCS_Model/Models/SerialPort/Dt_ArticleInfom.cs" "b/\351\241\271\347\233\256\344\273\243\347\240\201/WIDESEAWCS_Server \346\255\243\345\274\217/WIDESEAWCS_Model/Models/SerialPort/Dt_ArticleInfom.cs"
index c0b1059..722caa0 100644
--- "a/\351\241\271\347\233\256\344\273\243\347\240\201/WIDESEAWCS_Server \346\255\243\345\274\217/WIDESEAWCS_Model/Models/SerialPort/Dt_ArticleInfom.cs"
+++ "b/\351\241\271\347\233\256\344\273\243\347\240\201/WIDESEAWCS_Server \346\255\243\345\274\217/WIDESEAWCS_Model/Models/SerialPort/Dt_ArticleInfom.cs"
@@ -9,7 +9,7 @@
namespace WIDESEAWCS_Model.Models
{
- [SugarTable("Dt_ArticleInfom", "濂楃瓛/淇℃伅琛�"), MultiTenant]
+ [SugarTable("Dt_ArticleInfom", "濂楃瓛淇℃伅琛�"), MultiTenant]
public class Dt_ArticleInfom:BaseEntity
{
[SugarColumn(IsPrimaryKey = true, IsIdentity = true, ColumnDescription = "涓婚敭")]
diff --git "a/\351\241\271\347\233\256\344\273\243\347\240\201/WIDESEAWCS_Server \346\255\243\345\274\217/WIDESEAWCS_Server/appsettings.json" "b/\351\241\271\347\233\256\344\273\243\347\240\201/WIDESEAWCS_Server \346\255\243\345\274\217/WIDESEAWCS_Server/appsettings.json"
index 97c4b53..4af2a76 100644
--- "a/\351\241\271\347\233\256\344\273\243\347\240\201/WIDESEAWCS_Server \346\255\243\345\274\217/WIDESEAWCS_Server/appsettings.json"
+++ "b/\351\241\271\347\233\256\344\273\243\347\240\201/WIDESEAWCS_Server \346\255\243\345\274\217/WIDESEAWCS_Server/appsettings.json"
@@ -1,34 +1,35 @@
{
- "urls": "http://*:5000", //web鏈嶅姟绔彛锛屽鏋滅敤IIS閮ㄧ讲锛屾妸杩欎釜鍘绘帀
- "Logging": {
- "LogLevel": {
- "Default": "Information",
- "Microsoft.AspNetCore": "Warning"
- },
- "SerialPort": {
- "Port": "COM3"
- }
+ "urls": "http://*:5000", //web鏈嶅姟绔彛锛屽鏋滅敤IIS閮ㄧ讲锛屾妸杩欎釜鍘绘帀
+ "Logging": {
+ "LogLevel": {
+ "Default": "Information",
+ "Microsoft.AspNetCore": "Warning"
},
- "dics": "deviceType,devicePlcType,jobAssembly,jobClassName,deviceStatus,taskType,taskState,inOutType",
- "AllowedHosts": "*",
- "ConnectionStringsEncryption": false,
- "DBType": "SqlServer",
- "MainDB": "DB_WIDESEA", //褰撳墠椤圭洰鐨勪富搴擄紝鎵�瀵瑰簲鐨勮繛鎺ュ瓧绗︿覆鐨凟nabled蹇呴』涓簍rue
- //杩炴帴瀛楃涓�
- //"ConnectionString": "HTI6FB1H05Krd07mNm9yBCNhofW6edA5zLs9TY~MNthRYW3kn0qKbMIsGp~3yyPDF1YZUCPBQx8U0Jfk4PH~ajNFXVIwlH85M3F~v_qKYQ3CeAz3q1mLVDn8O5uWt1~3Ut2V3KRkEwYHvW2oMDN~QIDXPxDgXN0R2oTIhc9dNu7QNaLEknblqmHhjaNSSpERdDVZIgHnMKejU_SL49tralBkZmDNi0hmkbL~837j1NWe37u9fJKmv91QPb~16JsuI9uu0EvNZ06g6PuZfOSAeFH9GMMIZiketdcJG3tHelo=",
- "ConnectionString": "Data Source=.;Initial Catalog=WIDESEAWCS_MXNL;User ID=sa;Password=123456;Integrated Security=False;Connect Timeout=30;Encrypt=False;TrustServerCertificate=False;ApplicationIntent=ReadWrite;MultiSubnetFailover=False",
- //璺ㄥ煙
- "Cors": {
- "PolicyName": "CorsIpAccess", //绛栫暐鍚嶇О
- "EnableAllIPs": true, //褰撲负true鏃讹紝寮�鏀炬墍鏈塈P鍧囧彲璁块棶銆�
- // 鏀寔澶氫釜鍩熷悕绔彛锛屾敞鎰忕鍙ｅ彿鍚庝笉瑕佸甫/鏂滄潌锛氭瘮濡俵ocalhost:8000/锛屾槸閿欑殑
- // 娉ㄦ剰锛宧ttp://127.0.0.1:1818 鍜� http://localhost:1818 鏄笉涓�鏍风殑
- "IPs": "http://127.0.0.1:8080,http://localhost:8080"
- },
- "ApiName": "WIDESEA",
- "ExpMinutes": 120,
- "QuartzJobAutoStart": true,
- "PrintSql": false,
- "WebSocketEnable": true,
- "WebSocketPort": 0
+ "SerialPort": {
+ "Port": "COM3"
+ }
+ },
+ "dics": "deviceType,devicePlcType,jobAssembly,jobClassName,deviceStatus,taskType,taskState,inOutType",
+ "AllowedHosts": "*",
+ "ConnectionStringsEncryption": false,
+ "DBType": "SqlServer",
+ "MainDB": "DB_WIDESEA", //褰撳墠椤圭洰鐨勪富搴擄紝鎵�瀵瑰簲鐨勮繛鎺ュ瓧绗︿覆鐨凟nabled蹇呴』涓簍rue
+ //杩炴帴瀛楃涓�
+ //"ConnectionString": "HTI6FB1H05Krd07mNm9yBCNhofW6edA5zLs9TY~MNthRYW3kn0qKbMIsGp~3yyPDF1YZUCPBQx8U0Jfk4PH~ajNFXVIwlH85M3F~v_qKYQ3CeAz3q1mLVDn8O5uWt1~3Ut2V3KRkEwYHvW2oMDN~QIDXPxDgXN0R2oTIhc9dNu7QNaLEknblqmHhjaNSSpERdDVZIgHnMKejU_SL49tralBkZmDNi0hmkbL~837j1NWe37u9fJKmv91QPb~16JsuI9uu0EvNZ06g6PuZfOSAeFH9GMMIZiketdcJG3tHelo=",
+ "ConnectionString": "Data Source=.;Initial Catalog=WIDESEAWCS_MXNL;User ID=sa;Password=sa123456;Integrated Security=False;Connect Timeout=30;Encrypt=False;TrustServerCertificate=False;ApplicationIntent=ReadWrite;MultiSubnetFailover=False",
+ //璺ㄥ煙
+ "Cors": {
+ "PolicyName": "CorsIpAccess", //绛栫暐鍚嶇О
+ "EnableAllIPs": true, //褰撲负true鏃讹紝寮�鏀炬墍鏈塈P鍧囧彲璁块棶銆�
+ // 鏀寔澶氫釜鍩熷悕绔彛锛屾敞鎰忕鍙ｅ彿鍚庝笉瑕佸甫/鏂滄潌锛氭瘮濡俵ocalhost:8000/锛屾槸閿欑殑
+ // 娉ㄦ剰锛宧ttp://127.0.0.1:1818 鍜� http://localhost:1818 鏄笉涓�鏍风殑
+ "IPs": "http://127.0.0.1:8080,http://localhost:8080"
+ },
+ "ApiName": "WIDESEA",
+ "ExpMinutes": 120,
+ "QuartzJobAutoStart": true,
+ "PrintSql": false,
+ "WebSocketEnable": true,
+ "WebSocketPort": 0,
+ "LogDeubgEnable": true
}
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 097672d..286dd74 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"
@@ -12,6 +12,7 @@
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;
@@ -75,7 +76,6 @@
SerialPortDevice serialPortDevice = (SerialPortDevice)context.JobDetail.JobDataMap.Get("JobParams");
if (serialPortDevice != null)
{
-
List<DeviceProDTO> deviceProDTOs = serialPortDevice.DeviceProDTOs;
foreach (var item in deviceProDTOs)
{
@@ -131,6 +131,7 @@
//鏍煎紡鍖栨垚鏁存暟
serialPortDevice.Communicator.Write(com);
+ WriteDebug("鍐欏叆", com);
}
//绗簩绉嶏紝绗竴涓�兼壄瀹屼簡锛岀浜屼釜娌℃湁鎵畬
if (oponecount==onequantity&& optowcount < towquantity&& torquetwo!=0)
@@ -146,9 +147,7 @@
}
}
#endregion
- item.DeviceProParamName = CommandType.Set.ToString();
-
-
+ item.DeviceProParamName = CommandType.None.ToString();
}
}
@@ -159,28 +158,19 @@
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
@@ -200,7 +190,7 @@
string group = item.DeviceProDataBlock; // 璁惧鎵�灞炵粍鍒�
string devicecode = item.DeviceChildCode;//璁惧缂栧彿
string torqueValue = ExtractTorqueValue(receiveData);
-
+
if (group == "鐢垫皵")
{
#region
@@ -238,21 +228,27 @@
};
}
}
-
-
- #endregion
- item.DeviceProParamName = CommandType.Set.ToString();
+
+ #endregion
+
+ item.DeviceProParamName = CommandType.None.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);
}
}
--
Gitblit v1.9.3