yangle-wangannan
/
IotDB_kafka_mqtt
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix 修复车辆故障报错

master
rouchen 2024-06-23 22:39:42 +08:00
parent df8950f19d
commit a094ad06b4
3 changed files with 746 additions and 7947 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8652
logs/vehicle.log
View File

File diff suppressed because it is too large Load Diff

33
src/main/java/com/muyu/event/service/impl/EventServiceImpl.java
View File

@ -235,7 +235,6 @@ public class EventServiceImpl implements EventService {
// 发送消息到RabbitMQ
sendToRabbitMQ(gz001);
log.info("该车故障GZ001信息首次存储到本地缓存和Redis中，并发送到RabbitMQ");
} else if (messageData.getVehicleStatus().equals("0")) {
@ -250,7 +249,7 @@ public class EventServiceImpl implements EventService {
private void chargeStatus(MessageData messageData, Date formattedTime) {
if (messageData.getChargeStatus().equals("0")) {
if (messageData.getVehicleStatus().equals("0") && !redisTemplate.hasKey(messageData.getVin() + "-" + "GZ001")) {
if (messageData.getChargeStatus().equals("0") && !redisTemplate.hasKey(messageData.getVin() + "-" + "GZ002")) {
// 车辆状态异常，第一次发生
// 创建故障对象
@ -283,7 +282,7 @@ public class EventServiceImpl implements EventService {
private void runStatus(MessageData messageData, Date formattedTime) {
if (messageData.getRunStatus().equals("0")) {
if (messageData.getRunStatus().equals("0") && !redisTemplate.hasKey(messageData.getVin() + "-" + "GZ001")) {
if (messageData.getRunStatus().equals("0") && !redisTemplate.hasKey(messageData.getVin() + "-" + "GZ003")) {
// 车辆状态异常，第一次发生
// 创建故障对象
@ -314,7 +313,7 @@ public class EventServiceImpl implements EventService {
private void soc(MessageData messageData, Date formattedTime) {
if (messageData.getSoc().equals("0")) {
if (messageData.getSoc().equals("0") && !redisTemplate.hasKey(messageData.getVin() + "-" + "GZ001")) {
if (messageData.getSoc().equals("0") && !redisTemplate.hasKey(messageData.getVin() + "-" + "GZ004")) {
// 车辆状态异常，第一次发生
// 创建故障对象
@ -347,7 +346,7 @@ public class EventServiceImpl implements EventService {
private void chargeWorkStatus(MessageData messageData, Date formattedTime) {
if (messageData.getChargeWorkStatus().equals("0")) {
if (messageData.getChargeWorkStatus().equals("0") && !redisTemplate.hasKey(messageData.getVin() + "-" + "GZ001")) {
if (messageData.getChargeWorkStatus().equals("0") && !redisTemplate.hasKey(messageData.getVin() + "-" + "GZ005")) {
// 车辆状态异常，第一次发生
// 创建故障对象
@ -379,7 +378,7 @@ public class EventServiceImpl implements EventService {
private void driveMotorStatus(MessageData messageData,Date formattedTime){
if (messageData.getDriveMotorStatus().equals("0")) {
if (messageData.getDriveMotorStatus().equals("0") && !redisTemplate.hasKey(messageData.getVin() + "-" + "GZ001")) {
if (messageData.getDriveMotorStatus().equals("0") && !redisTemplate.hasKey(messageData.getVin() + "-" + "GZ006")) {
// 车辆状态异常，第一次发生
// 创建故障对象
@ -410,7 +409,7 @@ public class EventServiceImpl implements EventService {
private void location(MessageData messageData,Date formattedTime){
if (messageData.getLocation().equals("0")) {
if (messageData.getLocation().equals("0") && !redisTemplate.hasKey(messageData.getVin() + "-" + "GZ001")) {
if (messageData.getLocation().equals("0") && !redisTemplate.hasKey(messageData.getVin() + "-" + "GZ007")) {
// 车辆状态异常，第一次发生
// 创建故障对象
@ -441,7 +440,7 @@ public class EventServiceImpl implements EventService {
private void eas(MessageData messageData,Date formattedTime){
if (messageData.getEas().equals("0")) {
if (messageData.getVehicleStatus().equals("0") && !redisTemplate.hasKey(messageData.getVin() + "-" + "GZ001")) {
if (messageData.getVehicleStatus().equals("0") && !redisTemplate.hasKey(messageData.getVin() + "-" + "GZ008")) {
// 车辆状态异常，第一次发生
// 创建故障对象
@ -472,7 +471,7 @@ public class EventServiceImpl implements EventService {
private void ptc(MessageData messageData,Date formattedTime){
if (messageData.getPtc().equals("0")) {
if (messageData.getPtc().equals("0") && !redisTemplate.hasKey(messageData.getVin() + "-" + "GZ001")) {
if (messageData.getPtc().equals("0") && !redisTemplate.hasKey(messageData.getVin() + "-" + "GZ009")) {
// 车辆状态异常，第一次发生
// 创建故障对象
@ -503,7 +502,7 @@ public class EventServiceImpl implements EventService {
private void eps(MessageData messageData,Date formattedTime){
if (messageData.getEps().equals("0")) {
if (messageData.getEps().equals("0") && !redisTemplate.hasKey(messageData.getVin() + "-" + "GZ001")) {
if (messageData.getEps().equals("0") && !redisTemplate.hasKey(messageData.getVin() + "-" + "GZ010")) {
// 车辆状态异常，第一次发生
// 创建故障对象
@ -534,7 +533,7 @@ public class EventServiceImpl implements EventService {
private void abs(MessageData messageData,Date formattedTime){
if (messageData.getAbs().equals("0")) {
if (messageData.getAbs().equals("0") && !redisTemplate.hasKey(messageData.getVin() + "-" + "GZ001")) {
if (messageData.getAbs().equals("0") && !redisTemplate.hasKey(messageData.getVin() + "-" + "GZ011")) {
// 车辆状态异常，第一次发生
// 创建故障对象
@ -566,7 +565,7 @@ public class EventServiceImpl implements EventService {
private void mcu(MessageData messageData,Date formattedTime){
if (messageData.getMcu().equals("0")) {
if (messageData.getMcu().equals("0") && !redisTemplate.hasKey(messageData.getVin() + "-" + "GZ001")) {
if (messageData.getMcu().equals("0") && !redisTemplate.hasKey(messageData.getVin() + "-" + "GZ012")) {
// 车辆状态异常，第一次发生
// 创建故障对象
@ -597,7 +596,7 @@ public class EventServiceImpl implements EventService {
private void powerBatteryHeating(MessageData messageData,Date formattedTime){
if (messageData.getPowerBatteryHeating().equals("0")) {
if (messageData.getPowerBatteryHeating().equals("0") && !redisTemplate.hasKey(messageData.getVin() + "-" + "GZ001")) {
if (messageData.getPowerBatteryHeating().equals("0") && !redisTemplate.hasKey(messageData.getVin() + "-" + "GZ013")) {
// 车辆状态异常，第一次发生
// 创建故障对象
@ -628,7 +627,7 @@ public class EventServiceImpl implements EventService {
private void powerBatteryCurrentStatus(MessageData messageData,Date formattedTime){
if (messageData.getPowerBatteryCurrentStatus().equals("0")) {
if (messageData.getPowerBatteryCurrentStatus().equals("0") && !redisTemplate.hasKey(messageData.getVin() + "-" + "GZ001")) {
if (messageData.getPowerBatteryCurrentStatus().equals("0") && !redisTemplate.hasKey(messageData.getVin() + "-" + "GZ014")) {
// 车辆状态异常，第一次发生
// 创建故障对象
@ -659,7 +658,7 @@ public class EventServiceImpl implements EventService {
private void powerBatteryHeat(MessageData messageData,Date formattedTime){
if (messageData.getPowerBatteryHeat().equals("0")) {
if (messageData.getPowerBatteryHeat().equals("0") && !redisTemplate.hasKey(messageData.getVin() + "-" + "GZ001")) {
if (messageData.getPowerBatteryHeat().equals("0") && !redisTemplate.hasKey(messageData.getVin() + "-" + "GZ015")) {
// 车辆状态异常，第一次发生
// 创建故障对象
@ -690,7 +689,7 @@ public class EventServiceImpl implements EventService {
private void dcdc(MessageData messageData,Date formattedTime){
if (messageData.getDcdc().equals("0")) {
if (messageData.getDcdc().equals("0") && !redisTemplate.hasKey(messageData.getVin() + "-" + "GZ001")) {
if (messageData.getDcdc().equals("0") && !redisTemplate.hasKey(messageData.getVin() + "-" + "GZ016")) {
// 车辆状态异常，第一次发生
// 创建故障对象
@ -721,7 +720,7 @@ public class EventServiceImpl implements EventService {
private void chg(MessageData messageData,Date formattedTime){
if (messageData.getChg().equals("0")) {
if (messageData.getChg().equals("0") && !redisTemplate.hasKey(messageData.getVin() + "-" + "GZ001")) {
if (messageData.getChg().equals("0") && !redisTemplate.hasKey(messageData.getVin() + "-" + "GZ017")) {
// 车辆状态异常，第一次发生
// 创建故障对象

8
src/main/java/com/muyu/mqtt/config/RabbitConfig.java
View File

@ -30,13 +30,13 @@ public class RabbitConfig {
@Primary
@Bean
public Queue autoDeleteQueue1() {
return new Queue("discover_time", true,true,true);
return new Queue("discover_time", true);
}
@Primary
@Bean
public Queue resolve_time() {
return new Queue("resolve_time", true,true,true);
public Queue resolve() {
return new Queue("resolve_time", true);
}
@Primary
@Bean
@ -54,7 +54,7 @@ public class RabbitConfig {
@Bean
public Binding resolve_times() {
return BindingBuilder.bind(resolve_time())
return BindingBuilder.bind(resolve())
.to(directExchange())
.with("resolve_time");
}