File size: 3,065 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 | """合同 OA 信息同步会话模型。"""
from __future__ import annotations
from typing import ClassVar
from django.db import models
from django.utils.translation import gettext_lazy as _
class ContractOASyncStatus(models.TextChoices):
PENDING = "pending", _("待执行")
RUNNING = "running", _("执行中")
COMPLETED = "completed", _("已完成")
FAILED = "failed", _("失败")
CANCELLED = "cancelled", _("已取消")
class ContractOASyncSession(models.Model):
"""合同 OA 信息批量同步会话。"""
id: int
started_by_id: int | None
status: models.CharField = models.CharField(
max_length=16,
choices=ContractOASyncStatus.choices,
default=ContractOASyncStatus.PENDING,
verbose_name=_("状态"),
)
task_id: models.CharField = models.CharField(max_length=64, blank=True, default="", verbose_name=_("DjangoQ任务ID"))
total_count: models.PositiveIntegerField = models.PositiveIntegerField(default=0, verbose_name=_("总数"))
processed_count: models.PositiveIntegerField = models.PositiveIntegerField(default=0, verbose_name=_("已处理"))
matched_count: models.PositiveIntegerField = models.PositiveIntegerField(default=0, verbose_name=_("唯一命中"))
multiple_count: models.PositiveIntegerField = models.PositiveIntegerField(default=0, verbose_name=_("多结果"))
not_found_count: models.PositiveIntegerField = models.PositiveIntegerField(default=0, verbose_name=_("未匹配"))
error_count: models.PositiveIntegerField = models.PositiveIntegerField(default=0, verbose_name=_("错误"))
progress_message: models.CharField = models.CharField(
max_length=255, blank=True, default="", verbose_name=_("进度信息")
)
result_payload: models.JSONField = models.JSONField(default=dict, blank=True, verbose_name=_("结果载荷"))
error_message: models.TextField = models.TextField(blank=True, default="", verbose_name=_("错误信息"))
started_by: models.ForeignKey = models.ForeignKey(
"organization.Lawyer",
on_delete=models.SET_NULL,
null=True,
blank=True,
related_name="contract_oa_sync_sessions",
verbose_name=_("发起人"),
)
started_at: models.DateTimeField = models.DateTimeField(null=True, blank=True, verbose_name=_("开始时间"))
completed_at: models.DateTimeField = models.DateTimeField(null=True, blank=True, verbose_name=_("完成时间"))
created_at: models.DateTimeField = models.DateTimeField(auto_now_add=True, verbose_name=_("创建时间"))
updated_at: models.DateTimeField = models.DateTimeField(auto_now=True, verbose_name=_("更新时间"))
class Meta:
verbose_name = _("合同OA同步会话")
verbose_name_plural = _("合同OA同步会话")
indexes: ClassVar = [
models.Index(fields=["status", "-created_at"]),
models.Index(fields=["started_by", "-created_at"]),
]
def __str__(self) -> str:
return f"contract_oa_sync:{self.pk} status:{self.status}"
|