package cn.besteam.modules.medical.service.impl;
|
|
import cn.besteam.common.constant.CommonConstant;
|
import cn.besteam.common.constant.ErrorCode;
|
import cn.besteam.common.constant.MedicalWasteEnum;
|
import cn.besteam.common.exception.BusinessException;
|
import cn.besteam.modules.medical.dto.ApiMedicalCheckoutBatchDTO;
|
import cn.besteam.modules.medical.dto.ApiMedicalCheckoutDTO;
|
import cn.besteam.modules.medical.dto.MwCheckoutRecordBatchDTO;
|
import cn.besteam.modules.medical.entity.*;
|
import cn.besteam.modules.medical.mapper.MwCheckoutRecordMapper;
|
import cn.besteam.modules.medical.service.*;
|
import cn.besteam.modules.medical.vo.ApiMedicalCheckoutDetailsVO;
|
import cn.besteam.modules.medical.vo.ApiMedicalStatisticsVO;
|
import cn.besteam.modules.shiro.authc.util.EnvUtils;
|
import cn.besteam.modules.system.entity.SysDepartment;
|
import cn.besteam.modules.system.service.ISysDepartmentService;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.google.common.collect.Lists;
|
import org.apache.commons.collections.CollectionUtils;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.math.BigDecimal;
|
import java.util.*;
|
import java.util.concurrent.CompletableFuture;
|
import java.util.stream.Collectors;
|
|
/**
|
* @Description: 出库记录
|
* @author： besteam
|
* @date： 2020-04-25
|
* @version： V1.0
|
*/
|
@Service
|
public class MwCheckoutRecordServiceImpl extends ServiceImpl<MwCheckoutRecordMapper, MwCheckoutRecord> implements IMwCheckoutRecordService {
|
|
@Autowired
|
private IMwCollectRecordService mwCollectRecordService;
|
|
@Autowired
|
private IMwCheckoutRecordItemService mwCheckoutRecordItemService;
|
|
@Autowired
|
private IMwTransitConfigService mwTransitConfigService;
|
|
@Autowired
|
private ISysDepartmentService sysDepartmentService;
|
|
@Autowired
|
private IMwWarningConfigService mwWarningConfigService;
|
|
@Autowired
|
private IMwWarningRecordService mwWarningRecordService;
|
|
/**
|
* 出库
|
*
|
* @param dto
|
* @return
|
*/
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public ApiMedicalCheckoutDetailsVO checkoutBatch(ApiMedicalCheckoutBatchDTO dto) {
|
|
MwTransitConfig mwTransitConfig = mwTransitConfigService.getById(dto.getTransitConfigId());
|
if (mwTransitConfig == null) {
|
throw new BusinessException(ErrorCode.ERR_500, "出库配置不存在");
|
}
|
SysDepartment hospital = sysDepartmentService.getById(mwTransitConfig.getHospitalId());
|
if (hospital == null) {
|
throw new BusinessException(ErrorCode.ERR_500, "医院不存在");
|
}
|
List<Integer> idList = dto.getIdList();
|
if (CollectionUtils.isEmpty(idList)) {
|
throw new BusinessException(ErrorCode.ERR_500, "请选择需要出库的医废列表");
|
}
|
//批量更新收集状态为已出库
|
Date checkoutTime = new Date();
|
List<MwCollectRecord> mwCollectRecordList = new ArrayList<>();
|
List<MwCheckoutRecordItem> mwCheckoutRecordItemList = new ArrayList<>();
|
for (Integer collectRecordId : idList) {
|
MwCollectRecord mwCollectRecord = mwCollectRecordService.getById(collectRecordId);
|
if (mwCollectRecord == null) {
|
throw new BusinessException(ErrorCode.ERR_500, "医废不存在,请重新选择");
|
}
|
if (!mwCollectRecord.getStatus().equals(MedicalWasteEnum.MedicalWasteStatusEnum.STORE.getStatus())) {
|
throw new BusinessException(ErrorCode.ERR_500, "医废不处于待出库状态,请重新选择");
|
}
|
if (mwCollectRecord.getDelFlag().equals(CommonConstant.DEL_FLAG_1)) {
|
throw new BusinessException(ErrorCode.ERR_500, "医废已删除,请重新选择");
|
}
|
if (!mwCollectRecord.getAuditStatus().equals(MedicalWasteEnum.MedicalWasteAuditStatusEnum.PASS.getStatus())) {
|
throw new BusinessException(ErrorCode.ERR_500, "医废已删除,请重新选择");
|
}
|
if (!mwCollectRecord.getHospitalId().equals(mwTransitConfig.getHospitalId())) {
|
throw new BusinessException(ErrorCode.ERR_500, "医废所在医院与出库配置不对应,请重新选择");
|
}
|
mwCollectRecord.setCheckoutUserId(EnvUtils.getUser().getId());
|
mwCollectRecord.setCheckoutUser(EnvUtils.getUser().getName());
|
mwCollectRecord.setCheckoutTime(checkoutTime);
|
mwCollectRecord.setStatus(MedicalWasteEnum.MedicalWasteStatusEnum.CHECKOUT.getStatus());
|
mwCollectRecordList.add(mwCollectRecord);
|
//
|
mwCheckoutRecordItemList.add(new MwCheckoutRecordItem().setCollectRecordId(collectRecordId));
|
}
|
mwCollectRecordService.updateBatchById(mwCollectRecordList);
|
//新增出库运输信息记录
|
MwCheckoutRecord mwCheckoutRecord = new MwCheckoutRecord();
|
mwCheckoutRecord.setEngineDriver(mwTransitConfig.getEngineDriver());
|
mwCheckoutRecord.setLicensePlate(mwTransitConfig.getLicensePlate());
|
mwCheckoutRecord.setTransitCompany(mwTransitConfig.getTransitCompany());
|
mwCheckoutRecord.setTransitConfigId(mwTransitConfig.getId());
|
mwCheckoutRecord.setHospitalName(hospital.getDepartName());
|
mwCheckoutRecord.setHospitalId(hospital.getId());
|
mwCheckoutRecord.setCreateTime(checkoutTime);
|
mwCheckoutRecord.setWeight(dto.getWeightTotal());
|
mwCheckoutRecord.setCode(dto.getCode());
|
save(mwCheckoutRecord);
|
//批量新增出库记录-医废项
|
for (MwCheckoutRecordItem mwCheckoutRecordItem : mwCheckoutRecordItemList) {
|
mwCheckoutRecordItem.setCheckoutRecordId(mwCheckoutRecord.getId());
|
}
|
mwCheckoutRecordItemService.saveBatch(mwCheckoutRecordItemList);
|
//
|
//打印出库详情
|
ApiMedicalCheckoutDetailsVO checkoutDetails = new ApiMedicalCheckoutDetailsVO();
|
//运输人员
|
BeanUtils.copyProperties(mwCheckoutRecord, checkoutDetails);
|
Set<String> wasteTypeStrSet = mwCollectRecordList.stream().map(MwCollectRecord::getWasteTypeStr).collect(Collectors.toSet());
|
List<ApiMedicalStatisticsVO> statisticsList = new ArrayList<>();
|
//获取此次出库操作医废收集类型统计
|
for (String wasteTypeStr : wasteTypeStrSet) {
|
ApiMedicalStatisticsVO statisticsVO = new ApiMedicalStatisticsVO();
|
statisticsVO.setWasteTypeStr(wasteTypeStr);
|
statisticsVO.setWeightSum(BigDecimal.ZERO);
|
statisticsVO.setCount(0);
|
for (MwCollectRecord mwCollectRecord : mwCollectRecordList) {
|
if (mwCollectRecord.getWasteTypeStr().equals(wasteTypeStr)) {
|
statisticsVO.setWeightSum(statisticsVO.getWeightSum().add(mwCollectRecord.getWeight()));
|
statisticsVO.setCount(statisticsVO.getCount() + 1);
|
}
|
}
|
statisticsList.add(statisticsVO);
|
}
|
checkoutDetails.setStatisticsList(statisticsList);
|
checkoutDetails.setWasteTypeTotal(statisticsList.stream().mapToInt(ApiMedicalStatisticsVO::getCount).sum());
|
checkoutDetails.setWeightTotal(statisticsList.stream().map(ApiMedicalStatisticsVO::getWeightSum).reduce(BigDecimal.ZERO, BigDecimal::add));
|
checkoutDetails.setDateTime(checkoutTime);
|
//处理预警记录
|
mwWarningRecordService.handleCheckoutStoreWarning(mwCollectRecordList);
|
return checkoutDetails;
|
}
|
|
@Override
|
public ApiMedicalCheckoutDetailsVO checkout(ApiMedicalCheckoutDTO dto) {
|
|
MwTransitConfig mwTransitConfig = mwTransitConfigService.getById(dto.getTransitConfigId());
|
if (mwTransitConfig == null) {
|
throw new BusinessException(ErrorCode.ERR_500, "出库配置不存在");
|
}
|
SysDepartment hospital = sysDepartmentService.getById(mwTransitConfig.getHospitalId());
|
if (hospital == null) {
|
throw new BusinessException(ErrorCode.ERR_500, "医院不存在");
|
}
|
//批量更新收集状态为已出库
|
Date checkoutTime = new Date();
|
List<MwCheckoutRecordItem> mwCheckoutRecordItemList = new ArrayList<>();
|
List<MwCollectRecord> mwCollectRecordList = new ArrayList<>();
|
MwCollectRecord mwCollectRecord = mwCollectRecordService.getById(dto.getId());
|
if (mwCollectRecord == null) {
|
throw new BusinessException(ErrorCode.ERR_500, "医废不存在,请重新选择");
|
}
|
if (!mwCollectRecord.getStatus().equals(MedicalWasteEnum.MedicalWasteStatusEnum.STORE.getStatus())) {
|
throw new BusinessException(ErrorCode.ERR_500, "医废不处于待出库状态,请重新选择");
|
}
|
if (mwCollectRecord.getDelFlag().equals(CommonConstant.DEL_FLAG_1)) {
|
throw new BusinessException(ErrorCode.ERR_500, "医废已删除,请重新选择");
|
}
|
if (!mwCollectRecord.getAuditStatus().equals(MedicalWasteEnum.MedicalWasteAuditStatusEnum.PASS.getStatus())) {
|
throw new BusinessException(ErrorCode.ERR_500, "医废已删除,请重新选择");
|
}
|
if (!mwCollectRecord.getHospitalId().equals(mwTransitConfig.getHospitalId())) {
|
throw new BusinessException(ErrorCode.ERR_500, "医废所在医院与出库配置不对应,请重新选择");
|
}
|
//
|
mwCollectRecordList.add(mwCollectRecord);
|
mwCheckoutRecordItemList.add(new MwCheckoutRecordItem().setCollectRecordId(mwCollectRecord.getId()));
|
//
|
if (dto.getWeight() != null) {
|
mwCollectRecord.setCheckoutWeight(dto.getWeight());
|
BigDecimal subtract = dto.getWeight().subtract(mwCollectRecord.getBoxWeight());
|
if (subtract.compareTo(BigDecimal.ZERO) > 0) {
|
MwWarningConfig storeWeightConfig = mwWarningConfigService.getOne(new QueryWrapper<MwWarningConfig>().lambda().eq(MwWarningConfig::getType, MedicalWasteEnum.WarningConfigTypeEnum.CHECKOUT_WEIGHT.getType()));
|
if (subtract.compareTo(storeWeightConfig.getDefaultValue()) > 0 && storeWeightConfig.getDefaultValue().compareTo(BigDecimal.ZERO) > 0) {
|
MwWarningRecord warningRecord = new MwWarningRecord();
|
warningRecord.setHospitalId(mwCollectRecord.getHospitalId());
|
warningRecord.setHospitalName(mwCollectRecord.getHospitalName());
|
warningRecord.setOfficeId(mwCollectRecord.getDepartmentId());
|
warningRecord.setOfficeName(mwCollectRecord.getDepartmentName());
|
warningRecord.setType(MedicalWasteEnum.WarningConfigTypeEnum.CHECKOUT_WEIGHT.getType());
|
warningRecord.setTypeName(MedicalWasteEnum.WarningConfigTypeEnum.CHECKOUT_WEIGHT.getName());
|
warningRecord.setWarningTime(new Date());
|
warningRecord.setMessage("医疗废物出库重量不符");
|
warningRecord.setWarningTargetId(mwCollectRecord.getId());
|
warningRecord.setWarningTargetName(mwCollectRecord.getCode());
|
warningRecord.setStatus(MedicalWasteEnum.WarningRecordStatusEnum.WAIT_AUDIT.getStatus());
|
warningRecord.setWasteTypeName(mwCollectRecord.getWasteTypeStr());
|
warningRecord.setWeight(mwCollectRecord.getCheckoutWeight());
|
mwWarningRecordService.save(warningRecord);
|
}
|
} else {
|
subtract = subtract.abs();
|
MwWarningConfig leekConfig = mwWarningConfigService.getOne(new QueryWrapper<MwWarningConfig>().lambda().eq(MwWarningConfig::getType, MedicalWasteEnum.WarningConfigTypeEnum.LEEK.getType()));
|
if (subtract.compareTo(leekConfig.getDefaultValue()) > 0 && StringUtils.isNotEmpty(leekConfig.getWasteTypes()) && leekConfig.getDefaultValue().compareTo(BigDecimal.ZERO) > 0) {
|
List<String> wasteTypeList = Arrays.asList(leekConfig.getWasteTypes().split(","));
|
if (wasteTypeList.contains(String.valueOf(mwCollectRecord.getWasteType()))) {
|
MwWarningRecord warningRecord = new MwWarningRecord();
|
warningRecord.setHospitalId(mwCollectRecord.getHospitalId());
|
warningRecord.setHospitalName(mwCollectRecord.getHospitalName());
|
warningRecord.setOfficeId(mwCollectRecord.getDepartmentId());
|
warningRecord.setOfficeName(mwCollectRecord.getDepartmentName());
|
warningRecord.setType(MedicalWasteEnum.WarningConfigTypeEnum.LEEK.getType());
|
warningRecord.setTypeName(MedicalWasteEnum.WarningConfigTypeEnum.LEEK.getName());
|
warningRecord.setWarningTime(new Date());
|
warningRecord.setMessage("医疗废物可能出现泄漏");
|
warningRecord.setWarningTargetId(mwCollectRecord.getId());
|
warningRecord.setWarningTargetName(mwCollectRecord.getCode());
|
warningRecord.setStatus(MedicalWasteEnum.WarningRecordStatusEnum.WAIT_AUDIT.getStatus());
|
warningRecord.setWasteTypeName(mwCollectRecord.getWasteTypeStr());
|
warningRecord.setWeight(mwCollectRecord.getCheckoutWeight());
|
mwWarningRecordService.save(warningRecord);
|
}
|
}
|
MwWarningConfig damagedConfig = mwWarningConfigService.getOne(new QueryWrapper<MwWarningConfig>().lambda().eq(MwWarningConfig::getType, MedicalWasteEnum.WarningConfigTypeEnum.DAMAGED.getType()));
|
if (subtract.compareTo(damagedConfig.getDefaultValue()) > 0 && StringUtils.isNotEmpty(damagedConfig.getWasteTypes()) && damagedConfig.getDefaultValue().compareTo(BigDecimal.ZERO) > 0) {
|
List<String> wasteTypeList = Arrays.asList(damagedConfig.getWasteTypes().split(","));
|
if (wasteTypeList.contains(String.valueOf(mwCollectRecord.getWasteType()))) {
|
MwWarningRecord warningRecord = new MwWarningRecord();
|
warningRecord.setHospitalId(mwCollectRecord.getHospitalId());
|
warningRecord.setHospitalName(mwCollectRecord.getHospitalName());
|
warningRecord.setOfficeId(mwCollectRecord.getDepartmentId());
|
warningRecord.setOfficeName(mwCollectRecord.getDepartmentName());
|
warningRecord.setType(MedicalWasteEnum.WarningConfigTypeEnum.DAMAGED.getType());
|
warningRecord.setTypeName(MedicalWasteEnum.WarningConfigTypeEnum.DAMAGED.getName());
|
warningRecord.setWarningTime(new Date());
|
warningRecord.setMessage("医疗废物可能出现破损");
|
warningRecord.setWarningTargetId(mwCollectRecord.getId());
|
warningRecord.setWarningTargetName(mwCollectRecord.getCode());
|
warningRecord.setStatus(MedicalWasteEnum.WarningRecordStatusEnum.WAIT_AUDIT.getStatus());
|
warningRecord.setWasteTypeName(mwCollectRecord.getWasteTypeStr());
|
warningRecord.setWeight(mwCollectRecord.getCheckoutWeight());
|
mwWarningRecordService.save(warningRecord);
|
}
|
}
|
}
|
}
|
mwCollectRecord.setCheckoutUserId(EnvUtils.getUser().getId());
|
mwCollectRecord.setCheckoutUser(EnvUtils.getUser().getName());
|
mwCollectRecord.setCheckoutTime(checkoutTime);
|
mwCollectRecord.setStatus(MedicalWasteEnum.MedicalWasteStatusEnum.CHECKOUT.getStatus());
|
mwCollectRecordService.updateById(mwCollectRecord);
|
//
|
//
|
//新增出库运输信息记录
|
MwCheckoutRecord mwCheckoutRecord = new MwCheckoutRecord();
|
mwCheckoutRecord.setEngineDriver(mwTransitConfig.getEngineDriver());
|
mwCheckoutRecord.setLicensePlate(mwTransitConfig.getLicensePlate());
|
mwCheckoutRecord.setTransitCompany(mwTransitConfig.getTransitCompany());
|
mwCheckoutRecord.setTransitConfigId(mwTransitConfig.getId());
|
mwCheckoutRecord.setHospitalName(hospital.getDepartName());
|
mwCheckoutRecord.setCreateTime(checkoutTime);
|
mwCheckoutRecord.setWeight(dto.getWeightTotal());
|
mwCheckoutRecord.setCode(dto.getCode());
|
save(mwCheckoutRecord);
|
//批量新增出库记录-医废项
|
for (MwCheckoutRecordItem mwCheckoutRecordItem : mwCheckoutRecordItemList) {
|
mwCheckoutRecordItem.setCheckoutRecordId(mwCheckoutRecord.getId());
|
}
|
mwCheckoutRecordItemService.saveBatch(mwCheckoutRecordItemList);
|
//
|
//打印出库详情
|
ApiMedicalCheckoutDetailsVO checkoutDetails = new ApiMedicalCheckoutDetailsVO();
|
//运输人员
|
BeanUtils.copyProperties(mwCheckoutRecord, checkoutDetails);
|
Set<String> wasteTypeStrSet = mwCollectRecordList.stream().map(MwCollectRecord::getWasteTypeStr).collect(Collectors.toSet());
|
List<ApiMedicalStatisticsVO> statisticsList = new ArrayList<>();
|
//获取此次出库操作医废收集类型统计
|
for (String wasteTypeStr : wasteTypeStrSet) {
|
ApiMedicalStatisticsVO statisticsVO = new ApiMedicalStatisticsVO();
|
statisticsVO.setWasteTypeStr(wasteTypeStr);
|
statisticsVO.setWeightSum(BigDecimal.ZERO);
|
statisticsVO.setCount(0);
|
for (MwCollectRecord mwCollectRecordTemp : mwCollectRecordList) {
|
if (mwCollectRecordTemp.getWasteTypeStr().equals(wasteTypeStr)) {
|
statisticsVO.setWeightSum(statisticsVO.getWeightSum().add(mwCollectRecordTemp.getWeight()));
|
statisticsVO.setCount(statisticsVO.getCount() + 1);
|
}
|
}
|
statisticsList.add(statisticsVO);
|
}
|
checkoutDetails.setStatisticsList(statisticsList);
|
checkoutDetails.setWasteTypeTotal(statisticsList.stream().mapToInt(ApiMedicalStatisticsVO::getCount).sum());
|
checkoutDetails.setWeightTotal(statisticsList.stream().map(ApiMedicalStatisticsVO::getWeightSum).reduce(BigDecimal.ZERO, BigDecimal::add));
|
checkoutDetails.setDateTime(checkoutTime);
|
//处理入库超时、入库后遗失预警记录
|
mwWarningRecordService.handleCheckoutStoreWarning(Lists.newArrayList(mwCollectRecord));
|
return checkoutDetails;
|
}
|
|
/**
|
* 后台出库
|
*
|
* @param dto
|
* @return
|
*/
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public Boolean checkoutBatchBackground(MwCheckoutRecordBatchDTO dto) {
|
SysDepartment hospital = sysDepartmentService.getById(dto.getHospitalId());
|
if (hospital == null) {
|
throw new BusinessException(ErrorCode.ERR_500, "医院不存在");
|
}
|
List<Integer> idList = dto.getCollectRecordIdList();
|
if (CollectionUtils.isEmpty(idList)) {
|
throw new BusinessException(ErrorCode.ERR_500, "请选择需要出库的医废列表");
|
}
|
//批量更新收集状态为已出库
|
Date checkoutTime = dto.getCheckoutTime();
|
List<MwCollectRecord> mwCollectRecordList = new ArrayList<>();
|
List<MwCheckoutRecordItem> mwCheckoutRecordItemList = new ArrayList<>();
|
for (Integer collectRecordId : idList) {
|
MwCollectRecord mwCollectRecord = mwCollectRecordService.getById(collectRecordId);
|
if (mwCollectRecord == null) {
|
throw new BusinessException(ErrorCode.ERR_500, "医废不存在,请重新选择");
|
}
|
if (!mwCollectRecord.getStatus().equals(MedicalWasteEnum.MedicalWasteStatusEnum.STORE.getStatus())) {
|
throw new BusinessException(ErrorCode.ERR_500, "医废不处于待出库状态,请重新选择");
|
}
|
if (mwCollectRecord.getDelFlag().equals(CommonConstant.DEL_FLAG_1)) {
|
throw new BusinessException(ErrorCode.ERR_500, "医废已删除,请重新选择");
|
}
|
if (!mwCollectRecord.getAuditStatus().equals(MedicalWasteEnum.MedicalWasteAuditStatusEnum.PASS.getStatus())) {
|
throw new BusinessException(ErrorCode.ERR_500, "医废已删除,请重新选择");
|
}
|
mwCollectRecord.setCheckoutUserId(-1);
|
mwCollectRecord.setCheckoutUser(dto.getCheckoutUser());
|
mwCollectRecord.setCheckoutTime(checkoutTime);
|
mwCollectRecord.setCheckoutWeight(mwCollectRecord.getStoreWeight());
|
mwCollectRecord.setStatus(MedicalWasteEnum.MedicalWasteStatusEnum.CHECKOUT.getStatus());
|
mwCollectRecordList.add(mwCollectRecord);
|
//
|
mwCheckoutRecordItemList.add(new MwCheckoutRecordItem().setCollectRecordId(collectRecordId));
|
}
|
mwCollectRecordService.updateBatchById(mwCollectRecordList);
|
//新增出库运输信息记录
|
MwCheckoutRecord mwCheckoutRecord = new MwCheckoutRecord();
|
mwCheckoutRecord.setEngineDriver(dto.getEngineDriver());
|
mwCheckoutRecord.setLicensePlate(dto.getLicensePlate());
|
mwCheckoutRecord.setTransitCompany(dto.getTransitCompany());
|
mwCheckoutRecord.setTransitConfigId(-1);
|
mwCheckoutRecord.setHospitalName(dto.getHospitalName());
|
mwCheckoutRecord.setHospitalId(dto.getHospitalId());
|
mwCheckoutRecord.setCreateTime(checkoutTime);
|
mwCheckoutRecord.setCreator(dto.getCheckoutUser());
|
mwCheckoutRecord.setCreateBy(-1);
|
save(mwCheckoutRecord);
|
//批量新增出库记录-医废项
|
for (MwCheckoutRecordItem mwCheckoutRecordItem : mwCheckoutRecordItemList) {
|
mwCheckoutRecordItem.setCheckoutRecordId(mwCheckoutRecord.getId());
|
}
|
mwCheckoutRecordItemService.saveBatch(mwCheckoutRecordItemList);
|
return true;
|
}
|
|
}
|
