|
@@ -180,6 +180,8 @@ func (t *MQProc) onNtf(funcode uint32, sessionId uint32, bytes *[]byte) {
|
|
|
|
|
|
|
|
global.M2A_LOG.Info("接收 PosChangedNtf", zap.Any("ntf", funcode), zap.Any("AccountID", *p.AccountID))
|
|
global.M2A_LOG.Info("接收 PosChangedNtf", zap.Any("ntf", funcode), zap.Any("AccountID", *p.AccountID))
|
|
|
|
|
|
|
|
|
|
+ global.M2A_LOG.Info("当前的 Clients", zap.Any("ntf", funcode), zap.Any("client.Clients", client.Clients))
|
|
|
|
|
+
|
|
|
// 获取目标客户
|
|
// 获取目标客户
|
|
|
clients, err = accountSrv.GetClientsByAccountID(*p.AccountID)
|
|
clients, err = accountSrv.GetClientsByAccountID(*p.AccountID)
|
|
|
global.M2A_LOG.Info("找到对应的clients", zap.Any("ntf", funcode), zap.Any("clients", clients))
|
|
global.M2A_LOG.Info("找到对应的clients", zap.Any("ntf", funcode), zap.Any("clients", clients))
|
