|
|
@@ -512,11 +512,16 @@ def _process_one_task(row, runner):
|
|
|
# return None
|
|
|
|
|
|
max_threshold = round(drop_price_change_upper * runner.rate * 1.0) # 降价阈值要按汇率转人民币（四舍五入到整数）
|
|
|
- if abs(max_threshold) < 10: # 丢弃小于10人民币的降价幅度
|
|
|
+ max_threshold = max_threshold + 20
|
|
|
+ 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
|
|
|
+
|
|
|
+ flight_day = task.get("flight_day")
|
|
|
+ if flight_day in ['2026-04-28', '2026-04-29', '2026-04-30', '2026-05-01', '2026-05-05']: # 丢弃特殊起飞日期的
|
|
|
return None
|
|
|
|
|
|
time.sleep(1)
|
node04