LEO commit

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()
+	})
 }