From 2f3e3ec2c0cad87eab8a6d170caffc06a4e11c2d Mon Sep 17 00:00:00 2001
From: liuxiaolong <736321739@qq.com>
Date: 星期四, 07 十一月 2019 09:55:24 +0800
Subject: [PATCH] set getData 1 sec and add day task
---
src/main/java/com/cloud/count/listener/CountListener.java | 32 ++++++++++++++++++++++++++++++++
1 files changed, 32 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/cloud/count/listener/CountListener.java b/src/main/java/com/cloud/count/listener/CountListener.java
index 6a12900..a59e18e 100644
--- a/src/main/java/com/cloud/count/listener/CountListener.java
+++ b/src/main/java/com/cloud/count/listener/CountListener.java
@@ -25,6 +25,10 @@
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) {
@@ -32,7 +36,35 @@
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() {
--
Gitblit v1.8.0