组员入组消息发送

epmet-commons/epmet-commons-rocketmq/pom.xml

@@ -16,6 +16,7 @@
             <groupId>org.apache.rocketmq</groupId>
             <artifactId>rocketmq-spring-boot-starter</artifactId>
             <version>2.0.1</version>
+            <!--<version>2.2.0</version>-->
         </dependency>
         <dependency>
             <groupId>org.projectlombok</groupId>

epmet-module/epmet-message/epmet-message-client/src/main/java/com/epmet/constant/SystemMessageType.java

@@ -10,4 +10,9 @@ public interface SystemMessageType {
      */
     String INIT_CUSTOMER = "init_customer";
 
+    /**
+     * 小组成就
+     */
+    String GROUP_ACHIEVEMENT = "group_achievement";
+
 }

epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/service/impl/SystemMessageServiceImpl.java

@@ -64,6 +64,9 @@ public class SystemMessageServiceImpl implements SystemMessageService {
             case SystemMessageType.INIT_CUSTOMER:
                 topic = TopicConstants.INIT_CUSTOMER;
             break;
+            case SystemMessageType.GROUP_ACHIEVEMENT:
+                topic = TopicConstants.GROUP_ACHIEVEMENT;
+                break;
         }
         return topic;
     }

epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/group/service/impl/ResiGroupServiceImpl.java

@@ -21,6 +21,7 @@ import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.epmet.commons.mybatis.service.impl.BaseServiceImpl;
+import com.epmet.commons.rocketmq.messages.GroupAchievementMQMsg;
 import com.epmet.commons.tools.constant.*;
 import com.epmet.commons.tools.exception.EpmetErrorCode;
 import com.epmet.commons.tools.exception.RenException;
@@ -37,12 +38,13 @@ import com.epmet.commons.tools.utils.DateUtils;
 import com.epmet.commons.tools.utils.Result;
 import com.epmet.commons.tools.utils.ScanContentUtils;
 import com.epmet.constant.ReadFlagConstant;
+import com.epmet.constant.SystemMessageType;
 import com.epmet.dto.form.*;
 import com.epmet.dto.result.UserResiInfoResultDTO;
 import com.epmet.dto.result.UserRoleResultDTO;
 import com.epmet.feign.EpmetMessageOpenFeignClient;
-import com.epmet.group.constant.GroupConstant;
 import com.epmet.modules.constant.UserMessageConstant;
+import com.epmet.modules.enums.AchievementTypeEnum;
 import com.epmet.modules.feign.EpmetMessageFeignClient;
 import com.epmet.modules.feign.EpmetUserFeignClient;
 import com.epmet.modules.feign.GovOrgFeignClient;
@@ -660,6 +662,19 @@ public class ResiGroupServiceImpl extends BaseServiceImpl<ResiGroupDao, ResiGrou
 		List<WxSubscribeMessageFormDTO> msgList = new ArrayList<>();
 		msgList.add(wxSubscribeMessageFormDTO);
 		epmetMessageOpenFeignClient.sendWxSubscribeMessage(msgList);
+		//发送小组成就消息
+		GroupAchievementMQMsg msgContent = new GroupAchievementMQMsg();
+		msgContent.setCustomerId(resiGroupDTO.getCustomerId());
+		msgContent.setGroupId(resiGroupDTO.getId());
+		msgContent.setAchievementType(AchievementTypeEnum.MEMBER.getCode());
+
+		SystemMsgFormDTO systemMsgFormDTO = new SystemMsgFormDTO();
+		systemMsgFormDTO.setMessageType(SystemMessageType.GROUP_ACHIEVEMENT);
+		systemMsgFormDTO.setContent(msgContent);
+		Result sendMsgResult = epmetMessageOpenFeignClient.sendSystemMsgByMQ(systemMsgFormDTO);
+		if (!sendMsgResult.success()) {
+			logger.error("发送(小组成就)系统消息到message服务失败:{}", sendMsgResult.getInternalMsg());
+		}
 		return new Result();
 	}