From fd9f5cbc8774f121fc3145f44a8bebab432f39de Mon Sep 17 00:00:00 2001
From: puzhibing <393733352@qq.com>
Date: 星期三, 11 九月 2024 12:06:34 +0800
Subject: [PATCH] Merge branch 'master' of http://120.76.84.145:10101/gitblit/r/java/mx_charging_pile
---
ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/rocket/listener/UploadRealTimeMonitoringDataMessageListener.java | 11 +++++++++++
1 files changed, 11 insertions(+), 0 deletions(-)
diff --git a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/rocket/listener/UploadRealTimeMonitoringDataMessageListener.java b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/rocket/listener/UploadRealTimeMonitoringDataMessageListener.java
index 2756d20..ce52b46 100644
--- a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/rocket/listener/UploadRealTimeMonitoringDataMessageListener.java
+++ b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/rocket/listener/UploadRealTimeMonitoringDataMessageListener.java
@@ -95,14 +95,24 @@
switch (message.getCharging_gun_status()){
case 0:
faultMessage.setStatus(1);
+ chargingGun.setStatus(1);
break;
case 1:
faultMessage.setStatus(2);
+ chargingGun.setStatus(7);
break;
}
faultMessage.setDownTime(LocalDateTime.now());
faultMessageClient.createFaultMessage(faultMessage);
}else {
+ switch (message.getCharging_gun_status()){
+ case 2:
+ chargingGun.setStatus(2);
+ break;
+ case 3:
+ chargingGun.setStatus(4);
+ break;
+ }
// 空闲 充电 查询是否该设备之前存在离线记录或者故障记录
faultMessage = faultMessageClient.getFaultMessageByGunId(chargingGun.getId()).getData();
if(Objects.nonNull(faultMessage)){
@@ -110,6 +120,7 @@
faultMessageClient.updateFaultMessage(faultMessage);
}
}
+ chargingGunClient.updateChargingGunById(chargingGun);
}
}
--
Gitblit v1.7.1