-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathmapmatch_interactive.py
executable file
·200 lines (181 loc) · 8.05 KB
/
mapmatch_interactive.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
"""Test mapmatch."""
import csv
import os
import time
import copy
import errno
from pprint import pprint
import asap_orcycle as asap
import stats
import pg_tools_orcycle as pg
import orcycle_gps
import web_mapping as wm
import json
def gmap(gps, route, gmap_path, case, trip_id, srid=4326, nextmap=None):
"""Write a google map html file with points and route."""
# create output dir if not exists
try:
os.makedirs(gmap_path + str(trip_id))
except OSError as exception:
if exception.errno != errno.EEXIST:
raise
gmap_file = gmap_path + trip_id + '/' + str(case) + '.html'
if nextmap:
nextmap = str(nextmap) + '.html'
extent = gps.get_extent()
gmap = wm.Gmap((extent[1] + extent[3]) / 2.0,
(extent[0] + extent[2]) / 2.0, 17)
points = gps.points
start = True
for p in points:
if p.kwargs.get('trip', -999) == case:
if start:
gmap.addpoint(p.lat, p.lng, color='#009933', radius=3)
start = False
else:
gmap.addpoint(p.lat, p.lng)
elif p.kwargs.get('trip'):
gmap.addpoint(p.lat, p.lng, color='#808080')
else:
gmap.addpoint(p.lat, p.lng, color='#FFFFFF')
if route:
lines = pg.LineCollection(srid=srid, lines=route.links[:])
lines.get_geom(db_conn, vertices=True)
lines.transform(4326, db_conn)
for line in lines.lines:
path = [(y,x) for x, y in line.vertices]
gmap.addpath(path)
gmap.draw(gmap_file, extent, title=case, next=nextmap)
print ('gmap output written to {}'
.format(gmap_file, tripnum))
#### USER SETTINGS ####
with open('/Users/bblanc/OneDrive/_BikeAppProject/ORcycle_Analysis_Tool_Suite/mapMatch_Broach/userSettings.json') as data_file:
userSettings = json.load(data_file)
working_directory = userSettings["working_directory"]
db_pass = userSettings["db_credentials"]["db_pass"]
db_user = userSettings["db_credentials"]["db_user"]
db_name = userSettings["db_credentials"]["db_name"]
db_schema = userSettings["db_credentials"]["db_schema"]
gps_path = 'data/coordsForMatch.csv' # relative path to GPS points csv file
## Network settings
net_schema = 'data' # network schema
net_table = 'wbnet2012' # network table
net_sql = 'bik_rest != 1 and inpdx = 1' # (optional) body of SQL where clause to select network links
# Ex) 'bik_rest != 1' or '' to omit
## Map match parameters
max_candidates = 20 # [40] number of unique route candidates to track
# lower increases speed at expense of accuracy
# 20-40 seems to be a reasonable range
max_radius = 1000 # [1000] maximum radius to search for initial link
# candidates. Little downside to larger search
# radius and can help if trip start is noisy.
initial_candidates = 25 # [25] target number of initial candidates.
# Radius will expand until either this number
# or max_radius reached
max_angle_flags = 999 # [2] Number of angle flags (heading perpendicular to
# link) before link abandoned. Set to 999 to ignore
# headings. Angle flags can be problematic if signal
# is noisy. Worth experimenting.
max_dist_ratio = 1.05 # [1.05] Max GPS distance/link distance before link
# abandoned. Has only small effect in our tests.
# Reasonable range is 1.0-1.25
## Output settings
gmap_output = True # Output html google maps in specified directory
# Files will be named by caseid unless path ends
# with .html, in which case file will be overwritten
# each time (good for manual mod debugging).
gmap_path = ('C:/Users/Bryan/OneDrive/_BikeAppProject/_MapMatching/ORcycle_archive/ORcycle/maps/') # path to write gmap files
# if path ends in .html,
# file will overwrite each
# time
psql_output = True # Append route and link results to existing psql tables
db_conn = pg.db_conn({'user': db_user, 'pass': db_pass,
'db': db_name})
print 'Loading network...'
network = pg.Network(db_conn, net_schema + '.' + net_table,
length_attr='length_m', id_attr='psuid',
sql=net_sql, geom_attr='geom')
print 'Loading data...'
d = asap.Deployment(None, None, num=1,
gps=(gps_path, orcycle_gps),
astable_gps='trip_id')
index = 1
trip_id = None
while True:
while trip_id not in d.gps:
trip_id = raw_input('trip_id: ')
#print pid
gps = d.gps[trip_id]
print '{} points loaded'.format(len(gps.points))
print 'Reprojecting...'
gps.get_geom2(db_conn)
gps.transform2(2838, db_conn)
print 'Screening...'
# For now, this is in same units as GPS file
gps.screen(max_spd=40, max_accel=10, min_altitude=-100,
max_altitude=9999, min_spd=0.45, debug=True)
print 'Masking...'
gps.mask(db_conn)
gps.get_accel()
gps.split_trips(deploy_start=None, min_trip_pts=10,
max_time_gap=300,
num_near_points=30, search_radius=15,
min_bundle_density=10.0, min_bundle_ratio=2.0/3.0,
min_bundle_time=120, sequence_length=15,
max_time_zero_spd=120, zero_spd=0.01,
attribute_points=True, debug=False)
print '{} trips detected'.format(len(gps.trips))
gps4326 = pg.GPSCollection(srid=2838,
points=[copy.copy(p) for p in gps.points])
gps4326.get_geom2(db_conn)
gps4326.transform2(4326, db_conn)
tripnum = 1
for trip in gps.trips:
trip.get_stats()
# Hack to keep track of original and split trip nums
trip.kwargs['trip_id'] = trip_id
trip.num = tripnum
trip.gps.get_geom2(db_conn)
print 'Map matching {} of {}...'.format(tripnum, len(gps.trips))
t1 = time.time()
m = pg.MapMatch(db_conn, trip.gps, network, check=False)
route = m.solve(max_radius=max_radius, max_dist_ratio=max_dist_ratio,
initial_candidates=25, max_candidates=20,
u_turn=False, max_angle_flags=999, oneway_wt=0.0,
attribute_points=False, min_match_links=2,
max_route_aps=75, max_link_mps=75, max_odd_links=3,
fallback='gps', pos_tol=0.001)
if route:
print 'possible route found'
print ('avg point score: {:.1f} '
'(PSU <25 acceptable match, <75 Schuessler & Axhausen)'
.format(route.stats['aps']))
print ('odd links: {} '
'(3 is PSU and Schuessler & Axhausen max)'
.format(route.stats['odd_links']))
print ('{:.1f} ms/pt (expected performance is 20-50 ms/pt)'
.format((time.time() - t1) / len(trip.gps.points) * 1000))
# sttach to dummy stage
trip.route = route
trip.route.get_geom(db_conn, srid=2838)
else:
print 'no route found with given parameters'
trip.route = None
if gmap_output:
if tripnum == len(gps.trips):
nextmap = None
else:
nextmap = tripnum + 1
gmap(gps4326, route, gmap_path, tripnum, trip_id, srid=2838, nextmap=nextmap)
index += 1
## d.write_psql(db_conn, 'data',
## GPStripstages='orc_gpstrips',
## GPSroutes='orc_gpsroutes', GPSlinks='orc_gpslinks')
tripnum += 1
trip_id = None
if psql_output:
d.write_psql(db_conn, 'data',
GPSroutes='orc_gpsroutes',
GPSlinks='orc_gpslinks',
GPStripstages='orc_gpstrips')
db_conn.close()