WebSVN – SmartDukaan – Diff – /trunk/PyProj/src/shop2020/model/v1/order/script/ProcessRechargeTransaction.py

     OrderType
 from shop2020.model.v1.order.impl.DataAccessors import get_recharge_orders_for_status, update_recharge_order_status,\
     update_recharge_transaction_status, get_next_invoice_number
 from shop2020.model.v1.order.impl import DataService
 from shop2020.model.v1.order.impl.DataService import RechargeTransaction, HotspotStore,\
-    WalletForCompany, WalletHistoryForCompany
+    WalletForCompany, WalletHistoryForCompany, RechargeCollection
 from shop2020.model.v1.order.impl.model.RechargeOrder import RechargeOrder
 from shop2020.model.v1.order.impl.RechargeService import checkTransactionStatus, getRefunds
 def main():
         data[3] -= int(txn[4])
         data[4] -= int(txn[3]) - int(txn[4])
     print storeData
     wallet = WalletForCompany.query.filter(WalletForCompany.id == 1).one()
-    push_recharge_collection_to_ocr(storeData, todate, wallet.amount)
     dt = session.query(func.sum(RechargeTransaction.amount)).filter(RechargeTransaction.status.in_([RechargeOrderStatus.RECHARGE_SUCCESSFUL])).one()
     if int(dt[0]) != wallet.amount:
         mail("cnc.center@shop2020.in", "5h0p2o2o", ["rajveer.singh@shop2020.in", "anupam.singh@shop2020.in"], "Wallet amount: " + str(wallet.amount) + " does not match with transaction amount: " + str(int(dt[0])) , "", [], [], [])
-def push_recharge_collection_to_ocr(storeData, todate, wamount):
     maildata = "<html><body><table border='1'><thead><th>StoreId</th><th>Gross</th><th>Discount</th><th>Net</th></thead><tbody>"
     trecharge = 0
     for storeId in storeData.keys():
         store = HotspotStore.get_by(id = storeId)
         store.collectedAmount = 0
         store.availableLimit = store.creditLimit
         session.commit()
         data = storeData.get(storeId)
+        rc = RechargeCollection()
-        store_string = "<Store>" + store.hotspotId + "</Store>"
+        rc.hotspotId = store.hotspotId
-        date_string = "<ReconDate>" + todate.strftime("%Y%m%d") + "</ReconDate>"
+        rc.reconDate = int(todate.strftime("%Y%m%d"))
-        cash_string = "<Cash>" + str(data[0]) + "</Cash>"
+        rc.cash = data[0]
-        card_string = "<Hdfc>" + str(data[1]) + "</Hdfc>"
+        rc.hdfc = data[1]
+        rc.grossAmount = data[2]
-        type_string = "<Type>RechargeSale</Type>"
+        rc.discount = data[3]
+        rc.netCollection = data[4]
-        amount_string = "<GrossRechargeAmount>" + str(data[2]) + "</GrossRechargeAmount><Discount>" + str(data[3]) +  "</Discount><NetCollection>" + str(data[4]) + "</NetCollection>";
+        rc.addedAt = datetime.datetime.now()
+        rc.pushedToOcr = False
+        session.commit()
         maildata += "<tr><td>" + store.hotspotId + "</td><td>" + str(data[2]) + "</td><td>" + str(data[3]) + "</td><td>" + str(data[4]) + "</td></tr>"
         trecharge +=  data[2]
+    maildata += "</tbody></table></body></html>"
+    mail_html("cnc.center@shop2020.in", "5h0p2o2o", ["rajveer.singh@shop2020.in", "anupam.singh@shop2020.in", "Ashwani.Kumar@spiceretail.co.in","parveen.mittal@spiceretail.co.in","pardeep.panwar@spiceretail.co.in","gagan.sharma@spiceretail.co.in","j.p.gupta@shop2020.in", "rajneesh.arora@shop2020.in"], "MIS   (Date - " + todate.strftime("%d-%m-%Y") + ")   (Wallet Amount - " + str(wallet.amount) + ")    (Total Recharge - " + str(trecharge) + ")", maildata, [])
+    push_recharge_collection_to_ocr()
+def push_recharge_collection_to_ocr():
+    rcs = RechargeCollection.query.filter(RechargeCollection.pushedToOcr == False).all()
+    for rc in rcs:
+        store_string = "<Store>" + rc.hotspotId + "</Store>"
+        date_string = "<ReconDate>" + str(rc.reconDate) + "</ReconDate>"
+        cash_string = "<Cash>" + str(rc.cash) + "</Cash>"
+        card_string = "<Hdfc>" + str(rc.hdfc) + "</Hdfc>"
+        type_string = "<Type>RechargeSale</Type>"
+        amount_string = "<GrossRechargeAmount>" + str(rc.grossAmount) + "</GrossRechargeAmount><Discount>" + str(rc.discount) +  "</Discount><NetCollection>" + str(rc.netCollection) + "</NetCollection>";
         #SaholicRechargeSaleTransfer(string Store, int ReconDate, decimal Cash, decimal Hdfc, string Type, decimal GrossRechargeAmount, decimal Discount, decimal NetCollection)
         conn = httplib.HTTPConnection("182.71.104.182")
         XML="""
         <soap:Envelope xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:soap="http://schemas.xmlsoap.org/soap/envelope/">
         response = conn.getresponse()
         print response.status, response.reason
         resp = response.read()
         conn.close()
         print resp
+        if "Saved Successfully" in resp:
+            rc.pushedAt = datetime.datetime.now()
+            rc.pushedToOcr = True
+            session.commit()
+        elif "Error in Saving Data" in resp:
+            print "Send Alert to someone"
+        else:
+            print "Send Alert to someone"
-    maildata += "</tbody></table></body></html>"
-    mail_html("cnc.center@shop2020.in", "5h0p2o2o", ["rajveer.singh@shop2020.in", "anupam.singh@shop2020.in", "Ashwani.Kumar@spiceretail.co.in","parveen.mittal@spiceretail.co.in","pardeep.panwar@spiceretail.co.in","gagan.sharma@spiceretail.co.in","j.p.gupta@shop2020.in", "rajneesh.arora@shop2020.in"], "MIS   (Date - " + todate.strftime("%d-%m-%Y") + ")   (Wallet Amount - " + str(wamount) + ")    (Total Recharge - " + str(trecharge) + ")", maildata, [])
 def topup_company_wallet(companyId, amount):
     wallet = WalletForCompany.query.filter(WalletForCompany.id == companyId).with_lockmode("update").one()
     wh = WalletHistoryForCompany()

Subversion Repositories SmartDukaan

(root)/trunk/PyProj/src/shop2020/model/v1/order/script/ProcessRechargeTransaction.py – Rev 7245 → 7250