优化消息推送

src/services/index.ts

@@ -163,48 +163,51 @@ export default new (class LifeCycleCtr {
 
         // 推送信息
         socket.onReceivePush = (_self, msg) => {
-            switch (msg.funCode) {
-                case funCode.CustOfflineNtf:
-                    //接收到账户离线通知
-                    eventBus.$emit('custOfflineNtf', noticeParseRsp(msg, 'CustOfflineNtf'));
-                    break;
-                case funCode.LogoutRsp:
-                    // 接收到用户登出应答
-                    eventBus.$emit('userLogout', noticeParseRsp(msg, 'LogoutRsp'));
-                    break;
-                case funCode.PosChangedNtf:
-                    //接收到头寸变化通知!
-                    debounce(() => {
-                        eventBus.$emit('posChangedNtf', noticeParseRsp(msg, 'PosChangedNtf'));
-                    }, timeout, 'posChangedNtf')
-                    break;
-                case funCode.MoneyChangedNtf:
-                    // 接收到资金变化通知
-                    debounce(() => {
-                        eventBus.$emit('moneyChangedNtf', noticeParseRsp(msg, 'MoneyChangedNtf'));
-                    }, timeout, 'moneyChangedNtf')
-                    break;
-                case funCode.OrderCanceledNtf:
-                    // 接收到委托单撤单通知
-                    debounce(() => {
-                        eventBus.$emit('orderCanceledNtf', noticeParseRsp(msg, 'OrderCanceledNtf'));
-                    }, timeout, 'orderCanceledNtf')
-                    break;
-                case funCode.OrderDealedNtf:
-                    // 接收到委托单成交通知
-                    debounce(() => {
-                        eventBus.$emit('orderDealedNtf', noticeParseRsp(msg, 'OrderDealedNtf'));
-                    }, timeout, 'orderDealedNtf')
-                    break;
-                case funCode.WRTradeDealedNtf:
-                    // 接收到仓单贸易成交通知
-                    debounce(() => {
-                        eventBus.$emit('wrTradeDealedNtf', noticeParseRsp(msg, 'WRTradeDealedNtf'));
-                    }, timeout, 'wrTradeDealedNtf')
-                    break;
-                default:
-                    msg.funCode !== 0 && console.warn({ msg: '接收到通知:' + msg.funCode });
-                    break;
+            if (msg.funCode) {
+                console.log('接收到通知', msg.funCode);
+                switch (msg.funCode) {
+                    case funCode.CustOfflineNtf:
+                        //接收到账户离线通知
+                        eventBus.$emit('custOfflineNtf', noticeParseRsp(msg, 'CustOfflineNtf'));
+                        break;
+                    case funCode.LogoutRsp:
+                        // 接收到用户登出应答
+                        eventBus.$emit('userLogout', noticeParseRsp(msg, 'LogoutRsp'));
+                        break;
+                    case funCode.PosChangedNtf:
+                        //接收到头寸变化通知!
+                        debounce(() => {
+                            eventBus.$emit('posChangedNtf', noticeParseRsp(msg, 'PosChangedNtf'));
+                        }, timeout, 'posChangedNtf')
+                        break;
+                    case funCode.MoneyChangedNtf:
+                        // 接收到资金变化通知
+                        debounce(() => {
+                            eventBus.$emit('moneyChangedNtf', noticeParseRsp(msg, 'MoneyChangedNtf'));
+                        }, timeout, 'moneyChangedNtf')
+                        break;
+                    case funCode.OrderCanceledNtf:
+                        // 接收到委托单撤单通知
+                        debounce(() => {
+                            eventBus.$emit('orderCanceledNtf', noticeParseRsp(msg, 'OrderCanceledNtf'));
+                        }, timeout, 'orderCanceledNtf')
+                        break;
+                    case funCode.OrderDealedNtf:
+                        // 接收到委托单成交通知
+                        debounce(() => {
+                            eventBus.$emit('orderDealedNtf', noticeParseRsp(msg, 'OrderDealedNtf'));
+                        }, timeout, 'orderDealedNtf')
+                        break;
+                    case funCode.WRTradeDealedNtf:
+                        // 接收到仓单贸易成交通知
+                        debounce(() => {
+                            eventBus.$emit('wrTradeDealedNtf', noticeParseRsp(msg, 'WRTradeDealedNtf'));
+                        }, timeout, 'wrTradeDealedNtf')
+                        break;
+                    default:
+                        msg.funCode !== 0 && console.warn({ msg: '接收到通知:' + msg.funCode });
+                        break;
+                }
             }
         };
         // 重连成功回调