X-Git-Url: https://vcs.fsf.org/?a=blobdiff_plain;f=CRM%2FEvent%2FBAO%2FParticipant.php;h=29ee23386594138f694202a49d2e9509adad6ea7;hb=08c2d3c7b1058279abe043b0ad01390141042841;hp=eb6fc33e74e1d53e92016beb7fae7bc1e50bbb10;hpb=f6f65fc0eb2d4440a2662debef1b458ccf836da2;p=civicrm-core.git

diff --git a/CRM/Event/BAO/Participant.php b/CRM/Event/BAO/Participant.php
index eb6fc33e74..29ee233865 100644
--- a/CRM/Event/BAO/Participant.php
+++ b/CRM/Event/BAO/Participant.php
@@ -547,6 +547,7 @@ INNER JOIN  civicrm_participant participant ON ( line.entity_table  = 'civicrm_p
 INNER JOIN  civicrm_price_field_value value ON ( value.id = line.price_field_value_id )
 INNER JOIN  civicrm_price_field field       ON ( value.price_field_id = field.id )
      WHERE  participant.event_id = %1
+       AND  line.qty > 0
             {$statusIdClause}
             {$isTestClause}
             {$skipParticipantClause}";
@@ -648,7 +649,7 @@ GROUP BY  participant.event_id
           'title' => ts('Participant Note'),
           'name' => 'participant_note',
           'headerPattern' => '/(participant.)?note$/i',
-          'type' => 'text',
+          'data_type' => CRM_Utils_Type::T_TEXT,
         ),
       );
 
@@ -1788,16 +1789,20 @@ WHERE    civicrm_participant.contact_id = {$contactID} AND
     }
 
     // get primary participant id
-    $query = "SELECT participant_id FROM civicrm_participant_payment WHERE contribution_id = {$contributionId}";
-    $participantId = CRM_Core_DAO::singleValueQuery($query);
+    $query = "SELECT participant_id
+      FROM civicrm_participant cp
+      LEFT JOIN civicrm_participant_payment cpp ON cp.id = cpp.participant_id
+      WHERE cpp.contribution_id = {$contributionId}
+      AND cp.registered_by_id IS NULL";
+    $participantPayment = CRM_Core_DAO::executeQuery($query);
 
     // get additional participant ids (including cancelled)
-    if ($participantId) {
-      $ids = array_merge(array(
-        $participantId,
-      ), self::getAdditionalParticipantIds($participantId,
+    while ($participantPayment->fetch()) {
+      $ids = array_merge($ids, array_merge(array(
+        $participantPayment->participant_id,
+      ), self::getAdditionalParticipantIds($participantPayment->participant_id,
         $excludeCancelled
-      ));
+      )));
     }
 
     return $ids;
@@ -1880,323 +1885,6 @@ WHERE    civicrm_participant.contact_id = {$contactID} AND
     }
   }
 
-  /**
-   * @param array $params
-   * @param int $participantId
-   * @param int $contributionId
-   * @param $feeBlock
-   * @param array $lineItems
-   * @param $paidAmount
-   * @param int $priceSetId
-   */
-  public static function changeFeeSelections($params, $participantId, $contributionId, $feeBlock, $lineItems, $paidAmount, $priceSetId) {
-    $contributionStatuses = CRM_Contribute_PseudoConstant::contributionStatus(NULL, 'name');
-    $partiallyPaidStatusId = array_search('Partially paid', $contributionStatuses);
-    $pendingRefundStatusId = array_search('Pending refund', $contributionStatuses);
-    $previousLineItems = CRM_Price_BAO_LineItem::getLineItems($participantId, 'participant');
-    CRM_Price_BAO_PriceSet::processAmount($feeBlock,
-      $params, $lineItems
-    );
-
-    // get the submitted
-    foreach ($feeBlock as $id => $values) {
-      CRM_Price_BAO_LineItem::format($id, $params, $values, $submittedLineItems);
-      $submittedFieldId[] = CRM_Utils_Array::retrieveValueRecursive($submittedLineItems, 'price_field_id');
-    }
-    if (!empty($submittedLineItems)) {
-      $insertLines = $submittedLineItems;
-
-      $submittedFieldValueIds = array_keys($submittedLineItems);
-      $updateLines = array();
-      foreach ($previousLineItems as $id => $previousLineItem) {
-        // check through the submitted items if the previousItem exists,
-        // if found in submitted items, do not use it for new item creations
-        if (in_array($previousLineItem['price_field_value_id'], $submittedFieldValueIds)) {
-          // if submitted line items are existing don't fire INSERT query
-          if ($previousLineItem['line_total'] != 0) {
-            unset($insertLines[$previousLineItem['price_field_value_id']]);
-          }
-          else {
-            $insertLines[$previousLineItem['price_field_value_id']]['skip'] = TRUE;
-          }
-          // for updating the line items i.e. use-case - once deselect-option selecting again
-          if (($previousLineItem['line_total'] != $submittedLineItems[$previousLineItem['price_field_value_id']]['line_total']) ||
-            ($submittedLineItems[$previousLineItem['price_field_value_id']]['line_total'] == 0 && $submittedLineItems[$previousLineItem['price_field_value_id']]['qty'] == 1) ||
-            ($previousLineItem['qty'] != $submittedLineItems[$previousLineItem['price_field_value_id']]['qty'])
-          ) {
-            $updateLines[$previousLineItem['price_field_value_id']] = $submittedLineItems[$previousLineItem['price_field_value_id']];
-            $updateLines[$previousLineItem['price_field_value_id']]['id'] = $id;
-          }
-        }
-      }
-
-      $submittedFields = implode(', ', $submittedFieldId);
-      $submittedFieldValues = implode(', ', $submittedFieldValueIds);
-    }
-    $financialItemsArray = array();
-    if (!empty($submittedFields) && !empty($submittedFieldValues)) {
-      $updateLineItem = "UPDATE civicrm_line_item li
-INNER JOIN civicrm_financial_item fi
-   ON (li.id = fi.entity_id AND fi.entity_table = 'civicrm_line_item')
-SET li.qty = 0,
-    li.line_total = 0.00,
-    li.tax_amount = NULL
-WHERE (li.entity_table = 'civicrm_participant' AND li.entity_id = {$participantId}) AND
-       (price_field_value_id NOT IN ({$submittedFieldValues}))
-";
-      CRM_Core_DAO::executeQuery($updateLineItem);
-
-      // gathering necessary info to record negative (deselected) financial_item
-      $updateFinancialItem = "
-  SELECT fi.*, SUM(fi.amount) as differenceAmt, price_field_value_id, financial_type_id, tax_amount
-    FROM civicrm_financial_item fi LEFT JOIN civicrm_line_item li ON (li.id = fi.entity_id AND fi.entity_table = 'civicrm_line_item')
-WHERE (li.entity_table = 'civicrm_participant' AND li.entity_id = {$participantId})
-GROUP BY li.entity_table, li.entity_id, price_field_value_id, fi.id
-";
-      $updateFinancialItemInfoDAO = CRM_Core_DAO::executeQuery($updateFinancialItem);
-      $trxn = CRM_Core_BAO_FinancialTrxn::getFinancialTrxnId($contributionId, 'DESC', TRUE);
-      $trxnId['id'] = $trxn['financialTrxnId'];
-      $invoiceSettings = Civi::settings()->get('contribution_invoice_settings');
-      $taxTerm = CRM_Utils_Array::value('tax_term', $invoiceSettings);
-      $updateFinancialItemInfoValues = array();
-      while ($updateFinancialItemInfoDAO->fetch()) {
-        $updateFinancialItemInfoValues = (array) $updateFinancialItemInfoDAO;
-        $updateFinancialItemInfoValues['transaction_date'] = date('YmdHis');
-        // the below params are not needed
-        unset($updateFinancialItemInfoValues['id']);
-        unset($updateFinancialItemInfoValues['created_date']);
-        // if not submitted and difference is not 0 make it negative
-        if (!in_array($updateFinancialItemInfoValues['price_field_value_id'], $submittedFieldValueIds) && $updateFinancialItemInfoValues['differenceAmt'] != 0) {
-          // INSERT negative financial_items
-          $updateFinancialItemInfoValues['amount'] = -$updateFinancialItemInfoValues['amount'];
-          if ($previousLineItems[$updateFinancialItemInfoValues['entity_id']]['tax_amount']) {
-            $updateFinancialItemInfoValues['tax']['amount'] = -($previousLineItems[$updateFinancialItemInfoValues['entity_id']]['tax_amount']);
-            $updateFinancialItemInfoValues['tax']['description'] = $taxTerm;
-            if ($updateFinancialItemInfoValues['financial_type_id']) {
-              $updateFinancialItemInfoValues['tax']['financial_account_id'] = CRM_Contribute_BAO_Contribution::getFinancialAccountId($updateFinancialItemInfoValues['financial_type_id']);
-            }
-          }
-          // INSERT negative financial_items for tax amount
-          $financialItemsArray[] = $updateFinancialItemInfoValues;
-        }
-        // if submitted and difference is 0 add a positive entry again
-        elseif (in_array($updateFinancialItemInfoValues['price_field_value_id'], $submittedFieldValueIds) && $updateFinancialItemInfoValues['differenceAmt'] == 0) {
-          $updateFinancialItemInfoValues['amount'] = $updateFinancialItemInfoValues['amount'];
-          // INSERT financial_items for tax amount
-          if ($updateFinancialItemInfoValues['entity_id'] == $updateLines[$updateFinancialItemInfoValues['price_field_value_id']]['id'] &&
-            isset($updateLines[$updateFinancialItemInfoValues['price_field_value_id']]['tax_amount'])
-          ) {
-            $updateFinancialItemInfoValues['tax']['amount'] = $updateLines[$updateFinancialItemInfoValues['price_field_value_id']]['tax_amount'];
-            $updateFinancialItemInfoValues['tax']['description'] = $taxTerm;
-            if ($updateLines[$updateFinancialItemInfoValues['price_field_value_id']]['financial_type_id']) {
-              $updateFinancialItemInfoValues['tax']['financial_account_id'] = CRM_Contribute_BAO_Contribution::getFinancialAccountId($updateLines[$updateFinancialItemInfoValues['price_field_value_id']]['financial_type_id']);
-            }
-          }
-          $financialItemsArray[] = $updateFinancialItemInfoValues;
-        }
-      }
-    }
-    elseif (empty($submittedFields) && empty($submittedFieldValues)) {
-      $updateLineItem = "UPDATE civicrm_line_item li
-        INNER JOIN civicrm_financial_item fi
-        ON (li.id = fi.entity_id AND fi.entity_table = 'civicrm_line_item')
-        SET li.qty = 0,
-        li.line_total = 0.00,
-        li.tax_amount = NULL
-        WHERE (li.entity_table = 'civicrm_participant' AND li.entity_id = {$participantId})";
-      CRM_Core_DAO::executeQuery($updateLineItem);
-    }
-    $amountLevel = array();
-    $totalParticipant = $participantCount = 0;
-    if (!empty($updateLines)) {
-      foreach ($updateLines as $valueId => $vals) {
-        $taxAmount = "NULL";
-        if (isset($vals['tax_amount'])) {
-          $taxAmount = $vals['tax_amount'];
-        }
-        $amountLevel[] = $vals['label'] . ' - ' . (float) $vals['qty'];
-        if (isset($vals['participant_count'])) {
-          $participantCount = $vals['participant_count'];
-          $totalParticipant += $vals['participant_count'];
-        }
-        $updateLineItem = "
-UPDATE civicrm_line_item li
-SET li.qty = {$vals['qty']},
-    li.line_total = {$vals['line_total']},
-    li.tax_amount = {$taxAmount},
-    li.unit_price = {$vals['unit_price']},
-    li.participant_count = {$participantCount},
-    li.label = %1
-WHERE (li.entity_table = 'civicrm_participant' AND li.entity_id = {$participantId}) AND
-      (price_field_value_id = {$valueId})
-";
-        CRM_Core_DAO::executeQuery($updateLineItem, array(1 => array($vals['label'], 'String')));
-      }
-    }
-    // insert new 'adjusted amount' transaction entry and update contribution entry.
-    // ensure entity_financial_trxn table has a linking of it.
-    // insert new line items
-    if (!empty($insertLines)) {
-      foreach ($insertLines as $valueId => $lineParams) {
-        if (!array_key_exists('skip', $lineParams)) {
-          $lineParams['entity_table'] = 'civicrm_participant';
-          $lineParams['entity_id'] = $participantId;
-          $lineParams['contribution_id'] = $contributionId;
-          $lineObj = CRM_Price_BAO_LineItem::create($lineParams);
-        }
-      }
-    }
-
-    // the recordAdjustedAmt code would execute over here
-    $ids = CRM_Event_BAO_Participant::getParticipantIds($contributionId);
-    if (count($ids) > 1) {
-      $updatedAmount = CRM_Price_BAO_LineItem::getLineTotal($contributionId);
-    }
-    else {
-      $updatedAmount = $params['amount'];
-    }
-    if (strlen($params['tax_amount']) != 0) {
-      $taxAmount = $params['tax_amount'];
-    }
-    else {
-      $taxAmount = "NULL";
-    }
-    $displayParticipantCount = '';
-    if ($totalParticipant > 0) {
-      $displayParticipantCount = ' Participant Count -' . $totalParticipant;
-    }
-    $updateAmountLevel = NULL;
-    if (!empty($amountLevel)) {
-      $updateAmountLevel = CRM_Core_DAO::VALUE_SEPARATOR . implode(CRM_Core_DAO::VALUE_SEPARATOR, $amountLevel) . $displayParticipantCount . CRM_Core_DAO::VALUE_SEPARATOR;
-    }
-    $trxn = self::recordAdjustedAmt($updatedAmount, $paidAmount, $contributionId, $taxAmount, $updateAmountLevel);
-    $trxnId = array();
-    if ($trxn) {
-      $trxnId['id'] = $trxn->id;
-      foreach ($financialItemsArray as $updateFinancialItemInfoValues) {
-        CRM_Financial_BAO_FinancialItem::create($updateFinancialItemInfoValues, NULL, $trxnId);
-        if (!empty($updateFinancialItemInfoValues['tax'])) {
-          $updateFinancialItemInfoValues['tax']['amount'] = $updateFinancialItemInfoValues['amount'];
-          $updateFinancialItemInfoValues['tax']['description'] = $updateFinancialItemInfoValues['description'];
-          if (!empty($updateFinancialItemInfoValues['financial_account_id'])) {
-            $updateFinancialItemInfoValues['financial_account_id'] = $updateFinancialItemInfoValues['tax']['financial_account_id'];
-          }
-          CRM_Financial_BAO_FinancialItem::create($updateFinancialItemInfoValues, NULL, $trxnId);
-        }
-      }
-    }
-    $fetchCon = array('id' => $contributionId);
-    $updatedContribution = CRM_Contribute_BAO_Contribution::retrieve($fetchCon, CRM_Core_DAO::$_nullArray, CRM_Core_DAO::$_nullArray);
-    // insert financial items
-    if (!empty($insertLines)) {
-      foreach ($insertLines as $valueId => $lineParams) {
-        $lineParams['entity_table'] = 'civicrm_participant';
-        $lineParams['entity_id'] = $participantId;
-        $lineObj = CRM_Price_BAO_LineItem::retrieve($lineParams, CRM_Core_DAO::$_nullArray);
-        // insert financial items
-        // ensure entity_financial_trxn table has a linking of it.
-        $prevItem = CRM_Financial_BAO_FinancialItem::add($lineObj, $updatedContribution, NULL, $trxnId);
-        if (isset($lineObj->tax_amount)) {
-          CRM_Financial_BAO_FinancialItem::add($lineObj, $updatedContribution, TRUE, $trxnId);
-        }
-      }
-    }
-
-    // update participant fee_amount column
-    $partUpdateFeeAmt['id'] = $participantId;
-    $getUpdatedLineItems = "SELECT *
-FROM civicrm_line_item
-WHERE (entity_table = 'civicrm_participant' AND entity_id = {$participantId} AND qty > 0)";
-    $getUpdatedLineItemsDAO = CRM_Core_DAO::executeQuery($getUpdatedLineItems);
-    $line = array();
-    while ($getUpdatedLineItemsDAO->fetch()) {
-      $line[$getUpdatedLineItemsDAO->price_field_value_id] = $getUpdatedLineItemsDAO->label . ' - ' . (float) $getUpdatedLineItemsDAO->qty;
-    }
-
-    $partUpdateFeeAmt['fee_level'] = implode(', ', $line);
-    $partUpdateFeeAmt['fee_amount'] = $params['amount'];
-    self::add($partUpdateFeeAmt);
-
-    //activity creation
-    self::addActivityForSelection($participantId, 'Change Registration');
-  }
-
-  /**
-   * Record adjusted amount.
-   *
-   * @param int $updatedAmount
-   * @param int $paidAmount
-   * @param int $contributionId
-   *
-   * @param int $taxAmount
-   * @param bool $updateAmountLevel
-   *
-   * @return bool|\CRM_Core_BAO_FinancialTrxn
-   */
-  public static function recordAdjustedAmt($updatedAmount, $paidAmount, $contributionId, $taxAmount = NULL, $updateAmountLevel = NULL) {
-    $pendingAmount = CRM_Core_BAO_FinancialTrxn::getBalanceTrxnAmt($contributionId);
-    $pendingAmount = CRM_Utils_Array::value('total_amount', $pendingAmount, 0);
-    $balanceAmt = $updatedAmount - $paidAmount;
-    if ($paidAmount != $pendingAmount) {
-      $balanceAmt -= $pendingAmount;
-    }
-
-    $contributionStatuses = CRM_Contribute_PseudoConstant::contributionStatus(NULL, 'name');
-    $partiallyPaidStatusId = array_search('Partially paid', $contributionStatuses);
-    $pendingRefundStatusId = array_search('Pending refund', $contributionStatuses);
-    $completedStatusId = array_search('Completed', $contributionStatuses);
-
-    $updatedContributionDAO = new CRM_Contribute_BAO_Contribution();
-    $adjustedTrxn = $skip = FALSE;
-    if ($balanceAmt) {
-      if ($balanceAmt > 0 && $paidAmount != 0) {
-        $contributionStatusVal = $partiallyPaidStatusId;
-      }
-      elseif ($balanceAmt < 0 && $paidAmount != 0) {
-        $contributionStatusVal = $pendingRefundStatusId;
-      }
-      elseif ($paidAmount == 0) {
-        //skip updating the contribution status if no payment is made
-        $skip = TRUE;
-        $updatedContributionDAO->cancel_date = 'null';
-        $updatedContributionDAO->cancel_reason = NULL;
-      }
-      // update contribution status and total amount without trigger financial code
-      // as this is handled in current BAO function used for change selection
-      $updatedContributionDAO->id = $contributionId;
-      if (!$skip) {
-        $updatedContributionDAO->contribution_status_id = $contributionStatusVal;
-      }
-      $updatedContributionDAO->total_amount = $updatedContributionDAO->net_amount = $updatedAmount;
-      $updatedContributionDAO->fee_amount = 0;
-      $updatedContributionDAO->tax_amount = $taxAmount;
-      if (!empty($updateAmountLevel)) {
-        $updatedContributionDAO->amount_level = $updateAmountLevel;
-      }
-      $updatedContributionDAO->save();
-      // adjusted amount financial_trxn creation
-      $updatedContribution = CRM_Contribute_BAO_Contribution::getValues(
-        array('id' => $contributionId),
-        CRM_Core_DAO::$_nullArray,
-        CRM_Core_DAO::$_nullArray
-      );
-      $toFinancialAccount = CRM_Contribute_PseudoConstant::getRelationalFinancialAccount($updatedContribution->financial_type_id, 'Accounts Receivable Account is');
-      $adjustedTrxnValues = array(
-        'from_financial_account_id' => NULL,
-        'to_financial_account_id' => $toFinancialAccount,
-        'total_amount' => $balanceAmt,
-        'net_amount' => $balanceAmt,
-        'status_id' => $completedStatusId,
-        'payment_instrument_id' => $updatedContribution->payment_instrument_id,
-        'contribution_id' => $updatedContribution->id,
-        'trxn_date' => date('YmdHis'),
-        'currency' => $updatedContribution->currency,
-      );
-      $adjustedTrxn = CRM_Core_BAO_FinancialTrxn::create($adjustedTrxnValues);
-    }
-    return $adjustedTrxn;
-  }
-
   /**
    * @param int $participantId
    * @param $activityType