|
@@ -36,7 +36,7 @@ def get_odps_data(sql):
|
|
|
def get_demand_merge_level2_names():
|
|
def get_demand_merge_level2_names():
|
|
|
date_time = datetime.now(ZoneInfo("Asia/Shanghai")).date() - timedelta(days=1)
|
|
date_time = datetime.now(ZoneInfo("Asia/Shanghai")).date() - timedelta(days=1)
|
|
|
day = date_time.strftime("%Y%m%d")
|
|
day = date_time.strftime("%Y%m%d")
|
|
|
- count = 500
|
|
|
|
|
|
|
+ count = 50
|
|
|
sql_query = f'''
|
|
sql_query = f'''
|
|
|
select *
|
|
select *
|
|
|
from (
|
|
from (
|
|
@@ -99,13 +99,13 @@ where t1.缺量>= {count}
|
|
|
if lack_count > 1000:
|
|
if lack_count > 1000:
|
|
|
count = 70
|
|
count = 70
|
|
|
elif 500 < lack_count <= 1000:
|
|
elif 500 < lack_count <= 1000:
|
|
|
- count = 50
|
|
|
|
|
|
|
+ count = 60
|
|
|
elif 100 < lack_count <= 500:
|
|
elif 100 < lack_count <= 500:
|
|
|
- count = 30
|
|
|
|
|
|
|
+ count = 40
|
|
|
elif 50 < lack_count <= 100:
|
|
elif 50 < lack_count <= 100:
|
|
|
- count = 10
|
|
|
|
|
|
|
+ count = 20
|
|
|
else:
|
|
else:
|
|
|
- count = 0
|
|
|
|
|
|
|
+ count = 10
|
|
|
if count == 0:
|
|
if count == 0:
|
|
|
continue
|
|
continue
|
|
|
result_list.append({
|
|
result_list.append({
|