eab14ff1e1
- Ubah data menjadi array untuk memungkinkan pemrosesan batch. - Tambahkan loop untuk memproses setiap data entry dan mendispatch job secara individual. - Simpan job id dari setiap job yang didispatch ke array `jobIds`. - Update respons JSON untuk mencantumkan daftar job yang telah didispatch: - Tambahkan informasi `job_id`, `account_number`, `period`, dan `file_name` untuk setiap job. - Memperbaiki pesan respons agar sesuai dengan perubahan proses yang mendukung banyak job.
317 lines
12 KiB
PHP
317 lines
12 KiB
PHP
<?php
|
|
|
|
namespace Modules\Webstatement\Http\Controllers;
|
|
|
|
use App\Http\Controllers\Controller;
|
|
use Carbon\Carbon;
|
|
use Illuminate\Contracts\Bus\Dispatcher;
|
|
use Illuminate\Http\Request;
|
|
use Illuminate\Support\Facades\DB;
|
|
use Illuminate\Support\Facades\Storage;
|
|
use Modules\Webstatement\Jobs\ExportStatementJob;
|
|
use Modules\Webstatement\Models\StmtEntry;
|
|
use Modules\Webstatement\Models\TempFundsTransfer;
|
|
use Modules\Webstatement\Models\TempStmtNarrFormat;
|
|
use Modules\Webstatement\Models\TempStmtNarrParam;
|
|
|
|
class WebstatementController extends Controller
|
|
{
|
|
/**
|
|
* Display a listing of the resource.
|
|
*/
|
|
public function index()
|
|
{
|
|
$data = [[
|
|
'account_number' => '1080425781',
|
|
'period' => '2025012',
|
|
'saldo' => '23984352604'
|
|
],[
|
|
'account_number' => '1080425781',
|
|
'period' => '2025013',
|
|
'saldo' => '13984352604'
|
|
]];
|
|
|
|
$jobIds = [];
|
|
|
|
// Process each data entry
|
|
foreach ($data as $entry) {
|
|
// Dispatch job for each entry
|
|
$job = new ExportStatementJob(
|
|
$entry['account_number'],
|
|
$entry['period'],
|
|
$entry['saldo']
|
|
);
|
|
$jobIds[] = app(Dispatcher::class)->dispatch($job);
|
|
}
|
|
|
|
return response()->json([
|
|
'message' => 'Statement export jobs have been queued',
|
|
'jobs' => array_map(function($index, $jobId) use ($data) {
|
|
return [
|
|
'job_id' => $jobId,
|
|
'account_number' => $data[$index]['account_number'],
|
|
'period' => $data[$index]['period'],
|
|
'file_name' => "{$data[$index]['account_number']}_{$data[$index]['period']}.csv"
|
|
];
|
|
}, array_keys($jobIds), $jobIds)
|
|
]);
|
|
}
|
|
|
|
/**
|
|
* Download a previously exported statement
|
|
*/
|
|
public function downloadStatement(Request $request)
|
|
{
|
|
$account_number = $request->input('account_number', '1080425781');
|
|
$period = $request->input('period', '20250512');
|
|
$fileName = "{$account_number}_{$period}.csv";
|
|
$filePath = "statements/{$fileName}";
|
|
|
|
if (!Storage::disk('local')->exists($filePath)) {
|
|
return response()->json([
|
|
'message' => 'Statement file not found. It may still be processing.'
|
|
], 404);
|
|
}
|
|
|
|
return Storage::disk('local')->download($filePath, $fileName, [
|
|
"Content-Type" => "text/csv",
|
|
]);
|
|
}
|
|
|
|
/**
|
|
* Generate statement on-demand and return as download
|
|
*/
|
|
public function generateAndDownload(Request $request)
|
|
{
|
|
$account_number = $request->input('account_number', '1080425781');
|
|
$period = $request->input('period', '20250512');
|
|
$saldo = $request->input('saldo', '23984352604');
|
|
|
|
$stmt = StmtEntry::with(['ft', 'transaction'])
|
|
->where('account_number', $account_number)
|
|
->where('booking_date', $period)
|
|
->orderBy('date_time', 'ASC')
|
|
->orderBy('trans_reference', 'ASC')
|
|
->get();
|
|
|
|
if ($stmt->isEmpty()) {
|
|
return response()->json([
|
|
'message' => 'No statement data found for the specified account and period.'
|
|
], 404);
|
|
}
|
|
|
|
$runningBalance = (float) $saldo;
|
|
// Map the data to transform or format specific fields
|
|
$mappedData = $stmt->sortBy(['ACTUAL.DATE', 'REFERENCE.NUMBER'])
|
|
->map(function ($item, $index) use (&$runningBalance) {
|
|
$runningBalance += (float) $item->amount_lcy;
|
|
return [
|
|
'NO' => 0, // Will be updated later
|
|
'TRANSACTION.DATE' => Carbon::createFromFormat('YmdHi', $item->booking_date . substr($item->ft?->date_time ?? '0000000000', 6, 4))
|
|
->format('d/m/Y H:i'),
|
|
'REFERENCE.NUMBER' => $item->trans_reference,
|
|
'TRANSACTION.AMOUNT' => $item->amount_lcy,
|
|
'TRANSACTION.TYPE' => $item->amount_lcy < 0 ? 'D' : 'C',
|
|
'DESCRIPTION' => $this->generateNarrative($item),
|
|
'END.BALANCE' => $runningBalance,
|
|
'ACTUAL.DATE' => Carbon::createFromFormat('ymdHi', $item->ft?->date_time ?? '2505120000')
|
|
->format('d/m/Y H:i'),
|
|
];
|
|
})
|
|
->values();
|
|
|
|
// Then apply the sequential numbers
|
|
$mappedData = $mappedData->map(function ($item, $index) {
|
|
$item['NO'] = $index + 1;
|
|
return $item;
|
|
});
|
|
|
|
$csvFileName = $account_number . "_" . $period . ".csv";
|
|
$headers = [
|
|
"Content-Type" => "text/csv",
|
|
"Content-Disposition" => "attachment; filename={$csvFileName}"
|
|
];
|
|
|
|
$callback = function () use ($mappedData) {
|
|
$file = fopen('php://output', 'w');
|
|
// Write headers without quotes, using pipe separator
|
|
fputs($file, implode('|', array_keys($mappedData[0])) . "\n");
|
|
// Write data rows without quotes, using pipe separator
|
|
foreach ($mappedData as $row) {
|
|
fputs($file, implode('|', $row) . "\n");
|
|
}
|
|
fclose($file);
|
|
};
|
|
|
|
return response()->stream($callback, 200, $headers);
|
|
}
|
|
|
|
/**
|
|
* Generate narrative for a statement entry
|
|
*/
|
|
private function generateNarrative($item)
|
|
{
|
|
$narr = '';
|
|
if ($item->transaction && $item->transaction->narr_type) {
|
|
$narr .= $item->transaction->stmt_narr . ' ';
|
|
$narr .= $this->getFormatNarrative($item->transaction->narr_type, $item);
|
|
} else if ($item->transaction) {
|
|
$narr .= $item->transaction->stmt_narr . ' ';
|
|
}
|
|
|
|
if ($item->ft && $item->ft->recipt_no) {
|
|
$narr .= 'Receipt No: ' . $item->ft->recipt_no;
|
|
}
|
|
return $narr;
|
|
}
|
|
|
|
/**
|
|
* Get formatted narrative based on narrative type
|
|
*/
|
|
private function getFormatNarrative($narr, $item)
|
|
{
|
|
$narrParam = TempStmtNarrParam::where('_id', $narr)->first();
|
|
|
|
if (!$narrParam) {
|
|
return '';
|
|
}
|
|
|
|
$fmt = '';
|
|
if ($narrParam->_id == 'FTIN') {
|
|
$fmt = 'FT.IN';
|
|
} else if ($narrParam->_id == 'FTOUT') {
|
|
$fmt = 'FT.IN';
|
|
} else {
|
|
$fmt = $narrParam->_id;
|
|
}
|
|
|
|
$narrFormat = TempStmtNarrFormat::where('_id', $fmt)->first();
|
|
|
|
if (!$narrFormat) {
|
|
return '';
|
|
}
|
|
|
|
// Get the format string from the database
|
|
$formatString = $narrFormat->text_data ?? '';
|
|
|
|
// Parse the format string
|
|
// Split by the separator ']'
|
|
$parts = explode(']', $formatString);
|
|
|
|
$result = '';
|
|
|
|
foreach ($parts as $index => $part) {
|
|
if (empty($part)) {
|
|
continue;
|
|
}
|
|
|
|
if ($index === 0) {
|
|
// For the first part, take only what's before the '!'
|
|
$splitPart = explode('!', $part);
|
|
if (count($splitPart) > 0) {
|
|
// Remove quotes, backslashes, and other escape characters
|
|
$cleanPart = trim($splitPart[0]);
|
|
// Remove quotes at the beginning and end
|
|
$cleanPart = preg_replace('/^["\'\\\\]+|["\'\\\\]+$/', '', $cleanPart);
|
|
// Remove any remaining backslashes
|
|
$cleanPart = str_replace('\\', '', $cleanPart);
|
|
// Remove any remaining quotes
|
|
$cleanPart = str_replace('"', '', $cleanPart);
|
|
$result .= $cleanPart;
|
|
}
|
|
} else {
|
|
// For other parts, these are field placeholders
|
|
$fieldName = strtolower(str_replace('.', '_', $part));
|
|
|
|
// Get the corresponding parameter value from narrParam
|
|
$paramValue = null;
|
|
|
|
// Check if the field exists as a property in narrParam
|
|
if (property_exists($narrParam, $fieldName)) {
|
|
$paramValue = $narrParam->$fieldName;
|
|
} else if (isset($narrParam->$fieldName)) {
|
|
$paramValue = $narrParam->$fieldName;
|
|
}
|
|
|
|
// If we found a value, add it to the result
|
|
if ($paramValue !== null) {
|
|
$result .= $paramValue;
|
|
} else {
|
|
// If no value found, try to use the original field name as a fallback
|
|
if ($fieldName != 'recipt_no') {
|
|
$result .= $this->getTransaction($item->trans_reference, $fieldName) . ' ';
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
return $result;
|
|
}
|
|
|
|
/**
|
|
* Get transaction data by reference and field
|
|
*/
|
|
private function getTransaction($ref, $field)
|
|
{
|
|
$trans = TempFundsTransfer::where('ref_no', $ref)->first();
|
|
return $trans ? ($trans->$field ?? "") : "";
|
|
}
|
|
|
|
/**
|
|
* Queue a statement export job and return job ID
|
|
*/
|
|
public function queueExport(Request $request)
|
|
{
|
|
$account_number = $request->input('account_number', '1080425781');
|
|
$period = $request->input('period', '20250512');
|
|
$saldo = $request->input('saldo', '23984352604');
|
|
|
|
// Dispatch the job and get the job ID
|
|
$job = new ExportStatementJob($account_number, $period, $saldo);
|
|
$jobId = app(Dispatcher::class)->dispatch($job);
|
|
|
|
return response()->json([
|
|
'message' => 'Statement export job has been queued',
|
|
'job_id' => $jobId,
|
|
'account_number' => $account_number,
|
|
'period' => $period,
|
|
'file_name' => "{$account_number}_{$period}.csv"
|
|
]);
|
|
}
|
|
|
|
/**
|
|
* Check the status of an export job
|
|
*/
|
|
public function checkExportStatus(Request $request, $jobId)
|
|
{
|
|
// Get job status from the queue
|
|
$job = DB::table('jobs')
|
|
->where('id', $jobId)
|
|
->first();
|
|
|
|
if (!$job) {
|
|
// Check if job is completed
|
|
$completedJob = DB::table('job_batches')
|
|
->where('id', $jobId)
|
|
->first();
|
|
|
|
if ($completedJob) {
|
|
return response()->json([
|
|
'status' => 'completed',
|
|
'message' => 'Export job has been completed'
|
|
]);
|
|
}
|
|
|
|
return response()->json([
|
|
'status' => 'not_found',
|
|
'message' => 'Export job not found'
|
|
], 404);
|
|
}
|
|
|
|
return response()->json([
|
|
'status' => 'pending',
|
|
'message' => 'Export job is still processing'
|
|
]);
|
|
}
|
|
}
|