mirror of
https://github.com/lzh-1625/go_process_manager.git
synced 2025-10-05 16:06:51 +08:00
logic edit ,bug fix
This commit is contained in:
@@ -16,7 +16,7 @@ func (p *procApi) CreateNewProcess(ctx *gin.Context, req model.Process) {
|
||||
index, err := repository.ProcessRepository.AddProcessConfig(req)
|
||||
errCheck(ctx, err != nil, err)
|
||||
req.Uuid = index
|
||||
proc, err := logic.ProcessCtlLogic.RunNewProcess(req)
|
||||
proc, err := logic.ProcessCtlLogic.NewProcess(req)
|
||||
errCheck(ctx, err != nil, err)
|
||||
logic.ProcessCtlLogic.AddProcess(req.Uuid, proc)
|
||||
rOk(ctx, "Operation successful!", gin.H{
|
||||
|
@@ -207,24 +207,12 @@ func (p *processCtlLogic) UpdateProcessConfig(config model.Process) error {
|
||||
result.Config.cpuLimit = config.CpuLimit
|
||||
result.Config.AutoRestart = config.AutoRestart
|
||||
result.Config.compulsoryRestart = config.CompulsoryRestart
|
||||
result.StartCommand = strings.Split(config.Cmd, " ")
|
||||
result.StartCommand = strings.Fields(config.Cmd)
|
||||
result.WorkDir = config.Cwd
|
||||
result.Name = config.Name
|
||||
return nil
|
||||
}
|
||||
|
||||
func (p *processCtlLogic) RunNewProcess(config model.Process) (proc *ProcessBase, err error) {
|
||||
switch config.TermType {
|
||||
case constants.TERMINAL_STD:
|
||||
proc, err = RunNewProcessStd(config)
|
||||
case constants.TERMINAL_PTY:
|
||||
proc, err = RunNewProcessPty(config)
|
||||
default:
|
||||
err = errors.New("终端类型错误")
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (p *processCtlLogic) NewProcess(config model.Process) (proc *ProcessBase, err error) {
|
||||
switch config.TermType {
|
||||
case constants.TERMINAL_STD:
|
||||
@@ -236,3 +224,12 @@ func (p *processCtlLogic) NewProcess(config model.Process) (proc *ProcessBase, e
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (p *processCtlLogic) RunNewProcess(config model.Process) (proc *ProcessBase, err error) {
|
||||
proc, err = p.NewProcess(config)
|
||||
if err != nil {
|
||||
return
|
||||
}
|
||||
err = proc.Start()
|
||||
return
|
||||
}
|
||||
|
@@ -145,11 +145,3 @@ func NewProcessPty(pconfig model.Process) *ProcessBase {
|
||||
processPty.setProcessConfig(pconfig)
|
||||
return &p
|
||||
}
|
||||
|
||||
func RunNewProcessPty(pconfig model.Process) (*ProcessBase, error) {
|
||||
processPty := NewProcessPty(pconfig)
|
||||
if err := processPty.Start(); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return processPty, nil
|
||||
}
|
||||
|
@@ -147,11 +147,3 @@ func NewProcessPty(pconfig model.Process) *ProcessBase {
|
||||
processPty.setProcessConfig(pconfig)
|
||||
return &p
|
||||
}
|
||||
|
||||
func RunNewProcessPty(pconfig model.Process) (*ProcessBase, error) {
|
||||
processPty := NewProcessPty(pconfig)
|
||||
if err := processPty.Start(); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return processPty, nil
|
||||
}
|
||||
|
@@ -145,11 +145,3 @@ func NewProcessStd(pconfig model.Process) *ProcessBase {
|
||||
processStd.setProcessConfig(pconfig)
|
||||
return &p
|
||||
}
|
||||
|
||||
func RunNewProcessStd(pconfig model.Process) (*ProcessBase, error) {
|
||||
processStd := NewProcessStd(pconfig)
|
||||
if err := processStd.Start(); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return processStd, nil
|
||||
}
|
||||
|
@@ -83,3 +83,11 @@ func JsonStrToStruct[T any](str string) T {
|
||||
json.Unmarshal([]byte(str), &data)
|
||||
return data
|
||||
}
|
||||
|
||||
func StructToJsonStr[T any](data T) string {
|
||||
jsonStr, err := json.Marshal(data)
|
||||
if err != nil {
|
||||
return ""
|
||||
}
|
||||
return string(jsonStr)
|
||||
}
|
||||
|
Reference in New Issue
Block a user