From 191b3de92e362123e6d4d77d56e76c6d44fa4374 Mon Sep 17 00:00:00 2001
From: houzhongjian <houzhongyi@126.com>
Date: 星期四, 07 十一月 2024 09:20:22 +0800
Subject: [PATCH] 增加截图成功后发送rabbitMQ消息
---
iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/video/service/impl/CameraServiceImpl.java | 18 +++++++++++-------
1 files changed, 11 insertions(+), 7 deletions(-)
diff --git a/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/video/service/impl/CameraServiceImpl.java b/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/video/service/impl/CameraServiceImpl.java
index a79ee68..12f46e9 100644
--- a/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/video/service/impl/CameraServiceImpl.java
+++ b/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/video/service/impl/CameraServiceImpl.java
@@ -106,13 +106,7 @@
image.setCreateDate(captureDate);
imageDao.insert(image);
//存入rabbitmq消息队列，等待模型处理
- String createTime = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
- ImageMessage imageMessage = new ImageMessage();
- imageMessage.setMessageId(image.getId());
- imageMessage.setCreateTime(createTime);
- imageMessage.setImageDTO(BeanUtils.toBean(image, ImageDTO.class));
- rabbitTemplate.convertAndSend(ImageMessage.EXCHANGE, ImageMessage.ROUTING_KEY, imageMessage);
-// rabbitTemplate.convertAndSend("topic.image", imageMap);
+ sendRabbitMQMessage(image);
}
private QueryWrapper<CameraEntity> getWrapper(CameraPageReqVO cameraPageReqVO){
@@ -155,4 +149,14 @@
return baseDao.selectCount(queryWrapper);
}
+ // 发送rabbitMQ消息
+ private void sendRabbitMQMessage(ImageEntity image) {
+ String createTime = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
+ ImageMessage imageMessage = new ImageMessage();
+ imageMessage.setMessageId(image.getId());
+ imageMessage.setCreateTime(createTime);
+ imageMessage.setImageDTO(BeanUtils.toBean(image, ImageDTO.class));
+ rabbitTemplate.convertAndSend(ImageMessage.EXCHANGE, ImageMessage.DAHUA_ROUTING_KEY, imageMessage);
+ }
+
}
\ No newline at end of file
--
Gitblit v1.9.3