判断异常

couplet-common/couplet-common-business/src/main/java/com/couplet/common/domain/CoupletTroubleLog.java

@@ -40,13 +40,13 @@ public class CoupletTroubleLog {
      */
     @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
     @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
-    private Date troubleLogStartTime;
+    private Date troubleLogStart;
 
     /**
      * 结束预警时间
      */
     @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
     @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
-    private Date troubleLogEndTime;
+    private Date troubleLogEnd;
 
 }

couplet-common/couplet-common-core/src/main/java/com/couplet/common/core/constant/ServiceNameConstants.java

@@ -30,4 +30,6 @@ public class ServiceNameConstants {
      * @date
      */
     public static final String VEHICLE_SERVICE = "couplet-vehicle";
+
+    public static final String BUSINESS_SERVICE = "couplet-business";
 }

couplet-common/couplet-common-system/pom.xml

@@ -23,5 +23,10 @@
             <groupId>com.couplet</groupId>
             <artifactId>couplet-common-core</artifactId>
         </dependency>
+
+        <dependency>
+            <groupId>com.couplet</groupId>
+            <artifactId>couplet-common-business</artifactId>
+        </dependency>
     </dependencies>
 </project>

couplet-common/couplet-common-system/src/main/java/com/couplet/common/system/remote/RemoteCodeService.java

@@ -0,0 +1,22 @@
+package com.couplet.common.system.remote;
+
+import com.couplet.common.core.constant.ServiceNameConstants;
+import com.couplet.common.core.domain.Result;
+import com.couplet.common.domain.CoupletTroubleLog;
+import com.couplet.common.system.remote.factory.RemoteCodeFallbackFactory;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+
+/**
+ * @author DongXiaoDong
+ * @version 1.0
+ * @date 2024/4/4 16:00
+ * @description
+ */
+@FeignClient(contextId = "remoteCodeService",value = ServiceNameConstants.BUSINESS_SERVICE, fallbackFactory = RemoteCodeFallbackFactory.class)
+public interface RemoteCodeService {
+
+    @PostMapping("insertCode")
+    public Result<Integer> insertCode(@RequestBody CoupletTroubleLog coupletTroubleLog);
+}

couplet-common/couplet-common-system/src/main/java/com/couplet/common/system/remote/factory/RemoteCodeFallbackFactory.java

@@ -0,0 +1,32 @@
+package com.couplet.common.system.remote.factory;
+
+import com.couplet.common.core.domain.Result;
+import com.couplet.common.domain.CoupletTroubleLog;
+import com.couplet.common.system.remote.RemoteCodeService;
+import lombok.extern.slf4j.Slf4j;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.cloud.openfeign.FallbackFactory;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author DongXiaoDong
+ * @version 1.0
+ * @date 2024/4/4 16:03
+ * @description
+ */
+@Slf4j
+@Component
+public class RemoteCodeFallbackFactory implements FallbackFactory<RemoteCodeService> {
+    @Override
+    public RemoteCodeService create(Throwable cause) {
+        log.error("调用日志服务异常：{}", cause.getMessage());
+        return new RemoteCodeService()
+        {
+            @Override
+            public Result<Integer> insertCode(CoupletTroubleLog coupletTroubleLog) {
+                return null;
+            }
+        };
+    }
+}

couplet-common/couplet-common-system/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports

@@ -3,3 +3,4 @@ com.couplet.common.system.remote.factory.RemoteLogFallbackFactory
 com.couplet.common.system.remote.factory.RemoteFileFallbackFactory
 com.couplet.common.system.remote.factory.RemoteDeptFallbackFactory
 com.couplet.common.system.remote.factory.RemoteEmployeeFallbackFactory
+com.couplet.common.system.remote.factory.RemoteCodeFallbackFactory

couplet-modules/couplet-analyze/couplet-analyze-msg/pom.xml

@@ -86,6 +86,12 @@
             <artifactId>org.eclipse.paho.client.mqttv3</artifactId>
             <version>1.2.5</version>
         </dependency>
+
+        <!-- RabbitMQ依赖-->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-amqp</artifactId>
+        </dependency>
     </dependencies>
 
 </project>

couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/model/ModelMessage.java

@@ -6,6 +6,7 @@ import com.couplet.common.core.utils.SpringUtils;
 import com.couplet.common.core.utils.uuid.IdUtils;
 import lombok.extern.slf4j.Slf4j;
 import org.eclipse.paho.client.mqttv3.*;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.scheduling.annotation.Scheduled;
@@ -35,13 +36,8 @@ import static io.lettuce.core.pubsub.PubSubOutput.Type.message;
 @Component
 public class ModelMessage {
 
-//    @Autowired
+    @Autowired
-//    private CoupletMsgService coupletMsgService;
+    private RabbitTemplate rabbitTemplate;
-
-//    @Autowired
-//    public ModelMessage(CoupletMsgService coupletMsgService){
-//        this.coupletMsgService = coupletMsgService;
-//    }
     static ArrayList<String> strings = new ArrayList<>() {
         {
             add("breakdown");
@@ -87,7 +83,11 @@ public class ModelMessage {
 
                     for (CoupletMsgData msgData : coupletMsgDataList) {
                         log.info("解析到车辆数据：{}", msgData);
-                        //发送日志到MQ
+                        //发送消息到MQ
+                        rabbitTemplate.convertAndSend("send-couplet-code",msgData,message -> {
+                            message.getMessageProperties().setMessageId(UUID.randomUUID().toString());
+                            return message;
+                        });
                         for (String string : strings) {
                             IncidentService incidentService = SpringUtils.getBean(string);
                             incidentService.incident(msgData);

couplet-modules/couplet-business/pom.xml

@@ -87,6 +87,12 @@
             <artifactId>couplet-analyze-msg</artifactId>
         </dependency>
 
+        <!-- RabbitMQ依赖-->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-amqp</artifactId>
+        </dependency>
+
     </dependencies>
 
     <build>

couplet-modules/couplet-business/src/main/java/com/couplet/business/server/CoupletBusinessApplication.java

@@ -13,8 +13,8 @@ import org.springframework.boot.autoconfigure.SpringBootApplication;
  */
 @EnableCustomConfig
 @EnableCustomSwagger2
-@EnableMyFeignClients(basePackages = ("com.couplet"))
+@EnableMyFeignClients(basePackages = ("com.couplet.**"))
-@SpringBootApplication(scanBasePackages = {"com.couplet"})
+@SpringBootApplication(scanBasePackages = {"com.couplet.**"})
 public class CoupletBusinessApplication {
     public static void main (String[] args) {
         SpringApplication.run(CoupletBusinessApplication.class, args);

couplet-modules/couplet-business/src/main/java/com/couplet/business/server/consumer/SendCodeQueueConsumer.java

@@ -0,0 +1,97 @@
+package com.couplet.business.server.consumer;
+
+import com.alibaba.fastjson.JSONObject;
+import com.couplet.analyze.msg.domain.CoupletMsgData;
+import com.couplet.common.domain.CoupletTroubleLog;
+import com.couplet.common.system.remote.RemoteCodeService;
+import com.rabbitmq.client.Channel;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.amqp.core.Message;
+import org.springframework.amqp.rabbit.annotation.Queue;
+import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.stereotype.Component;
+
+import java.util.Date;
+import java.util.Random;
+import java.util.concurrent.CompletableFuture;
+
+/**
+ * @author DongXiaoDong
+ * @version 1.0
+ * @date 2024/3/14 22:09
+ * @description
+ */
+@Component
+@Slf4j
+public class SendCodeQueueConsumer {
+    @Autowired
+    private RedisTemplate<String, String> redisTemplate;
+
+    @Autowired
+    private RemoteCodeService remoteCodeService;
+
+    @RabbitListener(queuesToDeclare = {@Queue("send-couplet-code")})
+    public void sendLogQueueConsumer(Message message, CoupletMsgData msgData, Channel channel) {
+        log.info("日志队列：{}，接收到的消息：{}，开始消费...","send-couplet-code", JSONObject.toJSONString(msgData));
+        long start = System.currentTimeMillis();
+
+        String messageId = message.getMessageProperties().getMessageId();
+
+        try {
+            Long aLong = redisTemplate.opsForSet().add("send-log-queue", messageId);
+            if (aLong==1) {
+                //异步保存日志
+                CompletableFuture.runAsync(() -> {
+                    CoupletTroubleLog coupletTroubleLog = new CoupletTroubleLog();
+                    //判断状态是否为异常
+                    if (msgData.getVehicleStatus() !=1){
+                        String code = generateGTA();
+                        coupletTroubleLog.setTroubleLogCode(code);
+                        coupletTroubleLog.setTroubleLogStart(new Date());
+                        String vin = msgData.getVin();
+                        coupletTroubleLog.setTroubleLogVin(vin);
+                        // 如果状态为正常1时添加结束时间
+                        if (msgData.getVehicleStatus() == 1){
+                            coupletTroubleLog.setTroubleLogEnd(new Date());
+                        }
+                    }
+                    remoteCodeService.insertCode(coupletTroubleLog);
+                });
+                log.info("");
+            }
+            long end = System.currentTimeMillis();
+            log.info("日志队列：{}，接收到的消息：{}，消费完成，耗时：{}毫秒","send-log-queue", JSONObject.toJSONString(msgData), (end-start));
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+    }
+    /**
+     *
+     * 拼接GTA字符串
+     * @return
+     */
+    public static String generateGTA() {
+        // 生成以GTA开头的字符串
+        String codefix = "GTA";
+        // 删除4位数随机数字
+        String s = generateRandomNumber(4);
+        //拼接
+        return codefix + s;
+    }
+
+    /**
+     * 随机生成1到10位的数字
+     * @param length
+     * @return
+     */
+    public static String generateRandomNumber(int length) {
+        Random random = new Random();
+        StringBuilder builder = new StringBuilder();
+        for (int i = 0; i < length; i++) {
+            builder.append(random.nextInt(10));
+        }
+        return builder.toString();
+    }
+}

couplet-modules/couplet-business/src/main/java/com/couplet/business/server/controller/SysTroubleController.java

@@ -6,10 +6,12 @@ import com.couplet.common.core.domain.Result;
 import com.couplet.common.core.web.controller.BaseController;
 import com.couplet.common.domain.CoupletTroubleCode;
 import com.couplet.common.domain.CoupletTroubleGrade;
+import com.couplet.common.domain.CoupletTroubleLog;
 import com.couplet.common.domain.CoupletTroubleType;
 import com.couplet.common.domain.request.TroubleResp;
 import com.couplet.common.log.annotation.Log;
 import com.couplet.common.log.enums.BusinessType;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
@@ -24,6 +26,7 @@ import java.util.List;
  */
 @RestController
 @RequestMapping("trouble")
+@Slf4j
 public class SysTroubleController extends BaseController {
     @Autowired
     private SysTroubleService troubleService;
@@ -80,4 +83,15 @@ public class SysTroubleController extends BaseController {
         troubleService.removeById(troubleId);
         return success();
     }
+
+    @PostMapping("insertCode")
+    public Result<Integer> insertCode(@RequestBody CoupletTroubleLog coupletTroubleLog){
+        long start = System.currentTimeMillis();
+        int i = troubleService.insertMsgResq(coupletTroubleLog);
+
+        long end = System.currentTimeMillis();
+        log.info("记录异常信息成功,耗时：{}",(end-start));
+
+        return Result.success(i);
+    }
 }

couplet-modules/couplet-business/src/main/java/com/couplet/business/server/mapper/SysTroubleMapper.java

@@ -8,7 +8,6 @@ import com.couplet.common.domain.CoupletTroubleLog;
 import com.couplet.common.domain.CoupletTroubleType;
 import com.couplet.common.domain.request.TroubleResp;
 import org.apache.ibatis.annotations.Mapper;
-import org.apache.ibatis.annotations.Param;
 
 import java.util.List;
 
@@ -25,4 +24,8 @@ public interface SysTroubleMapper extends BaseMapper<CoupletTroubleCode> {
     List<CoupletTroubleType> selectTroubleListByType();
 
     List<CoupletTroubleGrade> selectTroubleListByGrade();
+
+    List<CoupletMsgData> selectTroubleListByMsg();
+
+    int insertMsgResq(CoupletTroubleLog coupletTroubleLog);
 }

couplet-modules/couplet-business/src/main/java/com/couplet/business/server/service/SysTroubleService.java

@@ -5,6 +5,7 @@ import com.couplet.analyze.msg.domain.CoupletMsgData;
 import com.couplet.common.core.domain.PageResult;
 import com.couplet.common.domain.CoupletTroubleCode;
 import com.couplet.common.domain.CoupletTroubleGrade;
+import com.couplet.common.domain.CoupletTroubleLog;
 import com.couplet.common.domain.CoupletTroubleType;
 import com.couplet.common.domain.request.TroubleResp;
 import io.swagger.models.auth.In;
@@ -24,4 +25,8 @@ public interface SysTroubleService extends IService<CoupletTroubleCode> {
     List<CoupletTroubleType> selectTroubleListByType();
 
     List<CoupletTroubleGrade> selectTroubleListByGrade();
+
+    List<CoupletMsgData> selectTroubleListByMsg();
+
+    int insertMsgResq(CoupletTroubleLog coupletTroubleLog);
 }

couplet-modules/couplet-business/src/main/java/com/couplet/business/server/service/impl/SysTroubleServiceImpl.java

@@ -7,6 +7,7 @@ import com.couplet.business.server.service.SysTroubleService;
 import com.couplet.common.core.domain.PageResult;
 import com.couplet.common.domain.CoupletTroubleCode;
 import com.couplet.common.domain.CoupletTroubleGrade;
+import com.couplet.common.domain.CoupletTroubleLog;
 import com.couplet.common.domain.CoupletTroubleType;
 import com.couplet.common.domain.request.TroubleResp;
 import com.github.pagehelper.PageHelper;
@@ -14,6 +15,7 @@ import com.github.pagehelper.PageInfo;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.util.Date;
 import java.util.List;
 import java.util.Random;
 
@@ -52,33 +54,23 @@ public class SysTroubleServiceImpl extends ServiceImpl<SysTroubleMapper, Couplet
         return sysTroubleMapper.selectTroubleListByGrade();
     }
 
-
     /**
-     *
+     * 查询报文信息
-     * 拼接GTA字符串
      * @return
      */
-    public static String generateGTA() {
+    @Override
-        // 生成以GTA开头的字符串
+    public List<CoupletMsgData> selectTroubleListByMsg() {
-        String codefix = "GTA";
+        return sysTroubleMapper.selectTroubleListByMsg();
-        // 删除4位数随机数字
-        String s = generateRandomNumber(4);
-        //拼接
-        return codefix + s;
     }
 
+
     /**
-     * 随机生成1到10位的数字
+     * 添加异常信息
-     * @param length
+     * @param coupletTroubleLog
      * @return
      */
-    public static String generateRandomNumber(int length) {
+    @Override
-        Random random = new Random();
+    public int insertMsgResq(CoupletTroubleLog coupletTroubleLog) {
-        StringBuilder builder = new StringBuilder();
+        return sysTroubleMapper.insertMsgResq(coupletTroubleLog);
-        for (int i = 0; i < length; i++) {
-            builder.append(random.nextInt(10));
-        }
-        return builder.toString();
     }
-
 }

couplet-modules/couplet-business/src/main/resources/mapper/business/SysTroubleMapper.xml

@@ -19,6 +19,11 @@
         LEFT JOIN couplet_trouble_grade g on t.grade_id = g.grade_id
         LEFT JOIN couplet_trouble_type y on t.type_id= y.type_id
     </sql>
+    <insert id="insertMsgResq">
+        insert into couplet_trouble_log(trouble_log_code,toruble_log_vin,trouble_log_start,trouble_log_end)
+        values(#{troubleLogCode},#{troubleLogVin},#{troubleLogStart},#{troubleLogEnd})
+    </insert>
+
 
     <select id="selectTroubleList" parameterType="com.couplet.business.server.mapper.SysTroubleMapper" resultMap="SysTroubleResult">
         <include refid="selectTroubleVo"/>
@@ -37,8 +42,8 @@
     <select id="selectTroubleListByGrade" resultType="com.couplet.common.domain.CoupletTroubleGrade">
         select * from couplet_trouble_grade
     </select>
-    <select id="isTroubleLogCode" resultType="com.couplet.common.domain.CoupletTroubleLog">
+    <select id="selectTroubleListByMsg" resultType="com.couplet.analyze.msg.domain.CoupletMsgData">
-        select * from couplet_trouble_log where trouble_log_id = #{troubleLogId}
+        select * from couplet_msg_data
     </select>