批量查询处理

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

@@ -141,7 +141,7 @@ public class RefreshServiceImpl implements RefreshService {
         logger.info("开始处理数据delPat：");
         long start = System.currentTimeMillis();
         List<PatPatient> list = refreshMapper.queryDelPatList(id);
-        if (CollectionUtils.isNotEmpty(list)) {
+        while (CollectionUtils.isNotEmpty(list)) {
             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);
@@ -154,7 +154,8 @@ public class RefreshServiceImpl implements RefreshService {
                 refreshMapper.deletePlan2(subList);
                 logger.info("处理数据中delPat：" + i);
             }
-
+            id = list.get(list.size() - 1).getId();
+            list = refreshMapper.queryDelPatList(id);
         }
         long end = System.currentTimeMillis();
         logger.info("结束处理数据delPat：消耗：" + (end - start) / 1000 + "【s】");

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

@@ -223,6 +223,8 @@
             mobile_phone as mobilePhone
         from pat_patient_del_0310
         where id > #{id}
+        order by id
+        limit 10000
     </select>
 
     <update id="deleteLabel" parameterType="java.lang.Integer" >