diff --git a/app/flow_worker.py b/app/flow_worker.py index 6712da8..368baf9 100644 --- a/app/flow_worker.py +++ b/app/flow_worker.py @@ -135,7 +135,7 @@ def cross_flow_tp_divide(params): res['data']['flow_data'].append({ "flow": round(flow_list[i], 2), "tp": time_str, - "recommend": recommend_tp.get(time_str, 0) + "recommend": 1 if recommend_tp.get(time_str) and time_str != '00:00' else 0 }) current_time += timedelta(minutes=15)