From 62c37c01fab473d0c08192a0608dcd85134b6333 Mon Sep 17 00:00:00 2001
From: "1378012178@qq.com" <1378012178@qq.com>
Date: Tue, 27 Jan 2026 14:57:40 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BE=9B=E5=BA=94=E5=95=86=E5=AE=A1=E6=A0=B8?=
 =?UTF-8?q?=E6=95=B4=E4=BD=93=E6=B5=81=E7=A8=8B=E5=8F=98=E6=9B=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../NuConfigSuppliersApplyController.java     |  3 ++-
 .../INuConfigSuppliersApplyService.java       |  2 +-
 .../NuConfigSuppliersApplyServiceImpl.java    |  4 ++-
 .../listener/DynamicQueueNameProvider.java    | 14 ++++++++++
 .../listener/SuppliersMQListener.java         | 27 +++++++++++++++++++
 5 files changed, 47 insertions(+), 3 deletions(-)

diff --git a/nursing-unit-invoicing/nu-invoicing-biz/src/main/java/com/nu/modules/configSuppliersApply/controller/NuConfigSuppliersApplyController.java b/nursing-unit-invoicing/nu-invoicing-biz/src/main/java/com/nu/modules/configSuppliersApply/controller/NuConfigSuppliersApplyController.java
index 99ee37b1..2e173365 100644
--- a/nursing-unit-invoicing/nu-invoicing-biz/src/main/java/com/nu/modules/configSuppliersApply/controller/NuConfigSuppliersApplyController.java
+++ b/nursing-unit-invoicing/nu-invoicing-biz/src/main/java/com/nu/modules/configSuppliersApply/controller/NuConfigSuppliersApplyController.java
@@ -220,9 +220,10 @@ public class NuConfigSuppliersApplyController extends JeecgController<NuConfigSu
 	 @ApiOperation(value="供应商入驻申请-变更审核", notes="供应商入驻申请-变更审核")
 	 @RequestMapping(value = "/audit", method = {RequestMethod.PUT,RequestMethod.POST})
 	 public Result<String> audit(@RequestBody NuConfigSuppliersApply nuConfigSuppliersApply) {
-		 nuConfigSuppliersApplyService.audit(nuConfigSuppliersApply);
+		 String orgCode = nuConfigSuppliersApplyService.audit(nuConfigSuppliersApply);
 		 SuppliersInfoMQDto suppliersInfoMQDto = new SuppliersInfoMQDto();
 		 BeanUtils.copyProperties(nuConfigSuppliersApply, suppliersInfoMQDto);
+		 suppliersInfoMQDto.setSysOrgCode(orgCode);
 		 rabbitMQUtil.sendToExchange("nu.suppliers.updateAuditResult", "nu.suppliers.updateAuditResult", suppliersInfoMQDto);
 		 return Result.OK("编辑成功!");
 	 }
diff --git a/nursing-unit-invoicing/nu-invoicing-biz/src/main/java/com/nu/modules/configSuppliersApply/service/INuConfigSuppliersApplyService.java b/nursing-unit-invoicing/nu-invoicing-biz/src/main/java/com/nu/modules/configSuppliersApply/service/INuConfigSuppliersApplyService.java
index b42f98a8..66316472 100644
--- a/nursing-unit-invoicing/nu-invoicing-biz/src/main/java/com/nu/modules/configSuppliersApply/service/INuConfigSuppliersApplyService.java
+++ b/nursing-unit-invoicing/nu-invoicing-biz/src/main/java/com/nu/modules/configSuppliersApply/service/INuConfigSuppliersApplyService.java
@@ -16,5 +16,5 @@ public interface INuConfigSuppliersApplyService extends IService<NuConfigSupplie
 
     List<Map<String, Object>> getModifyInfo(NuConfigSuppliersApply suppliersApply);
 
-    void audit(NuConfigSuppliersApply nuConfigSuppliersApply);
+    String audit(NuConfigSuppliersApply nuConfigSuppliersApply);
 }
diff --git a/nursing-unit-invoicing/nu-invoicing-biz/src/main/java/com/nu/modules/configSuppliersApply/service/impl/NuConfigSuppliersApplyServiceImpl.java b/nursing-unit-invoicing/nu-invoicing-biz/src/main/java/com/nu/modules/configSuppliersApply/service/impl/NuConfigSuppliersApplyServiceImpl.java
index a5fcc4c4..93f1ac5a 100644
--- a/nursing-unit-invoicing/nu-invoicing-biz/src/main/java/com/nu/modules/configSuppliersApply/service/impl/NuConfigSuppliersApplyServiceImpl.java
+++ b/nursing-unit-invoicing/nu-invoicing-biz/src/main/java/com/nu/modules/configSuppliersApply/service/impl/NuConfigSuppliersApplyServiceImpl.java
@@ -103,7 +103,7 @@ public class NuConfigSuppliersApplyServiceImpl extends ServiceImpl<NuConfigSuppl
     }
 
     @Override
-    public void audit(NuConfigSuppliersApply nuConfigSuppliersApply) {
+    public String audit(NuConfigSuppliersApply nuConfigSuppliersApply) {
         //变更后数据
         NuConfigSuppliersApply one = baseMapper.selectById(nuConfigSuppliersApply.getId());
 
@@ -134,5 +134,7 @@ public class NuConfigSuppliersApplyServiceImpl extends ServiceImpl<NuConfigSuppl
             apply.setApplyContent(nuConfigSuppliersApply.getApplyContent());
         }
         baseMapper.updateById(apply);
+
+        return one.getSysOrgCode();
     }
 }
diff --git a/nursing-unit-invoicing/nu-invoicing-biz/src/main/java/com/nu/mq/suppliers/listener/DynamicQueueNameProvider.java b/nursing-unit-invoicing/nu-invoicing-biz/src/main/java/com/nu/mq/suppliers/listener/DynamicQueueNameProvider.java
index ae4e7fcc..15119605 100644
--- a/nursing-unit-invoicing/nu-invoicing-biz/src/main/java/com/nu/mq/suppliers/listener/DynamicQueueNameProvider.java
+++ b/nursing-unit-invoicing/nu-invoicing-biz/src/main/java/com/nu/mq/suppliers/listener/DynamicQueueNameProvider.java
@@ -39,4 +39,18 @@ public class DynamicQueueNameProvider {
     public String getEditSuppApply() {
         return getEditSuppliersApply();
     }
+
+    public String getUpSuppliersInfo() {
+        JSONObject deptInfo = sysBaseAPI.getDeptInfo();
+        String orgCode = deptInfo.getString("code");
+        if (StringUtils.isNotBlank(orgCode)) {
+            return orgCode + ".suppliers.upSuppliersInfo";
+        } else {
+            return "";
+        }
+    }
+
+    public String getUpSuppApplyInfoKey() {
+        return getUpSuppliersInfo();
+    }
 }
diff --git a/nursing-unit-invoicing/nu-invoicing-biz/src/main/java/com/nu/mq/suppliers/listener/SuppliersMQListener.java b/nursing-unit-invoicing/nu-invoicing-biz/src/main/java/com/nu/mq/suppliers/listener/SuppliersMQListener.java
index ea81f763..cf3135db 100644
--- a/nursing-unit-invoicing/nu-invoicing-biz/src/main/java/com/nu/mq/suppliers/listener/SuppliersMQListener.java
+++ b/nursing-unit-invoicing/nu-invoicing-biz/src/main/java/com/nu/mq/suppliers/listener/SuppliersMQListener.java
@@ -114,6 +114,33 @@ public class SuppliersMQListener {
 
     }
 
+    @AutoLog(value = "供应商-信息变更通过")
+    @RabbitListener(
+            bindings = @QueueBinding(
+                    value = @Queue(name = "#{suppliersDQNP.getUpSuppliersInfo()}"),
+                    exchange = @Exchange(name = "nu.suppliers.upSuppliersInfo", type = ExchangeTypes.DIRECT),
+                    key = "#{suppliersDQNP.getUpSuppApplyInfoKey()}"
+            ),
+            errorHandler = "suppliersMQExceptionHandler"
+    )
+    public void upSuppliersInfo(SuppliersInfoMQDto suppliersInfoMQDto) {
+        try {
+            ConfigSuppliersInfo configSuppliersInfo = new ConfigSuppliersInfo();
+            configSuppliersInfo.setId(suppliersInfoMQDto.getSuppliersId());
+            configSuppliersInfo.setSuppliersName(suppliersInfoMQDto.getSuppliersName());//供应商名称
+            configSuppliersInfo.setSuppliersNature(suppliersInfoMQDto.getSuppliersNature());//供应商性质
+            configSuppliersInfo.setSuppliersAddress(suppliersInfoMQDto.getSuppliersAddress());//供应商地址
+            configSuppliersInfo.setPersonInCharge(suppliersInfoMQDto.getPersonInCharge());//负责人
+            configSuppliersInfo.setContactNumber(suppliersInfoMQDto.getContactNumber());//联系电话
+            configSuppliersInfo.setOpeningBank(suppliersInfoMQDto.getOpeningBank());//开户行
+            configSuppliersInfo.setOpeningBankNo(suppliersInfoMQDto.getOpeningBankNo());//开户行账号
+            configSuppliersInfo.setImgPath(suppliersInfoMQDto.getImgPath());//资质照片
+            configSuppliersInfoService.updateById(configSuppliersInfo);
+            System.out.println("保存成功");
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
 
+    }
 
 }