notify produk

src/agratek/api/merchant/views/notify_vendor.py

@@ -66,6 +66,10 @@ def purchase_notify(order):
         ))
         dat.update(produk=produk)
         data.append(dat)
+        log.info("Notify Save: %s %s" % (data))
+        order.notify["result"] = data
+
+        flush_row(order)
         js = get_jsonrpc(method="notify", params=dict(data=data))
         log.info("Notify: %s %s" % (url, js))
         try:
@@ -87,7 +91,8 @@ def payment_notify(order):
         # tx_id merchant harus dikirim
         tx_id = order.tx_id
         if not tx_id:
-            pay_request = 'request' in order.payment and order.payment['request'] or {}
+            pay_request = 'request' in order.payment \
+                    and order.payment['request'] or {}
             tx_id = 'tx_id' in pay_request and pay_request['tx_id'] or ""
 
         data.update(dict(
@@ -96,12 +101,9 @@ def payment_notify(order):
             type=typ,
             tx_id=tx_id
         ))
-        # data.update(order.notify["result"])
-        # print('>>>', json.dumps(data, indent=4, sort_keys=True))
         js = get_jsonrpc(method="notify", params=dict(data=data))
         log.info("Notify: %s %s" % (url, js))
         try:
-            # pass
             requests.post(url, data=js, timeout=20)
         except:
             pass

src/agratek/api/merchant/views/odeo/notify.py

@@ -57,7 +57,7 @@ def proses(data):
                     if loc>-1:
                         sn = message[loc+4:loc+28]
                         order.serial_number=sn
-
+            log.info("Notify Save: POST={}".format(data)) 
             flush_row(order)
             # todo: add to customer notify table
             # todo: create cron for notify