Feat: Assessment page completed with save method combining Assessment, Distraction, Assessment Command Modality Link, and Assessment Response save for creating new complete Assessnent.

2025-07-28 22:41:38 +01:00
parent 1bbe6f0040
commit 574d60442a
122 changed files with 3261 additions and 1057 deletions
--- a/datastores/datastore_dog.py
+++ b/datastores/datastore_dog.py
@@ -681,6 +681,54 @@ class DataStore_Dog(DataStore_Base):
        cls.db_cursor_clear(cursor)

        return assessments, errors
+    
+    @classmethod
+    def save_assessments(cls, comment, assessments):
+        _m = f'{cls}.save_assessments'
+        av.val_str(comment, 'comment', _m)
+
+        guid = Helper_DB_MySQL.create_guid_str()
+        now = datetime.now()
+        user = cls.get_user_session()
+
+        Helper_App.console_log(f'saving assessments: {assessments}')
+
+        rows = []
+        for link in assessments:
+            row = Assessment_Temp.from_assessment(link)
+            row.guid = guid
+            rows.append(row)
+        
+        Helper_App.console_log(f'rows: {rows}')
+
+        cls.upload_bulk(Assessment_Temp.__tablename__, rows, 1000)
+
+        Helper_App.console_log('assessments uploaded')
+
+        argument_dict_list = {
+            'a_comment': comment,
+            'a_guid': guid,
+            'a_id_user': user.id_user,
+            'a_debug': 0
+        }
+        result = cls.db_procedure_execute('p_dog_save_assessment', argument_dict_list)
+        
+        Helper_App.console_log('Assessments saved')
+
+        # Errors
+        cursor = result.cursor
+        cursor.nextset()
+        result_set_e = cursor.fetchall()
+        Helper_App.console_log(f"Raw errors: {result_set_e}")
+        errors = []
+        if len(result_set_e) > 0:
+            errors = [SQL_Error.from_db_record(row) for row in result_set_e]
+            for error in errors:
+                Helper_App.console_log(f"Error [{error.code}]: {error.msg}")
+
+        cls.db_cursor_clear(cursor)
+
+        return errors


    @classmethod
@@ -872,6 +920,54 @@ class DataStore_Dog(DataStore_Base):
        cls.db_cursor_clear(cursor)

        return distractions, errors
+    
+    @classmethod
+    def save_distractions(cls, comment, distractions):
+        _m = f'{cls}.save_distractions'
+        av.val_str(comment, 'comment', _m)
+
+        guid = Helper_DB_MySQL.create_guid_str()
+        now = datetime.now()
+        user = cls.get_user_session()
+
+        Helper_App.console_log(f'saving distractions: {distractions}')
+
+        rows = []
+        for distraction in distractions:
+            row = Distraction_Temp.from_distraction(distraction)
+            row.guid = guid
+            rows.append(row)
+        
+        Helper_App.console_log(f'rows: {rows}')
+
+        cls.upload_bulk(Distraction_Temp.__tablename__, rows, 1000)
+
+        Helper_App.console_log('distractions uploaded')
+
+        argument_dict_list = {
+            'a_comment': comment,
+            'a_guid': guid,
+            'a_id_user': user.id_user,
+            'a_debug': 0
+        }
+        result = cls.db_procedure_execute('p_dog_save_distraction', argument_dict_list)
+        
+        Helper_App.console_log('Distractions saved')
+
+        # Errors
+        cursor = result.cursor
+        cursor.nextset()
+        result_set_e = cursor.fetchall()
+        Helper_App.console_log(f"Raw errors: {result_set_e}")
+        errors = []
+        if len(result_set_e) > 0:
+            errors = [SQL_Error.from_db_record(row) for row in result_set_e]
+            for error in errors:
+                Helper_App.console_log(f"Error [{error.code}]: {error.msg}")
+
+        cls.db_cursor_clear(cursor)
+
+        return errors


    @classmethod
@@ -986,6 +1082,54 @@ class DataStore_Dog(DataStore_Base):
        cls.db_cursor_clear(cursor)

        return assessment_command_modality_links, errors
+    
+    @classmethod
+    def save_assessment_command_modality_links(cls, comment, assessment_command_modality_links):
+        _m = f'{cls}.save_assessment_command_modality_links'
+        av.val_str(comment, 'comment', _m)
+
+        guid = Helper_DB_MySQL.create_guid_str()
+        now = datetime.now()
+        user = cls.get_user_session()
+
+        Helper_App.console_log(f'saving assessment_command_modality_links: {assessment_command_modality_links}')
+
+        rows = []
+        for link in assessment_command_modality_links:
+            row = Assessment_Command_Modality_Link_Temp.from_assessment_command_modality_link(link)
+            row.guid = guid
+            rows.append(row)
+        
+        Helper_App.console_log(f'rows: {rows}')
+
+        cls.upload_bulk(Assessment_Command_Modality_Link_Temp.__tablename__, rows, 1000)
+
+        Helper_App.console_log('assessment_command_modality_links uploaded')
+
+        argument_dict_list = {
+            'a_comment': comment,
+            'a_guid': guid,
+            'a_id_user': user.id_user,
+            'a_debug': 0
+        }
+        result = cls.db_procedure_execute('p_dog_save_assessment_command_modality_link', argument_dict_list)
+        
+        Helper_App.console_log('Assessment_Command_Modality_Links saved')
+
+        # Errors
+        cursor = result.cursor
+        cursor.nextset()
+        result_set_e = cursor.fetchall()
+        Helper_App.console_log(f"Raw errors: {result_set_e}")
+        errors = []
+        if len(result_set_e) > 0:
+            errors = [SQL_Error.from_db_record(row) for row in result_set_e]
+            for error in errors:
+                Helper_App.console_log(f"Error [{error.code}]: {error.msg}")
+
+        cls.db_cursor_clear(cursor)
+
+        return errors


    @classmethod
@@ -1100,3 +1244,124 @@ class DataStore_Dog(DataStore_Base):
        cls.db_cursor_clear(cursor)

        return assessment_responses, errors
+    
+    @classmethod
+    def save_assessment_responses(cls, comment, assessment_responses):
+        _m = f'{cls}.save_assessment_responses'
+        av.val_str(comment, 'comment', _m)
+
+        guid = Helper_DB_MySQL.create_guid_str()
+        now = datetime.now()
+        user = cls.get_user_session()
+
+        Helper_App.console_log(f'saving assessment_responses: {assessment_responses}')
+
+        rows = []
+        for response in assessment_responses:
+            row = Assessment_Response_Temp.from_assessment_response(response)
+            row.guid = guid
+            rows.append(row)
+        
+        Helper_App.console_log(f'rows: {rows}')
+
+        cls.upload_bulk(Assessment_Response_Temp.__tablename__, rows, 1000)
+
+        Helper_App.console_log('assessment_responses uploaded')
+
+        argument_dict_list = {
+            'a_comment': comment,
+            'a_guid': guid,
+            'a_id_user': user.id_user,
+            'a_debug': 0
+        }
+        result = cls.db_procedure_execute('p_dog_save_assessment_response', argument_dict_list)
+        
+        Helper_App.console_log('Assessment_Responses saved')
+
+        # Errors
+        cursor = result.cursor
+        cursor.nextset()
+        result_set_e = cursor.fetchall()
+        Helper_App.console_log(f"Raw errors: {result_set_e}")
+        errors = []
+        if len(result_set_e) > 0:
+            errors = [SQL_Error.from_db_record(row) for row in result_set_e]
+            for error in errors:
+                Helper_App.console_log(f"Error [{error.code}]: {error.msg}")
+
+        cls.db_cursor_clear(cursor)
+
+        return errors
+    
+
+    @classmethod
+    def save_assessments_distactions_and_responses(cls, comment, assessments, distractions, assessment_command_modality_links, assessment_responses):
+        _m = f'{cls}.save_assessments_distactions_and_responses'
+        av.val_str(comment, 'comment', _m)
+
+        guid = Helper_DB_MySQL.create_guid_str()
+        now = datetime.now()
+        user = cls.get_user_session()
+
+        Helper_App.console_log(f'saving assessments, distractions, and responses:\nAssessments: {assessments}\nDistractions: {distractions}\nAssessment Command Modality Links: {assessment_command_modality_links}\nResponses: {assessment_responses}')
+
+        rows_assessment = []
+        for assessment in assessments:
+            row = Assessment_Temp.from_assessment(assessment)
+            row.guid = guid
+            rows_assessment.append(row)
+        Helper_App.console_log(f'rows_assessment: {rows_assessment}')
+        cls.upload_bulk(Assessment_Temp.__tablename__, rows_assessment, 1000)
+        Helper_App.console_log('assessments uploaded')
+
+        rows_distraction = []
+        for distraction in distractions:
+            row = Distraction_Temp.from_distraction(distraction)
+            row.guid = guid
+            rows_distraction.append(row)
+        Helper_App.console_log(f'rows_distraction: {rows_distraction}')
+        cls.upload_bulk(Distraction_Temp.__tablename__, rows_distraction, 1000)
+        Helper_App.console_log('distractions uploaded')
+
+        rows_link = []
+        for link in assessment_command_modality_links:
+            row = Assessment_Command_Modality_Link_Temp.from_assessment_command_modality_link(link)
+            row.guid = guid
+            rows_link.append(row)
+        Helper_App.console_log(f'rows_link: {rows_link}')
+        cls.upload_bulk(Assessment_Command_Modality_Link_Temp.__tablename__, rows_link, 1000)
+        Helper_App.console_log('links uploaded')
+
+        rows_response = []
+        for response in assessment_responses:
+            row = Assessment_Response_Temp.from_assessment_response(response)
+            row.guid = guid
+            rows_response.append(row)
+        Helper_App.console_log(f'rows_response: {rows_response}')
+        cls.upload_bulk(Assessment_Response_Temp.__tablename__, rows_response, 1000)
+        Helper_App.console_log('assessment responses uploaded')
+
+        argument_dict_list = {
+            'a_comment': comment,
+            'a_guid': guid,
+            'a_id_user': user.id_user,
+            'a_debug': 0
+        }
+        result = cls.db_procedure_execute('p_dog_save_assessment_distraction_and_response', argument_dict_list)
+        
+        Helper_App.console_log('All saved')
+
+        # Errors
+        cursor = result.cursor
+        cursor.nextset()
+        result_set_e = cursor.fetchall()
+        Helper_App.console_log(f"Raw errors: {result_set_e}")
+        errors = []
+        if len(result_set_e) > 0:
+            errors = [SQL_Error.from_db_record(row) for row in result_set_e]
+            for error in errors:
+                Helper_App.console_log(f"Error [{error.code}]: {error.msg}")
+
+        cls.db_cursor_clear(cursor)
+
+        return errors