From 9c7e12caf75558ec66ac73dbc79152a41e34bb29 Mon Sep 17 00:00:00 2001
From: "1378012178@qq.com" <1378012178@qq.com>
Date: Mon, 21 Apr 2025 13:59:26 +0800
Subject: [PATCH] =?UTF-8?q?=E4=B8=B4=E6=97=B6=E6=8F=90=E4=BA=A4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ConfigServiceDirectiveController.java     | 19 +++++++++++++------
 .../entity/ConfigServiceDirective.java        |  3 +++
 .../ConfigServiceDirectiveServiceImpl.java    |  2 +-
 3 files changed, 17 insertions(+), 7 deletions(-)

diff --git a/nursing-unit-service-directive/nu-service-directive-biz/src/main/java/com/nu/modules/servicedirective/controller/ConfigServiceDirectiveController.java b/nursing-unit-service-directive/nu-service-directive-biz/src/main/java/com/nu/modules/servicedirective/controller/ConfigServiceDirectiveController.java
index 1ad1177..5f8c07a 100644
--- a/nursing-unit-service-directive/nu-service-directive-biz/src/main/java/com/nu/modules/servicedirective/controller/ConfigServiceDirectiveController.java
+++ b/nursing-unit-service-directive/nu-service-directive-biz/src/main/java/com/nu/modules/servicedirective/controller/ConfigServiceDirectiveController.java
@@ -1,5 +1,6 @@
 package com.nu.modules.servicedirective.controller;
 
+import com.baomidou.dynamic.datasource.annotation.DS;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
@@ -56,10 +57,16 @@ public class ConfigServiceDirectiveController extends JeecgController<ConfigServ
     //@AutoLog(value = "服务指令-分页列表查询")
     @ApiOperation(value = "服务指令-分页列表查询", notes = "服务指令-分页列表查询")
     @GetMapping(value = "/list")
-    public Result<IPage<ConfigServiceDirective>> queryPageList(ConfigServiceDirective configServiceDirective,
+    @DS("#dataSourceCode")
+    public Result<IPage<ConfigServiceDirective>> queryPageList(String dataSourceCode,ConfigServiceDirective configServiceDirective,
                                                                @RequestParam(name = "pageNo", defaultValue = "1") Integer pageNo,
                                                                @RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize,
                                                                HttpServletRequest req) {
+        //切换数据源
+        if (StringUtils.isNotBlank(dataSourceCode)) {
+            pageNo = -1;
+            pageSize = -1;
+        }
 
         DirectiveMQDto directiveMQDto = new DirectiveMQDto();
         List<String> ids = Lists.newArrayList();
@@ -67,7 +74,7 @@ public class ConfigServiceDirectiveController extends JeecgController<ConfigServ
         ids.add("bbb");
         ids.add("ccc");
         directiveMQDto.setIds(ids);
-        rabbitMQUtil.sendToExchange("hldy.fwzl","nu001.fwzl.async",directiveMQDto);
+        rabbitMQUtil.sendToExchange("hldy.fwzl", "nu001.fwzl.async", directiveMQDto);
         Map<String, QueryRuleEnum> customeRuleMap = new HashMap<>();
         // 自定义多选的查询规则为：LIKE_WITH_OR
         customeRuleMap.put("categoryId", QueryRuleEnum.LIKE_WITH_OR);
@@ -83,8 +90,8 @@ public class ConfigServiceDirectiveController extends JeecgController<ConfigServ
         //如果有服务指令需要提前查询下对应的服务指令id
         List<ConfigServiceDirective> directiveIds = null;
         if (StringUtils.isNotBlank(configServiceDirective.getTags())) {
-            directiveIds =  configServiceDirectiveService.queryDirectiveIdByTagIds(configServiceDirective.getTags());
-            if(directiveIds != null && !directiveIds.isEmpty()){
+            directiveIds = configServiceDirectiveService.queryDirectiveIdByTagIds(configServiceDirective.getTags());
+            if (directiveIds != null && !directiveIds.isEmpty()) {
                 queryWrapper.in("id", directiveIds.stream().map(ConfigServiceDirective::getId).collect(Collectors.toList()));
             }
         }
@@ -109,7 +116,7 @@ public class ConfigServiceDirectiveController extends JeecgController<ConfigServ
         configServiceDirectiveService.save(configServiceDirective);
         if (StringUtils.isNotBlank(configServiceDirective.getTags())) {
             configServiceDirectiveService.saveTags(configServiceDirective);
-        }else{
+        } else {
             configServiceDirectiveService.removeTags(configServiceDirective);
         }
         return Result.OK("添加成功！");
@@ -129,7 +136,7 @@ public class ConfigServiceDirectiveController extends JeecgController<ConfigServ
         configServiceDirectiveService.updateById(configServiceDirective);
         if (StringUtils.isNotBlank(configServiceDirective.getTags())) {
             configServiceDirectiveService.saveTags(configServiceDirective);
-        }else{
+        } else {
             configServiceDirectiveService.removeTags(configServiceDirective);
         }
         return Result.OK("编辑成功!");
diff --git a/nursing-unit-service-directive/nu-service-directive-biz/src/main/java/com/nu/modules/servicedirective/entity/ConfigServiceDirective.java b/nursing-unit-service-directive/nu-service-directive-biz/src/main/java/com/nu/modules/servicedirective/entity/ConfigServiceDirective.java
index 267c48b..73af23a 100644
--- a/nursing-unit-service-directive/nu-service-directive-biz/src/main/java/com/nu/modules/servicedirective/entity/ConfigServiceDirective.java
+++ b/nursing-unit-service-directive/nu-service-directive-biz/src/main/java/com/nu/modules/servicedirective/entity/ConfigServiceDirective.java
@@ -148,4 +148,7 @@ public class ConfigServiceDirective implements Serializable {
     //服务指令标签
     @TableField(exist = false)
     List<DirectiveTag> tagList;
+
+    @TableField(exist = false)
+    private String orgCode;
 }
diff --git a/nursing-unit-service-directive/nu-service-directive-biz/src/main/java/com/nu/modules/servicedirective/service/impl/ConfigServiceDirectiveServiceImpl.java b/nursing-unit-service-directive/nu-service-directive-biz/src/main/java/com/nu/modules/servicedirective/service/impl/ConfigServiceDirectiveServiceImpl.java
index 44e7e72..f91222e 100644
--- a/nursing-unit-service-directive/nu-service-directive-biz/src/main/java/com/nu/modules/servicedirective/service/impl/ConfigServiceDirectiveServiceImpl.java
+++ b/nursing-unit-service-directive/nu-service-directive-biz/src/main/java/com/nu/modules/servicedirective/service/impl/ConfigServiceDirectiveServiceImpl.java
@@ -1,5 +1,6 @@
 package com.nu.modules.servicedirective.service.impl;
 
+import com.baomidou.dynamic.datasource.annotation.DS;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.nu.modules.directivetag.entity.DirectiveTag;
@@ -20,7 +21,6 @@ import java.util.stream.Collectors;
 @Service
 public class ConfigServiceDirectiveServiceImpl extends ServiceImpl<ConfigServiceDirectiveMapper, ConfigServiceDirective> implements IConfigServiceDirectiveService {
 
-
     @Override
     public List<ConfigServiceDirective> pageList(ConfigServiceDirective configServiceDirective,IPage<ConfigServiceDirective> list_) {
         if(list_.getRecords() == null || list_.getRecords().isEmpty()){