|
@@ -258,6 +258,19 @@ func (t *MQProc) getRspProtobuf(msg *[]byte) (funcode uint32, sessionId uint32,
|
|
|
bytes = &bs
|
|
bytes = &bs
|
|
|
serialNumber = p.GetHeader().GetRequestID()
|
|
serialNumber = p.GetHeader().GetRequestID()
|
|
|
}
|
|
}
|
|
|
|
|
+ case global.UserReceiveIsDefaultRsp:
|
|
|
|
|
+ var p pb.UserReceiveIsDefaultRsp
|
|
|
|
|
+ if err = proto.Unmarshal(b, &p); err != nil {
|
|
|
|
|
+ global.M2A_LOG.Error("总线回复数据反序列化失败", zap.Error(err))
|
|
|
|
|
+ return
|
|
|
|
|
+ }
|
|
|
|
|
+ if bs, e := protojson.Marshal(&p); e != nil {
|
|
|
|
|
+ global.M2A_LOG.Error("总线回复数据反序列化失败", zap.Error(err))
|
|
|
|
|
+ return
|
|
|
|
|
+ } else {
|
|
|
|
|
+ bytes = &bs
|
|
|
|
|
+ serialNumber = p.GetHeader().GetRequestID()
|
|
|
|
|
+ }
|
|
|
case global.UserReceiptInfoRsp: // 新增修改用户发票信息请求响应
|
|
case global.UserReceiptInfoRsp: // 新增修改用户发票信息请求响应
|
|
|
var p pb.UserReceiptInfoRsp
|
|
var p pb.UserReceiptInfoRsp
|
|
|
if err = proto.Unmarshal(b, &p); err != nil {
|
|
if err = proto.Unmarshal(b, &p); err != nil {
|