q792602257/my-video-workflow
0
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

避免自动清理了item而没提交

Browse Source
This commit is contained in:
Jerry Yan 2022-05-03 07:54:39 +08:00
parent ebe600f2e7
commit 957f06cd77
1 changed files with 4 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
controller/api/bilirecorder_blueprint.py
View File

@ -32,9 +32,11 @@ def auto_submit_task():
if len(bili_record_workflow_item.video_clips) == 0: if len(bili_record_workflow_item.video_clips) == 0:
print("[!]Auto Submit Fail: No Video Clips") print("[!]Auto Submit Fail: No Video Clips")
return return
_started = False
for video_clip in bili_record_workflow_item.video_clips: for video_clip in bili_record_workflow_item.video_clips:
if len(video_clip.danmaku_clips) > 0: if len(video_clip.danmaku_clips) > 0:
print("[+]Workflow:", bili_record_workflow_item.id, "; Video:", video_clip.full_path) print("[+]Workflow:", bili_record_workflow_item.id, "; Video:", video_clip.full_path)
_started = True
threading.Thread(target=do_workflow, args=( threading.Thread(target=do_workflow, args=(
video_clip.full_path, video_clip.full_path,
video_clip.danmaku_clips[0].full_path, video_clip.danmaku_clips[0].full_path,
@ -42,7 +44,8 @@ def auto_submit_task():
)).start() )).start()
else: else:
print("[-]Workflow:", bili_record_workflow_item.id, "; Video:", video_clip.full_path, "; No Danmaku") print("[-]Workflow:", bili_record_workflow_item.id, "; Video:", video_clip.full_path, "; No Danmaku")
clear_item() if _started:
clear_item()
def clear_item(): def clear_item():
@ -53,13 +56,6 @@ def clear_item():
bili_record_workflow_item.editing = True bili_record_workflow_item.editing = True
def reload_item():
global bili_record_workflow_item
if bili_record_workflow_item is None:
return
bili_record_workflow_item = Workflow.query.get(bili_record_workflow_item.id)
def commit_item(): def commit_item():
global bili_record_workflow_item global bili_record_workflow_item
if bili_record_workflow_item is None: if bili_record_workflow_item is None:
@ -188,7 +184,6 @@ def bilirecorder_event():
item.video_clips.append(video_clip) item.video_clips.append(video_clip)
commit_item() commit_item()
collect_danmaku_files(item) collect_danmaku_files(item)
reload_item()
auto_submit_task() auto_submit_task()
return jsonify(item.to_dict()) return jsonify(item.to_dict())
commit_item() commit_item()