package com.gzzn.omms.msgexchangeapi.runner;

import java.util.Date;
import java.util.concurrent.Executors;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.stereotype.Component;

import com.gzzn.omms.msgexchangeapi.redis.RedisKeyConstant;
import com.gzzn.omms.msgexchangeapi.redis.RedisService;
import com.gzzn.omms.msgexchangeapi.service.ICmoutmsgService;

@Component
public class AppRunner implements CommandLineRunner  {

	private static Logger logger = LoggerFactory.getLogger(AppRunner.class);
	
	@Autowired
	RedisService redisService;
	
	@Autowired
	private ICmoutmsgService cmoutmsgService;

	
	@Override
	public void run(String... args) throws Exception {
		
		logger.info("发送获取动态航班日计划的消息");
		
		
		Date nowDate = new Date();
		cmoutmsgService.sendSchdGetMsg(nowDate);
		
		//
		redisService.set(RedisKeyConstant.KEY_ISWAITSCHD, true);  //等待返回日计划状态
		redisService.set(RedisKeyConstant.KEY_WAITSCHDDATE,nowDate); //初始化消息进度
		
		logger.info("发送获取动态航班日计划的消息完成");
		
		Executors.newFixedThreadPool(1).execute(new SchdWaitRunner());
	}//end function run
}