Wavyzz/dolibarr
2
0
Fork 1
mirror of https://github.com/Dolibarr/dolibarr.git synced 2026-02-10 01:42:33 +01:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #24182 from Hystepik/develop#2

Browse Source 
Fix: stripe ipn.php for payment_intent.succeeded
This commit is contained in:
Laurent Destailleur
2023-03-23 14:23:51 +01:00
committed by GitHub
parent a050d109d4 8f96412ba2
commit dcc04ca018
1 changed files with 166 additions and 115 deletions
Download Patch File Download Diff File Expand all files Collapse all files

281
htdocs/public/stripe/ipn.php
View File

@@ -315,157 +315,208 @@ if ($event->type == 'payout.created') {
$db->commit();
} elseif ($event->type == 'payment_intent.succeeded') { // Called when making payment with PaymentIntent method ($conf->global->STRIPE_USE_NEW_CHECKOUT is on).
dol_syslog("object = ".var_export($event->data, true));
/* TODO LMR We must retreive the invoice and payment amount from the id = ext_payment_id into llx_prelevement_demande
include_once DOL_DOCUMENT_ROOT . '/compta/paiement/class/paiement.class.php';
include_once DOL_DOCUMENT_ROOT . '/compta/paiement/class/paiement.class.php'; //TOTEST
global $stripearrayofkeysbyenv;
$error = 0;
$object = $event->data->object;
$invoice_id = $object->metadata->dol_id;
$ipaddress = $object->metadata->ipaddress;
$invoice_amount = $object->amount / 100;
$TRANSACTIONID = $object->id;
$customer_id = $object->customer;
$errorforinvoice = 0;
$paymentmethod = 'stripe';
$ipaddress = $object->metadata->ipaddress;
$now = dol_now();
$currencyCodeType = strtoupper($object->currency);
$paymentmethodstripeid = $object->payment_method;
$customer_id = $object->customer;
$invoice_id = "";
$paymentTypeId = "";
$payment_amount = 0;
$sql = "SELECT pi.fk_facture, pi.fk_prelevement_bons, pi.amount, pi.type";
$sql .= " FROM llx_prelevement_demande as pi";
$sql .= " WHERE pi.ext_payment_id = '".$db->escape($TRANSACTIONID)."'";
$sql .= " AND pi.traite = '1'";
$sql .= " AND pi.ext_payment_site = '".$db->escape($service)."'";
$result = $db->query($sql);
if ($result) {
$obj = $db->fetch_object($result);
if ($obj) {
$invoice_id = $obj->fk_facture;
$prelevement_bons_id = $obj->fk_prelevement_bons;
$payment_amount = $obj->amount;
$paymentTypeId = $obj->type;
}
} else {
$postactionmessages[] = $db->lasterror();
http_response_code(500);
return -1;
}
global $stripearrayofkeysbyenv;
$stripeacc = $stripearrayofkeysbyenv[$servicestatus]['secret_key'];
dol_syslog("Try to create payment with data = ".json_encode($dataforcard));
dol_syslog("Try to find a payment method with id = ".json_encode($paymentmethodstripeid));
$s = new \Stripe\StripeClient($stripeacc);
$paymentmethodstripe = $s->paymentMethods->retrieve($paymentmethodstripeid);
$paymentTypeId = $paymentmethodstripe->type;
if ($paymentTypeId == "ban") {
$paymentTypeId = "PRE"
} elseif ($paymentTypeId == "sepa_debit") { // is this used ? how ?
$paymentTypeId = "BANCON";
if ($paymentTypeId == "ban" || $paymentTypeId == "sepa_debit") {
$paymentTypeId = "PRE";
} elseif ($paymentTypeId == "card") {
$paymentTypeId = "CB";
}
// TODO LMR Enable this only if this is a payment of a Dolibarr llx_prelevement_demande only
$paiement = new Paiement($db);
$paiement->datepaye = $now;
$paiement->date = $now;
if ($currencyCodeType == $conf->currency) {
$paiement->amounts = [$invoice_id => $invoice_amount]; // Array with all payments dispatching with invoice id
} else {
$paiement->multicurrency_amounts = [$invoice_id => $invoice_amount]; // Array with all payments dispatching
$postactionmessages[] = 'Payment was done in a different currency than currency expected of company';
$ispostactionok = -1;
// Not yet supported, so error
$error++;
$errorforinvoice++;
}
$paiement->paiementid = $paymentTypeId;
$paiement->num_payment = '';
$paiement->note_public = '';
$paiement->note_private = 'StripeSepa payment ' . dol_print_date($now, 'standard') . ' using ' . $paymentmethod . ($ipaddress ? ' from ip ' . $ipaddress : '') . ' - Transaction ID = ' . $TRANSACTIONID;
// TODO LMR Fill the $paiement->ext_payment_id with an ID of payment intent (so 'pi_....'). Like this:
$paiement->ext_payment_id = $TRANSACTIONID.':'.$customer_id.'@'.$stripearrayofkeysbyenv[$servicestatus]['publishable_key']; // May be we should store py_... instead of pi_... but we started with pi_... so we continue.
$paiement->ext_payment_site = $service; // 'StripeLive' or 'Stripe' if test
$db->begin();
if (!$errorforinvoice) {
dol_syslog('* Record payment for invoice id ' . $invoice_id . '. It includes closing of invoice and regenerating document');
// This include closing invoices to 'paid' (and trigger including unsuspending) and regenerating document
$paiement_id = $paiement->create($user, 1);
if ($paiement_id < 0) {
$postactionmessages[] = $paiement->error . ($paiement->error ? ' ' : '') . join("<br>\n", $paiement->errors);
$ispostactionok = -1;
$error++;
$errorforinvoice++;
if ($paymentTypeId == "PRE") {
$paiement = new Paiement($db);
$paiement->datepaye = $now;
$paiement->date = $now;
if ($currencyCodeType == $conf->currency) {
$paiement->amounts = [$invoice_id => $payment_amount]; // Array with all payments dispatching with invoice id
} else {
$postactionmessages[] = 'Payment created';
}
$paiement->multicurrency_amounts = [$invoice_id => $payment_amount]; // Array with all payments dispatching
dol_syslog("The payment has been created for invoice id " . $invoice_id);
}
if (!$errorforinvoice && isModEnabled('banque')) {
dol_syslog('* Add payment to bank');
// The bank used is the one defined into Stripe setup
$bankaccountid = 0;
if ($paymentmethod == 'stripe') {
$bankaccountid = $conf->global->STRIPE_BANK_ACCOUNT_FOR_PAYMENTS;
}
if ($bankaccountid > 0) {
$label = '(CustomerInvoicePayment)';
$result = $paiement->addPaymentToBank($user, 'payment', $label, $bankaccountid, $customer_id, '');
if ($result < 0) {
$postactionmessages[] = $paiement->error . ($paiement->error ? ' ' : '') . join("<br>\n", $paiement->errors);
$ispostactionok = -1;
$error++;
$errorforinvoice++;
} else {
$postactionmessages[] = 'Bank transaction of payment created (by makeStripeSepaRequest)';
}
} else {
$postactionmessages[] = 'Setup of bank account to use in module ' . $paymentmethod . ' was not set. No way to record the payment.';
$postactionmessages[] = 'Payment was done in a different currency than currency expected of company';
$ispostactionok = -1;
// Not yet supported, so error
$error++;
$errorforinvoice++;
}
}
$paiement->paiementid = $paymentTypeId;
$paiement->num_payment = '';
$paiement->note_public = '';
$paiement->note_private = 'StripeSepa payment ' . dol_print_date($now, 'standard') . ' using ' . $servicestatus . ($ipaddress ? ' from ip ' . $ipaddress : '') . ' - Transaction ID = ' . $TRANSACTIONID;
$paiement->ext_payment_id = $TRANSACTIONID.':'.$customer_id.'@'.$stripearrayofkeysbyenv[$servicestatus]['publishable_key']; // May be we should store py_... instead of pi_... but we started with pi_... so we continue.
$paiement->ext_payment_site = $service;
if (!$errorforinvoice && isModEnabled('prelevement')) {
$bon = new BonPrelevement($db);
$idbon = 0;
$sql = "SELECT dp.fk_prelevement_bons as idbon";
$sql .= " FROM ".MAIN_DB_PREFIX."prelevement_demande as dp";
$sql .= " WHERE dp.fk_facture = '".$db->escape($invoice_id)."'";
$sql .= " AND dp.sourcetype = 'facture'";
$sql .= " AND dp.traite = 1";
$ispaymentdone = 0;
$sql = "SELECT p.id FROM llx_paiement as p";
$sql .= " WHERE p.ext_payment_id = '".$db->escape($paiement->ext_payment_id)."'";
$sql .= " AND p.ext_payment_site = '".$db->escape($paiement->ext_payment_site)."'";
$result = $db->query($sql);
if ($result) {
if ($db->num_rows($result)) {
$obj = $db->fetch_object($result);
$idbon = $obj->idbon;
$ispaymentdone = 1;
dol_syslog('* Payment for ext_payment_id '.$paiement->ext_payment_id.' already done. We do not recreate the payment');
}
}
$db->begin();
if (!$error && !$ispaymentdone) {
dol_syslog('* Record payment for invoice id ' . $invoice_id . '. It includes closing of invoice and regenerating document');
// This include closing invoices to 'paid' (and trigger including unsuspending) and regenerating document
$paiement_id = $paiement->create($user, 1);
if ($paiement_id < 0) {
$postactionmessages[] = $paiement->error . ($paiement->error ? ' ' : '') . join("<br>\n", $paiement->errors);
$ispostactionok = -1;
$error++;
} else {
$postactionmessages[] = 'Payment created';
}
dol_syslog("The payment has been created for invoice id " . $invoice_id);
}
if (!$error && isModEnabled('banque')) {
$ispaymentdone = 0;
$sql = "SELECT p.id, p.fk_bank FROM llx_paiement as p";
$sql .= " WHERE p.ext_payment_id = '".$db->escape($paiement->ext_payment_id)."'";
$sql .= " AND p.ext_payment_site = '".$db->escape($paiement->ext_payment_site)."'";
$sql .= " AND p.fk_bank <> 0";
$result = $db->query($sql);
if ($result) {
if ($db->num_rows($result)) {
$ispaymentdone = 1;
$obj = $db->fetch_object($result);
dol_syslog('* Payment already linked to bank record '.$obj->fk_bank.' . We do not recrate the link');
}
}
if (!$ispaymentdone) {
dol_syslog('* Add payment to bank');
// The bank used is the one defined into Stripe setup
$bankaccountid = getDolGlobalInt("STRIPE_BANK_ACCOUNT_FOR_PAYMENTS");
if ($bankaccountid > 0) {
$label = '(CustomerInvoicePayment)';
$result = $paiement->addPaymentToBank($user, 'payment', $label, $bankaccountid, $customer_id, '');
if ($result < 0) {
$postactionmessages[] = $paiement->error . ($paiement->error ? ' ' : '') . join("<br>\n", $paiement->errors);
$ispostactionok = -1;
$error++;
} else {
$postactionmessages[] = 'Bank transaction of payment created (by makeStripeSepaRequest)';
}
} else {
$postactionmessages[] = 'Setup of bank account to use in module ' . $paymentmethod . ' was not set. No way to record the payment.';
$ispostactionok = -1;
$error++;
}
}
} else {
$postactionmessages[] = $db->lasterror();
$ispostactionok = -1;
$error++;
$errorforinvoice++;
}
if (!empty($idbon)) {
$bon->fetch($idbon);
$sql = "UPDATE ".MAIN_DB_PREFIX."prelevement_bons";
$sql .= " SET fk_user_credit = ".$user->id;
$sql .= ", statut = '".$db->escape($bon::STATUS_CREDITED)."'";
$sql .= ", date_credit = '".$db->idate($now)."'";
$sql .= ", credite = 1";
$sql .= " WHERE rowid=".((int) $bon->id);
$sql .= " AND statut = '".$db->escape($bon::STATUS_TRANSFERED)."'";
$db->begin();
if (!$error && isModEnabled('prelevement')) {
$bon = new BonPrelevement($db);
$idbon = 0;
$sql = "SELECT dp.fk_prelevement_bons as idbon";
$sql .= " FROM ".MAIN_DB_PREFIX."prelevement_demande as dp";
$sql .= " JOIN ".MAIN_DB_PREFIX."prelevement_bons as pb"; // Here we join to prevent modification of a prelevement bon already credited
$sql .= " ON pb.rowid = dp.fk_prelevement_bons";
$sql .= " WHERE dp.fk_facture = ".(int) $db->escape($invoice_id);
$sql .= " AND dp.sourcetype = 'facture'";
$sql .= " AND dp.ext_payment_id = '".$db->escape($TRANSACTIONID)."'";
$sql .= " AND dp.traite = 1";
$sql .= " AND statut = ".(int) $db->escape($bon::STATUS_TRANSFERED); // To be sure that it's not already credited
$result = $db->query($sql);
if (!$result) {
$db->rollback();
if ($result) {
if ($db->num_rows($result)) {
$obj = $db->fetch_object($result);
$idbon = $obj->idbon;
dol_syslog('* Set prelevement to credite');
} else {
dol_syslog('* Prelevement not found or already credited');
}
} else {
$postactionmessages[] = $db->lasterror();
$ispostactionok = -1;
$error++;
$errorforinvoice++;
} else {
$db->commit();
}
if (!$error && !empty($idbon)) {
$sql = "UPDATE ".MAIN_DB_PREFIX."prelevement_bons";
$sql .= " SET fk_user_credit = ".(int) $db->escape($user->id);
$sql .= ", statut = ".(int) $db->escape($bon::STATUS_CREDITED);
$sql .= ", date_credit = '".$db->idate($now)."'";
$sql .= ", credite = 1";
$sql .= " WHERE rowid = ".(int) $db->escape($idbon);
$sql .= " AND statut = ".(int) $db->escape($bon::STATUS_TRANSFERED);
$result = $db->query($sql);
if (!$result) {
$postactionmessages[] = $db->lasterror();
$ispostactionok = -1;
$error++;
}
}
if (!$error && !empty($idbon)) {
$sql = "UPDATE ".MAIN_DB_PREFIX."prelevement_lignes";
$sql .= " SET statut = 2";
$sql .= " WHERE fk_prelevement_bons = ".(int) $db->escape($idbon);
$result = $db->query($sql);
if (!$result) {
$postactionmessages[] = $db->lasterror();
$ispostactionok = -1;
$error++;
}
}
}
if (!$error) {
$db->commit();
http_response_code(200);
return 1;
} else {
$db->rollback();
http_response_code(500);
return -1;
}
}
*/
} elseif ($event->type == 'payment_intent.payment_failed') {
// TODO: Redirect to paymentko.php
} elseif ($event->type == 'checkout.session.completed') { // Called when making payment with new Checkout method ($conf->global->STRIPE_USE_NEW_CHECKOUT is on).