增加问题诊断定时任务和查询接口，增加按channel查询工序开始和结束时间

zhangqian

2023-11-02 f2d80dbaa80a1283bf1c0fe9ae1d280832652d7f

 crontask/cron_task.go

@@ -7,7 +7,9 @@
   "apsClient/nsq"
   "apsClient/pkg/ecode"
   "apsClient/pkg/logx"
   "apsClient/serf"
   "apsClient/service"
   "apsClient/service/problem"
   "fmt"
   "github.com/go-co-op/gocron"
   "github.com/spf13/cast"
@@ -79,6 +81,10 @@
      s.Every(60).Seconds().Do(SyncProductionProgress) //同步生产数据
      s.Every(30).Seconds().Do(SyncTaskStatus)         //同步任务状态
   }

   s.Every(10).Seconds().Do(QueryClusterStatus) //查询集群节点数量
   s.Every(30).Seconds().Do(ProblemCheck)       //问题诊断

   s.StartAsync()
   return nil
}
@@ -152,3 +158,13 @@
      logx.Errorf("send pull data msg error:%v, msg:%+v", err.Error(), msg)
   }
}

func QueryClusterStatus() {
   clusterStatus, nodeQuantity := serf.QueryClusterStatusAndNodeQuantity()
   conf.Conf.SerfClusterStatus = clusterStatus
   conf.Conf.ClusterNodeQuantity = nodeQuantity
}

func ProblemCheck() {
   problem.Check()
}