odeo

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

@@ -3,15 +3,12 @@ import json
 
 import requests
 from opensipkd.base import get_settings
-from opensipkd.base.models import Partner
-from opensipkd.pasar.models import PartnerProduk, Produk, PartnerLog, flush_row
-from pyramid.view import view_config
-from pyramid_rpc.jsonrpc import JsonRpcError
 
 from .vendor import VendorClass
 
 
-
+import urllib3
+urllib3.disable_warnings()
 class Vendor(VendorClass):
     def __init__(self, vendor_produk, bill_no, customer_id=None,
                  cust_trx_id=None, row=None):
@@ -34,49 +31,45 @@ class Vendor(VendorClass):
                 number=self.bill_no
             )
         )
+        self.request = params
+        self.save_log("inquiry")
         with requests.session():
             headers = {'Authorization': 'Bearer {key}'.format(key=self.key)}
             data = json.dumps(params)
             resp = requests.post(url=self.url, data=data,
                                  verify=False, headers=headers)
             if resp.ok:
-                print(resp.text)
                 content = resp.json() #json.dumps(resp.text)
+                self.response=content
+                self.save_log('inquiry')
             else:
-                raise JsonRpcError(code=resp.status_code,
-                                   message=resp.text)
+                content = dict(code=resp.status_code,
+                               error=resp.text)
         return content
-        return
 
 
     def payment(self):
-        # request = Request('https://api.odeo.co.id/v1/affiliate/prepaid/purchase', data=values, headers=headers)
-        #
-        # response_body = urlopen(request).read()
-        # print
-        # response_body
-        #
-        """
-        Digunakan untuk melakukan inquory ke server odeoo
-
-        :return:
-        """
-
-        if not self.product_kd or not self.cid:
+        if not self.v_produk_kd or not self.bill_no:
             return
 
         params = dict(
             data=dict(
-                denom=self.product_kd,
-                number=self.cid
+                denom=self.v_produk_kd,
+                number=self.bill_no
             )
         )
+        self.request = params
+        self.save_log("payment")
         with requests.session():
             headers = {'Authorization': 'Bearer {key}'.format(key=self.key)}
-            resp = requests.post(url=self.url, data=json.dump(params, None),
+            data = json.dumps(params)
+            resp = requests.post(url=self.url, data=data,
                                  verify=False, headers=headers)
-            content = resp.json()
-            if resp != "200":
-                raise JsonRpcError(data=content)
+            if resp.ok:
+                content = resp.json() #json.dumps(resp.text)
+                self.response=content
+                self.save_log('payment')
+            else:
+                content = dict(code=resp.status_code,
+                                   message=resp.text)
         return content
\ No newline at end of file
-        return