'NmeaFeeder',
'all_mmsi_generator',
'load_fleet_to_uset',
+ 'fleetname_to_fleetid',
'filter_area',
'filter_knownposition',
'filter_speedcheck',
yield fname[:-6]
-def load_fleet_to_uset(fleetname):
+def load_fleet_to_uset(fleetid):
"""
- Loads a fleet by name-id.
+ Loads a fleet by id.
Returns an array of strmmsi.
"""
result = []
- sqlexec(u"SELECT mmsi FROM fleet_vessel JOIN fleet ON (fleet_vessel.fleet_id = fleet.id) WHERE fleet.name=%(fleetname)s", {'fleetname': fleetname})
+ sqlexec(u"SELECT mmsi FROM fleet_vessel WHERE fleet_id=" + unicode(fleetid))
cursor = get_common_cursor()
while True:
row = cursor.fetchone()
return result
+def fleetname_to_fleetid(fleetname):
+ sqlexec(u"SELECT id FROM fleet WHERE name=%(fleetname)s", {'fleetname': fleetname})
+ cursor = get_common_cursor()
+ row = cursor.fetchone()
+ return row[0]
+
+
def filter_area(nmea, area):
"""
Returns false if position is out of area.
from optparse import OptionParser, OptionGroup
global DBPATH
- parser = OptionParser(usage='%prog [options] { mmsi | @fleet }+ | all')
+ parser = OptionParser(usage='%prog [options] { mmsi | @fleetname | ^fleetid }+ | all')
parser.add_option('-d', '--debug',
action='store_true', dest='debug', default=False,
if arg == 'all':
all_targets = True
elif arg.startswith('@'):
- target_mmsi_iterator += load_fleet_to_uset(arg[1:])
+ target_mmsi_iterator += load_fleet_to_uset(fleetname_to_fleetid(arg[1:]))
+ elif arg.startswith('^'):
+ target_mmsi_iterator += load_fleet_to_uset(int(arg[1:]))
else:
target_mmsi_iterator.append(arg)
if all_targets:
global DBPATH, STYLE
from optparse import OptionParser, OptionGroup
- parser = OptionParser(usage='%prog [options] { mmsi | @fleetfile }+ | all')
+ parser = OptionParser(usage='%prog [options] { mmsi | @fleetname | #fleetid }+ | all')
parser.add_option('-d', '--debug',
action='store_true', dest='debug', default=False,
if arg == 'all':
all_targets = True
elif arg.startswith('@'):
- target_mmsi_iterator += load_fleet_to_uset(arg[1:])
+ target_mmsi_iterator += load_fleet_to_uset(fleetname_to_fleetid(arg[1:]))
+ elif arg.startswith('^'):
+ target_mmsi_iterator += load_fleet_to_uset(int(arg[1:]))
else:
target_mmsi_iterator.append(arg)
if all_targets: