Subversion Repositories SmartDukaan

Rev

Rev 19970 | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
15916 amit.gupta 1
'''
2
Created on Jul 8, 2015
3
 
4
@author: amit
5
'''
6
from dtr.storage import Mysql
7
from dtr.storage.DataService import MissingAmazonOrderUsers, \
8
    PendingToTrackAmazonOrderUsers, initialize, RetailerAddresses, Users, \
9
    User_addresses, All_user_addresses, RetailerLinks, Retailers
10
from elixir import *
11
from pymongo.mongo_client import MongoClient
12
from sqlalchemy.sql.expression import func
13
 
14
 
15
 
16
 
17
 
18
 
19
 
20
 
16198 amit.gupta 21
def main(delete=False):
15916 amit.gupta 22
    try:
23
        initialize()
24
        #get all users
16993 amit.gupta 25
        maxUserId = 0
19970 amit.gupta 26
        query = session.query(func.max(All_user_addresses.user_id))
27
        maxUserId = query.scalar()
19971 amit.gupta 28
        query = session.query(Users)
15916 amit.gupta 29
        if maxUserId>0:
16198 amit.gupta 30
            query = query.filter(Users.id>maxUserId)
15916 amit.gupta 31
        for user in query.all():
16993 amit.gupta 32
            address = None
15916 amit.gupta 33
            if user.address_line_1:
34
                address = user.address_line_1
35
            if user.address_line_2:
15918 amit.gupta 36
                if address:
37
                    address += " " +  user.address_line_2
38
                else:
39
                    address = user.address_line_2
16993 amit.gupta 40
            if address:
41
                userAddress = All_user_addresses()
42
                userAddress.user_id = user.id
43
                userAddress.city = user.city
44
                userAddress.address = address
45
                userAddress.pincode = user.pincode
46
                userAddress.state = user.state
47
                userAddress.source = 'user_profile'
15916 amit.gupta 48
 
49
            ra2 = session.query(Retailers).filter(RetailerLinks.user_id==user.id).filter(Retailers.id==RetailerLinks.retailer_id).first()
50
            if ra2:
51
                ua2 = All_user_addresses()
52
                ua2.user_id = user.id
53
                ua2.store_name = ra2.title
54
                ua2.address = ra2.address
55
                ua2.city = ra2.city
56
                ua2.pincode = ra2.pin
57
                ua2.state = ra2.state
58
                ua2.source = 'retailer_master'
59
 
60
            ra1 = session.query(RetailerAddresses).filter(RetailerLinks.user_id==user.id).filter(RetailerAddresses.retailer_id==RetailerLinks.retailer_id).first()
61
            if ra1:
62
                ua1 = All_user_addresses()
63
                ua1.user_id= user.id
64
                ua1.store_name = ra2.title
65
                ua1.address = ra1.address
66
                ua1.city = ra1.city
67
                ua1.pincode = ra1.pin
68
                ua1.state = ra1.state
69
                ua1.source = 'retailer_crm_edited'
15919 amit.gupta 70
            session.commit()
15916 amit.gupta 71
        if maxUserId ==0:
72
            for address in session.query(User_addresses).all():
73
                ua3 = All_user_addresses()
74
                ua3.user_id = address.user_id
75
                ua3.store_name = address.store_name
76
                ua3.address = address.address
77
                ua3.city = address.city
78
                ua3.state = address.state
79
                ua3.pincode = address.pincode
80
                ua3.source = 'fos_crm'
81
            session.commit()
82
 
83
    finally:
84
        session.close()
85
 
86
 
87
 
88
 
89
 
90
 
91
 
92
if __name__ == '__main__':
93
    main()