api_payment.py

# import logging
# import re
# from datetime import datetime, date

# from tangsel.base.tools import number_only
# from tangsel.base.tools.api import (
#     auth_from_rpc, JsonRpcInvalidDataError,
#     JsonRpcDataNotFoundError, JsonRpcBillAllreadyPaidError,
#     JsonRpcBillDifferentError)
# from tangsel.base.tools.pbb import hitung_denda, FixNop
# from tangsel.base.views.base_views import BaseView as OsBaseView
# from pyramid_rpc.jsonrpc import jsonrpc_method
# from sqlalchemy import func, and_

# from tangsel.pbb.models import (
#     PbbDBSession, Sppt, PembayaranSppt, DatObjekPajak,
#     Propinsi, Dati2, Kecamatan, Kelurahan)
# from ..tools import get_settings, get_random_number

# # digunakan sam view yang lain

# log = logging.getLogger(__name__)


# class BaseView(OsBaseView):
#     def __init__(self, request):
#         super(BaseView, self).__init__(request)
#         self.params = request.params


# @jsonrpc_method(method='inquiry', endpoint='rpc-pbb-payment')
# def inquiry(request, data):
#     log.info(">>> INQUIRY REQUEST {}".format(data))
#     auth_from_rpc(request)
#     error = JsonRpcInvalidDataError
#     result = []
#     is_list = isinstance(data, list)
#     data_list = is_list and data or [data]
#     for data in data_list:
#         if not ('nop' in data and 'tahun' in data):
#             # log.warning("!!! NOP/Tahun tidak terdapat dalam request")
#             raise JsonRpcInvalidDataError
#         # blocking data
#         blocking = blocking_data(data)
#         if blocking:
#             error = JsonRpcDataNotFoundError
#             continue
#         # sppt, pokok, denda, jumlah = inquiry_(data)
#         sppt = query_tagihan(data).first()
#         if not sppt or (sppt and sppt.status_pembayaran_sppt == '2'):
#             # log.warning("!!! SPPT tidak ditemukan atau SPPT dibatalkan")
#             error = JsonRpcDataNotFoundError
#             continue
#         if sppt.status_pembayaran_sppt == '1':
#             # log.warning("!!! SPPT status=1 (sudah dibayar)")
#             error = JsonRpcBillAllreadyPaidError
#             continue
#         if sppt.status_pembayaran_sppt > '2':
#             # log.warning("!!! SPPT status > 2")
#             error = JsonRpcBillAllreadyPaidError
#             continue
#         nop = str(data["nop"])
#         thn_pajak = str(data["tahun"])
#         # log.info("### NOP %s-%s: ", nop, thn_pajak)
#         pay = PembayaranSppt.query_bayar(nop, thn_pajak).first()
#         bayar = pay.bayar and (pay.bayar - pay.denda) or 0
#         # pokok = sppt.pbb_yg_harus_dibayar_sppt - (hasattr(pay,'discount_pokok') and pay.discount_pokok or 0)
#         pokok = sppt.pbb_yg_harus_dibayar_sppt
#         sisa = float(pokok) - float(bayar)
#         if sisa < 1:
#             # log.warning("!!! Sisa < 1")
#             error = JsonRpcBillAllreadyPaidError
#             continue
#         denda = hitung_denda(sisa, sppt.tgl_jatuh_tempo_sppt)
#         discount_pokok = pengurangPokok(sisa, thn_pajak, nop)
#         discount_denda = pengurangDenda(denda, thn_pajak, nop)
#         discount = discount_pokok + discount_denda
#         jumlah = sisa + denda - discount
#         # log.info("### POKOK  : {}".format(sisa))
#         # log.info("### DENDA  : {}".format(denda))
#         # log.info("### DISKON : {}".format(discount))
#         # log.info("### JUMLAH : {}".format(jumlah))
#         jth_tempo = isinstance(sppt.tgl_jatuh_tempo_sppt, datetime) and \
#                     sppt.tgl_jatuh_tempo_sppt.date() or sppt.tgl_jatuh_tempo_sppt
#         data.update(dict(zip(sppt.keys(), sppt)))
#         data.update(
#             dict(pbb_yg_harus_dibayar_sppt=sisa,
#                  denda_sppt=denda,
#                  jml_sppt_yg_dibayar=jumlah,
#                  discount=discount,
#                  discount_pokok=discount_pokok,
#                  discount_denda=discount_denda,
#                  kelurahan=sppt.nm_kelurahan,
#                  kecamatan=sppt.nm_kecamatan,
#                  kota=sppt.nm_dati2,
#                  propinsi=sppt.nm_propinsi,
#                  tgl_jatuh_tempo_sppt=jth_tempo,
#                  ))
#         result.append(data)
#     if not result:
#         raise error
#     result = is_list and result or result[0]
#     log.info(">>> INQUIRY RESULT {}".format(result))
#     return dict(message="Sukses Inquiry", data=result)


# @jsonrpc_method(method='payment', endpoint='rpc-pbb-payment')
# def payment(request, data):
#     log.info(">>> PAYMENT REQUEST {}".format(data))
#     auth_from_rpc(request)
#     error = JsonRpcInvalidDataError
#     result = []
#     is_list = isinstance(data, list)
#     data_list = is_list and data or [data]
#     for data in data_list:
#         if not ('nop' in data and 'tahun' in data):
#             # log.warning("!!! NOP/Tahun tidak terdapat dalam request")
#             continue
#         # blocking data
#         blocking = blocking_data(data)
#         if blocking:
#             error = JsonRpcDataNotFoundError
#             continue
#         sppt = query_tagihan(data).first()
#         if not sppt or (sppt and sppt.status_pembayaran_sppt == '2'):
#             # log.warning("!!! SPPT tidak ditemukan atau SPPT dibatalkan")
#             error = JsonRpcDataNotFoundError
#             continue
#         if sppt.status_pembayaran_sppt == '1':
#             # log.warning("!!! SPPT status=1 (sudah dibayar)")
#             error = JsonRpcBillAllreadyPaidError
#             continue

#         if sppt.status_pembayaran_sppt > '2':
#             # log.warning("!!! SPPT status > 2")
#             error = JsonRpcBillAllreadyPaidError
#             continue

#         nop = str(data["nop"])
#         thn_pajak = str(data["tahun"])
#         # log.info("### NOP %s-%s: ", nop, thn_pajak)
#         # cek apakah pembayaran akan disimpan dengan konsep bruto
#         konsep_bruto = is_konsep_bruto(nop)
#         pay = PembayaranSppt.query_bayar(nop, thn_pajak).first()
#         bayar = pay.bayar and (pay.bayar - pay.denda) or 0
#         # pokok = sppt.pbb_yg_harus_dibayar_sppt - (hasattr(pay,'discount_pokok') and pay.discount_pokok or 0)
#         pokok = sppt.pbb_yg_harus_dibayar_sppt
#         sisa = float(pokok) - float(bayar)
#         if sisa < 1:
#             # log.warning("!!! Sisa < 1")
#             error = JsonRpcBillAllreadyPaidError
#             continue
#         denda = hitung_denda(sisa, sppt.tgl_jatuh_tempo_sppt)
#         discount_pokok = pengurangPokok(sisa, thn_pajak, nop)
#         discount_denda = pengurangDenda(denda, thn_pajak, nop)
#         discount = discount_pokok + discount_denda
#         jumlah = sisa + denda - discount
#         # jika jumlah denda atau jumlah bayar yang dikirim tidak sama dengan
#         # hasil perhitungan maka jangan dilanjutkan
#         if denda != data["denda_sppt"] or jumlah != data["jml_sppt_yg_dibayar"]:
#             # log.warning("!!! ** JUMLAH DENDA/BAYAR TIDAK SESUAI **")
#             error = JsonRpcBillDifferentError
#             continue
#         settings = get_settings()
#         tp = dict(b.split(":", 1) for b in settings["kd_tp"].split(","))
#         bank = data["bank"]
#         kd_tp = tp[bank].split(".")
#         channel = data["channel"]
#         values = dict(zip(sppt.keys(), sppt))
#         values.update(data)
#         if len(kd_tp) == 3:
#             values["kd_kanwil"] = kd_tp[0]
#             values["kd_kantor"] = kd_tp[1]
#             values["kd_tp"] = kd_tp[2]
#         values[
#             "denda_sppt"] = denda - discount_denda if not konsep_bruto else denda
#         values["denda_sblm_diskon"] = denda if discount_denda > 0 else 0
#         values["pbb_yg_harus_dibayar_sppt"] = sisa
#         values[
#             "jml_sppt_yg_dibayar"] = jumlah if not konsep_bruto else jumlah + discount
#         values["discount"] = discount
#         values["discount_pokok"] = discount_pokok
#         values["discount_denda"] = discount_denda
#         values["nip_rekam_byr_sppt"] = settings["nip_rekam_bayar"]
#         now = datetime.now()
#         values["tgl_pembayaran_sppt"] = now.date()
#         values["tgl_rekam_byr_sppt"] = now
#         values["kd_bank"] = bank
#         values["kd_channel"] = channel
#         values["ntpd"] = get_random_number(16)
#         pembayaran_sppt_save(values)
#         if "id" in values:
#             del values["id"]
#         data.update(values)
#         # TODO: nambahin field diskon di table log
#         # LogPaymentPbb.save(values)
#         # kirim nilai denda (TODO: agar nanti disesuaikan kembali)
#         values["denda_sppt"] = denda
#         data.update(values)
#         result.append(data)
#     if not result:
#         raise error
#     result = is_list and result or result[0]
#     log.info(">>> PAYMENT RESULT {}".format(result))
#     return dict(message="Sukses Payment", data=result)


# def pembayaran_sppt_save(values, row=None):
#     if not row:
#         row = PembayaranSppt()
#     row.from_dict(values)
#     nop = FixNop(values["nop"])
#     tahun = values["tahun"]
#     qry = PbbDBSession.query(func.max(PembayaranSppt.pembayaran_sppt_ke))
#     qry = qry.filter(
#         PembayaranSppt.kd_propinsi == nop["kd_propinsi"],
#         PembayaranSppt.kd_dati2 == nop["kd_dati2"],
#         PembayaranSppt.kd_kecamatan == nop["kd_kecamatan"],
#         PembayaranSppt.kd_kelurahan == nop["kd_kelurahan"],
#         PembayaranSppt.kd_blok == nop["kd_blok"],
#         PembayaranSppt.no_urut == nop["no_urut"],
#         PembayaranSppt.kd_jns_op == nop["kd_jns_op"],
#         PembayaranSppt.thn_pajak_sppt == tahun)
#     ke = qry.scalar()
#     row.pembayaran_sppt_ke = ke and ke + 1 or 1
#     PbbDBSession.add(row)
#     PbbDBSession.flush()


# def query_tagihan(data):
#     np = FixNop(str(data['nop']))
#     sppt = PbbDBSession.query(
#         Sppt.kd_propinsi,
#         Sppt.kd_dati2,
#         Sppt.kd_kecamatan,
#         Sppt.kd_kelurahan,
#         Sppt.kd_blok,
#         Sppt.no_urut,
#         Sppt.kd_jns_op,
#         Sppt.thn_pajak_sppt,
#         Sppt.siklus_sppt,
#         Sppt.kd_kanwil,
#         Sppt.kd_kantor,
#         Sppt.kd_tp,
#         Sppt.nm_wp_sppt,
#         Sppt.jln_wp_sppt,
#         Sppt.blok_kav_no_wp_sppt,
#         Sppt.rw_wp_sppt,
#         Sppt.rt_wp_sppt,
#         Sppt.kelurahan_wp_sppt,
#         Sppt.kota_wp_sppt,
#         Sppt.kd_pos_wp_sppt,
#         Sppt.npwp_sppt,
#         Sppt.no_persil_sppt,
#         Sppt.kd_kls_tanah,
#         Sppt.thn_awal_kls_tanah,
#         Sppt.kd_kls_bng,
#         Sppt.thn_awal_kls_bng,
#         Sppt.tgl_jatuh_tempo_sppt,
#         Sppt.luas_bumi_sppt,
#         Sppt.luas_bng_sppt,
#         Sppt.njop_bumi_sppt,
#         Sppt.njop_bng_sppt,
#         Sppt.njop_sppt,
#         Sppt.njoptkp_sppt,
#         Sppt.pbb_terhutang_sppt,
#         Sppt.faktor_pengurang_sppt,
#         Sppt.pbb_yg_harus_dibayar_sppt,
#         Sppt.status_pembayaran_sppt,
#         Sppt.status_tagihan_sppt,
#         Sppt.status_cetak_sppt,
#         Sppt.tgl_terbit_sppt,
#         Sppt.tgl_cetak_sppt,
#         Sppt.nip_pencetak_sppt,
#         Propinsi.nm_propinsi, Dati2.nm_dati2,
#         Kecamatan.nm_kecamatan, Kelurahan.nm_kelurahan) \
#         .outerjoin(Propinsi, Propinsi.kd_propinsi == Sppt.kd_propinsi) \
#         .outerjoin(Dati2,
#                    and_(Dati2.kd_propinsi == Sppt.kd_propinsi,
#                         Dati2.kd_dati2 == Sppt.kd_dati2)) \
#         .outerjoin(Kecamatan,
#                    and_(Kecamatan.kd_propinsi == Sppt.kd_propinsi,
#                         Kecamatan.kd_dati2 == Sppt.kd_dati2,
#                         Kecamatan.kd_kecamatan == Sppt.kd_kecamatan)) \
#         .outerjoin(Kelurahan,
#                    and_(Kelurahan.kd_propinsi == Sppt.kd_propinsi,
#                         Kelurahan.kd_dati2 == Sppt.kd_dati2,
#                         Kelurahan.kd_kecamatan == Sppt.kd_kecamatan,
#                         Kelurahan.kd_kelurahan == Sppt.kd_kelurahan)) \
#         .filter(
#         Sppt.kd_propinsi == np["kd_propinsi"],
#         Sppt.kd_dati2 == np["kd_dati2"],
#         Sppt.kd_kecamatan == np["kd_kecamatan"],
#         Sppt.kd_kelurahan == np["kd_kelurahan"],
#         Sppt.kd_blok == np["kd_blok"],
#         Sppt.no_urut == np["no_urut"],
#         Sppt.kd_jns_op == np["kd_jns_op"],
#         Sppt.thn_pajak_sppt == str(data['tahun']))
#     return sppt


# @jsonrpc_method(method='range_nop', endpoint='rpc-pbb-payment')
# def range_nop(request, data):
#     auth_from_rpc(request)
#     is_list = isinstance(data, list)
#     data_list = is_list and data or [data]
#     result = []
#     error = JsonRpcDataNotFoundError
#     for data in data_list:
#         if not ('nop' in data and 'tahun' in data and 'nop_akhir' in data):
#             raise JsonRpcInvalidDataError
#         nop = FixNop(data['nop'])
#         akhir = number_only(data["nop_akhir"])
#         sppt = PbbDBSession.query(Sppt.kd_propinsi, Sppt.kd_dati2,
#                                   Sppt.kd_kecamatan, Sppt.kd_kelurahan,
#                                   Sppt.kd_blok,
#                                   Sppt.no_urut, Sppt.kd_jns_op,
#                                   Sppt.thn_pajak_sppt) \
#             .filter(Sppt.kd_propinsi == nop["kd_propinsi"],
#                     Sppt.kd_dati2 == nop["kd_dati2"],
#                     Sppt.kd_kecamatan == nop["kd_kecamatan"],
#                     Sppt.kd_kelurahan == nop["kd_kelurahan"],
#                     Sppt.kd_blok == nop["kd_blok"],
#                     Sppt.no_urut.between(nop["no_urut"], akhir[:4]),
#                     Sppt.kd_jns_op == nop["kd_jns_op"],
#                     Sppt.thn_pajak_sppt == data['tahun']) \
#             .filter(Sppt.status_pembayaran_sppt == '0')
#         row = sppt.first()
#         if not row:
#             continue
#         keys = row.keys()
#         result = [dict(zip(keys, s)) for s in sppt.all()]
#     if not result:
#         raise error
#     return dict(message="Sukses Get Nop", data=result, count=len(result))


# @jsonrpc_method(method='status_nop', endpoint='rpc-pbb-payment')
# def status_nop(request, data):
#     auth_from_rpc(request)
#     if not 'nop' in data:
#         raise JsonRpcInvalidDataError
#     sppt = query_check_nop(data['nop'])
#     row = sppt.all()
#     if not row:
#         raise JsonRpcDataNotFoundError
#     result = [dict(zip(r.keys(), r)) for r in row]
#     return dict(message="Sukses Check Status Nop", data=result,
#                 count=len(result))


# def query_check_nop(nop):
#     nop = FixNop(nop)
#     sppt = PbbDBSession.query(
#         Sppt.nm_wp_sppt.label('nm_wp_sppt'),
#         func.concat(Sppt.jln_wp_sppt,
#                     func.concat(', ', Sppt.blok_kav_no_wp_sppt)).label(
#             'alamat_wp'),
#         func.concat(Sppt.rt_wp_sppt, func.concat(' / ', Sppt.rw_wp_sppt)).label(
#             'rt_rw_wp'),
#         Sppt.kota_wp_sppt.label('kota_wp_sppt'),
#         Sppt.kelurahan_wp_sppt.label('kelurahan_wp_sppt'),
#         func.concat(DatObjekPajak.jalan_op,
#                     func.concat(', ', DatObjekPajak.blok_kav_no_op)).label(
#             'alamat_op'),
#         func.concat(DatObjekPajak.rt_op,
#                     func.concat(' / ', DatObjekPajak.rw_op)).label('rt_rw_op'),
#         Kelurahan.nm_kelurahan.label('kelurahan_op'),
#         Kecamatan.nm_kecamatan.label('kecamatan_op'),
#         Dati2.nm_dati2.label('kota_op'),
#         func.concat(Sppt.kd_propinsi,
#                     func.concat(Sppt.kd_dati2,
#                                 func.concat(Sppt.kd_kecamatan,
#                                             func.concat(Sppt.kd_kelurahan,
#                                                         func.concat(
#                                                             Sppt.kd_blok,
#                                                             func.concat(
#                                                                 Sppt.no_urut,
#                                                                 Sppt.kd_jns_op)))))).label(
#             'nop'),
#         Sppt.thn_pajak_sppt.label('thn_pajak_sppt'),
#         Sppt.luas_bumi_sppt.label('luas_bumi_sppt'),
#         Sppt.njop_bumi_sppt.label('njop_bumi_sppt'),
#         Sppt.luas_bng_sppt.label('luas_bng_sppt'),
#         Sppt.njop_bng_sppt.label('njop_bng_sppt'),
#         Sppt.pbb_yg_harus_dibayar_sppt.label('pbb_yg_harus_dibayar_sppt'),
#         func.coalesce(func.sum(PembayaranSppt.jml_sppt_yg_dibayar), 0).label(
#             'jml_sppt_yg_dibayar'),
#         func.coalesce(func.sum(PembayaranSppt.denda_sppt), 0).label(
#             'denda_sppt'),
#         func.coalesce((Sppt.pbb_yg_harus_dibayar_sppt + func.coalesce(
#             func.sum(PembayaranSppt.denda_sppt), 0)
#                        - func.sum(PembayaranSppt.jml_sppt_yg_dibayar)),
#                       0).label('sisa'),
#         func.to_char(func.max(PembayaranSppt.tgl_pembayaran_sppt),
#                      'DD-MM-YYYY').label('tgl_pembayaran_sppt'),
#     ) \
#         .outerjoin(PembayaranSppt,
#                    and_(
#                        PembayaranSppt.kd_propinsi == Sppt.kd_propinsi,
#                        PembayaranSppt.kd_dati2 == Sppt.kd_dati2,
#                        PembayaranSppt.kd_kecamatan == Sppt.kd_kecamatan,
#                        PembayaranSppt.kd_kelurahan == Sppt.kd_kelurahan,
#                        PembayaranSppt.kd_blok == Sppt.kd_blok,
#                        PembayaranSppt.no_urut == Sppt.no_urut,
#                        PembayaranSppt.kd_jns_op == Sppt.kd_jns_op,
#                        PembayaranSppt.thn_pajak_sppt == Sppt.thn_pajak_sppt,
#                    )
#                    ) \
#         .outerjoin(DatObjekPajak,
#                    and_(
#                        DatObjekPajak.kd_propinsi == Sppt.kd_propinsi,
#                        DatObjekPajak.kd_dati2 == Sppt.kd_dati2,
#                        DatObjekPajak.kd_kecamatan == Sppt.kd_kecamatan,
#                        DatObjekPajak.kd_kelurahan == Sppt.kd_kelurahan,
#                        DatObjekPajak.kd_blok == Sppt.kd_blok,
#                        DatObjekPajak.no_urut == Sppt.no_urut,
#                        DatObjekPajak.kd_jns_op == Sppt.kd_jns_op,
#                    )
#                    ) \
#         .outerjoin(Dati2,
#                    and_(
#                        Dati2.kd_propinsi == Sppt.kd_propinsi,
#                        Dati2.kd_dati2 == Sppt.kd_dati2,
#                    )
#                    ) \
#         .outerjoin(Kecamatan,
#                    and_(
#                        Kecamatan.kd_propinsi == Sppt.kd_propinsi,
#                        Kecamatan.kd_dati2 == Sppt.kd_dati2,
#                        Kecamatan.kd_kecamatan == Sppt.kd_kecamatan,
#                    )
#                    ) \
#         .outerjoin(Kelurahan,
#                    and_(
#                        Kelurahan.kd_propinsi == Sppt.kd_propinsi,
#                        Kelurahan.kd_dati2 == Sppt.kd_dati2,
#                        Kelurahan.kd_kecamatan == Sppt.kd_kecamatan,
#                        Kelurahan.kd_kelurahan == Sppt.kd_kelurahan,
#                    )
#                    ) \
#         .filter(
#         Sppt.kd_propinsi == nop["kd_propinsi"],
#         Sppt.kd_dati2 == nop["kd_dati2"],
#         Sppt.kd_kecamatan == nop["kd_kecamatan"],
#         Sppt.kd_kelurahan == nop["kd_kelurahan"],
#         Sppt.kd_blok == nop["kd_blok"],
#         Sppt.no_urut == nop["no_urut"],
#         Sppt.kd_jns_op == nop["kd_jns_op"],
#         Sppt.status_pembayaran_sppt.in_(['0', '1']),
#     ) \
#         .group_by(
#         func.concat(Sppt.kd_propinsi,
#                     func.concat(Sppt.kd_dati2,
#                                 func.concat(Sppt.kd_kecamatan,
#                                             func.concat(Sppt.kd_kelurahan,
#                                                         func.concat(
#                                                             Sppt.kd_blok,
#                                                             func.concat(
#                                                                 Sppt.no_urut,
#                                                                 Sppt.kd_jns_op)))))),
#         Sppt.thn_pajak_sppt,
#         Sppt.nm_wp_sppt,
#         Sppt.jln_wp_sppt, Sppt.blok_kav_no_wp_sppt,
#         Sppt.rt_wp_sppt, Sppt.rw_wp_sppt,
#         Sppt.kota_wp_sppt, Sppt.kelurahan_wp_sppt,
#         DatObjekPajak.jalan_op, DatObjekPajak.blok_kav_no_op,
#         DatObjekPajak.rt_op, DatObjekPajak.rw_op,
#         Kelurahan.nm_kelurahan, Kecamatan.nm_kecamatan, Dati2.nm_dati2,
#         Sppt.luas_bumi_sppt, Sppt.njop_bumi_sppt,
#         Sppt.luas_bng_sppt, Sppt.njop_bng_sppt,
#         Sppt.pbb_yg_harus_dibayar_sppt,
#     ) \
#         .order_by(
#         Sppt.thn_pajak_sppt,
#         Sppt.kelurahan_wp_sppt
#     )
#     return sppt


# # @jsonrpc_method(method='get_syncron', endpoint='rpc-pbb-payment')
# # def get_syncron(request, data):
# #     auth_from_rpc(request)
# #     syncron = query_get_syncron(data)
# #     if not syncron['countData']:
# #         raise JsonRpcDataNotFoundError
# #     return dict(
# #         message="Success",
# #         data=syncron['data'],
# #         countData=syncron['countData'],
# #         countOracle=syncron['countOracle'],
# #         countLog=syncron['countLog']
# #     )

# #
# # def query_get_syncron(data):
# #     data = isinstance(data, list) and data or [data]
# #     dtSppt = PbbDBSession.query(
# #         PembayaranSppt.denda_sppt.label('denda_sppt'),
# #         PembayaranSppt.jml_sppt_yg_dibayar.label('jml_sppt_yg_dibayar'),
# #         PembayaranSppt.tgl_pembayaran_sppt.label('tgl_pembayaran_sppt'),
# #         PembayaranSppt.tgl_rekam_byr_sppt.label('tgl_rekam_byr_sppt'),
# #         PembayaranSppt.kd_propinsi.label('kd_propinsi'),
# #         PembayaranSppt.kd_dati2.label('kd_dati2'),
# #         PembayaranSppt.kd_kecamatan.label('kd_kecamatan'),
# #         PembayaranSppt.kd_kelurahan.label('kd_kelurahan'),
# #         PembayaranSppt.kd_blok.label('kd_blok'),
# #         PembayaranSppt.no_urut.label('no_urut'),
# #         PembayaranSppt.kd_jns_op.label('kd_jns_op'),
# #         PembayaranSppt.thn_pajak_sppt.label('thn_pajak_sppt'),
# #         PembayaranSppt.pembayaran_sppt_ke.label('pembayaran_sppt_ke'),
# #         Sppt.nm_wp_sppt.label('nm_wp_sppt'),
# #         Sppt.jln_wp_sppt.label('jln_wp_sppt'),
# #         Sppt.blok_kav_no_wp_sppt.label('blok_kav_no_wp_sppt'),
# #         Sppt.rw_wp_sppt.label('rw_wp_sppt'),
# #         Sppt.rt_wp_sppt.label('rt_wp_sppt'),
# #         Sppt.kelurahan_wp_sppt.label('kelurahan_wp_sppt'),
# #         Sppt.kota_wp_sppt.label('kota_wp_sppt'),
# #         Sppt.kd_pos_wp_sppt.label('kd_pos_wp_sppt'),
# #         Sppt.tgl_jatuh_tempo_sppt.label('tgl_jatuh_tempo_sppt'),
# #         Sppt.luas_bumi_sppt.label('luas_bumi_sppt'),
# #         Sppt.luas_bng_sppt.label('luas_bng_sppt'),
# #         Sppt.pbb_yg_harus_dibayar_sppt.label('pbb_yg_harus_dibayar_sppt'),
# #         Propinsi.nm_propinsi.label('propinsi'),
# #         Dati2.nm_dati2.label('kota'),
# #         Kecamatan.nm_kecamatan.label('kecamatan'),
# #         Kelurahan.nm_kelurahan.label('kelurahan'),
# #     ) \
# #         .join(Sppt,
# #               and_(
# #                   Sppt.kd_propinsi == PembayaranSppt.kd_propinsi,
# #                   Sppt.kd_dati2 == PembayaranSppt.kd_dati2,
# #                   Sppt.kd_kecamatan == PembayaranSppt.kd_kecamatan,
# #                   Sppt.kd_kelurahan == PembayaranSppt.kd_kelurahan,
# #                   Sppt.kd_blok == PembayaranSppt.kd_blok,
# #                   Sppt.no_urut == PembayaranSppt.no_urut,
# #                   Sppt.kd_jns_op == PembayaranSppt.kd_jns_op,
# #                   Sppt.thn_pajak_sppt == PembayaranSppt.thn_pajak_sppt,
# #               )
# #               ) \
# #         .outerjoin(Propinsi,
# #                    Propinsi.kd_propinsi == PembayaranSppt.kd_propinsi,
# #                    ) \
# #         .outerjoin(Dati2,
# #                    and_(
# #                        Dati2.kd_propinsi == PembayaranSppt.kd_propinsi,
# #                        Dati2.kd_dati2 == PembayaranSppt.kd_dati2,
# #                    )
# #                    ) \
# #         .outerjoin(Kecamatan,
# #                    and_(
# #                        Kecamatan.kd_propinsi == PembayaranSppt.kd_propinsi,
# #                        Kecamatan.kd_dati2 == PembayaranSppt.kd_dati2,
# #                        Kecamatan.kd_kecamatan == PembayaranSppt.kd_kecamatan,
# #                    )
# #                    ) \
# #         .outerjoin(Kelurahan,
# #                    and_(
# #                        Kelurahan.kd_propinsi == PembayaranSppt.kd_propinsi,
# #                        Kelurahan.kd_dati2 == PembayaranSppt.kd_dati2,
# #                        Kelurahan.kd_kecamatan == PembayaranSppt.kd_kecamatan,
# #                        Kelurahan.kd_kelurahan == PembayaranSppt.kd_kelurahan,
# #                    )
# #                    )
# #     dtSppt = dtSppt.filter(
# #         or_(*[
# #             and_(
# #                 PembayaranSppt.kd_propinsi == np['kd_propinsi'],
# #                 PembayaranSppt.kd_dati2 == np['kd_dati2'],
# #                 PembayaranSppt.kd_kecamatan == np['kd_kecamatan'],
# #                 PembayaranSppt.kd_kelurahan == np['kd_kelurahan'],
# #                 PembayaranSppt.kd_blok == np['kd_blok'],
# #                 PembayaranSppt.no_urut == np['no_urut'],
# #                 PembayaranSppt.kd_jns_op == np['kd_jns_op'],
# #                 PembayaranSppt.thn_pajak_sppt == np['thn_pajak_sppt'],
# #             )
# #             for np in data
# #         ])
# #     )
# #     dtSppt = dtSppt.all()
# #     Log = DBSession.query(LogPaymentPbb)
# #     Log = Log.filter(
# #         or_(*[
# #             and_(
# #                 LogPaymentPbb.kd_propinsi == np['kd_propinsi'],
# #                 LogPaymentPbb.kd_dati2 == np['kd_dati2'],
# #                 LogPaymentPbb.kd_kecamatan == np['kd_kecamatan'],
# #                 LogPaymentPbb.kd_kelurahan == np['kd_kelurahan'],
# #                 LogPaymentPbb.kd_blok == np['kd_blok'],
# #                 LogPaymentPbb.no_urut == np['no_urut'],
# #                 LogPaymentPbb.kd_jns_op == np['kd_jns_op'],
# #                 LogPaymentPbb.thn_pajak_sppt == np['thn_pajak_sppt'],
# #             )
# #             for np in data
# #         ])
# #     )
# #     Log = Log.all()
# #     dtLog = {}
# #     for lg in Log:
# #         nop = '{}{}{}{}{}{}{}'.format(
# #             lg.kd_propinsi, lg.kd_dati2, lg.kd_kecamatan, lg.kd_kelurahan,
# #             lg.kd_blok, lg.no_urut, lg.kd_jns_op
# #         )
# #         thn = str(lg.thn_pajak_sppt).strip()
# #         amount = str(lg.jml_sppt_yg_dibayar).strip()
# #         if nop + thn + amount not in dtLog:
# #             dtLog[nop + thn + amount] = lg
# #     dt_tobe_syncron = []
# #     for sppt in dtSppt:
# #         vsppt = dict(zip(sppt.keys(), sppt))
# #         if 'id' in vsppt:
# #             del vsppt['id']
# #         nop = '{}{}{}{}{}{}{}'.format(
# #             vsppt['kd_propinsi'], vsppt['kd_dati2'], vsppt['kd_kecamatan'],
# #             vsppt['kd_kelurahan'], vsppt['kd_blok'], vsppt['no_urut'],
# #             vsppt['kd_jns_op']
# #         )
# #         thn = vsppt['thn_pajak_sppt'].strip()
# #         amount = str(vsppt['jml_sppt_yg_dibayar']).strip()
# #         if nop + thn + amount not in dtLog:
# #             log.error('data pembayaran tidak ditemukan di Log')
# #             continue
# #         dLog = dtLog[nop + thn + amount]
# #         if not dLog.kd_cabang:
# #             log.error('kd_cabang tidak ditemukan')
# #             continue
# #         if not dLog.user_id:
# #             log.error('user_id tidak ditemukan')
# #             continue
# #         if not dLog.kd_channel:
# #             log.error('kd_channel tidak ditemukan')
# #             continue
# #         if not dLog.ntpd:
# #             log.error('ntpd tidak ditemukan')
# #             continue
# #         discount = hasattr(dLog, 'discount') and dLog.discount or 0
# #         vsppt.update({"kd_cabang": dLog.kd_cabang,
# #                       "user_id": dLog.user_id,
# #                       "kd_channel": dLog.kd_channel,
# #                       "ntpd": dLog.ntpd,
# #                       "discount": discount})
# #         vsppt['nop'] = nop
# #         vsppt['tahun'] = thn
# #         if isinstance(vsppt['tgl_jatuh_tempo_sppt'], datetime):
# #             vsppt['tgl_jatuh_tempo_sppt'] = vsppt[
# #                 'tgl_jatuh_tempo_sppt'].strftime('%Y-%m-%d')
# #         if isinstance(vsppt['tgl_pembayaran_sppt'], datetime):
# #             vsppt['tgl_pembayaran_sppt'] = vsppt[
# #                 'tgl_pembayaran_sppt'].strftime('%Y-%m-%d')
# #         if isinstance(vsppt['tgl_rekam_byr_sppt'], datetime):
# #             vsppt['tgl_rekam_byr_sppt'] = vsppt['tgl_rekam_byr_sppt'].strftime(
# #                 '%Y-%m-%d')
# #         dt_tobe_syncron.append(vsppt)
# #     return dict(
# #         data=dt_tobe_syncron,
# #         countData=len(dt_tobe_syncron),
# #         countOracle=len(dtSppt),
# #         countLog=len(Log))
# #

# def fixnop(nop):
#     """
#     Fungsi untuk membuang karakter selain angka pada NOP
#     """
#     return re.sub('[^0-9]', '', nop)


# def pengurangPokok(pokok, thn_pajak, nop):
#     """
#     Fungsi untuk menghitung pengurangan pokok (diskon pokok)
#     """
#     pengurang = 0
#     tgl_bayar = datetime.now().date()
#     fix_nop = fixnop(nop)[:4]
#     ## KAB CIREBON ##
#     if (fix_nop == '3211'):
#         """Diskon kab.cirebon 2022 (Konsep Bruto) - Req. Gilang @20220119
#         Rekap ulang terkait diskon PBB kab.cirebon 2022 (Konsep Bruto)
#         1.Untuk SPPT tahun 2022
#           a. Pembayaran dari Januari 2022 sd 30 April 2022 , diskon pokok 12%
#           b. Pembayaran dari 1 Mei 2022 sd 31 Juli 2022, diskon pokok 10%
#           c. Pembayaran dari 1 Agustus 2022 sd 31 Oktober 2022, diskon pokok 7%
#         2.Untuk SPPT tahun 2009 sd 2021
#           a. Pembayaran dari Januari 2022 sd 31 Maret 2022, diskon denda 100%
#         """
#         # Discount pokok berdasarkan bulan (point 1)
#         NILAI_DISC_POKOK = {
#             1: 0.12, 2: 0.12, 3: 0.12, 4: 0.12,
#             5: 0.1, 6: 0.1, 7: 0.1,
#             8: 0.07, 9: 0.07, 10: 0.07
#         }
#         if thn_pajak == '2022' \
#                 and tgl_bayar.year == 2022 \
#                 and tgl_bayar.month in NILAI_DISC_POKOK:
#             persen_pengurang = NILAI_DISC_POKOK[tgl_bayar.month]
#             pengurang = int(persen_pengurang * pokok)
#     # ## BOGOR - TEST ##
#     # elif (fix_nop == '3271'):
#     #     persen_pengurang = 20 / 100
#     #     pengurang = int(persen_pengurang * pokok)
#     # print("### PENGURANG POKOK: ", pengurang)
#     return pengurang


# def pengurangDenda(denda, thn_pajak, nop):
#     """
#     Fungsi untuk menghitung pengurangan denda (diskon denda)
#     """
#     pengurang = 0
#     tgl_bayar = datetime.now().date()
#     fix_nop = fixnop(nop)[:4]
#     ##KAB TASIK##
#     if (fix_nop == '3208'):
#         """Diskon denda Kab Tasik"""
#         NOV_30 = date(2020, 11, 30)
#         if thn_pajak in ['2018', '2019'] and tgl_bayar <= NOV_30:
#             persen_pengurang = 100 / 100
#             pengurang = int(persen_pengurang * denda)
#         """Diskon denda Kab Tasik"""
#         """Nomor SK : 973/ Kep. 148-BPKPD/2021"""
#         """Req Iwan . 27/07/2021"""
#         JUL_2021 = date(2021, 7, 1)
#         AGT_2021 = date(2021, 8, 31)
#         if thn_pajak in ['2018', '2019',
#                          '2020'] and tgl_bayar >= JUL_2021 and tgl_bayar <= AGT_2021:
#             persen_pengurang = 100 / 100
#             pengurang = int(persen_pengurang * denda)
#         """Diskon denda Kab Tasik"""
#         """Nomor SK : 973/ Kep. 251-BPKPD/2021"""
#         """Req Gilang . 11/12/2021"""
#         DES_24 = date(2021, 12, 24)
#         if thn_pajak in ['2014', '2015', '2016', '2017', '2018', '2019', '2020',
#                          '2021'] and tgl_bayar <= DES_24:
#             persen_pengurang = 100 / 100
#             pengurang = int(persen_pengurang * denda)
#         """Diskon denda Kab Tasik / Implement mulai tg 16/7/2022"""
#         """Nomor SK : 973/ Kep. 196-BPKPD/2022"""
#         """Req Pak Yasir . 15/7/2022"""
#         AGT_31 = date(2022, 8, 31)
#         if thn_pajak in ['2014', '2015', '2016', '2017', '2018', '2019', '2020',
#                          '2021'] and tgl_bayar <= AGT_31:
#             persen_pengurang = 100 / 100
#             pengurang = int(persen_pengurang * denda)
#     ##KAB SUBANG##
#     elif (fix_nop == '3215'):
#         """Penghapusan Denda Kab Subang 1 April - 30 Juni 2021
#            Req Pak Yasir 08/04/2021"""
#         apr = date(2021, 4, 1)
#         juni = date(2021, 6, 30)
#         if tgl_bayar >= apr and tgl_bayar <= juni:
#             persen_pengurang = 100 / 100
#             pengurang = int(persen_pengurang * denda)
#     ## KAB KUNINGAN ##
#     elif (fix_nop == '3210'):
#         """Diskon denda Kab Kuningan Hingga 31 Des 2022
#         Req Pak Yasir 04/02/2022
#         1. Pembebasan denda (diskon denda 100%)
#         2. Untuk SPPT 2016 sd 2021
#         3. Periode tidak disebutkan (mungkin sampe akhir desember 2022)"""
#         DES_31 = date(2022, 12, 31)
#         if thn_pajak in ['2016', '2017', '2018', '2019', '2020',
#                          '2021'] and tgl_bayar <= DES_31:
#             persen_pengurang = 100 / 100
#             pengurang = int(persen_pengurang * denda)
#     ## KAB CIREBON ##
#     elif (fix_nop == '3211'):
#         """Diskon kab.cirebon 2022 (Konsep Bruto) - Req. Gilang @20220119
#         Rekap ulang terkait diskon PBB kab.cirebon 2022 (Konsep Bruto)
#         1.Untuk SPPT tahun 2022
#           a. Pembayaran dari Januari 2022 sd 30 April 2022 , diskon pokok 12%
#           b. Pembayaran dari 1 Mei 2022 sd 31 Juli 2022, diskon pokok 10%
#           c. Pembayaran dari 1 Agustus 2022 sd 31 Oktober 2022, diskon pokok 7%
#         2.Untuk SPPT tahun 2009 sd 2021
#           a. Pembayaran dari Januari 2022 sd 31 Maret 2022, diskon denda 100%
#         3.Perpanjangan diskon hingga 30 Juni 2022 - 20220323
#         """
#         # Discount denda 100% (point 2)
#         AKHIR_DISC_DENDA = date(2022, 8, 31)
#         if thn_pajak >= '2009' and thn_pajak <= '2021':
#             if tgl_bayar <= AKHIR_DISC_DENDA:
#                 persen_pengurang = 100 / 100
#                 pengurang = int(persen_pengurang * denda)
#     ##KAB PANGANDARAN##
#     elif (fix_nop == '3219'):
#         """ Diskon denda Kab. Pangandaran 1 Sep 2021 - 31 Des 2021
#             Req Gilang 31/08/2021"""
#         SEP_2021 = date(2021, 9, 1)
#         DES_2021 = date(2021, 12, 31)
#         if thn_pajak in ['2014', '2015', '2016', '2017', '2018', '2019', '2020'] \
#                 and tgl_bayar >= SEP_2021 and tgl_bayar <= DES_2021:
#             persen_pengurang = 100 / 100
#             pengurang = int(persen_pengurang * denda)
#     ## KAB BEKASI ##
#     elif (fix_nop == '3218'):
#         """Ketentuan Penghapusan Denda (Diskon Denda 100%) Kab.Bekasi
#         a. SPPT Tahun < 2022
#         b. Pembayaran periode 01-07-2022 sd 31-08-2022
#         """
#         MAX_THN_PAJAK_SPPT = 2022
#         BERMULA = date(2022, 7, 1)
#         BERAKHIR = date(2022, 8, 31)
#         if tgl_bayar >= BERMULA and tgl_bayar <= BERAKHIR \
#                 and int(thn_pajak) < MAX_THN_PAJAK_SPPT:
#             persen_pengurang = 100 / 100
#             pengurang = int(persen_pengurang * denda)
#     # ## BOGOR - TEST ##
#     # elif (fix_nop == '3271'):
#     #     persen_pengurang = 20 / 100
#     #     pengurang = int(persen_pengurang * denda)
#     ##KOTA CILEGON
#     elif (fix_nop == '3672'):
#         """ NOMOR : 973/Kep.225-BPKAD/2021
#             Bebas sanksi untuk SPPT 1990 s/d 2021, Berlaku 1 Oktober 2021 s/d 17 Desember 2021
#             Req Iwan 14/10/2021 """
#         OKT_2021 = date(2021, 10, 1)
#         DES_2021 = date(2021, 12, 17)
#         list_tahun = [str(tahun) for tahun in range(1990, 2022)]
#         if thn_pajak in list_tahun and tgl_bayar >= OKT_2021 and tgl_bayar <= DES_2021:
#             persen_pengurang = 100 / 100
#             pengurang = int(persen_pengurang * denda)
#     # print("### PENGURANG DENDA: ", pengurang)
#     return pengurang


# def blocking_data(data):
#     """Digunakan untuk memblokir inquiry maupun payment mengembalikan data.
#     Mengembalikan True jika logika blokir tertangkap pada blok kode.
#     :param data: nop, tahun
#     :type data: dict
#     :return: True/False
#     :rtype: boolean
#     """
#     fix_nop = fixnop(data['nop'])[:4]
#     ## KAB KUNINGAN ##
#     # if (fix_nop == '3210'):
#     #    return int(data['tahun']) == 2022


# def is_konsep_bruto(nop):
#     """Fungsi untuk mendaftarkan prefix nop kota/kab yang akan menggunakan
#     konsep bruto dan akan mengembalikan nilai boolean True jika prefix nop
#     terdaftar pada varibale prefix_nop.
#     """
#     prefix_nop = [
#         # '3271',  # BOGOR TEST
#         # '3210',  # KAB KUNINGAN
#         '3211',  # KAB CIREBON
#     ]
#     fix_nop = fixnop(nop)[:4]
#     return fix_nop in prefix_nop