diff --git a/src/main/java/com/docus/server/collection/mapper/TBasicMapper.java b/src/main/java/com/docus/server/collection/mapper/TBasicMapper.java
index d8c916c..b124ad8 100644
--- a/src/main/java/com/docus/server/collection/mapper/TBasicMapper.java
+++ b/src/main/java/com/docus/server/collection/mapper/TBasicMapper.java
@@ -95,4 +95,12 @@ public interface TBasicMapper{
TBasic getByPatientId(@Param("patientId") String patientId);
int deleteByPatientId(@Param("patientId") String patientId);
+
+ /**
+ * 更新患者的护理采集状态
+ * @param patientId 病案
+ * @param state 状态 0未采集 1 已采集
+ * @return 数据库操作
+ */
+ int updateNursCollectState(@Param("patientId") String patientId, @Param("state") int state);
}
diff --git a/src/main/java/com/docus/server/report/listener/NisReportDownloadWaitHandler.java b/src/main/java/com/docus/server/report/listener/NisReportDownloadWaitHandler.java
index 75daf17..90d81f4 100644
--- a/src/main/java/com/docus/server/report/listener/NisReportDownloadWaitHandler.java
+++ b/src/main/java/com/docus/server/report/listener/NisReportDownloadWaitHandler.java
@@ -67,6 +67,7 @@ public class NisReportDownloadWaitHandler extends RedisKeyExpirationHandler {
boolean verifyNisFileCountResult = verifyNisFileCountAndPushErr(patientId);
if (verifyNisFileCountResult) {
nisQualityControl(patientId);
+ tBasicMapper.updateNursCollectState(patientId,1);
}
}
diff --git a/src/main/resources/mapper/TBasicMapper.xml b/src/main/resources/mapper/TBasicMapper.xml
index a96bc3d..d1e8002 100644
--- a/src/main/resources/mapper/TBasicMapper.xml
+++ b/src/main/resources/mapper/TBasicMapper.xml
@@ -112,6 +112,10 @@
`ward_name`=#{tBasicExtend.wardName},
`sdry_index`=#{tBasicExtend.sdryIndex}
+
+ UPDATE `docus_medicalrecord`.`t_basic` set nurs_collect = #{state}
+ where patient_id=#{patientId}
+