业务层

一、定义Message业务接口

创建 MessageService.java 类

public interface MessageService {public String insertMessage(MessageEntity entity);public List<HashMap> searchMessageByPage(int userId, long start, int length);public HashMap searchMessageById(String id);public String insertRef(MessageRefEntity entity);public long searchUnreadCount(int userId);public long searchLastCount(int userId);public long updateUnreadMessage(String id);public long deleteMessageRefById(String id);public long deleteUserMessageRef(int userId);
}

二、定义Message业务实现类

创建 MessageServiceImpl.java 类

@Service
public class MessageServiceImpl implements MessageService {@Autowiredprivate MessageDao messageDao;@Autowiredprivate MessageRefDao messageRefDao;@Overridepublic String insertMessage(MessageEntity entity) {String id=messageDao.insert(entity);return id;}@Overridepublic List<HashMap> searchMessageByPage(int userId, long start, int length) {List<HashMap> list=messageDao.searchMessageByPage(userId,start,length);return list;}@Overridepublic HashMap searchMessageById(String id) {HashMap map=messageDao.searchMessageById(id);return map;}@Overridepublic String insertRef(MessageRefEntity entity) {String id=messageRefDao.insert(entity);return id;}@Overridepublic long searchUnreadCount(int userId) {long count=messageRefDao.searchUnreadCount(userId);return count;}@Overridepublic long searchLastCount(int userId) {long count=messageRefDao.searchLastCount(userId);return count;}@Overridepublic long updateUnreadMessage(String id) {long rows=messageRefDao.updateUnreadMessage(id);return rows;}@Overridepublic long deleteMessageRefById(String id) {long rows=messageRefDao.deleteMessageRefById(id);return rows;}@Overridepublic long deleteUserMessageRef(int userId) {long rows=messageRefDao.deleteUserMessageRef(userId);return rows;}
}

Web层

一、获取分页消息列表

创建 SearchMessageByPageForm.java 类

@Data
@ApiModel
public class SearchMessageByPageForm {@NotNull@Min(1)private Integer page;@NotNull@Range(min = 1,max = 40)private Integer length;
}

创建 MessageController.java 类

@RestController
@RequestMapping("/message")
@Api("消息模块网络接口")
public class MessageController {@Autowiredprivate JwtUtil jwtUtil;@Autowiredprivate MessageService messageService;@PostMapping("/searchMessageByPage")@ApiOperation("获取分页消息列表")public R searchMessageByPage(@Valid @RequestBody SearchMessageByPageForm form, @RequestHeader("token") String token) {int userId = jwtUtil.getUserId(token);int page = form.getPage();int length = form.getLength();long start = (page - 1) * length;List<HashMap> list = messageService.searchMessageByPage(userId, start, length);return R.ok().put("result", list);}
}

二、根据ID查询消息

创建 SearchMessageByIdForm.java 类

@Data
@ApiModel
public class SearchMessageByIdForm {@NotNullprivate String id;
}

在 MessageController.java 中编写Web方法

……@PostMapping("/searchMessageById")@ApiOperation("根据ID查询消息")public R searchMessageById(@Valid @RequestBody SearchMessageByIdForm form) {HashMap map = messageService.searchMessageById(form.getId());return R.ok().put("result", map);}

三、把未读消息更新成已读消息

创建 UpdateUnreadMessageForm.java 类

@Data
@ApiModel
public class UpdateUnreadMessageForm {@NotNullprivate String id;
}

在 MessageController.java 中编写Web方法

……    @PostMapping("/updateUnreadMessage")@ApiOperation("未读消息更新成已读消息")public R updateUnreadMessage(@Valid @RequestBody UpdateUnreadMessageForm form) {long rows = messageService.updateUnreadMessage(form.getId());return R.ok().put("result", rows == 1 ? true : false);}

四、删除消息

创建 DeleteMessageRefByIdForm.java 类

@Data
@ApiModel
public class DeleteMessageRefByIdForm {@NotNullprivate String id;
}

在 MessageController.java 中编写Web方法

……@PostMapping("/deleteMessageRefById")@ApiOperation("删除消息")public R deleteMessageRefById(@Valid @RequestBody DeleteMessageRefByIdForm form) {long rows = messageService.deleteMessageRefById(form.getId());return R.ok().put("result", rows == 1 ? true : false);}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.hqwc.cn/news/2377.html

如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！