From 9597821e57d4bad1ea4e984241f363be956dda8c Mon Sep 17 00:00:00 2001
From: zjh <1084500556@qq.com>
Date: 星期四, 03 七月 2025 18:21:33 +0800
Subject: [PATCH] zjh20250703

---
 ltkj-admin/src/main/java/com/ltkj/web/config/timer/AsyncResultTask.java |   33 ++++++++++++++++++++++++---------
 1 files changed, 24 insertions(+), 9 deletions(-)

diff --git a/ltkj-admin/src/main/java/com/ltkj/web/config/timer/AsyncResultTask.java b/ltkj-admin/src/main/java/com/ltkj/web/config/timer/AsyncResultTask.java
index b3d9624..04d5dba 100644
--- a/ltkj-admin/src/main/java/com/ltkj/web/config/timer/AsyncResultTask.java
+++ b/ltkj-admin/src/main/java/com/ltkj/web/config/timer/AsyncResultTask.java
@@ -13,6 +13,7 @@
 import com.ltkj.hosp.service.*;
 import com.ltkj.hosp.sqlDomain.*;
 import com.ltkj.system.service.ISysConfigService;
+import com.ltkj.web.controller.system.SysConfigController;
 import jodd.util.StringUtil;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -60,6 +61,8 @@
     private IDictHospService dictHospService;
     @Autowired
     private DataSourceConfig dataSourceConfig;
+    @Autowired
+    private SysConfigController configController;
 
     private final Map<String, ReentrantLock> lockMap = new ConcurrentHashMap<>();
 
@@ -129,7 +132,7 @@
             boolean panduandangqianshijian = panduandangqianshijian(dsqkssj, dsqjssj);
             if (!panduandangqianshijian) {
                 if (lock) {
-                    log.info("浠诲姟寮�濮嬫墽琛屾椂闂� -> {}", dateTimeFormat.format(new Date()));
+                    log.info("{}浠诲姟寮�濮嬫墽琛屾椂闂� -> {}",dictHosp.getCode(), dateTimeFormat.format(new Date()));
                     long start = System.currentTimeMillis();
                     // 鏌ヨ浠诲姟鏁版嵁
                     log.info("寮�濮嬫墽琛屽悓姝� 鎵ц闄㈠尯->{}", dictHosp.getCode());
@@ -139,7 +142,7 @@
 
 
                     if (null != jy && !jy.isEmpty()) {
-                        log.info("鍚屾妫�楠屼汉鍛� 鎵ц鏁伴噺->{}", jy.size());
+                        log.info("{}鍚屾妫�楠屼汉鍛� 鎵ц鏁伴噺->{}{}",dictHosp.getCode(), jy.size(),JSONUtil.toJsonStr(jy));
                         for (String s : jy) {
                             extractedjianyan(s,dictHosp.getCode());
                         }
@@ -147,7 +150,7 @@
 
 
                     if (null != jc && !jc.isEmpty()) {
-                        log.info("鍚屾妫�鏌ヤ汉鍛� 鎵ц鏁伴噺->{}", jc.size());
+                        log.info("{}鍚屾妫�鏌ヤ汉鍛� 鎵ц鏁伴噺->{}{}",dictHosp.getCode(), jc.size(),JSONUtil.toJsonStr(jc));
                         for (String s : jc) {
                             extractedjiancha(s,dictHosp.getCode());
                         }
@@ -155,7 +158,7 @@
                     Map<String, Object> map = new HashMap<>();
                     testMapper.tjplUpdateDetatilByVi(map);
                     Integer object = (Integer) map.get("total");
-                    log.info("鎵ц瀛樺偍杩囩▼鍚庡嚭鍙�->{}", object);
+                    log.info("{}鎵ц瀛樺偍杩囩▼鍚庡嚭鍙�->{}",dictHosp.getCode(), object);
                     if (null != object && object.equals(1)) {
                         if (null != jc && !jc.isEmpty()) {
                             for (String s : jc) {
@@ -168,7 +171,19 @@
                                             if(StringUtil.isBlank(regex)) regex= "銆倈锛泑;|,|锛�";
                                             String[] split = jcsqd.getJgzt().replaceAll("\n", "").split(regex);
                                             for (String jg : split) {
-                                                if(StringUtil.isNotBlank(jg) && !jg.contains("鏈寮傚父")
+                                                boolean b = configController.apiJcycpdgjz(jg);
+                                                if(!b){
+                                                    TjJcycxm jcycxm=new TjJcycxm();
+                                                    jcycxm.setTjh(s);
+                                                    jcycxm.setYqid(dictHosp.getCode());
+                                                    String[] split1 = jcsqd.getJcxmid().split(";");
+                                                    jcycxm.setProId(split1[0]);
+                                                    jcycxm.setProName(jcsqd.getJcxmmc());
+                                                    jcycxm.setCreateTime(new Date());
+                                                    jcycxm.setJcjg(jg);
+                                                    jcycxmService.save(jcycxm);
+                                                }
+                                       /*         if(StringUtil.isNotBlank(jg) && !jg.contains("鏈寮傚父")
                                                         && !jg.contains("鏈鏄庢樉寮傚父") && !jg.contains("鏈鍗犱綅") && !jg.contains("鏈")
                                                         && !jg.contains("鏈鏄庢樉")&& !jg.contains("姝e父")&& !jg.contains("鍙屼晶妞庨棿瀛旀棤鐙獎")&& !jg.contains("鏃犳畩")){
                                                     TjJcycxm jcycxm=new TjJcycxm();
@@ -180,7 +195,7 @@
                                                     jcycxm.setCreateTime(new Date());
                                                     jcycxm.setJcjg(jg);
                                                     jcycxmService.save(jcycxm);
-                                                }
+                                                }*/
                                             }
                                         }
                                     }
@@ -188,7 +203,7 @@
                             }
                         }
                         long end = System.currentTimeMillis();
-                        log.info("鍚屾缁撴潫 鑰楁椂锛歿}绉�", (end - start) / 1000);
+                        log.info("{}鍚屾缁撴潫 鑰楁椂锛歿}绉�",dictHosp.getCode(), (end - start) / 1000);
                     }else {
                         log.info("鎵ц瀛樺偍杩囩▼鍑哄弬澶辫触");
                     }
@@ -304,7 +319,7 @@
 
         try {
             List<LtkjExamJcsqd> jcsqdList = testMapper.getCcXZxYyPacsLtkjExamJcsqd(s,hospId);
-            log.info("鑷姩鍚屾妫�鏌ョ敵璇峰崟鏁版嵁:"+jcsqdList);
+            log.info("{}鑷姩鍚屾妫�鏌ョ敵璇峰崟鏁版嵁:{}",hospId,JSONUtil.toJsonStr(jcsqdList));
             if (null != jcsqdList && !jcsqdList.isEmpty()) {
                 DynamicDataSourceContextHolder.clearDataSourceType();
                 jcsqdService.deletedLtkjJcsqdByTjhAndTmh(s);
@@ -312,7 +327,7 @@
                 jcsqdService.saveBatch(jcsqdList);
                 List<LtkjExamJcbgd> jcbgdList = testMapper.getCcXZxYyPacsLtkjExamJcbgd(s,hospId);
 //                DynamicDataSourceContextHolder.clearDataSourceType();
-                log.info("鑷姩鍚屾妫�鏌ユ姤鍛婂崟鏁版嵁:"+jcbgdList);
+                log.info("{}鑷姩鍚屾妫�鏌ユ姤鍛婂崟鏁版嵁:{}",hospId,JSONUtil.toJsonStr(jcbgdList));
                 if (null != jcbgdList && !jcbgdList.isEmpty()) jcbgdService.saveBatch(jcbgdList);
                 DynamicDataSourceContextHolder.clearDataSourceType();
             }

--
Gitblit v1.8.0