renyupeng 3 سال پیش
والد
کامیت
529b539ca8
1فایلهای تغییر یافته به همراه5 افزوده شده و 1 حذف شده
  1. 5 1
      Apietl/bytedance_etl/Q4Task/AppBytedanceImageReportBusi.py

+ 5 - 1
Apietl/bytedance_etl/Q4Task/AppBytedanceImageReportBusi.py

@@ -629,7 +629,8 @@ FROM (
                   image_mode,
                   inventory
      ) report
-        LEFT JOIN (select advertiser_id,signature,material_id,filename,image_url from  `media_api`.bytedance_file_image_get group by advertiser_id,signature,material_id,filename,image_url)  video 
+        LEFT JOIN (select advertiser_id,signature,material_id,filename,image_url
+from  `media_api`.bytedance_file_image_get group by advertiser_id,signature,material_id,filename,image_url)  video 
 ON report.account_id = video.advertiser_id AND report.material_id = video.material_id
           LEFT JOIN `jeecg-boot`.ctop_user_allocation cua
                    ON report.account_id = cua.account_id
@@ -643,7 +644,10 @@ ON report.account_id = video.advertiser_id AND report.material_id = video.materi
                    ON cp.product_id = product.id
          LEFT JOIN `jeecg-boot`.sys_user su
                    ON cua.user_id = su.id
+       .where cua.project_id={project_id}            
+                   
 """.format(date_time=self.date_time, day_count=self.day_count, project_id=project_id[0])
+                    print(sql)
                     TidbConn.upsert(conn=self.conn, sql_buff=sql)
                     self.conn.commit()
                 except Exception as e: