test:()修改企业入驻
parent
efa6861d2f
commit
59c16de298
|
@ -7,6 +7,7 @@ import com.muyu.auth.form.RegisterBody;
|
||||||
import com.muyu.auth.service.SysFirmService;
|
import com.muyu.auth.service.SysFirmService;
|
||||||
import com.muyu.auth.service.SysLoginService;
|
import com.muyu.auth.service.SysLoginService;
|
||||||
import com.muyu.cloud.common.many.datasource.constents.DatasourceContent;
|
import com.muyu.cloud.common.many.datasource.constents.DatasourceContent;
|
||||||
|
import com.muyu.common.core.constant.SecurityConstants;
|
||||||
import com.muyu.common.core.domain.Result;
|
import com.muyu.common.core.domain.Result;
|
||||||
import com.muyu.common.core.utils.JwtUtils;
|
import com.muyu.common.core.utils.JwtUtils;
|
||||||
import com.muyu.common.core.utils.StringUtils;
|
import com.muyu.common.core.utils.StringUtils;
|
||||||
|
@ -14,6 +15,8 @@ import com.muyu.common.security.auth.AuthUtil;
|
||||||
import com.muyu.common.security.service.TokenService;
|
import com.muyu.common.security.service.TokenService;
|
||||||
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.remote.RemoteUserService;
|
||||||
import io.swagger.v3.oas.annotations.Operation;
|
import io.swagger.v3.oas.annotations.Operation;
|
||||||
import io.swagger.v3.oas.annotations.tags.Tag;
|
import io.swagger.v3.oas.annotations.tags.Tag;
|
||||||
import lombok.extern.log4j.Log4j2;
|
import lombok.extern.log4j.Log4j2;
|
||||||
|
@ -32,6 +35,7 @@ import java.sql.Connection;
|
||||||
import java.sql.DriverManager;
|
import java.sql.DriverManager;
|
||||||
import java.sql.SQLException;
|
import java.sql.SQLException;
|
||||||
import java.sql.Statement;
|
import java.sql.Statement;
|
||||||
|
import java.util.Date;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* token 控制
|
* token 控制
|
||||||
|
@ -51,6 +55,9 @@ public class TokenController {
|
||||||
@Autowired
|
@Autowired
|
||||||
private SysFirmService sysFirmService;
|
private SysFirmService sysFirmService;
|
||||||
|
|
||||||
|
@Autowired
|
||||||
|
private RemoteUserService remoteUserService;
|
||||||
|
|
||||||
@PostMapping("login")
|
@PostMapping("login")
|
||||||
@Operation(summary = "登录", description = "登录")
|
@Operation(summary = "登录", description = "登录")
|
||||||
public Result<?> login (@RequestBody LoginBody form) {
|
public Result<?> login (@RequestBody LoginBody form) {
|
||||||
|
@ -120,6 +127,13 @@ public class TokenController {
|
||||||
} else {
|
} else {
|
||||||
log.warn("数据库 {} 创建成功", settlement.getDatabaseName());
|
log.warn("数据库 {} 创建成功", settlement.getDatabaseName());
|
||||||
|
|
||||||
|
|
||||||
|
SysUser sysUser = new SysUser();
|
||||||
|
sysUser.setCreateTime(new Date());
|
||||||
|
sysUser.setUserName(settlement.getFirmName());
|
||||||
|
sysUser.setDatabaseName(settlement.getDatabaseName());
|
||||||
|
remoteUserService.addUser(sysUser, SecurityConstants.INNER);
|
||||||
|
|
||||||
// 切换到新的数据库连接
|
// 切换到新的数据库连接
|
||||||
Connection connection = null;
|
Connection connection = null;
|
||||||
try {
|
try {
|
||||||
|
|
Loading…
Reference in New Issue