diff --git a/fastapi_modules/fastapi_leaudit/services/impl/crossReviewServiceImpl.py b/fastapi_modules/fastapi_leaudit/services/impl/crossReviewServiceImpl.py index 8b4f325..4f53d8a 100644 --- a/fastapi_modules/fastapi_leaudit/services/impl/crossReviewServiceImpl.py +++ b/fastapi_modules/fastapi_leaudit/services/impl/crossReviewServiceImpl.py @@ -2,10 +2,13 @@ from __future__ import annotations +import logging from math import floor from sqlalchemy import bindparam, text +logger = logging.getLogger(__name__) + from fastapi_common.fastapi_common_sqlalchemy.database import GetAsyncSession from fastapi_common.fastapi_common_web.domain.responses import StatusCodeEnum from fastapi_common.fastapi_common_web.exception.LeauditException import LeauditException @@ -38,6 +41,8 @@ from fastapi_modules.fastapi_leaudit.domian.vo.crossReviewVo import ( ) from fastapi_modules.fastapi_leaudit.services.crossReviewService import ICrossReviewService from fastapi_modules.fastapi_leaudit.services.documentService import IDocumentService +from fastapi_modules.fastapi_leaudit.services.auditService import IAuditService +from fastapi_modules.fastapi_leaudit.services.impl.auditServiceImpl import AuditServiceImpl from fastapi_modules.fastapi_leaudit.services.impl.documentServiceImpl import DocumentServiceImpl @@ -142,6 +147,7 @@ class CrossReviewServiceImpl(ICrossReviewService): def __init__(self): self.DocumentService: IDocumentService = DocumentServiceImpl() + self.AuditService: IAuditService = AuditServiceImpl() async def CreateTask(self, CurrentUserId: int, Body: CrossReviewTaskCreateDTO) -> CrossReviewTaskCreateVO: """创建交叉评查任务。""" @@ -213,6 +219,20 @@ class CrossReviewServiceImpl(ICrossReviewService): }, ) + for documentId in documentIds: + try: + await self.AuditService.Run( + DocumentId=documentId, + Force=False, + Speed="normal", + TriggerUserId=CurrentUserId, + ) + except Exception as exc: + logger.warning( + "交叉评查任务创建时触发评查失败: task_id=%s document_id=%s error=%s", + taskId, documentId, exc, + ) + return CrossReviewTaskCreateVO( taskId=taskId, taskName=str(taskRow["task_name"]),