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