File size: 2,400 Bytes
b4f2238
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
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
"""案件绑定文件夹扫描会话模型。"""

from __future__ import annotations

import uuid
from typing import ClassVar

from django.db import models
from django.utils.translation import gettext_lazy as _

from .case import Case


class CaseFolderScanStatus(models.TextChoices):
    PENDING = "pending", _("待执行")
    RUNNING = "running", _("扫描中")
    CLASSIFYING = "classifying", _("分类中")
    COMPLETED = "completed", _("已完成")
    STAGED = "staged", _("已导入附件")
    FAILED = "failed", _("失败")
    CANCELLED = "cancelled", _("已取消")


class CaseFolderScanSession(models.Model):
    """案件自动捕获扫描会话。"""

    id = models.UUIDField(primary_key=True, default=uuid.uuid4, editable=False)
    case = models.ForeignKey(
        Case,
        on_delete=models.CASCADE,
        related_name="folder_scan_sessions",
        verbose_name=_("案件"),
    )
    status = models.CharField(
        max_length=16,
        choices=CaseFolderScanStatus.choices,
        default=CaseFolderScanStatus.PENDING,
        verbose_name=_("状态"),
    )
    task_id = models.CharField(max_length=64, blank=True, default="", verbose_name=_("DjangoQ任务ID"))
    progress = models.PositiveIntegerField(default=0, verbose_name=_("进度百分比"))
    current_file = models.CharField(max_length=255, blank=True, default="", verbose_name=_("当前文件"))
    result_payload = models.JSONField(default=dict, blank=True, verbose_name=_("结果载荷"))
    error_message = models.TextField(blank=True, default="", verbose_name=_("错误信息"))
    started_by = models.ForeignKey(
        "organization.Lawyer",
        on_delete=models.SET_NULL,
        null=True,
        blank=True,
        related_name="case_folder_scan_sessions",
        verbose_name=_("发起人"),
    )
    created_at = models.DateTimeField(auto_now_add=True, verbose_name=_("创建时间"))
    updated_at = models.DateTimeField(auto_now=True, verbose_name=_("更新时间"))

    class Meta:
        verbose_name = _("案件文件夹扫描会话")
        verbose_name_plural = _("案件文件夹扫描会话")
        indexes: ClassVar = [
            models.Index(fields=["case", "-created_at"]),
            models.Index(fields=["status", "-created_at"]),
        ]

    def __str__(self) -> str:
        return f"case:{self.case_id} session:{self.id} status:{self.status}"