Merge branch 'dev' of http://gitlab.fontree.cn/bugmaker/fonchain-artistinfo into dev
This commit is contained in:
commit
3416cca9c6
@ -1,99 +0,0 @@
|
||||
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
|
||||
// }
|
||||
@ -1,147 +0,0 @@
|
||||
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
|
||||
}
|
||||
@ -2,6 +2,7 @@ package dao
|
||||
|
||||
import (
|
||||
"errors"
|
||||
"fmt"
|
||||
|
||||
"github.com/fonchain/fonchain-artistinfo/cmd/model"
|
||||
statement "github.com/fonchain/fonchain-artistinfo/pb/artistinfoStatement"
|
||||
@ -11,9 +12,9 @@ import (
|
||||
"gorm.io/gorm"
|
||||
)
|
||||
|
||||
func IsExistArtworkTx(batchTime, artistUid string) (exist bool, artworkTx *model.ArtworkTx, err error) {
|
||||
func IsExistArtworkTx(tx *gorm.DB, batchTime, artistUid string) (exist bool, artworkTx *model.ArtworkTx, err error) {
|
||||
|
||||
if err = db.DB.Where("batch_time = ? AND artist_uid = ?", batchTime, artistUid).First(&artworkTx).Error; err != nil {
|
||||
if err = tx.Where("batch_time = ? AND artist_uid = ?", batchTime, artistUid).First(&artworkTx).Error; err != nil {
|
||||
if err == gorm.ErrRecordNotFound {
|
||||
return true, nil, nil
|
||||
} else {
|
||||
@ -26,9 +27,9 @@ func IsExistArtworkTx(batchTime, artistUid string) (exist bool, artworkTx *model
|
||||
return
|
||||
}
|
||||
|
||||
func IsExistArtworkCopy(batchTime, artistUid string) (exist bool, artworkCopy *model.ArtworkCopy, err error) {
|
||||
func IsExistArtworkCopy(tx *gorm.DB, batchTime, artistUid string) (exist bool, artworkCopy *model.ArtworkCopy, err error) {
|
||||
|
||||
if err = db.DB.Where("batch_time = ? AND artist_uid = ?", batchTime, artistUid).First(&artworkCopy).Error; err != nil {
|
||||
if err = tx.Where("batch_time = ? AND artist_uid = ?", batchTime, artistUid).First(&artworkCopy).Error; err != nil {
|
||||
if err == gorm.ErrRecordNotFound {
|
||||
return true, nil, nil
|
||||
} else {
|
||||
@ -41,11 +42,11 @@ func IsExistArtworkCopy(batchTime, artistUid string) (exist bool, artworkCopy *m
|
||||
return
|
||||
}
|
||||
|
||||
func CreateArtworkTx(tx *gorm.DB, uid, batchTime, artistUid, asrtistName string) (err error) {
|
||||
func CreateArtworkTx(tx *gorm.DB, uid, batchTime, artistUid, artistName string) (err error) {
|
||||
artworkTx := &model.ArtworkTx{
|
||||
Uid: uid,
|
||||
ArtistUid: artistUid,
|
||||
ArtistName: asrtistName,
|
||||
ArtistName: artistName,
|
||||
BatchTime: batchTime,
|
||||
}
|
||||
|
||||
@ -58,11 +59,11 @@ func CreateArtworkTx(tx *gorm.DB, uid, batchTime, artistUid, asrtistName string)
|
||||
return
|
||||
}
|
||||
|
||||
func CreateArtworkCopy(tx *gorm.DB, uid, batchTime, artistUid, asrtistName string) (err error) {
|
||||
func CreateArtworkCopy(tx *gorm.DB, uid, batchTime, artistUid, artistName string) (err error) {
|
||||
artworkCopy := &model.ArtworkCopy{
|
||||
Uid: uid,
|
||||
ArtistUid: artistUid,
|
||||
ArtistName: asrtistName,
|
||||
ArtistName: artistName,
|
||||
BatchTime: batchTime,
|
||||
}
|
||||
|
||||
@ -80,7 +81,7 @@ func CreateArtworkTxDetail(tx *gorm.DB, uid1, uid2 string, excelOneInfo *stateme
|
||||
Uid: uid2,
|
||||
BatchUid: uid1,
|
||||
TfNum: excelOneInfo.TfNum,
|
||||
ArtworkName: excelOneInfo.ArtistName,
|
||||
ArtworkName: excelOneInfo.ArtworkName,
|
||||
Ruler: excelOneInfo.Ruler,
|
||||
MinPrice: excelOneInfo.MinPrice,
|
||||
GuaranteePrice: excelOneInfo.GuaranteePrice,
|
||||
@ -100,7 +101,7 @@ func CreateArtworkCopyDetail(tx *gorm.DB, uid1, uid2 string, excelOneInfo *state
|
||||
Uid: uid2,
|
||||
BatchUid: uid1,
|
||||
TfNum: excelOneInfo.TfNum,
|
||||
ArtworkName: excelOneInfo.ArtistName,
|
||||
ArtworkName: excelOneInfo.ArtworkName,
|
||||
Ruler: excelOneInfo.Ruler,
|
||||
MinPrice: excelOneInfo.MinPrice,
|
||||
GuaranteePrice: excelOneInfo.GuaranteePrice,
|
||||
@ -115,12 +116,50 @@ func CreateArtworkCopyDetail(tx *gorm.DB, uid1, uid2 string, excelOneInfo *state
|
||||
return
|
||||
}
|
||||
|
||||
func IsExistArtworkTxDetail(tx *gorm.DB, uid, tfNum string) (count int64, err error) {
|
||||
if err = tx.Model(&model.ArtworkTxDetail{}).Where("batch_uid = ? AND tf_num = ?", uid, tfNum).Count(&count).Error; err != nil {
|
||||
zap.L().Error("get artworkTxDetail num err", zap.Error(err))
|
||||
err = errors.New(m.ERROR_SELECT)
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func IsExistArtworkCopyDetail(tx *gorm.DB, uid, tfNum string) (count int64, err error) {
|
||||
if err = tx.Model(&model.ArtworkCopyDetail{}).Where("batch_uid = ? AND tf_num = ?", uid, tfNum).Count(&count).Error; err != nil {
|
||||
zap.L().Error("get artworkCopyDetail num err", zap.Error(err))
|
||||
err = errors.New(m.ERROR_SELECT)
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func IsExistArtworkSoldTxDetail(tx *gorm.DB, uid, tfNum string) (count int64, err error) {
|
||||
if err = tx.Model(&model.ArtworkSoldTxDetail{}).Where("batch_uid = ? AND tf_num = ?", uid, tfNum).Count(&count).Error; err != nil {
|
||||
zap.L().Error("get artworkSoldTxDetail num err", zap.Error(err))
|
||||
err = errors.New(m.ERROR_SELECT)
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func IsExistArtworkSoldCopyDetail(tx *gorm.DB, uid, tfNum string) (count int64, err error) {
|
||||
if err = tx.Model(&model.ArtworkSoldCopyDetail{}).Where("batch_uid = ? AND tf_num = ?", uid, tfNum).Count(&count).Error; err != nil {
|
||||
zap.L().Error("get artworkSoldCopyDetail num err", zap.Error(err))
|
||||
err = errors.New(m.ERROR_SELECT)
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func CreateArtworkSoldTxDetail(tx *gorm.DB, uid1, uid2 string, excelTwoInfo *statement.ExcelTwoInfo) (err error) {
|
||||
fmt.Println("excelTwoInfo:", excelTwoInfo)
|
||||
fmt.Println("excelTwoInfo.CompleteDate:", excelTwoInfo.CompleteDate)
|
||||
artworkSoldTxDetail := &model.ArtworkSoldTxDetail{
|
||||
Uid: uid2,
|
||||
BatchUid: uid1, //批次uid
|
||||
TfNum: excelTwoInfo.TfNum,
|
||||
ArtworkName: excelTwoInfo.ArtistName,
|
||||
ArtworkName: excelTwoInfo.ArtworkName,
|
||||
Ruler: excelTwoInfo.Ruler,
|
||||
SaleNo: excelTwoInfo.SaleNo,
|
||||
CompleteDate: excelTwoInfo.CompleteDate,
|
||||
@ -141,7 +180,7 @@ func CreateArtworkSoldCopyDetail(tx *gorm.DB, uid1, uid2 string, excelTwoInfo *s
|
||||
Uid: uid2,
|
||||
BatchUid: uid1, //批次uid
|
||||
TfNum: excelTwoInfo.TfNum,
|
||||
ArtworkName: excelTwoInfo.ArtistName,
|
||||
ArtworkName: excelTwoInfo.ArtworkName,
|
||||
Ruler: excelTwoInfo.Ruler,
|
||||
SaleNo: excelTwoInfo.SaleNo,
|
||||
CompleteDate: excelTwoInfo.CompleteDate,
|
||||
|
||||
@ -1,258 +0,0 @@
|
||||
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
|
||||
// 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
|
||||
// }
|
||||
@ -36,26 +36,20 @@ func (a *Statement) UploadExcelOneTx(req *statement.UploadExcelOneTxRequest) (re
|
||||
tx := db.DB.Begin()
|
||||
defer func() {
|
||||
if err != nil {
|
||||
fmt.Println("第一处")
|
||||
tx.Rollback()
|
||||
} else {
|
||||
fmt.Println("第二处")
|
||||
tx.Commit()
|
||||
}
|
||||
}()
|
||||
for _, v := range req.ExcelOneInfo {
|
||||
//查看是否已经被生成了批次，没有的就生成物权批次
|
||||
exist, artworkTx, err := dao.IsExistArtworkTx(v.BatchTime, v.ArtistUid)
|
||||
fmt.Println("第三处")
|
||||
exist, artworkTx, err := dao.IsExistArtworkTx(tx, v.BatchTime, v.ArtistUid)
|
||||
if err != nil {
|
||||
fmt.Println("第四处")
|
||||
return rep, err
|
||||
}
|
||||
fmt.Println("第一处exist", exist)
|
||||
fmt.Println("artworkTx", artworkTx)
|
||||
|
||||
if exist {
|
||||
//获取批次uid
|
||||
fmt.Println("第五处")
|
||||
uid1, err := util.GetUid()
|
||||
if err != nil {
|
||||
return rep, err
|
||||
@ -65,7 +59,6 @@ func (a *Statement) UploadExcelOneTx(req *statement.UploadExcelOneTxRequest) (re
|
||||
if err != nil {
|
||||
return rep, err
|
||||
}
|
||||
fmt.Println("第六处")
|
||||
//对账单画作物权委托详情uid
|
||||
uid2, err := util.GetUid()
|
||||
if err != nil {
|
||||
@ -76,14 +69,21 @@ func (a *Statement) UploadExcelOneTx(req *statement.UploadExcelOneTxRequest) (re
|
||||
if err != nil {
|
||||
return rep, err
|
||||
}
|
||||
fmt.Println("第七处")
|
||||
} else {
|
||||
//查看画作是否已经被该批次录入过，被录入过就跳过
|
||||
count, err := dao.IsExistArtworkTxDetail(tx, artworkTx.Uid, v.TfNum)
|
||||
if err != nil {
|
||||
return rep, err
|
||||
}
|
||||
if count != 0 {
|
||||
continue
|
||||
}
|
||||
|
||||
//获取批次uid
|
||||
uid, err := util.GetUid()
|
||||
if err != nil {
|
||||
return rep, err
|
||||
}
|
||||
fmt.Println("第八处")
|
||||
err = dao.CreateArtworkTxDetail(tx, artworkTx.Uid, uid, v)
|
||||
if err != nil {
|
||||
return rep, err
|
||||
@ -108,12 +108,19 @@ func (a *Statement) UploadExcelTwoTx(req *statement.UploadExcelTwoTxRequest) (re
|
||||
}()
|
||||
for _, v := range req.ExcelTwoInfo {
|
||||
//查看是否已经被生成了物权批次
|
||||
exist, artworkTx, err := dao.IsExistArtworkTx(v.BatchTime, v.ArtistUid)
|
||||
exist, artworkTx, err := dao.IsExistArtworkTx(tx, v.BatchTime, v.ArtistUid)
|
||||
if err != nil {
|
||||
return rep, err
|
||||
}
|
||||
|
||||
fmt.Println("exist", exist)
|
||||
fmt.Println("artworkTx", artworkTx)
|
||||
fmt.Println("artworkTx", artworkTx)
|
||||
|
||||
//没有的就生成物权批次
|
||||
if exist {
|
||||
fmt.Println("第一处")
|
||||
|
||||
//获取批次uid
|
||||
uid1, err := util.GetUid()
|
||||
if err != nil {
|
||||
@ -124,7 +131,7 @@ func (a *Statement) UploadExcelTwoTx(req *statement.UploadExcelTwoTxRequest) (re
|
||||
if err != nil {
|
||||
return rep, err
|
||||
}
|
||||
|
||||
fmt.Println("第二处")
|
||||
//对账单画作物权委托详情uid
|
||||
uid2, err := util.GetUid()
|
||||
if err != nil {
|
||||
@ -136,6 +143,18 @@ func (a *Statement) UploadExcelTwoTx(req *statement.UploadExcelTwoTxRequest) (re
|
||||
return rep, err
|
||||
}
|
||||
} else {
|
||||
fmt.Println("第三处")
|
||||
//查看画作是否已经被该批次录入过，被录入过就跳过
|
||||
count, err := dao.IsExistArtworkSoldTxDetail(tx, artworkTx.Uid, v.TfNum)
|
||||
if err != nil {
|
||||
return rep, err
|
||||
}
|
||||
fmt.Println("count", count)
|
||||
fmt.Println("err", err)
|
||||
if count != 0 {
|
||||
continue
|
||||
}
|
||||
fmt.Println("第四处")
|
||||
//获取批次uid
|
||||
uid, err := util.GetUid()
|
||||
if err != nil {
|
||||
@ -145,6 +164,7 @@ func (a *Statement) UploadExcelTwoTx(req *statement.UploadExcelTwoTxRequest) (re
|
||||
if err != nil {
|
||||
return rep, err
|
||||
}
|
||||
fmt.Println("第五处")
|
||||
}
|
||||
|
||||
}
|
||||
@ -166,7 +186,7 @@ func (a *Statement) UploadExcelOneCopy(req *statement.UploadExcelOneCopyRequest)
|
||||
|
||||
for _, v := range req.ExcelOneInfo {
|
||||
//查看是否已经被生成了批次，没有的就生成版权批次
|
||||
exist, artworkCopy, err := dao.IsExistArtworkCopy(v.BatchTime, v.ArtistUid)
|
||||
exist, artworkCopy, err := dao.IsExistArtworkCopy(tx, v.BatchTime, v.ArtistUid)
|
||||
if err != nil {
|
||||
return rep, err
|
||||
}
|
||||
@ -195,6 +215,15 @@ func (a *Statement) UploadExcelOneCopy(req *statement.UploadExcelOneCopyRequest)
|
||||
return rep, err
|
||||
}
|
||||
} else {
|
||||
|
||||
count, err := dao.IsExistArtworkCopyDetail(tx, artworkCopy.Uid, v.TfNum)
|
||||
if err != nil {
|
||||
return rep, err
|
||||
}
|
||||
if count != 0 {
|
||||
continue
|
||||
}
|
||||
|
||||
//获取批次uid
|
||||
uid, err := util.GetUid()
|
||||
if err != nil {
|
||||
@ -225,7 +254,7 @@ func (a *Statement) UploadExcelTwoCopy(req *statement.UploadExcelTwoCopyRequest)
|
||||
|
||||
for _, v := range req.ExcelTwoInfo {
|
||||
//查看是否已经被生成了物权批次
|
||||
exist, artworkCopy, err := dao.IsExistArtworkCopy(v.BatchTime, v.ArtistUid)
|
||||
exist, artworkCopy, err := dao.IsExistArtworkCopy(tx, v.BatchTime, v.ArtistUid)
|
||||
if err != nil {
|
||||
return rep, err
|
||||
}
|
||||
@ -254,6 +283,16 @@ func (a *Statement) UploadExcelTwoCopy(req *statement.UploadExcelTwoCopyRequest)
|
||||
return rep, err
|
||||
}
|
||||
} else {
|
||||
|
||||
//查看画作是否已经被该批次录入过，被录入过就跳过
|
||||
count, err := dao.IsExistArtworkSoldCopyDetail(tx, artworkCopy.Uid, v.TfNum)
|
||||
if err != nil {
|
||||
return rep, err
|
||||
}
|
||||
if count != 0 {
|
||||
continue
|
||||
}
|
||||
|
||||
//获取批次uid
|
||||
uid, err := util.GetUid()
|
||||
if err != nil {
|
||||
@ -556,9 +595,7 @@ func (a *Statement) GetCopyInfoByBatchUid(req *statement.GetCopyInfoByBatchUidRe
|
||||
artworkSoldCopyDetail.Ruler = v.Ruler
|
||||
artworkSoldCopyDetail.SaleNo = v.SaleNo
|
||||
artworkSoldCopyDetail.CompleteDate = v.CompleteDate
|
||||
artworkSoldCopyDetail.MinPrice = v.MinPrice
|
||||
artworkSoldCopyDetail.SalePrice = v.SalePrice
|
||||
artworkSoldCopyDetail.GuaranteePrice = v.GuaranteePrice
|
||||
rep.ArtworkSoldCopyDetail = append(rep.ArtworkSoldCopyDetail, artworkSoldCopyDetail)
|
||||
}
|
||||
|
||||
|
||||
@ -25,11 +25,11 @@ type ArtworkTxDetail 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"`
|
||||
TfNum string `gorm:"column:tf_num;unqiueIndex:batchid_tfnum_idx;comment:"泰丰画作编号"`
|
||||
ArtworkName string `gorm:"column:artwork_name;comment:画作名称"`
|
||||
Ruler float32 `gorm:"column:ruler;comment:平尺"`
|
||||
MinPrice float32 `gorm:"column:min_price;comment:委托销售底价"`
|
||||
GuaranteePrice float32 `gorm:"column:guarantee_price;comment:已收取保证金;"`
|
||||
TfNum string `gorm:"column:tf_num;unqiueIndex:batchid_tfnum_idx;comment:"泰丰画作编号" json:"tf_num"`
|
||||
ArtworkName string `gorm:"column:artwork_name;comment:画作名称" json:"artwork_name"`
|
||||
Ruler float32 `gorm:"column:ruler;comment:平尺" json:"ruler"`
|
||||
MinPrice float32 `gorm:"column:min_price;comment:委托销售底价" json:"min_price"`
|
||||
GuaranteePrice float32 `gorm:"column:guarantee_price;comment:已收取保证金;" json:"guarantee_price"`
|
||||
CreatedAt int32 `gorm:"column:created_at;autoCreateTime"`
|
||||
UpdatedAt int32 `gorm:"column:updated_at;autoCreateTime"`
|
||||
DeletedAt soft_delete.DeletedAt
|
||||
@ -40,12 +40,12 @@ 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"`
|
||||
TfNum string `gorm:"column:tf_num;unqiueIndex:batchid_tfnum_idx;comment:"泰丰画作编号"`
|
||||
ArtworkName string `gorm:"column:artwork_name;comment:画作名称"`
|
||||
Ruler float32 `gorm:"column:ruler;comment:平尺"`
|
||||
SaleNo string `gorm:"column:sale_no;comment:销售单号"`
|
||||
CompleteDate string `gorm:"column:complete_date;comment:成交日期"`
|
||||
SalePrice float32 `gorm:"column:sale_price;comment:画作售价"`
|
||||
TfNum string `gorm:"column:tf_num;unqiueIndex:batchid_tfnum_idx;comment:"泰丰画作编号" json:"tf_num"`
|
||||
ArtworkName string `gorm:"column:artwork_name;comment:画作名称" json:"artwork_name"`
|
||||
Ruler float32 `gorm:"column:ruler;comment:平尺" json:"ruler"`
|
||||
SaleNo string `gorm:"column:sale_no;comment:销售单号" json:"sale_no"`
|
||||
CompleteDate string `gorm:"column:complete_date;comment:成交日期" json:"complete_date"`
|
||||
SalePrice float32 `gorm:"column:sale_price;comment:画作售价" json:"sale_price"`
|
||||
CreatedAt int32 `gorm:"column:created_at;autoCreateTime"`
|
||||
UpdatedAt int32 `gorm:"column:updated_at;autoCreateTime"`
|
||||
DeletedAt soft_delete.DeletedAt
|
||||
@ -69,11 +69,11 @@ type ArtworkCopyDetail 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"`
|
||||
TfNum string `gorm:"column:tf_num;unqiueIndex:batchid_tfnum_idx;comment:"泰丰画作编号"`
|
||||
ArtworkName string `gorm:"column:artwork_name;comment:画作名称"`
|
||||
Ruler float32 `gorm:"column:ruler;comment:平尺"`
|
||||
MinPrice float32 `gorm:"column:min_price;comment:委托销售底价"`
|
||||
GuaranteePrice float32 `gorm:"column:guarantee_price;comment:已收取保证金;"`
|
||||
TfNum string `gorm:"column:tf_num;unqiueIndex:batchid_tfnum_idx;comment:"泰丰画作编号" json:"tf_num"`
|
||||
ArtworkName string `gorm:"column:artwork_name;comment:画作名称" json:"tf_num"`
|
||||
Ruler float32 `gorm:"column:ruler;comment:平尺" json:"ruler"`
|
||||
MinPrice float32 `gorm:"column:min_price;comment:委托销售底价" json:"min_price"`
|
||||
GuaranteePrice float32 `gorm:"column:guarantee_price;comment:已收取保证金;" json:"guarantee_price"`
|
||||
CreatedAt int32 `gorm:"column:created_at;autoCreateTime"`
|
||||
UpdatedAt int32 `gorm:"column:updated_at;autoCreateTime"`
|
||||
DeletedAt soft_delete.DeletedAt
|
||||
@ -81,18 +81,16 @@ type ArtworkCopyDetail struct {
|
||||
|
||||
// 对账单画作版权委托售卖详情(该画家一个批次的全部已被售卖了的画作)
|
||||
type ArtworkSoldCopyDetail 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"`
|
||||
TfNum string `gorm:"column:tf_num;unqiueIndex:batchid_tfnum_idx;comment:"泰丰画作编号"`
|
||||
ArtworkName string `gorm:"column:artwork_name;comment:画作名称"`
|
||||
Ruler float32 `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:已收取保证金;"`
|
||||
CreatedAt int32 `gorm:"column:created_at;autoCreateTime"`
|
||||
UpdatedAt int32 `gorm:"column:updated_at;autoCreateTime"`
|
||||
DeletedAt soft_delete.DeletedAt
|
||||
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"`
|
||||
TfNum string `gorm:"column:tf_num;unqiueIndex:batchid_tfnum_idx;comment:"泰丰画作编号" json:"tf_num"`
|
||||
ArtworkName string `gorm:"column:artwork_name;comment:画作名称" json:"tf_num"`
|
||||
Ruler float32 `gorm:"column:ruler;comment:平尺" json:"ruler"`
|
||||
SaleNo string `gorm:"column:sale_no;comment:销售单号" json:"sale_no"`
|
||||
CompleteDate string `gorm:"column:complete_date;comment:成交日期" json:"complete_date"`
|
||||
SalePrice float32 `gorm:"column:sale_price;comment:画作售价" json:"sale_price"`
|
||||
CreatedAt int32 `gorm:"column:created_at;autoCreateTime"`
|
||||
UpdatedAt int32 `gorm:"column:updated_at;autoCreateTime"`
|
||||
DeletedAt soft_delete.DeletedAt
|
||||
}
|
||||
|
||||
File diff suppressed because it is too large
Load Diff
@ -1,199 +0,0 @@
|
||||
//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"];
|
||||
}
|
||||
@ -1,462 +0,0 @@
|
||||
// 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",
|
||||
}
|
||||
Loading…
Reference in New Issue
Block a user