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

feat: #22_実績更新処理_卸販売データ（洗替後）処理日当日の取込データが反映されない 対応

Browse Source
This commit is contained in:
Takagi 2023-09-15 16:09:00 +09:00
parent 142d0fff10
commit 350905ce6d
1 changed files with 6 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
rds_mysql/stored_procedure/src05/sales_lau_upsert.sql
View File

@ -145,7 +145,6 @@ BEGIN
);
SET @extract_from_datetime = CAST(extract_from_date AS DATETIME);
SET @extract_to_datetime = ADDTIME(CAST(extract_to_date AS DATETIME), '23:59:59');
SET @upsert_sales_launderning = "
INSERT INTO
@ -334,11 +333,10 @@ BEGIN
SYSDATE()
FROM (
SELECT
? AS extract_from_datetime,
? AS extract_to_datetime
? AS extract_from_datetime
) AS sub
INNER JOIN src05.sales AS s
ON s.dwh_upd_dt BETWEEN sub.extract_from_datetime AND sub.extract_to_datetime
ON s.dwh_upd_dt >= sub.extract_from_datetime
LEFT OUTER JOIN src05.phm_prd_mst_v AS ppmv
ON s.comm_cd = ppmv.prd_cd
AND STR_TO_DATE(s.hsdn_ymd,'%Y%m%d') BETWEEN ppmv.start_date AND ppmv.end_date
@ -435,7 +433,7 @@ BEGIN
";
SET @upsert_sales_launderning = REPLACE(@upsert_sales_launderning, "$$target_table$$", target_table);
PREPARE upsert_sales_launderning_stmt from @upsert_sales_launderning;
EXECUTE upsert_sales_launderning_stmt USING @extract_from_datetime, @extract_to_datetime;
EXECUTE upsert_sales_launderning_stmt USING @extract_from_datetime;
CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'卸販売実績テーブル（洗替後）作成⑤ 終了'
@ -448,8 +446,7 @@ BEGIN
SET @update_institution_code = "
UPDATE (
SELECT
? AS extract_from_datetime,
? AS extract_to_datetime
? AS extract_from_datetime
) AS sub,
$$target_table$$ AS tt,
src05.sales AS s
@ -465,13 +462,13 @@ BEGIN
END
)
WHERE
s.dwh_upd_dt BETWEEN sub.extract_from_datetime AND sub.extract_to_datetime
s.dwh_upd_dt >= sub.extract_from_datetime
AND tt.slip_mgt_num = s.slip_mgt_num
AND tt.row_num = s.row_num
";
SET @update_institution_code = REPLACE(@update_institution_code, "$$target_table$$", target_table);
PREPARE update_institution_code_stmt from @update_institution_code;
EXECUTE update_institution_code_stmt USING @extract_from_datetime, @extract_to_datetime;
EXECUTE update_institution_code_stmt USING @extract_from_datetime;
CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'卸販売実績テーブル（洗替後）作成⑥ 終了'