Subversion Repositories SmartDukaan

Rev

Rev 15921 | Rev 16535 | Go to most recent revision | 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):
22 
    if delete:
23 
        Mysql.deleteTableData('user_addresses')
15916 amit.gupta 24 
    try:
25 
        initialize()
26 
        #get all users
15921 amit.gupta 27 
        (maxUserId,) = session.query(func.max(All_user_addresses.user_id)).first()
15916 amit.gupta 28 
        if maxUserId is None:
29 
            maxUserId = 0
30 
        query = session.query(Users)
31 
        if maxUserId>0:
16198 amit.gupta 32 
            query = query.filter(Users.id>maxUserId)
15916 amit.gupta 33 
        for user in query.all():
34 
            userAddress = All_user_addresses()
35 
            userAddress.user_id = user.id
36 
            address = None
37 
            if user.address_line_1:
38 
                address = user.address_line_1
39 
            if user.address_line_2:
15918 amit.gupta 40 
                if address:
41 
                    address += " " +  user.address_line_2
42 
                else:
43 
                    address = user.address_line_2
15916 amit.gupta 44 
            userAddress.address = address
45 
            userAddress.city = user.city
46 
            userAddress.pincode = user.pincode
47 
            userAddress.state = user.state
48 
            userAddress.source = 'user_profile'
49 
 
50 
            ra2 = session.query(Retailers).filter(RetailerLinks.user_id==user.id).filter(Retailers.id==RetailerLinks.retailer_id).first()
51 
            if ra2:
52 
                ua2 = All_user_addresses()
53 
                ua2.user_id = user.id
54 
                ua2.store_name = ra2.title
55 
                ua2.address = ra2.address
56 
                ua2.city = ra2.city
57 
                ua2.pincode = ra2.pin
58 
                ua2.state = ra2.state
59 
                ua2.source = 'retailer_master'
60 
 
61 
            ra1 = session.query(RetailerAddresses).filter(RetailerLinks.user_id==user.id).filter(RetailerAddresses.retailer_id==RetailerLinks.retailer_id).first()
62 
            if ra1:
63 
                ua1 = All_user_addresses()
64 
                ua1.user_id= user.id
65 
                ua1.store_name = ra2.title
66 
                ua1.address = ra1.address
67 
                ua1.city = ra1.city
68 
                ua1.pincode = ra1.pin
69 
                ua1.state = ra1.state
70 
                ua1.source = 'retailer_crm_edited'
15919 amit.gupta 71 
            session.commit()
15916 amit.gupta 72 
        if maxUserId ==0:
73 
            for address in session.query(User_addresses).all():
74 
                ua3 = All_user_addresses()
75 
                ua3.user_id = address.user_id
76 
                ua3.store_name = address.store_name
77 
                ua3.address = address.address
78 
                ua3.city = address.city
79 
                ua3.state = address.state
80 
                ua3.pincode = address.pincode
81 
                ua3.source = 'fos_crm'
82 
            session.commit()
83 
 
84 
    finally:
85 
        session.close()
86 
 
87 
 
88 
 
89 
 
90 
 
91 
 
92 
 
93 
if __name__ == '__main__':
94 
    main()