xiaohuang
/
xiaohuang-houduan1
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

重构车辆项目,还不可以添加数据 

fix():解决项目问题
1:德鲁伊没有禁用自动装载的数据源
master
xiaohuang 2024-06-11 22:34:56 +08:00
parent 9f1ac0a5dc
commit b78fee1dd0
2 changed files with 39 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
muyu-common/muyu-common-system/src/main/java/com/muyu/common/system/remote/RemoteUserService.java
View File

@ -47,8 +47,13 @@ public interface RemoteUserService {
@GetMapping("/user/authRole/{userId}") @GetMapping("/user/authRole/{userId}")
public Result authRole (@PathVariable("userId") Long userId); public Result authRole (@PathVariable("userId") Long userId);
@GetMapping("/user/userById/{userId}")
public SysUser userById(@PathVariable("userId") Long UserType);
@GetMapping("/user/selectByUserId/{userId}") @GetMapping("/user/selectByUserId/{userId}")
public SysUser selectByUserId (@PathVariable("userId") Long userId); public SysUser selectByUserId (@PathVariable("userId") Long userId);
} }

51
muyu-modules/muyu-business/muyu-data-service/src/main/java/com/muyu/business/service/impl/BusinessServiceImpl.java
View File

@ -3,9 +3,12 @@ package com.muyu.business.service.impl;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.muyu.business.domain.Business; import com.muyu.business.domain.Business;
import com.muyu.business.domain.Entinfo;
import com.muyu.business.mapper.BusinessMapper; import com.muyu.business.mapper.BusinessMapper;
import com.muyu.business.service.BusinessService; import com.muyu.business.service.BusinessService;
import com.muyu.common.core.domain.Result;
import com.muyu.common.core.utils.DateUtils; import com.muyu.common.core.utils.DateUtils;
import com.muyu.common.redis.service.RedisService;
import com.muyu.common.security.utils.SecurityUtils; import com.muyu.common.security.utils.SecurityUtils;
import com.muyu.common.system.domain.LoginUser; import com.muyu.common.system.domain.LoginUser;
import com.muyu.common.system.domain.SysUser; import com.muyu.common.system.domain.SysUser;
@ -40,8 +43,9 @@ public class BusinessServiceImpl extends ServiceImpl<BusinessMapper, Business> i
@Autowired @Autowired
private RemoteUserService remoteUserService; private RemoteUserService remoteUserService;
@Autowired @Autowired
private RedisTemplate<String,String> redisTemplate; private RedisService redisService;
@ -73,17 +77,17 @@ public class BusinessServiceImpl extends ServiceImpl<BusinessMapper, Business> i
int i = businessMapper.insertBusiness(business); int i = businessMapper.insertBusiness(business);
System.out.println(business); System.out.println(business);
SysUser sysUser = SysUser.builder() SysUser sysUser = SysUser.builder()
.userName(business.getName() + business.getId()) .userName(business.getName())
.password("admin123") .password("admin123")
.nickName(business.getName()) .nickName(business.getName())
.email(business.getBusinessEmail()) .email(business.getBusinessEmail())
.phonenumber(business.getBusinessPhone()) .phonenumber(business.getBusinessPhone())
.loginIp("175.24.138.82") .loginIp("111.229.102.61")
.userType(String.valueOf(business.getId())) .roleId(Long.valueOf(101))
.build(); .userType(String.valueOf(business.getId()))
.build();
remoteUserService.add(sysUser); Result add = remoteUserService.add(sysUser);
return i; return i;
} }
@ -97,16 +101,29 @@ public class BusinessServiceImpl extends ServiceImpl<BusinessMapper, Business> i
} }
@Autowired
private EntinfoServiceImpl entinfoService;
/** /**
* *
* @ 判断redis是否存在端口号 * @ 判断redis是否存在端口号
* @return * @return
*/ */
public void httpConnectMysql(Business business){ public void httpConnectMysql(Business business){
if (business.getBusinessStates().equals(2) ) { redisService.deleteObject("entinfo");
if (!redisTemplate.hasKey(business.getId()+business.getName())){ List<Entinfo> list = entinfoService.list();
redisTemplate.opsForValue().set(business.getId()+ business.getName(),String.valueOf(3306+business.getId())); if (list.size()!=0){
redisService.setCacheList("entinfo",list);
}
if (business.getBusinessStates().equals("2")){
SysUser sysUser = remoteUserService.userById(business.getId());
sysUser.setRoleId(Long.valueOf(2));
remoteUserService.updateById(sysUser);
Entinfo build = Entinfo.builder()
.entCode("test_" + business.getId())
.ip("192.168.120.128")
.port(Integer.valueOf(3306 + Integer.valueOf(String.valueOf(business.getId())))).build();
Entinfo entinfo =entinfoService.selectEntinfo(build);
if (entinfo == null){
extracted(business); extracted(business);
} }
} }