feat:新增企业入驻新增数据库

cloud-auth/pom.xml

@@ -62,6 +62,11 @@
             <artifactId>mysql-connector-j</artifactId>
         </dependency>
 
+        <dependency>
+            <groupId>com.muyu</groupId>
+            <artifactId>cloud-common-saas</artifactId>
+        </dependency>
+
     </dependencies>
 
     <build>

cloud-auth/src/main/java/com/muyu/auth/controller/TokenController.java

@@ -6,6 +6,7 @@ import com.muyu.auth.form.LoginBody;
 import com.muyu.auth.form.RegisterBody;
 import com.muyu.auth.service.SysFirmService;
 import com.muyu.auth.service.SysLoginService;
+import com.muyu.cloud.common.many.datasource.constents.DatasourceContent;
 import com.muyu.common.core.domain.Result;
 import com.muyu.common.core.utils.JwtUtils;
 import com.muyu.common.core.utils.StringUtils;
@@ -13,6 +14,7 @@ import com.muyu.common.security.auth.AuthUtil;
 import com.muyu.common.security.service.TokenService;
 import com.muyu.common.security.utils.SecurityUtils;
 import com.muyu.common.system.domain.LoginUser;
+import lombok.extern.log4j.Log4j2;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.DeleteMapping;
 import org.springframework.web.bind.annotation.PostMapping;
@@ -21,11 +23,17 @@ import org.springframework.web.bind.annotation.RestController;
 
 import jakarta.servlet.http.HttpServletRequest;
 
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.SQLException;
+import java.sql.Statement;
+
 /**
  * token 控制
  *
  * @author muyu
  */
+@Log4j2
 @RestController
 public class TokenController {
     @Autowired
@@ -81,9 +89,39 @@ public class TokenController {
         return Result.success();
     }
 
+    /**
+     * 企业入入驻
+     * @param settlement
+     * @return
+     */
     @PostMapping("/enterprise")
     public Result<?> enterprise( @RequestBody EnterpriseSettlement settlement){
+
+        String createDatabaseUrl="jdbc:mysql://"+ DatasourceContent.IP+":"+DatasourceContent.PORT+"?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8";
+        String createDatabaseSql = "CREATE DATABASE IF NOT EXISTS " + settlement.getDatabaseName() + ";";
+        try (Connection adminConn = DriverManager.getConnection(createDatabaseUrl, DatasourceContent.USER_NAME, DatasourceContent.PASSWORD);
+             Statement stmt = adminConn.createStatement()) {
+
+            boolean success = stmt.execute(createDatabaseSql);
+            if (success) {
+                log.info("数据库 {} 创建成功", settlement.getDatabaseName());
+
+            } else {
+                log.warn("数据库 {} 创建失败", settlement.getDatabaseName());
+            }
+
+        } catch (SQLException e) {
+            e.printStackTrace();
+            log.error("连接数据库时发生错误或创建数据库失败", e);
+        }
+        //企业入组
         sysLoginService.enterprise(settlement.getDatabaseName(),settlement.getFirmName());
+
+
+
+
+
+
         return Result.success();
     }
 }

cloud-common/cloud-common-saas/pom.xml

@@ -11,6 +11,10 @@
 
     <artifactId>cloud-common-saas</artifactId>
 
+    <description>
+        cloud-common-saas 模块
+    </description>
+
     <properties>
         <maven.compiler.source>17</maven.compiler.source>
         <maven.compiler.target>17</maven.compiler.target>
@@ -31,6 +35,11 @@
         </dependency>
 
 
+        <dependency>
+            <groupId>mysql</groupId>
+            <artifactId>mysql-connector-java</artifactId>
+            <version>8.0.29</version>
+        </dependency>
 
 
     </dependencies>

cloud-common/cloud-common-saas/src/main/java/com/muyu/cloud/common/many/datasource/ManyDataSource.java

@@ -40,7 +40,7 @@ import java.util.Map;
 public class ManyDataSource implements ApplicationRunner{
     private List<EntInfo> dataSourceInfoList(){
         RemoteSaaSService remoteSaaSService = SpringUtils.getBean(RemoteSaaSService.class);
-Result<List<Datasource>> tableDataInfoResult = remoteSaaSService.findDatabaseList();
+        Result<List<Datasource>> tableDataInfoResult = remoteSaaSService.findDatabaseList();
         if (tableDataInfoResult==null){
             throw new SaaSException("saas远调数据源错误");
         }

cloud-common/cloud-common-saas/src/main/java/com/muyu/cloud/common/many/datasource/constents/DatasourceContent.java

@@ -16,4 +16,8 @@ public class DatasourceContent {
     public final static String IP = "47.101.53.251";
 
     public final static Integer PORT = 3306;
+
+    public static String getDatasourceUrl(String databaseName) {
+        return String.format(DATASOURCE_URL,USER_NAME,PASSWORD,IP,PORT, databaseName);
+    }
 }