WebSVN – SmartDukaan – Diff – /trunk/PyProj/src/shop2020/model/v1/order/impl/DataAccessors.py

     OrderInventory, Alert, PaymentSettlement, EBSSettlementSummary, \
     CodVerificationAgent, Attribute, RechargeVoucherTracker, EmiScheme, MiscCharges, \
     BlockedIpRange, DeniedIpAddress, InsuranceDetailForOrder, DocumentStore, \
     RechargeTransaction, HotspotStore, WalletForCompany, WalletHistoryForCompany, \
     FRC, OperatorSeries, SourceDetail, Company, \
-    AmazonOrder, StoreOrderDetail, EdcBank
+    AmazonOrder, StoreOrderDetail, EdcBank, StoreOrderCollection
 from shop2020.model.v1.order.impl.model.BaseOrder import BaseOrder
 from shop2020.model.v1.order.impl.model.DTHRechargeOrder import DTHRechargeOrder
 from shop2020.model.v1.order.impl.model.MobileRechargeOrder import \
     MobileRechargeOrder
 from shop2020.model.v1.order.impl.model.RechargeDenomination import \
     StorePaymentStatus
 from shop2020.thriftpy.model.v1.user.ttypes import VoucherType
 from shop2020.thriftpy.payments.ttypes import PaymentException
 from shop2020.thriftpy.warehouse.ttypes import ScanType, \
     WarehouseServiceException
-from shop2020.utils.EmailAttachmentSender import mail, get_attachment_part
+from shop2020.utils.EmailAttachmentSender import mail, get_attachment_part,\
+    mail_html
 from shop2020.utils.Utils import to_py_date, to_java_date
 from sqlalchemy.orm.exc import NoResultFound, MultipleResultsFound
 from sqlalchemy.sql import func
 from sqlalchemy.sql.expression import and_, or_, desc, not_, distinct, cast, \
     between
     pdf.showPage()
     pdf.save()
     return filename
 def __push_store_collection_to_hotspot(order, ctype, amount):
-    try:
-        ts = order.created_timestamp
+    ts = datetime.datetime.now()
-        store =  get_hotspot_store(order.storeId, "")
+    store =  get_hotspot_store(order.storeId, "")
-        storeName = store.hotspotId
-        store_string = "<Store>" + storeName + "</Store>"
-        order_string = "<OrderID>" + str(order.id) + "</OrderID>"
-        product_string = "<Product>" + str(order.lineitems[0]) + "</Product>"
-        collection_type = "<CollectionType>" + ctype + "</CollectionType>"
-        amount_string = "<AdvanceAmount>" + amount + "</AdvanceAmount>"
-        date_string = "<TimeStamp>" + ts.strftime("%Y%m%d%H%M%S") + "</TimeStamp>"
-        cash_string = "<CashAmount>" + order.advanceAmount + "</CashAmount>"
-        card_string = "<CardAmount>" + "0" + "</CardAmount>"
-        #advance, saleClosure, advanceRefund, saleRefund
-        conn = httplib.HTTPConnection("182.71.104.186")
-        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/">
-          <soap:Body>
-            <SaholicAdvanceTransfer xmlns="http://tempuri.org/">
-        """
-        XML = XML + store_string + order_string + product_string + collection_type + amount_string + cash_string + card_string + date_string
-        footer = """
-            </SaholicAdvanceTransfer>
-          </soap:Body>
-        </soap:Envelope>
-        """
-        XML = XML + footer
+    soc = StoreOrderCollection()
+    soc.hotspotId = store.hotspotId
+    soc.orderId = order.id
+    soc.collectionType = ctype
+    soc.advanceAmount = int(amount)
+    soc.productName =  str(order.lineitems[0])
+    soc.addedAt = ts
+    soc.pushedToOcr = False
+    soc.cash = int(amount)
+    soc.card = 0
+    session.commit()
+    try:
+        rcs = StoreOrderCollection.query.filter(StoreOrderCollection.pushedToOcr == False).all()
+        for cs in rcs:
+            store_string = "<Store>" + cs.hotspotId + "</Store>"
+            order_string = "<OrderID>" + str(cs.orderId) + "</OrderID>"
+            product_string = "<Product>" + cs.productName + "</Product>"
+            collection_type = "<CollectionType>" + cs.collectionType + "</CollectionType>"
+            amount_string = "<AdvanceAmount>" + str(cs.advanceAmount) + "</AdvanceAmount>"
+            date_string = "<Date>" + cs.addedAt.strftime("%Y%m%d") + "</Date>"
+            time_string = "<Time>" + cs.addedAt.strftime("%H%M%S") + "</Time>"
+            cash_string = "<CashAmount>" + str(cs.cash) + "</CashAmount>"
+            card_string = "<CardAmount>" + str(cs.card) + "</CardAmount>"
+            #advance, saleClosure, advanceRefund, cashRefund, cardRefund
+            conn = httplib.HTTPConnection("182.71.104.186")
+            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/">
+              <soap:Body>
+                <SaholicAdvanceTransfer xmlns="http://tempuri.org/">
+            """
+            XML = XML + store_string + order_string + product_string + collection_type + amount_string + cash_string + card_string + time_string + date_string
+            footer = """
+                </SaholicAdvanceTransfer>
+              </soap:Body>
+            </soap:Envelope>
+            """
+            XML = XML + footer
-        params = urllib.urlencode({'op': 'SaholicAdvanceTransfer'})
+            params = urllib.urlencode({'op': 'SaholicAdvanceTransfer'})
-        headers = { "Content-type": "text/xml", "Content-Length": "%d" % len(XML)}
+            headers = { "Content-type": "text/xml", "Content-Length": "%d" % len(XML)}
-        conn.request("POST", "/loaddetect/Service.asmx?"+params, "", headers)
+            conn.request("POST", "/loaddetect/Service.asmx?"+params, "", headers)
-        conn.send(XML)
+            conn.send(XML)
-        response = conn.getresponse()
+            response = conn.getresponse()
-        print response.status, response.reason
+            print response.status, response.reason
-        resp = response.read()
+            resp = response.read()
-        conn.close()
+            conn.close()
-        print resp
+            print resp
-        if "Saved Successfully" in resp:
+            if "Saved Successfully" in resp:
-            return True
+                cs.pushedToOcr = True
-        elif "Error in Saving Data" in resp:
+                cs.pushedAt = datetime.datetime.now()
-            return False
+                session.commit()
-        else:
+            elif "Error in Saving Data" in resp:
+                mail_html("cnc.center@shop2020.in", "5h0p2o2o", ["rajveer.singh@shop2020.in", "anupam.singh@shop2020.in", "rajneesh.arora@shop2020.in"], "Problem while pushing store collection to OCR", resp, [])
-            return False
+            else:
-    except Exception as e:
+                mail_html("cnc.center@shop2020.in", "5h0p2o2o", ["rajveer.singh@shop2020.in", "anupam.singh@shop2020.in", "rajneesh.arora@shop2020.in"], "Problem while pushing store collection to OCR", resp, [])
-        print e
+    except:
-        return False
+        print "Problem while pushing to ocr"
 def __push_collection_to_hotspot(order, type, storeOrder = False):
     try:
         storeName = '109'
         if storeOrder:

Subversion Repositories SmartDukaan

(root)/trunk/PyProj/src/shop2020/model/v1/order/impl/DataAccessors.py – Rev 7402 → 7406