update callback ke pemda qris dan va

esipkd/views/bjb_qris.py

@@ -503,6 +503,8 @@ def callback(request, data):
     try:
     try:
         DBSession.add(get_va)
         DBSession.add(get_va)
         DBSession.flush()
         DBSession.flush()
+        if not sendrpc(request, get_va.invoice_no):
+            return
         return render_to_response('json',
         return render_to_response('json',
             dict(response_code='0000',response_message='Success'))
             dict(response_code='0000',response_message='Success'))
     except:
     except:
@@ -549,3 +551,29 @@ def calculate_tagihan(values):
     pokok = int(values['pokok'])
     pokok = int(values['pokok'])
     denda = hitung_bunga(pokok,values['jatuh_tempo'])
     denda = hitung_bunga(pokok,values['jatuh_tempo'])
     return pokok, denda
     return pokok, denda
+
+def sendrpc(request, kd_bayar):
+    settings = get_settings()
+    request = self.req
+    
+    if not 'pemdaqris_url' in settings and not settings['pemdaqris_url']:
+        log.error('pemdaqris_url belum ada di settings')
+        return
+        
+    url = settings['pemdaqris_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

esipkd/views/bjb_va.py

@@ -586,6 +586,8 @@ def callback(request, data):
     try:
     try:
         DBSession.add(get_va)
         DBSession.add(get_va)
         DBSession.flush()
         DBSession.flush()
+        if not sendrpc(request, get_va.invoice_no):
+            return
         return render_to_response('json',
         return render_to_response('json',
             dict(response_code='0000',response_message='Success'))
             dict(response_code='0000',response_message='Success'))
     except:
     except:
@@ -645,3 +647,29 @@ def calculate_tagihan(values):
     pokok = int(values['pokok'])
     pokok = int(values['pokok'])
     denda = hitung_bunga(pokok,values['jatuh_tempo'])
     denda = hitung_bunga(pokok,values['jatuh_tempo'])
     return pokok, denda
     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
\ No newline at end of file