package com.pz.system.service.impl; import cn.hutool.core.bean.BeanUtil; import com.baomidou.mybatisplus.core.toolkit.StringUtils; import com.pz.common.core.page.TableDataInfo; import com.pz.common.core.domain.PageQuery; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import lombok.RequiredArgsConstructor; import org.springframework.stereotype.Service; import com.pz.system.domain.bo.MsgInfoBo; import com.pz.system.domain.vo.MsgInfoVo; import com.pz.system.domain.MsgInfo; import com.pz.system.mapper.MsgInfoMapper; import com.pz.system.service.IMsgInfoService; import java.util.List; import java.util.Map; import java.util.Collection; /** * 消息Service业务层处理 * * @author ruoyi * @date 2023-09-09 */ @RequiredArgsConstructor @Service public class MsgInfoServiceImpl implements IMsgInfoService { private final MsgInfoMapper baseMapper; /** * 查询消息 */ @Override public MsgInfoVo queryById(Long id){ return baseMapper.selectVoById(id); } /** * 查询消息列表 */ @Override public TableDataInfo<MsgInfoVo> queryPageList(MsgInfoBo bo, PageQuery pageQuery) { LambdaQueryWrapper<MsgInfo> lqw = buildQueryWrapper(bo); Page<MsgInfoVo> result = baseMapper.selectVoPage(pageQuery.build(), lqw); return TableDataInfo.build(result); } /** * 查询消息列表 */ @Override public List<MsgInfoVo> queryList(MsgInfoBo bo) { LambdaQueryWrapper<MsgInfo> lqw = buildQueryWrapper(bo); return baseMapper.selectVoList(lqw); } private LambdaQueryWrapper<MsgInfo> buildQueryWrapper(MsgInfoBo bo) { Map<String, Object> params = bo.getParams(); LambdaQueryWrapper<MsgInfo> lqw = Wrappers.lambdaQuery(); lqw.eq(bo.getFromUserId() != null, MsgInfo::getFromUserId, bo.getFromUserId()); lqw.like(StringUtils.isNotBlank(bo.getFromUserName()), MsgInfo::getFromUserName, bo.getFromUserName()); lqw.eq(bo.getToUserId() != null, MsgInfo::getToUserId, bo.getToUserId()); lqw.like(StringUtils.isNotBlank(bo.getToUserName()), MsgInfo::getToUserName, bo.getToUserName()); lqw.eq(StringUtils.isNotBlank(bo.getContent()), MsgInfo::getContent, bo.getContent()); lqw.eq(bo.getUnReadFlag() != null, MsgInfo::getUnReadFlag, bo.getUnReadFlag()); return lqw; } /** * 新增消息 */ @Override public Boolean insertByBo(MsgInfoBo bo) { MsgInfo add = BeanUtil.toBean(bo, MsgInfo.class); validEntityBeforeSave(add); boolean flag = baseMapper.insert(add) > 0; if (flag) { bo.setId(add.getId()); } return flag; } /** * 修改消息 */ @Override public Boolean updateByBo(MsgInfoBo bo) { MsgInfo update = BeanUtil.toBean(bo, MsgInfo.class); validEntityBeforeSave(update); return baseMapper.updateById(update) > 0; } /** * 保存前的数据校验 */ private void validEntityBeforeSave(MsgInfo entity){ //TODO 做一些数据校验,如唯一约束 } /** * 批量删除消息 */ @Override public Boolean deleteWithValidByIds(Collection<Long> ids, Boolean isValid) { if(isValid){ //TODO 做一些业务上的校验,判断是否需要校验 } return baseMapper.deleteBatchIds(ids) > 0; } }