package com.yami.shop.api.controller;
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.yami.shop.bean.app.dto.NoticeDto;
|
import com.yami.shop.bean.enums.NoticeType;
|
import com.yami.shop.bean.model.Notice;
|
import com.yami.shop.bean.model.NoticeUserLog;
|
import com.yami.shop.common.enums.StatusEnum;
|
import com.yami.shop.common.response.ServerResponseEntity;
|
import com.yami.shop.common.util.PageParam;
|
import com.yami.shop.security.api.model.YamiUser;
|
import com.yami.shop.security.api.util.SecurityUtils;
|
import com.yami.shop.security.common.bo.UserInfoInTokenBO;
|
import com.yami.shop.security.common.util.AuthUserContext;
|
import com.yami.shop.service.NoticeService;
|
import com.yami.shop.service.NoticeUserLogService;
|
import io.swagger.v3.oas.annotations.tags.Tag;
|
import io.swagger.v3.oas.annotations.Parameter;
|
import io.swagger.v3.oas.annotations.Operation;
|
import lombok.AllArgsConstructor;
|
import ma.glasnost.orika.MapperFacade;
|
import org.springframework.web.bind.annotation.*;
|
|
import java.security.Security;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Objects;
|
import java.util.regex.Matcher;
|
import java.util.regex.Pattern;
|
import java.util.stream.Collectors;
|
|
@RestController
|
@RequestMapping("/p/notice")
|
@Tag(name = "用户登录状态的公告管理接口")
|
@AllArgsConstructor
|
public class MyNoticeController {
|
private final NoticeService noticeService;
|
private final NoticeUserLogService noticeUserLogService;
|
|
private final MapperFacade mapperFacade;
|
|
@GetMapping("/topNoticeList/{shopId}")
|
@Operation(summary = "置顶公告列表信息", description = "获取所有置顶公告列表信息")
|
@Parameter(name = "shopId", description = "店铺id", required = true)
|
public ServerResponseEntity<List<NoticeDto>> getTopNoticeListByShopId(@PathVariable("shopId") Long shopId) {
|
List<Notice> noticeList = noticeService.listTopNoticeByShopId(shopId);
|
//筛选出立即发送和到时间定时发送的公告
|
List<Notice> list = noticeList.stream().filter(noticeVO -> Objects.equals(noticeVO.getImmediatelySend(), 1) || (Objects.equals(noticeVO.getImmediatelySend(), 0) && noticeVO.getSendTime().before(new Date()))).collect(Collectors.toList());
|
|
List<NoticeDto> noticeDtoList = mapperFacade.mapAsList(list, NoticeDto.class);
|
UserInfoInTokenBO userInfoInTokenBO = AuthUserContext.get();
|
List<NoticeDto> result = new ArrayList<>();
|
String accountId = "";
|
//登录状态显示 指定全部用户和指定用户可见的公告
|
if (Objects.nonNull(userInfoInTokenBO)) {
|
accountId = userInfoInTokenBO.getUserId();
|
String userId = String.valueOf(accountId);
|
result = noticeDtoList.stream().filter(notice -> Objects.isNull(notice.getUserIds()) || (Objects.nonNull(notice.getUserIds()) && notice.getUserIds().contains(userId))).collect(Collectors.toList());
|
} else {
|
//未登录状态只显示 全部用户可见的公告
|
result = noticeDtoList.stream().filter(notice -> Objects.isNull(notice.getUserIds())).collect(Collectors.toList());
|
}
|
return ServerResponseEntity.success(result);
|
}
|
|
@GetMapping("/info/{id}")
|
@Operation(summary = "公告详情", description = "获取公告id公告详情")
|
@Parameter(name = "id", description = "公告id", required = true)
|
public ServerResponseEntity<NoticeDto> getNoticeById(@PathVariable("id") Long id) {
|
Notice notice = noticeService.getNoticeById(id);
|
NoticeDto noticeDto = mapperFacade.map(notice, NoticeDto.class);
|
return ServerResponseEntity.success(noticeDto);
|
}
|
|
/**
|
* 公告列表
|
*/
|
@GetMapping("/noticeList/{shopId}")
|
@Operation(summary = "公告列表信息", description = "获取所有公告列表信息")
|
@Parameter(name = "shopId", description = "店铺id", required = true)
|
public ServerResponseEntity<IPage<NoticeDto>> pageNotice(@PathVariable("shopId") Long shopId, PageParam<NoticeDto> page) {
|
Notice notice = new Notice();
|
notice.setShopId(shopId);
|
notice.setType(NoticeType.TO_USER.value());
|
UserInfoInTokenBO userInfoInTokenBO = AuthUserContext.get();
|
notice.setAccountId(Objects.nonNull(userInfoInTokenBO) ? userInfoInTokenBO.getUserId() : null);
|
notice.setSendTime(new Date());
|
notice.setStatus(StatusEnum.ENABLE.value());
|
return ServerResponseEntity.success(noticeService.pageNotice(page, notice));
|
}
|
|
/**
|
* 用户已读公告记录
|
*/
|
@PostMapping("/readNoticeLog")
|
@Operation(summary = "用户已读公告记录", description = "用户已读公告记录")
|
public ServerResponseEntity readNoticeLog(@RequestBody NoticeDto noticeDto) {
|
String userId = SecurityUtils.getUser().getUserId();
|
NoticeUserLog noticeUserLog = noticeUserLogService.getOne(Wrappers.lambdaQuery(NoticeUserLog.class)
|
.eq(NoticeUserLog::getNoticeId, noticeDto.getId())
|
.eq(NoticeUserLog::getUserId, userId));
|
if (noticeUserLog != null) {
|
return ServerResponseEntity.success();
|
}
|
noticeUserLog = new NoticeUserLog();
|
noticeUserLog.setNoticeId( noticeDto.getId());
|
noticeUserLog.setUserId(userId);
|
noticeUserLogService.save(noticeUserLog);
|
return ServerResponseEntity.success();
|
}
|
|
/**
|
* 查询最新的公告
|
*/
|
@GetMapping("/newNotice")
|
@Operation(summary = "查询最新的公告", description = "查询最新的公告")
|
public ServerResponseEntity<NoticeDto> getNewNotice() {
|
NoticeDto newNotice = noticeService.getNewNotice();
|
YamiUser user = SecurityUtils.getUser();
|
if (user != null) {
|
NoticeUserLog noticeUserLog = noticeUserLogService.getOne(Wrappers.lambdaQuery(NoticeUserLog.class)
|
.eq(NoticeUserLog::getNoticeId, newNotice.getId())
|
.eq(NoticeUserLog::getUserId, user.getUserId()));
|
if (noticeUserLog != null) {
|
return ServerResponseEntity.success();
|
}
|
}
|
return ServerResponseEntity.success(newNotice);
|
}
|
|
}
|
