xuwang
/
cross_doctor
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修复路口管家巡检页面产品走查bug

This commit is contained in:
wangxu 2025-12-08 14:38:55 +08:00
parent f408b2dab1
commit f5236e2774
4 changed files with 11 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
app/compare_views.py
View File

@ -46,3 +46,8 @@ def rerun_cross_survey_part_api():
@app.route('/api/query_usable_survey_crosses', methods=['GET']) @app.route('/api/query_usable_survey_crosses', methods=['GET'])
def query_usable_survey_crosses_api(): def query_usable_survey_crosses_api():
return query_usable_survey_crosses(request.args) return query_usable_survey_crosses(request.args)
@app.route('/api/query_cross_survey_usable_dates', methods=['GET'])
def query_cross_survey_usable_dates_api():
return query_cross_survey_usable_dates(request.args)

4
app/cross_compare_worker.py
View File

@ -316,7 +316,7 @@ def query_usable_survey_crosses(params):
return json.dumps(make_common_res(5, '辖区id异常，请检查后重试')) return json.dumps(make_common_res(5, '辖区id异常，请检查后重试'))
area_servey_jobs = db_tmnet.query_survey_job_info_by_area_id(area_id) area_servey_jobs = db_tmnet.query_survey_job_info_by_area_id(area_id)
usable_crossid_list = list(set([job['crossid'] for job in area_servey_jobs.values()])) usable_crossid_list = list(set([job['crossid'] for job in area_servey_jobs]))
res_list = [] res_list = []
for crossid in usable_crossid_list: for crossid in usable_crossid_list:
cross_name = g_roadnet.query_cross(crossid).name cross_name = g_roadnet.query_cross(crossid).name
@ -360,7 +360,7 @@ def query_cross_survey_usable_dates(params):
end_day = row['update_time'].strftime('%Y%m%d') end_day = row['update_time'].strftime('%Y%m%d')
usable_info['job_info'].append({ usable_info['job_info'].append({
'jobid': row['id'], 'jobid': row['id'],
'time_range': start_day + '-' + end_day, 'time_range': str(start_day) + '-' + str(end_day),
}) })
res = make_common_res(0, 'ok') res = make_common_res(0, 'ok')
res['data'] = usable_info res['data'] = usable_info

1
app/db_func_base.py
View File

@ -75,6 +75,7 @@ class TableDbHelperBase:
logging.error(f"do_execute '{sql_update}' Error: {e}") logging.error(f"do_execute '{sql_update}' Error: {e}")
return 0 return 0
return ret return ret
def do_executemany(self, sql, data_list, cursor=None): def do_executemany(self, sql, data_list, cursor=None):
try: try:
logging.info(f"sql = {sql}, data_list = {data_list}") logging.info(f"sql = {sql}, data_list = {data_list}")

4
app/monitor_common.py
View File

@ -1715,12 +1715,12 @@ def gen_cross_problem_detail(routing_crosses, high_park_problems, too_many_stop_
phase_infos = phase_tp['problems'][crossid] phase_infos = phase_tp['problems'][crossid]
phase_list = [] phase_list = []
for item in phase_infos: for item in phase_infos:
if item['final_state_int'] in (4, 5):
continue
if item['level_color_int'] < phase_color: if item['level_color_int'] < phase_color:
phase_color = item['level_color_int'] phase_color = item['level_color_int']
if item['final_state_int'] < phase_final_state: if item['final_state_int'] < phase_final_state:
phase_final_state = item['final_state_int'] phase_final_state = item['final_state_int']
if item['final_state_int'] in (4, 5):
continue
item_desc = '【' + item['first_date'] + ' ' + item['time_range'] + '】' + item['level_color'] + '异常' item_desc = '【' + item['first_date'] + ' ' + item['time_range'] + '】' + item['level_color'] + '异常'
phase_list.append({ phase_list.append({
'desc': item_desc, 'desc': item_desc,