WebSVN – SmartDukaan – Diff – /trunk/PyDTR/src/dtr/reports/affiliatereco.py

 import MySQLdb
 import smtplib
 import time
 import xlwt
 from dtr.utils import utils
+from dtr.utils.utils import toTimeStamp
 #from xlwt import
 DataService.initialize()
 client = MongoClient('mongodb://localhost:27017/')
     worksheet3 = workbook.add_sheet("DateWise Sale Summary")
     affNotReconciledSheet = workbook.add_sheet("Snapdeal Aff not reconciled")
     setHeaders(worksheet, worksheet1, worksheet2, affNotReconciledSheet, worksheet3)
     row = 0
     anotherrow = 0
-    row2 = 0
     row5=0
     datemap={}
     for row1 in curs:
         orderId = row1[0]
         order = db.merchantOrder.find_one({"orderId":orderId})
             continue
         #saleTime = int(time.mktime(datetime.strptime(order['placedOn'], "%b %d, %Y, %I:%M %p").timetuple()))
         try:
             saleTime = datetime.strptime(order['placedOn'], "%a, %d %b, %Y").strftime("%Y-%m-%d")
         except:
             saleTime = datetime.strptime(order['placedOn'], "%b %d, %Y, %I:%M %p").strftime("%Y-%m-%d")
-        if not datemap.has_key(saleTime):
-            datemap[saleTime] = {"totalAmount":0, "paidAmount":0, "rejectedAmount":0, "approvedAmount":0}
-        obj = datemap.get(saleTime)
-        obj['paidAmount'] += order["paidAmount"]
         aff = list(db.snapdealOrderAffiliateInfo.find({"subTagId":order["subTagId"]}))
         if len(aff) > 1:
             aff = [f for f in aff if f.get("payOut")>0]
         anotherrow += 1
         affNotReconciledSheet.write(row, inc(), offer.get("saleAmount"))
         affNotReconciledSheet.write(row, inc(), offer.get("payOut"))
         affNotReconciledSheet.write(row, inc(), offer.get("conversionStatus"))
         affNotReconciledSheet.write(row, inc(), offer.get("ip"))
-    for offer in db.snapdealOrderAffiliateInfo1.find({}):
-        saleTime =  utils.fromTimeStamp(offer.get('saleDate')).strftime("%Y-%m-%d")
-        obj = datemap.get(saleTime)
-        if offer.get("payOut"):
-            obj['approvedAmount'] += order["approvedAmount"]
-        else:
-            obj['rejectedAmount'] += order["rejectedAmount"]
     message=""
-    for key,valmap in  datemap.iteritems():
-        valmap['_id'] = key
-        db.flSaleSnapshot.save(valmap)
-        mailBodyTemplate="""
+#    mailBodyTemplate="""
-        <html>
+#        <html>
-            <body>
+#            <body>
-            <table cellspacing="0" border="1" style="text-align:right">
+#            <table cellspacing="0" border="1" style="text-align:right">
-                <thead>
+#                <thead>
-                    <tr>
+#                    <tr>
-                        <th style="text-align:center">Date</th>
+#                        <th style="text-align:center">Date</th>
-                        <th  style="text-align:center">Sale</th>
+#                        <th  style="text-align:center">Sale</th>
-                        <th  style="text-align:center">Approved</th>
+#                        <th  style="text-align:center">Approved</th>
-                        <th  style="text-align:center">Rejected</th>
+#                        <th  style="text-align:center">Rejected</th>
-                    </tr>
+#                    </tr>
-                </thead>
+#                </thead>
-                <tbody>
+#                <tbody>
-                    {10}
+#                    {0}
-                </tbody>
+#                </tbody>
-            </table>
+#            </table>
-            </body>
+#            </body>
-        </html>
+#        </html>
-    """
+#    """
-    tbody=[]
+#    tbody=[]
-    rowtemplate="<tr><td>{0}</td><td>{1}</td><td>{2}</td><td>{3}</td></tr>"
+#    rowtemplate="<tr><td>{0}</td><td>{1}</td><td>{2}</td><td>{3}</td></tr>"
-    for offer in db.flSaleSnapshot.find({}):
+#    for offer in db.flSaleSnapshot.find({}):
-        tbody.append(rowtemplate.format(offer.get("_id"), offer.get("paidAmount"), offer.get("saleAmount"), offer.get("rejectedAmount")))
+#        tbody.append(rowtemplate.format(offer.get("_id"), offer.get("paidAmount"), offer.get("saleAmount"), offer.get("rejectedAmount")))
-    message = mailBodyTemplate.format("".join(tbody))
+#    message = mailBodyTemplate.format("".join(tbody))
     workbook.save(XLS_FILENAME)
     return message
 def generateShopcluesReco():
     generateFlipkartReco()
     generateShopcluesReco()
     generateAmazonReco(XLS_A_FILENAME)
     getUserOrders()
     sendmail(["amit.gupta@shop2020.in","rajneesh.arora@saholic.com","manish.sharma@shop2020.in"], message, "Affiliate Reco", XLS_FILENAME, XLS_F_FILENAME, XLS_A_FILENAME, XLS_SC_FILENAME)
-    #sendmail(["amit.gupta@shop2020.in"], "", "Affiliate Reco", XLS_FILENAME, XLS_F_FILENAME, XLS_A_FILENAME)
+    #sendmail(["amit.gupta@shop2020.in"], "", "Affiliate Reco", XLS_FILENAME, XLS_F_FILENAME, XLS_A_FILENAME, XLS_SC_FILENAME)
     sendmail(["amit.gupta@shop2020.in", "rajneesh.arora@saholic.com", "chaitnaya.vats@saholic.com", "manoj.kumar@saholic.com", "manish.sharma@shop2020.in"], "", "All DTR Orders", XLS_O_FILENAME)
+def main2():
+    db = client.Dtr
+    curs = getOrdersAfterDate(datetime.now() - timedelta(days=1), 3)
+    datemap={}
+    for row1 in curs:
+        orderId = row1[0]
+        order = db.merchantOrder.find_one({"orderId":orderId})
+        if order is None:
+            continue
+        #saleTime = int(time.mktime(datetime.strptime(order['placedOn'], "%b %d, %Y, %I:%M %p").timetuple()))
+        try:
+            saleTime = datetime.strptime(order['placedOn'], "%a, %d %b, %Y").strftime("%Y-%m-%d")
+        except:
+            saleTime = datetime.strptime(order['placedOn'], "%b %d, %Y, %I:%M %p").strftime("%Y-%m-%d")
+        print "%s\t%s\t%s\t%s"%(orderId, order['placedOn'], saleTime, order['paidAmount'])
+        if not datemap.has_key(saleTime):
+            datemap[saleTime] = {"totalAmount":0, "paidAmount":0, "rejectedAmount":0, "approvedAmount":0, "count":0}
+        obj = datemap.get(saleTime)
+        obj['paidAmount'] += order["paidAmount"]
+        obj['count'] += 1
+    for offer in db.snapdealOrderAffiliateInfo1.find({"saleDate":{"$gte":toTimeStamp(datetime.now() - timedelta(days=1))}}):
+        saleTime =  utils.fromTimeStamp(offer.get('saleDate')).strftime("%Y-%m-%d")
+        obj = datemap.get(saleTime)
+        if obj is not None:
+            try:
+                if offer.get("payOut"):
+                    obj['approvedAmount'] += offer["saleAmount"]
+                else:
+                    obj['rejectedAmount'] += offer["saleAmount"]
+            except:
+                print "Exception for orderId" , offer.get("orderId")
+        else:
+            print "Could not find sale date", saleTime
+            continue
+    for key,valmap in  datemap.iteritems():
+        valmap['_id'] = key
+        db.flSaleSnapshot.save(valmap)
 if __name__ == '__main__':
     #info = client.Dtr.flipkartOrderAffiliateInfo.find()
     #print info
-    main()
+    main1()

Subversion Repositories SmartDukaan

(root)/trunk/PyDTR/src/dtr/reports/affiliatereco.py – Rev 16995 → 17001