add rabbitmq

base-system-server/pom.xml

@@ -32,6 +32,18 @@
     </properties>
 
     <dependencies>
+        <!-- rabbitMQ -->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-amqp</artifactId>
+        </dependency>
+
+        <!-- 消息转换器 -->
+        <dependency>
+            <groupId>com.fasterxml.jackson.dataformat</groupId>
+            <artifactId>jackson-dataformat-xml</artifactId>
+            <version>2.9.10</version>
+        </dependency>
         <dependency>
             <groupId>cn.hutool</groupId>
             <artifactId>hutool-all</artifactId>

base-system-server/src/main/java/com/health/system/server/service/impl/SysUserServiceImpl.java

@@ -16,6 +16,7 @@ import com.health.system.server.service.ISysConfigService;
 import com.health.system.server.service.ISysUserService;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.stereotype.Service;
@@ -25,6 +26,7 @@ import org.springframework.util.CollectionUtils;
 import javax.validation.Validator;
 import java.util.ArrayList;
 import java.util.List;
+import java.util.UUID;
 import java.util.stream.Collectors;
 
 /**
@@ -37,6 +39,8 @@ public class SysUserServiceImpl implements ISysUserService
 {
     private static final Logger log = LoggerFactory.getLogger(SysUserServiceImpl.class);
 
+    @Autowired
+    private RabbitTemplate rabbitTemplate;
     @Autowired
     private RedisTemplate<String,String> redisTemplate;
 
@@ -624,6 +628,10 @@ public class SysUserServiceImpl implements ISysUserService
             userMapper.insertDoctor(doctor1);
             //添加用户和角色中间表
             int i=userMapper.insertUseRole(userId,roleId);
+        rabbitTemplate.convertAndSend("add_userWallet",doctor1.getUserId(),msg->{
+            msg.getMessageProperties().setMessageId(UUID.randomUUID().toString().replaceAll("-",""));
+            return msg;
+        } );
             return i>0;
         //成功之后添加医生表
         //添加用户角色中间表