model.py 35 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027
  1. """
  2. 数据模型核心业务逻辑模块
  3. 本模块包含了数据模型相关的所有核心业务逻辑函数,包括:
  4. - 数据模型的创建、更新、删除
  5. - 数据模型与数据资源、元数据之间的关系处理
  6. - 数据模型血缘关系管理
  7. - 数据模型图谱生成
  8. - 数据模型层级计算等功能
  9. """
  10. import math
  11. import threading
  12. from concurrent.futures import ThreadPoolExecutor
  13. import pandas as pd
  14. from py2neo import Relationship
  15. import logging
  16. import json
  17. from app.core.graph.graph_operations import relationship_exists
  18. from app.core.graph.graph_operations import connect_graph,create_or_get_node,get_node
  19. from app.services.neo4j_driver import neo4j_driver
  20. from app.core.meta_data import get_formatted_time, handle_id_unstructured
  21. from app.core.common import delete_relationships, update_or_create_node, get_node_by_id_no_label
  22. from app.core.data_resource.resource import get_node_by_id
  23. # 根据child关系计算数据模型当前的level自动保存
  24. def calculate_model_level(id):
  25. """
  26. 根据child关系计算数据模型当前的level并自动保存
  27. Args:
  28. id: 数据模型的节点ID(整数)
  29. Returns:
  30. None
  31. """
  32. # 确保id是整数类型
  33. node_id = int(id) if id is not None else None
  34. cql = """
  35. MATCH (start_node:data_model)
  36. WHERE id(start_node) = $nodeId
  37. CALL {
  38. WITH start_node
  39. OPTIONAL MATCH path = (start_node)-[:child*]->(end_node)
  40. RETURN length(path) AS level
  41. }
  42. WITH coalesce(max(level), 0) AS max_level
  43. RETURN max_level
  44. """
  45. with connect_graph().session() as session:
  46. result = session.run(cql, nodeId=node_id)
  47. record = result.single()
  48. data = record["max_level"] if record and "max_level" in record else 0
  49. # 更新level属性
  50. update_query = """
  51. MATCH (n:data_model)
  52. WHERE id(n) = $nodeId
  53. SET n.level = $level
  54. RETURN n
  55. """
  56. with connect_graph().session() as session:
  57. session.run(update_query, nodeId=node_id, level=data)
  58. # 处理数据模型血缘关系
  59. def handle_model_relation(resource_ids):
  60. """
  61. 处理数据模型血缘关系
  62. Args:
  63. resource_ids: 数据资源ID
  64. Returns:
  65. 血缘关系数据
  66. """
  67. query = """
  68. MATCH (search:data_resource)-[:connection]->(common_node:meta_node)<-[:connection]-(connect:data_resource)
  69. WHERE id(search) = $resource_Ids
  70. WITH search, connect, common_node
  71. MATCH (search)-[:connection]->(search_node:meta_node)
  72. WITH search, connect, common_node, collect(DISTINCT id(search_node)) AS search_nodes
  73. MATCH (connect)-[:connection]->(connect_node:meta_node)
  74. WITH search, connect, common_node, search_nodes, collect(DISTINCT id(connect_node)) AS connect_nodes
  75. WITH search, connect, search_nodes, connect_nodes, collect(DISTINCT id(common_node)) AS common_nodes
  76. // 剔除 search_nodes 和 connect_nodes 中包含在 common_nodes 中的内容
  77. WITH search, connect, common_nodes,
  78. [node IN search_nodes WHERE NOT node IN common_nodes] AS filtered_search_nodes,
  79. [node IN connect_nodes WHERE NOT node IN common_nodes] AS filtered_connect_nodes
  80. RETURN id(connect) as blood_resources, common_nodes,
  81. filtered_search_nodes as origin_nodes, filtered_connect_nodes as blood_nodes
  82. """
  83. with connect_graph().session() as session:
  84. result = session.run(query, resource_Ids=resource_ids)
  85. return result.data()
  86. # 创建一个数据模型节点
  87. def handle_data_model(data_model, result_list, result, receiver):
  88. """
  89. 创建一个数据模型节点
  90. Args:
  91. data_model: 数据模型名称
  92. result_list: 数据模型英文名列表
  93. result: 序列化的ID列表
  94. receiver: 接收到的请求参数
  95. Returns:
  96. tuple: (id, data_model_node)
  97. """
  98. try:
  99. # 添加数据资源 血缘关系的字段 blood_resource
  100. data_model_en = result_list[0] if result_list and len(result_list) > 0 else ""
  101. receiver['id_list'] = result
  102. add_attribute = {
  103. 'time': get_formatted_time(),
  104. 'en_name': data_model_en
  105. }
  106. receiver.update(add_attribute)
  107. data_model_node = get_node('data_model', name=data_model) or create_or_get_node('data_model', **receiver)
  108. # 安全地处理子节点关系
  109. child_list = receiver.get('childrenId', [])
  110. for child_id in child_list:
  111. child_node = get_node_by_id_no_label(child_id)
  112. if child_node and not relationship_exists(data_model_node, 'child', child_node):
  113. with connect_graph().session() as session:
  114. session.execute_write(
  115. lambda tx: tx.run(
  116. "MATCH (a), (b) WHERE id(a) = $a_id AND id(b) = $b_id CREATE (a)-[:child]->(b)",
  117. a_id=data_model_node.id, b_id=child_node.id
  118. )
  119. )
  120. # 根据传入参数id,和数据标签建立关系
  121. if receiver.get('tag'):
  122. tag = get_node_by_id('data_label', receiver['tag'])
  123. if tag and not relationship_exists(data_model_node, 'label', tag):
  124. with connect_graph().session() as session:
  125. session.execute_write(
  126. lambda tx: tx.run(
  127. "MATCH (a), (b) WHERE id(a) = $a_id AND id(b) = $b_id CREATE (a)-[:label]->(b)",
  128. a_id=data_model_node.id, b_id=tag.id
  129. )
  130. )
  131. # 获取节点ID
  132. node_id = None
  133. if hasattr(data_model_node, 'id'):
  134. node_id = data_model_node.id
  135. else:
  136. # 如果节点没有identity属性,尝试通过查询获取
  137. query = """
  138. MATCH (n:data_model {name: $name})
  139. RETURN id(n) as node_id
  140. """
  141. with connect_graph().session() as session:
  142. result = session.run(query, name=data_model)
  143. record = result.single()
  144. if record and "node_id" in record:
  145. node_id = record["node_id"]
  146. return node_id, data_model_node
  147. except Exception as e:
  148. logging.error(f"Error in handle_data_model: {str(e)}")
  149. raise
  150. # (从数据资源中选取)
  151. def resource_handle_meta_data_model(id_lists, data_model_node_id):
  152. """
  153. 处理从数据资源中选取的数据模型与元数据的关系
  154. Args:
  155. id_lists: ID列表
  156. data_model_node_id: 数据模型节点ID
  157. Returns:
  158. None
  159. """
  160. # 构建meta_id和resouce_id的列表
  161. resouce_ids = [record['resource_id'] for record in id_lists]
  162. meta_ids = [record['id'] for id_list in id_lists for record in id_list['metaData']]
  163. metaData = [record['data_standard'] for id_list in id_lists for record in id_list['metaData']]
  164. # 创建与meta_node的关系 组成关系
  165. if meta_ids:
  166. query = """
  167. MATCH (source:data_model), (target:meta_node)
  168. WHERE id(source)=$source_id AND id(target) IN $target_ids
  169. MERGE (source)-[:component]->(target)
  170. """
  171. with neo4j_driver.get_session() as session:
  172. session.run(query, source_id=data_model_node_id, target_ids=meta_ids)
  173. # 创建与data_resource的关系 资源关系
  174. if resouce_ids:
  175. query = """
  176. MATCH (source:data_model), (target:data_resource)
  177. WHERE id(source)=$source_id AND id(target) IN $target_ids
  178. MERGE (source)-[:resource]->(target)
  179. """
  180. with neo4j_driver.get_session() as session:
  181. session.run(query, source_id=data_model_node_id, target_ids=resouce_ids)
  182. # (从数据模型中选取)
  183. def model_handle_meta_data_model(id_lists, data_model_node_id):
  184. """
  185. 处理从数据模型中选取的数据模型与元数据的关系
  186. Args:
  187. id_lists: ID列表
  188. data_model_node_id: 数据模型节点ID
  189. Returns:
  190. None
  191. """
  192. # 构建meta_id和model_id的列表
  193. model_ids = [record['model_id'] for record in id_lists]
  194. meta_ids = [record['id'] for id_list in id_lists for record in id_list['metaData']]
  195. # 创建与meta_node的关系 组成关系
  196. if meta_ids:
  197. query = """
  198. MATCH (source:data_model), (target:meta_node)
  199. WHERE id(source)=$source_id AND id(target) IN $target_ids
  200. MERGE (source)-[:component]->(target)
  201. """
  202. with neo4j_driver.get_session() as session:
  203. session.run(query, source_id=data_model_node_id, target_ids=meta_ids)
  204. # 创建与data_model的关系 模型关系
  205. if model_ids:
  206. query = """
  207. MATCH (source:data_model), (target:data_model)
  208. WHERE id(source)=$source_id AND id(target) IN $target_ids
  209. MERGE (source)-[:use]->(target)
  210. """
  211. with neo4j_driver.get_session() as session:
  212. session.run(query, source_id=data_model_node_id, target_ids=model_ids)
  213. # (从DDL中选取)
  214. def handle_no_meta_data_model(id_lists, receiver, data_model_node):
  215. """
  216. 处理从DDL中选取的没有元数据的数据模型
  217. Args:
  218. id_lists: ID列表
  219. receiver: 接收到的请求参数
  220. data_model_node: 数据模型节点
  221. Returns:
  222. None
  223. """
  224. # 构建meta_id和resouce_id的列表
  225. resouce_ids = [record['resource_id'] for record in id_lists]
  226. meta_ids = [record['id'] for id_list in id_lists for record in id_list['metaData']]
  227. # 获取数据模型节点ID
  228. data_model_node_id = None
  229. if hasattr(data_model_node, 'id'):
  230. data_model_node_id = data_model_node.id
  231. else:
  232. # 如果节点没有id属性,尝试通过查询获取
  233. query = """
  234. MATCH (n:data_model {name: $name})
  235. RETURN id(n) as node_id
  236. """
  237. with connect_graph().session() as session:
  238. result = session.run(query, name=data_model_node.get('name'))
  239. record = result.single()
  240. if record:
  241. data_model_node_id = record["node_id"]
  242. if not data_model_node_id:
  243. return
  244. # 创建与data_resource的关系 资源关系
  245. if resouce_ids:
  246. query = """
  247. MATCH (source:data_model), (target:data_resource)
  248. WHERE id(source)=$source_id AND id(target) IN $target_ids
  249. MERGE (source)-[:resource]->(target)
  250. """
  251. with connect_graph().session() as session:
  252. session.run(query, source_id=data_model_node_id, target_ids=resouce_ids)
  253. if meta_ids:
  254. meta_node_list = []
  255. for id in meta_ids:
  256. query = """
  257. MATCH (n)
  258. WHERE id(n) = $node_id
  259. RETURN n
  260. """
  261. with connect_graph().session() as session:
  262. result = session.run(query, node_id=id)
  263. if result:
  264. record = result.data()
  265. if record:
  266. meta_node_list.append(record[0]['n'])
  267. # 提取接收到的数据并创建meta_node节点
  268. meta_node = None
  269. resource_ids = []
  270. for item in id_lists:
  271. resource_id = item['resource_id']
  272. resource_ids.append(resource_id)
  273. for meta_item in item['metaData']:
  274. meta_id = meta_item['id']
  275. data_standard = meta_item.get('data_standard', '')
  276. en_name_zh = meta_item.get('en_name_zh', '')
  277. data_name = meta_item.get('data_name', '')
  278. # 使用传递的参数创建meta_node节点
  279. meta_params = {
  280. 'name': data_name,
  281. 'cn_name': en_name_zh,
  282. 'standard': data_standard,
  283. 'time': get_formatted_time()
  284. }
  285. # 创建meta_node节点
  286. meta_node = create_or_get_node('meta_node', **meta_params)
  287. # 创建与data_model的关系
  288. if meta_node and not relationship_exists(data_model_node, 'component', meta_node):
  289. with connect_graph().session() as session:
  290. session.execute_write(
  291. lambda tx: tx.run(
  292. "MATCH (a), (b) WHERE id(a) = $a_id AND id(b) = $b_id CREATE (a)-[:component]->(b)",
  293. a_id=data_model_node.id, b_id=meta_node.id
  294. )
  295. )
  296. # 数据模型-详情接口
  297. def handle_id_model(id):
  298. """
  299. 获取数据模型详情
  300. Args:
  301. id: 数据模型的节点ID
  302. Returns:
  303. dict: 包含数据模型详情的字典,格式为:
  304. {"data_model": {
  305. "resource_selected": [...],
  306. "leader": ...,
  307. "origin": ...,
  308. "frequency": ...,
  309. "childrenId": [...],
  310. "organization": ...,
  311. "name": ...,
  312. "en_name": ...,
  313. "data_sensitivity": ...,
  314. "describe": ...,
  315. "tag": ...,
  316. "time": ...,
  317. "category": ...,
  318. "status": ...
  319. }}
  320. """
  321. node_id = id
  322. cql = """
  323. MATCH (n:data_model) WHERE id(n) = $nodeId
  324. OPTIONAL MATCH (n)-[:connection]->(meta:meta_node)
  325. OPTIONAL MATCH (n)<-[:belongs_to]-(resource:data_resource)
  326. OPTIONAL MATCH (n)-[:label]->(tag:data_label)
  327. OPTIONAL MATCH (uses:model_use)-[:use]->(n)
  328. OPTIONAL MATCH (n)-[:has_component]->(component)
  329. WITH n,
  330. collect(DISTINCT meta) as meta_nodes,
  331. collect(DISTINCT resource) as resources,
  332. collect(DISTINCT component) as components,
  333. collect(DISTINCT uses) as uses,
  334. collect(DISTINCT tag) as tags,
  335. CASE WHEN n.childrenId IS NOT NULL THEN n.childrenId ELSE [] END as children
  336. RETURN {
  337. // 基本信息
  338. id: id(n),
  339. name: n.name,
  340. en_name: n.en_name,
  341. time: n.time,
  342. description: n.description,
  343. describe: n.description, // 使用description作为describe字段
  344. category: n.category,
  345. level: n.level,
  346. tag: CASE WHEN size(tags) > 0 AND tags[0] IS NOT NULL THEN {id: id(tags[0]), name: tags[0].name} ELSE null END,
  347. // 添加其他必需字段
  348. leader: n.leader,
  349. origin: n.origin,
  350. blood_resource: n.blood_resource,
  351. frequency: n.frequency,
  352. organization: n.organization,
  353. data_sensitivity: n.data_sensitivity,
  354. status: n.status,
  355. // 子节点列表
  356. childrenId: children
  357. } AS result,
  358. // 资源列表
  359. [{
  360. data_resource: [resource IN resources WHERE resource IS NOT NULL | {
  361. id: id(resource),
  362. name: resource.name,
  363. en_name: resource.en_name,
  364. description: resource.description
  365. }],
  366. resource_id: [resource IN resources WHERE resource IS NOT NULL | id(resource)],
  367. meta_ids: [meta IN meta_nodes WHERE meta IS NOT NULL | {
  368. id: id(meta),
  369. name: meta.name,
  370. en_name: meta.en_name,
  371. data_type: meta.data_type
  372. }]
  373. }] AS resource_selected
  374. """
  375. with connect_graph().session() as session:
  376. result = session.run(cql, nodeId=node_id)
  377. # 处理查询结果
  378. record = result.single()
  379. logging.info(f"获得查询结果---------->>>{record}")
  380. if record:
  381. # 获取基本属性和资源选择列表
  382. properties = record["result"]
  383. resource_selected = record["resource_selected"]
  384. # 确保所有必需字段都有默认值,避免空值
  385. required_fields = ['tag', 'description', 'leader', 'origin', 'blood_resource',
  386. 'frequency', 'describe', 'organization', 'name', 'en_name',
  387. 'data_sensitivity', 'time', 'category', 'status', 'childrenId']
  388. for field in required_fields:
  389. if field not in properties or properties[field] is None:
  390. if field == 'tag':
  391. properties[field] = {}
  392. elif field == 'childrenId':
  393. properties[field] = []
  394. else:
  395. properties[field] = ""
  396. # 构建最终返回格式
  397. final_data = {
  398. "resource_selected": resource_selected,
  399. **properties
  400. }
  401. return {"data_model": final_data}
  402. else:
  403. # 如果没有查询到结果,返回空的结构
  404. return {"data_model": {
  405. "resource_selected": [{"meta_ids": [], "data_resource": None, "resource_id": None}],
  406. "leader": None, "origin": None, "frequency": None, "childrenId": [],
  407. "organization": None, "name": None, "en_name": None, "data_sensitivity": None,
  408. "describe": None, "tag": {}, "time": None, "category": None, "status": None
  409. }}
  410. # 数据模型列表
  411. def model_list(skip_count, page_size, en_name_filter=None, name_filter=None,
  412. category=None, tag=None, level=None):
  413. """
  414. 获取数据模型列表
  415. Args:
  416. skip_count: 跳过的数量
  417. page_size: 页面大小
  418. en_name_filter: 英文名称过滤条件
  419. name_filter: 名称过滤条件
  420. category: 类别过滤条件
  421. tag: 标签过滤条件
  422. level: 层级过滤条件
  423. Returns:
  424. tuple: (数据模型列表, 总数量)
  425. """
  426. try:
  427. # 构建where子句
  428. where_clause = []
  429. params = {}
  430. if name_filter is not None:
  431. where_clause.append("n.name =~ $name")
  432. params['name'] = f".*{name_filter}.*"
  433. if en_name_filter is not None:
  434. where_clause.append("n.en_name =~ $en_name")
  435. params['en_name'] = f".*{en_name_filter}.*"
  436. if category is not None:
  437. where_clause.append("n.category = $category")
  438. params['category'] = category
  439. if level is not None:
  440. where_clause.append("n.level = $level")
  441. params['level'] = level
  442. if tag is not None:
  443. where_clause.append("id(t) = $tag")
  444. params['tag'] = tag
  445. # At the end of where_clause construction
  446. where_str = " AND ".join(where_clause)
  447. if where_str:
  448. where_str = f"WHERE {where_str}"
  449. # 构建查询
  450. with connect_graph().session() as session:
  451. # 计算总数量
  452. count_query = f"""
  453. MATCH (n:data_model)
  454. OPTIONAL MATCH (n)-[:label]->(t)
  455. {where_str}
  456. RETURN COUNT(DISTINCT n) AS count
  457. """
  458. count_result = session.run(count_query, **params)
  459. count_record = count_result.single()
  460. total = count_record['count'] if count_record else 0
  461. # 查询数据
  462. query = f"""
  463. MATCH (n:data_model)
  464. OPTIONAL MATCH (n)-[:label]->(t)
  465. {where_str}
  466. RETURN DISTINCT
  467. id(n) as id,
  468. n.name as name,
  469. n.en_name as en_name,
  470. n.time as time,
  471. n.description as description,
  472. n.level as level,
  473. id(t) as tag_id,
  474. t.name as tag_name
  475. ORDER BY n.time DESC
  476. SKIP $skip
  477. LIMIT $limit
  478. """
  479. result = session.run(query, skip=skip_count, limit=page_size, **params)
  480. # 处理结果
  481. data = []
  482. for record in result:
  483. item = {
  484. "id": record['id'],
  485. "name": record['name'],
  486. "en_name": record['en_name'],
  487. "time": record['time'],
  488. "description": record['description'],
  489. "level": record['level'],
  490. "tag": {"id": record['tag_id'], "name": record['tag_name']} if record['tag_id'] is not None else None
  491. }
  492. data.append(item)
  493. return data, total
  494. except Exception as e:
  495. print(f"Error in model_list: {str(e)}")
  496. import traceback
  497. traceback.print_exc()
  498. return [], 0
  499. # 有血缘关系的数据资源列表
  500. def model_resource_list(skip_count, page_size, name_filter=None, id=None,
  501. category=None, time=None):
  502. """
  503. 获取数据模型相关的数据资源列表
  504. Args:
  505. skip_count: 跳过的数量
  506. page_size: 页面大小
  507. name_filter: 名称过滤条件
  508. id: 数据模型ID
  509. category: 类别过滤条件
  510. time: 时间过滤条件
  511. Returns:
  512. tuple: (数据资源列表, 总数量)
  513. """
  514. try:
  515. # 构建基础查询
  516. base_query = """
  517. MATCH (n:data_model)
  518. WHERE id(n) = $nodeId
  519. MATCH (n)-[:children]->(m:data_resource)
  520. """
  521. # 计算总数量
  522. count_query = base_query + """
  523. RETURN COUNT(m) as count
  524. """
  525. with connect_graph().session() as session:
  526. # 执行计数查询
  527. count_result = session.run(count_query, nodeId=id)
  528. count_record = count_result.single()
  529. total = count_record['count'] if count_record else 0
  530. # 使用分页和筛选条件构建主查询
  531. main_query = base_query + """
  532. MATCH (m)-[:label]->(l)
  533. WHERE id(n) = $nodeId and labels(m) <> ['meta_node']
  534. RETURN m.name as name,
  535. m.en_name as en_name,
  536. id(m) as id,
  537. l.name as label,
  538. m.time as time,
  539. m.description as description,
  540. m.category as category
  541. ORDER BY m.time DESC
  542. SKIP $skip LIMIT $limit
  543. """
  544. # 执行主查询
  545. result = session.run(main_query, nodeId=id, skip=skip_count, limit=page_size)
  546. # 处理结果
  547. data = []
  548. for record in result:
  549. item = {
  550. "name": record['name'],
  551. "en_name": record['en_name'],
  552. "id": record['id'],
  553. "label": record['label'],
  554. "time": record['time'],
  555. "description": record['description'],
  556. "category": record['category']
  557. }
  558. data.append(item)
  559. return data, total
  560. except Exception as e:
  561. print(f"Error in model_resource_list: {str(e)}")
  562. import traceback
  563. traceback.print_exc()
  564. return [], 0
  565. # 数据模型血缘图谱
  566. def model_kinship_graph(nodeid, meta=False):
  567. """
  568. 生成数据模型的血缘关系图谱
  569. Args:
  570. nodeid: 节点ID
  571. meta: 是否包含元数据
  572. Returns:
  573. dict: 包含节点和连线信息的图谱数据
  574. """
  575. result = {}
  576. with connect_graph().session() as session:
  577. # 查询起始模型节点
  578. start_node_query = """
  579. MATCH (n:data_model)
  580. WHERE id(n) = $nodeId
  581. RETURN n.name as name, n.en_name as en_name
  582. """
  583. start_result = session.run(start_node_query, nodeId=nodeid)
  584. start_record = start_result.single()
  585. if not start_record:
  586. return {"nodes": [], "lines": []}
  587. # 查询与模型关联的数据资源
  588. resource_query = """
  589. MATCH (n:data_model)
  590. WHERE id(n) = $nodeId
  591. MATCH p = (n)-[:children]->(resource:data_resource)
  592. RETURN resource
  593. """
  594. resource_result = session.run(resource_query, nodeId=nodeid)
  595. nodes = [{"id": str(nodeid), "text": start_record['name'], "type": "model"}]
  596. lines = []
  597. # 处理资源节点
  598. for record in resource_result:
  599. if 'resource' in record:
  600. resource = record['resource']
  601. resource_id = str(resource.id)
  602. resource_name = resource.get('name', '')
  603. resource_en_name = resource.get('en_name', '')
  604. # 创建资源节点
  605. resource_node = {
  606. "id": resource_id,
  607. "text": resource_name,
  608. "type": "resource"
  609. }
  610. nodes.append(resource_node)
  611. # 创建资源到模型的关系
  612. line = {
  613. "from": str(nodeid),
  614. "to": resource_id,
  615. "text": "resource"
  616. }
  617. lines.append(line)
  618. # 处理元数据节点
  619. if meta:
  620. meta_query = """
  621. MATCH (n:data_model)
  622. WHERE id(n) = $nodeId and labels(m) <> ['meta_node']
  623. MATCH p = (n)-[:meta]->(meta:meta_node)
  624. RETURN meta
  625. """
  626. meta_result = session.run(meta_query, nodeId=nodeid)
  627. for record in meta_result:
  628. if 'meta' in record:
  629. meta_node = record['meta']
  630. meta_id = str(meta.id)
  631. meta_name = meta.get('name', '')
  632. meta_en_name = meta.get('en_name', '')
  633. # 创建元数据节点
  634. meta_node = {
  635. "id": meta_id,
  636. "text": meta_name,
  637. "type": "meta"
  638. }
  639. nodes.append(meta_node)
  640. # 创建模型到元数据的标签关系
  641. tag_line = {
  642. "from": str(nodeid),
  643. "to": meta_id,
  644. "text": "component"
  645. }
  646. lines.append(tag_line)
  647. # 构建结果
  648. result = {
  649. "nodes": nodes,
  650. "lines": lines
  651. }
  652. return result
  653. # 数据模型影响图谱
  654. def model_impact_graph(nodeid, meta=False):
  655. """
  656. 生成数据模型的影响关系图谱
  657. Args:
  658. nodeid: 节点ID
  659. meta: 是否包含元数据
  660. Returns:
  661. dict: 包含节点和连线信息的图谱数据
  662. """
  663. result = {}
  664. with connect_graph().session() as session:
  665. # 查询起始模型节点
  666. start_node_query = """
  667. MATCH (n:data_model)
  668. WHERE id(n) = $nodeId
  669. RETURN n.name as name, n.en_name as en_name
  670. """
  671. start_result = session.run(start_node_query, nodeId=nodeid)
  672. start_record = start_result.single()
  673. if not start_record:
  674. return {"nodes": [], "lines": []}
  675. # 查询影响模型的数据资源
  676. resource_query = """
  677. MATCH (n:data_model)
  678. WHERE id(n) = $nodeId
  679. MATCH p = (n)-[:children]->(resource:data_resource)
  680. RETURN resource
  681. """
  682. resource_result = session.run(resource_query, nodeId=nodeid)
  683. nodes = [{"id": str(nodeid), "text": start_record['name'], "type": "model"}]
  684. lines = []
  685. # 处理资源节点
  686. for record in resource_result:
  687. if 'resource' in record:
  688. resource = record['resource']
  689. resource_id = str(resource.id)
  690. resource_name = resource.get('name', '')
  691. resource_en_name = resource.get('en_name', '')
  692. # 创建资源节点
  693. resource_node = {
  694. "id": resource_id,
  695. "text": resource_name,
  696. "type": "resource"
  697. }
  698. nodes.append(resource_node)
  699. # 创建资源到模型的关系
  700. line = {
  701. "from": str(nodeid),
  702. "to": resource_id,
  703. "text": "resource"
  704. }
  705. lines.append(line)
  706. # 处理元数据节点
  707. if meta:
  708. meta_query = """
  709. MATCH (n:data_model)
  710. WHERE id(n) = $nodeId and labels(m) <> ['meta_node']
  711. MATCH p = (n)-[:meta]->(meta:meta_node)
  712. RETURN meta
  713. """
  714. meta_result = session.run(meta_query, nodeId=nodeid)
  715. for record in meta_result:
  716. if 'meta' in record:
  717. meta_node = record['meta']
  718. meta_id = str(meta.id)
  719. meta_name = meta.get('name', '')
  720. meta_en_name = meta.get('en_name', '')
  721. # 创建元数据节点
  722. meta_node = {
  723. "id": meta_id,
  724. "text": meta_name,
  725. "type": "meta"
  726. }
  727. nodes.append(meta_node)
  728. # 创建模型到元数据的标签关系
  729. tag_line = {
  730. "from": str(nodeid),
  731. "to": meta_id,
  732. "text": "component"
  733. }
  734. lines.append(tag_line)
  735. # 构建结果
  736. result = {
  737. "nodes": nodes,
  738. "lines": lines
  739. }
  740. return result
  741. # 数据模型全部图谱
  742. def model_all_graph(nodeid, meta=False):
  743. """
  744. 生成数据模型的所有关系图谱
  745. Args:
  746. nodeid: 节点ID
  747. meta: 是否包含元数据
  748. Returns:
  749. dict: 包含节点和连线信息的图谱数据
  750. """
  751. result = {}
  752. with connect_graph().session() as session:
  753. # 查询起始模型节点
  754. start_node_query = """
  755. MATCH (n:data_model)
  756. WHERE id(n) = $nodeId
  757. RETURN n.name as name, n.en_name as en_name
  758. """
  759. start_result = session.run(start_node_query, nodeId=nodeid)
  760. start_record = start_result.single()
  761. if not start_record:
  762. return {"nodes": [], "lines": []}
  763. # 查询与模型关联的数据资源
  764. resource_query = """
  765. MATCH (n:data_model)
  766. WHERE id(n) = $nodeId
  767. MATCH p = (n)-[:children]->(resource:data_resource)
  768. RETURN resource
  769. """
  770. resource_result = session.run(resource_query, nodeId=nodeid)
  771. # 查询与模型关联的元数据
  772. meta_query = """
  773. MATCH (n:data_model)
  774. WHERE id(n) = $nodeId and labels(m) <> ['meta_node']
  775. MATCH p = (n)-[:meta]->(meta:meta_node)
  776. RETURN meta
  777. """
  778. nodes = [{"id": str(nodeid), "text": start_record['name'], "type": "model"}]
  779. lines = []
  780. # 处理资源节点
  781. for record in resource_result:
  782. if 'resource' in record:
  783. resource = record['resource']
  784. resource_id = str(resource.id)
  785. resource_name = resource.get('name', '')
  786. resource_en_name = resource.get('en_name', '')
  787. # 创建资源节点
  788. resource_node = {
  789. "id": resource_id,
  790. "text": resource_name,
  791. "type": "resource"
  792. }
  793. nodes.append(resource_node)
  794. # 创建资源到模型的关系
  795. line = {
  796. "from": str(nodeid),
  797. "to": resource_id,
  798. "text": "resource"
  799. }
  800. lines.append(line)
  801. # 处理元数据节点
  802. if meta:
  803. meta_result = session.run(meta_query, nodeId=nodeid)
  804. for record in meta_result:
  805. if 'meta' in record:
  806. meta_node = record['meta']
  807. meta_id = str(meta.id)
  808. meta_name = meta.get('name', '')
  809. meta_en_name = meta.get('en_name', '')
  810. # 创建元数据节点
  811. meta_node = {
  812. "id": meta_id,
  813. "text": meta_name,
  814. "type": "meta"
  815. }
  816. nodes.append(meta_node)
  817. # 创建模型到元数据的标签关系
  818. tag_line = {
  819. "from": str(nodeid),
  820. "to": meta_id,
  821. "text": "component"
  822. }
  823. lines.append(tag_line)
  824. # 构建结果
  825. result = {
  826. "nodes": nodes,
  827. "lines": lines
  828. }
  829. return result
  830. # 更新数据模型
  831. def data_model_edit(receiver):
  832. """
  833. 更新数据模型
  834. Args:
  835. receiver: 接收到的请求参数
  836. Returns:
  837. 更新结果
  838. """
  839. id = receiver.get('id')
  840. name = receiver.get('name')
  841. en_name = receiver.get('en_name')
  842. category = receiver.get('category')
  843. description = receiver.get('description')
  844. tag = receiver.get('tag')
  845. # 更新数据模型节点
  846. query = """
  847. MATCH (n:data_model) WHERE id(n) = $id
  848. SET n.name = $name, n.en_name = $en_name, n.category = $category, n.description = $description
  849. RETURN n
  850. """
  851. with connect_graph().session() as session:
  852. result = session.run(query, id=id, name=name, en_name=en_name,
  853. category=category, description=description).data()
  854. # 处理标签关系
  855. if tag:
  856. # 先删除所有标签关系
  857. delete_query = """
  858. MATCH (n:data_model)-[r:label]->() WHERE id(n) = $id
  859. DELETE r
  860. """
  861. with connect_graph().session() as session:
  862. session.run(delete_query, id=id)
  863. # 再创建新的标签关系
  864. tag_node = get_node_by_id('data_label', tag)
  865. if tag_node:
  866. model_node = get_node_by_id_no_label(id)
  867. if model_node and not relationship_exists(model_node, 'label', tag_node):
  868. with connect_graph().session() as session:
  869. session.execute_write(
  870. lambda tx: tx.run(
  871. "MATCH (a), (b) WHERE id(a) = $a_id AND id(b) = $b_id CREATE (a)-[:label]->(b)",
  872. a_id=model_node.id, b_id=tag_node.id
  873. )
  874. )
  875. return {"message": "数据模型更新成功"}