Commit 85dd4779 authored by hcing's avatar hcing

fix(jg): 安全追溯表历史数据刷入reginCode和reginName接口调整,避免线程安全问题

parent 56c916fd
...@@ -2159,7 +2159,7 @@ public class DataHandlerServiceImpl { ...@@ -2159,7 +2159,7 @@ public class DataHandlerServiceImpl {
Page<SafetyProblemTracing> page = new Page<>(pageNum++, maxNum); Page<SafetyProblemTracing> page = new Page<>(pageNum++, maxNum);
IPage<SafetyProblemTracing> safetyProblemTracingIPage = safetyProblemTracingService.page(page); IPage<SafetyProblemTracing> safetyProblemTracingIPage = safetyProblemTracingService.page(page);
List<SafetyProblemTracing> safetyProblemTracingList = safetyProblemTracingIPage.getRecords(); List<SafetyProblemTracing> safetyProblemTracingList = safetyProblemTracingIPage.getRecords();
safetyProblemTracingList.parallelStream().forEach(x -> { safetyProblemTracingList.forEach(x -> {
JSONObject region = SafetyProblemTopicMessage.getRegionBySourceTypeAndId(x.getSourceType(), x.getSourceId()); JSONObject region = SafetyProblemTopicMessage.getRegionBySourceTypeAndId(x.getSourceType(), x.getSourceId());
x.setRegionCode(region.getString("regionCode")); x.setRegionCode(region.getString("regionCode"));
x.setRegionName(region.getString("regionName")); x.setRegionName(region.getString("regionName"));
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment