From 88152d7c8f73df91fe54be9335c90d2d42943601 Mon Sep 17 00:00:00 2001
From: 陈杰 <504987307@qq.com>
Date: Fri, 5 Jun 2020 11:04:55 +0800
Subject: [PATCH] 1

---
 cloud/quartz/src/main/java/com/sincere/quartz/mapper/YxyMapper.java              |  2 ++
 cloud/quartz/src/main/java/com/sincere/quartz/service/YxyService.java            |  2 ++
 cloud/quartz/src/main/java/com/sincere/quartz/service/impl/YxyServiceImpl.java   |  6 ++++++
 cloud/quartz/src/main/java/com/sincere/quartz/third/yixueyun/YXYReadService.java | 15 +++++++++++----
 cloud/quartz/src/main/resources/mapper/YxyMapper.xml                             |  3 +++
 5 files changed, 24 insertions(+), 4 deletions(-)

diff --git a/cloud/quartz/src/main/java/com/sincere/quartz/mapper/YxyMapper.java b/cloud/quartz/src/main/java/com/sincere/quartz/mapper/YxyMapper.java
index 9dc22b5..31bb171 100644
--- a/cloud/quartz/src/main/java/com/sincere/quartz/mapper/YxyMapper.java
+++ b/cloud/quartz/src/main/java/com/sincere/quartz/mapper/YxyMapper.java
@@ -6,6 +6,8 @@ import com.sincere.quartz.model.YxyTeacher;
 
 public interface YxyMapper {
 
+    int selectCount(String date);
+
     int deleteWeekBefore();
 
     int updateAgency() ;
diff --git a/cloud/quartz/src/main/java/com/sincere/quartz/service/YxyService.java b/cloud/quartz/src/main/java/com/sincere/quartz/service/YxyService.java
index cc820d4..5c7a9fd 100644
--- a/cloud/quartz/src/main/java/com/sincere/quartz/service/YxyService.java
+++ b/cloud/quartz/src/main/java/com/sincere/quartz/service/YxyService.java
@@ -6,6 +6,8 @@ import com.sincere.quartz.model.YxyTeacher;
 
 public interface YxyService {
 
+    int selectCount(String date);
+
     int deleteWeekBefore();
 
     int updateAgency() ;
diff --git a/cloud/quartz/src/main/java/com/sincere/quartz/service/impl/YxyServiceImpl.java b/cloud/quartz/src/main/java/com/sincere/quartz/service/impl/YxyServiceImpl.java
index dd338e3..6b37bea 100644
--- a/cloud/quartz/src/main/java/com/sincere/quartz/service/impl/YxyServiceImpl.java
+++ b/cloud/quartz/src/main/java/com/sincere/quartz/service/impl/YxyServiceImpl.java
@@ -18,6 +18,12 @@ public class YxyServiceImpl implements YxyService {
 
     @Override
     @MyDataSource(DataSourceType.Yxy)
+    public int selectCount(String date) {
+        return yxyMapper.selectCount(date);
+    }
+
+    @Override
+    @MyDataSource(DataSourceType.Yxy)
     public int deleteWeekBefore() {
         return yxyMapper.deleteWeekBefore();
     }
diff --git a/cloud/quartz/src/main/java/com/sincere/quartz/third/yixueyun/YXYReadService.java b/cloud/quartz/src/main/java/com/sincere/quartz/third/yixueyun/YXYReadService.java
index 74752f0..4721149 100644
--- a/cloud/quartz/src/main/java/com/sincere/quartz/third/yixueyun/YXYReadService.java
+++ b/cloud/quartz/src/main/java/com/sincere/quartz/third/yixueyun/YXYReadService.java
@@ -100,10 +100,17 @@ public class YXYReadService {
             // 等待所有子线程结束，才退出主线程
         }
         logger.info("------------------当天更新完成");
-        yxyService.deleteWeekBefore();
-        yxyService.updateAgency();
-        yxyService.updateStudent();
-        yxyService.updateTeacher();
+        try{
+            String today = DateUtils.getToday(DateUtils.format1)+" 22:00:00" ;
+            if(yxyService.selectCount(today) > 400000){
+                yxyService.deleteWeekBefore();
+                yxyService.updateAgency();
+                yxyService.updateStudent();
+                yxyService.updateTeacher();
+            }
+        }catch (Exception e){
+
+        }
     }
 
 
diff --git a/cloud/quartz/src/main/resources/mapper/YxyMapper.xml b/cloud/quartz/src/main/resources/mapper/YxyMapper.xml
index 66cd893..9953dd3 100644
--- a/cloud/quartz/src/main/resources/mapper/YxyMapper.xml
+++ b/cloud/quartz/src/main/resources/mapper/YxyMapper.xml
@@ -21,6 +21,9 @@
         update Student set state = 0 where DATEDIFF(n , intime, getdate()) > 240
     </update>
 
+    <select id="selectCount" parameterType="java.lang.String" resultType="java.lang.Integer">
+        select count(0) from Student where intime > #{date}
+    </select>
 
     <insert id="insertAgency" parameterType="com.sincere.quartz.model.YxyAgency" >
         insert into Agency(deptID , deptName , superDeptID , intime , state)
--
libgit2 0.21.0