/var/www/myprog.com.ua/server/node/ws
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));
});
}
}