31 lines
861 B
Go
31 lines
861 B
Go
package controller
|
||
|
||
import (
|
||
"context"
|
||
|
||
"ai-agent/digital-human/model/dto"
|
||
"ai-agent/digital-human/service"
|
||
|
||
"github.com/gogf/gf/v2/util/gconv"
|
||
)
|
||
|
||
type asyncTask struct{}
|
||
|
||
// AsyncTask 异步任务同步控制器（供定时任务服务调用）
|
||
var AsyncTask = new(asyncTask)
|
||
|
||
// SyncAsyncTasks 扫描待处理任务并同步状态/转移结果
|
||
func (c *asyncTask) SyncAsyncTasks(ctx context.Context, req *dto.SyncAsyncTasksReq) (res *dto.SyncAsyncTasksRes, err error) {
|
||
// 从上下文获取用户信息（gfdb Hook 会自动填充）
|
||
if ctx.Value("userId") == nil {
|
||
ctx = context.WithValue(ctx, "userId", gconv.String(1))
|
||
}
|
||
if ctx.Value("userName") == nil {
|
||
ctx = context.WithValue(ctx, "userName", "admin")
|
||
}
|
||
if ctx.Value("tenantId") == nil {
|
||
ctx = context.WithValue(ctx, "tenantId", uint64(1))
|
||
}
|
||
return service.AsyncTask.Sync(ctx, req)
|
||
}
|