金蝶更新

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("消息体类型错误跳过消息")
 	}