diff --git a/schedule/Scheduler.Ctrl.go b/schedule/Scheduler.Ctrl.go index 24034f1..d0c6723 100644 --- a/schedule/Scheduler.Ctrl.go +++ b/schedule/Scheduler.Ctrl.go @@ -149,26 +149,6 @@ func(schedsrv *SchedulerSrv)LoadSchedTaskData()(err error){ schedsrv.SortUnplannedTask() return } -// 对调度任务进行排序 -func(schedsrv *SchedulerSrv)SortUnplannedTask(){ - var ( - i int - sortTasks []interface{} - ) - - sortTasks = []interface{}{} - for i = 0; i < len(schedsrv.UnPlannedTaskArray); i++ { - sortTasks = append(sortTasks, schedsrv.UnPlannedTaskArray[i]) - } - - SortBody(sortTasks,func(p,q *interface{}) bool{ - v :=reflect.ValueOf(*p) - i := v.FieldByName("Create_time") - v =reflect.ValueOf(*q) - j := v.FieldByName("Create_time") - return i.String() < j.String() - }) -} // 撤回计划,将未下达的任务全部更新为未计划 func(schedsrv *SchedulerSrv)RetrieveSchedule(){ var schedTask TaskSrv @@ -748,4 +728,30 @@ func(schedsrv *SchedulerSrv)ParseSerialOrderEvent(event string)(err error){ } return +} +// 对调度任务进行排序 +func(schedsrv *SchedulerSrv)SortUnplannedTask(){ + var ( + i int + sortTasks []interface{} + ) + + // 计算排序任务的排序属性 + for i = 0; i < len(schedsrv.UnPlannedTaskArray); i++ { + + } + + // 准备排序 + sortTasks = []interface{}{} + for i = 0; i < len(schedsrv.UnPlannedTaskArray); i++ { + sortTasks = append(sortTasks, schedsrv.UnPlannedTaskArray[i]) + } + + SortBody(sortTasks,func(p,q *interface{}) bool{ + v :=reflect.ValueOf(*p) + i := v.FieldByName("Create_time") + v =reflect.ValueOf(*q) + j := v.FieldByName("Create_time") + return i.String() < j.String() + }) } \ No newline at end of file