|
|
@@ -174,69 +174,69 @@ def dw_channel_amount_daily():
|
|
|
sql="""
|
|
|
select toDate(formatDateTime(reg_time,'%Y-%m-%d')) as dt,
|
|
|
channel as channel,
|
|
|
- sum(if(subtractDays(date, 1)>=reg_time,0,amount)) as da1,
|
|
|
- sum(if(subtractDays(date, 2)>=reg_time,0,amount)) as da2,
|
|
|
- sum(if(subtractDays(date, 3)>=reg_time,0,amount)) as da3,
|
|
|
- sum(if(subtractDays(date, 4)>=reg_time,0,amount)) as da4,
|
|
|
- sum(if(subtractDays(date, 5)>=reg_time,0,amount)) as da5,
|
|
|
- sum(if(subtractDays(date, 6)>=reg_time,0,amount)) as da6,
|
|
|
- sum(if(subtractDays(date, 7)>=reg_time,0,amount)) as da7,
|
|
|
- sum(if(subtractDays(date, 8)>=reg_time,0,amount)) as da8,
|
|
|
- sum(if(subtractDays(date, 9)>=reg_time,0,amount)) as da9,
|
|
|
- sum(if(subtractDays(date, 10)>=reg_time,0,amount)) as da10,
|
|
|
- sum(if(subtractDays(date, 11)>=reg_time,0,amount)) as da11,
|
|
|
- sum(if(subtractDays(date, 12)>=reg_time,0,amount)) as da12,
|
|
|
- sum(if(subtractDays(date, 13)>=reg_time,0,amount)) as da13,
|
|
|
- sum(if(subtractDays(date, 14)>=reg_time,0,amount)) as da14,
|
|
|
- sum(if(subtractDays(date, 15)>=reg_time,0,amount)) as da15,
|
|
|
- sum(if(subtractDays(date, 16)>=reg_time,0,amount)) as da16,
|
|
|
- sum(if(subtractDays(date, 17)>=reg_time,0,amount)) as da17,
|
|
|
- sum(if(subtractDays(date, 18)>=reg_time,0,amount)) as da18,
|
|
|
- sum(if(subtractDays(date, 19)>=reg_time,0,amount)) as da19,
|
|
|
- sum(if(subtractDays(date, 20)>=reg_time,0,amount)) as da20,
|
|
|
- sum(if(subtractDays(date, 21)>=reg_time,0,amount)) as da21,
|
|
|
- sum(if(subtractDays(date, 22)>=reg_time,0,amount)) as da22,
|
|
|
- sum(if(subtractDays(date, 23)>=reg_time,0,amount)) as da23,
|
|
|
- sum(if(subtractDays(date, 24)>=reg_time,0,amount)) as da24,
|
|
|
- sum(if(subtractDays(date, 25)>=reg_time,0,amount)) as da25,
|
|
|
- sum(if(subtractDays(date, 26)>=reg_time,0,amount)) as da26,
|
|
|
- sum(if(subtractDays(date, 27)>=reg_time,0,amount)) as da27,
|
|
|
- sum(if(subtractDays(date, 28)>=reg_time,0,amount)) as da28,
|
|
|
- sum(if(subtractDays(date, 29)>=reg_time,0,amount)) as da29,
|
|
|
- sum(if(subtractDays(date, 30)>=reg_time,0,amount)) as da30,
|
|
|
- sum(if(subtractDays(date, 31)>=reg_time,0,amount)) as da31,
|
|
|
- sum(if(subtractDays(date, 32)>=reg_time,0,amount)) as da32,
|
|
|
- sum(if(subtractDays(date, 33)>=reg_time,0,amount)) as da33,
|
|
|
- sum(if(subtractDays(date, 34)>=reg_time,0,amount)) as da34,
|
|
|
- sum(if(subtractDays(date, 35)>=reg_time,0,amount)) as da35,
|
|
|
- sum(if(subtractDays(date, 36)>=reg_time,0,amount)) as da36,
|
|
|
- sum(if(subtractDays(date, 37)>=reg_time,0,amount)) as da37,
|
|
|
- sum(if(subtractDays(date, 38)>=reg_time,0,amount)) as da38,
|
|
|
- sum(if(subtractDays(date, 39)>=reg_time,0,amount)) as da39,
|
|
|
- sum(if(subtractDays(date, 40)>=reg_time,0,amount)) as da40,
|
|
|
- sum(if(subtractDays(date, 41)>=reg_time,0,amount)) as da41,
|
|
|
- sum(if(subtractDays(date, 42)>=reg_time,0,amount)) as da42,
|
|
|
- sum(if(subtractDays(date, 43)>=reg_time,0,amount)) as da43,
|
|
|
- sum(if(subtractDays(date, 44)>=reg_time,0,amount)) as da44,
|
|
|
- sum(if(subtractDays(date, 45)>=reg_time,0,amount)) as da45,
|
|
|
- sum(if(subtractDays(date, 46)>=reg_time,0,amount)) as da46,
|
|
|
- sum(if(subtractDays(date, 47)>=reg_time,0,amount)) as da47,
|
|
|
- sum(if(subtractDays(date, 48)>=reg_time,0,amount)) as da48,
|
|
|
- sum(if(subtractDays(date, 49)>=reg_time,0,amount)) as da49,
|
|
|
- sum(if(subtractDays(date, 50)>=reg_time,0,amount)) as da50,
|
|
|
- sum(if(subtractDays(date, 51)>=reg_time,0,amount)) as da51,
|
|
|
- sum(if(subtractDays(date, 52)>=reg_time,0,amount)) as da52,
|
|
|
- sum(if(subtractDays(date, 53)>=reg_time,0,amount)) as da53,
|
|
|
- sum(if(subtractDays(date, 54)>=reg_time,0,amount)) as da54,
|
|
|
- sum(if(subtractDays(date, 55)>=reg_time,0,amount)) as da55,
|
|
|
- sum(if(subtractDays(date, 56)>=reg_time,0,amount)) as da56,
|
|
|
- sum(if(subtractDays(date, 57)>=reg_time,0,amount)) as da57,
|
|
|
- sum(if(subtractDays(date, 58)>=reg_time,0,amount)) as da58,
|
|
|
- sum(if(subtractDays(date, 59)>=reg_time,0,amount)) as da59,
|
|
|
- sum(if(subtractDays(date, 60)>=reg_time,0,amount)) as da60,
|
|
|
- sum(if(subtractDays(date, 90)>=reg_time,0,amount)) as dm3,
|
|
|
- sum(if(subtractDays(date, 120)>=reg_time,0,amount)) as dm4,
|
|
|
- sum(if(subtractDays(date, 150)>=reg_time,0,amount)) as dm5
|
|
|
+ sum(if(subtractDays(date, 1)>=toDate(reg_time),0,amount)) as da1,
|
|
|
+ sum(if(subtractDays(date, 2)>=toDate(reg_time),0,amount)) as da2,
|
|
|
+ sum(if(subtractDays(date, 3)>=toDate(reg_time),0,amount)) as da3,
|
|
|
+ sum(if(subtractDays(date, 4)>=toDate(reg_time),0,amount)) as da4,
|
|
|
+ sum(if(subtractDays(date, 5)>=toDate(reg_time),0,amount)) as da5,
|
|
|
+ sum(if(subtractDays(date, 6)>=toDate(reg_time),0,amount)) as da6,
|
|
|
+ sum(if(subtractDays(date, 7)>=toDate(reg_time),0,amount)) as da7,
|
|
|
+ sum(if(subtractDays(date, 8)>=toDate(reg_time),0,amount)) as da8,
|
|
|
+ sum(if(subtractDays(date, 9)>=toDate(reg_time),0,amount)) as da9,
|
|
|
+ sum(if(subtractDays(date, 10)>=toDate(reg_time),0,amount)) as da10,
|
|
|
+ sum(if(subtractDays(date, 11)>=toDate(reg_time),0,amount)) as da11,
|
|
|
+ sum(if(subtractDays(date, 12)>=toDate(reg_time),0,amount)) as da12,
|
|
|
+ sum(if(subtractDays(date, 13)>=toDate(reg_time),0,amount)) as da13,
|
|
|
+ sum(if(subtractDays(date, 14)>=toDate(reg_time),0,amount)) as da14,
|
|
|
+ sum(if(subtractDays(date, 15)>=toDate(reg_time),0,amount)) as da15,
|
|
|
+ sum(if(subtractDays(date, 16)>=toDate(reg_time),0,amount)) as da16,
|
|
|
+ sum(if(subtractDays(date, 17)>=toDate(reg_time),0,amount)) as da17,
|
|
|
+ sum(if(subtractDays(date, 18)>=toDate(reg_time),0,amount)) as da18,
|
|
|
+ sum(if(subtractDays(date, 19)>=toDate(reg_time),0,amount)) as da19,
|
|
|
+ sum(if(subtractDays(date, 20)>=toDate(reg_time),0,amount)) as da20,
|
|
|
+ sum(if(subtractDays(date, 21)>=toDate(reg_time),0,amount)) as da21,
|
|
|
+ sum(if(subtractDays(date, 22)>=toDate(reg_time),0,amount)) as da22,
|
|
|
+ sum(if(subtractDays(date, 23)>=toDate(reg_time),0,amount)) as da23,
|
|
|
+ sum(if(subtractDays(date, 24)>=toDate(reg_time),0,amount)) as da24,
|
|
|
+ sum(if(subtractDays(date, 25)>=toDate(reg_time),0,amount)) as da25,
|
|
|
+ sum(if(subtractDays(date, 26)>=toDate(reg_time),0,amount)) as da26,
|
|
|
+ sum(if(subtractDays(date, 27)>=toDate(reg_time),0,amount)) as da27,
|
|
|
+ sum(if(subtractDays(date, 28)>=toDate(reg_time),0,amount)) as da28,
|
|
|
+ sum(if(subtractDays(date, 29)>=toDate(reg_time),0,amount)) as da29,
|
|
|
+ sum(if(subtractDays(date, 30)>=toDate(reg_time),0,amount)) as da30,
|
|
|
+ sum(if(subtractDays(date, 31)>=toDate(reg_time),0,amount)) as da31,
|
|
|
+ sum(if(subtractDays(date, 32)>=toDate(reg_time),0,amount)) as da32,
|
|
|
+ sum(if(subtractDays(date, 33)>=toDate(reg_time),0,amount)) as da33,
|
|
|
+ sum(if(subtractDays(date, 34)>=toDate(reg_time),0,amount)) as da34,
|
|
|
+ sum(if(subtractDays(date, 35)>=toDate(reg_time),0,amount)) as da35,
|
|
|
+ sum(if(subtractDays(date, 36)>=toDate(reg_time),0,amount)) as da36,
|
|
|
+ sum(if(subtractDays(date, 37)>=toDate(reg_time),0,amount)) as da37,
|
|
|
+ sum(if(subtractDays(date, 38)>=toDate(reg_time),0,amount)) as da38,
|
|
|
+ sum(if(subtractDays(date, 39)>=toDate(reg_time),0,amount)) as da39,
|
|
|
+ sum(if(subtractDays(date, 40)>=toDate(reg_time),0,amount)) as da40,
|
|
|
+ sum(if(subtractDays(date, 41)>=toDate(reg_time),0,amount)) as da41,
|
|
|
+ sum(if(subtractDays(date, 42)>=toDate(reg_time),0,amount)) as da42,
|
|
|
+ sum(if(subtractDays(date, 43)>=toDate(reg_time),0,amount)) as da43,
|
|
|
+ sum(if(subtractDays(date, 44)>=toDate(reg_time),0,amount)) as da44,
|
|
|
+ sum(if(subtractDays(date, 45)>=toDate(reg_time),0,amount)) as da45,
|
|
|
+ sum(if(subtractDays(date, 46)>=toDate(reg_time),0,amount)) as da46,
|
|
|
+ sum(if(subtractDays(date, 47)>=toDate(reg_time),0,amount)) as da47,
|
|
|
+ sum(if(subtractDays(date, 48)>=toDate(reg_time),0,amount)) as da48,
|
|
|
+ sum(if(subtractDays(date, 49)>=toDate(reg_time),0,amount)) as da49,
|
|
|
+ sum(if(subtractDays(date, 50)>=toDate(reg_time),0,amount)) as da50,
|
|
|
+ sum(if(subtractDays(date, 51)>=toDate(reg_time),0,amount)) as da51,
|
|
|
+ sum(if(subtractDays(date, 52)>=toDate(reg_time),0,amount)) as da52,
|
|
|
+ sum(if(subtractDays(date, 53)>=toDate(reg_time),0,amount)) as da53,
|
|
|
+ sum(if(subtractDays(date, 54)>=toDate(reg_time),0,amount)) as da54,
|
|
|
+ sum(if(subtractDays(date, 55)>=toDate(reg_time),0,amount)) as da55,
|
|
|
+ sum(if(subtractDays(date, 56)>=toDate(reg_time),0,amount)) as da56,
|
|
|
+ sum(if(subtractDays(date, 57)>=toDate(reg_time),0,amount)) as da57,
|
|
|
+ sum(if(subtractDays(date, 58)>=toDate(reg_time),0,amount)) as da58,
|
|
|
+ sum(if(subtractDays(date, 59)>=toDate(reg_time),0,amount)) as da59,
|
|
|
+ sum(if(subtractDays(date, 60)>=toDate(reg_time),0,amount)) as da60,
|
|
|
+ sum(if(subtractDays(date, 90)>=toDate(reg_time),0,amount)) as dm3,
|
|
|
+ sum(if(subtractDays(date, 120)>=toDate(reg_time),0,amount)) as dm4,
|
|
|
+ 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," \
|
|
|
@@ -254,4 +254,5 @@ def dw_channel():
|
|
|
if __name__ == '__main__':
|
|
|
|
|
|
# dw_daily_channel()
|
|
|
- dw_channel()
|
|
|
+ # dw_channel()
|
|
|
+ dw_channel_amount_daily()
|
