Subversion Repositories SmartDukaan

Rev

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

Rev 15440 Rev 15445
Line 4... Line 4...
4 
@author: amit
 4 
@author: amit
5 
'''
 5 
'''
6 
from datetime import date, datetime, timedelta
 6 
from datetime import date, datetime, timedelta
7 
from dtr.main import Store, sourceMap
 7 
from dtr.main import Store, sourceMap
8 
from dtr.reports.amazonreco import generateAmazonReco
 8 
from dtr.reports.amazonreco import generateAmazonReco
9 
from dtr.storage import Mysql
 9 
from dtr.storage import Mysql, DataService
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 sqlalchemy.sql.expression import func, func, or_
Line 24... Line 24...
24 
import smtplib
 24 
import smtplib
25 
import time
 25 
import time
26 
import xlwt
 26 
import xlwt
27 
#from xlwt import
27 
#from xlwt import
28 
 
 28 
 
- 
 
 29 
DataService.initialize()
29 
client = MongoClient('mongodb://localhost:27017/')
 30 
client = MongoClient('mongodb://localhost:27017/')
30 
 
 31 
 
31 
SENDER = "cnc.center@shop2020.in"
 32 
SENDER = "cnc.center@shop2020.in"
32 
PASSWORD = "5h0p2o2o"
 33 
PASSWORD = "5h0p2o2o"
33 
SUBJECT = "DTR User Segmentation report for " + date.today().isoformat()
 34 
SUBJECT = "DTR User Segmentation report for " + date.today().isoformat()
Line 675... Line 676...
675 
        userId = None
 676 
        userId = None
676 
        subTagId = None
 677 
        subTagId = None
677 
        email = None
 678 
        email = None
678 
        subTagId = order.get("subTagId")
 679 
        subTagId = order.get("subTagId")
679 
        if subTagId:
 680 
        if subTagId:
680 
            a = session.query(Clicks.user_id).filter_by(tag=subTagId).first()
 681 
            click = session.query(Clicks).filter_by(tag = subTagId).first()
681 
            if a is not None:
 682 
            if click is not None:
682 
                (userId,) = a
683 
                userId= click.user_id
683 
                (email,) = session.query(Users.email).filter_by(id = userId).first()
 684 
                (email,) = session.query(Users.email).filter_by(id = userId).first()
684
685
685 
        row3 += 1
 686 
        row3 += 1
686 
        i=-1
 687 
        i=-1
687 
        sh2.write(row3, inc(), userId)
 688 
        sh2.write(row3, inc(), userId)
Line 690... Line 691...
690 
        sh2.write(row3, inc(), "Flipkart")
 691 
        sh2.write(row3, inc(), "Flipkart")
691 
        sh2.write(row3, inc(), order.get("conversionStatus"))
 692 
        sh2.write(row3, inc(), order.get("conversionStatus"))
692 
        sh2.write(row3, inc(), order.get("productTitle"))
 693 
        sh2.write(row3, inc(), order.get("productTitle"))
693 
        sh2.write(row3, inc(), order.get("price"))
 694 
        sh2.write(row3, inc(), order.get("price"))
694 
        sh2.write(row3, inc(), order.get("quantity"))
 695 
        sh2.write(row3, inc(), order.get("quantity"))
695 
        skuData = getSkuData(morder.get("storeId"), subOrder.get("productCode"))
 696 
        skuData = getSkuData(2, order.get("productCode"))
696 
        if morder.get("storeId") in (1,2,4,5):
 - 
 
697 
            skuData = db1.MasterData.find_one({'identifier':subOrder.get("productCode").strip(), 'source_id':morder.get("storeId")})
 - 
 
698 
        if skuData is not None:
 697 
        if skuData is not None:
699 
            sh2.write(row3, inc(), skuData.get("skuBundleId"))
 698 
            sh2.write(row3, inc(), skuData.get("skuBundleId"))
700 
            sh2.write(row3, inc(), skuData.get("brand"))
 699 
            sh2.write(row3, inc(), skuData.get("brand"))
701 
            sh2.write(row3, inc(), skuData.get("model_name"))
 700 
            sh2.write(row3, inc(), skuData.get("model_name"))
702 
            sh2.write(row3, inc(), skuData.get("category"))
 701 
            sh2.write(row3, inc(), skuData.get("category"))