From 693a3da6af5c92a497dcd53e4a8442a53ee86637 Mon Sep 17 00:00:00 2001
From: 10002327 <lhj123456>
Date: Wed, 6 Nov 2024 14:12:46 +0800
Subject: [PATCH] =?UTF-8?q?=E5=91=86=E6=BB=9E=E7=89=A9=E6=96=99=E6=8F=90?=
 =?UTF-8?q?=E9=86=92rtx?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../product/material/config/MaterialMesConfig.java | 14 +++++++++++++-
 .../material/service/MaterialDeadStockService.java |  4 +++-
 2 files changed, 16 insertions(+), 2 deletions(-)

diff --git a/nflg_project_dev/material/src/main/java/com/nflg/product/material/config/MaterialMesConfig.java b/nflg_project_dev/material/src/main/java/com/nflg/product/material/config/MaterialMesConfig.java
index 7b025f44..5e19705a 100644
--- a/nflg_project_dev/material/src/main/java/com/nflg/product/material/config/MaterialMesConfig.java
+++ b/nflg_project_dev/material/src/main/java/com/nflg/product/material/config/MaterialMesConfig.java
@@ -1,5 +1,7 @@
 package com.nflg.product.material.config;
 
+import com.google.common.collect.Lists;
+import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
 import org.springframework.boot.context.properties.ConfigurationProperties;
 import org.springframework.cloud.context.config.annotation.RefreshScope;
@@ -76,5 +78,15 @@ public class MaterialMesConfig {
     /**
      *  采购组负责人RTX通知
      */
-    private List<Map<String,String>> purchaseNoticeList;
+    private List<NoticeRtx> purchaseNoticeList = Lists.newArrayList();
+
+    @Data
+    public class NoticeRtx{
+
+        @ApiModelProperty(value = "ekgrp")
+        private String ekgrp;
+
+        @ApiModelProperty(value = "rtx账号")
+        private String rtx;
+    }
 }
\ No newline at end of file
diff --git a/nflg_project_dev/material/src/main/java/com/nflg/product/material/service/MaterialDeadStockService.java b/nflg_project_dev/material/src/main/java/com/nflg/product/material/service/MaterialDeadStockService.java
index dfcaefec..79b04b24 100644
--- a/nflg_project_dev/material/src/main/java/com/nflg/product/material/service/MaterialDeadStockService.java
+++ b/nflg_project_dev/material/src/main/java/com/nflg/product/material/service/MaterialDeadStockService.java
@@ -74,7 +74,9 @@ public class MaterialDeadStockService  extends ServiceImpl<MaterialDeadStockMapp
             HttpUtils httpUtils = new HttpUtils();
             String title = "呆滞物料提醒";
             String msg = "有新增呆滞物料，请及时查看！";
-            httpUtils.rtxMessage(profiles,title,msg,purchaseSet.stream().collect(Collectors.joining(",")));
+            String receiver = materialMesConfig.getPurchaseNoticeList().stream().filter(pur -> purchaseSet.contains(pur.getEkgrp()))
+                            .map(MaterialMesConfig.NoticeRtx::getRtx).collect(Collectors.joining(","));
+            httpUtils.rtxMessage(profiles,title,msg,receiver);
         }
         return true;
     }