修改名称mq

src/main/java/com/fdkankan/manage/mq/common/MqQueueUtil.java

@@ -0,0 +1,7 @@
+package com.fdkankan.manage.mq.common;
+
+public class MqQueueUtil {
+
+    public static String manageToSaleQueue = "manageToSale";
+    public static String updateUserCommand = "updateUser";
+}

src/main/java/com/fdkankan/manage/mq/param/ManageToSaleParam.java

@@ -0,0 +1,14 @@
+package com.fdkankan.manage.mq.param;
+
+import com.fdkankan.manage.entity.SysUser;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+
+import java.io.Serializable;
+
+@Data
+@AllArgsConstructor
+public class ManageToSaleParam implements Serializable {
+    private String command;
+    private SysUser data;
+}

src/main/java/com/fdkankan/manage/service/impl/SysUserServiceImpl.java

@@ -14,6 +14,8 @@ import com.fdkankan.manage.entity.SysMenu;
 import com.fdkankan.manage.entity.SysRole;
 import com.fdkankan.manage.entity.SysUser;
 import com.fdkankan.manage.mapper.ISysUserMapper;
+import com.fdkankan.manage.mq.common.MqQueueUtil;
+import com.fdkankan.manage.mq.param.ManageToSaleParam;
 import com.fdkankan.manage.service.ISysMenuService;
 import com.fdkankan.manage.service.ISysRoleService;
 import com.fdkankan.manage.service.ISysUserService;
@@ -21,6 +23,7 @@ import com.fdkankan.manage.vo.request.SysUserParam;
 import com.fdkankan.manage.vo.response.ManageLoginResponse;
 import com.fdkankan.manage.vo.response.SysRoleVo;
 import com.fdkankan.manage.vo.response.SysUserVo;
+import com.fdkankan.rabbitmq.util.RabbitMqProducer;
 import com.fdkankan.redis.constant.RedisKey;
 import com.fdkankan.redis.util.RedisUtil;
 import org.springframework.beans.BeanUtils;
@@ -46,6 +49,8 @@ public class SysUserServiceImpl extends ServiceImpl<ISysUserMapper, SysUser> imp
     private ISysRoleService roleService;
     @Autowired
     private ISysMenuService sysMenuService;
+    @Autowired
+    RabbitMqProducer rabbitMqProducer;
 
     @Override
     public SysUser getByUserName(String userName) {
@@ -105,6 +110,9 @@ public class SysUserServiceImpl extends ServiceImpl<ISysUserMapper, SysUser> imp
                 throw new BusinessException(ResultCode.OLD_PASSWORD_ERROR);
             }
         }
+        if(sysUser.getId() != null){
+            rabbitMqProducer.sendByWorkQueue(MqQueueUtil.manageToSaleQueue,new ManageToSaleParam(MqQueueUtil.updateUserCommand,sysUser));
+        }
         this.saveOrUpdate(sysUser);
     }