故障解析

src/main/java/com/god/data/common/domain/BreakConstant.java

@@ -0,0 +1,102 @@
+package com.god.data.common.domain;
+
+/**
+ * 故障信息
+ *
+ * @author ChenXinHai
+ * @version 2023/11/22 - 21:48
+ */
+public enum BreakConstant {
+    /**
+     * 车辆状态
+     */
+    GET001("GTX001","vehicleStatus",0),
+    /**
+     * 充点状态
+     */
+    GTX002("GTX002","chargingStatus",0),
+    /**
+     * 运行状态
+     */
+    GTX003("GTX003","operatingStatus",0),
+    /**
+     * SOC
+     */
+    GTX004("GTX004","socStatus",0),
+    /**
+     * 可充电储能装置工作状态
+     */
+    GTX005("GTX005","chargingEnergyStorageStatus",0),
+    /**
+     * 驱动电机状态
+     */
+    GTX006("GTX006","driveMotorStatus",0),
+    /**
+     * 定位是否有效
+     */
+    GTX007("GTX007","positionStatus",0),
+    /**
+     * EPS工作状态
+     */
+    GTO0001("GTO001","epsStatus",0),
+    /**
+     * EAS工作状态
+     */
+    GTO0002("GTO002","easStatus",0),
+    /**
+     * PTC工作状态
+     */
+    GTO003("GTO003","ptcStatus",0),
+    /**
+     * DCDC工作状态
+     */
+    GTO004("GTO004","dcdcStatus",0),
+    /**
+     * EPS工作状态
+     */
+    GTO005("GTO005","epsStatus",0),
+    /**
+     * CHG工作状态
+     */
+    GTO006("GTO006","chgStatus",0),
+    /**
+     * ABS工作状态
+     */
+    GTO007("GTO007","absStatus",0),
+    /**
+     * MCU工作状态
+     */
+    GTO008("GTO008","mcuStatus",0),
+    /**
+     * 动力电池加热状态
+     */
+    GTB001("GTB001","heatingStatus",0),
+    /**
+     * 动力电池当前状态
+     */
+    GTB002("GTB002","batteryStatus",0),
+    /**
+     * 动力电池保温状态
+     */
+    GTB003("GTB003","batteryInsulationStatus",0);
+    private String key;
+    private String value;
+    private Integer status;
+    public String key(){
+        return key;
+    }
+    public Integer status(){
+        return status;
+    }
+    public String value(){
+        return value;
+    }
+    public void value(String value){
+        this.value=value;
+    }
+    BreakConstant(String key, String value, Integer status){
+        this.key=key;
+        this.value=value;
+        this.status=status;
+    }
+}

src/main/java/com/god/data/service/impl/FaultAlarmEvent.java

@@ -9,6 +9,8 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
 
 /**
  * 故障报警事件
@@ -33,16 +35,69 @@ public class FaultAlarmEvent implements EventService {
     @Override
     public void execute(CarMessage carMessage) {
         log.info("故障报警事件执行");
-//        //创建集合存故障码
-//        ArrayList<String> strings = new ArrayList<>();
-//        //判断车辆目前的报错故障，添加对应的故障码
-//        if (carMessage.getBatteryStatus()==1){
-//            strings.add("111");
-//        }
-//        //把对应的故障码集合存入rabbitmq
-//        if (strings.size()>0){
-//            rabbitTemplate.convertAndSend("god.car.fault.alarm",strings);
-//        }
+        HashMap<String, List<String>> stringListHashMap = new HashMap<>();
+
+        //创建集合存故障码
+       ArrayList<String> strings = new ArrayList<>();
+      //判断车辆目前的报错故障，添加对应的故障码
+        if (carMessage.getVehicleStatus()==1){
+            strings.add("GTX001");
+        }
+        if (carMessage.getChargingStatus()==1){
+            strings.add("GTX002");
+        }
+        if (carMessage.getOperatingStatus()==1){
+            strings.add("GTX003");
+        }
+        if (carMessage.getSocStatus()==1){
+            strings.add("GTX004");
+        }
+        if (carMessage.getChargingEnergyStorageStatus()==1){
+            strings.add("GTX005");
+        }
+        if (carMessage.getDriveMotorStatus()==1){
+            strings.add("GTX006");
+        }
+        if (carMessage.getPositionStatus()==1){
+            strings.add("GTX007");
+        }
+        if (carMessage.getEasStatus()==1){
+            strings.add("GTO002");
+        }
+        if (carMessage.getPtcStatus()==1){
+            strings.add("GTO003");
+        }
+        if (carMessage.getEpsStatus()==1){
+            strings.add("GTO005");
+        }
+        if (carMessage.getAbsStatus()==1){
+            strings.add("GTO007");
+        }
+        if (carMessage.getMcuStatus()==1){
+            strings.add("GTO008");
+        }
+        if (carMessage.getHeatingStatus()==1){
+            strings.add("GTB001");
+        }
+
+        if (carMessage.getBatteryStatus()==1){
+            strings.add("GTB002");
+        }
+        if (carMessage.getBatteryInsulationStatus()==1){
+            strings.add("GTB003");
+        }
+
+        if (carMessage.getDcdcStatus()==1){
+            strings.add("GTO004");
+        }
+        if (carMessage.getChgStatus()==1){
+            strings.add("GTO006");
+        }
+
+       //把对应的故障码集合存入rabbitmq
+       if (strings.size()>0){
+          rabbitTemplate.convertAndSend("god.car.fault.alarm",strings);
+       }
 
 
     }