package org.dromara.qa.qm.service.impl; import org.dromara.common.core.utils.MapstructUtils; import org.dromara.common.core.utils.StringUtils; import org.dromara.common.mybatis.core.page.TableDataInfo; import org.dromara.common.mybatis.core.page.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 lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Service; import org.dromara.qa.qm.domain.bo.QmCheckitemBo; import org.dromara.qa.qm.domain.vo.QmCheckitemVo; import org.dromara.qa.qm.domain.QmCheckitem; import org.dromara.qa.qm.mapper.QmCheckitemMapper; import org.dromara.qa.qm.service.IQmCheckitemService; import java.util.ArrayList; import java.util.List; import java.util.Map; import java.util.Collection; import java.util.stream.Collectors; import java.util.HashMap; // 导入 HashMap /** * 规程检验项目Service业务层处理 * * @author zhuguifei * @date 2026-03-12 */ @Slf4j @RequiredArgsConstructor @Service public class QmCheckitemServiceImpl implements IQmCheckitemService { private final QmCheckitemMapper baseMapper; /** * 查询规程检验项目 * * @param id 主键 * @return 规程检验项目 */ @Override public QmCheckitemVo queryById(String id){ return baseMapper.selectVoById(id); } /** * 分页查询规程检验项目列表 * * @param bo 查询条件 * @param pageQuery 分页参数 * @return 规程检验项目分页列表 */ @Override public TableDataInfo queryPageList(QmCheckitemBo bo, PageQuery pageQuery) { LambdaQueryWrapper lqw = buildQueryWrapper(bo); Page result = baseMapper.selectVoPage(pageQuery.build(), lqw); return TableDataInfo.build(result); } /** * 查询符合条件的规程检验项目列表 * * @param bo 查询条件 * @return 规程检验项目列表 */ @Override public List queryList(QmCheckitemBo bo) { LambdaQueryWrapper lqw = buildQueryWrapper(bo); return baseMapper.selectVoList(lqw); } @Override public List queryTreeListByStdCode(String stdCode) { List roots = selectTreeNodes(stdCode, null); for (QmCheckitemVo root : roots) { List children = selectTreeNodes(stdCode, root.getId()); for (QmCheckitemVo child : children) { List grandchildren = selectTreeNodes(stdCode, child.getId()); child.setChildren(grandchildren); } root.setChildren(children); } return roots; } @Override public List> getRid(String stdCode) { // 修改返回类型 if (StringUtils.isBlank(stdCode)) { return new ArrayList<>(); } LambdaQueryWrapper lqw = Wrappers.lambdaQuery(); lqw.select(QmCheckitem::getId, QmCheckitem::getItemName); lqw.eq(QmCheckitem::getStdCode, stdCode); lqw.eq(QmCheckitem::getIsmix, 1L); lqw.eq(QmCheckitem::getEnable, 1L); lqw.ne(QmCheckitem::getDel, 1L); List list = baseMapper.selectList(lqw); return list.stream() .map(item -> { Map map = new HashMap<>(); map.put("value", item.getId()); map.put("label", item.getItemName()); return map; }) .collect(Collectors.toList()); } private List selectTreeNodes(String stdCode, String rid) { if (StringUtils.isBlank(stdCode)) { return new ArrayList<>(); } LambdaQueryWrapper lqw = Wrappers.lambdaQuery(); lqw.eq(QmCheckitem::getStdCode, stdCode); lqw.ne(QmCheckitem::getDel, 1L); if (rid == null) { lqw.isNull(QmCheckitem::getRid); } else { lqw.eq(QmCheckitem::getRid, rid); } lqw.orderByAsc(QmCheckitem::getId); return baseMapper.selectVoList(lqw); } private LambdaQueryWrapper buildQueryWrapper(QmCheckitemBo bo) { Map params = bo.getParams(); LambdaQueryWrapper lqw = Wrappers.lambdaQuery(); lqw.orderByAsc(QmCheckitem::getId); lqw.like(StringUtils.isNotBlank(bo.getItemCode()), QmCheckitem::getItemCode, bo.getItemCode()); lqw.like(StringUtils.isNotBlank(bo.getItemName()), QmCheckitem::getItemName, bo.getItemName()); return lqw; } /** * 新增规程检验项目 * * @param bo 规程检验项目 * @return 是否新增成功 */ @Override public Boolean insertByBo(QmCheckitemBo bo) { QmCheckitem add = MapstructUtils.convert(bo, QmCheckitem.class); validEntityBeforeSave(add); boolean flag = baseMapper.insert(add) > 0; if (flag) { bo.setId(add.getId()); } return flag; } /** * 修改规程检验项目 * * @param bo 规程检验项目 * @return 是否修改成功 */ @Override public Boolean updateByBo(QmCheckitemBo bo) { QmCheckitem update = MapstructUtils.convert(bo, QmCheckitem.class); validEntityBeforeSave(update); return baseMapper.updateById(update) > 0; } /** * 保存前的数据校验 */ private void validEntityBeforeSave(QmCheckitem entity){ //TODO 做一些数据校验,如唯一约束 } /** * 校验并批量删除规程检验项目信息 * * @param ids 待删除的主键集合 * @param isValid 是否进行有效性校验 * @return 是否删除成功 */ @Override public Boolean deleteWithValidByIds(Collection ids, Boolean isValid) { if(isValid){ //TODO 做一些业务上的校验,判断是否需要校验 } return baseMapper.deleteByIds(ids) > 0; } }