|
@@ -211,8 +211,6 @@ async def file_task(file_path,task_id):
|
|
@airouter.post("/scan")
|
|
@airouter.post("/scan")
|
|
async def scan(request: RequestScan, background_tasks: BackgroundTasks):
|
|
async def scan(request: RequestScan, background_tasks: BackgroundTasks):
|
|
local_path, repo_name = generate_repo_path(request.uuid, request.repo_url)
|
|
local_path, repo_name = generate_repo_path(request.uuid, request.repo_url)
|
|
- repo = await Repos.get(name=repo_name)
|
|
|
|
- repo_id = repo.id
|
|
|
|
print(f"开始扫描仓库: {repo_name}")
|
|
print(f"开始扫描仓库: {repo_name}")
|
|
await Scan_Tasks.filter(id=request.task_id).update(state=1, scan_start_time=int(time.time()))
|
|
await Scan_Tasks.filter(id=request.task_id).update(state=1, scan_start_time=int(time.time()))
|
|
background_tasks.add_task(analysis, local_path, request.task_id)
|
|
background_tasks.add_task(analysis, local_path, request.task_id)
|
|
@@ -221,8 +219,6 @@ async def scan(request: RequestScan, background_tasks: BackgroundTasks):
|
|
@airouter.post("/summaryCommit")
|
|
@airouter.post("/summaryCommit")
|
|
async def summaryCommit(request: RequestCommit, background_tasks: BackgroundTasks):
|
|
async def summaryCommit(request: RequestCommit, background_tasks: BackgroundTasks):
|
|
local_path, repo_name = generate_repo_path(request.uuid, request.repo_url)
|
|
local_path, repo_name = generate_repo_path(request.uuid, request.repo_url)
|
|
- repo=await Repos.get(name=repo_name)
|
|
|
|
- repo_id=repo.id
|
|
|
|
repo_commit=await Commit_Summary_Tasks.get(id=request.task_id)
|
|
repo_commit=await Commit_Summary_Tasks.get(id=request.task_id)
|
|
repo_commit_hash=repo_commit.repo_hash
|
|
repo_commit_hash=repo_commit.repo_hash
|
|
print(f"开始提交仓库: {repo_name}")
|
|
print(f"开始提交仓库: {repo_name}")
|
|
@@ -234,9 +230,6 @@ async def summaryCommit(request: RequestCommit, background_tasks: BackgroundTask
|
|
|
|
|
|
@airouter.post("/summaryFile")
|
|
@airouter.post("/summaryFile")
|
|
async def summaryFile(request: RequestFile,background_tasks: BackgroundTasks):
|
|
async def summaryFile(request: RequestFile,background_tasks: BackgroundTasks):
|
|
- local_path, repo_name = generate_repo_path(request.uuid, request.repo_url)
|
|
|
|
- repo=await Repos.get(name=repo_name)
|
|
|
|
- repo_id = repo.id
|
|
|
|
await File_Summary_Tasks.filter(id=request.task_id).update(start_time=int(time.time()))
|
|
await File_Summary_Tasks.filter(id=request.task_id).update(start_time=int(time.time()))
|
|
background_tasks.add_task(file_task, request.file_path, request.task_id)
|
|
background_tasks.add_task(file_task, request.file_path, request.task_id)
|
|
return {"code": 200, "msg": "添加提交任务成功"}
|
|
return {"code": 200, "msg": "添加提交任务成功"}
|