package cn.besteam.modules.medical.service.impl;
|
|
import cn.besteam.common.constant.ErrorCode;
|
import cn.besteam.common.constant.MedicalWasteEnum;
|
import cn.besteam.common.exception.BusinessException;
|
import cn.besteam.modules.medical.dto.MwWarningRecordHandleDTO;
|
import cn.besteam.modules.medical.entity.MwWarningRecord;
|
import cn.besteam.modules.medical.entity.MwWarningRecordHandle;
|
import cn.besteam.modules.medical.mapper.MwWarningRecordHandleMapper;
|
import cn.besteam.modules.medical.service.IMwWarningRecordHandleService;
|
import cn.besteam.modules.medical.service.IMwWarningRecordService;
|
import cn.besteam.modules.medical.vo.MwWarningRecordHandleVO;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import org.apache.commons.collections.CollectionUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
/**
|
* @Description: 预警消息-处理记录
|
* @author： besteam
|
* @date： 2020-07-17
|
* @version： V1.0
|
*/
|
@Service
|
public class MwWarningRecordHandleServiceImpl extends ServiceImpl<MwWarningRecordHandleMapper, MwWarningRecordHandle> implements IMwWarningRecordHandleService {
|
|
@Autowired
|
private IMwWarningRecordService mwWarningRecordService;
|
|
@Override
|
public List<MwWarningRecordHandleVO> listByWarningRecord(Integer warningRecordId) {
|
|
return baseMapper.listByWarningRecord(warningRecordId);
|
}
|
|
@Transactional
|
@Override
|
public boolean handle(MwWarningRecordHandleDTO dto) {
|
|
MwWarningRecord warningRecord = mwWarningRecordService.getById(dto.getWarningRecordId());
|
if (warningRecord == null) {
|
throw new BusinessException(ErrorCode.ERR_500, "预警信息不存在");
|
}
|
if (warningRecord.getStatus().equals(MedicalWasteEnum.WarningRecordStatusEnum.PASS.getStatus())) {
|
throw new BusinessException(ErrorCode.ERR_500, "预警信息已通过,不能重复提交");
|
}
|
warningRecord.setStatus(dto.getStatus());
|
mwWarningRecordService.updateById(warningRecord);
|
//
|
MwWarningRecordHandle mwWarningRecordHandle = new MwWarningRecordHandle();
|
mwWarningRecordHandle.setWarningRecordId(warningRecord.getId());
|
mwWarningRecordHandle.setContent(dto.getContent());
|
mwWarningRecordHandle.setStatus(dto.getStatus());
|
return save(mwWarningRecordHandle);
|
}
|
|
@Transactional
|
@Override
|
public boolean batchHandle(List<MwWarningRecordHandleDTO> list, String content, Integer status) {
|
|
List<MwWarningRecord> warningRecordList = mwWarningRecordService.listByIds(list.stream().map(MwWarningRecordHandleDTO::getWarningRecordId).collect(Collectors.toList()));
|
if (CollectionUtils.isEmpty(warningRecordList)) {
|
throw new BusinessException(ErrorCode.ERR_500, "预警信息列表不能为空");
|
}
|
long count = warningRecordList.stream().map(MwWarningRecord::getType).collect(Collectors.toSet()).size();
|
if (count > 1) {
|
throw new BusinessException(ErrorCode.ERR_500, "只能选择同一类型的预警信息");
|
}
|
List<MwWarningRecordHandle> mwWarningRecordHandleList = new ArrayList<>(warningRecordList.size());
|
for (MwWarningRecord warningRecord : warningRecordList) {
|
if (warningRecord.getStatus().equals(MedicalWasteEnum.WarningRecordStatusEnum.PASS.getStatus())) {
|
throw new BusinessException(ErrorCode.ERR_500, "预警信息已通过,不能重复提交");
|
}
|
warningRecord.setStatus(status);
|
//;
|
MwWarningRecordHandle mwWarningRecordHandle = new MwWarningRecordHandle();
|
mwWarningRecordHandle.setWarningRecordId(warningRecord.getId());
|
mwWarningRecordHandle.setContent(content);
|
mwWarningRecordHandle.setStatus(status);
|
mwWarningRecordHandleList.add(mwWarningRecordHandle);
|
}
|
mwWarningRecordService.updateBatchById(warningRecordList);
|
return saveBatch(mwWarningRecordHandleList);
|
}
|
|
}
|
