package com.cfets.ts.u.limitapi.job;

 import java.text.SimpleDateFormat;

 import java.util.Date;

 import java.util.concurrent.Executors;

 import java.util.concurrent.ScheduledExecutorService;

 import java.util.concurrent.TimeUnit;

 import org.junit.Before;

 import jodd.datetime.JDateTime;

 import junit.runner.BaseTestRunner;

 import com.cfets.cwap.s.util.db.JdbcManager;

 import com.cfets.cwap.s.util.db.JdbcProperty;

 import com.cfets.ts.s.authentication.AuthenticationHelper;

 import com.cfets.ts.s.log.TsLogger;

 import com.cfets.ts.u.limitapi.LimitApiHelper;

 import com.cfets.ts.u.limitapi.service.impl.LimitServiceImpl;

 import com.cfets.ts.u.limitapi.util.DateUtils;

 import com.cfets.ts.u.limitapimgmt.LimitapimgmtProvider;

 import com.cfets.ts.u.limitapimgmt.entity.vo.FlowControlVO;

 public class LimitApilLinsenerJob{

     private static final TsLogger logger = TsLogger.getLogger(LimitServiceImpl.class);

     public static final int TASK_START_TIME = 1000;

     public static final int TASK_END_TIME = 5000;

     /*

     public static void main(String[] args) {

         ScheduledExecutorService timer =  Executors.newSingleThreadScheduledExecutor();

         TimerTask timerTask = new TimerTask(LimitApilLinsenerJob.TASK_END_TIME);

         logger.debug("起始时间：", new SimpleDateFormat("HH:mm").format(new Date()));

         //延时1s后，按3s的周期执行任务

         timer.scheduleAtFixedRate(timerTask, LimitApilLinsenerJob.TASK_START_TIME, LimitApilLinsenerJob.TASK_END_TIME, TimeUnit.MILLISECONDS);

     }*/

     public static class TimerTask implements Runnable{

         private final int sleepTime;

         private final SimpleDateFormat dateFormat;

         public TimerTask(int sleepTime){

             this.sleepTime = sleepTime;

             dateFormat = new SimpleDateFormat("HH:mm");

         }

         @Override

         public void run() {

             logger.debug("任务开始,当前时间：" + dateFormat.format(new Date()));

             try {

                 FlowControlVO flowControl = LimitapimgmtProvider.getLimitapimgmtProvider().findtimeAndthreshold();

                 logger.debug("start time is: " + flowControl.getStarttime() +  "|end time is:" +flowControl.getEndtime());

                 // 系统登录

                 JDateTime startTime = DateUtils.parseDate(flowControl.getStarttime(), LimitApiHelper.TIME_INTETERVAL_PARTTERN);

                 // 系统登录的结束时间

                 JDateTime endTime = DateUtils.parseDate(flowControl.getEndtime(), LimitApiHelper.TIME_INTETERVAL_PARTTERN);

                 // 当前时间

                 JDateTime currTime = new JDateTime();

                 logger.debug("currTime" + currTime);

                 if (!(currTime.isAfter(startTime) && currTime.isBefore(endTime))) {

                     logger.debug("模拟任务执行.....");

                     logger.debug("自动登出-----");

                     //此处先做删除登录用户信息，然后保存到用户登录历史信息表   authentication提供删除和保存方法

                 }

                 Thread.sleep(sleepTime);

             } catch (Exception e) {

                 logger.debug("This is e {}", e);

             }

             logger.debug("任务结束,当前时间：" + dateFormat.format(new Date()));

         }

     }

 }