zcdsj
/
factory
5
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat: 添加定时任务以标记mtask 状态

This commit is contained in:
caoqianming 2025-08-28 16:37:23 +08:00
parent 22a310906a
commit 4fa0b33254
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
apps/pm/tasks.py
View File

@ -13,12 +13,14 @@ def complete_mtask():
将2天前未提交的任务且数量已达标的任务标记为已完成 将2天前未提交的任务且数量已达标的任务标记为已完成
""" """
now = datetime.now().date() now = datetime.now().date()
mtasks = Mtask.objects.filter(state=Mtask.MTASK_ASSGINED, Mtask.objects.filter(state=Mtask.MTASK_ASSGINED,
end_date__lte=now-timedelta(days=2), end_date__lte=now-timedelta(days=2),
count_ok__gte=F('count')) count_ok__gte=F('count')).update(state=Mtask.MTASK_SUBMIT)
mtasks.update(state=Mtask.MTASK_SUBMIT) # Mtask.objects.filter(state=Mtask.MTASK_ASSGINED,
# end_date__lte=now-timedelta(days=7)).update(state=Mtask.MTASK_STOP)
utasks = Utask.objects.filter(id__in=mtasks.values_list("utask__id", flat=True)) utasks = Utask.objects.filter(state__in=[Utask.UTASK_ASSGINED, Utask.UTASK_WORKING],
end_date__lte=now-timedelta(days=2))
for utask in utasks: for utask in utasks:
PmService.utask_submit(utask=utask, raise_e=False) PmService.utask_submit(utask=utask, raise_e=False)