DeXun/be-process-control-system
9
1
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

二级修改

Browse Source
This commit is contained in:
86156
2026-01-07 13:39:46 +08:00
parent 53f8ccbadd
commit 0f7d83e3f8
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
business/src/main/java/com/fizz/business/service/impl/SendJobServiceImpl.java
View File

@@ -63,7 +63,8 @@ public class SendJobServiceImpl extends ServiceImpl<BizSendJobMapper, BizSendJob
BeanUtils.copyProperties(dto, job); BeanUtils.copyProperties(dto, job);
// 生成业务唯一键 // 生成业务唯一键
String bizKey = opcMessageIdsManager.generateMessageId("SEND_JOB"); // 生成业务唯一键（OpcMessageIdsManager 目前没有 generateMessageId 方法，改用 UUID）
String bizKey = "SEND_JOB_" + UUID.randomUUID();
job.setBizKey(bizKey); job.setBizKey(bizKey);
job.setStatus("PENDING"); job.setStatus("PENDING");
@@ -302,7 +303,9 @@ public class SendJobServiceImpl extends ServiceImpl<BizSendJobMapper, BizSendJob
boolean success = true; boolean success = true;
String failMsg = null; String failMsg = null;
try { try {
opcMessageSend.writeNode(last.getAddress(), last.getValueRaw()); // OpcMessageSend 没有 writeNode 方法，使用 writeData(identifier, value)
// address 字段在本业务里就是 OPC 的 identifier（如：ns=2;s=...）
opcMessageSend.writeData(last.getAddress(), last.getValueRaw());
} catch (Exception ex) { } catch (Exception ex) {
success = false; success = false;
allSuccess = false; allSuccess = false;