fiee/fonchain-fiee
10
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update task.go

Browse Source
This commit is contained in:
戴育兵 2026-01-15 16:26:34 +08:00
parent 7ce6994bc4
commit 7b9f75f27e
1 changed files with 46 additions and 43 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

89
pkg/cron/task.go
View File

@ -387,53 +387,56 @@ func ScheduledPublishTask() {
} }
func TaskStatus() { func TaskStatus() {
resp, err := service.CastProvider.ListTaskList(context.Background(), &cast.ListTaskListReq{ var actions []string = []string{"publishBatch1", "publishBatch2"}
Action: "publishBatch", for _, action := range actions {
Status: 1, resp, err := service.CastProvider.ListTaskList(context.Background(), &cast.ListTaskListReq{
Page: 1, Action: action,
PageSize: 100, Status: 1,
}) Page: 1,
if err != nil { PageSize: 100,
zap.L().Error("获取任务列表失败", zap.Error(err)) })
return if err != nil {
} zap.L().Error("获取任务列表失败", zap.Error(err))
for _, v := range resp.Data { return
var extraData modelCast.PublishTaskDto
if v.ExtraData == "" {
continue
} }
_ = json.Unmarshal([]byte(v.ExtraData), &extraData) for _, v := range resp.Data {
var allDone = true var extraData modelCast.PublishTaskDto
for _, workUuid := range extraData.WorkUuids { if v.ExtraData == "" {
infoResp, _err := service.CastProvider.WorkInfo(context.Background(), &cast.WorkInfoReq{WorkUuid: workUuid})
if _err != nil {
zap.L().Error("获取作品信息失败", zap.Error(_err))
allDone = false
break
}
if infoResp.PublishStatus != cast.PublishStatusENUM_PublishMediaStatus_DONE {
allDone = false
break
}
}
var excelUrl string
if allDone {
excelUrl, err = serverCast.PublishTaskExcel(extraData.WorkUuids, true, v.Action)
if err != nil {
zap.L().Error("生成发布任务Excel失败", zap.Error(err))
continue continue
} }
_, err = service.CastProvider.UpsertTaskList(context.Background(), &cast.UpsertTaskListReq{ _ = json.Unmarshal([]byte(v.ExtraData), &extraData)
Uuid: v.Uuid, var allDone = true
Action: v.Action, for _, workUuid := range extraData.WorkUuids {
Url: excelUrl, infoResp, _err := service.CastProvider.WorkInfo(context.Background(), &cast.WorkInfoReq{WorkUuid: workUuid})
Status: 3, if _err != nil {
}) zap.L().Error("获取作品信息失败", zap.Error(_err))
if err != nil { allDone = false
zap.L().Error("更新任务状态失败", zap.Error(err)) break
continue }
if infoResp.PublishStatus != cast.PublishStatusENUM_PublishMediaStatus_DONE {
allDone = false
break
}
}
var excelUrl string
if allDone {
excelUrl, err = serverCast.PublishTaskExcel(extraData.WorkUuids, true, v.Action)
if err != nil {
zap.L().Error("生成发布任务Excel失败", zap.Error(err))
continue
}
_, err = service.CastProvider.UpsertTaskList(context.Background(), &cast.UpsertTaskListReq{
Uuid: v.Uuid,
Action: v.Action,
Url: excelUrl,
Status: 3,
})
if err != nil {
zap.L().Error("更新任务状态失败", zap.Error(err))
continue
}
zap.L().Info("任务已完成，更新状态为完成", zap.String("task_uuid", v.Uuid), zap.String("excel_url", excelUrl))
} }
zap.L().Info("任务已完成，更新状态为完成", zap.String("task_uuid", v.Uuid), zap.String("excel_url", excelUrl))
} }
} }
} }