PAS/src/main/java/cn/cslg/pas/service/business/OralTrailService.java

package cn.cslg.pas.service.business;

import cn.cslg.pas.common.dto.business.ReportAffairDTO;
import cn.cslg.pas.common.dto.invalidDTO.AddOralTrailDTO;
import cn.cslg.pas.common.dto.invalidDTO.UpdateOralTrailDTO;
import cn.cslg.pas.common.vo.invalidVO.InvalidRequestFileVO;
import cn.cslg.pas.common.vo.invalidVO.OralTrailVO;
import cn.cslg.pas.domain.business.AssoReportAffairFile;
import cn.cslg.pas.domain.business.InvalidRequestFile;
import cn.cslg.pas.domain.business.OralTrail;
import cn.cslg.pas.domain.business.ReportAffair;
import cn.cslg.pas.exception.XiaoShiException;
import cn.cslg.pas.mapper.OralTrailMapper;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Lazy;
import org.springframework.stereotype.Service;
import org.springframework.web.bind.annotation.RequestBody;

import java.util.ArrayList;
import java.util.List;

/**
 * 口审记录Service
 * @Author xiexiang
 * @Date 2023/12/28
 */
@Slf4j
@Service
public class OralTrailService extends ServiceImpl<OralTrailMapper, OralTrail> {
    @Autowired
    private ReportAffairService reportAffairService;

    @Autowired
    private AssoReportAffairFileService assoReportAffairFileService;

    public Integer add(AddOralTrailDTO addOralTrailDTO){
        if (addOralTrailDTO == null) {
            throw new XiaoShiException("入参为空");
        }
        Integer projectId = addOralTrailDTO.getProjectId();
        if (projectId == null) {
            throw new XiaoShiException("报告id为空");
        }
        //1. 首先上传报告事务,拿到报告事务id
        ReportAffairDTO reportAffairDTO = new ReportAffairDTO();
        reportAffairDTO.setProjectId(projectId);
        //口审记录 0
        reportAffairDTO.setAffairType(0);
        //发生时间是口审时间
        reportAffairDTO.setOccurredTime(addOralTrailDTO.getOralTrailTime());
        //备注
        reportAffairDTO.setDescription(addOralTrailDTO.getRemark());
        Integer reportAffairId = reportAffairService.addReportAffair(reportAffairDTO);

        if (reportAffairId == null) {
            throw new XiaoShiException("上传报告事务失败");
        }
        //2. 上传口审记录
        OralTrail oralTrail = new OralTrail();
        oralTrail.setParticipator(addOralTrailDTO.getParticipator());
        oralTrail.setPosition(addOralTrailDTO.getPosition());
        oralTrail.setDescription(addOralTrailDTO.getDescription());
        oralTrail.setReportAffairId(reportAffairId);
        oralTrail.insert();
        //3. 添加报告事务与文件关联
        List<String> fileGuids = addOralTrailDTO.getFileGuids();
        if (fileGuids != null && !fileGuids.isEmpty()) {
            List<AssoReportAffairFile> assoReportAffairFiles = new ArrayList<>();
            fileGuids.forEach(item -> {
                AssoReportAffairFile assoReportAffairFile = new AssoReportAffairFile();
                assoReportAffairFile.setReportAffairId(reportAffairId);
                assoReportAffairFile.setFileGuid(item);
                assoReportAffairFiles.add(assoReportAffairFile);
            });
            assoReportAffairFileService.saveBatch(assoReportAffairFiles);
        }
        return reportAffairId;
    }

    public OralTrailVO getOralTrailVO(Integer reportAffairId) {
        LambdaQueryWrapper<OralTrail> queryWrapper = new LambdaQueryWrapper<>();
        queryWrapper.eq(OralTrail::getReportAffairId, reportAffairId);
        OralTrail oralTrail = this.getOne(queryWrapper, false);
        OralTrailVO oralTrailVO = new OralTrailVO();
        if (oralTrail != null) {
            BeanUtils.copyProperties(oralTrail, oralTrailVO);
            oralTrailVO.setOralTrailId(oralTrail.getId());
        }
        ReportAffair reportAffair = reportAffairService.getById(reportAffairId);
        oralTrailVO.setOralTrailTime(reportAffair.getOccurredTime());
        return oralTrailVO;
    }

    /**
     * 更新口审记录
     * @param updateOralTrailDTO
     * @return
     */
    public Integer update(UpdateOralTrailDTO updateOralTrailDTO){
        if (updateOralTrailDTO == null) {
            throw new XiaoShiException("入参为空");
        }
        Integer projectId = updateOralTrailDTO.getProjectId();
        Integer id = updateOralTrailDTO.getOralTrailId();
        if (id == null) {
            throw new XiaoShiException("id为空");
        }
        if (projectId == null) {
            throw new XiaoShiException("报告id为空");
        }
        //1. 根据id查出口审记录
        OralTrail oralTrail = this.getById(id);
        if (oralTrail == null) {
            throw new XiaoShiException("oralTrail查询错误");
        }
        BeanUtils.copyProperties(updateOralTrailDTO, oralTrail);
        oralTrail.updateById();
        Integer reportAffairId = oralTrail.getReportAffairId();
        //2. 拿到报告事务id，获取报告事务
        ReportAffair reportAffair = reportAffairService.getById(reportAffairId);
        reportAffair.setProjectId(projectId);
        //发生时间是无效请求日
        reportAffair.setOccurredTime(updateOralTrailDTO.getOralTrailTime());
        //备注
        reportAffair.setDescription(updateOralTrailDTO.getRemark());
        reportAffair.updateById();
        //3. 更新报告事务与文件关联
        List<String> fileGuids = updateOralTrailDTO.getFileGuids();
        if (fileGuids != null && !fileGuids.isEmpty()) {
            LambdaQueryWrapper<AssoReportAffairFile> queryWrapper = new LambdaQueryWrapper<>();
            queryWrapper.eq(AssoReportAffairFile::getReportAffairId, reportAffairId);
            assoReportAffairFileService.remove(queryWrapper);

            List<AssoReportAffairFile> assoReportAffairFiles = new ArrayList<>();
            fileGuids.forEach(item -> {
                AssoReportAffairFile assoReportAffairFile = new AssoReportAffairFile();
                assoReportAffairFile.setReportAffairId(reportAffairId);
                assoReportAffairFile.setFileGuid(item);
                assoReportAffairFiles.add(assoReportAffairFile);
            });
            assoReportAffairFileService.saveBatch(assoReportAffairFiles);
        }
        return reportAffairId;
    }
}