From 904319211bf9c9b1eafb0585e4c1efabd20785df Mon Sep 17 00:00:00 2001
From: lijiarao <lijiarao@syxysoft.com>
Date: Fri, 5 Jul 2024 09:22:21 +0800
Subject: [PATCH] =?UTF-8?q?update=20=E5=8A=9F=E8=83=BD=E5=AE=89=E5=85=A8?=
 =?UTF-8?q?=E4=B8=AD=E5=BF=83=20=E5=8F=91=E5=B8=83=E6=8F=90=E9=86=92?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/PayMeetingServiceImpl.java   | 33 +++++++++++++++++++
 .../jero/meeting/vo/PublishReminderVO.java    |  2 ++
 2 files changed, 35 insertions(+)

diff --git a/jero-boot-incoming-payment/src/main/java/com/jero/meeting/service/impl/PayMeetingServiceImpl.java b/jero-boot-incoming-payment/src/main/java/com/jero/meeting/service/impl/PayMeetingServiceImpl.java
index 618b0681..5917c61a 100644
--- a/jero-boot-incoming-payment/src/main/java/com/jero/meeting/service/impl/PayMeetingServiceImpl.java
+++ b/jero-boot-incoming-payment/src/main/java/com/jero/meeting/service/impl/PayMeetingServiceImpl.java
@@ -41,6 +41,10 @@ import com.jero.drafting.entity.PayDraftingGroup;
 import com.jero.drafting.entity.PayDraftingGroupSubItemContacts;
 import com.jero.drafting.service.IPayDraftingGroupService;
 import com.jero.drafting.service.IPayDraftingGroupSubItemContactsService;
+import com.jero.functionalsafetycenter.entity.SafetyCenter;
+import com.jero.functionalsafetycenter.entity.SafetyCenterSubitemContacts;
+import com.jero.functionalsafetycenter.service.SafetyCenterService;
+import com.jero.functionalsafetycenter.service.SafetyCenterSubitemContactsService;
 import com.jero.meeting.common.MeetingCommon;
 import com.jero.meeting.common.MeetingSubitemCommon;
 import com.jero.meeting.entity.*;
@@ -149,6 +153,10 @@ public class PayMeetingServiceImpl extends ServiceImpl<PayMeetingMapper, PayMeet
     private IPayContactsManagementService contactsManagementService;
     @Resource
     private PayMeetingStandardProjectService meetingStandardProjectService;
+    @Resource
+    private SafetyCenterService safetyCenterService;
+    @Resource
+    private SafetyCenterSubitemContactsService safetyCenterSubitemContactsService;
     /**
      * 新增会议
      */
@@ -723,6 +731,7 @@ public class PayMeetingServiceImpl extends ServiceImpl<PayMeetingMapper, PayMeet
         List<String> contactsIdList = new ArrayList<>();
         String workingGroupId = null;
         String draftingGroupId = null;
+        String safetyCenterId = null;
         //工作组项目直接是人
         if (Objects.equals(projectType, 1)) {
             //把单位会员中所有的联系人取出
@@ -784,6 +793,23 @@ public class PayMeetingServiceImpl extends ServiceImpl<PayMeetingMapper, PayMeet
                                 .setContactId(contactsId)
                 );
             }
+        }else if (Objects.equals(projectType, 5)) {
+            //把单位会员中所有的联系人取出
+            safetyCenterId = publishReminderVO.getSafetyCenterId();
+            LambdaQueryWrapper<SafetyCenterSubitemContacts> wrapper1 = new LambdaQueryWrapper<>();
+            wrapper1.eq(SafetyCenterSubitemContacts::getProjectId, safetyCenterId);
+            wrapper1.in(SafetyCenterSubitemContacts::getContactsId,subitemIds);
+            List<SafetyCenterSubitemContacts> groupSubItemContactsList = safetyCenterSubitemContactsService.list(wrapper1);
+            for (SafetyCenterSubitemContacts payDraftingGroupSubItemContacts : groupSubItemContactsList) {
+                String subitemId = payDraftingGroupSubItemContacts.getSubitemId();
+                String contactsId = payDraftingGroupSubItemContacts.getContactsId();
+                contactsIdList.add(contactsId);
+                meetingRemindRecordList.add(
+                        new PayMeetingRemindRecord()
+                                .setSubitemId(subitemId)
+                                .setContactId(contactsId)
+                );
+            }
         } else {
             throw new JeroBootException("项目类型不正确");
         }
@@ -815,6 +841,13 @@ public class PayMeetingServiceImpl extends ServiceImpl<PayMeetingMapper, PayMeet
                 LoginUser userById = sysBaseAPI.getUserById(principalIdA);
                 fromUser = userById.getUsername();
             }
+            //起草组项目用工作组负责人A发邮件
+            if (Objects.nonNull(safetyCenterId)) {
+                SafetyCenter safetyCenter = safetyCenterService.getById(safetyCenterId);
+                String principalId = safetyCenter.getPrincipalId();
+                LoginUser userById = sysBaseAPI.getUserById(principalId);
+                fromUser = userById.getUsername();
+            }
             //发送消息
             int success = list.size();
             int failed = 0;
diff --git a/jero-boot-incoming-payment/src/main/java/com/jero/meeting/vo/PublishReminderVO.java b/jero-boot-incoming-payment/src/main/java/com/jero/meeting/vo/PublishReminderVO.java
index 0450ebb0..d1e970b5 100644
--- a/jero-boot-incoming-payment/src/main/java/com/jero/meeting/vo/PublishReminderVO.java
+++ b/jero-boot-incoming-payment/src/main/java/com/jero/meeting/vo/PublishReminderVO.java
@@ -26,4 +26,6 @@ public class PublishReminderVO {
 
     @ApiModelProperty(value = "起草组id")
     private java.lang.String draftingGroupId;
+    @ApiModelProperty(value = "安全中心id")
+    private String safetyCenterId;
 }