src/Service/SalesforceService.php line 54

Open in your IDE?
  1. <?php 
  3. namespace App\Service;
  5. use App\Entity\Donation;
  6. use App\Service\ApiService;
  7. use App\Entity\FilmProject;
  8. use App\Entity\FilmProjectMember;
  9. use App\Entity\FilmProjectProgressReport;
  10. use App\Entity\FilmProjectProgressReportFile;
  11. use App\Entity\OrderBillingDetails;
  12. use App\Entity\OrderDetails;
  13. use App\Entity\User;
  14. use App\String\Constant;
  15. use App\Serializer\SalesforceObjectConverter;
  16. use App\Utility\SalesforceValues;
  17. use bjsmasth\Salesforce\Authentication\PasswordAuthentication;
  18. use bjsmasth\Salesforce\CRUD;
  19. use GuzzleHttp\Exception\ClientException;
  20. use Symfony\Component\DependencyInjection\ParameterBag\ContainerBagInterface;
  21. use Exception;
  23. final class SalesforceService extends ApiService
  24. {
  26.     private ContainerBagInterface $params;
  27.     private CRUD $salesforceCrud;
  28.     private SalesforceObjectConverter $salesforceObjectConverter;
  30.     public function __construct(ContainerBagInterface $params, SalesforceObjectConverter $salesforceObjectConverter)
  31.     {
  32.         $this->params = $params;
  33.         $this->salesforceObjectConverter = $salesforceObjectConverter;
  34.         $this->salesforceCrud = $this->authenticate();
  35.     }
  36.     
  37.     /**
  38.      * Setup access token and instance URL in session
  39.      *
  40.      * @return void
  41.      */
  42.     public function authenticate() 
  43.     {
  44.         $options = [
  45.             'grant_type' => 'password',
  46.             'client_id' => $this->params->get('app.salesforce_client_id'),
  47.             'client_secret' => $this->params->get('app.salesforce_client_secret'),
  48.             'username' => $this->params->get('app.salesforce_username'),
  49.             'password' => $this->params->get('app.salesforce_password'),
  50.         ];
  52.         $salesforce = new PasswordAuthentication($options);
  53.         $salesforce->setEndpoint(Constant::SALESFORCE_TOKEN_URL);
  54.         $salesforce->authenticate();
  56.         return new CRUD();
  57.     }
  59.     /**
  60.      * get contact ID if exists, return false if doesnt exists
  61.      *
  62.      * @param User $user
  63.      * @return string|void
  64.      */
  65.     public function getContact(string $email)
  66.     {
  67.         try {
  68.             $query = 'SELECT Id FROM Contact WHERE Email = \''. $email .'\'';
  69.             $result = $this->salesforceCrud->query($query);
  70.         } catch (ClientException $e) {
  71.             $response = $e->getResponse();
  72.             $responseBodyAsString = $response->getBody()->getContents();
  74.             $this->throwExceptionMessage($responseBodyAsString);
  75.             return null;
  76.         }
  78.         if ($result['totalSize'] <= 0) {
  79.             return false;
  80.         }
  82.         $id = $result['records'][0]['Id'];
  83.         return $id;
  84.     }
  86.      /**
  87.      * get contact ID if exists, return false if doesnt exists
  88.      *
  89.      * @param User $user
  90.      * @return string|void
  91.      */
  92.     public function getContactByEmailandFullName(string $firstName, string $lastName, string $email)
  93.     {
  94.         // $firstName = preg_replace('/[^a-zA-Z0-9\s]/', '\\\\$0', $firstName);
  95.         // $lastName = preg_replace('/[^a-zA-Z0-9\s]/', '\\\\$0', $lastName);
  97.         // $firstName = str_replace("'", "''", $firstName);
  98.         // $lastName = str_replace("'", "''", $lastName);
  100.         $firstName = str_replace("'", "\\'", $firstName);
  101.         $lastName  = str_replace("'", "\\'", $lastName);
  104.         try {
  105.             $query = 'SELECT Id FROM Contact WHERE Email = \''. $email .'\' AND FirstName = \''. $firstName .'\' AND LastName = \''. $lastName .'\'';
  106.             $result = $this->salesforceCrud->query($query);
  107.         } catch (ClientException $e) {
  108.             $response = $e->getResponse();
  109.             $responseBodyAsString = $response->getBody()->getContents();
  111.             $this->throwExceptionMessage($responseBodyAsString);
  112.             return null;
  113.         }
  115.         if ($result['totalSize'] <= 0) {
  116.             // Fallback: Last check by email 
  117.             // $id = $this->getContact($email);
  118.             // return $id ?? false;
  120.              // Removed fallback: do not check by email only
  121.             return false;
  122.         }
  124.         $id = $result['records'][0]['Id'];
  125.         return $id;
  126.     }
  128.     /**
  129.      * get contact ID if exists, return false if doesnt exists
  130.      *
  131.      * @param User $user
  132.      * @return string|void
  133.      */
  134.     public function getContactByFullName(string $firstName, string $lastName, string $email)
  135.     {
  136.         // $firstName = preg_replace('/[^a-zA-Z0-9\s]/', '\\\\$0', $firstName);
  137.         // $lastName = preg_replace('/[^a-zA-Z0-9\s]/', '\\\\$0', $lastName);
  139.         $firstName = str_replace("'", "''", $firstName);
  140.         $lastName = str_replace("'", "''", $lastName);
  141.         
  142.         $query = 'SELECT Id FROM Contact WHERE FirstName = \''. $firstName .'\' AND LastName = \''. $lastName .'\'';
  143.         $result = $this->salesforceCrud->query($query);
  145.         if ($result['totalSize'] <= 0) {
  146.             return false;
  147.         }
  149.         $id = $result['records'][0]['Id'];
  150.         if ($result['totalSize'] > 1) {
  151.             $id = $this->getContact($email);
  152.         }
  153.         return $id;
  154.     }
  157.     /**
  158.      * Create salesforce contact obj
  159.      *
  160.      * @param User $user
  161.      * @return string
  162.      */
  163.     public function createContact(User $user): string
  164.     {
  165.         $id = $this->getContact($user->getEmail());
  166.         // $id = $this->getContactByEmailandFullName($user->getFirstName(), $user->getLastName(), $user->getEmail());
  168.         if (!$id) {
  169.             $data =  $this->salesforceObjectConverter->convertUserToContact($user);
  170.         
  171.             $id = $this->salesforceCrud->create(Constant::CONTACT_OBJ, $data);  #returns id
  172.         }
  173.     
  174.         return $id;
  175.     }
  177.     /**
  178.      * Update Salesforce contact obj
  179.      *
  180.      * @param User $user
  181.      * @return void
  182.      */
  183.     public function updateContact(User $user)
  184.     {
  185.         $userInformation = $user->getUserInformation();
  186.         $id = $userInformation->getSalesforceId();
  188.         $data =  $this->salesforceObjectConverter->convertUserToContact($user);
  189.         
  190.         $this->salesforceCrud->update(Constant::CONTACT_OBJ, $id, $data);  #returns id
  191.     }
  193.     /**
  194.      * Create contact salesforce object from FilmProjectMember entity
  195.      *
  196.      * @param FilmProjectMember $filmProjectMember
  197.      * @return void|string
  198.      */
  199.     public function createContactFromFilmMember(FilmProjectMember $filmProjectMember)
  200.     {
  201.         $id = $this->getContact($filmProjectMember->getEmail());
  202.         // $id = $this->getContactByEmailandFullName($filmProjectMember->getName(), $filmProjectMember->getLastName(), $filmProjectMember->getEmail());
  204.         if (!$id) {
  205.             $data = $this->salesforceObjectConverter->convertFilmMemberToContact($filmProjectMember);            
  206.             try {
  207.                 $id = $this->salesforceCrud->create(Constant::CONTACT_OBJ, $data);  #returns id
  208.             } catch (ClientException $e) {
  209.                 $response = $e->getResponse();
  210.                 $responseBodyAsString = $response->getBody()->getContents();
  212.                 $this->throwExceptionMessage($responseBodyAsString);
  213.                 // var_dump($responseBodyAsString); exit();
  214.             }
  215.         }
  216.     
  217.         return $id;
  218.     }
  220.     /**
  221.      * Update contact salesforce object from FilmProjectMember entity
  222.      *
  223.      * @param FilmProjectMember $filmProjectMember
  224.      * @return void|string
  225.      */
  226.     public function updateContactFromFilmMember(FilmProjectMember $filmProjectMember)
  227.     {
  228.         $salesforceId = $filmProjectMember->getSalesforceId();
  230.         if (!$salesforceId) {
  231.             $data = $this->salesforceObjectConverter->convertFilmMemberToContact($filmProjectMember);            
  232.             try {
  233.                 $this->salesforceCrud->update(Constant::CONTACT_OBJ, $salesforceId, $data);  #returns id
  234.             } catch (ClientException $e) {
  235.                 $response = $e->getResponse();
  236.                 $responseBodyAsString = $response->getBody()->getContents();
  238.                 $this->throwExceptionMessage($responseBodyAsString);
  239.             }
  240.         }
  241.     }
  243.     /**
  244.      * Create salesforce contact obj
  245.      *
  246.      * @param User $user
  247.      * @return string
  248.      */
  249.     public function createGuestContactFromOrderDetails(OrderBillingDetails $orderBillingDetails): ?string
  250.     {
  251.         // $id = $this->getContactByEmailandFullName($orderBillingDetails->getFirstName(), $orderBillingDetails->getLastName(), $orderBillingDetails->getEmailAddress()) ?? $this->getContact($orderBillingDetails->getEmailAddress());
  252.         $id = $this->getContactByEmailandFullName($orderBillingDetails->getFirstName(), $orderBillingDetails->getLastName(), $orderBillingDetails->getEmailAddress());
  254.         if (!$id) {
  255.             $data =  $this->salesforceObjectConverter->convertBillingDetailsToContact($orderBillingDetails);
  257.             $id = $this->salesforceCrud->create(Constant::CONTACT_OBJ, $data);  #returns id
  258.         }
  259.     
  260.         return $id;
  261.     }
  263.     /**
  264.      * Create account salesforce object from film member on film application
  265.      *
  266.      * @return void|string
  267.      */
  268.     public function createAccount(string $organisationName, string $primaryContactSfId = null)
  269.     {
  270.         if ($organisationName) {
  271.             $id = $this->getAccount($organisationName);
  273.             if (!$id) {
  274.                 $data = [
  275.                     'Name' => $organisationName,
  276.                     'RecordTypeId' => Constant::SALESFORCE_ORGANISATION_FILMMAKER,
  277.                 ];
  279.                 if ($primaryContactSfId) {
  280.                     $data['npe01__One2OneContact__c'] = $primaryContactSfId;
  281.                 }
  282.                 
  283.                 $id = $this->salesforceCrud->create(Constant::ACCOUNT_OBJ, $data);  #returns id
  284.             } else {
  285.                 if ($primaryContactSfId) {
  286.                     // $data['npe01__One2OneContact__c'] = $primaryContactSfId;
  287.                     // $statusCode = $this->salesforceCrud->update(Constant::ACCOUNT_OBJ, $id, $data);  // Update Account
  288.                     $data = [
  289.                         'npsp__Primary_Affiliation__c' => $id
  290.                     ];
  291.                     
  292.                     $this->salesforceCrud->update(Constant::CONTACT_OBJ, $primaryContactSfId, $data); // Update contact affiliation to account
  293.                 }
  294.             }
  295.             
  296.             return $id;
  297.         }
  299.         return false;
  300.     }
  302.     /**
  303.      * Create account salesforce object from film member on film application
  304.      *
  305.      * @return void|string
  306.      */
  307.     public function createAccountWithOrderDetails(string $organisationName, ?OrderDetails $orderDetails = null, ?string $primaryContactSfId = null)
  308.     {
  309.         if ($organisationName) {
  310.             $id = $this->getAccount($organisationName);
  312.             $data = [];
  313.             if ($orderDetails) {
  314.                 $orderBillingDetails = $orderDetails->getOrderBillingDetails();
  315.                 if ($orderBillingDetails) {
  316.                     $data['Email__c'] = $orderBillingDetails->getEmailAddress();
  317.                     $data['Phone'] = $orderBillingDetails->getPhoneNumber();
  318.                     $data['BillingStreet'] = $orderBillingDetails->getStreet();
  319.                     $data['BillingState'] = $orderBillingDetails->getState();
  320.                     $data['BillingPostalCode'] = $orderBillingDetails->getPostcode();
  321.                     $data['BillingCountry'] = $orderBillingDetails->getCountry();
  322.                     $data['BillingCity'] = $orderBillingDetails->getSuburb();
  323.                 }
  324.             }
  326.             if (!$id) {
  327.                 $data['Name'] = $organisationName;
  328.                 $data['RecordTypeId'] = Constant::SALESFORCE_ORGANISATION_FILMMAKER;
  330.                 if ($primaryContactSfId) {
  331.                     $data['npe01__One2OneContact__c'] = $primaryContactSfId;
  332.                 }
  333.                 // TODO: IF not exists, create account with primary contact
  334.                 $id = $this->salesforceCrud->create(Constant::ACCOUNT_OBJ, $data);  #returns id
  335.             } else {
  336.                 // TODO: IF exists, update account with affiliate contact
  337.                 if ($primaryContactSfId) {
  338.                     // Update organisation salesforce object
  339.                     
  340.                     try {
  341.                         $data['npe01__One2OneContact__c'] = $primaryContactSfId;
  342.                         $statusCode = $this->salesforceCrud->update(Constant::ACCOUNT_OBJ, $id, $data);  // Update Account
  343.                     } catch (ClientException $e) {
  345.                     }
  346.                     // Update Contact Object
  347.                     try {
  348.                         $contactData = ['npsp__Primary_Affiliation__c' => $id];
  349.                         $this->salesforceCrud->update(Constant::CONTACT_OBJ, $primaryContactSfId, $contactData); // Update contact affiliation to account
  350.                     } catch (ClientException $e) {
  352.                     }
  353.                 }
  354.             }
  355.             
  356.             return $id;
  357.         }
  359.         return false;
  360.     }
  363.     /**
  364.      * get organisation ID if exists, return false if doesnt exists
  365.      *
  366.      * @param User $user
  367.      * @return void
  368.      */
  369.     public function getAccount(string $organisationName)
  370.     {
  371.         $organisationName = addslashes($organisationName);
  372.         $query = 'SELECT Id FROM Account WHERE Name = \''. $organisationName .'\'';
  373.         $result = $this->salesforceCrud->query($query);
  375.         if ($result['totalSize'] <= 0) {
  376.             return false;
  377.         }
  379.         $id = $result['records'][0]['Id'];
  380.         return $id;
  381.     }
  383.     /**
  384.      * Create account salesforce object from film member on film application
  385.      *
  386.      * @return void|string
  387.      */
  388.     public function createAccountFromFilmProjectMember(FilmProjectMember $filmProjectMember)
  389.     {
  390.         if ($organisationName = $filmProjectMember->getOrganisation()) {
  391.             $id = $this->getAccount($organisationName);
  393.             if (!$id) {
  394.                 $data = [
  395.                     'Name' => $organisationName,
  396.                     'RecordTypeId' => Constant::SALESFORCE_ORGANISATION_FILMMAKER,
  397.                 ];
  398.                 
  399.                 $id = $this->salesforceCrud->create(Constant::ACCOUNT_OBJ, $data);  #returns id
  400.             }
  401.         
  402.             return $id;
  403.         }
  405.         return false;
  406.     }
  408.     /**
  409.      * Create campaign object from film project entity
  410.      *
  411.      * @param FilmProject $filmProject
  412.      * @return void|string
  413.      */
  414.     public function createCampaign(FilmProject $filmProject)
  415.     {
  416.         $id = null;
  417.         if (!empty($filmProject->getOldWordpressId())) {
  418.             $id = $this->getCampaignByWordpressId($filmProject->getOldWordpressId());
  419.         } 
  421.         if (!$id) {
  422.             $data = $this->salesforceObjectConverter->convertProjectToCampaign($filmProject);
  423.             try {
  424.                 $id = $this->salesforceCrud->create(Constant::CAMPAIGN_OBJ, $data); 
  425.             } catch (ClientException $e) {
  426.                 $response = $e->getResponse();
  427.                 $responseBodyAsString = $response->getBody()->getContents();
  429.                 $this->throwExceptionMessage($responseBodyAsString);
  430.                 return null;
  431.             }
  432.         }
  433.     
  434.         return $id;
  435.     }
  437.     /**
  438.      * Update campaign object from film project entity
  439.      *
  440.      * @param FilmProject $filmProject
  441.      * @return void
  442.      */
  443.     public function updateCampaign(FilmProject $filmProject)
  444.     {
  445.         $salesforceId = $filmProject->getSalesforceId();
  447.         $data = $this->salesforceObjectConverter->convertProjectToCampaign($filmProject, true);
  448.         try {
  449.             $id = $this->salesforceCrud->update(Constant::CAMPAIGN_OBJ, $salesforceId, $data); 
  450.         } catch (ClientException $e) {
  451.             $response = $e->getResponse();
  452.             $responseBodyAsString = $response->getBody()->getContents();
  454.             $this->throwExceptionMessage($responseBodyAsString);
  455.             var_dump($responseBodyAsString); exit();
  456.         }
  457.     
  458.         return $id;
  459.     }
  461.     public function updateCampaignAdmin(FilmProject $filmProject) {
  462.         $salesforceId = $filmProject->getSalesforceId();
  464.         $data = [
  465.             'Application_Fee_Paid__c' => 0,
  466.             'Application_Fee_Amount__c' => 0,
  467.         ];
  469.         try {
  470.             $id = $this->salesforceCrud->update(Constant::CAMPAIGN_OBJ, $salesforceId, $data); 
  471.         } catch (ClientException $e) {
  472.             $response = $e->getResponse();
  473.             $responseBodyAsString = $response->getBody()->getContents();
  475.             $this->throwExceptionMessage($responseBodyAsString);
  476.             var_dump($responseBodyAsString); exit();
  477.         }
  479.         return $id;
  480.     }
  482.     /**
  483.      * Update campaign object to be approved
  484.      *
  485.      * @param FilmProject $filmProject
  486.      * @return void
  487.      */
  488.     public function approveCampaign(FilmProject $filmProject) 
  489.     {
  490.         $salesforceId = $filmProject->getSalesforceId();
  492.         $updatedData = [
  493.             'Project_Approved__c' => 1,
  494.             // 'Project_Approval_Date__c' => (new \DateTime('today'))->format('Y-m-d'),
  495.             'Wordpress_ID__c' => $filmProject->getWordpressId() ? $filmProject->getWordpressId() : '',
  496.             // 'Wordpress_ID_2023__c' => $filmProject->getWordpressId() ? $filmProject->getWordpressId() : '',
  497.             'IsActive' => 1,
  498.             'Status' => 'Completed'
  499.         ];
  501.         
  502.         if ($filmProject->getOldWordpressId()) { // If an old migrated project
  503.             $updatedData['Wordpress_ID__c'] = $filmProject->getOldWordpressId();
  504.         } else { // New project
  505.             $updatedData['Project_Approval_Date__c'] = (new \DateTime('today'))->format('Y-m-d');
  506.         }
  508.         $statusCode =  $this->salesforceCrud->update(Constant::CAMPAIGN_OBJ, $salesforceId, $updatedData);
  509.     }
  511.     /**
  512.      * Updated campaign object to be declined
  513.      *
  514.      * @param FilmProject $filmProject
  515.      * @return void
  516.      */
  517.     public function declineCampaign(FilmProject $filmProject)
  518.     {
  519.         $salesforceId = $filmProject->getSalesforceId();
  521.         $updatedData = [
  522.             'Project_Approved__c' => 0,
  523.             'Rejected_Date__c' => (new \DateTime('today'))->format('Y-m-d'),
  524.             'Resubmit__c' => 0,
  525.         ];
  526.         $statusCode =  $this->salesforceCrud->update(Constant::CAMPAIGN_OBJ, $salesforceId, $updatedData);
  527.     }
  529.     /**
  530.      * Updated campaign object to be asked to resubmit
  531.      *
  532.      * @param FilmProject $filmProject
  533.      * @return void
  534.      */
  535.     public function resubmitCampaign(FilmProject $filmProject)
  536.     {
  537.         $salesforceId = $filmProject->getSalesforceId();
  539.         $updatedData = [
  540.             'Project_Approved__c' => 0,
  541.             // 'Rejected_Date__c' => (new \DateTime('today'))->format('Y-m-d'),
  542.             'Status' => 'In Progress',
  543.             'Resubmit__c' => 1,
  544.         ];
  545.         $statusCode =  $this->salesforceCrud->update(Constant::CAMPAIGN_OBJ, $salesforceId, $updatedData);
  546.     }
  548.     /**
  549.      * Create Film Application Transaction
  550.      *
  551.      * @param FilmProject $filmProject
  552.      * @param OrderDetails $orderDetails
  553.      * @return string
  554.      */
  555.     public function createFilmApplicationTransaction(FilmProject $filmProject)
  556.     {
  557.         $orderDetails = $filmProject->getOrderDetails();
  559.         $projectOwner = $filmProject->getOwner();
  560.         $accountName = sprintf('%s (%s) Household', $projectOwner->getLastName(), $projectOwner->getFirstName());
  561.         
  562.         $ownerAccountId = "";
  563.         $ownerSfId = $this->getContact($projectOwner->getEmail());
  564.         if ($ownerSfId) {
  565.             $ownerAccountId = $this->createAccountWithOrderDetails($accountName, $orderDetails, $ownerSfId);
  566.         } else {
  567.             $ownerAccountId = $this->createAccountWithOrderDetails($accountName, $orderDetails);
  568.         }
  570.         $data = [
  571.             'RecordTypeId' => Constant::SALESFORCE_TRANSACTION_TRANSACTION,
  572.             'Name' => 'Film Application - '. $filmProject->getTitle(),
  573.             'AccountId' =>  $ownerAccountId,
  574.             // 'npsp__Primary_Contact__c' => $projectOwner->getUserInformation()->getSalesforceId(),
  575.             'LeadSource' => 'Website',
  576.             'Type' => 'Film Application Fee',
  577.             'StageName' => 'Closed',
  578.             'CloseDate' => (new \DateTime('now'))->format('Y-m-d'),
  579.             'Probability' => 100,
  580.             'DAF_retention__c' => '100%',
  581.             'Consent_to_be_identified__c' => 'Does NOT consent',
  582.             'Share_details__c' => 'DOESN\'T consent',
  583.             'Payment_Type__c' => 'Credit Card',
  584.             // 'Order_ID__c' => $orderDetails->getInvoiceNumber(),
  585.             'Order_ID__c' => 'MW'. $orderDetails->getId(),
  586.             'Description' => $filmProject->getTitle(),
  587.             'Amount' => number_format(((float)$orderDetails->getTotal() / 100), 2, '.', ''),
  588.             // 'npe01__Amount_Written_Off__c' => 0,
  589.             // 'npe01__Amount_Outstanding__c' => 0,
  590.             'npsp__Acknowledgment_Status__c' => 'Do Not Acknowledge',
  591.             'CampaignId' =>  ($filmProject->getSalesforceId()) ? $filmProject->getSalesforceId() : '',
  592.         ];
  594.         
  595.         if ($ownerSfId) {
  596.             $data['npsp__Primary_Contact__c'] = $ownerSfId;
  597.         }
  599.         try {
  600.             $id = $this->salesforceCrud->create(Constant::TRANSACTION_OBJ, $data);
  601.         } catch (ClientException $e) {
  602.             $response = $e->getResponse();
  603.             $responseBodyAsString = $response->getBody()->getContents();
  605.             $this->throwExceptionMessage($responseBodyAsString);
  606.             var_dump($responseBodyAsString); exit();
  607.         }
  609.         return $id;
  610.     }
  612.     /**
  613.      * Create Donation Transaction
  614.      *
  615.      * @param Donation $donation
  616.      * @param OrderDetails $orderDetails
  617.      * @return void
  618.      */
  619.     public function createDonationTransaction(Donation $donation)
  620.     {
  621.         $orderDetails = $donation->getOrderDetails();
  622.         $filmProject = $donation->getFilmProject();
  623.         $orderBillingDetails = $orderDetails->getOrderBillingDetails();
  624.         $accountName = $orderBillingDetails->getOrganisation();
  626.         $user = $orderDetails->getUser();
  627.         $salesforceDonatorId = $user ? ($user->isAdmin() ? $this->createGuestContactFromOrderDetails($orderBillingDetails) : $user->getUserInformation()->getSalesforceId()) : $this->createGuestContactFromOrderDetails($orderBillingDetails);
  629.         if (empty($accountName)) {
  630.             $accountName = sprintf('%s (%s) Household', $orderBillingDetails->getLastName(), $orderBillingDetails->getFirstName());
  631.         }
  632.         $ownerAccountId = $this->createAccountWithOrderDetails($accountName, $orderDetails, $salesforceDonatorId); // Get owner Id
  634.         $data = [
  635.             'RecordTypeId' => Constant::SALESFORCE_TRANSACTION_TRANSACTION,
  636.             'Name' => 'Donation - '. $filmProject->getTitle(),
  637.             'AccountId' =>  $ownerAccountId,
  638.             'npsp__Primary_Contact__c' => $salesforceDonatorId,
  639.             'LeadSource' => 'Website',
  640.             'Type' => 'Film Donation',
  641.             'StageName' => 'Closed',
  642.             'CloseDate' => (new \DateTime('now'))->format('Y-m-d'),
  643.             'Probability' => 100,
  644.             'DAF_retention__c' => '5%',
  645.             'Consent_to_be_identified__c' =>  ($donation->isIsOrganisationConsent()) ? 'Does consent' : 'Does NOT consent',
  646.             'Share_details__c' => ($donation->isIsContactShared()) ? 'Does consent' : 'DOESN\'T consent',
  647.             'Payment_Type__c' => 'Credit Card',
  648.             'Order_ID__c' => 'MW'. $orderDetails->getId(),
  649.             'Description' => 'Donation for project: '. $filmProject->getTitle(),
  650.             'Amount' => number_format(((float)($orderDetails->getTotal() - $donation->getSupportdaf()) / 100), 2, '.', ''),
  651.             // 'npe01__Amount_Written_Off__c' => 0,
  652.             // 'npe01__Amount_Outstanding__c' => 0,
  653.             'npsp__Acknowledgment_Status__c' => 'Do Not Acknowledge',
  654.             'CampaignId' => $filmProject->getSalesforceId(),
  655.             // 'WordPress_ID__c' => $filmProject->getWordpressId(),
  656.             // 'Wordpress_ID_from_2023__c' => $filmProject->getWordpressId(),
  657.         ];
  659.         // Check payment details
  660.         $paymentDetails = $orderDetails->getPaymentDetails();
  661.         if ($paymentDetails) {
  662.             if ($paymentDetails->getType() == Constant::PAYMENT_EFT) {
  663.                 $data['Payment_Type__c'] = Constant::PAYMENT_EFT;
  664.             }
  665.         }
  667.         // Change close date
  668.         if ($orderDate = $orderDetails->getCreatedAt()) {
  669.             $data['CloseDate'] = $orderDate->format('Y-m-d');
  670.         }
  672.         try {
  673.             $id = $this->salesforceCrud->create(Constant::TRANSACTION_OBJ, $data);
  674.         } catch (ClientException $e) {
  675.             $response = $e->getResponse();
  676.             $responseBodyAsString = $response->getBody()->getContents();
  678.             $this->throwExceptionMessage($responseBodyAsString);
  679.             var_dump($responseBodyAsString); exit();
  680.         }
  681.     
  682.         return $id;
  683.     }
  685.      /**
  686.      * Create DAF Donation Transaction
  687.      *
  688.      * @param Donation $donation
  689.      * @param OrderDetails $orderDetails
  690.      * @return string
  691.      */
  692.     public function createDafDonationTransaction(Donation $donation, $popUpSalesforceId = null)
  693.     {
  694.         $orderDetails = $donation->getOrderDetails();
  696.         $user = $orderDetails->getUser();
  697.         $orderBillingDetails = $orderDetails->getOrderBillingDetails();
  698.         $accountName = $orderBillingDetails->getOrganisation();
  699.         
  700.         $salesforceDonatorId = null;
  701.         if ($user) { 
  702.             $salesforceDonatorId = $user->getUserInformation()->getSalesforceId();
  703.         } else { // GUEST
  704.             $salesforceDonatorId = $this->createGuestContactFromOrderDetails($orderBillingDetails);
  705.         }
  707.         if (empty($accountName)) {
  708.             $accountName = sprintf('%s (%s) Household', $orderBillingDetails->getLastName(), $orderBillingDetails->getFirstName());
  709.         }
  710.         $ownerAccountId = $this->createAccountWithOrderDetails($accountName, $orderDetails, $salesforceDonatorId); // Get owner Id
  712.         $data = [
  713.             'RecordTypeId' => Constant::SALESFORCE_TRANSACTION_TRANSACTION,
  714.             'Name' => 'Donation - Support Documentary Australia',
  715.             'AccountId' =>  $ownerAccountId,
  716.             'npsp__Primary_Contact__c' => $salesforceDonatorId,
  717.             'LeadSource' => 'Website',
  718.             'Type' => 'Donation',
  719.             'StageName' => 'Closed',
  720.             'CloseDate' => (new \DateTime('now'))->format('Y-m-d'),
  721.             'Probability' => 100,
  722.             'DAF_retention__c' => '100%',
  723.             'Consent_to_be_identified__c' =>  ($donation->isIsOrganisationConsent()) ? 'Does consent' : 'Does NOT consent',
  724.             'Share_details__c' => ($donation->isIsContactShared()) ? 'Does consent' : 'DOESN\'T consent',
  725.             'Payment_Type__c' => 'Credit Card',
  726.             'Order_ID__c' => 'MW'. $orderDetails->getId(),
  727.             'Description' => 'Support Documentary Australia',
  728.             'Wordpress_ID_from_2023__c' => '35040', // Latest Support Documentary Australia Project
  729.             'Amount' => number_format(((float)$donation->getSupportdaf() / 100), 2, '.', ''),
  730.             // 'npe01__Amount_Written_Off__c' => 0,
  731.             // 'npe01__Amount_Outstanding__c' => 0,
  732.             'npsp__Acknowledgment_Status__c' => 'Do Not Acknowledge',
  733.         ];
  735.         if (!$popUpSalesforceId) {
  736.             if ($donation->getFilmProject()) {
  737.                 $filmProject = $donation->getFilmProject();
  738.                 $data['CampaignId'] = $filmProject->getSalesforceId();
  740.                 if ($filmProject->isIsDafCore() && $filmProject->isIsDafProgram()) {
  741.                     $data['Name'] = 'Donation - '. $filmProject->getTitle();
  742.                     $data['Description'] = 'Donation - '. $filmProject->getTitle();
  743.                     $data['Wordpress_ID_from_2023__c'] = $filmProject->getWordpressId();
  744.                     $data['Amount'] = number_format(((float)$orderDetails->getTotal() / 100), 2, '.', '');
  745.                 }
  746.             }
  747.         } else {
  748.             $data['CampaignId'] = $popUpSalesforceId;
  749.             $data['Wordpress_ID_from_2023__c'] = '17135'; // hardcoded latest popup filmproject
  750.             $data['Name'] = 'Donation - Documentary Australia\'s core operations_POP-UP';
  751.         }
  753.         // Check payment details
  754.         $paymentDetails = $orderDetails->getPaymentDetails();
  755.         if ($paymentDetails) {
  756.             if ($paymentDetails->getType() == Constant::PAYMENT_EFT) {
  757.                 $data['Payment_Type__c'] = Constant::PAYMENT_EFT;
  758.             }
  759.         }
  761.         // Change close date
  762.         if ($orderDate = $orderDetails->getCreatedAt()) {
  763.             $data['CloseDate'] = $orderDate->format('Y-m-d');
  764.         }
  766.         try {
  767.             $id = $this->salesforceCrud->create(Constant::TRANSACTION_OBJ, $data);
  768.         } catch (ClientException $e) {
  769.             $response = $e->getResponse();
  770.             $responseBodyAsString = $response->getBody()->getContents();
  772.             $this->throwExceptionMessage($responseBodyAsString);
  773.             var_dump($responseBodyAsString); exit();
  774.         }
  775.     
  776.         return $id;
  777.     }
  779.     /**
  780.      * Updated transaction details
  781.      *
  782.      * @param OrderDetails $orderDetails
  783.      * @return void
  784.      */
  785.     public function updateTransaction(OrderDetails $orderDetails)
  786.     {
  787.         $salesforceId = $orderDetails->getSalesforceId();
  789.         if (empty($salesforceId)) {
  790.             return;
  791.         }
  793.         $updatedData = [
  794.             'Amount' => $orderDetails->getTotal() / 100,
  795.         ];
  797.         if ($donation = $orderDetails->getDonation()) {
  798.             $filmProject = $donation->getFilmProject();
  800.             $updatedData = [
  801.                 'Name' => 'Donation - '. $filmProject->getTitle(),
  802.                 'Amount' => $orderDetails->getTotal() / 100,
  803.                 'CampaignId' => $filmProject->getSalesforceId(),
  804.                 'StageName' => 'Closed',
  805.                 'npsp__Acknowledgment_Status__c' => 'Do Not Acknowledge',
  806.             ];
  807.     
  808.         }
  810.         try {
  811.             $statusCode =  $this->salesforceCrud->update(Constant::TRANSACTION_OBJ, $salesforceId, $updatedData);
  812.         } catch (ClientException $e) {
  813.             $response = $e->getResponse();
  814.             $responseBodyAsString = $response->getBody()->getContents();
  816.             $this->throwExceptionMessage("Opportunity object on Salesforce is not found. Please contact admin for more information.");
  817.             var_dump($responseBodyAsString); exit();
  818.         }
  820.         // Update payment amount as well
  821.         $paymentId = $this->getPaymentByTransactionId($salesforceId);
  822.         if ($paymentId) {
  823.             $this->updatePaymentAmountReceived($paymentId, $orderDetails->getTotal() / 100);
  824.         }
  825.     }
  827.      /**
  828.      * Updated campaign object to be refunded
  829.      *
  830.      * @param OrderDetails $orderDetails
  831.      * @return void
  832.      */
  833.     public function refundTransaction(OrderDetails $orderDetails)
  834.     {
  835.         $salesforceId = $orderDetails->getSalesforceId();
  837.         if (empty($salesforceId)) {
  838.             return;
  839.         }
  841.         $updatedData = [
  842.             'Amount' => 0,
  843.             'Refunded__c' => 1,
  844.         ];
  845.         try {
  846.             $statusCode =  $this->salesforceCrud->update(Constant::TRANSACTION_OBJ, $salesforceId, $updatedData);
  847.         } catch (ClientException $e) {
  848.             $response = $e->getResponse();
  849.             $responseBodyAsString = $response->getBody()->getContents();
  851.             $this->throwExceptionMessage($responseBodyAsString);
  852.             var_dump($responseBodyAsString); exit();
  853.         }
  855.         // Update payment amount as well
  856.         $paymentId = $this->getPaymentByTransactionId($salesforceId);
  857.         if ($paymentId) {
  858.             $this->updatePaymentAmountRefund($paymentId);
  859.         }
  860.     }
  862.     /**
  863.      * Updated campaign object to be refunded
  864.      *
  865.      * @param OrderDetails $orderDetails
  866.      * @return void
  867.      */
  868.     public function refundDafSupportTransaction(Donation $donation)
  869.     {
  870.         $salesforceId = $donation->getSupportDafSalesforce();
  872.         if (empty($salesforceId)) {
  873.             return;
  874.         }
  876.         $updatedData = [
  877.             'Amount' => 0,
  878.             'Refunded__c' => 1,
  879.         ];
  880.         try {
  881.             $statusCode =  $this->salesforceCrud->update(Constant::TRANSACTION_OBJ, $salesforceId, $updatedData);
  882.         } catch (ClientException $e) {
  883.             $response = $e->getResponse();
  884.             $responseBodyAsString = $response->getBody()->getContents();
  886.             $this->throwExceptionMessage($responseBodyAsString);
  887.             var_dump($responseBodyAsString); exit();
  888.         }
  890.         // Update payment amount as well
  891.         $paymentId = $this->getPaymentByTransactionId($salesforceId);
  892.         if ($paymentId) {
  893.             $this->updatePaymentAmountRefund($paymentId);
  894.         }
  895.     }
  897.     /**
  898.      * get campaign with wordpress ID
  899.      *
  900.      * @param User $user
  901.      * @return void
  902.      */
  903.     public function getCampaignByWordpressId(int $id)
  904.     {
  905.         $query = 'SELECT Id FROM Campaign WHERE Wordpress_ID__c = \''. $id .'\'';
  906.         $result = $this->salesforceCrud->query($query);
  908.         if ($result['totalSize'] <= 0) {
  909.             return false;
  910.         }
  912.         $id = $result['records'][0]['Id'];
  913.         return $id;
  914.     }
  916.     /**
  917.      * Create campaign object from film project entity
  918.      *
  919.      * @param FilmProject $filmProject
  920.      * @return void|string
  921.      */
  922.     public function updateCampaignByPayload($salesforceId, array $payLoad)
  923.     {
  924.         try {
  925.             $id = $this->salesforceCrud->update(Constant::CAMPAIGN_OBJ, $salesforceId, $payLoad); 
  926.         } catch (ClientException $e) {
  927.             $response = $e->getResponse();
  928.             $responseBodyAsString = $response->getBody()->getContents();
  930.             var_dump($salesforceId .' is having error'); exit();
  932.             $this->throwExceptionMessage($responseBodyAsString);
  933.             return null;
  934.         }
  935.     
  936.         return $id;
  937.     }
  939.     /**
  940.      * get contact ID if exists, return false if doesnt exists
  941.      *
  942.      * @param User $user
  943.      * @return string|void
  944.      */
  945.     public function getContactBySalesforceId(string $id)
  946.     {
  947.         $query = 'SELECT Id FROM Contact WHERE Id = \''. $id .'\'';
  948.         $result = $this->salesforceCrud->query($query);
  950.         if ($result['totalSize'] <= 0) {
  951.             return false;
  952.         }
  954.         $id = $result['records'][0]['Id'];
  955.         return $id;
  956.     }
  958.     /**
  959.      * Get Payment ID by Transaction ID
  960.      *
  961.      * @param string $id
  962.      * @return false|String
  963.      */
  964.     public function getPaymentByTransactionId(string $id) 
  965.     {
  966.         $query = 'SELECT Id FROM npe01__OppPayment__c WHERE npe01__Opportunity__c = \''. $id .'\'';
  967.         try {
  968.             $result = $this->salesforceCrud->query($query);
  969.         } catch (ClientException $e) {
  970.             return false;
  971.         }
  973.         if ($result['totalSize'] <= 0) {
  974.             return false;
  975.         }
  977.         $id = $result['records'][0]['Id'];
  978.         return $id;
  979.     }
  981.     /**
  982.      * Update campaign object to be approved
  983.      *
  984.      * @param String $salesforceId
  985.      * @return void
  986.      */
  987.     public function updatePaymentAmountReceived(String $salesforceId, $amount) 
  988.     {
  989.         $updatedData = [
  990.             'npe01__Payment_Amount__c' => $amount,
  991.         ];
  992.         $statusCode =  $this->salesforceCrud->update('npe01__OppPayment__c', $salesforceId, $updatedData);
  993.     }
  995.     /**
  996.      * Update campaign object to be approved
  997.      *
  998.      * @param String $salesforceId
  999.      * @return void
  1000.      */
  1001.     public function updatePaymentAmountRefund(String $salesforceId) 
  1002.     {
  1003.         $updatedData = [
  1004.             'npe01__Payment_Amount__c' => number_format(0, 2, '.', ''),
  1005.         ];
  1006.         $statusCode =  $this->salesforceCrud->update('npe01__OppPayment__c', $salesforceId, $updatedData);
  1007.     }
  1009.     public function getSalesforceCrud() {
  1010.         return $this->salesforceCrud;
  1011.     }
  1013.     public function deleteContact(User $user)
  1014.     {
  1015.         $userInformation = $user->getUserInformation();
  1016.         $id = $userInformation->getSalesforceId();
  1018.         try {
  1019.             $this->salesforceCrud->delete(Constant::CONTACT_OBJ, $id);  #returns id
  1020.         } catch(Exception $e) {
  1021.             return;
  1022.         }
  1023.     }
  1025.     public function replaceWordpressIds(FilmProject $filmProject) 
  1026.     {
  1027.         $salesforceId = $filmProject->getSalesforceId();
  1029.         $updatedData = [
  1030.             'Wordpress_ID__c' => $filmProject->getOldWordpressId() ? $filmProject->getOldWordpressId() : '',
  1031.             // 'Wordpress_ID_2023__c' => $filmProject->getWordpressId() ? $filmProject->getWordpressId() : '',
  1032.         ];
  1034.         $statusCode =  $this->salesforceCrud->update(Constant::CAMPAIGN_OBJ, $salesforceId, $updatedData);
  1035.     }
  1038.     public function updateProgressReport(FilmProjectProgressReport $progressReport) {
  1039.         $filmProject = $progressReport->getFilmProject();
  1040.         $salesforceId = $filmProject->getSalesforceId();
  1042.         $updatedData =  $this->salesforceObjectConverter->convertProgressReportToCampaign($progressReport);
  1043.        
  1044.         $statusCode =  $this->salesforceCrud->update(Constant::CAMPAIGN_OBJ, $salesforceId, $updatedData);
  1045.     }
  1047.     /**
  1048.      * Creates content version data to upload file to Salesforce
  1049.      */
  1050.     public function createContentVersionData(FilmProjectProgressReportFile $progressReportFile) {
  1051.         $data = [
  1052.             'Title' => $progressReportFile->getFileName(),
  1053.             'PathOnClient' => $progressReportFile->getFileName(),
  1054.             'VersionData' => Constant::LOCALHOST_URL . '/uploads/progress_reports/'. $progressReportFile->getFileName(),
  1055.         ];
  1056.         
  1057.         $id = $this->salesforceCrud->create('ContentVersion', $data);  #returns id
  1059.         return $id;
  1060.     }
  1062.     /**
  1063.      * Gets Document ID from uploaded ContentVersionData
  1064.      */
  1065.     public function getDocumentIdFromContentVersion(String $contentVersionId) {
  1066.         $query = 'SELECT ContentDocumentId FROM ContentVersion WHERE Id = \''. $contentVersionId .'\'';
  1067.         try {
  1068.             $result = $this->salesforceCrud->query($query);
  1069.         } catch (ClientException $e) {
  1070.             return false;
  1071.         }
  1073.         if ($result['totalSize'] <= 0) {
  1074.             return false;
  1075.         }
  1077.         $id = $result['records'][0]['ContentDocumentId'];
  1078.         return $id;
  1079.     }
  1081.     /**
  1082.      * Links between the uplaoded file and campaign ID on Salesforce end
  1083.      */
  1084.     public function createDocumentLink(String $contentDocumentId, String $campaignId) {
  1085.         $data = [
  1086.             'ContentDocumentId' => $contentDocumentId,
  1087.             'LinkedEntityId' => $campaignId,
  1088.             'ShareType' => 'V', // Viewer
  1089.         ];
  1090.         
  1091.         $id = $this->salesforceCrud->create('ContentDocumentLink', $data);  #returns id
  1092.     }
  1093. }