```
refactor(jobs): update file extension and sanitize transaction reference - Mengubah konstanta `FILE_EXTENSION` pada `ProcessAtmTransactionJob` dari `.ST.ATM.csv` menjadi `.ST.ATM.TRANSACTION.csv`. - Menambahkan logika pembersihan pada `trans_reference` dalam `ProcessStmtEntryDataJob`: - Menghapus string `\BNK` jika ada dalam field `trans_reference`. - Mempertahankan fungsionalitas utama untuk memastikan kompatibilitas data dan pengolahan job tetap berjalan sesuai dengan kebutuhan. ```
This commit is contained in:
@@ -19,7 +19,7 @@
|
|||||||
private const PARAMETER_FOLDER = '_parameter';
|
private const PARAMETER_FOLDER = '_parameter';
|
||||||
|
|
||||||
// Konstanta untuk nilai-nilai statis
|
// Konstanta untuk nilai-nilai statis
|
||||||
private const FILE_EXTENSION = '.ST.ATM.csv';
|
private const FILE_EXTENSION = '.ST.ATM.TRANSACTION.csv';
|
||||||
private const CSV_DELIMITER = '~';
|
private const CSV_DELIMITER = '~';
|
||||||
private const DISK_NAME = 'sftpStatement';
|
private const DISK_NAME = 'sftpStatement';
|
||||||
private const HEADER_MAP = [
|
private const HEADER_MAP = [
|
||||||
|
|||||||
@@ -78,6 +78,11 @@
|
|||||||
$data = array_combine($headers, $row);
|
$data = array_combine($headers, $row);
|
||||||
try {
|
try {
|
||||||
if ($data['stmt_entry_id'] !== 'stmt_entry_id') {
|
if ($data['stmt_entry_id'] !== 'stmt_entry_id') {
|
||||||
|
// Bersihkan trans_reference dari \\BNK jika ada
|
||||||
|
if (isset($data['trans_reference'])) {
|
||||||
|
$data['trans_reference'] = str_replace('\\BNK', '', $data['trans_reference']);
|
||||||
|
}
|
||||||
|
|
||||||
StmtEntry::updateOrCreate(
|
StmtEntry::updateOrCreate(
|
||||||
['stmt_entry_id' => $data['stmt_entry_id']],
|
['stmt_entry_id' => $data['stmt_entry_id']],
|
||||||
$data
|
$data
|
||||||
|
|||||||
Reference in New Issue
Block a user