package com.ycl.service.impl; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper; import com.ycl.common.utils.SecurityUtils; import com.ycl.domain.entity.ProjectInvestmentInfo; import com.ycl.domain.entity.ProjectUnitRegistrationInfo; import com.ycl.domain.vo.ProjectInvestmentInfoVO; import com.ycl.mapper.ProjectUnitRegistrationInfoMapper; import com.ycl.service.ProjectUnitRegistrationInfoService; import com.ycl.common.base.Result; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.ycl.domain.form.ProjectUnitRegistrationInfoForm; import com.ycl.domain.vo.ProjectUnitRegistrationInfoVO; import com.ycl.domain.query.ProjectUnitRegistrationInfoQuery; import org.springframework.stereotype.Service; import lombok.RequiredArgsConstructor; import com.ycl.framework.utils.PageUtil; import org.springframework.beans.BeanUtils; import org.springframework.util.Assert; import java.util.List; import java.util.stream.Collectors; /** * 项目(法人)单位登记信息表 服务实现类 * * @author lhr * @since 2024-11-22 */ @Service @RequiredArgsConstructor public class ProjectUnitRegistrationInfoServiceImpl extends ServiceImpl implements ProjectUnitRegistrationInfoService { private final ProjectUnitRegistrationInfoMapper projectUnitRegistrationInfoMapper; /** * 添加 * * @param form * @return */ @Override public Result add(ProjectUnitRegistrationInfoForm form) { ProjectUnitRegistrationInfo entity = ProjectUnitRegistrationInfoForm.getEntityByForm(form, null); Long userId = SecurityUtils.getUserId(); entity.setCreateBy(userId); entity.setUpdateBy(userId); baseMapper.insert(entity); //避免新增一个后重复新增返回id给前端判断 return Result.ok("添加成功").data(entity.getId()); } /** * 修改 * * @param form * @return */ @Override public Result update(ProjectUnitRegistrationInfoForm form) { ProjectUnitRegistrationInfo entity = baseMapper.selectById(form.getId()); // 为空抛IllegalArgumentException,做全局异常处理 Assert.notNull(entity, "记录不存在"); BeanUtils.copyProperties(form, entity); Long userId = SecurityUtils.getUserId(); entity.setUpdateBy(userId); baseMapper.updateById(entity); return Result.ok("修改成功"); } /** * 批量删除 * * @param ids * @return */ @Override public Result remove(List ids) { baseMapper.deleteBatchIds(ids); return Result.ok("删除成功"); } /** * id删除 * * @param id * @return */ @Override public Result removeById(String id) { baseMapper.deleteById(id); return Result.ok("删除成功"); } /** * 分页查询 * * @param query * @return */ @Override public Result page(ProjectUnitRegistrationInfoQuery query) { IPage page = PageUtil.getPage(query, ProjectUnitRegistrationInfoVO.class); baseMapper.getPage(page, query); return Result.ok().data(page.getRecords()).total(page.getTotal()); } /** * 根据id查找 * * @param id * @return */ @Override public Result detail(Integer id) { ProjectUnitRegistrationInfo entity = new LambdaQueryChainWrapper<>(baseMapper) .eq(ProjectUnitRegistrationInfo::getProjectId, id) .one(); ProjectUnitRegistrationInfoVO vo = new ProjectUnitRegistrationInfoVO(); if (entity != null) { vo = ProjectUnitRegistrationInfoVO.getVoByEntity(entity, null); } return Result.ok().data(vo); } /** * 列表 * * @return */ @Override public Result all() { List entities = baseMapper.selectList(null); List vos = entities.stream() .map(entity -> ProjectUnitRegistrationInfoVO.getVoByEntity(entity, null)) .collect(Collectors.toList()); return Result.ok().data(vos); } @Override public Result getUnitRegistrationInfoByName(String name) { List entity = new LambdaQueryChainWrapper<>(baseMapper) .like(ProjectUnitRegistrationInfo::getProjectUnit,name) .list(); return Result.ok().data(entity); } }