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

生物由来ロット分解データの未確定データ削除

Browse Source
This commit is contained in:
mori.k 2025-05-28 19:12:22 +09:00
parent a49a616235
commit bb015efe3a
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
ecs/jskult-batch/src/batch/trn_result_data_bio_lot.py
View File

@ -120,8 +120,9 @@ class TrnResultDataBioLot(JskultBatchEntrypoint):
sql = """ sql = """
DELETE lot FROM src07.trn_result_data_bio_lot AS lot DELETE lot FROM src07.trn_result_data_bio_lot AS lot
INNER JOIN src07.trn_result_data_bio AS bio INNER JOIN src07.trn_result_data_bio AS bio
ON bio.slip_mgt_num = lot.slip_mgt_num ON bio.account_ym = lot.account_ym
AND DATE(bio.dwh_upd_dt) >= src07.get_syor_date() AND bio.seq_no = lot.seq_no
AND DATE(bio.last_upd_dtt) >= src07.get_syor_date()
""" """
res = db.execute(sql) res = db.execute(sql)
except Exception as e: except Exception as e:
@ -338,7 +339,7 @@ class TrnResultDataBioLot(JskultBatchEntrypoint):
AND bio.err_flg9 = '0' AND bio.err_flg9 = '0'
AND bio.err_flg10 = '0' AND bio.err_flg10 = '0'
AND bio.rec_sts_kbn <> '99' AND bio.rec_sts_kbn <> '99'
AND DATE(bio.dwh_upd_dt) >= src05.get_syor_date() AND DATE(bio.dwh_upd_dt) >= src07.get_syor_date()
""" """
res = db.execute(sql) res = db.execute(sql)