|
|
@@ -46,7 +46,6 @@ import java.util.stream.Collectors;
|
|
|
*/
|
|
|
@Service
|
|
|
@Slf4j
|
|
|
-@Transactional
|
|
|
public class SynchronizationServiceImpl implements SynchronizationService {
|
|
|
|
|
|
@Value("${synchronization.host}")
|
|
|
@@ -175,7 +174,7 @@ public class SynchronizationServiceImpl implements SynchronizationService {
|
|
|
.toList();
|
|
|
Map<String, EquipPipeSaveReqVO> equipPipe = equipPipeService.getEquipPipeByNo(projectNos);
|
|
|
|
|
|
- list.parallelStream().forEach(pipeDto -> {
|
|
|
+ list.forEach(pipeDto -> {
|
|
|
// 当前管道下的管线
|
|
|
List<PipeDetailDto> pipeDetailDtoList = pipeDetailDtoS.stream()
|
|
|
.filter(pipeDetailDto -> pipeDetailDto.getPIPEEQUIPMENTID().equals(pipeDto.getID()))
|