|
|
@ -621,12 +621,12 @@ public class ResiGroupMemberServiceImpl extends BaseServiceImpl<ResiGroupMemberD |
|
|
|
if(!result.success()){ |
|
|
|
logger.error((isNew ? "拉新用户入组事件发送失败" : "邀请已注册用户入组事件发送失败").concat(",参数:{}"),JSON.toJSONString(agreeApplyFormDTO)); |
|
|
|
} |
|
|
|
//发送小组成就消息
|
|
|
|
boolean flag = SendMqMsgUtil.build().openFeignClient(epmetMessageOpenFeignClient) |
|
|
|
.sendGroupAchievementMqMsg(new GroupAchievementMQMsg(resiGroupDTO.getCustomerId(), resiGroupDTO.getId(), AchievementTypeEnum.MEMBER.getCode())); |
|
|
|
if (!flag) { |
|
|
|
logger.error("发送(小组成就)系统消息到message服务失败"); |
|
|
|
} |
|
|
|
} |
|
|
|
//发送小组成就消息
|
|
|
|
boolean flag = SendMqMsgUtil.build().openFeignClient(epmetMessageOpenFeignClient) |
|
|
|
.sendGroupAchievementMqMsg(new GroupAchievementMQMsg(resiGroupDTO.getCustomerId(), resiGroupDTO.getId(), AchievementTypeEnum.MEMBER.getCode())); |
|
|
|
if (!flag) { |
|
|
|
logger.error("发送(小组成就)系统消息到message服务失败"); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|