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

开发对账单模块

Browse Source
This commit is contained in:
琚锦 2023-04-03 14:07:37 +08:00
parent b20fe7be3f
commit 4aa11fff20
9 changed files with 3543 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

99
cmd/internal/controller/mgmt_statement.go Normal file
View File

@ -0,0 +1,99 @@
package controller
import (
"context"
logic3 "github.com/fonchain/fonchain-artistinfo/cmd/internal/logic"
"github.com/fonchain/fonchain-artistinfo/pb/mgmtStatement"
"github.com/fonchain/fonchain-artistinfo/pkg/m"
)
type MgmtStatementProvider struct {
mgmtStatement.UnimplementedMgmtStatementServer
mgmtStatementLogic *logic3.MgmtStatement
}
//通过excel获得批次数据
func (a *MgmtStatementProvider) AddBatchDetail(ctx context.Context, in *mgmtStatement.AddBatchDetailreq) (resp *mgmtStatement.AddBatchDetailres, err error) {
resp = &mgmtStatement.AddBatchDetailres{}
err = nil
if resp, err = a.mgmtStatementLogic.AddBatchDetail(in); err != nil {
return
}
resp.Msg = m.CREATE_SUCCESS
return
}
//通过excel导入数据存入数据库(附件一)
func (a *MgmtStatementProvider) UploadExcelOne(ctx context.Context, in *mgmtStatement.UploadExcelOnereq) (resp *mgmtStatement.UploadExcelOneres, err error) {
resp = &mgmtStatement.UploadExcelOneres{}
err = nil
if resp, err = a.mgmtStatementLogic.UploadExcelOne(in); err != nil {
return
}
resp.Msg = m.CREATE_SUCCESS
return
}
//通过excel导入数据存入数据库(附件二)
func (a *MgmtStatementProvider) UploadExcelTwo(ctx context.Context, in *mgmtStatement.UploadExcelTworeq) (resp *mgmtStatement.UploadExcelTwores, err error) {
resp = &mgmtStatement.UploadExcelTwores{}
err = nil
if resp, err = a.mgmtStatementLogic.UploadExcelTwo(in); err != nil {
return
}
resp.Msg = m.CREATE_SUCCESS
return
}
//画家对账单列表
func (a *MgmtStatementProvider) ArtistStatementList(ctx context.Context, in *mgmtStatement.ArtistStatementListreq) (resp *mgmtStatement.ArtistStatementListres, err error) {
resp = &mgmtStatement.ArtistStatementListres{}
err = nil
if resp, err = a.mgmtStatementLogic.ArtistStatementList(in); err != nil {
return
}
resp.Msg = m.SUCCESS
return
}
//画作对账单列表
func (a *MgmtStatementProvider) ArtStatementList(ctx context.Context, in *mgmtStatement.ArtStatementListreq) (resp *mgmtStatement.ArtStatementListres, err error) {
resp = &mgmtStatement.ArtStatementListres{}
err = nil
if resp, err = a.mgmtStatementLogic.ArtStatementList(in); err != nil {
return
}
resp.Msg = m.SUCCESS
return
}
//更新对账单状态
func (a *MgmtStatementProvider) UpdateState(ctx context.Context, in *mgmtStatement.UpdateStatementreq) (resp *mgmtStatement.UpdateStatementres, err error) {
resp = &mgmtStatement.UpdateStatementres{}
if err = a.mgmtStatementLogic.UpdateState(in); err != nil {
return
}
resp.Msg = m.UPDATE_SUCCESS
return
}
//导出合同
func (a *MgmtStatementProvider) ExportContract(ctx context.Context, in *mgmtStatement.ExportContractreq) (resp *mgmtStatement.ExportContractres, err error) {
resp = &mgmtStatement.ExportContractres{}
err = nil
if resp, err = a.mgmtStatementLogic.ExportContract(in); err != nil {
return
}
return
}
//生成管理系统合同
func (a *MgmtStatementProvider) CreateTxContract(ctx context.Context, in *mgmtStatement.CreateTxContractreq) (resp *mgmtStatement.CreateTxContractres, err error) {
resp = &mgmtStatement.CreateTxContractres{}
err = nil
if resp, err = a.mgmtStatementLogic.CreateTxContract(in); err != nil {
return
}
return
}

147
cmd/internal/dao/mgmt_statement.go Normal file
View File

@ -0,0 +1,147 @@
package dao
import (
"errors"
"github.com/fonchain/fonchain-artistinfo/cmd/model"
"github.com/fonchain/fonchain-artistinfo/pb/mgmtStatement"
db "github.com/fonchain/fonchain-artistinfo/pkg/db"
"github.com/fonchain/fonchain-artistinfo/pkg/m"
"go.uber.org/zap"
)
//通过excel获得批次数据到数据库
func AddBatchDetail(batch *model.ArtworkTx) (err error) {
tx := db.DB.Begin()
if tx.Error != nil {
zap.L().Error("CreateBatch Begin err", zap.Error(tx.Error))
return errors.New(m.ERROR_SELECT)
}
defer tx.Rollback()
result := tx.Create(&batch)
if result.Error != nil || result.RowsAffected != 1 {
zap.L().Error("dao CreateBatch err", zap.Error(result.Error))
return errors.New(m.ERROR_CRE_ART)
}
tx.Commit()
return
}
//通过excel获得数据创建数据到数据库(附件一)
func UploadExcelOne(statement *model.ArtworkSoldTxDetail) (err error) {
tx := db.DB.Begin()
if tx.Error != nil {
zap.L().Error("CreateStatement Begin err", zap.Error(tx.Error))
return errors.New(m.ERROR_SELECT)
}
defer tx.Rollback()
result := tx.Create(&statement)
if result.Error != nil || result.RowsAffected != 1 {
zap.L().Error("dao CreateStatement err", zap.Error(result.Error))
return errors.New(m.ERROR_CRE_ART)
}
tx.Commit()
return
}
//通过excel获得数据创建数据到数据库(附件二)
func UploadExcelTwo(statement *model.ArtworkSoldTxDetail) (err error) {
tx := db.DB.Begin()
if tx.Error != nil {
zap.L().Error("CreateStatement Begin err", zap.Error(tx.Error))
return errors.New(m.ERROR_SELECT)
}
defer tx.Rollback()
result := tx.Create(&statement)
if result.Error != nil || result.RowsAffected != 1 {
zap.L().Error("dao CreateStatement err", zap.Error(result.Error))
return errors.New(m.ERROR_CRE_ART)
}
tx.Commit()
return
}
//画家对账单列表
func ArtistStatementList(in *mgmtStatement.ArtistStatementListreq) (statement []*model.ArtworkSoldTxDetail, count int64, err error) {
offset := (in.Page - 1) * in.PageSize
db := db.DB.Model(&statement).Select("artist_uid, artist_name, batch_time, view_url, download_url")
if err = db.Count(&count).Error; err != nil {
zap.L().Error("ArtistList err", zap.Error(err))
err = errors.New(m.ERROR_SELECT)
return
}
if count == 0 {
return
}
if err = db.Order("").Limit(int(in.PageSize)).Offset(int(offset)).Find(&statement).Error; err != nil {
zap.L().Error("ArtistList err", zap.Error(err))
err = errors.New(m.ERROR_SELECT)
return
}
return
}
//画作基于批次和画家的对账单列表
func ArtStatementList(in *mgmtStatement.ArtStatementListreq) (statement []*model.ArtworkSoldTxDetail, count int64, err error) {
offset := (in.Page - 1) * in.PageSize
db := db.DB.Model(&statement).Table("").Select("artwork_name, tf_num, ruler, sale_no, min_price")
if err = db.Count(&count).Error; err != nil {
zap.L().Error("ArtList err", zap.Error(err))
err = errors.New(m.ERROR_SELECT)
return
}
if count == 0 {
return
}
if err = db.Order("").Limit(int(in.PageSize)).Offset(int(offset)).Find(&statement).Error; err != nil {
zap.L().Error("ArtList err", zap.Error(err))
err = errors.New(m.ERROR_SELECT)
return
}
return
}
//更新对账单状态
func UpdateState(StatementUid string, columns map[string]interface{}) (err error) {
if err = db.DB.Model(&model.ArtworkSoldTxDetail{}).Where("StatementUid = ? ", StatementUid).Updates(columns).Error; err != nil {
err = errors.New(m.ERROR_UPDATE_STATEMENT)
}
return
}
//导出合同
func ExportContract(in mgmtStatement.ExportContractreq) (data []*model.Contract, count int64, err error) {
offset := (in.Page - 1) * in.PageSize
db := db.DB.Model(&data).Select("artist_uid, view_url, download_url, batch_time")
if err = db.Count(&count).Error; err != nil {
zap.L().Error("ArtList err", zap.Error(err))
err = errors.New(m.ERROR_SELECT)
return
}
if count == 0 {
return
}
if err = db.Order("").Limit(int(in.PageSize)).Offset(int(offset)).Find(&data).Error; err != nil {
zap.L().Error("ArtList err", zap.Error(err))
err = errors.New(m.ERROR_SELECT)
return
}
return
}
//生成合同
func CreateTxContract(contract []*model.Contract) (err error) {
tx := db.DB.Begin()
if tx.Error != nil {
zap.L().Error("CreateContract Begin err", zap.Error(tx.Error))
return errors.New(m.ERROR_SELECT)
}
defer tx.Rollback()
result := tx.Create(&contract)
if result.Error != nil || result.RowsAffected != 1 {
zap.L().Error("dao CreateContract err", zap.Error(result.Error))
return errors.New(m.ERROR_CRE_ART)
}
tx.Commit()
return
}

260
cmd/internal/logic/mgmt_statement.go Normal file
View File

@ -0,0 +1,260 @@
package logic
import (
"errors"
"github.com/fonchain/fonchain-artistinfo/cmd/internal/dao"
"github.com/fonchain/fonchain-artistinfo/cmd/model"
"github.com/fonchain/fonchain-artistinfo/pb/mgmtStatement"
db "github.com/fonchain/fonchain-artistinfo/pkg/db"
"github.com/fonchain/fonchain-artistinfo/pkg/m"
uuid "github.com/satori/go.uuid"
)
type IMgmtStatement interface {
AddBatchDetail(in *mgmtStatement.AddBatchDetailreq) (*mgmtStatement.AddBatchDetailres, error)
UploadExcelOne(in *mgmtStatement.UploadExcelOnereq) (*mgmtStatement.UploadExcelOneres, error)
UploadExcelTwo(in *mgmtStatement.UploadExcelTworeq) (*mgmtStatement.UploadExcelTwores, error)
ArtistStatementList(in *mgmtStatement.ArtistStatementListreq) (*mgmtStatement.ArtistStatementListres, error)
ArtStatementList(in *mgmtStatement.ArtStatementListreq) (*mgmtStatement.ArtStatementListres, error)
ExportContract(in *mgmtStatement.ExportContractreq) (*mgmtStatement.ExportContractres, error)
UpdateState(in *mgmtStatement.UpdateStatementreq) error
CreateTxContract(in *mgmtStatement.CreateTxContractreq) (resp *mgmtStatement.CreateTxContractres, err error)
}
func NewMgmtStatement() IMgmtStatement {
return &MgmtStatement{}
}
type MgmtStatement struct{}
//通过excel生成一条批次数据
func (a *MgmtStatement) AddBatchDetail(in *mgmtStatement.AddBatchDetailreq) (resp *mgmtStatement.AddBatchDetailres, err error) {
resp = &mgmtStatement.AddBatchDetailres{}
var uid uuid.UUID
if uid, err = uuid.NewV4(); err != nil {
err = errors.New(m.ERROR_UID)
return
}
if err != nil {
return nil, err
}
var data model.ArtworkTx
data.Uid = uid.String()
data.ArtistName = in.ArtistName
data.ArtistUid = in.ArtistUid
data.BatchTime = in.BatchTime
data.StType = in.StType //对账单类型：1=版权 2=物权
data.Status = 1 //对账单状态 1.未签署 2.已发送未签署 3.已签署
if err = dao.AddBatchDetail(&data); err != nil {
return
}
respData := &mgmtStatement.AddBatchRes{BatchUid: data.Uid}
resp.Data = respData
return
}
//生成一条对账单记录（附件一）
func (a *MgmtStatement) UploadExcelOne(in *mgmtStatement.UploadExcelOnereq) (resp *mgmtStatement.UploadExcelOneres, err error) {
resp = &mgmtStatement.UploadExcelOneres{}
var uid uuid.UUID
if uid, err = uuid.NewV4(); err != nil {
err = errors.New(m.ERROR_UID)
return
}
if err != nil {
return nil, err
}
var data model.ArtworkSoldTxDetail //物权版权的对账单
sqlSelect := `select uid from artwork_tx where artistid = ? and batchtime = ?`
var batchid string
if err := db.DB.Raw(sqlSelect, data.ArtistUid, data.BatchTime).Find(&batchid).Error; err != nil {
return nil, err
}
data.Uid = uid.String()
data.BatchUid = batchid
data.ArtworkName = in.ArtworkName
data.ArtistName = in.ArtistName
data.ArtistUid = in.ArtistUid
data.TfNum = in.TfNum
data.BatchTime = in.BatchTime
data.GuaranteePrice = in.GuaranteePrice
data.Ruler = in.Ruler
data.MinPrice = in.MinPrice
data.StType = in.StType //对账单类型：1=版权 2=物权
if err = dao.UploadExcelOne(&data); err != nil {
return
}
respData := &mgmtStatement.StatementAddRes{StatementUid: data.Uid}
resp.Data = respData
return
}
//生成一条对账单记录（附件二）
func (a *MgmtStatement) UploadExcelTwo(in *mgmtStatement.UploadExcelTworeq) (resp *mgmtStatement.UploadExcelTwores, err error) {
resp = &mgmtStatement.UploadExcelTwores{}
var uid uuid.UUID
if uid, err = uuid.NewV4(); err != nil {
err = errors.New(m.ERROR_UID)
return
}
if err != nil {
return nil, err
}
var data model.ArtworkSoldTxDetail //物权版权的对账单
sqlSelect := `select uid from artwork_tx_batch where artistid = ? and batchtime = ?`
var batchid string
if err := db.DB.Raw(sqlSelect, data.ArtistUid, data.BatchTime).Find(&batchid).Error; err != nil {
return nil, err
}
data.Uid = uid.String()
data.BatchUid = batchid
data.ArtworkName = in.ArtworkName
data.ArtistName = in.ArtistName
data.ArtistUid = in.ArtistUid
data.TfNum = in.TfNum
data.BatchTime = in.BatchTime
data.Ruler = in.Ruler
data.MinPrice = in.MinPrice
data.StType = in.StType //对账单类型：1=版权 2=物权
if err = dao.UploadExcelTwo(&data); err != nil {
return
}
respData := &mgmtStatement.StatementAddRes{StatementUid: data.Uid}
resp.Data = respData
return
}
//画家对账单列表
func (a *MgmtStatement) ArtistStatementList(in *mgmtStatement.ArtistStatementListreq) (resp *mgmtStatement.ArtistStatementListres, err error) {
resp = &mgmtStatement.ArtistStatementListres{}
if in.Page < model.InitPage {
in.Page = model.InitPage
}
if in.PageSize < 1 {
in.PageSize = model.PageSize
}
var list []*model.ArtworkSoldTxDetail
var count int64
if list, count, err = dao.ArtistStatementList(in); err != nil {
return
}
resp.Count = int32(count)
resp.Page = in.Page
resp.PageSize = in.PageSize
for _, v := range list {
temp := mgmtStatement.ArtistStatementListres_Info{}
temp.ArtistName = v.ArtistName
temp.ArtistUid = v.ArtistUid
temp.BatchTime = v.BatchTime
resp.Data = append(resp.Data, &temp)
}
return
}
//画作列表，根据画家和批次
func (a *MgmtStatement) ArtStatementList(in *mgmtStatement.ArtStatementListreq) (resp *mgmtStatement.ArtStatementListres, err error) {
resp = &mgmtStatement.ArtStatementListres{}
if in.Page < model.InitPage {
in.Page = model.InitPage
}
if in.PageSize < 1 {
in.PageSize = model.PageSize
}
var list []*model.ArtworkSoldTxDetail
var count int64
if list, count, err = dao.ArtStatementList(in); err != nil {
return
}
resp.Count = int32(count)
resp.Page = in.Page
resp.PageSize = in.PageSize
for _, v := range list {
temp := mgmtStatement.ArtStatementListres_Info{}
temp.ArtistName = v.ArtworkName
temp.ArtistUid = v.ArtistUid
temp.ArtworkName = v.ArtworkName
temp.Ruler = v.Ruler
temp.SaleNo = v.SaleNo
temp.TfNum = v.TfNum
temp.CompleteDate = v.CompleteDate
temp.MinPrice = v.MinPrice
}
return
}
//更新对账单状态
func (a *MgmtStatement) UpdateState(in *mgmtStatement.UpdateStatementreq) (err error) {
columns := map[string]interface{}{
"status": in.Status, //状态
}
if err = dao.UpdateState(in.StatementUid, columns); err != nil {
return
}
return
}
//导出合同
func (a *MgmtStatement) ExportContract(in *mgmtStatement.ExportContractreq) (resp *mgmtStatement.ExportContractres, err error) {
resp = &mgmtStatement.ExportContractres{}
if in.Page < model.InitPage {
in.Page = model.InitPage
}
if in.PageSize < 1 {
in.PageSize = model.PageSize
}
var list []*model.Contract
var count int64
if list, count, err = dao.ExportContract(in); err != nil {
return
}
resp.Count = int32(count)
for _, v := range list {
temp := mgmtStatement.ExportContractres_Info{}
temp.DownloadUrl = v.DownloadUrl
temp.BatchTime = v.BatchTime
temp.StType = v.StType
temp.ViewUrl = v.ViewUrl
temp.BatchUid = v.BatchUid
temp.ArtistUid = v.ArtistUid
resp.Data = append(resp.Data, &temp)
}
return
}
//生成合同
func (a *MgmtStatement) CreateTxContract(in *mgmtStatement.CreateTxContractreq) (resp *mgmtStatement.CreateTxContractres, err error) {
resp = &mgmtStatement.CreateTxContractres{}
var uid uuid.UUID
if uid, err = uuid.NewV4(); err != nil {
err = errors.New(m.ERROR_UID)
return
}
if err != nil {
return nil, err
}
var data model.Contract
data.Uid = uid.String()
data.ArtistUid = in.ArtistUid
data.BatchTime = in.BatchTime
data.BatchUid = in.BatchUid
data.ContractId = in.ContractId
data.StType = in.StType
data.Status = 1
data.DownloadUrl = in.DownloadUrl
data.ViewUrl = in.ViewUrl
data.CardId = in.CardId
if err = dao.CreateTxContract(&data); err != nil {
return
}
respData := &mgmtStatement.AddContractRes{BatchUid: data.Uid}
resp.Data = respData
return
}

1
cmd/model/contract.go
View File

@ -12,6 +12,7 @@ type Contract struct {
TransactionId string `gorm:"column:transaction_id;type:varchar(300);comment:交易id" json:"transaction_id"`
Type int32 `gorm:"column:type;type:int(1);comment:合同类型 (1);NOT NULL" json:"type"`
ViewUrl string `gorm:"column:view_url;type:varchar(500);comment:在线查看合同链接" json:"view_url"`
CardId string `gorm:"column:card_id;type:varchar(500);comment:银行卡号" json:"card_id"`
DownloadUrl string `gorm:"column:download_url;type:varchar(500);comment:合同下载链接" json:"download_url"`
State int32 `gorm:"column:state;type:int(1);comment:合同状态,1:未签署2:已签署;NOT NULL" json:"state"` //1 未签署 2 已签署
Status int32 `gorm:"column:status;default:2;comment:2=锁定 3=解锁" json:"status" ` //跟随用户的锁定和解锁状态,用于控制数据的展示

11
cmd/model/statement.go
View File

@ -2,6 +2,11 @@ package model
import "gorm.io/plugin/soft_delete"
const (
InitPage = 1
PageSize = 15
)
//对账单画作物权
type ArtworkTx struct {
ID int32 `gorm:"column:id;type:int(11);primary_key;AUTO_INCREMENT" json:"id"`
@ -9,6 +14,8 @@ type ArtworkTx struct {
ArtistUid string `gorm:"column:artist_uid;type:varchar(100);comment:画家Uid;NOT NULL" json:"artist_uid"`
ArtistName string `gorm:"column:artist_name;type:varchar(100);comment:画家名;NOT NULL" json:"artist_name"`
BatchTime string `gorm:"column:batch_time;comment:批次时间" json:"batch_time"`
StType int32 `gorm:"column:st_type;comment:对账单类型 1=版权 2=物权"`
Status int32 `gorm:"column:st_type;comment:对账单状态 1:未签署;2:已生成,未签署;3:已签署"`
CreatedAt int32 `gorm:"column:created_at;autoCreateTime"`
UpdatedAt int32 `gorm:"column:updated_at;autoCreateTime"`
DeletedAt soft_delete.DeletedAt
@ -34,14 +41,18 @@ type ArtworkSoldTxDetail struct {
ID int32 `gorm:"column:id;type:int(11);primary_key;AUTO_INCREMENT" json:"id"`
Uid string `gorm:"column:uid;type:varchar(100);comment:对账单画作物权详情表的唯一表示;NOT NULL" json:"uid"`
BatchUid string `gorm:"column:batch_uid;type:varchar(100);comment:对账单画作物权表的唯一表示,即批次Uid;NOT NULL" json:"batch_uid"`
BatchTime string `gorm:"column:batch_time;comment:批次时间"`
TfNum string `gorm:"column:tf_num;unqiueIndex:batchid_tfnum_idx;comment:"泰丰画作编号"`
ArtworkName string `gorm:"column:artwork_name;comment:画作名称"`
ArtistName string `gorm:"column:artist_name;comment:画家名称"`
ArtistUid string `gorm:"column:artist_uid;comment:画家uid"`
Ruler string `gorm:"column:ruler;comment:平尺"`
SaleNo string `gorm:"column:sale_no;comment:销售单号"`
CompleteDate string `gorm:"column:complete_date;comment:成交日期"`
MinPrice float32 `gorm:"column:min_price;comment:委托销售底价"`
SalePrice float32 `gorm:"column:sale_price;comment:画作售价"`
GuaranteePrice float32 `gorm:"column:guarantee_price;comment:已收取保证金;"`
StType int32 `gorm:"column:st_type;comment:对账单类型 1=版权 2=物权"`
CreatedAt int32 `gorm:"column:created_at;autoCreateTime"`
UpdatedAt int32 `gorm:"column:updated_at;autoCreateTime"`
DeletedAt soft_delete.DeletedAt

2362
pb/mgmtStatement/mgmtStatement.pb.go Normal file
View File

File diff suppressed because it is too large Load Diff

198
pb/mgmtStatement/mgmtStatement.proto Normal file
View File

@ -0,0 +1,198 @@
//proto版本
syntax = "proto3";
//默认的包名
package mgmtStatement;
//在golang中的包名
option go_package = "./;mgmtStatement";
//画家宝管理系统提供的服务
service MgmtStatement {
rpc AddBatchDetail(AddBatchDetailreq) returns (AddBatchDetailres){}//增加批次数据
rpc UploadExcelOne(UploadExcelOnereq) returns (UploadExcelOneres){}//通过导入excel附件一
rpc UploadExcelTwo(UploadExcelTworeq) returns (UploadExcelTwores){}//通过导入excel附件二
rpc ArtistStatementList(ArtistStatementListreq) returns (ArtistStatementListres){}//对账单画家列表
rpc ArtStatementList(ArtStatementListreq) returns (ArtStatementListres){}//对账单画作列表
rpc UpdateState(UpdateStatementreq) returns (UpdateStatementres){}//更新对账单状态
rpc CreateTxContract(CreateTxContractreq) returns (CreateTxContractres){}//生成合同
rpc ExportContract(ExportContractreq) returns (ExportContractres){}//导出合同
}
//批次数据
message AddBatchDetailreq {
int32 Id = 1 [json_name = "id"]; //批次id
string BatchUid = 2 [json_name = "batch_uid"]; //批次uid 批次唯一标识
string ArtistUid = 3 [json_name = "artist_uid"];//画家uid
string ArtistName = 4 [json_name = "artist_name"];//画家名
string BatchTime = 5 [json_name = "batch_time"];//批次名
int32 StType = 6 [json_name = "st_type"];//对账单类型：1=版权 2=物权
int32 Status = 7 [json_name = "status"];//对账单状态 1:未签署；2：已生成，未签署；3：已签署
}
message AddBatchRes {
string BatchUid = 1 [json_name = "batch_uid"];//批次uid 批次唯一标识
}
message AddBatchDetailres {
string Msg = 1 [json_name = "msg"];
AddBatchRes Data = 2 [json_name = "data"];
}
//附件一
message UploadExcelOnereq {
int32 Id = 1 [json_name = "id"]; //对账单id
string StatementUid = 2 [json_name = "statement_uid"]; //对账单uid 对账单唯一标识
string BatchUid = 3 [json_name = "batch_uid"]; //批次uid 批次唯一标识
string TfNum = 4 [json_name = "TfNum"];//画作的泰丰编号
string Ruler = 5 [json_name = "ruler"];//画作的平尺数
string ArtworkName = 6 [json_name = "artwork_name"];//画作名称
float GuaranteePrice = 7 [json_name = "guarantee_price"];//公司保证金
float MinPrice = 8 [json_name = "min_price"];//委托销售底价
string ArtistUid = 9 [json_name = "artist_uid"];//画家uid
string ArtistName = 10 [json_name = "artist_name"];//画家名
string BatchTime = 11 [json_name = "batch_time"];//批次名
int32 StType = 12 [json_name = "st_type"];//对账单类型：1=版权 2=物权
int32 Status = 13 [json_name = "status"];//对账单状态 1:未签署；2：已生成，未签署；3：已签署
}
message StatementAddRes {
string StatementUid = 1 [json_name = "statement_uid"];//对账单uid 对账单唯一标识
}
message UploadExcelOneres {
string Msg = 1 [json_name = "msg"];
StatementAddRes Data = 2 [json_name = "data"];
}
//附件二
message UploadExcelTworeq {
int32 Id = 1 [json_name = "id"]; //对账单id
string StatementUid = 2 [json_name = "statement_uid"]; //对账单uid 对账单唯一标识
string BatchUid = 3 [json_name = "batch_uid"]; //批次uid 批次唯一标识
string TfNum = 4 [json_name = "TfNum"];//画作的泰丰编号
string Ruler = 5 [json_name = "ruler"];//画作的平尺数
string ArtworkName = 6 [json_name = "artwork_name"];//画作名称
float MinPrice = 7 [json_name = "min_price"];//委托销售底价
string ArtistUid = 8 [json_name = "artist_uid"];//画家uid
string ArtistName = 9 [json_name = "artist_name"];//画家名
string BatchTime = 10 [json_name = "batch_time"];//批次名
string CompleteDate = 11 [json_name = "complete_date"];//成交日期
string SaleNo = 12 [json_name = "sale_no"];//销售单号
int32 StType = 13 [json_name = "st_type"];//对账单类型：1=版权 2=物权
int32 Status = 14 [json_name = "status"];//对账单状态 1:未签署；2：已生成，未签署；3：已签署
}
message UploadExcelTwores {
string Msg = 1 [json_name = "msg"];
StatementAddRes Data = 2 [json_name = "data"];
}
//画家列表
message ArtistStatementListreq {
int32 Page = 1 [json_name = "page"]; //页数
int32 PageSize = 2 [json_name = "page_size"]; //每页有多少数据
int32 StType = 3 [json_name = "st_type"];//对账单类型：1=版权 2=物权
string BatchUid = 4 [json_name = "batch_uid"]; //批次uid 批次唯一标识
}
message ArtistStatementListres {
message Info {
string ArtistUid = 1 [json_name = "artist_uid"];//画家uid
string ArtistName = 2 [json_name = "artist_name"];//画家名
string BatchTime = 3 [json_name = "batch_time"];//批次名
string ViewUrl = 4 [json_name = "view_url"];//预览地址
string DownloadUrl = 5 [json_name = "download_url"];//下载地址
}
repeated Info Data = 1 [json_name = "data"];
int32 Count = 2 [json_name = "count"]; //总数
int32 Page = 3 [json_name = "page"];
int32 PageSize = 4 [json_name = "page_size"];
string Msg = 5 [json_name = "message"];
}
message ArtStatementListreq {
int32 Page = 1 [json_name = "page"]; //页数
int32 PageSize = 2 [json_name = "page_size"]; //每页有多少数据
int32 StType = 3 [json_name = "st_type"];//对账单类型：1=版权 2=物权
string BatchUid = 4 [json_name = "batch_uid"]; //批次uid 批次唯一标识
}
message ArtStatementListres {
message Info {
string ArtistUid = 1 [json_name = "artist_uid"];//画家uid
string ArtistName = 2 [json_name = "artist_name"];//画家名
string ArtworkName = 3 [json_name = "artwork_name"];//画作名称
string TfNum = 4 [json_name = "TfNum"];//画作的泰丰编号
string Ruler = 5 [json_name = "ruler"];//画作的平尺数
string CompleteDate = 6 [json_name = "complete_date"];//成交日期
string SaleNo = 7 [json_name = "sale_no"];//销售单号
float MinPrice = 8 [json_name = "min_price"];//委托销售底价
}
repeated Info Data = 1 [json_name = "data"];
int32 Count = 2 [json_name = "count"]; //总数
int32 Page = 3 [json_name = "page"];
int32 PageSize = 4 [json_name = "page_size"];
string Msg = 5 [json_name = "message"];
}
message UpdateStatementreq {
string StatementUid = 1 [json_name = "statement_uid"]; //对账单uid 对账单唯一标识
int32 Status = 2 [json_name = "status"];//对账单状态
int32 StType = 3 [json_name = "st_type"];//对账单类型：1=版权 2=物权
}
message UpdateStatementres {
string Msg = 1[json_name = "message"];
}
message CreateTxContractreq {
string BatchUid = 1 [json_name = "batch_uid"]; //批次uid链接所有表的唯一标识
int32 StType = 2 [json_name = "st_type"];//对账单类型：1=版权 2=物权
string BatchTime = 3 [json_name = "batch_time"];//批次名
string DownloadUrl = 4 [json_name = "download_url"];//下载地址
string ViewUrl = 5 [json_name = "view_url"];//预览地址
string ContractId = 6 [json_name = "contract_id"];//合同id
string ArtistUid = 7 [json_name = "artist_uid"];//画家uid
int32 Status = 8 [json_name = "status"];//对账单状态
string CardId = 9 [json_name = "card_id"];//银行卡号
int64 UserId = 10 [json_name="userId"];
}
message CreateTxContractres {
string Msg = 1 [json_name = "message"];
AddContractRes Data = 2 [json_name = "data"];
}
message AddContractRes {
string BatchUid = 1 [json_name = "batch_uid"]; //批次uid链接所有表的唯一标识
}
message ExportContractreq {
int32 Page = 1 [json_name = "page"]; //页数
int32 PageSize = 2 [json_name = "page_size"]; //每页有多少数据
int32 StType = 3 [json_name = "st_type"];//对账单类型：1=版权 2=物权
}
message ExportContractres{
message Info {
string BatchUid = 1 [json_name = "batch_uid"]; //批次uid链接所有表的唯一标识
string BatchTime = 2 [json_name = "batch_time"];//批次名
string DownloadUrl = 3 [json_name = "download_url"];//下载地址
string ViewUrl = 4 [json_name = "view_url"];//预览地址
int32 StType = 5 [json_name = "st_type"];//对账单类型：1=版权 2=物权
string ArtistName = 6 [json_name = "artist_name"];//画家名
string ArtistUid = 7 [json_name = "artist_uid"];//画家uid
}
repeated Info Data = 1 [json_name = "data"];
int32 Count = 2 [json_name = "count"]; //总数
int32 Page = 3 [json_name = "page"];
int32 PageSize = 4 [json_name = "page_size"];
string Msg = 5 [json_name = "message"];
}

462
pb/mgmtStatement/mgmtStatement_triple.pb.go Normal file
View File

@ -0,0 +1,462 @@
// Code generated by protoc-gen-go-triple. DO NOT EDIT.
// versions:
// - protoc-gen-go-triple v1.0.5
// - protoc v3.21.1
// source: mgmtStatement.proto
package mgmtStatement
import (
context "context"
protocol "dubbo.apache.org/dubbo-go/v3/protocol"
dubbo3 "dubbo.apache.org/dubbo-go/v3/protocol/dubbo3"
invocation "dubbo.apache.org/dubbo-go/v3/protocol/invocation"
grpc_go "github.com/dubbogo/grpc-go"
codes "github.com/dubbogo/grpc-go/codes"
metadata "github.com/dubbogo/grpc-go/metadata"
status "github.com/dubbogo/grpc-go/status"
common "github.com/dubbogo/triple/pkg/common"
constant "github.com/dubbogo/triple/pkg/common/constant"
triple "github.com/dubbogo/triple/pkg/triple"
)
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
const _ = grpc_go.SupportPackageIsVersion7
// MgmtStatementClient is the client API for MgmtStatement service.
//
// 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 MgmtStatementClient interface {
AddBatchDetail(ctx context.Context, in *AddBatchDetailreq, opts ...grpc_go.CallOption) (*AddBatchDetailres, common.ErrorWithAttachment)
UploadExcelOne(ctx context.Context, in *UploadExcelOnereq, opts ...grpc_go.CallOption) (*UploadExcelOneres, common.ErrorWithAttachment)
UploadExcelTwo(ctx context.Context, in *UploadExcelTworeq, opts ...grpc_go.CallOption) (*UploadExcelTwores, common.ErrorWithAttachment)
ArtistStatementList(ctx context.Context, in *ArtistStatementListreq, opts ...grpc_go.CallOption) (*ArtistStatementListres, common.ErrorWithAttachment)
ArtStatementList(ctx context.Context, in *ArtStatementListreq, opts ...grpc_go.CallOption) (*ArtStatementListres, common.ErrorWithAttachment)
UpdateState(ctx context.Context, in *UpdateStatementreq, opts ...grpc_go.CallOption) (*UpdateStatementres, common.ErrorWithAttachment)
CreateTxContract(ctx context.Context, in *CreateTxContractreq, opts ...grpc_go.CallOption) (*CreateTxContractres, common.ErrorWithAttachment)
ExportContract(ctx context.Context, in *ExportContractreq, opts ...grpc_go.CallOption) (*ExportContractres, common.ErrorWithAttachment)
}
type mgmtStatementClient struct {
cc *triple.TripleConn
}
type MgmtStatementClientImpl struct {
AddBatchDetail func(ctx context.Context, in *AddBatchDetailreq) (*AddBatchDetailres, error)
UploadExcelOne func(ctx context.Context, in *UploadExcelOnereq) (*UploadExcelOneres, error)
UploadExcelTwo func(ctx context.Context, in *UploadExcelTworeq) (*UploadExcelTwores, error)
ArtistStatementList func(ctx context.Context, in *ArtistStatementListreq) (*ArtistStatementListres, error)
ArtStatementList func(ctx context.Context, in *ArtStatementListreq) (*ArtStatementListres, error)
UpdateState func(ctx context.Context, in *UpdateStatementreq) (*UpdateStatementres, error)
CreateTxContract func(ctx context.Context, in *CreateTxContractreq) (*CreateTxContractres, error)
ExportContract func(ctx context.Context, in *ExportContractreq) (*ExportContractres, error)
}
func (c *MgmtStatementClientImpl) GetDubboStub(cc *triple.TripleConn) MgmtStatementClient {
return NewMgmtStatementClient(cc)
}
func (c *MgmtStatementClientImpl) XXX_InterfaceName() string {
return "mgmtStatement.MgmtStatement"
}
func NewMgmtStatementClient(cc *triple.TripleConn) MgmtStatementClient {
return &mgmtStatementClient{cc}
}
func (c *mgmtStatementClient) AddBatchDetail(ctx context.Context, in *AddBatchDetailreq, opts ...grpc_go.CallOption) (*AddBatchDetailres, common.ErrorWithAttachment) {
out := new(AddBatchDetailres)
interfaceKey := ctx.Value(constant.InterfaceKey).(string)
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/AddBatchDetail", in, out)
}
func (c *mgmtStatementClient) UploadExcelOne(ctx context.Context, in *UploadExcelOnereq, opts ...grpc_go.CallOption) (*UploadExcelOneres, common.ErrorWithAttachment) {
out := new(UploadExcelOneres)
interfaceKey := ctx.Value(constant.InterfaceKey).(string)
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/UploadExcelOne", in, out)
}
func (c *mgmtStatementClient) UploadExcelTwo(ctx context.Context, in *UploadExcelTworeq, opts ...grpc_go.CallOption) (*UploadExcelTwores, common.ErrorWithAttachment) {
out := new(UploadExcelTwores)
interfaceKey := ctx.Value(constant.InterfaceKey).(string)
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/UploadExcelTwo", in, out)
}
func (c *mgmtStatementClient) ArtistStatementList(ctx context.Context, in *ArtistStatementListreq, opts ...grpc_go.CallOption) (*ArtistStatementListres, common.ErrorWithAttachment) {
out := new(ArtistStatementListres)
interfaceKey := ctx.Value(constant.InterfaceKey).(string)
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/ArtistStatementList", in, out)
}
func (c *mgmtStatementClient) ArtStatementList(ctx context.Context, in *ArtStatementListreq, opts ...grpc_go.CallOption) (*ArtStatementListres, common.ErrorWithAttachment) {
out := new(ArtStatementListres)
interfaceKey := ctx.Value(constant.InterfaceKey).(string)
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/ArtStatementList", in, out)
}
func (c *mgmtStatementClient) UpdateState(ctx context.Context, in *UpdateStatementreq, opts ...grpc_go.CallOption) (*UpdateStatementres, common.ErrorWithAttachment) {
out := new(UpdateStatementres)
interfaceKey := ctx.Value(constant.InterfaceKey).(string)
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/UpdateState", in, out)
}
func (c *mgmtStatementClient) CreateTxContract(ctx context.Context, in *CreateTxContractreq, opts ...grpc_go.CallOption) (*CreateTxContractres, common.ErrorWithAttachment) {
out := new(CreateTxContractres)
interfaceKey := ctx.Value(constant.InterfaceKey).(string)
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/CreateTxContract", in, out)
}
func (c *mgmtStatementClient) ExportContract(ctx context.Context, in *ExportContractreq, opts ...grpc_go.CallOption) (*ExportContractres, common.ErrorWithAttachment) {
out := new(ExportContractres)
interfaceKey := ctx.Value(constant.InterfaceKey).(string)
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/ExportContract", in, out)
}
// MgmtStatementServer is the server API for MgmtStatement service.
// All implementations must embed UnimplementedMgmtStatementServer
// for forward compatibility
type MgmtStatementServer interface {
AddBatchDetail(context.Context, *AddBatchDetailreq) (*AddBatchDetailres, error)
UploadExcelOne(context.Context, *UploadExcelOnereq) (*UploadExcelOneres, error)
UploadExcelTwo(context.Context, *UploadExcelTworeq) (*UploadExcelTwores, error)
ArtistStatementList(context.Context, *ArtistStatementListreq) (*ArtistStatementListres, error)
ArtStatementList(context.Context, *ArtStatementListreq) (*ArtStatementListres, error)
UpdateState(context.Context, *UpdateStatementreq) (*UpdateStatementres, error)
CreateTxContract(context.Context, *CreateTxContractreq) (*CreateTxContractres, error)
ExportContract(context.Context, *ExportContractreq) (*ExportContractres, error)
mustEmbedUnimplementedMgmtStatementServer()
}
// UnimplementedMgmtStatementServer must be embedded to have forward compatible implementations.
type UnimplementedMgmtStatementServer struct {
proxyImpl protocol.Invoker
}
func (UnimplementedMgmtStatementServer) AddBatchDetail(context.Context, *AddBatchDetailreq) (*AddBatchDetailres, error) {
return nil, status.Errorf(codes.Unimplemented, "method AddBatchDetail not implemented")
}
func (UnimplementedMgmtStatementServer) UploadExcelOne(context.Context, *UploadExcelOnereq) (*UploadExcelOneres, error) {
return nil, status.Errorf(codes.Unimplemented, "method UploadExcelOne not implemented")
}
func (UnimplementedMgmtStatementServer) UploadExcelTwo(context.Context, *UploadExcelTworeq) (*UploadExcelTwores, error) {
return nil, status.Errorf(codes.Unimplemented, "method UploadExcelTwo not implemented")
}
func (UnimplementedMgmtStatementServer) ArtistStatementList(context.Context, *ArtistStatementListreq) (*ArtistStatementListres, error) {
return nil, status.Errorf(codes.Unimplemented, "method ArtistStatementList not implemented")
}
func (UnimplementedMgmtStatementServer) ArtStatementList(context.Context, *ArtStatementListreq) (*ArtStatementListres, error) {
return nil, status.Errorf(codes.Unimplemented, "method ArtStatementList not implemented")
}
func (UnimplementedMgmtStatementServer) UpdateState(context.Context, *UpdateStatementreq) (*UpdateStatementres, error) {
return nil, status.Errorf(codes.Unimplemented, "method UpdateState not implemented")
}
func (UnimplementedMgmtStatementServer) CreateTxContract(context.Context, *CreateTxContractreq) (*CreateTxContractres, error) {
return nil, status.Errorf(codes.Unimplemented, "method CreateTxContract not implemented")
}
func (UnimplementedMgmtStatementServer) ExportContract(context.Context, *ExportContractreq) (*ExportContractres, error) {
return nil, status.Errorf(codes.Unimplemented, "method ExportContract not implemented")
}
func (s *UnimplementedMgmtStatementServer) XXX_SetProxyImpl(impl protocol.Invoker) {
s.proxyImpl = impl
}
func (s *UnimplementedMgmtStatementServer) XXX_GetProxyImpl() protocol.Invoker {
return s.proxyImpl
}
func (s *UnimplementedMgmtStatementServer) XXX_ServiceDesc() *grpc_go.ServiceDesc {
return &MgmtStatement_ServiceDesc
}
func (s *UnimplementedMgmtStatementServer) XXX_InterfaceName() string {
return "mgmtStatement.MgmtStatement"
}
func (UnimplementedMgmtStatementServer) mustEmbedUnimplementedMgmtStatementServer() {}
// UnsafeMgmtStatementServer may be embedded to opt out of forward compatibility for this service.
// Use of this interface is not recommended, as added methods to MgmtStatementServer will
// result in compilation errors.
type UnsafeMgmtStatementServer interface {
mustEmbedUnimplementedMgmtStatementServer()
}
func RegisterMgmtStatementServer(s grpc_go.ServiceRegistrar, srv MgmtStatementServer) {
s.RegisterService(&MgmtStatement_ServiceDesc, srv)
}
func _MgmtStatement_AddBatchDetail_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
in := new(AddBatchDetailreq)
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("AddBatchDetail", 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 _MgmtStatement_UploadExcelOne_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
in := new(UploadExcelOnereq)
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("UploadExcelOne", 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 _MgmtStatement_UploadExcelTwo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
in := new(UploadExcelTworeq)
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("UploadExcelTwo", 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 _MgmtStatement_ArtistStatementList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
in := new(ArtistStatementListreq)
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("ArtistStatementList", 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 _MgmtStatement_ArtStatementList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
in := new(ArtStatementListreq)
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("ArtStatementList", 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 _MgmtStatement_UpdateState_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
in := new(UpdateStatementreq)
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("UpdateState", 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 _MgmtStatement_CreateTxContract_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
in := new(CreateTxContractreq)
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 _MgmtStatement_ExportContract_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
in := new(ExportContractreq)
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("ExportContract", 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)
}
// MgmtStatement_ServiceDesc is the grpc_go.ServiceDesc for MgmtStatement service.
// It's only intended for direct use with grpc_go.RegisterService,
// and not to be introspected or modified (even as a copy)
var MgmtStatement_ServiceDesc = grpc_go.ServiceDesc{
ServiceName: "mgmtStatement.MgmtStatement",
HandlerType: (*MgmtStatementServer)(nil),
Methods: []grpc_go.MethodDesc{
{
MethodName: "AddBatchDetail",
Handler: _MgmtStatement_AddBatchDetail_Handler,
},
{
MethodName: "UploadExcelOne",
Handler: _MgmtStatement_UploadExcelOne_Handler,
},
{
MethodName: "UploadExcelTwo",
Handler: _MgmtStatement_UploadExcelTwo_Handler,
},
{
MethodName: "ArtistStatementList",
Handler: _MgmtStatement_ArtistStatementList_Handler,
},
{
MethodName: "ArtStatementList",
Handler: _MgmtStatement_ArtStatementList_Handler,
},
{
MethodName: "UpdateState",
Handler: _MgmtStatement_UpdateState_Handler,
},
{
MethodName: "CreateTxContract",
Handler: _MgmtStatement_CreateTxContract_Handler,
},
{
MethodName: "ExportContract",
Handler: _MgmtStatement_ExportContract_Handler,
},
},
Streams: []grpc_go.StreamDesc{},
Metadata: "mgmtStatement.proto",
}

3
pkg/m/msg.go
View File

@ -75,4 +75,7 @@ const (
ERROR_BATCH_INSERT = "批量插入失败"
CREATE_BATCH_SUCCESS = "批量插入成功"
ERROR_UPDATE_STATEMENT = "更新对账单状态失败"
ERROR_CRE_ART = "创建失败"
)