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;
|
}
|
}
|
