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


import com.gkhy.labRiskManage.api.controller.basic.dto.repDto.*;
import com.gkhy.labRiskManage.api.controller.basic.dto.respDto.BasicRiskSourceTypeListRespDTO;
import com.gkhy.labRiskManage.application.basic.dto.bo.*;
import com.gkhy.labRiskManage.application.basic.dto.dto.*;
import com.gkhy.labRiskManage.application.basic.service.BasicAppService;
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.basic.entity.BasicExperimentSite;
import com.gkhy.labRiskManage.domain.basic.entity.BasicExperimentStuff;
import com.gkhy.labRiskManage.domain.basic.model.dto.*;
import com.gkhy.labRiskManage.domain.basic.service.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.ObjectUtils;

import java.util.List;


@Service
public class BasicAppServiceImpl implements BasicAppService {

    @Autowired
    private BasicExperimentDeviceService basicExperimentDeviceService;
    @Autowired
    private BasicExperimentPersonService basicExperimentPersonService;
    @Autowired
    private BasicExperimentSiteService basicExperimentSiteService;
    @Autowired
    private BasicExperimentStuffService basicExperimentStuffService;
    @Autowired
    private BasicExperimentTypeService basicExperimentTypeService;
    @Autowired
    private BasicRiskUnitService basicRiskUnitService;
    @Autowired
    private BasicExperimentRiskSourceTypeService basicRiskSourceTypeService;
    @Autowired
    private UserDomainService userDomainService;

    /**
     * 基础仪器设备表 - 新增
     * */
    @Override
    public int insertBasicExperimentDevice(Long currentUserId, BasicExperimentDeviceInsertReqBO basicDeviceReqDTO) {

        BasicExperimentDeviceAppInsertBO basicExperimentDeviceAppInsertBO = BeanCopyUtils.copyBean(basicDeviceReqDTO, BasicExperimentDeviceAppInsertBO.class);

        DeviceInsertDTO deviceInsertDTO = basicExperimentDeviceService.insertBasicExperimentDevice(currentUserId, basicExperimentDeviceAppInsertBO);
        if (ObjectUtils.isEmpty(deviceInsertDTO)){
            return StatusEnum.FAIL.getCode();
        }
        return StatusEnum.SUCCESS.getCode();
    }

    /**
     * 基础仪器设备表 - 分页查询
     * */
    @Override
    public SearchResult<BasicExperimentDeviceAppQueryDTO> getBasicExperimentDevicePage(Long currentUserId, BasicExperimentDeviceQueryReqBO queryReqDTO) {

        SearchResult searchResult = new SearchResult<>();

        BasicExperimentDeviceAppQueryBO queryParam = BeanCopyUtils.copyBean(queryReqDTO, BasicExperimentDeviceAppQueryBO.class);
        SearchResult<DeviceQueryDTO> queryAppDeviceDTO = basicExperimentDeviceService.getBasicExperimentDevicePage(currentUserId, queryParam);

        Object data = queryAppDeviceDTO.getData();

        searchResult.setPageIndex(queryAppDeviceDTO.getPageIndex());
        searchResult.setPageSize(queryAppDeviceDTO.getPageSize());
        searchResult.setTotal(queryAppDeviceDTO.getTotal());
        searchResult.setData(BeanCopyUtils.copyDeviceAppQueryList(data, BasicExperimentDeviceAppQueryDTO.class));

        return searchResult;
    }

    /**
     * 基础仪器设备表 - 修改
     * */
    @Override
    public int updateBasicExperimentDevice(Long currentUserId, BasicExperimentDeviceUpdateReqBO deviceUpdateReqDO) {

        BasicExperimentDeviceAppUpdateBO updateParam = BeanCopyUtils.copyBean(deviceUpdateReqDO, BasicExperimentDeviceAppUpdateBO.class);

        DeviceUpdateDTO updateDeviceDTO = basicExperimentDeviceService.updateBasicExperimentDevice(currentUserId, updateParam);
        if (ObjectUtils.isEmpty(updateDeviceDTO)){
            return StatusEnum.FAIL.getCode();
        }
        return StatusEnum.SUCCESS.getCode();
    }

    /**
     * 基础仪器设备表 - 删除
     * */
    @Override
    public int deleteBasicExperimentDevice(Long currentUserId, Long id) {

        DeviceDeleteDTO deviceDeleteDTO = basicExperimentDeviceService.deleteBasicExperimentDevice(currentUserId, id);

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

    /**
     * 基础仪器设备表 - 设备列表
     * */
    @Override
    public SearchResult<BasicExperimentDeviceAppQueryDTO> listBasicExperimentDevice(Long currentUserId) {

        SearchResult searchResult = new SearchResult<>();

        List<BasicExperimentDeviceAppListDTO> deviceAppListDTOS = basicExperimentDeviceService.listBasicExperimentDevice(currentUserId);
        searchResult.setData(deviceAppListDTOS);
        searchResult.setCount(deviceAppListDTOS.size());

        return searchResult;
    }

    /**
     * 基础实验人员 - 插入
     * */
    @Override
    public int insertBasicExperimentPerson(Long currentUserId, BasicExperimentPersonInsertReqBO insertReqDO) {

        BasicExperimentPersonAppInsertBO personAppInsertDO = BeanCopyUtils.copyBean(insertReqDO, BasicExperimentPersonAppInsertBO.class);
        PersonInsertDTO personInsertDTO = basicExperimentPersonService.insertBasicExperimentPerson(currentUserId, personAppInsertDO);

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

    /**
     * 基础实验人员 - 分页查询
     * */
    @Override
    public SearchResult<BasicExperimentPersonAppQueryBO> getBasicExperimentPersonPage(Long currentUserId, BasicExperimentPersonQueryReqBO queryReqDO) {

        SearchResult searchResult = new SearchResult<>();
        BasicExperimentPersonAppQueryBO queryParam = BeanCopyUtils.copyBean(queryReqDO, BasicExperimentPersonAppQueryBO.class);
        SearchResult<PersonQueryDTO> queryPersonDTO = basicExperimentPersonService.getBasicExperimentPersonPage(currentUserId, queryParam);
        Object data = queryPersonDTO.getData();

        searchResult.setPageIndex(queryPersonDTO.getPageIndex());
        searchResult.setPageSize(queryPersonDTO.getPageSize());
        searchResult.setTotal(queryPersonDTO.getTotal());
        searchResult.setData(BeanCopyUtils.copyPersonAppQueryList(data, BasicExperimentPersonAppQueryBO.class));

        return searchResult;
    }

    /**
     * 基础实验人员 - 修改
     * */
    @Override
    public int updateBasicExperimentPerson(Long currentUserId, BasicExperimentPersonUpdateReqBO updateReqDO) {

        BasicExperimentPersonAppUpdateBO updateParam = BeanCopyUtils.copyBean(updateReqDO, BasicExperimentPersonAppUpdateBO.class);

        PersonUpdateDTO personUpdateDTO = basicExperimentPersonService.updateBasicExperimentPerson(currentUserId, updateParam);

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

    /**
     * 基础实验人员 - 删除
     * */
    @Override
    public int deleteBasicExperimentPerson(Long currentUserId, Long id) {

        PersonDeleteDTO personDeleteDTO = basicExperimentPersonService.deleteBasicExperimentPerson(currentUserId, id);

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

    /**
     * 基础实验人员 - 列表
     * */
    @Override
    public SearchResult<BasicExperimentPersonAppListDTO> listBasicExperimentPerson(Long currentUserId) {

        SearchResult searchResult = new SearchResult<>();

        List<PersonListDTO> personListDTOS = basicExperimentPersonService.listBasicExperimentPerson(currentUserId);
        searchResult.setData(BeanCopyUtils.copyBeanList(personListDTOS, BasicExperimentPersonAppListDTO.class));
        searchResult.setCount(personListDTOS.size());

        return searchResult;
    }

    /**
     * 基础场所管理 - 新增
     * */
    @Override
    public int insertBasicExperimentSite(Long currentUserId, BasicExperimentSiteInsertReqBO insertReqBO) {

        BasicExperimentSiteAppInsertBO insertParam = BeanCopyUtils.copyBean(insertReqBO, BasicExperimentSiteAppInsertBO.class);

        BasicExperimentSite insertResult = basicExperimentSiteService.insertBasicExperimentSite(currentUserId, insertParam);

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

    /**
     * 基础场所管理 - 分页查询
     * */
    @Override
    public SearchResult<BasicExperimentSiteAppQueryDTO> selectBasicExperimentSitePage(Long currentUserId, BasicExperimentSiteQueryReqBO queryReqBO) {

        SearchResult searchResult = new SearchResult<>();

        BasicExperimentSiteAppQueryBO queryParam = BeanCopyUtils.copyBean(queryReqBO, BasicExperimentSiteAppQueryBO.class);
        SearchResult<SiteQueryDTO> queryResult = basicExperimentSiteService.selectBasicExperimentSitePage(currentUserId, queryParam);

        Object data = queryResult.getData();

        searchResult.setPageIndex(queryResult.getPageIndex());
        searchResult.setPageSize(queryResult.getPageSize());
        searchResult.setTotal(queryResult.getTotal());
        searchResult.setData(BeanCopyUtils.copySiteAppQueryList(data, BasicExperimentSiteAppQueryDTO.class));

        return searchResult;
    }

    /**
     * 基础场所管理 - 修改
     * */
    @Override
    public int updateBasicExperimentSite(Long currentUserId, BasicExperimentSiteUpdateReqBO updateReqBO) {
        BasicExperimentSiteAppUpdateBO updateParam = BeanCopyUtils.copyBean(updateReqBO, BasicExperimentSiteAppUpdateBO.class);

        SiteUpdateDTO siteUpdateDTO = basicExperimentSiteService.updateBasicExperimentSite(currentUserId, updateParam);
        if (ObjectUtils.isEmpty(siteUpdateDTO)){
            return StatusEnum.FAIL.getCode();
        }
        return StatusEnum.SUCCESS.getCode();
    }

    /**
     * 基础场所管理 - 删除
     * */
    @Override
    public int deleteBasicExperimentSite(Long currentUserId, Long id) {

        SiteDeleteDTO deleteResult = basicExperimentSiteService.deleteBasicExperimentSite(currentUserId, id);
        if (ObjectUtils.isEmpty(deleteResult)){
            return StatusEnum.FAIL.getCode();
        }
        return StatusEnum.SUCCESS.getCode();
    }

    /**
     * 基础场所管理 - 列表
     * */
    @Override
    public SearchResult<BasicExperimentSiteAppListDTO> listBasicExperimentSite(Long currentUserId) {
        SearchResult searchResult = new SearchResult<>();

        List<SiteListDTO> listResult = basicExperimentSiteService.listBasicExperimentSite(currentUserId);

        searchResult.setData(BeanCopyUtils.copyBeanList(listResult, BasicExperimentSiteAppListDTO.class));
        searchResult.setCount(listResult.size());
        return searchResult;
    }

    /**
     * 基础实验耗材管理 - 新增
     */
    @Override
    public int insertBasicExperimentStuff(Long currentUserId, BasicExperimentStuffInsertReqBO insertReqBO) {

        BasicExperimentStuffAppInsertBO insertParam = BeanCopyUtils.copyBean(insertReqBO, BasicExperimentStuffAppInsertBO.class);
        StuffInsertDTO insertResult = basicExperimentStuffService.insertBasicExperimentStuff(currentUserId, insertParam);

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

    /**
     * 基础实验耗材管理 - 分页查询
     */
    @Override
    public SearchResult<BasicExperimentStuffAppQueryDTO> selectBasicExperimentStuffPage(Long currentUserId, BasicExperimentStuffQueryReqBO queryReqBO) {

        SearchResult searchResult = new SearchResult();

        BasicExperimentStuffAppQueryBO queryParam = BeanCopyUtils.copyBean(queryReqBO, BasicExperimentStuffAppQueryBO.class);
        SearchResult<StuffQueryDTO> queryResult = basicExperimentStuffService.selectBasicExperimentStuffPage(currentUserId, queryParam);


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

        return searchResult;
    }

    /**
     * 基础实验耗材管理 - 修改
     */
    @Override
    public int updateBasicExperimentStuff(Long currentUserId, BasicExperimentStuffUpdateReqBO updateReqBO) {

        BasicExperimentStuffAppUpdateBO updateParam = BeanCopyUtils.copyBean(updateReqBO, BasicExperimentStuffAppUpdateBO.class);

        StuffUpdateDTO stuffUpdateDTO = basicExperimentStuffService.updateBasicExperimentSite(currentUserId, updateParam);

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

    /**
     * 基础实验耗材管理 - 删除
     */
    @Override
    public int deleteBasicExperimentStuff(Long currentUserId, Long id) {

        StuffDeleteDTO deleteResult = basicExperimentStuffService.deleteBasicExperimentStuff(currentUserId, id);
        if (ObjectUtils.isEmpty(deleteResult)){
            return StatusEnum.FAIL.getCode();
        }
        return StatusEnum.SUCCESS.getCode();
    }

    /**
     * 基础实验耗材管理 - 列表
     */
    @Override
    public SearchResult<BasicExperimentStuffAppListDTO> listBasicExperimentStuff(Long currentUserId) {
        SearchResult searchResult = new SearchResult<>();

        List<StuffListDTO> listResult = basicExperimentStuffService.listBasicExperimentStuff(currentUserId);

        searchResult.setData(BeanCopyUtils.copyBeanList(listResult, BasicExperimentStuffAppListDTO.class));
        searchResult.setCount(listResult.size());

        return searchResult;
    }

    /**
     * 基础实验类型 - 列表
     */
    @Override
    public SearchResult<BasicExperimentTypeAppListDTO> listBasicExperimentType() {
        SearchResult searchResult = new SearchResult<>();

        List<TypeListDTO> listResult = basicExperimentTypeService.listBasicExperimentType();

        searchResult.setData(BeanCopyUtils.copyBeanList(listResult, BasicExperimentTypeAppListDTO.class));
        searchResult.setCount(listResult.size());

        return searchResult;
    }

    /**
     * 基础风险单元管理 - 插入
     */
    @Override
    public int insertBasicRiskUnit(Long currentUserId, BasicRiskUnitInsertReqBO insertReqBO) {

        BasicRiskUnitAppInsertBO insertParam = BeanCopyUtils.copyBean(insertReqBO, BasicRiskUnitAppInsertBO.class);

        //校验，如果类型是1或者2，则风险源id不可为空
        if (insertReqBO.getRiskSourceType() == 1 || insertReqBO.getRiskSourceType() == 2){
            if (ObjectUtils.isEmpty(insertReqBO.getRiskSourceId())){
                throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "风险源不能为空");
            }
            //如果riskType为1-区域
            if (insertReqBO.getRiskSourceType() == 1){
                SiteQueryDTO siteById = basicExperimentSiteService.getBasicExperimentSiteById(insertReqBO.getRiskSourceId());
                //设置参数
                insertParam.setRiskSourceId(siteById.getId());
            }
            //如果riskType为2-设备
            if (insertReqBO.getRiskSourceType() == 2){
                DeviceQueryDTO deviceById = basicExperimentDeviceService.getBasicExperimentDeviceById(insertReqBO.getRiskSourceId());
                //设置参数
                insertParam.setRiskSourceId(deviceById.getId());
            }
        }else {
            insertParam.setRiskSourceId(null);
        }

        RiskUnitInsertDTO insertResult = basicRiskUnitService.insertBasicRiskUnit(currentUserId, insertParam);

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

    /**
     * 基础风险单元管理 - 分页查询
     */
    @Override
    public SearchResult<BasicRiskUnitAppQueryDTO> selectBasicRiskUnitPage(Long currentUserId, BasicRiskUnitQueryReqBO queryReqBO) {

        SearchResult searchResult = new SearchResult();

        BasicRiskUnitAppQueryBO queryParam = BeanCopyUtils.copyBean(queryReqBO, BasicRiskUnitAppQueryBO.class);
        SearchResult<RiskUnitBasicQueryDTO> queryResult = basicRiskUnitService.selectBasicRiskUnitPage(currentUserId, queryParam);

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

        return searchResult;
    }

    /**
     * 基础风险单元管理 - 修改
     */
    @Override
    public int updateBasicRiskUnit(Long currentUserId, BasicRiskUnitUpdateReqBO updateReqBO) {

        BasicRiskUnitAppUpdateBO updateParam = BeanCopyUtils.copyBean(updateReqBO, BasicRiskUnitAppUpdateBO.class);

        RiskUnitUpdateDTO riskUnitUpdateDTO = basicRiskUnitService.updateBasicRiskUnit(currentUserId, updateParam);

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

    /**
     * 基础风险单元管理 - 删除
     */
    @Override
    public int deleteBasicRiskUnit(Long currentUserId, Long id) {

        RiskUnitBasicDeleteDTO deleteResult = basicRiskUnitService.deleteBasicRiskUnit(currentUserId, id);
        if (ObjectUtils.isEmpty(deleteResult)){
            return StatusEnum.FAIL.getCode();
        }
        return StatusEnum.SUCCESS.getCode();
    }

    /**
     * 基础风险单元管理 - 列表
     */
    @Override
    public SearchResult<BasicRiskUnitAppListDTO> listBasicRiskUnit(Long currentUserId) {
        SearchResult searchResult = new SearchResult<>();

        List<RiskUnitListDTO> listResult = basicRiskUnitService.listBasicRiskUnit(currentUserId);

        searchResult.setData(BeanCopyUtils.copyBeanList(listResult, BasicRiskUnitAppListDTO.class));
        searchResult.setCount(listResult.size());

        return searchResult;
    }

    /**
     * 基础实验风险 - 列表
     * */
    @Override
    public SearchResult<BasicRiskSourceTypeListRespDTO> listRiskSourceType() {
        SearchResult searchResult = new SearchResult<>();

        List<RiskSourceTypeDTO> listResult = basicRiskSourceTypeService.listBasicRiskSourceType();

        searchResult.setData(BeanCopyUtils.copyBeanList(listResult, BasicRiskUnitAppListDTO.class));
        searchResult.setCount(listResult.size());

        return searchResult;
    }
}