修改DM授权账号分配

This commit is contained in:
戴育兵 2026-01-04 14:09:26 +08:00
parent fb77d2560f
commit 817c38dffa
3 changed files with 27 additions and 4 deletions

View File

@ -3431,6 +3431,7 @@ type ArtistInfoResp struct {
DMEffectiveCount uint32 `protobuf:"varint,4,opt,name=DMEffectiveCount,proto3" json:"DMEffectiveCount"`
ProfileKey string `protobuf:"bytes,5,opt,name=profileKey,proto3" json:"profileKey"`
SubNum string `protobuf:"bytes,6,opt,name=subNum,proto3" json:"subNum"`
BlueskyEffectiveCount uint32 `protobuf:"varint,7,opt,name=BlueskyEffectiveCount,proto3" json:"BlueskyEffectiveCount"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
@ -3507,6 +3508,13 @@ func (x *ArtistInfoResp) GetSubNum() string {
return ""
}
func (x *ArtistInfoResp) GetBlueskyEffectiveCount() uint32 {
if x != nil {
return x.BlueskyEffectiveCount
}
return 0
}
type ImportWorkBatchReq struct {
state protoimpl.MessageState `protogen:"open.v1"`
ImageWorks []*UpdateWorkImageReq `protobuf:"bytes,1,rep,name=imageWorks,proto3" json:"imageWorks"`
@ -4281,6 +4289,7 @@ type OAuthCodeToTokenReq struct {
Code string `protobuf:"bytes,1,opt,name=code,proto3" json:"code"`
UserID string `protobuf:"bytes,2,opt,name=userID,proto3" json:"userID"`
PlatformID PlatformIDENUM `protobuf:"varint,3,opt,name=platformID,proto3,enum=Cast.PlatformIDENUM" json:"platformID"`
State string `protobuf:"bytes,4,opt,name=state,proto3" json:"state"` // 用于传递授权时的state参数包含partner_uuid等信息
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
@ -4336,6 +4345,13 @@ func (x *OAuthCodeToTokenReq) GetPlatformID() PlatformIDENUM {
return PlatformIDENUM_UNKNOWN
}
func (x *OAuthCodeToTokenReq) GetState() string {
if x != nil {
return x.State
}
return ""
}
type OAuthCodeToTokenResp struct {
state protoimpl.MessageState `protogen:"open.v1"`
unknownFields protoimpl.UnknownFields
@ -14471,7 +14487,7 @@ const file_pb_fiee_cast_proto_rawDesc = "" +
"\rArtistInfoReq\x12\x1e\n" +
"\n" +
"artistUuid\x18\x01 \x01(\tR\n" +
"artistUuid\"\x8c\x02\n" +
"artistUuid\"\xc2\x02\n" +
"\x0eArtistInfoResp\x122\n" +
"\x14TikTokEffectiveCount\x18\x01 \x01(\rR\x14TikTokEffectiveCount\x124\n" +
"\x15YouTubeEffectiveCount\x18\x02 \x01(\rR\x15YouTubeEffectiveCount\x12,\n" +
@ -14480,7 +14496,8 @@ const file_pb_fiee_cast_proto_rawDesc = "" +
"\n" +
"profileKey\x18\x05 \x01(\tR\n" +
"profileKey\x12\x16\n" +
"\x06subNum\x18\x06 \x01(\tR\x06subNum\"N\n" +
"\x06subNum\x18\x06 \x01(\tR\x06subNum\x124\n" +
"\x15BlueskyEffectiveCount\x18\a \x01(\rR\x15BlueskyEffectiveCount\"N\n" +
"\x12ImportWorkBatchReq\x128\n" +
"\n" +
"imageWorks\x18\x01 \x03(\v2\x18.Cast.UpdateWorkImageReqR\n" +
@ -14558,13 +14575,14 @@ const file_pb_fiee_cast_proto_rawDesc = "" +
"\frefreshToken\x18\x02 \x01(\tR\frefreshToken\x12\x1e\n" +
"\n" +
"expireTime\x18\x03 \x01(\x03R\n" +
"expireTime\"w\n" +
"expireTime\"\x8d\x01\n" +
"\x13OAuthCodeToTokenReq\x12\x12\n" +
"\x04code\x18\x01 \x01(\tR\x04code\x12\x16\n" +
"\x06userID\x18\x02 \x01(\tR\x06userID\x124\n" +
"\n" +
"platformID\x18\x03 \x01(\x0e2\x14.Cast.PlatformIDENUMR\n" +
"platformID\"\x16\n" +
"platformID\x12\x14\n" +
"\x05state\x18\x04 \x01(\tR\x05state\"\x16\n" +
"\x14OAuthCodeToTokenResp\"\xf8\x01\n" +
"\x0eUpdateOAuthReq\x12-\n" +
"\x04Data\x18\x01 \x03(\v2\x19.Cast.UpdateOAuthReq.InfoR\x04Data\x1a\xb6\x01\n" +

View File

@ -4795,6 +4795,8 @@ func (m *ArtistInfoResp) validate(all bool) error {
// no validation rules for SubNum
// no validation rules for BlueskyEffectiveCount
if len(errors) > 0 {
return ArtistInfoRespMultiError(errors)
}
@ -6514,6 +6516,8 @@ func (m *OAuthCodeToTokenReq) validate(all bool) error {
// no validation rules for PlatformID
// no validation rules for State
if len(errors) > 0 {
return OAuthCodeToTokenReqMultiError(errors)
}

View File

@ -381,6 +381,7 @@ func SyncAsAuth(artistUuid string) error {
InstagramDetails: true,
})
if err != nil {
zap.L().Error("SyncAsAuth error", zap.Error(err))
return errors.New("获取艺人绑定信息错误")
}
authReq := &cast.UpdateOAuthReq{Data: make([]*cast.UpdateOAuthReq_Info, 0)}