code formatting suggestions

script.js

var count_end = 0;
async function work(result, db, key) {
  var leadID          = result[key].id;
  var l_type          = result[key].l_type;
  var extra_column_13 = result[key].extra_column_13;
  var l_source        = result[key].l_source;
  var first_name      = result[key].first_name;
  var v_liquido       = result[key].extra_column_9;
  var v_bruto         = result[key].extra_column_11;
  var v_cronologica   = result[key].extra_column_15;

  if (l_type === 8) {
    func.log_message(`CHECK-EXTRAIDO: OK=>{id=${leadID}, l_type=${l_type}}`, 0);

    var executed = false;
    var rExecutedDB = result[key].extra_column_13
      .replace(/\s/g, "")
      .toLowerCase();

    for (var c = 0; c < jsonFile.collection.length; c++) {
      var rFileJson = jsonFile.collection[c].li
        .replace(/\s/g, "")
        .toLowerCase();
      if (rFileJson === rExecutedDB) {
        executed = true;
        break;
      } else {
        continue;
      }
    }

    if (executed === true) {
     
      func.log_message(`CHECK-EXECUTADO: OK=>{id=${leadID
        }, first_name=${first_name
        }, extra_column_13=${extra_column_13
        }, l_source=${l_source
        }, l_type=${l_type}}`, 0);

      try {
        var update = await new Promise((resolve, reject) => {

          var query = "UPDATE bd_shwcp_leads_2 SET l_source=1, updated_by='SCRIPT-TND'" +
            " where id=" + leadID;

          db.query(query, (error, results, fields) => {
            error ? reject(error) : resolve({ results, fields });
          });
        });

        func.log_message(`UPDATE-SOURCE: OK=>{id=${leadID
          }, result=${update.results.affectedRows}, l_source=1}`);

      } catch (err) {
        console.log(err);
      }

      var filtred = func.handle_values(v_liquido, v_bruto, "no", db,
        result[key]);
      var input_vliquido = document.getElementById('liquido').value;
      var input_vliquido_bruto = document.getElementById('liquido-bruto').value;

      if (filtred != 0) {
        var n_filtred_l = func.setNumToCompare(input_vliquido);
        var n_filtred_b = func.setNumToCompare(input_vliquido_bruto);
        
        // work filter example of 81.456,86 to 81456.86
        if(func.setNumToCompare(filtred) > n_filtred_l ||
            func.setNumToCompare(filtred) > n_filtred_b) {

          func.log_message(`CHECK-LIQUIDO: OK=>{id=${leadID}, l_type=${l_type}}`,0);

          var rEnd = func.data_compare(v_cronologica,
            document.getElementById('data-oficio').value,
            document.getElementById('termo-declaracao').value,
            document.getElementById('years-x').value,
            document.getElementById('years-y').value,
            result[key]);
            
          switch(rEnd) {
            case true:
              func.log_message(`IMPORT-CRM: OK=>{id=${leadID}, l_type=${l_type}}`,1);
              result[key].extra_column_9 = filtred;
              await func_people(conn2,result[key]);
            break;
            case false:
              func.log_message(`IMPORT-CRM: FALHA=>{id=${leadID} REJEITADO"}`,2);
              console.log(`${count_end}===================>ID-${key} REJEITADO: ${leadID}`);
            break;
            case 5:
              func.log_message(`IMPORT-CRM: FALHA=>{id=${leadID} ANALISAR"}`,1);
              console.log(`===================>ID-${key} ANALISAR: ${leadID}`);
            break;
          }

        } else {

          try {
            var update = await new Promise((resolve, reject) => {
              var query = "UPDATE bd_shwcp_leads_2 SET extra_column_24=17 " +
                "where id="+leadID;

              db.query(query, (error, results, fields) => {
                error ? reject(error) : resolve({ results, fields });
              });
            });

            func.log_message(`CHECK-LIQUIDO: VALOR_BAIXO=>{id=${leadID
              }, l_type=${l_type}, extra_column_24=17}`, 0);

          } catch (err) {
            console.log(err);
          }

        }

      } else {

        try {
          var update = await new Promise((resolve, reject) => {
            var query = "UPDATE bd_shwcp_leads_2 SET extra_column_24=19 "
              + "where id=" + leadID;
            db.query(query, (error, results, fields) => {
              error ? reject(error) : resolve({ results, fields });
            });
          });

          func.log_message(`CHECK-LIQUIDO: ANALISAR=>{` +
            `id=${leadID}, l_type=${l_type}, extra_column_24=19}`,0);
        } catch (err) {
          console.log(err);
        }

      }
      
    } else {
      try {
        var update1 = await new Promise((resolve, reject) => {
          var query = "UPDATE bd_shwcp_leads_2 SET extra_column_24=16, l_source=5 where id=" +leadID
          db.query(query, (error, results, fields) => {
            error ? reject(error) : resolve({ results, fields });
          });
        });
        func.log_message(`UPDATE-EXECUTADO MSG=(NAO) FALHA=>{` +
          `id=${leadID}, result=${update1.results.affectedRows}, l_source=16}`, 0);
      } catch (err) {
        console.log(err);
      }
    }

  } else {
    func.log_message(`CHECK-EXTRAIDO: FALHA=>{id=${leadID}, l_type=${l_type}}`,0);
  }

  (l_type === 8)
    ?   console.log(`RowsCount:${count_end} SIM              ID:${leadID}`);
    : (l_type === 6)
      ? console.log(`RowsCount:${count_end} NAO              ID:${leadID}`);
      : console.log(`RowsCount:${count_end} STATUS-${l_type} ID:${leadID}`);

  count_end = count_end + 1;
}

async function func_people(db,dataObj) {
  var pdf_files = {
    oficio:     dataObj.extra_column_4,
    declaracao: dataObj.extra_column_3,
    calculos:   dataObj.extra_column_2,
  };

  var people = {
    user_id:       0,
    first_name:    dataObj.first_name,
    last_name:     '',
    company:       0,
    email:         0,
    phone:         0,
    mobile:        0,
    other:         0,
    website:       0,
    fax:           0,
    notes:         0,
    street_1:      0,
    street_2:      0,
    city:          0,
    state:         0,
    postal_code:   0,
    life_stage:    0,
    contact_owner: 0,
    hash:          0,
    created_by:    0,
    created:       dataObj.creation_date,
  };

  try {
    var insert = new Promise((resolve, reject) => {
      var query = "INSERT INTO bd_erp_peoples SET ?";
      db.query(query, people,(error, results, fields) => {
        error ? reject(error) : resolve({ results, fields });
      });
    });
    //console.log("PEOPLE-OK:"+res.results.insertId);
    await func_people_relation(db, insert.results.insertId, dataObj, pdf_files);
    await func_people_meta(db, insert.results.insertId,dataObj)
  } catch (err) {
    console.log(err);
  }
}

async function func_people_relation(db, id, dataObj, pdf){
  var relation = { people_id: id, people_types_id: 1 };
  var query = "INSERT INTO bd_erp_people_type_relations SET ?";

  try {
    var insert = new Promise((resolve, reject) => {
      db.query(query, relation, (error, results, fields) => {
        error ? reject(error) : resolve({ results, fields });
      });
    });

    for (var prop in pdf) {
      await func_post(db, id, dataObj, pdf[prop]);
    }
  } catch (err) {
    console.log(err);
  }
}

async function func_people_meta(db, idpl, dataObj) {
  const meta = {
    collection: [
      {
        erp_people_id: idpl,
        meta_key: "cpf_cnpj",
        meta_value: dataObj.last_name,
      },
      {
        erp_people_id: idpl,
        meta_key: "ordin_ria",
        meta_value: 0,
      },
      {
        erp_people_id: idpl,
        meta_key: "execu__o",
        meta_value: dataObj.extra_column_13,
      },
      {
        erp_people_id: idpl,
        meta_key: "ordem",
        meta_value: 0,
      },
      {
        erp_people_id: idpl,
        meta_key: "ordem",
        meta_value: 0,
      },
      {
        erp_people_id: idpl,
        meta_key: "e_p_",
        meta_value: 0,
      },
      {
        erp_people_id: idpl,
        meta_key: "n_mero_do_processo_depre",
        meta_value: dataObj.extra_column_14,
      },
      {
        erp_people_id: idpl,
        meta_key: "cabe_a",
        meta_value: 0,
      },
      {
        erp_people_id: idpl,
        meta_key: "contra",
        meta_value: 0,
      },
      {
        erp_people_id: idpl,
        meta_key: "advogado",
        meta_value: dataObj.extra_column_12,
      },
      {
        erp_people_id: idpl,
        meta_key: "valor_principal",
        meta_value: dataObj.extra_column_11,
      },
      {
        erp_people_id: idpl,
        meta_key: "valor_da_lead",
        meta_value: dataObj.extra_column_11,
      },
      {
        erp_people_id: idpl,
        meta_key: "juros",
        meta_value: dataObj.extra_column_10,
      },
      {
        erp_people_id: idpl,
        meta_key: "data_base",
        meta_value: dataObj.extra_column_8,
      },
      {
        erp_people_id: idpl,
        meta_key: "_ndice_da__poca",
        meta_value: 0,
      },
      {
        erp_people_id: idpl,
        meta_key: "prioridade_de_pagamento",
        meta_value: 0,
      },
      {
        erp_people_id: idpl,
        meta_key: "link_tjsp",
        meta_value: dataObj.extra_column_1,
      },
    ],
  };

  var json = JSON.parse(JSON.stringify(meta));

  var q = 'insert into bd_erp_peoplemeta ?';
  return await new Promise((res, j) => {
    db.query(q, meta.collection, (e, results, fields) => e ? j(e) : res({ results, fields }));
  });
}

async function func_post(db, id_p, dataObj, pfd_name){
  var post = {
    post_author:           1,
    post_date:             dataObj.creation_date,
    post_date_gmt:         0,
    post_content:          0,
    post_title:            func.basename(pfd_name),
    post_excerpt:          0,
    post_status:           "erp_hr_rec",
    comment_status:        "open",
    ping_status:           "closed",
    post_password:         0,
    post_name:             func.basename(pfd_name),
    to_ping:               0,
    pinged:                0,
    post_modified:         0,
    post_modified_gmt:     0,
    post_content_filtered: 0,
    post_parent:           0,
    guid:                  0,
    menu_order:            0,
    post_type:             "attachment",
    post_mime_type:        "application/pdf",
    comment_count:         0,
  };

  try {
    var q = 'INSERT INTO bd_posts set ?';
    var insert = await new Promise((r, j) => {
      db.query(q, post, (e, results, fields) => e ? j(e) : r({ results, fields }));
    });

    await func_post_meta(db, insert.results.insertId, id_p, dataObj, pfd_name);
  } catch (e) {
    console.error(e);
  }
}

async function func_post_meta(db, id_post, id_pl, dataObj, pfd_name) {
  var meta = {
    post_id:    id_post,
    meta_key:   "_wp_attached_file",
    meta_value: pfd_name,
  };

  try {
    var q = 'INSERT INTO bd_postmeta SET ?';
    var insert = new Promise((r, j) => {
      db.query(q, meta, (e, results, fields) => e ? j(e) : r({ results, fields }));
    });
    await func_post_meta_dir_file_relationship(db,id_pl,id_post,dataObj,pfd_name);
  } catch (err) {
    console.log(err);
  }
}

async function func_post_meta_dir_file_relationship(db, id_pl, id_post, dataObj, pfd_name) {
  var file = {
    eid:           id_pl,
    dir_id:        1,
    dir_name:      pfd_name,
    attachment_id: id_post,
    parent_id:     0,
    is_dir:        0,
    eid_type:      "contact",
    created_by:    1,
    created_at:    dataObj.creation_date,
    updated_at:    0,
  };

  try {
    var q = 'INSERT INTO bd_erp_employee_dir_file_relationship SET ?';
    var insert = new Promise((r, j) => {
      db.query(q,file,(e, results, fields) => e ? j(e) : r({ results, fields }));
    });
    //console.log("Finished-meta_dir:"+id_pl);
  } catch (err) {
    console.log(err);
  }
}