Compare commits

..

3 Commits

Author SHA1 Message Date
b35278771e 跳转 2025-09-24 11:47:16 +08:00
4dba6c7669 视频封面 2025-09-22 16:41:40 +08:00
8271683614 添加信息查询 2025-09-22 16:29:38 +08:00
10 changed files with 513 additions and 63 deletions

View File

@ -1012,7 +1012,7 @@ type UpdateWorkVideoReq struct {
ArtistName string `protobuf:"bytes,15,opt,name=artistName,proto3" json:"artistName"` ArtistName string `protobuf:"bytes,15,opt,name=artistName,proto3" json:"artistName"`
ArtistPhoneAreaCode string `protobuf:"bytes,16,opt,name=artistPhoneAreaCode,proto3" json:"artistPhoneAreaCode"` ArtistPhoneAreaCode string `protobuf:"bytes,16,opt,name=artistPhoneAreaCode,proto3" json:"artistPhoneAreaCode"`
Source uint32 `protobuf:"varint,17,opt,name=source,proto3" json:"source"` Source uint32 `protobuf:"varint,17,opt,name=source,proto3" json:"source"`
CoverTimestampMs uint32 `protobuf:"varint,18,opt,name=coverTimestampMs,proto3" json:"coverTimestampMs"` CoverTimestampMs uint64 `protobuf:"varint,18,opt,name=coverTimestampMs,proto3" json:"coverTimestampMs"`
unknownFields protoimpl.UnknownFields unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache sizeCache protoimpl.SizeCache
} }
@ -1166,7 +1166,7 @@ func (x *UpdateWorkVideoReq) GetSource() uint32 {
return 0 return 0
} }
func (x *UpdateWorkVideoReq) GetCoverTimestampMs() uint32 { func (x *UpdateWorkVideoReq) GetCoverTimestampMs() uint64 {
if x != nil { if x != nil {
return x.CoverTimestampMs return x.CoverTimestampMs
} }
@ -1580,6 +1580,7 @@ type WorkDetailResp struct {
WorkLogData []*WorkLogInfo `protobuf:"bytes,15,rep,name=WorkLogData,proto3" json:"WorkLogData"` WorkLogData []*WorkLogInfo `protobuf:"bytes,15,rep,name=WorkLogData,proto3" json:"WorkLogData"`
WorkCategory uint32 `protobuf:"varint,16,opt,name=workCategory,proto3" json:"workCategory"` WorkCategory uint32 `protobuf:"varint,16,opt,name=workCategory,proto3" json:"workCategory"`
MediaAccData map[string]*MediaUserInfo `protobuf:"bytes,17,rep,name=mediaAccData,proto3" json:"mediaAccData" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"` MediaAccData map[string]*MediaUserInfo `protobuf:"bytes,17,rep,name=mediaAccData,proto3" json:"mediaAccData" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
CoverTimestampMs uint64 `protobuf:"varint,18,opt,name=coverTimestampMs,proto3" json:"coverTimestampMs"`
unknownFields protoimpl.UnknownFields unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache sizeCache protoimpl.SizeCache
} }
@ -1733,6 +1734,13 @@ func (x *WorkDetailResp) GetMediaAccData() map[string]*MediaUserInfo {
return nil return nil
} }
func (x *WorkDetailResp) GetCoverTimestampMs() uint64 {
if x != nil {
return x.CoverTimestampMs
}
return 0
}
type UpdateStatusReq struct { type UpdateStatusReq struct {
state protoimpl.MessageState `protogen:"open.v1"` state protoimpl.MessageState `protogen:"open.v1"`
WorkAction WorkActionENUM `protobuf:"varint,1,opt,name=workAction,proto3,enum=Cast.WorkActionENUM" json:"workAction"` WorkAction WorkActionENUM `protobuf:"varint,1,opt,name=workAction,proto3,enum=Cast.WorkActionENUM" json:"workAction"`
@ -2694,6 +2702,134 @@ func (x *RefreshTokenResp) GetAccessToken() string {
return "" return ""
} }
type PublishMediaInfoReq struct {
state protoimpl.MessageState `protogen:"open.v1"`
WorkUuid string `protobuf:"bytes,1,opt,name=workUuid,proto3" json:"workUuid"`
PlatformID int32 `protobuf:"varint,2,opt,name=platformID,proto3" json:"platformID"`
PlatformMediaUuid string `protobuf:"bytes,3,opt,name=platformMediaUuid,proto3" json:"platformMediaUuid"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *PublishMediaInfoReq) Reset() {
*x = PublishMediaInfoReq{}
mi := &file_pb_fiee_cast_proto_msgTypes[36]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *PublishMediaInfoReq) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*PublishMediaInfoReq) ProtoMessage() {}
func (x *PublishMediaInfoReq) ProtoReflect() protoreflect.Message {
mi := &file_pb_fiee_cast_proto_msgTypes[36]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use PublishMediaInfoReq.ProtoReflect.Descriptor instead.
func (*PublishMediaInfoReq) Descriptor() ([]byte, []int) {
return file_pb_fiee_cast_proto_rawDescGZIP(), []int{36}
}
func (x *PublishMediaInfoReq) GetWorkUuid() string {
if x != nil {
return x.WorkUuid
}
return ""
}
func (x *PublishMediaInfoReq) GetPlatformID() int32 {
if x != nil {
return x.PlatformID
}
return 0
}
func (x *PublishMediaInfoReq) GetPlatformMediaUuid() string {
if x != nil {
return x.PlatformMediaUuid
}
return ""
}
type PublishMediaInfoResp struct {
state protoimpl.MessageState `protogen:"open.v1"`
WorkUuid string `protobuf:"bytes,1,opt,name=workUuid,proto3" json:"workUuid"`
PlatformID int32 `protobuf:"varint,2,opt,name=platformID,proto3" json:"platformID"`
PlatformMediaUuid string `protobuf:"bytes,3,opt,name=platformMediaUuid,proto3" json:"platformMediaUuid"`
Info string `protobuf:"bytes,4,opt,name=info,proto3" json:"info"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *PublishMediaInfoResp) Reset() {
*x = PublishMediaInfoResp{}
mi := &file_pb_fiee_cast_proto_msgTypes[37]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *PublishMediaInfoResp) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*PublishMediaInfoResp) ProtoMessage() {}
func (x *PublishMediaInfoResp) ProtoReflect() protoreflect.Message {
mi := &file_pb_fiee_cast_proto_msgTypes[37]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use PublishMediaInfoResp.ProtoReflect.Descriptor instead.
func (*PublishMediaInfoResp) Descriptor() ([]byte, []int) {
return file_pb_fiee_cast_proto_rawDescGZIP(), []int{37}
}
func (x *PublishMediaInfoResp) GetWorkUuid() string {
if x != nil {
return x.WorkUuid
}
return ""
}
func (x *PublishMediaInfoResp) GetPlatformID() int32 {
if x != nil {
return x.PlatformID
}
return 0
}
func (x *PublishMediaInfoResp) GetPlatformMediaUuid() string {
if x != nil {
return x.PlatformMediaUuid
}
return ""
}
func (x *PublishMediaInfoResp) GetInfo() string {
if x != nil {
return x.Info
}
return ""
}
type WorkListResp_Info struct { type WorkListResp_Info struct {
state protoimpl.MessageState `protogen:"open.v1"` state protoimpl.MessageState `protogen:"open.v1"`
WorkUuid string `protobuf:"bytes,1,opt,name=workUuid,proto3" json:"workUuid"` WorkUuid string `protobuf:"bytes,1,opt,name=workUuid,proto3" json:"workUuid"`
@ -2716,7 +2852,7 @@ type WorkListResp_Info struct {
func (x *WorkListResp_Info) Reset() { func (x *WorkListResp_Info) Reset() {
*x = WorkListResp_Info{} *x = WorkListResp_Info{}
mi := &file_pb_fiee_cast_proto_msgTypes[36] mi := &file_pb_fiee_cast_proto_msgTypes[38]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi) ms.StoreMessageInfo(mi)
} }
@ -2728,7 +2864,7 @@ func (x *WorkListResp_Info) String() string {
func (*WorkListResp_Info) ProtoMessage() {} func (*WorkListResp_Info) ProtoMessage() {}
func (x *WorkListResp_Info) ProtoReflect() protoreflect.Message { func (x *WorkListResp_Info) ProtoReflect() protoreflect.Message {
mi := &file_pb_fiee_cast_proto_msgTypes[36] mi := &file_pb_fiee_cast_proto_msgTypes[38]
if x != nil { if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil { if ms.LoadMessageInfo() == nil {
@ -2856,7 +2992,7 @@ type MediaAccountsResp_Info struct {
func (x *MediaAccountsResp_Info) Reset() { func (x *MediaAccountsResp_Info) Reset() {
*x = MediaAccountsResp_Info{} *x = MediaAccountsResp_Info{}
mi := &file_pb_fiee_cast_proto_msgTypes[38] mi := &file_pb_fiee_cast_proto_msgTypes[40]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi) ms.StoreMessageInfo(mi)
} }
@ -2868,7 +3004,7 @@ func (x *MediaAccountsResp_Info) String() string {
func (*MediaAccountsResp_Info) ProtoMessage() {} func (*MediaAccountsResp_Info) ProtoMessage() {}
func (x *MediaAccountsResp_Info) ProtoReflect() protoreflect.Message { func (x *MediaAccountsResp_Info) ProtoReflect() protoreflect.Message {
mi := &file_pb_fiee_cast_proto_msgTypes[38] mi := &file_pb_fiee_cast_proto_msgTypes[40]
if x != nil { if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil { if ms.LoadMessageInfo() == nil {
@ -2944,7 +3080,7 @@ type MediaWorksResp_Info struct {
func (x *MediaWorksResp_Info) Reset() { func (x *MediaWorksResp_Info) Reset() {
*x = MediaWorksResp_Info{} *x = MediaWorksResp_Info{}
mi := &file_pb_fiee_cast_proto_msgTypes[39] mi := &file_pb_fiee_cast_proto_msgTypes[41]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi) ms.StoreMessageInfo(mi)
} }
@ -2956,7 +3092,7 @@ func (x *MediaWorksResp_Info) String() string {
func (*MediaWorksResp_Info) ProtoMessage() {} func (*MediaWorksResp_Info) ProtoMessage() {}
func (x *MediaWorksResp_Info) ProtoReflect() protoreflect.Message { func (x *MediaWorksResp_Info) ProtoReflect() protoreflect.Message {
mi := &file_pb_fiee_cast_proto_msgTypes[39] mi := &file_pb_fiee_cast_proto_msgTypes[41]
if x != nil { if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil { if ms.LoadMessageInfo() == nil {
@ -3166,7 +3302,7 @@ const file_pb_fiee_cast_proto_rawDesc = "" +
"artistName\x120\n" + "artistName\x120\n" +
"\x13artistPhoneAreaCode\x18\x10 \x01(\tR\x13artistPhoneAreaCode\x12\x16\n" + "\x13artistPhoneAreaCode\x18\x10 \x01(\tR\x13artistPhoneAreaCode\x12\x16\n" +
"\x06source\x18\x11 \x01(\rR\x06source\x12*\n" + "\x06source\x18\x11 \x01(\rR\x06source\x12*\n" +
"\x10coverTimestampMs\x18\x12 \x01(\rR\x10coverTimestampMs\"1\n" + "\x10coverTimestampMs\x18\x12 \x01(\x04R\x10coverTimestampMs\"1\n" +
"\x13UpdateWorkVideoResp\x12\x1a\n" + "\x13UpdateWorkVideoResp\x12\x1a\n" +
"\bworkUuid\x18\x01 \x01(\tR\bworkUuid\"\x8f\x04\n" + "\bworkUuid\x18\x01 \x01(\tR\bworkUuid\"\x8f\x04\n" +
"\vWorkListReq\x12\x1c\n" + "\vWorkListReq\x12\x1c\n" +
@ -3232,7 +3368,7 @@ const file_pb_fiee_cast_proto_rawDesc = "" +
"\textraData\x18\a \x01(\tR\textraData\x12\x1e\n" + "\textraData\x18\a \x01(\tR\textraData\x12\x1e\n" +
"\n" + "\n" +
"workStatus\x18\b \x01(\rR\n" + "workStatus\x18\b \x01(\rR\n" +
"workStatus\"\x9c\x06\n" + "workStatus\"\xc8\x06\n" +
"\x0eWorkDetailResp\x12\x1a\n" + "\x0eWorkDetailResp\x12\x1a\n" +
"\bworkUuid\x18\x01 \x01(\tR\bworkUuid\x12\x14\n" + "\bworkUuid\x18\x01 \x01(\tR\bworkUuid\x12\x14\n" +
"\x05title\x18\x02 \x01(\tR\x05title\x12\x18\n" + "\x05title\x18\x02 \x01(\tR\x05title\x12\x18\n" +
@ -3255,7 +3391,8 @@ const file_pb_fiee_cast_proto_rawDesc = "" +
"approvalID\x123\n" + "approvalID\x123\n" +
"\vWorkLogData\x18\x0f \x03(\v2\x11.Cast.WorkLogInfoR\vWorkLogData\x12\"\n" + "\vWorkLogData\x18\x0f \x03(\v2\x11.Cast.WorkLogInfoR\vWorkLogData\x12\"\n" +
"\fworkCategory\x18\x10 \x01(\rR\fworkCategory\x12J\n" + "\fworkCategory\x18\x10 \x01(\rR\fworkCategory\x12J\n" +
"\fmediaAccData\x18\x11 \x03(\v2&.Cast.WorkDetailResp.MediaAccDataEntryR\fmediaAccData\x1aT\n" + "\fmediaAccData\x18\x11 \x03(\v2&.Cast.WorkDetailResp.MediaAccDataEntryR\fmediaAccData\x12*\n" +
"\x10coverTimestampMs\x18\x12 \x01(\x04R\x10coverTimestampMs\x1aT\n" +
"\x11MediaAccDataEntry\x12\x10\n" + "\x11MediaAccDataEntry\x12\x10\n" +
"\x03key\x18\x01 \x01(\tR\x03key\x12)\n" + "\x03key\x18\x01 \x01(\tR\x03key\x12)\n" +
"\x05value\x18\x02 \x01(\v2\x13.Cast.MediaUserInfoR\x05value:\x028\x01\"\xf5\x01\n" + "\x05value\x18\x02 \x01(\v2\x13.Cast.MediaUserInfoR\x05value:\x028\x01\"\xf5\x01\n" +
@ -3363,7 +3500,20 @@ const file_pb_fiee_cast_proto_rawDesc = "" +
"platformID\x12\x16\n" + "platformID\x12\x16\n" +
"\x06userID\x18\x03 \x01(\tR\x06userID\"4\n" + "\x06userID\x18\x03 \x01(\tR\x06userID\"4\n" +
"\x10RefreshTokenResp\x12 \n" + "\x10RefreshTokenResp\x12 \n" +
"\vaccessToken\x18\x01 \x01(\tR\vaccessToken*G\n" + "\vaccessToken\x18\x01 \x01(\tR\vaccessToken\"\x7f\n" +
"\x13PublishMediaInfoReq\x12\x1a\n" +
"\bworkUuid\x18\x01 \x01(\tR\bworkUuid\x12\x1e\n" +
"\n" +
"platformID\x18\x02 \x01(\x05R\n" +
"platformID\x12,\n" +
"\x11platformMediaUuid\x18\x03 \x01(\tR\x11platformMediaUuid\"\x94\x01\n" +
"\x14PublishMediaInfoResp\x12\x1a\n" +
"\bworkUuid\x18\x01 \x01(\tR\bworkUuid\x12\x1e\n" +
"\n" +
"platformID\x18\x02 \x01(\x05R\n" +
"platformID\x12,\n" +
"\x11platformMediaUuid\x18\x03 \x01(\tR\x11platformMediaUuid\x12\x12\n" +
"\x04info\x18\x04 \x01(\tR\x04info*G\n" +
"\x0ePlatformIDENUM\x12\v\n" + "\x0ePlatformIDENUM\x12\v\n" +
"\aUNKNOWN\x10\x00\x12\n" + "\aUNKNOWN\x10\x00\x12\n" +
"\n" + "\n" +
@ -3377,7 +3527,7 @@ const file_pb_fiee_cast_proto_rawDesc = "" +
"\bAPPROVAL\x10\x02\x12\x11\n" + "\bAPPROVAL\x10\x02\x12\x11\n" +
"\rAPPROVAL_PASS\x10\x03\x12\x13\n" + "\rAPPROVAL_PASS\x10\x03\x12\x13\n" +
"\x0fAPPROVAL_REJECT\x10\x04\x12\x13\n" + "\x0fAPPROVAL_REJECT\x10\x04\x12\x13\n" +
"\x0fAPPROVAL_DELETE\x10\x052\x91\t\n" + "\x0fAPPROVAL_DELETE\x10\x052\xde\t\n" +
"\x04Cast\x12B\n" + "\x04Cast\x12B\n" +
"\rMediaUserList\x12\x16.Cast.MediaUserListReq\x1a\x17.Cast.MediaUserListResp\"\x00\x12Q\n" + "\rMediaUserList\x12\x16.Cast.MediaUserListReq\x1a\x17.Cast.MediaUserListResp\"\x00\x12Q\n" +
"\x12UpdateMediaAccount\x12\x1b.Cast.UpdateMediaAccountReq\x1a\x1c.Cast.UpdateMediaAccountResp\"\x00\x12B\n" + "\x12UpdateMediaAccount\x12\x1b.Cast.UpdateMediaAccountReq\x1a\x1c.Cast.UpdateMediaAccountResp\"\x00\x12B\n" +
@ -3397,7 +3547,8 @@ const file_pb_fiee_cast_proto_rawDesc = "" +
"\bWorkInfo\x12\x11.Cast.WorkInfoReq\x1a\x12.Cast.WorkInfoResp\"\x00\x12?\n" + "\bWorkInfo\x12\x11.Cast.WorkInfoReq\x1a\x12.Cast.WorkInfoResp\"\x00\x12?\n" +
"\fOAuthAccount\x12\x15.Cast.OAuthAccountReq\x1a\x16.Cast.OAuthAccountResp\"\x00\x12K\n" + "\fOAuthAccount\x12\x15.Cast.OAuthAccountReq\x1a\x16.Cast.OAuthAccountResp\"\x00\x12K\n" +
"\x10OAuthCodeToToken\x12\x19.Cast.OAuthCodeToTokenReq\x1a\x1a.Cast.OAuthCodeToTokenResp\"\x00\x12?\n" + "\x10OAuthCodeToToken\x12\x19.Cast.OAuthCodeToTokenReq\x1a\x1a.Cast.OAuthCodeToTokenResp\"\x00\x12?\n" +
"\fRefreshToken\x12\x15.Cast.RefreshTokenReq\x1a\x16.Cast.RefreshTokenResp\"\x00\x128\n" + "\fRefreshToken\x12\x15.Cast.RefreshTokenReq\x1a\x16.Cast.RefreshTokenResp\"\x00\x12K\n" +
"\x10PublishMediaInfo\x12\x19.Cast.PublishMediaInfoReq\x1a\x1a.Cast.PublishMediaInfoResp\"\x00\x128\n" +
"\x04Test\x12\x16.google.protobuf.Empty\x1a\x16.google.protobuf.Empty\"\x00B\rZ\v./cast;castb\x06proto3" "\x04Test\x12\x16.google.protobuf.Empty\x1a\x16.google.protobuf.Empty\"\x00B\rZ\v./cast;castb\x06proto3"
var ( var (
@ -3413,7 +3564,7 @@ func file_pb_fiee_cast_proto_rawDescGZIP() []byte {
} }
var file_pb_fiee_cast_proto_enumTypes = make([]protoimpl.EnumInfo, 2) var file_pb_fiee_cast_proto_enumTypes = make([]protoimpl.EnumInfo, 2)
var file_pb_fiee_cast_proto_msgTypes = make([]protoimpl.MessageInfo, 40) var file_pb_fiee_cast_proto_msgTypes = make([]protoimpl.MessageInfo, 42)
var file_pb_fiee_cast_proto_goTypes = []any{ var file_pb_fiee_cast_proto_goTypes = []any{
(PlatformIDENUM)(0), // 0: Cast.PlatformIDENUM (PlatformIDENUM)(0), // 0: Cast.PlatformIDENUM
(WorkActionENUM)(0), // 1: Cast.WorkActionENUM (WorkActionENUM)(0), // 1: Cast.WorkActionENUM
@ -3453,11 +3604,13 @@ var file_pb_fiee_cast_proto_goTypes = []any{
(*OAuthCodeToTokenResp)(nil), // 35: Cast.OAuthCodeToTokenResp (*OAuthCodeToTokenResp)(nil), // 35: Cast.OAuthCodeToTokenResp
(*RefreshTokenReq)(nil), // 36: Cast.RefreshTokenReq (*RefreshTokenReq)(nil), // 36: Cast.RefreshTokenReq
(*RefreshTokenResp)(nil), // 37: Cast.RefreshTokenResp (*RefreshTokenResp)(nil), // 37: Cast.RefreshTokenResp
(*WorkListResp_Info)(nil), // 38: Cast.WorkListResp.Info (*PublishMediaInfoReq)(nil), // 38: Cast.PublishMediaInfoReq
nil, // 39: Cast.WorkDetailResp.MediaAccDataEntry (*PublishMediaInfoResp)(nil), // 39: Cast.PublishMediaInfoResp
(*MediaAccountsResp_Info)(nil), // 40: Cast.MediaAccountsResp.Info (*WorkListResp_Info)(nil), // 40: Cast.WorkListResp.Info
(*MediaWorksResp_Info)(nil), // 41: Cast.MediaWorksResp.Info nil, // 41: Cast.WorkDetailResp.MediaAccDataEntry
(*emptypb.Empty)(nil), // 42: google.protobuf.Empty (*MediaAccountsResp_Info)(nil), // 42: Cast.MediaAccountsResp.Info
(*MediaWorksResp_Info)(nil), // 43: Cast.MediaWorksResp.Info
(*emptypb.Empty)(nil), // 44: google.protobuf.Empty
} }
var file_pb_fiee_cast_proto_depIdxs = []int32{ var file_pb_fiee_cast_proto_depIdxs = []int32{
0, // 0: Cast.MediaUserListReq.platformID:type_name -> Cast.PlatformIDENUM 0, // 0: Cast.MediaUserListReq.platformID:type_name -> Cast.PlatformIDENUM
@ -3472,15 +3625,15 @@ var file_pb_fiee_cast_proto_depIdxs = []int32{
12, // 9: Cast.UpdateWorkVideoReq.publishConfig1:type_name -> Cast.PublishConfig 12, // 9: Cast.UpdateWorkVideoReq.publishConfig1:type_name -> Cast.PublishConfig
12, // 10: Cast.UpdateWorkVideoReq.publishConfig2:type_name -> Cast.PublishConfig 12, // 10: Cast.UpdateWorkVideoReq.publishConfig2:type_name -> Cast.PublishConfig
12, // 11: Cast.UpdateWorkVideoReq.publishConfig3:type_name -> Cast.PublishConfig 12, // 11: Cast.UpdateWorkVideoReq.publishConfig3:type_name -> Cast.PublishConfig
38, // 12: Cast.WorkListResp.data:type_name -> Cast.WorkListResp.Info 40, // 12: Cast.WorkListResp.data:type_name -> Cast.WorkListResp.Info
12, // 13: Cast.WorkDetailResp.publishConfig1:type_name -> Cast.PublishConfig 12, // 13: Cast.WorkDetailResp.publishConfig1:type_name -> Cast.PublishConfig
12, // 14: Cast.WorkDetailResp.publishConfig2:type_name -> Cast.PublishConfig 12, // 14: Cast.WorkDetailResp.publishConfig2:type_name -> Cast.PublishConfig
12, // 15: Cast.WorkDetailResp.publishConfig3:type_name -> Cast.PublishConfig 12, // 15: Cast.WorkDetailResp.publishConfig3:type_name -> Cast.PublishConfig
18, // 16: Cast.WorkDetailResp.WorkLogData:type_name -> Cast.WorkLogInfo 18, // 16: Cast.WorkDetailResp.WorkLogData:type_name -> Cast.WorkLogInfo
39, // 17: Cast.WorkDetailResp.mediaAccData:type_name -> Cast.WorkDetailResp.MediaAccDataEntry 41, // 17: Cast.WorkDetailResp.mediaAccData:type_name -> Cast.WorkDetailResp.MediaAccDataEntry
1, // 18: Cast.UpdateStatusReq.workAction:type_name -> Cast.WorkActionENUM 1, // 18: Cast.UpdateStatusReq.workAction:type_name -> Cast.WorkActionENUM
40, // 19: Cast.MediaAccountsResp.data:type_name -> Cast.MediaAccountsResp.Info 42, // 19: Cast.MediaAccountsResp.data:type_name -> Cast.MediaAccountsResp.Info
41, // 20: Cast.MediaWorksResp.data:type_name -> Cast.MediaWorksResp.Info 43, // 20: Cast.MediaWorksResp.data:type_name -> Cast.MediaWorksResp.Info
0, // 21: Cast.OAuthCodeToTokenReq.platformID:type_name -> Cast.PlatformIDENUM 0, // 21: Cast.OAuthCodeToTokenReq.platformID:type_name -> Cast.PlatformIDENUM
0, // 22: Cast.RefreshTokenReq.platformID:type_name -> Cast.PlatformIDENUM 0, // 22: Cast.RefreshTokenReq.platformID:type_name -> Cast.PlatformIDENUM
3, // 23: Cast.WorkDetailResp.MediaAccDataEntry.value:type_name -> Cast.MediaUserInfo 3, // 23: Cast.WorkDetailResp.MediaAccDataEntry.value:type_name -> Cast.MediaUserInfo
@ -3501,27 +3654,29 @@ var file_pb_fiee_cast_proto_depIdxs = []int32{
30, // 38: Cast.Cast.OAuthAccount:input_type -> Cast.OAuthAccountReq 30, // 38: Cast.Cast.OAuthAccount:input_type -> Cast.OAuthAccountReq
34, // 39: Cast.Cast.OAuthCodeToToken:input_type -> Cast.OAuthCodeToTokenReq 34, // 39: Cast.Cast.OAuthCodeToToken:input_type -> Cast.OAuthCodeToTokenReq
36, // 40: Cast.Cast.RefreshToken:input_type -> Cast.RefreshTokenReq 36, // 40: Cast.Cast.RefreshToken:input_type -> Cast.RefreshTokenReq
42, // 41: Cast.Cast.Test:input_type -> google.protobuf.Empty 38, // 41: Cast.Cast.PublishMediaInfo:input_type -> Cast.PublishMediaInfoReq
4, // 42: Cast.Cast.MediaUserList:output_type -> Cast.MediaUserListResp 44, // 42: Cast.Cast.Test:input_type -> google.protobuf.Empty
6, // 43: Cast.Cast.UpdateMediaAccount:output_type -> Cast.UpdateMediaAccountResp 4, // 43: Cast.Cast.MediaUserList:output_type -> Cast.MediaUserListResp
8, // 44: Cast.Cast.UnbindManager:output_type -> Cast.UnbindManagerResp 6, // 44: Cast.Cast.UpdateMediaAccount:output_type -> Cast.UpdateMediaAccountResp
42, // 45: Cast.Cast.BindManager:output_type -> google.protobuf.Empty 8, // 45: Cast.Cast.UnbindManager:output_type -> Cast.UnbindManagerResp
11, // 46: Cast.Cast.UpdateWorkImage:output_type -> Cast.UpdateWorkImageResp 44, // 46: Cast.Cast.BindManager:output_type -> google.protobuf.Empty
14, // 47: Cast.Cast.UpdateWorkVideo:output_type -> Cast.UpdateWorkVideoResp 11, // 47: Cast.Cast.UpdateWorkImage:output_type -> Cast.UpdateWorkImageResp
16, // 48: Cast.Cast.WorkList:output_type -> Cast.WorkListResp 14, // 48: Cast.Cast.UpdateWorkVideo:output_type -> Cast.UpdateWorkVideoResp
19, // 49: Cast.Cast.WorkDetail:output_type -> Cast.WorkDetailResp 16, // 49: Cast.Cast.WorkList:output_type -> Cast.WorkListResp
42, // 50: Cast.Cast.UpdateStatus:output_type -> google.protobuf.Empty 19, // 50: Cast.Cast.WorkDetail:output_type -> Cast.WorkDetailResp
22, // 51: Cast.Cast.MediaAccounts:output_type -> Cast.MediaAccountsResp 44, // 51: Cast.Cast.UpdateStatus:output_type -> google.protobuf.Empty
24, // 52: Cast.Cast.MediaWorks:output_type -> Cast.MediaWorksResp 22, // 52: Cast.Cast.MediaAccounts:output_type -> Cast.MediaAccountsResp
26, // 53: Cast.Cast.RePublish:output_type -> Cast.RePublishResp 24, // 53: Cast.Cast.MediaWorks:output_type -> Cast.MediaWorksResp
42, // 54: Cast.Cast.DelWork:output_type -> google.protobuf.Empty 26, // 54: Cast.Cast.RePublish:output_type -> Cast.RePublishResp
29, // 55: Cast.Cast.WorkInfo:output_type -> Cast.WorkInfoResp 44, // 55: Cast.Cast.DelWork:output_type -> google.protobuf.Empty
31, // 56: Cast.Cast.OAuthAccount:output_type -> Cast.OAuthAccountResp 29, // 56: Cast.Cast.WorkInfo:output_type -> Cast.WorkInfoResp
35, // 57: Cast.Cast.OAuthCodeToToken:output_type -> Cast.OAuthCodeToTokenResp 31, // 57: Cast.Cast.OAuthAccount:output_type -> Cast.OAuthAccountResp
37, // 58: Cast.Cast.RefreshToken:output_type -> Cast.RefreshTokenResp 35, // 58: Cast.Cast.OAuthCodeToToken:output_type -> Cast.OAuthCodeToTokenResp
42, // 59: Cast.Cast.Test:output_type -> google.protobuf.Empty 37, // 59: Cast.Cast.RefreshToken:output_type -> Cast.RefreshTokenResp
42, // [42:60] is the sub-list for method output_type 39, // 60: Cast.Cast.PublishMediaInfo:output_type -> Cast.PublishMediaInfoResp
24, // [24:42] is the sub-list for method input_type 44, // 61: Cast.Cast.Test:output_type -> google.protobuf.Empty
43, // [43:62] is the sub-list for method output_type
24, // [24:43] is the sub-list for method input_type
24, // [24:24] is the sub-list for extension type_name 24, // [24:24] is the sub-list for extension type_name
24, // [24:24] is the sub-list for extension extendee 24, // [24:24] is the sub-list for extension extendee
0, // [0:24] is the sub-list for field type_name 0, // [0:24] is the sub-list for field type_name
@ -3538,7 +3693,7 @@ func file_pb_fiee_cast_proto_init() {
GoPackagePath: reflect.TypeOf(x{}).PkgPath(), GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
RawDescriptor: unsafe.Slice(unsafe.StringData(file_pb_fiee_cast_proto_rawDesc), len(file_pb_fiee_cast_proto_rawDesc)), RawDescriptor: unsafe.Slice(unsafe.StringData(file_pb_fiee_cast_proto_rawDesc), len(file_pb_fiee_cast_proto_rawDesc)),
NumEnums: 2, NumEnums: 2,
NumMessages: 40, NumMessages: 42,
NumExtensions: 0, NumExtensions: 0,
NumServices: 1, NumServices: 1,
}, },

View File

@ -2392,6 +2392,8 @@ func (m *WorkDetailResp) validate(all bool) error {
} }
} }
// no validation rules for CoverTimestampMs
if len(errors) > 0 { if len(errors) > 0 {
return WorkDetailRespMultiError(errors) return WorkDetailRespMultiError(errors)
} }
@ -4414,6 +4416,224 @@ var _ interface {
ErrorName() string ErrorName() string
} = RefreshTokenRespValidationError{} } = RefreshTokenRespValidationError{}
// Validate checks the field values on PublishMediaInfoReq with the rules
// defined in the proto definition for this message. If any rules are
// violated, the first error encountered is returned, or nil if there are no violations.
func (m *PublishMediaInfoReq) Validate() error {
return m.validate(false)
}
// ValidateAll checks the field values on PublishMediaInfoReq with the rules
// defined in the proto definition for this message. If any rules are
// violated, the result is a list of violation errors wrapped in
// PublishMediaInfoReqMultiError, or nil if none found.
func (m *PublishMediaInfoReq) ValidateAll() error {
return m.validate(true)
}
func (m *PublishMediaInfoReq) validate(all bool) error {
if m == nil {
return nil
}
var errors []error
// no validation rules for WorkUuid
// no validation rules for PlatformID
// no validation rules for PlatformMediaUuid
if len(errors) > 0 {
return PublishMediaInfoReqMultiError(errors)
}
return nil
}
// PublishMediaInfoReqMultiError is an error wrapping multiple validation
// errors returned by PublishMediaInfoReq.ValidateAll() if the designated
// constraints aren't met.
type PublishMediaInfoReqMultiError []error
// Error returns a concatenation of all the error messages it wraps.
func (m PublishMediaInfoReqMultiError) Error() string {
msgs := make([]string, 0, len(m))
for _, err := range m {
msgs = append(msgs, err.Error())
}
return strings.Join(msgs, "; ")
}
// AllErrors returns a list of validation violation errors.
func (m PublishMediaInfoReqMultiError) AllErrors() []error { return m }
// PublishMediaInfoReqValidationError is the validation error returned by
// PublishMediaInfoReq.Validate if the designated constraints aren't met.
type PublishMediaInfoReqValidationError struct {
field string
reason string
cause error
key bool
}
// Field function returns field value.
func (e PublishMediaInfoReqValidationError) Field() string { return e.field }
// Reason function returns reason value.
func (e PublishMediaInfoReqValidationError) Reason() string { return e.reason }
// Cause function returns cause value.
func (e PublishMediaInfoReqValidationError) Cause() error { return e.cause }
// Key function returns key value.
func (e PublishMediaInfoReqValidationError) Key() bool { return e.key }
// ErrorName returns error name.
func (e PublishMediaInfoReqValidationError) ErrorName() string {
return "PublishMediaInfoReqValidationError"
}
// Error satisfies the builtin error interface
func (e PublishMediaInfoReqValidationError) Error() string {
cause := ""
if e.cause != nil {
cause = fmt.Sprintf(" | caused by: %v", e.cause)
}
key := ""
if e.key {
key = "key for "
}
return fmt.Sprintf(
"invalid %sPublishMediaInfoReq.%s: %s%s",
key,
e.field,
e.reason,
cause)
}
var _ error = PublishMediaInfoReqValidationError{}
var _ interface {
Field() string
Reason() string
Key() bool
Cause() error
ErrorName() string
} = PublishMediaInfoReqValidationError{}
// Validate checks the field values on PublishMediaInfoResp with the rules
// defined in the proto definition for this message. If any rules are
// violated, the first error encountered is returned, or nil if there are no violations.
func (m *PublishMediaInfoResp) Validate() error {
return m.validate(false)
}
// ValidateAll checks the field values on PublishMediaInfoResp with the rules
// defined in the proto definition for this message. If any rules are
// violated, the result is a list of violation errors wrapped in
// PublishMediaInfoRespMultiError, or nil if none found.
func (m *PublishMediaInfoResp) ValidateAll() error {
return m.validate(true)
}
func (m *PublishMediaInfoResp) validate(all bool) error {
if m == nil {
return nil
}
var errors []error
// no validation rules for WorkUuid
// no validation rules for PlatformID
// no validation rules for PlatformMediaUuid
// no validation rules for Info
if len(errors) > 0 {
return PublishMediaInfoRespMultiError(errors)
}
return nil
}
// PublishMediaInfoRespMultiError is an error wrapping multiple validation
// errors returned by PublishMediaInfoResp.ValidateAll() if the designated
// constraints aren't met.
type PublishMediaInfoRespMultiError []error
// Error returns a concatenation of all the error messages it wraps.
func (m PublishMediaInfoRespMultiError) Error() string {
msgs := make([]string, 0, len(m))
for _, err := range m {
msgs = append(msgs, err.Error())
}
return strings.Join(msgs, "; ")
}
// AllErrors returns a list of validation violation errors.
func (m PublishMediaInfoRespMultiError) AllErrors() []error { return m }
// PublishMediaInfoRespValidationError is the validation error returned by
// PublishMediaInfoResp.Validate if the designated constraints aren't met.
type PublishMediaInfoRespValidationError struct {
field string
reason string
cause error
key bool
}
// Field function returns field value.
func (e PublishMediaInfoRespValidationError) Field() string { return e.field }
// Reason function returns reason value.
func (e PublishMediaInfoRespValidationError) Reason() string { return e.reason }
// Cause function returns cause value.
func (e PublishMediaInfoRespValidationError) Cause() error { return e.cause }
// Key function returns key value.
func (e PublishMediaInfoRespValidationError) Key() bool { return e.key }
// ErrorName returns error name.
func (e PublishMediaInfoRespValidationError) ErrorName() string {
return "PublishMediaInfoRespValidationError"
}
// Error satisfies the builtin error interface
func (e PublishMediaInfoRespValidationError) Error() string {
cause := ""
if e.cause != nil {
cause = fmt.Sprintf(" | caused by: %v", e.cause)
}
key := ""
if e.key {
key = "key for "
}
return fmt.Sprintf(
"invalid %sPublishMediaInfoResp.%s: %s%s",
key,
e.field,
e.reason,
cause)
}
var _ error = PublishMediaInfoRespValidationError{}
var _ interface {
Field() string
Reason() string
Key() bool
Cause() error
ErrorName() string
} = PublishMediaInfoRespValidationError{}
// Validate checks the field values on WorkListResp_Info with the rules defined // Validate checks the field values on WorkListResp_Info with the rules defined
// in the proto definition for this message. If any rules are violated, the // in the proto definition for this message. If any rules are violated, the
// first error encountered is returned, or nil if there are no violations. // first error encountered is returned, or nil if there are no violations.

View File

@ -46,6 +46,7 @@ type CastClient interface {
OAuthAccount(ctx context.Context, in *OAuthAccountReq, opts ...grpc_go.CallOption) (*OAuthAccountResp, common.ErrorWithAttachment) OAuthAccount(ctx context.Context, in *OAuthAccountReq, opts ...grpc_go.CallOption) (*OAuthAccountResp, common.ErrorWithAttachment)
OAuthCodeToToken(ctx context.Context, in *OAuthCodeToTokenReq, opts ...grpc_go.CallOption) (*OAuthCodeToTokenResp, common.ErrorWithAttachment) OAuthCodeToToken(ctx context.Context, in *OAuthCodeToTokenReq, opts ...grpc_go.CallOption) (*OAuthCodeToTokenResp, common.ErrorWithAttachment)
RefreshToken(ctx context.Context, in *RefreshTokenReq, opts ...grpc_go.CallOption) (*RefreshTokenResp, common.ErrorWithAttachment) RefreshToken(ctx context.Context, in *RefreshTokenReq, opts ...grpc_go.CallOption) (*RefreshTokenResp, common.ErrorWithAttachment)
PublishMediaInfo(ctx context.Context, in *PublishMediaInfoReq, opts ...grpc_go.CallOption) (*PublishMediaInfoResp, common.ErrorWithAttachment)
Test(ctx context.Context, in *emptypb.Empty, opts ...grpc_go.CallOption) (*emptypb.Empty, common.ErrorWithAttachment) Test(ctx context.Context, in *emptypb.Empty, opts ...grpc_go.CallOption) (*emptypb.Empty, common.ErrorWithAttachment)
} }
@ -71,6 +72,7 @@ type CastClientImpl struct {
OAuthAccount func(ctx context.Context, in *OAuthAccountReq) (*OAuthAccountResp, error) OAuthAccount func(ctx context.Context, in *OAuthAccountReq) (*OAuthAccountResp, error)
OAuthCodeToToken func(ctx context.Context, in *OAuthCodeToTokenReq) (*OAuthCodeToTokenResp, error) OAuthCodeToToken func(ctx context.Context, in *OAuthCodeToTokenReq) (*OAuthCodeToTokenResp, error)
RefreshToken func(ctx context.Context, in *RefreshTokenReq) (*RefreshTokenResp, error) RefreshToken func(ctx context.Context, in *RefreshTokenReq) (*RefreshTokenResp, error)
PublishMediaInfo func(ctx context.Context, in *PublishMediaInfoReq) (*PublishMediaInfoResp, error)
Test func(ctx context.Context, in *emptypb.Empty) (*emptypb.Empty, error) Test func(ctx context.Context, in *emptypb.Empty) (*emptypb.Empty, error)
} }
@ -188,6 +190,12 @@ func (c *castClient) RefreshToken(ctx context.Context, in *RefreshTokenReq, opts
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/RefreshToken", in, out) return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/RefreshToken", in, out)
} }
func (c *castClient) PublishMediaInfo(ctx context.Context, in *PublishMediaInfoReq, opts ...grpc_go.CallOption) (*PublishMediaInfoResp, common.ErrorWithAttachment) {
out := new(PublishMediaInfoResp)
interfaceKey := ctx.Value(constant.InterfaceKey).(string)
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/PublishMediaInfo", in, out)
}
func (c *castClient) Test(ctx context.Context, in *emptypb.Empty, opts ...grpc_go.CallOption) (*emptypb.Empty, common.ErrorWithAttachment) { func (c *castClient) Test(ctx context.Context, in *emptypb.Empty, opts ...grpc_go.CallOption) (*emptypb.Empty, common.ErrorWithAttachment) {
out := new(emptypb.Empty) out := new(emptypb.Empty)
interfaceKey := ctx.Value(constant.InterfaceKey).(string) interfaceKey := ctx.Value(constant.InterfaceKey).(string)
@ -215,6 +223,7 @@ type CastServer interface {
OAuthAccount(context.Context, *OAuthAccountReq) (*OAuthAccountResp, error) OAuthAccount(context.Context, *OAuthAccountReq) (*OAuthAccountResp, error)
OAuthCodeToToken(context.Context, *OAuthCodeToTokenReq) (*OAuthCodeToTokenResp, error) OAuthCodeToToken(context.Context, *OAuthCodeToTokenReq) (*OAuthCodeToTokenResp, error)
RefreshToken(context.Context, *RefreshTokenReq) (*RefreshTokenResp, error) RefreshToken(context.Context, *RefreshTokenReq) (*RefreshTokenResp, error)
PublishMediaInfo(context.Context, *PublishMediaInfoReq) (*PublishMediaInfoResp, error)
Test(context.Context, *emptypb.Empty) (*emptypb.Empty, error) Test(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
mustEmbedUnimplementedCastServer() mustEmbedUnimplementedCastServer()
} }
@ -275,6 +284,9 @@ func (UnimplementedCastServer) OAuthCodeToToken(context.Context, *OAuthCodeToTok
func (UnimplementedCastServer) RefreshToken(context.Context, *RefreshTokenReq) (*RefreshTokenResp, error) { func (UnimplementedCastServer) RefreshToken(context.Context, *RefreshTokenReq) (*RefreshTokenResp, error) {
return nil, status.Errorf(codes.Unimplemented, "method RefreshToken not implemented") return nil, status.Errorf(codes.Unimplemented, "method RefreshToken not implemented")
} }
func (UnimplementedCastServer) PublishMediaInfo(context.Context, *PublishMediaInfoReq) (*PublishMediaInfoResp, error) {
return nil, status.Errorf(codes.Unimplemented, "method PublishMediaInfo not implemented")
}
func (UnimplementedCastServer) Test(context.Context, *emptypb.Empty) (*emptypb.Empty, error) { func (UnimplementedCastServer) Test(context.Context, *emptypb.Empty) (*emptypb.Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method Test not implemented") return nil, status.Errorf(codes.Unimplemented, "method Test not implemented")
} }
@ -799,6 +811,35 @@ func _Cast_RefreshToken_Handler(srv interface{}, ctx context.Context, dec func(i
return interceptor(ctx, in, info, handler) return interceptor(ctx, in, info, handler)
} }
func _Cast_PublishMediaInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
in := new(PublishMediaInfoReq)
if err := dec(in); err != nil {
return nil, err
}
base := srv.(dubbo3.Dubbo3GrpcService)
args := []interface{}{}
args = append(args, in)
md, _ := metadata.FromIncomingContext(ctx)
invAttachment := make(map[string]interface{}, len(md))
for k, v := range md {
invAttachment[k] = v
}
invo := invocation.NewRPCInvocation("PublishMediaInfo", args, invAttachment)
if interceptor == nil {
result := base.XXX_GetProxyImpl().Invoke(ctx, invo)
return result, result.Error()
}
info := &grpc_go.UnaryServerInfo{
Server: srv,
FullMethod: ctx.Value("XXX_TRIPLE_GO_INTERFACE_NAME").(string),
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
result := base.XXX_GetProxyImpl().Invoke(ctx, invo)
return result, result.Error()
}
return interceptor(ctx, in, info, handler)
}
func _Cast_Test_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) { func _Cast_Test_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
in := new(emptypb.Empty) in := new(emptypb.Empty)
if err := dec(in); err != nil { if err := dec(in); err != nil {
@ -903,6 +944,10 @@ var Cast_ServiceDesc = grpc_go.ServiceDesc{
MethodName: "RefreshToken", MethodName: "RefreshToken",
Handler: _Cast_RefreshToken_Handler, Handler: _Cast_RefreshToken_Handler,
}, },
{
MethodName: "PublishMediaInfo",
Handler: _Cast_PublishMediaInfo_Handler,
},
{ {
MethodName: "Test", MethodName: "Test",
Handler: _Cast_Test_Handler, Handler: _Cast_Test_Handler,

View File

@ -4,10 +4,11 @@ import (
"errors" "errors"
"fmt" "fmt"
"fonchain-fiee/pkg/common" "fonchain-fiee/pkg/common"
"github.com/BurntSushi/toml"
"gopkg.in/ini.v1"
"os" "os"
"strconv" "strconv"
"github.com/BurntSushi/toml"
"gopkg.in/ini.v1"
) )
var ( var (
@ -108,15 +109,16 @@ type Redis struct {
} }
type System struct { type System struct {
Mode string Mode string
AppMode string AppMode string
Version string Version string
HttpPort string HttpPort string
Host string Host string
RedirectUri string RedirectUri string
Domain string Domain string
ErpHost string ErpHost string
FieeHost string FieeHost string
AuthRedirectUrl string
} }
type Oss struct { type Oss struct {
AccessKeyId string AccessKeyId string

View File

@ -6,6 +6,8 @@ Host = "https://common.szjixun.cn"
RedirectUri = "/api/redirect/url" RedirectUri = "/api/redirect/url"
ErpHost = "http://114.218.158.24:9020" ErpHost = "http://114.218.158.24:9020"
FieeHost = "http://114.218.158.24:9020" FieeHost = "http://114.218.158.24:9020"
AuthRedirectUrl = "http://172.16.100.99:9028/media_account"
[bos] [bos]
Ak = "ALTAKxrqOQHnAN525Tb2GX4Bhe" Ak = "ALTAKxrqOQHnAN525Tb2GX4Bhe"
Sk = "d2ecaa9d75114d3b9f42b99014198306" Sk = "d2ecaa9d75114d3b9f42b99014198306"

View File

@ -6,6 +6,7 @@ Host = "https://common.szjixun.cn"
RedirectUri = "/api/redirect/url" RedirectUri = "/api/redirect/url"
ErpHost = "https://erpapi.fontree.cn" ErpHost = "https://erpapi.fontree.cn"
FieeHost = "https://erpapi.fiee.com" FieeHost = "https://erpapi.fiee.com"
AuthRedirectUrl = "https://erp.fiee.com/media_account"
[bos] [bos]
Ak = "ALTAKxrqOQHnAN525Tb2GX4Bhe" Ak = "ALTAKxrqOQHnAN525Tb2GX4Bhe"
Sk = "d2ecaa9d75114d3b9f42b99014198306" Sk = "d2ecaa9d75114d3b9f42b99014198306"

View File

@ -6,6 +6,7 @@ Host = "https://common.szjixun.cn"
RedirectUri = "/api/redirect/url" RedirectUri = "/api/redirect/url"
ErpHost = "http://114.218.158.24:9020" ErpHost = "http://114.218.158.24:9020"
FieeHost = "https://saas-test.szjixun.cn" FieeHost = "https://saas-test.szjixun.cn"
AuthRedirectUrl = "http://172.16.100.99:9028/media_account"
[bos] [bos]
Ak = "ALTAKxrqOQHnAN525Tb2GX4Bhe" Ak = "ALTAKxrqOQHnAN525Tb2GX4Bhe"
Sk = "d2ecaa9d75114d3b9f42b99014198306" Sk = "d2ecaa9d75114d3b9f42b99014198306"

View File

@ -38,6 +38,7 @@ func MediaRouter(r *gin.RouterGroup) {
work.POST("republish", serviceCast.RePublish) work.POST("republish", serviceCast.RePublish)
work.POST("delete", serviceCast.DelWork) work.POST("delete", serviceCast.DelWork)
work.POST("remind", serviceCast.Remind) work.POST("remind", serviceCast.Remind)
work.POST("publish-info", serviceCast.PublishInfo)
} }
social := noAuth.Group("social") social := noAuth.Group("social")

View File

@ -3,6 +3,7 @@ package cast
import ( import (
"context" "context"
"errors" "errors"
"fmt"
"fonchain-fiee/api/accountFiee" "fonchain-fiee/api/accountFiee"
"fonchain-fiee/api/bundle" "fonchain-fiee/api/bundle"
"fonchain-fiee/api/cast" "fonchain-fiee/api/cast"
@ -10,6 +11,7 @@ import (
"fonchain-fiee/pkg/e" "fonchain-fiee/pkg/e"
modelCast "fonchain-fiee/pkg/model/cast" modelCast "fonchain-fiee/pkg/model/cast"
"fonchain-fiee/pkg/service" "fonchain-fiee/pkg/service"
"net/http"
"net/url" "net/url"
"strconv" "strconv"
@ -212,15 +214,19 @@ func OAuth2Callback(ctx *gin.Context) {
service.Error(ctx, errors.New(e.GetMsg(e.InvalidParams))) service.Error(ctx, errors.New(e.GetMsg(e.InvalidParams)))
return return
} }
resp, err := service.CastProvider.OAuthCodeToToken(ctx, req) _, err := service.CastProvider.OAuthCodeToToken(ctx, req)
if err != nil { if err != nil {
service.Error(ctx, err) fmt.Println(fmt.Sprintf("%s?%s", config.AppConfig.System.AuthRedirectUrl, "status=0"))
ctx.Redirect(http.StatusFound, fmt.Sprintf("%s?%s", config.AppConfig.System.AuthRedirectUrl, "status=0"))
return return
} }
service.Success(ctx, map[string]interface{}{ // TODO 跳转到前端页面
"req": req, ctx.Redirect(http.StatusFound, fmt.Sprintf("%s?%s", config.AppConfig.System.AuthRedirectUrl, "status=1"))
"resp": resp, //service.Success(ctx, map[string]interface{}{
}) // "req": req,
// "resp": resp,
//})
return return
} }
func RefreshToken(ctx *gin.Context) { func RefreshToken(ctx *gin.Context) {

View File

@ -364,3 +364,20 @@ func Remind(ctx *gin.Context) {
service.Success(ctx, nil) service.Success(ctx, nil)
return return
} }
func PublishInfo(ctx *gin.Context) {
var req *cast.PublishMediaInfoReq
var resp *cast.PublishMediaInfoResp
var err error
if err = ctx.ShouldBind(&req); err != nil {
service.Error(ctx, err)
return
}
resp, err = service.CastProvider.PublishMediaInfo(context.Background(), req)
if err != nil {
service.Error(ctx, err)
return
}
service.Success(ctx, resp)
return
}