From 5f2fa408ec96d4ab449f0b9756bfb03f6a9cbc66 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=8E=8B=E5=85=B4=E7=90=B3?= <1911390090@qq.com> Date: Fri, 18 Jul 2025 16:41:20 +0800 Subject: [PATCH] =?UTF-8?q?kafka=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../zc/business/controller/CodeScanningAlarmController.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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());