浏览代码

分割BUG修复

DESKTOP-6LTVLN7\Liumouren 3 周之前
父节点
当前提交
035d9cde6a

+ 3 - 3
src/main/java/com/skyversation/poiaddr/service/impl/YyskAddressStandardizationServiceImpl.java

@@ -537,7 +537,7 @@ public class YyskAddressStandardizationServiceImpl {
                     }
                 }
                 datas.add(data);
-                if (i != 0 && (i % pageSize == 0 || i == datas.size())) {
+                if (i != 0 && ((i + 1) % pageSize == 0 || (i + 1) == fileData.size())) {
                     dataList.put("data", datas);
                     try {
                         System.out.println(AddressQueryEngine.getInstance().putDataToSJ_Big_Data2(dataList));
@@ -599,7 +599,7 @@ public class YyskAddressStandardizationServiceImpl {
                     }
                 }
                 datas.add(data);
-                if (i != 0 && (i % pageSize == 0 || i == datas.size())) {
+                if (i != 0 && ((i + 1) % pageSize == 0 || (i + 1) == fileData.size())) {
                     dataList.put("data", datas);
                     try {
                         System.out.println(AddressQueryEngine.getInstance().putDataToSJ_Big_Data3(dataList));
@@ -813,7 +813,7 @@ public class YyskAddressStandardizationServiceImpl {
                 dataItem.put("updatetime", getCurrentDateTime());
                 dataItem.put("match_level", yyskAddressStandardization.getMatchLevel());
                 datas.add(dataItem);
-                if (i != 0 && (i % pageSize == 0 || i == listData.size())) {
+                if (i != 0 && ((i + 1) % pageSize == 0 || (i + 1) == listData.size())) {
                     dataList.put("data", datas);
                     try {
                         System.out.println(AddressQueryEngine.getInstance().putDataToSJ_Big_Data(dataList));