Skip to content

Commit

Permalink
fix : team.isDeleted 다시 반영
Browse files Browse the repository at this point in the history
  • Loading branch information
seungueonn committed Dec 21, 2023
1 parent 67a1373 commit c0ea38e
Show file tree
Hide file tree
Showing 2 changed files with 16 additions and 4 deletions.
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
package com.moing.backend.domain.mission.application.service;

import com.moing.backend.domain.history.application.dto.response.MemberIdAndToken;
import com.moing.backend.domain.history.application.mapper.AlarmHistoryMapper;
import com.moing.backend.domain.history.application.service.SaveMultiAlarmHistoryUseCase;
import com.moing.backend.domain.history.domain.entity.AlarmType;
import com.moing.backend.domain.history.domain.entity.PagePath;
import com.moing.backend.domain.member.domain.entity.Member;
Expand Down Expand Up @@ -35,6 +37,9 @@ public class MissionRemindAlarmUseCase {
private final MissionQueryService missionQueryService;
private final ApplicationEventPublisher eventPublisher;

private final FcmService fcmService;
private final SaveMultiAlarmHistoryUseCase saveMultiAlarmHistoryUseCase;

String REMIND_NAME = "미션 리마인드";


Expand All @@ -49,8 +54,15 @@ public Boolean sendRemindMissionAlarm() {
Optional<List<MemberIdAndToken>> memberIdAndTokens = mapToMemberAndToken(remainMissionPeople);
Optional<List<MemberIdAndToken>> pushMemberIdAndToken = isPushMemberIdAndToken(remainMissionPeople);

eventPublisher.publishEvent(new MultiFcmEvent(title, message, pushMemberIdAndToken, memberIdAndTokens,
"",REMIND_NAME, AlarmType.REMIND, PagePath.MISSION_ALL_PTAH.getValue()));
// eventPublisher.publishEvent(new MultiFcmEvent(title, message, pushMemberIdAndToken, memberIdAndTokens,
// "",REMIND_NAME, AlarmType.REMIND, PagePath.MISSION_ALL_PTAH.getValue()));

if (pushMemberIdAndToken.isPresent() && !pushMemberIdAndToken.get().isEmpty()) {
fcmService.sendMultipleDevices(new MultiRequest(pushMemberIdAndToken.get(), title,message, "",REMIND_NAME, AlarmType.REMIND, PagePath.MISSION_ALL_PTAH.getValue()));
}
if (memberIdAndTokens.isPresent() && !memberIdAndTokens.get().isEmpty()) {
saveMultiAlarmHistoryUseCase.saveAlarmHistories(AlarmHistoryMapper.getMemberIds(memberIdAndTokens.get()),"",title,message,REMIND_NAME, AlarmType.REMIND, PagePath.MISSION_ALL_PTAH.getValue());
}
return true;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -426,6 +426,7 @@ public Optional<List<Member>> findHavingRemainMissionsByQuerydsl() {
.from(teamMember)
.join(mission)
.on(teamMember.team.eq(mission.team),
teamMember.team.isDeleted.ne(true),
((mission.status.eq(MissionStatus.ONGOING).or(mission.status.eq(MissionStatus.WAIT)))
.and(mission.type.eq(MissionType.ONCE)))
.or(mission.status.eq(MissionStatus.ONGOING).and(mission.type.eq(MissionType.REPEAT)))
Expand All @@ -438,8 +439,7 @@ public Optional<List<Member>> findHavingRemainMissionsByQuerydsl() {
)
.groupBy(teamMember.member,mission,mission.number)
.having(missionArchive.count().lt(mission.number),
teamMember.member.isDeleted.ne(true),
teamMember.team.isDeleted.ne(true))
teamMember.member.isDeleted.ne(true))
.fetch());


Expand Down

0 comments on commit c0ea38e

Please sign in to comment.