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 com.pz.system.domain.Notice; import com.pz.system.mapper.NoticeMapper; import lombok.RequiredArgsConstructor; import org.springframework.stereotype.Service; import com.pz.system.domain.bo.ServicesBo; import com.pz.system.domain.vo.ServicesVo; import com.pz.system.domain.Services; import com.pz.system.mapper.ServicesMapper; import com.pz.system.service.IServicesService; import java.util.List; import java.util.Map; import java.util.Collection; import java.util.Optional; /** * 服务Service业务层处理 * * @author ruoyi * @date 2023-09-07 */ @RequiredArgsConstructor @Service public class ServicesServiceImpl implements IServicesService { private final ServicesMapper baseMapper; private final NoticeMapper noticeMapper; /** * 查询服务 */ @Override public ServicesVo queryById(Integer id){ return baseMapper.selectVoById(id); } /** * 查询服务列表 */ @Override public TableDataInfo<ServicesVo> queryPageList(ServicesBo bo, PageQuery pageQuery) { LambdaQueryWrapper<Services> lqw = buildQueryWrapper(bo); Page<ServicesVo> result = baseMapper.selectVoPage(pageQuery.build(), lqw); Optional.ofNullable(result.getRecords()).ifPresent(records -> { List<Notice> notices = noticeMapper.selectList(); if(null != notices && notices.size() != 0){ records.get(0).setNotice(notices.get(0).getInfo()); } }); return TableDataInfo.build(result); } /** * 查询服务列表 */ @Override public List<ServicesVo> queryList(ServicesBo bo) { LambdaQueryWrapper<Services> lqw = buildQueryWrapper(bo); return baseMapper.selectVoList(lqw); } private LambdaQueryWrapper<Services> buildQueryWrapper(ServicesBo bo) { Map<String, Object> params = bo.getParams(); LambdaQueryWrapper<Services> lqw = Wrappers.lambdaQuery(); lqw.eq(bo.getBid() != null, Services::getBid, bo.getBid()); lqw.like(StringUtils.isNotBlank(bo.getName()), Services::getName, bo.getName()); lqw.eq(StringUtils.isNotBlank(bo.getCover()), Services::getCover, bo.getCover()); lqw.eq(StringUtils.isNotBlank(bo.getPrice()), Services::getPrice, bo.getPrice()); lqw.eq(bo.getFenmo() != null, Services::getFenmo, bo.getFenmo()); lqw.eq(bo.getDuration() != null, Services::getDuration, bo.getDuration()); lqw.eq(bo.getOvertime() != null, Services::getOvertime, bo.getOvertime()); lqw.eq(bo.getStartTime() != null, Services::getStartTime, bo.getStartTime()); lqw.eq(bo.getEndTime() != null, Services::getEndTime, bo.getEndTime()); lqw.eq(StringUtils.isNotBlank(bo.getInfo()), Services::getInfo, bo.getInfo()); return lqw; } /** * 新增服务 */ @Override public Boolean insertByBo(ServicesBo bo) { Services add = BeanUtil.toBean(bo, Services.class); validEntityBeforeSave(add); boolean flag = baseMapper.insert(add) > 0; if (flag) { bo.setId(add.getId()); } return flag; } /** * 修改服务 */ @Override public Boolean updateByBo(ServicesBo bo) { Services update = BeanUtil.toBean(bo, Services.class); validEntityBeforeSave(update); return baseMapper.updateById(update) > 0; } /** * 保存前的数据校验 */ private void validEntityBeforeSave(Services entity){ //TODO 做一些数据校验,如唯一约束 } /** * 批量删除服务 */ @Override public Boolean deleteWithValidByIds(Collection<Integer> ids, Boolean isValid) { if(isValid){ //TODO 做一些业务上的校验,判断是否需要校验 } return baseMapper.deleteBatchIds(ids) > 0; } }