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

import com.gkhy.labRiskManage.api.controller.riskReport.dto.respDto.ReportSourceTypeQueryRespDTO;
import com.gkhy.labRiskManage.application.riskReport.dto.bo.ReportSourceTypeAppInsertBO;
import com.gkhy.labRiskManage.application.riskReport.dto.bo.ReportSourceTypeAppUpdateBO;
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.basic.model.dto.RiskSourceTypeDTO;
import com.gkhy.labRiskManage.domain.basic.service.BasicExperimentRiskSourceTypeService;
import com.gkhy.labRiskManage.domain.riskReport.entity.ReportExperimentRiskSourceType;
import com.gkhy.labRiskManage.domain.riskReport.model.bo.ReportSourceTypeInsertBO;
import com.gkhy.labRiskManage.domain.riskReport.model.bo.ReportSourceTypeUpdateBO;
import com.gkhy.labRiskManage.domain.riskReport.model.dto.ReportPersonInsertDTO;
import com.gkhy.labRiskManage.domain.riskReport.model.dto.ReportSourceTypeInsertDTO;
import com.gkhy.labRiskManage.domain.riskReport.model.dto.ReportSourceTypeQueryDTO;
import com.gkhy.labRiskManage.domain.riskReport.repository.jpa.ReportExperimentRiskSourceTypeRepository;
import com.gkhy.labRiskManage.domain.riskReport.service.ReportExperimentRiskSourceTypeService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.ObjectUtils;

import java.time.LocalDateTime;
import java.util.ArrayList;
import java.util.List;


/**
 * 风险评估报告-实验可能有的危险源或危险因素类型
 */
@Service
public class ReportExperimentRiskSourceTypeServiceImpl implements ReportExperimentRiskSourceTypeService {

    @Autowired
    private ReportExperimentRiskSourceTypeRepository sourceTypeRepository;
    @Autowired
    private BasicExperimentRiskSourceTypeService basicTypeService;
    /**
     * 危险因素类型 - 插入
     */
    @Override
    public List<ReportSourceTypeInsertDTO> insertReportSourceType(Long currentUserId, List<ReportSourceTypeAppInsertBO> reportSourceTypeInsertBO) {

        if (reportSourceTypeInsertBO.size() != 8){
            throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "危险源类型不符合标准，请重新填写");
        }

        List<ReportSourceTypeInsertBO> typeInsertBO = BeanCopyUtils.copyBeanList(reportSourceTypeInsertBO, ReportSourceTypeInsertBO.class);

        List<ReportExperimentRiskSourceType> sourceTypeLists = new ArrayList<>();

        for (ReportSourceTypeInsertBO sourceTypeInsertBO : typeInsertBO) {
            if (ObjectUtils.isEmpty(sourceTypeInsertBO.getReportId())){
                throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "报告id不能为空");
            }
            if (ObjectUtils.isEmpty(sourceTypeInsertBO.getRiskSourceTypeId())){
                throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "危险类型不能为空");
            }
            RiskSourceTypeDTO typeById = basicTypeService.getTypeById(sourceTypeInsertBO.getReportId());
            if (ObjectUtils.isEmpty(typeById )){
                throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR.getCode(), "危险类型不存在");
            }
            if (ObjectUtils.isEmpty(sourceTypeInsertBO.getStatus())){
                throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "危险类型,不能为空");
            }

            ReportExperimentRiskSourceType sourceType = BeanCopyUtils.copyBean(sourceTypeInsertBO, ReportExperimentRiskSourceType.class);
            //补全数据
            LocalDateTime date = LocalDateTime.now();

            sourceType.setReportId(sourceTypeInsertBO.getReportId());
            sourceType.setRiskSourceType(typeById.getRiskSourceType());
            sourceType.setCreateTime(date);
            sourceType.setUpdateTime(date);
            sourceType.setCreateByUserId(currentUserId);
            sourceType.setUpdateByUserId(currentUserId);
            sourceType.setDeleteStatus(StatusEnum.DELETE_NOT.getCode().byteValue());

            sourceTypeLists.add(sourceType);
        }

        List<ReportExperimentRiskSourceType> insertResult = sourceTypeRepository.saveAll(sourceTypeLists);
        if (insertResult.size() != typeInsertBO.size()){
            throw new BusinessException(this.getClass(), ResultCode.BUSINESS_ERROR.getCode(), "风险源类型写入失败");
        }

        return BeanCopyUtils.copyBeanList(insertResult, ReportSourceTypeInsertDTO.class);
    }

    /**
     * 危险因素类型 - 修改
     */
    @Override
    public List<ReportSourceTypeInsertDTO> updateReportSourceType(Long currentUserId, List<ReportSourceTypeAppUpdateBO> reportSourceTypeAppUpdateBO) {

        if (reportSourceTypeAppUpdateBO.size() != 8){
            throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "危险源类型不符合标准，请重新填写");
        }

        List<ReportSourceTypeUpdateBO> typeUpdateBO = BeanCopyUtils.copyBeanList(reportSourceTypeAppUpdateBO, ReportSourceTypeUpdateBO.class);

        List<ReportExperimentRiskSourceType> sourceTypeLists = new ArrayList<>();

        for (ReportSourceTypeUpdateBO updateBO : typeUpdateBO) {
            if (ObjectUtils.isEmpty(updateBO.getId())){
                throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "危险类型id不能为空");
            }
            if (ObjectUtils.isEmpty(updateBO.getReportId())){
                throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "报告id不能为空");
            }
            if (ObjectUtils.isEmpty(updateBO.getRiskSourceTypeId())){
                throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "危险类型不能为空");
            }
            RiskSourceTypeDTO typeById = basicTypeService.getTypeById(updateBO.getReportId());
            if (ObjectUtils.isEmpty(typeById )){
                throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR.getCode(), "危险类型不存在");
            }
            if (ObjectUtils.isEmpty(updateBO.getStatus())){
                throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "危险类型是否存在不能为空");
            }
            ReportExperimentRiskSourceType type = sourceTypeRepository.getTypeById(updateBO.getId());

            ReportExperimentRiskSourceType sourceType = BeanCopyUtils.copyBean(type, ReportExperimentRiskSourceType.class);
            //补全数据
            LocalDateTime date = LocalDateTime.now();

            sourceType.setRiskSourceType(typeById.getRiskSourceType());
            sourceType.setUpdateTime(date);
            sourceType.setUpdateByUserId(currentUserId);

            sourceTypeLists.add(sourceType);
        }

        List<ReportExperimentRiskSourceType> updateResult = sourceTypeRepository.saveAll(sourceTypeLists);
        if (updateResult.size() != reportSourceTypeAppUpdateBO.size()){
            throw new BusinessException(this.getClass(), ResultCode.BUSINESS_ERROR.getCode(), "风险源类型写入失败");
        }

        return BeanCopyUtils.copyBeanList(updateResult, ReportSourceTypeInsertDTO.class);
    }

    /**
     * 危险因素类型 - 查询 by 报告id
     */
    @Override
    public List<ReportSourceTypeQueryRespDTO> getSourceTypeByReportId(Long id) {

        List<ReportExperimentRiskSourceType> sourceTypeByReportId = sourceTypeRepository.getSourceTypeByReportId(id);

        if (ObjectUtils.isEmpty(sourceTypeByReportId)){
            return  null;
        }

        return BeanCopyUtils.copyBeanList(sourceTypeByReportId, ReportSourceTypeQueryRespDTO.class);
    }

    @Override
    public List<ReportExperimentRiskSourceType>  insertAllReportSource(List<ReportExperimentRiskSourceType> riskSourceTypeList) {

        List<ReportExperimentRiskSourceType> sourceTypes = sourceTypeRepository.saveAll(riskSourceTypeList);
        return sourceTypes;
    }
}