处理 WROutApplyReq 接口入参类型问题

model/mq/request/mq.go

@@ -498,7 +498,7 @@ func (r *MQBodyReq) GetProtoBytes(serialNumber *uint32) (bytes *[]byte, err erro
 		}
 	case global.WROutApplyReq:
 		m := pb.WROutApplyReq{}
-		if err = r.reflect(data, &m); err != nil {
+		if err = r.reflectNoLong(data, &m); err != nil {
 			return
 		}
 		if m.Header != nil {
@@ -716,3 +716,13 @@ func (r *MQBodyReq) reflect(data string, m proto.Message) (err error) {
 
 	return
 }
+
+func (r *MQBodyReq) reflectNoLong(data string, m proto.Message) (err error) {
+	if e := jsonpb.UnmarshalString(data, m); e != nil {
+		global.M2A_LOG.Error(e.Error(), zap.Error(e))
+		err = errors.New("业务数据装箱失败")
+		return
+	}
+
+	return
+}