Merge branch 'feature/community-center' into preview

mcwl-admin/src/main/java/com/mcwl/web/controller/mqtt/MqttController.java

@@ -0,0 +1,26 @@
+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);
+    }
+
+}

mcwl-admin/src/main/resources/application-dev.yml

@@ -98,7 +98,6 @@ spring:
         max-active: 1000
         # #连接池最大阻塞等待时间（使用负值表示没有限制）
         max-wait: -1ms
-        time-between-eviction-runs: 6000
 
 
 # token配置
@@ -170,4 +169,11 @@ huawei:
     upload:
       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
 

mcwl-admin/src/test/java/com/mcwl/TestMQTT.java

@@ -0,0 +1,22 @@
+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");
+    }
+}

mcwl-resource/pom.xml

@@ -39,5 +39,11 @@
             <version>3.1.2</version>
         </dependency>
 
+        <dependency>
+            <groupId>org.eclipse.paho</groupId>
+            <artifactId>org.eclipse.paho.client.mqttv3</artifactId>
+            <version>1.2.2</version>
+        </dependency>
+
     </dependencies>
 </project>

mcwl-resource/src/main/java/com/mcwl/resource/handler/IMessageHandler.java

@@ -0,0 +1,38 @@
+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;
+    }
+
+}

mcwl-resource/src/main/java/com/mcwl/resource/handler/impl/ImageCommentLikeHandler.java

@@ -0,0 +1,126 @@
+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);
+
+
+    }
+
+
+
+}

mcwl-resource/src/main/java/com/mcwl/resource/handler/impl/ImageLikeHandler.java

@@ -0,0 +1,122 @@
+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);
+
+
+    }
+
+
+}

mcwl-resource/src/main/java/com/mcwl/resource/handler/impl/ModelCommentLikeHandler.java

@@ -0,0 +1,121 @@
+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);
+
+
+    }
+
+
+
+}

mcwl-resource/src/main/java/com/mcwl/resource/handler/impl/ModelLikeHandler.java

@@ -0,0 +1,120 @@
+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);
+
+
+    }
+
+
+}

mcwl-resource/src/main/java/com/mcwl/resource/handler/impl/WorkFlowCommentLikeHandler.java

@@ -0,0 +1,124 @@
+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);
+
+
+    }
+
+
+
+}

mcwl-resource/src/main/java/com/mcwl/resource/handler/impl/WorkFlowLikeHandler.java

@@ -0,0 +1,118 @@
+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);
+
+
+    }
+
+
+}

mcwl-resource/src/main/java/com/mcwl/resource/service/impl/ModelCommentLikeServiceImpl.java

@@ -1,22 +1,18 @@
 package com.mcwl.resource.service.impl;
 
+import cn.hutool.json.JSONUtil;
 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.StringUtils;
-import com.mcwl.resource.domain.ModelComment;
 import com.mcwl.resource.domain.ModelCommentLike;
-import com.mcwl.resource.domain.SysAdvice;
 import com.mcwl.resource.mapper.ModelCommentLikeMapper;
-import com.mcwl.resource.mapper.ModelCommentMapper;
 import com.mcwl.resource.service.ModelCommentLikeService;
-import com.mcwl.system.domain.enums.AdviceEnum;
+import com.mcwl.resource.util.MqttTemplate;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
-import java.util.Date;
-import java.util.Objects;
+import java.util.HashMap;
+import java.util.Map;
 
 /**
  * 模型评论点赞
@@ -25,72 +21,14 @@ import java.util.Objects;
 public class ModelCommentLikeServiceImpl extends ServiceImpl<ModelCommentLikeMapper, ModelCommentLike> implements ModelCommentLikeService {
 
     @Autowired
-    private ModelCommentMapper modelCommentMapper;
+    private MqttTemplate mqttTemplate;
 
     @Override
-    @Transactional
     public void like(Long commentId) {
-        ModelComment modelComment = modelCommentMapper.selectById(commentId);
-        if (Objects.isNull(modelComment)) {
-            throw new ServiceException("该评论不存在");
-        }
-        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);
-
-
+        Map<String, Long> map = new HashMap<>();
+        map.put("userId", SecurityUtils.getUserId());
+        map.put("commentId", commentId);
+        mqttTemplate.publish("modelCommentLike", JSONUtil.toJsonStr(map), 0);
     }
 
 

mcwl-resource/src/main/java/com/mcwl/resource/service/impl/ModelImageCommentLikeServiceImpl.java

@@ -1,22 +1,19 @@
 package com.mcwl.resource.service.impl;
 
+import cn.hutool.json.JSONUtil;
 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.StringUtils;
-import com.mcwl.resource.domain.ModelImageComment;
 import com.mcwl.resource.domain.ModelImageCommentLike;
-import com.mcwl.resource.domain.SysAdvice;
 import com.mcwl.resource.mapper.ModelImageCommentLikeMapper;
-import com.mcwl.resource.mapper.ModelImageCommentMapper;
 import com.mcwl.resource.service.ModelImageCommentLikeService;
-import com.mcwl.system.domain.enums.AdviceEnum;
+import com.mcwl.resource.util.MqttTemplate;
 import lombok.RequiredArgsConstructor;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
-import java.util.Date;
-import java.util.Objects;
+import java.util.HashMap;
+import java.util.Map;
 
 /**
  * 图片评论点赞
@@ -25,72 +22,15 @@ import java.util.Objects;
 @RequiredArgsConstructor
 public class ModelImageCommentLikeServiceImpl extends ServiceImpl<ModelImageCommentLikeMapper, ModelImageCommentLike> implements ModelImageCommentLikeService {
 
-    private final ModelImageCommentMapper modelImageCommentMapper;
+    @Autowired
+    private MqttTemplate mqttTemplate;
 
     @Override
-    @Transactional
     public void  like(Long commentId) {
-        ModelImageComment modelImageComment = modelImageCommentMapper.selectById(commentId);
-        if (Objects.isNull(modelImageComment)) {
-            throw new ServiceException("该评论不存在");
-        }
-        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);
-
-
+        Map<String, Long> map = new HashMap<>();
+        map.put("userId", SecurityUtils.getUserId());
+        map.put("commentId", commentId);
+        mqttTemplate.publish("imageCommentLike", JSONUtil.toJsonStr(map),0);
     }
 
 

mcwl-resource/src/main/java/com/mcwl/resource/service/impl/ModelImageLikeServiceImpl.java

@@ -1,6 +1,7 @@
 package com.mcwl.resource.service.impl;
 
 import cn.hutool.core.bean.BeanUtil;
+import cn.hutool.json.JSONUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.OrderItem;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
@@ -11,7 +12,6 @@ import com.mcwl.common.constant.HttpStatus;
 import com.mcwl.common.core.domain.entity.SysUser;
 import com.mcwl.common.core.page.PageDomain;
 import com.mcwl.common.core.page.TableDataInfo;
-import com.mcwl.common.exception.ServiceException;
 import com.mcwl.common.utils.SecurityUtils;
 import com.mcwl.common.utils.StringUtils;
 import com.mcwl.resource.domain.ModelImage;
@@ -23,16 +23,14 @@ import com.mcwl.resource.domain.vo.PageVo;
 import com.mcwl.resource.mapper.ModelImageLikeMapper;
 import com.mcwl.resource.mapper.ModelImageMapper;
 import com.mcwl.resource.service.ModelImageLikeService;
+import com.mcwl.resource.util.MqttTemplate;
 import com.mcwl.system.domain.enums.AdviceEnum;
 import com.mcwl.system.service.ISysUserService;
 import lombok.RequiredArgsConstructor;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
-import org.springframework.transaction.annotation.Transactional;
 
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.List;
-import java.util.Objects;
+import java.util.*;
 
 /**
  * 图片点赞实现
@@ -45,44 +43,15 @@ public class ModelImageLikeServiceImpl extends ServiceImpl<ModelImageLikeMapper,
 
     private final ISysUserService sysUserService;
 
+    @Autowired
+    private MqttTemplate mqttTemplate;
+
     @Override
-    @Transactional
     public void like(Long imageId) {
-        ModelImage modelImage = modelImageMapper.selectById(imageId);
-        if (Objects.isNull(modelImage)) {
-            throw new ServiceException("该图片不存在或已下架");
-        }
-        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);
+        Map<String, Long> map = new HashMap<>();
+        map.put("userId", SecurityUtils.getUserId());
+        map.put("commentId", imageId);
+        mqttTemplate.publish("imageLike", JSONUtil.toJsonStr(map),0);
     }
 
     @Override

mcwl-resource/src/main/java/com/mcwl/resource/service/impl/ModelLikeServiceImpl.java

@@ -1,6 +1,7 @@
 package com.mcwl.resource.service.impl;
 
 import cn.hutool.core.bean.BeanUtil;
+import cn.hutool.json.JSONUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.OrderItem;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
@@ -9,26 +10,20 @@ import com.mcwl.common.constant.HttpStatus;
 import com.mcwl.common.core.domain.entity.SysUser;
 import com.mcwl.common.core.page.PageDomain;
 import com.mcwl.common.core.page.TableDataInfo;
-import com.mcwl.common.exception.ServiceException;
 import com.mcwl.common.utils.SecurityUtils;
 import com.mcwl.common.utils.StringUtils;
 import com.mcwl.resource.domain.ModelLike;
 import com.mcwl.resource.domain.ModelProduct;
-import com.mcwl.resource.domain.SysAdvice;
 import com.mcwl.resource.domain.vo.ModelLikeVo;
 import com.mcwl.resource.mapper.ModelLikeMapper;
 import com.mcwl.resource.mapper.ModelMapper;
 import com.mcwl.resource.service.ModelLikeService;
-import com.mcwl.system.domain.enums.AdviceEnum;
+import com.mcwl.resource.util.MqttTemplate;
 import com.mcwl.system.service.ISysUserService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
-import org.springframework.transaction.annotation.Transactional;
 
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.List;
-import java.util.Objects;
+import java.util.*;
 
 /**
  * 模型点赞
@@ -43,45 +38,16 @@ public class ModelLikeServiceImpl extends ServiceImpl<ModelLikeMapper, ModelLike
     @Autowired
     private ISysUserService sysUserService;
 
+    @Autowired
+    private MqttTemplate mqttTemplate;
+
 
     @Override
-    @Transactional(rollbackFor = Exception.class)
     public void like(Long modelId) {
-        ModelProduct model = modelMapper.selectById(modelId);
-        if (Objects.isNull(model)) {
-            throw new ServiceException("该模型不存在或已下架");
-        }
-        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);
+        Map<String, Long> map = new HashMap<>();
+        map.put("userId", SecurityUtils.getUserId());
+        map.put("commentId", modelId);
+        mqttTemplate.publish("modelLike", JSONUtil.toJsonStr(map),0);
     }
 
     @Override
@@ -132,31 +98,6 @@ 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) {
         Page<ModelLike> page = new Page<>(pageDomain.getPageNum(), pageDomain.getPageSize());
         if (StringUtils.isBlank(pageDomain.getOrderByColumn())) {

mcwl-resource/src/main/java/com/mcwl/resource/service/impl/WorkFlowCommentLikeServiceImpl.java

@@ -1,22 +1,18 @@
 package com.mcwl.resource.service.impl;
 
+import cn.hutool.json.JSONUtil;
 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.StringUtils;
-import com.mcwl.resource.domain.SysAdvice;
-import com.mcwl.resource.domain.WorkFlowComment;
 import com.mcwl.resource.domain.WorkFlowCommentLike;
 import com.mcwl.resource.mapper.WorkFlowCommentLikeMapper;
-import com.mcwl.resource.mapper.WorkFlowCommentMapper;
 import com.mcwl.resource.service.WorkFlowCommentLikeService;
-import com.mcwl.system.domain.enums.AdviceEnum;
+import com.mcwl.resource.util.MqttTemplate;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
-import java.util.Date;
-import java.util.Objects;
+import java.util.HashMap;
+import java.util.Map;
 
 /**
  * @Author：ChenYan
@@ -30,72 +26,15 @@ import java.util.Objects;
 public class WorkFlowCommentLikeServiceImpl extends ServiceImpl<WorkFlowCommentLikeMapper, WorkFlowCommentLike> implements WorkFlowCommentLikeService {
 
     @Autowired
-    private WorkFlowCommentMapper workFlowCommentMapper;
+    private MqttTemplate mqttTemplate;
 
     @Override
-    @Transactional
     public void like(Long commentId) {
-        WorkFlowComment workFlowComment = workFlowCommentMapper.selectById(commentId);
-        if (Objects.isNull(workFlowComment)) {
-            throw new ServiceException("该评论不存在");
-        }
-        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;
+        Map<String, Long> map = new HashMap<>();
+        map.put("userId", SecurityUtils.getUserId());
+        map.put("commentId", commentId);
+        mqttTemplate.publish("workFlowCommentLike", JSONUtil.toJsonStr(map),0);
     }
 
-        // 添加点赞记录
-        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);
-
-
-    }
 
 }

mcwl-resource/src/main/java/com/mcwl/resource/service/impl/WorkFlowLikeServiceImpl.java

@@ -1,6 +1,7 @@
 package com.mcwl.resource.service.impl;
 
 import cn.hutool.core.bean.BeanUtil;
+import cn.hutool.json.JSONUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.OrderItem;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
@@ -9,25 +10,21 @@ import com.mcwl.common.constant.HttpStatus;
 import com.mcwl.common.core.domain.entity.SysUser;
 import com.mcwl.common.core.page.PageDomain;
 import com.mcwl.common.core.page.TableDataInfo;
-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.domain.vo.WorkFlowLikeVo;
 import com.mcwl.resource.mapper.WorkFlowLikeMapper;
 import com.mcwl.resource.mapper.WorkFlowMapper;
 import com.mcwl.resource.service.WorkFlowLikeService;
-import com.mcwl.system.domain.enums.AdviceEnum;
+import com.mcwl.resource.util.MqttTemplate;
 import com.mcwl.system.service.ISysUserService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Objects;
+import java.util.*;
 
 /**
  * 工作流点赞
@@ -48,44 +45,15 @@ public class WorkFlowLikeServiceImpl extends ServiceImpl<WorkFlowLikeMapper, Wor
     @Autowired
     private ISysUserService sysUserService;
 
+    @Autowired
+    private MqttTemplate mqttTemplate;
+
     @Override
-    @Transactional
     public void like(Long modelId) {
-        WorkFlow workFlow = workFlowMapper.selectById(modelId);
-        if (Objects.isNull(workFlow)) {
-            throw new ServiceException("该工作流不存在或已下架");
-        }
-        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);
+        Map<String, Long> map = new HashMap<>();
+        map.put("userId", SecurityUtils.getUserId());
+        map.put("commentId", modelId);
+        mqttTemplate.publish("workFlowLike", JSONUtil.toJsonStr(map),0);
     }
 
     @Override
@@ -145,29 +113,7 @@ 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) {

mcwl-resource/src/main/java/com/mcwl/resource/util/MqttTemplate.java

@@ -0,0 +1,245 @@
+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));
+                });
+    }
+}