fix: 去除版本信息

zhongrj

2025-11-25 b89962006164a462404b79a738bee8cbb6d7fe7e

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
import logging
from django.dispatch import receiver
from django.core.mail import send_mail
from app.plugins.signals import task_completed, task_failed, task_removed
from app.plugins.functions import get_current_plugin
from . import email as notification
from . import config
from app.models import Task, Setting
 
logger = logging.getLogger('app.logger')
 
@receiver(task_completed)
def handle_task_completed(sender, task_id, **kwargs):
    if get_current_plugin(only_active=True) is None:
        return
 
    logger.info("TaskNotification: Task Completed")
 
    config_data = config.load()
    if config_data.get("notify_task_completed") == True:
        task = Task.objects.get(id=task_id)
        setting = Setting.objects.first()
        notification_app_name = config_data['notification_app_name'] or settings.app_name
 
        console_output = reverse_output(task.console.output())
        notification.send(
            f"{notification_app_name} - {task.project.name} Task Completed", 
            f"{task.project.name}\n{task.name} Completed\nProcessing time:{hours_minutes_secs(task.processing_time)}\n\nConsole Output:{console_output}",
            config_data
        )
 
@receiver(task_removed)
def handle_task_removed(sender, task_id, **kwargs):
    if get_current_plugin(only_active=True) is None:
        return
 
    logger.info("TaskNotification: Task Removed")
 
    config_data = config.load()
    if config_data.get("notify_task_removed") == True:
        task = Task.objects.get(id=task_id)
        setting = Setting.objects.first()
        notification_app_name = config_data['notification_app_name'] or settings.app_name
        console_output = reverse_output(task.console.output())
        notification.send(
            f"{notification_app_name} - {task.project.name} Task removed", 
            f"{task.project.name}\n{task.name} was removed\nProcessing time:{hours_minutes_secs(task.processing_time)}\n\nConsole Output:{console_output}",
            config_data
        )
 
@receiver(task_failed)
def handle_task_failed(sender, task_id, **kwargs):
    if get_current_plugin(only_active=True) is None:
        return
 
    logger.info("TaskNotification: Task Failed")
 
    config_data = config.load()
    if config_data.get("notify_task_failed") == True:
        task = Task.objects.get(id=task_id)
        setting = Setting.objects.first()
        notification_app_name = config_data['notification_app_name'] or settings.app_name
        console_output = reverse_output(task.console.output())
        notification.send(
            f"{notification_app_name} - {task.project.name} Task Failed", 
            f"{task.project.name}\n{task.name} Failed with error: {task.last_error}\nProcessing time:{hours_minutes_secs(task.processing_time)}\n\nConsole Output:{console_output}",
            config_data
        )
 
def hours_minutes_secs(milliseconds):
    if milliseconds == 0 or milliseconds == -1:
        return "-- : -- : --"
 
    ch = 60 * 60 * 1000
    cm = 60 * 1000
    h = milliseconds // ch
    m = (milliseconds - h * ch) // cm
    s = round((milliseconds - h * ch - m * cm) / 1000)
    pad = lambda n: '0' + str(n) if n < 10 else str(n)
 
    if s == 60:
        m += 1
        s = 0
    if m == 60:
        h += 1
        m = 0
 
    return ':'.join([pad(h), pad(m), pad(s)])
 
def reverse_output(output_string):
    # Split the output string into lines, then reverse the order
    lines = output_string.split('\n')
    lines.reverse()
 
    # Join the reversed lines back into a single string with newlines
    reversed_string = '\n'.join(lines)
 
    return reversed_string