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 getBasicExperimentDevicePage(Long currentUserId, BasicExperimentDeviceQueryReqBO queryReqDTO) { SearchResult searchResult = new SearchResult<>(); BasicExperimentDeviceAppQueryBO queryParam = BeanCopyUtils.copyBean(queryReqDTO, BasicExperimentDeviceAppQueryBO.class); SearchResult 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 listBasicExperimentDevice(Long currentUserId) { SearchResult searchResult = new SearchResult<>(); List 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 getBasicExperimentPersonPage(Long currentUserId, BasicExperimentPersonQueryReqBO queryReqDO) { SearchResult searchResult = new SearchResult<>(); BasicExperimentPersonAppQueryBO queryParam = BeanCopyUtils.copyBean(queryReqDO, BasicExperimentPersonAppQueryBO.class); SearchResult 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 listBasicExperimentPerson(Long currentUserId) { SearchResult searchResult = new SearchResult<>(); List 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 selectBasicExperimentSitePage(Long currentUserId, BasicExperimentSiteQueryReqBO queryReqBO) { SearchResult searchResult = new SearchResult<>(); BasicExperimentSiteAppQueryBO queryParam = BeanCopyUtils.copyBean(queryReqBO, BasicExperimentSiteAppQueryBO.class); SearchResult 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 listBasicExperimentSite(Long currentUserId) { SearchResult searchResult = new SearchResult<>(); List 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 selectBasicExperimentStuffPage(Long currentUserId, BasicExperimentStuffQueryReqBO queryReqBO) { SearchResult searchResult = new SearchResult(); BasicExperimentStuffAppQueryBO queryParam = BeanCopyUtils.copyBean(queryReqBO, BasicExperimentStuffAppQueryBO.class); SearchResult 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 listBasicExperimentStuff(Long currentUserId) { SearchResult searchResult = new SearchResult<>(); List listResult = basicExperimentStuffService.listBasicExperimentStuff(currentUserId); searchResult.setData(BeanCopyUtils.copyBeanList(listResult, BasicExperimentStuffAppListDTO.class)); searchResult.setCount(listResult.size()); return searchResult; } /** * 基础实验类型 - 列表 */ @Override public SearchResult listBasicExperimentType() { SearchResult searchResult = new SearchResult<>(); List 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 selectBasicRiskUnitPage(Long currentUserId, BasicRiskUnitQueryReqBO queryReqBO) { SearchResult searchResult = new SearchResult(); BasicRiskUnitAppQueryBO queryParam = BeanCopyUtils.copyBean(queryReqBO, BasicRiskUnitAppQueryBO.class); SearchResult 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 listBasicRiskUnit(Long currentUserId) { SearchResult searchResult = new SearchResult<>(); List listResult = basicRiskUnitService.listBasicRiskUnit(currentUserId); searchResult.setData(BeanCopyUtils.copyBeanList(listResult, BasicRiskUnitAppListDTO.class)); searchResult.setCount(listResult.size()); return searchResult; } /** * 基础实验风险 - 列表 * */ @Override public SearchResult listRiskSourceType() { SearchResult searchResult = new SearchResult<>(); List listResult = basicRiskSourceTypeService.listBasicRiskSourceType(); searchResult.setData(BeanCopyUtils.copyBeanList(listResult, BasicRiskUnitAppListDTO.class)); searchResult.setCount(listResult.size()); return searchResult; } }