diff --git a/capability/src/main/java/com/sdm/capability/service/impl/FlowServiceImpl.java b/capability/src/main/java/com/sdm/capability/service/impl/FlowServiceImpl.java index bf750d32..90c6b767 100644 --- a/capability/src/main/java/com/sdm/capability/service/impl/FlowServiceImpl.java +++ b/capability/src/main/java/com/sdm/capability/service/impl/FlowServiceImpl.java @@ -122,7 +122,6 @@ public class FlowServiceImpl extends BaseService implements IFlowService { } req.bindTaskkPoolItem.add(bindTaskPoolItem); } - simuluationTaskPoolFeignClient.updateTaskAndFlowTemplate(req); } @@ -358,7 +357,27 @@ public class FlowServiceImpl extends BaseService implements IFlowService { if(bindResponse.isSuccess()) { List flowBindTaskPoolItems = (List)bindResponse.getData(); + //过滤出工况库中最新的版本对流程模版的绑定关系 + Map latestPoolBindRelateMap = new HashMap<>(); for(FlowBindTaskPoolItem flowBindTaskPoolItem : flowBindTaskPoolItems) + { + String poolName = flowBindTaskPoolItem.poolName; + String version = flowBindTaskPoolItem.version; + FlowBindTaskPoolItem savedPoolItem = latestPoolBindRelateMap.get(poolName); + if(savedPoolItem == null) + { + latestPoolBindRelateMap.put(poolName,flowBindTaskPoolItem); + } + else + { + String savedVersion = savedPoolItem.version; + if(version.compareTo(savedVersion) > 0) + { + latestPoolBindRelateMap.put(poolName,flowBindTaskPoolItem); + } + } + } + for(FlowBindTaskPoolItem flowBindTaskPoolItem : latestPoolBindRelateMap.values()) { SimulationFlowTaskBindInfo flowTaskBindInfo = new SimulationFlowTaskBindInfo(); flowTaskBindInfo.simulationPoolName = flowBindTaskPoolItem.poolName;