feat: 推送人脸和车辆信息完结版

src/main/java/com/bootdo/datasend/dianxin/task/StandardTask.java

@@ -16,6 +16,7 @@ import lombok.RequiredArgsConstructor;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
+import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 import org.springframework.web.client.RestTemplate;
 
@@ -32,11 +33,13 @@ public class StandardTask {
     private final RabbitTemplate rabbitTemplate;
 
     //    @Scheduled(cron = "0/5 * * * * ? ")
+    @Scheduled(cron = "0/30 * * * * ? ")
     public void sendVehicleRecord() {
 
         List<BaseVehicleRecord> lists = vehicleRecordService.list(new QueryWrapper<BaseVehicleRecord>()
                 .eq("is_send", "0")
                 .last("limit 100")
+                .orderByAsc("id")
         );
 
         for (BaseVehicleRecord h : lists) {
@@ -80,6 +83,7 @@ public class StandardTask {
             dataDTO.setRequestDataList(list);
             dto.setRequestData(dataDTO);
             boolean b = sendVehicleMq(dto);
+            logger.info("车辆数据发送成功：" + JSON.toJSONString(dto));
             if (b) {
                 h.setIsSend(1);
                 vehicleRecordService.saveOrUpdate(h);
@@ -90,11 +94,13 @@ public class StandardTask {
     }
 
 
+    @Scheduled(cron = "0/30 * * * * ? ")
     public void sendUserRecord() {
 
         List<BaseUserRecord> lists = userRecordService.list(new QueryWrapper<BaseUserRecord>()
                 .eq("is_send", "0")
                 .last("limit 100")
+                .orderByAsc("id")
         );
 
         for (BaseUserRecord h : lists) {
@@ -131,6 +137,7 @@ public class StandardTask {
             dto.setRequestData(dataDTO);
 
             boolean result = sendUserMq(dto);
+            logger.info("人脸数据发送成功：" + JSON.toJSONString(dto));
             if (result) {
                 h.setIsSend(1);
                 userRecordService.saveOrUpdate(h);
@@ -142,6 +149,7 @@ public class StandardTask {
     public boolean sendVehicleMq(VehicleRecordDto bean) {
         try {
             rabbitTemplate.convertAndSend("warnrecord", "routing.key.vehiclerecord", JSON.toJSONString(bean));
+            logger.info("车辆数据发送成功：" + JSON.toJSONString(bean));
         } catch (Exception e) {
             return false;
         }
@@ -152,6 +160,7 @@ public class StandardTask {
     public boolean sendUserMq(UserRecordDto bean) {
         try {
             rabbitTemplate.convertAndSend("warnrecord", "routing.key.userrecord", JSON.toJSONString(bean));
+            logger.info("人脸数据发送成功：" + JSON.toJSONString(bean));
         } catch (Exception e) {
             return false;
         }

src/main/resources/application.yml

@@ -4,7 +4,7 @@ spring:
     username: root
     password: 'puxing@18912915666'
     url: jdbc:mysql://110.1.53.162:55306/multidimensional_box?useUnicode=true&characterEncoding=utf8&useSSL=false&allowMultiQueries=true&serverTimezone=GMT
-#    url: jdbc:mysql://127.0.0.1:55306/multidimensional_box?useUnicode=true&characterEncoding=utf8&useSSL=false&allowMultiQueries=true&serverTimezone=GMT
+    #    url: jdbc:mysql://127.0.0.1:55306/multidimensional_box?useUnicode=true&characterEncoding=utf8&useSSL=false&allowMultiQueries=true&serverTimezone=GMT
     driver-class-name: com.mysql.cj.jdbc.Driver
     initialSize: 5 # 配置初始化大小、最小、最大
     minIdle: 5
@@ -31,18 +31,18 @@ spring:
     properties:
       hibernate:
         format_sql: true
+  #  rabbitmq:
+  #    host: 221.229.107.118
+  #    port: 30529
+  #    username: root
+  #    password: 'sm@rtC@m!n23ty'
+  #    dynamic: true
   rabbitmq:
-    host: 221.229.107.118
+    host: 110.1.200.11
-    port: 30529
+    port: 19000
     username: root
-    password: 'sm@rtC@m!n23ty'
+    password: sm@rtC@m!n23ty
     dynamic: true
-#  rabbitmq:
-#    host: 110.1.200.11
-#    port: 19000
-#    username: root
-#    password: 'sm@rtC@m!n23ty'
-#    dynamic: true