Skip to content

D
dataquality_doc
Commit bbe69d1e authored by dong.wang@52ydwf.com's avatar dong.wang@52ydwf.com
Browse files
Options

初始化3

parent 642f2cf2
Show whitespace changes
Inline Side-by-side
Showing with 191 additions and 74 deletions
HAPOC/0-DDL/1-HAODS/HAODS_EXT_CONCATINFO--合同分组基本信息.sql
View file @ bbe69d1e
...@@ -12,6 +12,8 @@ N_CYEAR varchar(64) default null comment '发单年' , ...@@ -12,6 +12,8 @@ N_CYEAR varchar(64) default null comment '发单年' ,
PROFIT_LOSS_FLAG varchar(64) default null comment '盈亏 || 亏损组 盈利组 厚利组 ' , PROFIT_LOSS_FLAG varchar(64) default null comment '盈亏 || 亏损组 盈利组 厚利组 ' ,
METHOD varchar(64) default null comment '过渡方法 || FVA MRA' , METHOD varchar(64) default null comment '过渡方法 || FVA MRA' ,
LOGTIME datetime default null comment '记录时间' LOGTIME datetime default null comment '记录时间'
-- primary key (GRP_ID) -- primary key (GRP_ID)
) )
-- comment '合同分组基本信息' charset = utf8mb3 -- comment '合同分组基本信息' charset = utf8mb3
......
HAPOC/0-DDL/3-HADWS/HADWS_CONTACT_MEAS_REL--合同组计量内外关系表.sql 0 → 100644
View file @ bbe69d1e
-- HADWS_CONTACT_MEAS_REL HADWS_合同组计量内外关系表
create table HADWS_CONTACT_MEAS_REL(
DATAPKID varchar(64) not null comment '物理主键'
,GRP_ID_INSIDE varchar(64) not null comment '合同组号-内部'
,GRP_ID varchar(64) not null comment '合同组号'
,MEA_YM int not null comment '评估月'
, N_PRDTYPE varchar(64) default null comment '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 '
, N_PROFIT_FLAG varchar(64) default null comment '营利性代码|| 1 2 3'
, N_RISKCLASS varchar(64) default null comment '风险类别|| 保障型 储蓄型'
, MDL varchar(64) default null comment '适用模型|| BBA VFA PAA '
,MEA_TIME datetime default null comment '计量时间'
,ARC_TIME datetime default null comment '归档时间'
,MEA_BAT varchar(64) default null comment '计量批次'
,ARC_BAT varchar(64) default null comment '归档批次'
-- ,primary key (DATAPKID)
)
-- comment 'HADWS_合同组计量内外关系表' charset = utf8mb3
PRIMARY KEY (DATAPKID)
DISTRIBUTED BY HASH (DATAPKID)
;
HAPOC/1-HAODS/HAODS_TEAM_LP--理赔数据_团险.sql
View file @ bbe69d1e
...@@ -10,6 +10,7 @@ SELECT ...@@ -10,6 +10,7 @@ SELECT
,CLAIM_PAY_AMNT ,CLAIM_PAY_AMNT
,ACCI_DATE ,ACCI_DATE
,CLOSE_DATE ,CLOSE_DATE
,PERSONAL_RISK_CODE
) ) AS DATAPKID -- 'DATAPKID' , ) ) AS DATAPKID -- 'DATAPKID' ,
,GRP_INS_PLC_ID -- '团单号' , ,GRP_INS_PLC_ID -- '团单号' ,
...@@ -20,6 +21,7 @@ SELECT ...@@ -20,6 +21,7 @@ SELECT
,CLAIM_PAY_AMNT -- '理赔金额' , ,CLAIM_PAY_AMNT -- '理赔金额' ,
,ACCI_DATE -- '出险日期' , ,ACCI_DATE -- '出险日期' ,
,CLOSE_DATE -- '核赔通过日期' ,CLOSE_DATE -- '核赔通过日期'
,PERSONAL_RISK_CODE -- 个人险种号
,LOCALTIMESTAMP AS LOGTIME ,LOCALTIMESTAMP AS LOGTIME
FROM IFRS17.IFRS17_HAODS_MYSQL.HAODS_TEAM_LP s1 -- 理赔数据_团险 FROM IFRS17.IFRS17_HAODS_MYSQL.HAODS_TEAM_LP s1 -- 理赔数据_团险
\ No newline at end of file
HAPOC/1-HAODS/HAODS_TEAM_PLCRICK--保单险种明细数据_团险.sql
View file @ bbe69d1e
...@@ -4,7 +4,6 @@ INSERT INTO IFRS17.IFRS17_HAODS_SRDB.HAODS_TEAM_PLCRICK ...@@ -4,7 +4,6 @@ INSERT INTO IFRS17.IFRS17_HAODS_SRDB.HAODS_TEAM_PLCRICK
SELECT SELECT
MD5(ConcatObjUDF( MD5(ConcatObjUDF(
GRP_INS_PLC_ID GRP_INS_PLC_ID
,N_PRD_CODE
,PLC_RISK_CODE ,PLC_RISK_CODE
,PERSONAL_RISK_CODE ,PERSONAL_RISK_CODE
......
HAPOC/3-HADWS/HADWS_CONCAT_MANAGE--合同组管理费用_直接部分表.sql
View file @ bbe69d1e
-- HADWS_CONCAT_MANAGE HADWS_合同组管理费用_直接部分表 -- HADWS_CONCAT_MANAGE HADWS_合同组管理费用_直接部分表
INSERT INTO IFRS17.IFRS17_HAODS_MYSQL.HADWS_CONCAT_MANAGE -- 合同组管理费用_直接部分表 INSERT INTO IFRS17.IFRS17_HADWS_SRDB.HADWS_CONCAT_MANAGE -- 合同组管理费用_直接部分表
SELECT SELECT
MD5(ConcatObjUDF(GRP_ID , MEA_YM , N_PRDTYPE , BUSY_CHAN , N_CDX )) MD5(ConcatObjUDF(GRP_ID , MEA_YM , N_PRDTYPE , BUSY_CHAN , N_CDX ))
AS DATAPKID -- 物理主键 AS DATAPKID -- 物理主键
...@@ -46,13 +46,13 @@ FROM( ...@@ -46,13 +46,13 @@ FROM(
WHEN s1.BUSY_CHAN = 'EC' THEN STAND_PREM * 0.0033 + 13.0 WHEN s1.BUSY_CHAN = 'EC' THEN STAND_PREM * 0.0033 + 13.0
ELSE 0.0 END ELSE 0.0 END
) AS ISE_INS_OUT -- 期末_实际_当期_维持费用_直接部分 ) AS ISE_INS_OUT -- 期末_实际_当期_维持费用_直接部分
-- IFRS17_HAODS_SRDB IFRS17_HADWS_SRDB IFRS17_HAODS_MYSQL
FROM IFRS17.IFRS17_HAODS_MYSQL.HADWS_PERSONAL_PLCRICK_OUT s1 -- 个险现金流输出接口表 FROM IFRS17.IFRS17_HADWS_SRDB.HADWS_PERSONAL_PLCRICK_OUT s1 -- 个险现金流输出接口表
where s1.MEA_YM = cast('${MEA_YM}' as int) where s1.MEA_YM = cast('${MEA_YM}' as int)
union all union all
SELECT -- IFRS17_HAODS_SRDB IFRS17_HADWS_SRDB IFRS17_HAODS_MYSQL SELECT
s1.GRP_ID AS GRP_ID -- '合同组号' , s1.GRP_ID AS GRP_ID -- '合同组号' ,
,s1.MEA_YM AS MEA_YM -- '评估月' ,s1.MEA_YM AS MEA_YM -- '评估月'
...@@ -82,7 +82,7 @@ FROM( ...@@ -82,7 +82,7 @@ FROM(
ELSE 0.0 END ELSE 0.0 END
) AS ISE_INS_OUT -- 期末_实际_当期_维持费用_直接部分 ) AS ISE_INS_OUT -- 期末_实际_当期_维持费用_直接部分
FROM IFRS17.IFRS17_HAODS_MYSQL.HADWS_TEAM_PLCRICK_OUT s1 -- 团险现金流输出接口表 FROM IFRS17.IFRS17_HADWS_SRDB.HADWS_TEAM_PLCRICK_OUT s1 -- 团险现金流输出接口表
where s1.MEA_YM = cast('${MEA_YM}' as int) where s1.MEA_YM = cast('${MEA_YM}' as int)
) d1 ) d1
GROUP BY GROUP BY
......
HAPOC/3-HADWS/HADWS_CONTACT_MEAS_INPUT--合同组计量输入接口表.sql
View file @ bbe69d1e
-- HADWS_CONTACT_MEAS_INPUT HADWS_合同组计量输入接口表 -- HADWS_CONTACT_MEAS_INPUT HADWS_合同组计量输入接口表
INSERT INTO IFRS17.IFRS17_HAODS_MYSQL.HADWS_CONTACT_MEAS_INPUT --团险投资成分拆分数据表 INSERT INTO IFRS17.IFRS17_HADWS_SRDB.HADWS_CONTACT_MEAS_INPUT --团险投资成分拆分数据表
SELECT SELECT
md5(ConcatObjUDF( a1.GRP_ID_INSIDE md5(ConcatObjUDF( a1.GRP_ID_INSIDE
, a1.GRP_ID , a1.GRP_ID
...@@ -134,17 +134,17 @@ FROM ...@@ -134,17 +134,17 @@ FROM
, N_PROFIT_FLAG , N_PROFIT_FLAG
, N_RISKCLASS , N_RISKCLASS
, MDL , MDL
, ( PREM_INC ) AS PREM_INC -- '期末_实际_当期_保费收入' , SUM( PREM_INC ) AS PREM_INC -- '期末_实际_当期_保费收入'
, ( CLM_OUT ) AS CLM_OUT -- '期末_实际_当期_赔付及费用' , SUM( CLM_OUT ) AS CLM_OUT -- '期末_实际_当期_赔付及费用'
, ( CLM_OUT_CSM ) AS CLM_OUT_CSM -- '期末_实际_当期_赔付及费用_投资部分'分 , SUM( CLM_OUT_CSM ) AS CLM_OUT_CSM -- '期末_实际_当期_赔付及费用_投资部分'分
, ( SB_OUT ) AS SB_OUT -- '期末_实际_当期_生存金支出' , SUM( SB_OUT ) AS SB_OUT -- '期末_实际_当期_生存金支出'
, ( SB_OUT_CSM ) AS SB_OUT_CSM -- '期末_实际_当期_生存金支出_投资部分'分 , SUM( SB_OUT_CSM ) AS SB_OUT_CSM -- '期末_实际_当期_生存金支出_投资部分'分
, ( SUR_OUT ) AS SUR_OUT -- '期末_实际_当期_退保支出' , SUM( SUR_OUT ) AS SUR_OUT -- '期末_实际_当期_退保支出'
, ( SB_OUT_LIC ) AS SB_OUT_LIC -- 期末_实际_当期_生存金待支出_LIC部分 , SUM( SB_OUT_LIC ) AS SB_OUT_LIC -- 期末_实际_当期_生存金待支出_LIC部分
, ( SB_OUT_CSM_LIC ) AS SB_OUT_CSM_LIC -- 期末_实际_当期_生存金待支出_投资部分_LIC部分 , SUM( SB_OUT_CSM_LIC ) AS SB_OUT_CSM_LIC -- 期末_实际_当期_生存金待支出_投资部分_LIC部分
, ( CLM_OUT_LIC ) AS CLM_OUT_LIC -- 期末_实际_当期_赔付及费用待支付_LIC部分 , SUM( CLM_OUT_LIC ) AS CLM_OUT_LIC -- 期末_实际_当期_赔付及费用待支付_LIC部分
, ( CLM_OUT_CSM_LIC) AS CLM_OUT_CSM_LIC -- 期末_实际_当期_赔付及费用待支付_投资部分_LIC部分 , SUM( CLM_OUT_CSM_LIC) AS CLM_OUT_CSM_LIC -- 期末_实际_当期_赔付及费用待支付_投资部分_LIC部分
, (PAA_PREM_IN ) AS PAA_PREM_IN -- '期末_PAA_保险服务收入' , SUM(PAA_PREM_IN ) AS PAA_PREM_IN -- '期末_PAA_保险服务收入'
FROM( FROM(
SELECT SELECT
...@@ -169,7 +169,7 @@ FROM ...@@ -169,7 +169,7 @@ FROM
,IF(MDL = 'PAA',QM_PREM_INC,0) AS PAA_PREM_IN -- '期末_PAA_保险服务收入' ,IF(MDL = 'PAA',QM_PREM_INC,0) AS PAA_PREM_IN -- '期末_PAA_保险服务收入'
-- IFRS17_HAODS_SRDB IFRS17_HADWS_SRDB IFRS17_HAODS_MYSQL -- IFRS17_HAODS_SRDB IFRS17_HADWS_SRDB IFRS17_HAODS_MYSQL
FROM IFRS17.IFRS17_HAODS_MYSQL.HADWS_PERSONAL_INV_SPLIT s1 --个险投资成分拆分数据表 FROM IFRS17.IFRS17_HADWS_SRDB.HADWS_PERSONAL_INV_SPLIT s1 --个险投资成分拆分数据表
where s1.MEA_YM = cast('${MEA_YM}' as int) where s1.MEA_YM = cast('${MEA_YM}' as int)
union all union all
SELECT SELECT
...@@ -192,29 +192,29 @@ FROM ...@@ -192,29 +192,29 @@ FROM
, CLM_OUT_LIC AS CLM_OUT_LIC -- 期末_实际_当期_赔付及费用待支付_LIC部分 , CLM_OUT_LIC AS CLM_OUT_LIC -- 期末_实际_当期_赔付及费用待支付_LIC部分
, CLM_OUT_CSM_LIC AS CLM_OUT_CSM_LIC -- 期末_实际_当期_赔付及费用待支付_投资部分_LIC部分 , CLM_OUT_CSM_LIC AS CLM_OUT_CSM_LIC -- 期末_实际_当期_赔付及费用待支付_投资部分_LIC部分
, IF(MDL = 'PAA',QM_PREM_INC,0) AS PAA_PREM_IN -- '期末_PAA_保险服务收入' , IF(MDL = 'PAA',QM_PREM_INC,0) AS PAA_PREM_IN -- '期末_PAA_保险服务收入'
FROM IFRS17.IFRS17_HAODS_MYSQL.HADWS_TEAM_INV_SPLIT s1 --团险投资成分拆分数据表 FROM IFRS17.IFRS17_HADWS_SRDB.HADWS_TEAM_INV_SPLIT s1 --团险投资成分拆分数据表
where s1.MEA_YM = cast('${MEA_YM}' as int) where s1.MEA_YM = cast('${MEA_YM}' as int)
) d1 ) d1
-- GROUP BY GROUP BY
-- GRP_ID_INSIDE GRP_ID_INSIDE
-- , GRP_ID , GRP_ID
-- , MEA_YM , MEA_YM
-- , N_PRDTYPE , N_PRDTYPE
-- , N_PROFIT_FLAG , N_PROFIT_FLAG
-- , N_RISKCLASS , N_RISKCLASS
-- , MDL , MDL
) a1 ) a1
LEFT JOIN ( LEFT JOIN (
SELECT SELECT
GRP_ID -- '合同组号' GRP_ID -- '合同组号'
, MEA_YM -- '评估月' , MEA_YM -- '评估月'
, (CAST(IFIE_UI_PL AS DECIMAL(18, 4)) ) AS IFIE_UI_PL -- '期末_实际_UI投资收益_PL部分' , SUM(CAST(IFIE_UI_PL AS DECIMAL(18, 4)) ) AS IFIE_UI_PL -- '期末_实际_UI投资收益_PL部分'
, (CAST(IFIE_UI_OCI AS DECIMAL(18, 4))) AS IFIE_UI_OCI -- '期末_实际_UI投资收益_OCI部分' , SUM(CAST(IFIE_UI_OCI AS DECIMAL(18, 4))) AS IFIE_UI_OCI -- '期末_实际_UI投资收益_OCI部分'
FROM IFRS17.IFRS17_HAODS_MYSQL.HADWS_EXT_QMSJTZSY s1 --期末实际投资收益合同组原子指标 FROM IFRS17.IFRS17_HADWS_SRDB.HADWS_EXT_QMSJTZSY s1 --期末实际投资收益合同组原子指标
where s1.MEA_YM = cast('${MEA_YM}' as int) where s1.MEA_YM = cast('${MEA_YM}' as int)
-- GROUP BY GROUP BY
-- GRP_ID GRP_ID
-- , MEA_YM , MEA_YM
)a2 on a1.GRP_ID= a2.GRP_ID and a1.MEA_YM = a2.MEA_YM )a2 on a1.GRP_ID= a2.GRP_ID and a1.MEA_YM = a2.MEA_YM
...@@ -222,13 +222,38 @@ LEFT JOIN ( ...@@ -222,13 +222,38 @@ LEFT JOIN (
SELECT SELECT
GRP_ID -- '合同组号' GRP_ID -- '合同组号'
, MEA_YM -- '评估月' , MEA_YM -- '评估月'
, (IACF_INS_OUT) AS IACF_INS_OUT -- 期末_实际_IACF_直接部分, , SUM(IACF_INS_OUT) AS IACF_INS_OUT -- 期末_实际_IACF_直接部分,
, (ISE_INS_OUT ) AS ISE_INS_OUT -- 期末_实际_当期_维持费用_直接部分 , SUM(ISE_INS_OUT ) AS ISE_INS_OUT -- 期末_实际_当期_维持费用_直接部分
FROM IFRS17.IFRS17_HAODS_MYSQL.HADWS_CONCAT_MANAGE -- 合同组管理费用_直接部分表 FROM IFRS17.IFRS17_HADWS_SRDB.HADWS_CONCAT_MANAGE -- 合同组管理费用_直接部分表
where MEA_YM = cast('${MEA_YM}' as int) where MEA_YM = cast('${MEA_YM}' as int)
-- GROUP BY GROUP BY
-- GRP_ID GRP_ID
-- , MEA_YM , MEA_YM
)a3 on a1.GRP_ID= a3.GRP_ID and a1.MEA_YM =a3.MEA_YM
LEFT JOIN (
SELECT
SPCODE AS GRP_ID -- '合同组号'
,STAT_MONTH AS MEA_YM -- '评估月'
, SUM(IF(indi_code = 'IACF_FEE_OUT' ),aft_cost,0) AS IACF_FEE_OUT -- （分摊）'期末_实际_IACF_分摊部分'
, SUM(IF(indi_code = 'ISE_FEE_OUT' ),aft_cost,0) AS ISE_FEE_OUT -- （分摊）'期末_实际_当期_维护费用_分摊部分'
, SUM(IF(indi_code = 'IACF_FEE_OUT' ),fz ,0) AS IACF_FEE_OUT_RELS -- （分摊）'期末_实际_IACF_分摊因子分子'
, SUM(IF(indi_code = 'IACF_FEE_OUT' ),fm ,0) AS IACF_FEE_OUT_TOT -- （分摊）'期末_实际_IACF_分摊因子分母'
, SUM(IF(indi_code = 'ISE_FEE_OUT' ),fz ,0) AS ISE_FEE_OUT_RELS -- （分摊）'期末_实际_当期_维护费用_分摊因子分子'
, SUM(IF(indi_code = 'ISE_FEE_OUT' ),aft_cost,0) AS ISE_FEE_OUT_TOT -- （分摊）'期末_实际_当期_维护费用_分摊因子分母'
, SUM(IF(indi_code = 'BONUS_ADJ_BS_EOP' ),aft_cost,0) AS BONUS_ADJ_BS_EOP -- （分摊）'期末_分红资产份额调整'(分摊)
, SUM(IF(indi_code = 'UVL_RSV_EOP' ),aft_cost,0) AS UVL_RSV_EOP -- （分摊）'期末_万能平滑准备金'(分摊)
, SUM(IF(indi_code = 'AS_IF_VAL' ),aft_cost,0) AS AS_IF_VAL -- （分摊）'资产份额分摊因子'(分摊)
, SUM(IF(indi_code = 'AV_IF_VAL' ),aft_cost,0) AS AV_IF_VAL -- （分摊）'账户价值分摊因子'(分摊)
, SUM(IF(indi_code = 'AS_IF_VAL_TOT' ),aft_cost,0) AS AS_IF_VAL_TOT -- （分摊）'资产份额分摊因子合计'(分摊)
, SUM(IF(indi_code = 'AV_IF_VAL_TOT' ),aft_cost,0) AS AV_IF_VAL_TOT -- （分摊）'账户价值分摊因子合计'(分摊)
FROM IFRS17.IFRS17_HADWS_SRDB.T_CS_RESULT -- 分摊计量结果表
where STAT_MONTH = cast('${MEA_YM}' as int)
GROUP BY
GRP_ID
, MEA_YM
)a3 on a1.GRP_ID= a3.GRP_ID and a1.MEA_YM =a3.MEA_YM )a3 on a1.GRP_ID= a3.GRP_ID and a1.MEA_YM =a3.MEA_YM
......
HAPOC/3-HADWS/HADWS_CONTACT_MEAS_REL--合同组计量内外关系表.sql 0 → 100644
View file @ bbe69d1e
-- HADWS_CONTACT_MEAS_REL HADWS_合同组计量内外关系表
INSERT INTO IFRS17.IFRS17_HADWS_SRDB.HADWS_CONTACT_MEAS_REL --HADWS_合同组计量关系表
SELECT
DATAPKID -- 物理主键
, a1.GRP_ID_INSIDE -- '合同组号-内部'
, a1.GRP_ID -- '合同组号'
, a1.MEA_YM -- '评估月'
, a1.N_PRDTYPE -- '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 '
, a1.N_PROFIT_FLAG -- '营利性代码|| 1 2 3'
, a1.N_RISKCLASS -- '风险类别|| 保障型 储蓄型'
, a1.MDL -- '适用模型|| BBA VFA PAA '
,LOCALTIMESTAMP AS MEA_TIME -- '计量时间'
,LOCALTIMESTAMP AS ARC_TIME -- '归档时间'
,'' AS MEA_BAT -- '计量批次'
,'' AS ARC_BAT -- '归档批次'
FROM IFRS17.IFRS17_HADWS_SRDB.HADWS_CONTACT_MEAS_INPUT --团险投资成分拆分数据表
where s1.MEA_YM = cast('${MEA_YM}' as int)
HAPOC/3-HADWS/HADWS_PERSONAL_INV_SPLIT--个险投资成分拆分数据表.sql
View file @ bbe69d1e
-- HADWS_PERSONAL_INV_SPLIT 个险投资成分拆分数据表 -- HADWS_PERSONAL_INV_SPLIT 个险投资成分拆分数据表
INSERT INTO IFRS17.IFRS17_HAODS_MYSQL.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,GRP_ID_INSIDE N_RISKCLASS
,N_PRDTYPE
,MDL
,N_PROFIT_FLAG
,GRP_ID
,N_GRP__ID
,GRP_ID_INSIDE
)) ))
AS DATAPKID -- 物理主键 AS DATAPKID -- 物理主键
, MEA_YM AS MEA_YM -- '评估月' , MEA_YM AS MEA_YM -- '评估月'
...@@ -40,19 +46,19 @@ FROM ( ...@@ -40,19 +46,19 @@ FROM (
,d1.GRP_ID AS GRP_ID -- '合同组号' , ,d1.GRP_ID AS GRP_ID -- '合同组号' ,
,d1.N_GRP__ID AS N_GRP__ID -- '合同组合号' , ,d1.N_GRP__ID AS N_GRP__ID -- '合同组合号' ,
,d1.GRP_ID_INSIDE AS GRP_ID_INSIDE -- '合同组号-内部' , ,d1.GRP_ID_INSIDE AS GRP_ID_INSIDE -- '合同组号-内部' ,
,(d1.PLC_AMNT-(d1.LP_INV_VAL1+ d1.LP_INV_VAL2)) AS CLM_OUT_CSM -- 期初_实际_当期_赔付及费用_投资部分 ,SUM(d1.PLC_AMNT-(d1.LP_INV_VAL1+ d1.LP_INV_VAL2)) AS CLM_OUT_CSM -- 期初_实际_当期_赔付及费用_投资部分
,((d1.LP_INV_VAL1+ d1.LP_INV_VAL2)) AS CLM_OUT -- 期初_实际_当期_赔付及费用 ,SUM((d1.LP_INV_VAL1+ d1.LP_INV_VAL2)) AS CLM_OUT -- 期初_实际_当期_赔付及费用
,(d1.PLC_AMNT ) AS PREM_INC -- 期初_预期_当期_保费收入 ,SUM(d1.PLC_AMNT ) AS PREM_INC -- 期初_预期_当期_保费收入
,(QM_PREM_INC ) AS QM_PREM_INC -- 期末_实际_当期_保费收入 ,SUM(QM_PREM_INC ) AS QM_PREM_INC -- 期末_实际_当期_保费收入
,(QM_CLM_OUT ) AS QM_CLM_OUT -- 期末_实际_当期_赔付及费用 ,SUM(QM_CLM_OUT ) AS QM_CLM_OUT -- 期末_实际_当期_赔付及费用
,(QMCLM_OUT_CSM ) AS QMCLM_OUT_CSM -- 期末_实际_当期_赔付及费用_投资部分 ,SUM(QMCLM_OUT_CSM ) AS QMCLM_OUT_CSM -- 期末_实际_当期_赔付及费用_投资部分
,(SB_OUT ) AS SB_OUT -- 期末_实际_当期_生存金支出 ,SUM(SB_OUT ) AS SB_OUT -- 期末_实际_当期_生存金支出
,(SB_OUT_CSM ) AS SB_OUT_CSM -- 期末_实际_当期_生存金支出_投资部分 ,SUM(SB_OUT_CSM ) AS SB_OUT_CSM -- 期末_实际_当期_生存金支出_投资部分
,(SUR_OUT ) AS SUR_OUT -- 期末_实际_当期_退保支出 ,SUM(SUR_OUT ) AS SUR_OUT -- 期末_实际_当期_退保支出
,(SB_OUT_LIC ) AS SB_OUT_LIC -- 期末_实际_当期_生存金待支出_LIC部分 ,SUM(SB_OUT_LIC ) AS SB_OUT_LIC -- 期末_实际_当期_生存金待支出_LIC部分
,(SB_OUT_CSM_LIC ) AS SB_OUT_CSM_LIC -- 期末_实际_当期_生存金待支出_投资部分_LIC部分 ,SUM(SB_OUT_CSM_LIC ) AS SB_OUT_CSM_LIC -- 期末_实际_当期_生存金待支出_投资部分_LIC部分
,(CLM_OUT_LIC ) AS CLM_OUT_LIC -- 期末_实际_当期_赔付及费用待支付_LIC部分 ,SUM(CLM_OUT_LIC ) AS CLM_OUT_LIC -- 期末_实际_当期_赔付及费用待支付_LIC部分
,(CLM_OUT_CSM_LIC ) AS CLM_OUT_CSM_LIC -- 期末_实际_当期_赔付及费用待支付_投资部分_LIC部分 ,SUM(CLM_OUT_CSM_LIC ) AS CLM_OUT_CSM_LIC -- 期末_实际_当期_赔付及费用待支付_投资部分_LIC部分
FROM ( FROM (
SELECT SELECT
MEA_YM AS MEA_YM -- '评估月' MEA_YM AS MEA_YM -- '评估月'
...@@ -123,15 +129,15 @@ FROM ( ...@@ -123,15 +129,15 @@ FROM (
-- IFRS17_HAODS_SRDB IFRS17_HADWS_SRDB IFRS17_HAODS_MYSQL -- IFRS17_HAODS_SRDB IFRS17_HADWS_SRDB IFRS17_HAODS_MYSQL
FROM IFRS17.IFRS17_HAODS_MYSQL.HAODS_PERSONAL_PAY s1 -- 现金流_个人业务 FROM IFRS17.IFRS17_HAODS_SRDB.HAODS_PERSONAL_PAY s1 -- 现金流_个人业务
LEFT JOIN IFRS17.IFRS17_HAODS_MYSQL.HADWS_PERSONAL_PLCRICK_OUT s2 -- 个险现金流输出接口表 LEFT JOIN IFRS17.IFRS17_HADWS_SRDB.HADWS_PERSONAL_PLCRICK_OUT s2 -- 个险现金流输出接口表
ON s1.PLC_ID = s2.PLC_ID and s2.MEA_YM = cast('${MEA_YM}' as int) ON s1.PLC_ID = s2.PLC_ID and s2.MEA_YM = cast('${MEA_YM}' as int)
LEFT JOIN ( LEFT JOIN (
SELECT SELECT
PLC_OD PLC_OD
,CLAIM_NO ,CLAIM_NO
,(cast(ACCI_DAY_CV as decimal)) as ACCI_DAY_CV ,(cast(ACCI_DAY_CV as decimal)) as ACCI_DAY_CV
FROM IFRS17.IFRS17_HAODS_MYSQL.HAODS_PERSONAL_LP FROM IFRS17.IFRS17_HAODS_SRDB.HAODS_PERSONAL_LP
-- group by -- group by
-- PLC_OD -- PLC_OD
-- ,CLAIM_NO -- ,CLAIM_NO
...@@ -142,15 +148,15 @@ FROM ( ...@@ -142,15 +148,15 @@ FROM (
) a1 ) a1
) d1 ) d1
-- GROUP BY GROUP BY
-- d1.MEA_YM d1.MEA_YM
-- ,d1.N_RISKCLASS ,d1.N_RISKCLASS
-- ,d1.N_PRDTYPE ,d1.N_PRDTYPE
-- ,d1.MDL ,d1.MDL
-- ,d1.N_PROFIT_FLAG ,d1.N_PROFIT_FLAG
-- ,d1.GRP_ID ,d1.GRP_ID
-- ,d1.N_GRP__ID ,d1.N_GRP__ID
-- ,d1.GRP_ID_INSIDE ,d1.GRP_ID_INSIDE
)f1 )f1
\ No newline at end of file
HAPOC/3-HADWS/HADWS_PERSONAL_PLCRICK_OUT--个险现金流输出接口表.sql
View file @ bbe69d1e
...@@ -71,4 +71,21 @@ s4.GRP_ID is not null ...@@ -71,4 +71,21 @@ s4.GRP_ID is not null
and s1.MEA_YM = cast('${MEA_YM}' as int) and s1.MEA_YM = cast('${MEA_YM}' as int)
GRP_ID -- '合同组号' ,
,N_GRP__ID -- '合同组合号' ,
,N_CYEAR_D -- '发单年度' ,
,N_PROFIT_FLAG -- '营利性代码 || 1 2 3' ,
,MDL -- '计量模型 || BBA VFA PAA' ,
,N_PRDTYPE -- '产品大类 || 传统险 分红险 万能险 投连险 累积式分红' ,
,N_RISKCLASS -- '风险类别 || 保障型 储蓄型' ,
,N_CHNL -- '渠道 || ' ,
,N_CYEAR -- '发单年' ,
,PROFIT_LOSS_FLAG -- '盈亏' ,
, a1.GRP_ID_INSIDE -- '合同组号-内部'
, a1.GRP_ID -- '合同组号'
, a1.MEA_YM -- '评估月'
, a1.N_PRDTYPE -- '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 '
, a1.N_PROFIT_FLAG -- '营利性代码|| 1 2 3'
, a1.N_RISKCLASS -- '风险类别|| 保障型 储蓄型'
, a1.MDL -- '适用模型|| BBA VFA PAA '
\ No newline at end of file
HAPOC/3-HADWS/HADWS_TEAM_INV_SPLIT--团险投资成分拆分数据表.sql
View file @ bbe69d1e
...@@ -2,9 +2,15 @@ ...@@ -2,9 +2,15 @@
INSERT INTO IFRS17.IFRS17_HADWS_SRDB.HADWS_TEAM_INV_SPLIT --团险投资成分拆分数据表 INSERT INTO IFRS17.IFRS17_HADWS_SRDB.HADWS_TEAM_INV_SPLIT --团险投资成分拆分数据表
SELECT SELECT
MD5(ConcatObjUDF( MD5(ConcatObjUDF(
MEA_YM ,N_RISKCLASS,N_PRDTYPE,MDL,N_PROFIT_FLAG,GRP_ID,N_GRP__ID,GRP_ID_INSIDE MEA_YM
)) ,N_RISKCLASS
AS DATAPKID -- 物理主键 ,N_PRDTYPE
,MDL
,N_PROFIT_FLAG
,GRP_ID
,N_GRP__ID
,GRP_ID_INSIDE
)) AS DATAPKID -- 物理主键
, MEA_YM AS MEA_YM -- '评估月' , MEA_YM AS 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 -- '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' ,
...@@ -32,7 +38,7 @@ MD5(ConcatObjUDF( ...@@ -32,7 +38,7 @@ MD5(ConcatObjUDF(
, '' AS ARC_BAT -- '归档批次' , '' AS ARC_BAT -- '归档批次'
FROM ( FROM (
SELECT SELECT
,d1.MEA_YM AS MEA_YM --'评估月' d1.MEA_YM 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 '
...@@ -123,7 +129,11 @@ FROM ( ...@@ -123,7 +129,11 @@ FROM (
,s3.CLAIM_REVIEW_CODE AS CLAIM_REVIEW_CODE -- '给付责任类型 || 理赔 理赔（豁免） 生存金' , ,s3.CLAIM_REVIEW_CODE AS CLAIM_REVIEW_CODE -- '给付责任类型 || 理赔 理赔（豁免） 生存金' ,
FROM IFRS17.IFRS17_HAODS_SRDB.HAODS_TEAM_PAY s1 --现金流_团险 FROM IFRS17.IFRS17_HAODS_SRDB.HAODS_TEAM_PAY s1 --现金流_团险
LEFT JOIN IFRS17.IFRS17_HADWS_SRDB.HADWS_TEAM_PLCRICK_OUT s2-- 团险现金流输出接口表 LEFT JOIN IFRS17.IFRS17_HADWS_SRDB.HADWS_TEAM_PLCRICK_OUT s2-- 团险现金流输出接口表
ON s1.GRP_INS_PLC_ID = s2.GRP_INS_PLC_ID AND s1.RISK_CODE = s2.PLC_RISK_CODE ON s1.GRP_INS_PLC_ID = s2.GRP_INS_PLC_ID
AND s1.RISK_CODE = s2.PLC_RISK_CODE
and s2.MEA_YM = cast('${MEA_YM}' as int)
and s1.PERSONAL_RISK_CODE = s2.PERSONAL_RISK_CODE
LEFT JOIN ( LEFT JOIN (
SELECT SELECT
GRP_INS_PLC_ID GRP_INS_PLC_ID
...@@ -131,10 +141,13 @@ FROM ( ...@@ -131,10 +141,13 @@ FROM (
, first_value(CLAIM_REVIEW_CODE) as CLAIM_REVIEW_CODE -- '给付责任类型 || 理赔 理赔（豁免） 生存金' , , first_value(CLAIM_REVIEW_CODE) as CLAIM_REVIEW_CODE -- '给付责任类型 || 理赔 理赔（豁免） 生存金' ,
, SUM(cast(ACCI_DAY_CV as decimal)) as ACCI_DAY_CV -- '保单现价' , , SUM(cast(ACCI_DAY_CV as decimal)) as ACCI_DAY_CV -- '保单现价' ,
FROM IFRS17.IFRS17_HAODS_SRDB.HAODS_TEAM_LP FROM IFRS17.IFRS17_HAODS_SRDB.HAODS_TEAM_LP
GROUP BY
GRP_INS_PLC_ID
, CLAIM_NO
) s3 --理赔数据_团险 ) s3 --理赔数据_团险
ON s1.GRP_INS_PLC_ID = s3.GRP_INS_PLC_ID and s1.BUSI_NO = s3.CLAIM_NO ON s1.GRP_INS_PLC_ID = s3.GRP_INS_PLC_ID and s1.BUSI_NO = s3.CLAIM_NO
where s2.GRP_INS_PLC_ID is not null where s2.GRP_INS_PLC_ID is not null
and s2.MEA_YM = cast('${MEA_YM}' as int)
) a1 ) a1
) d1 ) d1
......
HAPOC/3-HADWS/HADWS_TEAM_PLCRICK_IN--团险现金流输入接口表.sql
View file @ bbe69d1e
-- HADWS_TEAM_PLCRICK_IN HADWS_团险现金流输入接口表 -- HADWS_TEAM_PLCRICK_IN HADWS_团险现金流输入接口表
INSERT INTO IFRS17.IFRS17_HADWS_SRDB.HADWS_TEAM_PLCRICK_IN --团险现金流输入接口表 INSERT INTO IFRS17.IFRS17_HADWS_SRDB.HADWS_TEAM_PLCRICK_IN --团险现金流输入接口表
SELECT SELECT
MD5(ConcatObjUDF('${MEA_YM}',s1.GRP_INS_PLC_ID,s1.PLC_RISK_CODE,STAND_PREM,N_SIX,N_AGE,YEAR_COVER)) MD5(ConcatObjUDF('${MEA_YM}',s1.DATAPKID))
AS DATAPKID -- 物理主键 AS DATAPKID -- 物理主键
,cast( '${MEA_YM}' as int) AS MEA_YM --'评估月' ,cast( '${MEA_YM}' as int) AS MEA_YM --'评估月'
, s1.GRP_INS_PLC_ID AS GRP_INS_PLC_ID -- '保单号' , , s1.GRP_INS_PLC_ID AS GRP_INS_PLC_ID -- '保单号' ,
...@@ -31,6 +31,7 @@ MD5(ConcatObjUDF('${MEA_YM}',s1.GRP_INS_PLC_ID,s1.PLC_RISK_CODE,STAND_PREM,N_SIX ...@@ -31,6 +31,7 @@ MD5(ConcatObjUDF('${MEA_YM}',s1.GRP_INS_PLC_ID,s1.PLC_RISK_CODE,STAND_PREM,N_SIX
,LOCALTIMESTAMP AS ARC_TIME -- '归档时间' ,LOCALTIMESTAMP AS ARC_TIME -- '归档时间'
,'' AS MEA_BAT -- '计量批次' ,'' AS MEA_BAT -- '计量批次'
,'' AS ARC_BAT -- '归档批次' ,'' AS ARC_BAT -- '归档批次'
-- IFRS17_HAODS_SRDB IFRS17_HADWS_SRDB IFRS17_HAODS_MYSQL
FROM IFRS17.IFRS17_HAODS_SRDB.HAODS_TEAM_PLCRICK s1 --保单险种明细数据_团险 FROM IFRS17.IFRS17_HAODS_SRDB.HAODS_TEAM_PLCRICK s1 --保单险种明细数据_团险
LEFT JOIN IFRS17.IFRS17_HAODS_SRDB.HADIM_PRDINFO s2 -- 产品基本信息 LEFT JOIN IFRS17.IFRS17_HAODS_SRDB.HADIM_PRDINFO s2 -- 产品基本信息
......
HAPOC/3-HADWS/HADWS_TEAM_PLCRICK_OUT--团险现金流输出接口表.sql
View file @ bbe69d1e
...@@ -40,6 +40,8 @@ DATAPKID AS DATAPKID ...@@ -40,6 +40,8 @@ DATAPKID AS DATAPKID
,'' AS MEA_BAT -- '计量批次' ,'' AS MEA_BAT -- '计量批次'
,'' AS ARC_BAT -- '归档批次' ,'' AS ARC_BAT -- '归档批次'
-- IFRS17_HAODS_SRDB IFRS17_HADWS_SRDB IFRS17_HAODS_MYSQL
FROM IFRS17.IFRS17_HADWS_SRDB.HADWS_TEAM_PLCRICK_IN s1 -- 团险现金流输入接口表 FROM IFRS17.IFRS17_HADWS_SRDB.HADWS_TEAM_PLCRICK_IN s1 -- 团险现金流输入接口表
-- LEFT JOIN IFRS17.HASOURCE_SRDB.HADIM_LRISKPROF s2 -- 长险营利性配置信息 -- LEFT JOIN IFRS17.HASOURCE_SRDB.HADIM_LRISKPROF s2 -- 长险营利性配置信息
-- ON s1.N_CDX ='长险' and s1.N_PRD_CODE = s2.PRDCODE and s1.BUSY_CHAN = s2.CHNL and s1.N_CYEAR_D_PROFIT = s2.CYEAR -- ON s1.N_CDX ='长险' and s1.N_PRD_CODE = s2.PRDCODE and s1.BUSY_CHAN = s2.CHNL and s1.N_CYEAR_D_PROFIT = s2.CYEAR
......
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

版权所有@2016-2024 北京云端微服科技有限公司