nik/newdwh2021
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge branch 'fix-NEWDWH2021-1360' of https://nds-tyo.backlog.com/git/NEWDWH2021/newsdwh2021 into fix-NEWDWH2021-1360

Browse Source
This commit is contained in:
Nik Afiq 2023-11-29 13:55:26 +09:00
commit 26b9507d23
14 changed files with 450 additions and 291 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

87
ecs/jskult-batch-daily/src/batch/ultmarc/utmp_tables/table_mapper/concrete/com_dr_mapper.py
View File

@ -214,6 +214,9 @@ class ComDrMapper(UltmarcTableMapper):
# 西暦の取得
self.__set_era()
# 「@」による項目クリアを設定
self.__set_clearing_item()
# レコードの存在確認
record_count = self.db.execute_select(self.RECORD_EXISTS_QUERY, self.query_parameter)
# 存在しない場合はInsert
@ -247,14 +250,10 @@ class ComDrMapper(UltmarcTableMapper):
# 削除予定理由
if len(self.record.drdel_code) > 0:
set_clauses.append('delete_sche_reason_cd = :drdel_code')
if self.record.drdel_code == '@':
self.query_parameter['drdel_code'] = None
# 重複時相手先ｺｰﾄﾞ
if len(self.record.opp_dup_code) > 0:
set_clauses.append('opp_dup_cd = :opp_dup_code')
if self.record.reptdr_id == '@':
self.query_parameter['opp_dup_code'] = None
# 医師名(漢字)
if len(self.record.dr_name) > 0:
@ -275,12 +274,6 @@ class ComDrMapper(UltmarcTableMapper):
set_clauses.append('birthday_month = :birthday_month')
set_clauses.append('birthday_day = :birthday_day')
set_clauses.append('birthday = :birth_day')
if self.record.birthday_era == '@':
self.query_parameter['birthday_era'] = None
self.query_parameter['birthday_year'] = None
self.query_parameter['birthday_month'] = None
self.query_parameter['birthday_day'] = None
self.query_parameter['birth_day'] = None
# 出身都道府県ｺｰﾄﾞ
if len(self.record.home_town_code) > 0:
@ -295,10 +288,6 @@ class ComDrMapper(UltmarcTableMapper):
set_clauses.append('grad_year = :grad_year')
set_clauses.append('grad_era = :grad_yearera')
set_clauses.append('grad_y = :grad_y')
if self.record.grad_yearera == '@':
self.query_parameter['grad_yearera'] = None
self.query_parameter['grad_year'] = None
self.query_parameter['grad_y'] = None
# 出身校ｺｰﾄﾞ
if len(self.record.graduniv_code) > 0:
@ -313,16 +302,10 @@ class ComDrMapper(UltmarcTableMapper):
set_clauses.append('drday_era = :drda_yera')
set_clauses.append('drday_year = :drday_year')
set_clauses.append('drday_y = :drday_y')
if self.record.drda_yera == '@':
self.query_parameter['drda_yera'] = None
self.query_parameter['drday_year'] = None
self.query_parameter['drday_y'] = None
# 住所不明
if len(self.record.dr_addr_lost_code) > 0:
set_clauses.append('addr_unknown_reason_cd = :dr_addr_lost_code')
if self.record.dr_addr_lost_code == '@':
self.query_parameter['dr_addr_lost_code'] = None
# 住所
# 集合項目のいずれかに入力がある場合に更新
@ -340,32 +323,22 @@ class ComDrMapper(UltmarcTableMapper):
# 自宅電話番号
if len(self.record.dr_tel) > 0:
set_clauses.append('home_phone_number = :dr_tel')
if self.record.dr_tel == '@':
self.query_parameter['dr_tel'] = None
# 利用停止区分
if len(self.record.use_stop_flag) > 0:
set_clauses.append('use_stop_div = :use_stop_flag')
if self.record.use_stop_flag == '@':
self.query_parameter['use_stop_flag'] = None
# 利用停止理由
if len(self.record.use_stopc_ode) > 0:
set_clauses.append('use_stop_reason_cd = :use_stopc_ode')
if self.record.use_stopc_ode == '@':
self.query_parameter['use_stopc_ode'] = None
# 利用停止登録年月日
if len(self.record.cre_stop_date) > 0:
set_clauses.append('use_stop_regist_ymd = :cre_stop_date')
if self.record.cre_stop_date == '@':
self.query_parameter['cre_stop_date'] = None
# 利用停止解除年月日
if len(self.record.release_date) > 0:
set_clauses.append('use_stop_cancel_ymd = :release_date')
if self.record.release_date == '@':
self.query_parameter['release_date'] = None
# 開勤区分
if len(self.record.pract_class_code) > 0:
@ -376,10 +349,6 @@ class ComDrMapper(UltmarcTableMapper):
set_clauses.append('estab_era = :pract_yearera')
set_clauses.append('estab_year = :pract_year')
set_clauses.append('estab_y = :estab_y')
if self.record.pract_yearera == '@':
self.query_parameter['pract_yearera'] = None
self.query_parameter['pract_year'] = None
self.query_parameter['estab_y'] = None
# 一括登録ﾌﾗｸﾞ
if len(self.record.bskregst_flag) > 0:
@ -459,3 +428,53 @@ class ComDrMapper(UltmarcTableMapper):
# 月日も空の場合、生年月日は空
return ''
def __set_clearing_item(self):
# 削除予定理由
if self.record.drdel_code == '@':
self.query_parameter['drdel_code'] = None
# 重複時相手先ｺｰﾄﾞ
if self.record.reptdr_id == '@':
self.query_parameter['opp_dup_code'] = None
# 生年月日
if self.record.birthday_era == '@':
self.query_parameter['birthday_era'] = None
self.query_parameter['birthday_year'] = None
self.query_parameter['birthday_month'] = None
self.query_parameter['birthday_day'] = None
self.query_parameter['birth_day'] = None
# 卒年
if self.record.grad_yearera == '@':
self.query_parameter['grad_yearera'] = None
self.query_parameter['grad_year'] = None
self.query_parameter['grad_y'] = None
# 登録年
if self.record.drda_yera == '@':
self.query_parameter['drda_yera'] = None
self.query_parameter['drday_year'] = None
self.query_parameter['drday_y'] = None
# 住所不明
if self.record.dr_addr_lost_code == '@':
self.query_parameter['dr_addr_lost_code'] = None
# 自宅電話番号
if self.record.dr_tel == '@':
self.query_parameter['dr_tel'] = None
# 利用停止区分
if self.record.use_stop_flag == '@':
self.query_parameter['use_stop_flag'] = None
# 利用停止理由
if self.record.use_stopc_ode == '@':
self.query_parameter['use_stopc_ode'] = None
# 利用停止登録年月日
if self.record.cre_stop_date == '@':
self.query_parameter['cre_stop_date'] = None
# 利用停止解除年月日
if self.record.release_date == '@':
self.query_parameter['release_date'] = None
# 開業年
if self.record.pract_yearera == '@':
self.query_parameter['pract_yearera'] = None
self.query_parameter['pract_year'] = None
self.query_parameter['estab_y'] = None
return

479
ecs/jskult-batch-daily/src/batch/ultmarc/utmp_tables/table_mapper/concrete/com_inst_att_mapper.py
View File

@ -677,6 +677,10 @@ class ComInstAttMapper(UltmarcTableMapper):
def __make_upsert_query(self):
# レコードの存在確認
record_count = self.db.execute_select(self.RECORD_EXISTS_QUERY, self.query_parameter)
# 「@」による項目クリアを設定
self.__set_clearing_item()
# 存在しない場合はInsert
if record_count[0]['count_num'] == 0:
self.queries.append(self.INSERT_QUERY)
@ -693,40 +697,24 @@ class ComInstAttMapper(UltmarcTableMapper):
set_clauses.append('dpc_flag = :dpc_flag')
set_clauses.append('dpc_specday = :dpc_spec_day')
set_clauses.append('dpc_cancelday = :dpc_cancel_day')
if self.record.dpc_flag == '@':
self.query_parameter['dpc_flag'] = None
self.query_parameter['dpc_spec_day'] = None
self.query_parameter['dpc_cancel_day'] = None
# DPC準備病院
if len(self.record.predpc_flag) > 0:
set_clauses.append('predpc_flag = :predpc_flag')
set_clauses.append('predpc_specday = :predpc_spec_day')
set_clauses.append('predpc_cancelday = :predpc_cancel_day')
if self.record.predpc_flag == '@':
self.query_parameter['predpc_flag'] = None
self.query_parameter['predpc_spec_day'] = None
self.query_parameter['predpc_cancel_day'] = None
# がん診療連携拠点病院
if len(self.record.cancer_flag) > 0:
set_clauses.append('cancer_flag = :cancer_flag')
set_clauses.append('cancer_specday = :cancer_spec_day')
set_clauses.append('cancer_cancelday = :cancer_cancel_day')
if self.record.cancer_flag == '@':
self.query_parameter['cancer_flag'] = None
self.query_parameter['cancer_spec_day'] = None
self.query_parameter['cancer_cancel_day'] = None
# 特定機能病院
if len(self.record.funchp_flag) > 0:
set_clauses.append('funchpflag = :funchp_flag')
set_clauses.append('funchpokdate = :funchp_ok_date')
set_clauses.append('funchpcandate = :funchp_can_date')
if self.record.funchp_flag == '@':
self.query_parameter['funchp_flag'] = None
self.query_parameter['funchp_ok_date'] = None
self.query_parameter['funchp_can_date'] = None
# 地域医療支援病院
if len(self.record.areasuphp_flag) > 0:
@ -734,275 +722,167 @@ class ComInstAttMapper(UltmarcTableMapper):
set_clauses.append('areasuphpintrate = :areasuphp_intrate')
set_clauses.append('areasuphpokdate = :areasuphp_ok_date')
set_clauses.append('areasuphpcandate = :areasuphp_can_date')
if self.record.areasuphp_flag == '@':
self.query_parameter['areasuphp_flag'] = None
self.query_parameter['areasuphp_intrate'] = None
self.query_parameter['areasuphp_ok_date'] = None
self.query_parameter['areasuphp_can_date'] = None
# 超急性期脳卒中加算
if len(self.record.acuthp_add_flag) > 0:
set_clauses.append('acuthpaddflag = :acuthp_add_flag')
set_clauses.append('acuthpaddokdate = :acuthp_add_ok_date')
set_clauses.append('acuthpaddcandate = :acuthp_add_can_date')
if self.record.acuthp_add_flag == '@':
self.query_parameter['acuthp_add_flag'] = None
self.query_parameter['acuthp_add_ok_date'] = None
self.query_parameter['acuthp_add_can_date'] = None
# 総合入院体制加算
if len(self.record.genadmisiion_flag) > 0:
set_clauses.append('genadmisiionflag = :genadmisiion_flag')
set_clauses.append('genadmisiionfokdate = :genadmisiion_ok_date')
set_clauses.append('genadmisiionfcandate = :genadmisiion_can_date')
if self.record.genadmisiion_flag == '@':
self.query_parameter['genadmisiion_flag'] = None
self.query_parameter['genadmisiion_ok_date'] = None
self.query_parameter['genadmisiion_can_date'] = None
# 医師事務作業補助体制加算
if len(self.record.assistance_flag) > 0:
set_clauses.append('assistanceflag = :assistance_flag')
set_clauses.append('assistanceokdate = :assistance_ok_date')
set_clauses.append('assistancecandate = :assistance_can_date')
if self.record.assistance_flag == '@':
self.query_parameter['assistance_flag'] = None
self.query_parameter['assistance_ok_date'] = None
self.query_parameter['assistance_can_date'] = None
# 診療録管理体制加算
if len(self.record.diagnosis_treatment_flag) > 0:
set_clauses.append('diagnosistreatment_flag = :diagnosis_treatment_flag')
set_clauses.append('diagnosistreatment_specday = :diagnosis_treatment_spec_day')
set_clauses.append('diagnosistreatment_cancelday = :diagnosis_treatment_cancel_day')
if self.record.diagnosis_treatment_flag == '@':
self.query_parameter['diagnosis_treatment_flag'] = None
self.query_parameter['diagnosis_treatment_spec_day'] = None
self.query_parameter['diagnosis_treatment_cancel_day'] = None
# 医療安全対策加算
if len(self.record.safety_flag) > 0:
set_clauses.append('safety_flag = :safety_flag')
set_clauses.append('safety_specday = :safety_spec_day')
set_clauses.append('safety_cancelday = :safety_cancel_day')
if self.record.safety_flag == '@':
self.query_parameter['safety_flag'] = None
self.query_parameter['safety_spec_day'] = None
self.query_parameter['safety_cancel_day'] = None
# 褥瘡ﾊｲﾘｽｸ患者ｹｱ加算
if len(self.record.highrisk_flag) > 0:
set_clauses.append('highrisk_flag = :highrisk_flag')
set_clauses.append('highrisk_specday = :highrisk_spec_day')
set_clauses.append('highrisk_cancelday = :highrisk_cancel_day')
if self.record.highrisk_flag == '@':
self.query_parameter['highrisk_flag'] = None
self.query_parameter['highrisk_spec_day'] = None
self.query_parameter['highrisk_cancel_day'] = None
# 地域連携小児夜間･休日診療料
if len(self.record.infant_and_holiday_flag) > 0:
set_clauses.append('infantandholiday_flag = :infant_and_holiday_flag')
set_clauses.append('infantandholiday_specday = :infant_and_holiday_spec_day')
set_clauses.append('infantandholiday_cancelday = :infant_and_holiday_cancel_day')
if self.record.infant_and_holiday_flag == '@':
self.query_parameter['infant_and_holiday_flag'] = None
self.query_parameter['infant_and_holiday_spec_day'] = None
self.query_parameter['infant_and_holiday_cancel_day'] = None
# 開放型病院
if len(self.record.ophp_flag) > 0:
set_clauses.append('ophpflag = :ophp_flag')
set_clauses.append('ophpokdate = :ophpok_date')
set_clauses.append('ophpcandate = :ophpcan_date')
if self.record.ophp_flag == '@':
self.query_parameter['ophp_flag'] = None
self.query_parameter['ophpok_date'] = None
self.query_parameter['ophpcan_date'] = None
# 地域連携ｸﾘﾃｨｶﾙﾊﾟｽ
if len(self.record.critical_flag) > 0:
set_clauses.append('critical_flag = :critical_flag')
# 項目クリア判断
is_aggregate_item_clear = self.record.critical_flag == '@'
if is_aggregate_item_clear:
self.query_parameter['critical_flag'] = None
# 20個分の項目設定(rangeの第2引数の数字はループに含まれないため、+1を指定する)
for i in range(1, 21):
num = str(i).zfill(2) # 2桁で0埋め
setting_item_name = f'critical_code{num}'
set_clauses.append(f'{setting_item_name} = :{setting_item_name}')
if is_aggregate_item_clear:
self.query_parameter[setting_item_name] = None
# 薬剤管理指導料
if len(self.record.drgmgthp_flag) > 0:
set_clauses.append('drgmgthpflag = :drgmgthp_flag')
set_clauses.append('drgmgthpokdate = :drgmgthp_ok_date')
set_clauses.append('drgmgthpcandate = :drgmgthp_can_date')
if self.record.drgmgthp_flag == '@':
self.query_parameter['drgmgthp_flag'] = None
self.query_parameter['drgmgthp_ok_date'] = None
self.query_parameter['drgmgthp_can_date'] = None
# 画像診断管理加算
if len(self.record.image_diagnosis_flag) > 0:
set_clauses.append('imagediagnosis_flag = :image_diagnosis_flag')
set_clauses.append('imagediagnosis_specifiedday = :image_diagnosis_specified_day')
set_clauses.append('imagediagnosis_cancelday = :image_diagnosis_cancel_day')
if self.record.image_diagnosis_flag == '@':
self.query_parameter['image_diagnosis_flag'] = None
self.query_parameter['image_diagnosis_specified_day'] = None
self.query_parameter['image_diagnosis_cancel_day'] = None
# 外来化学療法加算
if len(self.record.chemotherapy_flag) > 0:
set_clauses.append('chemotherapy_flag = :chemotherapy_flag')
set_clauses.append('chemotherapy_specday = :chemotherapy_spec_day')
set_clauses.append('chemotherapy_cancelday = :chemotherapy_cancel_day')
if self.record.chemotherapy_flag == '@':
self.query_parameter['chemotherapy_flag'] = None
self.query_parameter['chemotherapy_spec_day'] = None
self.query_parameter['chemotherapy_cancel_day'] = None
# 疾患別ﾘﾊﾋﾞﾘﾃｰｼｮﾝ料
if len(self.record.rehabilitation_flag) > 0:
set_clauses.append('rehabilitation_flag = :rehabilitation_flag')
# 項目クリア判断
is_aggregate_item_clear = self.record.rehabilitation_flag == '@'
if is_aggregate_item_clear:
self.query_parameter['rehabilitation_flag'] = None
# 10個分の項目設定(rangeの第2引数の数字はループに含まれないため、+1を指定する)
for i in range(1, 11):
num = str(i).zfill(2) # 2桁で0埋め
setting_item_name = f'rehabilitation_code{num}'
set_clauses.append(f'{setting_item_name} = :{setting_item_name}')
if is_aggregate_item_clear:
self.query_parameter[setting_item_name] = None
# 麻酔管理料
if len(self.record.anesthetizing_manage_flag) > 0:
set_clauses.append('anesthetizingmanage_flag = :anesthetizing_manage_flag')
set_clauses.append('anesthetizingmanage_specday = :anesthetizing_manage_spec_day')
set_clauses.append('anesthetizingmanage_cancelday = :anesthetizing_manage_can_day')
if self.record.anesthetizing_manage_flag == '@':
self.query_parameter['anesthetizing_manage_flag'] = None
self.query_parameter['anesthetizing_manage_spec_day'] = None
self.query_parameter['anesthetizing_manage_can_day'] = None
# 在宅療養支援病院･診療所
if len(self.record.home_recuperation_flag) > 0:
set_clauses.append('homerecuperation_flag = :home_recuperation_flag')
set_clauses.append('homerecuperation_specday = :home_recuperation_spec_day')
set_clauses.append('homerecuperation_cancelday = :home_recuperation_cancel_day')
if self.record.home_recuperation_flag == '@':
self.query_parameter['home_recuperation_flag'] = None
self.query_parameter['home_recuperation_spec_day'] = None
self.query_parameter['home_recuperation_cancel_day'] = None
# 在宅時医学総合管理料
if len(self.record.synthesis_when_staying_flag) > 0:
set_clauses.append('synthesiswhenstaying_flag = :synthesis_when_staying_flag')
set_clauses.append('synthesiswhenstaying_specday = :synthesis_when_staying_spec_day')
set_clauses.append('synthesiswhenstaying_cancelday = :synthesis_when_staying_can_day')
if self.record.synthesis_when_staying_flag == '@':
self.query_parameter['synthesis_when_staying_flag'] = None
self.query_parameter['synthesis_when_staying_spec_day'] = None
self.query_parameter['synthesis_when_staying_can_day'] = None
# 在宅末期医療総合診療料
if len(self.record.home_late_flag) > 0:
set_clauses.append('homelateflag = :home_late_flag')
set_clauses.append('homelateokday = :home_late_ok_day')
set_clauses.append('homelatecanday = :home_late_can_day')
if self.record.home_late_flag == '@':
self.query_parameter['home_late_flag'] = None
self.query_parameter['home_late_ok_day'] = None
self.query_parameter['home_late_can_day'] = None
# ｹｱﾐｯｸｽ区分
if len(self.record.caremix_kind) > 0:
set_clauses.append('caremixkind = :caremix_kind')
if self.record.caremix_kind == '@':
self.query_parameter['caremix_kind'] = None
# 完全型･移行型区分
if len(self.record.fullmove_flag) > 0:
set_clauses.append('fullmoveflag = :fullmove_flag')
if self.record.fullmove_flag == '@':
self.query_parameter['fullmove_flag'] = None
# 療養型病床群
if sum(len(item) for item in self.record.resthp_items) > 0:
# 医療型
set_clauses.append('resthpflag = :resthp_flag')
set_clauses.append('resthpcarekind = :resthp_care_kind')
set_clauses.append('resthpbednum = :resthp_bed_num')
set_clauses.append('resthpokdate = :resthp_ok_date')
set_clauses.append('resthpcandate = :resthp_can_date')
# 介護型
set_clauses.append('resthpcarenrskind = :resthp_care_nrs_kind')
set_clauses.append('resthpcarebednum = :resthp_care_bed_num')
set_clauses.append('resthpcareokdate = :resthp_care_ok_date')
set_clauses.append('resthpcarecandate = :resthp_care_can_date')
# 合計
set_clauses.append('resthpsbednum = :resthp_sbed_num')
if self.record.resthp_flag == '@':
self.query_parameter['resthp_flag'] = None
self.query_parameter['resthp_care_kind'] = None
self.query_parameter['resthp_bed_num'] = None
self.query_parameter['resthp_ok_date'] = None
self.query_parameter['resthp_can_date'] = None
self.query_parameter['resthp_care_nrs_kind'] = None
self.query_parameter['resthp_care_bed_num'] = None
self.query_parameter['resthp_care_ok_date'] = None
self.query_parameter['resthp_care_can_date'] = None
self.query_parameter['resthp_sbed_num'] = None
# 一般病棟
if len(self.record.nrmhp_flag) > 0:
set_clauses.append('nrmhpflag = :nrmhp_flag')
set_clauses.append('nrmhpcarekind = :nrmhp_care_kind')
set_clauses.append('nrmhpbedtotalnum = :nrmhp_bed_total_num')
if self.record.nrmhp_flag == '@':
self.query_parameter['nrmhp_flag'] = None
self.query_parameter['nrmhp_care_kind'] = None
self.query_parameter['nrmhp_bed_total_num'] = None
# 精神病棟
if len(self.record.menthp_flag) > 0:
set_clauses.append('menthpflag = :menthp_flag')
set_clauses.append('menthpcarekind = :menthp_care_kind')
set_clauses.append('menthpbednum = :menthp_bed_num')
if self.record.menthp_flag == '@':
self.query_parameter['menthp_flag'] = None
self.query_parameter['menthp_care_kind'] = None
self.query_parameter['menthp_bed_num'] = None
# 結核病棟
if len(self.record.tubhp_flag) > 0:
set_clauses.append('tubhpflag = :tubhp_flag')
set_clauses.append('tubhpcarekind = :tubhp_care_kind')
set_clauses.append('tubhpbednum = :tubhp_bed_num')
if self.record.tubhp_flag == '@':
self.query_parameter['tubhp_flag'] = None
self.query_parameter['tubhp_care_kind'] = None
self.query_parameter['tubhp_bed_num'] = None
# 感染症指定医療機関
if len(self.record.infhp_flag) > 0:
set_clauses.append('infhpflag = :infhp_flag')
set_clauses.append('infhpflag1 = :infhp_flag1')
set_clauses.append('infhpflag2 = :infhp_flag2')
if self.record.infhp_flag == '@':
self.query_parameter['infhp_flag'] = None
self.query_parameter['infhp_flag1'] = None
self.query_parameter['infhp_flag2'] = None
# 感染症病床
if len(self.record.infhp_bed_flag) > 0:
set_clauses.append('infhpbedflag = :infhp_bed_flag')
set_clauses.append('infhpbednum = :infhp_bed_num')
if self.record.infhp_bed_flag == '@':
self.query_parameter['infhp_bed_flag'] = None
self.query_parameter['infhp_bed_num'] = None
# 緩和ｹｱ病棟設置病院
if len(self.record.hospice_flag) > 0:
@ -1010,11 +890,6 @@ class ComInstAttMapper(UltmarcTableMapper):
set_clauses.append('hospicebednum = :hospice_bed_num')
set_clauses.append('hospiceokdate = :hospice_ok_date')
set_clauses.append('hospicecandate = :hospice_can_date')
if self.record.hospice_flag == '@':
self.query_parameter['hospice_flag'] = None
self.query_parameter['hospice_bed_num'] = None
self.query_parameter['hospice_ok_date'] = None
self.query_parameter['hospice_can_date'] = None
# 医療機能評価
if len(self.record.hpfunce_st_flag) > 0:
@ -1022,55 +897,35 @@ class ComInstAttMapper(UltmarcTableMapper):
set_clauses.append('hpfuncestkind = :hpfunce_st_kind')
set_clauses.append('hpfuncestokdate = :hpfunce_st_ok_date')
set_clauses.append('hpfuncestcandate = :hpfunce_st_can_date')
if self.record.hpfunce_st_flag == '@':
self.query_parameter['hpfunce_st_flag'] = None
self.query_parameter['hpfunce_st_kind'] = None
self.query_parameter['hpfunce_st_ok_date'] = None
self.query_parameter['hpfunce_st_can_date'] = None
# 臨床研修指定病院
if sum(len(item) for item in self.record.cl_items) > 0:
# 基幹型病院1
set_clauses.append('clolyhpkind = :clolyhp_kind')
set_clauses.append('clolyhpokdate = :clolyhp_ok_date')
set_clauses.append('clolyhpcandate = :clolyhp_can_date')
# 基幹型病院2（群指定）
set_clauses.append('clhpkind = :clhp_kind')
set_clauses.append('clhpokdate = :clhp_ok_date')
set_clauses.append('clhpcandate = :clhp_can_date')
# 協力型病院（群指定）
set_clauses.append('cldephpkind = :cldephp_kind')
set_clauses.append('cldephpokdate = :cldephp_ok_date')
set_clauses.append('cldephpcandate = :cldephp_can_date')
if self.record.clolyhp_kind == '@':
self.query_parameter['clolyhp_kind'] = None
self.query_parameter['clolyhp_ok_date'] = None
self.query_parameter['clolyhp_can_date'] = None
self.query_parameter['clhp_kind'] = None
self.query_parameter['clhp_ok_date'] = None
self.query_parameter['clhp_can_date'] = None
self.query_parameter['cldephp_kind'] = None
self.query_parameter['cldephp_ok_date'] = None
self.query_parameter['cldephp_can_date'] = None
# 災害拠点病院
if len(self.record.disasthp_flag) > 0:
set_clauses.append('disasthpflag = :disasthp_flag')
if self.record.disasthp_flag == '@':
self.query_parameter['disasthp_flag'] = None
# 救急医療
if len(self.record.d1emerhp_flag) > 0:
set_clauses.append('d1emerhpflag = :d1emerhp_flag')
set_clauses.append('d2emerhpflag = :d2emerhp_flag')
set_clauses.append('d3emerhpflag = :d3emerhp_flag')
if self.record.d1emerhp_flag == '@':
self.query_parameter['d1emerhp_flag'] = None
self.query_parameter['d2emerhp_flag'] = None
self.query_parameter['d3emerhp_flag'] = None
# 救急告示診療所
if len(self.record.emergency_clinic) > 0:
set_clauses.append('emergencyclinic = :emergency_clinic')
if self.record.emergency_clinic == '@':
self.query_parameter['emergency_clinic'] = None
# 治験中核病院
if len(self.record.trial_core_flag) > 0:
@ -1078,72 +933,42 @@ class ComInstAttMapper(UltmarcTableMapper):
set_clauses.append('trialcore_div = :trial_core_div')
set_clauses.append('trialcoreokdate = :trial_core_ok_date')
set_clauses.append('trialcorecandate = :trial_core_can_date')
if self.record.trial_core_flag == '@':
self.query_parameter['trial_core_flag'] = None
self.query_parameter['trial_core_div'] = None
self.query_parameter['trial_core_ok_date'] = None
self.query_parameter['trial_core_can_date'] = None
# 認知症疾患医療ｾﾝﾀｰ
if len(self.record.dementia_flag) > 0:
set_clauses.append('dementiaflag = :dementia_flag')
set_clauses.append('dementiaokdate = :dementia_okd_ate')
set_clauses.append('dementiacandate = :dementia_can_date')
if self.record.dementia_flag == '@':
self.query_parameter['dementia_flag'] = None
self.query_parameter['dementia_okd_ate'] = None
self.query_parameter['dementia_can_date'] = None
# 特定健康診査実施機関
if len(self.record.sphealth_exploration) > 0:
set_clauses.append('sphealth_exploration = :sphealth_exploration')
if self.record.sphealth_exploration == '@':
self.query_parameter['sphealth_exploration'] = None
# 特定保健指導実施機関
if len(self.record.sphealth_guidance) > 0:
set_clauses.append('sphealth_guidance = :sphealth_guidance')
if self.record.sphealth_guidance == '@':
self.query_parameter['sphealth_guidance'] = None
# 先進医療実施医療機関
if len(self.record.hiadhp_flag) > 0:
set_clauses.append('hiadhpflag = :hiadhp_flag')
# 項目クリア判断
is_aggregate_item_clear = self.record.hiadhp_flag == '@'
if is_aggregate_item_clear:
self.query_parameter['hiadhp_flag'] = None
# 40個分の項目設定(rangeの第2引数の数字はループに含まれないため、+1を指定する)
for i in range(1, 41):
setting_item_name_code = f'hiadhpcode{i}'
setting_item_name_kind = f'hiadhpkind{i}'
set_clauses.append(f'{setting_item_name_code} = :{setting_item_name_code}')
set_clauses.append(f'{setting_item_name_kind} = :{setting_item_name_kind}')
if is_aggregate_item_clear:
self.query_parameter[setting_item_name_code] = None
self.query_parameter[setting_item_name_kind] = None
# 先端医療実施医療機関
if len(self.record.hitechhp_flag) > 0:
set_clauses.append('hitechhpflag = :hitechhp_flag')
# 項目クリア判断
is_aggregate_item_clear = self.record.hitechhp_flag == '@'
if is_aggregate_item_clear:
self.query_parameter['hitechhp_flag'] = None
# 20個分の項目設定(rangeの第2引数の数字はループに含まれないため、+1を指定する)
for i in range(1, 21):
setting_item_name = f'hitechhpkind{i}'
set_clauses.append(f'{setting_item_name} = :{setting_item_name}')
if is_aggregate_item_clear:
self.query_parameter[setting_item_name] = None
# 政策医療
if len(self.record.policy_medical_flag) > 0:
set_clauses.append('policymedical_flag = :policy_medical_flag')
# 項目クリア判断
is_aggregate_item_clear = self.record.policy_medical_flag == '@'
if is_aggregate_item_clear:
self.query_parameter['policy_medical_flag'] = None
# 20個分の項目設定(rangeの第2引数の数字はループに含まれないため、+1を指定する)
for i in range(1, 21):
num = str(i).zfill(2) # 2桁で0埋め
@ -1151,9 +976,6 @@ class ComInstAttMapper(UltmarcTableMapper):
setting_item_name_content = f'policymedical_content{num}'
set_clauses.append(f'{setting_item_name_code} = :{setting_item_name_code}')
set_clauses.append(f'{setting_item_name_content} = :{setting_item_name_content}')
if is_aggregate_item_clear:
self.query_parameter[setting_item_name_code] = None
self.query_parameter[setting_item_name_content] = None
# 訪問看護ステーション
if len(self.record.visitcarest_flag) > 0:
@ -1161,17 +983,10 @@ class ComInstAttMapper(UltmarcTableMapper):
set_clauses.append('visitcarestation_id = :visitcarestation_id')
set_clauses.append('visitcarestation_code = :visitcarestation_code')
set_clauses.append('visitcarestation_yobi = :visitcarestation_yobi')
if self.record.visitcarest_flag == '@':
self.query_parameter['visitcarest_flag'] = None
self.query_parameter['visitcarestation_id'] = None
self.query_parameter['visitcarestation_code'] = None
self.query_parameter['visitcarestation_yobi'] = None
# 開設年月
if len(self.record.open_date) > 0:
set_clauses.append('opendate = :open_date')
if self.record.open_date == '@':
self.query_parameter['open_date'] = None
update_columns = ','.join(set_clauses)
# 何も更新項目が無い場合はNoneとする（更新処理は行わない）
@ -1184,3 +999,277 @@ class ComInstAttMapper(UltmarcTableMapper):
update_columns=update_columns
)
return update_query
def __set_clearing_item(self):
# DPC対象病院
if self.record.dpc_flag == '@':
self.query_parameter['dpc_flag'] = None
self.query_parameter['dpc_spec_day'] = None
self.query_parameter['dpc_cancel_day'] = None
# DPC準備病院
if self.record.predpc_flag == '@':
self.query_parameter['predpc_flag'] = None
self.query_parameter['predpc_spec_day'] = None
self.query_parameter['predpc_cancel_day'] = None
# がん診療連携拠点病院
if self.record.cancer_flag == '@':
self.query_parameter['cancer_flag'] = None
self.query_parameter['cancer_spec_day'] = None
self.query_parameter['cancer_cancel_day'] = None
# 特定機能病院
if self.record.funchp_flag == '@':
self.query_parameter['funchp_flag'] = None
self.query_parameter['funchp_ok_date'] = None
self.query_parameter['funchp_can_date'] = None
# 地域医療支援病院
if self.record.areasuphp_flag == '@':
self.query_parameter['areasuphp_flag'] = None
self.query_parameter['areasuphp_intrate'] = None
self.query_parameter['areasuphp_ok_date'] = None
self.query_parameter['areasuphp_can_date'] = None
# 超急性期脳卒中加算
if self.record.acuthp_add_flag == '@':
self.query_parameter['acuthp_add_flag'] = None
self.query_parameter['acuthp_add_ok_date'] = None
self.query_parameter['acuthp_add_can_date'] = None
# 総合入院体制加算
if self.record.genadmisiion_flag == '@':
self.query_parameter['genadmisiion_flag'] = None
self.query_parameter['genadmisiion_ok_date'] = None
self.query_parameter['genadmisiion_can_date'] = None
# 医師事務作業補助体制加算
if self.record.assistance_flag == '@':
self.query_parameter['assistance_flag'] = None
self.query_parameter['assistance_ok_date'] = None
self.query_parameter['assistance_can_date'] = None
# 診療録管理体制加算
if self.record.diagnosis_treatment_flag == '@':
self.query_parameter['diagnosis_treatment_flag'] = None
self.query_parameter['diagnosis_treatment_spec_day'] = None
self.query_parameter['diagnosis_treatment_cancel_day'] = None
# 医療安全対策加算
if self.record.safety_flag == '@':
self.query_parameter['safety_flag'] = None
self.query_parameter['safety_spec_day'] = None
self.query_parameter['safety_cancel_day'] = None
# 褥瘡ﾊｲﾘｽｸ患者ｹｱ加算
if self.record.highrisk_flag == '@':
self.query_parameter['highrisk_flag'] = None
self.query_parameter['highrisk_spec_day'] = None
self.query_parameter['highrisk_cancel_day'] = None
# 地域連携小児夜間･休日診療料
if self.record.infant_and_holiday_flag == '@':
self.query_parameter['infant_and_holiday_flag'] = None
self.query_parameter['infant_and_holiday_spec_day'] = None
self.query_parameter['infant_and_holiday_cancel_day'] = None
# 開放型病院
if self.record.ophp_flag == '@':
self.query_parameter['ophp_flag'] = None
self.query_parameter['ophpok_date'] = None
self.query_parameter['ophpcan_date'] = None
# 地域連携ｸﾘﾃｨｶﾙﾊﾟｽ
is_aggregate_item_clear = self.record.critical_flag == '@'
if is_aggregate_item_clear:
self.query_parameter['critical_flag'] = None
# 20個分の項目設定(rangeの第2引数の数字はループに含まれないため、+1を指定する)
for i in range(1, 21):
num = str(i).zfill(2) # 2桁で0埋め
setting_item_name = f'critical_code{num}'
if is_aggregate_item_clear:
self.query_parameter[setting_item_name] = None
# 薬剤管理指導料
if self.record.drgmgthp_flag == '@':
self.query_parameter['drgmgthp_flag'] = None
self.query_parameter['drgmgthp_ok_date'] = None
self.query_parameter['drgmgthp_can_date'] = None
# 画像診断管理加算
if self.record.image_diagnosis_flag == '@':
self.query_parameter['image_diagnosis_flag'] = None
self.query_parameter['image_diagnosis_specified_day'] = None
self.query_parameter['image_diagnosis_cancel_day'] = None
# 外来化学療法加算
if self.record.chemotherapy_flag == '@':
self.query_parameter['chemotherapy_flag'] = None
self.query_parameter['chemotherapy_spec_day'] = None
self.query_parameter['chemotherapy_cancel_day'] = None
# 疾患別ﾘﾊﾋﾞﾘﾃｰｼｮﾝ料
is_aggregate_item_clear = self.record.rehabilitation_flag == '@'
if is_aggregate_item_clear:
self.query_parameter['rehabilitation_flag'] = None
# 10個分の項目設定(rangeの第2引数の数字はループに含まれないため、+1を指定する)
for i in range(1, 11):
num = str(i).zfill(2) # 2桁で0埋め
setting_item_name = f'rehabilitation_code{num}'
if is_aggregate_item_clear:
self.query_parameter[setting_item_name] = None
# 麻酔管理料
if self.record.anesthetizing_manage_flag == '@':
self.query_parameter['anesthetizing_manage_flag'] = None
self.query_parameter['anesthetizing_manage_spec_day'] = None
self.query_parameter['anesthetizing_manage_can_day'] = None
# 在宅療養支援病院･診療所
if self.record.home_recuperation_flag == '@':
self.query_parameter['home_recuperation_flag'] = None
self.query_parameter['home_recuperation_spec_day'] = None
self.query_parameter['home_recuperation_cancel_day'] = None
# 在宅時医学総合管理料
if self.record.synthesis_when_staying_flag == '@':
self.query_parameter['synthesis_when_staying_flag'] = None
self.query_parameter['synthesis_when_staying_spec_day'] = None
self.query_parameter['synthesis_when_staying_can_day'] = None
# 在宅末期医療総合診療料
if self.record.home_late_flag == '@':
self.query_parameter['home_late_flag'] = None
self.query_parameter['home_late_ok_day'] = None
self.query_parameter['home_late_can_day'] = None
# ｹｱﾐｯｸｽ区分
if self.record.caremix_kind == '@':
self.query_parameter['caremix_kind'] = None
# 完全型･移行型区分
if self.record.fullmove_flag == '@':
self.query_parameter['fullmove_flag'] = None
# 療養型病床群
if self.record.resthp_flag == '@':
# 医療型
self.query_parameter['resthp_flag'] = None
self.query_parameter['resthp_care_kind'] = None
self.query_parameter['resthp_bed_num'] = None
self.query_parameter['resthp_ok_date'] = None
self.query_parameter['resthp_can_date'] = None
# 介護型
self.query_parameter['resthp_care_nrs_kind'] = None
self.query_parameter['resthp_care_bed_num'] = None
self.query_parameter['resthp_care_ok_date'] = None
self.query_parameter['resthp_care_can_date'] = None
# 合計
self.query_parameter['resthp_sbed_num'] = None
# 一般病棟
if self.record.nrmhp_flag == '@':
self.query_parameter['nrmhp_flag'] = None
self.query_parameter['nrmhp_care_kind'] = None
self.query_parameter['nrmhp_bed_total_num'] = None
# 精神病棟
if self.record.menthp_flag == '@':
self.query_parameter['menthp_flag'] = None
self.query_parameter['menthp_care_kind'] = None
self.query_parameter['menthp_bed_num'] = None
# 結核病棟
if self.record.tubhp_flag == '@':
self.query_parameter['tubhp_flag'] = None
self.query_parameter['tubhp_care_kind'] = None
self.query_parameter['tubhp_bed_num'] = None
# 感染症指定医療機関
if self.record.infhp_flag == '@':
self.query_parameter['infhp_flag'] = None
self.query_parameter['infhp_flag1'] = None
self.query_parameter['infhp_flag2'] = None
# 感染症病床
if self.record.infhp_bed_flag == '@':
self.query_parameter['infhp_bed_flag'] = None
self.query_parameter['infhp_bed_num'] = None
# 緩和ｹｱ病棟設置病院
if self.record.hospice_flag == '@':
self.query_parameter['hospice_flag'] = None
self.query_parameter['hospice_bed_num'] = None
self.query_parameter['hospice_ok_date'] = None
self.query_parameter['hospice_can_date'] = None
# 医療機能評価
if self.record.hpfunce_st_flag == '@':
self.query_parameter['hpfunce_st_flag'] = None
self.query_parameter['hpfunce_st_kind'] = None
self.query_parameter['hpfunce_st_ok_date'] = None
self.query_parameter['hpfunce_st_can_date'] = None
# 臨床研修指定病院
if self.record.clolyhp_kind == '@':
# 基幹型病院1
self.query_parameter['clolyhp_kind'] = None
self.query_parameter['clolyhp_ok_date'] = None
self.query_parameter['clolyhp_can_date'] = None
# 基幹型病院2（群指定）
self.query_parameter['clhp_kind'] = None
self.query_parameter['clhp_ok_date'] = None
self.query_parameter['clhp_can_date'] = None
# 協力型病院（群指定）
self.query_parameter['cldephp_kind'] = None
self.query_parameter['cldephp_ok_date'] = None
self.query_parameter['cldephp_can_date'] = None
# 災害拠点病院
if self.record.disasthp_flag == '@':
self.query_parameter['disasthp_flag'] = None
# 救急医療
if self.record.d1emerhp_flag == '@':
self.query_parameter['d1emerhp_flag'] = None
self.query_parameter['d2emerhp_flag'] = None
self.query_parameter['d3emerhp_flag'] = None
# 救急告示診療所
if self.record.emergency_clinic == '@':
self.query_parameter['emergency_clinic'] = None
# 治験中核病院
if self.record.trial_core_flag == '@':
self.query_parameter['trial_core_flag'] = None
self.query_parameter['trial_core_div'] = None
self.query_parameter['trial_core_ok_date'] = None
self.query_parameter['trial_core_can_date'] = None
# 認知症疾患医療ｾﾝﾀｰ
if self.record.dementia_flag == '@':
self.query_parameter['dementia_flag'] = None
self.query_parameter['dementia_okd_ate'] = None
self.query_parameter['dementia_can_date'] = None
# 特定健康診査実施機関
if self.record.sphealth_exploration == '@':
self.query_parameter['sphealth_exploration'] = None
# 特定保健指導実施機関
if self.record.sphealth_guidance == '@':
self.query_parameter['sphealth_guidance'] = None
# 先進医療実施医療機関
is_aggregate_item_clear = self.record.hiadhp_flag == '@'
if is_aggregate_item_clear:
self.query_parameter['hiadhp_flag'] = None
# 40個分の項目設定(rangeの第2引数の数字はループに含まれないため、+1を指定する)
for i in range(1, 41):
setting_item_name_code = f'hiadhpcode{i}'
setting_item_name_kind = f'hiadhpkind{i}'
if is_aggregate_item_clear:
self.query_parameter[setting_item_name_code] = None
self.query_parameter[setting_item_name_kind] = None
# 先端医療実施医療機関
is_aggregate_item_clear = self.record.hitechhp_flag == '@'
if is_aggregate_item_clear:
self.query_parameter['hitechhp_flag'] = None
# 20個分の項目設定(rangeの第2引数の数字はループに含まれないため、+1を指定する)
for i in range(1, 21):
setting_item_name = f'hitechhpkind{i}'
if is_aggregate_item_clear:
self.query_parameter[setting_item_name] = None
# 政策医療
# 項目クリア判断
is_aggregate_item_clear = self.record.policy_medical_flag == '@'
if is_aggregate_item_clear:
self.query_parameter['policy_medical_flag'] = None
# 20個分の項目設定(rangeの第2引数の数字はループに含まれないため、+1を指定する)
for i in range(1, 21):
num = str(i).zfill(2) # 2桁で0埋め
setting_item_name_code = f'policymedical_code{num}'
setting_item_name_content = f'policymedical_content{num}'
if is_aggregate_item_clear:
self.query_parameter[setting_item_name_code] = None
self.query_parameter[setting_item_name_content] = None
# 訪問看護ステーション
if self.record.visitcarest_flag == '@':
self.query_parameter['visitcarest_flag'] = None
self.query_parameter['visitcarestation_id'] = None
self.query_parameter['visitcarestation_code'] = None
self.query_parameter['visitcarestation_yobi'] = None
# 開設年月
if self.record.open_date == '@':
self.query_parameter['open_date'] = None
return

128
ecs/jskult-batch-daily/src/batch/ultmarc/utmp_tables/table_mapper/concrete/com_inst_mapper.py
View File

@ -263,6 +263,10 @@ class ComInstMapper(UltmarcTableMapper):
def __make_upsert_query(self):
# レコードの存在確認（施設）
record_count = self.db.execute_select(self.RECORD_EXISTS_QUERY, self.query_parameter)
# 「@」による項目クリアを設定
self.__set_clearing_item()
if record_count[0]['count_num'] == 0:
# 存在しない場合はInsert
self.queries.append(self.INSERT_INST_QUERY)
@ -344,96 +348,64 @@ class ComInstMapper(UltmarcTableMapper):
# 未確認フラグ
if len(self.record.uncheck_flag) > 0:
set_clauses.append('unconf_flg = :uncheck_flag')
if self.record.uncheck_flag == '@':
self.query_parameter['uncheck_flag'] = None
# 削除予定理由コード
if len(self.record.hpdel_code) > 0:
set_clauses.append('delete_sche_reason_cd = :hpdel_code')
if self.record.hpdel_code == '@':
self.query_parameter['hpdel_code'] = None
# 重複時相手先コード
if len(self.record.dup_opp_code) > 0:
set_clauses.append('dup_opp_cd = :dup_opp_code')
if self.record.duphp_id == '@':
self.query_parameter['dup_opp_code'] = None
# 住所不明理由コード
if len(self.record.hp_addr_lost_code) > 0:
set_clauses.append('addr_unknown_reason_cd = :hp_addr_lost_code')
if self.record.hp_addr_lost_code == '@':
self.query_parameter['hp_addr_lost_code'] = None
# 電話番号なしフラグ
if len(self.record.tel_nothing_flag) > 0:
set_clauses.append('phone_number_non_flg = :tel_nothing_flag')
if self.record.tel_nothing_flag == '@':
self.query_parameter['tel_nothing_flag'] = None
# 電話番号
if len(self.record.hp_tel) > 0:
set_clauses.append('inst_phone_number = :hp_tel')
if self.record.hp_tel == '@':
self.query_parameter['hp_tel'] = None
# 施設代表者コード
if len(self.record.inst_repre_code) > 0:
set_clauses.append('inst_repre_cd = :inst_repre_code')
if self.record.president_id == '@':
self.query_parameter['inst_repre_code'] = None
# 代表者(ｶﾅ)
if len(self.record.president_kana) > 0:
set_clauses.append('inst_repre_kana = :president_kana')
if self.record.president_kana == '@':
self.query_parameter['president_kana'] = None
# 代表者(漢字) ※「＠」が大文字
if len(self.record.president) > 0:
set_clauses.append('inst_repre = :president')
if self.record.president == '＠':
self.query_parameter['president'] = None
# 開業予定ﾌﾗｸﾞ・開業予定年月
if len(self.record.open_flag + self.record.open_year_month) > 0:
set_clauses.append('estab_sche_flg = :open_flag')
set_clauses.append('estab_sche_ym = :open_year_month')
if self.record.open_flag == '@':
self.query_parameter['open_flag'] = None
self.query_parameter['open_year_month'] = None
# 休院ﾌﾗｸﾞ・休院開始年月
if len(self.record.close_flag + self.record.close_year_month) > 0:
set_clauses.append('close_flg = :close_flag')
set_clauses.append('close_start_ym = :close_year_month')
if self.record.close_flag == '@':
self.query_parameter['close_flag'] = None
self.query_parameter['close_year_month'] = None
# 関連大学親コード
if len(self.record.univ_prnt_code) > 0:
set_clauses.append('rltd_univ_prnt_cd = :univ_prnt_code')
if self.record.assoc_parrent_id == '@':
self.query_parameter['univ_prnt_code'] = None
# 病棟閉鎖フラグ
if len(self.record.close_flag2) > 0:
set_clauses.append('ward_abolish_flg = :close_flag2')
if self.record.close_flag2 == '@':
self.query_parameter['close_flag2'] = None
# 病床数(定員)
if self.record.bed_num is not None:
set_clauses.append('bed_num = :bed_num')
if self.record.bed_num == '@':
self.query_parameter['bed_num'] = None
# 許可病床ﾒﾝﾃ日付
if len(self.record.bed_class_maint_date) > 0:
set_clauses.append('prmit_bed_maint_ymd = :bed_class_maint_date')
if self.record.bed_class_maint_date == '@':
self.query_parameter['bed_class_maint_date'] = None
# 許可ベッド数（合計、精神、結核、感染、その他、一般病床、療養病床）
if not self.record.prmit_bed.count(None) == len(self.record.prmit_bed):
@ -444,14 +416,6 @@ class ComInstMapper(UltmarcTableMapper):
set_clauses.append('prmit_bed_num_other = :bed_num_gen')
set_clauses.append('prmit_bed_num_gen = :bed_num_gen2')
set_clauses.append('prmit_bed_num_rcup = :bed_num_rest')
if self.record.bed_num_sum == '@':
self.query_parameter['bed_num_sum'] = None
self.query_parameter['bed_num_psy'] = None
self.query_parameter['bed_num_tub'] = None
self.query_parameter['bed_num_epi'] = None
self.query_parameter['bed_num_gen'] = None
self.query_parameter['bed_num_gen2'] = None
self.query_parameter['bed_num_rest'] = None
# 検査項目(微生物、血清、血液、病理、寄生虫、生化、RI)
if sum(len(item) for item in self.record.insp_item) > 0:
@ -462,14 +426,6 @@ class ComInstMapper(UltmarcTableMapper):
set_clauses.append('insp_item_paras = :inspect_code5')
set_clauses.append('insp_item_biochem = :inspect_code6')
set_clauses.append('insp_item_ri = :inspect_code7')
if self.record.inspect_code1 == '@':
self.query_parameter['inspect_code1'] = None
self.query_parameter['inspect_code2'] = None
self.query_parameter['inspect_code3'] = None
self.query_parameter['inspect_code4'] = None
self.query_parameter['inspect_code5'] = None
self.query_parameter['inspect_code6'] = None
self.query_parameter['inspect_code7'] = None
update_columns = ','.join(set_clauses)
# 何も更新項目が無い場合は更新処理は行わない
@ -494,6 +450,7 @@ class ComInstMapper(UltmarcTableMapper):
# 削除
self.queries.append(self.PHYSICAL_DELETE_TRT_QUERY)
# 診療科目の1つ目の値がクリアマーク（@）の場合、診療科目を登録しない
if self.record.medsbj_code[0] == "@":
return
@ -516,10 +473,15 @@ class ComInstMapper(UltmarcTableMapper):
record_count = self.db.execute_select(self.RECORD_EXISTS_SPCARE_QUERY, self.query_parameter)
# 存在しない場合はInsert
if record_count[0]['count_num'] == 0:
# 特養医務室の集合項目の値がクリアマーク(@)の場合、登録しない
if self.record.dcfhp_92id == "@":
return
self.queries.append(self.INSERT_SPCARE_QUERY)
return
# 存在する場合はUpdate
# 特養医務室の集合項目の値がクリアマーク(@)の場合、DCF親施設コードをクリアし、削除日を設定
if self.record.dcfhp_92id == "@":
self.query_parameter['dcf_prnt_inst_code'] = None
self.query_parameter['delete_ymd'] = self.query_parameter['execute_date_str_ymd']
@ -529,3 +491,73 @@ class ComInstMapper(UltmarcTableMapper):
self.queries.append(self.UPDATE_SPCARE_QUERY)
return
def __set_clearing_item(self):
# 未確認フラグ
if self.record.uncheck_flag == '@':
self.query_parameter['uncheck_flag'] = None
# 削除予定理由コード
if self.record.hpdel_code == '@':
self.query_parameter['hpdel_code'] = None
# 重複時相手先コード
if self.record.duphp_id == '@':
self.query_parameter['dup_opp_code'] = None
# 住所不明理由コード
if self.record.hp_addr_lost_code == '@':
self.query_parameter['hp_addr_lost_code'] = None
# 電話番号なしフラグ
if self.record.tel_nothing_flag == '@':
self.query_parameter['tel_nothing_flag'] = None
# 電話番号
if self.record.hp_tel == '@':
self.query_parameter['hp_tel'] = None
# 施設代表者コード
if self.record.president_id == '@':
self.query_parameter['inst_repre_code'] = None
# 代表者(ｶﾅ)
if self.record.president_kana == '@':
self.query_parameter['president_kana'] = None
# 代表者(漢字) ※全角文字のため、クリアマーク「＠」が大文字
if self.record.president == '＠':
self.query_parameter['president'] = None
# 開業予定ﾌﾗｸﾞ・開業予定年月
if self.record.open_flag == '@':
self.query_parameter['open_flag'] = None
self.query_parameter['open_year_month'] = None
# 休院ﾌﾗｸﾞ・休院開始年月
if self.record.close_flag == '@':
self.query_parameter['close_flag'] = None
self.query_parameter['close_year_month'] = None
# 関連大学親コード
if self.record.assoc_parrent_id == '@':
self.query_parameter['univ_prnt_code'] = None
# 病棟閉鎖フラグ
if self.record.close_flag2 == '@':
self.query_parameter['close_flag2'] = None
# 病床数(定員)
if self.record.bed_num == '@':
self.query_parameter['bed_num'] = None
# 許可病床ﾒﾝﾃ日付
if self.record.bed_class_maint_date == '@':
self.query_parameter['bed_class_maint_date'] = None
# 許可ベッド数（合計、精神、結核、感染、その他、一般病床、療養病床）
if self.record.bed_num_sum == '@':
self.query_parameter['bed_num_sum'] = None
self.query_parameter['bed_num_psy'] = None
self.query_parameter['bed_num_tub'] = None
self.query_parameter['bed_num_epi'] = None
self.query_parameter['bed_num_gen'] = None
self.query_parameter['bed_num_gen2'] = None
self.query_parameter['bed_num_rest'] = None
# 検査項目(微生物、血清、血液、病理、寄生虫、生化、RI)
if self.record.inspect_code1 == '@':
self.query_parameter['inspect_code1'] = None
self.query_parameter['inspect_code2'] = None
self.query_parameter['inspect_code3'] = None
self.query_parameter['inspect_code4'] = None
self.query_parameter['inspect_code5'] = None
self.query_parameter['inspect_code6'] = None
self.query_parameter['inspect_code7'] = None
return

30
ecs/jskult-batch-daily/src/batch/ultmarc/utmp_tables/table_mapper/concrete/com_sp_field_mapper.py
View File

@ -104,6 +104,10 @@ class ComSpFieldMapper(UltmarcTableMapper):
# レコードの存在確認
record_count = self.db.execute_select(self.RECORD_EXISTS_QUERY, self.query_parameter)
# 「@」による項目クリアを設定
self.__set_clearing_item()
# 存在しない場合はInsert
if record_count[0]['count_num'] == 0:
return self.INSERT_QUERY
@ -115,23 +119,14 @@ class ComSpFieldMapper(UltmarcTableMapper):
if len(self.record.specialist_flg) > 0:
set_clauses.append('specialist_flg = :specialist_flg')
set_clauses.append('specialist_publsh_ymd = :specialist_publsh_ymd')
if self.record.specialist_flg == '@':
self.query_parameter['specialist_flg'] = None
self.query_parameter['specialist_publsh_ymd'] = None
if len(self.record.ackn_med_flg) > 0:
set_clauses.append('ackn_med_flg = :ackn_med_flg')
set_clauses.append('ackn_med_publsh_ymd = :ackn_med_publsh_ymd')
if self.record.ackn_med_flg == '@':
self.query_parameter['ackn_med_flg'] = None
self.query_parameter['ackn_med_publsh_ymd'] = None
if len(self.record.guide_med_flg) > 0:
set_clauses.append('guide_med_flg = :guide_med_flg')
set_clauses.append('guide_med_publsh_ymd = :guide_med_publsh_ymd')
if self.record.guide_med_flg == '@':
self.query_parameter['guide_med_flg'] = None
self.query_parameter['guide_med_publsh_ymd'] = None
update_columns = ','.join(set_clauses)
# 何も更新項目が無い場合はNoneとする（更新処理は行わない）
@ -144,3 +139,20 @@ class ComSpFieldMapper(UltmarcTableMapper):
update_columns=update_columns
)
return update_query
def __set_clearing_item(self):
# 専門医の集合項目クリア
if self.record.specialist_flg == '@':
self.query_parameter['specialist_flg'] = None
self.query_parameter['specialist_publsh_ymd'] = None
# 認定医の集合項目クリア
if self.record.ackn_med_flg == '@':
self.query_parameter['ackn_med_flg'] = None
self.query_parameter['ackn_med_publsh_ymd'] = None
# 指導医の集合項目クリア
if self.record.guide_med_flg == '@':
self.query_parameter['guide_med_flg'] = None
self.query_parameter['guide_med_publsh_ymd'] = None
return

3
ecs/jskult-batch-daily/tests/batch/ultmarc/utmp_tables/table_mapper/com_dr/com_dr_insert.csv
View File

@ -3,6 +3,5 @@
"501","01","995783","00","A","20141113","20141114",,,,,"船越　正信","ﾌﾅｺｼ ﾏｻﾉﾌﾞ","1","3","29","01","06","53","55","3","53","039","1","3","53","A01","L01","E02","C04","L03","7","00","000","000","000",,,,,"00","00","00","00","00","00","00","00",,"02","A05","20051003",,"2",,,
"501","01","997682","00","A","20141113","20141114",,,,,"川崎　三紀子","ｶﾜｻｷ ﾐｷｺ","2","3","46","10","03","99","99","4","11","057","1","4","11","A01","A58",,,,,"13","119","047","000","173-0001","東京都板橋区本町６－３－３０１","ﾄｳｷﾖｳﾄ ｲﾀﾊﾞｼｸ ﾎﾝﾁﾖｳ 6-3-301","6-3-301","03","03","02","00","07","07","06","00","03-3579-1698",,,,,"2",,,"1"
"501","01","997906","00","A","20141113","20141114",,,,,"丘　守正","ｵｶ ﾓﾘﾏｻ","1","3","20","03","11","99","31","3","45","799","1",,,"A01","L01","A31","A21","A11",,"08","221","095","000","312-0021","茨城県ひたちなか市大字三反田３８９２－４","ｲﾊﾞﾗｷｹﾝ ﾋﾀﾁﾅｶｼ ｵｵｱｻﾞﾐﾀﾝﾀﾞ 3892-4","3892-4","03","06","05","00","08","07","11","00","029-274-7110",,,,,"1","4","03",
"501","01","999613","00","A","20141113","20141114","5","01","481065","00","藤田　茜","ﾌｼﾞﾀ ｱｶﾈ","2",,,,,"99","99",,,"799","1","4","23",,,,,,"6","00","000","000","000",,,,,"00","00","00","00","00","00","00","00",,,,,,"9",,,
"501","01","997907","00","A","20141113","20141114",,,,,"丘　守正","ｵｶ ﾓﾘﾏｻ","1",,,"03","11","99","31","3","45","799","1",,,"","","","","",,"08","221","095","000","312-0021","茨城県ひたちなか市大字三反田３８９２－４","ｲﾊﾞﾗｷｹﾝ ﾋﾀﾁﾅｶｼ ｵｵｱｻﾞﾐﾀﾝﾀﾞ 3892-4","3892-4","03","06","05","00","08","07","11","00","029-274-7110",,,,,"1","4","03",
"501","01","997908","00","A","20141113","20141114",,,,,"丘　守正","ｵｶ ﾓﾘﾏｻ","1","3","20",,,"99","31","3","45","799","1",,,"","","","","",,"08","221","095","000","312-0021","茨城県ひたちなか市大字三反田３８９２－４","ｲﾊﾞﾗｷｹﾝ ﾋﾀﾁﾅｶｼ ｵｵｱｻﾞﾐﾀﾝﾀﾞ 3892-4","3892-4","03","06","05","00","08","07","11","00","029-274-7110",,,,,"1","4","03",
"501","01","997908","00","A","20141113","20141114","@","@","481065","00","藤堂　尚也","ﾄｳﾄﾞｳ ﾅｵﾔ","1","@","20","10","03","99","31","@","45","799","1","@","23","@","L01","E02","C04","L03","@","08","221","095","000","312-0021","茨城県ひたちなか市大字三反田３８９２－４","ｲﾊﾞﾗｷｹﾝ ﾋﾀﾁﾅｶｼ ｵｵｱｻﾞﾐﾀﾝﾀﾞ 3892-4","3892-4","03","06","05","00","08","07","11","00","@","@","@","@","@","1","@","03","1"

1 501 01 222222 33 A 20230425 20230426 7 8 9 10 11 12 1 4 15 06 17 18 19 1 21 022 3 4 25 A26 C27 I28 K29 L30 1 32 033 034 035 231-0036 ３７ 38 126-1-39 40 41 42 43 44 45 46 47 045-625-2048 49 50 20200501 20200502 3 4 55 6
3 501 01 995783 00 A 20141113 20141114 船越　正信 ﾌﾅｺｼ ﾏｻﾉﾌﾞ 1 3 29 01 06 53 55 3 53 039 1 3 53 A01 L01 E02 C04 L03 7 00 000 000 000 00 00 00 00 00 00 00 00 02 A05 20051003 2
4 501 01 997682 00 A 20141113 20141114 川崎　三紀子 ｶﾜｻｷ ﾐｷｺ 2 3 46 10 03 99 99 4 11 057 1 4 11 A01 A58 13 119 047 000 173-0001 東京都板橋区本町６－３－３０１ ﾄｳｷﾖｳﾄ ｲﾀﾊﾞｼｸ ﾎﾝﾁﾖｳ 6-3-301 6-3-301 03 03 02 00 07 07 06 00 03-3579-1698 2 1
5 501 01 997906 00 A 20141113 20141114 丘　守正 ｵｶ ﾓﾘﾏｻ 1 3 20 03 11 99 31 3 45 799 1 A01 L01 A31 A21 A11 08 221 095 000 312-0021 茨城県ひたちなか市大字三反田３８９２－４ ｲﾊﾞﾗｷｹﾝ ﾋﾀﾁﾅｶｼ ｵｵｱｻﾞﾐﾀﾝﾀﾞ 3892-4 3892-4 03 06 05 00 08 07 11 00 029-274-7110 1 4 03
501 01 999613 00 A 20141113 20141114 5 01 481065 00 藤田　茜 ﾌｼﾞﾀ ｱｶﾈ 2 99 99 799 1 4 23 6 00 000 000 000 00 00 00 00 00 00 00 00 9
6 501 01 997907 00 A 20141113 20141114 丘　守正 ｵｶ ﾓﾘﾏｻ 1 03 11 99 31 3 45 799 1 08 221 095 000 312-0021 茨城県ひたちなか市大字三反田３８９２－４ ｲﾊﾞﾗｷｹﾝ ﾋﾀﾁﾅｶｼ ｵｵｱｻﾞﾐﾀﾝﾀﾞ 3892-4 3892-4 03 06 05 00 08 07 11 00 029-274-7110 1 4 03
7 501 01 997908 00 A 20141113 20141114 @ @ 481065 00 丘　守正 藤堂　尚也 ｵｶ ﾓﾘﾏｻ ﾄｳﾄﾞｳ ﾅｵﾔ 1 3 @ 20 10 03 99 31 3 @ 45 799 1 @ 23 @ L01 E02 C04 L03 @ 08 221 095 000 312-0021 茨城県ひたちなか市大字三反田３８９２－４ ｲﾊﾞﾗｷｹﾝ ﾋﾀﾁﾅｶｼ ｵｵｱｻﾞﾐﾀﾝﾀﾞ 3892-4 3892-4 03 06 05 00 08 07 11 00 029-274-7110 @ @ @ @ @ 1 4 @ 03 1

3
ecs/jskult-batch-daily/tests/batch/ultmarc/utmp_tables/table_mapper/com_dr/expect_com_dr_insert.csv
View File

@ -5,5 +5,4 @@
"0199768200","ｶﾜｻｷ ﾐｷｺ","川崎　三紀子","3","46","10","03","19711003","99",,,,"03-3579-1698","ﾄｳｷﾖｳﾄ ｲﾀﾊﾞｼｸ ﾎﾝﾁﾖｳ 6-3-301","東京都板橋区本町６－３－３０１","173-0001","13119047000","13","119","6-3-301","07070600","03030200","99","2","2",,,"057","1","4","11","1999","1",,"1",,,,,"4","11","1999","NULL","NULL","0","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","2017/10/08 16:16:43","com_dr_mapper","2017/10/08 16:16:43","com_dr_mapper"
"0199790600","ｵｶ ﾓﾘﾏｻ","丘　守正","3","20","03","11","19450311","99","4","03","1991","029-274-7110","ｲﾊﾞﾗｷｹﾝ ﾋﾀﾁﾅｶｼ ｵｵｱｻﾞﾐﾀﾝﾀﾞ 3892-4","茨城県ひたちなか市大字三反田３８９２－４","312-0021","08221095000","08","221","3892-4","08071100","03060500","31","1","1",,,"799","1","3","45","1970",,,"1",,,,,,,,"NULL","NULL","0","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","2017/10/08 16:16:43","com_dr_mapper","2017/10/08 16:16:43","com_dr_mapper"
"0199790700","ｵｶ ﾓﾘﾏｻ","丘　守正",,,"03","11"," 0311","99","4","03","1991","029-274-7110","ｲﾊﾞﾗｷｹﾝ ﾋﾀﾁﾅｶｼ ｵｵｱｻﾞﾐﾀﾝﾀﾞ 3892-4","茨城県ひたちなか市大字三反田３８９２－４","312-0021","08221095000","08","221","3892-4","08071100","03060500","31","1","1",,,"799","1","3","45","1970",,,"1",,,,,,,,"NULL","NULL","0","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","2017/10/08 16:16:43","com_dr_mapper","2017/10/08 16:16:43","com_dr_mapper"
"0199790800","ｵｶ ﾓﾘﾏｻ","丘　守正","3","20",,,"","99","4","03","1991","029-274-7110","ｲﾊﾞﾗｷｹﾝ ﾋﾀﾁﾅｶｼ ｵｵｱｻﾞﾐﾀﾝﾀﾞ 3892-4","茨城県ひたちなか市大字三反田３８９２－４","312-0021","08221095000","08","221","3892-4","08071100","03060500","31","1","1",,,"799","1","3","45","1970",,,"1",,,,,,,,"NULL","NULL","0","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","2017/10/08 16:16:43","com_dr_mapper","2017/10/08 16:16:43","com_dr_mapper"
"0199961300","ﾌｼﾞﾀ ｱｶﾈ","藤田　茜",,,,,,"99",,,,,,,,"00000000000","00","000",,"00000000","00000000","99","9","2","5","6","799","1",,,,,"0148106500","1",,,,,"4","23","2011","NULL","NULL","0","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","2017/10/08 16:16:43","com_dr_mapper","2017/10/08 16:16:43","com_dr_mapper"
"0199790800","ﾄｳﾄﾞｳ ﾅｵﾔ","藤堂　尚也","NULL","NULL","NULL","NULL","NULL","99","NULL","NULL","NULL","NULL","ｲﾊﾞﾗｷｹﾝ ﾋﾀﾁﾅｶｼ ｵｵｱｻﾞﾐﾀﾝﾀﾞ 3892-4","茨城県ひたちなか市大字三反田３８９２－４","312-0021","08221095000","08","221","3892-4","08071100","03060500","31","1","1","NULL","NULL","799","1","NULL","NULL","NULL","1","NULL","1","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","0","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","2017/10/08 16:16:43","com_dr_mapper","2017/10/08 16:16:43","com_dr_mapper"

1 dcf_pcf_dr_cd dr_name_kana dr_name birthday_era birthday_year birthday_month birthday_day birthday hometown_cd estab_era estab_year estab_y home_phone_number home_addr_kana home_addr home_postal_number addr_village_cd prefc_cd city_cd addr_display_number addr_cnt_kana addr_cnt dr_circle_cd estab_div_cd sex_cd delete_sche_reason_cd addr_unknown_reason_cd alma_cd depart_disc_cd grad_era grad_year grad_y lump_regist_flg opp_dup_cd dr_ph_div use_stop_div use_stop_reason_cd use_stop_regist_ymd use_stop_cancel_ymd drday_era drday_year drday_y cor_dnfdr_cd abolish_ymd delete_flg filler_1 filler_2 filler_3 filler_4 filler_5 regist_date create_user update_date update_user sys_regist_date regist_prgm_id sys_update_date update_prgm_id
5 0199768200 ｶﾜｻｷ ﾐｷｺ 川崎　三紀子 3 46 10 03 19711003 99 03-3579-1698 ﾄｳｷﾖｳﾄ ｲﾀﾊﾞｼｸ ﾎﾝﾁﾖｳ 6-3-301 東京都板橋区本町６－３－３０１ 173-0001 13119047000 13 119 6-3-301 07070600 03030200 99 2 2 057 1 4 11 1999 1 1 4 11 1999 NULL NULL 0 NULL NULL NULL NULL NULL NULL NULL NULL NULL 2017/10/08 16:16:43 com_dr_mapper 2017/10/08 16:16:43 com_dr_mapper
6 0199790600 ｵｶ ﾓﾘﾏｻ 丘　守正 3 20 03 11 19450311 99 4 03 1991 029-274-7110 ｲﾊﾞﾗｷｹﾝ ﾋﾀﾁﾅｶｼ ｵｵｱｻﾞﾐﾀﾝﾀﾞ 3892-4 茨城県ひたちなか市大字三反田３８９２－４ 312-0021 08221095000 08 221 3892-4 08071100 03060500 31 1 1 799 1 3 45 1970 1 NULL NULL 0 NULL NULL NULL NULL NULL NULL NULL NULL NULL 2017/10/08 16:16:43 com_dr_mapper 2017/10/08 16:16:43 com_dr_mapper
7 0199790700 ｵｶ ﾓﾘﾏｻ 丘　守正 03 11 0311 99 4 03 1991 029-274-7110 ｲﾊﾞﾗｷｹﾝ ﾋﾀﾁﾅｶｼ ｵｵｱｻﾞﾐﾀﾝﾀﾞ 3892-4 茨城県ひたちなか市大字三反田３８９２－４ 312-0021 08221095000 08 221 3892-4 08071100 03060500 31 1 1 799 1 3 45 1970 1 NULL NULL 0 NULL NULL NULL NULL NULL NULL NULL NULL NULL 2017/10/08 16:16:43 com_dr_mapper 2017/10/08 16:16:43 com_dr_mapper
8 0199790800 ｵｶ ﾓﾘﾏｻ ﾄｳﾄﾞｳ ﾅｵﾔ 丘　守正 藤堂　尚也 3 NULL 20 NULL NULL NULL NULL 99 4 NULL 03 NULL 1991 NULL 029-274-7110 NULL ｲﾊﾞﾗｷｹﾝ ﾋﾀﾁﾅｶｼ ｵｵｱｻﾞﾐﾀﾝﾀﾞ 3892-4 茨城県ひたちなか市大字三反田３８９２－４ 312-0021 08221095000 08 221 3892-4 08071100 03060500 31 1 1 NULL NULL 799 1 3 NULL 45 NULL 1970 NULL 1 NULL 1 NULL NULL NULL NULL NULL NULL NULL NULL NULL 0 NULL NULL NULL NULL NULL NULL NULL NULL NULL 2017/10/08 16:16:43 com_dr_mapper 2017/10/08 16:16:43 com_dr_mapper
0199961300 ﾌｼﾞﾀ ｱｶﾈ 藤田　茜 99 00000000000 00 000 00000000 00000000 99 9 2 5 6 799 1 0148106500 1 4 23 2011 NULL NULL 0 NULL NULL NULL NULL NULL NULL NULL NULL NULL 2017/10/08 16:16:43 com_dr_mapper 2017/10/08 16:16:43 com_dr_mapper

1
ecs/jskult-batch-daily/tests/batch/ultmarc/utmp_tables/table_mapper/com_inst/com_inst_insert.csv
View File

@ -5,3 +5,4 @@
"101","00","9901679","","A","20141113","20141114","","","","","","鹿児島市医師会臨床検査センター","ｶｺﾞｼﾏｼｲｼｶｲﾘﾝｼﾖｳｹﾝｻｾﾝﾀ-","鹿児島市医師会臨床検査センター","ｶｺﾞｼﾏｼｲｼｶｲﾘﾝｼﾖｳｹﾝｻｾﾝﾀ-","","46","201","017","000","892-0846","鹿児島県鹿児島市加治屋町３－１０","ｶｺﾞｼﾏｹﾝ ｶｺﾞｼﾏｼ ｶｼﾞﾔﾁﾖｳ 3-10","3-10","04","04","04","00","08","07","08","00","","099-226-8827","470","60","01","148013","","海江田　健","ｶｲｴﾀﾞ ﾀｹﾙ","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","9","9","","","","","0","","","","","","","","","1","1","1","1","1","1","1","","",""
"101","00","9904439","","A","20141113","20141114","","","","","","川崎市立井田病院","ｶﾜｻｷｼﾘﾂｲﾀﾞﾋﾞﾖｳｲﾝ","井田病院　市立","ｲﾀﾞﾋﾞﾖｳｲﾝ ｼﾘﾂ","","14","133","001","002","211-0035","神奈川県川崎市中原区井田２－２７－１","ｶﾅｶﾞﾜｹﾝ ｶﾜｻｷｼ ﾅｶﾊﾗｸ ｲﾀﾞ 2-27-1","2-27-1","04","06","02","02","08","12","04","02","","044-766-2188","221","01","","","","","","","","","","A01","A34","A22","M01","D02","A12","A81","C01","N03","K01","J01","P02","O01","B01","C04","E02","F01","I01","C05","B31","H02","A41","A03","A58","A61","A65","F08","A56","B11","B22","B04","P03","G06","A57","","","","","","","","","","","","","","","","","","","","","","","","","","","1","3","","","","","370","20140811","370","0","27","0","343","343","0","","","","","","","","","",""
"101","00","9929798","","A","20141113","20141114","","","","","","パーソナルヘルス学びのクリニック","ﾊﾟ-ｿﾅﾙﾍﾙｽﾏﾅﾋﾞﾉｸﾘﾆﾂｸ","パーソナルヘルス学びのＣＬ","ﾊﾟ-ｿﾅﾙﾍﾙｽﾏﾅﾋﾞﾉｸﾘﾆﾂｸ","","13","103","025","002","107-0062","東京都港区南青山２－２－１５　ウイン青山４０５","ﾄｳｷﾖｳﾄ ﾐﾅﾄｸ ﾐﾅﾐｱｵﾔﾏ 2-2-1 ｳｲﾝｱｵﾔﾏ 405","2-2-15-405","03","02","03","02","07","05","08","02","1","","472","10","01","331831","","白澤　博満","ｼﾗｻﾜ ﾋﾛﾐﾂ","","","","","A01","I01","A57","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","7","6","","","","","0","20130415","0","0","0","0","0","0","0","","","","","","","","","",""
"101","99","99999","99","A","20230606","200230607","@","@","@","11","12","あいうえおかきくけこあいうえおかきくけこあいうえおかきくけこあいうえおかきくけこあいうえおかきくけこ","アイウエオカクキケコアイウエオカクキケコアイウエオカクキケコアイウエオカクキケコ","あいうえおかきくけこあいうえおかきくけこあいうえお","アイウエオカクキケコアイウエオカクキケコ","@","18","19","20","21","123-4522","あいうえおかきくけこあいうえおかきくけこあいうえおかきくけこあいうえおかきくけこあいうえおかきくけこ","アイウエオカクキケコアイウエオカクキケコアイウエオカクキケコ","25","26","27","28","29","30","31","32","33","@","@","36","37","@","39","40","＠","@","@","202304","@","202306","@","48","49","50","51","52","53","54","55","56","57","58","59","60","61","62","63","64","65","66","67","68","69","70","71","72","73","74","75","76","77","78","79","80","81","82","83","84","85","86","87","88","89","90","91","92","93","94","95","96","97","98","99","100","101","102","103","104","105","106","7","8","@","10","11","@","@","@","@","6","7","8","9","0","1","@","3","4","5","6","7","8","@","333333","11"

1 101 22 33333 44 A 20230606 200230607 8 9 10 11 12 あいうえおかきくけこあいうえおかきくけこあいうえおかきくけこあいうえおかきくけこあいうえおかきくけこ アイウエオカクキケコアイウエオカクキケコアイウエオカクキケコアイウエオカクキケコ あいうえおかきくけこあいうえおかきくけこあいうえお アイウエオカクキケコアイウエオカクキケコ 7 18 19 20 21 123-4522 あいうえおかきくけこあいうえおかきくけこあいうえおかきくけこあいうえおかきくけこあいうえおかきくけこ アイウエオカクキケコアイウエオカクキケコアイウエオカクキケコ 25 26 27 28 29 30 31 32 33 4 35 36 37 38 39 40 あいうえおかきくけこあいうえおかきくけこ アイウエオカクキケコ 3 202304 5 202306 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 7 8 8 10 11 2 113 20230114 115 6 7 8 9 0 1 2 3 4 5 6 7 8 99 333333 11
5 101 00 9901679 A 20141113 20141114 鹿児島市医師会臨床検査センター ｶｺﾞｼﾏｼｲｼｶｲﾘﾝｼﾖｳｹﾝｻｾﾝﾀ- 鹿児島市医師会臨床検査センター ｶｺﾞｼﾏｼｲｼｶｲﾘﾝｼﾖｳｹﾝｻｾﾝﾀ- 46 201 017 000 892-0846 鹿児島県鹿児島市加治屋町３－１０ ｶｺﾞｼﾏｹﾝ ｶｺﾞｼﾏｼ ｶｼﾞﾔﾁﾖｳ 3-10 3-10 04 04 04 00 08 07 08 00 099-226-8827 470 60 01 148013 海江田　健 ｶｲｴﾀﾞ ﾀｹﾙ 9 9 0 1 1 1 1 1 1 1
6 101 00 9904439 A 20141113 20141114 川崎市立井田病院 ｶﾜｻｷｼﾘﾂｲﾀﾞﾋﾞﾖｳｲﾝ 井田病院　市立 ｲﾀﾞﾋﾞﾖｳｲﾝ ｼﾘﾂ 14 133 001 002 211-0035 神奈川県川崎市中原区井田２－２７－１ ｶﾅｶﾞﾜｹﾝ ｶﾜｻｷｼ ﾅｶﾊﾗｸ ｲﾀﾞ 2-27-1 2-27-1 04 06 02 02 08 12 04 02 044-766-2188 221 01 A01 A34 A22 M01 D02 A12 A81 C01 N03 K01 J01 P02 O01 B01 C04 E02 F01 I01 C05 B31 H02 A41 A03 A58 A61 A65 F08 A56 B11 B22 B04 P03 G06 A57 1 3 370 20140811 370 0 27 0 343 343 0
7 101 00 9929798 A 20141113 20141114 パーソナルヘルス学びのクリニック ﾊﾟ-ｿﾅﾙﾍﾙｽﾏﾅﾋﾞﾉｸﾘﾆﾂｸ パーソナルヘルス学びのＣＬ ﾊﾟ-ｿﾅﾙﾍﾙｽﾏﾅﾋﾞﾉｸﾘﾆﾂｸ 13 103 025 002 107-0062 東京都港区南青山２－２－１５　ウイン青山４０５ ﾄｳｷﾖｳﾄ ﾐﾅﾄｸ ﾐﾅﾐｱｵﾔﾏ 2-2-1 ｳｲﾝｱｵﾔﾏ 405 2-2-15-405 03 02 03 02 07 05 08 02 1 472 10 01 331831 白澤　博満 ｼﾗｻﾜ ﾋﾛﾐﾂ A01 I01 A57 7 6 0 20130415 0 0 0 0 0 0 0
8 101 99 99999 99 A 20230606 200230607 @ @ @ 11 12 あいうえおかきくけこあいうえおかきくけこあいうえおかきくけこあいうえおかきくけこあいうえおかきくけこ アイウエオカクキケコアイウエオカクキケコアイウエオカクキケコアイウエオカクキケコ あいうえおかきくけこあいうえおかきくけこあいうえお アイウエオカクキケコアイウエオカクキケコ @ 18 19 20 21 123-4522 あいうえおかきくけこあいうえおかきくけこあいうえおかきくけこあいうえおかきくけこあいうえおかきくけこ アイウエオカクキケコアイウエオカクキケコアイウエオカクキケコ 25 26 27 28 29 30 31 32 33 @ @ 36 37 @ 39 40 ＠ @ @ 202304 @ 202306 @ 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 7 8 @ 10 11 @ @ @ @ 6 7 8 9 0 1 @ 3 4 5 6 7 8 @ 333333 11

1
ecs/jskult-batch-daily/tests/batch/ultmarc/utmp_tables/table_mapper/com_inst/expect_com_inst_insert.csv
View File

@ -6,3 +6,4 @@
"009904439","01","","ｶﾜｻｷｼﾘﾂｲﾀﾞﾋﾞﾖｳｲﾝ","ｲﾀﾞﾋﾞﾖｳｲﾝ ｼﾘﾂ","川崎市立井田病院","井田病院　市立","","370","","","","","","","","","","","044-766-2188","ｶﾅｶﾞﾜｹﾝ ｶﾜｻｷｼ ﾅｶﾊﾗｸ ｲﾀﾞ 2-27-1","神奈川県川崎市中原区井田２－２７－１","211-0035","14133001002","14","133","2-27-1","08120402","04060202","221","","1","","","","","","","","","3","343","0","27","0","370","343","0","20140811","1","NULL","0","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","2022-01-31 11:38:27","com_inst_mapper","2022-01-31 11:38:27","com_inst_mapper"
"009929798","10","","ﾊﾟ-ｿﾅﾙﾍﾙｽﾏﾅﾋﾞﾉｸﾘﾆﾂｸ","ﾊﾟ-ｿﾅﾙﾍﾙｽﾏﾅﾋﾞﾉｸﾘﾆﾂｸ","パーソナルヘルス学びのクリニック","パーソナルヘルス学びのＣＬ","","0","","","","","","01331831","ｼﾗｻﾜ ﾋﾛﾐﾂ","白澤　博満","1","","","ﾄｳｷﾖｳﾄ ﾐﾅﾄｸ ﾐﾅﾐｱｵﾔﾏ 2-2-1 ｳｲﾝｱｵﾔﾏ 405","東京都港区南青山２－２－１５　ウイン青山４０５","107-0062","13103025002","13","103","2-2-15-405","07050802","03020302","472","","7","","","","","","","","","6","0","0","0","0","0","0","0","20130415","1","NULL","0","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","2022-01-31 11:38:28","com_inst_mapper","2022-01-31 11:38:28","com_inst_mapper"
"223333344","37","7","アイウエオカクキケコアイウエオカクキケコアイウエオカクキケコアイウエオカクキケコ","アイウエオカクキケコアイウエオカクキケコ","あいうえおかきくけこあいうえおかきくけこあいうえおかきくけこあいうえおかきくけこあいうえおかきくけこ","あいうえおかきくけこあいうえおかきくけこあいうえお","81011","113","5","3","202306","202304","2","383940","アイウエオカクキケコ","あいうえおかきくけこあいうえおかきくけこ","4","8","35","アイウエオカクキケコアイウエオカクキケコアイウエオカクキケコ","あいうえおかきくけこあいうえおかきくけこあいうえおかきくけこあいうえおかきくけこあいうえおかきくけこ","123-4522","18192021","18","19","25","30313233","26272829","36","9","7","101112","2","3","4","5","6","7","8","8","9","6","7","8","115","0","1","20230114","1","NULL","0","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","2023/04/12 00:00:00","com_inst_mapper","2023/04/12 00:00:00","com_inst_mapper"
"999999999","37","NULL","アイウエオカクキケコアイウエオカクキケコアイウエオカクキケコアイウエオカクキケコ","アイウエオカクキケコアイウエオカクキケコ","あいうえおかきくけこあいうえおかきくけこあいうえおかきくけこあいうえおかきくけこあいうえおかきくけこ","あいうえおかきくけこあいうえおかきくけこあいうえお","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","アイウエオカクキケコアイウエオカクキケコアイウエオカクキケコ","あいうえおかきくけこあいうえおかきくけこあいうえおかきくけこあいうえおかきくけこあいうえおかきくけこ","123-4522","18192021","18","19","25","30313233","26272829","36","NULL","7","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","8","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","1","NULL","0","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","2023/04/12 00:00:00","com_inst_mapper","2023/04/12 00:00:00","com_inst_mapper"

1 dcf_dsf_inst_cd inst_div_cd addr_unknown_reason_cd form_inst_name_kana inst_name_kana form_inst_name_kanji inst_name_kanji rltd_univ_prnt_cd bed_num close_flg estab_sche_flg close_start_ym estab_sche_ym ward_abolish_flg inst_repre_cd inst_repre_kana inst_repre phone_number_non_flg unconf_flg inst_phone_number inst_addr_kana inst_addr postal_number village_cd prefc_cd city_cd addr_display_number addr_cnt_kana addr_cnt manage_cd delete_sche_reason_cd hp_assrt_cd dup_opp_cd insp_item_micrb insp_item_serum insp_item_blood insp_item_patho insp_item_paras insp_item_biochem insp_item_ri re_exam_cd prmit_bed_num_other prmit_bed_num_mental prmit_bed_num_tuber prmit_bed_num_infection prmit_bed_num_sum prmit_bed_num_gen prmit_bed_num_rcup prmit_bed_maint_ymd inst_pharm_div abolish_ymd delete_flg filler_1 filler_2 filler_3 filler_4 filler_5 regist_date create_user update_date update_user sys_regist_date regist_prgm_id sys_update_date update_prgm_id
6 009904439 01 ｶﾜｻｷｼﾘﾂｲﾀﾞﾋﾞﾖｳｲﾝ ｲﾀﾞﾋﾞﾖｳｲﾝ ｼﾘﾂ 川崎市立井田病院 井田病院　市立 370 044-766-2188 ｶﾅｶﾞﾜｹﾝ ｶﾜｻｷｼ ﾅｶﾊﾗｸ ｲﾀﾞ 2-27-1 神奈川県川崎市中原区井田２－２７－１ 211-0035 14133001002 14 133 2-27-1 08120402 04060202 221 1 3 343 0 27 0 370 343 0 20140811 1 NULL 0 NULL NULL NULL NULL NULL NULL NULL NULL NULL 2022-01-31 11:38:27 com_inst_mapper 2022-01-31 11:38:27 com_inst_mapper
7 009929798 10 ﾊﾟ-ｿﾅﾙﾍﾙｽﾏﾅﾋﾞﾉｸﾘﾆﾂｸ ﾊﾟ-ｿﾅﾙﾍﾙｽﾏﾅﾋﾞﾉｸﾘﾆﾂｸ パーソナルヘルス学びのクリニック パーソナルヘルス学びのＣＬ 0 01331831 ｼﾗｻﾜ ﾋﾛﾐﾂ 白澤　博満 1 ﾄｳｷﾖｳﾄ ﾐﾅﾄｸ ﾐﾅﾐｱｵﾔﾏ 2-2-1 ｳｲﾝｱｵﾔﾏ 405 東京都港区南青山２－２－１５　ウイン青山４０５ 107-0062 13103025002 13 103 2-2-15-405 07050802 03020302 472 7 6 0 0 0 0 0 0 0 20130415 1 NULL 0 NULL NULL NULL NULL NULL NULL NULL NULL NULL 2022-01-31 11:38:28 com_inst_mapper 2022-01-31 11:38:28 com_inst_mapper
8 223333344 37 7 アイウエオカクキケコアイウエオカクキケコアイウエオカクキケコアイウエオカクキケコ アイウエオカクキケコアイウエオカクキケコ あいうえおかきくけこあいうえおかきくけこあいうえおかきくけこあいうえおかきくけこあいうえおかきくけこ あいうえおかきくけこあいうえおかきくけこあいうえお 81011 113 5 3 202306 202304 2 383940 アイウエオカクキケコ あいうえおかきくけこあいうえおかきくけこ 4 8 35 アイウエオカクキケコアイウエオカクキケコアイウエオカクキケコ あいうえおかきくけこあいうえおかきくけこあいうえおかきくけこあいうえおかきくけこあいうえおかきくけこ 123-4522 18192021 18 19 25 30313233 26272829 36 9 7 101112 2 3 4 5 6 7 8 8 9 6 7 8 115 0 1 20230114 1 NULL 0 NULL NULL NULL NULL NULL NULL NULL NULL NULL 2023/04/12 00:00:00 com_inst_mapper 2023/04/12 00:00:00 com_inst_mapper
9 999999999 37 NULL アイウエオカクキケコアイウエオカクキケコアイウエオカクキケコアイウエオカクキケコ アイウエオカクキケコアイウエオカクキケコ あいうえおかきくけこあいうえおかきくけこあいうえおかきくけこあいうえおかきくけこあいうえおかきくけこ あいうえおかきくけこあいうえおかきくけこあいうえお NULL NULL NULL NULL NULL NULL NULL NULL NULL NULL NULL NULL NULL アイウエオカクキケコアイウエオカクキケコアイウエオカクキケコ あいうえおかきくけこあいうえおかきくけこあいうえおかきくけこあいうえおかきくけこあいうえおかきくけこ 123-4522 18192021 18 19 25 30313233 26272829 36 NULL 7 NULL NULL NULL NULL NULL NULL NULL NULL 8 NULL NULL NULL NULL NULL NULL NULL NULL 1 NULL 0 NULL NULL NULL NULL NULL NULL NULL NULL NULL 2023/04/12 00:00:00 com_inst_mapper 2023/04/12 00:00:00 com_inst_mapper

2
ecs/jskult-batch-daily/tests/batch/ultmarc/utmp_tables/table_mapper/com_inst/test_com_inst_mapper.py
View File

@ -134,6 +134,8 @@ class TestComInstMapper:
# 期待値ファイルを読み込む(特養医務室データ)
expect_data_list = create_db_data_from_csv(path.join(self.test_file_path, 'expect_com_spcare_insert.csv'))
actual_record_count = self.db.execute_select('SELECT COUNT(*) AS count_num FROM src05.com_spcare_med_office_dat')[0]['count_num']
assert actual_record_count == len(expect_data_list), 'DBのレコード件数が期待値の件数と一致すること'
primary_keys = [f"'{primary_key['dcf_chld_inst_cd']}'" for primary_key in expect_data_list]
actual_select_sql = f"SELECT * FROM src05.com_spcare_med_office_dat WHERE dcf_chld_inst_cd IN ({','.join(primary_keys)})"
actual_data_list = self.db.execute_select(actual_select_sql)

1
ecs/jskult-batch-daily/tests/batch/ultmarc/utmp_tables/table_mapper/com_inst_att/com_inst_att_insert.csv
View File

@ -18,3 +18,4 @@
"111","00","9908576","","A","2","20141113","20141114","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","1","20100401","","","","","1","20080401","","","","","","","","","","","","","","","","","","20070831","","","20070831","","","","2","9","1","I001","33","20130401","","","","","","33","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","200704"
"111","00","9910624","","A","2","20141113","20141114","1","20030401","","","","","1","20120401","","1","19940201","","","","","","1","20120401","","","","","","","","1","20121201","","1","20090701","","1","20061101","","","","","","","","1","99","","","","","","","","","","","","","","","","","","","","1","20100401","","1","20140401","","1","20140401","","1","01","02","03","04","","","","","","","1","20140401","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","1","08","20100402","","","","20060331","1","20041001","","1","20040331","","1","1","1","","","1","2","20070702","","","","","1","1","1","002","1","006","1","051","4","004","1","100","2","165","1","035","1","168","1","118","1","101","1","182","","202","1","214","5","149","","197","1","198","","177","1","183","1","213","5","217","5","212","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","1","11","31","34","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","192202"
"111","00","9929798","","A","2","20141113","20141114","1","20080701","","","","","","","","","","","","","","","","","","","","","1","20100401","","1","20090301","","1","20100401","","","","20080531","","","","1","19971201","","","","","","","","","","","","","","","","","","","","","","","1","20100401","","","","","1","20080401","","1","01","02","03","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","1","13","20140106","","","","","","","","1","20040331","","","1","1","","","","","","","","","","1","1","1","168","1","197","1","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","195305"
"111","00","9929799",,"A","2","20141113","20141114","@","20080701","20080701","@","2008","20080701","@","20080701","20080701","@","20080701","20080701","@","10.1","20080701","20080701","@","20080701","20080701","@","20080701","20080701","@","20080701","20080701","@","20080701","20080701","@","20080701","20080701","@","20080701","20080701","@","20080701","20080701","@","20080701","20080701","@","01","02","03","04","05","06","07","08","09","10","11","12","13","14","15","15","17","18","19","20","@","20100401","20100401","@","20100401","20100401","@","20100401","20100401","@","01","02","03","04","05","06","07","08","09","10","@","20140401","20140401","@","20140401","20140401","@","20140401","20140401","@","20140401","20140401","@","@","@","I001","33","20130401","20130401","4101","116","20090501","20090501","33","@","B999","450","@","M999","40","@","K999","4","@","9","9","@","9","@","21","20130901","20130901","@","13","20140106","20140106","@","20030401","20040229","1","20041001","20041001","1","20040331","20040331","@","@","1","1","@","@","2","20070702","20070702","@","20070702","20070702","@","@","@","168","1","197","1","051","4","004","1","100","2","165","1","035","1","168","1","118","1","101","1","182",,"202","1","214","5","149","1","197","1","198","1","177","1","183","1","213","5","217","5","212","1","202","3","204","5","206","7","208","9","210","1","212","3","214","5","216","7","218","9","220","1","222","3","224","5","226","7","228","9","230","1","232","3","234","5","236","7","238","9","@","01","02","03","04","05","06","07","08","09","10","11","12","13","14","15","16","17","18","19","20","@","62","3","64","5","66","7","68","9","70","1","72","3","74","5","76","7","78","9","80","1","82","3","84","5","86","7","88","9","90","1","92","3","94","5","96","7","98","9","00","1","@","00","8106522","00","@"

1 111 123 456789 99 A 0 NULL NULL 9 20230510 20230511 2 2023 20230514 5 20230516 20230517 8 20230519 20230520 1 22.1 20230523 20230524 5 20230526 20230527 8 20230529 20230530 1 20230502 20230503 4 20230505 20230506 7 20230508 20230509 0 20230501 20230402 3 20230404 20230405 6 20230407 20230408 9 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 0 20230701 20230702 3 20230704 20230705 6 20230707 20230708 9 80 81 82 83 84 85 86 87 88 89 0 20230901 20230902 3 20230904 20230905 6 20230907 20230908 9 20231001 20231011 2 3 4 105 106 20231007 20231008 109 110 20231101 20231102 113 4 0115 116 7 0118 119 0 0121 122 3 4 5 6 127 8 129 20230130 20230131 2 33 20230104 20230105 6 20230107 20230108 9 20230104 20230101 2 20230103 20230104 5 6 7 8 9 0 1 20230102 20230403 4 20230105 20230106 7 8 9 160 1 162 3 164 5 166 7 168 9 170 1 172 3 174 5 176 7 178 9 180 1 182 3 184 5 186 7 188 9 190 1 192 3 194 5 196 7 198 9 200 1 202 3 204 5 206 7 208 9 210 1 212 3 214 5 216 7 218 9 220 1 222 3 224 5 226 7 228 9 230 1 232 3 234 5 236 7 238 9 0 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 1 62 3 64 5 66 7 68 9 70 1 72 3 74 5 76 7 78 9 80 1 82 3 84 5 86 7 88 9 90 1 92 3 94 5 96 7 98 9 00 1 2 3 0000304 05 202303
18 111 00 9908576 A 2 20141113 20141114 1 20100401 1 20080401 20070831 20070831 2 9 1 I001 33 20130401 33 200704
19 111 00 9910624 A 2 20141113 20141114 1 20030401 1 20120401 1 19940201 1 20120401 1 20121201 1 20090701 1 20061101 1 99 1 20100401 1 20140401 1 20140401 1 01 02 03 04 1 20140401 1 08 20100402 20060331 1 20041001 1 20040331 1 1 1 1 2 20070702 1 1 1 002 1 006 1 051 4 004 1 100 2 165 1 035 1 168 1 118 1 101 1 182 202 1 214 5 149 197 1 198 177 1 183 1 213 5 217 5 212 1 11 31 34 192202
20 111 00 9929798 A 2 20141113 20141114 1 20080701 1 20100401 1 20090301 1 20100401 20080531 1 19971201 1 20100401 1 20080401 1 01 02 03 1 13 20140106 1 20040331 1 1 1 1 1 168 1 197 1 195305
21 111 00 9929799 A 2 20141113 20141114 @ 20080701 20080701 @ 2008 20080701 @ 20080701 20080701 @ 20080701 20080701 @ 10.1 20080701 20080701 @ 20080701 20080701 @ 20080701 20080701 @ 20080701 20080701 @ 20080701 20080701 @ 20080701 20080701 @ 20080701 20080701 @ 20080701 20080701 @ 20080701 20080701 @ 01 02 03 04 05 06 07 08 09 10 11 12 13 14 15 15 17 18 19 20 @ 20100401 20100401 @ 20100401 20100401 @ 20100401 20100401 @ 01 02 03 04 05 06 07 08 09 10 @ 20140401 20140401 @ 20140401 20140401 @ 20140401 20140401 @ 20140401 20140401 @ @ @ I001 33 20130401 20130401 4101 116 20090501 20090501 33 @ B999 450 @ M999 40 @ K999 4 @ 9 9 @ 9 @ 21 20130901 20130901 @ 13 20140106 20140106 @ 20030401 20040229 1 20041001 20041001 1 20040331 20040331 @ @ 1 1 @ @ 2 20070702 20070702 @ 20070702 20070702 @ @ @ 168 1 197 1 051 4 004 1 100 2 165 1 035 1 168 1 118 1 101 1 182 202 1 214 5 149 1 197 1 198 1 177 1 183 1 213 5 217 5 212 1 202 3 204 5 206 7 208 9 210 1 212 3 214 5 216 7 218 9 220 1 222 3 224 5 226 7 228 9 230 1 232 3 234 5 236 7 238 9 @ 01 02 03 04 05 06 07 08 09 10 11 12 13 14 15 16 17 18 19 20 @ 62 3 64 5 66 7 68 9 70 1 72 3 74 5 76 7 78 9 80 1 82 3 84 5 86 7 88 9 90 1 92 3 94 5 96 7 98 9 00 1 @ 00 8106522 00 @

2
ecs/jskult-batch-daily/tests/batch/ultmarc/utmp_tables/table_mapper/com_inst_att/expect_com_inst_att_insert.csv
View File

@ -18,4 +18,4 @@
"009908576","","","","","","","","","","","","","","NULL","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","1","20100401","","","","","1","20080401","","","","","","","","","","","","","","","","","","20070831","","","20070831","","","","2","9","1","I001","33","20130401","","","NULL","","","33","","","NULL","","","NULL","","","NULL","","","","","NULL","","NULL","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","200704","20171008","20230509","NULL","NULL","NULL","NULL","2017/10/08 20:57:12","com_inst_att_mapper","2017/10/08 20:57:12","com_inst_att_mapper"
"009910624","1","20030401","","","","","1","20120401","","1","19940201","","","NULL","","","1","20120401","","","","","","","","1","20121201","","1","20090701","","1","20061101","","","","","","","","1","99","","","","","","","","","","","","","","","","","","","","1","20100401","","1","20140401","","1","20140401","","1","01","02","03","04","","","","","","","1","20140401","","","","","","","","","","","","","","","NULL","","","","NULL","","","NULL","","","NULL","","","NULL","","","NULL","","","","","NULL","","NULL","","","1","08","20100402","","","","20060331","1","20041001","","1","20040331","","1","1","1","","","1","2","20070702","","","","","1","1","1","002","1","006","1","051","4","004","1","100","2","165","1","035","1","168","1","118","1","101","1","182","","202","1","214","5","149","","197","1","198","","177","1","183","1","213","5","217","5","212","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","1","11","31","34","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","192202","20171008","20230509","NULL","NULL","NULL","NULL","2017/10/08 20:57:12","com_inst_att_mapper","2017/10/08 20:57:12","com_inst_att_mapper"
"009929798","1","20080701","","","","","","","","","","","","NULL","","","","","","","","","1","20100401","","1","20090301","","1","20100401","","","","20080531","","","","1","19971201","","","","","","","","","","","","","","","","","","","","","","","1","20100401","","","","","1","20080401","","1","01","02","03","","","","","","","","","","","","","","","","","","","","","","","","NULL","","","","NULL","","","NULL","","","NULL","","","NULL","","","NULL","","","","","NULL","","NULL","","","1","13","20140106","","","","","","","","1","20040331","","","1","1","","","","","","","","","","1","1","1","168","1","197","1","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","","195305","20171008","20230509","NULL","NULL","NULL","NULL","2017/10/08 20:57:12","com_inst_att_mapper","2017/10/08 20:57:12","com_inst_att_mapper"
"12345678999","9","20230510","20230511","2","2023","20230514","5","20230516","20230517","8","20230519","20230520","1","22.1","20230523","20230524","5","20230526","20230527","8","20230529","20230530","1","20230502","20230503","4","20230505","20230506","7","20230508","20230509","0","20230501","20230402","3","20230404","20230405","6","20230407","20230408","9","50","51","52","53","54","55","56","57","58","59","60","61","62","63","64","65","66","67","68","69","0","20230701","20230702","3","20230704","20230705","6","20230707","20230708","9","80","81","82","83","84","85","86","87","88","89","0","20230901","20230902","3","20230904","20230905","6","20230907","20230908","9","20231001","20231011","2","3","4","105","106","20231007","20231008","109","110","20231101","20231102","113","4","0115","116","7","0118","119","0","0121","122","3","4","5","6","127","8","129","20230130","20230131","2","33","20230104","20230105","6","20230107","20230108","9","20230104","20230101","2","20230103","20230104","5","6","7","8","9","0","1","20230102","20230403","4","20230105","20230106","7","8","9","160","1","162","3","164","5","166","7","168","9","170","1","172","3","174","5","176","7","178","9","180","1","182","3","184","5","186","7","188","9","190","1","192","3","194","5","196","7","198","9","200","1","202","3","204","5","206","7","208","9","210","1","212","3","214","5","216","7","218","9","220","1","222","3","224","5","226","7","228","9","230","1","232","3","234","5","236","7","238","9","0","41","42","43","44","45","46","47","48","49","50","51","52","53","54","55","56","57","58","59","60","1","62","3","64","5","66","7","68","9","70","1","72","3","74","5","76","7","78","9","80","1","82","3","84","5","86","7","88","9","90","1","92","3","94","5","96","7","98","9","00","1","2","3","0000304","05","202303","20230509","20230509","NULL","NULL","NULL","NULL","2023/05/09 10:10:10","com_inst_att_mapper","2023/05/09 10:10:10","com_inst_att_mapper"
"009929799","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","NULL","20171008","20230509","NULL","NULL","NULL","NULL","2017/10/08 20:57:12","com_inst_att_mapper","2017/10/08 20:57:12","com_inst_att_mapper"

1 dcf_dsf_inst_cd dpc_flag dpc_specday dpc_cancelday predpc_flag predpc_specday predpc_cancelday cancer_flag cancer_specday cancer_cancelday funchpflag funchpokdate funchpcandate areasuphpflag areasuphpintrate areasuphpokdate areasuphpcandate acuthpaddflag acuthpaddokdate acuthpaddcandate genadmisiionflag genadmisiionfokdate genadmisiionfcandate assistanceflag assistanceokdate assistancecandate diagnosistreatment_flag diagnosistreatment_specday diagnosistreatment_cancelday safety_flag safety_specday safety_cancelday highrisk_flag highrisk_specday highrisk_cancelday infantandholiday_flag infantandholiday_specday infantandholiday_cancelday ophpflag ophpokdate ophpcandate critical_flag critical_code01 critical_code02 critical_code03 critical_code04 critical_code05 critical_code06 critical_code07 critical_code08 critical_code09 critical_code10 critical_code11 critical_code12 critical_code13 critical_code14 critical_code15 critical_code16 critical_code17 critical_code18 critical_code19 critical_code20 drgmgthpflag drgmgthpokdate drgmgthpcandate imagediagnosis_flag imagediagnosis_specifiedday imagediagnosis_cancelday chemotherapy_flag chemotherapy_specday chemotherapy_cancelday rehabilitation_flag rehabilitation_code01 rehabilitation_code02 rehabilitation_code03 rehabilitation_code04 rehabilitation_code05 rehabilitation_code06 rehabilitation_code07 rehabilitation_code08 rehabilitation_code09 rehabilitation_code10 anesthetizingmanage_flag anesthetizingmanage_specday anesthetizingmanage_cancelday homerecuperation_flag homerecuperation_specday homerecuperation_cancelday synthesiswhenstaying_flag synthesiswhenstaying_specday synthesiswhenstaying_cancelday homelateflag homelateokday homelatecanday caremixkind fullmoveflag resthpflag resthpcarekind resthpbednum resthpokdate resthpcandate resthpcarenrskind resthpcarebednum resthpcareokdate resthpcarecandate resthpsbednum nrmhpflag nrmhpcarekind nrmhpbedtotalnum menthpflag menthpcarekind menthpbednum tubhpflag tubhpcarekind tubhpbednum infhpflag infhpflag1 infhpflag2 infhpbedflag infhpbednum hospiceflag hospicebednum hospiceokdate hospicecandate hpfuncestflag hpfuncestkind hpfuncestokdate hpfuncestcandate clolyhpkind clolyhpokdate clolyhpcandate clhpkind clhpokdate clhpcandate cldephpkind cldephpokdate cldephpcandate disasthpflag d1emerhpflag d2emerhpflag d3emerhpflag emergencyclinic trialcoreflag trialcore_div trialcoreokdate trialcorecandate dementiaflag dementiaokdate dementiacandate sphealth_exploration sphealth_guidance hiadhpflag hiadhpcode1 hiadhpkind1 hiadhpcode2 hiadhpkind2 hiadhpcode3 hiadhpkind3 hiadhpcode4 hiadhpkind4 hiadhpcode5 hiadhpkind5 hiadhpcode6 hiadhpkind6 hiadhpcode7 hiadhpkind7 hiadhpcode8 hiadhpkind8 hiadhpcode9 hiadhpkind9 hiadhpcode10 hiadhpkind10 hiadhpcode11 hiadhpkind11 hiadhpcode12 hiadhpkind12 hiadhpcode13 hiadhpkind13 hiadhpcode14 hiadhpkind14 hiadhpcode15 hiadhpkind15 hiadhpcode16 hiadhpkind16 hiadhpcode17 hiadhpkind17 hiadhpcode18 hiadhpkind18 hiadhpcode19 hiadhpkind19 hiadhpcode20 hiadhpkind20 hiadhpcode21 hiadhpkind21 hiadhpcode22 hiadhpkind22 hiadhpcode23 hiadhpkind23 hiadhpcode24 hiadhpkind24 hiadhpcode25 hiadhpkind25 hiadhpcode26 hiadhpkind26 hiadhpcode27 hiadhpkind27 hiadhpcode28 hiadhpkind28 hiadhpcode29 hiadhpkind29 hiadhpcode30 hiadhpkind30 hiadhpcode31 hiadhpkind31 hiadhpcode32 hiadhpkind32 hiadhpcode33 hiadhpkind33 hiadhpcode34 hiadhpkind34 hiadhpcode35 hiadhpkind35 hiadhpcode36 hiadhpkind36 hiadhpcode37 hiadhpkind37 hiadhpcode38 hiadhpkind38 hiadhpcode39 hiadhpkind39 hiadhpcode40 hiadhpkind40 hitechhpflag hitechhpkind1 hitechhpkind2 hitechhpkind3 hitechhpkind4 hitechhpkind5 hitechhpkind6 hitechhpkind7 hitechhpkind8 hitechhpkind9 hitechhpkind10 hitechhpkind11 hitechhpkind12 hitechhpkind13 hitechhpkind14 hitechhpkind15 hitechhpkind16 hitechhpkind17 hitechhpkind18 hitechhpkind19 hitechhpkind20 policymedical_flag policymedical_code01 policymedical_content01 policymedical_code02 policymedical_content02 policymedical_code03 policymedical_content03 policymedical_code04 policymedical_content04 policymedical_code05 policymedical_content05 policymedical_code06 policymedical_content06 policymedical_code07 policymedical_content07 policymedical_code08 policymedical_content08 policymedical_code09 policymedical_content09 policymedical_code10 policymedical_content10 policymedical_code11 policymedical_content11 policymedical_code12 policymedical_content12 policymedical_code13 policymedical_content13 policymedical_code14 policymedical_content14 policymedical_code15 policymedical_content15 policymedical_code16 policymedical_content16 policymedical_code17 policymedical_content17 policymedical_code18 policymedical_content18 policymedical_code19 policymedical_content19 policymedical_code20 policymedical_content20 visitcarestflag visitcarestation_id visitcarestation_code visitcarestation_yobi opendate regist_ymd update_ymd regist_date create_user update_date update_user sys_regist_date regist_prgm_id sys_update_date update_prgm_id
18 009908576 NULL 1 20100401 1 20080401 20070831 20070831 2 9 1 I001 33 20130401 NULL 33 NULL NULL NULL NULL NULL 200704 20171008 20230509 NULL NULL NULL NULL 2017/10/08 20:57:12 com_inst_att_mapper 2017/10/08 20:57:12 com_inst_att_mapper
19 009910624 1 20030401 1 20120401 1 19940201 NULL 1 20120401 1 20121201 1 20090701 1 20061101 1 99 1 20100401 1 20140401 1 20140401 1 01 02 03 04 1 20140401 NULL NULL NULL NULL NULL NULL NULL NULL 1 08 20100402 20060331 1 20041001 1 20040331 1 1 1 1 2 20070702 1 1 1 002 1 006 1 051 4 004 1 100 2 165 1 035 1 168 1 118 1 101 1 182 202 1 214 5 149 197 1 198 177 1 183 1 213 5 217 5 212 1 11 31 34 192202 20171008 20230509 NULL NULL NULL NULL 2017/10/08 20:57:12 com_inst_att_mapper 2017/10/08 20:57:12 com_inst_att_mapper
20 009929798 1 20080701 NULL 1 20100401 1 20090301 1 20100401 20080531 1 19971201 1 20100401 1 20080401 1 01 02 03 NULL NULL NULL NULL NULL NULL NULL NULL 1 13 20140106 1 20040331 1 1 1 1 1 168 1 197 1 195305 20171008 20230509 NULL NULL NULL NULL 2017/10/08 20:57:12 com_inst_att_mapper 2017/10/08 20:57:12 com_inst_att_mapper
21 12345678999 009929799 9 NULL 20230510 NULL 20230511 NULL 2 NULL 2023 NULL 20230514 NULL 5 NULL 20230516 NULL 20230517 NULL 8 NULL 20230519 NULL 20230520 NULL 1 NULL 22.1 NULL 20230523 NULL 20230524 NULL 5 NULL 20230526 NULL 20230527 NULL 8 NULL 20230529 NULL 20230530 NULL 1 NULL 20230502 NULL 20230503 NULL 4 NULL 20230505 NULL 20230506 NULL 7 NULL 20230508 NULL 20230509 NULL 0 NULL 20230501 NULL 20230402 NULL 3 NULL 20230404 NULL 20230405 NULL 6 NULL 20230407 NULL 20230408 NULL 9 NULL 50 NULL 51 NULL 52 NULL 53 NULL 54 NULL 55 NULL 56 NULL 57 NULL 58 NULL 59 NULL 60 NULL 61 NULL 62 NULL 63 NULL 64 NULL 65 NULL 66 NULL 67 NULL 68 NULL 69 NULL 0 NULL 20230701 NULL 20230702 NULL 3 NULL 20230704 NULL 20230705 NULL 6 NULL 20230707 NULL 20230708 NULL 9 NULL 80 NULL 81 NULL 82 NULL 83 NULL 84 NULL 85 NULL 86 NULL 87 NULL 88 NULL 89 NULL 0 NULL 20230901 NULL 20230902 NULL 3 NULL 20230904 NULL 20230905 NULL 6 NULL 20230907 NULL 20230908 NULL 9 NULL 20231001 NULL 20231011 NULL 2 NULL 3 NULL 4 NULL 105 NULL 106 NULL 20231007 NULL 20231008 NULL 109 NULL 110 NULL 20231101 NULL 20231102 NULL 113 NULL 4 NULL 0115 NULL 116 NULL 7 NULL 0118 NULL 119 NULL 0 NULL 0121 NULL 122 NULL 3 NULL 4 NULL 5 NULL 6 NULL 127 NULL 8 NULL 129 NULL 20230130 NULL 20230131 NULL 2 NULL 33 NULL 20230104 NULL 20230105 NULL 6 NULL 20230107 NULL 20230108 NULL 9 NULL 20230104 NULL 20230101 NULL 2 NULL 20230103 NULL 20230104 NULL 5 NULL 6 NULL 7 NULL 8 NULL 9 NULL 0 NULL 1 NULL 20230102 NULL 20230403 NULL 4 NULL 20230105 NULL 20230106 NULL 7 NULL 8 NULL 9 NULL 160 NULL 1 NULL 162 NULL 3 NULL 164 NULL 5 NULL 166 NULL 7 NULL 168 NULL 9 NULL 170 NULL 1 NULL 172 NULL 3 NULL 174 NULL 5 NULL 176 NULL 7 NULL 178 NULL 9 NULL 180 NULL 1 NULL 182 NULL 3 NULL 184 NULL 5 NULL 186 NULL 7 NULL 188 NULL 9 NULL 190 NULL 1 NULL 192 NULL 3 NULL 194 NULL 5 NULL 196 NULL 7 NULL 198 NULL 9 NULL 200 NULL 1 NULL 202 NULL 3 NULL 204 NULL 5 NULL 206 NULL 7 NULL 208 NULL 9 NULL 210 NULL 1 NULL 212 NULL 3 NULL 214 NULL 5 NULL 216 NULL 7 NULL 218 NULL 9 NULL 220 NULL 1 NULL 222 NULL 3 NULL 224 NULL 5 NULL 226 NULL 7 NULL 228 NULL 9 NULL 230 NULL 1 NULL 232 NULL 3 NULL 234 NULL 5 NULL 236 NULL 7 NULL 238 NULL 9 NULL 0 NULL 41 NULL 42 NULL 43 NULL 44 NULL 45 NULL 46 NULL 47 NULL 48 NULL 49 NULL 50 NULL 51 NULL 52 NULL 53 NULL 54 NULL 55 NULL 56 NULL 57 NULL 58 NULL 59 NULL 60 NULL 1 NULL 62 NULL 3 NULL 64 NULL 5 NULL 66 NULL 7 NULL 68 NULL 9 NULL 70 NULL 1 NULL 72 NULL 3 NULL 74 NULL 5 NULL 76 NULL 7 NULL 78 NULL 9 NULL 80 NULL 1 NULL 82 NULL 3 NULL 84 NULL 5 NULL 86 NULL 7 NULL 88 NULL 9 NULL 90 NULL 1 NULL 92 NULL 3 NULL 94 NULL 5 NULL 96 NULL 7 NULL 98 NULL 9 NULL 00 NULL 1 NULL 2 NULL 3 NULL 0000304 NULL 05 NULL 202303 NULL 20230509 20171008 20230509 NULL NULL NULL NULL 2023/05/09 10:10:10 2017/10/08 20:57:12 com_inst_att_mapper 2023/05/09 10:10:10 2017/10/08 20:57:12 com_inst_att_mapper

1
ecs/jskult-batch-daily/tests/batch/ultmarc/utmp_tables/table_mapper/com_sp_field/com_sp_field_insert.csv
View File

@ -5,3 +5,4 @@
"511","01","999613","00","A","0056","2","20141113","20141114","1","20140706","","","1","20140706"
"511","91","999999","99","B","9999","2","","","1","20220628","1","20230425","1","20230425"
"511","99","999999","99","A","9999","2","","","1","20220628","1","20230425","1","20230425"
"511","01","999988","99","A","9999","2",,,"@","20220628","@","20230425","@","20230425"

1 511 01 994301 00 A 0003 2 20141113 20141114 1 20140401
5 511 01 999613 00 A 0056 2 20141113 20141114 1 20140706 1 20140706
6 511 91 999999 99 B 9999 2 1 20220628 1 20230425 1 20230425
7 511 99 999999 99 A 9999 2 1 20220628 1 20230425 1 20230425
8 511 01 999988 99 A 9999 2 @ 20220628 @ 20230425 @ 20230425

1
ecs/jskult-batch-daily/tests/batch/ultmarc/utmp_tables/table_mapper/com_sp_field/expect_com_sp_field_insert.csv
View File

@ -6,3 +6,4 @@
"0199961300","0056","2","1","20140706","","","1","20140706","20230425","NULL","NULL","NULL","NULL","NULL","NULL","2023/01/08 17:05:14","com_sp_field_mapper","2023/01/08 17:05:14","com_sp_field_mapper"
"9199999999","9999","2","1","20220628","1","20230425","1","20230425","20230425","NULL","NULL","NULL","NULL","NULL","NULL","2023/01/08 17:05:14","com_sp_field_mapper","2023/01/08 17:05:14","com_sp_field_mapper"
"9999999999","9999","2","1","20220628","1","20230425","1","20230425","20230425","NULL","NULL","NULL","NULL","NULL","NULL","2023/01/08 17:05:14","com_sp_field_mapper","2023/01/08 17:05:14","com_sp_field_mapper"
"0199998899","9999","2","NULL","NULL","NULL","NULL","NULL","NULL","20230425","NULL","NULL","NULL","NULL","NULL","NULL","2023/01/08 17:05:14","com_sp_field_mapper","2023/01/08 17:05:14","com_sp_field_mapper"

1 dcf_pcf_dr_cd specialist_cd specialist_maint_div specialist_flg specialist_publsh_ymd ackn_med_flg ackn_med_publsh_ymd guide_med_flg guide_med_publsh_ymd regist_ymd update_ymd delete_ymd regist_date create_user update_date update_user sys_regist_date regist_prgm_id sys_update_date update_prgm_id
6 0199961300 0056 2 1 20140706 1 20140706 20230425 NULL NULL NULL NULL NULL NULL 2023/01/08 17:05:14 com_sp_field_mapper 2023/01/08 17:05:14 com_sp_field_mapper
7 9199999999 9999 2 1 20220628 1 20230425 1 20230425 20230425 NULL NULL NULL NULL NULL NULL 2023/01/08 17:05:14 com_sp_field_mapper 2023/01/08 17:05:14 com_sp_field_mapper
8 9999999999 9999 2 1 20220628 1 20230425 1 20230425 20230425 NULL NULL NULL NULL NULL NULL 2023/01/08 17:05:14 com_sp_field_mapper 2023/01/08 17:05:14 com_sp_field_mapper
9 0199998899 9999 2 NULL NULL NULL NULL NULL NULL 20230425 NULL NULL NULL NULL NULL NULL 2023/01/08 17:05:14 com_sp_field_mapper 2023/01/08 17:05:14 com_sp_field_mapper

2
ecs/jskult-batch-daily/tests/testing_utility.py
View File

@ -136,6 +136,8 @@ def is_valid_date_format(date_str: str, date_format):
Returns:
_type_: 正しい日付文字列の場合、True、それ以外はFalse
"""
if date_str is None:
return False
try:
datetime.strptime(date_str, date_format)
return True