From 7dca2bdfae296b511986a9add993d3047b78a415 Mon Sep 17 00:00:00 2001 From: wh_zcy Date: Wed, 14 Dec 2022 11:03:54 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A4=84=E7=90=86=E9=94=99=E8=AF=AF=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- lib/robot.go | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/lib/robot.go b/lib/robot.go index 047976e..9d4047c 100644 --- a/lib/robot.go +++ b/lib/robot.go @@ -127,8 +127,14 @@ func (r *Robot) SendMsg(mainType, subType string, req proto.Message, rsp proto.M if !ProtoUnmarshal(msg, rsp) { break } - return pb.ErrorCode_Success + } else if msg.MainType == "notify" && msg.SubType == "errornotify" { + rsp := &pb.NotifyErrorNotifyPush{} + if !ProtoUnmarshal(msg, rsp) { + break + } + logrus.Info(rsp.Code) + return rsp.Code } } } @@ -224,7 +230,7 @@ func (m *Robot) syncCall() { //这里执行会花很长时间 if err := scene.Run(m); err != nil { logrus.WithField("err", err).Error("执行业务时发生错误") - break + continue } elapsedTime := time.Since(start)