renyupeng 3 tahun lalu
induk
melakukan
eca6d0192f

+ 8 - 6
Apietl/bytedance_etl/Q4Task/AppBytedanceAdReportBusiMonth.py

@@ -21,10 +21,10 @@ class AppBytedanceAdReportBusiMonth:
 
     def taskHandler(self):
         try:
-            sql_porject = """select project_id from `jeecg-boot`.ctop_user_allocation where media_id=1
-group by project_id """
-            project_list = TidbConn.quary(self.conn, sql_porject)
-            for project_id in project_list:
+            sql_porject = """select account_id from `jeecg-boot`.ctop_user_allocation where media_id=1
+group by account_id """
+            account_list = TidbConn.quary(self.conn, sql_porject)
+            for account_id in account_list:
                 try:
                     sql = """SET sql_mode = 'STRICT_TRANS_TABLES,NO_ZERO_IN_DATE,NO_ZERO_DATE,NO_AUTO_CREATE_USER,NO_ENGINE_SUBSTITUTION';
                     REPLACE INTO application.app_bytedance_ad_report_busi_m 
@@ -540,6 +540,7 @@ group by project_id """
                         date_sub({date_time}, INTERVAL {day_count} DAY),
                         '%Y%m%d'
                        )
+                       and advertiser_id = {account_id}
                       GROUP BY
                     advertiser_id,
                     campaign_id,
@@ -571,9 +572,10 @@ group by project_id """
                      LEFT JOIN `jeecg-boot`.ctop_product product ON product.id = cp.product_id
                      WHERE
                       cua.account_id IS NOT NULL
+                       where cua.account_id={account_id}
                     ) bei ON report.account_id = bei.account_id
-                    where bei.project_id={project_id}""".format(date_time=self.date_time,
-                                                                day_count=self.day_count, project_id=project_id[0])
+                   """.format(date_time=self.date_time,
+                              day_count=self.day_count, account_id=account_id[0])
                     print(sql)
                     TidbConn.upsert(conn=self.conn, sql_buff=sql)
                     self.conn.commit()