"use strict"; const { ROOT_PATH, MODELS_PATH, HANDLERS_PATH, LIB_PATH } = process.env; const { getModel } = require( '../../../lib/Models' ); const { GenericHandler } = require( '../../../lib/Handlers/Generic.handler.js' ); const { getPagination } = require( '../../../lib/Misc.js' ); const usersModel = getModel('users'); const companiesModel = getModel('companies'); const companyGroupsModel = getModel('company_groups'); 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 , null, null , populate_select ); 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 ]; if( obj_with_fields[ field_name ] ){ 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; } const companySelectField = [ "rfc", "company_name", "company_type", "company_code", "company_city", "company_state", "createdAt", "membership", "categories", "truck_type", "company_description", "privacy" ]; async function getCompanyIdListFromGroups( companyId ){ const privateGroups = await companyGroupsModel.find({ allowedCompanies: { $in: [companyId] } }); if( !privateGroups ){ return null; } const companiesIds = privateGroups.map((group) => group.owner); return companiesIds; } async function getListByType( companyId, type , req ){ const { privacy } = req.query; const privacyVal = ( privacy && ( privacy >= 1 || privacy.toLowerCase() === 'true' ))? true: false; let filter; if( privacyVal ){ const companiesIds = await getCompanyIdListFromGroups( companyId ) || []; filter = { _id : { $in : companiesIds }, company_type: type, is_hidden: false, privacy: true, } }else{ filter = { company_type: type, is_hidden: false, $or : [ { privacy : false }, { privacy : { $exists : false } } ] }; } const select = companySelectField; const { $sort } = req.query; 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, $sort ); const data_list = queryVal.data; for(let i=0; i 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 companyId = req.context.companyId; const retVal = await getListByType( companyId, "Shipper" , req ); res.send( retVal ); }catch( error ){ console.error( error ); return res.status( 500 ).send({ error }); } } async function getListCarriers( req , res ) { try{ const companyId = req.context.companyId; const retVal = await getListByType( companyId, "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", "user_description", "job_role", "truck_type" ]; const queryVal = await user_generic.getList(page , query_elements, { company : companyId }, select ); const data_list = queryVal.data; for(let i=0; i c.name); data_list[i]["_categories"] = categories.join(", "); }else{ data_list[i]["_categories"] = ""; } /** Remove not requried fields */ 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 : "Companies: Internal error" }); } }; module.exports = { getOwnCompany, patchOwnCompany, getCompanyById, getListShippers, getListCarriers, getUserLists };