Compare commits

...

2 Commits

Author SHA1 Message Date
5db2617028 Merge remote-tracking branch 'origin/master' 2026-01-07 13:42:46 +08:00
0f7d83e3f8 二级修改 2026-01-07 13:39:46 +08:00

View File

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