package com.gkhy.labRiskManage.application.riskReport.service.impl;

import com.gkhy.labRiskManage.api.controller.riskReport.dto.repDto.ReportInfoUpdateReqBO;
import com.gkhy.labRiskManage.api.controller.riskReport.dto.repDto.ReportQueryReqBO;
import com.gkhy.labRiskManage.api.controller.riskReport.dto.repDto.ReportReqBO;
import com.gkhy.labRiskManage.api.controller.riskReport.dto.repDto.ReportUpdateReqBO;
import com.gkhy.labRiskManage.api.controller.riskReport.dto.respDto.ReportQueryRespDTO;
import com.gkhy.labRiskManage.application.riskReport.dto.bo.*;
import com.gkhy.labRiskManage.application.riskReport.dto.dto.ReportAppQueryDTO;
import com.gkhy.labRiskManage.application.riskReport.dto.dto.RiskAssessPlanAppQueryDTO;
import com.gkhy.labRiskManage.application.riskReport.service.ReportAppService;
import com.gkhy.labRiskManage.commons.domain.SearchResult;
import com.gkhy.labRiskManage.commons.enums.ResultCode;
import com.gkhy.labRiskManage.commons.enums.StatusEnum;
import com.gkhy.labRiskManage.commons.exception.BusinessException;
import com.gkhy.labRiskManage.commons.utils.BeanCopyUtils;
import com.gkhy.labRiskManage.domain.account.service.UserDomainService;
import com.gkhy.labRiskManage.domain.experiment.service.ExperimentInfoService;
import com.gkhy.labRiskManage.domain.riskReport.model.dto.*;
import com.gkhy.labRiskManage.domain.riskReport.service.ReportExperimentRiskSourceService;
import com.gkhy.labRiskManage.domain.riskReport.service.ReportExperimentRiskSourceTypeService;
import com.gkhy.labRiskManage.domain.riskReport.service.ReportRiskAssessInfoService;
import com.gkhy.labRiskManage.domain.riskReport.service.ReportRiskAssessPersonService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.ObjectUtils;

import java.util.List;

@Service
public class ReportAppServiceImpl implements ReportAppService {

    @Autowired
    private ReportRiskAssessInfoService reportInfoService;
    @Autowired
    private ReportRiskAssessPersonService reportPersonService;
    @Autowired
    private ReportExperimentRiskSourceTypeService reportSourceTypeService;
    @Autowired
    private ReportExperimentRiskSourceService reportSourceService;
    @Autowired
    private UserDomainService userDomainService;
    @Autowired
    private ExperimentInfoService experimentInfoService;


    /**
     * 风险评估报告 - 查询
     */
    @Override
    public SearchResult<ReportQueryRespDTO> selectRiskReportPage(Long currentUserId, ReportQueryReqBO queryReqBO) {

        SearchResult searchResult = new SearchResult<>();

        ReportAppQueryBO queryParam = BeanCopyUtils.copyBean(queryReqBO, ReportAppQueryBO.class);

        SearchResult<ReportAppQueryDTO> queryResult = reportInfoService.selectRiskReportPage(currentUserId, queryParam);

        searchResult.setPageIndex(queryResult.getPageIndex());
        searchResult.setPageSize(queryResult.getPageSize());
        searchResult.setTotal(queryResult.getTotal());
        searchResult.setData(BeanCopyUtils.copyRiskAssessPlanAppQueryList(queryResult.getData(), RiskAssessPlanAppQueryDTO.class));

        return searchResult;
    }

    /**
     * 风险评估报告 - 生成报告信息
     */
    @Override
    public int insertRiskReport(Long currentUserId, Long id) {

        ReportInsertDTO insertResult = reportInfoService.insertRiskReport(currentUserId, id);

        if (ObjectUtils.isEmpty(insertResult)){
            return StatusEnum.FAIL.getCode();
        }
        return StatusEnum.SUCCESS.getCode();
    }

    /**
     * 风险评估报告 - 填写信息
     */
    @Transactional
    @Override
    public int updateRiskReport(Long currentUserId, ReportUpdateReqBO updateReqBO) {

        int i = 0;
        //报告信息
        ReportAppUpdateBO reportUpdateBO = BeanCopyUtils.copyBean(updateReqBO, ReportAppUpdateBO.class);
        ReportUpdateDTO reportUpdateDTO = reportInfoService.updateReportInfoById(currentUserId,reportUpdateBO);
        if (ObjectUtils.isEmpty(reportUpdateDTO)){
            i = 1;
        }
//
//        //审核人信息
//        if (!ObjectUtils.isEmpty(updateReqBO.getPerson())){
//            List<ReportPersonAppInsertBO> personInsertBO = BeanCopyUtils.copyBeanList(updateReqBO.getPerson(), ReportPersonAppInsertBO.class);
//            List<ReportPersonInsertDTO> reportPersonInsertDTOS = reportPersonService.insertReportPerson(currentUserId,personInsertBO);
//            if (reportPersonInsertDTOS.size() != personInsertBO.size()){
//                i = 1;
//            }
//        }
//
//        //危险源类型信息
//        if (!ObjectUtils.isEmpty(updateReqBO.getRiskSourceType())){
//            List<ReportSourceTypeAppInsertBO> reportSourceTypeInsertBO = BeanCopyUtils.copyBeanList(updateReqBO.getRiskSourceType(), ReportSourceTypeAppInsertBO.class);
//            List<ReportSourceTypeInsertDTO> reportSourceTypeInsertDTOS = reportSourceTypeService.insertReportSourceType(currentUserId,reportSourceTypeInsertBO);
//            if (reportSourceTypeInsertDTOS.size() != reportSourceTypeInsertBO.size()){
//                i = 1;
//            }
//        }
//
        //危险源信
        if (!ObjectUtils.isEmpty(updateReqBO.getRiskSource())){
            List<ReportSourceAppInsertBO> riskSourceInsertBO = BeanCopyUtils.copyBeanList(updateReqBO.getRiskSource(), ReportSourceAppInsertBO.class);
            List<ReportRiskSourceDTO> reportRiskSourceDTOS = reportSourceService.insertReportSource(currentUserId,riskSourceInsertBO);
            if (reportRiskSourceDTOS.size() != riskSourceInsertBO.size()){
                i = 1;
            }
        }

        if (ObjectUtils.isEmpty(reportUpdateDTO)){
            throw new BusinessException(this.getClass(), ResultCode.BUSINESS_ERROR.getCode(), "风险评估报告写入失败");
        }
        return StatusEnum.SUCCESS.getCode();
    }

    /**
     * 风险评估报告 - 修改报告信息
     */
    @Transactional
    @Override
    public int updateReportInfo(Long currentUserId, ReportInfoUpdateReqBO updateReqBO) {

        int i = 0;
        //报告信息
        ReportAppUpdateBO reportUpdateBO = BeanCopyUtils.copyBean(updateReqBO, ReportAppUpdateBO.class);
        ReportUpdateDTO reportUpdateDTO = reportInfoService.updateReportInfoById(currentUserId,reportUpdateBO);
        if (ObjectUtils.isEmpty(reportUpdateDTO)){
            i = 1;
        }

        //审核人信息
//        if (!ObjectUtils.isEmpty(updateReqBO.getPerson())){
//            List<ReportPersonAppUpdateBO> personUpdateBO = BeanCopyUtils.copyBeanList(updateReqBO.getPerson(), ReportPersonAppUpdateBO.class);
//            List<ReportPersonInsertDTO> reportPersonUpdateDTOS = reportPersonService.updateReportPerson(currentUserId, personUpdateBO);
//            if (reportPersonUpdateDTOS.size() != personUpdateBO.size()){
//                i = 1;
//            }
//        }

        //危险源类型信息
//        if (!ObjectUtils.isEmpty(updateReqBO.getRiskSourceType())){
//            List<ReportSourceTypeAppUpdateBO> reportSourceTypeUpdateBO = BeanCopyUtils.copyBeanList(updateReqBO.getRiskSourceType(), ReportSourceTypeAppUpdateBO.class);
//            List<ReportSourceTypeInsertDTO> reportSourceTypeUpdateDTOS = reportSourceTypeService.updateReportSourceType(currentUserId, reportSourceTypeUpdateBO);
//            if (reportSourceTypeUpdateDTOS.size() != reportSourceTypeUpdateBO.size()){
//                i = 1;
//            }
//        }

//        if (!ObjectUtils.isEmpty(updateReqBO.getRiskSource())){
//            //危险源信息
//            List<ReportSourceAppUpdateBO> riskSourceUpdateBO = BeanCopyUtils.copyBeanList(updateReqBO.getRiskSource(), ReportSourceAppUpdateBO.class);
//            List<ReportRiskSourceDTO> reportRiskSourceUpdateDTOS = reportSourceService.updateReportSource(currentUserId, riskSourceUpdateBO);
//            if (reportRiskSourceUpdateDTOS.size() != riskSourceUpdateBO.size()){
//                i = 1;
//            }
//        }

        if (i == 1){
            throw new BusinessException(this.getClass(), ResultCode.BUSINESS_ERROR.getCode(), "风险评估报告修改失败");
        }
        return StatusEnum.SUCCESS.getCode();
    }

    /**
     * 风险评估报告 - 报告审核 - 旧 - 两层审核
     */
    @Override
    public int report(Long currentUserId, ReportReqBO reportReqBO) {

        int report = reportInfoService.report(currentUserId, reportReqBO);

        if (report == 0){
            return StatusEnum.FAIL.getCode();
        }
        return StatusEnum.SUCCESS.getCode();
    }

    /**
     * 风险评估报告 - 报告审核 - 新 - 单次审核
     */
    @Override
    public int reportNew(Long currentUserId, ReportReqBO reportReqBO) {

        int report = reportInfoService.reportNew(currentUserId, reportReqBO);

        if (report == 0){
            return StatusEnum.FAIL.getCode();
        }
        return StatusEnum.SUCCESS.getCode();
    }
}