WebSVN – SmartDukaan – Diff – /trunk/PyDTR/src/dtr/storage/Mongo.py

 from dtr.config import PythonPropertyReader
 from dtr.dao import FeaturedDeals, AppTransactions, AppOfferObj
 from dtr.storage import DataService
 from dtr.storage.DataService import price_preferences, brand_preferences, \
     user_actions, Brands, app_offers, approved_app_transactions, user_app_cashbacks, \
-    user_app_installs, appmasters
+    user_app_installs, appmasters, notification_campaigns
 from dtr.storage.MemCache import MemCache
 from dtr.utils.MailSender import Email
 from dtr.utils.utils import to_java_date, CB_PENDING, CB_APPROVED, CB_INIT, \
     to_py_date, CB_REJECTED
 from sqlalchemy.sql.expression import func, func, or_, desc, asc, case
 import random
 import re
 import time
 import traceback
 from itertools import groupby
+import urllib
+import urllib2
+import json
 con = None
 DataService.initialize(db_hostname="localhost")
 mc = MemCache("127.0.0.1")
         mc.set("cached_app_offers_"+str(retailerId), finalAppOffersMap, 120)
     else:
         print 'No Offers'
         mc.set("cached_app_offers_"+str(retailerId), {}, 10)
+def sendNotification(userIds, campaignName, title, message,notificationtype, url, expiresat='2999-01-01'):
+    campaignId = addNotificationCampaign(campaignName, title, message, notificationtype, url, None)
+    payload = {}
+    payload["user_id"]= userIds[0]
+    payload["type"]="pending"
+    payload["notification_campaign_id"]= campaignId
+    payload["status"]=0
+    payloadList = []
+    payloadList.append(payload)
+    jsonObj = json.dumps(payloadList)
+    pushpostrequest = urllib2.Request("http://45.33.50.227:3001/addPushNotification", jsonObj)
+    response = urllib2.urlopen(pushpostrequest).read()
+    print response
+def addNotificationCampaign(name, title, message, type, url, sql):
+    notificationCampaign = notification_campaigns()
+    notificationCampaign.name = name
+    notificationCampaign.title = title
+    notificationCampaign.type = type
+    notificationCampaign.message = message
+    notificationCampaign.url = url
+    notificationCampaign.sql = sql
+    notificationCampaign.expiresat = datetime(2999, 1, 1)
+    notificationCampaign.status = 'active'
+    notificationCampaign.created = datetime.now()
+    session.commit()
+    campaignId = notificationCampaign.id
+    session.close()
+    return campaignId
 def main():
     #generateRedirectUrl(101,1)
     print (getCashBackDetails('1351153', 3))
     #print addPayout("10", "55db82c0bcabd7fc59e0a71")

Subversion Repositories SmartDukaan

(root)/trunk/PyDTR/src/dtr/storage/Mongo.py – Rev 17180 → 17280