后端接口af --> jpt

app/routers/code_check.py

@@ -12,7 +12,7 @@ import sqlfluff
 
 
 router = APIRouter(
-    prefix="/af/code_check",
+    prefix="/jpt/code_check",
     tags=["code_check-代码校验"],
 )
 

app/routers/constants.py

@@ -9,7 +9,7 @@ import app.crud as crud
 from app import get_db
 
 router = APIRouter(
-    prefix="/af/constants",
+    prefix="/jpt/constants",
     tags=["constants-常量管理"],
 )
 

app/routers/dag.py

@@ -10,7 +10,7 @@ from app.common.hive import hiveDs
 from app import get_db
 
 router = APIRouter(
-    prefix="/af/dag",
+    prefix="/jpt/dag",
     tags=["dag-dag管理"],
 )
 

app/routers/dag_file.py

@@ -8,7 +8,7 @@ from utils.sx_web import web_try
 from fastapi.responses import StreamingResponse
 
 router = APIRouter(
-    prefix="/af/dag_file",
+    prefix="/jpt/dag_file",
     tags=["dag-dag管理"],
 )
 

app/routers/data_management.py

@@ -18,7 +18,7 @@ from app.common.hive import hiveDs
 from app import get_db
 
 router = APIRouter(
-    prefix="/af/datamanagement",
+    prefix="/jpt/datamanagement",
     tags=["datamanagement-数据管理"],
 )
 

app/routers/datax_json.py

@@ -13,7 +13,7 @@ from app import get_db
 
 
 router = APIRouter(
-    prefix="/af/datax",
+    prefix="/jpt/datax",
     tags=["datax构建JSON"],
 )
 

app/routers/files.py

@@ -15,7 +15,7 @@ from app import get_db
 
 
 router = APIRouter(
-    prefix="/af/files",
+    prefix="/jpt/files",
     tags=["files-文件管理"],
 )
 

app/routers/intermediate.py

@@ -1,62 +0,0 @@
-from ast import Raise
-import io
-import uuid
-from fastapi import APIRouter
-
-from fastapi import File, UploadFile
-from fastapi.responses import StreamingResponse
-from app.utils.utils import byte_conversion
-from utils.sx_time import sxtimeit
-from utils.sx_web import web_try
-from utils.sx_image import get_b64
-from app.common.minio import FileHandler
-
-from app import get_db
-
-
-
-router = APIRouter(
-    prefix="/af/intermediate",
-    tags=["intermediate-中间结果管理"],
-)
-
-
-@router.post("/")
-@web_try()
-@sxtimeit
-def put_intermediate(project_id: str, user_id: str, dag_uuid: str, node_uuid: str, file: UploadFile = File(...),):
-    print("UploadFile-->",file.filename)
-    file_name = file.filename.split('.', 1 )[0]
-    print(project_id, user_id, dag_uuid, node_uuid,file_name)
-    file_handler = FileHandler("datax")
-    file_exist = file_handler.get_file("intermediate/{}/{}/{}/{}/{}".format(project_id, user_id, dag_uuid, node_uuid, file_name))
-    if len(file_exist) > 0:
-        raise Exception('文件已存在')
-    url = file_handler.put_byte_file("intermediate/{}/{}/{}/{}/{}".format(project_id, user_id, dag_uuid, node_uuid, file_name), file.file.read())
-    return url
-
-
-@router.get("/get_intermediate")
-@web_try()
-@sxtimeit
-def get_file(project_id: str, user_id: str, dag_uuid: str):
-    file_handler = FileHandler("datax")
-    prefix = "intermediate/{}/{}/{}".format(project_id, user_id, dag_uuid)
-    objects = file_handler.ls_file(prefix)
-    res = []
-    for obj in objects:
-        intermediate = {}
-        storage_path = obj.object_name
-        file_path = storage_path.replace(prefix+"/", "")
-        n_n = file_path.split("/",1)
-        node_uuid = n_n[0]
-        file_name = n_n[1]
-        create_time = obj.last_modified.strftime("%Y:%d:%m %H:%M")
-        size = byte_conversion(obj.size)
-        intermediate.update({'name': file_name,
-                            'node_uuid': node_uuid,
-                            'storage_path':storage_path,
-                            'create_time': create_time,
-                            'size': size})
-        res.append(intermediate)
-    return res

app/routers/jm_homework.py

@@ -18,7 +18,7 @@ from app import get_db
 
 
 router = APIRouter(
-    prefix="/af/jm_homework",
+    prefix="/jpt/jm_homework",
     tags=["jm_homework-作业管理"],
 )
 

app/routers/jm_job_info.py

@@ -20,7 +20,7 @@ from app import get_db
 
 
 router = APIRouter(
-    prefix="/af/jm_job_info",
+    prefix="/jpt/jm_job_info",
     tags=["jm_job_info-定时任务管理"],
 )
 

app/routers/jm_job_log.py

@@ -17,7 +17,7 @@ from app import get_db, get_page
 
 
 router = APIRouter(
-    prefix="/af/jm_job_log",
+    prefix="/jpt/jm_job_log",
     tags=["jm_job_log-定时任务日志管理"],
 )
 

app/routers/job_info.py

@@ -23,7 +23,7 @@ from app import get_db, get_page
 
 
 router = APIRouter(
-    prefix="/af/jobinfo",
+    prefix="/jpt/jobinfo",
     tags=["jobinfo-任务管理"],
 )
 

app/routers/job_jdbc_datasource.py

@@ -15,7 +15,7 @@ from app import get_db
 
 
 router = APIRouter(
-    prefix="/af/datasource",
+    prefix="/jpt/datasource",
     tags=["datasource-数据源管理"],
 )
 

app/routers/job_log.py

@@ -15,7 +15,7 @@ from fastapi_pagination import Page, add_pagination, paginate, Params
 from app import get_db
 
 router = APIRouter(
-    prefix="/af/joblog",
+    prefix="/jpt/joblog",
     tags=["joblog-日志管理"],
 )