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

feat():下发钢卷设定值请求到模型程序

Browse Source
This commit is contained in:
Allenxy
2025-01-11 20:54:09 +08:00
parent 58e080264d
commit 383a8019a8
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
business/src/main/java/com/fizz/business/mq/RabbitMQ/RabbitQueueListener.java
View File

@@ -64,7 +64,7 @@ public class RabbitQueueListener {
String messageId = (String) headers.get("amqp_messageId"); String messageId = (String) headers.get("amqp_messageId");
// 处理消息逻辑 todo // 处理消息逻辑 todo
if ("someUniqueMessageId".equals(messageId)) { if ("TOTAL_PRESET_DONE".equalsIgnoreCase(messageId)) {
List<ModSetupResultVO> setup = modSetupResultService.getSetupByCoilid(message); List<ModSetupResultVO> setup = modSetupResultService.getSetupByCoilid(message);
@@ -74,8 +74,8 @@ public class RabbitQueueListener {
modSetupResultKeyVO.setLists(setup); modSetupResultKeyVO.setLists(setup);
//socket //socket
WebSocketUtil.sendMessage(WsTypeEnum.calc_setup_result,JSONUtil.toJsonStr(modSetupResultKeyVO)); WebSocketUtil.sendMessage(WsTypeEnum.calc_setup_result,JSONUtil.toJsonStr(modSetupResultKeyVO));
} else { } else if ("TOTAL_PRESET_FAILED".equalsIgnoreCase(messageId)) {
// 默认的处理逻辑 WebSocketUtil.sendMessage(WsTypeEnum.calc_setup_result,JSONUtil.toJsonStr("计算失败"));
} }
} }