|
|
@@ -124,7 +124,8 @@ left outer join
|
|
|
having order_amount+cost+reg_order_amount>0"""
|
|
|
|
|
|
data=ck.execute(sql)
|
|
|
- isql="replace into dw_channel values (%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s)"
|
|
|
+ isql="insert into dw_channel values (%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s)"
|
|
|
+ db.dm.execute("truncate table dw_channel")
|
|
|
db.dm.executeMany(isql,data)
|
|
|
|
|
|
def dw_channel_user_daily():
|
|
|
@@ -164,10 +165,11 @@ select toDate(formatDateTime(reg_time,'%Y-%m-%d')) as dt,
|
|
|
from order where reg_time>'2019-03-18 00:00:00' group by toDate(formatDateTime(reg_time,'%Y-%m-%d')),channel"""
|
|
|
|
|
|
data =ck.execute(sql)
|
|
|
- isql="replace into dw_channel_user_daily values " \
|
|
|
+ isql="insert into dw_channel_user_daily values " \
|
|
|
"(%s,%s,%s,%s,%s,%s,%s,%s,%s,%s," \
|
|
|
"%s,%s,%s,%s,%s,%s,%s,%s,%s,%s," \
|
|
|
"%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s)"
|
|
|
+ db.dm.execute("truncate table dw_channel_user_daily")
|
|
|
db.dm.executeMany(isql,data)
|
|
|
|
|
|
def dw_channel_amount_daily():
|
|
|
@@ -239,9 +241,9 @@ def dw_channel_amount_daily():
|
|
|
sum(if(subtractDays(date, 150)>=toDate(reg_time),0,amount)) as dm5
|
|
|
from order where reg_time>'2019-03-18 00:00:00' group by toDate(formatDateTime(reg_time,'%Y-%m-%d')),channel"""
|
|
|
data=ck.execute(sql)
|
|
|
- isql="replace into dw_channel_amount_daily values (%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s," \
|
|
|
+ isql="insert into dw_channel_amount_daily values (%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s," \
|
|
|
"%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s)"
|
|
|
-
|
|
|
+ db.dm.execute("truncate table dw_channel_amount_daily")
|
|
|
db.dm.executeMany(isql,data)
|
|
|
|
|
|
|
