by2025/SmartParks
9
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

增加人员聚集，停车消费者
All checks were successful
Build and Push to Target Registry / 构建并推送镜像到目标仓库 (push) Successful in 12m55s
Details

Browse Source
This commit is contained in:
15683799673
2025-08-31 22:40:48 +08:00
parent 0d83a93a7b
commit 046e9d925a
3 changed files with 14 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/RocketMqConstants.java
View File

@@ -9,10 +9,15 @@ public interface RocketMqConstants {
// mq topic // mq topic
String TOPIC = "SmartParks"; String TOPIC = "SmartParks";
/*-----------------------------------消息group------------------------------------*/
// 人比比对消费者组 // 人比比对消费者组
String COMPAREGROUP = "SmartParks-compare"; String COMPAREGROUP = "SmartParks-compare";
// 人脸抓拍消费者组 // 人脸抓拍消费者组
String CAPTUREGROUP = "SmartParks-capture"; String CAPTUREGROUP = "SmartParks-capture";
// 人员聚集消费组
String HIGH_DENSITY_GROUP = "SmartParks-highDensity";
// 停车消费组
String PARKING_GROUP = "SmartParks-parking";
/*-----------------------------------消息tag------------------------------------*/ /*-----------------------------------消息tag------------------------------------*/
String HIKADD = "ADD_HIK_DEVICE_TAG"; String HIKADD = "ADD_HIK_DEVICE_TAG";

8
ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/consumer/HighDensityConsumer.java
View File

@@ -7,8 +7,8 @@ import org.apache.rocketmq.common.message.MessageExt;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener; import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener; import org.apache.rocketmq.spring.core.RocketMQListener;
import org.dromara.sis.rocketmq.RocketMqConstants; import org.dromara.sis.rocketmq.RocketMqConstants;
import org.dromara.sis.rocketmq.domain.FaceCapture;
import org.dromara.sis.rocketmq.domain.HighDensity; import org.dromara.sis.rocketmq.domain.HighDensity;
import org.dromara.sis.service.IEventAlarmReportService;
import org.dromara.sis.service.IZeroSensationPassageService; import org.dromara.sis.service.IZeroSensationPassageService;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
@@ -23,19 +23,19 @@ import org.springframework.stereotype.Component;
@RequiredArgsConstructor @RequiredArgsConstructor
@RocketMQMessageListener( @RocketMQMessageListener(
topic = RocketMqConstants.TOPIC, topic = RocketMqConstants.TOPIC,
consumerGroup = RocketMqConstants.CAPTUREGROUP, consumerGroup = RocketMqConstants.HIGH_DENSITY,
selectorExpression = RocketMqConstants.HIGH_DENSITY selectorExpression = RocketMqConstants.HIGH_DENSITY
) )
public class HighDensityConsumer implements RocketMQListener<MessageExt> { public class HighDensityConsumer implements RocketMQListener<MessageExt> {
private final IZeroSensationPassageService zeroSensationPassageService; private final IEventAlarmReportService eventAlarmReportService;
@Override @Override
public void onMessage(MessageExt ext) { public void onMessage(MessageExt ext) {
log.info("消费人员聚集数据，数据长度={}", ext.getBody().length); log.info("消费人员聚集数据，数据长度={}", ext.getBody().length);
try { try {
HighDensity f = JSONObject.parseObject(ext.getBody(), HighDensity.class); HighDensity f = JSONObject.parseObject(ext.getBody(), HighDensity.class);
eventAlarmReportService.handleHighDensity(f);
} catch (Exception e) { } catch (Exception e) {
log.error("消费人脸抓拍数据处理失败，", e); log.error("消费人脸抓拍数据处理失败，", e);
} }

10
ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/consumer/ParkingDelayConsumer.java
View File

@@ -8,7 +8,7 @@ import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener; import org.apache.rocketmq.spring.core.RocketMQListener;
import org.dromara.sis.rocketmq.RocketMqConstants; import org.dromara.sis.rocketmq.RocketMqConstants;
import org.dromara.sis.rocketmq.domain.ParkingReport; import org.dromara.sis.rocketmq.domain.ParkingReport;
import org.dromara.sis.service.IZeroSensationPassageService; import org.dromara.sis.service.IEventAlarmReportService;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
/** /**
@@ -22,19 +22,19 @@ import org.springframework.stereotype.Component;
@RequiredArgsConstructor @RequiredArgsConstructor
@RocketMQMessageListener( @RocketMQMessageListener(
topic = RocketMqConstants.TOPIC, topic = RocketMqConstants.TOPIC,
consumerGroup = RocketMqConstants.CAPTUREGROUP, consumerGroup = RocketMqConstants.PARKING_GROUP,
selectorExpression = RocketMqConstants.HIGH_DENSITY selectorExpression = RocketMqConstants.PARKING_ALARM
) )
public class ParkingDelayConsumer implements RocketMQListener<MessageExt> { public class ParkingDelayConsumer implements RocketMQListener<MessageExt> {
private final IZeroSensationPassageService zeroSensationPassageService; private final IEventAlarmReportService eventAlarmReportService;
@Override @Override
public void onMessage(MessageExt ext) { public void onMessage(MessageExt ext) {
log.info("消费停车检测数据，数据长度={}", ext.getBody().length); log.info("消费停车检测数据，数据长度={}", ext.getBody().length);
try { try {
ParkingReport report = JSONObject.parseObject(ext.getBody(), ParkingReport.class); ParkingReport report = JSONObject.parseObject(ext.getBody(), ParkingReport.class);
eventAlarmReportService.handleParking(report);
} catch (Exception e) { } catch (Exception e) {
log.error("消费人脸抓拍数据处理失败，", e); log.error("消费人脸抓拍数据处理失败，", e);
} }