Kali pertama

.gitignore

+build
+dist
+*egg-info
+test-*.ini

CHANGES.txt

+0.1 2019-10-10
+--------------
+- Kali pertama

MANIFEST.in

+include *.txt *.rst *.py
+recursive-include opensipkd *.py

README.rst

+Struktur Tabel Web Register 
+===========================
+
+Web Register adalah istilah untuk pajak yang ditarik oleh pemerintah daerah. Ia
+merupakan kelanjutan sistem Pendapatan Daerah Lainnya (PDL). Kecenderungannya
+di retribusi.
+
+Paket ini selain berisi struktur tabel juga memuat query yang kerap digunakan
+untuk proses:
+
+1. inquiry (cek tagihan)
+2. payment (pembayaran)
+3. reversal (pembatalan pembayaran)
+
+Uji Coba
+--------
+
+Buat file ``test.ini`` seperti contoh berikut ini::
+
+  [main]
+  db_url = postgresql://sugiana:a@localhost/webr
+  persen_denda = 2
+
+Sesuaikanlah pada ``db_url``. Kemudian dapatkan daftar tagihan::
+
+  $ env/bin/webr_available_invoice test.ini
+
+Nanti akan tampil seperti ini #FIXME::
+
+  #1 10241 2019 36.72... ER*** Rp 1.465.200
+  #2 10356 2019 36.72... JU*** Rp 1.500.000
+  #3 10361 2019 36.72... MU*** Rp 1.500.000
+
+Kolom kedua adalah Invoice ID atau sering disebut sebagai nomor bayar. Nomor
+ini bekal untuk inquiry atau cek tagihan::
+
+  $ env/bin/webr_inquiry test.ini --invoice-id=10241
+
+Untuk melanjutkan pembayaran tambahkan opsi ``--payment``::
+
+  $ env/bin/webr_inquiry test.ini --invoice-id=10241 --payment
+
+Sedangkan untuk membatalkannya tambahkan opsi ``--reversal``::
+
+  $ env/bin/webr_inquiry test.ini --invoice-id=10241 --reversal
+
+Selamat mencoba, semoga berhasil.

devel.ini

+[main]
+db_url = postgresql://username:password@localhost/database
+persen_denda = 2

opensipkd/webr/scripts/available_invoice.py

+import sys
+from configparser import ConfigParser
+from argparse import ArgumentParser
+from sqlalchemy import create_engine
+from sqlalchemy.orm import sessionmaker
+
+
+default_count = 10
+help_count = f'default {default_count}'
+
+
+def get_option(argv):
+    pars = ArgumentParser()
+    pars.add_argument('conf')
+    pars.add_argument('--tahun', type=int)
+    pars.add_argument('--jatuh-tempo-min')
+    pars.add_argument('--jatuh-tempo-max')
+    pars.add_argument('--nominal-min', type=int)
+    pars.add_argument('--nominal-max', type=int)
+    pars.add_argument(
+        '--count', type=int, default=default_count, help=help_count)
+    return pars.parse_args(argv)
+
+
+def main(argv=sys.argv):
+    option = get_option(argv[1:])
+    conf = ConfigParser()
+    conf.read(option.conf)
+    module_name = 'services'
+    module = __import__('opensipkd.webr.' + module_name)
+    services = getattr(module.webr, module_name)
+    AvailableInvoice = services.AvailableInvoice
+    db_url = conf.get('main', 'db_url')
+    persen_denda = conf.getfloat('main', 'persen_denda')
+    engine = create_engine(db_url)
+    session_factory = sessionmaker(bind=engine)
+    module.webr.services.DBSession = session_factory()
+    a = AvailableInvoice(persen_denda, option)
+    a.show()

opensipkd/webr/scripts/inquiry.py

+import sys
+from datetime import (
+    datetime,
+    date,
+    )
+from configparser import ConfigParser
+from argparse import ArgumentParser
+from sqlalchemy import create_engine
+from sqlalchemy.orm import sessionmaker
+import transaction
+from zope.sqlalchemy import register
+from opensipkd.string.money import thousand
+
+
+ERR_PAYMENT_NOT_FOUND = 'Pembayaran tidak ditemukan, '\
+    'tidak ada yang perlu dibatalkan.'
+
+
+def show_val(label, value):
+    if value is None:
+        value = ''
+    print('{}: {}'.format(label, value))
+
+
+def show_rp(label, value):
+    show_val(label, 'Rp {}'.format(thousand(value)))
+
+
+def show_field(t, fieldname):
+    label = f'Field {t.__tablename__}.{fieldname}'
+    try:
+        value = getattr(t, fieldname)
+    except AttributeError:
+        return
+    if isinstance(value, float):
+        show_rp(label, value)
+    else:
+        show_val(label, value)
+
+
+def get_option(argv):
+    kini = date.today()
+    kini = kini.strftime('%d-%m-%Y')
+    help_tgl_bayar = f'default {kini}'
+    pars = ArgumentParser()
+    pars.add_argument('conf')
+    pars.add_argument('--invoice-id')
+    pars.add_argument('--payment', action='store_true')
+    pars.add_argument('--reversal', action='store_true')
+    pars.add_argument('--tgl-bayar', help=help_tgl_bayar, default=kini)
+    return pars.parse_args(argv)
+
+
+def show(inq):
+    show_val('Nama Penyetor', inq.get_nama())
+    show_val('Alamat 1', inq.get_alamat_1())
+    show_val('Alamat 2', inq.get_alamat_2())
+    show_val('Kode Rekening', inq.get_kode_rekening())
+    show_val('Nama Rekening', inq.get_nama_rekening())
+    show_val('Kode SKPD', inq.get_kode_departemen())
+    show_val('Nama SKPD', inq.get_nama_departemen())
+    show_rp('Tagihan Pokok', inq.tagihan)
+    show_rp('Denda', inq.denda)
+    show_rp('Total Tagihan', inq.total)
+    show_field(inq.invoice, 'status')
+    if inq.total_bayar:
+        pay = inq.get_payment()
+        show_field(pay, 'tgl_bayar')
+        show_field(pay, 'id')
+
+
+def show_pkey_values(row):
+    print('Primary key tabel {}:'.format(row.__table__.name))
+    for c in row.__table__.columns:
+        if c.primary_key:
+            val = getattr(row, c.name)
+            show_val('  '+c.name, val)
+
+
+def read_list_conf(conf, name):
+    return conf.has_option('main', name) and \
+            conf.get('main', name).split() or []
+
+
+def error(s):
+    print(s)
+    sys.exit()
+
+
+def date_from_str(s):
+    d, m, y = s.split('-')
+    return date(int(y), int(m), int(d))
+
+
+def get_conf(conf_file):
+    conf = ConfigParser()
+    conf.read(conf_file)
+    return conf
+
+
+def main(argv=sys.argv[1:]):
+    option = get_option(argv)
+    invoice_id = option.invoice_id
+    tgl_bayar = date_from_str(option.tgl_bayar)
+    conf = get_conf(option.conf)
+    module_name = 'services'
+    db_url = conf.get('main', 'db_url')
+    engine = create_engine(db_url)
+    module = __import__('opensipkd.webr.' + module_name)
+    services = getattr(module.webr, module_name)
+    session_factory = sessionmaker(bind=engine)
+    module.webr.services.DBSession = db_session = session_factory()
+    register(module.webr.services.DBSession)
+    inq = services.Inquiry(
+            invoice_id, conf.getfloat('main', 'persen_denda'), tgl_bayar)
+    if not inq.invoice:
+        error(f'Invoice ID {invoice_id} tidak ada.')
+    show(inq)
+    if option.payment:
+        if not inq.total:
+            error('Tidak ada tagihan, tidak ada yang perlu dibayar.')
+        ntb = datetime.now().strftime('%y%m%d%H%M%S')
+        with transaction.manager:
+            pay = inq.do_payment(ntb)
+            show_pkey_values(pay)
+            show_field(pay, 'status')
+            show_field(pay, 'posted')
+            print('Berhasil dibayar')
+    if option.reversal:
+        rev = services.Reversal(invoice_id)
+        if rev.is_available():
+            error('Memang belum dibayar')
+        pay = rev.payment
+        if not pay:
+            error(ERR_PAYMENT_NOT_FOUND)
+        with transaction.manager:
+            rev.do_reversal()
+            show_pkey_values(pay)
+            show_field(pay, 'is_valid')
+            print('Berhasil dibatalkan')

opensipkd/webr/services.py

+from time import time
+from datetime import (
+    date,
+    datetime,
+    )
+from sqlalchemy.sql import func
+from opensipkd.hitung import (
+    hitung_denda,
+    round_up,
+    )
+from opensipkd.string.money import thousand
+from opensipkd.string.transaction_id import TransactionID
+from .models import (
+    Invoice,
+    Payment,
+    )
+
+
+DBSession = None
+
+
+def get_db_session():
+    return DBSession
+
+
+def date_from_str(s):
+    d, m, y = [int(x) for x in s.split('-')]
+    return date(y, m, d)
+
+
+# Nomor Transaksi Pemda
+class NTP(TransactionID):
+    def is_found(self, tid):
+        DBSession = get_db_session()
+        q = DBSession.query(Payment).filter_by(kode=tid)
+        return q.first()
+
+
+class Inquiry:
+    def __init__(self, invoice_id, persen_denda=2, tgl_bayar=None):
+        self.invoice_id = invoice_id
+        self.persen_denda = persen_denda
+        self.tgl_bayar = tgl_bayar or date.today()
+        DBSession = get_db_session()
+        q = DBSession.query(Invoice).filter_by(kode=invoice_id)
+        self.invoice = q.first()
+        if self.invoice:
+            self.hitung()
+
+    def get_payment(self):
+        DBSession = get_db_session()
+        q = DBSession.query(Payment).filter_by(ar_invoice_id=self.invoice.id)
+        q = q.filter(Payment.bayar > 0)
+        q = q.order_by(Payment.pembayaran_ke.desc())
+        return q.first()
+
+    def get_total_payment(self):
+        DBSession = get_db_session()
+        q = DBSession.query(
+                func.sum(Payment.bayar).label('jml'))
+        q = q.filter_by(ar_invoice_id=self.invoice.id)
+        pay = q.first()
+        return pay and pay.jml or 0
+
+    def hitung(self):
+        bunga = self.invoice.bunga or 0
+        bunga = round_up(bunga)
+        self.tagihan = self.invoice.jumlah - bunga
+        self.tagihan = round_up(self.tagihan)
+        bln, denda_waktu = hitung_denda(
+                self.tagihan, self.invoice.jatuh_tempo, self.persen_denda,
+                self.tgl_bayar)
+        self.denda = denda_waktu + bunga
+        self.denda = round_up(self.denda)
+        self.total = self.tagihan + self.denda
+        self.total_bayar = self.get_total_payment()
+        if self.total_bayar > 0:
+            self.total -= self.total_bayar
+        if self.total < 0:
+            self.total = 0
+
+    def is_available(self):
+        return self.invoice.status == 0
+
+    def get_nama(self):
+        return self.invoice.subjek_nama
+
+    def get_alamat_1(self):
+        return self.invoice.objek_alamat_1
+
+    def get_alamat_2(self):
+        return self.invoice.objek_alamat_2
+
+    def get_kode_rekening(self):
+        return self.invoice.rekening_kode
+
+    def get_nama_rekening(self):
+        return self.invoice.rekening_nama
+
+    def get_kode_departemen(self):
+        return self.invoice.departemen_kode
+
+    def get_nama_departemen(self):
+        return self.invoice.departemen_nama
+
+    def get_no_urut(self):
+        DBSession = get_db_session()
+        q = DBSession.query(Payment).filter_by(
+                tahun=self.invoice.tahun,
+                departemen_id=self.invoice.departemen_id)
+        q = q.order_by(Payment.no_urut.desc())
+        row = q.first()
+        if row:
+            return row.no_urut + 1
+        return 1
+
+    def get_pembayaran_ke(self):
+        DBSession = get_db_session()
+        q = DBSession.query(Payment).filter_by(ar_invoice_id=self.invoice.id)
+        q = q.order_by(Payment.pembayaran_ke.desc())
+        row = q.first()
+        if row:
+            return row.pembayaran_ke + 1
+        return 1
+
+    def do_payment(self, ntb, bank_id=None, channel_id=None):
+        DBSession = get_db_session()
+        ntp_generator = NTP()
+        ntp = ntp_generator.create()
+        no_urut = self.get_no_urut()
+        pembayaran_ke = self.get_pembayaran_ke()
+        created = datetime.now()
+        pay = Payment(
+                kode=ntp,
+                status=1,
+                created=created,
+                updated=created,
+                create_date=created,
+                update_date=created,
+                tgl_bayar=self.tgl_bayar,
+                tahun=self.invoice.tahun,
+                departemen_id=self.invoice.departemen_id,
+                no_urut=no_urut,
+                ar_invoice_id=self.invoice.id,
+                pembayaran_ke=pembayaran_ke,
+                bayar=self.total,
+                bunga=self.denda,
+                jatuh_tempo=self.invoice.jatuh_tempo,
+                ntb=ntb,
+                bank_id=bank_id,
+                channel_id=channel_id)
+        DBSession.add(pay)
+        self.invoice.status = 1
+        DBSession.add(self.invoice)
+        DBSession.flush()
+        return pay
+
+
+class Reversal(Inquiry):
+    def __init__(self, *args, **kwargs):
+        super().__init__(*args, **kwargs)
+        if self.invoice:
+            self.payment = self.get_payment()
+
+    def do_reversal(self):
+        DBSession = get_db_session()
+        self.invoice.status = 0
+        DBSession.add(self.invoice)
+        if self.payment:
+            self.payment.bayar = 0
+            DBSession.add(self.payment)
+
+
+class AvailableInvoice:
+    def __init__(self, persen_denda=2, option=None):
+        self.option = option
+        self.persen_denda = persen_denda
+
+    def show(self):
+        offset = -1
+        count = 0
+        max_count_length = len(str(self.option.count))
+        q = self.get_query()
+        awal = time()
+        while True:
+            if time() - awal > 10:
+                break
+            offset += 1
+            row = q.offset(offset).first()
+            if not row:
+                break
+            msg = self.get_message(row)
+            if not msg:
+                continue
+            count += 1
+            no = str(count).zfill(max_count_length)
+            msg = f'#{no}/{self.option.count} {msg}'
+            print(msg)
+            if count == self.option.count:
+                break
+
+    def get_query(self):
+        DBSession = get_db_session()
+        q = DBSession.query(Invoice).filter_by(status=0)
+        q = self.get_filter_tahun(q)
+        q = self.get_filter_nominal(q)
+        q = self.get_filter_jatuh_tempo(q)
+        return q
+
+    def get_filter_tahun(self, q):
+        if self.option.tahun:
+            q = q.filter_by(tahun=self.option.tahun)
+        return q
+
+    def get_filter_nominal(self, q):
+        if self.option.nominal_min:
+            q = q.filter(
+                    Invoice.jumlah - Invoice.bunga >=
+                    self.option.nominal_min)
+        if self.option.nominal_max:
+            q = q.filter(
+                    Invoice.jumlah - Invoice.bunga <=
+                    self.option.nominal_max)
+        return q
+
+    def get_filter_jatuh_tempo(self, q):
+        if self.option.jatuh_tempo_min:
+            tgl = date_from_str(self.option.jatuh_tempo_min)
+            q = q.filter(Invoice.jatuh_tempo >= tgl)
+        if self.option.jatuh_tempo_max:
+            tgl = date_from_str(self.option.jatuh_tempo_max)
+            q = q.filter(Invoice.jatuh_tempo <= tgl)
+        return q
+
+    def get_message(self, row):
+        inq = Inquiry(row.kode, persen_denda=self.persen_denda)
+        if not inq.total:
+            return
+        total = thousand(inq.total)
+        tagihan = thousand(inq.tagihan)
+        denda = thousand(inq.denda)
+        s = f'{row.kode} Tagihan Rp {tagihan} + Denda Rp {denda} = Rp {total}'
+        jatuh_tempo = inq.invoice.jatuh_tempo
+        if jatuh_tempo:
+            jatuh_tempo = jatuh_tempo.strftime('%d-%m-%Y')
+            s = f'{s} jatuh tempo {jatuh_tempo}'
+        return s

setup.py

+import os
+import setuptools
+
+
+with open('README.rst') as f:
+    long_description = f.read()
+
+with open('CHANGES.txt') as f:
+    CHANGES = f.read()
+line = CHANGES.splitlines()[0]
+version = line.split()[0]
+
+requires = [
+    'sqlalchemy',
+    'opensipkd-base @ git+https://git.opensipkd.com/sugiana/opensipkd-base',
+    ]
+
+setuptools.setup(
+    name='opensipkd-webr-models',
+    version=version,
+    author='Owo Sugiana',
+    author_email='sugiana@gmail.com',
+    description='Struktur tabel Web Register',
+    long_description=long_description,
+    long_description_content_type='text/markdown',
+    license='PostgreSQL License',
+    install_requires=requires,
+    packages=setuptools.find_packages(),
+    classifiers=[
+        'Programming Language :: Python :: 3',
+        'Operating System :: OS Independent',
+        ],
+    entry_points={
+        'console_scripts': [
+            'webr_available_invoice = '
+            'opensipkd.webr.scripts.available_invoice:main',
+            'webr_inquiry = opensipkd.webr.scripts.inquiry:main',
+            ]
+        },
+    )