From 6dda9dc59288f5b609a530112d8b79de1660eb53 Mon Sep 17 00:00:00 2001 From: gcw_MV9p2JJN Date: Wed, 31 Dec 2025 13:59:14 +0800 Subject: [PATCH] Mqtt --- DOAN.Service/JobKanban/WorkorderProgressService.cs | 4 ++-- DOAN.Service/Mobile/PADReportWorkService.cs | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/DOAN.Service/JobKanban/WorkorderProgressService.cs b/DOAN.Service/JobKanban/WorkorderProgressService.cs index d28ce83..0a50322 100644 --- a/DOAN.Service/JobKanban/WorkorderProgressService.cs +++ b/DOAN.Service/JobKanban/WorkorderProgressService.cs @@ -213,8 +213,8 @@ public class WorkorderProgressService : BaseService, IWorkorderPro await _mqttHelper.ConnectAsync(); // 发送多条消息 - - await _mqttHelper.PublishMessageAsync("MES/Workorder/Start", jsonString); + string line = handleWorkorder.LineCode ==null?"-1": handleWorkorder.LineCode; + await _mqttHelper.PublishMessageAsync("MES/Workorder/Start/handleWorkorder/"+ line, jsonString); // 断开连接 await _mqttHelper.DisconnectAsync(); diff --git a/DOAN.Service/Mobile/PADReportWorkService.cs b/DOAN.Service/Mobile/PADReportWorkService.cs index 52b2c2a..767afbc 100644 --- a/DOAN.Service/Mobile/PADReportWorkService.cs +++ b/DOAN.Service/Mobile/PADReportWorkService.cs @@ -239,8 +239,8 @@ namespace DOAN.Service.Mobile await _mqttHelper.ConnectAsync(); // 发送多条消息 - - await _mqttHelper.PublishMessageAsync("MES/Workorder/Start", jsonString); + string line = handleWorkorder.LineCode == null ? "-1" : handleWorkorder.LineCode; + await _mqttHelper.PublishMessageAsync("MES/Workorder/Start/handleWorkorder/" + line, jsonString); // 断开连接 await _mqttHelper.DisconnectAsync();