查询基础数据修改

src/main/java/com/docus/server/collect/entity/TBasic.java

@@ -1,5 +1,6 @@
 package com.docus.server.collect.entity;
 
+import com.docus.server.collect.service.dto.ReportFileInfoDTO;
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
@@ -32,4 +33,17 @@ public class TBasic {
     private String name;
     @ApiModelProperty(value = "住院id")
     private String admissId;
+    @ApiModelProperty(value = "省中医患者主索引号")
+    private String empId;
+
+    public TBasic() {
+    }
+
+    public TBasic(ReportFileInfoDTO fileInfoDTO) {
+        this.jzh = fileInfoDTO.getJzh();
+        this.patientId = fileInfoDTO.getPatientId();
+        this.inpatientNo = fileInfoDTO.getInpatientNo();
+        this.admissTimes = fileInfoDTO.getAdmisstimes();
+        ;
+    }
 }

src/main/java/com/docus/server/collect/infrastructure/dao/DownloadTaskDao.java

@@ -3,25 +3,27 @@ package com.docus.server.collect.infrastructure.dao;
 import com.docus.infrastructure.core.db.dao.IBaseDao;
 import com.docus.server.collect.entity.DownloadTask;
 import com.docus.server.collect.entity.TBasic;
-import com.docus.server.collect.service.dto.ReportFileInfoDTO;
 
 import java.util.List;
 
 /**
  * 下载任务表-数据访问接口
+ *
  * @author wyb
  */
 public interface DownloadTaskDao extends IBaseDao<DownloadTask> {
     /**
-     * 根据上报文件信息中的患者信息，查询患者基础数据
+     * 根据患者信息，查询患者基础数据
-     * @param fileInfoDTO 上报文件信息
+     *
+     * @param tBasic 患者基础信息
      * @return 患者基础数据
      */
-    List<TBasic> getBasicInfo(ReportFileInfoDTO fileInfoDTO);
+    List<TBasic> getBasicInfo(TBasic tBasic);
 
 
     /**
      * 从下载任务表中获取下载任务id，来源，采文件唯一标识，和患者信息
+     *
      * @param downloadTask 下载任务
      * @return 下载任务id（也是文件id）
      */
@@ -29,17 +31,19 @@ public interface DownloadTaskDao extends IBaseDao<DownloadTask> {
 
     /**
      * 根据病案的来源，病案文件的唯一标识，从文件表得到文件下载任务id（也是文件id）
+     *
      * @param patientId 病案主键
-     * @param source 来源
+     * @param source    来源
      * @param serialNum 文件唯一标识
      * @return 下载任务id（也是文件id）
      */
     Long getDownloadTaskIdFromSanAssort(String patientId, String source, String serialNum);
 
     /**
-     *  根据病案的来源，病案文件的唯一标识，从下载记录表得到文件下载任务id（也是文件id）
+     * 根据病案的来源，病案文件的唯一标识，从下载记录表得到文件下载任务id（也是文件id）
+     *
      * @param patientId 病案主键
-     * @param source 来源
+     * @param source    来源
      * @param serialNum 文件唯一标识
      * @return 下载任务id（也是文件id）
      */

src/main/java/com/docus/server/collect/infrastructure/dao/impl/DownloadTaskDaoImpl.java

@@ -7,7 +7,6 @@ import com.docus.server.collect.entity.DownloadTask;
 import com.docus.server.collect.entity.TBasic;
 import com.docus.server.collect.infrastructure.dao.DownloadTaskDao;
 import com.docus.server.collect.infrastructure.mapper.DownloadTaskMapper;
-import com.docus.server.collect.service.dto.ReportFileInfoDTO;
 import org.springframework.stereotype.Repository;
 
 import java.util.List;
@@ -20,8 +19,8 @@ import java.util.List;
 @Repository
 public class DownloadTaskDaoImpl extends BaseDaoImpl<DownloadTaskMapper, DownloadTask> implements DownloadTaskDao {
     @Override
-    public List<TBasic> getBasicInfo(ReportFileInfoDTO fileInfoDTO) {
+    public List<TBasic> getBasicInfo(TBasic basic) {
-        return baseMapper.getBasicInfo(fileInfoDTO);
+        return baseMapper.getBasicInfo(basic);
     }
 
     @Override

src/main/java/com/docus/server/collect/infrastructure/mapper/DownloadTaskMapper.java

@@ -3,7 +3,6 @@ package com.docus.server.collect.infrastructure.mapper;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.docus.server.collect.entity.DownloadTask;
 import com.docus.server.collect.entity.TBasic;
-import com.docus.server.collect.service.dto.ReportFileInfoDTO;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 
@@ -12,12 +11,12 @@ import java.util.List;
 @Mapper
 public interface DownloadTaskMapper extends BaseMapper<DownloadTask> {
     /**
-     * 根据上报文件的患者信息获取基础病案信息 from    `docus_medicalrecord`.`t_basic`
+     * 根据患者信息获取基础病案信息 from    `docus_medicalrecord`.`t_basic`
      *
-     * @param fileInfoDTO 上报文件信息
+     * @param tBasic 患者基础信息
      * @return 病案基础信息
      */
-    List<TBasic> getBasicInfo(@Param("dto") ReportFileInfoDTO fileInfoDTO);
+    List<TBasic> getBasicInfo(@Param("basic") TBasic tBasic);
     /**
      * 根据病案的来源，病案文件的唯一标识，从文件表得到文件下载任务id（也是文件id）
      * @param patientId 病案主键

src/main/java/com/docus/server/collect/service/impl/FileReportServiceImpl.java

@@ -42,8 +42,9 @@ public class FileReportServiceImpl implements FileReportService {
 
     @Override
     public void saveDownloadTaskAndReport(ReportFileInfoDTO fileInfoDTO) {
+        TBasic basic = new TBasic(fileInfoDTO);
         // 查询基础数据，更新新的病案信息
-        List<TBasic> tBasics = downloadTaskDao.getBasicInfo(fileInfoDTO);
+        List<TBasic> tBasics = downloadTaskDao.getBasicInfo(basic);
         // 如果找到患者基础数据，并且刚好为1条
         if (CollUtil.isNotEmpty(tBasics) && tBasics.size() == 1) {
             TBasic tBasic = tBasics.get(0);

src/main/resources/mapper/TBasicMapper.xml

@@ -21,16 +21,19 @@
         WHERE
             is_cancel=0
             <if test="dto.patientId != null and dto.patientId != ''">
-                and `patient_id` = #{dto.patientId}
+                and `patient_id` = #{basic.patientId}
             </if>
             <if test="dto.jzh != null and dto.jzh != ''">
-                and `jzh` = #{dto.jzh}
+                and `jzh` = #{basic.jzh}
+            </if>
+            <if test="basic.empId != null and basic.empId != ''">
+                and `emp_id` = #{basic.empId}
             </if>
             <if test="dto.inpatientNo != null and dto.inpatientNo != ''">
-                and `inpatient_no` = #{dto.inpatientNo}
+                and `inpatient_no` = #{basic.inpatientNo}
             </if>
             <if test="dto.admisstimes != null">
-                and `admiss_times` = #{dto.admisstimes}
+                and `admiss_times` = #{basic.admissTimes}
             </if>
         limit 2
     </select>