Compare commits
No commits in common. "5cb6952434c269f39ab3cedbfa41dfeacfb39120" and "eaf4a778dde19ac9acd932e31d1db53b0aa36cb9" have entirely different histories.
5cb6952434
...
eaf4a778dd
|
|
@ -1,26 +0,0 @@
|
||||||
package com.mcwl.web.controller.mqtt;
|
|
||||||
|
|
||||||
import com.mcwl.common.core.domain.R;
|
|
||||||
import com.mcwl.myInvitation.domain.vo.CommissionRatioVo;
|
|
||||||
import com.mcwl.resource.util.MqttTemplate;
|
|
||||||
import io.swagger.annotations.ApiOperation;
|
|
||||||
import lombok.RequiredArgsConstructor;
|
|
||||||
import org.springframework.web.bind.annotation.GetMapping;
|
|
||||||
import org.springframework.web.bind.annotation.RequestMapping;
|
|
||||||
import org.springframework.web.bind.annotation.RestController;
|
|
||||||
|
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
@RestController()
|
|
||||||
@RequiredArgsConstructor
|
|
||||||
@RequestMapping("/mqtt")
|
|
||||||
public class MqttController {
|
|
||||||
|
|
||||||
private final MqttTemplate mqttTemplate;
|
|
||||||
|
|
||||||
@GetMapping("/send")
|
|
||||||
public void list(String topic, String msg) {
|
|
||||||
mqttTemplate.publish(topic, msg);
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
@ -98,6 +98,7 @@ spring:
|
||||||
max-active: 1000
|
max-active: 1000
|
||||||
# #连接池最大阻塞等待时间（使用负值表示没有限制）
|
# #连接池最大阻塞等待时间（使用负值表示没有限制）
|
||||||
max-wait: -1ms
|
max-wait: -1ms
|
||||||
|
time-between-eviction-runs: 6000
|
||||||
|
|
||||||
|
|
||||||
# token配置
|
# token配置
|
||||||
|
|
@ -116,7 +117,7 @@ wechat:
|
||||||
# 应用密钥
|
# 应用密钥
|
||||||
secret: 11218568b79e2c5eb10459ef8c0374bd
|
secret: 11218568b79e2c5eb10459ef8c0374bd
|
||||||
|
|
||||||
#公众号配置
|
#公众号配置
|
||||||
#wechat:
|
#wechat:
|
||||||
# # 应用ID
|
# # 应用ID
|
||||||
# appid: wx82d4c3c96f0ffa5b
|
# appid: wx82d4c3c96f0ffa5b
|
||||||
|
|
@ -169,11 +170,4 @@ huawei:
|
||||||
upload:
|
upload:
|
||||||
endPoint: obs.cn-south-1.myhuaweicloud.com
|
endPoint: obs.cn-south-1.myhuaweicloud.com
|
||||||
|
|
||||||
mqtt:
|
|
||||||
broker-url: tcp://192.168.136.128:1883
|
|
||||||
client-id-prefix: emqx-client
|
|
||||||
connection-timeout: 30
|
|
||||||
keep-alive-interval: 60
|
|
||||||
max-reconnect-attempts: 5
|
|
||||||
clean-session: true
|
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -1,22 +0,0 @@
|
||||||
package com.mcwl;
|
|
||||||
|
|
||||||
|
|
||||||
import com.mcwl.resource.util.MqttTemplate;
|
|
||||||
import lombok.RequiredArgsConstructor;
|
|
||||||
import org.junit.Test;
|
|
||||||
import org.junit.runner.RunWith;
|
|
||||||
import org.springframework.boot.test.context.SpringBootTest;
|
|
||||||
import org.springframework.test.context.junit4.SpringRunner;
|
|
||||||
|
|
||||||
@SpringBootTest(classes = McWlApplication.class)
|
|
||||||
@RunWith(SpringRunner.class)
|
|
||||||
@RequiredArgsConstructor
|
|
||||||
public class TestMQTT {
|
|
||||||
|
|
||||||
private final MqttTemplate mqttTemplate;
|
|
||||||
|
|
||||||
@Test
|
|
||||||
public void publishTest() throws Exception {
|
|
||||||
mqttTemplate.publish("workFlow/1", "test");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -39,11 +39,5 @@
|
||||||
<version>3.1.2</version>
|
<version>3.1.2</version>
|
||||||
</dependency>
|
</dependency>
|
||||||
|
|
||||||
<dependency>
|
|
||||||
<groupId>org.eclipse.paho</groupId>
|
|
||||||
<artifactId>org.eclipse.paho.client.mqttv3</artifactId>
|
|
||||||
<version>1.2.2</version>
|
|
||||||
</dependency>
|
|
||||||
|
|
||||||
</dependencies>
|
</dependencies>
|
||||||
</project>
|
</project>
|
||||||
|
|
|
||||||
|
|
@ -1,38 +0,0 @@
|
||||||
package com.mcwl.resource.handler;
|
|
||||||
|
|
||||||
import lombok.AllArgsConstructor;
|
|
||||||
import lombok.Getter;
|
|
||||||
import org.eclipse.paho.client.mqttv3.MqttMessage;
|
|
||||||
|
|
||||||
import java.lang.annotation.*;
|
|
||||||
import java.util.Collections;
|
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
public interface IMessageHandler {
|
|
||||||
void handleMessage(String topic, MqttMessage message);
|
|
||||||
|
|
||||||
@Target(ElementType.TYPE)
|
|
||||||
@Retention(RetentionPolicy.RUNTIME)
|
|
||||||
@interface Topic {
|
|
||||||
String value();
|
|
||||||
int qos() default 1;
|
|
||||||
}
|
|
||||||
|
|
||||||
default List<TopicSubscription> getTopics() {
|
|
||||||
Topic annotation = this.getClass().getAnnotation(Topic.class);
|
|
||||||
if (annotation != null) {
|
|
||||||
return Collections.singletonList(
|
|
||||||
new TopicSubscription(annotation.value(), annotation.qos())
|
|
||||||
);
|
|
||||||
}
|
|
||||||
return Collections.emptyList();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Getter
|
|
||||||
@AllArgsConstructor
|
|
||||||
class TopicSubscription {
|
|
||||||
private String topicFilter;
|
|
||||||
private int qos;
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
@ -1,126 +0,0 @@
|
||||||
package com.mcwl.resource.handler.impl;
|
|
||||||
|
|
||||||
import cn.hutool.json.JSON;
|
|
||||||
import cn.hutool.json.JSONUtil;
|
|
||||||
import com.mcwl.common.core.domain.entity.SysUser;
|
|
||||||
import com.mcwl.common.exception.ServiceException;
|
|
||||||
import com.mcwl.common.utils.SecurityUtils;
|
|
||||||
import com.mcwl.common.utils.StringUtils;
|
|
||||||
import com.mcwl.resource.domain.ModelImageComment;
|
|
||||||
import com.mcwl.resource.domain.ModelImageCommentLike;
|
|
||||||
import com.mcwl.resource.domain.SysAdvice;
|
|
||||||
import com.mcwl.resource.handler.IMessageHandler;
|
|
||||||
import com.mcwl.resource.mapper.ModelImageCommentLikeMapper;
|
|
||||||
import com.mcwl.resource.mapper.ModelImageCommentMapper;
|
|
||||||
import com.mcwl.resource.mapper.WorkFlowCommentLikeMapper;
|
|
||||||
import com.mcwl.resource.mapper.WorkFlowCommentMapper;
|
|
||||||
import com.mcwl.resource.service.ISysAdviceService;
|
|
||||||
import com.mcwl.system.domain.enums.AdviceEnum;
|
|
||||||
import com.mcwl.system.service.ISysUserService;
|
|
||||||
import lombok.RequiredArgsConstructor;
|
|
||||||
import lombok.extern.slf4j.Slf4j;
|
|
||||||
import org.eclipse.paho.client.mqttv3.MqttMessage;
|
|
||||||
import org.springframework.stereotype.Component;
|
|
||||||
import org.springframework.transaction.annotation.Transactional;
|
|
||||||
|
|
||||||
import java.util.Map;
|
|
||||||
import java.util.Objects;
|
|
||||||
|
|
||||||
@Slf4j
|
|
||||||
@Component
|
|
||||||
@IMessageHandler.Topic(value = "imageCommentLike/#", qos = 1)
|
|
||||||
@RequiredArgsConstructor
|
|
||||||
public class ImageCommentLikeHandler implements IMessageHandler {
|
|
||||||
|
|
||||||
private final ModelImageCommentMapper modelImageCommentMapper;
|
|
||||||
|
|
||||||
private final ModelImageCommentLikeMapper modelImageCommentLikeMapper;
|
|
||||||
|
|
||||||
private final ISysUserService userService;
|
|
||||||
|
|
||||||
private final ISysAdviceService adviceService;
|
|
||||||
@Override
|
|
||||||
@Transactional(rollbackFor = Exception.class)
|
|
||||||
public void handleMessage(String topic, MqttMessage message) {
|
|
||||||
String payload = new String(message.getPayload());
|
|
||||||
log.info("图片评论点赞: {} - {}", payload, message);
|
|
||||||
|
|
||||||
JSON parse = JSONUtil.parse(payload);
|
|
||||||
Long commentId = Long.parseLong(parse.getByPath("commentId").toString());
|
|
||||||
Long userId = Long.parseLong(parse.getByPath("userId").toString());
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
this.like(userId, commentId);
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
private void like(Long userId, Long commentId) {
|
|
||||||
ModelImageComment modelImageComment = modelImageCommentMapper.selectById(commentId);
|
|
||||||
if (Objects.isNull(modelImageComment)) {
|
|
||||||
throw new ServiceException("该评论不存在");
|
|
||||||
}
|
|
||||||
ModelImageCommentLike modelImageCommentLike = modelImageCommentLikeMapper.getLikeImageComment(userId, commentId);
|
|
||||||
if (Objects.nonNull(modelImageCommentLike)) {
|
|
||||||
if (Objects.equals(modelImageCommentLike.getDelFlag(), "0")) {
|
|
||||||
modelImageCommentLike.setDelFlag("2");
|
|
||||||
int likeNum = modelImageComment.getLikeNum() - 1;
|
|
||||||
likeNum = Math.max(likeNum, 0);
|
|
||||||
modelImageComment.setLikeNum(likeNum);
|
|
||||||
} else {
|
|
||||||
modelImageCommentLike.setDelFlag("0");
|
|
||||||
modelImageComment.setLikeNum(modelImageComment.getLikeNum() + 1);
|
|
||||||
this.addLikeAdvice(modelImageComment, userId);
|
|
||||||
}
|
|
||||||
// 更新点赞记录
|
|
||||||
modelImageCommentLikeMapper.updateDelFlagById(modelImageCommentLike);
|
|
||||||
// 更新图片评论点赞数
|
|
||||||
modelImageCommentMapper.updateById(modelImageComment);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
// 添加点赞记录
|
|
||||||
modelImageCommentLike = new ModelImageCommentLike();
|
|
||||||
modelImageCommentLike.setUserId(userId);
|
|
||||||
modelImageCommentLike.setModelImageCommentId(commentId);
|
|
||||||
modelImageCommentLikeMapper.insert(modelImageCommentLike);
|
|
||||||
|
|
||||||
// 更新图片点赞数
|
|
||||||
modelImageComment.setLikeNum(modelImageComment.getLikeNum() + 1);
|
|
||||||
modelImageCommentMapper.updateById(modelImageComment);
|
|
||||||
|
|
||||||
this.addLikeAdvice(modelImageComment, userId);
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
private void addLikeAdvice(ModelImageComment modelImageComment, Long userId) {
|
|
||||||
|
|
||||||
Long receiverUserId = modelImageComment.getUserId();
|
|
||||||
|
|
||||||
if (Objects.equals(userId, receiverUserId)) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
SysUser sysUser = userService.selectUserById(userId);
|
|
||||||
|
|
||||||
String content = StringUtils.format("恭喜！{}点赞了您的评论",
|
|
||||||
sysUser.getNickName());
|
|
||||||
|
|
||||||
SysAdvice sysAdvice = new SysAdvice();
|
|
||||||
sysAdvice.setSenderId(userId);
|
|
||||||
sysAdvice.setReceiverId(receiverUserId);
|
|
||||||
sysAdvice.setContent(content);
|
|
||||||
sysAdvice.setProductId(modelImageComment.getModelImageId());
|
|
||||||
sysAdvice.setProductType(2);
|
|
||||||
sysAdvice.setCommentId(modelImageComment.getId());
|
|
||||||
sysAdvice.setIsRead(0);
|
|
||||||
sysAdvice.setType(AdviceEnum.LIKE_REMIND);
|
|
||||||
adviceService.save(sysAdvice);
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
@ -1,122 +0,0 @@
|
||||||
package com.mcwl.resource.handler.impl;
|
|
||||||
|
|
||||||
import cn.hutool.json.JSON;
|
|
||||||
import cn.hutool.json.JSONUtil;
|
|
||||||
import com.mcwl.common.core.domain.entity.SysUser;
|
|
||||||
import com.mcwl.common.exception.ServiceException;
|
|
||||||
import com.mcwl.common.utils.SecurityUtils;
|
|
||||||
import com.mcwl.common.utils.StringUtils;
|
|
||||||
import com.mcwl.resource.domain.ModelImage;
|
|
||||||
import com.mcwl.resource.domain.ModelImageLike;
|
|
||||||
import com.mcwl.resource.domain.SysAdvice;
|
|
||||||
import com.mcwl.resource.handler.IMessageHandler;
|
|
||||||
import com.mcwl.resource.mapper.ModelImageLikeMapper;
|
|
||||||
import com.mcwl.resource.mapper.ModelImageMapper;
|
|
||||||
import com.mcwl.resource.mapper.WorkFlowLikeMapper;
|
|
||||||
import com.mcwl.resource.mapper.WorkFlowMapper;
|
|
||||||
import com.mcwl.resource.service.ISysAdviceService;
|
|
||||||
import com.mcwl.system.domain.enums.AdviceEnum;
|
|
||||||
import com.mcwl.system.service.ISysUserService;
|
|
||||||
import lombok.RequiredArgsConstructor;
|
|
||||||
import lombok.extern.slf4j.Slf4j;
|
|
||||||
import org.eclipse.paho.client.mqttv3.MqttMessage;
|
|
||||||
import org.springframework.stereotype.Component;
|
|
||||||
import org.springframework.transaction.annotation.Transactional;
|
|
||||||
|
|
||||||
import java.util.Objects;
|
|
||||||
|
|
||||||
@Slf4j
|
|
||||||
@Component
|
|
||||||
@IMessageHandler.Topic(value = "imageLike/#", qos = 1)
|
|
||||||
@RequiredArgsConstructor
|
|
||||||
public class ImageLikeHandler implements IMessageHandler {
|
|
||||||
|
|
||||||
|
|
||||||
private final ModelImageMapper modelImageMapper;
|
|
||||||
|
|
||||||
private final ModelImageLikeMapper modelImageLikeMapper;
|
|
||||||
|
|
||||||
private final ISysUserService userService;
|
|
||||||
|
|
||||||
private final ISysAdviceService adviceService;
|
|
||||||
|
|
||||||
@Override
|
|
||||||
@Transactional(rollbackFor = Exception.class)
|
|
||||||
public void handleMessage(String topic, MqttMessage message) {
|
|
||||||
String payload = new String(message.getPayload());
|
|
||||||
log.info("图片点赞: {}", payload);
|
|
||||||
|
|
||||||
JSON parse = JSONUtil.parse(payload);
|
|
||||||
Long commentId = Long.parseLong(parse.getByPath("commentId").toString());
|
|
||||||
Long userId = Long.parseLong(parse.getByPath("userId").toString());
|
|
||||||
|
|
||||||
this.like(userId, commentId);
|
|
||||||
}
|
|
||||||
|
|
||||||
private void like(Long userId, Long imageId) {
|
|
||||||
ModelImage modelImage = modelImageMapper.selectById(imageId);
|
|
||||||
if (Objects.isNull(modelImage)) {
|
|
||||||
throw new ServiceException("该图片不存在或已下架");
|
|
||||||
}
|
|
||||||
ModelImageLike modelImageLike = modelImageLikeMapper.getLikeImage(userId, imageId);
|
|
||||||
if (Objects.nonNull(modelImageLike)) {
|
|
||||||
if (Objects.equals(modelImageLike.getDelFlag(), "0")) {
|
|
||||||
modelImageLike.setDelFlag("2");
|
|
||||||
int likeNum = modelImage.getLikeNum() - 1;
|
|
||||||
likeNum = Math.max(likeNum, 0);
|
|
||||||
modelImage.setLikeNum(likeNum);
|
|
||||||
} else {
|
|
||||||
modelImageLike.setDelFlag("0");
|
|
||||||
modelImage.setLikeNum(modelImage.getLikeNum() + 1);
|
|
||||||
this.addLikeAdvice(modelImage, userId);
|
|
||||||
}
|
|
||||||
// 更新点赞记录
|
|
||||||
modelImageLikeMapper.updateDelFlagById(modelImageLike);
|
|
||||||
// 更新图片点赞数
|
|
||||||
modelImageMapper.updateById(modelImage);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
// 添加点赞记录
|
|
||||||
modelImageLike = new ModelImageLike();
|
|
||||||
modelImageLike.setUserId(userId);
|
|
||||||
modelImageLike.setModelImageId(imageId);
|
|
||||||
modelImageLikeMapper.insert(modelImageLike);
|
|
||||||
|
|
||||||
// 更新图片点赞数
|
|
||||||
modelImage.setLikeNum(modelImage.getLikeNum() + 1);
|
|
||||||
modelImageMapper.updateById(modelImage);
|
|
||||||
|
|
||||||
this.addLikeAdvice(modelImage, userId);
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
private void addLikeAdvice(ModelImage modelImage, Long userId) {
|
|
||||||
|
|
||||||
Long receiverUserId = modelImage.getUserId();
|
|
||||||
|
|
||||||
if (Objects.equals(userId, receiverUserId)) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
SysUser sysUser = userService.selectUserById(userId);
|
|
||||||
|
|
||||||
|
|
||||||
String content = StringUtils.format("恭喜！{}点赞了您的图片：{}",
|
|
||||||
sysUser.getNickName(), modelImage.getTitle());
|
|
||||||
|
|
||||||
SysAdvice sysAdvice = new SysAdvice();
|
|
||||||
sysAdvice.setSenderId(userId);
|
|
||||||
sysAdvice.setReceiverId(receiverUserId);
|
|
||||||
sysAdvice.setContent(content);
|
|
||||||
sysAdvice.setProductId(modelImage.getId());
|
|
||||||
sysAdvice.setProductType(2);
|
|
||||||
sysAdvice.setIsRead(0);
|
|
||||||
sysAdvice.setType(AdviceEnum.LIKE_REMIND);
|
|
||||||
adviceService.save(sysAdvice);
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
@ -1,121 +0,0 @@
|
||||||
package com.mcwl.resource.handler.impl;
|
|
||||||
|
|
||||||
import cn.hutool.json.JSON;
|
|
||||||
import cn.hutool.json.JSONUtil;
|
|
||||||
import com.mcwl.common.core.domain.entity.SysUser;
|
|
||||||
import com.mcwl.common.exception.ServiceException;
|
|
||||||
import com.mcwl.common.utils.SecurityUtils;
|
|
||||||
import com.mcwl.common.utils.StringUtils;
|
|
||||||
import com.mcwl.resource.domain.*;
|
|
||||||
import com.mcwl.resource.handler.IMessageHandler;
|
|
||||||
import com.mcwl.resource.mapper.ModelCommentLikeMapper;
|
|
||||||
import com.mcwl.resource.mapper.ModelCommentMapper;
|
|
||||||
import com.mcwl.resource.mapper.WorkFlowCommentLikeMapper;
|
|
||||||
import com.mcwl.resource.mapper.WorkFlowCommentMapper;
|
|
||||||
import com.mcwl.resource.service.ISysAdviceService;
|
|
||||||
import com.mcwl.system.domain.enums.AdviceEnum;
|
|
||||||
import com.mcwl.system.service.ISysUserService;
|
|
||||||
import lombok.RequiredArgsConstructor;
|
|
||||||
import lombok.extern.slf4j.Slf4j;
|
|
||||||
import org.eclipse.paho.client.mqttv3.MqttMessage;
|
|
||||||
import org.springframework.stereotype.Component;
|
|
||||||
import org.springframework.transaction.annotation.Transactional;
|
|
||||||
|
|
||||||
import java.util.Objects;
|
|
||||||
|
|
||||||
@Slf4j
|
|
||||||
@Component
|
|
||||||
@IMessageHandler.Topic(value = "modelCommentLike/#", qos = 1)
|
|
||||||
@RequiredArgsConstructor
|
|
||||||
public class ModelCommentLikeHandler implements IMessageHandler {
|
|
||||||
|
|
||||||
|
|
||||||
private final ModelCommentMapper modelCommentMapper;
|
|
||||||
|
|
||||||
private final ModelCommentLikeMapper modelCommentLikeMapper;
|
|
||||||
|
|
||||||
private final ISysUserService userService;
|
|
||||||
|
|
||||||
private final ISysAdviceService adviceService;
|
|
||||||
|
|
||||||
@Override
|
|
||||||
@Transactional(rollbackFor = Exception.class)
|
|
||||||
public void handleMessage(String topic, MqttMessage message) {
|
|
||||||
String payload = new String(message.getPayload());
|
|
||||||
log.info("模型评论点赞: {} - {}", payload, message);
|
|
||||||
|
|
||||||
JSON parse = JSONUtil.parse(payload);
|
|
||||||
Long commentId = Long.parseLong(parse.getByPath("commentId").toString());
|
|
||||||
Long userId = Long.parseLong(parse.getByPath("userId").toString());
|
|
||||||
|
|
||||||
|
|
||||||
this.like(userId, commentId);
|
|
||||||
}
|
|
||||||
|
|
||||||
private void like(Long userId, Long commentId) {
|
|
||||||
ModelComment modelComment = modelCommentMapper.selectById(commentId);
|
|
||||||
if (Objects.isNull(modelComment)) {
|
|
||||||
throw new ServiceException("该评论不存在");
|
|
||||||
}
|
|
||||||
ModelCommentLike modelCommentLike = modelCommentLikeMapper.getLikeComment(userId, commentId);
|
|
||||||
if (Objects.nonNull(modelCommentLike)) {
|
|
||||||
if (Objects.equals(modelCommentLike.getDelFlag(), "0")) {
|
|
||||||
modelCommentLike.setDelFlag("2");
|
|
||||||
int likeNum = modelComment.getLikeNum() - 1;
|
|
||||||
likeNum = Math.max(likeNum, 0);
|
|
||||||
modelComment.setLikeNum(likeNum);
|
|
||||||
} else {
|
|
||||||
modelCommentLike.setDelFlag("0");
|
|
||||||
modelComment.setLikeNum(modelComment.getLikeNum() + 1);
|
|
||||||
this.addLikeAdvice(modelComment, userId);
|
|
||||||
}
|
|
||||||
// 更新点赞记录
|
|
||||||
modelCommentLikeMapper.updateDelFlagById(modelCommentLike);
|
|
||||||
// 更新图片评论点赞数
|
|
||||||
modelCommentMapper.updateById(modelComment);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
// 添加点赞记录
|
|
||||||
modelCommentLike = new ModelCommentLike();
|
|
||||||
modelCommentLike.setUserId(userId);
|
|
||||||
modelCommentLike.setModelCommentId(commentId);
|
|
||||||
modelCommentLikeMapper.insert(modelCommentLike);
|
|
||||||
|
|
||||||
// 更新模型点赞数
|
|
||||||
modelComment.setLikeNum(modelComment.getLikeNum() + 1);
|
|
||||||
modelCommentMapper.updateById(modelComment);
|
|
||||||
|
|
||||||
this.addLikeAdvice(modelComment, userId);
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
private void addLikeAdvice(ModelComment modelComment, Long userId) {
|
|
||||||
|
|
||||||
Long receiverUserId = modelComment.getUserId();
|
|
||||||
|
|
||||||
if (Objects.equals(userId, receiverUserId)) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
SysUser sysUser = userService.selectUserById(userId);
|
|
||||||
|
|
||||||
String content = StringUtils.format("恭喜！{}点赞了您的评论",
|
|
||||||
sysUser.getNickName());
|
|
||||||
|
|
||||||
SysAdvice sysAdvice = new SysAdvice();
|
|
||||||
sysAdvice.setSenderId(userId);
|
|
||||||
sysAdvice.setReceiverId(receiverUserId);
|
|
||||||
sysAdvice.setContent(content);
|
|
||||||
sysAdvice.setProductId(modelComment.getModelId());
|
|
||||||
sysAdvice.setProductType(0);
|
|
||||||
sysAdvice.setCommentId(modelComment.getId());
|
|
||||||
sysAdvice.setIsRead(0);
|
|
||||||
sysAdvice.setType(AdviceEnum.LIKE_REMIND);
|
|
||||||
adviceService.save(sysAdvice);
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
@ -1,120 +0,0 @@
|
||||||
package com.mcwl.resource.handler.impl;
|
|
||||||
|
|
||||||
import cn.hutool.json.JSON;
|
|
||||||
import cn.hutool.json.JSONUtil;
|
|
||||||
import com.mcwl.common.core.domain.entity.SysUser;
|
|
||||||
import com.mcwl.common.exception.ServiceException;
|
|
||||||
import com.mcwl.common.utils.SecurityUtils;
|
|
||||||
import com.mcwl.common.utils.StringUtils;
|
|
||||||
import com.mcwl.resource.domain.*;
|
|
||||||
import com.mcwl.resource.handler.IMessageHandler;
|
|
||||||
import com.mcwl.resource.mapper.ModelLikeMapper;
|
|
||||||
import com.mcwl.resource.mapper.ModelMapper;
|
|
||||||
import com.mcwl.resource.mapper.WorkFlowLikeMapper;
|
|
||||||
import com.mcwl.resource.mapper.WorkFlowMapper;
|
|
||||||
import com.mcwl.resource.service.ISysAdviceService;
|
|
||||||
import com.mcwl.system.domain.enums.AdviceEnum;
|
|
||||||
import com.mcwl.system.service.ISysUserService;
|
|
||||||
import lombok.RequiredArgsConstructor;
|
|
||||||
import lombok.extern.slf4j.Slf4j;
|
|
||||||
import org.eclipse.paho.client.mqttv3.MqttMessage;
|
|
||||||
import org.springframework.stereotype.Component;
|
|
||||||
import org.springframework.transaction.annotation.Transactional;
|
|
||||||
|
|
||||||
import java.util.Objects;
|
|
||||||
|
|
||||||
@Slf4j
|
|
||||||
@Component
|
|
||||||
@IMessageHandler.Topic(value = "modelLike/#", qos = 1)
|
|
||||||
@RequiredArgsConstructor
|
|
||||||
public class ModelLikeHandler implements IMessageHandler {
|
|
||||||
|
|
||||||
private final ModelMapper modelMapper;
|
|
||||||
|
|
||||||
|
|
||||||
private final ModelLikeMapper modelLikeMapper;
|
|
||||||
|
|
||||||
private final ISysUserService userService;
|
|
||||||
|
|
||||||
private final ISysAdviceService adviceService;
|
|
||||||
|
|
||||||
|
|
||||||
@Override
|
|
||||||
@Transactional(rollbackFor = Exception.class)
|
|
||||||
public void handleMessage(String topic, MqttMessage message) {
|
|
||||||
String payload = new String(message.getPayload());
|
|
||||||
log.info("模型点赞: {}", payload);
|
|
||||||
|
|
||||||
JSON parse = JSONUtil.parse(payload);
|
|
||||||
Long commentId = Long.parseLong(parse.getByPath("commentId").toString());
|
|
||||||
Long userId = Long.parseLong(parse.getByPath("userId").toString());
|
|
||||||
|
|
||||||
|
|
||||||
this.like(userId, commentId);
|
|
||||||
}
|
|
||||||
|
|
||||||
private void like(Long userId, Long modelId) {
|
|
||||||
ModelProduct model = modelMapper.selectById(modelId);
|
|
||||||
if (Objects.isNull(model)) {
|
|
||||||
throw new ServiceException("该模型不存在或已下架");
|
|
||||||
}
|
|
||||||
ModelLike modelLike = modelLikeMapper.getLike(userId, modelId);
|
|
||||||
if (Objects.nonNull(modelLike)) {
|
|
||||||
if (Objects.equals(modelLike.getDelFlag(), "0")) {
|
|
||||||
modelLike.setDelFlag("2");
|
|
||||||
int likeNum = model.getLikeNum() - 1;
|
|
||||||
likeNum = Math.max(likeNum, 0);
|
|
||||||
model.setLikeNum(likeNum);
|
|
||||||
} else {
|
|
||||||
modelLike.setDelFlag("0");
|
|
||||||
model.setLikeNum(model.getLikeNum() + 1);
|
|
||||||
this.addLikeAdvice(model, userId);
|
|
||||||
}
|
|
||||||
// 更新点赞记录
|
|
||||||
modelLikeMapper.updateDelFlagById(modelLike);
|
|
||||||
// 更新图片点赞数
|
|
||||||
modelMapper.updateById(model);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
// 添加点赞记录
|
|
||||||
modelLike = new ModelLike();
|
|
||||||
modelLike.setUserId(userId);
|
|
||||||
modelLike.setModelId(modelId);
|
|
||||||
modelLikeMapper.insert(modelLike);
|
|
||||||
|
|
||||||
// 更新图片点赞数
|
|
||||||
model.setNumbers(model.getLikeNum() + 1);
|
|
||||||
modelMapper.updateById(model);
|
|
||||||
|
|
||||||
this.addLikeAdvice(model, userId);
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
private void addLikeAdvice(ModelProduct model, Long userId) {
|
|
||||||
|
|
||||||
Long receiverUserId = model.getUserId();
|
|
||||||
|
|
||||||
if (Objects.equals(userId, receiverUserId)) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
SysUser sysUser = userService.selectUserById(userId);
|
|
||||||
|
|
||||||
String content = StringUtils.format("恭喜！{}点赞了您的模型：{}",
|
|
||||||
sysUser.getNickName(), model.getModelName());
|
|
||||||
|
|
||||||
SysAdvice sysAdvice = new SysAdvice();
|
|
||||||
sysAdvice.setSenderId(userId);
|
|
||||||
sysAdvice.setReceiverId(receiverUserId);
|
|
||||||
sysAdvice.setContent(content);
|
|
||||||
sysAdvice.setProductId(model.getId());
|
|
||||||
sysAdvice.setProductType(0);
|
|
||||||
sysAdvice.setIsRead(0);
|
|
||||||
sysAdvice.setType(AdviceEnum.LIKE_REMIND);
|
|
||||||
adviceService.save(sysAdvice);
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
@ -1,124 +0,0 @@
|
||||||
package com.mcwl.resource.handler.impl;
|
|
||||||
|
|
||||||
import cn.hutool.json.JSON;
|
|
||||||
import cn.hutool.json.JSONUtil;
|
|
||||||
import com.mcwl.common.core.domain.entity.SysUser;
|
|
||||||
import com.mcwl.common.exception.ServiceException;
|
|
||||||
import com.mcwl.common.utils.SecurityUtils;
|
|
||||||
import com.mcwl.common.utils.StringUtils;
|
|
||||||
import com.mcwl.resource.domain.SysAdvice;
|
|
||||||
import com.mcwl.resource.domain.WorkFlowComment;
|
|
||||||
import com.mcwl.resource.domain.WorkFlowCommentLike;
|
|
||||||
import com.mcwl.resource.handler.IMessageHandler;
|
|
||||||
import com.mcwl.resource.mapper.WorkFlowCommentLikeMapper;
|
|
||||||
import com.mcwl.resource.mapper.WorkFlowCommentMapper;
|
|
||||||
import com.mcwl.resource.service.ISysAdviceService;
|
|
||||||
import com.mcwl.system.domain.enums.AdviceEnum;
|
|
||||||
import com.mcwl.system.service.ISysUserService;
|
|
||||||
import lombok.RequiredArgsConstructor;
|
|
||||||
import lombok.extern.slf4j.Slf4j;
|
|
||||||
import org.eclipse.paho.client.mqttv3.MqttMessage;
|
|
||||||
import org.springframework.stereotype.Component;
|
|
||||||
import org.springframework.transaction.annotation.Transactional;
|
|
||||||
|
|
||||||
import java.util.Objects;
|
|
||||||
|
|
||||||
@Slf4j
|
|
||||||
@Component
|
|
||||||
@IMessageHandler.Topic(value = "workFlowCommentLike/#", qos = 1)
|
|
||||||
@RequiredArgsConstructor
|
|
||||||
public class WorkFlowCommentLikeHandler implements IMessageHandler {
|
|
||||||
|
|
||||||
|
|
||||||
private final WorkFlowCommentMapper workFlowCommentMapper;
|
|
||||||
|
|
||||||
|
|
||||||
private final WorkFlowCommentLikeMapper workFlowCommentLikeMapper;
|
|
||||||
|
|
||||||
private final ISysUserService userService;
|
|
||||||
|
|
||||||
private final ISysAdviceService adviceService;
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
@Override
|
|
||||||
@Transactional(rollbackFor = Exception.class)
|
|
||||||
public void handleMessage(String topic, MqttMessage message) {
|
|
||||||
String payload = new String(message.getPayload());
|
|
||||||
log.info("工作流评论点赞: {} - {}", topic, payload);
|
|
||||||
|
|
||||||
JSON parse = JSONUtil.parse(payload);
|
|
||||||
Long commentId = Long.parseLong(parse.getByPath("commentId").toString());
|
|
||||||
Long userId = Long.parseLong(parse.getByPath("userId").toString());
|
|
||||||
|
|
||||||
|
|
||||||
this.like(userId, commentId);
|
|
||||||
}
|
|
||||||
|
|
||||||
private void like(Long userId, Long commentId) {
|
|
||||||
WorkFlowComment workFlowComment = workFlowCommentMapper.selectById(commentId);
|
|
||||||
if (Objects.isNull(workFlowComment)) {
|
|
||||||
throw new ServiceException("该评论不存在");
|
|
||||||
}
|
|
||||||
WorkFlowCommentLike workFlowCommentLike = workFlowCommentLikeMapper.getLikeComment(userId, commentId);
|
|
||||||
if (Objects.nonNull(workFlowCommentLike)) {
|
|
||||||
if (Objects.equals(workFlowCommentLike.getDelFlag(), "0")) {
|
|
||||||
workFlowCommentLike.setDelFlag("2");
|
|
||||||
int likeNum = workFlowComment.getLikeNum() - 1;
|
|
||||||
likeNum = Math.max(likeNum, 0);
|
|
||||||
workFlowComment.setLikeNum(likeNum);
|
|
||||||
} else {
|
|
||||||
workFlowCommentLike.setDelFlag("0");
|
|
||||||
workFlowComment.setLikeNum(workFlowComment.getLikeNum() + 1);
|
|
||||||
this.addLikeAdvice(workFlowComment, userId);
|
|
||||||
}
|
|
||||||
// 更新点赞记录
|
|
||||||
workFlowCommentLikeMapper.updateDelFlagById(workFlowCommentLike);
|
|
||||||
// 更新图片评论点赞数
|
|
||||||
workFlowCommentMapper.updateById(workFlowComment);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
// 添加点赞记录
|
|
||||||
workFlowCommentLike = new WorkFlowCommentLike();
|
|
||||||
workFlowCommentLike.setUserId(userId);
|
|
||||||
workFlowCommentLike.setWorkFlowCommentId(commentId);
|
|
||||||
workFlowCommentLikeMapper.insert(workFlowCommentLike);
|
|
||||||
|
|
||||||
// 更新模型点赞数
|
|
||||||
workFlowComment.setLikeNum(workFlowComment.getLikeNum() + 1);
|
|
||||||
workFlowCommentMapper.updateById(workFlowComment);
|
|
||||||
|
|
||||||
this.addLikeAdvice(workFlowComment, userId);
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
private void addLikeAdvice(WorkFlowComment workFlowComment, Long userId) {
|
|
||||||
|
|
||||||
Long receiverUserId = workFlowComment.getUserId();
|
|
||||||
|
|
||||||
if (Objects.equals(userId, receiverUserId)) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
SysUser sysUser = userService.selectUserById(userId);
|
|
||||||
|
|
||||||
String content = StringUtils.format("恭喜！{}点赞了您的评论",
|
|
||||||
sysUser.getNickName());
|
|
||||||
|
|
||||||
SysAdvice sysAdvice = new SysAdvice();
|
|
||||||
sysAdvice.setSenderId(userId);
|
|
||||||
sysAdvice.setReceiverId(receiverUserId);
|
|
||||||
sysAdvice.setContent(content);
|
|
||||||
sysAdvice.setProductId(workFlowComment.getWorkFlowId());
|
|
||||||
sysAdvice.setProductType(1);
|
|
||||||
sysAdvice.setCommentId(workFlowComment.getId());
|
|
||||||
sysAdvice.setIsRead(0);
|
|
||||||
sysAdvice.setType(AdviceEnum.LIKE_REMIND);
|
|
||||||
adviceService.save(sysAdvice);
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
@ -1,118 +0,0 @@
|
||||||
package com.mcwl.resource.handler.impl;
|
|
||||||
|
|
||||||
import cn.hutool.json.JSON;
|
|
||||||
import cn.hutool.json.JSONUtil;
|
|
||||||
import com.mcwl.common.core.domain.entity.SysUser;
|
|
||||||
import com.mcwl.common.exception.ServiceException;
|
|
||||||
import com.mcwl.common.utils.SecurityUtils;
|
|
||||||
import com.mcwl.common.utils.StringUtils;
|
|
||||||
import com.mcwl.resource.domain.SysAdvice;
|
|
||||||
import com.mcwl.resource.domain.WorkFlow;
|
|
||||||
import com.mcwl.resource.domain.WorkFlowLike;
|
|
||||||
import com.mcwl.resource.handler.IMessageHandler;
|
|
||||||
import com.mcwl.resource.mapper.WorkFlowLikeMapper;
|
|
||||||
import com.mcwl.resource.mapper.WorkFlowMapper;
|
|
||||||
import com.mcwl.resource.service.ISysAdviceService;
|
|
||||||
import com.mcwl.system.domain.enums.AdviceEnum;
|
|
||||||
import com.mcwl.system.service.ISysUserService;
|
|
||||||
import lombok.RequiredArgsConstructor;
|
|
||||||
import lombok.extern.slf4j.Slf4j;
|
|
||||||
import org.eclipse.paho.client.mqttv3.MqttMessage;
|
|
||||||
import org.springframework.stereotype.Component;
|
|
||||||
import org.springframework.transaction.annotation.Transactional;
|
|
||||||
|
|
||||||
import java.util.Objects;
|
|
||||||
|
|
||||||
@Slf4j
|
|
||||||
@Component
|
|
||||||
@IMessageHandler.Topic(value = "workFlowLike/#", qos = 1)
|
|
||||||
@RequiredArgsConstructor
|
|
||||||
public class WorkFlowLikeHandler implements IMessageHandler {
|
|
||||||
|
|
||||||
private final WorkFlowMapper workFlowMapper;
|
|
||||||
|
|
||||||
private final WorkFlowLikeMapper workFlowLikeMapper;
|
|
||||||
|
|
||||||
private final ISysUserService userService;
|
|
||||||
|
|
||||||
private final ISysAdviceService adviceService;
|
|
||||||
|
|
||||||
@Override
|
|
||||||
@Transactional(rollbackFor = Exception.class)
|
|
||||||
public void handleMessage(String topic, MqttMessage message) {
|
|
||||||
String payload = new String(message.getPayload());
|
|
||||||
log.info("工作流点赞: {} - {}", topic, payload);
|
|
||||||
|
|
||||||
JSON parse = JSONUtil.parse(payload);
|
|
||||||
Long commentId = Long.parseLong(parse.getByPath("commentId").toString());
|
|
||||||
Long userId = Long.parseLong(parse.getByPath("userId").toString());
|
|
||||||
|
|
||||||
|
|
||||||
this.like(userId, commentId);
|
|
||||||
}
|
|
||||||
|
|
||||||
private void like(Long userId, Long modelId) {
|
|
||||||
WorkFlow workFlow = workFlowMapper.selectById(modelId);
|
|
||||||
if (Objects.isNull(workFlow)) {
|
|
||||||
throw new ServiceException("该工作流不存在或已下架");
|
|
||||||
}
|
|
||||||
WorkFlowLike workFlowLike = workFlowLikeMapper.getLike(userId, modelId);
|
|
||||||
if (Objects.nonNull(workFlowLike)) {
|
|
||||||
if (Objects.equals(workFlowLike.getDelFlag(), "0")) {
|
|
||||||
workFlowLike.setDelFlag("2");
|
|
||||||
int likeCount = workFlow.getLikeNum() - 1;
|
|
||||||
likeCount = Math.max(likeCount, 0);
|
|
||||||
workFlow.setLikeNum(likeCount);
|
|
||||||
} else {
|
|
||||||
workFlowLike.setDelFlag("0");
|
|
||||||
workFlow.setLikeNum(workFlow.getLikeNum() + 1);
|
|
||||||
this.addLikeAdvice(workFlow, userId);
|
|
||||||
}
|
|
||||||
// 更新点赞记录
|
|
||||||
workFlowLikeMapper.updateStatus(workFlowLike);
|
|
||||||
// 更新图片点赞数
|
|
||||||
workFlowMapper.updateById(workFlow);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
// 添加点赞记录
|
|
||||||
workFlowLike = new WorkFlowLike();
|
|
||||||
workFlowLike.setUserId(userId);
|
|
||||||
workFlowLike.setWorkFlowId(modelId);
|
|
||||||
workFlowLikeMapper.insert(workFlowLike);
|
|
||||||
|
|
||||||
// 更新图片点赞数
|
|
||||||
workFlow.setLikeNum(workFlow.getLikeNum() + 1);
|
|
||||||
workFlowMapper.updateById(workFlow);
|
|
||||||
|
|
||||||
this.addLikeAdvice(workFlow, userId);
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
private void addLikeAdvice(WorkFlow workFlow, Long userId) {
|
|
||||||
|
|
||||||
Long receiverUserId = workFlow.getUserId();
|
|
||||||
|
|
||||||
if (Objects.equals(userId, receiverUserId)) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
SysUser sysUser = userService.selectUserById(userId);
|
|
||||||
|
|
||||||
String content = StringUtils.format("恭喜！{}点赞了您的工作流：{}",
|
|
||||||
sysUser.getNickName(), workFlow.getWorkflowName());
|
|
||||||
|
|
||||||
SysAdvice sysAdvice = new SysAdvice();
|
|
||||||
sysAdvice.setSenderId(userId);
|
|
||||||
sysAdvice.setReceiverId(receiverUserId);
|
|
||||||
sysAdvice.setContent(content);
|
|
||||||
sysAdvice.setProductId(workFlow.getId());
|
|
||||||
sysAdvice.setProductType(1);
|
|
||||||
sysAdvice.setIsRead(0);
|
|
||||||
sysAdvice.setType(AdviceEnum.LIKE_REMIND);
|
|
||||||
adviceService.save(sysAdvice);
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
@ -1,18 +1,22 @@
|
||||||
package com.mcwl.resource.service.impl;
|
package com.mcwl.resource.service.impl;
|
||||||
|
|
||||||
import cn.hutool.json.JSONUtil;
|
|
||||||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
||||||
|
import com.mcwl.common.exception.ServiceException;
|
||||||
import com.mcwl.common.utils.SecurityUtils;
|
import com.mcwl.common.utils.SecurityUtils;
|
||||||
|
import com.mcwl.common.utils.StringUtils;
|
||||||
|
import com.mcwl.resource.domain.ModelComment;
|
||||||
import com.mcwl.resource.domain.ModelCommentLike;
|
import com.mcwl.resource.domain.ModelCommentLike;
|
||||||
|
import com.mcwl.resource.domain.SysAdvice;
|
||||||
import com.mcwl.resource.mapper.ModelCommentLikeMapper;
|
import com.mcwl.resource.mapper.ModelCommentLikeMapper;
|
||||||
|
import com.mcwl.resource.mapper.ModelCommentMapper;
|
||||||
import com.mcwl.resource.service.ModelCommentLikeService;
|
import com.mcwl.resource.service.ModelCommentLikeService;
|
||||||
import com.mcwl.resource.util.MqttTemplate;
|
import com.mcwl.system.domain.enums.AdviceEnum;
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
import org.springframework.stereotype.Service;
|
import org.springframework.stereotype.Service;
|
||||||
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.transaction.annotation.Transactional;
|
||||||
|
|
||||||
import java.util.HashMap;
|
import java.util.Date;
|
||||||
import java.util.Map;
|
import java.util.Objects;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 模型评论点赞
|
* 模型评论点赞
|
||||||
|
|
@ -21,14 +25,72 @@ import java.util.Map;
|
||||||
public class ModelCommentLikeServiceImpl extends ServiceImpl<ModelCommentLikeMapper, ModelCommentLike> implements ModelCommentLikeService {
|
public class ModelCommentLikeServiceImpl extends ServiceImpl<ModelCommentLikeMapper, ModelCommentLike> implements ModelCommentLikeService {
|
||||||
|
|
||||||
@Autowired
|
@Autowired
|
||||||
private MqttTemplate mqttTemplate;
|
private ModelCommentMapper modelCommentMapper;
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
@Transactional
|
||||||
public void like(Long commentId) {
|
public void like(Long commentId) {
|
||||||
Map<String, Long> map = new HashMap<>();
|
ModelComment modelComment = modelCommentMapper.selectById(commentId);
|
||||||
map.put("userId", SecurityUtils.getUserId());
|
if (Objects.isNull(modelComment)) {
|
||||||
map.put("commentId", commentId);
|
throw new ServiceException("该评论不存在");
|
||||||
mqttTemplate.publish("modelCommentLike", JSONUtil.toJsonStr(map), 0);
|
}
|
||||||
|
Long userId = SecurityUtils.getUserId();
|
||||||
|
ModelCommentLike modelCommentLike = baseMapper.getLikeComment(userId, commentId);
|
||||||
|
if (Objects.nonNull(modelCommentLike)) {
|
||||||
|
if (Objects.equals(modelCommentLike.getDelFlag(), "0")) {
|
||||||
|
modelCommentLike.setDelFlag("2");
|
||||||
|
int likeNum = modelComment.getLikeNum() - 1;
|
||||||
|
likeNum = Math.max(likeNum, 0);
|
||||||
|
modelComment.setLikeNum(likeNum);
|
||||||
|
} else {
|
||||||
|
modelCommentLike.setDelFlag("0");
|
||||||
|
modelComment.setLikeNum(modelComment.getLikeNum() + 1);
|
||||||
|
this.addLikeAdvice(modelComment);
|
||||||
|
}
|
||||||
|
// 更新点赞记录
|
||||||
|
baseMapper.updateDelFlagById(modelCommentLike);
|
||||||
|
// 更新图片评论点赞数
|
||||||
|
modelCommentMapper.updateById(modelComment);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
// 添加点赞记录
|
||||||
|
modelCommentLike = new ModelCommentLike();
|
||||||
|
modelCommentLike.setUserId(userId);
|
||||||
|
modelCommentLike.setModelCommentId(commentId);
|
||||||
|
baseMapper.insert(modelCommentLike);
|
||||||
|
|
||||||
|
// 更新模型点赞数
|
||||||
|
modelComment.setLikeNum(modelComment.getLikeNum() + 1);
|
||||||
|
modelCommentMapper.updateById(modelComment);
|
||||||
|
|
||||||
|
this.addLikeAdvice(modelComment);
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
private void addLikeAdvice(ModelComment modelComment) {
|
||||||
|
|
||||||
|
Long userId = SecurityUtils.getUserId();
|
||||||
|
Long receiverUserId = modelComment.getUserId();
|
||||||
|
|
||||||
|
if (Objects.equals(userId, receiverUserId)) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
String content = StringUtils.format("恭喜！{}点赞了您的评论",
|
||||||
|
SecurityUtils.getLoginUser().getUser().getNickName());
|
||||||
|
|
||||||
|
SysAdvice sysAdvice = new SysAdvice();
|
||||||
|
sysAdvice.setSenderId(userId);
|
||||||
|
sysAdvice.setReceiverId(receiverUserId);
|
||||||
|
sysAdvice.setContent(content);
|
||||||
|
sysAdvice.setProductId(modelComment.getModelId());
|
||||||
|
sysAdvice.setProductType(0);
|
||||||
|
sysAdvice.setCommentId(modelComment.getId());
|
||||||
|
sysAdvice.setIsRead(0);
|
||||||
|
sysAdvice.setType(AdviceEnum.LIKE_REMIND);
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -1,19 +1,22 @@
|
||||||
package com.mcwl.resource.service.impl;
|
package com.mcwl.resource.service.impl;
|
||||||
|
|
||||||
import cn.hutool.json.JSONUtil;
|
|
||||||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
||||||
|
import com.mcwl.common.exception.ServiceException;
|
||||||
import com.mcwl.common.utils.SecurityUtils;
|
import com.mcwl.common.utils.SecurityUtils;
|
||||||
|
import com.mcwl.common.utils.StringUtils;
|
||||||
|
import com.mcwl.resource.domain.ModelImageComment;
|
||||||
import com.mcwl.resource.domain.ModelImageCommentLike;
|
import com.mcwl.resource.domain.ModelImageCommentLike;
|
||||||
|
import com.mcwl.resource.domain.SysAdvice;
|
||||||
import com.mcwl.resource.mapper.ModelImageCommentLikeMapper;
|
import com.mcwl.resource.mapper.ModelImageCommentLikeMapper;
|
||||||
|
import com.mcwl.resource.mapper.ModelImageCommentMapper;
|
||||||
import com.mcwl.resource.service.ModelImageCommentLikeService;
|
import com.mcwl.resource.service.ModelImageCommentLikeService;
|
||||||
import com.mcwl.resource.util.MqttTemplate;
|
import com.mcwl.system.domain.enums.AdviceEnum;
|
||||||
import lombok.RequiredArgsConstructor;
|
import lombok.RequiredArgsConstructor;
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
|
||||||
import org.springframework.stereotype.Service;
|
import org.springframework.stereotype.Service;
|
||||||
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.transaction.annotation.Transactional;
|
||||||
|
|
||||||
import java.util.HashMap;
|
import java.util.Date;
|
||||||
import java.util.Map;
|
import java.util.Objects;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 图片评论点赞
|
* 图片评论点赞
|
||||||
|
|
@ -22,15 +25,72 @@ import java.util.Map;
|
||||||
@RequiredArgsConstructor
|
@RequiredArgsConstructor
|
||||||
public class ModelImageCommentLikeServiceImpl extends ServiceImpl<ModelImageCommentLikeMapper, ModelImageCommentLike> implements ModelImageCommentLikeService {
|
public class ModelImageCommentLikeServiceImpl extends ServiceImpl<ModelImageCommentLikeMapper, ModelImageCommentLike> implements ModelImageCommentLikeService {
|
||||||
|
|
||||||
@Autowired
|
private final ModelImageCommentMapper modelImageCommentMapper;
|
||||||
private MqttTemplate mqttTemplate;
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
@Transactional
|
||||||
public void like(Long commentId) {
|
public void like(Long commentId) {
|
||||||
Map<String, Long> map = new HashMap<>();
|
ModelImageComment modelImageComment = modelImageCommentMapper.selectById(commentId);
|
||||||
map.put("userId", SecurityUtils.getUserId());
|
if (Objects.isNull(modelImageComment)) {
|
||||||
map.put("commentId", commentId);
|
throw new ServiceException("该评论不存在");
|
||||||
mqttTemplate.publish("imageCommentLike", JSONUtil.toJsonStr(map),0);
|
}
|
||||||
|
Long userId = SecurityUtils.getUserId();
|
||||||
|
ModelImageCommentLike modelImageCommentLike = baseMapper.getLikeImageComment(userId, commentId);
|
||||||
|
if (Objects.nonNull(modelImageCommentLike)) {
|
||||||
|
if (Objects.equals(modelImageCommentLike.getDelFlag(), "0")) {
|
||||||
|
modelImageCommentLike.setDelFlag("2");
|
||||||
|
int likeNum = modelImageComment.getLikeNum() - 1;
|
||||||
|
likeNum = Math.max(likeNum, 0);
|
||||||
|
modelImageComment.setLikeNum(likeNum);
|
||||||
|
} else {
|
||||||
|
modelImageCommentLike.setDelFlag("0");
|
||||||
|
modelImageComment.setLikeNum(modelImageComment.getLikeNum() + 1);
|
||||||
|
this.addLikeAdvice(modelImageComment);
|
||||||
|
}
|
||||||
|
// 更新点赞记录
|
||||||
|
baseMapper.updateDelFlagById(modelImageCommentLike);
|
||||||
|
// 更新图片评论点赞数
|
||||||
|
modelImageCommentMapper.updateById(modelImageComment);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
// 添加点赞记录
|
||||||
|
modelImageCommentLike = new ModelImageCommentLike();
|
||||||
|
modelImageCommentLike.setUserId(userId);
|
||||||
|
modelImageCommentLike.setModelImageCommentId(commentId);
|
||||||
|
baseMapper.insert(modelImageCommentLike);
|
||||||
|
|
||||||
|
// 更新图片点赞数
|
||||||
|
modelImageComment.setLikeNum(modelImageComment.getLikeNum() + 1);
|
||||||
|
modelImageCommentMapper.updateById(modelImageComment);
|
||||||
|
|
||||||
|
this.addLikeAdvice(modelImageComment);
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
private void addLikeAdvice(ModelImageComment modelImageComment) {
|
||||||
|
|
||||||
|
Long userId = SecurityUtils.getUserId();
|
||||||
|
Long receiverUserId = modelImageComment.getUserId();
|
||||||
|
|
||||||
|
if (Objects.equals(userId, receiverUserId)) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
String content = StringUtils.format("恭喜！{}点赞了您的评论",
|
||||||
|
SecurityUtils.getLoginUser().getUser().getNickName());
|
||||||
|
|
||||||
|
SysAdvice sysAdvice = new SysAdvice();
|
||||||
|
sysAdvice.setSenderId(userId);
|
||||||
|
sysAdvice.setReceiverId(receiverUserId);
|
||||||
|
sysAdvice.setContent(content);
|
||||||
|
sysAdvice.setProductId(modelImageComment.getModelImageId());
|
||||||
|
sysAdvice.setProductType(2);
|
||||||
|
sysAdvice.setCommentId(modelImageComment.getId());
|
||||||
|
sysAdvice.setIsRead(0);
|
||||||
|
sysAdvice.setType(AdviceEnum.LIKE_REMIND);
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -1,7 +1,6 @@
|
||||||
package com.mcwl.resource.service.impl;
|
package com.mcwl.resource.service.impl;
|
||||||
|
|
||||||
import cn.hutool.core.bean.BeanUtil;
|
import cn.hutool.core.bean.BeanUtil;
|
||||||
import cn.hutool.json.JSONUtil;
|
|
||||||
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
||||||
import com.baomidou.mybatisplus.core.metadata.OrderItem;
|
import com.baomidou.mybatisplus.core.metadata.OrderItem;
|
||||||
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
||||||
|
|
@ -12,6 +11,7 @@ import com.mcwl.common.constant.HttpStatus;
|
||||||
import com.mcwl.common.core.domain.entity.SysUser;
|
import com.mcwl.common.core.domain.entity.SysUser;
|
||||||
import com.mcwl.common.core.page.PageDomain;
|
import com.mcwl.common.core.page.PageDomain;
|
||||||
import com.mcwl.common.core.page.TableDataInfo;
|
import com.mcwl.common.core.page.TableDataInfo;
|
||||||
|
import com.mcwl.common.exception.ServiceException;
|
||||||
import com.mcwl.common.utils.SecurityUtils;
|
import com.mcwl.common.utils.SecurityUtils;
|
||||||
import com.mcwl.common.utils.StringUtils;
|
import com.mcwl.common.utils.StringUtils;
|
||||||
import com.mcwl.resource.domain.ModelImage;
|
import com.mcwl.resource.domain.ModelImage;
|
||||||
|
|
@ -23,14 +23,16 @@ import com.mcwl.resource.domain.vo.PageVo;
|
||||||
import com.mcwl.resource.mapper.ModelImageLikeMapper;
|
import com.mcwl.resource.mapper.ModelImageLikeMapper;
|
||||||
import com.mcwl.resource.mapper.ModelImageMapper;
|
import com.mcwl.resource.mapper.ModelImageMapper;
|
||||||
import com.mcwl.resource.service.ModelImageLikeService;
|
import com.mcwl.resource.service.ModelImageLikeService;
|
||||||
import com.mcwl.resource.util.MqttTemplate;
|
|
||||||
import com.mcwl.system.domain.enums.AdviceEnum;
|
import com.mcwl.system.domain.enums.AdviceEnum;
|
||||||
import com.mcwl.system.service.ISysUserService;
|
import com.mcwl.system.service.ISysUserService;
|
||||||
import lombok.RequiredArgsConstructor;
|
import lombok.RequiredArgsConstructor;
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
|
||||||
import org.springframework.stereotype.Service;
|
import org.springframework.stereotype.Service;
|
||||||
|
import org.springframework.transaction.annotation.Transactional;
|
||||||
|
|
||||||
import java.util.*;
|
import java.util.ArrayList;
|
||||||
|
import java.util.Date;
|
||||||
|
import java.util.List;
|
||||||
|
import java.util.Objects;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 图片点赞实现
|
* 图片点赞实现
|
||||||
|
|
@ -43,15 +45,44 @@ public class ModelImageLikeServiceImpl extends ServiceImpl<ModelImageLikeMapper,
|
||||||
|
|
||||||
private final ISysUserService sysUserService;
|
private final ISysUserService sysUserService;
|
||||||
|
|
||||||
@Autowired
|
|
||||||
private MqttTemplate mqttTemplate;
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
@Transactional
|
||||||
public void like(Long imageId) {
|
public void like(Long imageId) {
|
||||||
Map<String, Long> map = new HashMap<>();
|
ModelImage modelImage = modelImageMapper.selectById(imageId);
|
||||||
map.put("userId", SecurityUtils.getUserId());
|
if (Objects.isNull(modelImage)) {
|
||||||
map.put("commentId", imageId);
|
throw new ServiceException("该图片不存在或已下架");
|
||||||
mqttTemplate.publish("imageLike", JSONUtil.toJsonStr(map),0);
|
}
|
||||||
|
Long userId = SecurityUtils.getUserId();
|
||||||
|
ModelImageLike modelImageLike = baseMapper.getLikeImage(userId, imageId);
|
||||||
|
if (Objects.nonNull(modelImageLike)) {
|
||||||
|
if (Objects.equals(modelImageLike.getDelFlag(), "0")) {
|
||||||
|
modelImageLike.setDelFlag("2");
|
||||||
|
int likeNum = modelImage.getLikeNum() - 1;
|
||||||
|
likeNum = Math.max(likeNum, 0);
|
||||||
|
modelImage.setLikeNum(likeNum);
|
||||||
|
} else {
|
||||||
|
modelImageLike.setDelFlag("0");
|
||||||
|
modelImage.setLikeNum(modelImage.getLikeNum() + 1);
|
||||||
|
this.addLikeAdvice(modelImage);
|
||||||
|
}
|
||||||
|
// 更新点赞记录
|
||||||
|
baseMapper.updateDelFlagById(modelImageLike);
|
||||||
|
// 更新图片点赞数
|
||||||
|
modelImageMapper.updateById(modelImage);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
// 添加点赞记录
|
||||||
|
modelImageLike = new ModelImageLike();
|
||||||
|
modelImageLike.setUserId(userId);
|
||||||
|
modelImageLike.setModelImageId(imageId);
|
||||||
|
baseMapper.insert(modelImageLike);
|
||||||
|
|
||||||
|
// 更新图片点赞数
|
||||||
|
modelImage.setLikeNum(modelImage.getLikeNum() + 1);
|
||||||
|
modelImageMapper.updateById(modelImage);
|
||||||
|
|
||||||
|
this.addLikeAdvice(modelImage);
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|
|
||||||
|
|
@ -1,7 +1,6 @@
|
||||||
package com.mcwl.resource.service.impl;
|
package com.mcwl.resource.service.impl;
|
||||||
|
|
||||||
import cn.hutool.core.bean.BeanUtil;
|
import cn.hutool.core.bean.BeanUtil;
|
||||||
import cn.hutool.json.JSONUtil;
|
|
||||||
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
||||||
import com.baomidou.mybatisplus.core.metadata.OrderItem;
|
import com.baomidou.mybatisplus.core.metadata.OrderItem;
|
||||||
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
||||||
|
|
@ -10,20 +9,26 @@ import com.mcwl.common.constant.HttpStatus;
|
||||||
import com.mcwl.common.core.domain.entity.SysUser;
|
import com.mcwl.common.core.domain.entity.SysUser;
|
||||||
import com.mcwl.common.core.page.PageDomain;
|
import com.mcwl.common.core.page.PageDomain;
|
||||||
import com.mcwl.common.core.page.TableDataInfo;
|
import com.mcwl.common.core.page.TableDataInfo;
|
||||||
|
import com.mcwl.common.exception.ServiceException;
|
||||||
import com.mcwl.common.utils.SecurityUtils;
|
import com.mcwl.common.utils.SecurityUtils;
|
||||||
import com.mcwl.common.utils.StringUtils;
|
import com.mcwl.common.utils.StringUtils;
|
||||||
import com.mcwl.resource.domain.ModelLike;
|
import com.mcwl.resource.domain.ModelLike;
|
||||||
import com.mcwl.resource.domain.ModelProduct;
|
import com.mcwl.resource.domain.ModelProduct;
|
||||||
|
import com.mcwl.resource.domain.SysAdvice;
|
||||||
import com.mcwl.resource.domain.vo.ModelLikeVo;
|
import com.mcwl.resource.domain.vo.ModelLikeVo;
|
||||||
import com.mcwl.resource.mapper.ModelLikeMapper;
|
import com.mcwl.resource.mapper.ModelLikeMapper;
|
||||||
import com.mcwl.resource.mapper.ModelMapper;
|
import com.mcwl.resource.mapper.ModelMapper;
|
||||||
import com.mcwl.resource.service.ModelLikeService;
|
import com.mcwl.resource.service.ModelLikeService;
|
||||||
import com.mcwl.resource.util.MqttTemplate;
|
import com.mcwl.system.domain.enums.AdviceEnum;
|
||||||
import com.mcwl.system.service.ISysUserService;
|
import com.mcwl.system.service.ISysUserService;
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
import org.springframework.stereotype.Service;
|
import org.springframework.stereotype.Service;
|
||||||
|
import org.springframework.transaction.annotation.Transactional;
|
||||||
|
|
||||||
import java.util.*;
|
import java.util.ArrayList;
|
||||||
|
import java.util.Date;
|
||||||
|
import java.util.List;
|
||||||
|
import java.util.Objects;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 模型点赞
|
* 模型点赞
|
||||||
|
|
@ -38,16 +43,45 @@ public class ModelLikeServiceImpl extends ServiceImpl<ModelLikeMapper, ModelLike
|
||||||
@Autowired
|
@Autowired
|
||||||
private ISysUserService sysUserService;
|
private ISysUserService sysUserService;
|
||||||
|
|
||||||
@Autowired
|
|
||||||
private MqttTemplate mqttTemplate;
|
|
||||||
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
@Transactional(rollbackFor = Exception.class)
|
||||||
public void like(Long modelId) {
|
public void like(Long modelId) {
|
||||||
Map<String, Long> map = new HashMap<>();
|
ModelProduct model = modelMapper.selectById(modelId);
|
||||||
map.put("userId", SecurityUtils.getUserId());
|
if (Objects.isNull(model)) {
|
||||||
map.put("commentId", modelId);
|
throw new ServiceException("该模型不存在或已下架");
|
||||||
mqttTemplate.publish("modelLike", JSONUtil.toJsonStr(map),0);
|
}
|
||||||
|
Long userId = SecurityUtils.getUserId();
|
||||||
|
ModelLike modelLike = baseMapper.getLike(userId, modelId);
|
||||||
|
if (Objects.nonNull(modelLike)) {
|
||||||
|
if (Objects.equals(modelLike.getDelFlag(), "0")) {
|
||||||
|
modelLike.setDelFlag("2");
|
||||||
|
int likeNum = model.getLikeNum() - 1;
|
||||||
|
likeNum = Math.max(likeNum, 0);
|
||||||
|
model.setLikeNum(likeNum);
|
||||||
|
} else {
|
||||||
|
modelLike.setDelFlag("0");
|
||||||
|
model.setLikeNum(model.getLikeNum() + 1);
|
||||||
|
this.addLikeAdvice(model);
|
||||||
|
}
|
||||||
|
// 更新点赞记录
|
||||||
|
baseMapper.updateDelFlagById(modelLike);
|
||||||
|
// 更新图片点赞数
|
||||||
|
modelMapper.updateById(model);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
// 添加点赞记录
|
||||||
|
modelLike = new ModelLike();
|
||||||
|
modelLike.setUserId(userId);
|
||||||
|
modelLike.setModelId(modelId);
|
||||||
|
baseMapper.insert(modelLike);
|
||||||
|
|
||||||
|
// 更新图片点赞数
|
||||||
|
model.setNumbers(model.getLikeNum() + 1);
|
||||||
|
modelMapper.updateById(model);
|
||||||
|
|
||||||
|
this.addLikeAdvice(model);
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|
@ -98,6 +132,31 @@ public class ModelLikeServiceImpl extends ServiceImpl<ModelLikeMapper, ModelLike
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
private void addLikeAdvice(ModelProduct model) {
|
||||||
|
|
||||||
|
Long userId = SecurityUtils.getUserId();
|
||||||
|
Long receiverUserId = model.getUserId();
|
||||||
|
|
||||||
|
if (Objects.equals(userId, receiverUserId)) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
String content = StringUtils.format("恭喜！{}点赞了您的模型：{}",
|
||||||
|
SecurityUtils.getLoginUser().getUser().getNickName(), model.getModelName());
|
||||||
|
|
||||||
|
SysAdvice sysAdvice = new SysAdvice();
|
||||||
|
sysAdvice.setSenderId(userId);
|
||||||
|
sysAdvice.setReceiverId(receiverUserId);
|
||||||
|
sysAdvice.setContent(content);
|
||||||
|
sysAdvice.setProductId(model.getId());
|
||||||
|
sysAdvice.setProductType(0);
|
||||||
|
sysAdvice.setIsRead(0);
|
||||||
|
sysAdvice.setType(AdviceEnum.LIKE_REMIND);
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
private Page<ModelLike> initPage(PageDomain pageDomain) {
|
private Page<ModelLike> initPage(PageDomain pageDomain) {
|
||||||
Page<ModelLike> page = new Page<>(pageDomain.getPageNum(), pageDomain.getPageSize());
|
Page<ModelLike> page = new Page<>(pageDomain.getPageNum(), pageDomain.getPageSize());
|
||||||
if (StringUtils.isBlank(pageDomain.getOrderByColumn())) {
|
if (StringUtils.isBlank(pageDomain.getOrderByColumn())) {
|
||||||
|
|
|
||||||
|
|
@ -1,18 +1,22 @@
|
||||||
package com.mcwl.resource.service.impl;
|
package com.mcwl.resource.service.impl;
|
||||||
|
|
||||||
import cn.hutool.json.JSONUtil;
|
|
||||||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
||||||
|
import com.mcwl.common.exception.ServiceException;
|
||||||
import com.mcwl.common.utils.SecurityUtils;
|
import com.mcwl.common.utils.SecurityUtils;
|
||||||
|
import com.mcwl.common.utils.StringUtils;
|
||||||
|
import com.mcwl.resource.domain.SysAdvice;
|
||||||
|
import com.mcwl.resource.domain.WorkFlowComment;
|
||||||
import com.mcwl.resource.domain.WorkFlowCommentLike;
|
import com.mcwl.resource.domain.WorkFlowCommentLike;
|
||||||
import com.mcwl.resource.mapper.WorkFlowCommentLikeMapper;
|
import com.mcwl.resource.mapper.WorkFlowCommentLikeMapper;
|
||||||
|
import com.mcwl.resource.mapper.WorkFlowCommentMapper;
|
||||||
import com.mcwl.resource.service.WorkFlowCommentLikeService;
|
import com.mcwl.resource.service.WorkFlowCommentLikeService;
|
||||||
import com.mcwl.resource.util.MqttTemplate;
|
import com.mcwl.system.domain.enums.AdviceEnum;
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
import org.springframework.stereotype.Service;
|
import org.springframework.stereotype.Service;
|
||||||
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.transaction.annotation.Transactional;
|
||||||
|
|
||||||
import java.util.HashMap;
|
import java.util.Date;
|
||||||
import java.util.Map;
|
import java.util.Objects;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @Author：ChenYan
|
* @Author：ChenYan
|
||||||
|
|
@ -26,15 +30,72 @@ import java.util.Map;
|
||||||
public class WorkFlowCommentLikeServiceImpl extends ServiceImpl<WorkFlowCommentLikeMapper, WorkFlowCommentLike> implements WorkFlowCommentLikeService {
|
public class WorkFlowCommentLikeServiceImpl extends ServiceImpl<WorkFlowCommentLikeMapper, WorkFlowCommentLike> implements WorkFlowCommentLikeService {
|
||||||
|
|
||||||
@Autowired
|
@Autowired
|
||||||
private MqttTemplate mqttTemplate;
|
private WorkFlowCommentMapper workFlowCommentMapper;
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
@Transactional
|
||||||
public void like(Long commentId) {
|
public void like(Long commentId) {
|
||||||
Map<String, Long> map = new HashMap<>();
|
WorkFlowComment workFlowComment = workFlowCommentMapper.selectById(commentId);
|
||||||
map.put("userId", SecurityUtils.getUserId());
|
if (Objects.isNull(workFlowComment)) {
|
||||||
map.put("commentId", commentId);
|
throw new ServiceException("该评论不存在");
|
||||||
mqttTemplate.publish("workFlowCommentLike", JSONUtil.toJsonStr(map),0);
|
}
|
||||||
|
Long userId = SecurityUtils.getUserId();
|
||||||
|
WorkFlowCommentLike workFlowCommentLike = baseMapper.getLikeComment(userId, commentId);
|
||||||
|
if (Objects.nonNull(workFlowCommentLike)) {
|
||||||
|
if (Objects.equals(workFlowCommentLike.getDelFlag(), "0")) {
|
||||||
|
workFlowCommentLike.setDelFlag("2");
|
||||||
|
int likeNum = workFlowComment.getLikeNum() - 1;
|
||||||
|
likeNum = Math.max(likeNum, 0);
|
||||||
|
workFlowComment.setLikeNum(likeNum);
|
||||||
|
} else {
|
||||||
|
workFlowCommentLike.setDelFlag("0");
|
||||||
|
workFlowComment.setLikeNum(workFlowComment.getLikeNum() + 1);
|
||||||
|
this.addLikeAdvice(workFlowComment);
|
||||||
|
}
|
||||||
|
// 更新点赞记录
|
||||||
|
baseMapper.updateDelFlagById(workFlowCommentLike);
|
||||||
|
// 更新图片评论点赞数
|
||||||
|
workFlowCommentMapper.updateById(workFlowComment);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
// 添加点赞记录
|
||||||
|
workFlowCommentLike = new WorkFlowCommentLike();
|
||||||
|
workFlowCommentLike.setUserId(userId);
|
||||||
|
workFlowCommentLike.setWorkFlowCommentId(commentId);
|
||||||
|
baseMapper.insert(workFlowCommentLike);
|
||||||
|
|
||||||
|
// 更新模型点赞数
|
||||||
|
workFlowComment.setLikeNum(workFlowComment.getLikeNum() + 1);
|
||||||
|
workFlowCommentMapper.updateById(workFlowComment);
|
||||||
|
|
||||||
|
this.addLikeAdvice(workFlowComment);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
private void addLikeAdvice(WorkFlowComment workFlowComment) {
|
||||||
|
|
||||||
|
Long userId = SecurityUtils.getUserId();
|
||||||
|
Long receiverUserId = workFlowComment.getUserId();
|
||||||
|
|
||||||
|
if (Objects.equals(userId, receiverUserId)) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
String content = StringUtils.format("恭喜！{}点赞了您的评论",
|
||||||
|
SecurityUtils.getLoginUser().getUser().getNickName());
|
||||||
|
|
||||||
|
SysAdvice sysAdvice = new SysAdvice();
|
||||||
|
sysAdvice.setSenderId(userId);
|
||||||
|
sysAdvice.setReceiverId(receiverUserId);
|
||||||
|
sysAdvice.setContent(content);
|
||||||
|
sysAdvice.setProductId(workFlowComment.getWorkFlowId());
|
||||||
|
sysAdvice.setProductType(1);
|
||||||
|
sysAdvice.setCommentId(workFlowComment.getId());
|
||||||
|
sysAdvice.setIsRead(0);
|
||||||
|
sysAdvice.setType(AdviceEnum.LIKE_REMIND);
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -1,7 +1,6 @@
|
||||||
package com.mcwl.resource.service.impl;
|
package com.mcwl.resource.service.impl;
|
||||||
|
|
||||||
import cn.hutool.core.bean.BeanUtil;
|
import cn.hutool.core.bean.BeanUtil;
|
||||||
import cn.hutool.json.JSONUtil;
|
|
||||||
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
||||||
import com.baomidou.mybatisplus.core.metadata.OrderItem;
|
import com.baomidou.mybatisplus.core.metadata.OrderItem;
|
||||||
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
||||||
|
|
@ -10,21 +9,25 @@ import com.mcwl.common.constant.HttpStatus;
|
||||||
import com.mcwl.common.core.domain.entity.SysUser;
|
import com.mcwl.common.core.domain.entity.SysUser;
|
||||||
import com.mcwl.common.core.page.PageDomain;
|
import com.mcwl.common.core.page.PageDomain;
|
||||||
import com.mcwl.common.core.page.TableDataInfo;
|
import com.mcwl.common.core.page.TableDataInfo;
|
||||||
|
import com.mcwl.common.exception.ServiceException;
|
||||||
import com.mcwl.common.utils.SecurityUtils;
|
import com.mcwl.common.utils.SecurityUtils;
|
||||||
import com.mcwl.common.utils.StringUtils;
|
import com.mcwl.common.utils.StringUtils;
|
||||||
|
import com.mcwl.resource.domain.SysAdvice;
|
||||||
import com.mcwl.resource.domain.WorkFlow;
|
import com.mcwl.resource.domain.WorkFlow;
|
||||||
import com.mcwl.resource.domain.WorkFlowLike;
|
import com.mcwl.resource.domain.WorkFlowLike;
|
||||||
import com.mcwl.resource.domain.vo.WorkFlowLikeVo;
|
import com.mcwl.resource.domain.vo.WorkFlowLikeVo;
|
||||||
import com.mcwl.resource.mapper.WorkFlowLikeMapper;
|
import com.mcwl.resource.mapper.WorkFlowLikeMapper;
|
||||||
import com.mcwl.resource.mapper.WorkFlowMapper;
|
import com.mcwl.resource.mapper.WorkFlowMapper;
|
||||||
import com.mcwl.resource.service.WorkFlowLikeService;
|
import com.mcwl.resource.service.WorkFlowLikeService;
|
||||||
import com.mcwl.resource.util.MqttTemplate;
|
import com.mcwl.system.domain.enums.AdviceEnum;
|
||||||
import com.mcwl.system.service.ISysUserService;
|
import com.mcwl.system.service.ISysUserService;
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
import org.springframework.stereotype.Service;
|
import org.springframework.stereotype.Service;
|
||||||
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.transaction.annotation.Transactional;
|
||||||
|
|
||||||
import java.util.*;
|
import java.util.ArrayList;
|
||||||
|
import java.util.List;
|
||||||
|
import java.util.Objects;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 工作流点赞
|
* 工作流点赞
|
||||||
|
|
@ -45,15 +48,44 @@ public class WorkFlowLikeServiceImpl extends ServiceImpl<WorkFlowLikeMapper, Wor
|
||||||
@Autowired
|
@Autowired
|
||||||
private ISysUserService sysUserService;
|
private ISysUserService sysUserService;
|
||||||
|
|
||||||
@Autowired
|
|
||||||
private MqttTemplate mqttTemplate;
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
@Transactional
|
||||||
public void like(Long modelId) {
|
public void like(Long modelId) {
|
||||||
Map<String, Long> map = new HashMap<>();
|
WorkFlow workFlow = workFlowMapper.selectById(modelId);
|
||||||
map.put("userId", SecurityUtils.getUserId());
|
if (Objects.isNull(workFlow)) {
|
||||||
map.put("commentId", modelId);
|
throw new ServiceException("该工作流不存在或已下架");
|
||||||
mqttTemplate.publish("workFlowLike", JSONUtil.toJsonStr(map),0);
|
}
|
||||||
|
Long userId = SecurityUtils.getUserId();
|
||||||
|
WorkFlowLike workFlowLike = baseMapper.getLike(userId, modelId);
|
||||||
|
if (Objects.nonNull(workFlowLike)) {
|
||||||
|
if (Objects.equals(workFlowLike.getDelFlag(), "0")) {
|
||||||
|
workFlowLike.setDelFlag("2");
|
||||||
|
int likeCount = workFlow.getLikeNum() - 1;
|
||||||
|
likeCount = Math.max(likeCount, 0);
|
||||||
|
workFlow.setLikeNum(likeCount);
|
||||||
|
} else {
|
||||||
|
workFlowLike.setDelFlag("0");
|
||||||
|
workFlow.setLikeNum(workFlow.getLikeNum() + 1);
|
||||||
|
this.addLikeAdvice(workFlow);
|
||||||
|
}
|
||||||
|
// 更新点赞记录
|
||||||
|
baseMapper.updateStatus(workFlowLike);
|
||||||
|
// 更新图片点赞数
|
||||||
|
workFlowMapper.updateById(workFlow);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
// 添加点赞记录
|
||||||
|
workFlowLike = new WorkFlowLike();
|
||||||
|
workFlowLike.setUserId(userId);
|
||||||
|
workFlowLike.setWorkFlowId(modelId);
|
||||||
|
baseMapper.insert(workFlowLike);
|
||||||
|
|
||||||
|
// 更新图片点赞数
|
||||||
|
workFlow.setLikeNum(workFlow.getLikeNum() + 1);
|
||||||
|
workFlowMapper.updateById(workFlow);
|
||||||
|
|
||||||
|
this.addLikeAdvice(workFlow);
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|
@ -113,7 +145,29 @@ public class WorkFlowLikeServiceImpl extends ServiceImpl<WorkFlowLikeMapper, Wor
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
private void addLikeAdvice(WorkFlow workFlow) {
|
||||||
|
|
||||||
|
Long userId = SecurityUtils.getUserId();
|
||||||
|
Long receiverUserId = workFlow.getUserId();
|
||||||
|
|
||||||
|
if (Objects.equals(userId, receiverUserId)) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
String content = StringUtils.format("恭喜！{}点赞了您的工作流：{}",
|
||||||
|
SecurityUtils.getLoginUser().getUser().getNickName(), workFlow.getWorkflowName());
|
||||||
|
|
||||||
|
SysAdvice sysAdvice = new SysAdvice();
|
||||||
|
sysAdvice.setSenderId(userId);
|
||||||
|
sysAdvice.setReceiverId(receiverUserId);
|
||||||
|
sysAdvice.setContent(content);
|
||||||
|
sysAdvice.setProductId(workFlow.getId());
|
||||||
|
sysAdvice.setProductType(1);
|
||||||
|
sysAdvice.setIsRead(0);
|
||||||
|
sysAdvice.setType(AdviceEnum.LIKE_REMIND);
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
private Page<WorkFlowLike> initPage(PageDomain pageDomain) {
|
private Page<WorkFlowLike> initPage(PageDomain pageDomain) {
|
||||||
|
|
|
||||||
|
|
@ -1,245 +0,0 @@
|
||||||
package com.mcwl.resource.util;
|
|
||||||
|
|
||||||
|
|
||||||
import com.mcwl.common.utils.StringUtils;
|
|
||||||
import com.mcwl.resource.handler.IMessageHandler;
|
|
||||||
import lombok.Getter;
|
|
||||||
import lombok.extern.slf4j.Slf4j;
|
|
||||||
import org.eclipse.paho.client.mqttv3.*;
|
|
||||||
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
|
|
||||||
import org.springframework.beans.factory.DisposableBean;
|
|
||||||
import org.springframework.beans.factory.annotation.Value;
|
|
||||||
import org.springframework.boot.context.properties.ConfigurationProperties;
|
|
||||||
import org.springframework.context.ApplicationContext;
|
|
||||||
import org.springframework.context.annotation.Configuration;
|
|
||||||
import org.springframework.scheduling.annotation.Async;
|
|
||||||
|
|
||||||
import javax.annotation.PostConstruct;
|
|
||||||
import java.util.ArrayList;
|
|
||||||
import java.util.List;
|
|
||||||
import java.util.Map;
|
|
||||||
import java.util.UUID;
|
|
||||||
import java.util.concurrent.ConcurrentHashMap;
|
|
||||||
import java.util.concurrent.Executors;
|
|
||||||
import java.util.concurrent.ScheduledExecutorService;
|
|
||||||
import java.util.concurrent.TimeUnit;
|
|
||||||
|
|
||||||
import static com.mcwl.common.utils.Threads.sleep;
|
|
||||||
|
|
||||||
@Slf4j
|
|
||||||
@Getter
|
|
||||||
@Configuration
|
|
||||||
@ConfigurationProperties(prefix = "mqtt")
|
|
||||||
public class MqttTemplate implements MqttCallbackExtended, DisposableBean {
|
|
||||||
|
|
||||||
@Value("${mqtt.broker-url}")
|
|
||||||
private String brokerUrl;
|
|
||||||
|
|
||||||
@Value("${mqtt.client-id-prefix}")
|
|
||||||
private String clientIdPrefix;
|
|
||||||
|
|
||||||
@Value("${mqtt.connection-timeout}")
|
|
||||||
private int connectionTimeout;
|
|
||||||
|
|
||||||
@Value("${mqtt.keep-alive-interval}")
|
|
||||||
private int keepAliveInterval;
|
|
||||||
|
|
||||||
@Value("${mqtt.max-reconnect-attempts}")
|
|
||||||
private int maxReconnectAttempts;
|
|
||||||
|
|
||||||
@Value("${mqtt.clean-session}")
|
|
||||||
private boolean cleanSession;
|
|
||||||
|
|
||||||
private String clientId;
|
|
||||||
|
|
||||||
//================= 运行时组件 =================//
|
|
||||||
private MqttAsyncClient client;
|
|
||||||
private final Map<String, List<IMessageHandler>> topicHandlers = new ConcurrentHashMap<>();
|
|
||||||
private final ScheduledExecutorService reconnectExecutor = Executors.newSingleThreadScheduledExecutor();
|
|
||||||
private volatile boolean isConnecting;
|
|
||||||
private final ApplicationContext context;
|
|
||||||
|
|
||||||
public MqttTemplate(ApplicationContext context) {
|
|
||||||
this.context = context;
|
|
||||||
}
|
|
||||||
|
|
||||||
//================= 生命周期管理 =================//
|
|
||||||
@PostConstruct
|
|
||||||
public void init() throws MqttException {
|
|
||||||
if (StringUtils.isBlank(clientId)) {
|
|
||||||
clientId = clientIdPrefix + UUID.randomUUID().toString().substring(0, 8);
|
|
||||||
}
|
|
||||||
|
|
||||||
client = new MqttAsyncClient(brokerUrl, clientId, new MemoryPersistence());
|
|
||||||
client.setCallback(this);
|
|
||||||
connect();
|
|
||||||
// autoRegisterHandlers();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void destroy() throws Exception {
|
|
||||||
if (client != null && client.isConnected()) {
|
|
||||||
client.disconnect();
|
|
||||||
}
|
|
||||||
reconnectExecutor.shutdown();
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 连接管理
|
|
||||||
*
|
|
||||||
* @throws MqttException 连接失败
|
|
||||||
*/
|
|
||||||
private void connect() throws MqttException {
|
|
||||||
MqttConnectOptions options = new MqttConnectOptions();
|
|
||||||
options.setCleanSession(cleanSession);
|
|
||||||
options.setConnectionTimeout(connectionTimeout);
|
|
||||||
options.setKeepAliveInterval(keepAliveInterval);
|
|
||||||
options.setAutomaticReconnect(false); // 手动控制重连
|
|
||||||
|
|
||||||
client.connect(options, null, new IMqttActionListener() {
|
|
||||||
@Override
|
|
||||||
public void onSuccess(IMqttToken asyncActionToken) {
|
|
||||||
log.info("MQTT连接成功");
|
|
||||||
resubscribeAllTopics();
|
|
||||||
autoRegisterHandlers();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void onFailure(IMqttToken asyncActionToken, Throwable exception) {
|
|
||||||
log.error("初始连接失败", exception);
|
|
||||||
scheduleReconnect(1);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
//================= 自动重连机制 =================//
|
|
||||||
private void scheduleReconnect(int attempt) {
|
|
||||||
if (attempt > maxReconnectAttempts) {
|
|
||||||
log.error("达到最大重连次数: {}", maxReconnectAttempts);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
long delay = (long) Math.min(1000 * Math.pow(2, attempt), 30000);
|
|
||||||
reconnectExecutor.schedule(() -> {
|
|
||||||
try {
|
|
||||||
log.info("尝试第{}次重连", attempt);
|
|
||||||
if (client != null && client.isConnected()) {
|
|
||||||
client.disconnectForcibly(); // 强制断开旧连接
|
|
||||||
client.close(true);
|
|
||||||
}
|
|
||||||
// 重新初始化客户端
|
|
||||||
client = new MqttAsyncClient(brokerUrl, clientId, new MemoryPersistence());
|
|
||||||
client.setCallback(this); // 关键：重新绑定回调
|
|
||||||
client.reconnect();
|
|
||||||
resubscribeAllTopics(); // 重连后立即订阅
|
|
||||||
} catch (MqttException e) {
|
|
||||||
log.error("重连失败", e);
|
|
||||||
scheduleReconnect(attempt + 1);
|
|
||||||
}
|
|
||||||
}, delay, TimeUnit.MILLISECONDS);
|
|
||||||
}
|
|
||||||
|
|
||||||
//================= 消息发布 =================//
|
|
||||||
@Async
|
|
||||||
public void publish(String topic, String payload, int qos) {
|
|
||||||
try {
|
|
||||||
if (!client.isConnected()) {
|
|
||||||
throw new MqttException(MqttException.REASON_CODE_CLIENT_NOT_CONNECTED);
|
|
||||||
}
|
|
||||||
client.publish(topic, payload.getBytes(), qos, false);
|
|
||||||
} catch (MqttException e) {
|
|
||||||
log.error("消息发送失败 [topic: {}]", topic, e);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
@Async
|
|
||||||
public void publish(String topic, String payload) {
|
|
||||||
try {
|
|
||||||
if (!client.isConnected()) {
|
|
||||||
throw new MqttException(MqttException.REASON_CODE_CLIENT_NOT_CONNECTED);
|
|
||||||
}
|
|
||||||
client.publish(topic, payload.getBytes(), 1, false);
|
|
||||||
} catch (MqttException e) {
|
|
||||||
log.error("消息发送失败 [topic: {}]", topic, e);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
//================= 订阅管理 =================//
|
|
||||||
public void subscribe(String topicFilter, int qos, IMessageHandler handler) {
|
|
||||||
try {
|
|
||||||
if (!client.isConnected()) {
|
|
||||||
log.warn("客户端未连接，延迟订阅 [topic: {}]", topicFilter);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
client.subscribe(topicFilter, qos);
|
|
||||||
topicHandlers.computeIfAbsent(topicFilter, k -> new ArrayList<>())
|
|
||||||
.add(handler);
|
|
||||||
log.info("订阅成功: {}", topicFilter);
|
|
||||||
} catch (MqttException e) {
|
|
||||||
log.error("订阅失败 [topic: {}]", topicFilter);
|
|
||||||
e.printStackTrace();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private void resubscribeAllTopics() {
|
|
||||||
topicHandlers.forEach((topic, handlers) -> {
|
|
||||||
int retry = 0;
|
|
||||||
while (retry < 3) {
|
|
||||||
try {
|
|
||||||
client.subscribe(topic, 1);
|
|
||||||
log.info("主题重新订阅成功: {}", topic);
|
|
||||||
break;
|
|
||||||
} catch (MqttException e) {
|
|
||||||
retry++;
|
|
||||||
log.error("重新订阅失败 [topic: {}], 重试 {}/3", topic, retry);
|
|
||||||
sleep(1000L * retry);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
//================= 回调处理 =================//
|
|
||||||
@Override
|
|
||||||
public void messageArrived(String topic, MqttMessage message) {
|
|
||||||
|
|
||||||
topicHandlers.entrySet().stream()
|
|
||||||
.filter(entry -> MqttTopic.isMatched(entry.getKey(), topic))
|
|
||||||
.flatMap(entry -> entry.getValue().stream())
|
|
||||||
.forEach(handler -> {
|
|
||||||
try {
|
|
||||||
handler.handleMessage(topic, message);
|
|
||||||
} catch (Exception e) {
|
|
||||||
log.error("消息处理异常 [handler: {}]", handler.getClass(), e);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void connectionLost(Throwable cause) {
|
|
||||||
log.error("连接丢失", cause);
|
|
||||||
scheduleReconnect(1);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void deliveryComplete(IMqttDeliveryToken token) {
|
|
||||||
// QoS处理逻辑（可选）
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void connectComplete(boolean reconnect, String serverURI) {
|
|
||||||
log.info("连接已建立 [reconnect: {}]", reconnect);
|
|
||||||
if (reconnect) {
|
|
||||||
resubscribeAllTopics();
|
|
||||||
autoRegisterHandlers();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
//================= 自动注册处理器 =================//
|
|
||||||
private void autoRegisterHandlers() {
|
|
||||||
context.getBeansOfType(IMessageHandler.class).values()
|
|
||||||
.forEach(handler -> {
|
|
||||||
handler.getTopics().forEach(topic ->
|
|
||||||
subscribe(topic.getTopicFilter(), topic.getQos(), handler));
|
|
||||||
});
|
|
||||||
}
|
|
||||||
}
|
|
||||||
Loading…
Reference in New Issue