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