DoliModules\Stripe\Model\Stripe::sepaStripe()

Complexity

Conditions	28
Paths	8461

Size

Total Lines	158
Code Lines	104

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function sepaStripe($cu, CompanyPaymentMode $object, $stripeacc = '', $status = 0, $createifnotlinkedtostripe = 0)
    {
        global $conf;
        $sepa = null;

        $sql = "SELECT sa.stripe_card_ref, sa.proprio, sa.iban_prefix as iban, sa.rum"; // stripe_card_ref is 'src_...' for Stripe SEPA
        $sql .= " FROM " . MAIN_DB_PREFIX . "societe_rib as sa";
        $sql .= " WHERE sa.rowid = " . ((int) $object->id); // We get record from ID, no need for filter on entity
        $sql .= " AND sa.type = 'ban'"; //type ban to get normal bank account of customer (prelevement)

        $soc = new Company($this->db);
        $soc->fetch($object->fk_soc);

        dol_syslog(get_class($this) . "::sepaStripe search stripe ban id for paymentmode id=" . $object->id . ", stripeacc=" . $stripeacc . ", status=" . $status . ", createifnotlinkedtostripe=" . $createifnotlinkedtostripe, LOG_DEBUG);
        $resql = $this->db->query($sql);
        if ($resql) {
            $num = $this->db->num_rows($resql);
            if ($num) {
                $obj = $this->db->fetch_object($resql);
                $cardref = $obj->stripe_card_ref;
                dol_syslog(get_class($this) . "::sepaStripe paymentmode=" . $cardref);
                if ($cardref) {
                    try {
                        if (empty($stripeacc)) {                // If the Stripe connect account not set, we use common API usage
                            if (!preg_match('/^pm_/', $cardref) && !empty($cu->sources)) {
                                $sepa = $cu->sources->retrieve($cardref);
                            } else {
                                $sepa = \Stripe\PaymentMethod::retrieve($cardref);
                            }
                        } else {
                            if (!preg_match('/^pm_/', $cardref) && !empty($cu->sources)) {
                                //$sepa = $cu->sources->retrieve($cardref, array("stripe_account" => $stripeacc));      // this API fails when array stripe_account is provided
                                $sepa = $cu->sources->retrieve($cardref);
                            } else {
                                //$sepa = \Stripe\PaymentMethod::retrieve($cardref, array("stripe_account" => $stripeacc));     // Don't know if this works
                                $sepa = \Stripe\PaymentMethod::retrieve($cardref);
                            }
                        }
                    } catch (Exception $e) {
                        $this->error = $e->getMessage();
                        dol_syslog($this->error, LOG_WARNING);
                    }
                } elseif ($createifnotlinkedtostripe) {
                    $iban = $obj->iban;
                    $ipaddress = getUserRemoteIP();
                    $metadata = ['dol_version' => DOL_VERSION, 'dol_entity' => $conf->entity, 'ipaddress' => $ipaddress];
                    if (is_object($object)) {
                        $metadata['dol_type'] = $object->element;
                        $metadata['dol_id'] = $object->id;
                        $metadata['dol_thirdparty_id'] = $soc->id;
                    }

                    $description = 'SEPA for IBAN ' . $iban;

                    $dataforcard = [
                        'type' => 'sepa_debit',
                        "sepa_debit" => ['iban' => $iban],
                        'billing_details' => [
                            'name' => $soc->name,
                            'email' => !empty($soc->email) ? $soc->email : "",
                        ],
                        "metadata" => $metadata,
                    ];
                    // Complete owner name
                    if (!empty($soc->town)) {
                        $dataforcard['billing_details']['address']['city'] = $soc->town;
                    }
                    if (!empty($soc->country_code)) {
                        $dataforcard['billing_details']['address']['country'] = $soc->country_code;
                    }
                    if (!empty($soc->address)) {
                        $dataforcard['billing_details']['address']['line1'] = $soc->address;
                    }
                    if (!empty($soc->zip)) {
                        $dataforcard['billing_details']['address']['postal_code'] = $soc->zip;
                    }
                    if (!empty($soc->state)) {
                        $dataforcard['billing_details']['address']['state'] = $soc->state;
                    }

                    //$a = \Stripe\Stripe::getApiKey();
                    //var_dump($a);var_dump($stripeacc);exit;
                    try {
                        dol_syslog("Try to create sepa_debit");

                        $service = 'StripeTest';
                        $servicestatus = 0;
                        if (getDolGlobalString('STRIPE_LIVE') && !GETPOST('forcesandbox', 'alpha')) {
                            $service = 'StripeLive';
                            $servicestatus = 1;
                        }
                        // Force to use the correct API key
                        global $stripearrayofkeysbyenv;
                        $stripeacc = $stripearrayofkeysbyenv[$servicestatus]['secret_key'];

                        dol_syslog("Try to create sepa_debit with data = " . json_encode($dataforcard));

                        $s = new \Stripe\StripeClient($stripeacc);

                        //var_dump($dataforcard);exit;

                        $sepa = $s->paymentMethods->create($dataforcard);
                        if (!$sepa) {
                            $this->error = 'Creation of payment method sepa_debit on Stripe has failed';
                        } else {
                            // link customer and src
                            //$cs = $this->getSetupIntent($description, $soc, $cu, '', $status);
                            $dataforintent = [0 => ['description' => $description, 'payment_method_types' => ['sepa_debit'], 'customer' => $cu->id, 'payment_method' => $sepa->id], 'metadata' => $metadata];

                            $cs = $s->setupIntents->create($dataforintent);
                            //$cs = $s->setupIntents->update($cs->id, ['payment_method' => $sepa->id]);
                            $cs = $s->setupIntents->confirm($cs->id, ['mandate_data' => ['customer_acceptance' => ['type' => 'offline']]]);
                            // note: $cs->mandate contains ID of mandate on Stripe side

                            if (!$cs) {
                                $this->error = 'Link SEPA <-> Customer failed';
                            } else {
                                dol_syslog("Update the payment mode of the customer");

                                // print json_encode($sepa);

                                // Save the Stripe payment mode ID into the Dolibarr database
                                $sql = "UPDATE " . MAIN_DB_PREFIX . "societe_rib";
                                $sql .= " SET stripe_card_ref = '" . $this->db->escape($sepa->id) . "',";
                                $sql .= " card_type = 'sepa_debit',";
                                $sql .= " stripe_account= '" . $this->db->escape($cu->id . "@" . $stripeacc) . "',";
                                $sql .= " ext_payment_site = '" . $this->db->escape($service) . "'";
                                if (!empty($cs->mandate)) {
                                    $mandateservice = new \Stripe\Mandate($stripeacc);
                                    $mandate = $mandateservice->retrieve($cs->mandate);
                                    if (is_object($mandate) && is_object($mandate->payment_method_details) && is_object($mandate->payment_method_details->sepa_debit)) {
                                        $refmandate = $mandate->payment_method_details->sepa_debit->reference;
                                        //$urlmandate = $mandate->payment_method_details->sepa_debit->url;
                                        $sql .= ", rum = '" . $this->db->escape($refmandate) . "'";
                                    }
                                    $sql .= ", comment = '" . $this->db->escape($cs->mandate) . "'";
                                    $sql .= ", date_rum = '" . $this->db->idate(dol_now()) . "'";
                                }
                                $sql .= " WHERE rowid = " . ((int) $object->id);
                                $sql .= " AND type = 'ban'";
                                $resql = $this->db->query($sql);
                                if (!$resql) {
                                    $this->error = $this->db->lasterror();
                                }
                            }
                        }
                    } catch (Exception $e) {
                        $sepa = null;
                        $this->error = 'Stripe error: ' . $e->getMessage() . '. Check the BAN information.';
                        dol_syslog($this->error, LOG_WARNING);  // Error from Stripe, so a warning on Dolibarr
                    }
                }
            }
        } else {
            dol_print_error($this->db);
        }

        return $sepa;
    }