From 7e6bfded58c08e79fb33820b2a949fea18ef9a1b Mon Sep 17 00:00:00 2001
From: Daeng Deni Mardaeni <ddeni05@gmail.com>
Date: Wed, 29 Jan 2025 19:41:45 +0700
Subject: [PATCH] feat(jobs): tambahkan job untuk memproses data akun

- Menambahkan kelas ProcessAccountDataJob untuk memproses data akun dari file CSV.
- Mengimplementasikan logika untuk membaca file dan memperbarui atau membuat entri di tabel TempAccount.
- Menangani kesalahan dan mencatat log jika terjadi masalah saat memproses data.
- Menambahkan migrasi untuk membuat tabel temp_accounts dengan kolom yang diperlukan.
---
 app/Jobs/ProcessAccountDataJob.php            | 68 +++++++++++++++++++
 app/Models/TempAccount.php                    | 27 ++++++++
 ...1_28_032418_create_temp_accounts_table.php | 36 ++++++++++
 3 files changed, 131 insertions(+)
 create mode 100644 app/Jobs/ProcessAccountDataJob.php
 create mode 100644 app/Models/TempAccount.php
 create mode 100644 database/migrations/2025_01_28_032418_create_temp_accounts_table.php

diff --git a/app/Jobs/ProcessAccountDataJob.php b/app/Jobs/ProcessAccountDataJob.php
new file mode 100644
index 0000000..6fd7cde
--- /dev/null
+++ b/app/Jobs/ProcessAccountDataJob.php
@@ -0,0 +1,68 @@
+<?php
+
+    namespace Modules\Webstatement\Jobs;
+
+    use Exception;
+    use Illuminate\Bus\Queueable;
+    use Illuminate\Contracts\Queue\ShouldQueue;
+    use Illuminate\Foundation\Bus\Dispatchable;
+    use Illuminate\Queue\InteractsWithQueue;
+    use Illuminate\Queue\SerializesModels;
+    use Log;
+    use Modules\Webstatement\Models\TempAccount;
+
+    class ProcessAccountDataJob implements ShouldQueue
+    {
+        use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
+
+        /**
+         * Create a new job instance.
+         */
+        public function __construct()
+        {
+            //
+        }
+
+        /**
+         * Execute the job.
+         */
+        public function handle()
+        : void
+        {
+            $filePath = storage_path('app/20240901.ST.ACCOUNT.csv'); // Adjust this path as needed
+            try {
+                if (!file_exists($filePath)) {
+                    throw new Exception("File not found: $filePath");
+                }
+
+                set_time_limit(24 * 60 * 60);
+
+                if (!file_exists($filePath)) {
+                    throw new Exception("File not found: {$filePath}");
+                }
+
+                $handle = fopen($filePath, "r");
+
+                if ($handle !== false) {
+                    $headers = (new TempAccount())->getFillable();
+                    while (($row = fgetcsv($handle, 0, ";")) !== false) {
+                        if (count($headers) === count($row)) {
+                            $data = array_combine($headers, $row);
+
+                            try {
+                                TempAccount::updateOrCreate(['account_number' => $data['account_number']], $data);
+                            } catch (Exception $e) {
+                                Log::error('Error processing Account: ' . $e->getMessage());
+                            }
+                        }
+                    }
+                    fclose($handle);
+                } else {
+                    throw new Exception("Unable to open file: {$filePath}");
+                }
+            } catch (Exception $e) {
+                Log::error('Error in ProcessAccountDataJob: ' . $e->getMessage());
+                throw $e;
+            }
+        }
+    }
diff --git a/app/Models/TempAccount.php b/app/Models/TempAccount.php
new file mode 100644
index 0000000..2776a63
--- /dev/null
+++ b/app/Models/TempAccount.php
@@ -0,0 +1,27 @@
+<?php
+
+namespace Modules\Webstatement\Models;
+
+use Illuminate\Database\Eloquent\Model;
+use Illuminate\Database\Eloquent\Factories\HasFactory;
+// use Modules\Webstatement\Database\Factories\TempAccountFactory;
+
+class TempAccount extends Model
+{
+    use HasFactory;
+
+    protected $table = 'temp_accounts';
+
+    /**
+     * The attributes that are mass assignable.
+     */
+    protected $fillable = [
+        '_id','account_number','reserved_customer_mnemonic','reserved_acct_id','reserved_source_id','reserved_sector','reserved_industry','reserved_target','reserved_residence','account_no','customer_no','reserved_prodccy','customer','category','prodcat','account_title_1','account_title_2','short_title','mnemonic','position_type','currency','currency_market','limit_ref','account_officer','other_officer','posting_restrict','reconcile_acct','interest_liqu_acct','interest_comp_acct','int_no_booking','referal_code','waive_ledger_fee','local_ref','condition_group','inactiv_marker','open_actual_bal','open_cleared_bal','online_actual_bal','online_cleared_bal','working_balance','date_last_cr_cust','amnt_last_cr_cust','tran_last_cr_cust','date_last_cr_auto','amnt_last_cr_auto','tran_last_cr_auto','date_last_cr_bank','amnt_last_cr_bank','tran_last_cr_bank','date_last_dr_cust','amnt_last_dr_cust','tran_last_dr_cust','date_last_dr_auto','amnt_last_dr_auto','tran_last_dr_auto','date_last_dr_bank','amnt_last_dr_bank','tran_last_dr_bank','cap_date_charge','cap_date_cr_int','cap_date_c2_int','cap_date_dr_int','cap_date_d2_int','cap_back_value','accr_chg_categ','accr_chg_trans','accr_chg_amount','accr_chg_susp','accr_cr_categ','accr_cr_trans','accr_cr_amount','accr_cr_susp','accr_cr2_categ','accr_cr2_trans','accr_cr2_amount','accr_cr2_susp','accr_dr_categ','accr_dr_trans','accr_dr_amount','accr_dr_susp','accr_dr2_categ','accr_dr2_trans','accr_dr2_amount','accr_dr2_susp','consol_key','passbook','start_year_bal','opening_date','override','record_status','curr_no','inputter','date_time','authoriser','co_code','dept_code','auditor_code','audit_date_time','reserved_teller_id','reserved_show_till_acs','reserved_customer_code','reserved_nostro_ccy','value_date','credit_movement','debit_movement','value_dated_bal','contingent_bal_cr','contingent_bal_dr','open_category','open_val_dated_bal','charge_account','link_to_limit','closure_date','reserved_acct_ent_today','charge_ccy','charge_mkt','interest_ccy','interest_mkt','con_charge_accr','con_interest_accr','alt_acct_type','alt_acct_id','reserved_start_date','reserved_end_date','premium_type','reserved_cap_date','apr','reserved_long_pos_sign','cap_date_prm','premium_freq','reserved_grp_ccy','reserved_val_date','reserved_txn_amt','reserved_txn_code','joint_holder','relation_code','joint_notes','allow_netting','ledg_reco_with','stmt_reco_with','our_ext_acct_no','reco_tolerance','pending_id','total_pending','serial_no_format','stock_control_type','auto_pay_acct','orig_ccy_payment','auto_rec_ccy','original_acct','reserved_merge_ncu','from_date','locked_amount','reserved_grp_ac_no','dispo_officer','ica_main_account','ica_distrib_ratio','ica_main_acct_ind','ica_distrib_type','ica_post_interest','ica_main_ratio','ica_new_main_acc','ica_start_date','ica_add_remove','ica_back_value','ica_main_acct','ica_main_date','liquidation_mode','overdue_status','single_limit','contingent_int','all_in_one_product','dispo_exempt','er_balance','er_value_date','sb_group_id','open_available_bal','available_date','av_auth_db_mvmt','av_nau_db_mvmt','av_auth_cr_mvmt','av_nau_cr_mvmt','available_bal','credit_check','available_bal_upd','tax_suspend','tax_at_settle','ep_balance','consolidate_ent','max_sub_account','master_account','closed_online','reserved_country_risk','next_af_date','next_acct_cap','date_last_update','next_stmt_date','exposure_dates','next_exp_date','fwd_entry_hold','first_af_date','cash_pool_group','open_asset_type','portfolio_no','last_com_chg_date','ic_charge_id','ic_next_cap_date','ic_product','ic_lst_prod_cap','acc_deb_limit','acct_credit_int','acct_debit_int','forward_mvmts','arrangement_id','int_liqu_type','int_liqu_acct','int_liq_ccy','hvt_flag','mandate_appl','mandate_reg','mandate_record','dr_adj_amount','dr2_adj_amount','cr_adj_amount','cr2_adj_amount','event','field','operand','value','request_id','mv_alert_res6','mv_alert_res5','mv_alert_res4','mv_alert_res3','mv_alert_res2','mv_alert_res1','locked_with_limit','lock_inc_this_mvmt','shadow_account','accounting_company','closure_reason','closure_notes','ref_data_item','ref_data_value','sam_id_hist','parent_account','multi_currency','external_posting','secondary_limit_amt','parent_bv_date','allowed_bv_date','reserved_21','reserved_20','reserved_19','reserved_18','reserved_17','reserved_16','reserved_15','reserved_14','reserved_13','reserved_12','reserved_11','reserved_10','reserved_9','reserved_8','reserved_7','reserved_6','reserved_5','reserved_4','reserved_3','reserved_2','reserved_1','credit_chk_txn_type','credit_chk_condition','balance_conversion_mkt','limit_key','reserved_bundle_arrangement','reserved_s_simulated_ccy','reserved_s_days','reserved_s_linktype','reserved_s_bundleid','reducing_limit','limit_proc_type','fa_status','emergency_block','emergency_reason','risk_stage','account_type','multi_currency_parent','reserved_ac_no_days','welcome_pack','last_version','otor_version','charge_code','charge_amount','admin_fee_code','admin_fee_chrg','ld_acct_officer','lbu_pfolio','sid_kat_deb','lbu_sifat_kred','lbu_sektor_eko','lbu_kat_ukur','lbu_jenis_peng','lbu_or_guna','sid_sifat_kredi','sid_jenis_peng','or_guna','sid_sektor_econ','nil_proyek_bi','sid_lokasi_pryk','prk_ld_id','asset_class','asset_class_flg','l_kode_promo','l_passbook_no','l_joint_holder','is_joint_holder','term_id','po_descr','l_tujuan_buka_r','term_type','contact_person','l_reason_closed','prov_rate','l_product_group','prov_last_upd','l_unattach_prk','date_1st_trx','ent_1st_trx','l_ftcomm_id','trans_reff','recipt_no','l_post_restrict','ln_sub_product','l_instansi','reference','prk_write_off','prk_wo_date','prk_wo_amount','l_sprint_flag','l_sprint_no','l_ac_kode_layan','referral_code','l_flg_confident','mig_bilyet_depo','l_mig_date_depo','l_mig_orig_date','l_kode_rekening','l_sifat_rek','l_no_polis','l_per_emiten','l_per_metode','l_per_country','l_per_currency','l_per_kualitas','l_per_tujuan','l_per_waktu','l_per_bagian','l_jenis_klaim','l_percent_klaim','l_nama_asuransi','l_mig_wo_date','l_kel_guna','l_mulai_pinjam','l_akhir_pinjam','l_sk_bng_pjm','l_int_type','l_gol_kr','l_jns_kr','l_acct_notes','l_orig_pr_wo','l_orig_in_wo','l_orig_amt_wo','l_special_rate','l_ac_sikp','l_prd_sikp','l_target','freq_dep_month','freq_wdl_month','avg_wdl_month','avg_dep_month','stmt_email','stmt_sent_type','l_rek_block','l_ln_wo_flag','channel_partner','l_orig_pr_ht','l_orig_in_ht','l_orig_amt_ht','l_ht_date','acct_prk_wo','limit_prk_wo','l_orig_pe_wo','l_orig_pe_ht','l_batch_no'
+
+    ];
+
+    // protected static function newFactory(): TempAccountFactory
+    // {
+    //     // return TempAccountFactory::new();
+    // }
+}
diff --git a/database/migrations/2025_01_28_032418_create_temp_accounts_table.php b/database/migrations/2025_01_28_032418_create_temp_accounts_table.php
new file mode 100644
index 0000000..3372196
--- /dev/null
+++ b/database/migrations/2025_01_28_032418_create_temp_accounts_table.php
@@ -0,0 +1,36 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+return new class extends Migration
+{
+    /**
+     * Run the migrations.
+     */
+    public function up(): void
+    {
+        $fields = "_id,account_number,reserved_customer_mnemonic,reserved_acct_id,reserved_source_id,reserved_sector,reserved_industry,reserved_target,reserved_residence,account_no,customer_no,reserved_prodccy,customer,category,prodcat,account_title_1,account_title_2,short_title,mnemonic,position_type,currency,currency_market,limit_ref,account_officer,other_officer,posting_restrict,reconcile_acct,interest_liqu_acct,interest_comp_acct,int_no_booking,referal_code,waive_ledger_fee,local_ref,condition_group,inactiv_marker,open_actual_bal,open_cleared_bal,online_actual_bal,online_cleared_bal,working_balance,date_last_cr_cust,amnt_last_cr_cust,tran_last_cr_cust,date_last_cr_auto,amnt_last_cr_auto,tran_last_cr_auto,date_last_cr_bank,amnt_last_cr_bank,tran_last_cr_bank,date_last_dr_cust,amnt_last_dr_cust,tran_last_dr_cust,date_last_dr_auto,amnt_last_dr_auto,tran_last_dr_auto,date_last_dr_bank,amnt_last_dr_bank,tran_last_dr_bank,cap_date_charge,cap_date_cr_int,cap_date_c2_int,cap_date_dr_int,cap_date_d2_int,cap_back_value,accr_chg_categ,accr_chg_trans,accr_chg_amount,accr_chg_susp,accr_cr_categ,accr_cr_trans,accr_cr_amount,accr_cr_susp,accr_cr2_categ,accr_cr2_trans,accr_cr2_amount,accr_cr2_susp,accr_dr_categ,accr_dr_trans,accr_dr_amount,accr_dr_susp,accr_dr2_categ,accr_dr2_trans,accr_dr2_amount,accr_dr2_susp,consol_key,passbook,start_year_bal,opening_date,override,record_status,curr_no,inputter,date_time,authoriser,co_code,dept_code,auditor_code,audit_date_time,reserved_teller_id,reserved_show_till_acs,reserved_customer_code,reserved_nostro_ccy,value_date,credit_movement,debit_movement,value_dated_bal,contingent_bal_cr,contingent_bal_dr,open_category,open_val_dated_bal,charge_account,link_to_limit,closure_date,reserved_acct_ent_today,charge_ccy,charge_mkt,interest_ccy,interest_mkt,con_charge_accr,con_interest_accr,alt_acct_type,alt_acct_id,reserved_start_date,reserved_end_date,premium_type,reserved_cap_date,apr,reserved_long_pos_sign,cap_date_prm,premium_freq,reserved_grp_ccy,reserved_val_date,reserved_txn_amt,reserved_txn_code,joint_holder,relation_code,joint_notes,allow_netting,ledg_reco_with,stmt_reco_with,our_ext_acct_no,reco_tolerance,pending_id,total_pending,serial_no_format,stock_control_type,auto_pay_acct,orig_ccy_payment,auto_rec_ccy,original_acct,reserved_merge_ncu,from_date,locked_amount,reserved_grp_ac_no,dispo_officer,ica_main_account,ica_distrib_ratio,ica_main_acct_ind,ica_distrib_type,ica_post_interest,ica_main_ratio,ica_new_main_acc,ica_start_date,ica_add_remove,ica_back_value,ica_main_acct,ica_main_date,liquidation_mode,overdue_status,single_limit,contingent_int,all_in_one_product,dispo_exempt,er_balance,er_value_date,sb_group_id,open_available_bal,available_date,av_auth_db_mvmt,av_nau_db_mvmt,av_auth_cr_mvmt,av_nau_cr_mvmt,available_bal,credit_check,available_bal_upd,tax_suspend,tax_at_settle,ep_balance,consolidate_ent,max_sub_account,master_account,closed_online,reserved_country_risk,next_af_date,next_acct_cap,date_last_update,next_stmt_date,exposure_dates,next_exp_date,fwd_entry_hold,first_af_date,cash_pool_group,open_asset_type,portfolio_no,last_com_chg_date,ic_charge_id,ic_next_cap_date,ic_product,ic_lst_prod_cap,acc_deb_limit,acct_credit_int,acct_debit_int,forward_mvmts,arrangement_id,int_liqu_type,int_liqu_acct,int_liq_ccy,hvt_flag,mandate_appl,mandate_reg,mandate_record,dr_adj_amount,dr2_adj_amount,cr_adj_amount,cr2_adj_amount,event,field,operand,value,request_id,mv_alert_res6,mv_alert_res5,mv_alert_res4,mv_alert_res3,mv_alert_res2,mv_alert_res1,locked_with_limit,lock_inc_this_mvmt,shadow_account,accounting_company,closure_reason,closure_notes,ref_data_item,ref_data_value,sam_id_hist,parent_account,multi_currency,external_posting,secondary_limit_amt,parent_bv_date,allowed_bv_date,reserved_21,reserved_20,reserved_19,reserved_18,reserved_17,reserved_16,reserved_15,reserved_14,reserved_13,reserved_12,reserved_11,reserved_10,reserved_9,reserved_8,reserved_7,reserved_6,reserved_5,reserved_4,reserved_3,reserved_2,reserved_1,credit_chk_txn_type,credit_chk_condition,balance_conversion_mkt,limit_key,reserved_bundle_arrangement,reserved_s_simulated_ccy,reserved_s_days,reserved_s_linktype,reserved_s_bundleid,reducing_limit,limit_proc_type,fa_status,emergency_block,emergency_reason,risk_stage,account_type,multi_currency_parent,reserved_ac_no_days,welcome_pack,last_version,otor_version,charge_code,charge_amount,admin_fee_code,admin_fee_chrg,ld_acct_officer,lbu_pfolio,sid_kat_deb,lbu_sifat_kred,lbu_sektor_eko,lbu_kat_ukur,lbu_jenis_peng,lbu_or_guna,sid_sifat_kredi,sid_jenis_peng,or_guna,sid_sektor_econ,nil_proyek_bi,sid_lokasi_pryk,prk_ld_id,asset_class,asset_class_flg,l_kode_promo,l_passbook_no,l_joint_holder,is_joint_holder,term_id,po_descr,l_tujuan_buka_r,term_type,contact_person,l_reason_closed,prov_rate,l_product_group,prov_last_upd,l_unattach_prk,date_1st_trx,ent_1st_trx,l_ftcomm_id,trans_reff,recipt_no,l_post_restrict,ln_sub_product,l_instansi,reference,prk_write_off,prk_wo_date,prk_wo_amount,l_sprint_flag,l_sprint_no,l_ac_kode_layan,referral_code,l_flg_confident,mig_bilyet_depo,l_mig_date_depo,l_mig_orig_date,l_kode_rekening,l_sifat_rek,l_no_polis,l_per_emiten,l_per_metode,l_per_country,l_per_currency,l_per_kualitas,l_per_tujuan,l_per_waktu,l_per_bagian,l_jenis_klaim,l_percent_klaim,l_nama_asuransi,l_mig_wo_date,l_kel_guna,l_mulai_pinjam,l_akhir_pinjam,l_sk_bng_pjm,l_int_type,l_gol_kr,l_jns_kr,l_acct_notes,l_orig_pr_wo,l_orig_in_wo,l_orig_amt_wo,l_special_rate,l_ac_sikp,l_prd_sikp,l_target,freq_dep_month,freq_wdl_month,avg_wdl_month,avg_dep_month,stmt_email,stmt_sent_type,l_rek_block,l_ln_wo_flag,channel_partner,l_orig_pr_ht,l_orig_in_ht,l_orig_amt_ht,l_ht_date,acct_prk_wo,limit_prk_wo,l_orig_pe_wo,l_orig_pe_ht,l_batch_no";
+
+        $fieldArray = explode(',', $fields);
+
+        Schema::create('temp_accounts', function (Blueprint $table) use ($fieldArray) {
+            $table->id();
+
+            foreach ($fieldArray as $field) {
+                $field = trim($field);
+                $table->text($field)->nullable();
+            }
+            $table->timestamps();
+        });
+    }
+
+    /**
+     * Reverse the migrations.
+     */
+    public function down(): void
+    {
+        Schema::dropIfExists('temp_accounts');
+    }
+};