Commit db8bfcc4cd7379cbb4c0ec8a9383c27251d0f232
1 parent
a569dedc
Exists in
master
1
Showing
6 changed files
with
43 additions
and
25 deletions
Show diff stats
cloud/quartz/src/main/java/com/sincere/quartz/job/SyncJob.java
| @@ -20,7 +20,7 @@ public class SyncJob { | @@ -20,7 +20,7 @@ public class SyncJob { | ||
| 20 | @Autowired | 20 | @Autowired |
| 21 | YXYReadService yxyReadService ; | 21 | YXYReadService yxyReadService ; |
| 22 | 22 | ||
| 23 | - @Scheduled(cron = "30 10 22 * * ? ") | 23 | + @Scheduled(cron = "30 1 22 * * ? ") |
| 24 | public void Sync(){ | 24 | public void Sync(){ |
| 25 | //翼校通的同步 之后还有钉钉的同步等等 | 25 | //翼校通的同步 之后还有钉钉的同步等等 |
| 26 | yxyReadService.sync(); | 26 | yxyReadService.sync(); |
cloud/quartz/src/main/java/com/sincere/quartz/mapper/YxyMapper.java
| @@ -6,6 +6,8 @@ import com.sincere.quartz.model.YxyTeacher; | @@ -6,6 +6,8 @@ import com.sincere.quartz.model.YxyTeacher; | ||
| 6 | 6 | ||
| 7 | public interface YxyMapper { | 7 | public interface YxyMapper { |
| 8 | 8 | ||
| 9 | + int deleteWeekBefore(); | ||
| 10 | + | ||
| 9 | int updateAgency() ; | 11 | int updateAgency() ; |
| 10 | 12 | ||
| 11 | int updateTeacher() ; | 13 | int updateTeacher() ; |
cloud/quartz/src/main/java/com/sincere/quartz/service/YxyService.java
| @@ -6,6 +6,8 @@ import com.sincere.quartz.model.YxyTeacher; | @@ -6,6 +6,8 @@ import com.sincere.quartz.model.YxyTeacher; | ||
| 6 | 6 | ||
| 7 | public interface YxyService { | 7 | public interface YxyService { |
| 8 | 8 | ||
| 9 | + int deleteWeekBefore(); | ||
| 10 | + | ||
| 9 | int updateAgency() ; | 11 | int updateAgency() ; |
| 10 | 12 | ||
| 11 | int updateTeacher() ; | 13 | int updateTeacher() ; |
cloud/quartz/src/main/java/com/sincere/quartz/service/impl/YxyServiceImpl.java
| @@ -18,6 +18,12 @@ public class YxyServiceImpl implements YxyService { | @@ -18,6 +18,12 @@ public class YxyServiceImpl implements YxyService { | ||
| 18 | 18 | ||
| 19 | @Override | 19 | @Override |
| 20 | @MyDataSource(DataSourceType.Yxy) | 20 | @MyDataSource(DataSourceType.Yxy) |
| 21 | + public int deleteWeekBefore() { | ||
| 22 | + return yxyMapper.deleteWeekBefore(); | ||
| 23 | + } | ||
| 24 | + | ||
| 25 | + @Override | ||
| 26 | + @MyDataSource(DataSourceType.Yxy) | ||
| 21 | public int updateAgency() { | 27 | public int updateAgency() { |
| 22 | return yxyMapper.updateAgency(); | 28 | return yxyMapper.updateAgency(); |
| 23 | } | 29 | } |
cloud/quartz/src/main/java/com/sincere/quartz/third/yixueyun/YXYReadService.java
| @@ -50,9 +50,6 @@ public class YXYReadService { | @@ -50,9 +50,6 @@ public class YXYReadService { | ||
| 50 | 50 | ||
| 51 | public void sync(){ | 51 | public void sync(){ |
| 52 | ExecutorService pool = ThreadUtils.newFixedThreadPool(8); | 52 | ExecutorService pool = ThreadUtils.newFixedThreadPool(8); |
| 53 | - yxyService.updateAgency(); | ||
| 54 | - yxyService.updateStudent(); | ||
| 55 | - yxyService.updateTeacher(); | ||
| 56 | List<String> areaCodeList = new ArrayList<>(); | 53 | List<String> areaCodeList = new ArrayList<>(); |
| 57 | areaCodeList.add("0571") ; | 54 | areaCodeList.add("0571") ; |
| 58 | areaCodeList.add("0572") ; | 55 | areaCodeList.add("0572") ; |
| @@ -103,6 +100,10 @@ public class YXYReadService { | @@ -103,6 +100,10 @@ public class YXYReadService { | ||
| 103 | // 等待所有子线程结束，才退出主线程 | 100 | // 等待所有子线程结束，才退出主线程 |
| 104 | } | 101 | } |
| 105 | logger.info("------------------当天更新完成"); | 102 | logger.info("------------------当天更新完成"); |
| 103 | + yxyService.deleteWeekBefore(); | ||
| 104 | + yxyService.updateAgency(); | ||
| 105 | + yxyService.updateStudent(); | ||
| 106 | + yxyService.updateTeacher(); | ||
| 106 | } | 107 | } |
| 107 | 108 | ||
| 108 | 109 | ||
| @@ -116,15 +117,15 @@ public class YXYReadService { | @@ -116,15 +117,15 @@ public class YXYReadService { | ||
| 116 | 117 | ||
| 117 | 118 | ||
| 118 | public void syncStudent(String schoolId){ | 119 | public void syncStudent(String schoolId){ |
| 119 | - List list = new ArrayList(); | ||
| 120 | - list.add(SI); | ||
| 121 | - list.add(getPassword(SI_CODE)); | ||
| 122 | - list.add(schoolId); | ||
| 123 | - String wsdl =getAllStudent ; | ||
| 124 | - String ns = nameSpace; | ||
| 125 | - String method = getALlStudent_method; | ||
| 126 | - JSONArray jsonArray = getMessage(wsdl, ns, method, list); | ||
| 127 | try{ | 120 | try{ |
| 121 | + List list = new ArrayList(); | ||
| 122 | + list.add(SI); | ||
| 123 | + list.add(getPassword(SI_CODE)); | ||
| 124 | + list.add(schoolId); | ||
| 125 | + String wsdl =getAllStudent ; | ||
| 126 | + String ns = nameSpace; | ||
| 127 | + String method = getALlStudent_method; | ||
| 128 | + JSONArray jsonArray = getMessage(wsdl, ns, method, list); | ||
| 128 | logger.info("学校ID为："+schoolId + "共有学生" + jsonArray.size() +"人"); | 129 | logger.info("学校ID为："+schoolId + "共有学生" + jsonArray.size() +"人"); |
| 129 | if(jsonArray != null){ | 130 | if(jsonArray != null){ |
| 130 | for(int i = 0 ; i < jsonArray.size() ; i++){ | 131 | for(int i = 0 ; i < jsonArray.size() ; i++){ |
| @@ -160,15 +161,15 @@ public class YXYReadService { | @@ -160,15 +161,15 @@ public class YXYReadService { | ||
| 160 | } | 161 | } |
| 161 | 162 | ||
| 162 | public void syncTeacher(String schoolId){ | 163 | public void syncTeacher(String schoolId){ |
| 163 | - List list = new ArrayList(); | ||
| 164 | - list.add(SI); | ||
| 165 | - list.add(getPassword(SI_CODE)); | ||
| 166 | - list.add(schoolId); | ||
| 167 | - String wsdl =getAllTeacher ; | ||
| 168 | - String ns = nameSpace; | ||
| 169 | - String method = getAllTeacher_method; | ||
| 170 | - JSONArray jsonArray = getMessage(wsdl, ns, method, list); | ||
| 171 | try{ | 164 | try{ |
| 165 | + List list = new ArrayList(); | ||
| 166 | + list.add(SI); | ||
| 167 | + list.add(getPassword(SI_CODE)); | ||
| 168 | + list.add(schoolId); | ||
| 169 | + String wsdl =getAllTeacher ; | ||
| 170 | + String ns = nameSpace; | ||
| 171 | + String method = getAllTeacher_method; | ||
| 172 | + JSONArray jsonArray = getMessage(wsdl, ns, method, list); | ||
| 172 | logger.info("学校ID为："+schoolId + "共有老师" + jsonArray.size() +"人"); | 173 | logger.info("学校ID为："+schoolId + "共有老师" + jsonArray.size() +"人"); |
| 173 | if(jsonArray != null){ | 174 | if(jsonArray != null){ |
| 174 | for(int i = 0 ; i < jsonArray.size() ; i++){ | 175 | for(int i = 0 ; i < jsonArray.size() ; i++){ |
| @@ -192,8 +193,8 @@ public class YXYReadService { | @@ -192,8 +193,8 @@ public class YXYReadService { | ||
| 192 | } | 193 | } |
| 193 | 194 | ||
| 194 | private JSONArray getMessage(String wsdl, String ns, String method, List<String> list){ | 195 | private JSONArray getMessage(String wsdl, String ns, String method, List<String> list){ |
| 195 | - String resultXml = HttpClientUtils.invoiceWebService(wsdl,ns,method,list); | ||
| 196 | try { | 196 | try { |
| 197 | + String resultXml = HttpClientUtils.invoiceWebService(wsdl,ns,method,list); | ||
| 197 | if (StringUtils.isNotBlank(resultXml)) { | 198 | if (StringUtils.isNotBlank(resultXml)) { |
| 198 | resultXml = resultXml.replaceAll("<", "<"); | 199 | resultXml = resultXml.replaceAll("<", "<"); |
| 199 | resultXml = resultXml.replaceAll(">", ">"); | 200 | resultXml = resultXml.replaceAll(">", ">"); |
cloud/quartz/src/main/resources/mapper/YxyMapper.xml
| @@ -2,16 +2,23 @@ | @@ -2,16 +2,23 @@ | ||
| 2 | <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" > | 2 | <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" > |
| 3 | <mapper namespace="com.sincere.quartz.mapper.YxyMapper"> | 3 | <mapper namespace="com.sincere.quartz.mapper.YxyMapper"> |
| 4 | 4 | ||
| 5 | + | ||
| 6 | + <delete id="deleteWeekBefore" > | ||
| 7 | + delete Agency where DATEDIFF(d,intime,GETDATE())>7; | ||
| 8 | + delete Teacher where DATEDIFF(d,intime,GETDATE())>7; | ||
| 9 | + delete Student where DATEDIFF(d,intime,GETDATE())>7; | ||
| 10 | + </delete> | ||
| 11 | + | ||
| 5 | <update id="updateAgency" > | 12 | <update id="updateAgency" > |
| 6 | - update Agency set state = 0 where state = 1 | 13 | + update Agency set state = 0 where DATEDIFF(n , intime, getdate()) > 240 |
| 7 | </update> | 14 | </update> |
| 8 | - | 15 | + |
| 9 | <update id="updateTeacher"> | 16 | <update id="updateTeacher"> |
| 10 | - update Teacher set state = 0 where state = 1 | 17 | + update Teacher set state = 0 where DATEDIFF(n , intime, getdate()) > 240 |
| 11 | </update> | 18 | </update> |
| 12 | 19 | ||
| 13 | <update id="updateStudent"> | 20 | <update id="updateStudent"> |
| 14 | - update Student set state = 0 where state = 1 | 21 | + update Student set state = 0 where DATEDIFF(n , intime, getdate()) > 240 |
| 15 | </update> | 22 | </update> |
| 16 | 23 | ||
| 17 | 24 |