|
|
@@ -10,7 +10,7 @@ du=DateUtils()
|
|
|
|
|
|
|
|
|
def run(dt):
|
|
|
- sql=f"""SELECT a.dt,b.type,sum(a.cost),sum(view_count),sum(click_count),sum(follow_count),sum(order_count),sum(order_amount),
|
|
|
+ sql=f"""SELECT a.dt,b.type,count(*) as ct,sum(a.cost),sum(view_count),sum(click_count),sum(follow_count),sum(order_count),sum(order_amount),
|
|
|
title,description,book,platform,stage,e.channel,pitcher,ifnull(image_id,'')
|
|
|
from
|
|
|
ad_cost_day a
|
|
|
@@ -73,7 +73,7 @@ def run(dt):
|
|
|
i.append(height[1:])
|
|
|
|
|
|
# exit(0)
|
|
|
- sql_video = f"""SELECT a.dt,b.type,sum(a.cost),sum(view_count),sum(click_count),sum(follow_count),sum(order_count),sum(order_amount),
|
|
|
+ sql_video = f"""SELECT a.dt,b.type,count(*),sum(a.cost),sum(view_count),sum(click_count),sum(follow_count),sum(order_count),sum(order_amount),
|
|
|
title,description,book,platform,stage,e.channel,pitcher,ifnull(image_id,''),g.preview_url,g.signature,1,
|
|
|
g.width,g.height
|
|
|
from
|
|
|
@@ -92,7 +92,7 @@ def run(dt):
|
|
|
|
|
|
#进行数据存储
|
|
|
db.dm.execute(f'delete from dw_image_cost_day where dt="{dt}"')
|
|
|
- db.dm.executeMany("replace into dw_image_cost_day values (%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s)",data)
|
|
|
+ db.dm.executeMany("replace into dw_image_cost_day values (%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s)",data)
|
|
|
|
|
|
|
|
|
|
