FM / ws

/var/www/myprog.com.ua/server/node/ws/

/var/www/myprog.com.ua/server/node/ws

Name	Size	Mode	Actions
hosts.js	23377	0644	edit dl rm
system.js	5215	0644	edit dl rm
users.js	23704	0644	edit dl rm
ws_server.js	1937	0644	edit dl rm

Edit: /var/www/myprog.com.ua/server/node/ws/system.js (5215B)

const Session = require('../objects/session');

module.exports = (WsServer) => {
    WsServer.prototype.accept_system = function (socket) {
        let _self = this;
        socket.on(WHO.SYSTEM.PREFIX + 'balance', (resp) => {
            console.debug("WsServer::balance::");
            console.debug(resp);
            let balance = JSON.parse(resp)
            //this.services.chat.send_message(chat_arr.data);
            // _self.service_cars.park_move_car(car.car_id,car.park_id,car.park_status,car.penalty_id,car.cause,car.who_id,car.order_id,true);
        });
        socket.on(WHO.SYSTEM.PREFIX + 'chat_send', (resp) => {
            console.debug("WsServer::chat_send::", resp);
            let arr = JSON.parse(resp)
            switch (arr.data.type) {
                case 'all':
                    _self.core.sessions_manager.send_to_all("chat_send", JSON.stringify(arr.data));
                    break;
                case 'private':
                    // получателю
                    if (arr.data.client_id_to > 0) {
                        let driver = _self.core.sessions_manager.get_driver(arr.data.client_id_to);
                        if (driver && driver.id > 0) {
                            _self.core.sessions_manager.send_to_driver(driver.id, 'chat_send', JSON.stringify(arr.data));
                        }
                        let operator = _self.core.sessions_manager.get_operator(arr.data.client_id_to);
                        if (operator && operator.id > 0) {
                            _self.core.sessions_manager.send_to_operator(operator.id, 'chat_send', JSON.stringify(arr.data))
                        }
                    }
                    // отправителю
                    if (arr.data.client_id_from > 0 && arr.data.client_id_from != arr.data.client_id_to) {
                        let driver = _self.core.sessions_manager.get_driver(arr.data.client_id_from);
                        if (driver && driver.id > 0) {
                            _self.core.sessions_manager.send_to_driver(driver.id, 'chat_send', JSON.stringify(arr.data));
                        }
                        let operator = _self.core.sessions_manager.get_operator(arr.data.client_id_from);
                        if (operator && operator.id > 0) {
                            _self.core.sessions_manager.send_to_operator(operator.id, 'chat_send', JSON.stringify(arr.data))
                        }
                    }
                    break;
                case 'operator':
                    _self.core.sessions_manager.send_to_all_operators("chat_send", resp);
                    break;
                default:
                    break;
            }
            //this.services.chat.send_message(chat_arr.data);
            // _self.service_cars.park_move_car(car.car_id,car.park_id,car.park_status,car.penalty_id,car.cause,car.who_id,car.order_id,true);
        });
        socket.on(WHO.SYSTEM.PREFIX + 'park_move_car', (resp) => {
            console.debug("WsServer::park_move_car::");
            console.debug(resp);
            let car = JSON.parse(resp)
            _self.service_cars.park_move_car(car.car_id, car.park_id, car.park_status, car.penalty_id, car.cause, car.who_id, car.order_id, true);
        });
        socket.on(WHO.SYSTEM.PREFIX + 'order_create', (json) => {
            console.debug("WsServer::system_order_create::");
            console.debug(json);
            _self.service_orders.order_create_from_system(JSON.parse(json));
        });
        socket.on(WHO.SYSTEM.PREFIX + 'order_accept', (resp) => {
            console.debug("WsServer::system_order_accept::");
            console.debug(resp);
            //console.log(sess)
            let data = JSON.parse(resp)
            let car_id = data.car_id
            let order_id = data.id
            console.log("park_busy() car_id=" + car_id + " order_id=" + order_id)
            if (car_id > 0) {
                _self.service_cars.park_move_car(car_id, 0, global.PARK_STATUS.PARK_BUSY, 0, 0, 0, order_id)
                socket.emit("jparks", _self.service_cars.get_parks_cache());
            }
            _self.service_orders.order_accept_from_system(JSON.parse(resp));
        });
        socket.on(WHO.SYSTEM.PREFIX + 'order_arrive', (resp) => {
            console.debug("WsServer::system_order_arrive::");
            console.debug(resp);
            _self.service_orders.order_arrive(JSON.parse(resp));
        });
        socket.on(WHO.SYSTEM.PREFIX + 'order_ride', (resp) => {
            console.debug("WsServer::system_order_ride::");
            console.debug(resp);
            _self.service_orders.order_ride(JSON.parse(resp));
        });
        socket.on(WHO.SYSTEM.PREFIX + 'order_complete', (resp) => {
            console.debug("WsServer::system_order_complete::");
            console.debug(resp);
            _self.service_orders.order_complete(JSON.parse(resp));
        });
        socket.on(WHO.SYSTEM.PREFIX + 'order_cancel', (resp) => {
            console.debug("WsServer::system_order_cancel::");
            console.debug(resp);
            _self.service_orders.order_cancel(JSON.parse(resp));
        });
    }
}

cmd: