汇聚平台限制了传输条数，系统拆分条数做兼容处理

pom.xml

@@ -97,6 +97,11 @@
             <artifactId>cxf-rt-transports-http</artifactId>
             <version>3.1.4</version>
         </dependency>
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-collections4</artifactId>
+            <version>4.4</version>
+        </dependency>
 
     </dependencies>
 

src/main/java/com/reconciliation/recfj/service/RecService.java

@@ -9,6 +9,8 @@ import com.reconciliation.recfj.mapper.RecMapper;
 import com.reconciliation.recfj.util.DateUtils;
 import com.reconciliation.recfj.util.ExcelUtils;
 import com.reconciliation.recfj.util.XmlBuilderUtils;
+import org.apache.commons.collections4.ListUtils;
+import org.apache.commons.compress.utils.Lists;
 import org.apache.ibatis.session.ExecutorType;
 import org.apache.ibatis.session.SqlSession;
 import org.apache.ibatis.session.SqlSessionFactory;
@@ -103,11 +105,17 @@ public class RecService {
                 session.close();
             }
         }
+        if (CollectionUtils.isEmpty(list)) {
+            return ReturnValue.ok("无数据");
+        }
         //将数据写到excel文件: RecData_20190701140506.xlsx
         writeDataToExcel(list);
+        //由于推送数据到汇聚平台限制每次推送最多500条，将list分400条子list推送到汇聚平台
+        List<List<RecExcel>> partitionList = ListUtils.partition(list, 400);
         //将数据封装成XML格式
         String type = "add";
-        List<RecXml> recXmlList = packRecXmlData(list, type);
+        partitionList.forEach(subList -> {
+            List<RecXml> recXmlList = packRecXmlData(subList, type);
             String xmlStr = XmlBuilderUtils.buildXml(recXmlList);
             // 发送到汇聚平台
             boolean flag = sendWebService.pushXmlData(xmlStr);
@@ -118,6 +126,7 @@ public class RecService {
                 rtv.setSuccess(false);
                 rtv.setMsg("发送到汇聚平台失败！");
             }
+        });
         return rtv;
     }