Skip to content

fix: exclude sandbox payments, export all with filters, add compare s… #67

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
Bhav-ikkk merged 2 commits into from
Mar 29, 2026
Merged

fix: exclude sandbox payments, export all with filters, add compare s… #67

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
5788267
fix: exclude sandbox payments, export all with filters, add compare s…
Bhav-ikkk Mar 29, 2026
fe772c5
fixed query
Bhav-ikkk Mar 29, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
387 changes: 387 additions & 0 deletions scripts/compare-payments.js
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,387 @@
/**
* Payment Comparison Script
* Compares Juspay HDFC Dashboard CSV with Admin Portal Export CSV
* to find missing/mismatched payments.
*
* Usage: node scripts/compare-payments.js
*
* Place the following files in your Downloads folder:
* 1. Juspay CSV (HDFC dashboard export) - filename starting with "44207_tab_performance"
* 2. Admin CSV (portal export) - filename starting with "payments_all"
*/

const fs = require('fs');
const path = require('path');
const os = require('os');

// ─── CSV Parser (handles quoted fields with commas) ───
function parseCSV(content) {
const lines = content.trim().split(/\r?\n/);
const headers = parseCSVLine(lines[0]);
const rows = [];
for (let i = 1; i < lines.length; i++) {
Comment on lines +18 to +22

Copilot AI Mar 29, 2026

Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

parseCSV() splits lines using split('\n'), which will leave trailing \r characters when the CSV uses Windows line endings (\r\n)—this can corrupt the last column/header and break comparisons. Consider splitting with /\r?\n/ (and/or trimming a trailing \r in parseCSVLine).

Copilot uses AI. Check for mistakes.
const line = lines[i].trim();
if (!line) continue;
const values = parseCSVLine(line);
const row = {};
headers.forEach((h, idx) => {
row[h.trim()] = (values[idx] || '').trim();
});
rows.push(row);
}
return rows;
}

function parseCSVLine(line) {
const result = [];
let current = '';
let inQuotes = false;
for (let i = 0; i < line.length; i++) {
const ch = line[i];
if (ch === '"') {
if (inQuotes && line[i + 1] === '"') {
current += '"';
i++;
} else {
inQuotes = !inQuotes;
}
} else if (ch === ',' && !inQuotes) {
result.push(current);
current = '';
} else {
current += ch;
}
}
result.push(current);
return result;
}

// ─── Find CSV files in Downloads ───
const downloadsDir = path.join(os.homedir(), 'Downloads');

function findFile(prefix) {
const files = fs.readdirSync(downloadsDir);
// Find most recent matching file
const matches = files
.filter(f => f.startsWith(prefix) && f.endsWith('.csv'))
.map(f => ({ name: f, mtime: fs.statSync(path.join(downloadsDir, f)).mtime }))
.sort((a, b) => b.mtime - a.mtime);
return matches.length > 0 ? path.join(downloadsDir, matches[0].name) : null;
}

const juspayFile = findFile('44207_tab_performance');
const adminFile = findFile('payments_all');

if (!juspayFile) {
console.error('❌ Juspay CSV not found in Downloads! (looking for 44207_tab_performance*.csv)');
process.exit(1);
}
if (!adminFile) {
console.error('❌ Admin CSV not found in Downloads! (looking for payments_all*.csv)');
process.exit(1);
}

console.log('📁 Juspay CSV:', path.basename(juspayFile));
console.log('📁 Admin CSV:', path.basename(adminFile));
console.log('');

// ─── Parse both CSVs ───
const juspayData = parseCSV(fs.readFileSync(juspayFile, 'utf-8'));
const adminData = parseCSV(fs.readFileSync(adminFile, 'utf-8'));

// ─── Build lookup maps ───

// Juspay: Group by order_id, track all txn attempts and final status
// For each unique order_id, find the last transaction attempt's status
const juspayByOrder = {};
for (const row of juspayData) {
const orderId = row.order_id;
if (!juspayByOrder[orderId]) {
juspayByOrder[orderId] = [];
}
juspayByOrder[orderId].push(row);
}

// Determine final Juspay status for each order (SUCCESS if any attempt was SUCCESS)
const juspayFinalStatus = {};
for (const [orderId, attempts] of Object.entries(juspayByOrder)) {
const hasSuccess = attempts.some(a => a.payment_status === 'SUCCESS');
juspayFinalStatus[orderId] = {
status: hasSuccess ? 'SUCCESS' : 'FAILURE',
amount: parseFloat(attempts[0].amount),
attempts: attempts.length,
successTxn: attempts.find(a => a.payment_status === 'SUCCESS'),
allAttempts: attempts,
customerId: attempts[0].customer_id,
platform: attempts[0].platform,
};
}

// Admin: Map by Juspay ID (which is the order_id from Juspay)
const adminByJuspayId = {};
const adminByOrderId = {}; // by admin's internal Order ID
for (const row of adminData) {
const juspayId = row['Juspay ID'];
if (juspayId) {
adminByJuspayId[juspayId] = row;
}
adminByOrderId[row['Order ID']] = row;
}
Comment on lines +89 to +129

@coderabbitai coderabbitai Bot Mar 29, 2026

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

⚠️ Potential issue | 🟠 Major

Fail fast when the CSV headers do not match the expected export shape.

This script is keyed off exact columns like order_id, payment_status, Order ID, Juspay ID, and Gateway Status. If someone grabs the wrong file or the admin headers drift from src/views/admin/payments/PaymentAnalysisView.js:145-160, adminByJuspayId goes empty and Section 4 can emit misleading fix SQL for every successful Juspay order.

🧪 Suggested guardrail 
 function parseCSV(content) {
   const lines = content.trim().split(/\r?\n/);
-  const headers = parseCSVLine(lines[0]);
+  const headers = parseCSVLine(lines[0]).map(h => h.trim());
   const rows = [];
   for (let i = 1; i < lines.length; i++) {
     const line = lines[i].trim();
     if (!line) continue;
     const values = parseCSVLine(line);
     const row = {};
     headers.forEach((h, idx) => {
-      row[h.trim()] = (values[idx] || '').trim();
+      row[h] = (values[idx] || '').trim();
     });
     rows.push(row);
   }
-  return rows;
+  return { headers, rows };
+}
+
+function assertRequiredColumns(headers, required, label) {
+  const present = new Set(headers);
+  const missing = required.filter(column => !present.has(column));
+  if (missing.length > 0) {
+    throw new Error(`${label} CSV is missing required columns: ${missing.join(', ')}`);
+  }
 }
 
-const juspayData = parseCSV(fs.readFileSync(juspayFile, 'utf-8'));
-const adminData = parseCSV(fs.readFileSync(adminFile, 'utf-8'));
+const { headers: juspayHeaders, rows: juspayData } = parseCSV(fs.readFileSync(juspayFile, 'utf-8'));
+const { headers: adminHeaders, rows: adminData } = parseCSV(fs.readFileSync(adminFile, 'utf-8'));
+
+assertRequiredColumns(juspayHeaders, ['order_id', 'payment_status', 'amount'], 'Juspay');
+assertRequiredColumns(adminHeaders, ['Order ID', 'Juspay ID', 'Gateway Status', 'Status', 'Amount'], 'Admin');
🤖 Prompt for AI Agents 
Verify each finding against the current code and only fix it if needed.

In `@scripts/compare-payments.js` around lines 89 - 129, Add explicit header
validation immediately after parseCSV results for both juspayData and adminData:
check that each row contains the expected keys used later (e.g., for Juspay
rows: order_id, payment_status, amount, customer_id, platform; for Admin rows:
Juspay ID, Order ID, Gateway Status). Implement this validation in the same
scope where juspayData/adminData are created (before building juspayByOrder or
adminByJuspayId) and if any required header is missing, throw or exit with a
clear error referencing the missing header(s) and the source file variable
(juspayData/adminData) so the script fails fast instead of producing empty
lookups like juspayByOrder or adminByJuspayId and generating misleading SQL.


// ═══════════════════════════════════════════════════════════
// SECTION 1: Find SUCCESS payments in Juspay that are NOT
// showing as "success" in Admin portal
// ═══════════════════════════════════════════════════════════
console.log('═══════════════════════════════════════════════════════════');
console.log(' SECTION 1: MISSING / MISMATCHED PAYMENTS');
console.log(' (Juspay = SUCCESS but Admin ≠ success)');
console.log('═══════════════════════════════════════════════════════════');
console.log('');

const missingPayments = [];
const mismatchedPayments = [];

for (const [orderId, info] of Object.entries(juspayFinalStatus)) {
if (info.status !== 'SUCCESS') continue; // Only care about successful Juspay payments

const adminRow = adminByJuspayId[orderId];

if (!adminRow) {
// Order exists in Juspay but NOT in admin portal at all
missingPayments.push({ orderId, ...info });
} else {
const adminGatewayStatus = adminRow['Gateway Status'];
const adminStatus = adminRow['Status'];

if (adminGatewayStatus !== 'success') {
mismatchedPayments.push({
orderId,
juspayInfo: info,
adminRow,
});
}
}
}

console.log(`🔍 Total unique orders in Juspay CSV: ${Object.keys(juspayByOrder).length}`);
console.log(`🔍 Total successful orders in Juspay: ${Object.values(juspayFinalStatus).filter(v => v.status === 'SUCCESS').length}`);
console.log(`🔍 Total rows in Admin CSV: ${adminData.length}`);
console.log(`🔍 Admin rows with gateway_status=success: ${adminData.filter(r => r['Gateway Status'] === 'success').length}`);
console.log('');

if (missingPayments.length > 0) {
console.log(`⚠️ ${missingPayments.length} Juspay SUCCESS payment(s) NOT FOUND in Admin portal:`);
console.log('─'.repeat(80));
for (const mp of missingPayments) {
console.log(` Order ID: ${mp.orderId}`);
console.log(` Amount: ₹${mp.amount}`);
console.log(` Customer ID: ${mp.customerId}`);
console.log(` Platform: ${mp.platform}`);
if (mp.successTxn) {
console.log(` Juspay Txn ID: ${mp.successTxn.juspay_txn_id}`);
console.log(` Txn UUID: ${mp.successTxn.txn_uuid}`);
}
console.log('─'.repeat(80));
}
console.log('');
}

if (mismatchedPayments.length > 0) {
console.log(`⚠️ ${mismatchedPayments.length} payment(s) SUCCESS in Juspay but NOT success in Admin:`);
console.log('─'.repeat(80));
for (const mm of mismatchedPayments) {
const a = mm.adminRow;
console.log(` Order ID: ${mm.orderId}`);
console.log(` Admin Booking #: ${a['Order ID']}`);
console.log(` User: ${a['User']}`);
console.log(` Email: ${a['Email']}`);
console.log(` Phone: ${a['Phone']}`);
console.log(` Event: ${a['Event']}`);
console.log(` Amount: ₹${a['Amount']} (Juspay: ₹${mm.juspayInfo.amount})`);
console.log(` Admin Status: ${a['Status']} | Gateway: ${a['Gateway Status']}`);
console.log(` Juspay Status: SUCCESS`);
console.log(` Booking Date: ${a['Date']}`);
if (mm.juspayInfo.successTxn) {
console.log(` Juspay Txn ID: ${mm.juspayInfo.successTxn.juspay_txn_id}`);
console.log(` Txn UUID: ${mm.juspayInfo.successTxn.txn_uuid}`);
}
console.log(` ⚡ ACTION NEEDED: Payment received but booking not confirmed!`);
console.log('─'.repeat(80));
}
console.log('');
}

if (missingPayments.length === 0 && mismatchedPayments.length === 0) {
console.log('✅ No missing or mismatched payments found!');
console.log('');
}

// ═══════════════════════════════════════════════════════════
// SECTION 2: Details for the 2 specific Image Order IDs
// ═══════════════════════════════════════════════════════════
console.log('═══════════════════════════════════════════════════════════');
console.log(' SECTION 2: IMAGE ORDER ID DETAILS');
console.log('═══════════════════════════════════════════════════════════');
console.log('');

const imageOrderIds = [
'CIT-1774452223765-24F89F26', // Image 1: 44207-CIT-1774452223765-24F89F26-1
'CIT-1774552664401-8C339AC7', // Image 2: 44207-CIT-1774552664401-8C339AC7-1
];

for (const orderId of imageOrderIds) {
console.log(`📋 Order: ${orderId}`);
console.log('─'.repeat(70));

// Juspay data
const juspayEntries = juspayByOrder[orderId];
if (juspayEntries) {
console.log(' [JUSPAY HDFC Dashboard]');
for (const entry of juspayEntries) {
console.log(` Txn ID: ${entry.juspay_txn_id}`);
console.log(` Amount: ₹${entry.amount}`);
console.log(` Status: ${entry.payment_status}`);
console.log(` Platform: ${entry.platform}`);
console.log(` Customer: ${entry.customer_id}`);
console.log(` Txn UUID: ${entry.txn_uuid}`);
console.log(` Error: ${entry.error_code || 'None'}`);
console.log('');
}
} else {
console.log(' [JUSPAY] ❌ Not found in Juspay CSV');
}

// Admin data
const adminRow = adminByJuspayId[orderId];
if (adminRow) {
console.log(' [ADMIN Portal]');
console.log(` Booking #: ${adminRow['Order ID']}`);
console.log(` User: ${adminRow['User']}`);
console.log(` Email: ${adminRow['Email']}`);
console.log(` Phone: ${adminRow['Phone']}`);
console.log(` Event: ${adminRow['Event']}`);
console.log(` Amount: ₹${adminRow['Amount']}`);
console.log(` Qty: ${adminRow['Qty']}`);
console.log(` Status: ${adminRow['Status']}`);
console.log(` Gateway Status: ${adminRow['Gateway Status']}`);
console.log(` Transaction ID: ${adminRow['Transaction ID'] || 'NONE'}`);
console.log(` Date: ${adminRow['Date']}`);
} else {
console.log(' [ADMIN] ❌ Not found in Admin CSV');
}

// Mismatch check
if (juspayEntries && adminRow) {
const juspayHasSuccess = juspayEntries.some(e => e.payment_status === 'SUCCESS');
const adminIsSuccess = adminRow['Gateway Status'] === 'success';
if (juspayHasSuccess && !adminIsSuccess) {
console.log('');
console.log(' 🚨 MISMATCH: Juspay shows SUCCESS but Admin shows ' +
`${adminRow['Status']}/${adminRow['Gateway Status']}`);
console.log(' ⚡ This payment was COLLECTED but booking is NOT confirmed!');
} else if (juspayHasSuccess && adminIsSuccess) {
console.log('');
console.log(' ✅ MATCH: Both Juspay and Admin show successful payment');
}
}

console.log('');
console.log('═'.repeat(70));
console.log('');
}

// ═══════════════════════════════════════════════════════════
// SECTION 3: Summary Statistics
// ═══════════════════════════════════════════════════════════
console.log('═══════════════════════════════════════════════════════════');
console.log(' SECTION 3: SUMMARY');
console.log('═══════════════════════════════════════════════════════════');
console.log('');

const juspaySuccessCount = Object.values(juspayFinalStatus).filter(v => v.status === 'SUCCESS').length;
const juspayFailCount = Object.values(juspayFinalStatus).filter(v => v.status === 'FAILURE').length;
const juspaySuccessAmount = Object.values(juspayFinalStatus)
.filter(v => v.status === 'SUCCESS')
.reduce((sum, v) => sum + v.amount, 0);

const adminSuccessCount = adminData.filter(r => r['Gateway Status'] === 'success').length;
const adminSuccessAmount = adminData
.filter(r => r['Gateway Status'] === 'success')
.reduce((sum, r) => sum + parseFloat(r['Amount'] || 0), 0);

console.log('Juspay HDFC Dashboard:');
console.log(` Total unique orders: ${Object.keys(juspayByOrder).length}`);
console.log(` Successful: ${juspaySuccessCount} (₹${juspaySuccessAmount.toFixed(2)})`);
console.log(` Failed: ${juspayFailCount}`);
console.log('');
console.log('Admin Portal:');
console.log(` Total bookings: ${adminData.length}`);
console.log(` Gateway Success: ${adminSuccessCount} (₹${adminSuccessAmount.toFixed(2)})`);
console.log(` Confirmed: ${adminData.filter(r => r['Status'] === 'confirmed').length}`);
console.log(` Pending: ${adminData.filter(r => r['Status'] === 'pending').length}`);
console.log(` Cancelled: ${adminData.filter(r => r['Status'] === 'cancelled').length}`);
console.log('');
console.log(`📊 Difference: ${juspaySuccessCount - adminSuccessCount} payment(s) SUCCESS in Juspay but not in Admin`);
console.log(`💰 Revenue difference: ₹${(juspaySuccessAmount - adminSuccessAmount).toFixed(2)}`);
console.log('');

// ═══════════════════════════════════════════════════════════
// SECTION 4: SQL Queries for DB investigation
// ═══════════════════════════════════════════════════════════
console.log('═══════════════════════════════════════════════════════════');
console.log(' SECTION 4: SQL QUERIES FOR DB FIX');
console.log(' (Run these against your PostgreSQL database)');
console.log('═══════════════════════════════════════════════════════════');
console.log('');

// Generate SQL for each mismatched payment
const allProblematic = [...mismatchedPayments];
if (allProblematic.length > 0) {
console.log('-- Query to check the problematic bookings:');
const problemOrderIds = allProblematic.map(p => `'${p.orderId}'`).join(', ');
console.log(`SELECT b.id, b.status, b.juspay_order_id, b.total_amount, b.created_at,`);
console.log(` p.status as payment_status, p.gateway_status, p.transaction_id, p.paid_at,`);
console.log(` u.name, u.email, u.phone,`);
console.log(` e.title as event_name`);

@coderabbitai coderabbitai Bot Mar 29, 2026

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

⚠️ Potential issue | 🟡 Minor

🧩 Analysis chain

🏁 Script executed:

#!/bin/bash
# Verify the events table column name
rg -n "e\.name\s+AS\s+(event_name|event)" src/services/admin-service.js | head -5
# Check schema for events table structure
rg -n "CREATE TABLE events" -A 20 schema.sql 2>/dev/null || rg -n "CREATE TABLE events" -A 20 . --type sql

Repository: NexEvent/Citronics_2k26

Length of output: 1328

🏁 Script executed:

cat -n scripts/compare-payments.js | sed -n '340,350p'

Repository: NexEvent/Citronics_2k26

Length of output: 853

Column name mismatch: e.title should be e.name.

The events table schema defines the event name column as name, not title. The query being logged at line 345 references a non-existent column and would fail if executed.

🤖 Prompt for AI Agents 
Verify each finding against the current code and only fix it if needed.

In `@scripts/compare-payments.js` at line 345, Update the logged SQL fragment that
references a non-existent column by replacing "e.title as event_name" with
"e.name as event_name" in the console.log inside scripts/compare-payments.js
(the logged query string that currently contains e.title) so the column matches
the events table schema.

console.log(`FROM bookings b`);
console.log(`LEFT JOIN payments p ON p.booking_id = b.id`);
console.log(`LEFT JOIN users u ON u.id = b.user_id`);
console.log(`LEFT JOIN booking_items bi ON bi.booking_id = b.id`);
console.log(`LEFT JOIN events e ON e.id = bi.event_id`);
console.log(`WHERE b.juspay_order_id IN (${problemOrderIds});`);
Comment on lines +341 to +351

@coderabbitai coderabbitai Bot Mar 29, 2026

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

⚠️ Potential issue | 🟡 Minor

SQL injection risk in generated queries if CSV contains malicious data.

The order IDs are directly interpolated into SQL strings without escaping. If someone crafts a malicious CSV with an order_id like '; DROP TABLE bookings; --, the generated SQL could be dangerous when copy-pasted. Consider escaping single quotes or adding a warning comment.

🛡️ Proposed fix to escape single quotes 
+// Helper to escape single quotes for SQL literals
+function escapeSql(str) {
+  return String(str).replace(/'/g, "''");
+}
+
 if (allProblematic.length > 0) {
   console.log('-- Query to check the problematic bookings:');
-  const problemOrderIds = allProblematic.map(p => `'${p.orderId}'`).join(', ');
+  const problemOrderIds = allProblematic.map(p => `'${escapeSql(p.orderId)}'`).join(', ');

Apply similar escaping to all orderId and juspay_txn_id interpolations in SQL strings.

🤖 Prompt for AI Agents 
Verify each finding against the current code and only fix it if needed.

In `@scripts/compare-payments.js` around lines 341 - 351, The code builds SQL by
interpolating order IDs (problemOrderIds) directly from allProblematic, exposing
SQL injection risk; update the mapping that builds problemOrderIds to escape
single quotes in each orderId (replace each ' with ''), and apply the same
escaping wherever juspay_txn_id or other CSV-derived values are interpolated
into SQL strings; also add a short console.warn before printing the query
warning that these queries are for inspection only and should not be executed
against production without parameterization or proper escaping.

console.log('');

console.log('-- Fix queries (UPDATE status for confirmed payments):');
console.log('-- ⚠️ VERIFY EACH ONE BEFORE RUNNING! Check Juspay dashboard first.');
console.log('');
for (const mm of allProblematic) {
const a = mm.adminRow;
const successTxn = mm.juspayInfo.successTxn;
console.log(`-- Fix: ${a['User']} - ${a['Event']} - ₹${a['Amount']}`);
console.log(`-- Juspay Txn: ${successTxn ? successTxn.juspay_txn_id : 'N/A'}`);
console.log(`UPDATE bookings SET status = 'confirmed' WHERE juspay_order_id = '${mm.orderId}';`);
if (successTxn) {
console.log(`UPDATE payments SET status = 'completed', gateway_status = 'success',`);
console.log(` transaction_id = '${successTxn.juspay_txn_id}',`);
console.log(` paid_at = NOW()`);
console.log(` WHERE booking_id = (SELECT id FROM bookings WHERE juspay_order_id = '${mm.orderId}');`);
Comment on lines +343 to +367

@coderabbitai coderabbitai Bot Mar 29, 2026

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

⚠️ Potential issue | 🟠 Major

Update the same payment status field/value that the export reads.

src/services/admin-service.js:1-30 exposes the admin CSV’s “Gateway Status” from p.status AS gateway_status, and this script only treats 'success' as successful on Line 156 and Line 307. The generated fix SQL sets payments.status = 'completed' and separately updates gateway_status, so rerunning the export can still leave the row non-success. paid_at = NOW() also rewrites the original settlement time.

🛠️ Suggested fix 
-  console.log(`       p.status as payment_status, p.gateway_status, p.transaction_id, p.paid_at,`);
+  console.log(`       p.status as payment_status, p.transaction_id, p.paid_at,`);
...
-      console.log(`UPDATE payments SET status = 'completed', gateway_status = 'success',`);
-      console.log(`  transaction_id = '${successTxn.juspay_txn_id}',`);
-      console.log(`  paid_at = NOW()`);
+      console.log(`UPDATE payments SET status = 'success',`);
+      console.log(`  transaction_id = '${successTxn.juspay_txn_id}'`);
...
-  console.log(`       p.status as pay_status, p.gateway_status, p.transaction_id,`);
+  console.log(`       p.status as payment_status, p.transaction_id,`);

Also applies to: 377-379

🤖 Prompt for AI Agents 
Verify each finding against the current code and only fix it if needed.

In `@scripts/compare-payments.js` around lines 343 - 367, The export uses
payments.status as gateway_status, but the fix SQL sets payments.status =
'completed' while the CSV checks for 'success', and also overwrites paid_at with
NOW(); update the UPDATE logic in the loop that builds SQL (around variables mm,
a, successTxn and the generated UPDATE statements) to set the same field/value
the export reads (use payments.status = 'success' or whatever exact token the
export expects instead of 'completed') and set gateway_status consistently, and
do NOT set paid_at = NOW() — instead use the original Juspay settlement
timestamp from successTxn (e.g. successTxn.settled_at or
successTxn.settlement_time) or omit paid_at so the original value is preserved;
make the same correction for the second occurrence that the comment notes (the
other UPDATE block around lines 377-379).

}
console.log('');
}
}

// Image order queries
console.log('-- Query for the 2 specific Image Order IDs:');
for (const orderId of imageOrderIds) {
console.log(`SELECT b.id, b.status, b.juspay_order_id, b.total_amount,`);
console.log(` p.status as pay_status, p.gateway_status, p.transaction_id,`);
console.log(` p.sdk_payload::text as sdk_payload_text,`);
console.log(` u.name, u.email, u.phone, e.title as event`);
console.log(`FROM bookings b`);
console.log(`LEFT JOIN payments p ON p.booking_id = b.id`);
console.log(`LEFT JOIN users u ON u.id = b.user_id`);
console.log(`LEFT JOIN booking_items bi ON bi.booking_id = b.id`);
console.log(`LEFT JOIN events e ON e.id = bi.event_id`);
console.log(`WHERE b.juspay_order_id = '${orderId}';`);
console.log('');
}
4 changes: 3 additions & 1 deletion src/pages/api/admin/payments/index.js
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,9 @@ export default async function handler(req, res) {

try {
const managerId = permissions.isOwner ? null : user.id
const limit = Math.min(Math.max(parseInt(req.query.limit) || 50, 1), 200)
const isExport = req.query.export === 'true'
const maxLimit = isExport ? 10000 : 200
const limit = Math.min(Math.max(parseInt(req.query.limit) || 50, 1), maxLimit)
const offset = Math.max(parseInt(req.query.offset) || 0, 0)
const status = ['confirmed', 'pending', 'cancelled'].includes(req.query.status)
? req.query.status
Expand Down
Loading
Loading