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 | 11 ++++++----- 1 files changed, 6 insertions(+), 5 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 fc7c7f0..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,23 +40,24 @@ response.getWriter().write("{\"message\":\"401锛氭壘涓嶅埌闄㈠尯缂栧彿\"}"); return false; } - DictHosp hosp = null; +// DictHosp hosp = null; try { DataSourceContextHolder.setDataSourceKey("default"); LambdaQueryWrapper<DictHosp> wrapper = new LambdaQueryWrapper<>(); wrapper.eq(DictHosp::getCode,hospId); - hosp = dictHospService.getOne(wrapper); - if (hosp == null || hosp.getDatabase() == null || hosp.getDatabase().trim().isEmpty()) { + 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.getDatabase()); + dataSourceConfig.addDataSource(hosp.getDbname()); + DataSourceContextHolder.setDataSourceKey(hosp.getDbname()); } catch (IOException e) { return false; } - DataSourceContextHolder.setDataSourceKey(hosp.getDatabase()); + return true; } -- Gitblit v1.8.0