AS1024/itflow
1
0
Fork 0
mirror of https://github.com/itflow-org/itflow synced 2026-03-03 12:24:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix Recurring Payment Migration for stripe

Browse Source
This commit is contained in:
johnnyq
2025-09-04 16:07:38 -04:00
parent 9d9bfc65d5
commit d37da2e8ff
1 changed files with 72 additions and 66 deletions
Download Patch File Download Diff File Expand all files Collapse all files

138
admin/database_updates.php
View File

@@ -3849,79 +3849,85 @@ if (LATEST_DATABASE_VERSION > CURRENT_DATABASE_VERSION) {
} }
if (CURRENT_DATABASE_VERSION == '2.2.9') { if (CURRENT_DATABASE_VERSION == '2.2.9') {
// Migrate Stripe Settings over to new Tables // Migrate Stripe Settings over to new Tables
// Get Current Stripe Settings // Get Current Stripe Settings
$sql_stripe_settings = mysqli_query($mysqli, "SELECT * FROM settings WHERE company_id = 1"); $sql_stripe_settings = mysqli_query($mysqli, "SELECT * FROM settings WHERE company_id = 1");
$row = mysqli_fetch_array($sql_stripe_settings); $row = mysqli_fetch_array($sql_stripe_settings);
$config_stripe_enable = intval($row['config_stripe_enable']); $config_stripe_enable = intval($row['config_stripe_enable']);
if ($config_stripe_enable === 1) { if ($config_stripe_enable === 1) {
$config_stripe_publishable = mysqli_real_escape_string($mysqli, $row['config_stripe_publishable']); $config_stripe_publishable = mysqli_real_escape_string($mysqli, $row['config_stripe_publishable']);
$config_stripe_secret = mysqli_real_escape_string($mysqli, $row['config_stripe_secret']); $config_stripe_secret = mysqli_real_escape_string($mysqli, $row['config_stripe_secret']);
$config_stripe_account = intval($row['config_stripe_account']); $config_stripe_account = intval($row['config_stripe_account']);
$config_stripe_expense_vendor = intval($row['config_stripe_expense_vendor']); $config_stripe_expense_vendor = intval($row['config_stripe_expense_vendor']);
$config_stripe_expense_category = intval($row['config_stripe_expense_category']); $config_stripe_expense_category = intval($row['config_stripe_expense_category']);
$config_stripe_percentage_fee = floatval($row['config_stripe_percentage_fee']); $config_stripe_percentage_fee = floatval($row['config_stripe_percentage_fee']);
$config_stripe_flat_fee = floatval($row['config_stripe_flat_fee']); $config_stripe_flat_fee = floatval($row['config_stripe_flat_fee']);
mysqli_query($mysqli,"INSERT INTO payment_providers SET mysqli_query($mysqli,"INSERT INTO payment_providers SET
payment_provider_name = 'Stripe', payment_provider_name = 'Stripe',
payment_provider_public_key = '$config_stripe_publishable', payment_provider_public_key = '$config_stripe_publishable',
payment_provider_private_key = '$config_stripe_secret', payment_provider_private_key = '$config_stripe_secret',
payment_provider_account = $config_stripe_account, payment_provider_account = $config_stripe_account,
payment_provider_expense_vendor = $config_stripe_expense_vendor, payment_provider_expense_vendor = $config_stripe_expense_vendor,
payment_provider_expense_category = $config_stripe_expense_category, payment_provider_expense_category = $config_stripe_expense_category,
payment_provider_expense_percentage_fee = $config_stripe_percentage_fee, payment_provider_expense_percentage_fee = $config_stripe_percentage_fee,
payment_provider_expense_flat_fee = $config_stripe_flat_fee" payment_provider_expense_flat_fee = $config_stripe_flat_fee"
);
$provider_id = mysqli_insert_id($mysqli);
// Migrate Clients and Payment Method over
$sql_stripe_clients = mysqli_query($mysqli, "SELECT * FROM client_stripe WHERE stripe_pm IS NOT NULL AND stripe_pm != ''");
while ($row = mysqli_fetch_array($sql_stripe_clients)) {
$client_id = intval($row['client_id']);
$stripe_id = mysqli_real_escape_string($mysqli, $row['stripe_id']);
$stripe_pm = mysqli_real_escape_string($mysqli, $row['stripe_pm']);
$stripe_pm_details = mysqli_real_escape_string($mysqli, $row['stripe_pm_details'] ?? 'Saved Card');
mysqli_query($mysqli,"INSERT INTO client_payment_provider SET
client_id = $client_id,
payment_provider_id = $provider_id,
payment_provider_client = '$stripe_id'"
); );
mysqli_query($mysqli,"INSERT INTO client_saved_payment_methods SET $provider_id = mysqli_insert_id($mysqli);
saved_payment_provider_method = '$stripe_pm',
saved_payment_description = '$stripe_pm_details', // Migrate Clients and Payment Method over
saved_payment_client_id = $client_id, $sql_stripe_clients = mysqli_query($mysqli, "SELECT * FROM client_stripe WHERE stripe_pm IS NOT NULL AND stripe_pm != ''");
saved_payment_provider_id = $provider_id" while ($row = mysqli_fetch_array($sql_stripe_clients)) {
); $client_id = intval($row['client_id']);
$stripe_id = mysqli_real_escape_string($mysqli, $row['stripe_id']);
$stripe_pm = mysqli_real_escape_string($mysqli, $row['stripe_pm']);
$stripe_pm_details = mysqli_real_escape_string($mysqli, $row['stripe_pm_details'] ?? 'Saved Card');
mysqli_query($mysqli,"INSERT INTO client_payment_provider SET
client_id = $client_id,
payment_provider_id = $provider_id,
payment_provider_client = '$stripe_id'"
);
mysqli_query($mysqli,"INSERT INTO client_saved_payment_methods SET
saved_payment_provider_method = '$stripe_pm',
saved_payment_description = '$stripe_pm_details',
saved_payment_client_id = $client_id,
saved_payment_provider_id = $provider_id"
);
}
} }
// Look up the Stripe provider id we just inserted (or most recent one)
$result = mysqli_query($mysqli, "
SELECT payment_provider_id
FROM payment_providers
WHERE payment_provider_name = 'Stripe'
ORDER BY payment_provider_id DESC
LIMIT 1
");
$stripe = mysqli_fetch_assoc($result);
$stripe_provider_id = intval($stripe['payment_provider_id']);
// Update all Stripe recurring payments to use the single saved method per client
mysqli_query($mysqli, "
UPDATE recurring_payments rp
INNER JOIN invoices i
ON rp.recurring_payment_recurring_invoice_id = i.invoice_id
INNER JOIN client_saved_payment_methods spm
ON spm.saved_payment_client_id = i.invoice_client_id
AND spm.saved_payment_provider_id = $stripe_provider_id
SET
rp.recurring_payment_method = 'Credit Card',
rp.recurring_payment_saved_payment_id = spm.saved_payment_id
WHERE rp.recurring_payment_method = 'Stripe'
");
mysqli_query($mysqli, "UPDATE `settings` SET `config_current_database_version` = '2.3.0'");
} }
// Set Recurring payment method with Stripe to the new saved_payment_id and update the method to Credit Card
$sql_recurring_payments = mysqli_query($mysqli, "SELECT * FROM recurring_payments
LEFT JOIN invoices ON recurring_payment_recurring_invoice_id = invoice_id
LEFT JOIN client_saved_payment_methods ON saved_payment_client_id = invoice_client_id
WHERE recurring_payment_method = 'Stripe'"
);
while ($row = mysqli_fetch_array($sql_recurring_payments)) {
$recurring_payment_id = intval($row['recurring_payment_id']);
$client_id = intval($row['invoice_client_id']);
$saved_payment_id = intval($row['saved_payment_id']);
mysqli_query($mysqli,"UPDATE recurring_payments SET
recurring_payment_method = 'Credit Card',
recurring_payment_saved_payment_id = $saved_payment_id
WHERE recurring_payment_id = $recurring_payment_id"
);
}
mysqli_query($mysqli, "UPDATE `settings` SET `config_current_database_version` = '2.3.0'");
}
if (CURRENT_DATABASE_VERSION == '2.3.0') { if (CURRENT_DATABASE_VERSION == '2.3.0') {
// Migrate Payment Methods from Categories Table to new payment_methods table // Migrate Payment Methods from Categories Table to new payment_methods table
$sql_categories = mysqli_query($mysqli, "SELECT * FROM categories WHERE category_type = 'Payment Method' AND category_name != 'Stripe' AND category_archived_at IS NULL"); $sql_categories = mysqli_query($mysqli, "SELECT * FROM categories WHERE category_type = 'Payment Method' AND category_name != 'Stripe' AND category_archived_at IS NULL");