From 55c3b10c726509ed4b048c46d724d842c39d220d Mon Sep 17 00:00:00 2001
From: xuhy <3313886187@qq.com>
Date: 星期二, 10 九月 2024 12:26:22 +0800
Subject: [PATCH] mq修改
---
ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/rocket/listener/PingMessageListener.java | 10 ----------
1 files changed, 0 insertions(+), 10 deletions(-)
diff --git a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/rocket/listener/PingMessageListener.java b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/rocket/listener/PingMessageListener.java
index 6c0bc92..dadb590 100644
--- a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/rocket/listener/PingMessageListener.java
+++ b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/rocket/listener/PingMessageListener.java
@@ -31,10 +31,6 @@
@Autowired
private PingService pingService;
- @Autowired
- private MessageUtil messageUtil;
- @Autowired
- private IotMessageProduce iotMessageProduce;
@Override
protected void handleMessage(PingMessage message) throws Exception {
// 此时这里才是最终的业务处理，代码只需要处理资源类关闭异常，其他的可以交给父类重试
@@ -44,12 +40,6 @@
BeanUtils.copyProperties(message,ping);
pingService.create(ping);
// 业务处理
- Pong pong = new Pong();
- pong.setCharging_pile_code(message.getCharging_pile_code());
- pong.setCharging_gun_code(message.getCharging_gun_code());
- pong.setCharging_gun_status(0);
- String result = iotMessageProduce.sendMessage(pong.getCharging_pile_code(), ServiceIdMenu.PONG.getKey(), messageUtil.pong(pong));
- log.info("充电桩心跳包-返回结果：{}",result);
}
@Override
--
Gitblit v1.7.1