Kali pertama

.gitignore

+__pycache__
+dist
+*egg-info

CHANGES.txt

+0.1 4-11-2021
+-------------
+- Kali pertama

MANIFEST.in

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

README.rst

+Aggregator ke BPD Sultra
+========================
+
+Ini merupakan perantara daemon lain untuk transaksi ke Bank Pembangunan Daerah
+Sulawesi Tenggara. Biasa disebut sebagai aggregator. Daemon lain yang dimaksud
+contohnya adalah LinkAja, produk PT Telkom.

opensipkd/__init__.py

+__path__ = __import__('pkgutil').extend_path(__path__, __name__)

opensipkd/views/__init__.py

+__path__ = __import__('pkgutil').extend_path(__path__, __name__)

opensipkd/views/bpd_sultra/__init__.py

+__path__ = __import__('pkgutil').extend_path(__path__, __name__)

opensipkd/views/bpd_sultra/linkaja/__init__.py

+from opensipkd.views.bjb.linkaja.pbb import PREFIX_HANDLER_WEB
+from .pbb import PrefixHandler
+
+
+def includeme(config):
+    # Prefix NOP PBB Kota Kendari
+    PREFIX_HANDLER_WEB['7471'] = PrefixHandler

opensipkd/views/bpd_sultra/linkaja/pbb.py

+import requests
+from opensipkd.string import exception_message
+from pyramid_linkaja.responses import get_template_response
+from pyramid_linkaja.exceptions import (
+    InvoiceIdError,
+    AlreadyPaidError,
+    BaseError,
+    LinkError,
+    )
+from linkaja.models import Bank
+from bpd_sultra.structure import (
+    RC_OK,
+    RC_NOT_FOUND,
+    RC_ALREADY_PAID,
+    RC_LINK_DOWN,
+    RC_INVALID_TOKEN,
+    RC_INVALID_REQUEST,
+    )
+from bpd_sultra.pbb import WebClient as BaseWebClient
+
+
+NUM_FIELDS = [
+    ('JML_POKOK', 'Pok'),
+    ('JML_DENDA', 'Den')]
+
+STR_FIELDS = ['ALAMAT_WP', 'KELURAHAN_WP']
+
+
+def profile2name(resp):
+    invoice_id = 'NOP {} Tahun {}'.format(resp['NOP'], resp['THN_PAJAK'])
+    msg = [invoice_id, resp['NAMA_WP']]
+    for field, label in NUM_FIELDS:
+        s = resp[field]
+        if s:
+            msg.append(f'{label} {s}')
+    for field in STR_FIELDS:
+        s = resp[field]
+        if s:
+            if field == 'ALAMAT_OP':
+                s = s.replace(':', ' ')
+            msg.append(s)
+    return ', '.join(msg)
+
+
+class WebClient(BaseWebClient):
+    def __init__(self, parent):
+        self.parent = parent
+        base_url = self.parent.qconf.get_value('bpd sultra base url')
+        username = self.parent.qconf.get_value('bpd sultra username')
+        password = self.parent.qconf.get_value('bpd sultra password')
+        super().__init__(base_url, username, password)
+
+    def before_send(self, url, data):
+        self.bank_log = None
+        if url.find('inquiry') > -1 or url.find('payment') > -1:
+            self.bank_log = Bank(
+                    rpc_id=self.parent.web_log.id, conf_name='bpd sultra',
+                    url=url, request=data)
+            self.parent.request.dbsession.add(self.bank_log)
+            self.parent.request.tm.commit()
+            self.parent.request.tm.begin()
+
+    def after_send(self, data):
+        if not self.bank_log:
+            return
+        self.bank_log.response = data
+        self.parent.request.dbsession.add(self.bank_log)
+        self.parent.request.tm.commit()
+        self.parent.request.tm.begin()
+
+    def send(self, url, headers, data):  # Override
+        self.before_send(url, data)
+        r = super().send(url, headers, data)
+        self.after_send(r)
+        return r
+
+
+class PrefixHandler:
+    def __init__(self, parent):
+        self.parent = parent
+
+    def auth(self):
+        try:
+            self.remote.auth()
+        except requests.exceptions.ConnectionError as e:
+            self.parent.log_error(e)
+            raise LinkError()
+        except Exception as e:
+            msg = exception_message()
+            self.parent.log_error(msg)
+            raise LinkError()
+
+    def __inquiry(self):
+        invoice_id = self.parent.q_web_log.get_invoice_id()
+        try:
+            return self.remote.inquiry(invoice_id)
+        except requests.exceptions.ConnectionError as e:
+            self.parent.log_error(e)
+            raise LinkError()
+        except Exception:
+            raise LinkError()
+
+    def inquiry(self):
+        resp = get_template_response(self.parent.q_web_log.data)
+        self.remote = WebClient(self.parent)
+        try:
+            self.auth()
+        except BaseError as err:
+            resp.from_err(err)
+            return resp
+        try:
+            r = self.__inquiry()
+        except BaseError as err:
+            resp.from_err(err)
+            return resp
+        if r['RC'] == RC_OK:
+            d = self.rc_ok(r)
+            for key in d:
+                resp[key] = d[key]
+        else:
+            err = self.rc_error(r['RC'])
+            resp.from_err(err)
+        return resp
+
+    def __payment(self):
+        q = self.parent.request.dbsession.query(Bank).filter_by(
+                rpc_id=self.parent.web_log.inquiry_id)
+        bank_log = q.first()
+        data = dict(bank_log.response)  # dari inquiry response
+        del data['RC']
+        del data['RM']
+        del data['TRACENUM']
+        data['NO_ARSIP'] = self.parent.q_web_log.data['trx_id']  # NTB
+        try:
+            return self.remote.payment(data)
+        except requests.exceptions.ConnectionError as e:
+            self.parent.log_error(e)
+            raise LinkError()
+        except Exception:
+            raise LinkError()
+
+    def payment(self):
+        resp = get_template_response(self.parent.q_web_log.data)
+        self.remote = WebClient(self.parent)
+        try:
+            self.auth()
+        except BaseError as err:
+            resp.from_err(err)
+            return resp
+        try:
+            r = self.__payment()
+        except BaseError as err:
+            resp.from_err(err)
+            return resp
+        if r['RC'] == RC_OK:
+            d = self.rc_ok(r)
+            for key in d:
+                resp[key] = d[key]
+        else:
+            err = self.rc_error(r['RC'])
+            resp.from_err(err)
+        return resp
+
+    def rc_error(self, rc):
+        if rc == RC_NOT_FOUND:
+            return InvoiceIdError()
+        if rc == RC_ALREADY_PAID:
+            return AlreadyPaidError()
+        if rc in (RC_LINK_DOWN, RC_INVALID_TOKEN, RC_INVALID_REQUEST):
+            return LinkError()
+        return BaseError()
+
+    def rc_ok(self, resp):
+        web_log = self.parent.web_log
+        keterangan = profile2name(resp)
+        d = {'Response Code': '00'}
+        if self.parent.is_inquiry():
+            total = int(resp['JML_POKOK']) + int(resp['JML_DENDA'])
+            d['Bill Amount'] = str(total)
+            d['Bill Ref'] = str(web_log.id)
+            d['Biller Name'] = web_log.biller_name = keterangan
+            d['Notification Message'] = self.parent.notification_message
+        else:  # payment
+            d['Transaction ID'] = web_log.ntp = resp['NO_NTTP']  # NTP
+            d['Notification Message'] = keterangan
+        return d

setup.py

+import os
+from setuptools import (
+    setup,
+    find_packages,
+    )
+
+
+here = os.path.abspath(os.path.dirname(__file__))
+with open(os.path.join(here, 'README.rst')) as f:
+    README = f.read()
+with open(os.path.join(here, 'CHANGES.txt')) as f:
+    CHANGES = f.read()
+
+line = CHANGES.splitlines()[0]
+version = line.split()[0]
+
+requires = [
+    'opensipkd-iso8583-bjb @ '
+    'git+https://git.opensipkd.com/sugiana/opensipkd-iso8583-bjb.git',
+    'bpd-sultra-web-service @ '
+    'git+https://git.opensipkd.com/sugiana/bpd-sultra-web-service.git',
+    ]
+
+
+setup(
+    name='opensipkd-bpd-sultra',
+    version=version,
+    description='Pengolahan LinkAja request ke BPD Sulawesi Tenggara',
+    long_description=README + '\n\n' + CHANGES,
+    author='Owo Sugiana',
+    author_email='sugiana@gmail.com',
+    license='PostgreSQL License',
+    packages=find_packages(),
+    include_package_data=True,
+    install_requires=requires,
+    zip_safe=False)