From cf6e03365dd647f2e2c1c868b752e936d6f6751a Mon Sep 17 00:00:00 2001 From: songchuang <192749120@qq.com> Date: Tue, 18 Apr 2023 11:06:57 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AF=B9=E8=B4=A6=E5=8D=95=E6=B5=8B=E8=AF=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- cmd/internal/logic/statement.go | 14 ++++++++++++-- 1 file changed, 12 insertions(+), 2 deletions(-) diff --git a/cmd/internal/logic/statement.go b/cmd/internal/logic/statement.go index 9ee8cf8..fd39931 100644 --- a/cmd/internal/logic/statement.go +++ b/cmd/internal/logic/statement.go @@ -1,6 +1,8 @@ package logic import ( + "fmt" + "github.com/fonchain/fonchain-artistinfo/cmd/internal/dao" statement "github.com/fonchain/fonchain-artistinfo/pb/artistinfoStatement" 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) { rep = &statement.UploadExcelOneTxRespond{} + fmt.Println("req.ExcelOneInfo", req.ExcelOneInfo) //开启事务,遇到错误就回滚 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("第三处") if err != nil { + fmt.Println("第四处") return rep, err } - + fmt.Println("第一处exist", exist) if exist { //获取批次uid + fmt.Println("第五处") uid1, err := util.GetUid() if err != nil { return rep, err @@ -56,7 +64,7 @@ func (a *Statement) UploadExcelOneTx(req *statement.UploadExcelOneTxRequest) (re if err != nil { return rep, err } - + fmt.Println("第六处") //对账单画作物权委托详情uid uid2, err := util.GetUid() if err != nil { @@ -67,12 +75,14 @@ func (a *Statement) UploadExcelOneTx(req *statement.UploadExcelOneTxRequest) (re if err != nil { return rep, err } + fmt.Println("第七处") } else { //获取批次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