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);
            }
        }

    }
}