package com.ruoyi.service.impl; import java.util.Arrays; import java.util.HashMap; import java.util.List; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.ruoyi.common.core.domain.AjaxResult; import com.ruoyi.common.utils.MapUtils; import com.ruoyi.common.utils.StringUtils; import com.ruoyi.domain.ArchiveRecords; import com.ruoyi.mapper.ArchiveRecordsMapper; import com.ruoyi.service.IArchiveRecordsService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; /** * 档案记录Service业务层处理 * * @author ruoyi * @date 2025-07-12 */ @Service public class ArchiveRecordsServiceImpl extends ServiceImpl implements IArchiveRecordsService { // @Autowired // private ArchiveRecordsMapper archiveRecordsMapper; private LambdaQueryWrapper buildCondition(ArchiveRecords archiveRecords){ LambdaQueryWrapper lqw = new LambdaQueryWrapper<>(); lqw.like(!StringUtils.isEmpty(archiveRecords.getProjectName()), ArchiveRecords::getProjectName, archiveRecords.getProjectName()) .like(!StringUtils.isEmpty(archiveRecords.getFilingNumber()), ArchiveRecords::getFilingNumber, archiveRecords.getFilingNumber()) .like(!StringUtils.isEmpty(archiveRecords.getArchiveRoomNumber()), ArchiveRecords::getArchiveRoomNumber, archiveRecords.getArchiveRoomNumber()) .like(!StringUtils.isEmpty(archiveRecords.getRecordId()), ArchiveRecords::getRecordId, archiveRecords.getRecordId()); // .like(!StringUtils.isEmpty(zfProperty.getLocation()), ZfProperty::getLocation, zfProperty.getLocation()) // .like(!StringUtils.isEmpty(zfProperty.getHolder()), ZfProperty::getHolder, zfProperty.getHolder()) // .like(!StringUtils.isEmpty(zfProperty.getAddress()), ZfProperty::getAddress, zfProperty.getAddress()) // .like(!StringUtils.isEmpty(zfProperty.getRemark()), ZfProperty::getRemark, zfProperty.getRemark()) // .eq(zfProperty.getFamilyId()!=null,ZfProperty::getFamilyId,zfProperty.getFamilyId()) // .in(ZfProperty::getFamilyId,familyIdList) // .eq(zfProperty.getHappenTime()!=null,ZfProperty::getHappenTime,zfProperty.getHappenTime()) // .between(zfProperty.getHappenStartTime() != null && zfProperty.getHappenEndTime() != null, ZfProperty::getHappenTime, zfProperty.getHappenStartTime(), zfProperty.getHappenEndTime()); // lqw.orderByDesc(ZfProperty::getCreateTime); System.out.println("ssssssssssssddd0000000000000000"); return lqw; } @Override public AjaxResult selectDataList(ArchiveRecords archiveRecords, Integer pageNum, Integer pageSize) { LambdaQueryWrapper lqw = buildCondition(archiveRecords); System.out.println("-------------"); System.out.println(pageNum); Page zfClanPage = new Page<>(pageNum, pageSize); Page pageResult = page(zfClanPage, lqw); List beanRecords = pageResult.getRecords();//得到查询出来的数据 // List beanRecords = list(lqw); // log.info("从数据库中查到的为:{}", beanRecords); // return markOwnData(familyId, fatherFaId, motherFaId, beanRecords); HashMap data = MapUtils.getResult(pageResult, beanRecords); // System.out.println(data.get("data")); // System.out.println(data.get("pageNum")); // System.out.println(data.get("total")); return AjaxResult.success(data); } /** * 查询档案记录 * * @param id 档案记录主键 * @return 档案记录 */ @Override public ArchiveRecords selectArchiveRecordsById(Long id) { System.out.println(id); System.out.println("-------------ssssssssssssssssss"); LambdaQueryWrapper lqw = new LambdaQueryWrapper<>(); lqw.eq(id!=null, ArchiveRecords::getId, id); List records = list(lqw); if(!records.isEmpty()) return records.get(0); else return null; } /** * 查询档案记录列表 * * @param archiveRecords 档案记录 * @return 档案记录 */ @Override public List selectArchiveRecordsList(ArchiveRecords archiveRecords) { LambdaQueryWrapper lambdaQueryWrapper = buildCondition(archiveRecords); List beanRecords = list(lambdaQueryWrapper); return beanRecords; } /** * 新增档案记录 * * @param archiveRecords 档案记录 * @return 结果 */ @Override public int insertArchiveRecords(ArchiveRecords archiveRecords) { boolean res = this.save(archiveRecords); if(res) return 1; else return 0; } /** * 修改档案记录 * * @param archiveRecords 档案记录 * @return 结果 */ @Override public int updateArchiveRecords(ArchiveRecords archiveRecords) { boolean result = updateById(archiveRecords); if(result) return 1; else return 0; } /** * 批量删除档案记录 * * @param ids 需要删除的档案记录主键 * @return 结果 */ @Override public int deleteArchiveRecordsByIds(Long[] ids) { if (this.removeByIds(Arrays.asList(ids))) { return 1; } else return 0; } /** * 删除档案记录信息 * * @param id 档案记录主键 * @return 结果 */ @Override public int deleteArchiveRecordsById(Long id) { return 0; } }