From 165583d024259fd3c6e7f405276fb3669b6adaf0 Mon Sep 17 00:00:00 2001
From: dongxiaodong <13970843+dxdwork@user.noreply.gitee.com>
Date: Sat, 6 Apr 2024 21:34:23 +0800
Subject: [PATCH] =?UTF-8?q?kafka=E4=BB=A3=E7=A0=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../common/domain/CoupletTroubleCode.java | 6 -
.../service/impl/BreakdownServiceImpl.java | 176 +++++++++---------
.../mapper/business/SysTroubleMapper.xml | 7 +-
3 files changed, 88 insertions(+), 101 deletions(-)
diff --git a/couplet-common/couplet-common-business/src/main/java/com/couplet/common/domain/CoupletTroubleCode.java b/couplet-common/couplet-common-business/src/main/java/com/couplet/common/domain/CoupletTroubleCode.java
index a29b482..0ace253 100644
--- a/couplet-common/couplet-common-business/src/main/java/com/couplet/common/domain/CoupletTroubleCode.java
+++ b/couplet-common/couplet-common-business/src/main/java/com/couplet/common/domain/CoupletTroubleCode.java
@@ -46,12 +46,6 @@ public class CoupletTroubleCode {
@Excel(name = "vin")
private String troubleVin;
- /**
- * 故障标签
- */
- @Excel(name = "故障标签")
- private Integer troubleTag;
-
/**
* 故障开始时间
*/
diff --git a/couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/service/impl/BreakdownServiceImpl.java b/couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/service/impl/BreakdownServiceImpl.java
index cc347c2..aaa11b1 100644
--- a/couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/service/impl/BreakdownServiceImpl.java
+++ b/couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/service/impl/BreakdownServiceImpl.java
@@ -71,95 +71,6 @@ public class BreakdownServiceImpl extends KeyExpirationEventMessageListener impl
|| StateConstant.DCDC_STATUS != coupletMsgData.getDcdcStatus()
|| StateConstant.CHG_STATUS != coupletMsgData.getChgStatus()){
//获取过期的key
-
- // 定义一个CoupletTroubleCode对象，用于记录故障位置信息
- CoupletTroubleCode troubleCode = new CoupletTroubleCode();
-
- // 检查车辆状态，若为0，则设置故障位置为"190"
- if(coupletMsgData.getVehicleStatus() == 0) {
- troubleCode.setTroublePosition("190");
- }
-
- // 检查充电状态，若为0，则设置故障位置为"191"
- if (coupletMsgData.getChargingStatus() == 0) {
- troubleCode.setTroublePosition("191");
- }
-
- // 检查运行状态，若为0，则设置故障位置为"192"
- if (coupletMsgData.getOperatingStatus() == 0) {
- troubleCode.setTroublePosition("192");
- }
-
- // 检查电池荷电状态（SOC）, 若为0，则设置故障位置为"193"
- if (coupletMsgData.getSocStatus() == 0) {
- troubleCode.setTroublePosition("193");
- }
-
- // 检查充电能源存储状态，若为0，则设置故障位置为"194"
- if (coupletMsgData.getChargingEnergyStorageStatus() == 0) {
- troubleCode.setTroublePosition("194");
- }
-
- // 检查驱动电机状态，若为0，则设置故障位置为"195"
- if (coupletMsgData.getDriveMotorStatus() == 0) {
- troubleCode.setTroublePosition("195");
- }
-
- // 检查定位状态，若为0，则设置故障位置为"196"
- if (coupletMsgData.getPositionStatus() == 0) {
- troubleCode.setTroublePosition("196");
- }
-
- // 检查电子驻车系统（EAS）状态，若为0，则设置故障位置为"197"
- if (coupletMsgData.getEasStatus() == 0) {
- troubleCode.setTroublePosition("197");
- }
-
- // 检查PTC（正温度系数热敏电阻）状态，若为0，则设置故障位置为"198"
- if (coupletMsgData.getPtcStatus() == 0) {
- troubleCode.setTroublePosition("198");
- }
-
- // 检查电动助力转向系统（EPS）状态，若为0，则设置故障位置为"199"
- if (coupletMsgData.getEpsStatus() == 0) {
- troubleCode.setTroublePosition("199");
- }
-
- // 检查防抱死制动系统（ABS）状态，若为0，则设置故障位置为"200"
- if (coupletMsgData.getAbsStatus() == 0) {
- troubleCode.setTroublePosition("200");
- }
-
- // 检查主控制器（MCU）状态，若为0，则设置故障位置为"201"
- if (coupletMsgData.getMcuStatus() == 0) {
- troubleCode.setTroublePosition("201");
- }
-
- // 检查加热状态，若为0，则设置故障位置为"202"
- if (coupletMsgData.getHeatingStatus() == 0) {
- troubleCode.setTroublePosition("202");
- }
-
- // 检查电池状态，若为0，则设置故障位置为"203"
- if (coupletMsgData.getBatteryStatus() == 0) {
- troubleCode.setTroublePosition("203");
- }
-
- // 检查电池绝缘状态，若为0，则设置故障位置为"204"
- if (coupletMsgData.getBatteryInsulationStatus() == 0) {
- troubleCode.setTroublePosition("204");
- }
-
- // 检查直流-直流转换器（DC/DC）状态，若为0，则设置故障位置为"205"
- if (coupletMsgData.getDcdcStatus() == 0) {
- troubleCode.setTroublePosition("205");
- }
-
- // 检查充电机（CHG）状态，若为0，则设置故障位置为"206"
- if (coupletMsgData.getChgStatus() == 0) {
- troubleCode.setTroublePosition("206");
- }
-
String key = "breakdown";
log.debug("失效+key is:"+ key);
String value = JSON.toJSONString(coupletMsgData);
@@ -197,12 +108,95 @@ public class BreakdownServiceImpl extends KeyExpirationEventMessageListener impl
if (breakdownIds.size()==0){
CoupletTroubleCode troubleCode = new CoupletTroubleCode();
troubleCode.setTroubleStartTime(new Date());
- // 插入数据库
- troubleCode.setTroubleTag(0);
troubleCode.setTroubleVin(code.getVin());
// 随机生成故障码
String faultCode = MsgUtils.generateGTA();
troubleCode.setTroubleCode(faultCode);
+
+ // 检查车辆状态，若为0，则设置故障位置为"190"
+ if(code.getVehicleStatus() == 0) {
+ troubleCode.setTroublePosition("190");
+ }
+
+ // 检查充电状态，若为0，则设置故障位置为"191"
+ if (code.getChargingStatus() == 0) {
+ troubleCode.setTroublePosition("191");
+ }
+
+ // 检查运行状态，若为0，则设置故障位置为"192"
+ if (code.getOperatingStatus() == 0) {
+ troubleCode.setTroublePosition("192");
+ }
+
+ // 检查电池荷电状态（SOC）, 若为0，则设置故障位置为"193"
+ if (code.getSocStatus() == 0) {
+ troubleCode.setTroublePosition("193");
+ }
+
+ // 检查充电能源存储状态，若为0，则设置故障位置为"194"
+ if (code.getChargingEnergyStorageStatus() == 0) {
+ troubleCode.setTroublePosition("194");
+ }
+
+ // 检查驱动电机状态，若为0，则设置故障位置为"195"
+ if (code.getDriveMotorStatus() == 0) {
+ troubleCode.setTroublePosition("195");
+ }
+
+ // 检查定位状态，若为0，则设置故障位置为"196"
+ if (code.getPositionStatus() == 0) {
+ troubleCode.setTroublePosition("196");
+ }
+
+ // 检查电子驻车系统（EAS）状态，若为0，则设置故障位置为"197"
+ if (code.getEasStatus() == 0) {
+ troubleCode.setTroublePosition("197");
+ }
+
+ // 检查PTC（正温度系数热敏电阻）状态，若为0，则设置故障位置为"198"
+ if (code.getPtcStatus() == 0) {
+ troubleCode.setTroublePosition("198");
+ }
+
+ // 检查电动助力转向系统（EPS）状态，若为0，则设置故障位置为"199"
+ if (code.getEpsStatus() == 0) {
+ troubleCode.setTroublePosition("199");
+ }
+
+ // 检查防抱死制动系统（ABS）状态，若为0，则设置故障位置为"200"
+ if (code.getAbsStatus() == 0) {
+ troubleCode.setTroublePosition("200");
+ }
+
+ // 检查主控制器（MCU）状态，若为0，则设置故障位置为"201"
+ if (code.getMcuStatus() == 0) {
+ troubleCode.setTroublePosition("201");
+ }
+
+ // 检查加热状态，若为0，则设置故障位置为"202"
+ if (code.getHeatingStatus() == 0) {
+ troubleCode.setTroublePosition("202");
+ }
+
+ // 检查电池状态，若为0，则设置故障位置为"203"
+ if (code.getBatteryStatus() == 0) {
+ troubleCode.setTroublePosition("203");
+ }
+
+ // 检查电池绝缘状态，若为0，则设置故障位置为"204"
+ if (code.getBatteryInsulationStatus() == 0) {
+ troubleCode.setTroublePosition("204");
+ }
+
+ // 检查直流-直流转换器（DC/DC）状态，若为0，则设置故障位置为"205"
+ if (code.getDcdcStatus() == 0) {
+ troubleCode.setTroublePosition("205");
+ }
+
+ // 检查充电机（CHG）状态，若为0，则设置故障位置为"206"
+ if (code.getChgStatus() == 0) {
+ troubleCode.setTroublePosition("206");
+ }
remoteTroubleService.newFaultData(troubleCode);
redisTemplate.opsForSet().add(code.getVin(), code.getVin()+":"+code);
long expireTime = 30;
diff --git a/couplet-modules/couplet-business/src/main/resources/mapper/business/SysTroubleMapper.xml b/couplet-modules/couplet-business/src/main/resources/mapper/business/SysTroubleMapper.xml
index 9fede3f..f7c39f5 100644
--- a/couplet-modules/couplet-business/src/main/resources/mapper/business/SysTroubleMapper.xml
+++ b/couplet-modules/couplet-business/src/main/resources/mapper/business/SysTroubleMapper.xml
@@ -18,13 +18,12 @@
INSERT INTO `couplet-cloud`.`couplet_trouble_code`
- (`trouble_vin`, `trouble_tag`,
- `trouble_start_time`)
+ (`trouble_code`,`trouble_vin`,`trouble_position`,`trouble_start_time`)
VALUES
- (#{troubleVin}, #{troubleTag}, #{troubleStartTime})
+ (#{troubleCode},#{troubleVin}, #{troublePosition},#{troubleStartTime})
-
+ truncate table couplet_trouble_code