|
@@ -175,14 +175,12 @@ public class CtrlService {
|
|
public void processJJYJCtrl(String taskId, List<Map<String, Object>> clueList, List<String> resourceIdList, List<String> areaIdList) {
|
|
public void processJJYJCtrl(String taskId, List<Map<String, Object>> clueList, List<String> resourceIdList, List<String> areaIdList) {
|
|
ExecutorService executorService = Executors.newFixedThreadPool(Constants.NUM_1);
|
|
ExecutorService executorService = Executors.newFixedThreadPool(Constants.NUM_1);
|
|
executorService.execute(() -> {
|
|
executorService.execute(() -> {
|
|
- for (String resourceId : resourceIdList) {
|
|
|
|
- // 根据数据资源业务ID读取配置文件中对应的数据资源标识符和数据资源编码
|
|
|
|
- String[] resourceInfoArr = CommonUtil.getConfValueByKey("SJZYYWID_" + resourceId).split(",");
|
|
|
|
|
|
+ for (String resourceCode : resourceIdList) {
|
|
for (Map<String, Object> clueMap : clueList) {
|
|
for (Map<String, Object> clueMap : clueList) {
|
|
String clue = String.valueOf(clueMap.get("clue"));
|
|
String clue = String.valueOf(clueMap.get("clue"));
|
|
String clueType = String.valueOf(clueMap.get("clueType"));
|
|
String clueType = String.valueOf(clueMap.get("clueType"));
|
|
if(clueCodeIdCard.equals(clueType)){
|
|
if(clueCodeIdCard.equals(clueType)){
|
|
- sameTravelService.callFHUniQueryService(taskId, clue, resourceInfoArr[0], resourceInfoArr[1]);
|
|
|
|
|
|
+ sameTravelService.callFHUniQueryService(taskId, clue, resourceCode, CommonUtil.getConfValueByKey(resourceCode));
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|