backend/controllers/crmController.js

@@ -30,7 +30,6 @@ const redirectContactLinkCRM = require('../utils/redirectContactLinkCRM')
 const sfcase = require('../utils/sfCase')
 const sfCaseUpdate = require('../utils/sfCaseUpdate')
 const removeZeroInicial = require('../utils/removeZeroInicial')
-const getSalesforceUser = require('../utils/getSalesforceUser')
 
 
 const contactCreate = async (req, res) => {
@@ -170,11 +169,11 @@ const sfCreateCase = async (req, res) => {
 
 const sfUpdateCase = async (req, res) => {
 
-    const { companyId, caseId, agentEmail, case: caseUpdate } = req.body
+    const { companyId, caseId, case: caseUpdate } = req.body
 
     mustContainProperties(req, ['companyId', 'caseId', 'case'])
 
-    const resCaseUpdate = await sfCaseUpdate(companyId, caseId, caseUpdate, agentEmail)
+    const resCaseUpdate = await sfCaseUpdate(companyId, caseId, caseUpdate)
 
     if (resCaseUpdate) res.status(StatusCodes.OK).send()
 

backend/utils/getSalesforceUser.js

@@ -1,39 +0,0 @@
-const axios = require('axios')
-
-async function getSalesforceUser(token, email, url) {
-  try {
-
-    const parsedUrl = new URL(url);
-    const baseUrl = `${parsedUrl.protocol}//${parsedUrl.hostname}`;
-
-    const config = {
-      method: 'get',
-      url: `${baseUrl}/services/data/v59.0/query/?q=SELECT+Id+FROM+User+WHERE+Email='${email}'`,
-      headers: {
-        'Authorization': `Bearer ${token}`,
-        "Content-Type": "application/json"
-      }
-    }
-
-    const { data } = await axios(config)
-    return data
-  } catch (error) {
-    if (error.response) {
-      console.error('==================> getSalesforceUser Erro na resposta da API:', {
-        status: error.response.status,
-        data: error.response.data,
-      })
-    }
-    else if (error.request) {
-      console.error('==================> getSalesforceUser Nenhuma resposta recebida da API:', error.request)
-    }
-    else {
-      console.error('==================> getSalesforceUser Erro ao configurar a request:', error.message)
-    }
-  }
-}
-
-module.exports = getSalesforceUser
-
-
-

backend/utils/sfCase.js

@@ -3,30 +3,7 @@ const lookupContactByPhone = require('./lookupCRMContactByPhone')
 const findProperty = require('./findProperty')
 const axios = require('axios')
 const requestConfigHeader = require('./requestConfigHeader')
-const getSalesforceUser = require('./getSalesforceUser')
 
-/**
- * ===================== IMPLEMENTAÇÃO DA TASK: Criação de Caso Genérico via URA =====================
- *
- * Esta lógica foi implementada para atender à solicitação da cliente Suelen Araujo (Veste),
- * permitindo que o sistema CRM crie casos automaticamente mesmo quando o telefone de origem
- * da chamada recebida na URA não estiver vinculado a nenhuma conta (Account) no Salesforce.
- *
- * O que foi feito:
- * - Ao receber uma chamada, o sistema busca Account e Contact pelo telefone informado.
- * - Se encontrar uma Account (ID começa com '001'), inclui AccountId no payload do Case.
- * - Se encontrar um Contact (ID começa com '003'), inclui ContactId no payload do Case.
- * - Nunca envia um ID de Account no campo ContactId (evita erro de integridade).
- * - Se não encontrar Account nem Contact, o caso é criado sem esses campos (caso genérico).
- * - O restante do payload segue o template normalmente.
- * - O comportamento padrão para outros fluxos/canais é mantido.
- *
- * Resultado:
- * - O agente recebe o caso via OpenCTI, mesmo sem vínculo com Account.
- * - O fluxo está 100% aderente à regra de negócio definida na task.
- *
- * 
- */
 async function sfcase(companyId, crmPhone) {
 
     const crmFiles = await loadCRM(companyId)
@@ -46,44 +23,41 @@ async function sfcase(companyId, crmPhone) {
             let contact = await lookupContactByPhone(rest, authentication, crmPhone, companyId, {}, false)
 
             console.log('==========> contact: ', contact)
-            if (contact?.exist) {
-
-            } else {
-                console.log('Nenhum contato encontrado para o telefone:', crmPhone);
-            }
 
             if (!contact?.exist) {
                 console.log('===============> ContactExist: ', JSON.stringify(contact, null, 6))
-                // break; // Removido para permitir criação de caso genérico
+                break
             }
 
             const { contactId, created, accountId } = contact
 
             let { request, body } = createCase
 
+            console.log("====> request: ", request)
+            console.log("====> body: ", body)
 
             const { type, userName, passWord, token, crmClientId } = authentication
             const { requestContentType, requestEncoding, requestType, responseType, url } = request
 
             let config = await requestConfigHeader(url, crmPhone, requestType, requestContentType, type, userName, passWord, token, crmClientId, body, '', companyId)
 
+	        console.log("====> config", config)
+            console.log("====> accountId: ", accountId, " | contactId: ", contactId)
 
-
-            // Montagem do payload: só adiciona AccountId/ContactId se existirem e forem do tipo correto
-            let payload = { ...config.data };
-            if (accountId && accountId.startsWith('001')) {
-                payload.AccountId = accountId;
-            }
-            if (contactId && contactId.startsWith('003')) {
-                payload.ContactId = contactId;
-            }
-            config.data = payload;
+            const complementarInformations = {
+		AccountId: accountId
+	    }
+            if (!config?.data?.ContactId && !config?.data?.ContactId === "") {
+		complementarInformations.ContactId = contactId
+	    }
+            if (accountId && contactId)
+                config.data = {
+                    ...config.data, 
+		    ...complementarInformations
+                }
 
             console.log("====> create case request config: ", config)
 
-            // Log do payload que será enviado ao Salesforce
-            console.log('Payload enviado para o Salesforce:', JSON.stringify(config.data, null, 2));
-
             try {
                 const { data } = await axios(config)
 

backend/utils/sfCaseUpdate.js

@@ -3,10 +3,8 @@ const lookupContactByPhone = require('./lookupCRMContactByPhone')
 const findProperty = require('./findProperty')
 const axios = require('axios')
 const requestConfigHeader = require('./requestConfigHeader')
-const getSalesforceUser = require('./getSalesforceUser')
-const { getAccessToken } = require('./oauth2')
 
-async function sfCaseUpdate(companyId, caseId, caseUpdate, agentEmail = null) {
+async function sfCaseUpdate(companyId, caseId, caseUpdate) {
 
     const crmFiles = await loadCRM(companyId)
 
@@ -39,46 +37,15 @@ async function sfCaseUpdate(companyId, caseId, caseUpdate, agentEmail = null) {
                 }
             }
 
-            console.log("========> agentEmail: ", agentEmail)
-             
-            if (agentEmail) {
-
-                const accessToken = await getAccessToken(crmClientId, companyId)
- 
-                let userData = await getSalesforceUser(accessToken, agentEmail, url)  
-
-                console.log("========> userData: ", userData)
-
-                if (userData && userData?.records?.length > 0){ 
-                    config.headers = {...config.headers, ...{"Sforce-Auto-Assign": false}}
-                    config.data = { ...config.data, ...{ "OwnerId": userData.records[0].Id } } 
-                } 
-            }  
- 
             try {
-
-                // console.log("=========== payload that will be send to update the case: ", JSON.stringify(config, null, 6))
-
                 const { data } = await axios(config)
 
-                console.log('=============> Data from case updated: ', JSON.stringify(data, null, 6))
+                console.log('Data from case updated: ', JSON.stringify(data, null, 6))
 
                 return true
 
             } catch (error) {
-
-                if (error.response) {
-                    console.error('==================> sfCaseUpdate Erro na resposta da API:', {
-                        status: error.response.status,
-                        data: error.response.data,
-                    })
-                }
-                else if (error.request) {
-                    console.error('==================> sfCaseUpdate Nenhuma resposta recebida da API:', error.request)
-                }
-                else {
-                    console.error('==================> sfCaseUpdate Erro ao configurar a request:', error.message)
-                }
+                console.log(`CASE UPDATED ERROR: `, error)
             }
         }