From ea3f88d0e8b24eec9c58fc2286847d75856f75b8 Mon Sep 17 00:00:00 2001 From: zzw <1464003642@qq.com> Date: Tue, 27 Oct 2026 13:53:26 +0800 Subject: [PATCH] chore: faceback --- services/analysis/internal/callback/faceback.go | 9 +++------ 1 file changed, 3 insertions(+), 6 deletions(-) diff --git a/services/analysis/internal/callback/faceback.go b/services/analysis/internal/callback/faceback.go index 80ff4c5..860902f 100644 --- a/services/analysis/internal/callback/faceback.go +++ b/services/analysis/internal/callback/faceback.go @@ -43,8 +43,6 @@ type AnalysisSummary struct { PredictedAge string `json:"predicted_age"` } -// ProcessPyCallback 对应旧项目 POST /v1/analysis/callback -// 入参 task_id 实际为 python 侧的 sub_task_id。 func ProcessPyCallback(subTaskId string) error { sub, err := GetSubTask(subTaskId) if err != nil { @@ -90,9 +88,9 @@ func FinishSubTask(subTaskId string) error { _, err := model.ImageAnalysisSubModel{}.Init().Edit(modelbase.Params{ Eq: map[string]string{"sub_task_id": subTaskId}, }, map[string]interface{}{ - "status": dao.AnalysisStatusDone, - "process_end_ts": time.Now().UnixMilli(), - "updated_at": utils.Now(), + "status": dao.AnalysisStatusDone, + "process_end_ts": time.Now().UnixMilli(), + "updated_at": utils.Now(), }) return err } @@ -341,7 +339,6 @@ func CountFinishedTask(taskId string) (int64, error) { }) } -// TryFinishTask 六组图都已上传 OSS 后做最终落库。可重复调用,已完成则直接返回。 func TryFinishTask(taskId string) error { count, err := CountFinishedTask(taskId) if err != nil || count < 6 {