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

隐患关闭停止跟踪计划

This commit is contained in:
caoqianming 2021-02-01 21:02:46 +08:00
parent 418034a5b6
commit 34dc9b6d9e
1 changed files with 14 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
safesite/tasks.py
View File

@ -312,16 +312,21 @@ def sendGridtask(obj):
def sendGridtask2(**kwargs): def sendGridtask2(**kwargs):
obj = GridTaskSet.objects.get(id=kwargs['gridtaskset']) obj = GridTaskSet.objects.get(id=kwargs['gridtaskset'])
if obj.trouble: if obj.trouble:
TroubleFollowTask.objects.filter(taskset=obj, usable=1).update(usable=0) if obj.trouble.yhzt == 6:
nowtime = datetime.datetime.now() #如果隐患关闭了就直接停止计划任务
if obj.expire: obj.periodictask.enabled = False
newm = nowtime + datetime.timedelta(hours=int(obj.expire)) obj.periodictask.save()
TroubleFollowTask.objects.create(trouble=obj.trouble,taskexpire = newm,taskadd=nowtime,taskset=obj,tasknote=obj.note,user=obj.user,gridlevel=obj.gridlevel)
else: else:
TroubleFollowTask.objects.create(trouble=obj.trouble,taskadd=nowtime,taskset=obj,tasknote=obj.note,user=obj.user,gridlevel=obj.gridlevel) TroubleFollowTask.objects.filter(taskset=obj, usable=1).update(usable=0)
obj.last_run_at = nowtime nowtime = datetime.datetime.now()
obj.count = obj.count+1 if obj.expire:
obj.save() newm = nowtime + datetime.timedelta(hours=int(obj.expire))
TroubleFollowTask.objects.create(trouble=obj.trouble,taskexpire = newm,taskadd=nowtime,taskset=obj,tasknote=obj.note,user=obj.user,gridlevel=obj.gridlevel)
else:
TroubleFollowTask.objects.create(trouble=obj.trouble,taskadd=nowtime,taskset=obj,tasknote=obj.note,user=obj.user,gridlevel=obj.gridlevel)
obj.last_run_at = nowtime
obj.count = obj.count+1
obj.save()
elif obj.riskact: elif obj.riskact:
RiskActTask.objects.filter(taskset=obj, usable=1).update(usable=0) RiskActTask.objects.filter(taskset=obj, usable=1).update(usable=0)