中台注销激活

src/main/java/cn/quantgroup/xyqb/controller/middleoffice/user/UserController.java

 package cn.quantgroup.xyqb.controller.middleoffice.user;
 
 import cn.quantgroup.xyqb.entity.User;
+import cn.quantgroup.xyqb.event.DisableActiveEvent;
 import cn.quantgroup.xyqb.model.JsonResult;
 import cn.quantgroup.xyqb.service.user.IUserService;
+import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.messaging.handler.annotation.Header;
 import org.springframework.web.bind.annotation.*;
 
@@ -20,6 +22,9 @@ public class UserController {
     @Resource
     private IUserService userService;
 
+    @Resource
+    private ApplicationEventPublisher applicationEventPublisher;
+
     @PutMapping("/enable/{userId}")
     public JsonResult enable(@PathVariable Long userId) {
         User user = userService.findById(userId);
@@ -29,6 +34,8 @@ public class UserController {
         }
         user.setEnable(true);
         userService.saveUser(user);
+        //通知消息中心
+        applicationEventPublisher.publishEvent(new DisableActiveEvent(this,user));
         return JsonResult.buildSuccessResult();
     }
 
@@ -42,6 +49,9 @@ public class UserController {
         user.setEnable(false);
         //清理缓存
         userService.saveUser(user);
+        //通知消息中心
+        applicationEventPublisher.publishEvent(new DisableActiveEvent(this,user));
+
         return JsonResult.buildSuccessResult();
     }
 

src/main/java/cn/quantgroup/xyqb/event/DisableActiveEventListner.java

@@ -46,7 +46,7 @@ public class DisableActiveEventListner implements ApplicationListener<DisableAct
         String post = httpService.postJson(msgCenter.concat(SMS_MARKET_BLACK_LIST),
                 ImmutableMap.of("userId", userId,
                         "phoneNo", phoneNo,
-                        "enable", String.valueOf(enable)));
+                        "enable", String.valueOf(!enable)));//true代表消息中心的注销false代表激活跟用户中心是反的
 
         log.info("通知消息中心激活/注销用户结束user:{} ,post：{} ", user, post);
     }