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

 from dtr.reports.amazonreco import generateAmazonReco
 from dtr.storage import Mysql, DataService
 from dtr.storage.DataService import Users, Clicks, FlipkartOrders,\
     All_user_addresses
 from dtr.storage.Mysql import getOrdersAfterDate, getOrdersByTag
-from dtr.utils.utils import fromTimeStamp
+from dtr.utils import utils
 from elixir import *
 from sqlalchemy.sql.expression import func, func, or_
 from email import encoders
 from email.mime.base import MIMEBase
 from email.mime.multipart import MIMEMultipart
     matchedList = []
     workbook = xlwt.Workbook()
     worksheet = workbook.add_sheet("Snapdeal Reconciled")
     worksheet1 = workbook.add_sheet("Snapdeal Reconciled All")
     worksheet2 = workbook.add_sheet("Snapdeal Orders not reconciled")
+    worksheet3 = workbook.add_sheet("DateWise Sale Summary")
     affNotReconciledSheet = workbook.add_sheet("Snapdeal Aff not reconciled")
-    setHeaders(worksheet, worksheet1, worksheet2, affNotReconciledSheet)
+    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})
         if order is None:
             continue
         #saleTime = int(time.mktime(datetime.strptime(order['placedOn'], "%b %d, %Y, %I:%M %p").timetuple()))
+        saleTime = datetime.strptime(order['placedOn'], "%b %d, %Y, %I:%M %p").stftime("%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
         try:
             formattedTimestamp = order['placedOn']
             timestamp1 = int(time.mktime(datetime.strptime(order['placedOn'], "%b %d, %Y, %I:%M %p").timetuple()))
         except:
             timestamp1 = int(time.mktime(row1[-4].timetuple()))
-            formattedTimestamp = datetime.strftime(fromTimeStamp(timestamp1), "%b %d, %Y, %I:%M %p")
+            formattedTimestamp = datetime.strftime(utils.fromTimeStamp(timestamp1), "%b %d, %Y, %I:%M %p")
         if len(aff) > 0 and order["subTagId"] not in matchedList and int(order["paidAmount"])==int(aff[0]["saleAmount"]):
             matchedList.append(order["subTagId"])
             db.snapdealOrderAffiliateInfo.update({"adId":aff[0].get("adId")}, {"$set":{"reconciled":True, "orderId":orderId}}, multi=True)
             order['reconciled'] = True
         affNotReconciledSheet.write(row, inc(), offer.get("saleDate"))
         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')).stftime("%Y-%m-%d")
+        obj = datemap.get(saleTime)
+        if offer.get("payOut"):
+            obj['approvedAmount'] += order["approvedAmount"]
+        else:
+            obj['rejectedAmount'] += order["rejectedAmount"]
     workbook.save(XLS_FILENAME)
 def generateShopcluesReco():
     global i
         try:
             formattedTimestamp = order['placedOn']
             timestamp1 = int(time.mktime(datetime.strptime(order['placedOn'], "%d %b %Y %I:%M %p").timetuple()))
         except:
             timestamp1 = int(time.mktime(row1[-4].timetuple()))
-            formattedTimestamp = datetime.strftime(fromTimeStamp(timestamp1), "%d %b %Y %I:%M %p")
+            formattedTimestamp = datetime.strftime(utils.fromTimeStamp(timestamp1), "%d %b %Y %I:%M %p")
         if len(aff) > 0 and order["subTagId"] not in matchedList and long(order["paidAmount"])==long(float(aff[0]["transactionValue"])):
             matchedList.append(order["subTagId"])
             db.shopcluesOrderAffiliateInfo.update({"merchantOrderId":aff[0].get("merchantOrderId")}, {"$set":{"reconciled":True, "orderId":orderId}}, multi=True)
             order['reconciled'] = True
             worksheet1.write(anotherrow, i, order['placedOn'])
             worksheet.write(row, inc(), formattedTimestamp)
             worksheet1.write(anotherrow, i, formattedTimestamp)
             worksheet.write(row, inc(), int(order['paidAmount']))
             worksheet1.write(anotherrow, i, int(order['paidAmount']))
-            worksheet.write(row, inc(), datetime.strftime(fromTimeStamp(aff[0]['transactionTime']), "%d %b %Y %I:%M %p"))
+            worksheet.write(row, inc(), datetime.strftime(utils.fromTimeStamp(aff[0]['transactionTime']), "%d %b %Y %I:%M %p"))
-            worksheet1.write(anotherrow, i, datetime.strftime(fromTimeStamp(aff[0]['transactionTime']), "%d %b %Y %I:%M %p"))
+            worksheet1.write(anotherrow, i, datetime.strftime(utils.fromTimeStamp(aff[0]['transactionTime']), "%d %b %Y %I:%M %p"))
             worksheet.write(row, inc(), aff[0]['transactionValue'])
             worksheet1.write(anotherrow, i, aff[0]['transactionValue'])
             worksheet.write(row, inc(), aff[0]['payOut'])
             worksheet1.write(anotherrow, i, aff[0]['payOut'])
             worksheet.write(row, inc(), "NA")
         for order in orders:
             if notReconciled.has_key(order[0]):
                 (roww, column, paidAmount, timestamp1, oSubTagId) = notReconciled[order[0]]
                 if paidAmount==int(offer.get("transactionValue")) and timestamp1 <= saleTime and timestamp1 + 120 >= saleTime:
                     i = column
-                    worksheet1.write(roww, inc(), datetime.strftime(fromTimeStamp(offer.get("transactionTime")), "%d %b %Y %I:%M %p"))
+                    worksheet1.write(roww, inc(), datetime.strftime(utils.fromTimeStamp(offer.get("transactionTime")), "%d %b %Y %I:%M %p"))
                     worksheet1.write(roww, inc(), offer.get("transactionValue"))
                     worksheet1.write(roww, inc(), offer.get("payOut"))
                     del notReconciled[order[0]]
                     print "found match for user", order[1]
                     db.shopcluesOrderAffiliateInfo.update({"transactionId":offer.get("transactionId")}, {"$set":{"reconciled":True, "orderId":order[0]}}, multi=True)
                                                                  "$lt":int(time.mktime(date.today().timetuple()))}} ):
         row += 1
         i=-1
         affNotReconciledSheet.write(row, inc(), offer.get("uniqueKey"))
         affNotReconciledSheet.write(row, inc(), offer.get("subTagId"))
-        affNotReconciledSheet.write(row, inc(), datetime.strftime(fromTimeStamp(offer.get("transactionTime")), "%d %b %Y %I:%M %p"))
+        affNotReconciledSheet.write(row, inc(), datetime.strftime(utils.fromTimeStamp(offer.get("transactionTime")), "%d %b %Y %I:%M %p"))
         affNotReconciledSheet.write(row, inc(), offer.get("transactionValue"))
         affNotReconciledSheet.write(row, inc(), offer.get("payOut"))
         affNotReconciledSheet.write(row, inc(), offer.get("status"))
         affNotReconciledSheet.write(row, inc(), 'NA')
     email.append('amit.gupta@shop2020.in')
     MAILTO = email
     mailServer.login(SENDER, PASSWORD)
     mailServer.sendmail(PASSWORD, MAILTO, msg.as_string())
-def setHeaders(worksheet, worksheet1, worksheet2, affNotReconciledSheet):
+def setHeaders(worksheet, worksheet1, worksheet2, affNotReconciledSheet, worksheet3):
     boldStyle = xlwt.XFStyle()
     f = xlwt.Font()
     f.bold = True
     boldStyle.font = f
     row = 0
     affNotReconciledSheet.write(row, inc(), 'Sale Amount', boldStyle)
     affNotReconciledSheet.write(row, inc(), 'Pay Out', boldStyle)
     affNotReconciledSheet.write(row, inc(), 'Status', boldStyle)
     affNotReconciledSheet.write(row, inc(), 'IP', boldStyle)
+    i =-1
+    worksheet3.write(row, inc(), 'Date', boldStyle)
+    worksheet3.write(row, inc(), 'Sale Amount', boldStyle)
+    worksheet3.write(row, inc(), 'Approved Sales', boldStyle)
+    worksheet3.write(row, inc(), 'Rejected Sales', boldStyle)
 def getUserAmountReconciled():
     pass
 def getUserOrders():
     global i
             flipkartOrder.model = skuData.get("model_name")
             flipkartOrder.category =categoryMap.get(skuData.get("category_id"))
             flipkartOrder.title =skuData.get("source_product_name")
     session.commit()
+def main1():
+    db = client.Dtr
+    for offer in db.snapdealOrderAffiliateInfo.find({}):
+        print offer.get("adId"), offer.get("saleAmount"), type(offer.get("saleAmount"))
+        #obj = offer.get(saleTime)
+        #obj['paidAmount'] += order["paidAmount"]
 def addHeaders(sheet):
     global i
     i = 0
     sheet.write(0, inc(), )
 def main():
     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)
 if __name__ == '__main__':
     #info = client.Dtr.flipkartOrderAffiliateInfo.find()
     #print info
-    main()
+    main1()

Subversion Repositories SmartDukaan

(root)/trunk/PyDTR/src/dtr/reports/affiliatereco.py – Rev 16785 → 16947