| | |
| | | import com.ruoyi.project.system.domain.SysNotice;
|
| | | import com.ruoyi.project.system.mapper.SysNoticeMapper;
|
| | | import com.ruoyi.project.system.service.ISysNoticeService;
|
| | | import org.springframework.transaction.annotation.Transactional;
|
| | |
|
| | | /**
|
| | | * 公告 服务层实现
|
| | |
| | | .map(it -> convertSysNotice(title, message, it, tenantId, jumpPath, unipushService.convertWebPathToAppPath(jumpPath), userId))
|
| | | .collect(Collectors.toList());
|
| | | sysNoticeService.saveBatch(sysNotices);
|
| | | try {
|
| | | unipushService.sendClientMessage(sysNotices);
|
| | | } catch (Exception e) {
|
| | | log.error("APP推送通知失败,原因: {}", e);
|
| | | }
|
| | | // try {
|
| | | // unipushService.sendClientMessage(sysNotices);
|
| | | // } catch (Exception e) {
|
| | | // log.error("APP推送通知失败,原因: {}", e);
|
| | | // }
|
| | | }
|
| | |
|
| | | @Override
|
| | |
| | | .collect(Collectors.toList());
|
| | |
|
| | | sysNoticeService.saveBatch(collect);
|
| | | try {
|
| | | unipushService.sendClientMessage(collect);
|
| | | } catch (Exception e) {
|
| | | log.error("APP推送通知失败,原因: {}", e);
|
| | | }
|
| | | // try {
|
| | | // unipushService.sendClientMessage(collect);
|
| | | // } catch (Exception e) {
|
| | | // log.error("APP推送通知失败,原因: {}", e);
|
| | | // }
|
| | | }
|
| | |
|
| | |
|
| | |
| | | return sysNotice;
|
| | | }
|
| | |
|
| | | @Override
|
| | | @Transactional(rollbackFor = Exception.class)
|
| | | public boolean appReadNotice(Long noticeId) {
|
| | | if (noticeId == null) {
|
| | | return false;
|
| | | }
|
| | | SysNotice sysNotice = noticeMapper.selectNoticeById(noticeId);
|
| | | if (sysNotice == null) {
|
| | | return false;
|
| | | }
|
| | | sysNotice.setStatus("1");
|
| | | return noticeMapper.update(null, Wrappers.<SysNotice>lambdaUpdate()
|
| | | .eq(SysNotice::getNoticeId, noticeId)
|
| | | .eq(SysNotice::getStatus, "0")
|
| | | .set(SysNotice::getStatus, "1")) > 0;
|
| | | }
|
| | | }
|