更新采集任务的信息

src/main/java/com/docus/server/report/mapper/AfCollectTaskMapper.java

@@ -24,4 +24,13 @@ public interface AfCollectTaskMapper {
      * @return 任务信息
      */
     AfCollectTask getTaskById(@Param("id") Long taskId);
+
+    /**
+     * 更新新提交的任务的文件名和唯一号
+     * @param id 任务id
+     * @param fileName 文件名
+     * @param serialnum 文件唯一
+     * @return 数据库操作行
+     */
+    int updateNewSubmit(@Param("id") Long id,@Param("c2")  String fileName,@Param("c1")  String serialnum);
 }

src/main/java/com/docus/server/report/service/impl/ReportServiceImpl.java

@@ -176,6 +176,8 @@ public class ReportServiceImpl implements ReportService {
             afCollectTask.setPatientId(patientId);
             afCollectTask.setCreateTime(new Date());
             collectTaskMapper.saveTask(afCollectTask);
+        }else{
+            collectTaskMapper.updateNewSubmit(afCollectTask.getId(),afReportRecord.getFileName(),reportDto.getSerialnum());
         }
         // 都成功后发布下载事件
         applicationContext.publishEvent(new ThreePartyPushReportDownEvent(this, afReportRecord.getTaskId()));

src/main/resources/mapper/AfCollectTaskMapper.xml

@@ -8,6 +8,14 @@
                                                           `state`, `C1`,`C2`, `C3`,`create_time`)
         VALUES (#{task.id}, #{task.patientId}, #{task.sysflag}, '0', #{task.C1}, #{task.C2}, #{task.C3},#{task.createTime});
     </insert>
+    <update id="updateNewSubmit">
+        update `docus_archivefile`.`af_collect_task`
+        set c1=#{c1},
+         c2=#{c2},
+            state=0,
+            recollect_time=now()
+        where `id` = #{id}
+    </update>
 
     <select id="getTaskById" resultType="com.docus.server.report.entity.AfCollectTask">
         select *