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

fix 车辆故障维护

master
rouchen 2024-06-24 22:24:47 +08:00
parent a094ad06b4
commit 3505f719a9
5 changed files with 24460 additions and 829 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25282
logs/vehicle.log
View File

File diff suppressed because it is too large Load Diff

BIN
logs/vehicle.log.2024-06-16.0.gz
View File

Binary file not shown.

4
src/main/java/com/muyu/event/common/Fault.java
View File

@ -20,11 +20,15 @@ import java.util.Date;
@NoArgsConstructor @NoArgsConstructor
@SuperBuilder @SuperBuilder
public class Fault { public class Fault {
private String vin; private String vin;
private String faultCode; private String faultCode;
@JsonFormat(pattern = "yyyy-MM-dd HH-mm-ss",timezone = "GMT+8") @JsonFormat(pattern = "yyyy-MM-dd HH-mm-ss",timezone = "GMT+8")
@DateTimeFormat(pattern = "yyyy-MM-dd HH-mm-ss") @DateTimeFormat(pattern = "yyyy-MM-dd HH-mm-ss")
private Date startTime; private Date startTime;
@JsonFormat(pattern = "yyyy-MM-dd HH-mm-ss",timezone = "GMT+8") @JsonFormat(pattern = "yyyy-MM-dd HH-mm-ss",timezone = "GMT+8")
@DateTimeFormat(pattern = "yyyy-MM-dd HH-mm-ss") @DateTimeFormat(pattern = "yyyy-MM-dd HH-mm-ss")
private Date endTime; private Date endTime;

2
src/main/java/com/muyu/event/redis/RedisKeyExpirationListener.java
View File

@ -36,7 +36,6 @@ public class RedisKeyExpirationListener extends KeyExpirationEventMessageListen
*/ */
@Override @Override
public void onMessage(Message message, byte[] pattern) { public void onMessage(Message message, byte[] pattern) {
log.info("过期redis数据：" + message.toString());
try { try {
String key = message.toString(); String key = message.toString();
@ -48,7 +47,6 @@ public class RedisKeyExpirationListener extends KeyExpirationEventMessageListen
rabbitTemplate.convertAndSend("exchange_breakdown","resolve_time", JSON.toJSONString(fault)); rabbitTemplate.convertAndSend("exchange_breakdown","resolve_time", JSON.toJSONString(fault));
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
log.error("【修改支付订单过期状态异常】：" + e.getMessage());
} }
} }

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

@ -751,6 +751,7 @@ public class EventServiceImpl implements EventService {
public void sendToRabbitMQ(Fault gz001){ public void sendToRabbitMQ(Fault gz001){
rabbitTemplate.convertAndSend("exchange_breakdown","discover_time",JSON.toJSONString(gz001)); rabbitTemplate.convertAndSend("exchange_breakdown","discover_time",JSON.toJSONString(gz001));
log.info("故障信息"+gz001.getVin()+"发送到RabbitMQ"); log.info("故障信息"+gz001.getVin()+"发送到RabbitMQ");
} }