|
|
|
@ -68,16 +68,14 @@ public class ProjectService implements IProjectService { |
|
|
|
@Override |
|
|
|
public void saveData(Long startTime, StepTask stepTask, Long operationId, byte operation) { |
|
|
|
//患者平车id
|
|
|
|
Long patientCarId = null; |
|
|
|
// 修改平车结束时间点
|
|
|
|
ProjectVo.BindCar bindCar = stepTaskDao.getBindCarTaskId(stepTask.getTaskSubId()); |
|
|
|
|
|
|
|
// 判断是否为结束结点
|
|
|
|
Step step = stepDao.selectByPrimaryKey(stepTask.getStepId()); |
|
|
|
Integer max = stepDao.getMaxSequence(Constant.STEP_TYPE_REAL); |
|
|
|
if (step != null && max != null && step.getSequence() != null && step.getSequence().intValue() == max.intValue()) { |
|
|
|
// 修改平车结束时间点
|
|
|
|
ProjectVo.BindCar bindCar = stepTaskDao.getBindCarTaskId(stepTask.getTaskSubId()); |
|
|
|
if(ObjectUtil.isNotNull(bindCar)){ |
|
|
|
patientCarId = bindCar.getCarId(); |
|
|
|
} |
|
|
|
|
|
|
|
boolean needModifyEndTime = bindCar != null && (bindCar.getEndTime() == null || bindCar.getEndTime() == 0); |
|
|
|
if (needModifyEndTime) { |
|
|
|
log.info("出现异常,未找到绑定平车:{}", stepTask.getTaskSubId()); |
|
|
|
@ -107,19 +105,22 @@ public class ProjectService implements IProjectService { |
|
|
|
|
|
|
|
|
|
|
|
PatientData data = new PatientData(); |
|
|
|
|
|
|
|
data.setId(snowflake.nextId()); |
|
|
|
if (operation == Constant.OPERATION_USER) { |
|
|
|
data.setUserId(operationId); |
|
|
|
} else { |
|
|
|
data.setWisdomCarRecordId(operationId); |
|
|
|
} |
|
|
|
data.setPatientCarId(patientCarId); |
|
|
|
|
|
|
|
if(ObjectUtil.isNotNull(bindCar)) { |
|
|
|
data.setPatientCarId(bindCar.getId()); |
|
|
|
} |
|
|
|
data.setTaskSubId(stepTask.getTaskSubId()); |
|
|
|
data.setStepId(stepTask.getStepId()); |
|
|
|
data.setPushStatus(Constant.PUSH_STATUS_NO); |
|
|
|
data.setStartTime(startTime); |
|
|
|
data.setType(operation); |
|
|
|
log.info("添加患者数据:{}", data); |
|
|
|
patientDataDao.insertSelective(data); |
|
|
|
// 异步推送数据 根据结果修改状态
|
|
|
|
asyncService.pushTime(stepTask, data); |
|
|
|
|