1.新增复制定时任务接口

2.升级go版本到1.26.1

app/http/controllers/backend/cmd_controller.go

@@ -5,6 +5,7 @@ import (
 	"cron_admin/app/http/controllers"
 	"cron_admin/app/http/entities/backend"
 	cmd_services "cron_admin/app/services/cmd_service"
+
 	"github.com/gin-gonic/gin"
 )
 
@@ -37,6 +38,12 @@ func CmdDel(c *gin.Context) {
 	controllers.HandRes(c, nil, err)
 }
 
+func CmdCopy(c *gin.Context) {
+	request := controllers.GetRequest(c).(*backend.CmdCopyRequest)
+	err := cmd_services.Copy(request)
+	controllers.HandRes(c, nil, err)
+}
+
 func CmdStop(c *gin.Context) {
 	request := controllers.GetRequest(c).(*backend.CmdStopRequest)
 	err := cmd_services.Stop(request)

app/http/entities/backend/cmd.go

@@ -85,6 +85,10 @@ type CmdDeleteRequest struct {
 	CmdId int `json:"cmd_id" validate:"required" form:"cmd_id" example:""`
 }
 
+type CmdCopyRequest struct {
+	CmdId int `json:"cmd_id" validate:"required" form:"cmd_id" example:""`
+}
+
 type CmdStartRequest struct {
 	CmdId int `json:"cmd_id" validate:"required" form:"cmd_id" example:""`
 }

app/http/requestmapping/backend.go

@@ -41,6 +41,7 @@ var BackendRequestMap = map[string]func() interface{}{
 	common.ADMIN_OAUTH_V1 + "/cmd/list":       func() interface{} { return new(backend.CmdListRequest) },
 	common.ADMIN_OAUTH_V1 + "/cmd/add":        func() interface{} { return new(backend.CmdAddRequest) },
 	common.ADMIN_OAUTH_V1 + "/cmd/edit":       func() interface{} { return new(backend.CmdEditRequest) },
+	common.ADMIN_OAUTH_V1 + "/cmd/copy":       func() interface{} { return new(backend.CmdCopyRequest) },
 	common.ADMIN_OAUTH_V1 + "/cmd/del":        func() interface{} { return new(backend.CmdDeleteRequest) },
 	common.ADMIN_OAUTH_V1 + "/cmd/start":      func() interface{} { return new(backend.CmdStartRequest) },
 	common.ADMIN_OAUTH_V1 + "/cmd/stop":       func() interface{} { return new(backend.CmdStopRequest) },

app/http/routes/admin.go

@@ -7,6 +7,7 @@ import (
 	"cron_admin/app/http/trace"
 	"cron_admin/app/utils"
 	"cron_admin/config"
+
 	"github.com/gin-gonic/gin"
 	"github.com/qit-team/snow-core/http/middleware"
 )
@@ -56,6 +57,7 @@ func RegisterAdminRoute(router *gin.Engine) {
 					cmd.POST("/add", backend.CmdAdd)
 					cmd.POST("/edit", backend.CmdEdit)
 					cmd.DELETE("/del", backend.CmdDel)
+					cmd.POST("/copy", backend.CmdCopy)
 					cmd.POST("/start", backend.CmdStart)
 					cmd.POST("/stop", backend.CmdStop)
 					cmd.POST("/test/read", backend.CmdTestRead)

app/services/cmd_service/cmd_service.go

@@ -11,10 +11,11 @@ import (
 	"cron_admin/app/utils/excute"
 	"cron_admin/app/utils/mapstructure"
 	"fmt"
-	"github.com/ahmetb/go-linq/v3"
 	"strconv"
 	"strings"
 	"time"
+
+	"github.com/ahmetb/go-linq/v3"
 	"xorm.io/builder"
 )
 
@@ -81,6 +82,19 @@ func Del(request *backend.CmdDeleteRequest) (err error) {
 	return
 }
 
+func Copy(request *backend.CmdCopyRequest) (err error) {
+	var data croncmdmodel.CronCmd
+	_, err = croncmdmodel.GetInstance().GetDb().ID(request.CmdId).Get(&data)
+	if err != nil {
+		return
+	}
+	data.CmdId = 0
+	data.Status = common.CMD_STATUS_STOP
+	data.CmdName = data.CmdName + "_copy"
+	_, err = croncmdmodel.GetInstance().GetDb().InsertOne(data)
+	return
+}
+
 func Start(request *backend.CmdStartRequest) (err error) {
 	var data croncmdmodel.CronCmd
 	exists, err := croncmdmodel.GetInstance().GetDb().ID(request.CmdId).Get(&data)

go.mod

@@ -1,6 +1,6 @@
 module cron_admin
 
-go 1.21
+go 1.26.1
 
 require (
 	gitee.com/chengdu_blue_brothers/openapi-go-sdk v0.0.2