update

initialize/rabbitmq.go

@@ -109,12 +109,12 @@ func (t *MQProc) onNtf(funcode uint32, sessionId uint32, bytes *[]byte) {
 			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 {
-			sendBytes = &bs
-		}
+		// if bs, e := protojson.Marshal(&p); e != nil {
+		// 	global.M2A_LOG.Error("总线数据反序列化失败", zap.Error(err))
+		// 	return
+		// } else {
+		// 	sendBytes = &bs
+		// }
 
 		// 获取目标客户
 		for i := range client.Clients {
@@ -132,7 +132,7 @@ func (t *MQProc) onNtf(funcode uint32, sessionId uint32, bytes *[]byte) {
 			return
 		}
 		if bs, e := protojson.Marshal(&p); e != nil {
-			global.M2A_LOG.Error("总线数据反序列化失败", zap.Error(err))
+			global.M2A_LOG.Error("总线数据序列化JSON失败", zap.Error(err))
 			return
 		} else {
 			sendBytes = &bs
@@ -153,7 +153,7 @@ func (t *MQProc) onNtf(funcode uint32, sessionId uint32, bytes *[]byte) {
 			return
 		}
 		if bs, e := protojson.Marshal(&p); e != nil {
-			global.M2A_LOG.Error("总线数据反序列化失败", zap.Error(err))
+			global.M2A_LOG.Error("总线数据序列化JSON失败", zap.Error(err))
 			return
 		} else {
 			sendBytes = &bs
@@ -171,7 +171,7 @@ func (t *MQProc) onNtf(funcode uint32, sessionId uint32, bytes *[]byte) {
 			return
 		}
 		if bs, e := protojson.Marshal(&p); e != nil {
-			global.M2A_LOG.Error("总线数据反序列化失败", zap.Error(err))
+			global.M2A_LOG.Error("总线数据序列化JSON失败", zap.Error(err))
 			return
 		} else {
 			sendBytes = &bs
@@ -189,7 +189,7 @@ func (t *MQProc) onNtf(funcode uint32, sessionId uint32, bytes *[]byte) {
 			return
 		}
 		if bs, e := protojson.Marshal(&p); e != nil {
-			global.M2A_LOG.Error("总线数据反序列化失败", zap.Error(err))
+			global.M2A_LOG.Error("总线数据序列化JSON失败", zap.Error(err))
 			return
 		} else {
 			sendBytes = &bs
@@ -208,7 +208,7 @@ func (t *MQProc) onNtf(funcode uint32, sessionId uint32, bytes *[]byte) {
 			return
 		}
 		if bs, e := protojson.Marshal(&p); e != nil {
-			global.M2A_LOG.Error("总线数据反序列化失败", zap.Error(err))
+			global.M2A_LOG.Error("总线数据序列化JSON失败", zap.Error(err))
 			return
 		} else {
 			sendBytes = &bs