Log to DB Ciamis kini bisa membaca direktori

payment_report/scripts/bphtb.py

@@ -518,7 +518,8 @@ class App(BaseApp):
                 channel_nama = self.get_va_channel(pay.tanggal) or 'MANUAL'
                 channel_nama = self.get_va_channel(pay.tanggal) or 'MANUAL'
         if pay.tanggal > date.today():
         if pay.tanggal > date.today():
             print(f'DEBUG self.tgl_akhir {self.tgl_akhir}')
             print(f'DEBUG self.tgl_akhir {self.tgl_akhir}')
-            raise Exception(f'{pay.tanggal} adalah masa depan. Perbaiki script.')
+            raise Exception(
+                    f'{pay.tanggal} adalah masa depan. Perbaiki script.')
         return dict(
         return dict(
             id=pay.id, stan=stan, ntb=ntb, tgl=pay.tanggal, jam=pay.jam,
             id=pay.id, stan=stan, ntb=ntb, tgl=pay.tanggal, jam=pay.jam,
             invoice_id=self.invoice_id, nop=pay.nop, wp_nama=pay.wp_nama,
             invoice_id=self.invoice_id, nop=pay.nop, wp_nama=pay.wp_nama,

payment_report/scripts/log2db_ciamis.py

@@ -3,6 +3,7 @@ import os
 import re
 import re
 from argparse import ArgumentParser
 from argparse import ArgumentParser
 from configparser import ConfigParser
 from configparser import ConfigParser
+from glob import glob
 from hashlib import sha256
 from hashlib import sha256
 from time import sleep
 from time import sleep
 from sqlalchemy import create_engine
 from sqlalchemy import create_engine
@@ -60,9 +61,18 @@ def read_log(log_file, db_url):
 def main(argv=sys.argv[1:]):
 def main(argv=sys.argv[1:]):
     pars = ArgumentParser()
     pars = ArgumentParser()
     pars.add_argument('conf')
     pars.add_argument('conf')
-    pars.add_argument('--log-file', required=True)
+    pars.add_argument('--log-file')
     option = pars.parse_args(argv)
     option = pars.parse_args(argv)
     conf = ConfigParser()
     conf = ConfigParser()
     conf.read(option.conf)
     conf.read(option.conf)
     db_url = conf.get('main', 'db_url')
     db_url = conf.get('main', 'db_url')
-    read_log(option.log_file, db_url)
+    if option.log_file:
+        files = [option.log_file]
+    else:
+        dir_name = conf.get('main', 'log_dir')
+        pola = os.path.join(dir_name, 'sent_*_log.txt')
+        files = glob(pola)
+    for log_file in files:
+        bak_file = log_file[:-3] + 'bak'
+        read_log(log_file, db_url)
+        os.rename(log_file, bak_file)

payment_report/scripts/webr.py

@@ -106,7 +106,8 @@ class App(BaseApp):
                 jam=pay.created.time(), nomor_bayar=self.invoice_id,
                 jam=pay.created.time(), nomor_bayar=self.invoice_id,
                 nama_wp=inv.subjek_nama, pokok=inv.jumlah-inv.bunga,
                 nama_wp=inv.subjek_nama, pokok=inv.jumlah-inv.bunga,
                 denda=pay.bunga, jml_bayar=pay.bayar, channel_id=channel_id,
                 denda=pay.bunga, jml_bayar=pay.bayar, channel_id=channel_id,
-                channel_name=channel_name, status=pay.status, produk=inv.produk_nama)
+                channel_name=channel_name, status=pay.status,
+                produk=inv.produk_nama)
 
 
     def create_data_from_h2h(self, row):
     def create_data_from_h2h(self, row):
         self.invoice_id = row.bit_061.strip()
         self.invoice_id = row.bit_061.strip()