From 404fa9ff4331d6bb5037dbec466022fade5e82bc Mon Sep 17 00:00:00 2001
From: zjh <1084500556@qq.com>
Date: 星期三, 18 十二月 2024 18:11:46 +0800
Subject: [PATCH] zjh202412018
---
ltkj-admin/src/main/java/com/ltkj/web/config/timer/DefaultScheduled.java | 85 ++++++++++++++++++++++--------------------
1 files changed, 44 insertions(+), 41 deletions(-)
diff --git a/ltkj-admin/src/main/java/com/ltkj/web/config/timer/DefaultScheduled.java b/ltkj-admin/src/main/java/com/ltkj/web/config/timer/DefaultScheduled.java
index 11b12db..8a4043e 100644
--- a/ltkj-admin/src/main/java/com/ltkj/web/config/timer/DefaultScheduled.java
+++ b/ltkj-admin/src/main/java/com/ltkj/web/config/timer/DefaultScheduled.java
@@ -96,22 +96,27 @@
List<String> jc = orderService.getDingShiTongBuJianChaTjNum();
+
if(null !=jy && !jy.isEmpty()){
+ log.info("鍚屾妫�楠屼汉鍛� 鎵ц鏁伴噺->{}", jy.size());
for (String s : jy) {
- TjOrder order = orderService.getOrderByTjNum(s);
- extractedjianyan(s,order);
+// TjOrder order = orderService.getOrderByTjNum(s);
+ extractedjianyan(s);
}
}
+
if(null !=jc && !jc.isEmpty()){
+ log.info("鍚屾妫�鏌ヤ汉鍛� 鎵ц鏁伴噺->{}", jc.size());
for (String s : jc) {
- TjOrder order = orderService.getOrderByTjNum(s);
- extractedjiancha(s,order);
+// TjOrder order = orderService.getOrderByTjNum(s);
+ extractedjiancha(s);
}
}
Map<String,Object> map=new HashMap<>();
testMapper.tjplUpdateDetatilByVi(map);
Integer object = (Integer) map.get("total");
+ log.info("鎵ц瀛樺偍杩囩▼鍚庡嚭鍙�->{}",object);
if(null !=object && object.equals(1)){
long end = System.currentTimeMillis();
log.info("鍚屾缁撴潫 鑰楁椂锛歿}绉�", (end - start) / 1000);
@@ -123,6 +128,7 @@
}
}
} catch (Exception e) {
+ log.error("瀹氭椂鍣ㄦ墽琛屾姤閿�");
e.printStackTrace();
} finally {
scheduleNextTask(Long.parseLong(dsrwsjjg));
@@ -130,50 +136,47 @@
}
}
- private void extractedjianyan(String s,TjOrder order) {
- List<LtkjHysqd> hysqdList = testMapper.getCcXZxYyLtkjHysqdByLisVi(order.getTjNumber());
- if(null != hysqdList && !hysqdList.isEmpty()){
- for (LtkjHysqd hysqd : hysqdList) {
- LtkjHysqd jybgid = ltkjHysqdService.getLtkjHysqdByTjhAndTmh(hysqd.getTjh(),hysqd.getTmh());
- if (null != jybgid) {
- ltkjHysqdService.deletedLtkjHysqdByTjhAndTmh(hysqd.getTjh(),hysqd.getTmh());
- ltkjHybgdService.deletedLtkjHybgdByTjhAndTmh(hysqd.getTmh());
+ private void extractedjianyan(String s) {
+ try {
+ List<LtkjHysqd> hysqdList = testMapper.getCcXZxYyLtkjHysqdByLisVi(s);
+ if(null != hysqdList && !hysqdList.isEmpty()){
+ for (LtkjHysqd hysqd : hysqdList) {
+ LtkjHysqd jybgid = ltkjHysqdService.getLtkjHysqdByTjhAndTmh(hysqd.getTjh(),hysqd.getTmh());
+ if (null != jybgid) {
+ ltkjHysqdService.deletedLtkjHysqdByTjhAndTmh(hysqd.getTjh(),hysqd.getTmh());
+ ltkjHybgdService.deletedLtkjHybgdByTjhAndTmh(hysqd.getTmh());
+ }
+ if (ltkjHysqdService.save(hysqd)) {
+ List<LtkjHybgd> hybgdList = testMapper.getCcXZxYyLtkjHybgdByLisVi(hysqd.getTmh());
+ ltkjHybgdService.saveBatch(hybgdList);
+ }
}
- if (ltkjHysqdService.save(hysqd)) {
- List<LtkjHybgd> hybgdList = testMapper.getCcXZxYyLtkjHybgdByLisVi(hysqd.getTmh());
- ltkjHybgdService.saveBatch(hybgdList);
- }
+ DynamicDataSourceContextHolder.clearDataSourceType();
}
- DynamicDataSourceContextHolder.clearDataSourceType();
+ } catch (Exception e) {
+ log.info("鍚屾妫�楠屾暟鎹け璐�");
+ throw new RuntimeException(e);
}
-// String tjNumber1 = order.getTjNumber();
-// log.info("鏌ヨ鍑烘潵鐨勪綋妫�鍙锋槸: " + tjNumber1);
-// log.info("浼犺繃鏉ョ殑鐨勪綋妫�鍙锋槸: "+ s);
-// Map<String,Object> map=new HashMap<>();
-// map.put("tjnum", s);
-// testMapper.tjUpdateDetatilByVi(map);
-// asyncService.tjUpdateDetatilByVi(s);
-// log.info("瀹氭椂浠诲姟瀛樺偍杩囩▼宸叉墽琛�!!!");
}
- private void extractedjiancha(String s,TjOrder order) {
+ private void extractedjiancha(String s) {
- List<LtkjExamJcsqd> jcsqdList = testMapper.getCcXZxYyPacsLtkjExamJcsqd(order.getTjNumber());
- if(null !=jcsqdList && !jcsqdList.isEmpty()){
- jcsqdService.deletedLtkjJcsqdByTjhAndTmh(order.getCardId());
- jcbgdService.deletedLtkjJcbgdByTjhAndTmh(order.getCardId());
- jcsqdService.saveBatch(jcsqdList);
- List<LtkjExamJcbgd> jcbgdList = testMapper.getCcXZxYyPacsLtkjExamJcbgd(order.getCardId());
- if(null != jcbgdList && !jcbgdList.isEmpty())jcbgdService.saveBatch(jcbgdList);
- DynamicDataSourceContextHolder.clearDataSourceType();
+ try {
+ List<LtkjExamJcsqd> jcsqdList = testMapper.getCcXZxYyPacsLtkjExamJcsqd(s);
+ if(null !=jcsqdList && !jcsqdList.isEmpty()){
+ DynamicDataSourceContextHolder.clearDataSourceType();
+ jcsqdService.deletedLtkjJcsqdByTjhAndTmh(s);
+ jcbgdService.deletedLtkjJcbgdByTjhAndTmh(s);
+ jcsqdService.saveBatch(jcsqdList);
+ List<LtkjExamJcbgd> jcbgdList = testMapper.getCcXZxYyPacsLtkjExamJcbgd(s);
+ DynamicDataSourceContextHolder.clearDataSourceType();
+ if(null != jcbgdList && !jcbgdList.isEmpty())jcbgdService.saveBatch(jcbgdList);
+ DynamicDataSourceContextHolder.clearDataSourceType();
+ }
+ } catch (Exception e) {
+ log.info("鍚屾妫�鏌ユ暟鎹け璐�");
+ throw new RuntimeException(e);
}
-// String tjNumber1 = order.getTjNumber();
-// log.info("鏌ヨ鍑烘潵鐨勪綋妫�鍙锋槸: " + tjNumber1);
-// log.info("浼犺繃鏉ョ殑鐨勪綋妫�鍙锋槸: "+ s);
-// Map<String,Object> map=new HashMap<>();
-// map.put("tjnum", s);
-// testMapper.tjUpdateDetatilByVi(map);
-// log.info("瀹氭椂浠诲姟瀛樺偍杩囩▼宸叉墽琛�!!!");
}
}
--
Gitblit v1.8.0