From 6cfbce38436435f574680c0b1e58342e4a2ac444 Mon Sep 17 00:00:00 2001
From: zjh <1084500556@qq.com>
Date: 星期三, 31 七月 2024 10:51:51 +0800
Subject: [PATCH] zjh 2024/07/31-1

---
 ltkj-admin/src/main/java/com/ltkj/web/controller/his/HisApiGetMethodService.java |   29 +++++++++++++++++++----------
 1 files changed, 19 insertions(+), 10 deletions(-)

diff --git a/ltkj-admin/src/main/java/com/ltkj/web/controller/his/HisApiGetMethodService.java b/ltkj-admin/src/main/java/com/ltkj/web/controller/his/HisApiGetMethodService.java
index 6d1c214..0342faa 100644
--- a/ltkj-admin/src/main/java/com/ltkj/web/controller/his/HisApiGetMethodService.java
+++ b/ltkj-admin/src/main/java/com/ltkj/web/controller/his/HisApiGetMethodService.java
@@ -14,6 +14,7 @@
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Propagation;
 import org.springframework.transaction.annotation.Transactional;
 
 import java.io.FileInputStream;
@@ -202,7 +203,7 @@
         }
     }
 
-    @Transactional
+    @Transactional(propagation = Propagation.REQUIRES_NEW)
     public AjaxResult getHISDataNew(String type, Map<String, Object> params){
         LambdaQueryWrapper<HisApiConfig> lambdaQueryWrapper = new LambdaQueryWrapper<>();
         lambdaQueryWrapper.eq(HisApiConfig::getApiMethod, type);
@@ -264,10 +265,11 @@
         } catch (SQLException e) {
             e.printStackTrace();
             return AjaxResult.error();
-        }
-        try {
-            connection.close();
-        } catch (SQLException ignored) {
+        }finally {
+            try {
+                connection.close();
+            } catch (SQLException ignored) {
+            }
         }
         return AjaxResult.success();
     }
@@ -407,9 +409,9 @@
         }
         deleteSqlBuilder.delete(deleteSqlBuilder.length() - 5, deleteSqlBuilder.length());
         Statement statement = connection.prepareStatement(deleteSqlBuilder.toString());
-//        log.info("鎵ц鍒犻櫎 ->{}",deleteSqlBuilder.toString());
+        log.info("HIS鏁版嵁淇濆瓨绫� 鎵ц鍒犻櫎 ->{}",deleteSqlBuilder.toString());
         int i = statement.executeUpdate(deleteSqlBuilder.toString());
-//        log.info("鍒犻櫎鏉℃暟 ->{}",i);
+        log.info("HIS鏁版嵁淇濆瓨绫� 鍒犻櫎鏉℃暟 ->{}",i);
         statement.close();
         insertSqlBuilder.append("insert_time, ");
         insertSqlBuilder.append("request_params, ");
@@ -436,9 +438,16 @@
         insertSqlBuilder.append(") values (").append(valueBuilder).append(")");
 //        log.info("鎵ц鎻掑叆 ->{}",insertSqlBuilder.toString());
         // 鎻掑叆鏁版嵁
-        statement = connection.createStatement();
-        statement.execute(insertSqlBuilder.toString());
-        statement.close();
+//        boolean execute = statement.execute(insertSqlBuilder.toString());
+        for (int j = 0; j < 10; j++) {
+            statement = connection.createStatement();
+            log.info("HIS鏁版嵁淇濆瓨绫� 鎵ц鎻掑叆 ->{}",insertSqlBuilder.toString());
+            boolean execute = statement.execute(insertSqlBuilder.toString());
+            log.info("HIS鏁版嵁淇濆瓨绫� 鎵ц鎻掑叆鐘舵�� ->{},娆℃暟->{}",execute,(j+1));
+            statement.close();
+            if (execute)
+                break;
+        }
     }
 
     /**

--
Gitblit v1.8.0