Merge branch 'dev' of http://gitea.tools.fontree.cn:3000/fiee/fonchain-fiee into dev

api/cast/cast_triple.pb.go

@@ -1,7 +1,7 @@
 // Code generated by protoc-gen-go-triple. DO NOT EDIT.
 // versions:
 // - protoc-gen-go-triple v1.0.8
-// - protoc             v3.21.1
+// - protoc             v6.32.0--rc2
 // source: pb/fiee/cast.proto
 
 package cast

pkg/cron/task.go

@@ -27,7 +27,7 @@ import (
 // InitTasks 初始化定时任务
 func InitTasks() error {
 	cm := GetCronManager()
-	err := cm.AddTask("refreshWorkApprovalStatus", "0 */5 * * * *", RefreshWorkApprovalStatusTask)
+	err := cm.AddTask("refreshWorkApprovalStatus", "0 */1 * * * *", RefreshApprovalStatusTask)
 	err = cm.AddTask("artistAutoConfirm", "0 */1 * * * *", ArtistAutoConfirmTask)
 	err = cm.AddTask("refreshPublishStatus", "0 */5 * * * *", PublishTask)
 	err = cm.AddTask("scheduledPublish", "0 */1 * * * *", ScheduledPublishTask) //FIXME正式30分钟一次
@@ -61,6 +61,12 @@ func InitTasks() error {
 	return nil
 }
 
+func RefreshApprovalStatusTask() {
+	go RefreshWorkApprovalStatusTask()
+	go RefreshScriptApprovalStatusTask()
+}
+
+// RefreshWorkApprovalStatusTask 刷新作品审批状态任务
 func RefreshWorkApprovalStatusTask() {
 	resp, err := service.CastProvider.WorkList(context.Background(), &cast.WorkListReq{
 		Page:       1,
@@ -77,6 +83,44 @@ func RefreshWorkApprovalStatusTask() {
 	serverCast.RefreshWorkApproval(nil, resp.Data)
 }
 
+// RefreshScriptApprovalStatusTask 刷新脚本审批状态任务
+func RefreshScriptApprovalStatusTask() {
+	resp, err := service.CastProvider.ListVideoScripts(context.Background(), &cast.ListVideoScriptsReq{
+		Status:   2,
+		Page:     1,
+		PageSize: 9999,
+	})
+	if err != nil {
+		log.Printf("获取工作列表失败: %v", err)
+		return
+	}
+	if resp.Data == nil || len(resp.Data) == 0 {
+		return
+	}
+	var approvalIds []int
+	for _, v := range resp.Data {
+		id, _ := strconv.ParseInt(v.ApprovalID, 10, 64)
+		approvalIds = append(approvalIds, int(id))
+	}
+	var data map[int]modelCast.Item
+	castService := new(serverCast.CastService)
+	data, err = castService.ApprovalDetail(approvalIds)
+	if err != nil {
+		return
+	}
+	for _, v := range data {
+		var scriptReq cast.UpdateScriptStatusReq
+		if v.Status == 2 {
+			scriptReq.WorkAction = cast.WorkActionENUM_APPROVAL_PASS
+		}
+		if v.Status == 3 {
+			scriptReq.WorkAction = cast.WorkActionENUM_APPROVAL_REJECT
+		}
+		scriptReq.ApprovalReply = v.Reply
+		_, _ = service.CastProvider.UpdateScriptStatus(context.Background(), &scriptReq)
+	}
+}
+
 // AutoManuallyConfirmWorkTaskWithRandomInterval 以随机间隔（3-7分钟）执行自动确认任务
 func AutoManuallyConfirmWorkTaskWithRandomInterval() {