| | |
|---|
| | | package com.ruoyi.utils.mqtt; |
|---|
| | | |
|---|
| | | import com.ruoyi.alarm.global.service.IGlobalAlarmService; |
|---|
| | | import com.ruoyi.alarm.global.service.impl.GlobalAlarmServiceImpl; |
|---|
| | | import com.ruoyi.alarm.radar.service.ArdRadarService; |
|---|
| | | import com.ruoyi.common.utils.spring.SpringUtils; |
|---|
| | |
|---|
| | | // subscribe后得到的消息会执行到这里面 |
|---|
| | | log.debug("接收消息 【主题】:" + topic + " 【内容】:" + new String(message.getPayload(), StandardCharsets.UTF_8)); |
|---|
| | | //进行业务处理(接收报警数据) |
|---|
| | | GlobalAlarmServiceImpl globalAlarmService = SpringUtils.getBean(GlobalAlarmServiceImpl.class); |
|---|
| | | IGlobalAlarmService globalAlarmService = SpringUtils.getBean(IGlobalAlarmService.class); |
|---|
| | | globalAlarmService.receiveAlarm(topic, new String(message.getPayload(), StandardCharsets.UTF_8)); |
|---|
| | | |
|---|
| | | if (topic.equals("minioEvent")) |
|---|
| | | { |
|---|
| | | IStorageMinioEventService storageMinioEventService = SpringUtils.getBean(IStorageMinioEventService.class); |
|---|
