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();