异步任务列表

api/cast/cast.pb.go

@@ -13140,6 +13140,10 @@ type WorkListResp_Info struct {
 	DmStatus          uint32                 `protobuf:"varint,21,opt,name=dmStatus,proto3" json:"dmStatus"`
 	ConfirmType       uint32                 `protobuf:"varint,22,opt,name=confirmType,proto3" json:"confirmType"`
 	Remark            string                 `protobuf:"bytes,23,opt,name=remark,proto3" json:"remark"`
+	Status1Time       string                 `protobuf:"bytes,24,opt,name=status1Time,proto3" json:"status1Time"`
+	Status4Time       string                 `protobuf:"bytes,25,opt,name=status4Time,proto3" json:"status4Time"`
+	Status9Time       string                 `protobuf:"bytes,26,opt,name=status9Time,proto3" json:"status9Time"`
+	Status6Time       string                 `protobuf:"bytes,27,opt,name=status6Time,proto3" json:"status6Time"`
 	unknownFields     protoimpl.UnknownFields
 	sizeCache         protoimpl.SizeCache
 }
@@ -13335,6 +13339,34 @@ func (x *WorkListResp_Info) GetRemark() string {
 	return ""
 }
 
+func (x *WorkListResp_Info) GetStatus1Time() string {
+	if x != nil {
+		return x.Status1Time
+	}
+	return ""
+}
+
+func (x *WorkListResp_Info) GetStatus4Time() string {
+	if x != nil {
+		return x.Status4Time
+	}
+	return ""
+}
+
+func (x *WorkListResp_Info) GetStatus9Time() string {
+	if x != nil {
+		return x.Status9Time
+	}
+	return ""
+}
+
+func (x *WorkListResp_Info) GetStatus6Time() string {
+	if x != nil {
+		return x.Status6Time
+	}
+	return ""
+}
+
 type MediaAccountsResp_Info struct {
 	state            protoimpl.MessageState `protogen:"open.v1"`
 	PlatformID       uint32                 `protobuf:"varint,1,opt,name=platformID,proto3" json:"platformID"`
@@ -14039,10 +14071,10 @@ const file_pb_fiee_cast_proto_rawDesc = "" +
 	"\n" +
 	"startTime6\x18\x1b \x01(\tR\n" +
 	"startTime6\x12\x1a\n" +
-	"\bendTime6\x18\x1c \x01(\tR\bendTime6\"\xe6\x06\n" +
+	"\bendTime6\x18\x1c \x01(\tR\bendTime6\"\xee\a\n" +
 	"\fWorkListResp\x12+\n" +
 	"\x04data\x18\x01 \x03(\v2\x17.Cast.WorkListResp.InfoR\x04data\x12\x14\n" +
-	"\x05count\x18\x02 \x01(\x03R\x05count\x1a\x92\x06\n" +
+	"\x05count\x18\x02 \x01(\x03R\x05count\x1a\x9a\a\n" +
 	"\x04Info\x12\x1a\n" +
 	"\bworkUuid\x18\x01 \x01(\tR\bworkUuid\x12\x1e\n" +
 	"\n" +
@@ -14077,7 +14109,11 @@ const file_pb_fiee_cast_proto_rawDesc = "" +
 	"\tinsStatus\x18\x14 \x01(\rR\tinsStatus\x12\x1a\n" +
 	"\bdmStatus\x18\x15 \x01(\rR\bdmStatus\x12 \n" +
 	"\vconfirmType\x18\x16 \x01(\rR\vconfirmType\x12\x16\n" +
-	"\x06remark\x18\x17 \x01(\tR\x06remark\"+\n" +
+	"\x06remark\x18\x17 \x01(\tR\x06remark\x12 \n" +
+	"\vstatus1Time\x18\x18 \x01(\tR\vstatus1Time\x12 \n" +
+	"\vstatus4Time\x18\x19 \x01(\tR\vstatus4Time\x12 \n" +
+	"\vstatus9Time\x18\x1a \x01(\tR\vstatus9Time\x12 \n" +
+	"\vstatus6Time\x18\x1b \x01(\tR\vstatus6Time\"+\n" +
 	"\rWorkDetailReq\x12\x1a\n" +
 	"\bworkUuid\x18\x01 \x01(\tR\bworkUuid\"\xfb\x01\n" +
 	"\vWorkLogInfo\x12\x1a\n" +

api/cast/cast.pb.validate.go

@@ -19733,6 +19733,14 @@ func (m *WorkListResp_Info) validate(all bool) error {
 
 	// no validation rules for Remark
 
+	// no validation rules for Status1Time
+
+	// no validation rules for Status4Time
+
+	// no validation rules for Status9Time
+
+	// no validation rules for Status6Time
+
 	if len(errors) > 0 {
 		return WorkListResp_InfoMultiError(errors)
 	}

pkg/router/media.go

@@ -59,6 +59,11 @@ func MediaRouter(r *gin.RouterGroup) {
 		script.POST("delete", serviceCast.DeleteVideoScript)
 	}
 
+	task := auth.Group("task")
+	{
+		task.POST("list", serviceCast.TaskList)
+	}
+
 	layout := auth.Group("layout")
 	{
 		layout.POST("update", serviceCast.LayoutUpdate)

pkg/service/cast/task.go

@@ -0,0 +1,28 @@
+package cast
+
+import (
+	"context"
+	"fmt"
+	"fonchain-fiee/api/cast"
+	"fonchain-fiee/pkg/model/login"
+	"fonchain-fiee/pkg/service"
+
+	"github.com/gin-gonic/gin"
+)
+
+func TaskList(ctx *gin.Context) {
+	var req *cast.ListTaskListReq
+	var err error
+	if err = ctx.ShouldBind(&req); err != nil {
+		service.Error(ctx, err)
+		return
+	}
+	loginInfo := login.GetUserInfoFromC(ctx)
+	req.OperatorID = fmt.Sprint(loginInfo.ID)
+	resp, err := service.CastProvider.ListTaskList(context.Background(), req)
+	if err != nil {
+		service.Error(ctx, err)
+		return
+	}
+	service.Success(ctx, resp)
+}

pkg/service/cast/work.go

@@ -1087,7 +1087,7 @@ func ImportWorkBatch(ctx *gin.Context) {
 			var subInfoResp *accountFiee.UserInfoResponse
 			if config.AppConfig.System.AppMode == "dev" { //FIXME
 				subInfoResp = &accountFiee.UserInfoResponse{
-					Id:          123456,
+					Id:          1245,
 					Name:        "测试用户",
 					TelNum:      "18288888888",
 					TelAreaCode: "86",
@@ -1152,7 +1152,7 @@ func ImportWorkBatch(ctx *gin.Context) {
 				if utils.CleanString(row[i]) != "" {
 					ok, _err := check.SecurityFile(row[i])
 					if _err != nil {
-						temp.Remark = _err.Error()
+						temp.Remark = fmt.Sprintf("图片%d:%s", i-7, _err.Error())
 						req.ImageWorks = append(req.ImageWorks, temp)
 						break
 					}