pro/olons_server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: persist ai task user ids consistently

Browse Source
This commit is contained in:
richjohnrambo
2026-09-29 15:51:12 +08:00
parent 97a43a6c96
commit 37e89a6457
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/httpapi/ai.go
+4 -3
View File
@@ -7,6 +7,7 @@ import (
"errors" "errors"
"net/http" "net/http"
"os" "os"
"strconv"
"strings" "strings"
"time" "time"
@@ -114,7 +115,7 @@ func (a *API) aiDocumentGenerate(w http.ResponseWriter, r *http.Request, p *auth
taskID := "aitask_" + randomToken(12) taskID := "aitask_" + randomToken(12)
started := time.Now().UTC().Round(time.Millisecond) started := time.Now().UTC().Round(time.Millisecond)
if err := st.CreateAITask(r.Context(), store.AITask{ if err := st.CreateAITask(r.Context(), store.AITask{
TaskID: taskID, TenantCode: p.TenantCode, UserID: formatUserID(p.UserID), Feature: "smart_document", TaskID: taskID, TenantCode: p.TenantCode, UserID: strconv.FormatInt(p.UserID, 10), Feature: "smart_document",
Status: "processing", Progress: 10, SourceType: "text", InputHash: hashText(source), Status: "processing", Progress: 10, SourceType: "text", InputHash: hashText(source),
PromptVersion: "smart_document_v1", Model: "", PromptVersion: "smart_document_v1", Model: "",
StartedAt: &started, StartedAt: &started,
@@ -366,7 +367,7 @@ func (a *API) aiTableAnalysisCreate(w http.ResponseWriter, r *http.Request, p *a
recordID := "airec_tbl_" + randomToken(10) recordID := "airec_tbl_" + randomToken(10)
started := time.Now().UTC().Round(time.Millisecond) started := time.Now().UTC().Round(time.Millisecond)
if err := st.CreateAITask(r.Context(), store.AITask{ if err := st.CreateAITask(r.Context(), store.AITask{
TaskID: taskID, TenantCode: p.TenantCode, UserID: formatUserID(p.UserID), Feature: "smart_table", TaskID: taskID, TenantCode: p.TenantCode, UserID: strconv.FormatInt(p.UserID, 10), Feature: "smart_table",
Status: "processing", Progress: 20, SourceType: "file", SourceRefID: fileID, InputHash: hashText(fileID + ":" + topic), Status: "processing", Progress: 20, SourceType: "file", SourceRefID: fileID, InputHash: hashText(fileID + ":" + topic),
PromptVersion: "smart_table_v1", StartedAt: &started, PromptVersion: "smart_table_v1", StartedAt: &started,
}, nil); err != nil { }, nil); err != nil {
@@ -496,7 +497,7 @@ func (a *API) aiMeetingSummaryCreate(w http.ResponseWriter, r *http.Request, p *
summaryID := "aisum_" + randomToken(10) summaryID := "aisum_" + randomToken(10)
started := time.Now().UTC().Round(time.Millisecond) started := time.Now().UTC().Round(time.Millisecond)
if err := st.CreateAITask(r.Context(), store.AITask{ if err := st.CreateAITask(r.Context(), store.AITask{
TaskID: taskID, TenantCode: p.TenantCode, UserID: formatUserID(p.UserID), Feature: "meeting_summary", TaskID: taskID, TenantCode: p.TenantCode, UserID: strconv.FormatInt(p.UserID, 10), Feature: "meeting_summary",
Status: "processing", Progress: 20, SourceType: "meeting", SourceRefID: meetingID, InputHash: hashText(meetingID + strings.Join(fileIDs, ",")), Status: "processing", Progress: 20, SourceType: "meeting", SourceRefID: meetingID, InputHash: hashText(meetingID + strings.Join(fileIDs, ",")),
PromptVersion: "meeting_summary_v1", StartedAt: &started, PromptVersion: "meeting_summary_v1", StartedAt: &started,
}, nil); err != nil { }, nil); err != nil {