From db8bfcc4cd7379cbb4c0ec8a9383c27251d0f232 Mon Sep 17 00:00:00 2001 From: 陈杰 <504987307@qq.com> Date: Thu, 14 May 2020 15:10:12 +0800 Subject: [PATCH] 1 --- cloud/quartz/src/main/java/com/sincere/quartz/job/SyncJob.java | 2 +- 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 | 41 +++++++++++++++++++++-------------------- cloud/quartz/src/main/resources/mapper/YxyMapper.xml | 15 +++++++++++---- 6 files changed, 43 insertions(+), 25 deletions(-) diff --git a/cloud/quartz/src/main/java/com/sincere/quartz/job/SyncJob.java b/cloud/quartz/src/main/java/com/sincere/quartz/job/SyncJob.java index 9b46fa0..78c11d3 100644 --- a/cloud/quartz/src/main/java/com/sincere/quartz/job/SyncJob.java +++ b/cloud/quartz/src/main/java/com/sincere/quartz/job/SyncJob.java @@ -20,7 +20,7 @@ public class SyncJob { @Autowired YXYReadService yxyReadService ; - @Scheduled(cron = "30 10 22 * * ? ") + @Scheduled(cron = "30 1 22 * * ? ") public void Sync(){ //翼校通的同步 之后还有钉钉的同步等等 yxyReadService.sync(); 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 b74c005..9dc22b5 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 deleteWeekBefore(); + int updateAgency() ; int updateTeacher() ; 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 44bd998..cc820d4 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 deleteWeekBefore(); + int updateAgency() ; int updateTeacher() ; 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 bede705..dd338e3 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 deleteWeekBefore() { + return yxyMapper.deleteWeekBefore(); + } + + @Override + @MyDataSource(DataSourceType.Yxy) public int updateAgency() { return yxyMapper.updateAgency(); } 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 61ec7ed..74752f0 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 @@ -50,9 +50,6 @@ public class YXYReadService { public void sync(){ ExecutorService pool = ThreadUtils.newFixedThreadPool(8); - yxyService.updateAgency(); - yxyService.updateStudent(); - yxyService.updateTeacher(); List areaCodeList = new ArrayList<>(); areaCodeList.add("0571") ; areaCodeList.add("0572") ; @@ -103,6 +100,10 @@ public class YXYReadService { // 等待所有子线程结束，才退出主线程 } logger.info("------------------当天更新完成"); + yxyService.deleteWeekBefore(); + yxyService.updateAgency(); + yxyService.updateStudent(); + yxyService.updateTeacher(); } @@ -116,15 +117,15 @@ public class YXYReadService { public void syncStudent(String schoolId){ - List list = new ArrayList(); - list.add(SI); - list.add(getPassword(SI_CODE)); - list.add(schoolId); - String wsdl =getAllStudent ; - String ns = nameSpace; - String method = getALlStudent_method; - JSONArray jsonArray = getMessage(wsdl, ns, method, list); try{ + List list = new ArrayList(); + list.add(SI); + list.add(getPassword(SI_CODE)); + list.add(schoolId); + String wsdl =getAllStudent ; + String ns = nameSpace; + String method = getALlStudent_method; + JSONArray jsonArray = getMessage(wsdl, ns, method, list); logger.info("学校ID为："+schoolId + "共有学生" + jsonArray.size() +"人"); if(jsonArray != null){ for(int i = 0 ; i < jsonArray.size() ; i++){ @@ -160,15 +161,15 @@ public class YXYReadService { } public void syncTeacher(String schoolId){ - List list = new ArrayList(); - list.add(SI); - list.add(getPassword(SI_CODE)); - list.add(schoolId); - String wsdl =getAllTeacher ; - String ns = nameSpace; - String method = getAllTeacher_method; - JSONArray jsonArray = getMessage(wsdl, ns, method, list); try{ + List list = new ArrayList(); + list.add(SI); + list.add(getPassword(SI_CODE)); + list.add(schoolId); + String wsdl =getAllTeacher ; + String ns = nameSpace; + String method = getAllTeacher_method; + JSONArray jsonArray = getMessage(wsdl, ns, method, list); logger.info("学校ID为："+schoolId + "共有老师" + jsonArray.size() +"人"); if(jsonArray != null){ for(int i = 0 ; i < jsonArray.size() ; i++){ @@ -192,8 +193,8 @@ public class YXYReadService { } private JSONArray getMessage(String wsdl, String ns, String method, List list){ - String resultXml = HttpClientUtils.invoiceWebService(wsdl,ns,method,list); try { + String resultXml = HttpClientUtils.invoiceWebService(wsdl,ns,method,list); if (StringUtils.isNotBlank(resultXml)) { resultXml = resultXml.replaceAll("<", "<"); resultXml = resultXml.replaceAll(">", ">"); diff --git a/cloud/quartz/src/main/resources/mapper/YxyMapper.xml b/cloud/quartz/src/main/resources/mapper/YxyMapper.xml index e1ab6e7..66cd893 100644 --- a/cloud/quartz/src/main/resources/mapper/YxyMapper.xml +++ b/cloud/quartz/src/main/resources/mapper/YxyMapper.xml @@ -2,16 +2,23 @@ + + + delete Agency where DATEDIFF(d,intime,GETDATE())>7; + delete Teacher where DATEDIFF(d,intime,GETDATE())>7; + delete Student where DATEDIFF(d,intime,GETDATE())>7; + + - update Agency set state = 0 where state = 1 + update Agency set state = 0 where DATEDIFF(n , intime, getdate()) > 240 - + - update Teacher set state = 0 where state = 1 + update Teacher set state = 0 where DATEDIFF(n , intime, getdate()) > 240 - update Student set state = 0 where state = 1 + update Student set state = 0 where DATEDIFF(n , intime, getdate()) > 240 -- libgit2 0.21.0