jjxu/fonchain-artistinfo
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge branch 'songchuang' into dev

Browse Source
This commit is contained in:
songchuang 2023-03-24 14:13:34 +08:00
commit deaeee5c16
7 changed files with 681 additions and 262 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
cmd/internal/controller/statement.go
View File

@ -28,3 +28,11 @@ func (c *ArtistInfoStatementProvider) GetTxInfoByBatchUid(ctx context.Context, r
}
return rep, nil
}
func (c *ArtistInfoStatementProvider) GetCopyInfoByBatchUid(ctx context.Context, req *statement.GetCopyInfoByBatchUidRequest) (rep *statement.GetCopyInfoByBatchUidRespond, err error) {
fmt.Println("第一处")
if rep, err = c.statementLogic.GetCopyInfoByBatchUid(req); err != nil {
return nil, err
}
return rep, nil
}

32
cmd/internal/dao/statement.go
View File

@ -43,7 +43,7 @@ func StatementList(artistUid string, state int32) (contractData []*statement.Con
return
}
func GetArtistNameByBatchUid(batchUid string) (artworkTx model.ArtworkTx, err error) {
func GetTxArtistNameByBatchUid(batchUid string) (artworkTx model.ArtworkTx, err error) {
if err = db.DB.Where("uid = ?", batchUid).Find(&artworkTx).Error; err != nil {
zap.L().Error("get artworkTx info err", zap.Error(err))
err = errors.New(m.ERROR_SELECT)
@ -72,3 +72,33 @@ func GetArtworkSoldTxDetailByBatchUid(batchUid string) (artworkSoldTxDetail []mo
return
}
func GetCopyArtistNameByBatchUid(batchUid string) (artworkCopy model.ArtworkCopy, err error) {
if err = db.DB.Where("uid = ?", batchUid).Find(&artworkCopy).Error; err != nil {
zap.L().Error("get artworkCopy info err", zap.Error(err))
err = errors.New(m.ERROR_SELECT)
return
}
return
}
func GetArtworkCopyDetailByBatchUid(batchUid string) (artworkCopyDetail []model.ArtworkCopyDetail, err error) {
if err = db.DB.Where("batch_uid = ?", batchUid).Find(&artworkCopyDetail).Error; err != nil {
zap.L().Error("get artworkCopyDetail infos err", zap.Error(err))
err = errors.New(m.ERROR_SELECT)
return
}
return
}
func GetArtworkSoldCopyDetailByBatchUid(batchUid string) (artworkSoldCopyDetail []model.ArtworkSoldCopyDetail, err error) {
if err = db.DB.Where("batch_uid = ?", batchUid).Find(&artworkSoldCopyDetail).Error; err != nil {
zap.L().Error("get artworkSoldCopyDetail infos err", zap.Error(err))
err = errors.New(m.ERROR_SELECT)
return
}
return
}

54
cmd/internal/logic/statement.go
View File

@ -8,6 +8,7 @@ import (
type IStatement interface {
StatementList(req *statement.StatementListRequest) (rep *statement.StatementListRespond, err error)
GetTxInfoByBatchUid(req *statement.GetTxInfoByBatchUidRequest) (rep *statement.GetTxInfoByBatchUidRespond, err error)
GetCopyInfoByBatchUid(req *statement.GetCopyInfoByBatchUidRequest) (rep *statement.GetCopyInfoByBatchUidRespond, err error)
}
func NewStatement() IStatement {
@ -41,7 +42,7 @@ func (a *Statement) GetTxInfoByBatchUid(req *statement.GetTxInfoByBatchUidReques
rep = &statement.GetTxInfoByBatchUidRespond{}
//获取画家名
artworkTx, err := dao.GetArtistNameByBatchUid(req.BatchUid)
artworkTx, err := dao.GetTxArtistNameByBatchUid(req.BatchUid)
if err != nil {
return
}
@ -86,3 +87,54 @@ func (a *Statement) GetTxInfoByBatchUid(req *statement.GetTxInfoByBatchUidReques
return
}
func (a *Statement) GetCopyInfoByBatchUid(req *statement.GetCopyInfoByBatchUidRequest) (rep *statement.GetCopyInfoByBatchUidRespond, err error) {
rep = &statement.GetCopyInfoByBatchUidRespond{}
//获取画家名
artworkTx, err := dao.GetCopyArtistNameByBatchUid(req.BatchUid)
if err != nil {
return
}
rep.ArtistName = artworkTx.ArtistName
//获取版权画作详细信息
artworkTxDetails, err := dao.GetArtworkCopyDetailByBatchUid(req.BatchUid)
if err != nil {
return
}
rep.ArtistName = artworkTx.ArtistName
//获取版权画作被售卖详细信息
artworkSoldTxDetails, err := dao.GetArtworkSoldCopyDetailByBatchUid(req.BatchUid)
if err != nil {
return
}
artworkCopyDetail := new(statement.ArtworkCopyDetail)
artworkSoldCopyDetail := new(statement.ArtworkSoldCopyDetail)
for _, v := range artworkTxDetails {
artworkCopyDetail.TfNum = v.TfNum
artworkCopyDetail.ArtworkName = v.ArtworkName
artworkCopyDetail.Ruler = v.Ruler
artworkCopyDetail.MinPrice = v.MinPrice
artworkCopyDetail.GuaranteePrice = v.GuaranteePrice
rep.ArtworkCopyDetail = append(rep.ArtworkCopyDetail, artworkCopyDetail)
}
for _, v := range artworkSoldTxDetails {
artworkSoldCopyDetail.TfNum = v.TfNum
artworkSoldCopyDetail.ArtworkName = v.ArtworkName
artworkSoldCopyDetail.Ruler = v.Ruler
artworkSoldCopyDetail.SaleNo = v.SaleNo
artworkSoldCopyDetail.CompleteDate = v.CompleteDate
artworkSoldCopyDetail.MinPrice = v.MinPrice
artworkSoldCopyDetail.SalePrice = v.SalePrice
artworkSoldCopyDetail.GuaranteePrice = v.GuaranteePrice
rep.ArtworkSoldCopyDetail = append(rep.ArtworkSoldCopyDetail, artworkSoldCopyDetail)
}
return
}

665
pb/artistinfoStatement/statement.pb.go
View File

@ -40,7 +40,6 @@ type Contracts struct {
SignTime string `protobuf:"bytes,13,opt,name=SignTime,json=sign_time,proto3" json:"SignTime,omitempty"`
BatchTime string `protobuf:"bytes,14,opt,name=BatchTime,json=batch_time,proto3" json:"BatchTime,omitempty"`
BatchUid string `protobuf:"bytes,15,opt,name=BatchUid,json=batch_uid,proto3" json:"BatchUid,omitempty"`
ArtistName string `protobuf:"bytes,16,opt,name=ArtistName,json=artist_name,proto3" json:"ArtistName,omitempty"`
}
func (x *Contracts) Reset() {
@ -180,13 +179,6 @@ func (x *Contracts) GetBatchUid() string {
return ""
}
func (x *Contracts) GetArtistName() string {
if x != nil {
return x.ArtistName
}
return ""
}
type ArtworkTxDetail struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
@ -385,6 +377,204 @@ func (x *ArtworkSoldTxDetail) GetGuaranteePrice() float32 {
return 0
}
type ArtworkCopyDetail struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
BatchUid string `protobuf:"bytes,1,opt,name=BatchUid,json=batch_uid,proto3" json:"BatchUid,omitempty"`
TfNum string `protobuf:"bytes,2,opt,name=TfNum,proto3" json:"TfNum,omitempty"`
ArtworkName string `protobuf:"bytes,3,opt,name=ArtworkName,json=artwork_name,proto3" json:"ArtworkName,omitempty"`
Ruler string `protobuf:"bytes,4,opt,name=Ruler,json=ruler,proto3" json:"Ruler,omitempty"`
MinPrice float32 `protobuf:"fixed32,5,opt,name=MinPrice,json=min_price,proto3" json:"MinPrice,omitempty"`
GuaranteePrice float32 `protobuf:"fixed32,6,opt,name=GuaranteePrice,json=guarantee_price,proto3" json:"GuaranteePrice,omitempty"`
}
func (x *ArtworkCopyDetail) Reset() {
*x = ArtworkCopyDetail{}
if protoimpl.UnsafeEnabled {
mi := &file_statement_proto_msgTypes[3]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *ArtworkCopyDetail) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*ArtworkCopyDetail) ProtoMessage() {}
func (x *ArtworkCopyDetail) ProtoReflect() protoreflect.Message {
mi := &file_statement_proto_msgTypes[3]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use ArtworkCopyDetail.ProtoReflect.Descriptor instead.
func (*ArtworkCopyDetail) Descriptor() ([]byte, []int) {
return file_statement_proto_rawDescGZIP(), []int{3}
}
func (x *ArtworkCopyDetail) GetBatchUid() string {
if x != nil {
return x.BatchUid
}
return ""
}
func (x *ArtworkCopyDetail) GetTfNum() string {
if x != nil {
return x.TfNum
}
return ""
}
func (x *ArtworkCopyDetail) GetArtworkName() string {
if x != nil {
return x.ArtworkName
}
return ""
}
func (x *ArtworkCopyDetail) GetRuler() string {
if x != nil {
return x.Ruler
}
return ""
}
func (x *ArtworkCopyDetail) GetMinPrice() float32 {
if x != nil {
return x.MinPrice
}
return 0
}
func (x *ArtworkCopyDetail) GetGuaranteePrice() float32 {
if x != nil {
return x.GuaranteePrice
}
return 0
}
type ArtworkSoldCopyDetail struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
BatchUid string `protobuf:"bytes,1,opt,name=BatchUid,json=batch_uid,proto3" json:"BatchUid,omitempty"`
TfNum string `protobuf:"bytes,2,opt,name=TfNum,proto3" json:"TfNum,omitempty"`
ArtworkName string `protobuf:"bytes,3,opt,name=ArtworkName,json=artwork_name,proto3" json:"ArtworkName,omitempty"`
Ruler string `protobuf:"bytes,4,opt,name=Ruler,json=ruler,proto3" json:"Ruler,omitempty"`
SaleNo string `protobuf:"bytes,5,opt,name=SaleNo,json=sale_no,proto3" json:"SaleNo,omitempty"`
CompleteDate string `protobuf:"bytes,6,opt,name=CompleteDate,json=complete_date,proto3" json:"CompleteDate,omitempty"`
MinPrice float32 `protobuf:"fixed32,7,opt,name=MinPrice,json=min_price,proto3" json:"MinPrice,omitempty"`
SalePrice float32 `protobuf:"fixed32,8,opt,name=SalePrice,json=sale_price,proto3" json:"SalePrice,omitempty"`
GuaranteePrice float32 `protobuf:"fixed32,9,opt,name=GuaranteePrice,json=guarantee_price,proto3" json:"GuaranteePrice,omitempty"`
}
func (x *ArtworkSoldCopyDetail) Reset() {
*x = ArtworkSoldCopyDetail{}
if protoimpl.UnsafeEnabled {
mi := &file_statement_proto_msgTypes[4]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *ArtworkSoldCopyDetail) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*ArtworkSoldCopyDetail) ProtoMessage() {}
func (x *ArtworkSoldCopyDetail) ProtoReflect() protoreflect.Message {
mi := &file_statement_proto_msgTypes[4]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use ArtworkSoldCopyDetail.ProtoReflect.Descriptor instead.
func (*ArtworkSoldCopyDetail) Descriptor() ([]byte, []int) {
return file_statement_proto_rawDescGZIP(), []int{4}
}
func (x *ArtworkSoldCopyDetail) GetBatchUid() string {
if x != nil {
return x.BatchUid
}
return ""
}
func (x *ArtworkSoldCopyDetail) GetTfNum() string {
if x != nil {
return x.TfNum
}
return ""
}
func (x *ArtworkSoldCopyDetail) GetArtworkName() string {
if x != nil {
return x.ArtworkName
}
return ""
}
func (x *ArtworkSoldCopyDetail) GetRuler() string {
if x != nil {
return x.Ruler
}
return ""
}
func (x *ArtworkSoldCopyDetail) GetSaleNo() string {
if x != nil {
return x.SaleNo
}
return ""
}
func (x *ArtworkSoldCopyDetail) GetCompleteDate() string {
if x != nil {
return x.CompleteDate
}
return ""
}
func (x *ArtworkSoldCopyDetail) GetMinPrice() float32 {
if x != nil {
return x.MinPrice
}
return 0
}
func (x *ArtworkSoldCopyDetail) GetSalePrice() float32 {
if x != nil {
return x.SalePrice
}
return 0
}
func (x *ArtworkSoldCopyDetail) GetGuaranteePrice() float32 {
if x != nil {
return x.GuaranteePrice
}
return 0
}
type StatementListRequest struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
@ -399,7 +589,7 @@ type StatementListRequest struct {
func (x *StatementListRequest) Reset() {
*x = StatementListRequest{}
if protoimpl.UnsafeEnabled {
mi := &file_statement_proto_msgTypes[3]
mi := &file_statement_proto_msgTypes[5]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@ -412,7 +602,7 @@ func (x *StatementListRequest) String() string {
func (*StatementListRequest) ProtoMessage() {}
func (x *StatementListRequest) ProtoReflect() protoreflect.Message {
mi := &file_statement_proto_msgTypes[3]
mi := &file_statement_proto_msgTypes[5]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@ -425,7 +615,7 @@ func (x *StatementListRequest) ProtoReflect() protoreflect.Message {
// Deprecated: Use StatementListRequest.ProtoReflect.Descriptor instead.
func (*StatementListRequest) Descriptor() ([]byte, []int) {
return file_statement_proto_rawDescGZIP(), []int{3}
return file_statement_proto_rawDescGZIP(), []int{5}
}
func (x *StatementListRequest) GetArtistUid() string {
@ -468,7 +658,7 @@ type StatementListRespond struct {
func (x *StatementListRespond) Reset() {
*x = StatementListRespond{}
if protoimpl.UnsafeEnabled {
mi := &file_statement_proto_msgTypes[4]
mi := &file_statement_proto_msgTypes[6]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@ -481,7 +671,7 @@ func (x *StatementListRespond) String() string {
func (*StatementListRespond) ProtoMessage() {}
func (x *StatementListRespond) ProtoReflect() protoreflect.Message {
mi := &file_statement_proto_msgTypes[4]
mi := &file_statement_proto_msgTypes[6]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@ -494,7 +684,7 @@ func (x *StatementListRespond) ProtoReflect() protoreflect.Message {
// Deprecated: Use StatementListRespond.ProtoReflect.Descriptor instead.
func (*StatementListRespond) Descriptor() ([]byte, []int) {
return file_statement_proto_rawDescGZIP(), []int{4}
return file_statement_proto_rawDescGZIP(), []int{6}
}
func (x *StatementListRespond) GetData() []*Contracts {
@ -511,100 +701,6 @@ func (x *StatementListRespond) GetMsg() string {
return ""
}
type CreateTxContractRequest struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
BatchUid string `protobuf:"bytes,1,opt,name=BatchUid,json=batch_uid,proto3" json:"BatchUid,omitempty"`
}
func (x *CreateTxContractRequest) Reset() {
*x = CreateTxContractRequest{}
if protoimpl.UnsafeEnabled {
mi := &file_statement_proto_msgTypes[5]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *CreateTxContractRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CreateTxContractRequest) ProtoMessage() {}
func (x *CreateTxContractRequest) ProtoReflect() protoreflect.Message {
mi := &file_statement_proto_msgTypes[5]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use CreateTxContractRequest.ProtoReflect.Descriptor instead.
func (*CreateTxContractRequest) Descriptor() ([]byte, []int) {
return file_statement_proto_rawDescGZIP(), []int{5}
}
func (x *CreateTxContractRequest) GetBatchUid() string {
if x != nil {
return x.BatchUid
}
return ""
}
type CreateTxContractRespond struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Msg string `protobuf:"bytes,1,opt,name=Msg,json=msg,proto3" json:"Msg,omitempty"`
}
func (x *CreateTxContractRespond) Reset() {
*x = CreateTxContractRespond{}
if protoimpl.UnsafeEnabled {
mi := &file_statement_proto_msgTypes[6]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *CreateTxContractRespond) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CreateTxContractRespond) ProtoMessage() {}
func (x *CreateTxContractRespond) ProtoReflect() protoreflect.Message {
mi := &file_statement_proto_msgTypes[6]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use CreateTxContractRespond.ProtoReflect.Descriptor instead.
func (*CreateTxContractRespond) Descriptor() ([]byte, []int) {
return file_statement_proto_rawDescGZIP(), []int{6}
}
func (x *CreateTxContractRespond) GetMsg() string {
if x != nil {
return x.Msg
}
return ""
}
type GetTxInfoByBatchUidRequest struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
@ -723,11 +819,129 @@ func (x *GetTxInfoByBatchUidRespond) GetMsg() string {
return ""
}
type GetCopyInfoByBatchUidRequest struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
BatchUid string `protobuf:"bytes,1,opt,name=BatchUid,json=batch_uid,proto3" json:"BatchUid,omitempty"`
}
func (x *GetCopyInfoByBatchUidRequest) Reset() {
*x = GetCopyInfoByBatchUidRequest{}
if protoimpl.UnsafeEnabled {
mi := &file_statement_proto_msgTypes[9]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *GetCopyInfoByBatchUidRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*GetCopyInfoByBatchUidRequest) ProtoMessage() {}
func (x *GetCopyInfoByBatchUidRequest) ProtoReflect() protoreflect.Message {
mi := &file_statement_proto_msgTypes[9]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use GetCopyInfoByBatchUidRequest.ProtoReflect.Descriptor instead.
func (*GetCopyInfoByBatchUidRequest) Descriptor() ([]byte, []int) {
return file_statement_proto_rawDescGZIP(), []int{9}
}
func (x *GetCopyInfoByBatchUidRequest) GetBatchUid() string {
if x != nil {
return x.BatchUid
}
return ""
}
type GetCopyInfoByBatchUidRespond struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
ArtistName string `protobuf:"bytes,1,opt,name=ArtistName,json=artist_name,proto3" json:"ArtistName,omitempty"`
ArtworkCopyDetail []*ArtworkCopyDetail `protobuf:"bytes,2,rep,name=ArtworkCopyDetail,json=artwork_copy_detail,proto3" json:"ArtworkCopyDetail,omitempty"`
ArtworkSoldCopyDetail []*ArtworkSoldCopyDetail `protobuf:"bytes,3,rep,name=ArtworkSoldCopyDetail,json=artwork_sold_copy_detail,proto3" json:"ArtworkSoldCopyDetail,omitempty"`
Msg string `protobuf:"bytes,4,opt,name=Msg,json=msg,proto3" json:"Msg,omitempty"`
}
func (x *GetCopyInfoByBatchUidRespond) Reset() {
*x = GetCopyInfoByBatchUidRespond{}
if protoimpl.UnsafeEnabled {
mi := &file_statement_proto_msgTypes[10]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *GetCopyInfoByBatchUidRespond) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*GetCopyInfoByBatchUidRespond) ProtoMessage() {}
func (x *GetCopyInfoByBatchUidRespond) ProtoReflect() protoreflect.Message {
mi := &file_statement_proto_msgTypes[10]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use GetCopyInfoByBatchUidRespond.ProtoReflect.Descriptor instead.
func (*GetCopyInfoByBatchUidRespond) Descriptor() ([]byte, []int) {
return file_statement_proto_rawDescGZIP(), []int{10}
}
func (x *GetCopyInfoByBatchUidRespond) GetArtistName() string {
if x != nil {
return x.ArtistName
}
return ""
}
func (x *GetCopyInfoByBatchUidRespond) GetArtworkCopyDetail() []*ArtworkCopyDetail {
if x != nil {
return x.ArtworkCopyDetail
}
return nil
}
func (x *GetCopyInfoByBatchUidRespond) GetArtworkSoldCopyDetail() []*ArtworkSoldCopyDetail {
if x != nil {
return x.ArtworkSoldCopyDetail
}
return nil
}
func (x *GetCopyInfoByBatchUidRespond) GetMsg() string {
if x != nil {
return x.Msg
}
return ""
}
var File_statement_proto protoreflect.FileDescriptor
var file_statement_proto_rawDesc = []byte{
0x0a, 0x0f, 0x73, 0x74, 0x61, 0x74, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74,
0x6f, 0x12, 0x09, 0x73, 0x74, 0x61, 0x74, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x22, 0xf6, 0x03, 0x0a,
0x6f, 0x12, 0x09, 0x73, 0x74, 0x61, 0x74, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x22, 0xd5, 0x03, 0x0a,
0x09, 0x43, 0x6f, 0x6e, 0x74, 0x72, 0x61, 0x63, 0x74, 0x73, 0x12, 0x21, 0x0a, 0x0b, 0x43, 0x6f,
0x6e, 0x74, 0x72, 0x61, 0x63, 0x74, 0x55, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52,
0x0c, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x61, 0x63, 0x74, 0x5f, 0x75, 0x69, 0x64, 0x12, 0x1d, 0x0a,
@ -757,22 +971,51 @@ var file_statement_proto_rawDesc = []byte{
0x68, 0x54, 0x69, 0x6d, 0x65, 0x18, 0x0e, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x62, 0x61, 0x74,
0x63, 0x68, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x12, 0x1b, 0x0a, 0x08, 0x42, 0x61, 0x74, 0x63, 0x68,
0x55, 0x69, 0x64, 0x18, 0x0f, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x62, 0x61, 0x74, 0x63, 0x68,
0x5f, 0x75, 0x69, 0x64, 0x12, 0x1f, 0x0a, 0x0a, 0x41, 0x72, 0x74, 0x69, 0x73, 0x74, 0x4e, 0x61,
0x6d, 0x65, 0x18, 0x10, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x61, 0x72, 0x74, 0x69, 0x73, 0x74,
0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x22, 0xc3, 0x01, 0x0a, 0x0f, 0x41, 0x72, 0x74, 0x77, 0x6f, 0x72,
0x6b, 0x54, 0x78, 0x44, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x12, 0x1b, 0x0a, 0x08, 0x42, 0x61, 0x74,
0x63, 0x68, 0x55, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x62, 0x61, 0x74,
0x63, 0x68, 0x5f, 0x75, 0x69, 0x64, 0x12, 0x14, 0x0a, 0x05, 0x54, 0x66, 0x4e, 0x75, 0x6d, 0x18,
0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x54, 0x66, 0x4e, 0x75, 0x6d, 0x12, 0x21, 0x0a, 0x0b,
0x41, 0x72, 0x74, 0x77, 0x6f, 0x72, 0x6b, 0x4e, 0x61, 0x6d, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28,
0x09, 0x52, 0x0c, 0x61, 0x72, 0x74, 0x77, 0x6f, 0x72, 0x6b, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x12,
0x14, 0x0a, 0x05, 0x52, 0x75, 0x6c, 0x65, 0x72, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05,
0x72, 0x75, 0x6c, 0x65, 0x72, 0x12, 0x1b, 0x0a, 0x08, 0x4d, 0x69, 0x6e, 0x50, 0x72, 0x69, 0x63,
0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 0x02, 0x52, 0x09, 0x6d, 0x69, 0x6e, 0x5f, 0x70, 0x72, 0x69,
0x63, 0x65, 0x12, 0x27, 0x0a, 0x0e, 0x47, 0x75, 0x61, 0x72, 0x61, 0x6e, 0x74, 0x65, 0x65, 0x50,
0x72, 0x69, 0x63, 0x65, 0x18, 0x06, 0x20, 0x01, 0x28, 0x02, 0x52, 0x0f, 0x67, 0x75, 0x61, 0x72,
0x61, 0x6e, 0x74, 0x65, 0x65, 0x5f, 0x70, 0x72, 0x69, 0x63, 0x65, 0x22, 0xa4, 0x02, 0x0a, 0x13,
0x41, 0x72, 0x74, 0x77, 0x6f, 0x72, 0x6b, 0x53, 0x6f, 0x6c, 0x64, 0x54, 0x78, 0x44, 0x65, 0x74,
0x5f, 0x75, 0x69, 0x64, 0x22, 0xc3, 0x01, 0x0a, 0x0f, 0x41, 0x72, 0x74, 0x77, 0x6f, 0x72, 0x6b,
0x54, 0x78, 0x44, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x12, 0x1b, 0x0a, 0x08, 0x42, 0x61, 0x74, 0x63,
0x68, 0x55, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x62, 0x61, 0x74, 0x63,
0x68, 0x5f, 0x75, 0x69, 0x64, 0x12, 0x14, 0x0a, 0x05, 0x54, 0x66, 0x4e, 0x75, 0x6d, 0x18, 0x02,
0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x54, 0x66, 0x4e, 0x75, 0x6d, 0x12, 0x21, 0x0a, 0x0b, 0x41,
0x72, 0x74, 0x77, 0x6f, 0x72, 0x6b, 0x4e, 0x61, 0x6d, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09,
0x52, 0x0c, 0x61, 0x72, 0x74, 0x77, 0x6f, 0x72, 0x6b, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x14,
0x0a, 0x05, 0x52, 0x75, 0x6c, 0x65, 0x72, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x72,
0x75, 0x6c, 0x65, 0x72, 0x12, 0x1b, 0x0a, 0x08, 0x4d, 0x69, 0x6e, 0x50, 0x72, 0x69, 0x63, 0x65,
0x18, 0x05, 0x20, 0x01, 0x28, 0x02, 0x52, 0x09, 0x6d, 0x69, 0x6e, 0x5f, 0x70, 0x72, 0x69, 0x63,
0x65, 0x12, 0x27, 0x0a, 0x0e, 0x47, 0x75, 0x61, 0x72, 0x61, 0x6e, 0x74, 0x65, 0x65, 0x50, 0x72,
0x69, 0x63, 0x65, 0x18, 0x06, 0x20, 0x01, 0x28, 0x02, 0x52, 0x0f, 0x67, 0x75, 0x61, 0x72, 0x61,
0x6e, 0x74, 0x65, 0x65, 0x5f, 0x70, 0x72, 0x69, 0x63, 0x65, 0x22, 0xa4, 0x02, 0x0a, 0x13, 0x41,
0x72, 0x74, 0x77, 0x6f, 0x72, 0x6b, 0x53, 0x6f, 0x6c, 0x64, 0x54, 0x78, 0x44, 0x65, 0x74, 0x61,
0x69, 0x6c, 0x12, 0x1b, 0x0a, 0x08, 0x42, 0x61, 0x74, 0x63, 0x68, 0x55, 0x69, 0x64, 0x18, 0x01,
0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x62, 0x61, 0x74, 0x63, 0x68, 0x5f, 0x75, 0x69, 0x64, 0x12,
0x14, 0x0a, 0x05, 0x54, 0x66, 0x4e, 0x75, 0x6d, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05,
0x54, 0x66, 0x4e, 0x75, 0x6d, 0x12, 0x21, 0x0a, 0x0b, 0x41, 0x72, 0x74, 0x77, 0x6f, 0x72, 0x6b,
0x4e, 0x61, 0x6d, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x61, 0x72, 0x74, 0x77,
0x6f, 0x72, 0x6b, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x14, 0x0a, 0x05, 0x52, 0x75, 0x6c, 0x65,
0x72, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x72, 0x75, 0x6c, 0x65, 0x72, 0x12, 0x17,
0x0a, 0x06, 0x53, 0x61, 0x6c, 0x65, 0x4e, 0x6f, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07,
0x73, 0x61, 0x6c, 0x65, 0x5f, 0x6e, 0x6f, 0x12, 0x23, 0x0a, 0x0c, 0x43, 0x6f, 0x6d, 0x70, 0x6c,
0x65, 0x74, 0x65, 0x44, 0x61, 0x74, 0x65, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x63,
0x6f, 0x6d, 0x70, 0x6c, 0x65, 0x74, 0x65, 0x5f, 0x64, 0x61, 0x74, 0x65, 0x12, 0x1b, 0x0a, 0x08,
0x4d, 0x69, 0x6e, 0x50, 0x72, 0x69, 0x63, 0x65, 0x18, 0x07, 0x20, 0x01, 0x28, 0x02, 0x52, 0x09,
0x6d, 0x69, 0x6e, 0x5f, 0x70, 0x72, 0x69, 0x63, 0x65, 0x12, 0x1d, 0x0a, 0x09, 0x53, 0x61, 0x6c,
0x65, 0x50, 0x72, 0x69, 0x63, 0x65, 0x18, 0x08, 0x20, 0x01, 0x28, 0x02, 0x52, 0x0a, 0x73, 0x61,
0x6c, 0x65, 0x5f, 0x70, 0x72, 0x69, 0x63, 0x65, 0x12, 0x27, 0x0a, 0x0e, 0x47, 0x75, 0x61, 0x72,
0x61, 0x6e, 0x74, 0x65, 0x65, 0x50, 0x72, 0x69, 0x63, 0x65, 0x18, 0x09, 0x20, 0x01, 0x28, 0x02,
0x52, 0x0f, 0x67, 0x75, 0x61, 0x72, 0x61, 0x6e, 0x74, 0x65, 0x65, 0x5f, 0x70, 0x72, 0x69, 0x63,
0x65, 0x22, 0xc5, 0x01, 0x0a, 0x11, 0x41, 0x72, 0x74, 0x77, 0x6f, 0x72, 0x6b, 0x43, 0x6f, 0x70,
0x79, 0x44, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x12, 0x1b, 0x0a, 0x08, 0x42, 0x61, 0x74, 0x63, 0x68,
0x55, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x62, 0x61, 0x74, 0x63, 0x68,
0x5f, 0x75, 0x69, 0x64, 0x12, 0x14, 0x0a, 0x05, 0x54, 0x66, 0x4e, 0x75, 0x6d, 0x18, 0x02, 0x20,
0x01, 0x28, 0x09, 0x52, 0x05, 0x54, 0x66, 0x4e, 0x75, 0x6d, 0x12, 0x21, 0x0a, 0x0b, 0x41, 0x72,
0x74, 0x77, 0x6f, 0x72, 0x6b, 0x4e, 0x61, 0x6d, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52,
0x0c, 0x61, 0x72, 0x74, 0x77, 0x6f, 0x72, 0x6b, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x14, 0x0a,
0x05, 0x52, 0x75, 0x6c, 0x65, 0x72, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x72, 0x75,
0x6c, 0x65, 0x72, 0x12, 0x1b, 0x0a, 0x08, 0x4d, 0x69, 0x6e, 0x50, 0x72, 0x69, 0x63, 0x65, 0x18,
0x05, 0x20, 0x01, 0x28, 0x02, 0x52, 0x09, 0x6d, 0x69, 0x6e, 0x5f, 0x70, 0x72, 0x69, 0x63, 0x65,
0x12, 0x27, 0x0a, 0x0e, 0x47, 0x75, 0x61, 0x72, 0x61, 0x6e, 0x74, 0x65, 0x65, 0x50, 0x72, 0x69,
0x63, 0x65, 0x18, 0x06, 0x20, 0x01, 0x28, 0x02, 0x52, 0x0f, 0x67, 0x75, 0x61, 0x72, 0x61, 0x6e,
0x74, 0x65, 0x65, 0x5f, 0x70, 0x72, 0x69, 0x63, 0x65, 0x22, 0xa6, 0x02, 0x0a, 0x15, 0x41, 0x72,
0x74, 0x77, 0x6f, 0x72, 0x6b, 0x53, 0x6f, 0x6c, 0x64, 0x43, 0x6f, 0x70, 0x79, 0x44, 0x65, 0x74,
0x61, 0x69, 0x6c, 0x12, 0x1b, 0x0a, 0x08, 0x42, 0x61, 0x74, 0x63, 0x68, 0x55, 0x69, 0x64, 0x18,
0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x62, 0x61, 0x74, 0x63, 0x68, 0x5f, 0x75, 0x69, 0x64,
0x12, 0x14, 0x0a, 0x05, 0x54, 0x66, 0x4e, 0x75, 0x6d, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52,
@ -803,52 +1046,66 @@ var file_statement_proto_rawDesc = []byte{
0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x14, 0x2e, 0x73, 0x74, 0x61, 0x74, 0x65, 0x6d, 0x65, 0x6e,
0x74, 0x2e, 0x43, 0x6f, 0x6e, 0x74, 0x72, 0x61, 0x63, 0x74, 0x73, 0x52, 0x04, 0x64, 0x61, 0x74,
0x61, 0x12, 0x10, 0x0a, 0x03, 0x4d, 0x73, 0x67, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03,
0x6d, 0x73, 0x67, 0x22, 0x36, 0x0a, 0x17, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x78, 0x43,
0x6f, 0x6e, 0x74, 0x72, 0x61, 0x63, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1b,
0x0a, 0x08, 0x42, 0x61, 0x74, 0x63, 0x68, 0x55, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09,
0x52, 0x09, 0x62, 0x61, 0x74, 0x63, 0x68, 0x5f, 0x75, 0x69, 0x64, 0x22, 0x2b, 0x0a, 0x17, 0x43,
0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x78, 0x43, 0x6f, 0x6e, 0x74, 0x72, 0x61, 0x63, 0x74, 0x52,
0x65, 0x73, 0x70, 0x6f, 0x6e, 0x64, 0x12, 0x10, 0x0a, 0x03, 0x4d, 0x73, 0x67, 0x18, 0x01, 0x20,
0x01, 0x28, 0x09, 0x52, 0x03, 0x6d, 0x73, 0x67, 0x22, 0x39, 0x0a, 0x1a, 0x47, 0x65, 0x74, 0x54,
0x78, 0x49, 0x6e, 0x66, 0x6f, 0x42, 0x79, 0x42, 0x61, 0x74, 0x63, 0x68, 0x55, 0x69, 0x64, 0x52,
0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1b, 0x0a, 0x08, 0x42, 0x61, 0x74, 0x63, 0x68, 0x55,
0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x62, 0x61, 0x74, 0x63, 0x68, 0x5f,
0x75, 0x69, 0x64, 0x22, 0xec, 0x01, 0x0a, 0x1a, 0x47, 0x65, 0x74, 0x54, 0x78, 0x49, 0x6e, 0x66,
0x6f, 0x42, 0x79, 0x42, 0x61, 0x74, 0x63, 0x68, 0x55, 0x69, 0x64, 0x52, 0x65, 0x73, 0x70, 0x6f,
0x6e, 0x64, 0x12, 0x1f, 0x0a, 0x0a, 0x41, 0x72, 0x74, 0x69, 0x73, 0x74, 0x4e, 0x61, 0x6d, 0x65,
0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x61, 0x72, 0x74, 0x69, 0x73, 0x74, 0x5f, 0x6e,
0x61, 0x6d, 0x65, 0x12, 0x46, 0x0a, 0x0f, 0x41, 0x72, 0x74, 0x77, 0x6f, 0x72, 0x6b, 0x54, 0x78,
0x44, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x73,
0x74, 0x61, 0x74, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x2e, 0x41, 0x72, 0x74, 0x77, 0x6f, 0x72, 0x6b,
0x54, 0x78, 0x44, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x52, 0x11, 0x61, 0x72, 0x74, 0x77, 0x6f, 0x72,
0x6b, 0x5f, 0x74, 0x78, 0x5f, 0x64, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x12, 0x53, 0x0a, 0x13, 0x41,
0x72, 0x74, 0x77, 0x6f, 0x72, 0x6b, 0x53, 0x6f, 0x6c, 0x64, 0x54, 0x78, 0x44, 0x65, 0x74, 0x61,
0x69, 0x6c, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1e, 0x2e, 0x73, 0x74, 0x61, 0x74, 0x65,
0x6d, 0x65, 0x6e, 0x74, 0x2e, 0x41, 0x72, 0x74, 0x77, 0x6f, 0x72, 0x6b, 0x53, 0x6f, 0x6c, 0x64,
0x54, 0x78, 0x44, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x52, 0x16, 0x61, 0x72, 0x74, 0x77, 0x6f, 0x72,
0x6b, 0x5f, 0x73, 0x6f, 0x6c, 0x64, 0x5f, 0x74, 0x78, 0x5f, 0x64, 0x65, 0x74, 0x61, 0x69, 0x6c,
0x12, 0x10, 0x0a, 0x03, 0x4d, 0x73, 0x67, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6d,
0x73, 0x67, 0x32, 0xa5, 0x02, 0x0a, 0x09, 0x53, 0x74, 0x61, 0x74, 0x65, 0x6d, 0x65, 0x6e, 0x74,
0x12, 0x53, 0x0a, 0x0d, 0x53, 0x74, 0x61, 0x74, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x4c, 0x69, 0x73,
0x74, 0x12, 0x1f, 0x2e, 0x73, 0x74, 0x61, 0x74, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x2e, 0x53, 0x74,
0x61, 0x74, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x4c, 0x69, 0x73, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65,
0x73, 0x74, 0x1a, 0x1f, 0x2e, 0x73, 0x74, 0x61, 0x74, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x2e, 0x53,
0x74, 0x61, 0x74, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x4c, 0x69, 0x73, 0x74, 0x52, 0x65, 0x73, 0x70,
0x6f, 0x6e, 0x64, 0x22, 0x00, 0x12, 0x5c, 0x0a, 0x10, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x54,
0x78, 0x43, 0x6f, 0x6e, 0x74, 0x72, 0x61, 0x63, 0x74, 0x12, 0x22, 0x2e, 0x73, 0x74, 0x61, 0x74,
0x65, 0x6d, 0x65, 0x6e, 0x74, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x78, 0x43, 0x6f,
0x6e, 0x74, 0x72, 0x61, 0x63, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x22, 0x2e,
0x73, 0x74, 0x61, 0x74, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65,
0x54, 0x78, 0x43, 0x6f, 0x6e, 0x74, 0x72, 0x61, 0x63, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,
0x64, 0x22, 0x00, 0x12, 0x65, 0x0a, 0x13, 0x47, 0x65, 0x74, 0x54, 0x78, 0x49, 0x6e, 0x66, 0x6f,
0x42, 0x79, 0x42, 0x61, 0x74, 0x63, 0x68, 0x55, 0x69, 0x64, 0x12, 0x25, 0x2e, 0x73, 0x74, 0x61,
0x74, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x2e, 0x47, 0x65, 0x74, 0x54, 0x78, 0x49, 0x6e, 0x66, 0x6f,
0x6d, 0x73, 0x67, 0x22, 0x39, 0x0a, 0x1a, 0x47, 0x65, 0x74, 0x54, 0x78, 0x49, 0x6e, 0x66, 0x6f,
0x42, 0x79, 0x42, 0x61, 0x74, 0x63, 0x68, 0x55, 0x69, 0x64, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73,
0x74, 0x1a, 0x25, 0x2e, 0x73, 0x74, 0x61, 0x74, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x2e, 0x47, 0x65,
0x74, 0x12, 0x1b, 0x0a, 0x08, 0x42, 0x61, 0x74, 0x63, 0x68, 0x55, 0x69, 0x64, 0x18, 0x01, 0x20,
0x01, 0x28, 0x09, 0x52, 0x09, 0x62, 0x61, 0x74, 0x63, 0x68, 0x5f, 0x75, 0x69, 0x64, 0x22, 0xec,
0x01, 0x0a, 0x1a, 0x47, 0x65, 0x74, 0x54, 0x78, 0x49, 0x6e, 0x66, 0x6f, 0x42, 0x79, 0x42, 0x61,
0x74, 0x63, 0x68, 0x55, 0x69, 0x64, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x64, 0x12, 0x1f, 0x0a,
0x0a, 0x41, 0x72, 0x74, 0x69, 0x73, 0x74, 0x4e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28,
0x09, 0x52, 0x0b, 0x61, 0x72, 0x74, 0x69, 0x73, 0x74, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x46,
0x0a, 0x0f, 0x41, 0x72, 0x74, 0x77, 0x6f, 0x72, 0x6b, 0x54, 0x78, 0x44, 0x65, 0x74, 0x61, 0x69,
0x6c, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x73, 0x74, 0x61, 0x74, 0x65, 0x6d,
0x65, 0x6e, 0x74, 0x2e, 0x41, 0x72, 0x74, 0x77, 0x6f, 0x72, 0x6b, 0x54, 0x78, 0x44, 0x65, 0x74,
0x61, 0x69, 0x6c, 0x52, 0x11, 0x61, 0x72, 0x74, 0x77, 0x6f, 0x72, 0x6b, 0x5f, 0x74, 0x78, 0x5f,
0x64, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x12, 0x53, 0x0a, 0x13, 0x41, 0x72, 0x74, 0x77, 0x6f, 0x72,
0x6b, 0x53, 0x6f, 0x6c, 0x64, 0x54, 0x78, 0x44, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x18, 0x03, 0x20,
0x03, 0x28, 0x0b, 0x32, 0x1e, 0x2e, 0x73, 0x74, 0x61, 0x74, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x2e,
0x41, 0x72, 0x74, 0x77, 0x6f, 0x72, 0x6b, 0x53, 0x6f, 0x6c, 0x64, 0x54, 0x78, 0x44, 0x65, 0x74,
0x61, 0x69, 0x6c, 0x52, 0x16, 0x61, 0x72, 0x74, 0x77, 0x6f, 0x72, 0x6b, 0x5f, 0x73, 0x6f, 0x6c,
0x64, 0x5f, 0x74, 0x78, 0x5f, 0x64, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x12, 0x10, 0x0a, 0x03, 0x4d,
0x73, 0x67, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6d, 0x73, 0x67, 0x22, 0x3b, 0x0a,
0x1c, 0x47, 0x65, 0x74, 0x43, 0x6f, 0x70, 0x79, 0x49, 0x6e, 0x66, 0x6f, 0x42, 0x79, 0x42, 0x61,
0x74, 0x63, 0x68, 0x55, 0x69, 0x64, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1b, 0x0a,
0x08, 0x42, 0x61, 0x74, 0x63, 0x68, 0x55, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52,
0x09, 0x62, 0x61, 0x74, 0x63, 0x68, 0x5f, 0x75, 0x69, 0x64, 0x22, 0xfa, 0x01, 0x0a, 0x1c, 0x47,
0x65, 0x74, 0x43, 0x6f, 0x70, 0x79, 0x49, 0x6e, 0x66, 0x6f, 0x42, 0x79, 0x42, 0x61, 0x74, 0x63,
0x68, 0x55, 0x69, 0x64, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x64, 0x12, 0x1f, 0x0a, 0x0a, 0x41,
0x72, 0x74, 0x69, 0x73, 0x74, 0x4e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52,
0x0b, 0x61, 0x72, 0x74, 0x69, 0x73, 0x74, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x4c, 0x0a, 0x11,
0x41, 0x72, 0x74, 0x77, 0x6f, 0x72, 0x6b, 0x43, 0x6f, 0x70, 0x79, 0x44, 0x65, 0x74, 0x61, 0x69,
0x6c, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1c, 0x2e, 0x73, 0x74, 0x61, 0x74, 0x65, 0x6d,
0x65, 0x6e, 0x74, 0x2e, 0x41, 0x72, 0x74, 0x77, 0x6f, 0x72, 0x6b, 0x43, 0x6f, 0x70, 0x79, 0x44,
0x65, 0x74, 0x61, 0x69, 0x6c, 0x52, 0x13, 0x61, 0x72, 0x74, 0x77, 0x6f, 0x72, 0x6b, 0x5f, 0x63,
0x6f, 0x70, 0x79, 0x5f, 0x64, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x12, 0x59, 0x0a, 0x15, 0x41, 0x72,
0x74, 0x77, 0x6f, 0x72, 0x6b, 0x53, 0x6f, 0x6c, 0x64, 0x43, 0x6f, 0x70, 0x79, 0x44, 0x65, 0x74,
0x61, 0x69, 0x6c, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x73, 0x74, 0x61, 0x74,
0x65, 0x6d, 0x65, 0x6e, 0x74, 0x2e, 0x41, 0x72, 0x74, 0x77, 0x6f, 0x72, 0x6b, 0x53, 0x6f, 0x6c,
0x64, 0x43, 0x6f, 0x70, 0x79, 0x44, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x52, 0x18, 0x61, 0x72, 0x74,
0x77, 0x6f, 0x72, 0x6b, 0x5f, 0x73, 0x6f, 0x6c, 0x64, 0x5f, 0x63, 0x6f, 0x70, 0x79, 0x5f, 0x64,
0x65, 0x74, 0x61, 0x69, 0x6c, 0x12, 0x10, 0x0a, 0x03, 0x4d, 0x73, 0x67, 0x18, 0x04, 0x20, 0x01,
0x28, 0x09, 0x52, 0x03, 0x6d, 0x73, 0x67, 0x32, 0xb4, 0x02, 0x0a, 0x09, 0x53, 0x74, 0x61, 0x74,
0x65, 0x6d, 0x65, 0x6e, 0x74, 0x12, 0x53, 0x0a, 0x0d, 0x53, 0x74, 0x61, 0x74, 0x65, 0x6d, 0x65,
0x6e, 0x74, 0x4c, 0x69, 0x73, 0x74, 0x12, 0x1f, 0x2e, 0x73, 0x74, 0x61, 0x74, 0x65, 0x6d, 0x65,
0x6e, 0x74, 0x2e, 0x53, 0x74, 0x61, 0x74, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x4c, 0x69, 0x73, 0x74,
0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1f, 0x2e, 0x73, 0x74, 0x61, 0x74, 0x65, 0x6d,
0x65, 0x6e, 0x74, 0x2e, 0x53, 0x74, 0x61, 0x74, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x4c, 0x69, 0x73,
0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x64, 0x22, 0x00, 0x12, 0x65, 0x0a, 0x13, 0x47, 0x65,
0x74, 0x54, 0x78, 0x49, 0x6e, 0x66, 0x6f, 0x42, 0x79, 0x42, 0x61, 0x74, 0x63, 0x68, 0x55, 0x69,
0x64, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x64, 0x22, 0x00, 0x42, 0x0e, 0x5a, 0x0c, 0x2e, 0x2f,
0x3b, 0x73, 0x74, 0x61, 0x74, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74,
0x6f, 0x33,
0x64, 0x12, 0x25, 0x2e, 0x73, 0x74, 0x61, 0x74, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x2e, 0x47, 0x65,
0x74, 0x54, 0x78, 0x49, 0x6e, 0x66, 0x6f, 0x42, 0x79, 0x42, 0x61, 0x74, 0x63, 0x68, 0x55, 0x69,
0x64, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x25, 0x2e, 0x73, 0x74, 0x61, 0x74, 0x65,
0x6d, 0x65, 0x6e, 0x74, 0x2e, 0x47, 0x65, 0x74, 0x54, 0x78, 0x49, 0x6e, 0x66, 0x6f, 0x42, 0x79,
0x42, 0x61, 0x74, 0x63, 0x68, 0x55, 0x69, 0x64, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x64, 0x22,
0x00, 0x12, 0x6b, 0x0a, 0x15, 0x47, 0x65, 0x74, 0x43, 0x6f, 0x70, 0x79, 0x49, 0x6e, 0x66, 0x6f,
0x42, 0x79, 0x42, 0x61, 0x74, 0x63, 0x68, 0x55, 0x69, 0x64, 0x12, 0x27, 0x2e, 0x73, 0x74, 0x61,
0x74, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x2e, 0x47, 0x65, 0x74, 0x43, 0x6f, 0x70, 0x79, 0x49, 0x6e,
0x66, 0x6f, 0x42, 0x79, 0x42, 0x61, 0x74, 0x63, 0x68, 0x55, 0x69, 0x64, 0x52, 0x65, 0x71, 0x75,
0x65, 0x73, 0x74, 0x1a, 0x27, 0x2e, 0x73, 0x74, 0x61, 0x74, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x2e,
0x47, 0x65, 0x74, 0x43, 0x6f, 0x70, 0x79, 0x49, 0x6e, 0x66, 0x6f, 0x42, 0x79, 0x42, 0x61, 0x74,
0x63, 0x68, 0x55, 0x69, 0x64, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x64, 0x22, 0x00, 0x42, 0x0e,
0x5a, 0x0c, 0x2e, 0x2f, 0x3b, 0x73, 0x74, 0x61, 0x74, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x62, 0x06,
0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
}
var (
@ -863,33 +1120,37 @@ func file_statement_proto_rawDescGZIP() []byte {
return file_statement_proto_rawDescData
}
var file_statement_proto_msgTypes = make([]protoimpl.MessageInfo, 9)
var file_statement_proto_msgTypes = make([]protoimpl.MessageInfo, 11)
var file_statement_proto_goTypes = []interface{}{
(*Contracts)(nil), // 0: statement.Contracts
(*ArtworkTxDetail)(nil), // 1: statement.ArtworkTxDetail
(*ArtworkSoldTxDetail)(nil), // 2: statement.ArtworkSoldTxDetail
(*StatementListRequest)(nil), // 3: statement.StatementListRequest
(*StatementListRespond)(nil), // 4: statement.StatementListRespond
(*CreateTxContractRequest)(nil), // 5: statement.CreateTxContractRequest
(*CreateTxContractRespond)(nil), // 6: statement.CreateTxContractRespond
(*ArtworkCopyDetail)(nil), // 3: statement.ArtworkCopyDetail
(*ArtworkSoldCopyDetail)(nil), // 4: statement.ArtworkSoldCopyDetail
(*StatementListRequest)(nil), // 5: statement.StatementListRequest
(*StatementListRespond)(nil), // 6: statement.StatementListRespond
(*GetTxInfoByBatchUidRequest)(nil), // 7: statement.GetTxInfoByBatchUidRequest
(*GetTxInfoByBatchUidRespond)(nil), // 8: statement.GetTxInfoByBatchUidRespond
(*GetCopyInfoByBatchUidRequest)(nil), // 9: statement.GetCopyInfoByBatchUidRequest
(*GetCopyInfoByBatchUidRespond)(nil), // 10: statement.GetCopyInfoByBatchUidRespond
}
var file_statement_proto_depIdxs = []int32{
0, // 0: statement.StatementListRespond.Data:type_name -> statement.Contracts
1, // 1: statement.GetTxInfoByBatchUidRespond.ArtworkTxDetail:type_name -> statement.ArtworkTxDetail
2, // 2: statement.GetTxInfoByBatchUidRespond.ArtworkSoldTxDetail:type_name -> statement.ArtworkSoldTxDetail
3, // 3: statement.Statement.StatementList:input_type -> statement.StatementListRequest
5, // 4: statement.Statement.CreateTxContract:input_type -> statement.CreateTxContractRequest
7, // 5: statement.Statement.GetTxInfoByBatchUid:input_type -> statement.GetTxInfoByBatchUidRequest
4, // 6: statement.Statement.StatementList:output_type -> statement.StatementListRespond
6, // 7: statement.Statement.CreateTxContract:output_type -> statement.CreateTxContractRespond
8, // 8: statement.Statement.GetTxInfoByBatchUid:output_type -> statement.GetTxInfoByBatchUidRespond
6, // [6:9] is the sub-list for method output_type
3, // [3:6] is the sub-list for method input_type
3, // [3:3] is the sub-list for extension type_name
3, // [3:3] is the sub-list for extension extendee
0, // [0:3] is the sub-list for field type_name
3, // 3: statement.GetCopyInfoByBatchUidRespond.ArtworkCopyDetail:type_name -> statement.ArtworkCopyDetail
4, // 4: statement.GetCopyInfoByBatchUidRespond.ArtworkSoldCopyDetail:type_name -> statement.ArtworkSoldCopyDetail
5, // 5: statement.Statement.StatementList:input_type -> statement.StatementListRequest
7, // 6: statement.Statement.GetTxInfoByBatchUid:input_type -> statement.GetTxInfoByBatchUidRequest
9, // 7: statement.Statement.GetCopyInfoByBatchUid:input_type -> statement.GetCopyInfoByBatchUidRequest
6, // 8: statement.Statement.StatementList:output_type -> statement.StatementListRespond
8, // 9: statement.Statement.GetTxInfoByBatchUid:output_type -> statement.GetTxInfoByBatchUidRespond
10, // 10: statement.Statement.GetCopyInfoByBatchUid:output_type -> statement.GetCopyInfoByBatchUidRespond
8, // [8:11] is the sub-list for method output_type
5, // [5:8] is the sub-list for method input_type
5, // [5:5] is the sub-list for extension type_name
5, // [5:5] is the sub-list for extension extendee
0, // [0:5] is the sub-list for field type_name
}
func init() { file_statement_proto_init() }
@ -935,7 +1196,7 @@ func file_statement_proto_init() {
}
}
file_statement_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*StatementListRequest); i {
switch v := v.(*ArtworkCopyDetail); i {
case 0:
return &v.state
case 1:
@ -947,7 +1208,7 @@ func file_statement_proto_init() {
}
}
file_statement_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*StatementListRespond); i {
switch v := v.(*ArtworkSoldCopyDetail); i {
case 0:
return &v.state
case 1:
@ -959,7 +1220,7 @@ func file_statement_proto_init() {
}
}
file_statement_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*CreateTxContractRequest); i {
switch v := v.(*StatementListRequest); i {
case 0:
return &v.state
case 1:
@ -971,7 +1232,7 @@ func file_statement_proto_init() {
}
}
file_statement_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*CreateTxContractRespond); i {
switch v := v.(*StatementListRespond); i {
case 0:
return &v.state
case 1:
@ -1006,6 +1267,30 @@ func file_statement_proto_init() {
return nil
}
}
file_statement_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*GetCopyInfoByBatchUidRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_statement_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*GetCopyInfoByBatchUidRespond); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
}
type x struct{}
out := protoimpl.TypeBuilder{
@ -1013,7 +1298,7 @@ func file_statement_proto_init() {
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
RawDescriptor: file_statement_proto_rawDesc,
NumEnums: 0,
NumMessages: 9,
NumMessages: 11,
NumExtensions: 0,
NumServices: 1,
},

42
pb/artistinfoStatement/statement.proto
View File

@ -4,8 +4,8 @@ option go_package = "./;statement";
service Statement {
rpc StatementList (StatementListRequest) returns (StatementListRespond) {}
rpc CreateTxContract (CreateTxContractRequest) returns (CreateTxContractRespond) {}
rpc GetTxInfoByBatchUid (GetTxInfoByBatchUidRequest) returns (GetTxInfoByBatchUidRespond) {}
rpc GetCopyInfoByBatchUid (GetCopyInfoByBatchUidRequest) returns (GetCopyInfoByBatchUidRespond) {}
}
message Contracts{
@ -47,6 +47,27 @@ message Contracts{
float GuaranteePrice = 9 [json_name = "guarantee_price"];
}
message ArtworkCopyDetail{
string BatchUid = 1 [json_name = "batch_uid"];
string TfNum = 2 [json_name = "TfNum"];
string ArtworkName = 3 [json_name = "artwork_name"];
string Ruler = 4 [json_name = "ruler"];
float MinPrice = 5 [json_name = "min_price"];
float GuaranteePrice = 6 [json_name = "guarantee_price"];
}
message ArtworkSoldCopyDetail{
string BatchUid = 1 [json_name = "batch_uid"];
string TfNum = 2 [json_name = "TfNum"];
string ArtworkName = 3 [json_name = "artwork_name"];
string Ruler = 4 [json_name = "ruler"];
string SaleNo = 5 [json_name = "sale_no"];
string CompleteDate = 6 [json_name = "complete_date"];
float MinPrice = 7 [json_name = "min_price"];
float SalePrice = 8 [json_name = "sale_price"];
float GuaranteePrice = 9 [json_name = "guarantee_price"];
}
message StatementListRequest {
string ArtistUid = 1 [json_name = "artist_uid"];
int32 PageSize = 2 [json_name="pageSize"];
@ -59,14 +80,6 @@ message StatementListRespond {
string Msg = 2 [json_name = "msg"];
}
message CreateTxContractRequest {
string BatchUid = 1 [json_name = "batch_uid"];
}
message CreateTxContractRespond {
string Msg = 1 [json_name = "msg"];
}
message GetTxInfoByBatchUidRequest {
string BatchUid = 1 [json_name = "batch_uid"];
}
@ -77,3 +90,14 @@ message GetTxInfoByBatchUidRespond {
repeated ArtworkSoldTxDetail ArtworkSoldTxDetail = 3 [json_name = "artwork_sold_tx_detail"];
string Msg = 4 [json_name = "msg"];
}
message GetCopyInfoByBatchUidRequest {
string BatchUid = 1 [json_name = "batch_uid"];
}
message GetCopyInfoByBatchUidRespond {
string ArtistName = 1 [json_name = "artist_name"];
repeated ArtworkCopyDetail ArtworkCopyDetail = 2 [json_name = "artwork_copy_detail"];
repeated ArtworkSoldCopyDetail ArtworkSoldCopyDetail = 3 [json_name = "artwork_sold_copy_detail"];
string Msg = 4 [json_name = "msg"];
}

32
pb/artistinfoStatement/statement.validator.pb.go
View File

@ -24,6 +24,12 @@ func (this *ArtworkTxDetail) Validate() error {
func (this *ArtworkSoldTxDetail) Validate() error {
return nil
}
func (this *ArtworkCopyDetail) Validate() error {
return nil
}
func (this *ArtworkSoldCopyDetail) Validate() error {
return nil
}
func (this *StatementListRequest) Validate() error {
return nil
}
@ -37,12 +43,6 @@ func (this *StatementListRespond) Validate() error {
}
return nil
}
func (this *CreateTxContractRequest) Validate() error {
return nil
}
func (this *CreateTxContractRespond) Validate() error {
return nil
}
func (this *GetTxInfoByBatchUidRequest) Validate() error {
return nil
}
@ -63,3 +63,23 @@ func (this *GetTxInfoByBatchUidRespond) Validate() error {
}
return nil
}
func (this *GetCopyInfoByBatchUidRequest) Validate() error {
return nil
}
func (this *GetCopyInfoByBatchUidRespond) Validate() error {
for _, item := range this.ArtworkCopyDetail {
if item != nil {
if err := github_com_mwitkow_go_proto_validators.CallValidatorIfExists(item); err != nil {
return github_com_mwitkow_go_proto_validators.FieldError("ArtworkCopyDetail", err)
}
}
}
for _, item := range this.ArtworkSoldCopyDetail {
if item != nil {
if err := github_com_mwitkow_go_proto_validators.CallValidatorIfExists(item); err != nil {
return github_com_mwitkow_go_proto_validators.FieldError("ArtworkSoldCopyDetail", err)
}
}
}
return nil
}

90
pb/artistinfoStatement/statement_triple.pb.go
View File

@ -29,8 +29,8 @@ const _ = grpc_go.SupportPackageIsVersion7
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
type StatementClient interface {
StatementList(ctx context.Context, in *StatementListRequest, opts ...grpc_go.CallOption) (*StatementListRespond, common.ErrorWithAttachment)
CreateTxContract(ctx context.Context, in *CreateTxContractRequest, opts ...grpc_go.CallOption) (*CreateTxContractRespond, common.ErrorWithAttachment)
GetTxInfoByBatchUid(ctx context.Context, in *GetTxInfoByBatchUidRequest, opts ...grpc_go.CallOption) (*GetTxInfoByBatchUidRespond, common.ErrorWithAttachment)
GetCopyInfoByBatchUid(ctx context.Context, in *GetCopyInfoByBatchUidRequest, opts ...grpc_go.CallOption) (*GetCopyInfoByBatchUidRespond, common.ErrorWithAttachment)
}
type statementClient struct {
@ -39,8 +39,8 @@ type statementClient struct {
type StatementClientImpl struct {
StatementList func(ctx context.Context, in *StatementListRequest) (*StatementListRespond, error)
CreateTxContract func(ctx context.Context, in *CreateTxContractRequest) (*CreateTxContractRespond, error)
GetTxInfoByBatchUid func(ctx context.Context, in *GetTxInfoByBatchUidRequest) (*GetTxInfoByBatchUidRespond, error)
GetCopyInfoByBatchUid func(ctx context.Context, in *GetCopyInfoByBatchUidRequest) (*GetCopyInfoByBatchUidRespond, error)
}
func (c *StatementClientImpl) GetDubboStub(cc *triple.TripleConn) StatementClient {
@ -61,25 +61,25 @@ func (c *statementClient) StatementList(ctx context.Context, in *StatementListRe
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/StatementList", in, out)
}
func (c *statementClient) CreateTxContract(ctx context.Context, in *CreateTxContractRequest, opts ...grpc_go.CallOption) (*CreateTxContractRespond, common.ErrorWithAttachment) {
out := new(CreateTxContractRespond)
interfaceKey := ctx.Value(constant.InterfaceKey).(string)
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/CreateTxContract", in, out)
}
func (c *statementClient) GetTxInfoByBatchUid(ctx context.Context, in *GetTxInfoByBatchUidRequest, opts ...grpc_go.CallOption) (*GetTxInfoByBatchUidRespond, common.ErrorWithAttachment) {
out := new(GetTxInfoByBatchUidRespond)
interfaceKey := ctx.Value(constant.InterfaceKey).(string)
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/GetTxInfoByBatchUid", in, out)
}
func (c *statementClient) GetCopyInfoByBatchUid(ctx context.Context, in *GetCopyInfoByBatchUidRequest, opts ...grpc_go.CallOption) (*GetCopyInfoByBatchUidRespond, common.ErrorWithAttachment) {
out := new(GetCopyInfoByBatchUidRespond)
interfaceKey := ctx.Value(constant.InterfaceKey).(string)
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/GetCopyInfoByBatchUid", in, out)
}
// StatementServer is the server API for Statement service.
// All implementations must embed UnimplementedStatementServer
// for forward compatibility
type StatementServer interface {
StatementList(context.Context, *StatementListRequest) (*StatementListRespond, error)
CreateTxContract(context.Context, *CreateTxContractRequest) (*CreateTxContractRespond, error)
GetTxInfoByBatchUid(context.Context, *GetTxInfoByBatchUidRequest) (*GetTxInfoByBatchUidRespond, error)
GetCopyInfoByBatchUid(context.Context, *GetCopyInfoByBatchUidRequest) (*GetCopyInfoByBatchUidRespond, error)
mustEmbedUnimplementedStatementServer()
}
@ -91,12 +91,12 @@ type UnimplementedStatementServer struct {
func (UnimplementedStatementServer) StatementList(context.Context, *StatementListRequest) (*StatementListRespond, error) {
return nil, status.Errorf(codes.Unimplemented, "method StatementList not implemented")
}
func (UnimplementedStatementServer) CreateTxContract(context.Context, *CreateTxContractRequest) (*CreateTxContractRespond, error) {
return nil, status.Errorf(codes.Unimplemented, "method CreateTxContract not implemented")
}
func (UnimplementedStatementServer) GetTxInfoByBatchUid(context.Context, *GetTxInfoByBatchUidRequest) (*GetTxInfoByBatchUidRespond, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetTxInfoByBatchUid not implemented")
}
func (UnimplementedStatementServer) GetCopyInfoByBatchUid(context.Context, *GetCopyInfoByBatchUidRequest) (*GetCopyInfoByBatchUidRespond, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetCopyInfoByBatchUid not implemented")
}
func (s *UnimplementedStatementServer) XXX_SetProxyImpl(impl protocol.Invoker) {
s.proxyImpl = impl
}
@ -154,35 +154,6 @@ func _Statement_StatementList_Handler(srv interface{}, ctx context.Context, dec
return interceptor(ctx, in, info, handler)
}
func _Statement_CreateTxContract_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
in := new(CreateTxContractRequest)
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("CreateTxContract", 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 _Statement_GetTxInfoByBatchUid_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
in := new(GetTxInfoByBatchUidRequest)
if err := dec(in); err != nil {
@ -212,6 +183,35 @@ func _Statement_GetTxInfoByBatchUid_Handler(srv interface{}, ctx context.Context
return interceptor(ctx, in, info, handler)
}
func _Statement_GetCopyInfoByBatchUid_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
in := new(GetCopyInfoByBatchUidRequest)
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("GetCopyInfoByBatchUid", 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)
}
// Statement_ServiceDesc is the grpc_go.ServiceDesc for Statement service.
// It's only intended for direct use with grpc_go.RegisterService,
// and not to be introspected or modified (even as a copy)
@ -223,14 +223,14 @@ var Statement_ServiceDesc = grpc_go.ServiceDesc{
MethodName: "StatementList",
Handler: _Statement_StatementList_Handler,
},
{
MethodName: "CreateTxContract",
Handler: _Statement_CreateTxContract_Handler,
},
{
MethodName: "GetTxInfoByBatchUid",
Handler: _Statement_GetTxInfoByBatchUid_Handler,
},
{
MethodName: "GetCopyInfoByBatchUid",
Handler: _Statement_GetCopyInfoByBatchUid_Handler,
},
},
Streams: []grpc_go.StreamDesc{},
Metadata: "statement.proto",