From 45b5e3f63283e622f4321f3d03992343636dabf8 Mon Sep 17 00:00:00 2001
From: zjh <1084500556@qq.com>
Date: 星期五, 07 二月 2025 16:18:22 +0800
Subject: [PATCH] zjh20250207

---
 ltkj-framework/src/main/java/com/ltkj/framework/interceptor/DBChangeInterceptor.java |   26 ++++++++++++++++----------
 1 files changed, 16 insertions(+), 10 deletions(-)

diff --git a/ltkj-framework/src/main/java/com/ltkj/framework/interceptor/DBChangeInterceptor.java b/ltkj-framework/src/main/java/com/ltkj/framework/interceptor/DBChangeInterceptor.java
index 006b157..ee96596 100644
--- a/ltkj-framework/src/main/java/com/ltkj/framework/interceptor/DBChangeInterceptor.java
+++ b/ltkj-framework/src/main/java/com/ltkj/framework/interceptor/DBChangeInterceptor.java
@@ -40,18 +40,24 @@
             response.getWriter().write("{\"message\":\"401锛氭壘涓嶅埌闄㈠尯缂栧彿\"}");
             return false;
         }
-        DataSourceContextHolder.setDataSourceKey("default");
-        LambdaQueryWrapper<DictHosp> wrapper = new LambdaQueryWrapper<>();
-        wrapper.eq(DictHosp::getCode,hospId);
-        DictHosp hosp = dictHospService.getOne(wrapper);
-        if (hosp == null || hosp.getDatabase() == null || hosp.getDatabase().trim().isEmpty()) {
-            response.setStatus(HttpServletResponse.SC_UNAUTHORIZED);
-            response.setContentType("application/json;charset=UTF-8");
-            response.getWriter().write("{\"message\":\"401锛氭壘涓嶅埌闄㈠尯鏁版嵁\"}");
+//        DictHosp hosp = null;
+        try {
+            DataSourceContextHolder.setDataSourceKey("default");
+            LambdaQueryWrapper<DictHosp> wrapper = new LambdaQueryWrapper<>();
+            wrapper.eq(DictHosp::getCode,hospId);
+            DictHosp hosp = dictHospService.getOne(wrapper);
+            if (hosp == null || hosp.getDbname() == null || hosp.getDbname().trim().isEmpty()) {
+                response.setStatus(HttpServletResponse.SC_UNAUTHORIZED);
+                response.setContentType("application/json;charset=UTF-8");
+                response.getWriter().write("{\"message\":\"401锛氭壘涓嶅埌闄㈠尯鏁版嵁\"}");
+                return false;
+            }
+            dataSourceConfig.addDataSource(hosp.getDbname());
+            DataSourceContextHolder.setDataSourceKey(hosp.getDbname());
+        } catch (IOException e) {
             return false;
         }
-        dataSourceConfig.addDataSource(hosp.getDatabase());
-        DataSourceContextHolder.setDataSourceKey(hosp.getDatabase());
+
         return true;
     }
 

--
Gitblit v1.8.0