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

Merge commit '63025bfa22f2e5c60370a364be95365d1c62364e' into feature-NEWDWH2021-1241

Browse Source
This commit is contained in:
shimoda.m@nds-tyo.co.jp 2023-10-02 10:42:03 +09:00
commit 73d4d2d4e3
17 changed files with 396 additions and 377 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
ecs/jskult-batch-daily/src/batch/ultmarc/utmp_tables/tables/com_dr.py
View File

@ -143,9 +143,9 @@ class ComDr(UltmarcTable):
# 住所（町字）コード # 住所（町字）コード
self.addr_village_cd = ''.join([self.pref_code, self.city_code, self.addr_code1, self.addr_code2]) self.addr_village_cd = ''.join([self.pref_code, self.city_code, self.addr_code1, self.addr_code2])
# 住所カウントカナ # 住所カウントカナ
self.addr_cnt_kana = ''.join([self.dr_addr_kana_cnt1, self.dr_addr_kana_cnt2, self.dr_addr_kana_cnt3, self.dr_addr_kana_cnt4]) self.addr_cnt_kana = ''.join([self.dr_addr_kana_cnt1.zfill(2), self.dr_addr_kana_cnt2.zfill(2), self.dr_addr_kana_cnt3.zfill(2), self.dr_addr_kana_cnt4.zfill(2)])
# 住所カウント # 住所カウント
self.addr_cnt = ''.join([self.dr_addr_kanj_cnt1, self.dr_addr_kanj_cnt2, self.dr_addr_kanj_cnt3, self.dr_addr_kanj_cnt4]) self.addr_cnt = ''.join([self.dr_addr_kanj_cnt1.zfill(2), self.dr_addr_kanj_cnt2.zfill(2), self.dr_addr_kanj_cnt3.zfill(2), self.dr_addr_kanj_cnt4.zfill(2)])
# 相手先重複コード # 相手先重複コード
self.opp_dup_code = ''.join([self.reptdr_id, self.reptdr_code, self.reptdr_yobi]) self.opp_dup_code = ''.join([self.reptdr_id, self.reptdr_code, self.reptdr_yobi])

12
ecs/jskult-batch-daily/src/batch/ultmarc/utmp_tables/tables/com_pharm.py
View File

@ -108,6 +108,18 @@ class ComPharm(UltmarcTable):
self.franchise_hq_code = record[46] self.franchise_hq_code = record[46]
self.franchise_hq_yobi = record[47] self.franchise_hq_yobi = record[47]
# 住所ｶｳﾝﾄ_漢字の０埋め
self.addrkanacnt1 = self.addrkanacnt1.zfill(2)
self.addrkanacnt2 = self.addrkanacnt2.zfill(2)
self.addrkanacnt3 = self.addrkanacnt3.zfill(2)
self.addrkanacnt4 = self.addrkanacnt4.zfill(2)
# 住所ｶｳﾝﾄ_ｶﾅの０埋め
self.addrkanjcnt1 = self.addrkanjcnt1.zfill(2)
self.addrkanjcnt2 = self.addrkanjcnt2.zfill(2)
self.addrkanjcnt3 = self.addrkanjcnt3.zfill(2)
self.addrkanjcnt4 = self.addrkanjcnt4.zfill(2)
# 施設コード(2+3+4) # 施設コード(2+3+4)
self.dcfdsf_inst_cd = ''.join([self.dcfhp_id, self.dcfhp_cd, self.dcfhp_yobi]) self.dcfdsf_inst_cd = ''.join([self.dcfhp_id, self.dcfhp_cd, self.dcfhp_yobi])

698
ecs/jskult-batch-daily/src/batch/vjsk/vjsk_recv_file_mapper.py
View File

@ -211,89 +211,89 @@ class VjskReceiveFileMapper:
,SYSDATE() ,SYSDATE()
FROM org05.sales AS t FROM org05.sales AS t
ON DUPLICATE KEY UPDATE ON DUPLICATE KEY UPDATE
rec_data=VALUES(rec_data) rec_data=medaca_common.convert_empty_to_null(t.rec_data)
,rec_whs_cd=VALUES(rec_whs_cd) ,rec_whs_cd=medaca_common.convert_empty_to_null(t.rec_whs_cd)
,rec_whs_sub_cd=VALUES(rec_whs_sub_cd) ,rec_whs_sub_cd=medaca_common.convert_empty_to_null(t.rec_whs_sub_cd)
,rec_whs_org_cd=VALUES(rec_whs_org_cd) ,rec_whs_org_cd=medaca_common.convert_empty_to_null(t.rec_whs_org_cd)
,rec_cust_cd=VALUES(rec_cust_cd) ,rec_cust_cd=medaca_common.convert_empty_to_null(t.rec_cust_cd)
,rec_comm_cd=VALUES(rec_comm_cd) ,rec_comm_cd=medaca_common.convert_empty_to_null(t.rec_comm_cd)
,rec_tran_kbn=VALUES(rec_tran_kbn) ,rec_tran_kbn=medaca_common.convert_empty_to_null(t.rec_tran_kbn)
,rev_hsdnymd_wrk=VALUES(rev_hsdnymd_wrk) ,rev_hsdnymd_wrk=medaca_common.convert_empty_to_null(t.rev_hsdnymd_wrk)
,rev_hsdnymd_srk=VALUES(rev_hsdnymd_srk) ,rev_hsdnymd_srk=medaca_common.convert_empty_to_null(t.rev_hsdnymd_srk)
,rec_urag_num=VALUES(rec_urag_num) ,rec_urag_num=medaca_common.convert_empty_to_null(t.rec_urag_num)
,rec_qty=VALUES(rec_qty) ,rec_qty=medaca_common.convert_empty_to_null(t.rec_qty)
,rec_nonyu_price=VALUES(rec_nonyu_price) ,rec_nonyu_price=medaca_common.convert_empty_to_null(t.rec_nonyu_price)
,rec_nonyu_amt=VALUES(rec_nonyu_amt) ,rec_nonyu_amt=medaca_common.convert_empty_to_null(t.rec_nonyu_amt)
,rec_comm_name=VALUES(rec_comm_name) ,rec_comm_name=medaca_common.convert_empty_to_null(t.rec_comm_name)
,rec_nonyu_fcl_name=VALUES(rec_nonyu_fcl_name) ,rec_nonyu_fcl_name=medaca_common.convert_empty_to_null(t.rec_nonyu_fcl_name)
,free_item=VALUES(free_item) ,free_item=medaca_common.convert_empty_to_null(t.free_item)
,rec_nonyu_fcl_addr=VALUES(rec_nonyu_fcl_addr) ,rec_nonyu_fcl_addr=medaca_common.convert_empty_to_null(t.rec_nonyu_fcl_addr)
,rec_nonyu_fcl_post=VALUES(rec_nonyu_fcl_post) ,rec_nonyu_fcl_post=medaca_common.convert_empty_to_null(t.rec_nonyu_fcl_post)
,rec_nonyu_fcl_tel=VALUES(rec_nonyu_fcl_tel) ,rec_nonyu_fcl_tel=medaca_common.convert_empty_to_null(t.rec_nonyu_fcl_tel)
,rec_bef_hsdn_ymd=VALUES(rec_bef_hsdn_ymd) ,rec_bef_hsdn_ymd=medaca_common.convert_empty_to_null(t.rec_bef_hsdn_ymd)
,rec_bef_slip_num=VALUES(rec_bef_slip_num) ,rec_bef_slip_num=medaca_common.convert_empty_to_null(t.rec_bef_slip_num)
,rec_ymd=VALUES(rec_ymd) ,rec_ymd=medaca_common.convert_empty_to_null(t.rec_ymd)
,sale_data_cat=VALUES(sale_data_cat) ,sale_data_cat=medaca_common.convert_empty_to_null(t.sale_data_cat)
,slip_file_name=VALUES(slip_file_name) ,slip_file_name=medaca_common.convert_empty_to_null(t.slip_file_name)
,slip_mgt_num=VALUES(slip_mgt_num) ,slip_mgt_num=t.slip_mgt_num
,row_num=VALUES(row_num) ,row_num=t.row_num
,hsdn_ymd=VALUES(hsdn_ymd) ,hsdn_ymd=medaca_common.convert_empty_to_null(t.hsdn_ymd)
,exec_dt=VALUES(exec_dt) ,exec_dt=medaca_common.convert_empty_to_null(t.exec_dt)
,v_tran_cd=VALUES(v_tran_cd) ,v_tran_cd=t.v_tran_cd
,tran_kbn_name=VALUES(tran_kbn_name) ,tran_kbn_name=medaca_common.convert_empty_to_null(t.tran_kbn_name)
,whs_org_cd=VALUES(whs_org_cd) ,whs_org_cd=medaca_common.convert_empty_to_null(t.whs_org_cd)
,v_whsorg_cd=VALUES(v_whsorg_cd) ,v_whsorg_cd=t.v_whsorg_cd
,whs_org_name=VALUES(whs_org_name) ,whs_org_name=medaca_common.convert_empty_to_null(t.whs_org_name)
,whs_org_kn=VALUES(whs_org_kn) ,whs_org_kn=medaca_common.convert_empty_to_null(t.whs_org_kn)
,v_whs_cd=VALUES(v_whs_cd) ,v_whs_cd=t.v_whs_cd
,whs_name=VALUES(whs_name) ,whs_name=medaca_common.convert_empty_to_null(t.whs_name)
,nonyu_fcl_cd=VALUES(nonyu_fcl_cd) ,nonyu_fcl_cd=medaca_common.convert_empty_to_null(t.nonyu_fcl_cd)
,v_inst_cd=VALUES(v_inst_cd) ,v_inst_cd=medaca_common.convert_empty_to_null(t.v_inst_cd)
,v_inst_kn=VALUES(v_inst_kn) ,v_inst_kn=medaca_common.convert_empty_to_null(t.v_inst_kn)
,v_inst_name=VALUES(v_inst_name) ,v_inst_name=medaca_common.convert_empty_to_null(t.v_inst_name)
,v_inst_addr=VALUES(v_inst_addr) ,v_inst_addr=medaca_common.convert_empty_to_null(t.v_inst_addr)
,comm_cd=VALUES(comm_cd) ,comm_cd=medaca_common.convert_empty_to_null(t.comm_cd)
,comm_name=VALUES(comm_name) ,comm_name=medaca_common.convert_empty_to_null(t.comm_name)
,nonyu_qty=VALUES(nonyu_qty) ,nonyu_qty=t.nonyu_qty
,nonyu_price=VALUES(nonyu_price) ,nonyu_price=t.nonyu_price
,nonyu_amt=VALUES(nonyu_amt) ,nonyu_amt=t.nonyu_amt
,shikiri_price=VALUES(shikiri_price) ,shikiri_price=t.shikiri_price
,shikiri_amt=VALUES(shikiri_amt) ,shikiri_amt=t.shikiri_amt
,nhi_price=VALUES(nhi_price) ,nhi_price=t.nhi_price
,nhi_amt=VALUES(nhi_amt) ,nhi_amt=t.nhi_amt
,whspos_err_kbn=VALUES(whspos_err_kbn) ,whspos_err_kbn=medaca_common.convert_empty_to_null(t.whspos_err_kbn)
,htdnymd_err_kbn=VALUES(htdnymd_err_kbn) ,htdnymd_err_kbn=medaca_common.convert_empty_to_null(t.htdnymd_err_kbn)
,prd_exis_kbn=VALUES(prd_exis_kbn) ,prd_exis_kbn=medaca_common.convert_empty_to_null(t.prd_exis_kbn)
,fcl_exis_kbn=VALUES(fcl_exis_kbn) ,fcl_exis_kbn=medaca_common.convert_empty_to_null(t.fcl_exis_kbn)
,bef_hsdn_ymd=VALUES(bef_hsdn_ymd) ,bef_hsdn_ymd=medaca_common.convert_empty_to_null(t.bef_hsdn_ymd)
,bef_slip_num=VALUES(bef_slip_num) ,bef_slip_num=medaca_common.convert_empty_to_null(t.bef_slip_num)
,slip_org_kbn=VALUES(slip_org_kbn) ,slip_org_kbn=t.slip_org_kbn
,err_flg1=VALUES(err_flg1) ,err_flg1=medaca_common.convert_empty_to_null(t.err_flg1)
,err_flg2=VALUES(err_flg2) ,err_flg2=medaca_common.convert_empty_to_null(t.err_flg2)
,err_flg3=VALUES(err_flg3) ,err_flg3=medaca_common.convert_empty_to_null(t.err_flg3)
,err_flg4=VALUES(err_flg4) ,err_flg4=medaca_common.convert_empty_to_null(t.err_flg4)
,err_flg5=VALUES(err_flg5) ,err_flg5=medaca_common.convert_empty_to_null(t.err_flg5)
,err_flg6=VALUES(err_flg6) ,err_flg6=medaca_common.convert_empty_to_null(t.err_flg6)
,err_flg7=VALUES(err_flg7) ,err_flg7=medaca_common.convert_empty_to_null(t.err_flg7)
,err_flg8=VALUES(err_flg8) ,err_flg8=medaca_common.convert_empty_to_null(t.err_flg8)
,err_flg9=VALUES(err_flg9) ,err_flg9=medaca_common.convert_empty_to_null(t.err_flg9)
,err_flg10=VALUES(err_flg10) ,err_flg10=medaca_common.convert_empty_to_null(t.err_flg10)
,err_flg11=VALUES(err_flg11) ,err_flg11=medaca_common.convert_empty_to_null(t.err_flg11)
,err_flg12=VALUES(err_flg12) ,err_flg12=medaca_common.convert_empty_to_null(t.err_flg12)
,err_flg13=VALUES(err_flg13) ,err_flg13=medaca_common.convert_empty_to_null(t.err_flg13)
,err_flg14=VALUES(err_flg14) ,err_flg14=medaca_common.convert_empty_to_null(t.err_flg14)
,err_flg15=VALUES(err_flg15) ,err_flg15=medaca_common.convert_empty_to_null(t.err_flg15)
,err_flg16=VALUES(err_flg16) ,err_flg16=medaca_common.convert_empty_to_null(t.err_flg16)
,err_flg17=VALUES(err_flg17) ,err_flg17=medaca_common.convert_empty_to_null(t.err_flg17)
,err_flg18=VALUES(err_flg18) ,err_flg18=medaca_common.convert_empty_to_null(t.err_flg18)
,err_flg19=VALUES(err_flg19) ,err_flg19=medaca_common.convert_empty_to_null(t.err_flg19)
,err_flg20=VALUES(err_flg20) ,err_flg20=medaca_common.convert_empty_to_null(t.err_flg20)
,kjyo_ym=VALUES(kjyo_ym) ,kjyo_ym=medaca_common.convert_empty_to_null(t.kjyo_ym)
,tksnbk_kbn=VALUES(tksnbk_kbn) ,tksnbk_kbn=medaca_common.convert_empty_to_null(t.tksnbk_kbn)
,fcl_exec_kbn=VALUES(fcl_exec_kbn) ,fcl_exec_kbn=medaca_common.convert_empty_to_null(t.fcl_exec_kbn)
,rec_sts_kbn=VALUES(rec_sts_kbn) ,rec_sts_kbn=medaca_common.convert_empty_to_null(t.rec_sts_kbn)
,ins_dt=VALUES(ins_dt) ,ins_dt=nullif(t.ins_dt, 0)
,ins_usr=VALUES(ins_usr) ,ins_usr=medaca_common.convert_empty_to_null(t.ins_usr)
,dwh_upd_dT=SYSDATE() ,dwh_upd_dT=SYSDATE()
; ;
""") """)
@ -337,17 +337,17 @@ class VjskReceiveFileMapper:
,SYSDATE() ,SYSDATE()
FROM org05.hld_mst_v AS t FROM org05.hld_mst_v AS t
ON DUPLICATE KEY UPDATE ON DUPLICATE KEY UPDATE
v_hld_cd=VALUES(v_hld_cd) v_hld_cd=t.v_hld_cd
,sub_num=VALUES(sub_num) ,sub_num=t.sub_num
,name=VALUES(name) ,name=t.name
,kn_name=VALUES(kn_name) ,kn_name=medaca_common.convert_empty_to_null(t.kn_name)
,abb_name=VALUES(abb_name) ,abb_name=medaca_common.convert_empty_to_null(t.abb_name)
,start_date=VALUES(start_date) ,start_date=t.start_date
,end_date=VALUES(end_date) ,end_date=t.end_date
,dsp_odr=VALUES(dsp_odr) ,dsp_odr=t.dsp_odr
,rec_sts_kbn=VALUES(rec_sts_kbn) ,rec_sts_kbn=t.rec_sts_kbn
,ins_dt=VALUES(ins_dt) ,ins_dt=nullif(t.ins_dt, 0)
,upd_dt=VALUES(upd_dt) ,upd_dt=nullif(t.upd_dt, 0)
,dwh_upd_dt=SYSDATE() ,dwh_upd_dt=SYSDATE()
; ;
""") """)
@ -401,22 +401,22 @@ class VjskReceiveFileMapper:
,SYSDATE() ,SYSDATE()
FROM org05.whs_mst_v AS t FROM org05.whs_mst_v AS t
ON DUPLICATE KEY UPDATE ON DUPLICATE KEY UPDATE
v_whs_cd=VALUES(v_whs_cd) v_whs_cd=t.v_whs_cd
,sub_num=VALUES(sub_num) ,sub_num=t.sub_num
,name=VALUES(name) ,name=t.name
,kn_name=VALUES(kn_name) ,kn_name=medaca_common.convert_empty_to_null(t.kn_name)
,abb_name=VALUES(abb_name) ,abb_name=medaca_common.convert_empty_to_null(t.abb_name)
,postal_cd=VALUES(postal_cd) ,postal_cd=medaca_common.convert_empty_to_null(t.postal_cd)
,addr=VALUES(addr) ,addr=medaca_common.convert_empty_to_null(t.addr)
,kn_addr=VALUES(kn_addr) ,kn_addr=medaca_common.convert_empty_to_null(t.kn_addr)
,tel_num=VALUES(tel_num) ,tel_num=medaca_common.convert_empty_to_null(t.tel_num)
,v_hld_cd=VALUES(v_hld_cd) ,v_hld_cd=t.v_hld_cd
,start_date=VALUES(start_date) ,start_date=t.start_date
,end_date=VALUES(end_date) ,end_date=t.end_date
,dsp_odr=VALUES(dsp_odr) ,dsp_odr=t.dsp_odr
,rec_sts_kbn=VALUES(rec_sts_kbn) ,rec_sts_kbn=t.rec_sts_kbn
,ins_dt=VALUES(ins_dt) ,ins_dt=nullif(t.ins_dt, 0)
,upd_dt=VALUES(upd_dt) ,upd_dt=nullif(t.upd_dt, 0)
,dwh_upd_dt=SYSDATE() ,dwh_upd_dt=SYSDATE()
; ;
""") """)
@ -530,52 +530,52 @@ class VjskReceiveFileMapper:
,SYSDATE() ,SYSDATE()
FROM org05.mkr_org_horizon_v AS t FROM org05.mkr_org_horizon_v AS t
ON DUPLICATE KEY UPDATE ON DUPLICATE KEY UPDATE
vid_kind_1=VALUES(vid_kind_1) vid_kind_1=t.vid_kind_1
,v_cd_1=VALUES(v_cd_1) ,v_cd_1=t.v_cd_1
,name_1=VALUES(name_1) ,name_1=medaca_common.convert_empty_to_null(t.name_1)
,dsp_odr_1=VALUES(dsp_odr_1) ,dsp_odr_1=t.dsp_odr_1
,vid_kind_2=VALUES(vid_kind_2) ,vid_kind_2=t.vid_kind_2
,v_cd_2=VALUES(v_cd_2) ,v_cd_2=t.v_cd_2
,name_2=VALUES(name_2) ,name_2=medaca_common.convert_empty_to_null(t.name_2)
,dsp_odr_2=VALUES(dsp_odr_2) ,dsp_odr_2=t.dsp_odr_2
,vid_kind_3=VALUES(vid_kind_3) ,vid_kind_3=t.vid_kind_3
,v_cd_3=VALUES(v_cd_3) ,v_cd_3=t.v_cd_3
,name_3=VALUES(name_3) ,name_3=medaca_common.convert_empty_to_null(t.name_3)
,dsp_odr_3=VALUES(dsp_odr_3) ,dsp_odr_3=t.dsp_odr_3
,vid_kind_4=VALUES(vid_kind_4) ,vid_kind_4=t.vid_kind_4
,v_cd_4=VALUES(v_cd_4) ,v_cd_4=t.v_cd_4
,name_4=VALUES(name_4) ,name_4=medaca_common.convert_empty_to_null(t.name_4)
,dsp_odr_4=VALUES(dsp_odr_4) ,dsp_odr_4=t.dsp_odr_4
,vid_kind_5=VALUES(vid_kind_5) ,vid_kind_5=t.vid_kind_5
,v_cd_5=VALUES(v_cd_5) ,v_cd_5=t.v_cd_5
,name_5=VALUES(name_5) ,name_5=medaca_common.convert_empty_to_null(t.name_5)
,dsp_odr_5=VALUES(dsp_odr_5) ,dsp_odr_5=t.dsp_odr_5
,vid_kind_6=VALUES(vid_kind_6) ,vid_kind_6=t.vid_kind_6
,v_cd_6=VALUES(v_cd_6) ,v_cd_6=t.v_cd_6
,name_6=VALUES(name_6) ,name_6=medaca_common.convert_empty_to_null(t.name_6)
,dsp_odr_6=VALUES(dsp_odr_6) ,dsp_odr_6=t.dsp_odr_6
,vid_kind_7=VALUES(vid_kind_7) ,vid_kind_7=t.vid_kind_7
,v_cd_7=VALUES(v_cd_7) ,v_cd_7=t.v_cd_7
,name_7=VALUES(name_7) ,name_7=medaca_common.convert_empty_to_null(t.name_7)
,dsp_odr_7=VALUES(dsp_odr_7) ,dsp_odr_7=t.dsp_odr_7
,vid_kind_8=VALUES(vid_kind_8) ,vid_kind_8=t.vid_kind_8
,v_cd_8=VALUES(v_cd_8) ,v_cd_8=t.v_cd_8
,name_8=VALUES(name_8) ,name_8=medaca_common.convert_empty_to_null(t.name_8)
,dsp_odr_8=VALUES(dsp_odr_8) ,dsp_odr_8=t.dsp_odr_8
,vid_kind_9=VALUES(vid_kind_9) ,vid_kind_9=t.vid_kind_9
,v_cd_9=VALUES(v_cd_9) ,v_cd_9=t.v_cd_9
,name_9=VALUES(name_9) ,name_9=medaca_common.convert_empty_to_null(t.name_9)
,dsp_odr_9=VALUES(dsp_odr_9) ,dsp_odr_9=t.dsp_odr_9
,vid_kind_10=VALUES(vid_kind_10) ,vid_kind_10=t.vid_kind_10
,v_cd_10=VALUES(v_cd_10) ,v_cd_10=t.v_cd_10
,name_10=VALUES(name_10) ,name_10=medaca_common.convert_empty_to_null(t.name_10)
,dsp_odr_10=VALUES(dsp_odr_10) ,dsp_odr_10=t.dsp_odr_10
,v_whs_cd=VALUES(v_whs_cd) ,v_whs_cd=t.v_whs_cd
,start_date=VALUES(start_date) ,start_date=t.start_date
,end_date=VALUES(end_date) ,end_date=t.end_date
,rec_sts_kbn=VALUES(rec_sts_kbn) ,rec_sts_kbn=t.rec_sts_kbn
,ins_dt=VALUES(ins_dt) ,ins_dt=nullif(t.ins_dt, 0)
,upd_dt=VALUES(upd_dt) ,upd_dt=nullif(t.upd_dt, 0)
,dwh_upd_dt=SYSDATE() ,dwh_upd_dt=SYSDATE()
; ;
""") """)
@ -670,15 +670,15 @@ class VjskReceiveFileMapper:
,SYSDATE() ,SYSDATE()
FROM org05.tran_kbn_mst_v AS t FROM org05.tran_kbn_mst_v AS t
ON DUPLICATE KEY UPDATE ON DUPLICATE KEY UPDATE
v_tran_cd=VALUES(v_tran_cd) v_tran_cd=t.v_tran_cd
,sub_num=VALUES(sub_num) ,sub_num=t.sub_num
,name=VALUES(name) ,name=medaca_common.convert_empty_to_null(t.name)
,start_date=VALUES(start_date) ,start_date=t.start_date
,end_date=VALUES(end_date) ,end_date=t.end_date
,dsp_odr=VALUES(dsp_odr) ,dsp_odr=t.dsp_odr
,rec_sts_kbn=VALUES(rec_sts_kbn) ,rec_sts_kbn=t.rec_sts_kbn
,ins_dt=VALUES(ins_dt) ,ins_dt=nullif(t.ins_dt, 0)
,upd_dt=VALUES(upd_dt) ,upd_dt=nullif(t.upd_dt, 0)
,dwh_upd_dt=SYSDATE() ,dwh_upd_dt=SYSDATE()
; ;
""") """)
@ -743,35 +743,35 @@ class VjskReceiveFileMapper:
,medaca_common.convert_empty_to_null(t.admin_kbn) ,medaca_common.convert_empty_to_null(t.admin_kbn)
,medaca_common.convert_empty_to_null(t.fcl_type) ,medaca_common.convert_empty_to_null(t.fcl_type)
,t.rec_sts_kbn ,t.rec_sts_kbn
,nullif(t.ins_dt, 0) -- 受領データがブランクだった場合にゼロ日付で取得されるので明示的にNULL値に変換する ,medaca_common.convert_empty_to_null(t.ins_dt) -- (留意)fcm_mst_vではvarchar型
,nullif(t.upd_dt, 0) -- 受領データがブランクだった場合にゼロ日付で取得されるので明示的にNULL値に変換する ,medaca_common.convert_empty_to_null(t.upd_dt) -- (留意)fcm_mst_vではvarchar型
,SYSDATE() ,SYSDATE()
FROM org05.fcl_mst_v AS t FROM org05.fcl_mst_v AS t
ON DUPLICATE KEY UPDATE ON DUPLICATE KEY UPDATE
v_inst_cd=VALUES(v_inst_cd) v_inst_cd=t.v_inst_cd
,sub_num=VALUES(sub_num) ,sub_num=t.sub_num
,start_date=VALUES(start_date) ,start_date=t.start_date
,end_date=VALUES(end_date) ,end_date=t.end_date
,closed_dt=VALUES(closed_dt) ,closed_dt=medaca_common.convert_empty_to_null(t.closed_dt)
,fcl_name=VALUES(fcl_name) ,fcl_name=medaca_common.convert_empty_to_null(t.fcl_name)
,fcl_kn_name=VALUES(fcl_kn_name) ,fcl_kn_name=medaca_common.convert_empty_to_null(t.fcl_kn_name)
,fcl_abb_name=VALUES(fcl_abb_name) ,fcl_abb_name=medaca_common.convert_empty_to_null(t.fcl_abb_name)
,fcl_abb_kn_name=VALUES(fcl_abb_kn_name) ,fcl_abb_kn_name=medaca_common.convert_empty_to_null(t.fcl_abb_kn_name)
,mkr_cd=VALUES(mkr_cd) ,mkr_cd=medaca_common.convert_empty_to_null(t.mkr_cd)
,jsk_proc_kbn=VALUES(jsk_proc_kbn) ,jsk_proc_kbn=t.jsk_proc_kbn
,fmt_addr=VALUES(fmt_addr) ,fmt_addr=medaca_common.convert_empty_to_null(t.fmt_addr)
,fmt_kn_addr=VALUES(fmt_kn_addr) ,fmt_kn_addr=medaca_common.convert_empty_to_null(t.fmt_kn_addr)
,postal_cd=VALUES(postal_cd) ,postal_cd=medaca_common.convert_empty_to_null(t.postal_cd)
,prft_cd=VALUES(prft_cd) ,prft_cd=medaca_common.convert_empty_to_null(t.prft_cd)
,prft_name=VALUES(prft_name) ,prft_name=medaca_common.convert_empty_to_null(t.prft_name)
,city_name=VALUES(city_name) ,city_name=medaca_common.convert_empty_to_null(t.city_name)
,addr_line_1=VALUES(addr_line_1) ,addr_line_1=medaca_common.convert_empty_to_null(t.addr_line_1)
,tel_num=VALUES(tel_num) ,tel_num=medaca_common.convert_empty_to_null(t.tel_num)
,admin_kbn=VALUES(admin_kbn) ,admin_kbn=medaca_common.convert_empty_to_null(t.admin_kbn)
,fcl_type=VALUES(fcl_type) ,fcl_type=medaca_common.convert_empty_to_null(t.fcl_type)
,rec_sts_kbn=VALUES(rec_sts_kbn) ,rec_sts_kbn=t.rec_sts_kbn
,ins_dt=VALUES(ins_dt) ,ins_dt=medaca_common.convert_empty_to_null(t.ins_dt)
,upd_dt=VALUES(upd_dt) ,upd_dt=medaca_common.convert_empty_to_null(t.upd_dt)
,dwh_upd_dt=SYSDATE() ,dwh_upd_dt=SYSDATE()
; ;
""") """)
@ -849,34 +849,34 @@ class VjskReceiveFileMapper:
,SYSDATE() ,SYSDATE()
FROM org05.phm_prd_mst_v AS t FROM org05.phm_prd_mst_v AS t
ON DUPLICATE KEY UPDATE ON DUPLICATE KEY UPDATE
prd_cd=VALUES(prd_cd) prd_cd=t.prd_cd
,sub_num=VALUES(sub_num) ,sub_num=t.sub_num
,prd_name=VALUES(prd_name) ,prd_name=t.prd_name
,prd_e_name=VALUES(prd_e_name) ,prd_e_name=medaca_common.convert_empty_to_null(t.prd_e_name)
,mkr_cd=VALUES(mkr_cd) ,mkr_cd=medaca_common.convert_empty_to_null(t.mkr_cd)
,mkr_inf_1=VALUES(mkr_inf_1) ,mkr_inf_1=medaca_common.convert_empty_to_null(t.mkr_inf_1)
,mkr_inf_2=VALUES(mkr_inf_2) ,mkr_inf_2=medaca_common.convert_empty_to_null(t.mkr_inf_2)
,phm_itm_cd=VALUES(phm_itm_cd) ,phm_itm_cd=medaca_common.convert_empty_to_null(t.phm_itm_cd)
,itm_name=VALUES(itm_name) ,itm_name=medaca_common.convert_empty_to_null(t.itm_name)
,itm_abb_name=VALUES(itm_abb_name) ,itm_abb_name=medaca_common.convert_empty_to_null(t.itm_abb_name)
,form_cd=VALUES(form_cd) ,form_cd=medaca_common.convert_empty_to_null(t.form_cd)
,form_name=VALUES(form_name) ,form_name=medaca_common.convert_empty_to_null(t.form_name)
,vol_cd=VALUES(vol_cd) ,vol_cd=medaca_common.convert_empty_to_null(t.vol_cd)
,vol_name=VALUES(vol_name) ,vol_name=medaca_common.convert_empty_to_null(t.vol_name)
,cont_cd=VALUES(cont_cd) ,cont_cd=medaca_common.convert_empty_to_null(t.cont_cd)
,cont_name=VALUES(cont_name) ,cont_name=medaca_common.convert_empty_to_null(t.cont_name)
,pkg_cd=VALUES(pkg_cd) ,pkg_cd=medaca_common.convert_empty_to_null(t.pkg_cd)
,pkg_name=VALUES(pkg_name) ,pkg_name=medaca_common.convert_empty_to_null(t.pkg_name)
,cnv_num=VALUES(cnv_num) ,cnv_num=t.cnv_num
,jsk_start_dt=VALUES(jsk_start_dt) ,jsk_start_dt=nullif(t.jsk_start_dt, 0)
,prd_sale_kbn=VALUES(prd_sale_kbn) ,prd_sale_kbn=t.prd_sale_kbn
,jsk_proc_kbn=VALUES(jsk_proc_kbn) ,jsk_proc_kbn=t.jsk_proc_kbn
,start_date=VALUES(start_date) ,start_date=t.start_date
,end_date=VALUES(end_date) ,end_date=t.end_date
,dsp_odr=VALUES(dsp_odr) ,dsp_odr=t.dsp_odr
,rec_sts_kbn=VALUES(rec_sts_kbn) ,rec_sts_kbn=t.rec_sts_kbn
,ins_dt=VALUES(ins_dt) ,ins_dt=nullif(t.ins_dt, 0)
,upd_dt=VALUES(upd_dt) ,upd_dt=nullif(t.upd_dt, 0)
,dwh_upd_dt=SYSDATE() ,dwh_upd_dt=SYSDATE()
; ;
""") """)
@ -1018,23 +1018,23 @@ class VjskReceiveFileMapper:
,SYSDATE() ,SYSDATE()
FROM org05.whs_customer_mst_v AS t FROM org05.whs_customer_mst_v AS t
ON DUPLICATE KEY UPDATE ON DUPLICATE KEY UPDATE
whs_cd=VALUES(whs_cd) whs_cd=t.whs_cd
,whs_sub_cd=VALUES(whs_sub_cd) ,whs_sub_cd=t.whs_sub_cd
,customer_cd=VALUES(customer_cd) ,customer_cd=t.customer_cd
,sub_num=VALUES(sub_num) ,sub_num=t.sub_num
,start_date=VALUES(start_date) ,start_date=t.start_date
,end_date=VALUES(end_date) ,end_date=t.end_date
,whs_org_cd=VALUES(whs_org_cd) ,whs_org_cd=medaca_common.convert_empty_to_null(t.whs_org_cd)
,src_org_cd=VALUES(src_org_cd) ,src_org_cd=medaca_common.convert_empty_to_null(t.src_org_cd)
,name=VALUES(name) ,name=medaca_common.convert_empty_to_null(t.name)
,kn_name=VALUES(kn_name) ,kn_name=medaca_common.convert_empty_to_null(t.kn_name)
,addr=VALUES(addr) ,addr=medaca_common.convert_empty_to_null(t.addr)
,kn_addr=VALUES(kn_addr) ,kn_addr=medaca_common.convert_empty_to_null(t.kn_addr)
,postal_cd=VALUES(postal_cd) ,postal_cd=medaca_common.convert_empty_to_null(t.postal_cd)
,tel_num=VALUES(tel_num) ,tel_num=medaca_common.convert_empty_to_null(t.tel_num)
,rec_sts_kbn=VALUES(rec_sts_kbn) ,rec_sts_kbn=t.rec_sts_kbn
,ins_dt=VALUES(ins_dt) ,ins_dt=nullif(t.ins_dt, 0)
,upd_dt=VALUES(upd_dt) ,upd_dt=nullif(t.upd_dt, 0)
,dwh_upd_dt=SYSDATE() ,dwh_upd_dt=SYSDATE()
; ;
""") """)
@ -1160,35 +1160,35 @@ class VjskReceiveFileMapper:
,SYSDATE() ,SYSDATE()
FROM org05.whole_stock AS t FROM org05.whole_stock AS t
ON DUPLICATE KEY UPDATE ON DUPLICATE KEY UPDATE
rec_data=VALUES(rec_data) rec_data=medaca_common.convert_empty_to_null(t.rec_data)
,rec_whs_cd=VALUES(rec_whs_cd) ,rec_whs_cd=medaca_common.convert_empty_to_null(t.rec_whs_cd)
,rec_whs_sub_cd=VALUES(rec_whs_sub_cd) ,rec_whs_sub_cd=medaca_common.convert_empty_to_null(t.rec_whs_sub_cd)
,rec_sto_place=VALUES(rec_sto_place) ,rec_sto_place=medaca_common.convert_empty_to_null(t.rec_sto_place)
,rec_stock_ymd=VALUES(rec_stock_ymd) ,rec_stock_ymd=medaca_common.convert_empty_to_null(t.rec_stock_ymd)
,rec_comm_cd=VALUES(rec_comm_cd) ,rec_comm_cd=medaca_common.convert_empty_to_null(t.rec_comm_cd)
,rec_qty=VALUES(rec_qty) ,rec_qty=medaca_common.convert_empty_to_null(t.rec_qty)
,rec_stock_no_sign=VALUES(rec_stock_no_sign) ,rec_stock_no_sign=medaca_common.convert_empty_to_null(t.rec_stock_no_sign)
,rec_jan_cd=VALUES(rec_jan_cd) ,rec_jan_cd=medaca_common.convert_empty_to_null(t.rec_jan_cd)
,free_item=VALUES(free_item) ,free_item=medaca_common.convert_empty_to_null(t.free_item)
,rec_ymd=VALUES(rec_ymd) ,rec_ymd=medaca_common.convert_empty_to_null(t.rec_ymd)
,sale_data_cat=VALUES(sale_data_cat) ,sale_data_cat=medaca_common.convert_empty_to_null(t.sale_data_cat)
,slip_file_name=VALUES(slip_file_name) ,slip_file_name=medaca_common.convert_empty_to_null(t.slip_file_name)
,slip_mgt_num=VALUES(slip_mgt_num) ,slip_mgt_num=t.slip_mgt_num
,row_num=VALUES(row_num) ,row_num=t.row_num
,exec_dt=VALUES(exec_dt) ,exec_dt=medaca_common.convert_empty_to_null(t.exec_dt)
,err_flg1=VALUES(err_flg1) ,err_flg1=medaca_common.convert_empty_to_null(t.err_flg1)
,err_flg2=VALUES(err_flg2) ,err_flg2=medaca_common.convert_empty_to_null(t.err_flg2)
,err_flg3=VALUES(err_flg3) ,err_flg3=medaca_common.convert_empty_to_null(t.err_flg3)
,err_flg4=VALUES(err_flg4) ,err_flg4=medaca_common.convert_empty_to_null(t.err_flg4)
,err_flg5=VALUES(err_flg5) ,err_flg5=medaca_common.convert_empty_to_null(t.err_flg5)
,err_flg6=VALUES(err_flg6) ,err_flg6=medaca_common.convert_empty_to_null(t.err_flg6)
,err_flg7=VALUES(err_flg7) ,err_flg7=medaca_common.convert_empty_to_null(t.err_flg7)
,err_flg8=VALUES(err_flg8) ,err_flg8=medaca_common.convert_empty_to_null(t.err_flg8)
,err_flg9=VALUES(err_flg9) ,err_flg9=medaca_common.convert_empty_to_null(t.err_flg9)
,err_flg10=VALUES(err_flg10) ,err_flg10=medaca_common.convert_empty_to_null(t.err_flg10)
,rec_sts_kbn=VALUES(rec_sts_kbn) ,rec_sts_kbn=medaca_common.convert_empty_to_null(t.rec_sts_kbn)
,ins_dt=VALUES(ins_dt) ,ins_dt=nullif(t.ins_dt, 0)
,ins_usr=VALUES(ins_usr) ,ins_usr=medaca_common.convert_empty_to_null(t.ins_usr)
,dwh_upd_dt=SYSDATE() ,dwh_upd_dt=SYSDATE()
; ;
""") """)
@ -1366,84 +1366,84 @@ class VjskReceiveFileMapper:
,SYSDATE() ,SYSDATE()
FROM org05.bio_sales AS t FROM org05.bio_sales AS t
ON DUPLICATE KEY UPDATE ON DUPLICATE KEY UPDATE
rec_data=VALUES(rec_data) rec_data=medaca_common.convert_empty_to_null(t.rec_data)
,rec_whs_cd=VALUES(rec_whs_cd) ,rec_whs_cd=medaca_common.convert_empty_to_null(t.rec_whs_cd)
,rec_whs_sub_cd=VALUES(rec_whs_sub_cd) ,rec_whs_sub_cd=medaca_common.convert_empty_to_null(t.rec_whs_sub_cd)
,rec_whs_org_cd=VALUES(rec_whs_org_cd) ,rec_whs_org_cd=medaca_common.convert_empty_to_null(t.rec_whs_org_cd)
,rec_cust_cd=VALUES(rec_cust_cd) ,rec_cust_cd=medaca_common.convert_empty_to_null(t.rec_cust_cd)
,rec_comm_cd=VALUES(rec_comm_cd) ,rec_comm_cd=medaca_common.convert_empty_to_null(t.rec_comm_cd)
,rec_tran_kbn=VALUES(rec_tran_kbn) ,rec_tran_kbn=medaca_common.convert_empty_to_null(t.rec_tran_kbn)
,rev_hsdnymd_wrk=VALUES(rev_hsdnymd_wrk) ,rev_hsdnymd_wrk=medaca_common.convert_empty_to_null(t.rev_hsdnymd_wrk)
,rev_hsdnymd_srk=VALUES(rev_hsdnymd_srk) ,rev_hsdnymd_srk=medaca_common.convert_empty_to_null(t.rev_hsdnymd_srk)
,rec_urag_num=VALUES(rec_urag_num) ,rec_urag_num=medaca_common.convert_empty_to_null(t.rec_urag_num)
,rec_comm_name=VALUES(rec_comm_name) ,rec_comm_name=medaca_common.convert_empty_to_null(t.rec_comm_name)
,rec_nonyu_fcl_name=VALUES(rec_nonyu_fcl_name) ,rec_nonyu_fcl_name=medaca_common.convert_empty_to_null(t.rec_nonyu_fcl_name)
,rec_nonyu_fcl_addr=VALUES(rec_nonyu_fcl_addr) ,rec_nonyu_fcl_addr=medaca_common.convert_empty_to_null(t.rec_nonyu_fcl_addr)
,rec_lot_num1=VALUES(rec_lot_num1) ,rec_lot_num1=medaca_common.convert_empty_to_null(t.rec_lot_num1)
,rec_qty1=VALUES(rec_qty1) ,rec_qty1=medaca_common.convert_empty_to_null(t.rec_qty1)
,rec_lot_num2=VALUES(rec_lot_num2) ,rec_lot_num2=medaca_common.convert_empty_to_null(t.rec_lot_num2)
,rec_qty2=VALUES(rec_qty2) ,rec_qty2=medaca_common.convert_empty_to_null(t.rec_qty2)
,rec_lot_num3=VALUES(rec_lot_num3) ,rec_lot_num3=medaca_common.convert_empty_to_null(t.rec_lot_num3)
,rec_qty3=VALUES(rec_qty3) ,rec_qty3=medaca_common.convert_empty_to_null(t.rec_qty3)
,rec_ymd=VALUES(rec_ymd) ,rec_ymd=medaca_common.convert_empty_to_null(t.rec_ymd)
,sale_data_cat=VALUES(sale_data_cat) ,sale_data_cat=medaca_common.convert_empty_to_null(t.sale_data_cat)
,slip_file_name=VALUES(slip_file_name) ,slip_file_name=medaca_common.convert_empty_to_null(t.slip_file_name)
,slip_mgt_num=VALUES(slip_mgt_num) ,slip_mgt_num=t.slip_mgt_num
,row_num=VALUES(row_num) ,row_num=t.row_num
,hsdn_ymd=VALUES(hsdn_ymd) ,hsdn_ymd=medaca_common.convert_empty_to_null(t.hsdn_ymd)
,exec_dt=VALUES(exec_dt) ,exec_dt=medaca_common.convert_empty_to_null(t.exec_dt)
,v_tran_cd=VALUES(v_tran_cd) ,v_tran_cd=t.v_tran_cd
,tran_kbn_name=VALUES(tran_kbn_name) ,tran_kbn_name=medaca_common.convert_empty_to_null(t.tran_kbn_name)
,whs_org_cd=VALUES(whs_org_cd) ,whs_org_cd=medaca_common.convert_empty_to_null(t.whs_org_cd)
,v_whsorg_cd=VALUES(v_whsorg_cd) ,v_whsorg_cd=t.v_whsorg_cd
,whs_org_name=VALUES(whs_org_name) ,whs_org_name=medaca_common.convert_empty_to_null(t.whs_org_name)
,whs_org_kn=VALUES(whs_org_kn) ,whs_org_kn=medaca_common.convert_empty_to_null(t.whs_org_kn)
,v_whs_cd=VALUES(v_whs_cd) ,v_whs_cd=t.v_whs_cd
,whs_name=VALUES(whs_name) ,whs_name=medaca_common.convert_empty_to_null(t.whs_name)
,nonyu_fcl_cd=VALUES(nonyu_fcl_cd) ,nonyu_fcl_cd=medaca_common.convert_empty_to_null(t.nonyu_fcl_cd)
,v_inst_cd=VALUES(v_inst_cd) ,v_inst_cd=nullif(t.v_inst_cd,'')
,v_inst_name=VALUES(v_inst_name) ,v_inst_name=nullif(t.v_inst_name,'')
,v_inst_kn=VALUES(v_inst_kn) ,v_inst_kn=nullif(t.v_inst_kn,'')
,v_inst_addr=VALUES(v_inst_addr) ,v_inst_addr=nullif(t.v_inst_addr,'')
,comm_cd=VALUES(comm_cd) ,comm_cd=nullif(t.comm_cd,'')
,product_name=VALUES(product_name) ,product_name=nullif(t.product_name,'')
,htdnymd_err_kbn=VALUES(htdnymd_err_kbn) ,htdnymd_err_kbn=nullif(t.htdnymd_err_kbn,'')
,prd_exis_kbn=VALUES(prd_exis_kbn) ,prd_exis_kbn=nullif(t.prd_exis_kbn,'')
,fcl_exis_kbn=VALUES(fcl_exis_kbn) ,fcl_exis_kbn=nullif(t.fcl_exis_kbn,'')
,qty1=VALUES(qty1) ,qty1=t.qty1
,qty2=VALUES(qty2) ,qty2=t.qty2
,qty3=VALUES(qty3) ,qty3=t.qty3
,slip_org_kbn=VALUES(slip_org_kbn) ,slip_org_kbn=t.slip_org_kbn
,bef_slip_mgt_num=VALUES(bef_slip_mgt_num) ,bef_slip_mgt_num=medaca_common.convert_empty_to_null(t.bef_slip_mgt_num)
,whs_rep_comm_name=VALUES(whs_rep_comm_name) ,whs_rep_comm_name=medaca_common.convert_empty_to_null(t.whs_rep_comm_name)
,whs_rep_nonyu_fcl_name=VALUES(whs_rep_nonyu_fcl_name) ,whs_rep_nonyu_fcl_name=medaca_common.convert_empty_to_null(t.whs_rep_nonyu_fcl_name)
,whs_rep_nonyu_fcl_addr=VALUES(whs_rep_nonyu_fcl_addr) ,whs_rep_nonyu_fcl_addr=medaca_common.convert_empty_to_null(t.whs_rep_nonyu_fcl_addr)
,err_flg1=VALUES(err_flg1) ,err_flg1=medaca_common.convert_empty_to_null(t.err_flg1)
,err_flg2=VALUES(err_flg2) ,err_flg2=medaca_common.convert_empty_to_null(t.err_flg2)
,err_flg3=VALUES(err_flg3) ,err_flg3=medaca_common.convert_empty_to_null(t.err_flg3)
,err_flg4=VALUES(err_flg4) ,err_flg4=medaca_common.convert_empty_to_null(t.err_flg4)
,err_flg5=VALUES(err_flg5) ,err_flg5=medaca_common.convert_empty_to_null(t.err_flg5)
,err_flg6=VALUES(err_flg6) ,err_flg6=medaca_common.convert_empty_to_null(t.err_flg6)
,err_flg7=VALUES(err_flg7) ,err_flg7=medaca_common.convert_empty_to_null(t.err_flg7)
,err_flg8=VALUES(err_flg8) ,err_flg8=medaca_common.convert_empty_to_null(t.err_flg8)
,err_flg9=VALUES(err_flg9) ,err_flg9=medaca_common.convert_empty_to_null(t.err_flg9)
,err_flg10=VALUES(err_flg10) ,err_flg10=medaca_common.convert_empty_to_null(t.err_flg10)
,err_flg11=VALUES(err_flg11) ,err_flg11=medaca_common.convert_empty_to_null(t.err_flg11)
,err_flg12=VALUES(err_flg12) ,err_flg12=medaca_common.convert_empty_to_null(t.err_flg12)
,err_flg13=VALUES(err_flg13) ,err_flg13=medaca_common.convert_empty_to_null(t.err_flg13)
,err_flg14=VALUES(err_flg14) ,err_flg14=medaca_common.convert_empty_to_null(t.err_flg14)
,err_flg15=VALUES(err_flg15) ,err_flg15=medaca_common.convert_empty_to_null(t.err_flg15)
,err_flg16=VALUES(err_flg16) ,err_flg16=medaca_common.convert_empty_to_null(t.err_flg16)
,err_flg17=VALUES(err_flg17) ,err_flg17=medaca_common.convert_empty_to_null(t.err_flg17)
,err_flg18=VALUES(err_flg18) ,err_flg18=medaca_common.convert_empty_to_null(t.err_flg18)
,err_flg19=VALUES(err_flg19) ,err_flg19=medaca_common.convert_empty_to_null(t.err_flg19)
,err_flg20=VALUES(err_flg20) ,err_flg20=medaca_common.convert_empty_to_null(t.err_flg20)
,kjyo_ym=VALUES(kjyo_ym) ,kjyo_ym=medaca_common.convert_empty_to_null(t.kjyo_ym)
,tksnbk_kbn=VALUES(tksnbk_kbn) ,tksnbk_kbn=medaca_common.convert_empty_to_null(t.tksnbk_kbn)
,fcl_exec_kbn=VALUES(fcl_exec_kbn) ,fcl_exec_kbn=medaca_common.convert_empty_to_null(t.fcl_exec_kbn)
,rec_sts_kbn=VALUES(rec_sts_kbn) ,rec_sts_kbn=medaca_common.convert_empty_to_null(t.rec_sts_kbn)
,ins_dt=VALUES(ins_dt) ,ins_dt=nullif(t.ins_dt, 0)
,ins_usr=VALUES(ins_usr) ,ins_usr=medaca_common.convert_empty_to_null(t.ins_usr)
,dwh_upd_dt=SYSDATE() ,dwh_upd_dt=SYSDATE()
; ;
""") """)
@ -1477,12 +1477,12 @@ class VjskReceiveFileMapper:
,SYSDATE() ,SYSDATE()
FROM org05.lot_num_mst AS t FROM org05.lot_num_mst AS t
ON DUPLICATE KEY UPDATE ON DUPLICATE KEY UPDATE
ser_num=VALUES(ser_num) ser_num=t.ser_num
,lot_num=VALUES(lot_num) ,lot_num=t.lot_num
,expr_dt=VALUES(expr_dt) ,expr_dt=t.expr_dt
,frst_mov_dt=VALUES(frst_mov_dt) ,frst_mov_dt=t.frst_mov_dt
,ins_dt=VALUES(ins_dt) ,ins_dt=nullif(t.ins_dt, 0)
,ins_usr=VALUES(ins_usr) ,ins_usr=medaca_common.convert_empty_to_null(t.ins_usr)
,dwh_upd_dt=SYSDATE() ,dwh_upd_dt=SYSDATE()
; ;
""") """)

8
ecs/jskult-batch-daily/tests/batch/vjsk/vjsk_load/test_vjsk_load.py
View File

@ -564,7 +564,7 @@ class TestImportFileToDb:
# 突合から除外する項目 # 突合から除外する項目
ignore_columns = ['dwh_upd_dt'] ignore_columns = ['dwh_upd_dt']
# 日付型に変換して比較する項目 # 日付型に変換して比較する項目
force_cast_to_str_columns = ['closed_dt'] force_cast_to_str_columns = ['closed_dt', 'ins_dt', 'upd_dt']
# orgテーブル結果が期待値通りかを突合 # orgテーブル結果が期待値通りかを突合
assert_table_results(result_org, assert_list, ignore_columns, force_cast_to_str_columns, is_loaddata=True) assert_table_results(result_org, assert_list, ignore_columns, force_cast_to_str_columns, is_loaddata=True)
# srcテーブル結果を取得 # srcテーブル結果を取得
@ -572,7 +572,7 @@ class TestImportFileToDb:
# 突合から除外する項目 # 突合から除外する項目
ignore_columns = ['dwh_upd_dt'] ignore_columns = ['dwh_upd_dt']
# 日付型に変換して比較する項目 # 日付型に変換して比較する項目
force_cast_to_str_columns = ['closed_dt'] force_cast_to_str_columns = ['closed_dt', 'ins_dt', 'upd_dt']
# srcテーブル結果が期待値通りかを突合 # srcテーブル結果が期待値通りかを突合
assert_table_results(result_src, assert_list, ignore_columns, force_cast_to_str_columns) assert_table_results(result_src, assert_list, ignore_columns, force_cast_to_str_columns)
@ -895,7 +895,7 @@ class TestImportFileToDb:
# orgテーブル結果が期待値通りかを突合 # orgテーブル結果が期待値通りかを突合
assert_table_results(result_org, assert_list, ignore_columns, is_loaddata=True) assert_table_results(result_org, assert_list, ignore_columns, is_loaddata=True)
# srcテーブル結果を取得 # srcテーブル結果を取得
result_src = self.db.execute_select(f"select * from {table_name_src}") result_src = self.db.execute_select(f"select * from {table_name_src} order by customer_cd")
# 突合から除外する項目 # 突合から除外する項目
ignore_columns = ['dwh_upd_dt'] ignore_columns = ['dwh_upd_dt']
# srcテーブル結果が期待値通りかを突合 # srcテーブル結果が期待値通りかを突合
@ -1085,7 +1085,7 @@ class TestImportFileToDb:
# orgテーブル結果が期待値通りかを突合 # orgテーブル結果が期待値通りかを突合
assert_table_results(result_org, assert_list, ignore_columns, is_loaddata=True) assert_table_results(result_org, assert_list, ignore_columns, is_loaddata=True)
# srcテーブル結果を取得 # srcテーブル結果を取得
result_src = self.db.execute_select(f"select * from {table_name_src}") result_src = self.db.execute_select(f"select * from {table_name_src} order by ser_num, lot_num")
# 突合から除外する項目 # 突合から除外する項目
ignore_columns = ['dwh_upd_dt'] ignore_columns = ['dwh_upd_dt']
# srcテーブル結果が期待値通りかを突合 # srcテーブル結果が期待値通りかを突合

2
ecs/jskult-batch-daily/tests/batch/vjsk/vjsk_load/testdata/fcl_mst_202304280000.tsv vendored
View File

@ -1,5 +1,5 @@
"fcl_cd" "sub_no" "start_dt" "end_dt" "closed_dt" "nm" "kn_nm" "sht_nm" "sht_kn_nm" "mkr_cd" "jsk_proc_kbn" "fmt_addr" "fmt_kn_addr" "post_cd" "prft_cd" "prft_nm" "city_nm" "addr_line_1" "tel_no" "admin_kbn" "fcl_type" "rec_sts_kbn" "ins_dt" "upd_dt" "fcl_cd" "sub_no" "start_dt" "end_dt" "closed_dt" "nm" "kn_nm" "sht_nm" "sht_kn_nm" "mkr_cd" "jsk_proc_kbn" "fmt_addr" "fmt_kn_addr" "post_cd" "prft_cd" "prft_nm" "city_nm" "addr_line_1" "tel_no" "admin_kbn" "fcl_type" "rec_sts_kbn" "ins_dt" "upd_dt"
"670229430760653825" "0" "20000101" "99991231" "" "駅前町歯科診療所" "ｴｷﾏｴﾁｮｳｼｶｼﾝﾘｮｳｼﾞｮ" "駅前町歯科診療所" "ｴｷﾏｴﾁｮｳｼｶｼﾝﾘｮｳｼﾞｮ" "" "0" "700-0023 岡山県岡山市北区駅前町１−６−２０" "ｵｶﾔﾏｹﾝ ｵｶﾔﾏｼｷﾀｸ ｴｷﾏｴﾁｮｳ1-6-20" "700-0023" "33" "岡山県" "岡山市北区" "駅前町１−６−２０" "0862236468" "33101" "30" "1" "" "" "670229430760653825" "0" "20000101" "99991231" "" "駅前町歯科診療所" "ｴｷﾏｴﾁｮｳｼｶｼﾝﾘｮｳｼﾞｮ" "駅前町歯科診療所" "ｴｷﾏｴﾁｮｳｼｶｼﾝﾘｮｳｼﾞｮ" "" "0" "700-0023 岡山県岡山市北区駅前町１−６−２０" "ｵｶﾔﾏｹﾝ ｵｶﾔﾏｼｷﾀｸ ｴｷﾏｴﾁｮｳ1-6-20" "700-0023" "33" "岡山県" "岡山市北区" "駅前町１−６−２０" "0862236468" "33101" "30" "1" "2023-09-29 09:43:55" "2023-09-29 09:48:44"
"670229435466662922" "0" "20000101" "99991231" "" "医療法人社団仁卓会　ほりかわ歯科クリニック" "ｲﾘｮｳﾎｳｼﾞﾝｼｬﾀﾞﾝｼﾞﾝﾀｸｶｲ ﾎﾘｶﾜｼｶｸﾘﾆｯｸ" "ほりかわ歯科クリニック　（医社）" "ﾎﾘｶﾜｼｶｸﾘﾆｯｸ (ｲｼｬ)" "" "0" "675-0101 兵庫県加古川市平岡町新在家１５７３−１−４Ｆ" "ﾋｮｳｺﾞｹﾝ ｶｺｶﾞﾜｼ ﾋﾗｵｶﾁｮｳｼﾝｻﾞｲｹ1573-1-4F" "675-0101" "28" "兵庫県" "加古川市" "平岡町新在家１５７３−１−４Ｆ" "0794244617" "28210" "30" "1" "" "" "670229435466662922" "0" "20000101" "99991231" "" "医療法人社団仁卓会　ほりかわ歯科クリニック" "ｲﾘｮｳﾎｳｼﾞﾝｼｬﾀﾞﾝｼﾞﾝﾀｸｶｲ ﾎﾘｶﾜｼｶｸﾘﾆｯｸ" "ほりかわ歯科クリニック　（医社）" "ﾎﾘｶﾜｼｶｸﾘﾆｯｸ (ｲｼｬ)" "" "0" "675-0101 兵庫県加古川市平岡町新在家１５７３−１−４Ｆ" "ﾋｮｳｺﾞｹﾝ ｶｺｶﾞﾜｼ ﾋﾗｵｶﾁｮｳｼﾝｻﾞｲｹ1573-1-4F" "675-0101" "28" "兵庫県" "加古川市" "平岡町新在家１５７３−１−４Ｆ" "0794244617" "28210" "30" "1" "" ""
"670229435785430019" "0" "20000101" "99991231" "" "株式会社コミュニティメディカル　なつめ薬局　千歳船橋店" "ｶﾌﾞｼｷｶﾞｲｼｬｺﾐｭﾆﾃｨﾒﾃﾞｨｶﾙ ﾅﾂﾒﾔｯｷｮｸ ﾁﾄｾﾌﾅﾊﾞｼﾃﾝ" "なつめ薬局　千歳船橋店　（株）" "ﾅﾂﾒﾔｯｷｮｸ ﾁﾄｾﾌﾅﾊﾞｼﾃﾝ (ｶ)" "" "0" "156-0054 東京都世田谷区桜丘２−２４−２" "ﾄｳｷｮｳﾄ ｾﾀｶﾞﾔｸ ｻｸﾗｶﾞｵｶ2-24-2" "156-0054" "13" "東京都" "世田谷区" "桜丘２−２４−２" "0364136189" "13112" "20" "1" "" "" "670229435785430019" "0" "20000101" "99991231" "" "株式会社コミュニティメディカル　なつめ薬局　千歳船橋店" "ｶﾌﾞｼｷｶﾞｲｼｬｺﾐｭﾆﾃｨﾒﾃﾞｨｶﾙ ﾅﾂﾒﾔｯｷｮｸ ﾁﾄｾﾌﾅﾊﾞｼﾃﾝ" "なつめ薬局　千歳船橋店　（株）" "ﾅﾂﾒﾔｯｷｮｸ ﾁﾄｾﾌﾅﾊﾞｼﾃﾝ (ｶ)" "" "0" "156-0054 東京都世田谷区桜丘２−２４−２" "ﾄｳｷｮｳﾄ ｾﾀｶﾞﾔｸ ｻｸﾗｶﾞｵｶ2-24-2" "156-0054" "13" "東京都" "世田谷区" "桜丘２−２４−２" "0364136189" "13112" "20" "1" "" ""
"670229447437206529" "0" "20000101" "20230407" "2023-04-07" "ヒカリ薬局" "ﾋｶﾘﾔｯｷｮｸ" "ヒカリ薬局" "ﾋｶﾘﾔｯｷｮｸ" "" "0" "670-0955 兵庫県姫路市安田４−４７−８−１Ｆ" "ﾋｮｳｺﾞｹﾝ ﾋﾒｼﾞｼ ﾔｽﾀﾞ4-47-8-1F" "670-0955" "28" "兵庫県" "姫路市" "安田４−４７−８−１Ｆ" "0792846396" "28201" "20" "1" "" "" "670229447437206529" "0" "20000101" "20230407" "2023-04-07" "ヒカリ薬局" "ﾋｶﾘﾔｯｷｮｸ" "ヒカリ薬局" "ﾋｶﾘﾔｯｷｮｸ" "" "0" "670-0955 兵庫県姫路市安田４−４７−８−１Ｆ" "ﾋｮｳｺﾞｹﾝ ﾋﾒｼﾞｼ ﾔｽﾀﾞ4-47-8-1F" "670-0955" "28" "兵庫県" "姫路市" "安田４−４７−８−１Ｆ" "0792846396" "28201" "20" "1" "" ""

1 fcl_cd sub_no start_dt end_dt closed_dt nm kn_nm sht_nm sht_kn_nm mkr_cd jsk_proc_kbn fmt_addr fmt_kn_addr post_cd prft_cd prft_nm city_nm addr_line_1 tel_no admin_kbn fcl_type rec_sts_kbn ins_dt upd_dt
2 670229430760653825 0 20000101 99991231 駅前町歯科診療所 ｴｷﾏｴﾁｮｳｼｶｼﾝﾘｮｳｼﾞｮ 駅前町歯科診療所 ｴｷﾏｴﾁｮｳｼｶｼﾝﾘｮｳｼﾞｮ 0 700-0023 岡山県岡山市北区駅前町１−６−２０ ｵｶﾔﾏｹﾝ ｵｶﾔﾏｼｷﾀｸ ｴｷﾏｴﾁｮｳ1-6-20 700-0023 33 岡山県 岡山市北区 駅前町１−６−２０ 0862236468 33101 30 1 2023-09-29 09:43:55 2023-09-29 09:48:44
3 670229435466662922 0 20000101 99991231 医療法人社団仁卓会　ほりかわ歯科クリニック ｲﾘｮｳﾎｳｼﾞﾝｼｬﾀﾞﾝｼﾞﾝﾀｸｶｲ ﾎﾘｶﾜｼｶｸﾘﾆｯｸ ほりかわ歯科クリニック　（医社） ﾎﾘｶﾜｼｶｸﾘﾆｯｸ (ｲｼｬ) 0 675-0101 兵庫県加古川市平岡町新在家１５７３−１−４Ｆ ﾋｮｳｺﾞｹﾝ ｶｺｶﾞﾜｼ ﾋﾗｵｶﾁｮｳｼﾝｻﾞｲｹ1573-1-4F 675-0101 28 兵庫県 加古川市 平岡町新在家１５７３−１−４Ｆ 0794244617 28210 30 1
4 670229435785430019 0 20000101 99991231 株式会社コミュニティメディカル　なつめ薬局　千歳船橋店 ｶﾌﾞｼｷｶﾞｲｼｬｺﾐｭﾆﾃｨﾒﾃﾞｨｶﾙ ﾅﾂﾒﾔｯｷｮｸ ﾁﾄｾﾌﾅﾊﾞｼﾃﾝ なつめ薬局　千歳船橋店　（株） ﾅﾂﾒﾔｯｷｮｸ ﾁﾄｾﾌﾅﾊﾞｼﾃﾝ (ｶ) 0 156-0054 東京都世田谷区桜丘２−２４−２ ﾄｳｷｮｳﾄ ｾﾀｶﾞﾔｸ ｻｸﾗｶﾞｵｶ2-24-2 156-0054 13 東京都 世田谷区 桜丘２−２４−２ 0364136189 13112 20 1
5 670229447437206529 0 20000101 20230407 2023-04-07 ヒカリ薬局 ﾋｶﾘﾔｯｷｮｸ ヒカリ薬局 ﾋｶﾘﾔｯｷｮｸ 0 670-0955 兵庫県姫路市安田４−４７−８−１Ｆ ﾋｮｳｺﾞｹﾝ ﾋﾒｼﾞｼ ﾔｽﾀﾞ4-47-8-1F 670-0955 28 兵庫県 姫路市 安田４−４７−８−１Ｆ 0792846396 28201 20 1

4
ecs/jskult-batch-daily/tests/batch/vjsk/vjsk_load/testdata/lot_num_mst_202304290000.tsv vendored
View File

@ -1,5 +1,5 @@
"ser_no" "lot_num" "expr_dt" "frst_mov_dt" "ins_dt" "ins_usr" "ser_no" "lot_num" "expr_dt" "frst_mov_dt" "ins_dt" "ins_usr"
"F0110602" "BAVA001" "20231031" "20210719" "23-05-08 20:40:41" "batch"
"F0110602" "BAVA002" "20231031" "20210823" "23-05-08 20:40:41" ""
"F0110601" "BAVA005" "20231031" "20210927" "23-05-08 20:40:41" "batch" "F0110601" "BAVA005" "20231031" "20210927" "23-05-08 20:40:41" "batch"
"F0110601" "BAVA006" "20240131" "20211025" "23-05-08 20:40:41" "batch" "F0110601" "BAVA006" "20240131" "20211025" "23-05-08 20:40:41" "batch"
"F0110602" "BAVA001" "20231031" "20210719" "23-05-08 20:40:41" "batch"
"F0110602" "BAVA002" "20231031" "20210823" "23-05-08 20:40:41" ""

1 ser_no lot_num expr_dt frst_mov_dt ins_dt ins_usr
F0110602 BAVA001 20231031 20210719 23-05-08 20:40:41 batch
F0110602 BAVA002 20231031 20210823 23-05-08 20:40:41
2 F0110601 BAVA005 20231031 20210927 23-05-08 20:40:41 batch
3 F0110601 BAVA006 20240131 20211025 23-05-08 20:40:41 batch
4 F0110602 BAVA001 20231031 20210719 23-05-08 20:40:41 batch
5 F0110602 BAVA002 20231031 20210823 23-05-08 20:40:41

4
ecs/jskult-batch-daily/tests/batch/vjsk/vjsk_load/testdata/whs_customer_mst_202304290000.tsv vendored
View File

@ -1,5 +1,5 @@
"whs_cd" "whs_sub_cd" "customer_cd" "sub_no" "start_dt" "end_dt" "org_cd" "src_org_cd" "nm" "kn_nm" "addr" "kn_addr" "zip_cd" "tel_no" "rec_sts_kbn" "ins_dt" "upd_dt" "whs_cd" "whs_sub_cd" "customer_cd" "sub_no" "start_dt" "end_dt" "org_cd" "src_org_cd" "nm" "kn_nm" "addr" "kn_addr" "zip_cd" "tel_no" "rec_sts_kbn" "ins_dt" "upd_dt"
"006" "01" "1009200000" "0" "20000101" "99991231" "11" "1121A2224212" "山口医院２　　　　　　　　　　　　　　　　　　" "ﾔﾏｸﾞﾁｲｲﾝ" "長崎県　佐世保市春日町２９−１４　　　　　　　　　　　　　　　　" "ﾅｶﾞｻｷｹﾝ ｻｾﾎﾞｼｶｽｶﾞﾁﾖｳ29-14" "8570011" "0956228610" "0" "23-04-14 11:53:14" "23-04-14 11:53:14"
"006" "01" "1009300000" "0" "20000101" "99991231" "" "" "" "" "" "" "" "" "0" "23-04-14 11:53:14" "23-04-14 11:53:14"
"006" "01" "1008000000" "0" "20000101" "99991231" "11" "1131A2283316" "北原整形外科医院２　　　　　　　　　　　　　　" "ｷﾀﾊﾗｾｲｹｲｹﾞｶ ｲｲﾝ" "長崎県　佐世保市瀬戸越町４丁目１２９８−１　　　　　　　　　　　" "ﾅｶﾞｻｷｹﾝ ｻｾﾎﾞｼｾﾄｺﾞｼﾁﾖｳ 1298-1" "8570135" "0956497773" "0" "23-04-14 11:53:14" "23-04-14 11:53:14" "006" "01" "1008000000" "0" "20000101" "99991231" "11" "1131A2283316" "北原整形外科医院２　　　　　　　　　　　　　　" "ｷﾀﾊﾗｾｲｹｲｹﾞｶ ｲｲﾝ" "長崎県　佐世保市瀬戸越町４丁目１２９８−１　　　　　　　　　　　" "ﾅｶﾞｻｷｹﾝ ｻｾﾎﾞｼｾﾄｺﾞｼﾁﾖｳ 1298-1" "8570135" "0956497773" "0" "23-04-14 11:53:14" "23-04-14 11:53:14"
"006" "01" "1009100000" "0" "20000101" "99991231" "11" "1121A2224212" "山口医院２　　　　　　　　　　　　　　　　　　" "ﾔﾏｸﾞﾁｲｲﾝ" "長崎県　佐世保市春日町２９−１４　　　　　　　　　　　　　　　　" "ﾅｶﾞｻｷｹﾝ ｻｾﾎﾞｼｶｽｶﾞﾁﾖｳ29-14" "8570011" "0956228610" "0" "23-04-14 11:53:14" "23-04-14 11:53:14" "006" "01" "1009100000" "0" "20000101" "99991231" "11" "1121A2224212" "山口医院２　　　　　　　　　　　　　　　　　　" "ﾔﾏｸﾞﾁｲｲﾝ" "長崎県　佐世保市春日町２９−１４　　　　　　　　　　　　　　　　" "ﾅｶﾞｻｷｹﾝ ｻｾﾎﾞｼｶｽｶﾞﾁﾖｳ29-14" "8570011" "0956228610" "0" "23-04-14 11:53:14" "23-04-14 11:53:14"
"006" "01" "1009200000" "0" "20000101" "99991231" "11" "1121A2224212" "山口医院２　　　　　　　　　　　　　　　　　　" "ﾔﾏｸﾞﾁｲｲﾝ" "長崎県　佐世保市春日町２９−１４　　　　　　　　　　　　　　　　" "ﾅｶﾞｻｷｹﾝ ｻｾﾎﾞｼｶｽｶﾞﾁﾖｳ29-14" "8570011" "0956228610" "0" "23-04-14 11:53:14" "23-04-14 11:53:14"
"006" "01" "1009300000" "0" "20000101" "99991231" "" "" "" "" "" "" "" "" "0" "23-04-14 11:53:14" "23-04-14 11:53:14"

1 whs_cd whs_sub_cd customer_cd sub_no start_dt end_dt org_cd src_org_cd nm kn_nm addr kn_addr zip_cd tel_no rec_sts_kbn ins_dt upd_dt
006 01 1009200000 0 20000101 99991231 11 1121A2224212 山口医院２　　　　　　　　　　　　　　　　　　 ﾔﾏｸﾞﾁｲｲﾝ 長崎県　佐世保市春日町２９−１４　　　　　　　　　　　　　　　　 ﾅｶﾞｻｷｹﾝ ｻｾﾎﾞｼｶｽｶﾞﾁﾖｳ29-14 8570011 0956228610 0 23-04-14 11:53:14 23-04-14 11:53:14
006 01 1009300000 0 20000101 99991231 0 23-04-14 11:53:14 23-04-14 11:53:14
2 006 01 1008000000 0 20000101 99991231 11 1131A2283316 北原整形外科医院２　　　　　　　　　　　　　　 ｷﾀﾊﾗｾｲｹｲｹﾞｶ ｲｲﾝ 長崎県　佐世保市瀬戸越町４丁目１２９８−１　　　　　　　　　　　 ﾅｶﾞｻｷｹﾝ ｻｾﾎﾞｼｾﾄｺﾞｼﾁﾖｳ 1298-1 8570135 0956497773 0 23-04-14 11:53:14 23-04-14 11:53:14
3 006 01 1009100000 0 20000101 99991231 11 1121A2224212 山口医院２　　　　　　　　　　　　　　　　　　 ﾔﾏｸﾞﾁｲｲﾝ 長崎県　佐世保市春日町２９−１４　　　　　　　　　　　　　　　　 ﾅｶﾞｻｷｹﾝ ｻｾﾎﾞｼｶｽｶﾞﾁﾖｳ29-14 8570011 0956228610 0 23-04-14 11:53:14 23-04-14 11:53:14
4 006 01 1009200000 0 20000101 99991231 11 1121A2224212 山口医院２　　　　　　　　　　　　　　　　　　 ﾔﾏｸﾞﾁｲｲﾝ 長崎県　佐世保市春日町２９−１４　　　　　　　　　　　　　　　　 ﾅｶﾞｻｷｹﾝ ｻｾﾎﾞｼｶｽｶﾞﾁﾖｳ29-14 8570011 0956228610 0 23-04-14 11:53:14 23-04-14 11:53:14
5 006 01 1009300000 0 20000101 99991231 0 23-04-14 11:53:14 23-04-14 11:53:14

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

@ -93,6 +93,8 @@ def assert_table_results(actual_rows: list[dict], expect_rows: list[dict], ignor
# DB項目(varchar)に日付型としてキャスト可能な値が期待値である場合、force_cast_to_str_columnsに基づいて強制的に文字列キャストする # DB項目(varchar)に日付型としてキャスト可能な値が期待値である場合、force_cast_to_str_columnsに基づいて強制的に文字列キャストする
if type(expect_value).__name__ == 'date': if type(expect_value).__name__ == 'date':
expect_value = expect_value.strftime('%Y-%m-%d') expect_value = expect_value.strftime('%Y-%m-%d')
elif type(expect_value).__name__ == 'datetime':
expect_value = expect_value.strftime('%Y-%m-%d %H:%M:%S')
elif not is_loaddata and expect_value == "": elif not is_loaddata and expect_value == "":
expect_value = None expect_value = None
elif isinstance(actual_value, (int)): elif isinstance(actual_value, (int)):

BIN
ecs/jskult-webapp/src/data/BioData_template.xlsx
View File

Binary file not shown.

6
ecs/jskult-webapp/src/model/view/bio_view_model.py
View File

@ -62,9 +62,9 @@ class BioViewModel(BaseModel):
part_size = 500 part_size = 500
for i in range(0, search_data_len, part_size): for i in range(0, search_data_len, part_size):
json_str = json.dumps(search_data_list[i:i + part_size], ensure_ascii=False, default=date_handler) json_str = json.dumps(search_data_list[i:i + part_size], ensure_ascii=False, default=date_handler)
# JavaScriptに埋め込むため、クォートをエスケープ # JavaScriptに埋め込むため、バックスラッシュ、バッククォートをエスケープ
json_str = json_str.replace("'", "\\'") json_str = json_str.replace('\\', '\\\\')
json_str = json_str.replace('\\"', '\\\\"') json_str = json_str.replace("`", "\\`")
yield json_str yield json_str
def make_whs_name(self): def make_whs_name(self):

6
ecs/jskult-webapp/src/model/view/ultmarc_doctor_search_view_model.py
View File

@ -28,9 +28,9 @@ class UltmarcDoctorSearchViewModel(BaseModel):
part_size = 50 part_size = 50
for i in range(0, search_data_len, part_size): for i in range(0, search_data_len, part_size):
json_str = json.dumps(search_data_list[i:i + part_size], ensure_ascii=False, default=date_handler) json_str = json.dumps(search_data_list[i:i + part_size], ensure_ascii=False, default=date_handler)
# JavaScriptに埋め込むため、クォートをエスケープ # JavaScriptに埋め込むため、バックスラッシュ、バッククォートをエスケープ
json_str = json_str.replace("'", "\\'") json_str = json_str.replace('\\', '\\\\')
json_str = json_str.replace('\\"', '\\\\"') json_str = json_str.replace("`", "\\`")
yield json_str yield json_str
# ページネーションのページ番号 # ページネーションのページ番号

6
ecs/jskult-webapp/src/model/view/ultmarc_inst_search_view_model.py
View File

@ -30,9 +30,9 @@ class UltmarcInstSearchViewModel(BaseModel):
part_size = 50 part_size = 50
for i in range(0, search_data_len, part_size): for i in range(0, search_data_len, part_size):
json_str = json.dumps(search_data_list[i:i + part_size], ensure_ascii=False, default=date_handler) json_str = json.dumps(search_data_list[i:i + part_size], ensure_ascii=False, default=date_handler)
# JavaScriptに埋め込むため、クォートをエスケープ # JavaScriptに埋め込むため、バックスラッシュ、バッククォートをエスケープ
json_str = json_str.replace("'", "\\'") json_str = json_str.replace('\\', '\\\\')
json_str = json_str.replace('\\"', '\\\\"') json_str = json_str.replace("`", "\\`")
yield json_str yield json_str
# ページネーションのページ番号 # ページネーションのページ番号

7
ecs/jskult-webapp/src/repositories/bio_sales_lot_repository.py
View File

@ -45,10 +45,11 @@ class BioSalesLotRepository(BaseRepository):
inst_name_form, inst_name_form,
address, address,
tel_num, tel_num,
v_whs_cd, -- Excel出力のため、数値型のコード値を文字列として取得(Veeva卸コード、Veeva卸組織コード、Veeva取引区分コード)
v_whsorg_cd, CAST(v_whs_cd AS CHAR) AS v_whs_cd,
CAST(v_whsorg_cd AS CHAR) AS v_whsorg_cd,
whs_org_name, whs_org_name,
v_tran_cd, CAST(v_tran_cd AS CHAR) AS v_tran_cd,
iko_flg iko_flg
FROM FROM
src05.bio_sales_lot src05.bio_sales_lot

5
ecs/jskult-webapp/src/services/bio_view_service.py
View File

@ -152,12 +152,13 @@ class BioViewService(BaseService):
# DF内のヘッダと連番を書き込みたくない場合、`header`と`index`をFalseに指定する。 # DF内のヘッダと連番を書き込みたくない場合、`header`と`index`をFalseに指定する。
# `startrow`と`startcol`で、Excelの書き込み位置を決定する。省略した場合はA1セルから書く。 # `startrow`と`startcol`で、Excelの書き込み位置を決定する。省略した場合はA1セルから書く。
data_frame_chunk_size = 2000 # 各部分データフレームのサイズ
is_first = True # ループの初回
data_frame_range = len(data_frame) data_frame_range = len(data_frame)
data_frame_chunk_size = 2000 # 1回あたりの書き出し行数
is_first = True # ループの初回
# 指定行数ごとにデータを分割して処理 # 指定行数ごとにデータを分割して処理
for i in range(0, data_frame_range, data_frame_chunk_size): for i in range(0, data_frame_range, data_frame_chunk_size):
chunk_df = data_frame.iloc[i:i + data_frame_chunk_size] chunk_df = data_frame.iloc[i:i + data_frame_chunk_size]
start_row = i + 1 start_row = i + 1
# 1回目の分割では、ヘッダ部分を上書きしないようにする # 1回目の分割では、ヘッダ部分を上書きしないようにする
if is_first: if is_first:

3
ecs/jskult-webapp/src/templates/bioSearchList.html
View File

@ -370,7 +370,8 @@
// {% autoescape False%} // {% autoescape False%}
// ジェネレータですこしずつ取得してリストに詰める // ジェネレータですこしずつ取得してリストに詰める
// {% for bio_data_json_str in bio.bio_data_json_str() %} // {% for bio_data_json_str in bio.bio_data_json_str() %}
searchResultData.push(...JSON.parse('{{bio_data_json_str}}')) // unicode制御文字をエスケープしてからJSON.parseする
searchResultData.push(...JSON.parse(`{{bio_data_json_str}}`.replace(/[\u0000-\u001F]+/g, " ")))
// {% endfor %} // {% endfor %}
// {% endautoescape%} // {% endautoescape%}
// {% endif %} // {% endif %}

3
ecs/jskult-webapp/src/templates/docSearch.html
View File

@ -273,7 +273,8 @@
// {% autoescape False%} // {% autoescape False%}
// ジェネレータですこしずつ取得してリストに詰める // ジェネレータですこしずつ取得してリストに詰める
// {% for ultmarc_data_json_str in ultmarc.ultmarc_data_json_str() %} // {% for ultmarc_data_json_str in ultmarc.ultmarc_data_json_str() %}
searchResultData.push(...JSON.parse('{{ultmarc_data_json_str}}')) // unicode制御文字をエスケープしてからJSON.parseする
searchResultData.push(...JSON.parse(`{{ultmarc_data_json_str}}`.replace(/[\u0000-\u001F]+/g, " ")))
// {% endfor %} // {% endfor %}
// {% endautoescape%} // {% endautoescape%}
// {% endif %} // {% endif %}

3
ecs/jskult-webapp/src/templates/instSearch.html
View File

@ -257,7 +257,8 @@
// {% autoescape False%} // {% autoescape False%}
// ジェネレータですこしずつ取得してリストに詰める // ジェネレータですこしずつ取得してリストに詰める
// {% for ultmarc_data_json_str in ultmarc.ultmarc_data_json_str() %} // {% for ultmarc_data_json_str in ultmarc.ultmarc_data_json_str() %}
searchResultData.push(...JSON.parse('{{ultmarc_data_json_str}}')) // unicode制御文字をエスケープしてからJSON.parseする
searchResultData.push(...JSON.parse(`{{ultmarc_data_json_str}}`.replace(/[\u0000-\u001F]+/g, " ")))
// {% endfor %} // {% endfor %}
// {% endautoescape%} // {% endautoescape%}
// {% endif %} // {% endif %}