renyupeng 3 年之前
父节点
当前提交
ed7d8cb3da

+ 23 - 23
Apietl/kwai_etl/Q4Task/AppKuaishouCampaignReportBusi.py

@@ -302,29 +302,29 @@ from
  group by advertiser_id,campaign_id,campaign_name) report
 LEFT JOIN (
 /{day_count}SELECT
-/{day_count}/{day_count}cua.account_id id,
-/{day_count}/{day_count}cua.account_id account_id,
-/{day_count}/{day_count}cp.id project_id,
-/{day_count}/{day_count}product.id product_id,
-/{day_count}/{day_count}ca.id advertiser_id,
-/{day_count}/{day_count}uc.company_id company_id,
-/{day_count}/{day_count}cua.auth_name account_name,
-/{day_count}/{day_count}cp.project_name project_name,
-/{day_count}/{day_count}ca.`name` advertiser_name,
-/{day_count}/{day_count}uc.company_name company_name,
-/{day_count}/{day_count}cp.sale_id sale_id,
-/{day_count}/{day_count}su.id user_id,
-/{day_count}/{day_count}su.leader_id,
-/{day_count}/{day_count}su.org_code org_code
-/{day_count}FROM
-/{day_count}/{day_count}`jeecg-boot`.ctop_user_allocation cua
-/{day_count}LEFT JOIN `jeecg-boot`.ctop_project cp ON cua.project_id = cp.id
-/{day_count}LEFT JOIN `jeecg-boot`.ctop_advertiser ca ON ca.id = cua.advertiser_id
-/{day_count}LEFT JOIN `jeecg-boot`.sys_user su ON su.id = cua.user_id
-/{day_count}LEFT JOIN `jeecg-boot`.user_company uc ON uc.user_id = cua.user_id
-/{day_count}LEFT JOIN `jeecg-boot`.ctop_product product ON product.id = cp.product_id
-/{day_count}WHERE
-/{day_count}/{day_count}cua.account_id IS NOT NULL) bei 
+cua.account_id id,
+cua.account_id account_id,
+cp.id project_id,
+product.id product_id,
+ca.id advertiser_id,
+uc.company_id company_id,
+cua.auth_name account_name,
+cp.project_name project_name,
+ca.`name` advertiser_name,
+uc.company_name company_name,
+cp.sale_id sale_id,
+su.id user_id,
+su.leader_id,
+su.org_code org_code
+FROM
+`jeecg-boot`.ctop_user_allocation cua
+LEFT JOIN `jeecg-boot`.ctop_project cp ON cua.project_id = cp.id
+LEFT JOIN `jeecg-boot`.ctop_advertiser ca ON ca.id = cua.advertiser_id
+LEFT JOIN `jeecg-boot`.sys_user su ON su.id = cua.user_id
+LEFT JOIN `jeecg-boot`.user_company uc ON uc.user_id = cua.user_id
+LEFT JOIN `jeecg-boot`.ctop_product product ON product.id = cp.product_id
+WHERE
+cua.account_id IS NOT NULL) bei 
 ON report.account_id = bei.account_id;
 """.format(date_time=self.date_time, day_count=self.day_count)
             TidbConn.upsert(conn=self.conn, sql_buff=sql)

+ 24 - 25
Apietl/kwai_etl/Q4Task/AppKuaishouCampaignReportBusiMonth.py

@@ -23,7 +23,6 @@ class AppKuaishouCampaignReportBusiMonth:
         try:
             sql = """#插入数据
 SET sql_mode = 'STRICT_TRANS_TABLES,NO_ZERO_IN_DATE,NO_ZERO_DATE,NO_AUTO_CREATE_USER,NO_ENGINE_SUBSTITUTION';
-
 REPLACE INTO app_kuaishou_campaign_report_busi_m
 SELECT
 date_format({date_time},'%Y%m') as stat_mon,
@@ -302,30 +301,30 @@ from
  where stat_date >= date_format(date_sub({date_time}, INTERVAL {day_count}  DAY),'%Y%m%d')
  group by advertiser_id,campaign_id,campaign_name) report
 LEFT JOIN (
-/{day_count}SELECT
-/{day_count}/{day_count}cua.account_id id,
-/{day_count}/{day_count}cua.account_id account_id,
-/{day_count}/{day_count}cp.id project_id,
-/{day_count}/{day_count}product.id product_id,
-/{day_count}/{day_count}ca.id advertiser_id,
-/{day_count}/{day_count}uc.company_id company_id,
-/{day_count}/{day_count}cua.auth_name account_name,
-/{day_count}/{day_count}cp.project_name project_name,
-/{day_count}/{day_count}ca.`name` advertiser_name,
-/{day_count}/{day_count}uc.company_name company_name,
-/{day_count}/{day_count}cp.sale_id sale_id,
-/{day_count}/{day_count}su.id user_id,
-/{day_count}/{day_count}su.leader_id,
-/{day_count}/{day_count}su.org_code org_code
-/{day_count}FROM
-/{day_count}/{day_count}`jeecg-boot`.ctop_user_allocation cua
-/{day_count}LEFT JOIN `jeecg-boot`.ctop_project cp ON cua.project_id = cp.id
-/{day_count}LEFT JOIN `jeecg-boot`.ctop_advertiser ca ON ca.id = cua.advertiser_id
-/{day_count}LEFT JOIN `jeecg-boot`.sys_user su ON su.id = cua.user_id
-/{day_count}LEFT JOIN `jeecg-boot`.user_company uc ON uc.user_id = cua.user_id
-/{day_count}LEFT JOIN `jeecg-boot`.ctop_product product ON product.id = cp.product_id
-/{day_count}WHERE
-/{day_count}/{day_count}cua.account_id IS NOT NULL) bei 
+SELECT
+cua.account_id id,
+cua.account_id account_id,
+cp.id project_id,
+product.id product_id,
+ca.id advertiser_id,
+uc.company_id company_id,
+cua.auth_name account_name,
+cp.project_name project_name,
+ca.`name` advertiser_name,
+uc.company_name company_name,
+cp.sale_id sale_id,
+su.id user_id,
+su.leader_id,
+su.org_code org_code
+FROM
+`jeecg-boot`.ctop_user_allocation cua
+LEFT JOIN `jeecg-boot`.ctop_project cp ON cua.project_id = cp.id
+LEFT JOIN `jeecg-boot`.ctop_advertiser ca ON ca.id = cua.advertiser_id
+LEFT JOIN `jeecg-boot`.sys_user su ON su.id = cua.user_id
+LEFT JOIN `jeecg-boot`.user_company uc ON uc.user_id = cua.user_id
+LEFT JOIN `jeecg-boot`.ctop_product product ON product.id = cp.product_id
+WHERE
+cua.account_id IS NOT NULL) bei 
 ON report.account_id = bei.account_id;
 """.format(date_time=self.date_time, day_count=self.day_count)
             TidbConn.upsert(conn=self.conn, sql_buff=sql)