From 0f7d83e3f8fa9374a3926de8b3a8fc5d69b69a4d Mon Sep 17 00:00:00 2001
From: 86156 <823267011@qq.com>
Date: Wed, 7 Jan 2026 13:39:46 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BA=8C=E7=BA=A7=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/fizz/business/service/impl/SendJobServiceImpl.java | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/business/src/main/java/com/fizz/business/service/impl/SendJobServiceImpl.java b/business/src/main/java/com/fizz/business/service/impl/SendJobServiceImpl.java
index da782e5..ab4d164 100644
--- a/business/src/main/java/com/fizz/business/service/impl/SendJobServiceImpl.java
+++ b/business/src/main/java/com/fizz/business/service/impl/SendJobServiceImpl.java
@@ -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 的 identifier（如：ns=2;s=...）
+                opcMessageSend.writeData(last.getAddress(), last.getValueRaw());
             } catch (Exception ex) {
                 success = false;
                 allSuccess = false;