commit

src/package/config/c_db/c_sqlx_mysql.go

@@ -1,54 +0,0 @@
-package c_db
-
-import (
-	"dcl_dispatch_server/src/package/config/c_log"
-	_ "github.com/go-sql-driver/mysql"
-	"github.com/jmoiron/sqlx"
-	"os"
-)
-
-var MysqlDb *sqlx.DB
-
-// InitSqlxMysql 初始化mysql连接
-// - charset 字符集 utf8、utf8mb4
-func InitSqlxMysql(username string, password string, ip string, port string, dbname string, charset string) {
-	var err error
-	// 连接数据库
-	// - parseTime 是否将数据库中的时间类型字段解析为 Go 中的 time.Time 类型。
-	// - loc 时间解析时使用的本地位置信息。通常设置为 "Local"。
-	MysqlDb, err = sqlx.Open("mysql", username+":"+password+"@tcp("+ip+":"+port+")/"+dbname+"?charset="+charset+"&parseTime=True&loc=Local")
-	if err != nil {
-		c_log.GlobalLogger.Error("程序退出。mysql连接失败：", err)
-		os.Exit(-1)
-	}
-
-	// 配置连接池
-	MysqlDb.SetMaxOpenConns(10)   // 设置最大打开连接数为 10
-	MysqlDb.SetMaxIdleConns(5)    // 设置最大空闲连接数为 5
-	MysqlDb.SetConnMaxLifetime(0) // 设置连接的最大生存时间为 0（不限制）
-	c_log.GlobalLogger.Info("mysql连接成功。")
-}
-
-func DoTx(sqlTemplate string, params []any) error {
-	// 插入到数据库
-	tx, err := MysqlDb.Beginx()
-	if err != nil {
-		c_log.GlobalLogger.Error("开启事务失败：", err)
-		return err
-	}
-	// 2 在事务中执行操作
-	_, err = tx.Exec(sqlTemplate, params...)
-	if err != nil {
-		c_log.GlobalLogger.Error("执行操作失败，回滚事务：", err)
-		tx.Rollback()
-		return err
-	}
-
-	// 如果所有操作成功，则提交事务
-	err = tx.Commit()
-	if err != nil {
-		c_log.GlobalLogger.Error("提交事务失败：", err)
-		return err
-	}
-	return nil
-}

src/package/config/c_db/c_sqlx_sqlfile.go

@@ -1,25 +0,0 @@
-package c_db
-
-import (
-	"dcl_dispatch_server/src/package/config/c_log"
-	"os"
-	"path/filepath"
-)
-
-var SqlFilesMap = map[string]string{}
-
-func InitSqlFilesMap(dir string) {
-	files, err := os.ReadDir(dir)
-	if err != nil {
-		c_log.GlobalLogger.Error("程序退出。加载sql文件错误：", err)
-		os.Exit(-1)
-	}
-
-	for _, file := range files {
-		if !file.IsDir() && filepath.Ext(file.Name()) == ".sql" {
-			filePath := filepath.Join(dir, file.Name())
-			SqlFilesMap[file.Name()] = filePath
-		}
-	}
-	c_log.GlobalLogger.Info("sql文件加载成功：", SqlFilesMap)
-}

src/package/domain/comm_with_k8s.go

@@ -1 +0,0 @@
-package domain

src/package/handler/old_interface_adapter.go

@@ -24,7 +24,7 @@ func Tick(c *gin.Context) {
 func State(c *gin.Context) {
 	taskId := c.Query("taskId")
 	state := c.Query("state")
-	podName := c.Query("podName") // todo 根据pod名称杀死pod并清理redis缓存
+	podName := c.Query("podName")
 	if taskId == "" || state == "" || podName == "" {
 		infra.GlobalLogger.Error("任务状态接口请求参数错误，需要GET请求和【taskId】【state】【podName】三个参数。")
 		c.JSON(http.StatusBadRequest, entity.HttpResult{Status: false, Code: "1003", Message: "请求参数格式错误。"})

src/package/handler/receive_task_state.go

@@ -1 +0,0 @@
-package handler

src/package/handler/stop_project.go

@@ -1 +0,0 @@
-package handler

src/package/infra/i_application.go

@@ -1,6 +1,7 @@
 package infra
 
 import (
+	"dcl_dispatch_server/src/package/util"
 	_ "embed"
 	"fmt"
 	"gopkg.in/yaml.v2"

src/package/infra/i_log.go

@@ -1,6 +1,7 @@
 package infra
 
 import (
+	"dcl_dispatch_server/src/package/util"
 	"fmt"
 	"github.com/sirupsen/logrus"
 	"os"

src/package/kafka/consumer.go

@@ -1 +0,0 @@
-package kafka

src/package/kafka/producer.go

@@ -1 +0,0 @@
-package kafka

src/package/util/u_file.go

@@ -6,6 +6,12 @@ import (
 	"path/filepath"
 )
 
+// CreateDir 创建目录
+func CreateDir(directory string) {
+	if _, err := os.Stat(directory); os.IsNotExist(err) {
+		_ = os.MkdirAll(directory, os.ModePerm)
+	}
+}
 func ReadFile(filePath string) (string, error) {
 	// 1 打开文件
 	file, err := os.Open(filePath)