package com.ruoyi.basic.service.impl; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.ruoyi.basic.dto.CoalQualityDto; import com.ruoyi.basic.entity.CoalQuality; import com.ruoyi.basic.mapper.CoalQualityMapper; import com.ruoyi.basic.service.CoalQualityService; import com.ruoyi.common.utils.bean.BeanUtils; import lombok.RequiredArgsConstructor; import org.springframework.stereotype.Service; import java.util.Objects; /** *

* 煤质信息表,记录煤炭质量检测相关数据 服务实现类 *

* * @author ruoyi * @since 2025-06-03 */ @Service @RequiredArgsConstructor public class CoalQualityServiceImpl extends ServiceImpl implements CoalQualityService { private final CoalQualityMapper coalQualityMapper; @Override public IPage selectCoalQualityList(Page page, CoalQualityDto coalQualityDto) { LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); queryWrapper.orderByDesc(CoalQuality::getCreateTime); return coalQualityMapper.selectPage(page, queryWrapper); } @Override public int addOrEditCoalQuality(CoalQualityDto coalQualityDto) { CoalQuality coalQuality = new CoalQuality(); BeanUtils.copyProperties(coalQualityDto, coalQuality); if (Objects.isNull(coalQualityDto.getId())) { return coalQualityMapper.insert(coalQuality); } else { return coalQualityMapper.updateById(coalQuality); } } @Override public int delCoalQualityByIds(Long[] ids) { // 检查参数 if (ids == null || ids.length == 0) { return 0; } // 构造更新条件 UpdateWrapper updateWrapper = new UpdateWrapper<>(); updateWrapper.in("id", ids) .set("deleted", 1); // 设置 deleted 为 1 表示已删除 // 执行批量逻辑删除 return coalQualityMapper.update(null, updateWrapper); } }