diff --git a/base-system-server/pom.xml b/base-system-server/pom.xml index 5c4d018..12ad9df 100644 --- a/base-system-server/pom.xml +++ b/base-system-server/pom.xml @@ -32,6 +32,18 @@ + + + org.springframework.boot + spring-boot-starter-amqp + + + + + com.fasterxml.jackson.dataformat + jackson-dataformat-xml + 2.9.10 + cn.hutool hutool-all diff --git a/base-system-server/src/main/java/com/health/system/server/service/impl/SysUserServiceImpl.java b/base-system-server/src/main/java/com/health/system/server/service/impl/SysUserServiceImpl.java index 2c29911..6971adb 100644 --- a/base-system-server/src/main/java/com/health/system/server/service/impl/SysUserServiceImpl.java +++ b/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 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; //成功之后添加医生表 //添加用户角色中间表