diff --git a/src/main/java/com/docus/server/archive/mapper/TBasicMapper.java b/src/main/java/com/docus/server/archive/mapper/TBasicMapper.java
index 8105422..0b50efc 100644
--- a/src/main/java/com/docus/server/archive/mapper/TBasicMapper.java
+++ b/src/main/java/com/docus/server/archive/mapper/TBasicMapper.java
@@ -2,11 +2,11 @@ package com.docus.server.archive.mapper;
 
 
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
 
 @Mapper
 public interface TBasicMapper {
 
 
-
-
+    int invalidFileBySource(@Param("patientId") String patientId,@Param("collectorId") String collectorId);
 }
diff --git a/src/main/java/com/docus/server/sdry/job/CollectJob.java b/src/main/java/com/docus/server/sdry/job/CollectJob.java
index 3a0a05d..0f5b246 100644
--- a/src/main/java/com/docus/server/sdry/job/CollectJob.java
+++ b/src/main/java/com/docus/server/sdry/job/CollectJob.java
@@ -69,6 +69,8 @@ public class CollectJob {
             if (size <= 0) {
                 return;
             }
+            tBasicMapper.invalidFileBySource(downTwoDto.getPatientId(),collectorId);
+
             ReportDownPatientDto patient = new ReportDownPatientDto();
             patient.setPatientid(downTwoDto.getPatientId());
 
diff --git a/src/main/resources/mapper/TBasicMapper.xml b/src/main/resources/mapper/TBasicMapper.xml
index 8b84532..5ae4ce4 100644
--- a/src/main/resources/mapper/TBasicMapper.xml
+++ b/src/main/resources/mapper/TBasicMapper.xml
@@ -4,4 +4,9 @@
         "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.docus.server.archive.mapper.TBasicMapper">
 
+
+    <update id="invalidFileBySource">
+        update docus_archivefile.t_scan_assort set is_del=1
+        where patient_id =#{patientId} and source= #{collectorId}
+    </update>
 </mapper>