From cc0d353b8b3e25f08df00d91778075bfcd8e2ba8 Mon Sep 17 00:00:00 2001
From: "1378012178@qq.com" <1378012178@qq.com>
Date: Thu, 17 Jul 2025 09:38:18 +0800
Subject: [PATCH] =?UTF-8?q?=E6=9C=8D=E5=8A=A1=E6=8C=87=E4=BB=A4-=E7=BB=99?=
 =?UTF-8?q?=E6=89=80=E6=9C=89=E4=B8=9A=E5=8A=A1=E5=B9=B3=E5=8F=B0=E6=9B=B4?=
 =?UTF-8?q?=E6=96=B0=E6=8C=87=E4=BB=A4=E8=B5=84=E6=BA=90?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ConfigServiceDirectiveController.java     | 45 ++++++++++++++++++-
 1 file changed, 43 insertions(+), 2 deletions(-)

diff --git a/nursing-unit-services/nu-services-biz/src/main/java/com/nu/modules/servicedirective/controller/ConfigServiceDirectiveController.java b/nursing-unit-services/nu-services-biz/src/main/java/com/nu/modules/servicedirective/controller/ConfigServiceDirectiveController.java
index c5de6af..c60c111 100644
--- a/nursing-unit-services/nu-services-biz/src/main/java/com/nu/modules/servicedirective/controller/ConfigServiceDirectiveController.java
+++ b/nursing-unit-services/nu-services-biz/src/main/java/com/nu/modules/servicedirective/controller/ConfigServiceDirectiveController.java
@@ -1,5 +1,6 @@
 package com.nu.modules.servicedirective.controller;
 
+import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
@@ -14,6 +15,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang.StringUtils;
 import org.jeecg.common.api.vo.Result;
 import org.jeecg.common.aspect.annotation.AutoLog;
+import org.jeecg.common.system.api.ISysBaseAPI;
 import org.jeecg.common.system.base.controller.JeecgController;
 import org.jeecg.common.system.query.QueryGenerator;
 import org.jeecg.common.system.query.QueryRuleEnum;
@@ -28,6 +30,7 @@ import java.util.Arrays;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
 
 /**
@@ -45,6 +48,8 @@ public class ConfigServiceDirectiveController extends JeecgController<ConfigServ
     private IConfigServiceDirectiveService configServiceDirectiveService;
     @Autowired
     private RabbitMQUtil rabbitMQUtil;
+    @Autowired
+    private ISysBaseAPI sysBaseAPI;
 
     /**
      * 分页列表查询
@@ -261,8 +266,8 @@ public class ConfigServiceDirectiveController extends JeecgController<ConfigServ
      * @param dto
      * @return
      */
-    @AutoLog(value = "服务指令-同步媒体资源给业务平台")
-    @ApiOperation(value = "服务指令-同步媒体资源给业务平台", notes = "服务指令-同步媒体资源给业务平台")
+    @AutoLog(value = "服务指令-同步媒体资源给服务指令对应的业务平台")
+    @ApiOperation(value = "服务指令-同步媒体资源给服务指令对应的业务平台", notes = "服务指令-同步媒体资源给服务指令对应的业务平台")
     @RequestMapping(value = "/syncMediaForBiz", method = {RequestMethod.PUT, RequestMethod.POST})
     public Result<Map> syncMediaForBiz(@RequestBody ConfigServiceDirective dto) {
         //处理媒体资源（放在保存方法之前）
@@ -277,4 +282,40 @@ public class ConfigServiceDirectiveController extends JeecgController<ConfigServ
         rabbitMQUtil.sendToExchange("hldy.directive", dto.getSysOrgCode() + ".directive.createmedia", directiveAsyncMQDto);
         return Result.OK(Maps.newHashMap());
     }
+
+    @AutoLog(value = "服务指令-同步媒体资源给所有业务平台")
+    @ApiOperation(value = "服务指令-同步媒体资源给所有业务平台", notes = "服务指令-同步媒体资源给所有业务平台")
+    @RequestMapping(value = "/syncMediaForAllBiz", method = {RequestMethod.PUT, RequestMethod.POST})
+    public Result<Map> syncMediaForAllBiz(@RequestBody ConfigServiceDirective dto) {
+        //处理媒体资源（放在保存方法之前）
+        configServiceDirectiveService.handleMediaFile(dto);
+        //保存
+        ConfigServiceDirective configServiceDirective = new ConfigServiceDirective();
+        BeanUtils.copyProperties(dto,configServiceDirective);
+        configServiceDirectiveService.updateById(configServiceDirective);
+
+        DirectiveAsyncMQDto directiveAsyncMQDto = new DirectiveAsyncMQDto();
+        BeanUtils.copyProperties(dto, directiveAsyncMQDto);
+
+        List<JSONObject> orgList = sysBaseAPI.queryOpeDept();
+        List<String> codes = orgList.stream()
+                .map(o -> o.getString("code"))
+                .collect(Collectors.toList());
+
+        //启动线程，循环 codes， 5 分钟通知一个平台
+        new Thread(() -> {
+            for (String code : codes) {
+                try {
+                    rabbitMQUtil.sendToExchange("hldy.directive", code + ".directive.createmedia", directiveAsyncMQDto);
+                    // 发送完后，休眠 5 分钟
+                    Thread.sleep(TimeUnit.MINUTES.toMillis(5));
+                } catch (InterruptedException e) {
+                    Thread.currentThread().interrupt();
+                    break;
+                }
+            }
+        }).start();
+
+        return Result.OK(Maps.newHashMap());
+    }
 }