会员分成记录信息

ace-common/src/main/java/com/github/wxiaoqi/security/common/config/rabbit/RabbitConstant.java

@@ -25,7 +25,7 @@ public class RabbitConstant {
     public static final String KEY_APPUSER_REGISTER = "appUser.register";
     public static final String KEY_APPUSER_AUTH = "appUser.auth";
     public static final String KEY_MEMBER_SHARE = "member.share";
-
+    public static final String KEY_MEMBER_CHANGE = "member.change";
 
     //积分
     public static final String INTEGRAL_ROUTING_KEY = "integral_routing_key";

ace-modules/ace-admin/src/main/java/com/github/wxiaoqi/security/admin/biz/BaseUserMemberBiz.java

@@ -2,6 +2,7 @@ package com.github.wxiaoqi.security.admin.biz;
 
 import com.ace.cache.annotation.Cache;
 import com.ace.cache.annotation.CacheClear;
+import com.alibaba.fastjson.JSONObject;
 import com.github.wxiaoqi.security.admin.dto.BaseUserMemberVO;
 import com.github.wxiaoqi.security.admin.dto.UserMemberDTO;
 import com.github.wxiaoqi.security.admin.entity.AppUserRelation;
@@ -16,9 +17,11 @@ import com.github.wxiaoqi.security.auth.client.config.UserAuthConfig;
 import com.github.wxiaoqi.security.auth.client.jwt.UserAuthUtil;
 import com.github.wxiaoqi.security.auth.common.util.jwt.IJWTInfo;
 import com.github.wxiaoqi.security.common.biz.BaseBiz;
+import com.github.wxiaoqi.security.common.config.rabbit.RabbitConstant;
 import com.github.wxiaoqi.security.common.exception.BaseException;
 import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
 import com.github.wxiaoqi.security.common.util.process.ResultCode;
+import com.xxfc.platform.universal.feign.MQSenderFeign;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.beanutils.BeanUtils;
 import org.apache.commons.collections.CollectionUtils;
@@ -69,6 +72,10 @@ public class BaseUserMemberBiz extends BaseBiz<BaseUserMemberMapper, BaseUserMem
 
     @Autowired
     private HttpServletRequest request;
+
+    @Autowired
+    MQSenderFeign mqSenderFeign;
+
 //    @Autowired
 //    private TaskExecutor taskExecutor;
 //
@@ -321,7 +328,7 @@ public class BaseUserMemberBiz extends BaseBiz<BaseUserMemberMapper, BaseUserMem
         baseUserMember.setMemberLevel(baseUserMember.getMemberLevel());
         updateSelectiveByIdRe(baseUserMember);
         // todo 执行上级会员等级初始化操作
-
+        mqSenderFeign.sendMessage(RabbitConstant.ADMIN_TOPIC, RabbitConstant.KEY_MEMBER_CHANGE, JSONObject.toJSONString(baseUserMember));
         return ObjectRestResponse.succ();
     }
 

ace-modules/ace-admin/src/main/java/com/github/wxiaoqi/security/admin/config/RabbitAdminConfig.java

@@ -35,6 +35,8 @@ public class RabbitAdminConfig extends RabbitCommonConfig {
 
     public static final String MEMBER_SHARE_QUEUE = "admin.member.share";
 
+    public static final String MEMBER_CHANGE_QUEUE = "admin.member.change";
+
     static {
         myQueue = new ArrayList<BindDTO>() {{
             //支付完成后永久绑定关系
@@ -53,6 +55,8 @@ public class RabbitAdminConfig extends RabbitCommonConfig {
             add(new BindDTO(COMPANY_UPD_QUEUE, VEHICLE_TOPIC, KEY_COMPANY_UPD));
 
             add(new BindDTO(MEMBER_SHARE_QUEUE, ADMIN_TOPIC, KEY_MEMBER_SHARE));
+
+            add(new BindDTO(MEMBER_CHANGE_QUEUE, ADMIN_TOPIC, KEY_MEMBER_CHANGE));
         }};
     }
 }

ace-modules/ace-admin/src/main/java/com/github/wxiaoqi/security/admin/handler/MemberChangeMQHandler.java

+package com.github.wxiaoqi.security.admin.handler;
+
+import cn.hutool.json.JSONUtil;
+import com.github.wxiaoqi.security.admin.biz.BaseUserMemberBiz;
+import com.github.wxiaoqi.security.admin.entity.BaseUserMember;
+import com.rabbitmq.client.Channel;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.amqp.core.Message;
+import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.messaging.handler.annotation.Headers;
+import org.springframework.stereotype.Component;
+
+import java.util.Map;
+
+import static com.github.wxiaoqi.security.admin.config.RabbitAdminConfig.MEMBER_CHANGE_QUEUE;
+
+/**
+ * @ClassName : MemberChangeMQHandler
+ * @Description : 修改会员等级
+ * @Author : jiaoruizhen
+ * @Date: 2020-11-07 11:10
+ */
+@Component
+@Slf4j
+public class MemberChangeMQHandler {
+
+	@Autowired
+	BaseUserMemberBiz baseUserMemberBiz;
+
+	@RabbitListener(queues = MEMBER_CHANGE_QUEUE)
+	public void integralHandler(Message message, @Headers Map<String, Object> headers, Channel channel) {
+		try {
+			Thread.sleep(2000);
+			String msg = new String(message.getBody(), "UTF-8");
+			log.info("接收到的消息-----msg===="+msg);
+			BaseUserMember baseUserMember = JSONUtil.toBean(msg, BaseUserMember.class);
+			baseUserMemberBiz.executeParentMemberLevel(baseUserMember);
+		} catch (Exception e) {
+			log.error("接收消息失败：{}", e);
+		}
+
+	}
+}