RWC sjekk for diska løpere

otime/cli.py

@@ -1,5 +1,6 @@
 import argparse
 import file_io
+import datetime
 import iof_xml
 import serial
 import subprocess
@@ -11,6 +12,10 @@ from pdf import format_m_s
 from rich import print
 import search_tui
 
+from rich.traceback import install
+from rich import inspect
+install(show_locals=True)
+
 # Main entrypoint for now. Cli with two options; init will make the files needed and run will start the program from the specified directory
 def main():
     parser = argparse.ArgumentParser(description='Otime very alpha version 😁')
@@ -28,22 +33,44 @@ def main():
     parser_init.add_argument('--port', required=False, dest='port', action='store', help='specify a serial port')
     parser_init.add_argument('--xml', required=False, dest='xml_path', action='store', default=None, help='Where the xml result file should be saved')
 
-    parser_init = subparsers.add_parser('viewer', help='View otime data')
+    parser_init = subparsers.add_parser('gen', help='Generate result files')
     parser_init.add_argument('--dir', required=False, dest='dir', action='store', default='./', help='specify a directory')
     parser_init.add_argument('--xml', required=False, dest='xml_path', action='store', default=None, help='Where the xml result file should be saved')
 
+    parser_init = subparsers.add_parser('view', help='View otime data')
+    parser_init.add_argument('--dir', required=False, dest='dir', action='store', default='./', help='specify a directory')
+    parser_init.add_argument('--xml', required=False, dest='xml_path', action='store', default=None, help='Where the xml result file should be saved')
+
+    parser_init = subparsers.add_parser('mtr', help='run mtr commands')
+    parser_init.add_argument('--port', required=True, dest='port', action='store', help='specify a serial port')
+    parser_init.add_argument('--spool', required=False, dest='mtr_spool', action='store_true', help='Spool all mtr data')
+    parser_init.add_argument('--status', required=False, dest='mtr_status', action='store_true', help='Spool all mtr data')
+
     args = parser.parse_args()
 
-    if not args.xml_path:
+    try:
-        args.xml_path = args.dir + '/output'
+        if not args.xml_path:
+            args.xml_path = args.dir + '/output'
+    except AttributeError:
+        pass
 
     match args.command:
         case 'init':
             init_dir(args.dir, args.entries_file, args.courses_file)
         case 'run':
             run(args.port, args.dir, args.xml_path)
-        case 'viewer':
+        case 'view':
             search_tui.main(args.dir)
+        case 'gen':
+            gen(args.dir, args.xml_path)
+        case 'mtr':
+            mtr = serial.Serial(port=args.port, baudrate=9600, timeout=40)
+            if args.mtr_spool:
+                mtr.write(b'/SA')
+            if args.mtr_status:
+                mtr.write(b'/ST')
+        case other:
+            parser.print_help()
 
 def init_dir(project_dir, entries_xml_file, courses_xml_file):
     # Lager mappe med en config fil, en csv fil med løpere og en fil med mtr data
@@ -73,40 +100,79 @@ def run(port='/dev/ttyUSB0', project_dir='./', xml_path='./output/'):
     csv_path = project_dir + '/runners.csv'
     while True:
         if mtr.in_waiting > 0:
-            mtr.read_until(expected=b'\xFF\xFF\xFF\xFF')
+            block = mtr.read_until(expected=b'\xFF\xFF\xFF\xFF')
-            size = mtr.read(size=1)
+            size = block[0]
-            if size == b'\xe6':
+            if size == 230:
                 event = file_io.event_from_yaml_and_csv(config_path, mtr_path, csv_path)
-                meat = mtr.read(229)
+                message = b'\xFF\xFF\xFF\xFF' + block[:230]
-                full = b'\xFF\xFF\xFF\xFF' + size + meat
+                if not is_checksum_valid(message):
-                card_dump = otime.CardDump.from_mtr_bytes(full)
+                    print('[red]Checksum is not valid![red]')
-                event.card_dumps.append(card_dump)
+                    try:
-                file_io.write_card_dumps(event, mtr_path)
+                        print(otime.CardDump.from_mtr_bytes(message))
-                print(runner_info(event, card_dump))
+                        print(runner_info(event, card_dump))
-                subprocess.run(['git', 'add', './*'], cwd=project_dir, stdout=subprocess.DEVNULL)
+                    except Exception as error:
-                subprocess.run(['git', 'commit', '-m', f'Added {card_dump.card}'], cwd=project_dir, stdout=subprocess.DEVNULL)
+                        print(error)
+                else:
+                    card_dump = otime.CardDump.from_mtr_bytes(message)
+                    event.card_dumps.append(card_dump)
+                    file_io.write_card_dumps(event, mtr_path)
+                    print(runner_info(event, card_dump))
+                    subprocess.run(['git', 'add', './*'], cwd=project_dir, stdout=subprocess.DEVNULL)
+                    subprocess.run(['git', 'commit', '-m', f'Added {card_dump.card}'], cwd=project_dir, stdout=subprocess.DEVNULL)
+                    iof_xml.create_result_file(event, xml_path + '/results.xml')
+                    pdf.create_result_list(event, project_dir + '/output/results.pdf')
                 
-                iof_xml.create_result_file(event, xml_path + '/results.xml')
+            elif size == 55:
-                pdf.create_result_list(event, project_dir + '/output/results.pdf')
+                message = b'\xFF\xFF\xFF\xFF' + block[:55]
                 
-            elif size == b'\x37':
+                mtr_id = int.from_bytes(message[6:8], 'little')
-                meat = mtr.read(55)
+                year = int.from_bytes(message[8:9], 'little')
-                inspect(status)
+                month = int.from_bytes(message[9:10], 'little')
+                day = int.from_bytes(message[10:11], 'little')
+                hours =int.from_bytes(message[11:12], 'little')
+                minutes = int.from_bytes(message[12:13], 'little')
+                seconds = int.from_bytes(message[13:14], 'little')
+                milliseconds =int.from_bytes(message[14:16], 'little')
+                battery_status = int.from_bytes(message[16:17], 'little')
+                time = datetime.datetime(year, month, day, hours, minutes, seconds, milliseconds)
+                print(f'MTR status message: id: {mtr_id}, time: {time}, battery: {battery_status}')
+            else:
+                print('Data not found!')
+                print(block)
+
+
+def gen(project_dir='./', xml_path='./output/'):
+    config_path = project_dir + '/config.yaml'
+    mtr_path = project_dir + '/mtr.yaml'
+    csv_path = project_dir + '/runners.csv'
+    event = file_io.event_from_yaml_and_csv(config_path, mtr_path, csv_path)
+    subprocess.run(['git', 'add', './*'], cwd=project_dir, stdout=subprocess.DEVNULL)
+    subprocess.run(['git', 'commit', '-m', f'Manually run'], cwd=project_dir, stdout=subprocess.DEVNULL)
+    
+    iof_xml.create_result_file(event, xml_path + '/results.xml')
+    pdf.create_result_list(event, project_dir + '/output/results.pdf')
 
 def runner_info(event, card_dump):
     runner = next((i for i in event.runners if str(i.card_id) == str(card_dump.card)), None)
     if runner is None:
-        return card_dump
+        return f'[orange_red1]No runner with ecard {card_dump.card}! It matches these courses: {otime.find_courses_matching_controls(card_dump.controls, event.courses)}[/orange_red1] {card_dump}'
     result = event.get_runner_result(runner.id)
     if result is None:
         return '🧐 Dette skal ikke skje...'
     if result.status == 'OK':
         result_text = f'[green]Place: {result.place}. Time: [bold][yellow]{format_m_s(result.total_time)}[/yellow][/bold][/green]'
     elif result.status == 'MissingPunch':
-        result_text = f'[red]Missed Control! Time: [bold][yellow]{format_m_s(result.total_time)}[/yellow][/bold][/red]'
+        result_text = f'[red]Missed control(s): {result.missed_controls}! Time: [bold][yellow]{format_m_s(result.total_time)}[/yellow][/bold][/red]'
     else:
         result_text = f'[blue]{result.status}, Time: [bold][yellow]{result.total_time}[/yellow][/bold][/blue]'
     return result_text + f' [blue]{result.fullname()}[/blue], {result.o_class}, {result.club}, [italic]Card: {result.card_id}[/italic]'
 
+def is_checksum_valid(message):
+    # Hentet fra https://github.com/knutsiem/mtr-log-extractor
+    checksum = int.from_bytes(message[232:233], 'little')
+    # calculate checksum for message bytes up until checksum
+    calculated_checksum = sum(message[:232]) % 256
+    return checksum == calculated_checksum
+
 if __name__ == '__main__':
     main()

otime/file_io.py

@@ -22,6 +22,7 @@ def write_card_dumps(event, file_path):
         
 def write_runners_csv(event, file_path):
     with open(file_path, 'w') as f:
+        f.write('ID;Status;Fornavn, Etternavn;Klasse;klubb;Brikke;Gafling;Starttid\n')
         for i in event.runners:
             f.write(f'{i.id};{i.status_override};{i.first}, {i.last};{i.o_class};{i.club};{i.card_id};{i.fork};{i.start_time}\n')
     
@@ -37,7 +38,17 @@ def event_from_yaml_and_csv(config_path, mtr_path, csv_path):
 
     with open(csv_path, 'r') as f:
         data = [i.split(';') for i in f.readlines()]
+        data.pop(0)
         for i in data: i[2] = i[2].split(',')
+        for i in data:
+            # Setter starttid til None hvis den ikke er satt
+            if len(i[7]) > 8: 
+                i[7] = i[7]
+            else:
+                i[7] = None
+            # Sjekk om brikkenummer er tomt
+            if i[5] == '':
+                i[5] = 0
         runners = [otime.Runner(id=i[0], status_override=i[1], first=i[2][0], last=i[2][1].strip(), o_class=i[3], club=i[4], card_id=int(i[5]), fork=int(i[6]), start_time=i[7]) for i in data]
     event.card_dumps = card_dumps
     event.runners = runners

otime/iof_xml.py

@@ -30,6 +30,9 @@ def create_result_file(event, file_path, o_classes=[]):
         # <PersonResult>
 
         for n in i.runner_results:
+            if n.status == 'DidNotStart':
+                continue
+
             person_result = ET.SubElement(class_result, 'PersonResult')
             # <Person>
             person = ET.SubElement(person_result, 'Person')
@@ -64,14 +67,14 @@ def create_result_file(event, file_path, o_classes=[]):
                     xml_child(result, 'Status', n.status)
                     # <SplitTime>
                     # TODO: ta utgangspunkt i løypa, ikke det brikka har stempla
-                    for code, split in zip(i.course.codes, n.splits):
+                    for code, split in zip(i.course.codes[n.fork][:-1], n.splits[:-1]):
                         st = ET.SubElement(result, 'SplitTime')
                         xml_child(st, 'ControlCode', code)
                         xml_child(st, 'Time', split)
                     # </SplitTime>
                 elif n.status == 'MissingPunch':
                     xml_child(result, 'Status', n.status)
-                    for code, split in zip(i.course.codes, n.splits):
+                    for code, split in zip(i.course.codes[n.fork][:-1], n.splits[:-1]):
                         st = ET.SubElement(result, 'SplitTime')
                         xml_child(st, 'ControlCode', code)
                         if split != 0: xml_child(st, 'Time', split)
@@ -122,7 +125,7 @@ def runners_from_xml_entries(xml_file):
 
         start_time = None
         runners.append(otime.Runner(rid, first, last, club=club_name, club_id=club_id,
-                              country=country,card_id=card, o_class_str=class_str,
+                              country=country,card_id=card, o_class=class_str,
                               start_time=start_time, fee_id=fee_id))
     return runners
 
@@ -201,7 +204,9 @@ def event_from_xml_entries(xml_file):
     o_classes = [otime.OClass(i, []) for i in set(class_names)]
 
     runners = runners_from_xml_entries(xml_file)
-    fees = fees_from_xml_entries(xml_file)
+    # TODO: fiks fees
+    #fees = fees_from_xml_entries(xml_file)
+    fees = []
 
     return otime.Event(event_id, name, organiser=organiser, runners=runners,
                     fees=fees, start_time=start_time, end_time=end_time, o_classes=o_classes)

otime/otime.py

@@ -181,7 +181,7 @@ class OClass:
 
 class RunnerResult:
     def __init__(self, runner_id: int, first: str, last: str, status: str, place: int, total_time: int, splits: list[int], end_time,
-                 club=None, club_id=None, country=None, card_id=None, o_class=None, controls=None, fork=0, start_time=datetime.datetime(1973, 1, 1), fee_id=None):
+                 club=None, club_id=None, country=None, card_id=None, o_class=None, controls=None, fork=0, start_time=datetime.datetime(1973, 1, 1), fee_id=None, missed_controls=None, ran_other_course=None):
         self.id = runner_id
         self.first = first
         self.last = last
@@ -200,6 +200,10 @@ class RunnerResult:
         self.total_time = total_time
         self.splits = splits
         self.end_time = end_time
+        # List of controls missed
+        self.missed_controls = missed_controls
+        # If the runner ran other course it is named here
+        self.ran_other_course = ran_other_course
     
     def fullname(self):
         return f'{self.first} {self.last}'
@@ -278,19 +282,32 @@ class Event:
         runner = self.get_runner(runner_id)
         return next((i for i in produce_class_result(self, runner.o_class).runner_results if i.id == runner_id), None)
 
+    def get_runner_o_class(self, id):
+        runner = self.get_runner(id)
+        return next((copy.copy(i) for i in self.o_classes if i.name == runner.o_class), None)
+
     def get_runner_time(self, id):
         runner = self.get_runner(id)
         card_dump = self.get_card_dump(runner.card_id)
-        if card_dump == None:
+        course = self.get_course(self.get_runner_o_class(id).course)
+        if card_dump == None or course == None:
             return False
 
-        f_control = card_dump.controls[-1]
+        f_control = course.codes[runner.fork][-1]
         # TODO: Må gjøres mer robust
-        try:
+        if f_control not in card_dump.controls:
-            index = card_dump.controls.index(f_control)
+            # Hvis løperen ikke har vært på sistepost tar vi siste stempling istedet
+            return card_dump.splits[-1]
+        index = card_dump.controls.index(f_control)
+        # Hvis løperen ikke har en startid spesifisert brukes brikketid
+        if runner.start_time is None:
             return card_dump.splits[index]
-        except:
+        #Hvis det er en startid finner jeg tidsforskjellen mellom brikkestart og faktisk start og trekker den fra totaltida
-            return False
+        else:
+            time_list = runner.start_time.split(':') # hour, minute, second
+            start_datetime = self.start_time.replace(hour=int(time_list[0]), minute=int(time_list[1]), second=int(time_list[2]))
+            diff =  start_datetime - card_dump.s_time
+            return card_dump.splits[index] - diff.total_seconds()
 
     def get_runner_splits(self, id):
         # Tida brukt frem til hver post, ikke tida fra forrige post
@@ -298,6 +315,7 @@ class Event:
             runner = self.get_runner(id)
             card_dump = self.get_card_dump(runner.card_id)
             course = self.get_course(self.get_o_class(runner.o_class).course)
+            codes = course.codes[runner.fork]
         except AttributeError:
             return None
 
@@ -305,8 +323,8 @@ class Event:
             return None
 
         split_iter = zip(card_dump.controls, card_dump.splits).__iter__()
-        splits = [0] * len(course.codes[runner.fork])
+        splits = [0] * len(codes)
-        for n, control in enumerate(course.codes[runner.fork]):
+        for n, control in enumerate(codes):
             if control not in card_dump.controls:
                 continue
             while True:
@@ -384,7 +402,11 @@ def produce_class_result(event, o_class_name) -> ClassResult:
     results = [RunnerResult(i.id, i.first, i.last, event.get_runner_status(i.id), ok_runners.index(i)+1, event.get_runner_time(i.id), event.get_runner_splits(i.id),
                 event.get_runner_end_clock(i.id), i.club, 0, i.country, i.card_id, i.o_class, event.get_runner_controls(i.id), start_time=event.get_card_dump(i.card_id).s_time) for i in ok_runners]
     results += [RunnerResult(i.id, i.first, i.last, event.get_runner_status(i.id), 0, event.get_runner_time(i.id), event.get_runner_splits(i.id),
-                event.get_runner_end_clock(i.id), i.club, 0, i.country, i.card_id, i.o_class, event.get_runner_controls(i.id), start_time=event.get_card_dump(i.card_id).s_time) for i in dsq_runners]
+                event.get_runner_end_clock(i.id), i.club, 0, i.country, i.card_id, i.o_class, event.get_runner_controls(i.id), 
+                start_time=event.get_card_dump(i.card_id).s_time,
+                missed_controls=find_missed_controls(event.get_runner_controls(i.id), event.get_course(o_class.course).codes[i.fork]),
+                ran_other_course=find_courses_matching_controls(event.get_card_dump(i.card_id).controls, event.courses)) 
+                for i in dsq_runners]
     results += [RunnerResult(i.id, i.first, i.last, event.get_runner_status(i.id), 0, event.get_runner_time(i.id), event.get_runner_splits(i.id),
                 event.get_runner_end_clock(i.id), i.club, 0, i.country, i.card_id, i.o_class, event.get_runner_controls(i.id)) for i in other_runners]
     
@@ -438,3 +460,14 @@ def contains(small, big):
         return map_bl
     else:
         return False
+
+def find_missed_controls(punches, codes):
+        return [i for i in codes if i not in punches]
+
+def find_courses_matching_controls(controls, courses):
+    matches = []
+    for i in courses:
+        for fork in i.codes:
+            if contains(fork, controls):
+                matches.append(i.name)
+    return matches