修复注册用户时没有记录账号id的情况
This commit is contained in:
parent
ca9bb47931
commit
cf83d6c30f
8
.idea/.gitignore
vendored
8
.idea/.gitignore
vendored
@ -1,8 +0,0 @@
|
||||
# Default ignored files
|
||||
/shelf/
|
||||
/workspace.xml
|
||||
# Editor-based HTTP Client requests
|
||||
/httpRequests/
|
||||
# Datasource local storage ignored files
|
||||
/dataSources/
|
||||
/dataSources.local.xml
|
||||
@ -1,9 +1,4 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<module type="WEB_MODULE" version="4">
|
||||
<module version="4">
|
||||
<component name="Go" enabled="true" />
|
||||
<component name="NewModuleRootManager">
|
||||
<content url="file://$MODULE_DIR$" />
|
||||
<orderEntry type="inheritedJdk" />
|
||||
<orderEntry type="sourceFolder" forTests="false" />
|
||||
</component>
|
||||
</module>
|
||||
@ -1,8 +0,0 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<project version="4">
|
||||
<component name="ProjectModuleManager">
|
||||
<modules>
|
||||
<module fileurl="file://$PROJECT_DIR$/.idea/fonchain-artistinfo.iml" filepath="$PROJECT_DIR$/.idea/fonchain-artistinfo.iml" />
|
||||
</modules>
|
||||
</component>
|
||||
</project>
|
||||
114
.idea/workspace.xml
Normal file
114
.idea/workspace.xml
Normal file
@ -0,0 +1,114 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<project version="4">
|
||||
<component name="AutoImportSettings">
|
||||
<option name="autoReloadType" value="ALL" />
|
||||
</component>
|
||||
<component name="ChangeListManager">
|
||||
<list default="true" id="d68f5e32-c2e9-42ba-a8ac-6f711f18b57a" name="Changes" comment="">
|
||||
<change beforePath="$PROJECT_DIR$/.idea/.gitignore" beforeDir="false" />
|
||||
<change beforePath="$PROJECT_DIR$/.idea/fonchain-artistinfo.iml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/fonchain-artistinfo.iml" afterDir="false" />
|
||||
<change beforePath="$PROJECT_DIR$/.idea/modules.xml" beforeDir="false" />
|
||||
<change beforePath="$PROJECT_DIR$/cmd/internal/controller/artisrInfo.go" beforeDir="false" afterPath="$PROJECT_DIR$/cmd/internal/controller/artisrInfo.go" afterDir="false" />
|
||||
<change beforePath="$PROJECT_DIR$/cmd/internal/dao/artistInfo.go" beforeDir="false" afterPath="$PROJECT_DIR$/cmd/internal/dao/artistInfo.go" afterDir="false" />
|
||||
<change beforePath="$PROJECT_DIR$/cmd/logs/artist_server.log" beforeDir="false" afterPath="$PROJECT_DIR$/cmd/logs/artist_server.log" afterDir="false" />
|
||||
<change beforePath="$PROJECT_DIR$/cmd/model/user.go" beforeDir="false" afterPath="$PROJECT_DIR$/cmd/model/user.go" afterDir="false" />
|
||||
<change beforePath="$PROJECT_DIR$/conf/conf.ini" beforeDir="false" afterPath="$PROJECT_DIR$/conf/conf.ini" afterDir="false" />
|
||||
<change beforePath="$PROJECT_DIR$/conf/dubbogo.yaml" beforeDir="false" afterPath="$PROJECT_DIR$/conf/dubbogo.yaml" afterDir="false" />
|
||||
<change beforePath="$PROJECT_DIR$/go.mod" beforeDir="false" afterPath="$PROJECT_DIR$/go.mod" afterDir="false" />
|
||||
<change beforePath="$PROJECT_DIR$/pb/artistinfo/artistinfo.pb.go" beforeDir="false" afterPath="$PROJECT_DIR$/pb/artistinfo/artistinfo.pb.go" afterDir="false" />
|
||||
<change beforePath="$PROJECT_DIR$/pb/artistinfo/artistinfo.proto" beforeDir="false" afterPath="$PROJECT_DIR$/pb/artistinfo/artistinfo.proto" afterDir="false" />
|
||||
<change beforePath="$PROJECT_DIR$/pb/artistinfo/artistinfo_triple.pb.go" beforeDir="false" afterPath="$PROJECT_DIR$/pb/artistinfo/artistinfo_triple.pb.go" afterDir="false" />
|
||||
</list>
|
||||
<option name="SHOW_DIALOG" value="false" />
|
||||
<option name="HIGHLIGHT_CONFLICTS" value="true" />
|
||||
<option name="HIGHLIGHT_NON_ACTIVE_CHANGELIST" value="false" />
|
||||
<option name="LAST_RESOLUTION" value="IGNORE" />
|
||||
</component>
|
||||
<component name="FileTemplateManagerImpl">
|
||||
<option name="RECENT_TEMPLATES">
|
||||
<list>
|
||||
<option value="Go File" />
|
||||
</list>
|
||||
</option>
|
||||
</component>
|
||||
<component name="GOROOT" url="file://$USER_HOME$/.g/go" />
|
||||
<component name="Git.Settings">
|
||||
<option name="RECENT_GIT_ROOT_PATH" value="$PROJECT_DIR$" />
|
||||
</component>
|
||||
<component name="MarkdownSettingsMigration">
|
||||
<option name="stateVersion" value="1" />
|
||||
</component>
|
||||
<component name="ProjectId" id="2LhssKjCTz4ydBhOcLUaoMlKRzA" />
|
||||
<component name="ProjectViewState">
|
||||
<option name="hideEmptyMiddlePackages" value="true" />
|
||||
<option name="showLibraryContents" value="true" />
|
||||
</component>
|
||||
<component name="PropertiesComponent">{
|
||||
"keyToString": {
|
||||
"DefaultGoTemplateProperty": "Go File",
|
||||
"RunOnceActivity.OpenProjectViewOnStart": "true",
|
||||
"RunOnceActivity.ShowReadmeOnStart": "true",
|
||||
"RunOnceActivity.go.formatter.settings.were.checked": "true",
|
||||
"RunOnceActivity.go.migrated.go.modules.settings": "true",
|
||||
"RunOnceActivity.go.modules.go.list.on.any.changes.was.set": "true",
|
||||
"WebServerToolWindowFactoryState": "false",
|
||||
"go.import.settings.migrated": "true",
|
||||
"go.sdk.automatically.set": "true",
|
||||
"last_opened_file_path": "D:/jjxu/work/projects/fonchain-artistinfo/pkg/service",
|
||||
"node.js.detected.package.eslint": "true",
|
||||
"node.js.selected.package.eslint": "(autodetect)",
|
||||
"nodejs_package_manager_path": "npm"
|
||||
}
|
||||
}</component>
|
||||
<component name="RecentsManager">
|
||||
<key name="CopyFile.RECENT_KEYS">
|
||||
<recent name="D:\jjxu\work\projects\fonchain-artistinfo\pkg\service" />
|
||||
<recent name="D:\jjxu\work\projects\fonchain-artistinfo\pb" />
|
||||
</key>
|
||||
</component>
|
||||
<component name="RunManager">
|
||||
<configuration name="go build app.go" type="GoApplicationRunConfiguration" factoryName="Go Application" temporary="true" nameIsGenerated="true">
|
||||
<module name="fonchain-artistinfo" />
|
||||
<working_directory value="$PROJECT_DIR$/cmd" />
|
||||
<kind value="FILE" />
|
||||
<package value="github.com/fonchain/fonchain-artistinfo/cmd" />
|
||||
<directory value="$PROJECT_DIR$" />
|
||||
<filePath value="$PROJECT_DIR$/cmd/app.go" />
|
||||
<method v="2" />
|
||||
</configuration>
|
||||
<recent_temporary>
|
||||
<list>
|
||||
<item itemvalue="Go Build.go build app.go" />
|
||||
</list>
|
||||
</recent_temporary>
|
||||
</component>
|
||||
<component name="SpellCheckerSettings" RuntimeDictionaries="0" Folders="0" CustomDictionaries="0" DefaultDictionary="application-level" UseSingleDictionary="true" transferred="true" />
|
||||
<component name="TypeScriptGeneratedFilesManager">
|
||||
<option name="version" value="3" />
|
||||
</component>
|
||||
<component name="Vcs.Log.Tabs.Properties">
|
||||
<option name="TAB_STATES">
|
||||
<map>
|
||||
<entry key="MAIN">
|
||||
<value>
|
||||
<State />
|
||||
</value>
|
||||
</entry>
|
||||
</map>
|
||||
</option>
|
||||
</component>
|
||||
<component name="VgoProject">
|
||||
<settings-migrated>true</settings-migrated>
|
||||
</component>
|
||||
<component name="XDebuggerManager">
|
||||
<breakpoint-manager>
|
||||
<breakpoints>
|
||||
<line-breakpoint enabled="true" type="DlvLineBreakpoint">
|
||||
<url>file://$PROJECT_DIR$/cmd/internal/dao/artistInfo.go</url>
|
||||
<line>26</line>
|
||||
<option name="timeStamp" value="3" />
|
||||
</line-breakpoint>
|
||||
</breakpoints>
|
||||
</breakpoint-manager>
|
||||
</component>
|
||||
</project>
|
||||
@ -3,6 +3,8 @@ package controller
|
||||
import (
|
||||
"context"
|
||||
"fmt"
|
||||
"github.com/fonchain/fonchain-artistinfo/cmd/model"
|
||||
db "github.com/fonchain/fonchain-artistinfo/pkg/db"
|
||||
|
||||
"github.com/fonchain/fonchain-artistinfo/cmd/internal/logic"
|
||||
"github.com/fonchain/fonchain-artistinfo/pb/artistinfo"
|
||||
@ -139,3 +141,10 @@ func (a *ArtistInfoProvider) BindInviteInvitedAccount(ctx context.Context, in *a
|
||||
}
|
||||
return nil, err
|
||||
}
|
||||
|
||||
func (a *ArtistInfoProvider) BindArtistId(ctx context.Context, in *artistinfo.BindArtistIdRequest) (*artistinfo.BindArtistIdResp, error) {
|
||||
if err := db.DB.Model(model.User{}).Where("mgmt_user_id = ?", in.UserId).Update("mgmt_artist_id", in.ArtistId).Error; err != nil {
|
||||
return &artistinfo.BindArtistIdResp{Error: err.Error()}, err
|
||||
}
|
||||
return nil, nil
|
||||
}
|
||||
|
||||
@ -17,7 +17,11 @@ import (
|
||||
|
||||
func RegisterUser(req *artistinfo.RegisterUserRequest) (rep *artistinfo.RegisterUserRespond, err error) {
|
||||
|
||||
var user model.User
|
||||
var user = model.User{
|
||||
MgmtUserId: req.MgmtUserId,
|
||||
TelNum: req.TelNum,
|
||||
MgmtArtistId: req.MgmtArtistId,
|
||||
}
|
||||
user.TelNum = req.TelNum
|
||||
user.MgmtArtistId = req.MgmtArtistId
|
||||
if err := db.DB.Create(&user).Error; err != nil {
|
||||
|
||||
@ -2,3 +2,10 @@
|
||||
{"level":"\u001b[34mINFO\u001b[0m","time":"2022-12-02T11:24:08.395+0800","caller":"config/root_config.go:150","message":"[Config Center] Config center doesn't start"}
|
||||
{"level":"\u001b[34mINFO\u001b[0m","time":"2022-12-02T11:39:34.056+0800","caller":"config/root_config.go:150","message":"[Config Center] Config center doesn't start"}
|
||||
{"level":"\u001b[34mINFO\u001b[0m","time":"2022-12-02T11:48:17.606+0800","caller":"config/root_config.go:150","message":"[Config Center] Config center doesn't start"}
|
||||
{"level":"\u001b[34mINFO\u001b[0m","time":"2023-02-15T21:33:56.444+0800","caller":"config/root_config.go:150","message":"[Config Center] Config center doesn't start"}
|
||||
{"level":"\u001b[33mWARN\u001b[0m","time":"2023-02-15T21:33:56.445+0800","caller":"prometheus/reporter.go:235","message":"new prometheus reporter with error = listen tcp :9091: bind: Only one usage of each socket address (protocol/network address/port) is normally permitted."}
|
||||
{"level":"\u001b[34mINFO\u001b[0m","time":"2023-02-15T21:33:56.445+0800","caller":"dubbo3/dubbo3_protocol.go:81","message":"[Triple Protocol] Export service: tri://:20050/com.fontree.microservices.common.Contract?accesslog=&app.version=3.0.0&application=dubbo.io&auth=&bean.name=ContractProvider&cluster=failover&config.tracing=&environment=dev&execute.limit=&execute.limit.rejected.handler=&export=true&interface=com.fontree.microservices.common.Contract&loadbalance=random&message_size=4&metadata-type=local&module=sample&name=dubbo.io&organization=dubbo-go&owner=dubbo-go¶m.sign=&pid=37204®istry=zookeeper®istry.role=3&release=dubbo-golang-3.0.0&retries=&serialization=&service.filter=echo%2Cmetrics%2Ctoken%2Caccesslog%2Ctps%2Cgeneric_service%2Cexecute%2Cpshutdown&side=provider×tamp=1676468036&tps.limit.interval=&tps.limit.rate=&tps.limit.rejected.handler=&tps.limit.strategy=&tps.limiter=&warmup="}
|
||||
{"level":"\u001b[34mINFO\u001b[0m","time":"2023-02-15T21:33:56.446+0800","caller":"zookeeper/registry.go:72","message":"[Zookeeper Registry] New zookeeper registry with url map[host:zookeeper port:2181 protocol:zookeeper registry:zookeeper registry.group: registry.label:true registry.namespace: registry.preferred:false registry.role:3 registry.timeout:120s registry.ttl:10s registry.weight:0 registry.zone: remote-client-name:dubbo.registries-zookeeper-zookeeper:2181 simplified:false]"}
|
||||
{"level":"\u001b[34mINFO\u001b[0m","time":"2023-02-15T21:33:56.446+0800","caller":"zookeeper/client.go:55","message":"[Zookeeper Client] New zookeeper client with name = zookeeper:2181, zkAddress = zookeeper:2181, timeout = 10s"}
|
||||
{"level":"\u001b[33mWARN\u001b[0m","time":"2023-02-15T21:33:58.710+0800","caller":"zookeeper/client.go:58","message":"newZookeeperClient(name{zookeeper:2181}, zk address{zookeeper:2181}, timeout{%!d(string=10s)}) = error{lookup zookeeper: no such host}"}
|
||||
{"level":"\u001b[31mERROR\u001b[0m","time":"2023-02-15T21:33:58.710+0800","caller":"protocol/protocol.go:88","message":"Registry can not connect success, program is going to panic.Error message is newZookeeperClient(address:zookeeper:2181): lookup zookeeper: no such host"}
|
||||
|
||||
@ -4,8 +4,8 @@ package model
|
||||
type User struct {
|
||||
Model
|
||||
ID uint64 `gorm:"not null"`
|
||||
MgmtUserId uint64 `gorm:"not null"`
|
||||
MgmtArtistId string `gorm:"type:varchar(256) not null"`
|
||||
MgmtUserId uint64 `gorm:"column:mgmt_user_id;not null;comment:账号id"`
|
||||
MgmtArtistId string `gorm:"column:mgmt_artist_id;type:varchar(256) not null;comment:艺术家id"`
|
||||
Account string `gorm:"type:varchar(256) not null"`
|
||||
MnemonicWords string `gorm:"type:varchar(256) not null"`
|
||||
TelNum string `gorm:"type:varchar(20) not null"`
|
||||
|
||||
@ -3,7 +3,7 @@ mode = dev #正式prod #测试dev
|
||||
|
||||
[mysql]
|
||||
Db = mysql
|
||||
DbHost = mysql
|
||||
DbHost = 127.0.0.1
|
||||
DbPort = 3306
|
||||
DbUser = root
|
||||
DbPassWord = 123456
|
||||
@ -12,9 +12,9 @@ DbName = artistmgmttest
|
||||
[redis]
|
||||
|
||||
RedisDB = 2
|
||||
RedisAddr = 172.16.100.99:9008
|
||||
RedisPW = "nDCTrfTtBu3Pw"
|
||||
RedisDBNAme =
|
||||
RedisAddr = 127.0.0.1:6379
|
||||
#RedisPW = "nDCTrfTtBu3Pw"
|
||||
#RedisDBNAme =
|
||||
|
||||
[chain]
|
||||
IP=127.0.0.1:37101
|
||||
|
||||
@ -8,10 +8,10 @@ dubbo:
|
||||
demoZK:
|
||||
protocol: zookeeper
|
||||
timeout: 120s
|
||||
# address: 127.0.0.1:2181
|
||||
address: 127.0.0.1:2181
|
||||
# address: 121.229.45.214:9004
|
||||
# address: 114.218.158.24:2181
|
||||
address: zookeeper:2181
|
||||
# address: zookeeper:2181
|
||||
protocols:
|
||||
triple: #triple
|
||||
name: tri
|
||||
|
||||
1
go.mod
1
go.mod
@ -33,6 +33,7 @@ require (
|
||||
)
|
||||
|
||||
require (
|
||||
github.com/alibaba/sentinel-golang v1.0.4 // indirect
|
||||
github.com/baidubce/bce-sdk-go v0.9.138 // indirect
|
||||
github.com/baiyubin/aliyun-sts-go-sdk v0.0.0-20180326062324-cfa1a18b161f // indirect
|
||||
github.com/spf13/viper v1.11.0 // indirect
|
||||
|
||||
File diff suppressed because it is too large
Load Diff
@ -18,8 +18,17 @@ service ArtistInfo {
|
||||
rpc CheckInvitedCode(CheckInvitedCodeRequest)returns (GetUserRespond){}
|
||||
rpc UnFinishList(UnFinishListRequest)returns (UnFinishListRespond){}
|
||||
rpc GetUserMsg(GetUserMsgRequest) returns (GetUserMsgRespond){}
|
||||
rpc BindInviteInvitedAccount(BindInviteInvitedAccountRequest)returns(BindInviteInvitedAccountRespond){}
|
||||
rpc UpdateMsg(UpdateMsgRequest) returns (UpdateMsgRespond){}
|
||||
rpc BindInviteInvitedAccount(BindInviteInvitedAccountRequest)returns(BindInviteInvitedAccountRespond){} //绑定邀请人与被邀请人账号
|
||||
rpc BindArtistId(BindArtistIdRequest)returns(BindArtistIdResp){} // 账号绑定艺术家id
|
||||
}
|
||||
message UpdateMsgRequest {
|
||||
uint64 Id =1;
|
||||
}
|
||||
|
||||
message UpdateMsgRespond {
|
||||
|
||||
}
|
||||
|
||||
message GetUserMsgRequest{
|
||||
uint64 Id =1;
|
||||
@ -204,6 +213,7 @@ message CreateUserInfoRequest {
|
||||
string QrCodeImgDownload =23 [json_name ="qrCodeDownload" ];
|
||||
string HtmlType =24 [json_name ="htmlType" ];
|
||||
string EnvType =25 [json_name ="envType" ];
|
||||
uint64 Id = 26 [json_name="id"];
|
||||
}
|
||||
|
||||
message CreateUserInfoRespond {
|
||||
@ -308,9 +318,19 @@ message UserLockRespond {
|
||||
message BindInviteInvitedAccountRequest{
|
||||
int32 UserId =1; //邀请人账号id
|
||||
int32 InvitedUserId =2; // 受邀请人账号id
|
||||
int32 InviteCode = 3; //邀请人的邀请码
|
||||
int32 InvitedCode = 4; //受邀请人的邀请码
|
||||
string InviteCode = 3; //邀请人的邀请码
|
||||
string InvitedCode = 4; //受邀请人的邀请码
|
||||
}
|
||||
message BindInviteInvitedAccountRespond{
|
||||
// no params
|
||||
}
|
||||
|
||||
|
||||
|
||||
message BindArtistIdRequest{
|
||||
int64 UserId =1; // 用户账号id
|
||||
int64 ArtistId = 2; // 艺术家id
|
||||
}
|
||||
message BindArtistIdResp{
|
||||
string Error =1;
|
||||
}
|
||||
@ -1,7 +1,7 @@
|
||||
// Code generated by protoc-gen-go-triple. DO NOT EDIT.
|
||||
// versions:
|
||||
// - protoc-gen-go-triple v1.0.5
|
||||
// - protoc v3.9.0
|
||||
// - protoc-gen-go-triple v1.0.8
|
||||
// - protoc v4.22.0--rc2
|
||||
// source: pb/artistinfo/artistinfo.proto
|
||||
|
||||
package artistinfo
|
||||
@ -43,6 +43,9 @@ type ArtistInfoClient interface {
|
||||
CheckInvitedCode(ctx context.Context, in *CheckInvitedCodeRequest, opts ...grpc_go.CallOption) (*GetUserRespond, common.ErrorWithAttachment)
|
||||
UnFinishList(ctx context.Context, in *UnFinishListRequest, opts ...grpc_go.CallOption) (*UnFinishListRespond, common.ErrorWithAttachment)
|
||||
GetUserMsg(ctx context.Context, in *GetUserMsgRequest, opts ...grpc_go.CallOption) (*GetUserMsgRespond, common.ErrorWithAttachment)
|
||||
UpdateMsg(ctx context.Context, in *UpdateMsgRequest, opts ...grpc_go.CallOption) (*UpdateMsgRespond, common.ErrorWithAttachment)
|
||||
BindInviteInvitedAccount(ctx context.Context, in *BindInviteInvitedAccountRequest, opts ...grpc_go.CallOption) (*BindInviteInvitedAccountRespond, common.ErrorWithAttachment)
|
||||
BindArtistId(ctx context.Context, in *BindArtistIdRequest, opts ...grpc_go.CallOption) (*BindArtistIdResp, common.ErrorWithAttachment)
|
||||
}
|
||||
|
||||
type artistInfoClient struct {
|
||||
@ -50,21 +53,24 @@ type artistInfoClient struct {
|
||||
}
|
||||
|
||||
type ArtistInfoClientImpl struct {
|
||||
UploadPic func(ctx context.Context, in *UploadPicRequest) (*UploadPicRespond, error)
|
||||
UploadIdCard func(ctx context.Context, in *UploadIdCardRequest) (*UploadIdCardRespond, error)
|
||||
RegisterUser func(ctx context.Context, in *RegisterUserRequest) (*RegisterUserRespond, error)
|
||||
GetUser func(ctx context.Context, in *GetUserRequest) (*GetUserRespond, error)
|
||||
GetUserById func(ctx context.Context, in *GetUserByIdRequest) (*GetUserByIdRespond, error)
|
||||
CreateUser func(ctx context.Context, in *CreateUserRequest) (*CreateUserRespond, error)
|
||||
CreateUserInfo func(ctx context.Context, in *CreateUserInfoRequest) (*CreateUserInfoRespond, error)
|
||||
UpdateRealName func(ctx context.Context, in *UpdateRealNameRequest) (*UpdateRealNameRespond, error)
|
||||
FinishVerify func(ctx context.Context, in *FinishVerifyRequest) (*FinishVerifyRespond, error)
|
||||
CheckUserLock func(ctx context.Context, in *CheckUserLockRequest) (*CheckUserLockRespond, error)
|
||||
ArtistSupplyList func(ctx context.Context, in *ArtistSupplyListRequest) (*ArtistSupplyListRespond, error)
|
||||
UserLock func(ctx context.Context, in *UserLockRequest) (*UserLockRespond, error)
|
||||
CheckInvitedCode func(ctx context.Context, in *CheckInvitedCodeRequest) (*GetUserRespond, error)
|
||||
UnFinishList func(ctx context.Context, in *UnFinishListRequest) (*UnFinishListRespond, error)
|
||||
GetUserMsg func(ctx context.Context, in *GetUserMsgRequest) (*GetUserMsgRespond, error)
|
||||
UploadPic func(ctx context.Context, in *UploadPicRequest) (*UploadPicRespond, error)
|
||||
UploadIdCard func(ctx context.Context, in *UploadIdCardRequest) (*UploadIdCardRespond, error)
|
||||
RegisterUser func(ctx context.Context, in *RegisterUserRequest) (*RegisterUserRespond, error)
|
||||
GetUser func(ctx context.Context, in *GetUserRequest) (*GetUserRespond, error)
|
||||
GetUserById func(ctx context.Context, in *GetUserByIdRequest) (*GetUserByIdRespond, error)
|
||||
CreateUser func(ctx context.Context, in *CreateUserRequest) (*CreateUserRespond, error)
|
||||
CreateUserInfo func(ctx context.Context, in *CreateUserInfoRequest) (*CreateUserInfoRespond, error)
|
||||
UpdateRealName func(ctx context.Context, in *UpdateRealNameRequest) (*UpdateRealNameRespond, error)
|
||||
FinishVerify func(ctx context.Context, in *FinishVerifyRequest) (*FinishVerifyRespond, error)
|
||||
CheckUserLock func(ctx context.Context, in *CheckUserLockRequest) (*CheckUserLockRespond, error)
|
||||
ArtistSupplyList func(ctx context.Context, in *ArtistSupplyListRequest) (*ArtistSupplyListRespond, error)
|
||||
UserLock func(ctx context.Context, in *UserLockRequest) (*UserLockRespond, error)
|
||||
CheckInvitedCode func(ctx context.Context, in *CheckInvitedCodeRequest) (*GetUserRespond, error)
|
||||
UnFinishList func(ctx context.Context, in *UnFinishListRequest) (*UnFinishListRespond, error)
|
||||
GetUserMsg func(ctx context.Context, in *GetUserMsgRequest) (*GetUserMsgRespond, error)
|
||||
UpdateMsg func(ctx context.Context, in *UpdateMsgRequest) (*UpdateMsgRespond, error)
|
||||
BindInviteInvitedAccount func(ctx context.Context, in *BindInviteInvitedAccountRequest) (*BindInviteInvitedAccountRespond, error)
|
||||
BindArtistId func(ctx context.Context, in *BindArtistIdRequest) (*BindArtistIdResp, error)
|
||||
}
|
||||
|
||||
func (c *ArtistInfoClientImpl) GetDubboStub(cc *triple.TripleConn) ArtistInfoClient {
|
||||
@ -169,6 +175,24 @@ func (c *artistInfoClient) GetUserMsg(ctx context.Context, in *GetUserMsgRequest
|
||||
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/GetUserMsg", in, out)
|
||||
}
|
||||
|
||||
func (c *artistInfoClient) UpdateMsg(ctx context.Context, in *UpdateMsgRequest, opts ...grpc_go.CallOption) (*UpdateMsgRespond, common.ErrorWithAttachment) {
|
||||
out := new(UpdateMsgRespond)
|
||||
interfaceKey := ctx.Value(constant.InterfaceKey).(string)
|
||||
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/UpdateMsg", in, out)
|
||||
}
|
||||
|
||||
func (c *artistInfoClient) BindInviteInvitedAccount(ctx context.Context, in *BindInviteInvitedAccountRequest, opts ...grpc_go.CallOption) (*BindInviteInvitedAccountRespond, common.ErrorWithAttachment) {
|
||||
out := new(BindInviteInvitedAccountRespond)
|
||||
interfaceKey := ctx.Value(constant.InterfaceKey).(string)
|
||||
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/BindInviteInvitedAccount", in, out)
|
||||
}
|
||||
|
||||
func (c *artistInfoClient) BindArtistId(ctx context.Context, in *BindArtistIdRequest, opts ...grpc_go.CallOption) (*BindArtistIdResp, common.ErrorWithAttachment) {
|
||||
out := new(BindArtistIdResp)
|
||||
interfaceKey := ctx.Value(constant.InterfaceKey).(string)
|
||||
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/BindArtistId", in, out)
|
||||
}
|
||||
|
||||
// ArtistInfoServer is the server API for ArtistInfo service.
|
||||
// All implementations must embed UnimplementedArtistInfoServer
|
||||
// for forward compatibility
|
||||
@ -188,6 +212,9 @@ type ArtistInfoServer interface {
|
||||
CheckInvitedCode(context.Context, *CheckInvitedCodeRequest) (*GetUserRespond, error)
|
||||
UnFinishList(context.Context, *UnFinishListRequest) (*UnFinishListRespond, error)
|
||||
GetUserMsg(context.Context, *GetUserMsgRequest) (*GetUserMsgRespond, error)
|
||||
UpdateMsg(context.Context, *UpdateMsgRequest) (*UpdateMsgRespond, error)
|
||||
BindInviteInvitedAccount(context.Context, *BindInviteInvitedAccountRequest) (*BindInviteInvitedAccountRespond, error)
|
||||
BindArtistId(context.Context, *BindArtistIdRequest) (*BindArtistIdResp, error)
|
||||
mustEmbedUnimplementedArtistInfoServer()
|
||||
}
|
||||
|
||||
@ -241,6 +268,15 @@ func (UnimplementedArtistInfoServer) UnFinishList(context.Context, *UnFinishList
|
||||
func (UnimplementedArtistInfoServer) GetUserMsg(context.Context, *GetUserMsgRequest) (*GetUserMsgRespond, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method GetUserMsg not implemented")
|
||||
}
|
||||
func (UnimplementedArtistInfoServer) UpdateMsg(context.Context, *UpdateMsgRequest) (*UpdateMsgRespond, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method UpdateMsg not implemented")
|
||||
}
|
||||
func (UnimplementedArtistInfoServer) BindInviteInvitedAccount(context.Context, *BindInviteInvitedAccountRequest) (*BindInviteInvitedAccountRespond, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method BindInviteInvitedAccount not implemented")
|
||||
}
|
||||
func (UnimplementedArtistInfoServer) BindArtistId(context.Context, *BindArtistIdRequest) (*BindArtistIdResp, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method BindArtistId not implemented")
|
||||
}
|
||||
func (s *UnimplementedArtistInfoServer) XXX_SetProxyImpl(impl protocol.Invoker) {
|
||||
s.proxyImpl = impl
|
||||
}
|
||||
@ -704,6 +740,93 @@ func _ArtistInfo_GetUserMsg_Handler(srv interface{}, ctx context.Context, dec fu
|
||||
return interceptor(ctx, in, info, handler)
|
||||
}
|
||||
|
||||
func _ArtistInfo_UpdateMsg_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
|
||||
in := new(UpdateMsgRequest)
|
||||
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("UpdateMsg", 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 _ArtistInfo_BindInviteInvitedAccount_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
|
||||
in := new(BindInviteInvitedAccountRequest)
|
||||
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("BindInviteInvitedAccount", 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 _ArtistInfo_BindArtistId_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
|
||||
in := new(BindArtistIdRequest)
|
||||
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("BindArtistId", 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)
|
||||
}
|
||||
|
||||
// ArtistInfo_ServiceDesc is the grpc_go.ServiceDesc for ArtistInfo service.
|
||||
// It's only intended for direct use with grpc_go.RegisterService,
|
||||
// and not to be introspected or modified (even as a copy)
|
||||
@ -771,6 +894,18 @@ var ArtistInfo_ServiceDesc = grpc_go.ServiceDesc{
|
||||
MethodName: "GetUserMsg",
|
||||
Handler: _ArtistInfo_GetUserMsg_Handler,
|
||||
},
|
||||
{
|
||||
MethodName: "UpdateMsg",
|
||||
Handler: _ArtistInfo_UpdateMsg_Handler,
|
||||
},
|
||||
{
|
||||
MethodName: "BindInviteInvitedAccount",
|
||||
Handler: _ArtistInfo_BindInviteInvitedAccount_Handler,
|
||||
},
|
||||
{
|
||||
MethodName: "BindArtistId",
|
||||
Handler: _ArtistInfo_BindArtistId_Handler,
|
||||
},
|
||||
},
|
||||
Streams: []grpc_go.StreamDesc{},
|
||||
Metadata: "pb/artistinfo/artistinfo.proto",
|
||||
|
||||
Loading…
Reference in New Issue
Block a user