Commit 5ceb25ad by taufikyu

cron h2h fix

1 parent d8fb0bcd
...@@ -20,17 +20,14 @@ from sqlalchemy.orm import ( ...@@ -20,17 +20,14 @@ from sqlalchemy.orm import (
from sqlalchemy.ext.declarative import declarative_base from sqlalchemy.ext.declarative import declarative_base
from esipkd.models.isipkd import (ARInvoice, ARSspd) from esipkd.models.isipkd import (ARInvoice, ARSspd)
import logging ## python cron_payment_callback_pemda.py [/config.ini] [tahun]
log = logging.getLogger('LOG CRON RPC PEMDA SCRIPTS')
if len(sys.argv) < 2: if len(sys.argv) < 2:
raise Exception('CONFIG .ini Not Found.') raise Exception('CONFIG .ini Not Found.')
if len(sys.argv) < 3:
raise Exception('tahun Not Found.')
configpath = sys.argv[1] # CONFIG .ini
tahunargs = sys.argv[2] # CONFIG tahun_id
datenow = date.today() datenow = date.today()
configpath = sys.argv[1] # CONFIG .ini
tahunargs = (len(sys.argv) < 3) and datenow.year or sys.argv[2] # CONFIG tahun_id
settings = get_appsettings(configpath) settings = get_appsettings(configpath)
engine = engine_from_config(settings, 'sqlalchemy.') engine = engine_from_config(settings, 'sqlalchemy.')
...@@ -50,10 +47,10 @@ def get_listkdbayar(): ...@@ -50,10 +47,10 @@ def get_listkdbayar():
return list_kd_bayar return list_kd_bayar
def sendrpc(kd_bayar): def sendrpc(kd_bayar):
log.info('STARTING RPC CALLBACK PEMDA') print('STARTING RPC CALLBACK PEMDA')
headers = {'Content-Type':'application/json'} headers = {'Content-Type':'application/json'}
if not 'pemdaqris_url' in settings and not settings['pemdaqris_url']: if not 'pemdaqris_url' in settings and not settings['pemdaqris_url']:
log.error('pemdaqris_url belum ada di settings') print('pemdaqris_url belum ada di settings')
raise Exception('pemdaqris_url belum ada di settings') raise Exception('pemdaqris_url belum ada di settings')
url = settings['pemdaqris_url'] url = settings['pemdaqris_url']
...@@ -62,17 +59,18 @@ def sendrpc(kd_bayar): ...@@ -62,17 +59,18 @@ def sendrpc(kd_bayar):
data=json.dumps(dict(kd_bayar=kd_bayar)), data=json.dumps(dict(kd_bayar=kd_bayar)),
headers=headers, headers=headers,
verify=False) verify=False)
log.info('Response RPC CALLBACK PEMDA : {}'.format(resp.content)) l
print('Response RPC CALLBACK PEMDA : {}'.format(resp.content))
try: try:
jsonr = json.loads(resp.content) jsonr = json.loads(resp.content)
if jsonr.get('success')==False: if jsonr.get('success')==False:
raise Exception(jsonr.get('message')) raise Exception(jsonr.get('message'))
except Exception as err: except Exception as err:
log.error(err) print(err)
raise Exception(err) raise Exception(err)
return True return True
except requests.exceptions.RequestException as err: except requests.exceptions.RequestException as err:
log.error('Error send BJBQRIS to pemda : {}'.format(err)) print('Error send BJBQRIS to pemda : {}'.format(err))
raise Exception(err) raise Exception(err)
def main(): def main():
...@@ -80,4 +78,3 @@ def main(): ...@@ -80,4 +78,3 @@ def main():
sendrpc(k) sendrpc(k)
main() main()
## python cron_payment_callback_pemda.py [/config.ini] [tahun]
Markdown is supported
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!