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());