-- A5M2で実行時に[SQL] - [スラッシュ(/)のみの行でSQLを区切る]に変えてから実行する
-- extract_to_dateは、NEWDWH2021-1230の対応の結果、未使用の引数となっています
CREATE PROCEDURE src05.sales_lau_upsert(target_table VARCHAR(255), extract_from_date DATE,
                                    extract_to_date DATE)
SQL SECURITY INVOKER
BEGIN
    -- スキーマ名
    DECLARE schema_name VARCHAR(50) DEFAULT (SELECT DATABASE());
    -- プロシージャ名
    DECLARE procedure_name VARCHAR(100) DEFAULT 'sales_lau_upsert';
    -- プロシージャの引数
    DECLARE procedure_args JSON DEFAULT JSON_OBJECT('target_table', target_table, 'extract_from_date', 
                            extract_from_date, 'extract_to_date', extract_to_date);

    -- 例外処理
    DECLARE EXIT HANDLER FOR SQLEXCEPTION
        BEGIN
            GET DIAGNOSTICS CONDITION 1
                @error_state = RETURNED_SQLSTATE, @error_msg = MESSAGE_TEXT;
            CALL medaca_common.put_error_log(schema_name, procedure_name, procedure_args,
                                    'sales_lau_upsertでエラーが発生', @error_state, @error_msg);
            SET @error_msg = (
                CASE
                WHEN LENGTH(@error_msg) > 128 THEN CONCAT(SUBSTRING(@error_msg, 1, 125), '...')
                ELSE @error_msg
                END
            );
            SIGNAL SQLSTATE '45000'
                SET MYSQL_ERRNO = @error_state, MESSAGE_TEXT = @error_msg;
        END;

    SET @error_state = NULL, @error_msg = NULL;

    CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
                            '卸販売実績テーブル（洗替後）作成① 開始'
    );

    TRUNCATE TABLE internal05.bu_prd_name_contrast_t;

    CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
                            '卸販売実績テーブル（洗替後）作成① 終了' 
    );

    CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
                            '卸販売実績テーブル（洗替後）作成② 開始' 
    );

    INSERT INTO
        internal05.bu_prd_name_contrast_t (
            prd_cd,
            bu_cd,
            phm_itm_cd,
            pp_start_date,
            pp_end_date,
            update_date,
            bp_start_date,
            bp_end_date
        )
    SELECT
        ppmv.prd_cd,
        bpnc.bu_cd,
        ppmv.phm_itm_cd,
        ppmv.start_date AS pp_start_date,
        ppmv.end_date AS pp_end_date,
        bpnc.update_date AS update_date,
        bpnc.start_date AS bp_start_date,
        bpnc.end_date AS bp_end_date
    FROM
        src05.phm_prd_mst_v AS ppmv
    LEFT OUTER JOIN src05.bu_prd_name_contrast AS bpnc
        ON ppmv.phm_itm_cd = bpnc.phm_itm_cd
    WHERE
        ppmv.rec_sts_kbn != '9'
    ;

    CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
                            '卸販売実績テーブル（洗替後）作成② 終了' 
    );


    CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
                            '卸販売実績テーブル（洗替後）作成③ 開始'
    );

    TRUNCATE TABLE internal05.fcl_mst_v_t;

    CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
                            '卸販売実績テーブル（洗替後）作成③ 終了'
    );

    CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
                            '卸販売実績テーブル（洗替後）作成④ 開始'
    );

    INSERT INTO
        internal05.fcl_mst_v_t
    SELECT
        fmv1.v_inst_cd,
        fmv1.sub_num,
        fmv1.start_date,
        fmv1.end_date,
        fmv1.closed_dt,
        fmv1.fcl_name,
        fmv1.fcl_kn_name,
        fmv1.fcl_abb_name,
        fmv1.fcl_abb_kn_name,
        fmv1.mkr_cd,
        fmv1.jsk_proc_kbn,
        fmv1.fmt_addr,
        fmv1.fmt_kn_addr,
        fmv1.postal_cd,
        fmv1.prft_cd,
        fmv1.prft_name,
        fmv1.city_name,
        fmv1.addr_line_1,
        fmv1.tel_num,
        fmv1.admin_kbn,
        fmv1.fcl_type,
        fmv1.rec_sts_kbn,
        fmv1.ins_dt,
        fmv1.upd_dt,
        fmv1.dwh_upd_dt
    FROM
        src05.fcl_mst_v AS fmv1
    INNER JOIN (
        SELECT
            fmv.v_inst_cd,
            MAX(fmv.sub_num) AS sno  
        FROM
            src05.fcl_mst_v AS fmv
        GROUP BY
            fmv.v_inst_cd
        ) AS fmv2 
        ON fmv1.v_inst_cd = fmv2.v_inst_cd
        AND fmv1.sub_num = fmv2.sno
    WHERE
        fmv1.rec_sts_kbn != '9'
    ;

    CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
                            '卸販売実績テーブル（洗替後）作成④ 終了'
    );

    CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
                            '卸販売実績テーブル（洗替後）作成⑤ 開始'
    );

    SET @extract_from_datetime = CAST(extract_from_date AS DATETIME);

    SET @upsert_sales_launderning = "
        INSERT INTO
            $$target_table$$ (
                rec_whs_cd,
                rec_whs_sub_cd,
                rec_whs_org_cd,
                rec_cust_cd,
                rec_comm_cd,
                rec_tran_kbn,
                rev_hsdnymd_wrk,
                rev_hsdnymd_srk,
                rec_urag_num,
                rec_qty,
                rec_nonyu_price,
                rec_nonyu_amt,
                rec_comm_name,
                rec_nonyu_fcl_name,
                free_item,
                rec_nonyu_fcl_addr,
                rec_nonyu_fcl_post,
                rec_nonyu_fcl_tel,
                rec_bef_hsdn_ymd,
                rec_bef_slip_num,
                rec_ymd,
                sale_data_cat,
                slip_file_name,
                slip_mgt_num,
                row_num,
                hsdn_ymd,
                exec_dt,
                v_tran_cd,
                tran_kbn_name,
                whs_org_cd,
                v_whsorg_cd,
                whs_org_name,
                whs_org_kn,
                v_whs_cd,
                whs_name,
                nonyu_fcl_cd,
                inst_name,
                inst_name_kana,
                address,
                comm_cd,
                comm_name,
                nonyu_qty,
                nonyu_price,
                nonyu_amt,
                shikiri_price,
                shikiri_amt,
                nhi_price,
                nhi_amt,
                v_inst_cd,
                inst_clas_cd,
                bu_cd,
                item_cd,
                item_name,
                item_english_name,
                pref_cd,
                whspos_err_kbn,
                htdnymd_err_kbn,
                prd_exis_kbn,
                fcl_exis_kbn,
                bef_hsdn_ymd,
                bef_slip_num,
                slip_org_kbn,
                kjyo_ym,
                tksnbk_kbn,
                fcl_exec_kbn,
                rec_sts_kbn,
                ins_dt,
                ins_usr,
                dwh_upd_dt 
            )
        SELECT
            s.rec_whs_cd,
            s.rec_whs_sub_cd,
            s.rec_whs_org_cd,
            s.rec_cust_cd,
            s.rec_comm_cd,
            s.rec_tran_kbn,
            s.rev_hsdnymd_wrk,
            s.rev_hsdnymd_srk,
            s.rec_urag_num,
            s.rec_qty,
            s.rec_nonyu_price,
            s.rec_nonyu_amt,
            s.rec_comm_name,
            s.rec_nonyu_fcl_name,
            s.free_item,
            s.rec_nonyu_fcl_addr,
            s.rec_nonyu_fcl_post,
            s.rec_nonyu_fcl_tel,
            s.rec_bef_hsdn_ymd,
            s.rec_bef_slip_num,
            s.rec_ymd,
            s.sale_data_cat,
            s.slip_file_name,
            s.slip_mgt_num,
            s.row_num,
            s.hsdn_ymd,
            s.exec_dt,
            s.v_tran_cd,
            s.tran_kbn_name,
            s.whs_org_cd,
            s.v_whsorg_cd,
            s.whs_org_name,
            s.whs_org_kn,
            s.v_whs_cd,
            s.whs_name,
            s.nonyu_fcl_cd,
            s.v_inst_name,
            s.v_inst_kn,
            s.v_inst_addr,
            s.comm_cd,
            s.comm_name,
            CASE
                WHEN
                    (LEFT(s.v_tran_cd, 1) = 2 AND (s.err_flg20 IS NULL OR s.err_flg20 != 'M'))
                THEN
                    -s.nonyu_qty
                ELSE
                    s.nonyu_qty
            END AS nonyu_qty,
            s.nonyu_price,
            CASE
                WHEN
                    (LEFT(s.v_tran_cd, 1) = 2 AND (s.err_flg20 IS NULL OR s.err_flg20 != 'M'))
                THEN
                    -s.nonyu_amt
                ELSE
                    s.nonyu_amt
            END AS nonyu_amt,
            s.shikiri_price,
            CASE
                WHEN
                    (LEFT(s.v_tran_cd, 1) = 2 AND (s.err_flg20 IS NULL OR s.err_flg20 != 'M'))
                THEN
                    -s.shikiri_amt
                ELSE
                    s.shikiri_amt
            END AS shikiri_amt,
            s.nhi_price,
            CASE
                WHEN
                    (LEFT(s.v_tran_cd,1) = 2 AND (s.err_flg20 IS NULL OR s.err_flg20 != 'M'))
                THEN
                    -s.nhi_amt
                ELSE
                    s.nhi_amt
            END AS nhi_amt,
            s.v_inst_cd,
            CASE 
                WHEN
                    (fmvt.fcl_type = 'A1' or fmvt.fcl_type = 'A0') THEN '3'
                WHEN
                    fmvt.fcl_type BETWEEN '20' AND '29' THEN '2'
                ELSE
                    '1'
            END AS inst_clas_cd,
            bpnct.bu_cd,
            ppmv.mkr_cd,
            ppmv.mkr_inf_1,
            ppmv.mkr_inf_2,
            CASE
                WHEN
                    s.v_inst_cd LIKE '00%'
                THEN
                    ci.prefc_cd
                ELSE
                    fmvt.prft_cd
            END AS pref_cd,
            s.whspos_err_kbn,
            s.htdnymd_err_kbn,
            s.prd_exis_kbn,
            s.fcl_exis_kbn,
            s.bef_hsdn_ymd,
            s.bef_slip_num,
            s.slip_org_kbn,
            s.kjyo_ym,
            s.tksnbk_kbn,
            s.fcl_exec_kbn,
            s.rec_sts_kbn,
            s.ins_dt,
            s.ins_usr,
            SYSDATE()
        FROM (
            SELECT
                ? AS extract_from_datetime
        ) AS sub
        INNER JOIN src05.sales AS s
            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
            AND ppmv.rec_sts_kbn != '9'
        LEFT OUTER JOIN internal05.fcl_mst_v_t AS fmvt
            ON s.v_inst_cd = fmvt.v_inst_cd
        LEFT OUTER JOIN internal05.bu_prd_name_contrast_t AS bpnct
            ON s.comm_cd = bpnct.prd_cd
            AND STR_TO_DATE(s.hsdn_ymd, '%Y%m%d') BETWEEN bpnct.pp_start_date AND bpnct.pp_end_date
            AND STR_TO_DATE(s.hsdn_ymd, '%Y%m%d') BETWEEN bpnct.bp_start_date AND bpnct.bp_end_date
        LEFT OUTER JOIN src05.com_inst AS ci
            ON s.v_inst_cd = ci.dcf_dsf_inst_cd
        WHERE
            (s.rec_sts_kbn = '0' AND s.err_flg20 = 'M')
            OR (
                        s.rec_sts_kbn = '0'
                    AND s.err_flg20 != 'M'
                    AND s.v_tran_cd IN (110, 120, 210, 220)
                    AND (
                                (s.fcl_exec_kbn NOT IN ('2', '5') AND (s.fcl_exec_kbn != '6' OR ppmv.prd_sale_kbn != 1))
                            OR  s.fcl_exec_kbn IS NULL
                    )
            )

        ON DUPLICATE KEY UPDATE
            rec_whs_cd = s.rec_whs_cd,
            rec_whs_sub_cd = s.rec_whs_sub_cd,
            rec_whs_org_cd = s.rec_whs_org_cd,
            rec_cust_cd = s.rec_cust_cd,
            rec_comm_cd = s.rec_comm_cd,
            rec_tran_kbn = s.rec_tran_kbn,
            rev_hsdnymd_wrk = s.rev_hsdnymd_wrk,
            rev_hsdnymd_srk = s.rev_hsdnymd_srk,
            rec_urag_num = s.rec_urag_num,
            rec_qty = s.rec_qty,
            rec_nonyu_price = s.rec_nonyu_price,
            rec_nonyu_amt = s.rec_nonyu_amt,
            rec_comm_name = s.rec_comm_name,
            rec_nonyu_fcl_name = s.rec_nonyu_fcl_name,
            free_item = s.free_item,
            rec_nonyu_fcl_addr = s.rec_nonyu_fcl_addr,
            rec_nonyu_fcl_post = s.rec_nonyu_fcl_post,
            rec_nonyu_fcl_tel = s.rec_nonyu_fcl_tel,
            rec_bef_hsdn_ymd = s.rec_bef_hsdn_ymd,
            rec_bef_slip_num = s.rec_bef_slip_num,
            rec_ymd = s.rec_ymd,
            sale_data_cat = s.sale_data_cat,
            slip_file_name = s.slip_file_name,
            row_num = s.row_num,
            hsdn_ymd = s.hsdn_ymd,
            exec_dt = s.exec_dt,
            v_tran_cd = s.v_tran_cd,
            tran_kbn_name = s.tran_kbn_name,
            whs_org_cd = s.whs_org_cd,
            v_whsorg_cd = s.v_whsorg_cd,
            whs_org_name = s.whs_org_name,
            whs_org_kn = s.whs_org_kn,
            v_whs_cd = s.v_whs_cd,
            whs_name = s.whs_name,
            nonyu_fcl_cd = s.nonyu_fcl_cd,
            inst_name = s.v_inst_name,
            inst_name_kana = s.v_inst_kn,
            address = s.v_inst_addr,
            comm_cd = s.comm_cd,
            comm_name = s.comm_name,
            nonyu_qty = VALUES(nonyu_qty),
            nonyu_price = s.nonyu_price,
            nonyu_amt = VALUES(nonyu_amt),
            shikiri_price = s.shikiri_price,
            shikiri_amt = VALUES(shikiri_amt),
            nhi_price = s.nhi_price,
            nhi_amt = VALUES(nhi_amt),
            v_inst_cd = s.v_inst_cd,
            inst_clas_cd = VALUES(inst_clas_cd),
            bu_cd = bpnct.bu_cd,
            item_cd = ppmv.mkr_cd,
            item_name = ppmv.mkr_inf_1,
            item_english_name = ppmv.mkr_inf_2,
            pref_cd = VALUES(pref_cd),
            whspos_err_kbn = s.whspos_err_kbn,
            htdnymd_err_kbn = s.htdnymd_err_kbn,
            prd_exis_kbn = s.prd_exis_kbn,
            fcl_exis_kbn = s.fcl_exis_kbn,
            bef_hsdn_ymd = s.bef_hsdn_ymd,
            bef_slip_num = s.bef_slip_num,
            slip_org_kbn = s.slip_org_kbn,
            kjyo_ym = s.kjyo_ym,
            tksnbk_kbn = s.tksnbk_kbn,
            fcl_exec_kbn = s.fcl_exec_kbn,
            rec_sts_kbn = s.rec_sts_kbn,
            ins_dt = s.ins_dt,
            ins_usr = s.ins_usr,
            dwh_upd_dt = SYSDATE()
    ";
    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;

    CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
                            '卸販売実績テーブル（洗替後）作成⑤ 終了'
    );

    CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
                            '卸販売実績テーブル（洗替後）作成⑥ 開始'
    );    

    SET @update_institution_code = "  
        UPDATE (
                SELECT 
                    ? AS extract_from_datetime
            ) AS sub,
            $$target_table$$ AS tt,
            src05.sales AS s
        SET
            tt.inst_cd = (
                CASE
                    WHEN
                        (s.err_flg20 != 'M' AND tt.inst_clas_cd IN ('2', '3')) OR (s.err_flg20 = 'M')
                    THEN
                        s.v_inst_cd
                    ELSE
                        NULL
                END
            )
        WHERE
                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;

    CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
                            '卸販売実績テーブル（洗替後）作成⑥ 終了'
    );

END