diff --git a/zc-business/src/main/java/com/zc/business/controller/CodeScanningAlarmController.java b/zc-business/src/main/java/com/zc/business/controller/CodeScanningAlarmController.java index 3189ffd2..27dc34cd 100644 --- a/zc-business/src/main/java/com/zc/business/controller/CodeScanningAlarmController.java +++ b/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());