FM / services

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

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

Name	Size	Mode	Actions
service_cameras.js	1480	0666	edit dl rm
service_chat.js	832	0644	edit dl rm
service_clients.js	3702	0644	edit dl rm
service_commands.js	1763	0666	edit dl rm
service_devices.js	1340	0666	edit dl rm
service_events.js	1909	0666	edit dl rm
service_hosts.js	2077	0644	edit dl rm
service_host_config.js	1317	0644	edit dl rm
service_places.js	3450	0644	edit dl rm
service_scenario.js	1081	0666	edit dl rm
service_users.js	1064	0644	edit dl rm
service_values.js	2077	0666	edit dl rm
service_var.js	992	0666	edit dl rm

Edit: /var/www/myprog.com.ua/server/node/services/service_clients.js (3702B)

const bcrypt = require('bcrypt')
// const log = require('../logs/log')
const CustomError = require('../objects/custom_error')
// const Order = require('../objects/order')
const Client = require('../objects/client')

let instance_service_client

module.exports = class ServiceClient {
    constructor() {
        if (!instance_service_client) {
            instance_service_client = this
        }
        return instance_service_client
    }

async get_client({ client_id, phone }){
        let res = await core.context.get_client({ client_id, phone })
        if(res && res.id){
            return new Client(res)
        }else{
            return
        }
    }
    async create_client({ phone, password, name, email, company_id }) {
        let connection
        try {
            phone = await core.normalize_phone(phone)
            if (!phone) {
                throw new CustomError(400, 'phone required')
            }
            if (!name) {
                throw new CustomError(400, 'name required')
            }

// найти клинета по номеру телефона
            let client_old = await this.get_client({ phone })
            if (client_old) {
                throw new CustomError(400, 'user with this number is already registered')
            }
            let client = new Client({ password, name, email, company_id })
            if (!password) {// если нет пароля создать
                password = core.make_random_string(6)
            }
            client.set_password(await bcrypt.hash(password, 10))

connection = await core.context.beginTransaction()

let insert_id = await core.context.create_client(client, connection)
            if (insert_id > 0) {
                await core.context.client_add_phone({ client_id: insert_id, phone: phone }, connection)
                client.set_id(insert_id)
            }
            await core.context.commit(connection)
            return client
        } catch (e) {
            await core.context.rollback(connection)
            throw e
        }
    }
    async activation({ phone, app_id, type }) {
        let code = core.make_random_string(4, true)
        phone = await core.normalize_phone(phone)
        if (!phone) {
            throw new CustomError(400, 'phone required')
        }
        let insert_id = await core.context.insert_activation({ code, phone, app_id, type })
        if (insert_id > 0) {
            return code
        } else {
            return
        }
    }
    async activation_confirm({ phone, code }) {
        let connection
        try {
            phone = await core.normalize_phone(phone)
            if (!phone) {
                throw new CustomError(400, 'phone required')
            }
            if (!code) {
                throw new CustomError(400, 'code required')
            }
            let activation = await core.context.get_activation({ phone, code })
            if (!activation) {
                throw new CustomError(404, 'code not found')
            }
            let client = await this.get_client({ phone })
            if (!client) {
                throw new CustomError(404, 'client not found')
            }

client.set_activated(1)
            client.set_enabled(1)

connection = await core.context.beginTransaction()
            await core.context.update_client(client, connection)
            await core.context.set_activation({ id: activation.id }, connection)
            await core.context.commit(connection)

return true
        } catch (e) {
            await core.context.rollback(connection)
            throw e
        }
    }
}

cmd: