|
|
@@ -72,12 +72,17 @@ def _process_one_task(row):
|
|
|
|
|
|
drop_price_change_upper = float(task.get("drop_price_change_upper") or 0) # 最小的降价幅度
|
|
|
max_threshold = round(drop_price_change_upper * 1.0)
|
|
|
+ max_threshold = max_threshold + 20
|
|
|
|
|
|
- if abs(max_threshold) < 10: # 丢弃小于10人民币的降价幅度
|
|
|
+ if max_threshold > 0 or abs(max_threshold) < 10: # 丢弃小于10人民币的降价幅度
|
|
|
return None
|
|
|
|
|
|
drop_price_sample_size = int(task.get("drop_price_sample_size", "0"))
|
|
|
- if drop_price_sample_size < 2: # 丢弃历史降价样本数过少(小于2)的
|
|
|
+ if drop_price_sample_size < 3: # 丢弃历史降价样本数过少(小于3)的
|
|
|
+ return None
|
|
|
+
|
|
|
+ from_date = task.get("from_date")
|
|
|
+ if from_date in ['2026-04-28', '2026-04-29', '2026-04-30', '2026-05-01', '2026-05-05']: # 丢弃特殊起飞日期的
|
|
|
return None
|
|
|
|
|
|
end_segments = []
|
node04