修复bug

273548560@qq.com
1 parent 871cd1bf
Showing 1 changed file with 6 additions and 1 deletions
trash-workFlow/src/main/java/com/trash/casefile/kafka/Consumer.java
@@ -23,6 +23,7 @@ import org.springframework.kafka.support.KafkaHeaders;
 import org.springframework.messaging.handler.annotation.Header;
 import org.springframework.messaging.handler.annotation.Payload;
 import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
 import java.io.IOException;
 import java.util.*;
@@ -51,8 +52,9 @@ public class Consumer {
     @Autowired
     RedisCache redisCache;
+    @Transactional
     public void autoViolationWarning(String data,String id) throws InterruptedException {
-
+        log.info("开始报警,data:" + data);
         String[] code = {"44030020=工地预警-未报开工作业", "44030021=工地预警-视频设备离线超时报警", "44030022=工地预警-三无车辆进入工地", "44030023=工地预警未按时间作业",
                 "44030024=消纳场预警-未报开工作业", "44030025=消纳场预警-视频设备离线超时报警", "44030026=消纳场预警-三无车辆进入消纳场", "44030027=消纳场预警-未到指定的消纳场作业",
@@ -180,9 +182,12 @@ public class Consumer {
         kafkaCompensation.setId(Long.valueOf(id));
         kafkaCompensation.setStatus(1);
         SpringUtils.getBean(KafkaCompensationMapper.class).updateKafkaCompensation(kafkaCompensation);
+        log.info("报警结束,data:" + data);
     }
+    @Transactional
     public String insertKafkaCompensation(String data){
+        log.info("添加kafka补偿信息,data:" + data);
         KafkaCompensation kafkaCompensation = new KafkaCompensation();
         kafkaCompensation.setData(data);
         kafkaCompensation.setCreateTime(DateUtils.getNowDate());