From ffc3510e6602ab134c3af6b1457c8dab55dc0209 Mon Sep 17 00:00:00 2001 From: zzc Date: Wed, 19 Mar 2025 09:03:18 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E5=A4=96=E9=83=A8=E6=8E=A5?= =?UTF-8?q?=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../web/controller/web/ExternalController.java | 18 ++++++++++++------ 1 file changed, 12 insertions(+), 6 deletions(-) diff --git a/acupuncture-admin/src/main/java/com/acupuncture/web/controller/web/ExternalController.java b/acupuncture-admin/src/main/java/com/acupuncture/web/controller/web/ExternalController.java index efa922ac..4d18978b 100644 --- a/acupuncture-admin/src/main/java/com/acupuncture/web/controller/web/ExternalController.java +++ b/acupuncture-admin/src/main/java/com/acupuncture/web/controller/web/ExternalController.java @@ -11,6 +11,7 @@ import com.acupuncture.common.core.domain.AjaxResult; import com.acupuncture.common.core.domain.BaseDto; import com.acupuncture.common.core.domain.JsonResponse; import com.acupuncture.common.core.redis.RedisCache; +import com.acupuncture.common.core.text.Convert; import com.acupuncture.common.exception.base.BaseException; import com.acupuncture.common.utils.file.FileUploadUtils; import com.acupuncture.common.utils.file.FileUtils; @@ -76,13 +77,18 @@ public class ExternalController { //切换数据源 private void checkoutData(String from) { - //根据社区ID查询数据源 - List dataSourceList = umsDataSourceDao.query(Long.parseLong(from)); - if (CollectionUtil.isEmpty(dataSourceList)) { - throw new BaseException("查询不到社区"); + try { + //根据社区ID查询数据源 + List dataSourceList = umsDataSourceDao.query(Long.parseLong(from)); + if (CollectionUtil.isEmpty(dataSourceList)) { + throw new BaseException("查询不到社区"); + } + //切换数据源查询 + changeDataSource(dataSourceList.get(0).getDataSourceKey()); + }catch (Exception e) { + throw new BaseException("UUID错误:{}", from); } - //切换数据源查询 - changeDataSource(dataSourceList.get(0).getDataSourceKey()); + } private static void changeDataSource(String key) {