package com.fzzy.gateway;

import com.fzzy.api.data.ApiParam;
import com.fzzy.api.entity.ApiConfs;
import com.fzzy.api.service.*;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.utils.RedisUtil;
import com.fzzy.gateway.api.GatewayRemoteManager;
import com.fzzy.gateway.entity.GatewayConf;
import com.fzzy.gateway.service.GatewayConfService;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.time.DateUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

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

/**
 * 网关相关的定时器
 */
@Slf4j
@Component(GatewayTimerScheduled.BEAN_ID)
public class GatewayTimerScheduled {

    public static final String BEAN_ID = "gateway.timerScheduled";

    @Resource
    private GatewayConfService confService;

    @Resource
    private GatewayRemoteManager gatewayRemoteManager;


    /**
     * <p>
     * 固定时间：每间隔10分钟执行一次
     */
    @Scheduled(cron = "0 0/10 * * * ? ")
    public void scheduled() {

        //网关的心跳执行
        doHeartbeat();

    }


    /**
     * 执行网关心跳
     */
    private void doHeartbeat() {

        //获取缓存中的网关信息
        List<GatewayConf> list = confService.getCacheConfList();
        if (null == list || list.isEmpty()) {
            log.warn("------系统为获取到网关配置信息，不执行定时心跳-----");
            return;
        }

        for (GatewayConf conf : list) {
            gatewayRemoteManager.getRemoteService(conf.getPushProtocol()).heartbeat(conf);
        }
    }
    
}