批量处理，每次100

server/src/main/java/com/pica/cloud/wechat/yunqueyilian/server/controller/refresh/RefreshServiceImpl.java

@@ -58,10 +58,10 @@ public class RefreshServiceImpl implements RefreshService {
                         if (CollectionUtils.isNotEmpty(patRealList)) {
                             for (PatPatient patReal : patRealList) {
                                 if (patReal.getId() != null) {
-                                    refreshMapper.deletePat(patReal.getId());
-                                    refreshMapper.deletePatInfo(patReal.getId());
-                                    refreshMapper.deleteDocPat(patReal.getId());
-                                    refreshMapper.deleteDocPatInfo(patReal.getId());
+//                                    refreshMapper.deletePat(patReal.getId());
+//                                    refreshMapper.deletePatInfo(patReal.getId());
+//                                    refreshMapper.deleteDocPat(patReal.getId());
+//                                    refreshMapper.deleteDocPatInfo(patReal.getId());
                                     refreshMapper.updateRepeat(patReal);
                                     refreshIndex++;
                                 }
@@ -114,10 +114,10 @@ public class RefreshServiceImpl implements RefreshService {
                                 wechatPats.add(pat);
                             } else {
                                 if (StringUtil.isNull(pat.getMobilePhone())) {
-                                    refreshMapper.deletePat(pat.getId());
-                                    refreshMapper.deletePatInfo(pat.getId());
-                                    refreshMapper.deleteDocPat(pat.getId());
-                                    refreshMapper.deleteDocPatInfo(pat.getId());
+//                                    refreshMapper.deletePat(pat.getId());
+//                                    refreshMapper.deletePatInfo(pat.getId());
+//                                    refreshMapper.deleteDocPat(pat.getId());
+//                                    refreshMapper.deleteDocPatInfo(pat.getId());
                                 }
                             }
                         }
@@ -142,16 +142,19 @@ public class RefreshServiceImpl implements RefreshService {
         long start = System.currentTimeMillis();
         List<PatPatient> list = refreshMapper.queryDelPatList(id);
         if (CollectionUtils.isNotEmpty(list)) {
-            for (PatPatient pat : list) {
-                refreshMapper.deletePat(pat.getId());
-                refreshMapper.deletePatInfo(pat.getId());
-                refreshMapper.deleteDocPat(pat.getId());
-                refreshMapper.deleteDocPatInfo(pat.getId());
-                refreshMapper.deleteLabel(pat.getId());
-                refreshMapper.deletePlan(pat.getId());
-                refreshMapper.deletePlan2(pat.getId());
-                logger.info("处理数据中delPat：" + pat.getId());
+            for (int i = 0; i < list.size(); i += 100) {
+                int end = list.size() > (i + 100) ? (i + 100) : list.size();
+                List<PatPatient> subList = list.subList(i, end);
+                refreshMapper.deletePat(subList);
+                refreshMapper.deletePatInfo(subList);
+                refreshMapper.deleteDocPat(subList);
+                refreshMapper.deleteDocPatInfo(subList);
+                refreshMapper.deleteLabel(subList);
+                refreshMapper.deletePlan(subList);
+                refreshMapper.deletePlan2(subList);
+                logger.info("处理数据中delPat：" + i);
             }
+
         }
         long end = System.currentTimeMillis();
         logger.info("结束处理数据delPat：消耗：" + (end - start) / 1000 + "【s】");

server/src/main/java/com/pica/cloud/wechat/yunqueyilian/server/mapper/RefreshMapper.java

@@ -22,13 +22,13 @@ public interface RefreshMapper {
 
     Integer validateWechat(@Param("id") Integer id);
 
-    void deletePat(@Param("id") Integer id);
+    void deletePat(List<PatPatient> subList);
 
-    void deletePatInfo(@Param("id") Integer id);
+    void deletePatInfo(List<PatPatient> subList);
 
-    void deleteDocPat(@Param("id") Integer id);
+    void deleteDocPat(List<PatPatient> subList);
 
-    void deleteDocPatInfo(@Param("id") Integer id);
+    void deleteDocPatInfo(List<PatPatient> subList);
 
     void updateRepeat(PatPatient info);
 
@@ -52,10 +52,10 @@ public interface RefreshMapper {
 
     List<PatPatient> queryDelPatList(@Param("id") Integer id);
 
-    void deleteLabel(@Param("id") Integer id);
+    void deleteLabel(List<PatPatient> subList);
 
-    void deletePlan(@Param("id") Integer id);
+    void deletePlan(List<PatPatient> subList);
 
-    void deletePlan2(@Param("id") Integer id);
+    void deletePlan2(List<PatPatient> subList);
 
 }
\ No newline at end of file

server/src/main/resources/mybatis/RefreshMapper.xml

@@ -63,7 +63,11 @@
         set delete_flag = 2,
         modified_id = 3,
         modified_time = now()
-        where id = #{id}
+        where delete_flag = 1
+        and id in
+        <foreach collection="list" index="index" item="item" open="(" close=")" separator=",">
+            #{item.id}
+        </foreach>
     </update>
 
     <update id="deletePatInfo" parameterType="java.lang.Integer" >
@@ -71,7 +75,11 @@
         set delete_flag = 2,
         modified_id = 3,
         modified_time = now()
-        where patient_id = #{id}
+        where  delete_flag = 1
+        and patient_id in
+        <foreach collection="list" index="index" item="item" open="(" close=")" separator=",">
+            #{item.id}
+        </foreach>
     </update>
 
     <update id="deleteDocPat" parameterType="java.lang.Integer" >
@@ -79,7 +87,11 @@
         set delete_flag = 2,
         modified_id = 3,
         modified_time = now()
-        where patient_id = #{id}
+        where  delete_flag = 1
+        and patient_id in
+        <foreach collection="list" index="index" item="item" open="(" close=")" separator=",">
+            #{item.id}
+        </foreach>
     </update>
 
     <update id="deleteDocPatInfo" parameterType="java.lang.Integer" >
@@ -87,7 +99,11 @@
         set delete_flag = 2,
         modified_id = 3,
         modified_time = now()
-        where patient_id = #{id}
+        where  delete_flag = 1
+        and patient_id in
+        <foreach collection="list" index="index" item="item" open="(" close=")" separator=",">
+            #{item.id}
+        </foreach>
     </update>
 
     <update id="updateRepeat" parameterType="com.pica.cloud.wechat.yunqueyilian.server.controller.refresh.PatPatient">
@@ -214,7 +230,11 @@
         set delete_flag = 2,
         modified_id = 3,
         modified_time = now()
-        where patient_id = #{id}
+        where  delete_flag = 1
+        and patient_id in
+        <foreach collection="list" index="index" item="item" open="(" close=")" separator=",">
+            #{item.id}
+        </foreach>
     </update>
 
     <update id="deletePlan" parameterType="java.lang.Integer" >
@@ -222,7 +242,11 @@
         set delete_flag = 2,
         modified_id = 3,
         modified_time = now()
-        where patient_id = #{id}
+        where  delete_flag = 1
+        and patient_id in
+        <foreach collection="list" index="index" item="item" open="(" close=")" separator=",">
+            #{item.id}
+        </foreach>
     </update>
 
     <update id="deletePlan2" parameterType="java.lang.Integer" >
@@ -230,7 +254,11 @@
         set delete_flag = 2,
         modified_id = 3,
         modified_time = now()
-        where patient_id = #{id}
+        where  delete_flag = 1
+        and patient_id in
+        <foreach collection="list" index="index" item="item" open="(" close=")" separator=",">
+            #{item.id}
+        </foreach>
     </update>