|
|
@@ -29,7 +29,7 @@ public class 松江地名地址库治理 {
|
|
|
AddressTools.getInstance().initSHQH();
|
|
|
|
|
|
// 任务总数
|
|
|
- int totalTasks = 412;
|
|
|
+ int totalTasks = 6;
|
|
|
// 最大线程数
|
|
|
int maxThreads = 6;
|
|
|
|
|
|
@@ -79,6 +79,7 @@ public class 松江地名地址库治理 {
|
|
|
|
|
|
// executor.execute(() ->{
|
|
|
|
|
|
+ int jj = 1;
|
|
|
List<Map<String, Object>> result = new ArrayList<>();
|
|
|
for (Map<String, Object> map : list) {
|
|
|
String address = map.get(addressParam) + "";
|
|
|
@@ -120,6 +121,7 @@ public class 松江地名地址库治理 {
|
|
|
addressN = addressN.replace("中山", "中山街道");
|
|
|
}
|
|
|
System.out.println("《《《 查询地址是： " + addressN + " 》》》");
|
|
|
+ System.out.println("<<<<<<< 当前条数是： " + jj + " 条 >>>>>>>>>");
|
|
|
|
|
|
AddressResult addressResult = AddressQueryEngine.getInstance().szxSearchByName(addressN);// 使用四中心接口
|
|
|
if(addressResult == null || addressResult.getData() == null || addressResult.getData().size() < 1){
|
|
|
@@ -154,7 +156,7 @@ public class 松江地名地址库治理 {
|
|
|
map.put("residentialCommittee", "");
|
|
|
resultYc(map, address, result);
|
|
|
}
|
|
|
-
|
|
|
+ jj ++;
|
|
|
|
|
|
// if(result.size() % 10000 == 9999){
|
|
|
// System.out.println("<<<<<<< 写入数据，第" + num[0] + " 条 >>>>>>>>>");
|
|
|
@@ -168,6 +170,7 @@ public class 松江地名地址库治理 {
|
|
|
// }
|
|
|
//
|
|
|
// }
|
|
|
+
|
|
|
}
|
|
|
System.out.println("<<<<<<< 写入数据，第" + num + " 条 >>>>>>>>>");
|
|
|
try {
|
zhanghan