Commit becf958e authored by 王东's avatar 王东

DWD部分加工规则-替换数据源

parent 6a3dfc3b
-- HADWS_PERSONAL_INV_SPLIT 个险投资成分拆分数据表 -- HADWS_PERSONAL_INV_SPLIT 个险投资成分拆分数据表
INSERT INTO IFRS17.IFRS17_HADWS_SRDB.HADWS_PERSONAL_INV_SPLIT --个险投资成分拆分数据表 INSERT INTO IFRS17.IFRS17_HADWS_SRDB.HADWS_PERSONAL_INV_SPLIT -- 个险投资成分拆分数据表
SELECT SELECT
MD5(ConcatObjUDF( MD5(ConcatObjUDF(
MEA_YM ,N_RISKCLASS,N_PRDTYPE,MDL,N_PROFIT_FLAG,GRP_ID,N_GRP__ID MEA_YM ,N_RISKCLASS,N_PRDTYPE,MDL,N_PROFIT_FLAG,GRP_ID,N_GRP__ID
)) ))
AS DATAPKID -- 物理主键 AS DATAPKID -- 物理主键
, MEA_YM --'评估月' , MEA_YM -- '评估月'
, COALESCE (N_RISKCLASS ,'') AS N_RISKCLASS -- '风险类别|| 保障型 储蓄型' , , COALESCE (N_RISKCLASS ,'') AS N_RISKCLASS -- '风险类别|| 保障型 储蓄型' ,
, COALESCE (N_PRDTYPE ,'') AS N_PRDTYPE -- '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' , , COALESCE (N_PRDTYPE ,'') AS N_PRDTYPE -- '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' ,
, COALESCE (MDL ,'') AS MDL -- '适用模型|| BBA VFA PAA ' , COALESCE (MDL ,'') AS MDL -- '适用模型|| BBA VFA PAA '
...@@ -31,7 +31,7 @@ MD5(ConcatObjUDF( ...@@ -31,7 +31,7 @@ MD5(ConcatObjUDF(
, '' AS ARC_BAT -- '归档批次' , '' AS ARC_BAT -- '归档批次'
FROM ( FROM (
SELECT SELECT
cast( d1.MEA_YM as int) AS MEA_YM --'评估月' cast( d1.MEA_YM as int) AS MEA_YM -- '评估月'
,d1.N_RISKCLASS AS N_RISKCLASS -- '风险类别|| 保障型 储蓄型' , ,d1.N_RISKCLASS AS N_RISKCLASS -- '风险类别|| 保障型 储蓄型' ,
,d1.N_PRDTYPE AS N_PRDTYPE -- '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' , ,d1.N_PRDTYPE AS N_PRDTYPE -- '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' ,
,d1.MDL AS MDL -- '适用模型|| BBA VFA PAA ' ,d1.MDL AS MDL -- '适用模型|| BBA VFA PAA '
...@@ -53,7 +53,7 @@ FROM ( ...@@ -53,7 +53,7 @@ FROM (
,(CLM_OUT_CSM_LIC ) AS CLM_OUT_CSM_LIC -- 期末_实际_当期_赔付及费用待支付_投资部分_LIC部分 ,(CLM_OUT_CSM_LIC ) AS CLM_OUT_CSM_LIC -- 期末_实际_当期_赔付及费用待支付_投资部分_LIC部分
FROM ( FROM (
SELECT SELECT
MEA_YM AS MEA_YM --'评估月' MEA_YM AS MEA_YM -- '评估月'
, N_RISKCLASS AS N_RISKCLASS -- '风险类别|| 保障型 储蓄型' , , N_RISKCLASS AS N_RISKCLASS -- '风险类别|| 保障型 储蓄型' ,
, N_PRDTYPE AS N_PRDTYPE -- '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' , , N_PRDTYPE AS N_PRDTYPE -- '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' ,
, MDL AS MDL -- '适用模型|| BBA VFA PAA ' , MDL AS MDL -- '适用模型|| BBA VFA PAA '
...@@ -92,7 +92,7 @@ FROM ( ...@@ -92,7 +92,7 @@ FROM (
as decimal(18,4)) AS CLM_OUT_CSM_LIC -- 期末_实际_当期_赔付及费用待支付_投资部分_LIC部分 as decimal(18,4)) AS CLM_OUT_CSM_LIC -- 期末_实际_当期_赔付及费用待支付_投资部分_LIC部分
FROM ( FROM (
SELECT SELECT
'${MEA_YM}' AS MEA_YM --'评估月' '${MEA_YM}' AS MEA_YM -- '评估月'
,s1.ID AS ID -- 'ID' , ,s1.ID AS ID -- 'ID' ,
,s1.GRP_INS_PLC_ID AS GRP_INS_PLC_ID -- '团单号' , ,s1.GRP_INS_PLC_ID AS GRP_INS_PLC_ID -- '团单号' ,
,s1.PLC_ID AS PLC_ID -- '保单号' , ,s1.PLC_ID AS PLC_ID -- '保单号' ,
...@@ -116,10 +116,10 @@ FROM ( ...@@ -116,10 +116,10 @@ FROM (
,s2.N_GRP__ID AS N_GRP__ID -- '合同组合号' , ,s2.N_GRP__ID AS N_GRP__ID -- '合同组合号' ,
,s2.N_CDX AS N_CDX -- '长短险标识 || 长险 短险 极短险' , ,s2.N_CDX AS N_CDX -- '长短险标识 || 长险 短险 极短险' ,
,cast(s3.ACCI_DAY_CV as decimal) AS ACCI_DAY_CV -- '保单现价' , ,cast(s3.ACCI_DAY_CV as decimal) AS ACCI_DAY_CV -- '保单现价' ,
FROM IFRS17.IFRS17_HAODS_SRDB.HAODS_PERSONAL_PAY s1 --现金流_个人业务 FROM IFRS17.IFRS17_HAODS_SRDB.HAODS_PERSONAL_PAY s1 -- 现金流_个人业务
LEFT JOIN IFRS17.IFRS17_HADWS_SRDB.HADWS_PERSONAL_PLCRICK_OUT s2 -- 个险现金流输出接口表 LEFT JOIN IFRS17.IFRS17_HADWS_SRDB.HADWS_PERSONAL_PLCRICK_OUT s2 -- 个险现金流输出接口表
ON s1.PLC_ID = s2.PLC_ID ON s1.PLC_ID = s2.PLC_ID
LEFT JOIN IFRS17.IFRS17_HAODS_SRDB.HAODS_PERSONAL_LP s3 --理赔数据_个人业务 LEFT JOIN IFRS17.IFRS17_HAODS_SRDB.HAODS_PERSONAL_LP s3 -- 理赔数据_个人业务
ON s1.PLC_ID = s3.PLC_OD and s1.BUSI_NO = s3.CLAIM_NO ON s1.PLC_ID = s3.PLC_OD and s1.BUSI_NO = s3.CLAIM_NO
where s2.PLC_ID is not null where s2.PLC_ID is not null
and s2.MEA_YM = cast('${MEA_YM}' as int) and s2.MEA_YM = cast('${MEA_YM}' as int)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment