删除出院时间为空的数据

src/main/java/com/docus/server/archive/mapper/TBasicMapper.java

@@ -21,6 +21,8 @@ public interface TBasicMapper {
 
     int insertBatch(@Param("basicList") List<TBasic> basicList);
 
+    int deleteBatch(@Param("jzhs") List<String> jzhs);
+
     int updateBatch(@Param("basicList") List<TBasic> updateList);
 
     int updateExtend(@Param("basicList") List<TBasic> basicList);

src/main/java/com/docus/server/archive/service/impl/MzsyPatientInfoSyncServiceImpl.java

@@ -96,9 +96,14 @@ public class MzsyPatientInfoSyncServiceImpl implements PatientInfoSyncService {
         Map<String, TBasic> existsJzhBasicMap = existsBasicList.stream().collect(Collectors.toMap(TBasic::getJzh, Function.identity()));
         List<TBasic> insertBasicList = new ArrayList<>();
         List<TBasic> updateBasicList = new ArrayList<>();
+        List<String> deleteList = new ArrayList<>();
         List<TBasic> leaveMethodList = new ArrayList<>();
         for (TBasic iuBasic : iuBasicList) {
             if (existsJzhBasicMap.containsKey(iuBasic.getJzh())) {
+                if (ObjectUtil.isEmpty(iuBasic.getDisDate())) {
+                    deleteList.add(iuBasic.getJzh());
+                    continue;
+                }
                 TBasic tBasic = existsJzhBasicMap.get(iuBasic.getJzh());
                 tBasic.setName(iuBasic.getName());
                 tBasic.setInpatientNo(iuBasic.getInpatientNo());
@@ -142,7 +147,10 @@ public class MzsyPatientInfoSyncServiceImpl implements PatientInfoSyncService {
             }
             insertBasicList.add(iuBasic);
         }
-
+        if (Func.isNotEmpty(deleteList)) {
+            tBasicMapper.deleteBatch(deleteList);
+            syncZkInfo(insertBasicList);
+        }
         if (Func.isNotEmpty(insertBasicList)) {
             tBasicMapper.insertBatch(insertBasicList);
             syncZkInfo(insertBasicList);

src/main/resources/mapper/MzsyPatientInfoViewMapper.xml

@@ -9,6 +9,7 @@
         FROM
             (select ROW_NUMBER()over(order by jzh) as ROWNUMBER,* from dbo.V_JSWZH_BASE_ZL
             where CONVERT(DATETIME, cyrq) > #{cyrqStart}
+            or CONVERT(DATETIME, updated_time) > #{cyrqStart}
             ) AS v
         WHERE v.ROWNUMBER BETWEEN ${(pageNum-1)*pageSize+1}
         AND ${pageNum*pageSize}

src/main/resources/mapper/TBasicMapper.xml

@@ -64,6 +64,13 @@
     <delete id="delZkInfo">
         delete from docus_medicalrecord.t_basic_zk_info where patient_id = #{patientId}
     </delete>
+    <delete id="deleteBatch">
+        delete from docus_medicalrecord.t_basic
+        where jzh in
+        <foreach collection="jzhs" item="jzh" open="(" close=")" separator=",">
+        #{jzh}
+        </foreach>
+    </delete>
 
     <select id="getByJzh" resultType="com.docus.server.archive.entity.TBasic">
         select `patient_id`, `admiss_times`, `inpatient_no`,  `name`, `name_spell`,