fix(jg): 压力管道管道长度

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/service/impl/DataHandlerServiceImpl.java

@@ -2507,7 +2507,7 @@ public class    DataHandlerServiceImpl {
                 .select(BaseEntity::getSequenceNbr)
         );
         watch.start("安装告知" + notices.size());
-        notices.forEach(n->{
+        notices.parallelStream().forEach(n->{
             JSONObject jsonObject = commonServiceImpl.queryHistoryData(n.getSequenceNbr());
             if(jsonObject != null){
                 JSONArray jsonArray = jsonObject.getJSONArray("deviceList");
@@ -2530,7 +2530,7 @@ public class    DataHandlerServiceImpl {
                 .ne(JgUseRegistration::getProjectContraptionId, "")
                 .select(BaseEntity::getSequenceNbr));
         watch.start("使用登记" + useRegistrations.size() );
-        useRegistrations.forEach(u->{
+        useRegistrations.parallelStream().forEach(u->{
             JSONObject jsonObject = commonServiceImpl.queryHistoryData(u.getSequenceNbr());
             if(jsonObject != null){
                 String pipelistKey;
@@ -2561,7 +2561,7 @@ public class    DataHandlerServiceImpl {
                 .ne(JgChangeRegistrationReform::getProjectContraptionId, "")
                 .select(JgChangeRegistrationReform::getApplyNo));
         watch.start("改造变更登记" + changeRegistrationReforms.size());
-        changeRegistrationReforms.forEach(u->{
+        changeRegistrationReforms.parallelStream().forEach(u->{
             JSONObject jsonObject = commonServiceImpl.queryHistoryData(u.getApplyNo());
             if(jsonObject != null){
                 JSONArray jsonArray = jsonObject.getJSONArray("equipmentLists");
@@ -2586,7 +2586,7 @@ public class    DataHandlerServiceImpl {
                 .ne(JgReformNotice::getProjectContraptionId, "")
                 .select(BaseEntity::getSequenceNbr));
         watch.start("改造告知" + reformNotices.size());
-        reformNotices.forEach(u->{
+        reformNotices.parallelStream().forEach(u->{
             JSONObject jsonObject = commonServiceImpl.queryHistoryData(u.getSequenceNbr());
             if(jsonObject != null){
                 JSONArray jsonArray = jsonObject.getJSONArray("deviceList");