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

feat: task_ticket 默认发送通知

This commit is contained in:
caoqianming 2023-06-21 15:31:36 +08:00
parent 07822f093d
commit 7ab3535c83
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
apps/wf/services.py
View File

@ -431,7 +431,7 @@ class WfService(object):
@classmethod
def task_ticket(cls, ticket: Ticket):
"""
执行任务(自定义任务或通知)
执行任务(自定义任务和通知)
"""
state = ticket.state
# 如果目标状态有func,由func执行额外操作(比如发送通知)
@ -440,14 +440,14 @@ class WfService(object):
m = importlib.import_module(module)
f = getattr(m, func)
f(ticket=ticket) # 同步执行
else:
# wf默认只发送通知
last_log = TicketFlow.objects.filter(ticket=ticket).order_by('-create_time').first()
if (last_log.state != state or
last_log.intervene_type == Transition.TRANSITION_INTERVENE_TYPE_DELIVER or
ticket.in_add_node):
# 如果状态变化或是转交加签的情况再发送通知
Thread(target=send_ticket_notice_t, args=(ticket,), daemon=True).start()
# wf默认只发送通知
last_log = TicketFlow.objects.filter(ticket=ticket).order_by('-create_time').first()
if (last_log.state != state or
last_log.intervene_type == Transition.TRANSITION_INTERVENE_TYPE_DELIVER or
ticket.in_add_node):
# 如果状态变化或是转交加签的情况再发送通知
Thread(target=send_ticket_notice_t, args=(ticket,), daemon=True).start()
# 如果目标状态是脚本则异步执行
if state.participant_type == State.PARTICIPANT_TYPE_ROBOT: