|
|
@@ -178,8 +178,11 @@ func (t *MQProc) onNtf(funcode uint32, sessionId uint32, bytes *[]byte) {
|
|
|
sendBytes = &bs
|
|
|
}
|
|
|
|
|
|
+ global.M2A_LOG.Info("接收 PosChangedNtf", zap.Any("ntf", funcode), zap.Any("AccountID", *p.AccountID))
|
|
|
+
|
|
|
// 获取目标客户
|
|
|
clients, err = accountSrv.GetClientsByAccountID(*p.AccountID)
|
|
|
+ global.M2A_LOG.Info("找到对应的clients", zap.Any("ntf", funcode), zap.Any("clients", clients))
|
|
|
if err != nil {
|
|
|
global.M2A_LOG.Info(fmt.Sprintf("接收头寸变化通知时获取不到对应Client，AccountID:%v", *p.AccountID))
|
|
|
return
|
