table_list.py
5.1 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
#author: 4N
#createtime: 2021/1/27
#email: nheweijun@sina.com
from ..models import Table,Catalog
from app.modules.auth.models import User
from sqlalchemy import or_,and_
from sqlalchemy.orm import Query
from app.util.component.ApiTemplate import ApiTemplate
from app.util.component.UserAlias import UserAlias
from app.util.component.ModelVisitor import ModelVisitor
class Api(ApiTemplate):
api_name = "表列表"
def process(self):
res = {}
try:
page_index = int(self.para.get("page_index", "0"))
page_size = int(self.para.get("page_size", "10"))
alias = self.para.get("alias")
name = self.para.get("name")
database_guid = self.para.get("database_guid")
catalog_guid = self.para.get("catalog_guid")
table_type = self.para.get("table_type")
start_time = self.para.get("start_time")
end_time = self.para.get("end_time")
is_for_partition = self.para.get("is_for_partition")
recursion = int(self.para.get("recursion","0"))
sort = int(self.para.get("sort","1"))
if sort.__eq__(1):
tables:Query = Table.query.order_by(Table.update_time.desc(),Table.name)
else:
tables = Table.query.order_by(Table.name)
#过滤spatial_ref_sys
tables = tables.filter(Table.name.notin_(["spatial_ref_sys"]))
if database_guid:
tables = tables.filter_by(database_guid=database_guid)
if is_for_partition:
tables = tables.filter_by(is_for_partition=int(is_for_partition))
if catalog_guid:
if recursion.__eq__(0):
tables = tables.filter_by(catalog_guid=catalog_guid)
else:
#所有子目录id
catalog_guids = [c.guid for c in Catalog.query.filter(Catalog.path.like("%" + catalog_guid + "%")).all()]
tables = tables.filter(Table.catalog_guid.in_(catalog_guids))
if table_type:
tables = tables.filter_by(table_type=table_type)
if start_time and end_time:
tables = tables.filter(Table.create_time.between(start_time, end_time))
# 并集
if alias and name:
tables = tables.filter(or_(Table.alias.like("%" + alias + "%") , Table.name.like("%" + name + "%")))
else:
if alias:
tables = tables.filter(Table.alias.like("%" + alias + "%"))
if name:
tables = tables.filter(Table.name.like("%" + name + "%"))
res["data"]={}
res["data"]["count"] = tables.count()
tables = tables.limit(page_size).offset(page_index * page_size).all()
res["data"]["list"]=[]
user_alias = UserAlias()
for t in tables:
table_json = ModelVisitor.table_to_json(t)
table_json["display_name"] = user_alias.get_alias(table_json["creator"])
res["data"]["list"].append(table_json)
res["result"] = True
except Exception as e:
raise e
return res
api_doc={
"tags":["管理接口"],
"parameters":[
{"name": "page_index",
"in": "formData",
"type": "int",
"description": "页"},
{"name": "page_size",
"in": "formData",
"type": "int",
"description": "页大小"},
{"name": "alias",
"in": "formData",
"type": "string",
"description": "表别名"},
{"name": "name",
"in": "formData",
"type": "string",
"description": "表名"},
{"name": "table_type",
"in": "formData",
"type": "int",
"description": "点线面123","enum":[1,2,3]},
{"name": "is_for_partition",
"in": "formData",
"type": "int",
"description": "是否用于分层分级", "enum": [0, 1]},
{"name": "database_guid",
"in": "formData",
"type": "string",
"description": "数据库guid"},
{"name": "catalog_guid",
"in": "formData",
"type": "string",
"description": "目录guid"},
{"name": "recursion",
"in": "formData",
"type": "int",
"description": "是否递归目录,0不递归，1递归","enum":[0,1]},
{"name": "start_time",
"in": "formData",
"type": "string",
"description": "开始时间 2020-12-12 00:00:00"},
{"name": "end_time",
"in": "formData",
"type": "string",
"description": "结束时间"},
{"name": "sort",
"in": "formData",
"type": "int",
"description": "排序","enum":[1,2]},
],
"responses":{
200:{
"schema":{
"properties":{
}
}
}
}
}