fix(#732): zhaoyun (文件合入)

healthlink-his-server/healthlink-his-application/src/main/java/com/healthlink/his/web/orderclosedloop/appservice/impl/OrderClosedLoopAppServiceImpl.java

@@ -174,7 +174,12 @@ public class OrderClosedLoopAppServiceImpl implements IOrderClosedLoopAppService
 
     private Map<String, Object> getUnclosedWarnings(Integer pageNum, Integer pageSize) {
         Map<String, Object> result = new HashMap<>();
-        List<Map<String, Object>> rows = recordMapper.selectUnclosedWarnings();
+        // 使用分页查询避免全量拉取导致卡死
+        int pn = (pageNum != null && pageNum > 0) ? pageNum : 1;
+        int ps = (pageSize != null && pageSize > 0) ? pageSize : 10;
+        int offset = (pn - 1) * ps;
+        long total = recordMapper.countUnclosedWarnings();
+        List<Map<String, Object>> rows = recordMapper.selectUnclosedWarningsPaged(ps, offset);
         java.text.SimpleDateFormat sdf = new java.text.SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
         List<Map<String, Object>> warnings = new ArrayList<>();
         for (Map<String, Object> row : rows) {
@@ -195,6 +200,9 @@ public class OrderClosedLoopAppServiceImpl implements IOrderClosedLoopAppService
             warnings.add(warning);
         }
         result.put("records", warnings);
+        result.put("total", total);
+        result.put("pageNum", pn);
+        result.put("pageSize", ps);
         return result;
     }
 

healthlink-his-server/healthlink-his-domain/src/main/java/com/healthlink/his/orderclosedloop/mapper/OrderExecuteRecordMapper.java

@@ -41,6 +41,11 @@ public interface OrderExecuteRecordMapper extends BaseMapper<OrderExecuteRecord>
             "GROUP BY m.doctor_name ORDER BY totalOrders DESC")
     List<Map<String, Object>> selectGroupByDoctor();
 
+    @Select("SELECT COUNT(*) FROM order_execute_record e " +
+            "WHERE e.delete_flag = '0' " +
+            "AND e.execute_status IN ('pending', 'in_progress', 'overdue', 'executing')")
+    long countUnclosedWarnings();
+
     @Select("SELECT e.order_no AS orderNo, e.patient_name AS patientName, e.order_type AS orderType, " +
             "COALESCE(m.department_name, '未知') AS department, " +
             "COALESCE(m.doctor_name, '未知') AS doctorName, " +
@@ -49,6 +54,7 @@ public interface OrderExecuteRecordMapper extends BaseMapper<OrderExecuteRecord>
             "LEFT JOIN order_main m ON e.order_no = m.order_no AND m.delete_flag = '0' " +
             "WHERE e.delete_flag = '0' " +
             "AND e.execute_status IN ('pending', 'in_progress', 'overdue', 'executing') " +
-            "ORDER BY e.create_time DESC")
-    List<Map<String, Object>> selectUnclosedWarnings();
+            "ORDER BY e.create_time DESC " +
+            "LIMIT #{limit} OFFSET #{offset}")
+    List<Map<String, Object>> selectUnclosedWarningsPaged(@Param("limit") int limit, @Param("offset") int offset);
 }