feat: 获取该批次的DAG图数据 支持仅直接关系

apps/wpm/services.py

@@ -1017,27 +1017,29 @@ def mlog_audit_end(ticket: Ticket):
     mlog_submit(ins, ticket.create_by, now)
 
 
-def get_batch_dag(batch_number: str, version=1):
+def get_batch_dag(batch_number: str, method="full"):
-        try:
+    try:
-            batch_ins = BatchSt.objects.get(batch=batch_number, version=version)
+        batch_ins = BatchSt.objects.get(batch=batch_number, version=1)
-        except Exception:
+    except Exception:
-            raise ParseError("该批次号未构建关系链")
+        raise ParseError("该批次号未构建关系链")
-        # 收集所有相关批次和边
+
+    r_dict = {
+        "split": "分",
+        "merge": "合"
+    }
+
+    if method == "full":
+        # 完整DAG模式 - 收集所有相关批次和边（原逻辑）
         nodes_set = {batch_ins.id}
         edges = []
         prev_size = 0
 
-        r_dict = {
-            "split": "分",
-            "merge": "合"
-        }
         while len(nodes_set) > prev_size:
             prev_size = len(nodes_set)
-            # 查询所有与当前批次相关的记录（作为source或target）
             logs = BatchLog.objects.filter(Q(source__id__in=nodes_set) | Q(target__id__in=nodes_set)).select_related(
                 "source", "target"
             ).order_by("update_time")
-            # 处理每条记录，扩展节点和边
+            
             for log in logs:
                 source = log.source.id
                 target = log.target.id
@@ -1047,33 +1049,42 @@ def get_batch_dag(batch_number: str, version=1):
                     'target': target,
                     "handover": log.handover.id if log.handover else None,
                     "mlog": log.mlog.id if log.mlog else None,
-                    'label': r_dict.get(log.relation_type, ""),  # 使用relation_type作为边的标签
+                    'label': r_dict.get(log.relation_type, ""),
                 })
-        
+
-        # 去重边
+    elif method == "direct":
-        # unique_edges = {}
+        # 直接关系模式 - 只查询直接相连的批次
-        # for edge in edges:
+        nodes_set = {batch_ins.id}
-        #     key = (edge['source'], edge['target'])
+        edges = []
-        #     if key not in unique_edges:
+
-        #         unique_edges[key] = edge
+        # 查询作为source或target的直接关系
-        
+        logs = BatchLog.objects.filter(Q(source__id=batch_ins.id) | Q(target__id=batch_ins.id)).select_related(
-        # 将批次号排序
+            "source", "target"
-        nodes_qs = BatchSt.objects.filter(id__in=nodes_set).order_by('update_time')
+        ).order_by("update_time")
-        
+        
-        # batch_to_id = {batch: idx for idx, batch in enumerate(nodes_list)}
+        for log in logs:
-        # 构建节点数据，默认使用'rect'形状
+            source = log.source.id
-        nodes = [{
+            target = log.target.id
-            'id': item.id,
+            nodes_set.update([source, target])
-            'label': item.batch,
+            edges.append({
-            'shape': 'rect'  # 可根据业务需求调整形状
+                'source': source,
-        } for item in nodes_qs]
+                'target': target,
-        
+                "handover": log.handover.id if log.handover else None,
-        # 构建边数据
+                "mlog": log.mlog.id if log.mlog else None,
-        # edges_converted = [{
+                'label': r_dict.get(log.relation_type, ""),
-        #     'source': edge['source'],
+            })
-        #     'target': edge['target'],
+
-        #     'label': edge['label']
+    else:
-        # } for edge in unique_edges.values()]
+        raise ParseError("不支持的查询方法，请使用'full'或'direct'")
-        
+
-        return {'nodes': nodes, 'edges': edges}
+    # 将批次号排序
+    nodes_qs = BatchSt.objects.filter(id__in=nodes_set).order_by('update_time')
+    
+    nodes = [{
+        'id': item.id,
+        'label': item.batch,
+        'shape': 'rect'
+    } for item in nodes_qs]
+
+    return {'nodes': nodes, 'edges': edges}
 

apps/wpm/views.py

@@ -927,10 +927,10 @@ class BatchLogViewSet(ListModelMixin, CustomGenericViewSet):
         获取该批次的DAG图数据
         """
         batch = request.data.get("batch", None)
-        version = request.data.get("version", 1)
+        method = request.data.get("method", "full")
         if not batch:
             raise ParseError("缺少batch参数")
-        return Response(get_batch_dag(batch, version))
+        return Response(get_batch_dag(batch, method))
     
     @action(methods=['post'], detail=False, perms_map={'post': '*'}, serializer_class=Serializer)
     def batches_to(self, request, *args, **kwargs):