liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
邹宗楠
2022-04-15 20:05:16 +08:00
parent 2e06f42b7f
commit 8b5eef7078
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
business/jxstore/event/event.go
View File

@@ -69,7 +69,8 @@ func AddOperateEvent(ctx *jxcontext.Context, accessUUID, jsonData string, errCod
ErrMsg: errMsg, ErrMsg: errMsg,
UseTime: useTime, UseTime: useTime,
} }
txDB , _ := dao.Begin(db) txDB, err := dao.Begin(db)
fmt.Println("errr222222222", err)
defer func() { defer func() {
if r := recover(); r != nil { if r := recover(); r != nil {
dao.Rollback(db, txDB) dao.Rollback(db, txDB)
@@ -79,11 +80,12 @@ func AddOperateEvent(ctx *jxcontext.Context, accessUUID, jsonData string, errCod
err = dao.CreateEntity(db, event) err = dao.CreateEntity(db, event)
dao.Commit(db, txDB) dao.Commit(db, txDB)
fmt.Println("4444444444") fmt.Println("4444444444")
fmt.Println("4444444444err", err)
return err return err
} }
func AddOperateEventDetail(db *dao.DaoDB, operateEventDetail *model.OperateEventDetail) (err error) { func AddOperateEventDetail(db *dao.DaoDB, operateEventDetail *model.OperateEventDetail) (err error) {
txDB , _ := dao.Begin(db) txDB, _ := dao.Begin(db)
defer func() { defer func() {
if r := recover(); r != nil { if r := recover(); r != nil {
dao.Rollback(db, txDB) dao.Rollback(db, txDB)
@@ -99,7 +101,7 @@ func AddOperateEventDetail(db *dao.DaoDB, operateEventDetail *model.OperateEvent
func DeleteOperateEventAndDetail(ctx *jxcontext.Context, deleteTime time.Time) (err error) { func DeleteOperateEventAndDetail(ctx *jxcontext.Context, deleteTime time.Time) (err error) {
db := dao.GetDB() db := dao.GetDB()
txDB , _ := dao.Begin(db) txDB, _ := dao.Begin(db)
defer func() { defer func() {
if r := recover(); r != nil { if r := recover(); r != nil {
dao.Rollback(db, txDB) dao.Rollback(db, txDB)