update code

main
周平 11 months ago
parent 809ef6f7b4
commit ead7b8fc94

@ -52,4 +52,14 @@ class ModelRepositry(object):
if not model or not model.suid: if not model or not model.suid:
return "" return ""
return model.suid return model.suid
def get_model_by_id(self, model_id: int) -> Model | None:
session = get_session()
with get_session() as session:
model = session.query(Model).filter(Model.id == model_id).first()
if not model:
return None
return model

@ -98,10 +98,12 @@ class EnterpriseBusiModelRepository(object):
base_model_db = DB_alg_model.ModelRepositry() base_model_db = DB_alg_model.ModelRepositry()
base_model = [] base_model = []
for base_model_id in base_model_ids: for base_model_id in base_model_ids:
base_model_suid = base_model_db.get_suid(base_model_id) # base_model_suid = base_model_db.get_suid(base_model_id)
base_model_info = base_model_db.get_model_by_id(base_model_id)
base_model.append({ base_model.append({
'id': base_model_id, 'id': base_model_id,
'suid': base_model_suid 'suid': base_model_info.suid,
'name': base_model_info.name,
}) })
data['base_models'] = json.dumps(base_model) data['base_models'] = json.dumps(base_model)
new_data = copy.copy(data) new_data = copy.copy(data)
@ -146,7 +148,6 @@ class EnterpriseBusiModelRepository(object):
获取企业部署的业务模型列表 获取企业部署的业务模型列表
Args: Args:
session (Session): SQLAlchemy 数据库会话
entity_id (int): 企业 ID entity_id (int): 企业 ID
page_no (int): 页码 page_no (int): 页码
page_size (int): 每页数量 page_size (int): 每页数量

@ -1,6 +1,6 @@
# -*- coding: utf-8 -*- # -*- coding: utf-8 -*-
from typing import List, Dict, Any from typing import List, Dict, Any, Type
from sqlalchemy import Column, Integer, String, DateTime, func, text from sqlalchemy import Column, Integer, String, DateTime, func, text
from sqlalchemy.ext.declarative import declarative_base from sqlalchemy.ext.declarative import declarative_base
@ -43,12 +43,12 @@ class File(Base):
class FileRepository(object): class FileRepository(object):
def get_file_by_md5(self, md5_list: List[str]) -> List(File): def get_file_by_md5(self, md5_list: List[str]) -> List[File]:
with get_session() as session: with get_session() as session:
# return ( # return (
# session.query(File).filter(File.md5_str == md5_str).first() # session.query(File).filter(File.md5_str == md5_str).first()
# ) # )
return session.query(File).filter(File.md5_str.in_(md5_list)).all() return session.query(File).filter(File.md5_str.in_(md5_list)).all()

@ -155,7 +155,7 @@ class InfoHandler(APIHandler):
link_nodes = db_model_node.get_nodes_by_busi_model(busimodel_id) link_nodes = db_model_node.get_nodes_by_busi_model(busimodel_id)
link_node_list = [] link_node_list = []
for node in link_nodes: for node in link_nodes:
link_node_list.append(node.node_id) link_node_list.append({"node_id": node.node_id, "node_name": node.node_name})
self.finish({ self.finish({
"name": busi_model_data.name, "name": busi_model_data.name,
@ -166,7 +166,7 @@ class InfoHandler(APIHandler):
"business_conf_name": business_conf_name, # 业务参数配置文件名 "business_conf_name": business_conf_name, # 业务参数配置文件名
"business_conf_md5": busi_model_data.business_conf_file, # 业务参数配置md5 "business_conf_md5": busi_model_data.business_conf_file, # 业务参数配置md5
"business_conf_param": busi_model_data.business_conf_param, # 业务参数配置的字段 "business_conf_param": busi_model_data.business_conf_param, # 业务参数配置的字段
"link_node_list": ",".join(link_node_list) # 关联节点的id多个id逗号分割 "link_node_list": link_node_list # 关联节点的id多个id逗号分割
}) })

Loading…
Cancel
Save