对账单测试

This commit is contained in:
songchuang 2023-04-18 11:06:57 +08:00
parent f2bf3b0bdc
commit cf6e03365d

View File

@ -1,6 +1,8 @@
package logic package logic
import ( import (
"fmt"
"github.com/fonchain/fonchain-artistinfo/cmd/internal/dao" "github.com/fonchain/fonchain-artistinfo/cmd/internal/dao"
statement "github.com/fonchain/fonchain-artistinfo/pb/artistinfoStatement" statement "github.com/fonchain/fonchain-artistinfo/pb/artistinfoStatement"
db "github.com/fonchain/fonchain-artistinfo/pkg/db" db "github.com/fonchain/fonchain-artistinfo/pkg/db"
@ -29,24 +31,30 @@ type Statement struct {
func (a *Statement) UploadExcelOneTx(req *statement.UploadExcelOneTxRequest) (rep *statement.UploadExcelOneTxRespond, err error) { func (a *Statement) UploadExcelOneTx(req *statement.UploadExcelOneTxRequest) (rep *statement.UploadExcelOneTxRespond, err error) {
rep = &statement.UploadExcelOneTxRespond{} rep = &statement.UploadExcelOneTxRespond{}
fmt.Println("req.ExcelOneInfo", req.ExcelOneInfo)
//开启事务,遇到错误就回滚 //开启事务,遇到错误就回滚
tx := db.DB.Begin() tx := db.DB.Begin()
defer func() { defer func() {
if err != nil { if err != nil {
fmt.Println("第一处")
tx.Rollback() tx.Rollback()
} else { } else {
fmt.Println("第二处")
tx.Commit() tx.Commit()
} }
}() }()
for _, v := range req.ExcelOneInfo { for _, v := range req.ExcelOneInfo {
//查看是否已经被生成了批次,没有的就生成物权批次 //查看是否已经被生成了批次,没有的就生成物权批次
exist, artworkTx, err := dao.IsExistArtworkTx(v.BatchTime, v.ArtistUid) exist, artworkTx, err := dao.IsExistArtworkTx(v.BatchTime, v.ArtistUid)
fmt.Println("第三处")
if err != nil { if err != nil {
fmt.Println("第四处")
return rep, err return rep, err
} }
fmt.Println("第一处exist", exist)
if exist { if exist {
//获取批次uid //获取批次uid
fmt.Println("第五处")
uid1, err := util.GetUid() uid1, err := util.GetUid()
if err != nil { if err != nil {
return rep, err return rep, err
@ -56,7 +64,7 @@ func (a *Statement) UploadExcelOneTx(req *statement.UploadExcelOneTxRequest) (re
if err != nil { if err != nil {
return rep, err return rep, err
} }
fmt.Println("第六处")
//对账单画作物权委托详情uid //对账单画作物权委托详情uid
uid2, err := util.GetUid() uid2, err := util.GetUid()
if err != nil { if err != nil {
@ -67,12 +75,14 @@ func (a *Statement) UploadExcelOneTx(req *statement.UploadExcelOneTxRequest) (re
if err != nil { if err != nil {
return rep, err return rep, err
} }
fmt.Println("第七处")
} else { } else {
//获取批次uid //获取批次uid
uid, err := util.GetUid() uid, err := util.GetUid()
if err != nil { if err != nil {
return rep, err return rep, err
} }
fmt.Println("第八处")
err = dao.CreateArtworkTxDetail(tx, artworkTx.Uid, uid, v) err = dao.CreateArtworkTxDetail(tx, artworkTx.Uid, uid, v)
if err != nil { if err != nil {
return rep, err return rep, err