diff --git a/src/main/java/com/docus/server/message/busservice/impl/SdBusinessServiceImpl.java b/src/main/java/com/docus/server/message/busservice/impl/SdBusinessServiceImpl.java index 9f66091..e3e1ed8 100644 --- a/src/main/java/com/docus/server/message/busservice/impl/SdBusinessServiceImpl.java +++ b/src/main/java/com/docus/server/message/busservice/impl/SdBusinessServiceImpl.java @@ -77,6 +77,7 @@ public class SdBusinessServiceImpl implements SdBusinessService { tBasicMapper.insertOrUpdateDoctorSubmitTime(patientIds.get(0), recordSubmitDto.getSubmitTime()); log.info("补偿电子病历任务 patientIds:{} collectId:{}", patientIds, taskConfig.getCollectorIds()); compensateTask(patientIds, taskConfig.getCollectorIds()); + tBasicMapper.updateEmrSubmitState(patientIds.get(0),1); return new MessageResponse(ResultCode.SUCCESS.getCode(), success()); } catch (BaseException baseException) { log.error(baseException.getMessage(), baseException); diff --git a/src/main/java/com/docus/server/message/mapper/TBasicMapper.java b/src/main/java/com/docus/server/message/mapper/TBasicMapper.java index 59059f6..a0b9695 100644 --- a/src/main/java/com/docus/server/message/mapper/TBasicMapper.java +++ b/src/main/java/com/docus/server/message/mapper/TBasicMapper.java @@ -70,4 +70,12 @@ public interface TBasicMapper { * @return 未作废文件数量 */ int getFileCountByPatientAndSource(@Param("patientId") String patientId, @Param("source") String source); + + /** + * 更新电子病历提交状态 + * @param patientId 病案主键 + * @param emrSubmitState 提交状态 0 否 1 是 + * @return 数据库操作 + */ + int updateEmrSubmitState(@Param("patientId") String patientId, @Param("emrSubmitState") int emrSubmitState); } diff --git a/src/main/resources/mapper/TBasicMapper.xml b/src/main/resources/mapper/TBasicMapper.xml index ff391d0..3985244 100644 --- a/src/main/resources/mapper/TBasicMapper.xml +++ b/src/main/resources/mapper/TBasicMapper.xml @@ -26,6 +26,11 @@ where inpatient_no=#{inpatientNo} and admiss_times=#{admissTimes} + + update `docus_medicalrecord`.`t_basic` + set `emr_submit`=#{emrSubmitState} + where patientId=#{patientId} +