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
+
insert into Agency(deptID , deptName , superDeptID , intime , state)
--
libgit2 0.21.0