引包目录名调整
This commit is contained in:
24
digital-human/model/dto/async_task_ref_dto.go
Normal file
24
digital-human/model/dto/async_task_ref_dto.go
Normal file
@@ -0,0 +1,24 @@
|
||||
package dto
|
||||
|
||||
import "github.com/gogf/gf/v2/frame/g"
|
||||
|
||||
// SyncAsyncTasksReq 定时任务/业务侧轮询使用:同步处理中间件任务状态并转移结果
|
||||
type SyncAsyncTasksReq struct {
|
||||
g.Meta `path:"/syncAsyncTasks" method:"post" tags:"异步任务" summary:"同步异步任务" dc:"扫描本服务待处理任务(task_id),批量查询 model-asynch 状态,成功则转移OSS并更新业务表"`
|
||||
Limit int `p:"limit" json:"limit" dc:"单次处理上限(默认200)"`
|
||||
}
|
||||
|
||||
type SyncAsyncTasksItem struct {
|
||||
TaskID string `json:"taskId"`
|
||||
State int `json:"state"`
|
||||
TableName string `json:"tableName"`
|
||||
BizID string `json:"bizId"`
|
||||
OssFile string `json:"ossFile"`
|
||||
ErrorMsg string `json:"errorMsg"`
|
||||
}
|
||||
|
||||
type SyncAsyncTasksRes struct {
|
||||
Total int `json:"total" dc:"本次扫描到的任务数"`
|
||||
Handled int `json:"handled" dc:"本次成功处理数(含更新状态/转移)"`
|
||||
List []SyncAsyncTasksItem `json:"list" dc:"任务明细"`
|
||||
}
|
||||
Reference in New Issue
Block a user