^fh2SSKrSSKrSSKrSSKrSSKJr SSKrSrSr Sr Sr Sr Sr S S S S S S.rS0SS_SS_SS_SS_SS_SS_SS_SS_S S!_S"S#_S$S%_S&S'_S(S)_S*S+_S,S-_S.S/_S0S1_0S2S3S4S5S6.S2SSS7.S8.rS9rS:rS;SS?\R$R&S@.r/SAQr/SBQr/SCQr/SDQ/SEQSF.rSG\SH\4SIjrSJS2S3S4S5S6.0rS SKSLSM.S SNSOSM.S SNSOSM.S SNSOSM.SP.rSQSRSS.rSWSTjr"SUSV5rg)XN)Pathc[R"S5S:Xa[RO[Rn[R "USS9 [R "[5nU$)u6ロギング設定を初期化し、ロガーを返すDEBUG1z)%(asctime)s - %(levelname)s - %(message)s)levelformat)osgetenvloggingrINFO basicConfig getLogger__name__) log_levelloggers /app/config.py setup_loggingr sG!#7!3s!:  I i0[\   x (F Mc8[R"[5nURS5 URS[35 URS[ SS[ S35 URS[ [535 URS5 g ) u設定情報を表示するu=== 設定情報 ===uCSVパス設定: uデータベース: databasez @ hostu対象テーブル数: z===============N)r rrinfo CSV_PATHS DB_CONFIGlen TARGET_TABLES)rs rprint_config_infors   x (F KK&' KK#I;/0 KK&y'<&=S6AR@STU KK)#m*<)=>? KK!"rcZ[(a[[5R5OS[(a[[5R5OSS.n[R "[ 5nUR5H'up#U(aSOSnURSUSU35 M) U$)u*オプションファイルの存在確認F)code_mapping_excelcode_type_excelu✅ 存在しますu❌ 存在しませんuオプションファイル z: ) CODE_MAPPING_EXCELrexistsCODE_TYPE_EXCELr rritemsdebug)resultsrfile_keyr"statuss rcheck_optional_filesr)sDVCUd#56==?[`=L_40779RWG  x (F#MMO*0&6N 3H:RxHI, Nrc[R"[5nURS5 [S[S[S[S[S/n/nUHHn[ U5R 5(aM#URU5 URSU35 MJ U(a;URS[U5S 35 [SS RU535eURS 5 g ) u'必須入力ファイルの存在確認u'入力ファイルの検証を開始... institutiondonor_followupsrecipient_followups transplants mapping_tableu,必須ファイルが見つかりません: u必須ファイル u:件 が見つかりません。処理を中止します。z, uO✅ 必須ファイル検証完了 - すべてのファイルが存在しますT) r rrrrrr"appenderrorrFileNotFoundErrorjoin)rrequired_files missing_files file_paths rvalidate_input_filesr7%s   x (F KK9: - #$'(- /" NM# I%%''   + LLG {S T$  *3}+=*>>xyz"NtyyYfOgNh ijj KKab rc.[RU/5$)u'テーブルのカラム一覧を取得) TABLE_COLUMNSget) table_names rget_table_columnsr<@s   Z ,,rc2[R"[5n[R"[ SSSS9nUR S[U5S35 U$![a3nURSU35 [R"5sSnA$SnAff=f) u-データマッピング情報を読み込むr/u腎臓　生体) sheet_nameheaderu2マッピングデータを読み込みました: u行u2マッピングデータの読み込みに失敗: N) r rrpd read_excelrrr Exceptionr1 DataFrame)rdfes rload_data_mappingsrGDs   x (F ]]9_5BS\] ^ HR QTUV  I!MN||~s)u良好u 変化なしu不良不明)uはいu いいえr])fieldsstatus_mappingboolean_mappinguK/csv/kan/移行データ_コード変換表アルトマーク→TRACER.xlsxu#/csv/kan/00_コードタイプ.xlsxdbroot123456dev_tracer_db2utf8mb4)ruserpasswordrcharset cursorclass) T_NYURYOKUJOKYO_LIVT_IJI_MENEKI_YOKUSEI_R_LIVT_GAPPEI_R_LIVT_KANSEN_R_LIV T_KENSA_R_LIV T_KENSA_D_LIVT_LIVING_D_LIVT_DONOR_KIDNEY_LIV T_DONOR_LIVT_ISHOKU_KIHON_KIDNEY_LIV T_TRACER_IKOT_ISHOKU_KIHON_LIV) rurtrsrrrqrlrkrmrprorn) )u[合併症等:感染症の有無(調査期間中):サイトメガロウイルス抗原血症ug合併症等:感染症の有無(調査期間中):サイトメガロウイルス抗原血症の診断日)uX合併症等:感染症の有無(調査期間中):サイトメガロウイルス感染症ud合併症等:感染症の有無(調査期間中):サイトメガロウイルス感染症の診断日)uS合併症等:感染症の有無(調査期間中):その他のウイルス感染症1u_合併症等:感染症の有無(調査期間中):その他のウイルス感染症1の診断日)uS合併症等:感染症の有無(調査期間中):その他のウイルス感染症2u_合併症等:感染症の有無(調査期間中):その他のウイルス感染症2の診断日)uS合併症等:感染症の有無(調査期間中):その他のウイルス感染症3u_合併症等:感染症の有無(調査期間中):その他のウイルス感染症3の診断日)u@合併症等:感染症の有無(調査期間中):細菌性肺炎uL合併症等:感染症の有無(調査期間中):細菌性肺炎の診断日)uI合併症等:感染症の有無(調査期間中):細菌性尿路感染症uU合併症等:感染症の有無(調査期間中):細菌性尿路感染症の診断日)uP合併症等:感染症の有無(調査期間中):その他の細菌性感染症1u\合併症等:感染症の有無(調査期間中):その他の細菌性感染症1の診断日)uP合併症等:感染症の有無(調査期間中):その他の細菌性感染症2u\合併症等:感染症の有無(調査期間中):その他の細菌性感染症2の診断日)uP合併症等:感染症の有無(調査期間中):その他の細菌性感染症3u\合併症等:感染症の有無(調査期間中):その他の細菌性感染症3の診断日)u9合併症等:感染症の有無(調査期間中):PC肺炎uE合併症等:感染症の有無(調査期間中):PC肺炎の診断日)uP合併症等:感染症の有無(調査期間中):その他の真菌性感染症1u\合併症等:感染症の有無(調査期間中):その他の真菌性感染症1の診断日)uP合併症等:感染症の有無(調査期間中):その他の真菌性感染症2u\合併症等:感染症の有無(調査期間中):その他の真菌性感染症2の診断日)SEITAI_ISYOKU_IDISYOKU_ISYOKUSISETU_CD ZOKI_CODEDEL_FLG INS_USER_IDINS_PROGRAM_ID)DONOR_IDrvDONOR_BIRTH_DATE DONOR_SEXryrzr{)rurrtsuisekireturncUR5nUS:XagSU;a1[URSS5R55nUS-S$g! g=f)uW '3ヶ月後' → 99, '1年後' → '01', '2年後' → '02', ..., '50年後' → '50' u 3ヶ月後99u年後r>02)stripintreplace)ryears r to_cycle_strrse~~H< X  x''"5;;=>DQhr] #  s /AAPRESSURE_STATUS_MAPzutf-8 )pathencodingsepcp932,)r+r,r-r.z./logs) sample_rows log_directorycUc1[R"[SS[S9R S5nXSU:HnUR(dURS S $XSRRUS S 9nUR(dURS S $g![ a8n[ R"[5nURSU35 SnAgSnAff=f) u'施設名から施設コードを取得Nr+r)rdtyperu)施設データの読み込みに失敗: 700000u名称ru コードF)na) rAread_csvrstrfillnarCr rrr1emptyiloccontains) facility_nameinstitution_dfrFr match_exact match_likes r get_sisetu_cdrs [[=)AtSVW^^_abN!!9]!JKK   ";// x 8 < < E EmX] E ^_J   q!+.. ! &&x0F LLDQCH I s0B%% C'/.C""C'c*\rSrSrSSjrSrSrSrg)ConversionProcessoriNcXl0UlU(a7[RR U5(aUR U5 gggN)rules code_mappingr rr"_load_code_mapping)selfrcode_mapping_files r__init__ConversionProcessor.__init__ s=  0A!B!B  # #$5 6"C rc[R"U5nURS5RS5Ulg![ a8n[ R"[5nURSU35 SnAgSnAff=f)Nuソースコードindexu2コードマッピングの読み込みに失敗: ) rArB set_indexto_dictrrCr rrr1)rr6rErFrs rr&ConversionProcessor._load_code_mapping&sl Sy)B " -A B J J7 SD  S&&x0F LLMaSQ R R Ss;> B.A;;BcU$r)r source_valuerule_keys rconvertConversionProcessor.convert.sr)rrr)r __module__ __qualname____firstlineno__rrr__static_attributes__rrrrrs7 Srrr) r r pymysqljsonpathlibrpandasrArrr)r7r<rGrDONOR_KIDNEY_RULESr!r#cursors DictCursorrORDERED_TABLESrKANSEN_COLUMNSr9rrCONVERSION_RULES FILE_SETTINGSDEBUG_SETTINGSrrrrrrsL  # 6- $-15-=     *,@ $&8      ()D  ()C   12K  12I  12I  %&9  ()A  }  ()C  ()C  12L l! " "#6# , 9!Fc7   ??--      $   3 3 &  * + + +! 2 0r