解析device和task的配置全部用内置方法处理

internal/app/service/task/delay_task.go

@@ -1,7 +1,6 @@
 package task
 
 import (
-	"encoding/json"
 	"fmt"
 	"time"
 
@@ -46,7 +45,7 @@ func (d *DelayTask) parseParameters() error {
 	}
 
 	var params DelayTaskParams
-	err := json.Unmarshal(d.executionTask.Task.Parameters, &params)
+	err := d.executionTask.Task.ParseParameters(&params)
 	if err != nil {
 		d.logger.Errorf("任务 %v: 解析参数失败: %v", d.executionTask.TaskID, err)
 		return fmt.Errorf("任务 %v: 解析参数失败: %v", d.executionTask.TaskID, err)

internal/app/service/task/release_feed_weight_task.go

@@ -122,7 +122,7 @@ func (r *ReleaseFeedWeightTask) parseParameters() error {
 	}
 
 	var params ReleaseFeedWeightTaskParams
-	err := json.Unmarshal(r.claimedLog.Task.Parameters, &params)
+	err := r.claimedLog.Task.ParseParameters(&params)
 	if err != nil {
 		r.logger.Errorf("任务 %v: 解析参数失败: %v", r.claimedLog.TaskID, err)
 		return fmt.Errorf("任务 %v: 解析参数失败: %v", r.claimedLog.TaskID, err)

internal/app/service/task/scheduler.go

@@ -1,7 +1,6 @@
 package task
 
 import (
-	"encoding/json"
 	"errors"
 	"sync"
 	"time"
@@ -305,7 +304,7 @@ func (s *Scheduler) analysisPlan(claimedLog *models.TaskExecutionLog) error {
 	var params struct {
 		PlanID uint `json:"plan_id"`
 	}
-	if err := json.Unmarshal(claimedLog.Task.Parameters, &params); err != nil {
+	if err := claimedLog.Task.ParseParameters(&params); err != nil {
 		s.logger.Errorf("解析任务参数中的计划ID失败，日志ID: %d, 错误: %v", claimedLog.ID, err)
 		return err
 	}