b 0.0.1

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

@@ -95,43 +95,42 @@ def inquiry(request, data, **kwargs):
         raise JsonRpcCustomerNotFoundError()
 
     r_data = []
-    for dat in data:
-        prods = "produk" in dat and dat["produk"] or None
-        for prod in prods:
-            log.info(prod)
-            produk_kd = 'denom' in prod and prod['denom'] or None
-            if not produk_kd:
-                raise JsonRpcProdukNotFoundError(message="Produk harus diisi")
-
-            # todo: search product lowest price
-            vend_kd = 'ODEO'
-            vendor_produk = get_vendor_produk() \
-                .filter(Partner.kode == vend_kd) \
-                .filter(Produk.kode == produk_kd).first()
-            print(vendor_produk.to_dict())
-
-            if not vendor_produk:
-                raise JsonRpcProdukNotFoundError(message="Produk %s tidak ditemukan" % produk_kd)
-
-            partner_log = PartnerLog()
-            partner_log.vendor_id = vendor_produk.partner_id
-            partner_log.customer_id = customer.id
-            partner_log.produk_id = vendor_produk.produk.id
-            # partner_log.cust_inv = dat["inv_no"]
-            partner_log.id_pel = prod["id_pel"]
-
-            flush_row(partner_log)
-            result = build_request('inquiry', vendor_produk, partner_log)
-            if result["code"] == 0:
-                prod.update(dict(subtotal=result["subtotal"],
-                                 discount=result["purchase"],
-                                 total=result["total"]
-                                 )
-                            )
-            else:
-                prod.update(dict(status="FAILED",
-                                 message=result["message"]))
-            r_data.append(prod)
+    for prod in data:
+        # prods = "produk" in dat and dat["produk"] or None
+        # for prod in prods:
+        # log.info(prod)
+        produk_kd = 'denom' in prod and prod['denom'] or None
+        if not produk_kd:
+            raise JsonRpcProdukNotFoundError(message="Produk harus diisi")
+
+        # todo: search product lowest price
+        vend_kd = 'ODEO'
+        vendor_produk = get_vendor_produk() \
+            .filter(Partner.kode == vend_kd) \
+            .filter(Produk.kode == produk_kd).first()
+
+        if not vendor_produk:
+            raise JsonRpcProdukNotFoundError(message="Produk %s tidak ditemukan" % produk_kd)
+
+        partner_log = PartnerLog()
+        partner_log.vendor_id = vendor_produk.partner_id
+        partner_log.customer_id = customer.id
+        partner_log.produk_id = vendor_produk.produk.id
+        # partner_log.cust_inv = dat["inv_no"]
+        partner_log.id_pel = prod["id_pel"]
+
+        flush_row(partner_log)
+        result = build_request('inquiry', vendor_produk, partner_log)
+        if result["code"] == 0:
+            prod.update(dict(subtotal=result["subtotal"],
+                             discount=result["purchase"],
+                             total=result["total"]
+                             )
+                        )
+        else:
+            prod.update(dict(status="FAILED",
+                             message=result["message"]))
+        r_data.append(prod)
 
     data = is_list and r_data or r_data[0]
     return data