250520-1代码。

models/__init__.py

@@ -25,6 +25,8 @@ from .company_management_base import *
 from .resource_provision_base import *
 from .three_proofing_responsible_base import *
 from .city_base import *
+from .data_management_base import *
+
 
 # sharedb 库
 from .sharedb import *

models/data_management_base.py

@@ -0,0 +1,20 @@
+from sqlalchemy import create_engine, Column, BigInteger, String, Text, DateTime, CHAR,Integer,Float
+
+from database import Base
+from datetime import datetime
+
+
+class TpDashboardDataManager(Base):
+    __tablename__ = 'tp_dashboard_data_management'
+
+    id = Column(Integer, primary_key=True, autoincrement=True, comment='主键')
+    layer_name = Column(String(255), comment='图层名称')
+    table_name = Column(String(255), comment='表名')
+    database_name = Column(String(255), comment='库名')
+    technical_field = Column(String(255), comment='技术字段')
+    data_update_time = Column(DateTime,  comment='创建时间')
+    data_resouce = Column(String(255), nullable=False, comment='数源单位')
+    order_num = Column(Integer, default=0, comment='显示顺序')
+    create_time = Column(DateTime, default=datetime.now, comment='创建时间')
+    update_time = Column(DateTime, default=datetime.now, onupdate=datetime.now, comment='更新时间')
+    del_flag = Column(String(1), default='0', comment='删除标志（0代表存在 2代表删除）')

routers/api/__init__.py

@@ -39,6 +39,7 @@ from routers.prod_api import system
 from routers.prod_api import auth
 from . import qrcode
 from . import expert
+from . import dataManagement
 router = APIRouter()
 
 @router.get("/yzy/callback.html")
@@ -91,5 +92,6 @@ router.include_router(comprehensive_search.router, prefix="/comprehensive/search
 router.include_router(ThreeProofingResponsible.router, prefix="/ThreeProofingResponsible", tags=["三防责任人管理"], dependencies=[Depends(valid_access_token_role)])
 router.include_router(city.router, prefix="/city", tags=["区划"], dependencies=[Depends(valid_access_token_role)])
 router.include_router(expert.router, prefix="/expert", tags=["应急专家"], dependencies=[Depends(valid_access_token_role)])
+router.include_router(dataManagement.router, prefix="/dataManager", tags=["数据管理"], dependencies=[Depends(valid_access_token_role)])
 
 router.include_router(yst.router, prefix="/yst", tags=["粤商通"]) # 粤商通不需要，单独的验证逻辑

routers/api/dataManagement/__init__.py

@@ -0,0 +1,52 @@
+#!/usr/bin/env python3
+# -*- coding: utf-8 -*-
+
+from fastapi import APIRouter, Request, Depends, Query, HTTPException, status,WebSocket,WebSocketDisconnect
+from common.security import valid_access_token,valid_websocket_token
+from fastapi.responses import JSONResponse,StreamingResponse
+from common.db import db_czrz
+from sqlalchemy.orm import Session
+from sqlalchemy.sql import func
+from common.auth_user import *
+from sqlalchemy import  text
+from pydantic import BaseModel
+from common.BigDataCenterAPI import *
+from database import get_db
+from typing import List
+from models import *
+from utils import *
+from utils.spatial import *
+from utils.ry_system_util import *
+from utils.resource_provision_util import *
+from common.websocketManager import *
+import json
+import traceback
+
+router = APIRouter()
+
+@router.get("/list")
+async def get_pattern_list(
+    # name: str = Query(None, description='名称'),
+    user_id=Depends(valid_access_token),
+    db: Session = Depends(get_db)
+):
+    try:
+        query = db.query(TpDashboardDataManager)
+        query = query.filter_by(del_flag='0')
+
+        # 排序
+        query = query.order_by(TpDashboardDataManager.order_num)
+        # 执行分页查询
+        lists = query.all()
+        data = [ ]
+        for info in lists:
+            data.append({"id": info.id,
+                "layer_name": info.layer_name,
+                "data_update_time": info.data_update_time,
+                "data_resouce": info.data_resouce
+                })
+        return {"code": 200, "msg": "查询成功", "data": data
+                }
+    except Exception as e:
+        traceback.print_exc()
+        return JSONResponse(status_code=500,content={'code':500,'msg':f"接口发生错误:{e}"})