fix：完善逻辑

kongdeqiang

2025-12-02 3bd9c82bf2b67833ad60fc9522da0b50b63f5d2a

 src/main/java/com/wgcloud/task/ScheduledTask.java

@@ -78,13 +78,15 @@
    private ServletContext servletContext;

    /**
     * 30秒后执行，每2分钟检测一次
     * 30秒后执行，每1分钟检测一次
     * 检测ospf状态
     */
    @Scheduled(initialDelay = 30000L, fixedRate = 2 * 60 * 1000)
    public void ospfDownCheckTask() {
        logger.info("ospfDownCheckTask------------" + DateUtil.getDateTimeString(new Date()));
        ospfInfoService.getDetailedOspfNeighborInfo();
        logger.info("ospf链路检测任务开始------------" + DateUtil.getDateTimeString(new Date()));
        //ospfInfoService.getDetailedOspfNeighborInfo();
        ospfInfoService.getRouterStatus();
        logger.info("ospf链路检测任务结束------------" + DateUtil.getDateTimeString(new Date()));
    }

    /**
@@ -124,7 +126,7 @@
     * 20秒后执行，之后每6分钟刷新一次
     * 初始化一些任务
     */
    @Scheduled(initialDelay = 20000L, fixedRate = 6 * 60 * 1000)
    //@Scheduled(initialDelay = 20000L, fixedRate = 6 * 60 * 1000)
    public void initTask() {
        logger.info("initTask------------" + DateUtil.getDateTimeString(new Date()));
        try {
@@ -160,7 +162,7 @@
     * 15秒后执行，之后每小时刷新一次
     * 获取所有磁盘总容量之和，缓存起来
     */
    @Scheduled(initialDelay = 15000L, fixedRate = 60 * 60 * 1000)
    //@Scheduled(initialDelay = 15000L, fixedRate = 60 * 60 * 1000)
    public void sumDiskSizeCacheTask() {
        logger.info("sumDiskSizeCacheTask------------" + DateUtil.getDateTimeString(new Date()));
        try {
@@ -174,7 +176,7 @@
     * 150秒后执行，之后每隔15分钟执行, 单位：ms。
     * snmp设备监测
     */
    @Scheduled(initialDelay = 150000L, fixedRateString = "${base.snmpTimes}" + "000")
    //@Scheduled(initialDelay = 150000L, fixedRateString = "${base.snmpTimes}" + "000")
    public void snmpInfoTask() {
        if (!StaticKeys.NODE_MASTER.equals(commonConfig.getNodeType())) {
            logger.info("slave节点不执行snmp设备监测任务");
@@ -211,7 +213,7 @@
     * 60秒后执行，之后每隔10分钟执行, 单位：ms。
     * 检测服务接口
     */
    @Scheduled(initialDelay = 60000L, fixedRateString = "${base.heathTimes}" + "000")
    //@Scheduled(initialDelay = 60000L, fixedRateString = "${base.heathTimes}" + "000")
    public void heathMonitorTask() {
        if (!StaticKeys.NODE_MASTER.equals(commonConfig.getNodeType())) {
            logger.info("slave节点不执行检测服务接口任务");
@@ -247,7 +249,7 @@
     * 90秒后执行，之后每隔15分钟执行, 单位：ms。
     * 检测数通PING设备
     */
    @Scheduled(initialDelay = 90000L, fixedRateString = "${base.dceTimes}" + "000")
    //@Scheduled(initialDelay = 90000L, fixedRateString = "${base.dceTimes}" + "000")
    public void dceInfoTask() {
        if (!StaticKeys.NODE_MASTER.equals(commonConfig.getNodeType())) {
            logger.info("slave节点不执行检测数通设备PING任务");
@@ -283,7 +285,7 @@
     * 120秒后执行，之后每隔120分钟执行, 单位：ms。
     * 数据表监控
     */
    @Scheduled(initialDelay = 120000L, fixedRateString = "${base.dbTableTimes}" + "000")
    //@Scheduled(initialDelay = 120000L, fixedRateString = "${base.dbTableTimes}" + "000")
    public void tableCountTask() {
        if (!StaticKeys.NODE_MASTER.equals(commonConfig.getNodeType())) {
            logger.info("slave节点不执行数据表监控任务");
@@ -302,7 +304,7 @@
     * 300秒后执行，每6分钟检测一次
     * 检测主机是否已经下线，检测进程、端口、docker、文件防篡改是否恢复
     */
    @Scheduled(initialDelay = 300000L, fixedRate = 5 * 60 * 1000)
    //@Scheduled(initialDelay = 300000L, fixedRate = 5 * 60 * 1000)
    public void hostDownCheckTask() {
        if (!StaticKeys.NODE_MASTER.equals(commonConfig.getNodeType())) {
            logger.info("slave节点不执行检测主机/进程/docker/端口是否恢复任务");