package com.cloud.count.listener;
import com.cloud.count.dao.CountDao;
import com.cloud.count.model.CountState;
import com.cloud.count.model.People;
import com.cloud.count.service.CountService;
import com.cloud.count.service.serviceImpl.CountServiceImpl;
import com.cloud.count.utils.XmlUtil;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationListener;
import org.springframework.context.event.ContextRefreshedEvent;
import org.springframework.stereotype.Service;

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.Date;
/**
 * 计数监听器
 */

public class CountListener implements ApplicationListener<ContextRefreshedEvent> {
    static ServerSocket server;
    static Integer port = 2010;
    static boolean isServerReboot = false;

    @Autowired
    private CountDao dao;

    @Override
    public void onApplicationEvent(ContextRefreshedEvent contextRefreshedEvent) {

        if(contextRefreshedEvent.getApplicationContext().getParent() !=null){
            return;
        }
        op: if(!isServerReboot){
            isServerReboot = true;
            CountState state = dao.getCountState();//恢复统计状态
            Date nowDate = new Date();
            Date BaseDate = new Date(state.getBaseTime()*1000L);
            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
            if(!sdf.format(nowDate).equals(sdf.format(BaseDate))){//历史数据不等于当天
//                CountServiceImpl.baseEnters  = people.getEnters();
//                CountServiceImpl.baseExits = people.getExits();
//                CountServiceImpl.realtimeBaseEnters = people.getEnters();
//                CountServiceImpl.realtimebBaseExits =  people.getExits();
//                CountServiceImpl.errorCount = 0;

                People initPeople = new People();
                initPeople.setEnters(0);
                initPeople.setExits(0);
                CountServiceImpl.initCountArgs(initPeople);
                CountServiceImpl.errorCount = 0;
                break op;
            }
            //还原状态
            CountServiceImpl.baseEnters  = state.getBaseEnters();
            CountServiceImpl.baseExits = state.getBaseExits();
            CountServiceImpl.totalEnters = state.getTotalEnters();
            CountServiceImpl.totalExits = state.getTotalExits();
            CountServiceImpl.realtimeBaseEnters = state.getRealtimeBaseEnters();
            CountServiceImpl.realtimebBaseExits = state.getRealtimeBaseExits();
            CountServiceImpl.errorCount = state.getErrorCount();
        }
        new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    server = new ServerSocket(port);
                }
                catch (IOException e){
                    e.printStackTrace();
                }

                while (true){
                    Socket client = null;
                    try{
                        client = server.accept();
                        new Thread(new CountThread(client)).start();
                    }catch (IOException ex){

                    }
                }
            }
        }).start();
    }
}