ETAApi/src/apps/private/companies/services.js

"use strict";
const { ROOT_PATH, MODELS_PATH, HANDLERS_PATH, LIB_PATH } = process.env;
const { getModel } = require( `${ROOT_PATH}/${MODELS_PATH}` );
const { GenericHandler } = require( `${ROOT_PATH}/${HANDLERS_PATH}/Generic.handler.js` );
const { getPagination } = require( `${ROOT_PATH}/${LIB_PATH}/Misc.js` );

const usersModel = getModel('users');
const companiesModel = getModel('companies');
const branchesModel = getModel('branches');
const vehiclesModel = getModel('vehicles');
const loadsModel = getModel('loads');
const productCategoriesModel = getModel('product_categories');

const populate_select = {
    categories:"-_id name",
};
const generic = new GenericHandler( companiesModel, null, null , populate_select );
const user_generic = new GenericHandler( usersModel  );

function join_field_list( obj_with_fields , list_of_fields )
{
    for(let field_idx=0; field_idx < list_of_fields.length; field_idx++){
        const field_name = list_of_fields[ field_idx ];
        const new_field_name = "_" + list_of_fields[ field_idx ];
        obj_with_fields[ new_field_name ] = obj_with_fields[field_name].join(", ");
    }
    return obj_with_fields;
}

function getAndFilterList( query ){
    const filter_list = [];
    const { company_type, company_name, truck_type, categories, company_state, company_city } = query;

    if( company_name ){ filter_list.push( { company_name } ); }
    if( company_type ){ filter_list.push( { company_type } ); }
    if( company_state ){ filter_list.push( { company_state } ); }
    if( company_city ){ filter_list.push( { company_city } ); }
    if( truck_type ){ filter_list.push( { truck_type } ); }
    if( categories ){ filter_list.push( { categories } ); }

    if( filter_list.length == 0 ){
        return null;
    }
    return filter_list;
}

async function getListByType( type , req ){
    const filter = { "company_type" : type , "is_hidden" : false };
    const select = [
        "rfc",
        "company_name",
        "company_type",
        "company_code",
        "company_city",
        "company_state",
        "createdAt",
        "membership",
        "categories",
        "truck_type",
        "company_description"
    ];
    const { elements , page } = getPagination( req.query );
    let query_elements;
    if( elements >= 100 ){
        query_elements = 100;// Never return more than 100 elements
    }else{
        query_elements = elements;
    }

    const andFilterList = getAndFilterList( req.query );

    if( andFilterList ){
        filter.$and = andFilterList;
    }

    const queryVal = await generic.getList(page , query_elements, filter, select );
    const data_list = queryVal.data;
    for(let i=0; i<data_list.length; i++){
        data_list[i] = data_list[i].toObject();
        data_list[i] = join_field_list( data_list[i] , ["company_city","company_state","truck_type"] );
        let categories = data_list[i].categories.map( ( c ) => c.name);
        data_list[i]._truck_types = data_list[i]._truck_type;
        data_list[i]._categories = categories.join(", ");

        /** Remove not requried fields */
        delete data_list[i].categories;
        delete data_list[i].company_city;
        delete data_list[i].company_state;
        delete data_list[i].truck_type;
        delete data_list[i]._truck_type;
    }
    const retVal = {
        total : queryVal.total,
        limit : queryVal.limit,
        skip : queryVal.skip,
        data : data_list
    };
    return retVal;
}

async function getOwnCompany( req , res ) {
    try{
        const companyId = req.context.companyId;
        const result = await companiesModel.findById( companyId )
            .populate("categories" , "_id name")
            .populate("company_city", "-_id name")
            .populate("company_state", "-_id name")
            .populate("truck_type", "-_id name");
        return res.send( result );
    }catch( error ){
        console.error( error );
        return res.status( 500 ).send({ error });
    }
}

async function patchOwnCompany( req , res ) {
    try{
        const companyId = req.context.companyId;
        const data = req.body;
        if( data.company_type ){ delete data.company_type; }
        await companiesModel.findByIdAndUpdate( companyId , data );
        const result = await companiesModel.findById( companyId );
        return res.send( result );
    }catch( error ){
        console.error( error );
        return res.status( 500 ).send({ error });
    }
}

async function getCompanyById( req , res ) {
    try{
        const companyId = req.params.id;
        const result = await companiesModel.findById( companyId );
        return res.send( result );
    }catch( error ){
        console.error( error );
        return res.status( 500 ).send({ error });
    }
}

async function getListShippers( req , res ) {
    try{
        const retVal = await getListByType( "Shipper" , req );
        res.send( retVal );
    }catch( error ){
        console.error( error );
        return res.status( 500 ).send({ error });
    }
}

async function getListCarriers( req , res ) {
    try{
        const retVal = await getListByType( "Carrier" , req );
        res.send( retVal );
    }catch( error ){
        console.error( error );
        return res.status( 500 ).send({ error });
    }
}

const getUserLists = async(req, res) => {
    try{
        const companyId = req.params.companyId;

        const { elements, page } = getPagination( req.query );
        let query_elements;
        if( elements >= 100 ){
            query_elements = 100;// Never return more than 100 elements
        }else{
            query_elements = elements;
        }

        const select = [
            "first_name",
            "middle_name",
            "last_name",
            "company",
            "employe_id",
            "phone",
            "phone2",
            "email",
            "categories",
            "user_city",
            "user_state",
            "truck_type"
        ];
        const queryVal = await user_generic.getList(page , query_elements, { company : companyId }, select );
        const data_list = queryVal.data;
        for(let i=0; i<data_list.length; i++){
            data_list[i] = data_list[i].toObject();
            let name;
            name = ( !data_list[i].first_name )? "" : data_list[i].first_name;
            name += ( !data_list[i].middle_name )? "": " " + data_list[i].middle_name;
            name += ( !data_list[i].last_name )? "": " " + data_list[i].last_name;

            data_list[i].name = name;
            data_list[i] = join_field_list( data_list[i] , ["categories","user_city","user_state","truck_type"] );
            let categories = data_list[i].categories.map( ( c ) => c.name);
    
            /** Remove not requried fields */
            delete data_list[i].categories;
            delete data_list[i].user_city;
            delete data_list[i].user_state;
            delete data_list[i].truck_type;
        }
        const retVal = {
            total : queryVal.total,
            limit : queryVal.limit,
            skip : queryVal.skip,
            data : data_list
        };
        return res.status(200).send( retVal );
    } catch ( err ){
        console.error( err );
        return res.status(500).send({ error : "Public-Companies: Internal error" });
    } 
};

module.exports = { 
    getOwnCompany,
    patchOwnCompany,
    getCompanyById,
    getListShippers,
    getListCarriers,
    getUserLists
};