package com.cloud.attendance.config;
|
|
import com.cloud.attendance.dao.AttDayDao;
|
import com.cloud.attendance.service.impl.EsAndErlangStartLoading;
|
import com.cloud.attendance.service.impl.ScheduledDayData;
|
import com.cloud.attendance.utils.HttpClient;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.io.IOUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.core.io.Resource;
|
import org.springframework.stereotype.Component;
|
|
import javax.servlet.ServletContextEvent;
|
import javax.servlet.ServletContextListener;
|
import javax.servlet.annotation.WebListener;
|
import java.io.IOException;
|
import java.nio.charset.Charset;
|
|
@Slf4j
|
@WebListener
|
@Component
|
public class MyServletContextListener implements ServletContextListener {
|
|
@Value("classpath:EsAttRecordToDB_1903.json")
|
private Resource esjson;
|
|
@Autowired
|
private AttDayDao attDayDao;
|
|
@Autowired
|
private ScheduledDayData sdData;
|
@Autowired
|
private EsAndErlangStartLoading erlangStart;
|
|
|
@Override
|
public void contextInitialized(ServletContextEvent sce){
|
log.info(sce.getServletContext().getServletContextName()+"wp init listener");
|
try {
|
String areaData = IOUtils.toString(esjson.getInputStream() , Charset.forName("UTF-8").toString());
|
// 给某一个 httpClient 赋值 esjson
|
log.info("为 esJson 赋值,监听启动。");
|
HttpClient.setEsJson(areaData);
|
|
erlangStart.reportCurrentByDay(); // 启动 添加今天数据
|
log.info("监听启动添加人员信息。");
|
|
// erlangStart.getMouthDayRecord(); // 执行 每天 es 数据汇总 18-12-19 添加 历史记录 使用
|
}catch (IOException e){
|
e.printStackTrace();
|
} /*catch (ParseException e) {
|
e.printStackTrace();
|
}*/
|
}
|
|
@Override
|
public void contextDestroyed(ServletContextEvent sce) {
|
log.info(sce.getServletContext().getServletContextName()+"wp listener destroy.........");
|
}
|
}
|
