增加对账单配置文件

cmd/app.go

@@ -22,6 +22,7 @@ func main() {
 	config.SetProviderService(&controller.ArtistInfoArtshowProvider{})
 	config.SetProviderService(&controller.ArtistInfoContractProvider{})
 	config.SetConsumerService(&controller.ArtistInfoStatementProvider{})
+	config.SetProviderService(&controller.MgmtStatementProvider{})
 	db.Init(m.SERVER_CONFIG)
 	cache.InitRedis(m.SERVER_CONFIG)
 	if err := config.Load(); err != nil {

cmd/internal/controller/mgmt_statement.go

@@ -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
+}

cmd/internal/dao/mgmt_statement.go

@@ -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").Where("st_type = ?", in.StType)
+	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").Where("st_type = ?", in.StType)
+	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").Where("st_type = ?", in.StType)
+	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
+}

cmd/internal/logic/mgmt_statement.go

@@ -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
+}

cmd/model/contract.go

@@ -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" `               //跟随用户的锁定和解锁状态,用于控制数据的展示
@@ -19,7 +20,7 @@ type Contract struct {
 	SignTime              string                  `gorm:"column:sign_time;comment:签署时间" json:"sign_time"`
 	BatchTime             string                  `gorm:"column:batch_time;comment:批次时间" json:"batch_time"`
 	BatchUid              string                  `gorm:"column:batch_uid;comment:批次ID" json:"batch_uid"`
-	StType                int32                   `gorm:"column:st_type;unqiueIndex:sttype_uid_batchtime_idx;comment:对账单类型 1=版权 2=物权;"`
+	StType                int32                   `gorm:"column:st_type;unqiueIndex:stype_uid_batchtime_idx;comment:对账单类型 1=版权 2=物权;"`
 	ArtworkTx             *ArtworkTx              `gorm:"foreignKey:BatchUid;references:Uid"`      //当前批次的物权委托单
 	ArtworkCopy           *ArtworkCopy            `gorm:"foreignKey:BatchUid;references:Uid"`      //当前批次的版权委托单
 	ArtworkTxDetail       []ArtworkTxDetail       `gorm:"foreignKey:BatchUid;references:BatchUid"` //当前批次的物权委托单详情

cmd/model/statement.go

@@ -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

conf/dubbogo.yaml

@@ -34,6 +34,9 @@ dubbo:
       ArtistInfoStatementProvider:
         interface: com.fontree.microservices.common.ArtistInfoStatement
         retries: 100
+      MgmtStatementProvider:
+        interface: com.fontree.microservices.common.MgmtStatement
+        retries: 100
       #ContractProvider:
       #  interface: com.fontree.microservices.common.Contract
         # retries: 0

pb/contract/contract.proto

@@ -33,7 +33,7 @@ message Contracts{
    string SignTime = 13 [json_name = "sign_time"];
    string BatchTime = 14 [json_name = "batch_time"];
    string BatchUid = 15 [json_name = "batch_uid"];
-   int32 StType = 16 [json_name = "st_yype"];
+   int32 StType = 16 [json_name = "st_type"];
 }
 
 message CreateContractRequest {

pb/mgmtStatement/mgmtStatement.proto

@@ -0,0 +1,199 @@
+//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"];//下载地址
+        string BatchUid = 6 [json_name = "batch_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"];
+
+}
+
+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"];
+}

pb/mgmtStatement/mgmtStatement_triple.pb.go

@@ -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",
+}

pkg/m/msg.go

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