增加定时校验网关是否在线

czt

2026-01-30 312710045c2b5d84ed0dc97af4a4fe7704f619d5

增加定时校验网关是否在线

 fzzy-igdss-core/src/main/java/com/fzzy/igds/service/GatewaySerService.java

@@ -139,10 +139,9 @@

        if(isUpdateTime){
            //心跳时间
            ser.setHeartbeatTime(new Date());
            ser.setUpdateTime(new Date());
        }

        ser.setUpdateTime(new Date());
        ser.setStatus(status);
        gatewaySerMapper.updateById(ser);

@@ -159,7 +158,31 @@

        //删除缓存
        delCache(ser);
    }

    /**
     * èŽ·å–组织下所有网关信息
     * @param companyId
     * @return
     */
    public List<GatewaySer> getCacheSer(String companyId) {
        if (StringUtils.isEmpty(companyId)) {
            companyId = ContextUtil.getCompanyId();
        }

        List<GatewaySer> result = new ArrayList<>();
        String patten = RedisConst.buildKey(companyId, RedisConst.KEY_GATEWAY_SER_LIST) + "*";
        Collection<String> keys = redisCache.keys(patten);
        if (null != keys) {
            for (String key : keys) {
                result.add((GatewaySer) redisCache.getCacheObject(key));
            }
        }
        if(result.isEmpty()){
            result = getAllSer();
            this.setCacheSer(result);
        }
        return result;
    }

    /**

 fzzy-igdss-core/src/main/java/com/fzzy/igds/timer/GatewayScheduled.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,54 @@
package com.fzzy.igds.timer;

import com.fzzy.igds.constant.Constant;
import com.fzzy.igds.domain.GatewaySer;
import com.fzzy.igds.service.GatewaySerService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.util.Date;
import java.util.List;

/**
 * @Description  å®šæ—¶æ ¸éªŒç½‘关是否在线并更新
 * @Author CZT
 * @Date 2026/1/30 9:47
 */
@Slf4j
@Component
public class GatewayScheduled {

    @Resource
    private GatewaySerService gatewaySerService;

    /**
     * æ¯15分执行一次
     */
    @Scheduled(cron = "0 0/15 * * * ?")
    public void timer() {

        //获取缓存中所有网关
        List<GatewaySer> list = gatewaySerService.getCacheSer(null);
        if(null == list || list.isEmpty()){
            log.error("------------获取网关信息为空，不校验是否离线------------");
            return;
        }

        Date cur = new Date();
        Date update;
        long min = 0;
        for (GatewaySer gatewaySer : list) {
            update = gatewaySer.getUpdateTime();
            //计算分钟差
            min = (cur.getTime() - update.getTime())/(60*1000);

            if(min > 15){
                //设置网关离线
                gatewaySerService.updateStatus(gatewaySer, Constant.YN_N, false);
            }
        }

    }
}

 fzzy-igdss-core/src/main/java/com/fzzy/igds/timer/JobWarnService.java

@@ -42,8 +42,7 @@
    /**
     * æ¯å¤©ä¸¤ç‚¹æ‰§è¡Œï¼šè¿˜æ¬¾æé†’
     */
//    @Scheduled(cron = "0 0 2 * * ?")
    @Scheduled(cron = "0 6 10 * * ?")
    @Scheduled(cron = "0 0 2 * * ?")
    public void timer() {
        doExe();
    }