From 57180fb19b4f9bc6de50c6ccbecef45a722bc712 Mon Sep 17 00:00:00 2001 From: yehongyang Date: Fri, 24 Dec 2021 13:27:41 +0800 Subject: [PATCH] =?UTF-8?q?=E9=87=91=E8=9D=B6=E6=9B=B4=E6=96=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- services/ap/implments/PlanOrderVersion.service.impl.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/services/ap/implments/PlanOrderVersion.service.impl.go b/services/ap/implments/PlanOrderVersion.service.impl.go index 4a7fc94..38ee2a8 100644 --- a/services/ap/implments/PlanOrderVersion.service.impl.go +++ b/services/ap/implments/PlanOrderVersion.service.impl.go @@ -133,14 +133,13 @@ func (impl *PlanOrderVersionServiceImplement) Publish(info utils.ChannelsInfo) ( entity, ok := info.Info.(model.PlanOrderVersion) engine := db.Eloquent.Master() session := engine.NewSession() + defer session.Close() defer func() { //在panic前声明defer,能捕获异常 if err := recover(); err != nil { - session.Rollback() innerLog, _ := logger.NewLogger("system", "planOrderVersion_cancel") innerLog.Debug("系统异常:", err) } }() - defer session.Close() if !ok || entity.PlanOrderId == "" { panic("消息体类型错误跳过消息") }