| Line 118... |
Line 118... |
| 118 |
sendNotificationModel.setUserIds(fofoStoreRepository.selectAllDtrUserIds());
|
118 |
sendNotificationModel.setUserIds(fofoStoreRepository.selectAllDtrUserIds());
|
| 119 |
Set<AuthUser> authUsers = new HashSet<>(csService.getAuthUserByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_RBM));
|
119 |
Set<AuthUser> authUsers = new HashSet<>(csService.getAuthUserByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_RBM));
|
| 120 |
authUsers.addAll(csService.getAuthUserByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_CATEGORY));
|
120 |
authUsers.addAll(csService.getAuthUserByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_CATEGORY));
|
| 121 |
authUsers.addAll(csService.getAuthUserByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_SALES));
|
121 |
authUsers.addAll(csService.getAuthUserByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_SALES));
|
| 122 |
List<String> emailIds = authUsers.stream().map(x -> x.getEmailId()).collect(Collectors.toList());
|
122 |
List<String> emailIds = authUsers.stream().map(x -> x.getEmailId()).collect(Collectors.toList());
|
| 123 |
List<User> user = dtrUserRepository.selectAllByEmailIds(emailIds);
|
123 |
List<User> systemUsers = dtrUserRepository.selectAllByEmailIds(emailIds);
|
| 124 |
sendNotificationModel.getUserIds().addAll(user.stream().map(x -> x.getId()).collect(Collectors.toList()));
|
124 |
sendNotificationModel.getUserIds().addAll(systemUsers.stream().map(x -> x.getId()).collect(Collectors.toList()));
|
| 125 |
this.sendNotification(sendNotificationModel);
|
125 |
this.sendNotification(sendNotificationModel);
|
| 126 |
}
|
126 |
}
|
| 127 |
|
127 |
|
| 128 |
public void pushNotification(int cid, List<Device> devices) {
|
128 |
public void pushNotification(int cid, List<Device> devices) {
|
| 129 |
|
129 |
|