commit

src/main/main.go

@@ -5,11 +5,11 @@ package main
 */
 
 import (
-	"dcl_dispatch_server/src/package/global"
-	"dcl_dispatch_server/src/package/handler"
+	"dcl_dispatch_server/src/package/application"
 	"dcl_dispatch_server/src/package/infra"
-	"dcl_dispatch_server/src/package/middleware"
-	"dcl_dispatch_server/src/package/service"
+	"dcl_dispatch_server/src/package/infra/global"
+	"dcl_dispatch_server/src/package/infra/handler"
+	"dcl_dispatch_server/src/package/infra/middleware"
 	"dcl_dispatch_server/src/package/util"
 	_ "embed"
 	"encoding/json"
@@ -74,8 +74,8 @@ func init() {
 func main() {
 
 	// 启动任务处理进程
-	go service.RunWaitingUser()
-	go service.RunWaitingCluster()
+	go application.RunWaitingUser()
+	go application.RunWaitingCluster()
 
 	// 启动 web 服务器
 	{

src/package/service/run_task.go → src/package/application/run_task.go

@@ -1,10 +1,10 @@
-package service
+package application
 
 import (
 	"dcl_dispatch_server/src/package/domain/project"
 	"dcl_dispatch_server/src/package/domain/task_cache"
-	"dcl_dispatch_server/src/package/global"
 	"dcl_dispatch_server/src/package/infra"
+	"dcl_dispatch_server/src/package/infra/global"
 	"dcl_dispatch_server/src/package/infra/redis"
 	"dcl_dispatch_server/src/package/util"
 	"fmt"
@@ -21,7 +21,7 @@ import (
  负责运行集群等待队列中的任务
 */
 
-// RunWaitingUser 判断用户等待队列中的任务是否可以加入到集群等待队列
+// 判断用户等待队列中的任务是否可以加入到集群等待队列
 func RunWaitingUser() {
 	infra.GlobalLogger.Infof("启动【用户等待队列】监控进程。")
 	for {

src/package/handler/old_interface_adapter.go → src/package/infra/handler/old_interface_adapter.go

@@ -2,9 +2,9 @@ package handler
 
 import (
 	"dcl_dispatch_server/src/package/domain/task_cache"
-	"dcl_dispatch_server/src/package/entity"
-	"dcl_dispatch_server/src/package/global"
 	"dcl_dispatch_server/src/package/infra"
+	"dcl_dispatch_server/src/package/infra/entity"
+	"dcl_dispatch_server/src/package/infra/global"
 	"dcl_dispatch_server/src/package/util"
 	"github.com/gin-gonic/gin"
 	"net/http"

src/package/handler/start_project.go → src/package/infra/handler/start_project.go

@@ -3,9 +3,9 @@ package handler
 import (
 	"bytes"
 	"dcl_dispatch_server/src/package/domain/project"
-	"dcl_dispatch_server/src/package/entity"
-	"dcl_dispatch_server/src/package/global"
 	"dcl_dispatch_server/src/package/infra"
+	"dcl_dispatch_server/src/package/infra/entity"
+	"dcl_dispatch_server/src/package/infra/global"
 	"dcl_dispatch_server/src/package/infra/redis"
 	"github.com/gin-gonic/gin"
 	"io"

src/package/middleware/m_validate_header.go → src/package/infra/middleware/m_validate_header.go

@@ -1,7 +1,7 @@
 package middleware
 
 import (
-	"dcl_dispatch_server/src/package/entity"
+	"dcl_dispatch_server/src/package/infra/entity"
 	"github.com/gin-gonic/gin"
 	"net/http"
 	"strings"

src/package/infra/redis/comm_with_redis.go

@@ -3,8 +3,8 @@ package redis
 import (
 	"dcl_dispatch_server/src/package/domain/project"
 	"dcl_dispatch_server/src/package/domain/task_cache"
-	"dcl_dispatch_server/src/package/global"
 	"dcl_dispatch_server/src/package/infra"
+	"dcl_dispatch_server/src/package/infra/global"
 	"dcl_dispatch_server/src/package/util"
 	"errors"
 )