bjb_va.py

import os
import json
import ast
import uuid
import colander
from datetime import datetime, date, timedelta, time
from sqlalchemy.orm import aliased
from pyramid.view import view_config
from sqlalchemy import not_, func, between, and_, literal_column, case, literal
from pyramid.httpexceptions import HTTPFound
from deform import Form, widget, ValidationFailure
from ..views import ColumnDT, DataTables
from ..models.isipkd import (ARInvoice as ArInvoice, ARSspd as ArPayment, SubjekPajak as Subjek, Unit as Departemen)
from ..models import DBSession
from ..models.bjb_va import BJBVA
from ..tools import (dmy, get_settings, date_from_str, 
                     odt_export, thousand, get_settings, datetime_from_str)
from ..models.rpc import auth_from_rpc
from ..tools import ymd, dmy, ymdhms, dmyhms, dmy_to_date

from pyramid_rpc.jsonrpc import jsonrpc_method
from time import sleep
from daftar import hitung_bunga
from arsspd import save as save_payment

SESS_ADD_FAILED = 'Gagal tambah BJBVA'
SESS_EDIT_FAILED = 'Gagal edit BJBVA'

import logging
log = logging.getLogger('BJBVA LOG')
from pyramid.renderers import render_to_response
from sqlalchemy.sql.expression import cast
from sqlalchemy import Integer

def rpc_params():
    parameter = dict(
        bjbva_url  = get_settings()['bjbva_url'] and get_settings()['bjbva_url'].strip('/') or '',
        bjbva_user = get_settings()['bjbva_user'] and get_settings()['bjbva_user'].strip() or '',
        bjbva_key  = get_settings()['bjbva_key'] and get_settings()['bjbva_key'].strip() or ''
    )
    return parameter
    
class Item(object):
    pass
        
class AddSchema(colander.Schema):
    client_type                 =   colander.SchemaNode(
                                    colander.Integer(),
                                    widget = widget.HiddenWidget(),
                                    default = 3,
                                    oid = "client_type",
                                    title="")
    product_code                  =   colander.SchemaNode(
                                    colander.String(),
                                    widget = widget.HiddenWidget(),
                                    default = 99,
                                    oid = "product_code",
                                    title="")
    invoice_no                  =   colander.SchemaNode(
                                    colander.String(),
                                    widget=widget.SelectWidget(),
                                    validator=colander.Length(max=16),
                                    oid = "invoice_no",
                                    title="Kode Bayar")
    description                 =   colander.SchemaNode(
                                    colander.String(),
                                    widget=widget.TextAreaWidget(rows=6),
                                    validator=colander.Length(max=128),
                                    oid = "description",)
    customer_name               =   colander.SchemaNode(
                                    colander.String(),
                                    validator=colander.Length(max=64),
                                    oid = "customer_name",
                                    title="Customer Name")
    customer_email              =   colander.SchemaNode(
                                    colander.String(),
                                    validator=colander.Length(max=128),
                                    oid = "customer_email",
                                    title="Customer Email")
    customer_phone              =   colander.SchemaNode(
                                    colander.String(),
                                    validator=colander.Length(max=32),
                                    oid = "customer_phone",
                                    title="Customer Phone")
    expired_date                =   colander.SchemaNode(
                                    colander.String(),
                                    widget=widget.TextInputWidget(css_class="input-date"),
                                    oid = "expired_date",
                                    default = ymdhms(datetime.now()),
                                    title="Expired Date")
    amount                      =   colander.SchemaNode(
                                    colander.Integer(),
                                    oid = "amount",
                                    title="Amount")


class AddParamsSchema(colander.Schema):
    client_type                 =   colander.SchemaNode(
                                    colander.Integer(),
                                    widget = widget.HiddenWidget(),
                                    default = 3,
                                    oid = "client_type",
                                    title="")
    product_code                  =   colander.SchemaNode(
                                    colander.String(),
                                    widget = widget.HiddenWidget(),
                                    default = 99,
                                    oid = "product_code",
                                    title="")
    invoice_no                  =   colander.SchemaNode(
                                    colander.String(),
                                    validator=colander.Length(max=16),
                                    oid = "invoice_no",
                                    title="Kode Bayar")
    description                 =   colander.SchemaNode(
                                    colander.String(),
                                    widget=widget.TextAreaWidget(rows=6),
                                    validator=colander.Length(max=128),
                                    oid = "description",)
    customer_name               =   colander.SchemaNode(
                                    colander.String(),
                                    validator=colander.Length(max=64),
                                    oid = "customer_name",
                                    title="Customer Name")
    customer_email              =   colander.SchemaNode(
                                    colander.String(),
                                    validator=colander.Length(max=128),
                                    oid = "customer_email",
                                    title="Customer Email")
    customer_phone              =   colander.SchemaNode(
                                    colander.String(),
                                    validator=colander.Length(max=32),
                                    oid = "customer_phone",
                                    title="Customer Phone")
    expired_date                =   colander.SchemaNode(
                                    colander.String(),
                                    widget=widget.TextInputWidget(css_class="input-date"),
                                    oid = "expired_date",
                                    default = ymdhms(datetime.now()),
                                    title="Expired Date")
    amount                      =   colander.SchemaNode(
                                    colander.Integer(),
                                    oid = "amount",
                                    title="Amount")

    
class EditSchema(AddSchema):
    invoice_no                  =   colander.SchemaNode(
                                    colander.String(),
                                    validator=colander.Length(max=16),
                                    oid = "invoice_no",
                                    title="Kode Bayar")
    billing_type                =   colander.SchemaNode(
                                    colander.String(),
                                    missing=colander.drop,
                                    validator=colander.Length(max=1),
                                    oid = "billing_type",
                                    title="Billing Type")
    va_type                     =   colander.SchemaNode(
                                    colander.String(),
                                    missing=colander.drop,
                                    validator=colander.Length(max=1),
                                    oid = "va_type",
                                    title="VA Type")
    va_number                   =   colander.SchemaNode(
                                    colander.String(),
                                    missing=colander.drop,
                                    validator=colander.Length(max=32),
                                    oid = "va_number",
                                    title="VA Number")
    currency                    =   colander.SchemaNode(
                                    colander.String(),
                                    missing=colander.drop,
                                    validator=colander.Length(max=32),
                                    oid = "currency",
                                    title="Currency")
    customer_id                 =   colander.SchemaNode(
                                    colander.String(),
                                    missing=colander.drop,
                                    validator=colander.Length(max=32),
                                    oid = "customer_id",
                                    title="Customer ID")
    status                      =   colander.SchemaNode(
                                    colander.String(),
                                    missing=colander.drop,
                                    oid = "status",
                                    title="Status")
    cin                         =   colander.SchemaNode(
                                    colander.String(),
                                    missing=colander.drop,
                                    validator=colander.Length(max=4),
                                    oid = "cin",
                                    title="cin")
    response_code               =   colander.SchemaNode(
                                    colander.String(),
                                    missing=colander.drop,
                                    validator=colander.Length(max=4),
                                    oid = "response_code",
                                    title="response_code")
    response_message            =   colander.SchemaNode(
                                    colander.String(),
                                    missing=colander.drop,
                                    validator=colander.Length(max=128),
                                    oid = "response_message",
                                    title="response_message")
    
    id              =   colander.SchemaNode(
                        colander.Integer(),
                        missing=colander.drop,
                        oid='id',
                        widget=widget.HiddenWidget(readonly=True)
                        )

def get_form(request, class_form):
    schema = class_form()
    schema.request = request
    return Form(schema, buttons=('simpan','batal'))

def route_list(request):
    return HTTPFound(location=request.route_url('bjbva'))

def session_failed(request, session_name):
    r = dict(form=request.session[session_name])
    del request.session[session_name]
    return r

def query_id(request):
    return DBSession.query(BJBVA).join(ArInvoice, ArInvoice.kode==BJBVA.invoice_no).\
            filter(BJBVA.id==request.matchdict['id'])
            # ArInvoice.departemen_id==request.session['departemen_id'])

def id_not_found(request):
    msg = 'BJBVA ID %s not found.' % request.matchdict['id']
    request.session.flash(msg, 'error')
    return route_list(request)
    
def id_paid(request):
    msg = 'BJBVA ID %s sudah terbayar.' % request.matchdict['id']
    request.session.flash(msg, 'error')
    return route_list(request)
    
def id_expired(request):
    msg = 'BJBVA ID %s expired.' % request.matchdict['id']
    request.session.flash(msg, 'error')
    return route_list(request)
    
def cekva(values,request):
    cekva = DBSession.query(BJBVA).\
        filter(BJBVA.invoice_no==values['invoice_no'],BJBVA.expired_date>datetime.now()).first()
    if cekva:
        msg = 'BJBVA No. VA %s sudah ada.' % cekva.va_number
        request.session.flash(msg, 'error')
        raise route_list(request)
        
def cekbayar(invoice_no, request, responfor):
    id_bayar = DBSession.query(ArInvoice.id).\
        filter(ArInvoice.kode==invoice_no).scalar()
    cekbayar = DBSession.query(ArPayment).\
        filter(ArPayment.arinvoice_id==id_bayar).first()
    if cekbayar:
        if responfor == 0:
            msg = 'BJBVA No. Billing %s sudah di bayar. Cek menu pembayaran.' % invoice_no
            request.session.flash(msg, 'error')
            raise route_list(request)
        else:
            return render_to_response('json',
            dict(response_code='-1',response_message='Already Paid'))
            log.error('CALLBACK BJBVA RESPONSE ALREADY PAID FOR INVOICE_NO %s' % invoice_no)
###########
#  List   #
###########
class view(object):
    def __init__(self, request):
        now = datetime.now()
        self.req = request
        self.ses = self.req.session
        self.params = self.req.params
        self.awal = 'awal' in self.ses and self.ses['awal'] or dmy(now)
        awal = 'awal' in self.params and self.params['awal'] or self.awal
        try:
            self.dt_awal = dmy_to_date(awal)
            self.awal = awal
        except:
            self.dt_awal = dmy_to_date(self.awal)

        self.ses['awal'] = self.awal
        self.ses['dt_awal'] = self.dt_awal

        self.akhir = 'akhir' in self.ses and self.ses['akhir'] or dmy(now)
        akhir = 'akhir' in self.params and self.params['akhir'] or self.akhir

        try:
            self.dt_akhir = dmy_to_date(akhir)
            self.akhir = akhir
        except:
            self.dt_akhir = dmy_to_date(self.akhir)

        self.ses['akhir'] = self.akhir
        self.ses['dt_akhir'] = self.dt_akhir
        self.tahun = 'tahun' in self.ses and self.ses['tahun'] or datetime.now().strftime('%Y')
        self.tahun = 'tahun' in self.params and self.params['tahun'] or self.tahun
        self.ses['tahun'] = self.tahun
        
    @view_config(route_name='bjbva', renderer='templates/bjbva/list.pt')
    def view_list(self):
        return dict()


#########
#  Add  #
#########
    @view_config(route_name='bjbva-add', renderer='templates/bjbva/add-edit.pt', permission='read')
    def view_add(self):
        request = self.req
        params   = request.params
        form = get_form(request, AddSchema)
        if 'no_invoice' in params and params['no_invoice']:
            row_invoice = q_inv(params['no_invoice']).first()
        else:
            row_invoice = 0
            # ArInvoice.departemen_id==request.session['departemen_id'])


        if request.POST:
            if 'simpan' in request.POST:
                controls = request.POST.items()
                try:
                    controls = form.validate(controls)
                except ValidationFailure as e:
                    return dict(form=form)
                cekva(dict(controls),request)
                val = dict(controls)
                inv = q_inv(val['invoice_no']).first()
                pokok, denda = calculate_tagihan(dict(pokok = inv.jumlah,jatuh_tempo=inv.jatuh_tempo))
                val['amount'] = (pokok+denda)
                print ("=======================")
                print(val)
                row = BJBVA.create_va(val, rpc_params())
                if row:
                    request.session.flash('BJBVA No. %s sudah ditambahkan.' % row.va_number)
                else:
                    request.session.flash('BJBVA gagal ditambahkan.')
                return route_list(request)
            return route_list(request)
        elif SESS_ADD_FAILED in request.session:
            return session_failed(request, SESS_ADD_FAILED)

        if row_invoice!=0:
            form = get_form(request, AddParamsSchema)
            pokok, denda = calculate_tagihan(dict(pokok = row_invoice.jumlah,jatuh_tempo=row_invoice.jatuh_tempo))
            print ("++++++++++++++++++++++++++", str(row_invoice.description))
            values = {}
            values['invoice_no']=str(row_invoice.kode)
            values['description']=str(row_invoice.description)
            values['customer_name']=row_invoice.subjek_nama
            values['customer_email']=row_invoice.subjek_email and row_invoice.subjek_email or '-'
            values['customer_phone']=row_invoice.subjek_phone and row_invoice.subjek_phone or '-'
            values['expired_date']=ymdhms(datetime.combine(date.today(),time(23,59,59)))
            values['amount']=(pokok + denda)

            print ('---------------------------------', values)
            form.set_appstruct(values)
            return dict(form=form, invoice_no=params['no_invoice'])
        else:
            values = {}
            form.set_appstruct(values)
            return dict(form=form)


########
# Edit #
########
    @view_config(route_name='bjbva-edt', renderer='templates/bjbva/add-edit.pt', permission='edit')
    def view_edit(self):
        request = self.req
        form = get_form(request, EditSchema)
        row = query_id(request).first()
        if not row or int(row.status) == 4:
            return id_not_found(request)
        if int(row.status) in [1,2]:
            return id_paid(request)
        if int(row.status) == 3:
            return id_expired(request)
        if request.POST:
            if 'simpan' in request.POST:
                controls = request.POST.items()
                try:
                    controls = form.validate(controls)
                except ValidationFailure as e:
                    return dict(form=form)
                save = BJBVA.update_va(dict(controls), row, rpc_params())
                if save:
                    request.session.flash('BJBVA No. %s sudah ditambahkan.' % save.va_number)
                else:
                    request.session.flash('BJBVA gagal ditambahkan.')
                return route_list(request)
                
            return route_list(request)
        elif SESS_EDIT_FAILED in request.session:
            return session_failed(request, SESS_EDIT_FAILED)
        values = row.to_dict()
        values['expired_date'] = ymdhms(values['expired_date'])
        inv = q_inv(values['invoice_no']).first()
        pokok, denda = calculate_tagihan(dict(pokok = inv.jumlah,jatuh_tempo=inv.jatuh_tempo))
        values['amount'] = (pokok+denda)
        form.set_appstruct(values)
        return dict(form=form)


##########
# Delete #
##########
    @view_config(route_name='bjbva-del', renderer='templates/bjbva/delete.pt', permission='delete')
    def view_delete(self):
        request = self.req
        row = query_id(request).first()
        if not row or int(row.status) == 4:
            return id_not_found(request)
        if int(row.status) in [1,2]:
            return id_paid(request)
        if int(row.status) == 3:
            return id_expired(request)
        form = Form(colander.Schema(), buttons=('hapus','batal'))
        if request.POST:
            if 'hapus' in request.POST:
                save = BJBVA.cancel_va(row.to_dict(), rpc_params())
                if save:
                    request.session.flash('BJBVA No. %s sudah dihapus.' % save.va_number)
                else:
                    request.session.flash('BJBVA gagal dihapus.')
                DBSession.flush()
            return route_list(request)
        return dict(row=row, form=form.render())
        

##########
# Action #
##########
    @view_config(route_name='bjbva-act', renderer='json', permission='read')
    def view_act(self):
        req      = self.req
        params   = req.params
        url_dict = req.matchdict

        if url_dict['act']=='grid':
                            
            columns = [
              ColumnDT('id'),
              ColumnDT('va_number'),
              ColumnDT('invoice_no'),
              ColumnDT('description'),
              ColumnDT('customer_name'),
              ColumnDT('amount'),
              ColumnDT('client_refnum'),
              ColumnDT('expired_date'),
              ColumnDT('tgl_bayar'),
              ColumnDT('status'),
            ]
            query = DBSession.query(BJBVA.id, BJBVA.va_number, BJBVA.invoice_no, BJBVA.description,
                    BJBVA.customer_name, BJBVA.amount, BJBVA.client_refnum, 
                    func.to_char(BJBVA.expired_date, 'DD-MM-YYYY HH24:MI:SS').label('expired_date'),
                    func.to_char(ArPayment.tgl_bayar, 'DD-MM-YYYY HH24:MI:SS').label('tgl_bayar'),
                    ArInvoice.jumlah.label('jml_bayar'),
                    case([
                        (BJBVA.status == '0', literal('Belum Dibayar'))
                        ],
                      else_= 
                    case([
                        (BJBVA.status == '1', literal('Dibayar Sebagian'))
                        ],
                      else_= 
                    case([
                        (BJBVA.status == '2', literal('Dibayar Penuh'))
                        ],
                      else_= 
                    case([
                        (BJBVA.status == '3', literal('Kadaluarsa'))
                        ],
                      else_=
                    case([
                        (BJBVA.status == '4', literal('Disabled'))
                        ],
                      else_= literal('-')))))).label('status'),
                    ).join(ArInvoice, ArInvoice.kode==BJBVA.invoice_no).\
                      outerjoin(ArPayment, ArInvoice.id==ArPayment.arinvoice_id).\
                      filter( #ArInvoice.departemen_id==req.session['departemen_id'],
                             func.to_char(BJBVA.created,'YYYY') == str(req.session['tahun']))
                            
            rowTable = DataTables(req, BJBVA, query, columns)
            return rowTable.output_result()

        elif url_dict['act'] == 'kodebayar':
            term = 'term' in params and params['term'] or ''
            q = DBSession.query(ArInvoice). \
                filter(ArInvoice.status_bayar == 0,
                       ArInvoice.kode.ilike('%%%s%%' % term)).\
                order_by(ArInvoice.kode)
                # filter(ArInvoice.departemen_id==req.session['departemen_id']).\
            rows = q.all()
            r = []
            for k in rows:
                d = dict(id=k.id,
                         value=k.kode,
                         kode=k.kode,
                         nama=k.op_nama)
                r.append(d)
            return r
            
        elif url_dict['act'] == 'detail':
            term = 'term' in params and params['term'].strip() or ''
            row = q_inv(term).first()
            pokok, denda = calculate_tagihan(dict(pokok = row.jumlah,jatuh_tempo=row.jatuh_tempo))
            return dict(id=row.id,
                         value=row.subjek_nama,
                         description=row.description,
                         customer_name=row.subjek_nama,
                         customer_email=row.subjek_email and row.subjek_email or '-',
                         customer_phone=row.subjek_phone and row.subjek_phone or '-',
                         expired_date=ymdhms(datetime.combine(date.today(),time(23,59,59))),
                         amount=(pokok + denda))
                         
        elif url_dict['act'] == 'update':
            term = 'term' in params and params['term'] or ''
            if term:
                va = DBSession.query(BJBVA).join(ArInvoice, ArInvoice.kode==BJBVA.invoice_no).\
                    filter(BJBVA.id==term, ArInvoice.status_bayar==0).first()
                if va:
                    update_va(req, va, rpc_params())

        elif url_dict['act'] == 'cron':
            vas = DBSession.query(BJBVA).select_from(BJBVA).join(ArInvoice, ArInvoice.kode==BJBVA.invoice_no).\
                join(ArPayment, ArPayment.arinvoice_id == ArInvoice.id).\
                filter(BJBVA.status=='0',ArInvoice.status_bayar==1).all()
            for va in vas:
                values = va.to_dict()
                BJBVA.cancel_va(values, rpc_params())


        elif url_dict['act'] == 'vacode':
            id = 'id' in params and params['id'] or ''
            invoice_no = ''
            va_number = ''
            if id:
                qris = BJBVA.query_id(id).first()
                invoice_no = qris.invoice_no
                va_number = qris.va_number
                
            from pyramid.renderers import render_to_response
            return render_to_response("templates/bjbva/vacode.pt", dict(invoice_no=invoice_no, va_number=va_number))

@jsonrpc_method(method='callback', endpoint='bjbva-callback')
def callback(request, data):
    ## 
    ## CALLBACK BODY
    ## {
    ##     "data": {
    ##         "invoice_no": "230001",
    ##         "va_number": "00170743733",
    ##         "transaction_date": "2021-08-19 10:08:30",
    ##         "transaction_amount": 526829,
    ##         "unpaid": 0,
    ##         "status": 2
    ##     }
    ## }
    ## 
    sleep(1)
    auth_from_rpc(request)
    
    log.error('REQUEST BJBVA')
    log.error(data)
    
    get_va = BJBVA.query().filter(BJBVA.va_number==data['va_number'],
                                  BJBVA.invoice_no==data['invoice_no']).first()
    if not get_va:
        return render_to_response('json',
            dict(response_code='-1',response_message='VA Number not Found'))
    if cekbayar(get_va.invoice_no,request, 1):
        return render_to_response('json',
            dict(response_code='-1',response_message='Failed to update'))
    get_va.status = 'status' in data and data['status']\
        and str(data['status']) or get_va.status
    get_va.transaction_amount = 'transaction_amount' in data and data['transaction_amount']\
        and data['transaction_amount'] or get_va.amount
    get_va.transaction_date = 'transaction_date' in data and data['transaction_date']\
        and data['transaction_date'] or datetime.now().strftime('%Y-%m-%d %H:%M:%S')
    
    pay = save_pembayaran(
            request,
            dict(
                invoice_no = get_va.invoice_no,
                va_number = get_va.va_number,
                transaction_date = get_va.transaction_date,
                transaction_amount = get_va.transaction_amount,
                status = get_va.status,
                amount = get_va.amount
            )
        )
    if not pay:
        return render_to_response('json',
            dict(response_code='-1',response_message='Failed to update'))
            
    if int(get_va.status) == 2 and not pay.status:
        get_va.status = '1'
    if DBSession.add(get_va):
        DBSession.flush()
        if not sendrpc(request, get_va.invoice_no):
            log.error('Error send BJBVA to pemda')
        return render_to_response('json',
            dict(response_code='0000',response_message='Success'))
    else:
        return render_to_response('json',
            dict(response_code='-1',response_message='Failed to update'))
    
def update_va(request,row, parameter):
    saved_va = BJBVA.inquiry_va(row, parameter)
    if hasattr(saved_va,'status') and saved_va.status and int(saved_va.status) in [1,2]:
        save_pembayaran(
            request,
            dict(
                invoice_no = saved_va.invoice_no,
                va_number = saved_va.va_number,
                transaction_date = ymdhms(saved_va.transaction_date),
                transaction_amount = saved_va.transaction_amount,
                status = saved_va.status,
            )
        )
    
def save_pembayaran(request, values):
    if int(values['status']) not in [1,2]:
        return
    invoice =  ArInvoice.query().filter(ArInvoice.kode==values['invoice_no']).first()
    if not invoice:
        return
    values.update(invoice.to_dict())
    
    values['tgl_bayar'] = datetime_from_str(values['transaction_date'])
    values['ntb'] = 'BJBVA'
    values['bayar'] = int(values['transaction_amount'])
    values['tahun'] = values['tgl_bayar'].strftime('%Y')
    values['status'] = 2
    
    pay = save_payment(request, values)
    return pay
        
def q_inv(kode):
    return DBSession.query(ArInvoice.id.label('id'),
                                  ArInvoice.jumlah.label('jumlah'),
                                  ArInvoice.kode.label('kode'),
                                  ArInvoice.jatuh_tempo.label('jatuh_tempo'),
                                  func.concat(ArInvoice.no_skrd ,
                                    literal_column("' Tgl:'") ,
                                    func.to_char(ArInvoice.tgl_tetap, 'DD/MM/YYYY') ,
                                    literal_column("' Jatuh Tempo:'") ,
                                    func.to_char(ArInvoice.jatuh_tempo, 'DD/MM/YYYY') ,
                                    literal_column("' '") ,
                                    ArInvoice.keterangan).label('description'),
                                  ArInvoice.wp_nama.label('subjek_nama'),
                                  Subjek.email.label('subjek_email'),
                                  literal_column("'-'").label('subjek_phone')).\
                filter(ArInvoice.status_bayar == 0,ArInvoice.kode == kode).\
                outerjoin(Subjek, Subjek.id==ArInvoice.subjek_pajak_id)
                
def calculate_tagihan(values):
    pokok = int(values['pokok'])
    denda = hitung_bunga(pokok,values['jatuh_tempo'])
    return pokok, denda

def sendrpc(request, kd_bayar):
    settings = get_settings()
    request = self.req
    
    if not 'pemdava_url' in settings and not settings['pemdava_url']:
        log.error('pemdava_url belum ada di settings')
        return
        
    url = settings['pemdava_url']
    if request.devel:
        verify = False
    else:
        verify = True
    try:
        resp = requests.post(url=url,
                        data=dict(kd_bayar=kd_bayar), 
                    verify=verify)
        datarsp = json.loads(resp.content)
        if not 'result' in datarsp or datarsp['result'] != "true":
            log.error('Error : {}'.format(datarsp))
            return
        return True
    except requests.exceptions.RequestException as err:
        log.error('Gagal membuat koneksi, silakan coba lagi beberapa saat')
        return