src/Service/SalesforceService.php line 53

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\FilmProjectProgressReport;
  9. use App\Entity\FilmProjectProgressReportFile;
  10. use App\Entity\FilmProjectMember;
  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;
  22. final class SalesforceService extends ApiService
  23. {
  25.     private ContainerBagInterface $params;
  26.     private CRUD $salesforceCrud;
  27.     private SalesforceObjectConverter $salesforceObjectConverter;
  29.     public function __construct(ContainerBagInterface $params, SalesforceObjectConverter $salesforceObjectConverter)
  30.     {
  31.         $this->params = $params;
  32.         $this->salesforceObjectConverter = $salesforceObjectConverter;
  33.         $this->salesforceCrud = $this->authenticate();
  34.     }
  35.     
  36.     /**
  37.      * Setup access token and instance URL in session
  38.      *
  39.      * @return void
  40.      */
  41.     public function authenticate() 
  42.     {
  43.         $options = [
  44.             'grant_type' => 'password',
  45.             'client_id' => $this->params->get('app.salesforce_client_id'),
  46.             'client_secret' => $this->params->get('app.salesforce_client_secret'),
  47.             'username' => $this->params->get('app.salesforce_username'),
  48.             'password' => $this->params->get('app.salesforce_password'),
  49.         ];
  51.         $salesforce = new PasswordAuthentication($options);
  52.         $salesforce->setEndpoint(Constant::SALESFORCE_TOKEN_URL);
  53.         $salesforce->authenticate();
  55.         return new CRUD();
  56.     }
  58.     /**
  59.      * get contact ID if exists, return false if doesnt exists
  60.      *
  61.      * @param User $user
  62.      * @return string|void
  63.      */
  64.     public function getContact(string $email)
  65.     {
  66.         $query = 'SELECT Id FROM Contact WHERE Email = \''. $email .'\'';
  67.         $result = $this->salesforceCrud->query($query);
  69.         if ($result['totalSize'] <= 0) {
  70.             return false;
  71.         }
  73.         $id = $result['records'][0]['Id'];
  74.         return $id;
  75.     }
  77.      /**
  78.      * get contact ID if exists, return false if doesnt exists
  79.      *
  80.      * @param User $user
  81.      * @return string|void
  82.      */
  83.     public function getContactByEmailandFullName(string $firstName, string $lastName, string $email)
  84.     {
  85.         $firstName = addslashes($firstName);
  86.         $lastName = addslashes($lastName);
  88.         $query = 'SELECT Id FROM Contact WHERE Email = \''. $email .'\' AND FirstName = \''. $firstName .'\' AND LastName = \''. $lastName .'\'';
  89.         $result = $this->salesforceCrud->query($query);
  91.         if ($result['totalSize'] <= 0) {
  92.             return false;
  93.         }
  95.         $id = $result['records'][0]['Id'];
  96.         return $id;
  97.     }
  99.     /**
  100.      * Create salesforce contact obj
  101.      *
  102.      * @param User $user
  103.      * @return string
  104.      */
  105.     public function createContact(User $user): string
  106.     {
  107.         // $id = $this->getContact($user->getEmail());
  108.         $id = $this->getContactByEmailandFullName($user->getFirstName(), $user->getLastName(), $user->getEmail());
  110.         if (!$id) {
  111.             $data =  $this->salesforceObjectConverter->convertUserToContact($user);
  112.         
  113.             $id = $this->salesforceCrud->create(Constant::CONTACT_OBJ, $data);  #returns id
  114.         }
  115.     
  116.         return $id;
  117.     }
  119.     /**
  120.      * Update Salesforce contact obj
  121.      *
  122.      * @param User $user
  123.      * @return void
  124.      */
  125.     public function updateContact(User $user)
  126.     {
  127.         $userInformation = $user->getUserInformation();
  128.         $id = $userInformation->getSalesforceId();
  130.         $data =  $this->salesforceObjectConverter->convertUserToContact($user);
  131.         
  132.         $this->salesforceCrud->update(Constant::CONTACT_OBJ, $id, $data);  #returns id
  133.     }
  135.     /**
  136.      * Create contact salesforce object from FilmProjectMember entity
  137.      *
  138.      * @param FilmProjectMember $filmProjectMember
  139.      * @return void|string
  140.      */
  141.     public function createContactFromFilmMember(FilmProjectMember $filmProjectMember)
  142.     {
  143.         $id = $this->getContact($filmProjectMember->getEmail());
  144.         // $id = $this->getContactByEmailandFullName($filmProjectMember->getName(), $filmProjectMember->getLastName(), $filmProjectMember->getEmail());
  146.         if (!$id) {
  147.             $data = $this->salesforceObjectConverter->convertFilmMemberToContact($filmProjectMember);            
  148.             try {
  149.                 $id = $this->salesforceCrud->create(Constant::CONTACT_OBJ, $data);  #returns id
  150.             } catch (ClientException $e) {
  151.                 $response = $e->getResponse();
  152.                 $responseBodyAsString = $response->getBody()->getContents();
  154.                 $this->throwExceptionMessage($responseBodyAsString);
  155.                 // var_dump($responseBodyAsString); exit();
  156.             }
  157.         }
  158.     
  159.         return $id;
  160.     }
  162.     /**
  163.      * Update contact salesforce object from FilmProjectMember entity
  164.      *
  165.      * @param FilmProjectMember $filmProjectMember
  166.      * @return void|string
  167.      */
  168.     public function updateContactFromFilmMember(FilmProjectMember $filmProjectMember)
  169.     {
  170.         $salesforceId = $filmProjectMember->getSalesforceId();
  172.         if (!$salesforceId) {
  173.             $data = $this->salesforceObjectConverter->convertFilmMemberToContact($filmProjectMember);            
  174.             try {
  175.                 $this->salesforceCrud->update(Constant::CONTACT_OBJ, $salesforceId, $data);  #returns id
  176.             } catch (ClientException $e) {
  177.                 $response = $e->getResponse();
  178.                 $responseBodyAsString = $response->getBody()->getContents();
  180.                 $this->throwExceptionMessage($responseBodyAsString);
  181.             }
  182.         }
  183.     }
  185.     /**
  186.      * Create salesforce contact obj
  187.      *
  188.      * @param User $user
  189.      * @return string
  190.      */
  191.     public function createGuestContactFromOrderDetails(OrderBillingDetails $orderBillingDetails): string
  192.     {
  193.         // $id = $this->getContact($orderBillingDetails->getEmailAddress());
  194.         $id = $this->getContactByEmailandFullName($orderBillingDetails->getFirstName(), $orderBillingDetails->getLastName(), $orderBillingDetails->getEmailAddress());
  196.         if (!$id) {
  197.             $data =  $this->salesforceObjectConverter->convertBillingDetailsToContact($orderBillingDetails);
  198.         
  199.             $id = $this->salesforceCrud->create(Constant::CONTACT_OBJ, $data);  #returns id
  200.         }
  201.     
  202.         return $id;
  203.     }
  205.     /**
  206.      * Create account salesforce object from film member on film application
  207.      *
  208.      * @return void|string
  209.      */
  210.     public function createAccount(string $organisationName, string $primaryContactSfId = null)
  211.     {
  212.         if ($organisationName) {
  213.             $id = $this->getAccount($organisationName);
  215.             if (!$id) {
  216.                 $data = [
  217.                     'Name' => $organisationName,
  218.                     'RecordTypeId' => Constant::SALESFORCE_ORGANISATION_FILMMAKER,
  219.                 ];
  221.                 if ($primaryContactSfId) {
  222.                     $data['npe01__One2OneContact__c'] = $primaryContactSfId;
  223.                 }
  224.                 
  225.                 $id = $this->salesforceCrud->create(Constant::ACCOUNT_OBJ, $data);  #returns id
  226.             } else {
  227.                 if ($primaryContactSfId) {
  228.                     // $data['npe01__One2OneContact__c'] = $primaryContactSfId;
  229.                     // $statusCode = $this->salesforceCrud->update(Constant::ACCOUNT_OBJ, $id, $data);  // Update Account
  230.                     $data = [
  231.                         'npsp__Primary_Affiliation__c' => $id
  232.                     ];
  233.                     
  234.                     $this->salesforceCrud->update(Constant::CONTACT_OBJ, $primaryContactSfId, $data); // Update contact affiliation to account
  235.                 }
  236.             }
  237.             
  238.             return $id;
  239.         }
  241.         return false;
  242.     }
  244.     /**
  245.      * Create account salesforce object from film member on film application
  246.      *
  247.      * @return void|string
  248.      */
  249.     public function createAccountWithOrderDetails(string $organisationName, OrderDetails $orderDetails = null, string $primaryContactSfId = null,)
  250.     {
  251.         if ($organisationName) {
  252.             $id = $this->getAccount($organisationName);
  254.             $data = [];
  255.             if ($orderDetails) {
  256.                 $orderBillingDetails = $orderDetails->getOrderBillingDetails();
  257.                 if ($orderBillingDetails) {
  258.                     $data['Email__c'] = $orderBillingDetails->getEmailAddress();
  259.                     $data['Phone'] = $orderBillingDetails->getPhoneNumber();
  260.                     $data['BillingStreet'] = $orderBillingDetails->getStreet();
  261.                     $data['BillingState'] = $orderBillingDetails->getState();
  262.                     $data['BillingPostalCode'] = $orderBillingDetails->getPostcode();
  263.                     $data['BillingCountry'] = $orderBillingDetails->getCountry();
  264.                     $data['BillingCity'] = $orderBillingDetails->getSuburb();
  265.                 }
  266.             }
  268.             if (!$id) {
  269.                 $data['Name'] = $organisationName;
  270.                 $data['RecordTypeId'] = Constant::SALESFORCE_ORGANISATION_FILMMAKER;
  272.                 if ($primaryContactSfId) {
  273.                     $data['npe01__One2OneContact__c'] = $primaryContactSfId;
  274.                 }
  275.                 // TODO: IF not exists, create account with primary contact
  276.                 $id = $this->salesforceCrud->create(Constant::ACCOUNT_OBJ, $data);  #returns id
  277.             } else {
  278.                 // TODO: IF exists, update account with affiliate contact
  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.             return $id;
  288.         }
  290.         return false;
  291.     }
  294.     /**
  295.      * get organisation ID if exists, return false if doesnt exists
  296.      *
  297.      * @param User $user
  298.      * @return void
  299.      */
  300.     public function getAccount(string $organisationName)
  301.     {
  302.         $organisationName = addslashes($organisationName);
  303.         // $organisationName = str_replace("'", "\'", $organisationName);
  305.         $query = 'SELECT Id FROM Account WHERE Name = \''. $organisationName .'\'';
  306.         $result = $this->salesforceCrud->query($query);
  308.         if ($result['totalSize'] <= 0) {
  309.             return false;
  310.         }
  312.         $id = $result['records'][0]['Id'];
  313.         return $id;
  314.     }
  316.     /**
  317.      * Create account salesforce object from film member on film application
  318.      *
  319.      * @return void|string
  320.      */
  321.     public function createAccountFromFilmProjectMember(FilmProjectMember $filmProjectMember)
  322.     {
  323.         if ($organisationName = $filmProjectMember->getOrganisation()) {
  324.             $id = $this->getAccount($organisationName);
  326.             if (!$id) {
  327.                 $data = [
  328.                     'Name' => $organisationName,
  329.                     'RecordTypeId' => Constant::SALESFORCE_ORGANISATION_FILMMAKER,
  330.                 ];
  331.                 
  332.                 $id = $this->salesforceCrud->create(Constant::ACCOUNT_OBJ, $data);  #returns id
  333.             }
  334.         
  335.             return $id;
  336.         }
  338.         return false;
  339.     }
  341.     /**
  342.      * Create campaign object from film project entity
  343.      *
  344.      * @param FilmProject $filmProject
  345.      * @return void|string
  346.      */
  347.     public function createCampaign(FilmProject $filmProject)
  348.     {
  349.         $id = null;
  350.         if (!empty($filmProject->getOldWordpressId())) {
  351.             $id = $this->getCampaignByWordpressId($filmProject->getOldWordpressId());
  352.         } 
  354.         if (!$id) {
  355.             $data = $this->salesforceObjectConverter->convertProjectToCampaign($filmProject);
  356.             try {
  357.                 $id = $this->salesforceCrud->create(Constant::CAMPAIGN_OBJ, $data); 
  358.             } catch (ClientException $e) {
  359.                 $response = $e->getResponse();
  360.                 $responseBodyAsString = $response->getBody()->getContents();
  362.                 $this->throwExceptionMessage($responseBodyAsString);
  363.                 return null;
  364.             }
  365.         }
  366.     
  367.         return $id;
  368.     }
  370.     /**
  371.      * Update campaign object from film project entity
  372.      *
  373.      * @param FilmProject $filmProject
  374.      * @return void
  375.      */
  376.     public function updateCampaign(FilmProject $filmProject)
  377.     {
  378.         $salesforceId = $filmProject->getSalesforceId();
  380.         $data = $this->salesforceObjectConverter->convertProjectToCampaign($filmProject, true);
  381.         try {
  382.             $id = $this->salesforceCrud->update(Constant::CAMPAIGN_OBJ, $salesforceId, $data); 
  383.         } catch (ClientException $e) {
  384.             $response = $e->getResponse();
  385.             $responseBodyAsString = $response->getBody()->getContents();
  387.             $this->throwExceptionMessage($responseBodyAsString);
  388.             var_dump($responseBodyAsString); exit();
  389.         }
  390.     
  391.         return $id;
  392.     }
  394.     public function updateCampaignAdmin(FilmProject $filmProject) {
  395.         $salesforceId = $filmProject->getSalesforceId();
  397.         $data = [
  398.             'Application_Fee_Paid__c' => 0,
  399.             'Application_Fee_Amount__c' => 0,
  400.         ];
  402.         try {
  403.             $id = $this->salesforceCrud->update(Constant::CAMPAIGN_OBJ, $salesforceId, $data); 
  404.         } catch (ClientException $e) {
  405.             $response = $e->getResponse();
  406.             $responseBodyAsString = $response->getBody()->getContents();
  408.             $this->throwExceptionMessage($responseBodyAsString);
  409.             var_dump($responseBodyAsString); exit();
  410.         }
  412.         return $id;
  413.     }
  415.     /**
  416.      * Update campaign object to be approved
  417.      *
  418.      * @param FilmProject $filmProject
  419.      * @return void
  420.      */
  421.     public function approveCampaign(FilmProject $filmProject) 
  422.     {
  423.         $salesforceId = $filmProject->getSalesforceId();
  425.         $updatedData = [
  426.             'Project_Approved__c' => 1,
  427.             'Project_Approval_Date__c' => (new \DateTime('today'))->format('Y-m-d'),
  428.             'Wordpress_ID__c' => $filmProject->getWordpressId(),
  429.             'IsActive' => 1,
  430.         ];
  431.         $statusCode =  $this->salesforceCrud->update(Constant::CAMPAIGN_OBJ, $salesforceId, $updatedData);
  432.     }
  434.     /**
  435.      * Updated campaign object to be declined
  436.      *
  437.      * @param FilmProject $filmProject
  438.      * @return void
  439.      */
  440.     public function declineCampaign(FilmProject $filmProject)
  441.     {
  442.         $salesforceId = $filmProject->getSalesforceId();
  444.         $updatedData = [
  445.             'Project_Approved__c' => 0,
  446.             'Rejected_Date__c' => (new \DateTime('today'))->format('Y-m-d'),
  447.             'Resubmit__c' => 0,
  448.         ];
  449.         $statusCode =  $this->salesforceCrud->update(Constant::CAMPAIGN_OBJ, $salesforceId, $updatedData);
  450.     }
  452.     /**
  453.      * Updated campaign object to be asked to resubmit
  454.      *
  455.      * @param FilmProject $filmProject
  456.      * @return void
  457.      */
  458.     public function resubmitCampaign(FilmProject $filmProject)
  459.     {
  460.         $salesforceId = $filmProject->getSalesforceId();
  462.         $updatedData = [
  463.             'Project_Approved__c' => 0,
  464.             'Rejected_Date__c' => (new \DateTime('today'))->format('Y-m-d'),
  465.             'Resubmit__c' => 1,
  466.         ];
  467.         $statusCode =  $this->salesforceCrud->update(Constant::CAMPAIGN_OBJ, $salesforceId, $updatedData);
  468.     }
  470.     /**
  471.      * Create Film Application Transaction
  472.      *
  473.      * @param FilmProject $filmProject
  474.      * @param OrderDetails $orderDetails
  475.      * @return string
  476.      */
  477.     public function createFilmApplicationTransaction(FilmProject $filmProject)
  478.     {
  479.         $orderDetails = $filmProject->getOrderDetails();
  481.         $projectOwner = $filmProject->getOwner();
  482.         $accountName = sprintf('%s (%s) Household', $projectOwner->getLastName(), $projectOwner->getFirstName());
  483.         
  484.         $ownerAccountId = "";
  485.         $ownerSfId = $this->getContact($projectOwner->getEmail());
  486.         if ($ownerSfId) {
  487.             $ownerAccountId = $this->createAccountWithOrderDetails($accountName, $orderDetails, $ownerSfId);
  488.         } else {
  489.             $ownerAccountId = $this->createAccountWithOrderDetails($accountName, $orderDetails);
  490.         }
  492.         $data = [
  493.             'RecordTypeId' => Constant::SALESFORCE_TRANSACTION_TRANSACTION,
  494.             'Name' => 'Film Application - '. $filmProject->getTitle(),
  495.             'AccountId' =>  $ownerAccountId,
  496.             // 'npsp__Primary_Contact__c' => $projectOwner->getUserInformation()->getSalesforceId(),
  497.             'LeadSource' => 'Website',
  498.             'Type' => 'Film Application Fee',
  499.             'StageName' => 'Closed',
  500.             'CloseDate' => (new \DateTime('now'))->format('Y-m-d'),
  501.             'Probability' => 100,
  502.             'DAF_retention__c' => '100%',
  503.             'Consent_to_be_identified__c' => 'Does NOT consent',
  504.             'Share_details__c' => 'DOESN\'T consent',
  505.             'Payment_Type__c' => 'Credit Card',
  506.             // 'Order_ID__c' => $orderDetails->getInvoiceNumber(),
  507.             'Order_ID__c' => 'MW'. $orderDetails->getId(),
  508.             'Description' => $filmProject->getTitle(),
  509.             'Amount' => number_format(((float)$orderDetails->getTotal() / 100), 2, '.', ''),
  510.             // 'npe01__Amount_Written_Off__c' => 0,
  511.             // 'npe01__Amount_Outstanding__c' => 0,
  512.             'npsp__Acknowledgment_Status__c' => (($orderDetails->getTotal() / 100) < 200) ? 'Do Not Acknowledge' : 'To Be Acknowledged',
  513.             'CampaignId' =>  ($filmProject->getSalesforceId()) ? $filmProject->getSalesforceId() : '',
  514.         ];
  516.         
  517.         if ($ownerSfId) {
  518.             $data['npsp__Primary_Contact__c'] = $ownerSfId;
  519.         }
  521.         try {
  522.             $id = $this->salesforceCrud->create(Constant::TRANSACTION_OBJ, $data);
  523.         } catch (ClientException $e) {
  524.             $response = $e->getResponse();
  525.             $responseBodyAsString = $response->getBody()->getContents();
  527.             $this->throwExceptionMessage($responseBodyAsString);
  528.             var_dump($responseBodyAsString); exit();
  529.         }
  531.         return $id;
  532.     }
  534.     /**
  535.      * Create Donation Transaction
  536.      *
  537.      * @param Donation $donation
  538.      * @param OrderDetails $orderDetails
  539.      * @return void
  540.      */
  541.     public function createDonationTransaction(Donation $donation)
  542.     {
  543.         $orderDetails = $donation->getOrderDetails();
  544.         $filmProject = $donation->getFilmProject();
  545.         $orderBillingDetails = $orderDetails->getOrderBillingDetails();
  546.         $accountName = $orderBillingDetails->getOrganisation();
  548.         $user = $orderDetails->getUser();
  550.         $salesforceDonatorId = null;
  551.         if ($user) { 
  552.             $salesforceDonatorId = $user->getUserInformation()->getSalesforceId();
  553.         } else { // GUEST
  554.             $salesforceDonatorId = $this->createGuestContactFromOrderDetails($orderBillingDetails);
  555.         }
  557.         if (empty($accountName)) {
  558.             $accountName = sprintf('%s (%s) Household', $orderBillingDetails->getLastName(), $orderBillingDetails->getFirstName());
  559.         }
  560.         $ownerAccountId = $this->createAccountWithOrderDetails($accountName, $orderDetails, $salesforceDonatorId); // Get owner Id
  562.         $data = [
  563.             'RecordTypeId' => Constant::SALESFORCE_TRANSACTION_TRANSACTION,
  564.             'Name' => 'Donation - '. $filmProject->getTitle(),
  565.             'AccountId' =>  $ownerAccountId,
  566.             'npsp__Primary_Contact__c' => $salesforceDonatorId,
  567.             'LeadSource' => 'Website',
  568.             'Type' => 'Film Donation',
  569.             'StageName' => 'Closed',
  570.             'CloseDate' => (new \DateTime('now'))->format('Y-m-d'),
  571.             'Probability' => 100,
  572.             'DAF_retention__c' => '5%',
  573.             'Consent_to_be_identified__c' =>  ($donation->isIsOrganisationConsent()) ? 'Does consent' : 'Does NOT consent',
  574.             'Share_details__c' => ($donation->isIsContactShared()) ? 'Does consent' : 'DOESN\'T consent',
  575.             'Payment_Type__c' => 'Credit Card',
  576.             'Order_ID__c' => 'MW'. $orderDetails->getId(),
  577.             'Description' => 'Donation for project: '. $filmProject->getTitle(),
  578.             'Amount' => number_format(((float)($orderDetails->getTotal() - $donation->getSupportdaf()) / 100), 2, '.', ''),
  579.             // 'npe01__Amount_Written_Off__c' => 0,
  580.             // 'npe01__Amount_Outstanding__c' => 0,
  581.             'npsp__Acknowledgment_Status__c' => ((($orderDetails->getTotal() - $donation->getSupportdaf()) / 100) < 200) ? 'Do Not Acknowledge' : 'To Be Acknowledged',
  582.             'CampaignId' => $filmProject->getSalesforceId(),
  583.             // 'WordPress_ID__c' => $filmProject->getWordpressId(),
  584.             // 'Wordpress_ID_from_2023__c' => $filmProject->getWordpressId(),
  585.         ];
  587.         // Check payment details
  588.         $paymentDetails = $orderDetails->getPaymentDetails();
  589.         if ($paymentDetails) {
  590.             if ($paymentDetails->getType() == Constant::PAYMENT_EFT) {
  591.                 $data['Payment_Type__c'] = Constant::PAYMENT_EFT;
  592.             }
  593.         }
  595.         // Change close date
  596.         if ($orderDate = $orderDetails->getCreatedAt()) {
  597.             $data['CloseDate'] = $orderDate->format('Y-m-d');
  598.         }
  600.         try {
  601.             $id = $this->salesforceCrud->create(Constant::TRANSACTION_OBJ, $data);
  602.         } catch (ClientException $e) {
  603.             $response = $e->getResponse();
  604.             $responseBodyAsString = $response->getBody()->getContents();
  606.             $this->throwExceptionMessage($responseBodyAsString);
  607.             var_dump($responseBodyAsString); exit();
  608.         }
  609.     
  610.         return $id;
  611.     }
  613.      /**
  614.      * Create DAF Donation Transaction
  615.      *
  616.      * @param Donation $donation
  617.      * @param OrderDetails $orderDetails
  618.      * @return string
  619.      */
  620.     public function createDafDonationTransaction(Donation $donation, $popUpSalesforceId = null)
  621.     {
  622.         $orderDetails = $donation->getOrderDetails();
  624.         $user = $orderDetails->getUser();
  625.         $orderBillingDetails = $orderDetails->getOrderBillingDetails();
  626.         $accountName = $orderBillingDetails->getOrganisation();
  627.         
  628.         $salesforceDonatorId = null;
  629.         if ($user) { 
  630.             $salesforceDonatorId = $user->getUserInformation()->getSalesforceId();
  631.         } else { // GUEST
  632.             $salesforceDonatorId = $this->createGuestContactFromOrderDetails($orderBillingDetails);
  633.         }
  635.         if (empty($accountName)) {
  636.             $accountName = sprintf('%s (%s) Household', $orderBillingDetails->getLastName(), $orderBillingDetails->getFirstName());
  637.         }
  638.         $ownerAccountId = $this->createAccountWithOrderDetails($accountName, $orderDetails, $salesforceDonatorId); // Get owner Id
  640.         $data = [
  641.             'RecordTypeId' => Constant::SALESFORCE_TRANSACTION_TRANSACTION,
  642.             'Name' => 'Support Our Work',
  643.             'AccountId' =>  $ownerAccountId,
  644.             'npsp__Primary_Contact__c' => $salesforceDonatorId,
  645.             'LeadSource' => 'Website',
  646.             'Type' => 'Donation',
  647.             'StageName' => 'Closed',
  648.             'CloseDate' => (new \DateTime('now'))->format('Y-m-d'),
  649.             'Probability' => 100,
  650.             'DAF_retention__c' => '100%',
  651.             'Consent_to_be_identified__c' =>  ($donation->isIsOrganisationConsent()) ? 'Does consent' : 'Does NOT consent',
  652.             'Share_details__c' => ($donation->isIsContactShared()) ? 'Does consent' : 'DOESN\'T consent',
  653.             'Payment_Type__c' => 'Credit Card',
  654.             'Order_ID__c' => 'MW'. $orderDetails->getId(),
  655.             'Description' => 'Support Our Work',
  656.             'Amount' => number_format(((float)$donation->getSupportdaf() / 100), 2, '.', ''),
  657.             // 'npe01__Amount_Written_Off__c' => 0,
  658.             // 'npe01__Amount_Outstanding__c' => 0,
  659.             'npsp__Acknowledgment_Status__c' => (($donation->getSupportdaf() / 100) < 200) ? 'Do Not Acknowledge' : 'To Be Acknowledged',
  660.         ];
  662.         if (!$popUpSalesforceId) {
  663.             if ($donation->getFilmProject()) {
  664.                 $filmProject = $donation->getFilmProject();
  665.                 $data['CampaignId'] = $filmProject->getSalesforceId();
  667.                 if ($filmProject->isIsDafCore() && $filmProject->isIsDafProgram()) {
  668.                     $data['Name'] = 'Donation - '. $filmProject->getTitle();
  669.                     $data['Description'] = 'Donation - '. $filmProject->getTitle();
  670.                     // $data['Wordpress_ID_from_2023__c'] = $filmProject->getWordpressId();
  671.                 }
  672.             }
  673.         } else {
  674.             $data['CampaignId'] = $popUpSalesforceId;
  675.         }
  677.         // Check payment details
  678.         $paymentDetails = $orderDetails->getPaymentDetails();
  679.         if ($paymentDetails) {
  680.             if ($paymentDetails->getType() == Constant::PAYMENT_EFT) {
  681.                 $data['Payment_Type__c'] = Constant::PAYMENT_EFT;
  682.             }
  683.         }
  685.         // Change close date
  686.         if ($orderDate = $orderDetails->getCreatedAt()) {
  687.             $data['CloseDate'] = $orderDate->format('Y-m-d');
  688.         }
  690.         try {
  691.             $id = $this->salesforceCrud->create(Constant::TRANSACTION_OBJ, $data);
  692.         } catch (ClientException $e) {
  693.             $response = $e->getResponse();
  694.             $responseBodyAsString = $response->getBody()->getContents();
  696.             $this->throwExceptionMessage($responseBodyAsString);
  697.             var_dump($responseBodyAsString); exit();
  698.         }
  699.     
  700.         return $id;
  701.     }
  703.     /**
  704.      * Updated transaction details
  705.      *
  706.      * @param OrderDetails $orderDetails
  707.      * @return void
  708.      */
  709.     public function updateTransaction(OrderDetails $orderDetails)
  710.     {
  711.         $salesforceId = $orderDetails->getSalesforceId();
  713.         if (empty($salesforceId)) {
  714.             return;
  715.         }
  717.         $updatedData = [
  718.             'Amount' => $orderDetails->getTotal() / 100,
  719.         ];
  721.         if ($donation = $orderDetails->getDonation()) {
  722.             $filmProject = $donation->getFilmProject();
  724.             $updatedData = [
  725.                 'Name' => 'Donation - '. $filmProject->getTitle(),
  726.                 'Amount' => $orderDetails->getTotal() / 100,
  727.                 'CampaignId' => $filmProject->getSalesforceId(),
  728.             ];
  729.     
  730.         }
  732.         try {
  733.             $statusCode =  $this->salesforceCrud->update(Constant::TRANSACTION_OBJ, $salesforceId, $updatedData);
  734.         } catch (ClientException $e) {
  735.             $response = $e->getResponse();
  736.             $responseBodyAsString = $response->getBody()->getContents();
  738.             $this->throwExceptionMessage($responseBodyAsString);
  739.             var_dump($responseBodyAsString); exit();
  740.         }
  742.         // Update payment amount as well
  743.         $paymentId = $this->getPaymentByTransactionId($salesforceId);
  744.         if ($paymentId) {
  745.             $this->updatePaymentAmountRefund($paymentId);
  746.         }
  747.     }
  749.      /**
  750.      * Updated campaign object to be refunded
  751.      *
  752.      * @param OrderDetails $orderDetails
  753.      * @return void
  754.      */
  755.     public function refundTransaction(OrderDetails $orderDetails)
  756.     {
  757.         $salesforceId = $orderDetails->getSalesforceId();
  759.         if (empty($salesforceId)) {
  760.             return;
  761.         }
  763.         $updatedData = [
  764.             'Amount' => 0,
  765.             'Refunded__c' => 1,
  766.         ];
  767.         try {
  768.             $statusCode =  $this->salesforceCrud->update(Constant::TRANSACTION_OBJ, $salesforceId, $updatedData);
  769.         } catch (ClientException $e) {
  770.             $response = $e->getResponse();
  771.             $responseBodyAsString = $response->getBody()->getContents();
  773.             $this->throwExceptionMessage($responseBodyAsString);
  774.             var_dump($responseBodyAsString); exit();
  775.         }
  777.         // Update payment amount as well
  778.         $paymentId = $this->getPaymentByTransactionId($salesforceId);
  779.         if ($paymentId) {
  780.             $this->updatePaymentAmountRefund($paymentId);
  781.         }
  782.     }
  784.     /**
  785.      * Updated campaign object to be refunded
  786.      *
  787.      * @param OrderDetails $orderDetails
  788.      * @return void
  789.      */
  790.     public function refundDafSupportTransaction(Donation $donation)
  791.     {
  792.         $salesforceId = $donation->getSupportDafSalesforce();
  794.         if (empty($salesforceId)) {
  795.             return;
  796.         }
  798.         $updatedData = [
  799.             'Amount' => 0,
  800.             'Refunded__c' => 1,
  801.         ];
  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($responseBodyAsString);
  809.             var_dump($responseBodyAsString); exit();
  810.         }
  812.         // Update payment amount as well
  813.         $paymentId = $this->getPaymentByTransactionId($salesforceId);
  814.         if ($paymentId) {
  815.             $this->updatePaymentAmountRefund($paymentId);
  816.         }
  817.     }
  819.     /**
  820.      * get campaign with wordpress ID
  821.      *
  822.      * @param User $user
  823.      * @return void
  824.      */
  825.     public function getCampaignByWordpressId(int $id)
  826.     {
  827.         $query = 'SELECT Id FROM Campaign WHERE Wordpress_ID__c = \''. $id .'\'';
  828.         $result = $this->salesforceCrud->query($query);
  830.         if ($result['totalSize'] <= 0) {
  831.             return false;
  832.         }
  834.         $id = $result['records'][0]['Id'];
  835.         return $id;
  836.     }
  838.     /**
  839.      * Create campaign object from film project entity
  840.      *
  841.      * @param FilmProject $filmProject
  842.      * @return void|string
  843.      */
  844.     public function updateCampaignByPayload($salesforceId, array $payLoad)
  845.     {
  846.         try {
  847.             $id = $this->salesforceCrud->update(Constant::CAMPAIGN_OBJ, $salesforceId, $payLoad); 
  848.         } catch (ClientException $e) {
  849.             $response = $e->getResponse();
  850.             $responseBodyAsString = $response->getBody()->getContents();
  852.             var_dump($salesforceId .' is having error'); exit();
  854.             $this->throwExceptionMessage($responseBodyAsString);
  855.             return null;
  856.         }
  857.     
  858.         return $id;
  859.     }
  861.     /**
  862.      * get contact ID if exists, return false if doesnt exists
  863.      *
  864.      * @param User $user
  865.      * @return string|void
  866.      */
  867.     public function getContactBySalesforceId(string $id)
  868.     {
  869.         $query = 'SELECT Id FROM Contact WHERE Id = \''. $id .'\'';
  870.         $result = $this->salesforceCrud->query($query);
  872.         if ($result['totalSize'] <= 0) {
  873.             return false;
  874.         }
  876.         $id = $result['records'][0]['Id'];
  877.         return $id;
  878.     }
  880.     /**
  881.      * Get Payment ID by Transaction ID
  882.      *
  883.      * @param string $id
  884.      * @return false|String
  885.      */
  886.     public function getPaymentByTransactionId(string $id) 
  887.     {
  888.         $query = 'SELECT Id FROM npe01__OppPayment__c WHERE npe01__Opportunity__c = \''. $id .'\'';
  889.         try {
  890.             $result = $this->salesforceCrud->query($query);
  891.         } catch (ClientException $e) {
  892.             return false;
  893.         }
  895.         if ($result['totalSize'] <= 0) {
  896.             return false;
  897.         }
  899.         $id = $result['records'][0]['Id'];
  900.         return $id;
  901.     }
  903.     /**
  904.      * Update campaign object to be approved
  905.      *
  906.      * @param String $salesforceId
  907.      * @return void
  908.      */
  909.     public function updatePaymentAmountRefund(String $salesforceId) 
  910.     {
  911.         $updatedData = [
  912.             'npe01__Payment_Amount__c' => number_format(0, 2, '.', ''),
  913.         ];
  914.         $statusCode =  $this->salesforceCrud->update('npe01__OppPayment__c', $salesforceId, $updatedData);
  915.     }
  917.     public function updateProgressReport(FilmProjectProgressReport $progressReport) {
  918.         $filmProject = $progressReport->getFilmProject();
  919.         $salesforceId = $filmProject->getSalesforceId();
  921.         $updatedData =  $this->salesforceObjectConverter->convertProgressReportToCampaign($progressReport);
  922.        
  923.         $statusCode =  $this->salesforceCrud->update(Constant::CAMPAIGN_OBJ, $salesforceId, $updatedData);
  924.     }
  926.     /**
  927.      * Creates content version data to upload file to Salesforce
  928.      */
  929.     public function createContentVersionData(FilmProjectProgressReportFile $progressReportFile) {
  930.         $data = [
  931.             'Title' => $progressReportFile->getFileName(),
  932.             'PathOnClient' => $progressReportFile->getFileName(),
  933.             'VersionData' => Constant::LOCALHOST_URL . '/uploads/progress_reports/'. $progressReportFile->getFileName(),
  934.         ];
  935.         
  936.         $id = $this->salesforceCrud->create('ContentVersion', $data);  #returns id
  938.         return $id;
  939.     }
  941.     /**
  942.      * Gets Document ID from uploaded ContentVersionData
  943.      */
  944.     public function getDocumentIdFromContentVersion(String $contentVersionId) {
  945.         $query = 'SELECT ContentDocumentId FROM ContentVersion WHERE Id = \''. $contentVersionId .'\'';
  946.         try {
  947.             $result = $this->salesforceCrud->query($query);
  948.         } catch (ClientException $e) {
  949.             return false;
  950.         }
  952.         if ($result['totalSize'] <= 0) {
  953.             return false;
  954.         }
  956.         $id = $result['records'][0]['ContentDocumentId'];
  957.         return $id;
  958.     }
  960.     /**
  961.      * Links between the uplaoded file and campaign ID on Salesforce end
  962.      */
  963.     public function createDocumentLink(String $contentDocumentId, String $campaignId) {
  964.         $data = [
  965.             'ContentDocumentId' => $contentDocumentId,
  966.             'LinkedEntityId' => $campaignId,
  967.             'ShareType' => 'V', // Viewer
  968.         ];
  969.         
  970.         $id = $this->salesforceCrud->create('ContentDocumentLink', $data);  #returns id
  971.     }
  972. }