From c6fb23bfa7ff9e5f080650ee5a7addbe2c3da16c Mon Sep 17 00:00:00 2001 From: Leufolium Date: Thu, 1 Aug 2024 21:31:22 +0800 Subject: [PATCH] 1 --- library/contentaudit/textaudit/textaudit.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/library/contentaudit/textaudit/textaudit.go b/library/contentaudit/textaudit/textaudit.go index 821f9547..368824df 100644 --- a/library/contentaudit/textaudit/textaudit.go +++ b/library/contentaudit/textaudit/textaudit.go @@ -139,6 +139,7 @@ func handleScanTextResponseBodyDataElements(ctrlBlock *TextAuditTaskBatchControl // 4.等待所有动作链元素均已抵达，判定本批次对该字段的操作是否成功 if isActionCompleted { + logger.Info("entering finalizeTask...") if err = finalizeTask(action); err != nil { logger.Error("finalizeTask fail: %v", err) } @@ -170,6 +171,7 @@ func handleTextAudit(id *string, result *textaudit.ScanTextResponseBodyDataEleme // 通过task的actionId查出action, 通知该task已完成 func handleTaskAction(task *TextAuditTaskControlBlock, actionMap map[string]*TextAuditAction) (isActionCompleted bool, action *TextAuditAction) { + logger.Info("entering handleTaskAction...") action = actionMap[task.ActionId] action.AuditedTaskNum++ @@ -205,6 +207,8 @@ func finalizeTask(action *TextAuditAction) (err error) { } } } + + logger.Info("reday for handler execution...") // 判定任务链终态，终态非成功，执行回退操作，记录到数据库中 if !action.IsPassed() { if err = executeRollBack(lastValidTask.TextAuditTask); err != nil { @@ -221,6 +225,7 @@ func finalizeTask(action *TextAuditAction) (err error) { } // 终态成功，执行成功后操作 + logger.Info("reday for success...") if action.IsPassed() { if err = handleSuccess(action.TaskChain[len(action.TaskChain)-1].TextAuditTask); err != nil { return