src/Service/SalesforceService.php line 30

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.         try {
  101.             $query = 'SELECT Id FROM Contact WHERE Email = \''. $email .'\' AND FirstName = \''. $firstName .'\' AND LastName = \''. $lastName .'\'';
  102.             $result = $this->salesforceCrud->query($query);
  103.         } catch (ClientException $e) {
  104.             $response = $e->getResponse();
  105.             $responseBodyAsString = $response->getBody()->getContents();
  107.             $this->throwExceptionMessage($responseBodyAsString);
  108.             return null;
  109.         }
  111.         if ($result['totalSize'] <= 0) {
  112.             // Fallback: Last check by email 
  113.             $id = $this->getContact($email);
  114.             return $id ?? false;
  115.         }
  117.         $id = $result['records'][0]['Id'];
  118.         return $id;
  119.     }
  121.     /**
  122.      * get contact ID if exists, return false if doesnt exists
  123.      *
  124.      * @param User $user
  125.      * @return string|void
  126.      */
  127.     public function getContactByFullName(string $firstName, string $lastName, string $email)
  128.     {
  129.         // $firstName = preg_replace('/[^a-zA-Z0-9\s]/', '\\\\$0', $firstName);
  130.         // $lastName = preg_replace('/[^a-zA-Z0-9\s]/', '\\\\$0', $lastName);
  132.         $firstName = str_replace("'", "''", $firstName);
  133.         $lastName = str_replace("'", "''", $lastName);
  134.         
  135.         $query = 'SELECT Id FROM Contact WHERE FirstName = \''. $firstName .'\' AND LastName = \''. $lastName .'\'';
  136.         $result = $this->salesforceCrud->query($query);
  138.         if ($result['totalSize'] <= 0) {
  139.             return false;
  140.         }
  142.         $id = $result['records'][0]['Id'];
  143.         if ($result['totalSize'] > 1) {
  144.             $id = $this->getContact($email);
  145.         }
  146.         return $id;
  147.     }
  150.     /**
  151.      * Create salesforce contact obj
  152.      *
  153.      * @param User $user
  154.      * @return string
  155.      */
  156.     public function createContact(User $user): string
  157.     {
  158.         $id = $this->getContact($user->getEmail());
  159.         // $id = $this->getContactByEmailandFullName($user->getFirstName(), $user->getLastName(), $user->getEmail());
  161.         if (!$id) {
  162.             $data =  $this->salesforceObjectConverter->convertUserToContact($user);
  163.         
  164.             $id = $this->salesforceCrud->create(Constant::CONTACT_OBJ, $data);  #returns id
  165.         }
  166.     
  167.         return $id;
  168.     }
  170.     /**
  171.      * Update Salesforce contact obj
  172.      *
  173.      * @param User $user
  174.      * @return void
  175.      */
  176.     public function updateContact(User $user)
  177.     {
  178.         $userInformation = $user->getUserInformation();
  179.         $id = $userInformation->getSalesforceId();
  181.         $data =  $this->salesforceObjectConverter->convertUserToContact($user);
  182.         
  183.         $this->salesforceCrud->update(Constant::CONTACT_OBJ, $id, $data);  #returns id
  184.     }
  186.     /**
  187.      * Create contact salesforce object from FilmProjectMember entity
  188.      *
  189.      * @param FilmProjectMember $filmProjectMember
  190.      * @return void|string
  191.      */
  192.     public function createContactFromFilmMember(FilmProjectMember $filmProjectMember)
  193.     {
  194.         $id = $this->getContact($filmProjectMember->getEmail());
  195.         // $id = $this->getContactByEmailandFullName($filmProjectMember->getName(), $filmProjectMember->getLastName(), $filmProjectMember->getEmail());
  197.         if (!$id) {
  198.             $data = $this->salesforceObjectConverter->convertFilmMemberToContact($filmProjectMember);            
  199.             try {
  200.                 $id = $this->salesforceCrud->create(Constant::CONTACT_OBJ, $data);  #returns id
  201.             } catch (ClientException $e) {
  202.                 $response = $e->getResponse();
  203.                 $responseBodyAsString = $response->getBody()->getContents();
  205.                 $this->throwExceptionMessage($responseBodyAsString);
  206.                 // var_dump($responseBodyAsString); exit();
  207.             }
  208.         }
  209.     
  210.         return $id;
  211.     }
  213.     /**
  214.      * Update contact salesforce object from FilmProjectMember entity
  215.      *
  216.      * @param FilmProjectMember $filmProjectMember
  217.      * @return void|string
  218.      */
  219.     public function updateContactFromFilmMember(FilmProjectMember $filmProjectMember)
  220.     {
  221.         $salesforceId = $filmProjectMember->getSalesforceId();
  223.         if (!$salesforceId) {
  224.             $data = $this->salesforceObjectConverter->convertFilmMemberToContact($filmProjectMember);            
  225.             try {
  226.                 $this->salesforceCrud->update(Constant::CONTACT_OBJ, $salesforceId, $data);  #returns id
  227.             } catch (ClientException $e) {
  228.                 $response = $e->getResponse();
  229.                 $responseBodyAsString = $response->getBody()->getContents();
  231.                 $this->throwExceptionMessage($responseBodyAsString);
  232.             }
  233.         }
  234.     }
  236.     /**
  237.      * Create salesforce contact obj
  238.      *
  239.      * @param User $user
  240.      * @return string
  241.      */
  242.     public function createGuestContactFromOrderDetails(OrderBillingDetails $orderBillingDetails): ?string
  243.     {
  244.         $id = $this->getContactByEmailandFullName($orderBillingDetails->getFirstName(), $orderBillingDetails->getLastName(), $orderBillingDetails->getEmailAddress()) ?? $this->getContact($orderBillingDetails->getEmailAddress());
  246.         if (!$id) {
  247.             $data =  $this->salesforceObjectConverter->convertBillingDetailsToContact($orderBillingDetails);
  248.         
  249.             $id = $this->salesforceCrud->create(Constant::CONTACT_OBJ, $data);  #returns id
  250.         }
  251.     
  252.         return $id;
  253.     }
  255.     /**
  256.      * Create account salesforce object from film member on film application
  257.      *
  258.      * @return void|string
  259.      */
  260.     public function createAccount(string $organisationName, string $primaryContactSfId = null)
  261.     {
  262.         if ($organisationName) {
  263.             $id = $this->getAccount($organisationName);
  265.             if (!$id) {
  266.                 $data = [
  267.                     'Name' => $organisationName,
  268.                     'RecordTypeId' => Constant::SALESFORCE_ORGANISATION_FILMMAKER,
  269.                 ];
  271.                 if ($primaryContactSfId) {
  272.                     $data['npe01__One2OneContact__c'] = $primaryContactSfId;
  273.                 }
  274.                 
  275.                 $id = $this->salesforceCrud->create(Constant::ACCOUNT_OBJ, $data);  #returns id
  276.             } else {
  277.                 if ($primaryContactSfId) {
  278.                     // $data['npe01__One2OneContact__c'] = $primaryContactSfId;
  279.                     // $statusCode = $this->salesforceCrud->update(Constant::ACCOUNT_OBJ, $id, $data);  // Update Account
  280.                     $data = [
  281.                         'npsp__Primary_Affiliation__c' => $id
  282.                     ];
  283.                     
  284.                     $this->salesforceCrud->update(Constant::CONTACT_OBJ, $primaryContactSfId, $data); // Update contact affiliation to account
  285.                 }
  286.             }
  287.             
  288.             return $id;
  289.         }
  291.         return false;
  292.     }
  294.     /**
  295.      * Create account salesforce object from film member on film application
  296.      *
  297.      * @return void|string
  298.      */
  299.     public function createAccountWithOrderDetails(string $organisationName, ?OrderDetails $orderDetails = null, ?string $primaryContactSfId = null)
  300.     {
  301.         if ($organisationName) {
  302.             $id = $this->getAccount($organisationName);
  304.             $data = [];
  305.             if ($orderDetails) {
  306.                 $orderBillingDetails = $orderDetails->getOrderBillingDetails();
  307.                 if ($orderBillingDetails) {
  308.                     $data['Email__c'] = $orderBillingDetails->getEmailAddress();
  309.                     $data['Phone'] = $orderBillingDetails->getPhoneNumber();
  310.                     $data['BillingStreet'] = $orderBillingDetails->getStreet();
  311.                     $data['BillingState'] = $orderBillingDetails->getState();
  312.                     $data['BillingPostalCode'] = $orderBillingDetails->getPostcode();
  313.                     $data['BillingCountry'] = $orderBillingDetails->getCountry();
  314.                     $data['BillingCity'] = $orderBillingDetails->getSuburb();
  315.                 }
  316.             }
  318.             if (!$id) {
  319.                 $data['Name'] = $organisationName;
  320.                 $data['RecordTypeId'] = Constant::SALESFORCE_ORGANISATION_FILMMAKER;
  322.                 if ($primaryContactSfId) {
  323.                     $data['npe01__One2OneContact__c'] = $primaryContactSfId;
  324.                 }
  325.                 // TODO: IF not exists, create account with primary contact
  326.                 $id = $this->salesforceCrud->create(Constant::ACCOUNT_OBJ, $data);  #returns id
  327.             } else {
  328.                 // TODO: IF exists, update account with affiliate contact
  329.                 if ($primaryContactSfId) {
  330.                     // Update organisation salesforce object
  331.                     
  332.                     try {
  333.                         $data['npe01__One2OneContact__c'] = $primaryContactSfId;
  334.                         $statusCode = $this->salesforceCrud->update(Constant::ACCOUNT_OBJ, $id, $data);  // Update Account
  335.                     } catch (ClientException $e) {
  337.                     }
  338.                     // Update Contact Object
  339.                     try {
  340.                         $contactData = ['npsp__Primary_Affiliation__c' => $id];
  341.                         $this->salesforceCrud->update(Constant::CONTACT_OBJ, $primaryContactSfId, $contactData); // Update contact affiliation to account
  342.                     } catch (ClientException $e) {
  344.                     }
  345.                 }
  346.             }
  347.             
  348.             return $id;
  349.         }
  351.         return false;
  352.     }
  355.     /**
  356.      * get organisation ID if exists, return false if doesnt exists
  357.      *
  358.      * @param User $user
  359.      * @return void
  360.      */
  361.     public function getAccount(string $organisationName)
  362.     {
  363.         $organisationName = addslashes($organisationName);
  364.         $query = 'SELECT Id FROM Account WHERE Name = \''. $organisationName .'\'';
  365.         $result = $this->salesforceCrud->query($query);
  367.         if ($result['totalSize'] <= 0) {
  368.             return false;
  369.         }
  371.         $id = $result['records'][0]['Id'];
  372.         return $id;
  373.     }
  375.     /**
  376.      * Create account salesforce object from film member on film application
  377.      *
  378.      * @return void|string
  379.      */
  380.     public function createAccountFromFilmProjectMember(FilmProjectMember $filmProjectMember)
  381.     {
  382.         if ($organisationName = $filmProjectMember->getOrganisation()) {
  383.             $id = $this->getAccount($organisationName);
  385.             if (!$id) {
  386.                 $data = [
  387.                     'Name' => $organisationName,
  388.                     'RecordTypeId' => Constant::SALESFORCE_ORGANISATION_FILMMAKER,
  389.                 ];
  390.                 
  391.                 $id = $this->salesforceCrud->create(Constant::ACCOUNT_OBJ, $data);  #returns id
  392.             }
  393.         
  394.             return $id;
  395.         }
  397.         return false;
  398.     }
  400.     /**
  401.      * Create campaign object from film project entity
  402.      *
  403.      * @param FilmProject $filmProject
  404.      * @return void|string
  405.      */
  406.     public function createCampaign(FilmProject $filmProject)
  407.     {
  408.         $id = null;
  409.         if (!empty($filmProject->getOldWordpressId())) {
  410.             $id = $this->getCampaignByWordpressId($filmProject->getOldWordpressId());
  411.         } 
  413.         if (!$id) {
  414.             $data = $this->salesforceObjectConverter->convertProjectToCampaign($filmProject);
  415.             try {
  416.                 $id = $this->salesforceCrud->create(Constant::CAMPAIGN_OBJ, $data); 
  417.             } catch (ClientException $e) {
  418.                 $response = $e->getResponse();
  419.                 $responseBodyAsString = $response->getBody()->getContents();
  421.                 $this->throwExceptionMessage($responseBodyAsString);
  422.                 return null;
  423.             }
  424.         }
  425.     
  426.         return $id;
  427.     }
  429.     /**
  430.      * Update campaign object from film project entity
  431.      *
  432.      * @param FilmProject $filmProject
  433.      * @return void
  434.      */
  435.     public function updateCampaign(FilmProject $filmProject)
  436.     {
  437.         $salesforceId = $filmProject->getSalesforceId();
  439.         $data = $this->salesforceObjectConverter->convertProjectToCampaign($filmProject, true);
  440.         try {
  441.             $id = $this->salesforceCrud->update(Constant::CAMPAIGN_OBJ, $salesforceId, $data); 
  442.         } catch (ClientException $e) {
  443.             $response = $e->getResponse();
  444.             $responseBodyAsString = $response->getBody()->getContents();
  446.             $this->throwExceptionMessage($responseBodyAsString);
  447.             var_dump($responseBodyAsString); exit();
  448.         }
  449.     
  450.         return $id;
  451.     }
  453.     public function updateCampaignAdmin(FilmProject $filmProject) {
  454.         $salesforceId = $filmProject->getSalesforceId();
  456.         $data = [
  457.             'Application_Fee_Paid__c' => 0,
  458.             'Application_Fee_Amount__c' => 0,
  459.         ];
  461.         try {
  462.             $id = $this->salesforceCrud->update(Constant::CAMPAIGN_OBJ, $salesforceId, $data); 
  463.         } catch (ClientException $e) {
  464.             $response = $e->getResponse();
  465.             $responseBodyAsString = $response->getBody()->getContents();
  467.             $this->throwExceptionMessage($responseBodyAsString);
  468.             var_dump($responseBodyAsString); exit();
  469.         }
  471.         return $id;
  472.     }
  474.     /**
  475.      * Update campaign object to be approved
  476.      *
  477.      * @param FilmProject $filmProject
  478.      * @return void
  479.      */
  480.     public function approveCampaign(FilmProject $filmProject) 
  481.     {
  482.         $salesforceId = $filmProject->getSalesforceId();
  484.         $updatedData = [
  485.             'Project_Approved__c' => 1,
  486.             // 'Project_Approval_Date__c' => (new \DateTime('today'))->format('Y-m-d'),
  487.             'Wordpress_ID__c' => $filmProject->getWordpressId() ? $filmProject->getWordpressId() : '',
  488.             // 'Wordpress_ID_2023__c' => $filmProject->getWordpressId() ? $filmProject->getWordpressId() : '',
  489.             'IsActive' => 1,
  490.             'Status' => 'Completed'
  491.         ];
  493.         
  494.         if ($filmProject->getOldWordpressId()) { // If an old migrated project
  495.             $updatedData['Wordpress_ID__c'] = $filmProject->getOldWordpressId();
  496.         } else { // New project
  497.             $updatedData['Project_Approval_Date__c'] = (new \DateTime('today'))->format('Y-m-d');
  498.         }
  500.         $statusCode =  $this->salesforceCrud->update(Constant::CAMPAIGN_OBJ, $salesforceId, $updatedData);
  501.     }
  503.     /**
  504.      * Updated campaign object to be declined
  505.      *
  506.      * @param FilmProject $filmProject
  507.      * @return void
  508.      */
  509.     public function declineCampaign(FilmProject $filmProject)
  510.     {
  511.         $salesforceId = $filmProject->getSalesforceId();
  513.         $updatedData = [
  514.             'Project_Approved__c' => 0,
  515.             'Rejected_Date__c' => (new \DateTime('today'))->format('Y-m-d'),
  516.             'Resubmit__c' => 0,
  517.         ];
  518.         $statusCode =  $this->salesforceCrud->update(Constant::CAMPAIGN_OBJ, $salesforceId, $updatedData);
  519.     }
  521.     /**
  522.      * Updated campaign object to be asked to resubmit
  523.      *
  524.      * @param FilmProject $filmProject
  525.      * @return void
  526.      */
  527.     public function resubmitCampaign(FilmProject $filmProject)
  528.     {
  529.         $salesforceId = $filmProject->getSalesforceId();
  531.         $updatedData = [
  532.             'Project_Approved__c' => 0,
  533.             // 'Rejected_Date__c' => (new \DateTime('today'))->format('Y-m-d'),
  534.             'Status' => 'In Progress',
  535.             'Resubmit__c' => 1,
  536.         ];
  537.         $statusCode =  $this->salesforceCrud->update(Constant::CAMPAIGN_OBJ, $salesforceId, $updatedData);
  538.     }
  540.     /**
  541.      * Create Film Application Transaction
  542.      *
  543.      * @param FilmProject $filmProject
  544.      * @param OrderDetails $orderDetails
  545.      * @return string
  546.      */
  547.     public function createFilmApplicationTransaction(FilmProject $filmProject)
  548.     {
  549.         $orderDetails = $filmProject->getOrderDetails();
  551.         $projectOwner = $filmProject->getOwner();
  552.         $accountName = sprintf('%s (%s) Household', $projectOwner->getLastName(), $projectOwner->getFirstName());
  553.         
  554.         $ownerAccountId = "";
  555.         $ownerSfId = $this->getContact($projectOwner->getEmail());
  556.         if ($ownerSfId) {
  557.             $ownerAccountId = $this->createAccountWithOrderDetails($accountName, $orderDetails, $ownerSfId);
  558.         } else {
  559.             $ownerAccountId = $this->createAccountWithOrderDetails($accountName, $orderDetails);
  560.         }
  562.         $data = [
  563.             'RecordTypeId' => Constant::SALESFORCE_TRANSACTION_TRANSACTION,
  564.             'Name' => 'Film Application - '. $filmProject->getTitle(),
  565.             'AccountId' =>  $ownerAccountId,
  566.             // 'npsp__Primary_Contact__c' => $projectOwner->getUserInformation()->getSalesforceId(),
  567.             'LeadSource' => 'Website',
  568.             'Type' => 'Film Application Fee',
  569.             'StageName' => 'Closed',
  570.             'CloseDate' => (new \DateTime('now'))->format('Y-m-d'),
  571.             'Probability' => 100,
  572.             'DAF_retention__c' => '100%',
  573.             'Consent_to_be_identified__c' => 'Does NOT consent',
  574.             'Share_details__c' => 'DOESN\'T consent',
  575.             'Payment_Type__c' => 'Credit Card',
  576.             // 'Order_ID__c' => $orderDetails->getInvoiceNumber(),
  577.             'Order_ID__c' => 'MW'. $orderDetails->getId(),
  578.             'Description' => $filmProject->getTitle(),
  579.             'Amount' => number_format(((float)$orderDetails->getTotal() / 100), 2, '.', ''),
  580.             // 'npe01__Amount_Written_Off__c' => 0,
  581.             // 'npe01__Amount_Outstanding__c' => 0,
  582.             'npsp__Acknowledgment_Status__c' => 'Do Not Acknowledge',
  583.             'CampaignId' =>  ($filmProject->getSalesforceId()) ? $filmProject->getSalesforceId() : '',
  584.         ];
  586.         
  587.         if ($ownerSfId) {
  588.             $data['npsp__Primary_Contact__c'] = $ownerSfId;
  589.         }
  591.         try {
  592.             $id = $this->salesforceCrud->create(Constant::TRANSACTION_OBJ, $data);
  593.         } catch (ClientException $e) {
  594.             $response = $e->getResponse();
  595.             $responseBodyAsString = $response->getBody()->getContents();
  597.             $this->throwExceptionMessage($responseBodyAsString);
  598.             var_dump($responseBodyAsString); exit();
  599.         }
  601.         return $id;
  602.     }
  604.     /**
  605.      * Create Donation Transaction
  606.      *
  607.      * @param Donation $donation
  608.      * @param OrderDetails $orderDetails
  609.      * @return void
  610.      */
  611.     public function createDonationTransaction(Donation $donation)
  612.     {
  613.         $orderDetails = $donation->getOrderDetails();
  614.         $filmProject = $donation->getFilmProject();
  615.         $orderBillingDetails = $orderDetails->getOrderBillingDetails();
  616.         $accountName = $orderBillingDetails->getOrganisation();
  618.         $user = $orderDetails->getUser();
  619.         $salesforceDonatorId = $user ? ($user->isAdmin() ? $this->createGuestContactFromOrderDetails($orderBillingDetails) : $user->getUserInformation()->getSalesforceId()) : $this->createGuestContactFromOrderDetails($orderBillingDetails);
  621.         if (empty($accountName)) {
  622.             $accountName = sprintf('%s (%s) Household', $orderBillingDetails->getLastName(), $orderBillingDetails->getFirstName());
  623.         }
  624.         $ownerAccountId = $this->createAccountWithOrderDetails($accountName, $orderDetails, $salesforceDonatorId); // Get owner Id
  626.         $data = [
  627.             'RecordTypeId' => Constant::SALESFORCE_TRANSACTION_TRANSACTION,
  628.             'Name' => 'Donation - '. $filmProject->getTitle(),
  629.             'AccountId' =>  $ownerAccountId,
  630.             'npsp__Primary_Contact__c' => $salesforceDonatorId,
  631.             'LeadSource' => 'Website',
  632.             'Type' => 'Film Donation',
  633.             'StageName' => 'Closed',
  634.             'CloseDate' => (new \DateTime('now'))->format('Y-m-d'),
  635.             'Probability' => 100,
  636.             'DAF_retention__c' => '5%',
  637.             'Consent_to_be_identified__c' =>  ($donation->isIsOrganisationConsent()) ? 'Does consent' : 'Does NOT consent',
  638.             'Share_details__c' => ($donation->isIsContactShared()) ? 'Does consent' : 'DOESN\'T consent',
  639.             'Payment_Type__c' => 'Credit Card',
  640.             'Order_ID__c' => 'MW'. $orderDetails->getId(),
  641.             'Description' => 'Donation for project: '. $filmProject->getTitle(),
  642.             'Amount' => number_format(((float)($orderDetails->getTotal() - $donation->getSupportdaf()) / 100), 2, '.', ''),
  643.             // 'npe01__Amount_Written_Off__c' => 0,
  644.             // 'npe01__Amount_Outstanding__c' => 0,
  645.             'npsp__Acknowledgment_Status__c' => 'Do Not Acknowledge',
  646.             'CampaignId' => $filmProject->getSalesforceId(),
  647.             // 'WordPress_ID__c' => $filmProject->getWordpressId(),
  648.             // 'Wordpress_ID_from_2023__c' => $filmProject->getWordpressId(),
  649.         ];
  651.         // Check payment details
  652.         $paymentDetails = $orderDetails->getPaymentDetails();
  653.         if ($paymentDetails) {
  654.             if ($paymentDetails->getType() == Constant::PAYMENT_EFT) {
  655.                 $data['Payment_Type__c'] = Constant::PAYMENT_EFT;
  656.             }
  657.         }
  659.         // Change close date
  660.         if ($orderDate = $orderDetails->getCreatedAt()) {
  661.             $data['CloseDate'] = $orderDate->format('Y-m-d');
  662.         }
  664.         try {
  665.             $id = $this->salesforceCrud->create(Constant::TRANSACTION_OBJ, $data);
  666.         } catch (ClientException $e) {
  667.             $response = $e->getResponse();
  668.             $responseBodyAsString = $response->getBody()->getContents();
  670.             $this->throwExceptionMessage($responseBodyAsString);
  671.             var_dump($responseBodyAsString); exit();
  672.         }
  673.     
  674.         return $id;
  675.     }
  677.      /**
  678.      * Create DAF Donation Transaction
  679.      *
  680.      * @param Donation $donation
  681.      * @param OrderDetails $orderDetails
  682.      * @return string
  683.      */
  684.     public function createDafDonationTransaction(Donation $donation, $popUpSalesforceId = null)
  685.     {
  686.         $orderDetails = $donation->getOrderDetails();
  688.         $user = $orderDetails->getUser();
  689.         $orderBillingDetails = $orderDetails->getOrderBillingDetails();
  690.         $accountName = $orderBillingDetails->getOrganisation();
  691.         
  692.         $salesforceDonatorId = null;
  693.         if ($user) { 
  694.             $salesforceDonatorId = $user->getUserInformation()->getSalesforceId();
  695.         } else { // GUEST
  696.             $salesforceDonatorId = $this->createGuestContactFromOrderDetails($orderBillingDetails);
  697.         }
  699.         if (empty($accountName)) {
  700.             $accountName = sprintf('%s (%s) Household', $orderBillingDetails->getLastName(), $orderBillingDetails->getFirstName());
  701.         }
  702.         $ownerAccountId = $this->createAccountWithOrderDetails($accountName, $orderDetails, $salesforceDonatorId); // Get owner Id
  704.         $data = [
  705.             'RecordTypeId' => Constant::SALESFORCE_TRANSACTION_TRANSACTION,
  706.             'Name' => 'Donation - Support Documentary Australia',
  707.             'AccountId' =>  $ownerAccountId,
  708.             'npsp__Primary_Contact__c' => $salesforceDonatorId,
  709.             'LeadSource' => 'Website',
  710.             'Type' => 'Donation',
  711.             'StageName' => 'Closed',
  712.             'CloseDate' => (new \DateTime('now'))->format('Y-m-d'),
  713.             'Probability' => 100,
  714.             'DAF_retention__c' => '100%',
  715.             'Consent_to_be_identified__c' =>  ($donation->isIsOrganisationConsent()) ? 'Does consent' : 'Does NOT consent',
  716.             'Share_details__c' => ($donation->isIsContactShared()) ? 'Does consent' : 'DOESN\'T consent',
  717.             'Payment_Type__c' => 'Credit Card',
  718.             'Order_ID__c' => 'MW'. $orderDetails->getId(),
  719.             'Description' => 'Support Documentary Australia',
  720.             // 'Wordpress_ID_from_2023__c' => '35040', // Latest Support Documentary Australia Project
  721.             'Amount' => number_format(((float)$donation->getSupportdaf() / 100), 2, '.', ''),
  722.             // 'npe01__Amount_Written_Off__c' => 0,
  723.             // 'npe01__Amount_Outstanding__c' => 0,
  724.             'npsp__Acknowledgment_Status__c' => 'Do Not Acknowledge',
  725.         ];
  727.         if (!$popUpSalesforceId) {
  728.             if ($donation->getFilmProject()) {
  729.                 $filmProject = $donation->getFilmProject();
  730.                 $data['CampaignId'] = $filmProject->getSalesforceId();
  732.                 if ($filmProject->isIsDafCore() && $filmProject->isIsDafProgram()) {
  733.                     $data['Name'] = 'Donation - '. $filmProject->getTitle();
  734.                     $data['Description'] = 'Donation - '. $filmProject->getTitle();
  735.                     // $data['Wordpress_ID_from_2023__c'] = $filmProject->getWordpressId();
  736.                     $data['Amount'] = number_format(((float)$orderDetails->getTotal() / 100), 2, '.', '');
  737.                 }
  738.             }
  739.         } else {
  740.             $data['CampaignId'] = $popUpSalesforceId;
  741.             // $data['Wordpress_ID_from_2023__c'] = '17135'; // hardcoded latest popup filmproject
  742.             $data['Name'] = 'Donation - Documentary Australia\'s core operations_POP-UP';
  743.         }
  745.         // Check payment details
  746.         $paymentDetails = $orderDetails->getPaymentDetails();
  747.         if ($paymentDetails) {
  748.             if ($paymentDetails->getType() == Constant::PAYMENT_EFT) {
  749.                 $data['Payment_Type__c'] = Constant::PAYMENT_EFT;
  750.             }
  751.         }
  753.         // Change close date
  754.         if ($orderDate = $orderDetails->getCreatedAt()) {
  755.             $data['CloseDate'] = $orderDate->format('Y-m-d');
  756.         }
  758.         try {
  759.             $id = $this->salesforceCrud->create(Constant::TRANSACTION_OBJ, $data);
  760.         } catch (ClientException $e) {
  761.             $response = $e->getResponse();
  762.             $responseBodyAsString = $response->getBody()->getContents();
  764.             $this->throwExceptionMessage($responseBodyAsString);
  765.             var_dump($responseBodyAsString); exit();
  766.         }
  767.     
  768.         return $id;
  769.     }
  771.     /**
  772.      * Updated transaction details
  773.      *
  774.      * @param OrderDetails $orderDetails
  775.      * @return void
  776.      */
  777.     public function updateTransaction(OrderDetails $orderDetails)
  778.     {
  779.         $salesforceId = $orderDetails->getSalesforceId();
  781.         if (empty($salesforceId)) {
  782.             return;
  783.         }
  785.         $updatedData = [
  786.             'Amount' => $orderDetails->getTotal() / 100,
  787.         ];
  789.         if ($donation = $orderDetails->getDonation()) {
  790.             $filmProject = $donation->getFilmProject();
  792.             $updatedData = [
  793.                 'Name' => 'Donation - '. $filmProject->getTitle(),
  794.                 'Amount' => $orderDetails->getTotal() / 100,
  795.                 'CampaignId' => $filmProject->getSalesforceId(),
  796.                 'StageName' => 'Closed',
  797.                 'npsp__Acknowledgment_Status__c' => 'Do Not Acknowledge',
  798.             ];
  799.     
  800.         }
  802.         try {
  803.             $statusCode =  $this->salesforceCrud->update(Constant::TRANSACTION_OBJ, $salesforceId, $updatedData);
  804.         } catch (ClientException $e) {
  805.             $response = $e->getResponse();
  806.             $responseBodyAsString = $response->getBody()->getContents();
  808.             $this->throwExceptionMessage("Opportunity object on Salesforce is not found. Please contact admin for more information.");
  809.             var_dump($responseBodyAsString); exit();
  810.         }
  812.         // Update payment amount as well
  813.         $paymentId = $this->getPaymentByTransactionId($salesforceId);
  814.         if ($paymentId) {
  815.             $this->updatePaymentAmountReceived($paymentId, $orderDetails->getTotal() / 100);
  816.         }
  817.     }
  819.      /**
  820.      * Updated campaign object to be refunded
  821.      *
  822.      * @param OrderDetails $orderDetails
  823.      * @return void
  824.      */
  825.     public function refundTransaction(OrderDetails $orderDetails)
  826.     {
  827.         $salesforceId = $orderDetails->getSalesforceId();
  829.         if (empty($salesforceId)) {
  830.             return;
  831.         }
  833.         $updatedData = [
  834.             'Amount' => 0,
  835.             'Refunded__c' => 1,
  836.         ];
  837.         try {
  838.             $statusCode =  $this->salesforceCrud->update(Constant::TRANSACTION_OBJ, $salesforceId, $updatedData);
  839.         } catch (ClientException $e) {
  840.             $response = $e->getResponse();
  841.             $responseBodyAsString = $response->getBody()->getContents();
  843.             $this->throwExceptionMessage($responseBodyAsString);
  844.             var_dump($responseBodyAsString); exit();
  845.         }
  847.         // Update payment amount as well
  848.         $paymentId = $this->getPaymentByTransactionId($salesforceId);
  849.         if ($paymentId) {
  850.             $this->updatePaymentAmountRefund($paymentId);
  851.         }
  852.     }
  854.     /**
  855.      * Updated campaign object to be refunded
  856.      *
  857.      * @param OrderDetails $orderDetails
  858.      * @return void
  859.      */
  860.     public function refundDafSupportTransaction(Donation $donation)
  861.     {
  862.         $salesforceId = $donation->getSupportDafSalesforce();
  864.         if (empty($salesforceId)) {
  865.             return;
  866.         }
  868.         $updatedData = [
  869.             'Amount' => 0,
  870.             'Refunded__c' => 1,
  871.         ];
  872.         try {
  873.             $statusCode =  $this->salesforceCrud->update(Constant::TRANSACTION_OBJ, $salesforceId, $updatedData);
  874.         } catch (ClientException $e) {
  875.             $response = $e->getResponse();
  876.             $responseBodyAsString = $response->getBody()->getContents();
  878.             $this->throwExceptionMessage($responseBodyAsString);
  879.             var_dump($responseBodyAsString); exit();
  880.         }
  882.         // Update payment amount as well
  883.         $paymentId = $this->getPaymentByTransactionId($salesforceId);
  884.         if ($paymentId) {
  885.             $this->updatePaymentAmountRefund($paymentId);
  886.         }
  887.     }
  889.     /**
  890.      * get campaign with wordpress ID
  891.      *
  892.      * @param User $user
  893.      * @return void
  894.      */
  895.     public function getCampaignByWordpressId(int $id)
  896.     {
  897.         $query = 'SELECT Id FROM Campaign WHERE Wordpress_ID__c = \''. $id .'\'';
  898.         $result = $this->salesforceCrud->query($query);
  900.         if ($result['totalSize'] <= 0) {
  901.             return false;
  902.         }
  904.         $id = $result['records'][0]['Id'];
  905.         return $id;
  906.     }
  908.     /**
  909.      * Create campaign object from film project entity
  910.      *
  911.      * @param FilmProject $filmProject
  912.      * @return void|string
  913.      */
  914.     public function updateCampaignByPayload($salesforceId, array $payLoad)
  915.     {
  916.         try {
  917.             $id = $this->salesforceCrud->update(Constant::CAMPAIGN_OBJ, $salesforceId, $payLoad); 
  918.         } catch (ClientException $e) {
  919.             $response = $e->getResponse();
  920.             $responseBodyAsString = $response->getBody()->getContents();
  922.             var_dump($salesforceId .' is having error'); exit();
  924.             $this->throwExceptionMessage($responseBodyAsString);
  925.             return null;
  926.         }
  927.     
  928.         return $id;
  929.     }
  931.     /**
  932.      * get contact ID if exists, return false if doesnt exists
  933.      *
  934.      * @param User $user
  935.      * @return string|void
  936.      */
  937.     public function getContactBySalesforceId(string $id)
  938.     {
  939.         $query = 'SELECT Id FROM Contact WHERE Id = \''. $id .'\'';
  940.         $result = $this->salesforceCrud->query($query);
  942.         if ($result['totalSize'] <= 0) {
  943.             return false;
  944.         }
  946.         $id = $result['records'][0]['Id'];
  947.         return $id;
  948.     }
  950.     /**
  951.      * Get Payment ID by Transaction ID
  952.      *
  953.      * @param string $id
  954.      * @return false|String
  955.      */
  956.     public function getPaymentByTransactionId(string $id) 
  957.     {
  958.         $query = 'SELECT Id FROM npe01__OppPayment__c WHERE npe01__Opportunity__c = \''. $id .'\'';
  959.         try {
  960.             $result = $this->salesforceCrud->query($query);
  961.         } catch (ClientException $e) {
  962.             return false;
  963.         }
  965.         if ($result['totalSize'] <= 0) {
  966.             return false;
  967.         }
  969.         $id = $result['records'][0]['Id'];
  970.         return $id;
  971.     }
  973.     /**
  974.      * Update campaign object to be approved
  975.      *
  976.      * @param String $salesforceId
  977.      * @return void
  978.      */
  979.     public function updatePaymentAmountReceived(String $salesforceId, $amount) 
  980.     {
  981.         $updatedData = [
  982.             'npe01__Payment_Amount__c' => $amount,
  983.         ];
  984.         $statusCode =  $this->salesforceCrud->update('npe01__OppPayment__c', $salesforceId, $updatedData);
  985.     }
  987.     /**
  988.      * Update campaign object to be approved
  989.      *
  990.      * @param String $salesforceId
  991.      * @return void
  992.      */
  993.     public function updatePaymentAmountRefund(String $salesforceId) 
  994.     {
  995.         $updatedData = [
  996.             'npe01__Payment_Amount__c' => number_format(0, 2, '.', ''),
  997.         ];
  998.         $statusCode =  $this->salesforceCrud->update('npe01__OppPayment__c', $salesforceId, $updatedData);
  999.     }
  1001.     public function getSalesforceCrud() {
  1002.         return $this->salesforceCrud;
  1003.     }
  1005.     public function deleteContact(User $user)
  1006.     {
  1007.         $userInformation = $user->getUserInformation();
  1008.         $id = $userInformation->getSalesforceId();
  1010.         try {
  1011.             $this->salesforceCrud->delete(Constant::CONTACT_OBJ, $id);  #returns id
  1012.         } catch(Exception $e) {
  1013.             return;
  1014.         }
  1015.     }
  1017.     public function replaceWordpressIds(FilmProject $filmProject) 
  1018.     {
  1019.         $salesforceId = $filmProject->getSalesforceId();
  1021.         $updatedData = [
  1022.             'Wordpress_ID__c' => $filmProject->getOldWordpressId() ? $filmProject->getOldWordpressId() : '',
  1023.             // 'Wordpress_ID_2023__c' => $filmProject->getWordpressId() ? $filmProject->getWordpressId() : '',
  1024.         ];
  1026.         $statusCode =  $this->salesforceCrud->update(Constant::CAMPAIGN_OBJ, $salesforceId, $updatedData);
  1027.     }
  1030.     public function updateProgressReport(FilmProjectProgressReport $progressReport) {
  1031.         $filmProject = $progressReport->getFilmProject();
  1032.         $salesforceId = $filmProject->getSalesforceId();
  1034.         $updatedData =  $this->salesforceObjectConverter->convertProgressReportToCampaign($progressReport);
  1035.        
  1036.         $statusCode =  $this->salesforceCrud->update(Constant::CAMPAIGN_OBJ, $salesforceId, $updatedData);
  1037.     }
  1039.     /**
  1040.      * Creates content version data to upload file to Salesforce
  1041.      */
  1042.     public function createContentVersionData(FilmProjectProgressReportFile $progressReportFile) {
  1043.         $data = [
  1044.             'Title' => $progressReportFile->getFileName(),
  1045.             'PathOnClient' => $progressReportFile->getFileName(),
  1046.             'VersionData' => Constant::LOCALHOST_URL . '/uploads/progress_reports/'. $progressReportFile->getFileName(),
  1047.         ];
  1048.         
  1049.         $id = $this->salesforceCrud->create('ContentVersion', $data);  #returns id
  1051.         return $id;
  1052.     }
  1054.     /**
  1055.      * Gets Document ID from uploaded ContentVersionData
  1056.      */
  1057.     public function getDocumentIdFromContentVersion(String $contentVersionId) {
  1058.         $query = 'SELECT ContentDocumentId FROM ContentVersion WHERE Id = \''. $contentVersionId .'\'';
  1059.         try {
  1060.             $result = $this->salesforceCrud->query($query);
  1061.         } catch (ClientException $e) {
  1062.             return false;
  1063.         }
  1065.         if ($result['totalSize'] <= 0) {
  1066.             return false;
  1067.         }
  1069.         $id = $result['records'][0]['ContentDocumentId'];
  1070.         return $id;
  1071.     }
  1073.     /**
  1074.      * Links between the uplaoded file and campaign ID on Salesforce end
  1075.      */
  1076.     public function createDocumentLink(String $contentDocumentId, String $campaignId) {
  1077.         $data = [
  1078.             'ContentDocumentId' => $contentDocumentId,
  1079.             'LinkedEntityId' => $campaignId,
  1080.             'ShareType' => 'V', // Viewer
  1081.         ];
  1082.         
  1083.         $id = $this->salesforceCrud->create('ContentDocumentLink', $data);  #returns id
  1084.     }
  1085. }