Subversion Repositories SmartDukaan

Rev

Rev 15432 | Rev 15445 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 15432 Rev 15440
Line 9... Line 9...
9
from dtr.storage import Mysql
9
from dtr.storage import Mysql
10
from dtr.storage.DataService import Users, Clicks
10
from dtr.storage.DataService import Users, Clicks
11
from dtr.storage.Mysql import getOrdersAfterDate, getOrdersByTag
11
from dtr.storage.Mysql import getOrdersAfterDate, getOrdersByTag
12
from dtr.utils.utils import fromTimeStamp
12
from dtr.utils.utils import fromTimeStamp
13
from elixir import *
13
from elixir import *
-
 
14
from sqlalchemy.sql.expression import func, func, or_
14
from email import encoders
15
from email import encoders
15
from email.mime.base import MIMEBase
16
from email.mime.base import MIMEBase
16
from email.mime.multipart import MIMEMultipart
17
from email.mime.multipart import MIMEMultipart
17
from email.mime.text import MIMEText
18
from email.mime.text import MIMEText
18
from pymongo.mongo_client import MongoClient
19
from pymongo.mongo_client import MongoClient
Line 674... Line 675...
674
        userId = None
675
        userId = None
675
        subTagId = None
676
        subTagId = None
676
        email = None
677
        email = None
677
        subTagId = order.get("subTagId")
678
        subTagId = order.get("subTagId")
678
        if subTagId:
679
        if subTagId:
679
            (userId,) = session.query(Clicks.user_id).filter_by(tag=subTagId).first()
680
            a = session.query(Clicks.user_id).filter_by(tag=subTagId).first()
680
            if userId is not None:
681
            if a is not None:
-
 
682
                (userId,) = a 
681
                (email,) = session.query(Users.email).filter_by(id = userId).first()
683
                (email,) = session.query(Users.email).filter_by(id = userId).first()
682
        
684
        
683
        row3 += 1
685
        row3 += 1
684
        i=-1
686
        i=-1
685
        sh2.write(row3, inc(), userId)
687
        sh2.write(row3, inc(), userId)
Line 727... Line 729...
727
    getUserOrders()
729
    getUserOrders()
728
    sendmail(["amit.gupta@shop2020.in","rajneesh.arora@saholic.com"], "", "Affiliate Reco", XLS_FILENAME, XLS_F_FILENAME, XLS_A_FILENAME)
730
    sendmail(["amit.gupta@shop2020.in","rajneesh.arora@saholic.com"], "", "Affiliate Reco", XLS_FILENAME, XLS_F_FILENAME, XLS_A_FILENAME)
729
    sendmail(["amit.gupta@shop2020.in", "rajneesh.arora@saholic.com", "chaitnaya.vats@saholic.com", "manoj.kumar@saholic.com"], "", "All DTR Orders", XLS_O_FILENAME)
731
    sendmail(["amit.gupta@shop2020.in", "rajneesh.arora@saholic.com", "chaitnaya.vats@saholic.com", "manoj.kumar@saholic.com"], "", "All DTR Orders", XLS_O_FILENAME)
730
 
732
 
731
if __name__ == '__main__':
733
if __name__ == '__main__':
732
    info = lclient.Dtr.flipkartOrderAffiliateInfo.find()
734
    #info = client.Dtr.flipkartOrderAffiliateInfo.find()
733
    print info
735
    #print info
734
    #main()
736
    main()
735
    
737
    
736
738