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 d841272..9b46fa0 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 = "0 0 22 * * ? ") + @Scheduled(cron = "30 10 22 * * ? ") public void Sync(){ //翼校通的同步 之后还有钉钉的同步等等 yxyReadService.sync(); 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 0464f78..61ec7ed 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 @@ -98,14 +98,11 @@ public class YXYReadService { for(String schoolId : schoolList){ pool.execute(initSchool(schoolId)); } - try { - boolean loop = true; - do { //等待所有任务完成 - loop = !pool.awaitTermination(2, TimeUnit.SECONDS); //阻塞,直到线程池里所有任务结束 - } while(loop); - } catch (InterruptedException e) { - e.printStackTrace(); + pool.shutdown(); + while (!pool.isTerminated()) { + // 等待所有子线程结束,才退出主线程 } + logger.info("------------------当天更新完成"); } @@ -138,8 +135,17 @@ public class YXYReadService { student.setAccount(object.get("account").toString()); student.setName(object.get("name").toString()); student.setUserId(object.get("userID").toString()); + }catch (Exception e){ + } + try{ student.setCardID(object.get("cardID").toString()); + }catch (Exception e){ + } + try{ student.setCardID2(object.get("cardID2").toString()); + }catch (Exception e){ + } + try{ student.setCardID3(object.get("cardID3").toString()); }catch (Exception e){ } -- libgit2 0.21.0