kafka优化

zc-business/src/main/java/com/zc/business/controller/CodeScanningAlarmController.java

@@ -103,6 +103,7 @@ public class CodeScanningAlarmController extends BaseController {
             dcWarning.setRemark(simpleDateFormat.format(dcWarning.getWarningTime()) + warningTitle);
             dcWarning.setWarningSource(UniversalEnum.FIVE.getNumber());
             dcWarning.setWarningState(UniversalEnum.ONE.getNumber());
+            int insertDcWarning = dcWarningService.insertDcWarning(dcWarning);
             //todo  推送kafak扫码报警事件
             Gson gson = new GsonBuilder()
                     .setDateFormat("yyyy-MM-dd HH:mm:ss")
@@ -111,7 +112,7 @@ public class CodeScanningAlarmController extends BaseController {
             KafkaTopicProducer kafkaTopicProducer = SpringUtils.getBean(KafkaTopicProducer.class);
             kafkaTopicProducer.KafkaTopicProducer(jsonString, KafkEnum.scanAlarm.value());
 
-            return AjaxResult.success(dcWarningService.insertDcWarning(dcWarning));
+            return AjaxResult.success(insertDcWarning);
         } else {
             dcWarning.setId(oldData.get("id").toString());
 

zc-business/src/main/java/com/zc/business/message/device/handler/DeviceMessageHandler.java

@@ -533,10 +533,10 @@ public class DeviceMessageHandler {
      * @param msg 设备消息
      */
     private void oneStopDeviceMessageHandle(JSONObject msg) {
-        //kafka消息推送
-        kafkaTopicProducer.KafkaTopicProducer(msg.toJSONString(), KafkEnum.surveyStation.value());
 
         dcTrafficSectionDataService.processRealtimeOneStopMessage(msg);
+        //kafka消息推送
+        kafkaTopicProducer.KafkaTopicProducer(msg.toJSONString(), KafkEnum.surveyStation.value());
     }