feat: optimize task

app/console/commands/monitoring.go

@@ -56,7 +56,6 @@ func (receiver *Monitoring) Handle(console.Context) error {
 	}
 
 	info := tools.GetMonitoringInfo()
-
 	translate := facades.Lang(context.Background())
 
 	// 去除部分数据以减少数据库存储

internal/services/php.go

@@ -328,8 +328,7 @@ func (r *PHPImpl) InstallExtension(slug string) error {
 		return err
 	}
 
-	NewTaskImpl().Process(task.ID)
-	return nil
+	return NewTaskImpl().Process(task.ID)
 }
 
 func (r *PHPImpl) UninstallExtension(slug string) error {
@@ -353,8 +352,7 @@ func (r *PHPImpl) UninstallExtension(slug string) error {
 		return err
 	}
 
-	NewTaskImpl().Process(task.ID)
-	return nil
+	return NewTaskImpl().Process(task.ID)
 }
 
 func (r *PHPImpl) checkExtension(slug string) bool {

internal/services/plugin.go

@@ -120,8 +120,7 @@ func (r *PluginImpl) Install(slug string) error {
 		return errors.New("创建任务失败")
 	}
 
-	r.task.Process(task.ID)
-	return nil
+	return r.task.Process(task.ID)
 }
 
 // Uninstall 卸载插件
@@ -166,8 +165,7 @@ func (r *PluginImpl) Uninstall(slug string) error {
 		return errors.New("创建任务失败")
 	}
 
-	r.task.Process(task.ID)
-	return nil
+	return r.task.Process(task.ID)
 }
 
 // Update 更新插件
@@ -212,6 +210,5 @@ func (r *PluginImpl) Update(slug string) error {
 		return errors.New("创建任务失败")
 	}
 
-	r.task.Process(task.ID)
-	return nil
+	return r.task.Process(task.ID)
 }

internal/services/task.go

@@ -14,12 +14,8 @@ func NewTaskImpl() *TaskImpl {
 	return &TaskImpl{}
 }
 
-func (r *TaskImpl) Process(taskID uint) {
-	err := facades.Queue().Job(&jobs.ProcessTask{}, []any{taskID}).Dispatch()
-	if err != nil {
-		facades.Log().Info("[面板][TaskService] 运行任务失败: " + err.Error())
-		return
-	}
+func (r *TaskImpl) Process(taskID uint) error {
+	return facades.Queue().Job(&jobs.ProcessTask{}, []any{taskID}).Dispatch()
 }
 
 func (r *TaskImpl) DispatchWaiting() error {
@@ -29,7 +25,9 @@ func (r *TaskImpl) DispatchWaiting() error {
 	}
 
 	for _, task := range tasks {
-		r.Process(task.ID)
+		if err := r.Process(task.ID); err != nil {
+			return err
+		}
 	}
 
 	return nil

internal/task.go

@@ -1,6 +1,6 @@
 package internal
 
 type Task interface {
-	Process(taskID uint)
+	Process(taskID uint) error
 	DispatchWaiting() error
 }