| | |
| | | package com.ycl.service.impl; |
| | | |
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
| | | import com.baomidou.mybatisplus.core.metadata.IPage; |
| | | import com.ycl.common.enums.business.FileTypeEnum; |
| | | import com.ycl.common.utils.SecurityUtils; |
| | | import com.ycl.domain.entity.File; |
| | | import com.ycl.domain.entity.ProjectInvestmentPolicyCompliance; |
| | | import com.ycl.domain.entity.ProjectUnitRegistrationInfo; |
| | | import com.ycl.domain.vo.ProjectUnitRegistrationInfoVO; |
| | | import com.ycl.mapper.FileMapper; |
| | | import com.ycl.mapper.ProjectInvestmentPolicyComplianceMapper; |
| | | import com.ycl.service.FileService; |
| | | import com.ycl.service.ProjectInvestmentPolicyComplianceService; |
| | | import com.ycl.common.base.Result; |
| | | import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
| | |
| | | import lombok.RequiredArgsConstructor; |
| | | import com.ycl.framework.utils.PageUtil; |
| | | import org.springframework.beans.BeanUtils; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | | import org.springframework.util.Assert; |
| | | |
| | | import java.util.List; |
| | |
| | | public class ProjectInvestmentPolicyComplianceServiceImpl extends ServiceImpl<ProjectInvestmentPolicyComplianceMapper, ProjectInvestmentPolicyCompliance> implements ProjectInvestmentPolicyComplianceService { |
| | | |
| | | private final ProjectInvestmentPolicyComplianceMapper projectInvestmentPolicyComplianceMapper; |
| | | |
| | | private final FileService fileService; |
| | | private final FileMapper fileMapper; |
| | | /** |
| | | * 添加 |
| | | * @param form |
| | | * @return |
| | | */ |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public Result add(ProjectInvestmentPolicyComplianceForm form) { |
| | | ProjectInvestmentPolicyCompliance entity = ProjectInvestmentPolicyComplianceForm.getEntityByForm(form, null); |
| | | Long userId = SecurityUtils.getUserId(); |
| | | entity.setCreateBy(userId); |
| | | entity.setUpdateBy(userId); |
| | | baseMapper.insert(entity); |
| | | return Result.ok("添加成功"); |
| | | //添加文件 |
| | | List<File> fileList = form.getFileList(); |
| | | fileList.forEach(item->{ |
| | | item.setBusId(entity.getId()); |
| | | item.setType(FileTypeEnum.INVEST_POLICY); |
| | | }); |
| | | fileService.saveBatch(fileList); |
| | | //避免新增一个后重复新增返回id给前端判断 |
| | | return Result.ok("添加成功").data(entity.getId()); |
| | | } |
| | | |
| | | /** |
| | |
| | | @Override |
| | | public Result update(ProjectInvestmentPolicyComplianceForm form) { |
| | | ProjectInvestmentPolicyCompliance entity = baseMapper.selectById(form.getId()); |
| | | |
| | | // 为空抛IllegalArgumentException,做全局异常处理 |
| | | Assert.notNull(entity, "记录不存在"); |
| | | BeanUtils.copyProperties(form, entity); |
| | | Long userId = SecurityUtils.getUserId(); |
| | | entity.setUpdateBy(userId); |
| | | baseMapper.updateById(entity); |
| | | List<File> fileList = form.getFileList(); |
| | | fileList.forEach(item->{ |
| | | item.setBusId(entity.getId()); |
| | | item.setType(FileTypeEnum.INVEST_POLICY); |
| | | }); |
| | | //删除原有文件 |
| | | QueryWrapper<File> fileQueryWrapper = new QueryWrapper<>(); |
| | | fileQueryWrapper.eq("type",FileTypeEnum.INVEST_POLICY.getType()); |
| | | fileQueryWrapper.eq("bus_id",entity.getId()); |
| | | fileMapper.delete(fileQueryWrapper); |
| | | //替换成现有 |
| | | fileService.saveBatch(fileList); |
| | | return Result.ok("修改成功"); |
| | | } |
| | | |
| | |
| | | */ |
| | | @Override |
| | | public Result detail(Integer id) { |
| | | ProjectInvestmentPolicyComplianceVO vo = baseMapper.getById(id); |
| | | Assert.notNull(vo, "记录不存在"); |
| | | QueryWrapper<ProjectInvestmentPolicyCompliance> queryWrapper = new QueryWrapper<>(); |
| | | queryWrapper.eq("project_id", id); |
| | | ProjectInvestmentPolicyCompliance entity = baseMapper.selectOne(queryWrapper); |
| | | ProjectInvestmentPolicyComplianceVO vo = new ProjectInvestmentPolicyComplianceVO(); |
| | | if (entity != null) { |
| | | vo = ProjectInvestmentPolicyComplianceVO.getVoByEntity(entity, null); |
| | | QueryWrapper<File> fileQueryWrapper = new QueryWrapper<>(); |
| | | fileQueryWrapper.eq("type",FileTypeEnum.INVEST_POLICY.getType()); |
| | | fileQueryWrapper.eq("bus_id",vo.getId()); |
| | | List<File> files = fileMapper.selectList(fileQueryWrapper); |
| | | vo.setFileList(files); |
| | | } |
| | | return Result.ok().data(vo); |
| | | } |
| | | |