l'hQKSrSSKrSSKrSSKJrJrJrJr SSK r SSK r SSK J r SSK r \ R"\5r"SS5rg)u エラーレポート生成モジュール データベースのテーブル定義を取得し、エラー情報と組み合わせて 詳細なエラーレポートを生成する N)DictListAnyOptional)datetimec .\rSrSrSrS\R R4SjrS\ \ \ \ \ 444Sjr S\ S\ R4SjrS \ S\ \ \ 44S jrS\ S \ S\ \ \44S jrS!S\\ S\ RS\ RS\ R4SjjrS!S\ S \ S\ RS\ 4SjjrS\ S\ 4SjrS\ S\ S\S\ 4SjrS"S\ RS\ S\ S\ 4SjjrS\ S\ RSS 4SjrS\ RS\ R4SjrS rg )#ErrorReportGeneratoru$エラーレポート生成クラス db_connectioncHXl0UlUR5Ulg)u> 初期化 Args: db_connection: データベース接続 N) connectiontable_definitions_init_error_analysis_ruleserror_analysis_rules)selfr s /app/error_report_generator.py__init__ErrorReportGenerator.__init__s"(!#$($C$C$E!returnc:SSSS.SSSS.SS S S.S S S S.S S SS.S.$)u$エラー分析ルールを初期化z&Data too long for column '(.+)' at rowuEカラムのサイズを拡張するか、データを切り詰めるデータ長超過)pattern 対処方法エラータイプzDuplicate entry '(.+)' for keyuE重複チェックを追加するか、既存データを更新する重複エラーz*Incorrect integer value: '(.+)' for columnu!数値変換処理を追加する型変換エラーz*Incorrect decimal value: '(.+)' for columnzColumn '(.+)' cannot be nullu4NULL値のチェックとデフォルト値の設定uNULL制約違反)z Data too longzDuplicate entryzIncorrect integer valuezIncorrect decimal valuezcannot be null)rs rr/ErrorReportGenerator._init_error_analysis_ruless_E g&: = g&7  I C&:( I C&:( ; V&8+  r table_namec:XR;aURU$SnURR5nURX!45 UR 5nSSS5 [ R "W5nXPRU'U$!,(df  N4=f)uu テーブル定義を取得 Args: table_name: テーブル名 Returns: テーブル定義のDataFrame a SELECT COLUMN_NAME, DATA_TYPE, COLUMN_TYPE, IS_NULLABLE, COLUMN_DEFAULT, CHARACTER_MAXIMUM_LENGTH, NUMERIC_PRECISION, NUMERIC_SCALE, COLUMN_COMMENT FROM INFORMATION_SCHEMA.COLUMNS WHERE TABLE_SCHEMA = DATABASE() AND TABLE_NAME = %s ORDER BY ORDINAL_POSITION N)rr cursorexecutefetchallpd DataFrame)rr queryr"columnsdfs rget_table_definition)ErrorReportGenerator.get_table_definition<s // /))*5 5 "__ # # % NN5- 0oo'G&\\' "-/z* & %s #B  B error_messagec$SSUS.nURR5Hkup4X1;dM [R"USU5nU(dM/USUS'USUS'UR 5(aUR S5OUUS' U$ U$) u~ エラーメッセージを分析 Args: error_message: エラーメッセージ Returns: 分析結果の辞書 不明u*エラー内容を確認してくださいrrエラー詳細rrrr0)ritemsresearchgroupsgroup)rr,result error_typerulematchs r analyze_error"ErrorReportGenerator.analyze_errorbs#+H,  !% 9 9 ? ? A J* $y/=A5378L3MF/0-1.-AF>*BG,,.. AVcF,- !B r column_namecURU5nX3SU:HnUR(aSSS.$URSnUSUS(aUSS.$SS.$)u カラム情報を取得 Args: table_name: テーブル名 column_name: カラム名 Returns: カラム情報の辞書 COLUMN_NAMEr.)型 コメントr COLUMN_TYPECOLUMN_COMMENT)r*emptyiloc)rr r=r) column_rowrows rget_column_info$ErrorReportGenerator.get_column_info}s & &z 2=)[89    (  ooa }%589I5JC 01  PR  rN error_logs transplant_df mapping_dfc/nU(dUURSSSSSSSS[R"5RS5SSS . 5 [R "U5$[ US 5GHcupVURS S 5nURS URSS55nURSURSS55n URSURSS55n URSS5n URSURSS55n URSURSS55n URSS5nURSS5nURSS5nURS[R"5RS55nU(aU (aURX5O0nU (aURU 5OUS:XaSOSS U=(d U S!.nU(aUOURXU5nURUUU 5nUS:XaSOSn0S"U_S#U_S$U=(d S%_S&U_S'URU5_S(U _S)U_S*U _S+URS+S5_S,URS,S5_S-U _S.U (aU OS_S/U _S0U(aUOS_SU _S1US1_S2U_S3US4UUS5.EnURU5 GMf [R "U5$)6uF エラーレポートを生成（統一フォーマット対応） Args: error_logs: エラー/警告ログのリスト（統一フォーマット） transplant_df: 移植データのDataFrame mapping_df: マッピング情報のDataFrame（オプション） Returns: エラーレポートのDataFrame -uエラーなしu 正常終了u$処理は正常に完了しましたu 対処不要z%Y-%m-%d %H:%M:%S情報uなし) uエラー番号YearNoテーブル名 カラム名rエラー内容 元の値r 発生日時 重要度u 影響度r1levelERRORtablerRrDcolumnu更新カラム名year_norQseitai_isyoku_idmessagerToriginal_valueu値expected_value csv_source error_detail timestampWARNINGu警告u エラーu!詳細を確認してくださいr/NO レベルCSVu項目名（移植時）u CSVカラムu テーブルrSテーブル物理名u物理カラム名r@rAu移植登録ID(YearNo)u生体移植IDrUu 期待値r0ru 未対応r)u 対応状況rrWrV) appendrnowstrftimer%r& enumerategetrIr;_find_csv_column_suggest_action_get_table_japanese_name)rrKrLrM report_dataidx log_entryrXr r=r\r]r^r_r`rarbrc column_infoerror_analysis csv_columnactionseverity report_rows rgenerate_error_report*ErrorReportGenerator.generate_error_reportsK    #&#4 #&4#I . (  7 78K L%%  << , ,' A6NCMM'73E"w >OQS0TUJ#--)--@TVX2YZKmmIy}}Xr/JKG(}}-?D mmIy}}=NPR/STG&]]+;Y]]5RT=UVN&]]+;R@N"|R8J$==3J3JK^3_`ILVZe$..zGkmK=DT//82792Dh+ C#/#:7JN(2t7L7LZfp7qJ)).+~VF$)I#5x;HcUz?%?   = =j I   (%k{ub1  C)'!6F"2C^~^3"7 ">2C#D!"#$!,&45I&J% )+J0   z *s7v||K((rc.UbUR(agg)u マッピング情報からCSVカラム名を検索 Args: table_name: テーブル名 column_name: カラム名 mapping_df: マッピング情報 Returns: CSVカラム名 r.)rE)rr r=rMs rrn%ErrorReportGenerator._find_csv_columns  !1!1rc >SSSSSSSSS S S . nURX5$) u$テーブルの日本語名を取得u!移植基本情報(共通-生体)uドナー情報(共通-生体)uドナー情報(腎-生体)u移植基本情報(腎-生体)u生活状況D(生体-ドナー)u(検査項目R(生体-レシピエント)u検査項目D(生体-ドナー)u%合併症R(生体-レシピエント)u4維持期免疫抑制薬R(生体-レシピエント)u%感染症R(生体-レシピエント)) T_ISHOKU_KIHON_LIV T_DONOR_LIVT_DONOR_KIDNEY_LIVT_ISHOKU_KIHON_KIDNEY_LIVT_LIVING_D_LIV T_KENSA_R_LIV T_KENSA_D_LIVT_GAPPEI_R_LIVT_IJI_MENEKI_YOKUSEI_R_LIVT_KANSEN_R_LIV)rm)rr table_name_maps rrp-ErrorReportGenerator._get_table_japanese_name s=#F;"?)I?G>E*`E  !!*99rrurt error_datacUSnURSS5nUS:XaSU;aa[R"SU5nU(a=[UR S55n[ [ U55nSUS US -S US 3$US$S U;a"[U[[45(aUS:agUS$US:XaSU;dSU;agUS$US:XagUS$)u エラーに応じた具体的な対処方法を提案 Args: error_analysis: エラー分析結果 column_info: カラム情報 error_data: エラーデータ Returns: 対処方法の提案 rr@rDrvarcharzvarchar\((\d+)\)r1zvarchar(u )をvarchar( u")に拡張するか、データをu文字に切り詰めるtinyintu-tinyintをsmallintまたはintに変更するrrintdecimalu9数値以外の文字を除去する変換処理を追加ruRINSERT前に存在チェックを追加し、既存の場合はUPDATEまたはSKIP) rmr3r4rr6lenstr isinstancefloat) rrurtrr8 column_typer:current_lengthrequired_lengths rro$ErrorReportGenerator._suggest_actions$$89 !ooeR0 - -K' "5{C%(Q%8N&)#j/&:O%n%5\/TVBVAWWy{IzJJbcc".1 1k)jc5\.R.R#J!.1 1 / / #yK'?R!.1 1 , ,gn--r report_df output_dir range_suffixcn[R"USS9 [R"5R S5n[R R USUUS35n[R"USS9nSUR;aXSS :HnUR(d$URUS S S 9 URUS U5 XSS :HnUR(d$URUSS S 9 URUSU5 URUSS S 9 URUSU5 O$URUSS S 9 URUSU5 SSS5 [R R USUUS35n URU S SS9 [RSU35 U$!,(df  N_=f)u8 エラーレポートを保存（ERROR/WARNING別シート対応） Args: report_df: エラーレポートのDataFrame output_dir: 出力ディレクトリ range_suffix: ファイル名に追加する範囲サフィックス（分割実行対応） Returns: 保存したファイルパス T)exist_okz %Y%m%d_%H%M%S error_report_z.xlsxopenpyxl)enginerfrYuエラー一覧F) sheet_nameindexrdu 警告一覧u 全件一覧uエラーレポートNz.csvz utf-8-sig)rencodingu,エラーレポートを保存しました: )osmakedirsrrjrkpathjoinr% ExcelWriterr(rEto_excel_adjust_column_widthto_csvloggerinfo) rrrrrc excel_pathwritererror_df warning_dfcsv_paths rsave_error_report&ErrorReportGenerator.save_error_report?s J.LLN++O< WW\\* i[V[.\] ^^Jz :fi///${%;w%FG~~%%f9JRW%X--f6GR''='JK !''''>QV'W--fnjQ""6nE"R))&.)L""66MUZ"[))&2I9U-;277<< mI;|nTX,YZE B:,OP=; :s 5CF&& F4rr)cX!R;aURUnUHn[X5R[5R [ 5R5[ U55nUR RU5n[US-S5UR[SU-5l M gg![a Mf=f)u列幅を自動調整2AN) sheetsmaxastypermaprr(get_locmincolumn_dimensionschrwidth Exception)rrrr) worksheetr[ column_lengthcol_idxs rr)ErrorReportGenerator._adjust_column_widthrs  & j1I$' (9(9#(>(B(B3(G(K(K(MsSY{$[M jj008GKN}_`O`bdKeI//BL0ABH  '!sBB>> C  C c/nSUR;aQURS5R5RSS9nSUS'UR UR SS0S95 SUR;ajS UR;aZURSS /5R5RSS9nS US'USS -US -US'UR U/S Q5 S UR;a^URS 5R S SS.5R5n/SQUlSUS'US US'UR U/SQ5 U(a;[R"USS9n/SQnUHnXR;dMSXh'M Xg$S UR;a=URS 5R S SS.5R5n/SQUlU$[R"S/S/S/S/S.5$)u エラーサマリーレポートを生成（統一フォーマット対応） Args: report_df: エラーレポートのDataFrame Returns: サマリーレポートのDataFrame rf件数)nameu レベル別分類項目)r(rhruテーブル別z - )rrrcountc^[U5S:aUR5RS$S$NrrDr value_countsrxs r>ErrorReportGenerator.generate_summary_report..s*s1vPQz!..*:*@*@*C*YWY*Yr)rer)rr主な対処方法uエラータイプ別)rrrrT) ignore_indexrOc^[U5S:aUR5RS$S$rrrs rrrs*3q6TU:ann.>.D.DQ.G.][].]rrPuデータなしr) r(groupbysize reset_indexrirenameaggr%concatr&) rr summary_data level_summary table_summaryerror_type_summary final_summaryrequired_columnscols rgenerate_summary_report,ErrorReportGenerator.generate_summary_reportsN  )++ +%--k:??AMMS[M\M&4M( #    4 4k8=T 4 U V #i&7&7 7R+S x (    23g h i IIlFMS '333),M&(!2 2$y'8'88%.%6%67K%L%P%P!$]R&;=#.d"*))||zFWEXefdgAD@E%FGGr)r rr)N)z./logsrD)__name__ __module__ __qualname____firstlineno____doc__pymysql connections Connectionrrrrr%r&r*r;rrIrrzrnrprorrr__static_attributes__rrrr r s. Fg&9&9&D&D F Dd38n1D,E <$s$r||$L34S>6 # C DcN 88<\)T \)+-<<\)(* \)@B \)~483S$&LLrsB ,,    8 $fGfGr