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 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 wrapper1 = new LambdaQueryWrapper<>(); + wrapper1.eq(SafetyCenterSubitemContacts::getProjectId, safetyCenterId); + wrapper1.in(SafetyCenterSubitemContacts::getContactsId,subitemIds); + List 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