消息提醒代码开发

master
薛宏祥 1 year ago
parent 09641ae56c
commit 9d611ac092
  1. 26
      src/main/java/org/springblade/modules/business/contraller/MessageController.java
  2. 2
      src/main/java/org/springblade/modules/business/pojo/vo/MessageVO.java
  3. 15
      src/main/java/org/springblade/modules/business/pojo/vo/PageVO.java
  4. 3
      src/main/java/org/springblade/modules/business/service/IMessageService.java
  5. 9
      src/main/java/org/springblade/modules/business/service/impl/MessageServiceImpl.java

@ -10,7 +10,6 @@ import org.springblade.modules.business.pojo.vo.MessageVO;
import org.springblade.modules.business.service.IMessageService; import org.springblade.modules.business.service.IMessageService;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
import javax.swing.plaf.SeparatorUI;
import java.time.LocalDateTime; import java.time.LocalDateTime;
import java.util.List; import java.util.List;
@ -33,32 +32,33 @@ public class MessageController extends BladeController {
* @param status * @param status
* @return * @return
*/ */
@PostMapping("/list") @GetMapping("/list")
@Operation(summary = "消息列表获取", description = "消息列表获取") @Operation(summary = "消息列表获取", description = "消息列表获取")
public R getMessageList(Integer current, Integer size, LocalDateTime start, LocalDateTime end, Integer status) { public R getMessageList(Integer current, Integer size, LocalDateTime start, LocalDateTime end, Integer status) {
List<MessageVO> messageList = messageService.getMessageList(current, size, start, end, status); return R.data(messageService.getMessageList(current, size, start, end, status));
return R.data(messageList);
} }
/** /**
* 获取消息总数接口 * 获取消息总数接口
*
* @return * @return
*/ */
@PostMapping("/total") @GetMapping("/total")
@Operation(summary = "获取消息总数",description = "获取消息总数") @Operation(summary = "获取消息总数", description = "获取消息总数")
public R getMessageTotal(){ public R getMessageTotal() {
Long messageTotal = messageService.getMessageTotal(); Long messageTotal = messageService.getMessageTotal();
return R.data(messageTotal); return R.data(messageTotal);
} }
/** /**
* 更新已读接口 * 更新已读接口
*
* @param id * @param id
* @param status * @param status
* @return * @return
*/ */
@PostMapping("/updateStatus") @PutMapping("/updateStatus")
@Operation(summary = "更新已读",description = "更新已读") @Operation(summary = "更新已读", description = "更新已读")
public void updateMessageStatus(Integer id, Integer status) { public void updateMessageStatus(Integer id, Integer status) {
messageService.updateMessageStatus(id, status); messageService.updateMessageStatus(id, status);
} }
@ -66,9 +66,9 @@ public class MessageController extends BladeController {
/** /**
* 一键已读全部接口 * 一键已读全部接口
*/ */
@PostMapping("/updateStatusAll") @PutMapping("/updateStatusAll")
@Operation(summary = "一键全部已读",description = "一键全部已读") @Operation(summary = "一键全部已读", description = "一键全部已读")
public void updateMessageStatusAll(){ public void updateMessageStatusAll() {
messageService.updateMessageStatusAll(); messageService.updateMessageStatusAll();
} }
@ -80,7 +80,7 @@ public class MessageController extends BladeController {
Long messageUser = message.getMessageUser(); Long messageUser = message.getMessageUser();
Integer messageType = message.getMessageType(); Integer messageType = message.getMessageType();
messageService.saveMessage(systemType,title,content,messageUser,messageType); messageService.saveMessage(systemType, title, content, messageUser, messageType);
} }
} }

@ -17,6 +17,4 @@ public class MessageVO {
private Integer status; private Integer status;
private Integer messageType; private Integer messageType;
} }

@ -0,0 +1,15 @@
package org.springblade.modules.business.pojo.vo;
import io.lettuce.core.protocol.CommandHandler;
import lombok.Data;
import java.util.List;
@Data
public class PageVO {
private List<MessageVO> list;
private Long total;
}

@ -3,6 +3,7 @@ package org.springblade.modules.business.service;
import org.springblade.core.mp.base.BaseService; import org.springblade.core.mp.base.BaseService;
import org.springblade.modules.business.pojo.entity.Message; import org.springblade.modules.business.pojo.entity.Message;
import org.springblade.modules.business.pojo.vo.MessageVO; import org.springblade.modules.business.pojo.vo.MessageVO;
import org.springblade.modules.business.pojo.vo.PageVO;
import java.time.LocalDateTime; import java.time.LocalDateTime;
import java.util.List; import java.util.List;
@ -12,7 +13,7 @@ public interface IMessageService extends BaseService<Message> {
void saveMessage(String systemType, String title, String content, Long messageUser, Integer messageType); void saveMessage(String systemType, String title, String content, Long messageUser, Integer messageType);
List<MessageVO> getMessageList(Integer current, Integer size, LocalDateTime start, LocalDateTime end, Integer status); PageVO getMessageList(Integer current, Integer size, LocalDateTime start, LocalDateTime end, Integer status);
Long getMessageTotal(); Long getMessageTotal();

@ -8,6 +8,7 @@ import org.springblade.core.secure.utils.AuthUtil;
import org.springblade.modules.business.mapper.MessageMapper; import org.springblade.modules.business.mapper.MessageMapper;
import org.springblade.modules.business.pojo.entity.Message; import org.springblade.modules.business.pojo.entity.Message;
import org.springblade.modules.business.pojo.vo.MessageVO; import org.springblade.modules.business.pojo.vo.MessageVO;
import org.springblade.modules.business.pojo.vo.PageVO;
import org.springblade.modules.business.service.IMessageService; import org.springblade.modules.business.service.IMessageService;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
@ -54,7 +55,7 @@ public class MessageServiceImpl extends BaseServiceImpl<MessageMapper, Message>
* @return * @return
*/ */
@Override @Override
public List<MessageVO> getMessageList(Integer current, Integer size, LocalDateTime start, LocalDateTime end, Integer status) { public PageVO getMessageList(Integer current, Integer size, LocalDateTime start, LocalDateTime end, Integer status) {
QueryWrapper<Message> queryWrapper = new QueryWrapper<>(); QueryWrapper<Message> queryWrapper = new QueryWrapper<>();
if (start != null && end != null) { if (start != null && end != null) {
queryWrapper.between("create_time", start, end); queryWrapper.between("create_time", start, end);
@ -65,6 +66,7 @@ public class MessageServiceImpl extends BaseServiceImpl<MessageMapper, Message>
Page<Message> page = new Page<>(current, size); Page<Message> page = new Page<>(current, size);
Page<Message> messagePage = baseMapper.selectPage(page, queryWrapper); Page<Message> messagePage = baseMapper.selectPage(page, queryWrapper);
List<Message> records = messagePage.getRecords(); List<Message> records = messagePage.getRecords();
Long total = messagePage.getTotal();
MessageVO messageVO = new MessageVO(); MessageVO messageVO = new MessageVO();
List<MessageVO> messageVOList = new ArrayList<>(); List<MessageVO> messageVOList = new ArrayList<>();
for (Message record : records) { for (Message record : records) {
@ -75,7 +77,10 @@ public class MessageServiceImpl extends BaseServiceImpl<MessageMapper, Message>
messageVO.setCreateTime(record.getCreateTime()); messageVO.setCreateTime(record.getCreateTime());
messageVOList.add(messageVO); messageVOList.add(messageVO);
} }
return messageVOList; PageVO pageVO = new PageVO();
pageVO.setList(messageVOList);
pageVO.setTotal(total);
return pageVO;
} }
/** /**

Loading…
Cancel
Save