1

陈杰
1 parent 98d8dd15
Showing 5 changed files with 24 additions and 4 deletions Show diff stats
cloud/quartz/src/main/java/com/sincere/quartz/mapper/YxyMapper.java
cloud/quartz/src/main/java/com/sincere/quartz/service/YxyService.java
cloud/quartz/src/main/java/com/sincere/quartz/service/impl/YxyServiceImpl.java
cloud/quartz/src/main/java/com/sincere/quartz/third/yixueyun/YXYReadService.java
cloud/quartz/src/main/resources/mapper/YxyMapper.xml
@@ -6,6 +6,8 @@ import com.sincere.quartz.model.YxyTeacher;
  
 public interface YxyMapper {
  
+    int selectCount(String date);
+
     int deleteWeekBefore();
  
     int updateAgency() ;
@@ -6,6 +6,8 @@ import com.sincere.quartz.model.YxyTeacher;
  
 public interface YxyService {
  
+    int selectCount(String date);
+
     int deleteWeekBefore();
  
     int updateAgency() ;
@@ -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();
     }
@@ -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){
+
+        }
     }
  
  
@@ -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)
...	...	@@ -6,6 +6,8 @@ import com.sincere.quartz.model.YxyTeacher;
6	6
7	7	public interface YxyMapper {
8	8
	9	+ int selectCount(String date);
	10	+
9	11	int deleteWeekBefore();
10	12
11	13	int updateAgency() ;
...	...
...	...	@@ -6,6 +6,8 @@ import com.sincere.quartz.model.YxyTeacher;
6	6
7	7	public interface YxyService {
8	8
	9	+ int selectCount(String date);
	10	+
9	11	int deleteWeekBefore();
10	12
11	13	int updateAgency() ;
...	...
...	...	@@ -18,6 +18,12 @@ public class YxyServiceImpl implements YxyService {
18	18
19	19	@Override
20	20	@MyDataSource(DataSourceType.Yxy)
	21	+ public int selectCount(String date) {
	22	+ return yxyMapper.selectCount(date);
	23	+ }
	24	+
	25	+ @Override
	26	+ @MyDataSource(DataSourceType.Yxy)
21	27	public int deleteWeekBefore() {
22	28	return yxyMapper.deleteWeekBefore();
23	29	}
...	...
...	...	@@ -100,10 +100,17 @@ public class YXYReadService {
100	100	// 等待所有子线程结束，才退出主线程
101	101	}
102	102	logger.info("------------------当天更新完成");
103		- yxyService.deleteWeekBefore();
104		- yxyService.updateAgency();
105		- yxyService.updateStudent();
106		- yxyService.updateTeacher();
	103	+ try{
	104	+ String today = DateUtils.getToday(DateUtils.format1)+" 22:00:00" ;
	105	+ if(yxyService.selectCount(today) > 400000){
	106	+ yxyService.deleteWeekBefore();
	107	+ yxyService.updateAgency();
	108	+ yxyService.updateStudent();
	109	+ yxyService.updateTeacher();
	110	+ }
	111	+ }catch (Exception e){
	112	+
	113	+ }
107	114	}
108	115
109	116
...	...
...	...	@@ -21,6 +21,9 @@
21	21	update Student set state = 0 where DATEDIFF(n , intime, getdate()) > 240
22	22	</update>
23	23
	24	+ <select id="selectCount" parameterType="java.lang.String" resultType="java.lang.Integer">
	25	+ select count(0) from Student where intime > #{date}
	26	+ </select>
24	27
25	28	<insert id="insertAgency" parameterType="com.sincere.quartz.model.YxyAgency" >
26	29	insert into Agency(deptID , deptName , superDeptID , intime , state)
...	...