WebSVN – SmartDukaan – Diff – /trunk/PyDTR/src/dtr/api/Service.py

 from dtr.config import PythonPropertyReader
 from dtr.storage import Mongo
 from dtr.storage.DataService import Retailers, Users, CallHistory, RetryConfig, \
     RetailerLinks, Activation_Codes, Agents, Agent_Roles, AgentLoginTimings, \
     FetchDataHistory, RetailerContacts, Orders, OnboardedRetailerChecklists,\
-    RetailerAddresses, Pincodeavailability, app_offers, appmasters
+    RetailerAddresses, Pincodeavailability, app_offers, appmasters, user_app_cashbacks, user_app_installs
 from dtr.storage.Mongo import get_mongo_connection
 from dtr.storage.Mysql import fetchResult
 from dtr.utils import FetchLivePrices, DealSheet as X_DealSheet, \
     UserSpecificDeals
 from dtr.utils.utils import getLogger
 import traceback
 import urllib
 import urllib2
 import uuid
 import gdshortener
-from dtr.dao import AppOfferObj
+from dtr.dao import AppOfferObj, UserAppBatchDrillDown, UserAppBatchDateDrillDown
 alphalist = list(string.uppercase)
 alphalist.remove('O')
 numList = ['1','2','3','4','5','6','7','8','9']
 codesys = [alphalist, alphalist, numList, numList, numList]
 class AppOffers():
     def on_get(self, req, resp, retailerId):
         retailerId = int(retailerId)
         nullCheckList = ['','0']
-        offers = session.query(app_offers.id,app_offers.appmaster_id, app_offers.app_name, app_offers.affiliate_offer_id, app_offers.image_url, app_offers.downloads, app_offers.link, app_offers.offer_price, app_offers.offerCategory, app_offers.package_name, app_offers.promoImage, app_offers.ratings, case([(app_offers.override_payout == True, app_offers.overriden_payout)], else_=app_offers.user_payout).label('user_payout'), case([(appmasters.shortDescription != None, appmasters.shortDescription)], else_=None).label('shortDescription'), case([(appmasters.longDescription != None, appmasters.longDescription)], else_=None).label('longDescription'), appmasters.customerOneLiner, appmasters.retailerOneLiner,app_offers.priority, app_offers.offerCondition).join((appmasters,appmasters.id==app_offers.appmaster_id)).filter(app_offers.affiliate_id==retailerId).filter(app_offers.show==True).filter(app_offers.offer_active==True).filter(app_offers.offer_price>0).order_by(case([(app_offers.priority.in_(tuple(nullCheckList)), 1)], else_=0), asc(app_offers.priority),desc('user_payout')).all()
+        offers = session.query(app_offers.id,app_offers.appmaster_id, app_offers.app_name, app_offers.affiliate_offer_id, app_offers.image_url, app_offers.downloads, app_offers.link, app_offers.offer_price, app_offers.offerCategory, app_offers.package_name, app_offers.promoImage, app_offers.ratings, case([(app_offers.override_payout == True, app_offers.overriden_payout)], else_=app_offers.user_payout).label('user_payout'), case([(appmasters.shortDescription != None, appmasters.shortDescription)], else_=None).label('shortDescription'), case([(appmasters.longDescription != None, appmasters.longDescription)], else_=None).label('longDescription'), appmasters.customerOneLiner, appmasters.retailerOneLiner,app_offers.priority, app_offers.offerCondition).join((appmasters,appmasters.id==app_offers.appmaster_id)).filter(app_offers.affiliate_id==retailerId).filter(appmasters.showApp==True).filter(app_offers.show==True).filter(app_offers.offer_active==True).filter(app_offers.offer_price>0).order_by(case([(app_offers.priority.in_(tuple(nullCheckList)), 1)], else_=0), asc(app_offers.priority),desc('user_payout')).all()
         offersJsonArray = []
         if offers is None or len(offers)==0:
             resp.body = json.dumps("{}")
         else:
             for offer in offers:
         if session.is_active:
             print "session is active. closing it."
             session.close()
         resp.body = json.dumps({"AppOffers":offersJsonArray}, encoding='utf-8')
+class AppUserBatchRefund():
+    def on_get(self, req, resp, batchId, userId):
+        batchId = long(batchId)
+        userId = long(userId)
+        userBatchCashback = user_app_cashbacks.get_by(user_id=userId, batchCreditId=batchId)
+        if session.is_active:
+            print "session is active. closing it."
+            session.close()
+        if userBatchCashback is None:
+            resp.body = json.dumps("{}")
+        else:
+            resp.body = json.dumps(todict(userBatchCashback), encoding='utf-8')
+class AppUserBatchDrillDown():
+    def on_get(self, req, resp, batchId, userId):
+        batchId = long(batchId)
+        userId = long(userId)
+        appUserBatchDrillDown = session.query(user_app_installs.transaction_date, func.sum(user_app_installs.installCount).label('downloads'), func.sum(user_app_installs.payoutAmount).label('amount')).join((user_app_cashbacks,user_app_cashbacks.user_id==user_app_installs.user_id)).filter(user_app_cashbacks.fortnightOfYear==user_app_installs.fortnightOfYear).filter(user_app_cashbacks.user_id==userId).filter(user_app_cashbacks.batchCreditId==batchId).group_by(user_app_installs.transaction_date).all()
+        cashbackArray = []
+        if session.is_active:
+            print "session is active. closing it."
+            session.close()
+        if appUserBatchDrillDown is None or len(appUserBatchDrillDown)==0:
+            resp.body = json.dumps("{}")
+        else:
+            for appcashBack in appUserBatchDrillDown:
+                userAppBatchDrillDown = UserAppBatchDrillDown(str(appcashBack[0]),long(appcashBack[1]), long(appcashBack[2]))
+                cashbackArray.append(todict(userAppBatchDrillDown))
+            resp.body = json.dumps({"UserAppCashBackInBatch":cashbackArray}, encoding='utf-8')
+class AppUserBatchDateDrillDown():
+    def on_get(self, req, resp, userId, date):
+        userId = long(userId)
+        date = str(date)
+        date = datetime.strptime(date, '%Y-%m-%d')
+        appUserBatchDateDrillDown = session.query(user_app_installs.app_name, func.sum(user_app_installs.installCount).label('downloads'), func.sum(user_app_installs.payoutAmount).label('amount')).filter(user_app_installs.user_id==userId).filter(user_app_installs.transaction_date==date).group_by(user_app_installs.app_name).all()
+        cashbackArray = []
+        if session.is_active:
+            print "session is active. closing it."
+            session.close()
+        if appUserBatchDateDrillDown is None or len(appUserBatchDateDrillDown)==0:
+            resp.body = json.dumps("{}")
+        else:
+            for appcashBack in appUserBatchDateDrillDown:
+                userAppBatchDateDrillDown = UserAppBatchDateDrillDown(str(appcashBack[0]),long(appcashBack[1]),long(appcashBack[2]))
+                cashbackArray.append(todict(userAppBatchDateDrillDown))
+            resp.body = json.dumps({"UserAppCashBackDateWise":cashbackArray}, encoding='utf-8')
 def main():
     #tagActivatedReatilers()
     a = RetailerDetail()
     retailer = a.getNotActiveRetailer()

Subversion Repositories SmartDukaan

(root)/trunk/PyDTR/src/dtr/api/Service.py – Rev 16723 → 16727