| Line 12... |
Line 12... |
| 12 |
from shop2020.thriftpy.model.v1.order.ttypes import OrderStatus
|
12 |
from shop2020.thriftpy.model.v1.order.ttypes import OrderStatus
|
| 13 |
from shop2020.model.v1.order.impl.DataService import Order
|
13 |
from shop2020.model.v1.order.impl.DataService import Order
|
| 14 |
from datetime import date, timedelta
|
14 |
from datetime import date, timedelta
|
| 15 |
from elixir import *
|
15 |
from elixir import *
|
| 16 |
from sqlalchemy.sql.expression import and_, or_, desc, not_, distinct, cast, between
|
16 |
from sqlalchemy.sql.expression import and_, or_, desc, not_, distinct, cast, between
|
| - |
|
17 |
from sqlalchemy.sql import func
|
| - |
|
18 |
from sqlalchemy.sql.expression import text
|
| 17 |
from shop2020.thriftpy.crm.ttypes import *
|
19 |
from shop2020.thriftpy.crm.ttypes import *
|
| 18 |
from shop2020.clients.HelperClient import HelperClient
|
20 |
from shop2020.clients.HelperClient import HelperClient
|
| 19 |
|
21 |
|
| 20 |
import datetime
|
22 |
import datetime
|
| 21 |
|
23 |
|
| Line 26... |
Line 28... |
| 26 |
DataService.initialize('transaction','192.168.190.114')
|
28 |
DataService.initialize('transaction','192.168.190.114')
|
| 27 |
crm_client = CRMClient().get_client()
|
29 |
crm_client = CRMClient().get_client()
|
| 28 |
current_time = datetime.datetime.now().date()
|
30 |
current_time = datetime.datetime.now().date()
|
| 29 |
time_start= current_time - datetime.timedelta(days=16)
|
31 |
time_start= current_time - datetime.timedelta(days=16)
|
| 30 |
time_end = time_start + datetime.timedelta(days=1)
|
32 |
time_end = time_start + datetime.timedelta(days=1)
|
| 31 |
mfn_orders = Order.query.filter(Order.source == 3).filter((Order.status == OrderStatus.DELIVERY_SUCCESS)).filter(Order.delivery_timestamp.between (time_start,time_end)).filter(Order.delivery_timestamp <= Order.promised_delivery_time)
|
33 |
mfn_orders = Order.query.filter(Order.source == 3).filter((Order.status == OrderStatus.DELIVERY_SUCCESS)).filter(Order.delivery_timestamp.between (time_start,time_end)).filter(Order.delivery_timestamp <= func.timestampadd(text('day'),1,Order.promised_delivery_time))
|
| 32 |
|
34 |
|
| 33 |
for order in mfn_orders:
|
35 |
for order in mfn_orders:
|
| 34 |
searchFilter = SearchFilter()
|
36 |
searchFilter = SearchFilter()
|
| 35 |
searchFilter.customerEmailId = order.customer_email
|
37 |
searchFilter.customerEmailId = order.customer_email
|
| 36 |
|
38 |
|