Skip to content

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

初始化4

parent a5a204c9
Expand all Show whitespace changes
Inline Side-by-side
Showing with 708 additions and 713 deletions
HAPOC/0-DDL/0-HASOURCE/HASOURCE_EXT_CONCATINFO--合同分组基本信息.sql 0 → 100644
View file @ bd9e5dfa
create table db_ifrs17hengan.hasource_ext_concatinfo
(
GRP_ID varchar(64) not null comment '合同组号',
N_GRP__ID varchar(64) null comment '合同组合号',
N_CYEAR_D varchar(64) null comment '发单年度',
N_PROFIT_FLAG varchar(64) null comment '营利性代码 || 1 2 3',
MDL varchar(64) null comment '计量模型 || BBA VFA PAA',
N_PRDTYPE varchar(64) null comment '产品大类 || 传统险 分红险 万能险 投连险 累积式分红',
N_RISKCLASS varchar(64) null comment '风险类别 || 保障型 储蓄型',
N_CHNL varchar(64) null comment '渠道 || 个险 银保 多元 团险 健康险事业部 寿险事业部 ',
N_CYEAR varchar(64) null comment '发单年',
PROFIT_LOSS_FLAG varchar(64) null comment '盈亏 || 亏损组 盈利组 厚利组 ',
METHOD varchar(64) null comment '过渡方法 || FVA MRA'
);
HAPOC/0-DDL/0-HASOURCE/HASOURCE_EXT_CS--待分摊费用获取费用&维护费用-Y9.sql 0 → 100644
View file @ bd9e5dfa
create table db_ifrs17hengan.hasource_ext_cs
(
N_CHNL varchar(64) not null comment '渠道|| 多元 个险 银保 团险 互联网',
N_CDX varchar(64) not null comment '长短险|| 长险 短险',
CS_ITEM varchar(64) not null comment '待分摊项|| 获取费用 维持费用',
CS_AMONT decimal(18, 4) null comment '待分摊项金额'
);
HAPOC/0-DDL/0-HASOURCE/HASOURCE_EXT_INCURRED-法定准备金数据.sql 0 → 100644
View file @ bd9e5dfa
create table db_ifrs17hengan.hasource_ext_incurred
(
N_CYEAR varchar(64) not null comment '发单年',
N_CHNL varchar(64) not null comment '渠道 || BK FC AD GP EC EL ',
N_PRDCODE varchar(64) not null comment '产品代码',
N_INCURRED varchar(64) null comment '法定准备金'
);
HAPOC/0-DDL/0-HASOURCE/HASOURCE_EXT_JSXJLSJ--精算现金流数据合同组原子指标-dws.sql 0 → 100644
View file @ bd9e5dfa
create table db_ifrs17hengan.hasource_ext_jsxjlsj
(
GRP_ID varchar(64) not null comment '合同组号' ,
N_PRDTYPE varchar(64) null comment '产品大类|| I__PAR 个人养老保险,I__PUL 万能险,I__UL_ 万能险,I__TRA 传统险,I__UVL 万能险',
CSM_CARR_RELS decimal(18, 4) null comment 'CSM_当期_释放比例分子',
CSM_CARR_TOT decimal(18, 4) null comment 'CSM_当期_释放比例分母',
CSM_IF decimal(18, 4) null comment 'CSM_期初',
EXPC_CF_OUT_CSM decimal(18, 4) null comment '期初_预期_当期_影响CSM的现金流（流出-流入)',
EXPC_CLM_OUT_CSM decimal(18, 4) null comment '期初_预期_当期_赔付及费用_投资部分',
EXPC_CLM_OUT_PL decimal(18, 4) null comment '期初_预期_当期_赔付及费用_保险部分',
EXPC_CLM_OUT_PUI_PL decimal(18, 4) null comment '期初_预期_当期_赔付及费用_保险部分_PUI部分',
EXPC_IACF_COMM decimal(18, 4) null comment '期初_预期_IACF_获取佣金',
EXPC_IACF_EXP decimal(18, 4) null comment '期初_预期_IACF_获取费用',
EXPC_IFIE_GPV_CSM decimal(18, 4) null comment '期初_当期利率_预期_GPV利息',
EXPC_IFIE_GPV_PL decimal(18, 4) null comment '期初_锁定利率_预期_GPV利息',
EXPC_IFIE_NU_I decimal(18, 4) null comment '期初_当前利率_预期_GPV利息_NU部分',
EXPC_IFIE_PUI_I decimal(18, 4) null comment '期初_当前利率_预期_GPV利息_PUI部分',
EXPC_IFIE_RA_CSM decimal(18, 4) null comment '期初_当前利率_预期_RA利息',
EXPC_IFIE_RA_PL decimal(18, 4) null comment '期初_锁定利率_预期_RA利息',
EXPC_IFIE_TVOG_CSM decimal(18, 4) null comment '期初_当前利率_预期_TVOG利息',
EXPC_ISE_COMM_OUT decimal(18, 4) null comment '期初_预期_当期_维持佣金',
EXPC_ISE_COMM_PUI_PL decimal(18, 4) null comment '期初_预期_当期_维持佣金_PUI部分',
EXPC_ISE_EXP_OUT decimal(18, 4) null comment '期初_预期_当期_维护费用',
EXPC_ISE_EXP_PUI_PL decimal(18, 4) null comment '期初_预期_当期_维护费用_PUI部分',
EXPC_PREM_INC decimal(18, 4) null comment '期初_预期_当期_保费收入',
EXPC_RA_RELS_B decimal(18, 4) null comment '期初_预期_当期_期初RA释放',
EXPC_RA_RELS_E decimal(18, 4) null comment '期初_预期_当期_期末RA释放',
EXPC_SB_OUT_CSM decimal(18, 4) null comment '期初_预期_当期_生存金支出_投资部分',
EXPC_SB_OUT_PL decimal(18, 4) null comment '期初_预期_当期_生存金支出_保险部分',
EXPC_SUR_OUT decimal(18, 4) null comment '期初_预期_当期_退保支出',
EXPC_TVOG_RELS_B decimal(18, 4) null comment '期初_预期_当期_TVOG释放',
GPV_ACTL_ACFA_FH decimal(18, 4) null comment '期末_金融假设变更后_当期_现金流现值',
GPV_ACTL_AFA decimal(18, 4) null comment '期末_金融假设变更后_未来_现金流现值',
GPV_ACTL_ANFA decimal(18, 4) null comment '期末_非金融假设变更后_未来_现金流现值',
GPV_ACTL_ANOP decimal(18, 4) null comment '期末_有效人数调整_未来_现金流现值',
GPV_ACTL_BS_BOP decimal(18, 4) null comment '期初_当期利率_未来_现金流现值',
GPV_ACTL_BS_EOP decimal(18, 4) null comment '期末_当前利率_未来_现金流现值',
GPV_ACTL_PL_BOP decimal(18, 4) null comment '期初_锁定利率_未来_现金流现值',
GPV_ACTL_PL_EOP decimal(18, 4) null comment '期末_锁定利率_未来_现金流现值',
GPV_EXPC decimal(18, 4) null comment '期末_预期_未来_现金流现值',
IACF_CARR_RELS decimal(18, 4) null comment 'IACF_当期分摊比例分子',
IACF_CARR_TOT decimal(18, 4) null comment 'IACF_当期分摊比例分母',
IACF_IF decimal(18, 4) null comment 'IACF_期初',
INIT_GPV_NB decimal(18, 4) null comment '新合同_现金流现值',
INIT_RA_NB decimal(18, 4) null comment '新合同_RA',
INIT_TVOG_NB decimal(18, 4) null comment '新合同_TVOG',
LC_CARR_AMORT decimal(18, 4) null comment 'LC_当期摊回比例分子',
LC_CARR_TOT decimal(18, 4) null comment 'LC_当期摊回比例分母',
LC_IF decimal(18, 4) null comment 'LC_期初',
RA_ACTL_ACFA_FH decimal(18, 4) null comment '期末_金融假设变更后_当期_RA',
RA_ACTL_AFA decimal(18, 4) null comment '期末_金融假设变更后_未来_RA',
RA_ACTL_ANFA decimal(18, 4) null comment '期末_非金融假设变更后_未来_RA',
RA_ACTL_ANOP decimal(18, 4) null comment '期末_有效人数调整_未来_RA',
RA_ACTL_BS_BOP decimal(18, 4) null comment '期初_当期利率_未来_RA',
RA_ACTL_BS_EOP decimal(18, 4) null comment '期末_当前利率_未来_RA',
RA_ACTL_PL_BOP decimal(18, 4) null comment '期初_锁定利率_未来_RA',
RA_ACTL_PL_EOP decimal(18, 4) null comment '期末_锁定利率_未来_RA',
RA_EXPC decimal(18, 4) null comment '期末_预期_RA',
SPEC_RES_LAPSE_BOP decimal(18, 4) null comment '期初_失效准备金',
SPEC_RES_LAPSE_EOP decimal(18, 4) null comment '期末_失效准备金',
SPEC_RES_RP_BOP decimal(18, 4) null comment '期初_减额缴清准备金',
SPEC_RES_RP_EOP decimal(18, 4) null comment '期末_减额缴清准备金',
TVOG_ACTL_ACFA_FH decimal(18, 4) null comment '期末_金融假设变更后_当期TVOG',
TVOG_ACTL_AFA decimal(18, 4) null comment '期末_金融假设变更后_未来TVOG',
TVOG_ACTL_ANFA decimal(18, 4) null comment '期末_非金融假设变更后_未来TVOG',
TVOG_ACTL_ANOP decimal(18, 4) null comment '期末_有效人数调整_未来_TVOG',
TVOG_ACTL_BS_BOP decimal(18, 4) null comment '期初_当期利率_未来_TVOG',
TVOG_ACTL_BS_EOP decimal(18, 4) null comment '期末_当前利率_未来_TVOG',
TVOG_EXPC decimal(18, 4) null comment '期末_预期_TVOG',
MEA_TIME datetime null comment '计量时间',
ARC_TIME datetime null comment '归档时间',
MEA_BAT varchar(64) null comment '计量批次',
ARC_BAT varchar(64) null comment '归档批次'
);
HAPOC/0-DDL/0-HASOURCE/HASOURCE_EXT_QMSJTZSY--期末实际投资收益合同组原子指标-dws.sql 0 → 100644
View file @ bd9e5dfa
create table db_ifrs17hengan.hasource_ext_qmsjtzsy
(
GRP_ID varchar(64) not null comment '合同组号',
MEA_YM int not null comment '评估月',
N_CYEAR_D varchar(64) null comment '发单年度',
MDL varchar(64) null comment '适用模型|| BBA VFA PAA ',
N_PRDTYPE varchar(64) null comment '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ',
N_RISKCLASS varchar(64) null comment '风险类别|| 保障型 储蓄型',
N_CHNL varchar(64) null comment '渠道 || 个险 银保 多元 团险 健康险事业部 寿险事业部 ',
N_CYEAR varchar(64) null comment '发单年',
PROFIT_LOSS_FLAG varchar(64) null comment '盈亏 || 亏损组 盈利组 厚利组 ',
IFIE_UI_PL varchar(64) null comment '期末_实际_UI投资收益_PL部分',
IFIE_UI_OCI varchar(64) null comment '期末_实际_UI投资收益_OCI部分',
MEA_TIME datetime null comment '计量时间',
ARC_TIME datetime null comment '归档时间',
MEA_BAT varchar(64) null comment '计量批次',
ARC_BAT varchar(64) null comment '归档批次'
);
HAPOC/0-DDL/0-HASOURCE/HASOURCE_EXT_SHARECS--资产份额与账户价值分摊载体.sql 0 → 100644
View file @ bd9e5dfa
create table db_ifrs17hengan.hasource_ext_sharecs
(
N_SPCODE varchar(64) not null comment 'N_SPCODE ',
N_PRODUCT varchar(64) not null comment 'N_PRODUCT ',
N_AS_IF_VAL varchar(64) null comment 'N_AS_IF_VAL ',
N_AV_IF_VAL varchar(64) null comment 'N_AV_IF_VAL ',
N_ALL varchar(64) null comment 'N_N_ALL '
);
HAPOC/0-DDL/0-HASOURCE/HASOURCE_EXT_SHAREVAL--资产份额与账户价值数据.sql 0 → 100644
View file @ bd9e5dfa
create table db_ifrs17hengan.hasource_ext_shareval
(
N_SHARE varchar(64) not null comment '资产份额' ,
N_CV varchar(64) null comment '账户价值'
);
HAPOC/0-DDL/0-HASOURCE/HASOURCE_PERSONAL_LP--理赔数据_个人业务.sql 0 → 100644
View file @ bd9e5dfa
create table db_ifrs17hengan.hasource_personal_lp
(
ID varchar(64) not null comment 'ID' ,
PLC_OD varchar(64) null comment '保单号',
N_PRD_CODE varchar(64) null comment '产品代码',
CLAIM_REVIEW_CODE varchar(64) null comment '给付责任类型 || 理赔 理赔（豁免） 生存金',
CLAIM_NO varchar(64) null comment '赔案号',
ACCI_DAY_CV varchar(64) null comment '保单现价',
CLAIM_PAY_AMNT varchar(64) null comment '理赔金额',
ACCI_DATE varchar(64) null comment '出险日期',
CLOSE_DATE varchar(64) null comment '核赔通过日期'
);
HAPOC/0-DDL/0-HASOURCE/HASOURCE_PERSONAL_PAY--现金流_个人业务.sql 0 → 100644
View file @ bd9e5dfa
create table db_ifrs17hengan.hasource_personal_pay
(
ID varchar(64) not null comment 'ID' ,
GRP_INS_PLC_ID varchar(64) null comment '团单号',
PLC_ID varchar(64) null comment '保单号',
BUSI_NO varchar(64) null comment '业务号（赔案号）',
RISK_CODE varchar(64) null comment '险种',
N_ORG_4 varchar(64) null comment '四级机构',
N_COST_CODE varchar(64) null comment '成本中心代码',
N_BUSY_CHAN varchar(64) null comment '销售渠道 || 多元 银保 健康险 寿险 个险 团险 收展',
N_CLAIM_REVIEW_CODE varchar(64) null comment '给付责任类型 || 理赔 理赔（豁免） 生存金',
N_TYPE varchar(64) null comment '记账大类 || 实收 实付',
BUSI_TYPE varchar(64) null comment '业务场景编号 || T656 B522 T642 BZ39 T607 BH63 T512 T513 BZ42',
N_BUSI_TYPE_DESC varchar(64) null comment '业务场景编号说明 || 保费收入 红利 理赔 理赔（豁免） 正常退保 通融退保 生存金',
N_CURRENCY varchar(64) null comment '币种 || 人民币',
AMNT varchar(64) null comment '金额',
N_BUS_DATE varchar(64) null comment '业务日期'
);
HAPOC/0-DDL/0-HASOURCE/HASOURCE_PERSONAL_PLCRICK--保单险种明细_个人业务.sql 0 → 100644
View file @ bd9e5dfa
create table db_ifrs17hengan.hasource_personal_plcrick
(
PLC_ID varchar(64) not null comment '保单号',
N_PRD_CODE varchar(64) not null comment '产品代码',
PLC_RISK_CODE varchar(64) not null comment '险种号',
GUAR_PERIOD varchar(64) null comment '保障年期',
GUAR_PERIOD_UNITID varchar(64) null comment '保障年期类型 || 按年保 按年龄保',
PAY_FREQ varchar(64) null comment '缴费频率 || 趸缴 月缴 不定期缴 年缴 季缴 半年缴',
PAY_PERIOD varchar(64) null comment '缴费期限',
PAY_PERIOD_UNITID varchar(64) null comment '缴费年期类型',
ORGID varchar(64) null comment '分支机构',
BUSY_CHAN varchar(64) null comment '销售渠道代码',
PLC_B_DATE varchar(64) null comment '保单生效日',
SIGN_DATE varchar(64) null comment '签单日期',
STAND_PREM varchar(64) null comment '标准保费',
N_SIX varchar(64) null comment '被保人性别 || 女 男',
N_AGE varchar(64) null comment '被保险人投保时年龄',
YEAR_COVER varchar(64) null comment '初始保额',
DIVID_COLL_METHOD varchar(64) null comment '生存金领取方式 || 自动给付 累计生息',
N_CDX varchar(64) null comment '长短险标识 || 长险 短险 极短险',
STS varchar(64) null comment '保单状态 || 生效 满期终止 签单 保单退保 犹豫期退保'
);
HAPOC/0-DDL/0-HASOURCE/HASOURCE_TEAM_LP--理赔数据_团险.sql 0 → 100644
View file @ bd9e5dfa
create table db_ifrs17hengan.hasource_team_lp
(
GRP_INS_PLC_ID varchar(64) null comment '团单号',
N_PRD_CODE varchar(64) null comment '产品代码',
CLAIM_REVIEW_CODE varchar(64) null comment '给付责任类型 || 理赔 理赔（豁免） 生存金',
CLAIM_NO varchar(64) null comment '赔案号',
ACCI_DAY_CV varchar(64) null comment '保单现价',
CLAIM_PAY_AMNT varchar(64) null comment '理赔金额',
ACCI_DATE varchar(64) null comment '出险日期',
CLOSE_DATE varchar(64) null comment '核赔通过日期',
PERSONAL_RISK_CODE varchar(64) null comment '个人险种号'
)
comment '理赔数据_团险' charset = utf8mb3;
HAPOC/0-DDL/0-HASOURCE/HASOURCE_TEAM_PAY--现金流_团险.sql 0 → 100644
View file @ bd9e5dfa
create table db_ifrs17hengan.hasource_team_pay
(
ID varchar(64) not null comment 'ID',
GRP_INS_PLC_ID varchar(64) null comment '团单号',
PLC_ID varchar(64) null comment '保单号',
BUSI_NO varchar(64) null comment '业务号（赔案号）',
RISK_CODE varchar(64) null comment '险种',
N_ORG_4 varchar(64) null comment '四级机构',
N_COST_CODE varchar(64) null comment '成本中心代码',
N_BUSY_CHAN varchar(64) null comment '销售渠道',
N_CLAIM_REVIEW_CODE varchar(64) null comment '给付责任类型 || 理赔 理赔（豁免） 生存金',
N_TYPE varchar(64) null comment '记账大类 || 实收付交易',
BUSI_TYPE varchar(64) null comment '业务场景编号 || NB CM RW ZT NI CT RN LC IC UD RG BE RD RT DE SA WT ',
N_BUSI_TYPE_DESC varchar(64) null comment '业务场景编号说明 || 新单 理赔 续期 减少被保险人 新增被保险人 整单退保 不定期缴费 被保险人保险方案变更 被保险人重要资料变更 企业年金领取 满期领取 被保险人复效 部分领取 续期回退 被保险人责任复效 建工险保单延期 犹豫期退保 ',
N_CURRENCY varchar(64) null comment '币种 || CNY',
AMNT varchar(64) null comment '金额',
N_BUS_DATE varchar(64) null comment '业务日期',
PERSONAL_RISK_CODE varchar(64) null comment '个人险种号'
)
comment '现金流_团险' charset = utf8mb3;
HAPOC/0-DDL/0-HASOURCE/HASOURCE_TEAM_PLCRICK--保单险种明细_团险.sql 0 → 100644
View file @ bd9e5dfa
create table db_ifrs17hengan.hasource_team_plcrick
(
GRP_INS_PLC_ID varchar(64) not null comment '保单号',
N_PRD_CODE varchar(64) not null comment '产品代码',
PLC_RISK_CODE varchar(64) not null comment '险种号',
GUAR_PERIOD varchar(64) null comment '保障年期',
GUAR_PERIOD_UNITID varchar(64) null comment '保障年期类型 || Y D M A',
PAY_FREQ varchar(64) null comment '缴费频率 || 趸缴 月缴 不定期缴 年缴 季缴 半年缴',
PAY_PERIOD varchar(64) null comment '缴费期限',
PAY_PERIOD_UNITID varchar(64) null comment '缴费年期类型 || Y D M A',
ORGID varchar(64) null comment '分支机构',
BUSY_CHAN varchar(64) null comment '销售渠道代码',
PLC_B_DATE varchar(64) null comment '保单生效日',
SIGN_DATE varchar(64) null comment '签单日期',
STAND_PREM varchar(64) null comment '标准保费',
N_SIX varchar(64) null comment '被保人性别 || 0 1 2',
N_AGE varchar(64) null comment '被保险人投保时年龄',
YEAR_COVER varchar(64) null comment '初始保额',
DIVID_COLL_METHOD varchar(64) null comment '生存金领取方式 || 满期一次性领取',
N_CDX varchar(64) null comment '长短险标识 || M L',
STS varchar(64) null comment '保单状态 || 生效 满期终止 签单 保单退保 犹豫期退保',
PERSONAL_RISK_CODE varchar(64) null comment '个人险种号',
BF varchar(64) null comment '保费'
)
comment '保单险种明细数据_团险' charset = utf8mb3;
HAPOC/0-DDL/2-HAODSCK/HAODS_EXT_CONCATINFO--合同分组基本信息-Y4.sql deleted 100644 → 0
View file @ a5a204c9
-- HAODS_EXT_CONCATINFO--合同分组基本信息
create table HAODS_EXT_CONCATINFO(
-- 合同组号,合同组合号,发单年度,营利性代码,计量模型,产品大类,风险类别,渠道,发单年,盈亏,过渡方法
GRP_ID varchar(64) default null comment '合同组号' ,
N_GRP__ID varchar(64) default null comment '合同组合号' ,
N_CYEAR_D varchar(64) default null comment '发单年度' ,
N_PROFIT_FLAG varchar(64) default null comment '营利性代码 || 1 2 3' ,
MDL varchar(64) default null comment '计量模型 || BBA VFA PAA' ,
N_PRDTYPE varchar(64) default null comment '产品大类 || 传统险 分红险 万能险 投连险 累积式分红' ,
N_RISKCLASS varchar(64) default null comment '风险类别 || 保障型 储蓄型' ,
N_CHNL varchar(64) default null comment '渠道 || 个险 银保 多元 团险 健康险事业部 寿险事业部 ' ,
N_CYEAR varchar(64) default null comment '发单年' ,
PROFIT_LOSS_FLAG varchar(64) default null comment '盈亏 || 亏损组 盈利组 厚利组 ' ,
METHOD varchar(64) default null comment '过渡方法 || FVA MRA' ,
)
-- DUPLICATE KEY(event_time, event_type) -- 排序字段
DISTRIBUTED BY HASH(GRP_ID)
PROPERTIES (
"replication_num" = "1"
)
HAPOC/0-DDL/2-HAODSCK/HAODS_EXT_CS--待分摊费用获取费用&维护费用-Y9.sql deleted 100644 → 0
View file @ a5a204c9
-- HAODS_EXT_CS--待分摊费用获取费用&维护费用
create table HAODS_EXT_CS(
N_CHNL varchar(64) default null comment '渠道|| 多元 个险 银保 团险 互联网'
,N_CDX varchar(64) default null comment '长短险|| 长险 短险'
,CS_ITEM varchar(64) default null comment '待分摊项|| 获取费用 维持费用'
,CS_AMONT decimal(18,4) default null comment '待分摊项金额'
)
comment '待分摊费用获取费用&维护费用' charset = utf8mb3
-- DUPLICATE KEY(event_time, event_type) -- 排序字段
-- DISTRIBUTED BY HASH(精算现金流数据合同组原子指标)
-- PROPERTIES (
-- "replication_num" = "1"
-- )
;
HAPOC/0-DDL/2-HAODSCK/HAODS_EXT_INCURRED-法定准备金数据-Y5.sql deleted 100644 → 0
View file @ a5a204c9
-- HAODS_EXT_INCURRED-法定准备金数据
create table HAODS_EXT_INCURRED(
-- #发单年,渠道,产品代码, 法定准备金 ,,,,,,
N_CYEAR varchar(64) default null comment '发单年' ,
N_CHNL varchar(64) default null comment '渠道 || BK FC AD GP EC EL ' ,
N_PRDCODE varchar(64) default null comment '产品代码' ,
N_INCURRED varchar(64) default null comment '法定准备金' ,
C1 varchar(64) default null comment 'C1' ,
C2 varchar(64) default null comment 'C2' ,
C3 varchar(64) default null comment 'C3' ,
C4 varchar(64) default null comment 'C4' ,
C5 varchar(64) default null comment 'C5' ,
C6 varchar(64) default null comment 'C6'
)
-- DUPLICATE KEY(event_time, event_type) -- 排序字段
DISTRIBUTED BY HASH(ID)
PROPERTIES (
"replication_num" = "1"
)
HAPOC/0-DDL/2-HAODSCK/HAODS_EXT_SHARECS--资产份额与账户价值分摊载体-Y6.sql deleted 100644 → 0
View file @ a5a204c9
-- HAODS_EXT_SHARECS-资产份额与账户价值分摊载体
create table HAODS_EXT_SHARECS(
-- SPCODE,Product,AS_IF_VAL,AV_IF_VAL,ALL
N_SPCODE varchar(64) default null comment 'N_SPCODE ' ,
N_PRODUCT varchar(64) default null comment 'N_PRODUCT ' ,
N_AS_IF_VAL varchar(64) default null comment 'N_AS_IF_VAL ' ,
N_AV_IF_VAL varchar(64) default null comment 'N_AV_IF_VAL ' ,
N_ALL varchar(64) default null comment 'N_N_ALL ' ,
)
-- DUPLICATE KEY(event_time, event_type) -- 排序字段
DISTRIBUTED BY HASH(SPCODE)
PROPERTIES (
"replication_num" = "1"
)
HAPOC/0-DDL/2-HAODSCK/HAODS_EXT_SHAREVAL--资产份额与账户价值数据-Y7.sql deleted 100644 → 0
View file @ a5a204c9
-- HAODS_EXT_SHAREVAL-资产份额与账户价值数据
create table HAODS_EXT_SHAREVAL(
-- #资产份额,账户价值
N_SHARE varchar(64) default null comment '资产份额' ,
N_CV varchar(64) default null comment '账户价值' ,
)
-- DUPLICATE KEY(event_time, event_type) -- 排序字段
DISTRIBUTED BY HASH(ID)
PROPERTIES (
"replication_num" = "1"
)
HAPOC/0-DDL/2-HAODSCK/HAODS_PERSONAL_LP--理赔数据_个人业务.sql deleted 100644 → 0
View file @ a5a204c9
-- HAODS_PERSONAL_LP--理赔数据_个人业务
create table HAODS_PERSONAL_LP(
ID varchar(64) default null comment 'ID' ,
PLC_OD varchar(64) default null comment '保单号' ,
N_PRD_CODE varchar(64) default null comment '产品代码' ,
CLAIM_REVIEW_CODE varchar(64) default null comment '给付责任类型 || 理赔 理赔（豁免） 生存金' ,
CLAIM_NO varchar(64) default null comment '赔案号' ,
ACCI_DAY_CV varchar(64) default null comment '保单现价' ,
CLAIM_PAY_AMNT varchar(64) default null comment '理赔金额' ,
ACCI_DATE varchar(64) default null comment '出险日期' ,
CLOSE_DATE varchar(64) default null comment '核赔通过日期'
)
-- DUPLICATE KEY(event_time, event_type) -- 排序字段
DISTRIBUTED BY HASH(ID)
PROPERTIES (
"replication_num" = "1"
)
-- comment '理赔数据_个人业务' charset = utf8mb3
;
HAPOC/0-DDL/2-HAODSCK/HAODS_PERSONAL_PAY--现金流_个人业务.sql deleted 100644 → 0
View file @ a5a204c9
-- HAODS_PERSONAL_PAY--现金流_个人业务
create table HAODS_PERSONAL_PAY(
ID varchar(64) default null comment 'ID' ,
GRP_INS_PLC_ID varchar(64) default null comment '团单号' ,
PLC_ID varchar(64) default null comment '保单号' ,
BUSI_NO varchar(64) default null comment '业务号（赔案号）' ,
RISK_CODE varchar(64) default null comment '险种' ,
N_ORG_4 varchar(64) default null comment '四级机构' ,
N_COST_CODE varchar(64) default null comment '成本中心代码' ,
N_BUSY_CHAN varchar(64) default null comment '销售渠道 || 多元 银保 健康险 寿险 个险 团险 收展' ,
N_CLAIM_REVIEW_CODE varchar(64) default null comment '给付责任类型 || 理赔 理赔（豁免） 生存金' ,
N_TYPE varchar(64) default null comment '记账大类 || 实收 实付' ,
BUSI_TYPE varchar(64) default null comment '业务场景编号 || T656 B522 T642 BZ39 T607 BH63 T512 T513 BZ42' ,
N_BUSI_TYPE_DESC varchar(64) default null comment '业务场景编号说明 || 保费收入 红利 理赔 理赔（豁免） 正常退保 通融退保 生存金' ,
N_CURRENCY varchar(64) default null comment '币种 || 人民币' ,
AMNT varchar(64) default null comment '金额' ,
N_BUS_DATE varchar(64) default null comment '业务日期'
)
-- DUPLICATE KEY(event_time, event_type) -- 排序字段
DISTRIBUTED BY HASH(ID)
PROPERTIES (
"replication_num" = "1"
)
-- comment '现金流_个人业务' charset = utf8mb3
;
HAPOC/0-DDL/2-HAODSCK/HAODS_PERSONAL_PLCRICK--保单险种明细_个人业务.sql deleted 100644 → 0
View file @ a5a204c9
-- HAODS_PERSONAL_PLCRICK--保单险种明细_个人业务
create table HAODS_PERSONAL_PLCRICK(
PLC_ID varchar(64) default null comment '保单号' ,
N_PRD_CODE varchar(64) default null comment '产品代码' ,
PLC_RISK_CODE varchar(64) default null comment '险种号' ,
GUAR_PERIOD varchar(64) default null comment '保障年期' ,
GUAR_PERIOD_UNITID varchar(64) default null comment '保障年期类型 || 按年保 按年龄保' ,
PAY_FREQ varchar(64) default null comment '缴费频率 || 趸缴 月缴 不定期缴 年缴 季缴 半年缴' ,
PAY_PERIOD varchar(64) default null comment '缴费期限' ,
PAY_PERIOD_UNITID varchar(64) default null comment '缴费年期类型' ,
ORGID varchar(64) default null comment '分支机构' ,
BUSY_CHAN varchar(64) default null comment '销售渠道代码' ,
PLC_B_DATE varchar(64) default null comment '保单生效日' ,
SIGN_DATE varchar(64) default null comment '签单日期' ,
STAND_PREM varchar(64) default null comment '标准保费' ,
N_SIX varchar(64) default null comment '被保人性别 || 女 男' ,
N_AGE varchar(64) default null comment '被保险人投保时年龄' ,
YEAR_COVER varchar(64) default null comment '初始保额' ,
DIVID_COLL_METHOD varchar(64) default null comment '生存金领取方式 || 自动给付 累计生息' ,
N_CDX varchar(64) default null comment '长短险标识 || 长险 短险 极短险' ,
STS varchar(64) default null comment '保单状态 || 生效 满期终止 签单 保单退保 犹豫期退保'
)
-- PRIMARY KEY (PLC_ID)
-- DISTRIBUTED BY HASH (PLC_ID)
-- DUPLICATE KEY(event_time, event_type) -- 排序字段
DISTRIBUTED BY HASH(PLC_ID)
PROPERTIES (
"replication_num" = "1"
)
-- comment '保单险种明细_个人业务' charset = utf8mb3
;
HAPOC/0-DDL/2-HAODSCK/HAODS_TEAM_LP--理赔数据_团险.sql deleted 100644 → 0
View file @ a5a204c9
-- HAODS_TEAM_LP--理赔数据_团险
create table HAODS_TEAM_LP(
ID varchar(64) default null comment 'ID' ,
GRP_INS_PLC_ID varchar(64) default null comment '团单号' ,
N_PRD_CODE varchar(64) default null comment '产品代码' ,
CLAIM_REVIEW_CODE varchar(64) default null comment '给付责任类型 || 理赔 理赔（豁免） 生存金' ,
CLAIM_NO varchar(64) default null comment '赔案号' ,
ACCI_DAY_CV varchar(64) default null comment '保单现价' ,
CLAIM_PAY_AMNT varchar(64) default null comment '理赔金额' ,
ACCI_DATE varchar(64) default null comment '出险日期' ,
CLOSE_DATE varchar(64) default null comment '核赔通过日期'
)
-- DUPLICATE KEY(event_time, event_type) -- 排序字段
DISTRIBUTED BY HASH(ID)
PROPERTIES (
"replication_num" = "1"
)
-- comment '理赔数据_团险' charset = utf8mb3
;
HAPOC/0-DDL/2-HAODSCK/HAODS_TEAM_PAY--现金流_团险.sql deleted 100644 → 0
View file @ a5a204c9
-- HAODS_TEAM_PLCRICK--保单险种明细_团险
create table HAODS_TEAM_PAY(
ID varchar(64) default null comment 'ID' ,
GRP_INS_PLC_ID varchar(64) default null comment '团单号' ,
PLC_ID varchar(64) default null comment '保单号' ,
BUSI_NO varchar(64) default null comment '业务号（赔案号）' ,
RISK_CODE varchar(64) default null comment '险种' ,
N_ORG_4 varchar(64) default null comment '四级机构' ,
N_COST_CODE varchar(64) default null comment '成本中心代码' ,
N_BUSY_CHAN varchar(64) default null comment '销售渠道' ,
N_CLAIM_REVIEW_CODE varchar(64) default null comment '给付责任类型 || 理赔 理赔（豁免） 生存金' ,
N_TYPE varchar(64) default null comment '记账大类 || 实收付交易' ,
BUSI_TYPE varchar(64) default null comment '业务场景编号 || NB CM RW ZT NI CT RN LC IC UD RG BE RD RT DE SA WT ' ,
N_BUSI_TYPE_DESC varchar(64) default null comment '业务场景编号说明 || 新单 理赔 续期 减少被保险人 新增被保险人 整单退保 不定期缴费 被保险人保险方案变更 被保险人重要资料变更 企业年金领取 满期领取 被保险人复效 部分领取 续期回退 被保险人责任复效 建工险保单延期 犹豫期退保 ' ,
N_CURRENCY varchar(64) default null comment '币种 || CNY' ,
AMNT varchar(64) default null comment '金额' ,
N_BUS_DATE varchar(64) default null comment '业务日期'
)
-- DUPLICATE KEY(event_time, event_type) -- 排序字段
DISTRIBUTED BY HASH(ID)
PROPERTIES (
"replication_num" = "1"
)
-- comment '现金流_团险' charset = utf8mb3
;
HAPOC/0-DDL/2-HAODSCK/HAODS_TEAM_PLCRICK--保单险种明细_团险.sql deleted 100644 → 0
View file @ a5a204c9
create table HAODS_TEAM_PLCRICK(
GRP_INS_PLC_ID varchar(64) default null comment '保单号' ,
N_PRD_CODE varchar(64) default null comment '产品代码' ,
PLC_RISK_CODE varchar(64) default null comment '险种号' ,
GUAR_PERIOD varchar(64) default null comment '保障年期' ,
GUAR_PERIOD_UNITID varchar(64) default null comment '保障年期类型 || Y D M A' ,
PAY_FREQ varchar(64) default null comment '缴费频率 || 趸缴 月缴 不定期缴 年缴 季缴 半年缴' ,
PAY_PERIOD varchar(64) default null comment '缴费期限' ,
PAY_PERIOD_UNITID varchar(64) default null comment '缴费年期类型 || Y D M A' ,
ORGID varchar(64) default null comment '分支机构' ,
BUSY_CHAN varchar(64) default null comment '销售渠道代码' ,
PLC_B_DATE varchar(64) default null comment '保单生效日' ,
SIGN_DATE varchar(64) default null comment '签单日期' ,
STAND_PREM varchar(64) default null comment '标准保费' ,
N_SIX varchar(64) default null comment '被保人性别 || 0 1 2' ,
N_AGE varchar(64) default null comment '被保险人投保时年龄' ,
YEAR_COVER varchar(64) default null comment '初始保额' ,
DIVID_COLL_METHOD varchar(64) default null comment '生存金领取方式 || 满期一次性领取' ,
N_CDX varchar(64) default null comment '长短险标识 || M L' ,
STS varchar(64) default null comment '保单状态 || 生效 满期终止 签单 保单退保 犹豫期退保'
)
-- DUPLICATE KEY(event_time, event_type) -- 排序字段
DISTRIBUTED BY HASH(GRP_INS_PLC_ID)
PROPERTIES (
"replication_num" = "1"
)
-- comment '保单险种明细数据_团险' charset = utf8mb3
;
HAPOC/3-HADWS/HADWS_CONCAT_MANAGE--合同组管理费用_直接部分表.sql
View file @ bd9e5dfa
-- HADWS_CONCAT_MANAGE HADWS_合同组管理费用_直接部分表 /*HADWS_CONCAT_MANAGE HADWS_合同组管理费用_直接部分表*/
INSERT INTO IFRS17.IFRS17_HAODS_MYSQL.HADWS_CONCAT_MANAGE -- 合同组管理费用_直接部分表 INSERT INTO db_ifrs17hengan.HADWS_CONCAT_MANAGE /* 合同组管理费用_直接部分表*/
SELECT SELECT
MD5(ConcatObjUDF(GRP_ID , MEA_YM , N_PRDTYPE , BUSY_CHAN , N_CDX )) MD5(concat(GRP_ID , MEA_YM , N_PRDTYPE , BUSY_CHAN , N_CDX ))
AS DATAPKID -- 物理主键 AS DATAPKID /* 物理主键*/
, GRP_ID AS GRP_ID -- '合同组号' , , GRP_ID AS GRP_ID /* '合同组号' ,*/
, MEA_YM AS MEA_YM -- '评估月' , MEA_YM AS MEA_YM /* '评估月'*/
, COALESCE(N_PRDTYPE,'') AS N_PRDTYPE -- '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' , , COALESCE(N_PRDTYPE,'') AS N_PRDTYPE /* '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' ,*/
, COALESCE(BUSY_CHAN,'') AS BUSY_CHAN -- '销售渠道代码' , , COALESCE(BUSY_CHAN,'') AS BUSY_CHAN /* '销售渠道代码' ,*/
, COALESCE(N_CDX ,'') AS N_CDX -- '长短险标识 || 长险 短险 极短险' , , COALESCE(N_CDX ,'') AS N_CDX /* '长短险标识 || 长险 短险 极短险' ,*/
, '' AS P_FLAG , '' AS P_FLAG
, SUM(IACF_INS_OUT) AS IACF_INS_OUT -- 期末_实际_IACF_直接部分, , SUM(IACF_INS_OUT) AS IACF_INS_OUT /* 期末_实际_IACF_直接部分,*/
, SUM(ISE_INS_OUT ) AS ISE_INS_OUT -- 期末_实际_当期_维持费用_直接部分 , SUM(ISE_INS_OUT ) AS ISE_INS_OUT /* 期末_实际_当期_维持费用_直接部分*/
, LOCALTIMESTAMP AS MEA_TIME -- '计量时间' , LOCALTIMESTAMP AS MEA_TIME /* '计量时间'*/
, LOCALTIMESTAMP AS ARC_TIME -- '归档时间' , LOCALTIMESTAMP AS ARC_TIME /* '归档时间'*/
, '' AS MEA_BAT -- '计量批次' , '' AS MEA_BAT /* '计量批次'*/
, '' AS ARC_BAT -- '归档批次' , '' AS ARC_BAT /* '归档批次'*/
FROM( FROM(
SELECT 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 /*'评估月'*/
,s1.N_PRDTYPE AS N_PRDTYPE -- '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' , ,s1.N_PRDTYPE AS N_PRDTYPE /*'产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' ,*/
,s1.BUSY_CHAN AS BUSY_CHAN -- '销售渠道代码' , ,s1.BUSY_CHAN AS BUSY_CHAN /*'销售渠道代码' ,*/
,s1.N_CDX AS N_CDX -- '长短险标识 || 长险 短险 极短险' , ,s1.N_CDX AS N_CDX /*'长短险标识 || 长险 短险 极短险' ,*/
,'1' AS P_FLAG -- '团险个险标记|| 1 个单, 2 团单', ,'1' AS P_FLAG /*'团险个险标记|| 1 个单, 2 团单',*/
,( ,(
CASE CASE
WHEN s1.BUSY_CHAN = 'FC' THEN STAND_PREM * 0.50 + 250.0 WHEN s1.BUSY_CHAN = 'FC' THEN STAND_PREM * 0.50 + 250.0
...@@ -33,7 +33,7 @@ FROM( ...@@ -33,7 +33,7 @@ FROM(
WHEN s1.BUSY_CHAN = 'BK' THEN STAND_PREM * 0.12 + 250.0 WHEN s1.BUSY_CHAN = 'BK' THEN STAND_PREM * 0.12 + 250.0
WHEN s1.BUSY_CHAN = 'EC' THEN STAND_PREM * 0.05 + 25.0 WHEN s1.BUSY_CHAN = 'EC' THEN STAND_PREM * 0.05 + 25.0
ELSE 0.0 END ELSE 0.0 END
) AS IACF_INS_OUT -- 期末_实际_IACF_直接部分, ) AS IACF_INS_OUT /*期末_实际_IACF_直接部分,*/
,( ,(
CASE CASE
...@@ -45,21 +45,21 @@ FROM( ...@@ -45,21 +45,21 @@ FROM(
THEN STAND_PREM * 0.00165 + 6.5 THEN STAND_PREM * 0.00165 + 6.5
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 /*IFRS17_HAODS_SRDB IFRS17_HADWS_SRDB IFRS17_HAODS_MYSQL*/
FROM IFRS17.IFRS17_HAODS_MYSQL.HADWS_PERSONAL_PLCRICK_OUT s1 -- 个险现金流输出接口表 FROM db_ifrs17hengan.HADWS_PERSONAL_PLCRICK_OUT s1 /*个险现金流输出接口表*/
where s1.MEA_YM = cast('${MEA_YM}' as int) where s1.MEA_YM = cast('202401' as int)
union all union all
SELECT 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 /* '评估月'*/
,s1.N_PRDTYPE AS N_PRDTYPE -- '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' , ,s1.N_PRDTYPE AS N_PRDTYPE /* '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' ,*/
,s1.BUSY_CHAN AS BUSY_CHAN -- '销售渠道代码' , ,s1.BUSY_CHAN AS BUSY_CHAN /* '销售渠道代码' ,*/
,s1.N_CDX AS N_CDX -- '长短险标识 || 长险 短险 极短险' , ,s1.N_CDX AS N_CDX /* '长短险标识 || 长险 短险 极短险' ,*/
,'2' AS P_FLAG -- '团险个险标记|| 1 个单, 2 团单', ,'2' AS P_FLAG /* '团险个险标记|| 1 个单, 2 团单',*/
,( ,(
CASE CASE
WHEN s1.BUSY_CHAN = 'FC' THEN STAND_PREM * 0.50 + 250.0 WHEN s1.BUSY_CHAN = 'FC' THEN STAND_PREM * 0.50 + 250.0
...@@ -68,7 +68,7 @@ FROM( ...@@ -68,7 +68,7 @@ FROM(
WHEN s1.BUSY_CHAN = 'BK' THEN STAND_PREM * 0.12 + 250.0 WHEN s1.BUSY_CHAN = 'BK' THEN STAND_PREM * 0.12 + 250.0
WHEN s1.BUSY_CHAN = 'EC' THEN STAND_PREM * 0.05 + 25.0 WHEN s1.BUSY_CHAN = 'EC' THEN STAND_PREM * 0.05 + 25.0
ELSE 0.0 END ELSE 0.0 END
) AS IACF_INS_OUT -- 期末_实际_IACF_直接部分, ) AS IACF_INS_OUT /*期末_实际_IACF_直接部分,*/
,( ,(
CASE CASE
...@@ -80,10 +80,10 @@ FROM( ...@@ -80,10 +80,10 @@ FROM(
THEN STAND_PREM * 0.00165 + 6.5 THEN STAND_PREM * 0.00165 + 6.5
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 /* 期末_实际_当期_维持费用_直接部分*/
FROM IFRS17.IFRS17_HAODS_MYSQL.HADWS_TEAM_PLCRICK_OUT s1 -- 团险现金流输出接口表 FROM db_ifrs17hengan.HADWS_TEAM_PLCRICK_OUT s1 /*团险现金流输出接口表*/
where s1.MEA_YM = cast('${MEA_YM}' as int) where s1.MEA_YM = cast('202401' as int)
) d1 ) d1
GROUP BY GROUP BY
GRP_ID GRP_ID
......
HAPOC/3-HADWS/HADWS_CONTACT_MEAS_REL--合同组计量内外关系表.sql
View file @ bd9e5dfa
-- HADWS_CONTACT_MEAS_REL HADWS_合同组计量内外关系表 /* HADWS_CONTACT_MEAS_REL HADWS_合同组计量内外关系表*/
INSERT INTO IFRS17.IFRS17_HADWS_SRDB.HADWS_CONTACT_MEAS_REL --HADWS_合同组计量关系表 INSERT INTO db_ifrs17hengan.HADWS_CONTACT_MEAS_REL /*HADWS_合同组计量关系表*/
SELECT SELECT
DATAPKID -- 物理主键 DATAPKID /* 物理主键*/
, a1.GRP_ID_INSIDE -- '合同组号-内部' , a1.GRP_ID_INSIDE /* '合同组号-内部'*/
, a1.GRP_ID -- '合同组号' , a1.GRP_ID /* '合同组号'*/
, a1.MEA_YM -- '评估月' , a1.MEA_YM /* '评估月'*/
, a1.N_PRDTYPE -- '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' , a1.N_PRDTYPE /* '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 '*/
, a1.N_PROFIT_FLAG -- '营利性代码|| 1 2 3' , a1.N_PROFIT_FLAG /* '营利性代码|| 1 2 3'*/
, a1.N_RISKCLASS -- '风险类别|| 保障型 储蓄型' , a1.N_RISKCLASS /* '风险类别|| 保障型 储蓄型'*/
, a1.MDL -- '适用模型|| BBA VFA PAA ' , a1.MDL /* '适用模型|| BBA VFA PAA '*/
,LOCALTIMESTAMP AS MEA_TIME -- '计量时间' ,LOCALTIMESTAMP AS MEA_TIME /* '计量时间'*/
,LOCALTIMESTAMP AS ARC_TIME -- '归档时间' ,LOCALTIMESTAMP AS ARC_TIME /* '归档时间'*/
,'' AS MEA_BAT -- '计量批次' ,'' AS MEA_BAT /* '计量批次'*/
,'' AS ARC_BAT -- '归档批次' ,'' AS ARC_BAT /* '归档批次'*/
FROM IFRS17.IFRS17_HADWS_SRDB.HADWS_CONTACT_MEAS_INPUT --团险投资成分拆分数据表 FROM db_ifrs17hengan.HADWS_CONTACT_MEAS_INPUT a1 /*团险投资成分拆分数据表*/
where s1.MEA_YM = cast('${MEA_YM}' as int) where a1.MEA_YM = cast('202401' as int)
......
HAPOC/3-HADWS/HADWS_PERSONAL_PLCRICK_IN--个险现金流输入接口表.sql
View file @ bd9e5dfa
-- HADWS_PERSONAL_PLCRICK_IN HADWS_个险现金流输入接口表 /*HADWS_PERSONAL_PLCRICK_IN HADWS_个险现金流输入接口表*/
INSERT INTO IFRS17.IFRS17_HAODS_MYSQL.HADWS_PERSONAL_PLCRICK_IN -- 个险现金流输入接口表 INSERT INTO db_ifrs17hengan.HADWS_PERSONAL_PLCRICK_IN /* 个险现金流输入接口表*/
SELECT SELECT
MD5(ConcatObjUDF( '${MEA_YM}',s1.PLC_ID)) MD5(concat( '202401',s1.PLC_ID))
AS DATAPKID -- 物理主键 AS DATAPKID /* 物理主键*/
,cast('${MEA_YM}' as int) AS MEA_YM --'评估月' ,cast('202401' as int) AS MEA_YM /* '评估月'*/
,s1.PLC_ID AS PLC_ID -- '保单号' , ,s1.PLC_ID AS PLC_ID /* '保单号' ,*/
,s1.N_PRD_CODE AS N_PRD_CODE -- '产品代码' , ,s1.N_PRD_CODE AS N_PRD_CODE /* '产品代码' ,*/
,s1.PLC_RISK_CODE AS PLC_RISK_CODE -- '险种号' , ,s1.PLC_RISK_CODE AS PLC_RISK_CODE /* '险种号' ,*/
,s1.GUAR_PERIOD AS GUAR_PERIOD -- '保障年期' , ,s1.GUAR_PERIOD AS GUAR_PERIOD /* '保障年期' ,*/
,s1.GUAR_PERIOD_UNITID AS GUAR_PERIOD_UNITID -- '保障年期类型 || 按年保 按年龄保' , ,s1.GUAR_PERIOD_UNITID AS GUAR_PERIOD_UNITID /* '保障年期类型 || 按年保 按年龄保' ,*/
,s1.PAY_FREQ AS PAY_FREQ -- '缴费频率 || 趸缴 月缴 不定期缴 年缴 季缴 半年缴' , ,s1.PAY_FREQ AS PAY_FREQ /* '缴费频率 || 趸缴 月缴 不定期缴 年缴 季缴 半年缴' ,*/
,s1.PAY_PERIOD AS PAY_PERIOD -- '缴费期限' , ,s1.PAY_PERIOD AS PAY_PERIOD /* '缴费期限' ,*/
,s1.PAY_PERIOD_UNITID AS PAY_PERIOD_UNITID -- '缴费年期类型' , ,s1.PAY_PERIOD_UNITID AS PAY_PERIOD_UNITID /* '缴费年期类型' ,*/
,s1.ORGID AS ORGID -- '分支机构' , ,s1.ORGID AS ORGID /* '分支机构' ,*/
,s2.CHNL AS BUSY_CHAN -- '销售渠道代码' , ,s2.CHNL AS BUSY_CHAN /* '销售渠道代码' ,*/
,s1.PLC_B_DATE AS PLC_B_DATE -- '保单生效日' , ,s1.PLC_B_DATE AS PLC_B_DATE /* '保单生效日' ,*/
,s1.SIGN_DATE AS SIGN_DATE -- '签单日期' , ,s1.SIGN_DATE AS SIGN_DATE /* '签单日期' ,*/
,cast(s1.STAND_PREM as decimal(18,4)) AS STAND_PREM -- '标准保费' , ,cast(s1.STAND_PREM as decimal(18,4)) AS STAND_PREM /* '标准保费' ,*/
,s1.N_SIX AS N_SIX -- '被保人性别 || 女 男' , ,s1.N_SIX AS N_SIX /* '被保人性别 || 女 男' ,*/
,s1.N_AGE AS N_AGE -- '被保险人投保时年龄' , ,s1.N_AGE AS N_AGE /* '被保险人投保时年龄' ,*/
,cast(s1.YEAR_COVER as decimal(18,4)) AS YEAR_COVER -- '初始保额' , ,cast(s1.YEAR_COVER as decimal(18,4)) AS YEAR_COVER /* '初始保额' ,*/
,s1.DIVID_COLL_METHOD AS DIVID_COLL_METHOD -- '生存金领取方式 || 自动给付 累计生息' , ,s1.DIVID_COLL_METHOD AS DIVID_COLL_METHOD /* '生存金领取方式 || 自动给付 累计生息' ,*/
,s1.N_CDX AS N_CDX -- '长短险标识 || 长险 短险 极短险' , ,s1.N_CDX AS N_CDX /* '长短险标识 || 长险 短险 极短险' ,*/
,s1.STS AS STS -- '保单状态' || 生效 满期终止 签单 保单退保 犹豫期退保' ,s1.STS AS STS /* '保单状态' || 生效 满期终止 签单 保单退保 犹豫期退保'*/
,LEFT(s1.SIGN_DATE,4) AS N_CYEAR_D --'发单年度' ,LEFT(s1.SIGN_DATE,4) AS N_CYEAR_D /* '发单年度'*/
,if(LEFT(s1.SIGN_DATE,4)<'2021','2021',LEFT(s1.SIGN_DATE,4)) AS N_CYEAR_D_PROFIT --'发单年度-营利性' ,if(LEFT(s1.SIGN_DATE,4)<'2021','2021',LEFT(s1.SIGN_DATE,4)) AS N_CYEAR_D_PROFIT /* '发单年度-营利性'*/
,s2.RISKCLASS AS N_RISKCLASS -- '风险类别|| 保障型 储蓄型' , ,s2.RISKCLASS AS N_RISKCLASS /* '风险类别|| 保障型 储蓄型' ,*/
,s2.PRDTYPE AS N_PRDTYPE -- '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' , ,s2.PRDTYPE AS N_PRDTYPE /* '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' ,*/
,s2.MDL AS MDL -- '适用模型|| BBA VFA PAA ' ,s2.MDL AS MDL /* '适用模型|| BBA VFA PAA '*/
,LOCALTIMESTAMP AS MEA_TIME -- '计量时间' ,LOCALTIMESTAMP AS MEA_TIME /* '计量时间'*/
,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 /* IFRS17_HAODS_SRDB IFRS17_HADWS_SRDB IFRS17_HAODS_MYSQL*/
FROM IFRS17.IFRS17_HAODS_MYSQL.HAODS_PERSONAL_PLCRICK s1 -- 保单险种明细_个人业务 FROM db_ifrs17hengan.HAODS_PERSONAL_PLCRICK s1 /* 保单险种明细_个人业务*/
LEFT JOIN IFRS17.IFRS17_HAODS_MYSQL.HADIM_PRDINFO s2 -- 产品基本信息 LEFT JOIN db_ifrs17hengan.HADIM_PRDINFO s2 /* 产品基本信息*/
ON s1.PLC_RISK_CODE = s2.PRDCODE ON s1.PLC_RISK_CODE = s2.PRDCODE
and ( and (
CASE CASE
......
HAPOC/3-HADWS/HADWS_PERSONAL_PLCRICK_OUT--个险现金流输出接口表.sql
View file @ bd9e5dfa
-- HADWS_PERSONAL_PLCRICK_OUT HADWS_个险现金流输出接口表 /* HADWS_PERSONAL_PLCRICK_OUT HADWS_个险现金流输出接口表*/
INSERT INTO IFRS17.IFRS17_HAODS_MYSQL.HADWS_PERSONAL_PLCRICK_OUT -- 个险现金流输出接口表 INSERT INTO db_ifrs17hengan.HADWS_PERSONAL_PLCRICK_OUT /* 个险现金流输出接口表*/
SELECT SELECT
DATAPKID AS DATAPKID -- 物理主键 DATAPKID AS DATAPKID /* 物理主键*/
,cast( '${MEA_YM}' as int) AS MEA_YM --'评估月' ,cast( '202401' as int) AS MEA_YM /*'评估月'*/
,s1.PLC_ID AS PLC_ID -- '保单号' , ,s1.PLC_ID AS PLC_ID /* '保单号' ,*/
,s1.N_PRD_CODE AS N_PRD_CODE -- '产品代码' , ,s1.N_PRD_CODE AS N_PRD_CODE /* '产品代码' ,*/
,s1.PLC_RISK_CODE AS PLC_RISK_CODE -- '险种号' , ,s1.PLC_RISK_CODE AS PLC_RISK_CODE /* '险种号' ,*/
,s1.GUAR_PERIOD AS GUAR_PERIOD -- '保障年期' , ,s1.GUAR_PERIOD AS GUAR_PERIOD /* '保障年期' ,*/
,s1.GUAR_PERIOD_UNITID AS GUAR_PERIOD_UNITID -- '保障年期类型 || 按年保 按年龄保' , ,s1.GUAR_PERIOD_UNITID AS GUAR_PERIOD_UNITID /* '保障年期类型 || 按年保 按年龄保' ,*/
,s1.PAY_FREQ AS PAY_FREQ -- '缴费频率 || 趸缴 月缴 不定期缴 年缴 季缴 半年缴' , ,s1.PAY_FREQ AS PAY_FREQ /* '缴费频率 || 趸缴 月缴 不定期缴 年缴 季缴 半年缴' ,*/
,s1.PAY_PERIOD AS PAY_PERIOD -- '缴费期限' , ,s1.PAY_PERIOD AS PAY_PERIOD /* '缴费期限' ,*/
,s1.PAY_PERIOD_UNITID AS PAY_PERIOD_UNITID -- '缴费年期类型' , ,s1.PAY_PERIOD_UNITID AS PAY_PERIOD_UNITID /* '缴费年期类型' ,*/
,s1.ORGID AS ORGID -- '分支机构' , ,s1.ORGID AS ORGID /* '分支机构' ,*/
,s1.BUSY_CHAN AS BUSY_CHAN -- '销售渠道代码' , ,s1.BUSY_CHAN AS BUSY_CHAN /* '销售渠道代码' ,*/
,s1.PLC_B_DATE AS PLC_B_DATE -- '保单生效日' , ,s1.PLC_B_DATE AS PLC_B_DATE /* '保单生效日' ,*/
,s1.SIGN_DATE AS SIGN_DATE -- '签单日期' , ,s1.SIGN_DATE AS SIGN_DATE /* '签单日期' ,*/
,s1.STAND_PREM AS STAND_PREM -- '标准保费' , ,s1.STAND_PREM AS STAND_PREM /* '标准保费' ,*/
,s1.N_SIX AS N_SIX -- '被保人性别 || 女 男' , ,s1.N_SIX AS N_SIX /* '被保人性别 || 女 男' ,*/
,s1.N_AGE AS N_AGE -- '被保险人投保时年龄' , ,s1.N_AGE AS N_AGE /* '被保险人投保时年龄' ,*/
,s1.YEAR_COVER AS YEAR_COVER -- '初始保额' , ,s1.YEAR_COVER AS YEAR_COVER /* '初始保额' ,*/
,s1.DIVID_COLL_METHOD AS DIVID_COLL_METHOD -- '生存金领取方式 || 自动给付 累计生息' , ,s1.DIVID_COLL_METHOD AS DIVID_COLL_METHOD /* '生存金领取方式 || 自动给付 累计生息' ,*/
,s1.N_CDX AS N_CDX -- '长短险标识 || 长险 短险 极短险' , ,s1.N_CDX AS N_CDX /* '长短险标识 || 长险 短险 极短险' ,*/
,s1.STS AS STS -- '保单状态' || 生效 满期终止 签单 保单退保 犹豫期退保' ,s1.STS AS STS /* '保单状态' || 生效 满期终止 签单 保单退保 犹豫期退保'*/
,s4.N_CYEAR_D AS N_CYEAR_D --'发单年度' ,s4.N_CYEAR_D AS N_CYEAR_D /*'发单年度'*/
,s1.N_CYEAR_D_PROFIT AS N_CYEAR_D_PROFIT --'发单年度-营利性' ,s1.N_CYEAR_D_PROFIT AS N_CYEAR_D_PROFIT /*'发单年度-营利性'*/
,s4.N_RISKCLASS AS N_RISKCLASS -- '风险类别|| 保障型 储蓄型' , ,s4.N_RISKCLASS AS N_RISKCLASS /* '风险类别|| 保障型 储蓄型' ,*/
,s4.N_PRDTYPE AS N_PRDTYPE -- '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' , ,s4.N_PRDTYPE AS N_PRDTYPE /* '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' ,*/
,s4.MDL AS MDL -- '适用模型|| BBA VFA PAA ' ,s4.MDL AS MDL /* '适用模型|| BBA VFA PAA '*/
,s4.N_PRDTYPE AS N_PROFIT_FLAG -- 营利性代码|| 1 2 3 ,s4.N_PRDTYPE AS N_PROFIT_FLAG /* 营利性代码|| 1 2 3*/
,s4.GRP_ID AS GRP_ID -- '合同组号' , ,s4.GRP_ID AS GRP_ID /* '合同组号' ,*/
,s4.N_GRP__ID AS N_GRP__ID -- '合同组合号' , ,s4.N_GRP__ID AS N_GRP__ID /* '合同组合号' ,*/
,ConcatObjUDF( ,CONCAT(
s4.N_PRDTYPE s4.N_PRDTYPE,','
,s4.N_CYEAR_D ,s4.N_CYEAR_D,','
,s4.N_PROFIT_FLAG ,s4.N_PROFIT_FLAG,','
, CASE , CASE
WHEN s4.N_CHNL in ('健康险事业部','寿险险事业部') THEN '事业部' WHEN s4.N_CHNL in ('健康险事业部','寿险险事业部') THEN '事业部'
ELSE s4.N_CHNL END ELSE s4.N_CHNL END,','
,s4.N_RISKCLASS ,s4.N_RISKCLASS
) AS GRP_ID_INSIDE -- '合同组号-内部' , ) AS GRP_ID_INSIDE /* '合同组号-内部' ,*/
,LOCALTIMESTAMP AS MEA_TIME -- '计量时间' ,LOCALTIMESTAMP AS MEA_TIME /* '计量时间'*/
,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 /* IFRS17_HAODS_SRDB IFRS17_HADWS_SRDB IFRS17_HAODS_MYSQL*/
FROM IFRS17.IFRS17_HAODS_MYSQL.HADWS_PERSONAL_PLCRICK_IN s1 -- 个险现金流输入接口表 FROM db_ifrs17hengan.HADWS_PERSONAL_PLCRICK_IN s1 /* 个险现金流输入接口表*/
LEFT JOIN IFRS17.IFRS17_HAODS_MYSQL.HADIM_LRISKPROF s2 -- 长险营利性配置信息 LEFT JOIN db_ifrs17hengan.HADIM_LRISKPROF s2 /* 长险营利性配置信息*/
ON s1.N_CDX ='长险' and s1.PLC_RISK_CODE = s2.PRDCODE and s1.BUSY_CHAN = s2.CHNL and s1.N_CYEAR_D_PROFIT = s2.CYEAR ON s1.N_CDX ='长险' and s1.PLC_RISK_CODE = s2.PRDCODE and s1.BUSY_CHAN = s2.CHNL and s1.N_CYEAR_D_PROFIT = s2.CYEAR
LEFT JOIN IFRS17.IFRS17_HAODS_MYSQL.HADIM_SRISKPROF s3 --短险营利性配置信息 LEFT JOIN db_ifrs17hengan.HADIM_SRISKPROF s3 /*短险营利性配置信息*/
ON s1.N_CDX ='短险' and s1.PLC_RISK_CODE = s3.PRDCODE ON s1.N_CDX ='短险' and s1.PLC_RISK_CODE = s3.PRDCODE
LEFT JOIN IFRS17.IFRS17_HAODS_MYSQL.HAODS_EXT_CONCATINFO s4 --合同分组基本信息 LEFT JOIN db_ifrs17hengan.HAODS_EXT_CONCATINFO s4 /*合同分组基本信息*/
ON s1.N_PRDTYPE = s4.N_PRDTYPE -- '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' ON s1.N_PRDTYPE = s4.N_PRDTYPE /* '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 '*/
and s1.N_CYEAR_D = s4.N_CYEAR_D and s1.N_CYEAR_D = s4.N_CYEAR_D
and COALESCE(s2.PROFIT_FLAG ,s3.PROFIT_FLAG ) = s4.N_PROFIT_FLAG and COALESCE(s2.PROFIT_FLAG ,s3.PROFIT_FLAG ) = s4.N_PROFIT_FLAG
and s1.BUSY_CHAN = ( and s1.BUSY_CHAN = (
...@@ -69,6 +69,6 @@ LEFT JOIN IFRS17.IFRS17_HAODS_MYSQL.HAODS_EXT_CONCATINFO s4 --合同分组基 ...@@ -69,6 +69,6 @@ LEFT JOIN IFRS17.IFRS17_HAODS_MYSQL.HAODS_EXT_CONCATINFO s4 --合同分组基
and s1.N_RISKCLASS = s4.N_RISKCLASS and s1.N_RISKCLASS = s4.N_RISKCLASS
where where
s4.GRP_ID is not null s4.GRP_ID is not null
and s1.MEA_YM = cast('${MEA_YM}' as int) and s1.MEA_YM = cast('202401' as int)
HAPOC/3-HADWS/HADWS_TEAM_PLCRICK_IN--团险现金流输入接口表.sql
View file @ bd9e5dfa
-- HADWS_TEAM_PLCRICK_IN HADWS_团险现金流输入接口表 /* HADWS_TEAM_PLCRICK_IN HADWS_团险现金流输入接口表 */
INSERT INTO IFRS17.IFRS17_HAODS_MYSQL.HADWS_TEAM_PLCRICK_IN --团险现金流输入接口表 INSERT INTO db_ifrs17hengan.HADWS_TEAM_PLCRICK_IN /*团险现金流输入接口表*/
SELECT SELECT
MD5(ConcatObjUDF('${MEA_YM}' MD5(concat('202401'
,GRP_INS_PLC_ID ,GRP_INS_PLC_ID
,PLC_RISK_CODE ,PLC_RISK_CODE
,PERSONAL_RISK_CODE ,PERSONAL_RISK_CODE
)) ))
AS DATAPKID -- 物理主键 AS DATAPKID /* 物理主键*/
,cast( '${MEA_YM}' as int) AS MEA_YM --'评估月' ,cast( '202401' 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 /* '保单号' ,*/
,s1.N_PRD_CODE AS N_PRD_CODE -- '产品代码' , ,s1.N_PRD_CODE AS N_PRD_CODE /* '产品代码' ,*/
,s1.PLC_RISK_CODE AS PLC_RISK_CODE -- '险种号' , ,s1.PLC_RISK_CODE AS PLC_RISK_CODE /* '险种号' ,*/
,s1.GUAR_PERIOD AS GUAR_PERIOD -- '保障年期' , ,s1.GUAR_PERIOD AS GUAR_PERIOD /* '保障年期' ,*/
,s1.GUAR_PERIOD_UNITID AS GUAR_PERIOD_UNITID -- '保障年期类型 || Y D M A' , ,s1.GUAR_PERIOD_UNITID AS GUAR_PERIOD_UNITID /* '保障年期类型 || Y D M A' ,*/
,s1.PAY_FREQ AS PAY_FREQ -- '缴费频率 || 趸缴 月缴 不定期缴 年缴 季缴 半年缴' , ,s1.PAY_FREQ AS PAY_FREQ /* '缴费频率 || 趸缴 月缴 不定期缴 年缴 季缴 半年缴' ,*/
,s1.PAY_PERIOD AS PAY_PERIOD -- '缴费期限' , ,s1.PAY_PERIOD AS PAY_PERIOD /* '缴费期限' ,*/
,s1.PAY_PERIOD_UNITID AS PAY_PERIOD_UNITID -- '缴费年期类型 || Y D M A' , ,s1.PAY_PERIOD_UNITID AS PAY_PERIOD_UNITID /* '缴费年期类型 || Y D M A' ,*/
,s1.ORGID AS ORGID -- '分支机构' , ,s1.ORGID AS ORGID /* '分支机构' ,*/
,s2.CHNL AS BUSY_CHAN -- '销售渠道代码' , ,s2.CHNL AS BUSY_CHAN /* '销售渠道代码' ,*/
,s1.PLC_B_DATE AS PLC_B_DATE -- '保单生效日' , ,s1.PLC_B_DATE AS PLC_B_DATE /* '保单生效日' ,*/
,s1.SIGN_DATE AS SIGN_DATE -- '签单日期' , ,s1.SIGN_DATE AS SIGN_DATE /* '签单日期' ,*/
,cast(s1.STAND_PREM as decimal(18,4)) AS STAND_PREM -- '标准保费' , ,cast(s1.STAND_PREM as decimal(18,4)) AS STAND_PREM /* '标准保费' ,*/
,s1.N_SIX AS N_SIX -- '被保人性别 || 0 1 2' , ,s1.N_SIX AS N_SIX /* '被保人性别 || 0 1 2' ,*/
,s1.N_AGE AS N_AGE -- '被保险人投保时年龄' , ,s1.N_AGE AS N_AGE /* '被保险人投保时年龄' ,*/
,cast(s1.YEAR_COVER as decimal(18,4)) AS YEAR_COVER -- '初始保额' , ,cast(s1.YEAR_COVER as decimal(18,4)) AS YEAR_COVER /* '初始保额' ,*/
,s1.DIVID_COLL_METHOD AS DIVID_COLL_METHOD -- '生存金领取方式 || 满期一次性领取' , ,s1.DIVID_COLL_METHOD AS DIVID_COLL_METHOD /* '生存金领取方式 || 满期一次性领取' ,*/
,s1.N_CDX AS N_CDX -- '长短险标识 || M L' , ,s1.N_CDX AS N_CDX /* '长短险标识 || M L' ,*/
,s1.STS AS STS -- '保单状态 || 生效 满期终止 签单 保单退保 犹豫期退保' ,s1.STS AS STS /* '保单状态 || 生效 满期终止 签单 保单退保 犹豫期退保'*/
,s1.PERSONAL_RISK_CODE AS PERSONAL_RISK_CODE -- 个人险种号 ,s1.PERSONAL_RISK_CODE AS PERSONAL_RISK_CODE /* 个人险种号*/
,LEFT(s1.SIGN_DATE,4) AS N_CYEAR_D -- '发单年度' ,LEFT(s1.SIGN_DATE,4) AS N_CYEAR_D /* '发单年度'*/
,s2.RISKCLASS AS N_RISKCLASS -- '风险类别|| 保障型 储蓄型' , ,s2.RISKCLASS AS N_RISKCLASS /* '风险类别|| 保障型 储蓄型' ,*/
,s2.PRDTYPE AS N_PRDTYPE -- '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' , ,s2.PRDTYPE AS N_PRDTYPE /* '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' ,*/
,s2.MDL AS MDL -- '适用模型|| BBA VFA PAA ' ,s2.MDL AS MDL /* '适用模型|| BBA VFA PAA '*/
,LOCALTIMESTAMP AS MEA_TIME -- '计量时间' ,LOCALTIMESTAMP AS MEA_TIME /* '计量时间'*/
,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 /* IFRS17_HAODS_SRDB IFRS17_HADWS_SRDB IFRS17_HAODS_MYSQL*/
FROM db_ifrs17hengan.HAODS_TEAM_PLCRICK s1 /*保单险种明细数据_团险*/
FROM IFRS17.IFRS17_HAODS_MYSQL.HAODS_TEAM_PLCRICK s1 --保单险种明细数据_团险 LEFT JOIN db_ifrs17hengan.HADIM_PRDINFO s2 /* 产品基本信息*/
LEFT JOIN IFRS17.IFRS17_HAODS_MYSQL.HADIM_PRDINFO s2 -- 产品基本信息
ON s1.PLC_RISK_CODE = s2.PRDCODE ON s1.PLC_RISK_CODE = s2.PRDCODE
and s2.CHNL = 'BK' -- 团险得渠道全是团险 and s2.CHNL = 'GP' /* 团险得渠道全是团险 BK 没数据*/
WHERE s2.PRDCODE is not null WHERE s2.PRDCODE is not null
......
HAPOC/3-HADWS/HADWS_TEAM_PLCRICK_OUT--团险现金流输出接口表.sql
View file @ bd9e5dfa
-- HADWS_TEAM_PLCRICK_OUT HADWS_团险现金流输出接口表 /* HADWS_TEAM_PLCRICK_OUT HADWS_团险现金流输出接口表*/
INSERT INTO IFRS17.IFRS17_HAODS_MYSQL.HADWS_TEAM_PLCRICK_OUT --团险现金流输出接口表 INSERT INTO db_ifrs17hengan.HADWS_TEAM_PLCRICK_OUT /*团险现金流输出接口表*/
SELECT SELECT
DATAPKID AS DATAPKID -- 物理主键 DATAPKID AS DATAPKID /* 物理主键*/
,cast( '${MEA_YM}' as int) AS MEA_YM --'评估月' ,cast( '202401' 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 /* '保单号' ,*/
,s1.N_PRD_CODE AS N_PRD_CODE -- '产品代码' , ,s1.N_PRD_CODE AS N_PRD_CODE /* '产品代码' ,*/
,s1.PLC_RISK_CODE AS PLC_RISK_CODE -- '险种号' , ,s1.PLC_RISK_CODE AS PLC_RISK_CODE /* '险种号' ,*/
,s1.GUAR_PERIOD AS GUAR_PERIOD -- '保障年期' , ,s1.GUAR_PERIOD AS GUAR_PERIOD /* '保障年期' ,*/
,s1.GUAR_PERIOD_UNITID AS GUAR_PERIOD_UNITID -- '保障年期类型 || Y D M A' , ,s1.GUAR_PERIOD_UNITID AS GUAR_PERIOD_UNITID /* '保障年期类型 || Y D M A' ,*/
,s1.PAY_FREQ AS PAY_FREQ -- '缴费频率 || 趸缴 月缴 不定期缴 年缴 季缴 半年缴' , ,s1.PAY_FREQ AS PAY_FREQ /* '缴费频率 || 趸缴 月缴 不定期缴 年缴 季缴 半年缴' ,*/
,s1.PAY_PERIOD AS PAY_PERIOD -- '缴费期限' , ,s1.PAY_PERIOD AS PAY_PERIOD /* '缴费期限' ,*/
,s1.PAY_PERIOD_UNITID AS PAY_PERIOD_UNITID -- '缴费年期类型 || Y D M A' , ,s1.PAY_PERIOD_UNITID AS PAY_PERIOD_UNITID /* '缴费年期类型 || Y D M A' ,*/
,s1.ORGID AS ORGID -- '分支机构' , ,s1.ORGID AS ORGID /* '分支机构' ,*/
,s1.BUSY_CHAN AS BUSY_CHAN -- '销售渠道代码' , ,s1.BUSY_CHAN AS BUSY_CHAN /* '销售渠道代码' ,*/
,s1.PLC_B_DATE AS PLC_B_DATE -- '保单生效日' , ,s1.PLC_B_DATE AS PLC_B_DATE /* '保单生效日' ,*/
,s1.SIGN_DATE AS SIGN_DATE -- '签单日期' , ,s1.SIGN_DATE AS SIGN_DATE /* '签单日期' ,*/
,s1.STAND_PREM AS STAND_PREM -- '标准保费' , ,s1.STAND_PREM AS STAND_PREM /* '标准保费' ,*/
,s1.N_SIX AS N_SIX -- '被保人性别 || 0 1 2' , ,s1.N_SIX AS N_SIX /* '被保人性别 || 0 1 2' ,*/
,s1.N_AGE AS N_AGE -- '被保险人投保时年龄' , ,s1.N_AGE AS N_AGE /* '被保险人投保时年龄' ,*/
,s1.YEAR_COVER AS YEAR_COVER -- '初始保额' , ,s1.YEAR_COVER AS YEAR_COVER /* '初始保额' ,*/
,s1.DIVID_COLL_METHOD AS DIVID_COLL_METHOD -- '生存金领取方式 || 满期一次性领取' , ,s1.DIVID_COLL_METHOD AS DIVID_COLL_METHOD /* '生存金领取方式 || 满期一次性领取' ,*/
,s1.N_CDX AS N_CDX -- '长短险标识 || M L' , ,s1.N_CDX AS N_CDX /* '长短险标识 || M L' ,*/
,s1.STS AS STS -- '保单状态 || 生效 满期终止 签单 保单退保 犹豫期退保' ,s1.STS AS STS /* '保单状态 || 生效 满期终止 签单 保单退保 犹豫期退保'*/
,s1.PERSONAL_RISK_CODE AS PERSONAL_RISK_CODE -- 个人险种号 ,s1.PERSONAL_RISK_CODE AS PERSONAL_RISK_CODE /* 个人险种号*/
,s4.N_CYEAR_D AS N_CYEAR_D -- '发单年度' ,s4.N_CYEAR_D AS N_CYEAR_D /* '发单年度'*/
,s4.N_RISKCLASS AS N_RISKCLASS -- '风险类别|| 保障型 储蓄型' , ,s4.N_RISKCLASS AS N_RISKCLASS /* '风险类别|| 保障型 储蓄型' ,*/
,s4.N_PRDTYPE AS N_PRDTYPE -- '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' , ,s4.N_PRDTYPE AS N_PRDTYPE /* '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' ,*/
,s4.MDL AS MDL -- '适用模型|| BBA VFA PAA ' ,s4.MDL AS MDL /* '适用模型|| BBA VFA PAA '*/
,s3.PROFIT_FLAG AS N_PROFIT_FLAG -- 营利性代码|| 1 2 3 ,s3.PROFIT_FLAG AS N_PROFIT_FLAG /* 营利性代码|| 1 2 3*/
,s4.GRP_ID AS GRP_ID -- '合同组号' , ,s4.GRP_ID AS GRP_ID /* '合同组号' ,*/
,s4.N_GRP__ID AS N_GRP__ID -- '合同组合号' , ,s4.N_GRP__ID AS N_GRP__ID /* '合同组合号' ,*/
,ConcatObjUDF( ,concat(
s4.N_PRDTYPE s4.N_PRDTYPE ,','
,s4.N_CYEAR_D ,s4.N_CYEAR_D,','
,s4.N_PROFIT_FLAG ,s4.N_PROFIT_FLAG,','
,s4.N_CHNL ,s4.N_CHNL,','
,s4.N_RISKCLASS ,s4.N_RISKCLASS
) AS GRP_ID_INSIDE -- '合同组号-内部' , ) AS GRP_ID_INSIDE /* '合同组号-内部' ,*/
,LOCALTIMESTAMP AS MEA_TIME -- '计量时间' ,LOCALTIMESTAMP AS MEA_TIME /* '计量时间'*/
,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 /* IFRS17_HAODS_SRDB IFRS17_HADWS_SRDB IFRS17_HAODS_MYSQL
*/
FROM IFRS17.IFRS17_HAODS_MYSQL.HADWS_TEAM_PLCRICK_IN s1 -- 团险现金流输入接口表 FROM db_ifrs17hengan.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*/
LEFT JOIN IFRS17.IFRS17_HAODS_MYSQL.HADIM_SRISKPROF s3 --短险营利性配置信息 LEFT JOIN db_ifrs17hengan.HADIM_SRISKPROF s3 /*短险营利性配置信息*/
ON s1.N_CDX ='M' and s1.PLC_RISK_CODE = s3.PRDCODE ON s1.N_CDX ='M' and s1.PLC_RISK_CODE = s3.PRDCODE
LEFT JOIN IFRS17.IFRS17_HAODS_MYSQL.HAODS_EXT_CONCATINFO s4 --合同分组基本信息 LEFT JOIN db_ifrs17hengan.HAODS_EXT_CONCATINFO s4 /*合同分组基本信息*/
ON s1.N_PRDTYPE = s4.N_PRDTYPE ON s1.N_PRDTYPE = s4.N_PRDTYPE
and s1.N_CYEAR_D = s4.N_CYEAR_D and s1.N_CYEAR_D = s4.N_CYEAR_D
and s3.PROFIT_FLAG = s4.N_PROFIT_FLAG and s3.PROFIT_FLAG = s4.N_PROFIT_FLAG
...@@ -58,7 +58,7 @@ LEFT JOIN IFRS17.IFRS17_HAODS_MYSQL.HAODS_EXT_CONCATINFO s4 --合同分组基 ...@@ -58,7 +58,7 @@ LEFT JOIN IFRS17.IFRS17_HAODS_MYSQL.HAODS_EXT_CONCATINFO s4 --合同分组基
where where
s4.GRP_ID is NOT NULL s4.GRP_ID is NOT NULL
AND s1.MEA_YM = cast('${MEA_YM}' as int) AND s1.MEA_YM = cast('202401' as int)
HAPOC/3-HADWS_1/HADWS_CONCAT_MANAGE--合同组管理费用_直接部分表.sql → HAPOC/3-HADWS/back/HADWS_CONCAT_MANAGE--合同组管理费用_直接部分表.sql
View file @ bd9e5dfa
/*HADWS_CONCAT_MANAGE HADWS_合同组管理费用_直接部分表*/ -- HADWS_CONCAT_MANAGE HADWS_合同组管理费用_直接部分表
INSERT INTO db_ifrs17hengan.HADWS_CONCAT_MANAGE /* 合同组管理费用_直接部分表*/ INSERT INTO IFRS17.IFRS17_HAODS_MYSQL.HADWS_CONCAT_MANAGE -- 合同组管理费用_直接部分表
SELECT SELECT
MD5(concat(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 -- 物理主键
, GRP_ID AS GRP_ID /* '合同组号' ,*/ , GRP_ID AS GRP_ID -- '合同组号' ,
, MEA_YM AS MEA_YM /* '评估月'*/ , MEA_YM AS MEA_YM -- '评估月'
, COALESCE(N_PRDTYPE,'') AS N_PRDTYPE /* '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' ,*/ , COALESCE(N_PRDTYPE,'') AS N_PRDTYPE -- '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' ,
, COALESCE(BUSY_CHAN,'') AS BUSY_CHAN /* '销售渠道代码' ,*/ , COALESCE(BUSY_CHAN,'') AS BUSY_CHAN -- '销售渠道代码' ,
, COALESCE(N_CDX ,'') AS N_CDX /* '长短险标识 || 长险 短险 极短险' ,*/ , COALESCE(N_CDX ,'') AS N_CDX -- '长短险标识 || 长险 短险 极短险' ,
, '' AS P_FLAG , '' AS P_FLAG
, SUM(IACF_INS_OUT) AS IACF_INS_OUT /* 期末_实际_IACF_直接部分,*/ , SUM(IACF_INS_OUT) AS IACF_INS_OUT -- 期末_实际_IACF_直接部分,
, SUM(ISE_INS_OUT ) AS ISE_INS_OUT /* 期末_实际_当期_维持费用_直接部分*/ , SUM(ISE_INS_OUT ) AS ISE_INS_OUT -- 期末_实际_当期_维持费用_直接部分
, LOCALTIMESTAMP AS MEA_TIME /* '计量时间'*/ , LOCALTIMESTAMP AS MEA_TIME -- '计量时间'
, LOCALTIMESTAMP AS ARC_TIME /* '归档时间'*/ , LOCALTIMESTAMP AS ARC_TIME -- '归档时间'
, '' AS MEA_BAT /* '计量批次'*/ , '' AS MEA_BAT -- '计量批次'
, '' AS ARC_BAT /* '归档批次'*/ , '' AS ARC_BAT -- '归档批次'
FROM( FROM(
SELECT 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 -- '评估月'
,s1.N_PRDTYPE AS N_PRDTYPE /*'产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' ,*/ ,s1.N_PRDTYPE AS N_PRDTYPE -- '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' ,
,s1.BUSY_CHAN AS BUSY_CHAN /*'销售渠道代码' ,*/ ,s1.BUSY_CHAN AS BUSY_CHAN -- '销售渠道代码' ,
,s1.N_CDX AS N_CDX /*'长短险标识 || 长险 短险 极短险' ,*/ ,s1.N_CDX AS N_CDX -- '长短险标识 || 长险 短险 极短险' ,
,'1' AS P_FLAG /*'团险个险标记|| 1 个单, 2 团单',*/ ,'1' AS P_FLAG -- '团险个险标记|| 1 个单, 2 团单',
,( ,(
CASE CASE
WHEN s1.BUSY_CHAN = 'FC' THEN STAND_PREM * 0.50 + 250.0 WHEN s1.BUSY_CHAN = 'FC' THEN STAND_PREM * 0.50 + 250.0
...@@ -33,7 +33,7 @@ FROM( ...@@ -33,7 +33,7 @@ FROM(
WHEN s1.BUSY_CHAN = 'BK' THEN STAND_PREM * 0.12 + 250.0 WHEN s1.BUSY_CHAN = 'BK' THEN STAND_PREM * 0.12 + 250.0
WHEN s1.BUSY_CHAN = 'EC' THEN STAND_PREM * 0.05 + 25.0 WHEN s1.BUSY_CHAN = 'EC' THEN STAND_PREM * 0.05 + 25.0
ELSE 0.0 END ELSE 0.0 END
) AS IACF_INS_OUT /*期末_实际_IACF_直接部分,*/ ) AS IACF_INS_OUT -- 期末_实际_IACF_直接部分,
,( ,(
CASE CASE
...@@ -45,21 +45,21 @@ FROM( ...@@ -45,21 +45,21 @@ FROM(
THEN STAND_PREM * 0.00165 + 6.5 THEN STAND_PREM * 0.00165 + 6.5
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*/ -- IFRS17_HAODS_SRDB IFRS17_HADWS_SRDB IFRS17_HAODS_MYSQL
FROM db_ifrs17hengan.HADWS_PERSONAL_PLCRICK_OUT s1 /*个险现金流输出接口表*/ FROM IFRS17.IFRS17_HAODS_MYSQL.HADWS_PERSONAL_PLCRICK_OUT s1 -- 个险现金流输出接口表
where s1.MEA_YM = cast('202401' as int) where s1.MEA_YM = cast('${MEA_YM}' as int)
union all union all
SELECT 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 -- '评估月'
,s1.N_PRDTYPE AS N_PRDTYPE /* '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' ,*/ ,s1.N_PRDTYPE AS N_PRDTYPE -- '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' ,
,s1.BUSY_CHAN AS BUSY_CHAN /* '销售渠道代码' ,*/ ,s1.BUSY_CHAN AS BUSY_CHAN -- '销售渠道代码' ,
,s1.N_CDX AS N_CDX /* '长短险标识 || 长险 短险 极短险' ,*/ ,s1.N_CDX AS N_CDX -- '长短险标识 || 长险 短险 极短险' ,
,'2' AS P_FLAG /* '团险个险标记|| 1 个单, 2 团单',*/ ,'2' AS P_FLAG -- '团险个险标记|| 1 个单, 2 团单',
,( ,(
CASE CASE
WHEN s1.BUSY_CHAN = 'FC' THEN STAND_PREM * 0.50 + 250.0 WHEN s1.BUSY_CHAN = 'FC' THEN STAND_PREM * 0.50 + 250.0
...@@ -68,7 +68,7 @@ FROM( ...@@ -68,7 +68,7 @@ FROM(
WHEN s1.BUSY_CHAN = 'BK' THEN STAND_PREM * 0.12 + 250.0 WHEN s1.BUSY_CHAN = 'BK' THEN STAND_PREM * 0.12 + 250.0
WHEN s1.BUSY_CHAN = 'EC' THEN STAND_PREM * 0.05 + 25.0 WHEN s1.BUSY_CHAN = 'EC' THEN STAND_PREM * 0.05 + 25.0
ELSE 0.0 END ELSE 0.0 END
) AS IACF_INS_OUT /*期末_实际_IACF_直接部分,*/ ) AS IACF_INS_OUT -- 期末_实际_IACF_直接部分,
,( ,(
CASE CASE
...@@ -80,10 +80,10 @@ FROM( ...@@ -80,10 +80,10 @@ FROM(
THEN STAND_PREM * 0.00165 + 6.5 THEN STAND_PREM * 0.00165 + 6.5
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 -- 期末_实际_当期_维持费用_直接部分
FROM db_ifrs17hengan.HADWS_TEAM_PLCRICK_OUT s1 /*团险现金流输出接口表*/ FROM IFRS17.IFRS17_HAODS_MYSQL.HADWS_TEAM_PLCRICK_OUT s1 -- 团险现金流输出接口表
where s1.MEA_YM = cast('202401' as int) where s1.MEA_YM = cast('${MEA_YM}' as int)
) d1 ) d1
GROUP BY GROUP BY
GRP_ID GRP_ID
......
HAPOC/3-HADWS/back/HADWS_CONTACT_MEAS_REL--合同组计量内外关系表.sql 0 → 100644
View file @ bd9e5dfa
-- 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_1/HADWS_PERSONAL_PLCRICK_IN--个险现金流输入接口表.sql → HAPOC/3-HADWS/back/HADWS_PERSONAL_PLCRICK_IN--个险现金流输入接口表.sql
View file @ bd9e5dfa
/*HADWS_PERSONAL_PLCRICK_IN HADWS_个险现金流输入接口表*/ -- HADWS_PERSONAL_PLCRICK_IN HADWS_个险现金流输入接口表
INSERT INTO db_ifrs17hengan.HADWS_PERSONAL_PLCRICK_IN /* 个险现金流输入接口表*/ INSERT INTO IFRS17.IFRS17_HAODS_MYSQL.HADWS_PERSONAL_PLCRICK_IN -- 个险现金流输入接口表
SELECT SELECT
MD5(concat( '202401',s1.PLC_ID)) MD5(ConcatObjUDF( '${MEA_YM}',s1.PLC_ID))
AS DATAPKID /* 物理主键*/ AS DATAPKID -- 物理主键
,cast('202401' as int) AS MEA_YM /* '评估月'*/ ,cast('${MEA_YM}' as int) AS MEA_YM --'评估月'
,s1.PLC_ID AS PLC_ID /* '保单号' ,*/ ,s1.PLC_ID AS PLC_ID -- '保单号' ,
,s1.N_PRD_CODE AS N_PRD_CODE /* '产品代码' ,*/ ,s1.N_PRD_CODE AS N_PRD_CODE -- '产品代码' ,
,s1.PLC_RISK_CODE AS PLC_RISK_CODE /* '险种号' ,*/ ,s1.PLC_RISK_CODE AS PLC_RISK_CODE -- '险种号' ,
,s1.GUAR_PERIOD AS GUAR_PERIOD /* '保障年期' ,*/ ,s1.GUAR_PERIOD AS GUAR_PERIOD -- '保障年期' ,
,s1.GUAR_PERIOD_UNITID AS GUAR_PERIOD_UNITID /* '保障年期类型 || 按年保 按年龄保' ,*/ ,s1.GUAR_PERIOD_UNITID AS GUAR_PERIOD_UNITID -- '保障年期类型 || 按年保 按年龄保' ,
,s1.PAY_FREQ AS PAY_FREQ /* '缴费频率 || 趸缴 月缴 不定期缴 年缴 季缴 半年缴' ,*/ ,s1.PAY_FREQ AS PAY_FREQ -- '缴费频率 || 趸缴 月缴 不定期缴 年缴 季缴 半年缴' ,
,s1.PAY_PERIOD AS PAY_PERIOD /* '缴费期限' ,*/ ,s1.PAY_PERIOD AS PAY_PERIOD -- '缴费期限' ,
,s1.PAY_PERIOD_UNITID AS PAY_PERIOD_UNITID /* '缴费年期类型' ,*/ ,s1.PAY_PERIOD_UNITID AS PAY_PERIOD_UNITID -- '缴费年期类型' ,
,s1.ORGID AS ORGID /* '分支机构' ,*/ ,s1.ORGID AS ORGID -- '分支机构' ,
,s2.CHNL AS BUSY_CHAN /* '销售渠道代码' ,*/ ,s2.CHNL AS BUSY_CHAN -- '销售渠道代码' ,
,s1.PLC_B_DATE AS PLC_B_DATE /* '保单生效日' ,*/ ,s1.PLC_B_DATE AS PLC_B_DATE -- '保单生效日' ,
,s1.SIGN_DATE AS SIGN_DATE /* '签单日期' ,*/ ,s1.SIGN_DATE AS SIGN_DATE -- '签单日期' ,
,cast(s1.STAND_PREM as decimal(18,4)) AS STAND_PREM /* '标准保费' ,*/ ,cast(s1.STAND_PREM as decimal(18,4)) AS STAND_PREM -- '标准保费' ,
,s1.N_SIX AS N_SIX /* '被保人性别 || 女 男' ,*/ ,s1.N_SIX AS N_SIX -- '被保人性别 || 女 男' ,
,s1.N_AGE AS N_AGE /* '被保险人投保时年龄' ,*/ ,s1.N_AGE AS N_AGE -- '被保险人投保时年龄' ,
,cast(s1.YEAR_COVER as decimal(18,4)) AS YEAR_COVER /* '初始保额' ,*/ ,cast(s1.YEAR_COVER as decimal(18,4)) AS YEAR_COVER -- '初始保额' ,
,s1.DIVID_COLL_METHOD AS DIVID_COLL_METHOD /* '生存金领取方式 || 自动给付 累计生息' ,*/ ,s1.DIVID_COLL_METHOD AS DIVID_COLL_METHOD -- '生存金领取方式 || 自动给付 累计生息' ,
,s1.N_CDX AS N_CDX /* '长短险标识 || 长险 短险 极短险' ,*/ ,s1.N_CDX AS N_CDX -- '长短险标识 || 长险 短险 极短险' ,
,s1.STS AS STS /* '保单状态' || 生效 满期终止 签单 保单退保 犹豫期退保'*/ ,s1.STS AS STS -- '保单状态' || 生效 满期终止 签单 保单退保 犹豫期退保'
,LEFT(s1.SIGN_DATE,4) AS N_CYEAR_D /* '发单年度'*/ ,LEFT(s1.SIGN_DATE,4) AS N_CYEAR_D --'发单年度'
,if(LEFT(s1.SIGN_DATE,4)<'2021','2021',LEFT(s1.SIGN_DATE,4)) AS N_CYEAR_D_PROFIT /* '发单年度-营利性'*/ ,if(LEFT(s1.SIGN_DATE,4)<'2021','2021',LEFT(s1.SIGN_DATE,4)) AS N_CYEAR_D_PROFIT --'发单年度-营利性'
,s2.RISKCLASS AS N_RISKCLASS /* '风险类别|| 保障型 储蓄型' ,*/ ,s2.RISKCLASS AS N_RISKCLASS -- '风险类别|| 保障型 储蓄型' ,
,s2.PRDTYPE AS N_PRDTYPE /* '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' ,*/ ,s2.PRDTYPE AS N_PRDTYPE -- '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' ,
,s2.MDL AS MDL /* '适用模型|| BBA VFA PAA '*/ ,s2.MDL AS MDL -- '适用模型|| BBA VFA PAA '
,LOCALTIMESTAMP AS MEA_TIME /* '计量时间'*/ ,LOCALTIMESTAMP AS MEA_TIME -- '计量时间'
,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*/ -- IFRS17_HAODS_SRDB IFRS17_HADWS_SRDB IFRS17_HAODS_MYSQL
FROM db_ifrs17hengan.HAODS_PERSONAL_PLCRICK s1 /* 保单险种明细_个人业务*/ FROM IFRS17.IFRS17_HAODS_MYSQL.HAODS_PERSONAL_PLCRICK s1 -- 保单险种明细_个人业务
LEFT JOIN db_ifrs17hengan.HADIM_PRDINFO s2 /* 产品基本信息*/ LEFT JOIN IFRS17.IFRS17_HAODS_MYSQL.HADIM_PRDINFO s2 -- 产品基本信息
ON s1.PLC_RISK_CODE = s2.PRDCODE ON s1.PLC_RISK_CODE = s2.PRDCODE
and ( and (
CASE CASE
......
HAPOC/3-HADWS_1/HADWS_PERSONAL_PLCRICK_OUT--个险现金流输出接口表.sql → HAPOC/3-HADWS/back/HADWS_PERSONAL_PLCRICK_OUT--个险现金流输出接口表.sql
View file @ bd9e5dfa
/* HADWS_PERSONAL_PLCRICK_OUT HADWS_个险现金流输出接口表*/ -- HADWS_PERSONAL_PLCRICK_OUT HADWS_个险现金流输出接口表
INSERT INTO db_ifrs17hengan.HADWS_PERSONAL_PLCRICK_OUT /* 个险现金流输出接口表*/ INSERT INTO IFRS17.IFRS17_HAODS_MYSQL.HADWS_PERSONAL_PLCRICK_OUT -- 个险现金流输出接口表
SELECT SELECT
DATAPKID AS DATAPKID /* 物理主键*/ DATAPKID AS DATAPKID -- 物理主键
,cast( '202401' as int) AS MEA_YM /*'评估月'*/ ,cast( '${MEA_YM}' as int) AS MEA_YM --'评估月'
,s1.PLC_ID AS PLC_ID /* '保单号' ,*/ ,s1.PLC_ID AS PLC_ID -- '保单号' ,
,s1.N_PRD_CODE AS N_PRD_CODE /* '产品代码' ,*/ ,s1.N_PRD_CODE AS N_PRD_CODE -- '产品代码' ,
,s1.PLC_RISK_CODE AS PLC_RISK_CODE /* '险种号' ,*/ ,s1.PLC_RISK_CODE AS PLC_RISK_CODE -- '险种号' ,
,s1.GUAR_PERIOD AS GUAR_PERIOD /* '保障年期' ,*/ ,s1.GUAR_PERIOD AS GUAR_PERIOD -- '保障年期' ,
,s1.GUAR_PERIOD_UNITID AS GUAR_PERIOD_UNITID /* '保障年期类型 || 按年保 按年龄保' ,*/ ,s1.GUAR_PERIOD_UNITID AS GUAR_PERIOD_UNITID -- '保障年期类型 || 按年保 按年龄保' ,
,s1.PAY_FREQ AS PAY_FREQ /* '缴费频率 || 趸缴 月缴 不定期缴 年缴 季缴 半年缴' ,*/ ,s1.PAY_FREQ AS PAY_FREQ -- '缴费频率 || 趸缴 月缴 不定期缴 年缴 季缴 半年缴' ,
,s1.PAY_PERIOD AS PAY_PERIOD /* '缴费期限' ,*/ ,s1.PAY_PERIOD AS PAY_PERIOD -- '缴费期限' ,
,s1.PAY_PERIOD_UNITID AS PAY_PERIOD_UNITID /* '缴费年期类型' ,*/ ,s1.PAY_PERIOD_UNITID AS PAY_PERIOD_UNITID -- '缴费年期类型' ,
,s1.ORGID AS ORGID /* '分支机构' ,*/ ,s1.ORGID AS ORGID -- '分支机构' ,
,s1.BUSY_CHAN AS BUSY_CHAN /* '销售渠道代码' ,*/ ,s1.BUSY_CHAN AS BUSY_CHAN -- '销售渠道代码' ,
,s1.PLC_B_DATE AS PLC_B_DATE /* '保单生效日' ,*/ ,s1.PLC_B_DATE AS PLC_B_DATE -- '保单生效日' ,
,s1.SIGN_DATE AS SIGN_DATE /* '签单日期' ,*/ ,s1.SIGN_DATE AS SIGN_DATE -- '签单日期' ,
,s1.STAND_PREM AS STAND_PREM /* '标准保费' ,*/ ,s1.STAND_PREM AS STAND_PREM -- '标准保费' ,
,s1.N_SIX AS N_SIX /* '被保人性别 || 女 男' ,*/ ,s1.N_SIX AS N_SIX -- '被保人性别 || 女 男' ,
,s1.N_AGE AS N_AGE /* '被保险人投保时年龄' ,*/ ,s1.N_AGE AS N_AGE -- '被保险人投保时年龄' ,
,s1.YEAR_COVER AS YEAR_COVER /* '初始保额' ,*/ ,s1.YEAR_COVER AS YEAR_COVER -- '初始保额' ,
,s1.DIVID_COLL_METHOD AS DIVID_COLL_METHOD /* '生存金领取方式 || 自动给付 累计生息' ,*/ ,s1.DIVID_COLL_METHOD AS DIVID_COLL_METHOD -- '生存金领取方式 || 自动给付 累计生息' ,
,s1.N_CDX AS N_CDX /* '长短险标识 || 长险 短险 极短险' ,*/ ,s1.N_CDX AS N_CDX -- '长短险标识 || 长险 短险 极短险' ,
,s1.STS AS STS /* '保单状态' || 生效 满期终止 签单 保单退保 犹豫期退保'*/ ,s1.STS AS STS -- '保单状态' || 生效 满期终止 签单 保单退保 犹豫期退保'
,s4.N_CYEAR_D AS N_CYEAR_D /*'发单年度'*/ ,s4.N_CYEAR_D AS N_CYEAR_D --'发单年度'
,s1.N_CYEAR_D_PROFIT AS N_CYEAR_D_PROFIT /*'发单年度-营利性'*/ ,s1.N_CYEAR_D_PROFIT AS N_CYEAR_D_PROFIT --'发单年度-营利性'
,s4.N_RISKCLASS AS N_RISKCLASS /* '风险类别|| 保障型 储蓄型' ,*/ ,s4.N_RISKCLASS AS N_RISKCLASS -- '风险类别|| 保障型 储蓄型' ,
,s4.N_PRDTYPE AS N_PRDTYPE /* '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' ,*/ ,s4.N_PRDTYPE AS N_PRDTYPE -- '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' ,
,s4.MDL AS MDL /* '适用模型|| BBA VFA PAA '*/ ,s4.MDL AS MDL -- '适用模型|| BBA VFA PAA '
,s4.N_PRDTYPE AS N_PROFIT_FLAG /* 营利性代码|| 1 2 3*/ ,s4.N_PRDTYPE AS N_PROFIT_FLAG -- 营利性代码|| 1 2 3
,s4.GRP_ID AS GRP_ID /* '合同组号' ,*/ ,s4.GRP_ID AS GRP_ID -- '合同组号' ,
,s4.N_GRP__ID AS N_GRP__ID /* '合同组合号' ,*/ ,s4.N_GRP__ID AS N_GRP__ID -- '合同组合号' ,
,CONCAT( ,ConcatObjUDF(
s4.N_PRDTYPE,',' s4.N_PRDTYPE
,s4.N_CYEAR_D,',' ,s4.N_CYEAR_D
,s4.N_PROFIT_FLAG,',' ,s4.N_PROFIT_FLAG
, CASE , CASE
WHEN s4.N_CHNL in ('健康险事业部','寿险险事业部') THEN '事业部' WHEN s4.N_CHNL in ('健康险事业部','寿险险事业部') THEN '事业部'
ELSE s4.N_CHNL END,',' ELSE s4.N_CHNL END
,s4.N_RISKCLASS ,s4.N_RISKCLASS
) AS GRP_ID_INSIDE /* '合同组号-内部' ,*/ ) AS GRP_ID_INSIDE -- '合同组号-内部' ,
,LOCALTIMESTAMP AS MEA_TIME /* '计量时间'*/ ,LOCALTIMESTAMP AS MEA_TIME -- '计量时间'
,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*/ -- IFRS17_HAODS_SRDB IFRS17_HADWS_SRDB IFRS17_HAODS_MYSQL
FROM db_ifrs17hengan.HADWS_PERSONAL_PLCRICK_IN s1 /* 个险现金流输入接口表*/ FROM IFRS17.IFRS17_HAODS_MYSQL.HADWS_PERSONAL_PLCRICK_IN s1 -- 个险现金流输入接口表
LEFT JOIN db_ifrs17hengan.HADIM_LRISKPROF s2 /* 长险营利性配置信息*/ LEFT JOIN IFRS17.IFRS17_HAODS_MYSQL.HADIM_LRISKPROF s2 -- 长险营利性配置信息
ON s1.N_CDX ='长险' and s1.PLC_RISK_CODE = s2.PRDCODE and s1.BUSY_CHAN = s2.CHNL and s1.N_CYEAR_D_PROFIT = s2.CYEAR ON s1.N_CDX ='长险' and s1.PLC_RISK_CODE = s2.PRDCODE and s1.BUSY_CHAN = s2.CHNL and s1.N_CYEAR_D_PROFIT = s2.CYEAR
LEFT JOIN db_ifrs17hengan.HADIM_SRISKPROF s3 /*短险营利性配置信息*/ LEFT JOIN IFRS17.IFRS17_HAODS_MYSQL.HADIM_SRISKPROF s3 --短险营利性配置信息
ON s1.N_CDX ='短险' and s1.PLC_RISK_CODE = s3.PRDCODE ON s1.N_CDX ='短险' and s1.PLC_RISK_CODE = s3.PRDCODE
LEFT JOIN db_ifrs17hengan.HAODS_EXT_CONCATINFO s4 /*合同分组基本信息*/ LEFT JOIN IFRS17.IFRS17_HAODS_MYSQL.HAODS_EXT_CONCATINFO s4 --合同分组基本信息
ON s1.N_PRDTYPE = s4.N_PRDTYPE /* '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 '*/ ON s1.N_PRDTYPE = s4.N_PRDTYPE -- '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 '
and s1.N_CYEAR_D = s4.N_CYEAR_D and s1.N_CYEAR_D = s4.N_CYEAR_D
and COALESCE(s2.PROFIT_FLAG ,s3.PROFIT_FLAG ) = s4.N_PROFIT_FLAG and COALESCE(s2.PROFIT_FLAG ,s3.PROFIT_FLAG ) = s4.N_PROFIT_FLAG
and s1.BUSY_CHAN = ( and s1.BUSY_CHAN = (
...@@ -69,6 +69,6 @@ LEFT JOIN db_ifrs17hengan.HAODS_EXT_CONCATINFO s4 /*合同分组基本信息*/ ...@@ -69,6 +69,6 @@ LEFT JOIN db_ifrs17hengan.HAODS_EXT_CONCATINFO s4 /*合同分组基本信息*/
and s1.N_RISKCLASS = s4.N_RISKCLASS and s1.N_RISKCLASS = s4.N_RISKCLASS
where where
s4.GRP_ID is not null s4.GRP_ID is not null
and s1.MEA_YM = cast('202401' as int) and s1.MEA_YM = cast('${MEA_YM}' as int)
HAPOC/3-HADWS_1/HADWS_TEAM_PLCRICK_IN--团险现金流输入接口表.sql → HAPOC/3-HADWS/back/HADWS_TEAM_PLCRICK_IN--团险现金流输入接口表.sql
View file @ bd9e5dfa
/* HADWS_TEAM_PLCRICK_IN HADWS_团险现金流输入接口表 */ -- HADWS_TEAM_PLCRICK_IN HADWS_团险现金流输入接口表
INSERT INTO db_ifrs17hengan.HADWS_TEAM_PLCRICK_IN /*团险现金流输入接口表*/ INSERT INTO IFRS17.IFRS17_HAODS_MYSQL.HADWS_TEAM_PLCRICK_IN --团险现金流输入接口表
SELECT SELECT
MD5(concat('202401' MD5(ConcatObjUDF('${MEA_YM}'
,GRP_INS_PLC_ID ,GRP_INS_PLC_ID
,PLC_RISK_CODE ,PLC_RISK_CODE
,PERSONAL_RISK_CODE ,PERSONAL_RISK_CODE
)) ))
AS DATAPKID /* 物理主键*/ AS DATAPKID -- 物理主键
,cast( '202401' 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 -- '保单号' ,
,s1.N_PRD_CODE AS N_PRD_CODE /* '产品代码' ,*/ ,s1.N_PRD_CODE AS N_PRD_CODE -- '产品代码' ,
,s1.PLC_RISK_CODE AS PLC_RISK_CODE /* '险种号' ,*/ ,s1.PLC_RISK_CODE AS PLC_RISK_CODE -- '险种号' ,
,s1.GUAR_PERIOD AS GUAR_PERIOD /* '保障年期' ,*/ ,s1.GUAR_PERIOD AS GUAR_PERIOD -- '保障年期' ,
,s1.GUAR_PERIOD_UNITID AS GUAR_PERIOD_UNITID /* '保障年期类型 || Y D M A' ,*/ ,s1.GUAR_PERIOD_UNITID AS GUAR_PERIOD_UNITID -- '保障年期类型 || Y D M A' ,
,s1.PAY_FREQ AS PAY_FREQ /* '缴费频率 || 趸缴 月缴 不定期缴 年缴 季缴 半年缴' ,*/ ,s1.PAY_FREQ AS PAY_FREQ -- '缴费频率 || 趸缴 月缴 不定期缴 年缴 季缴 半年缴' ,
,s1.PAY_PERIOD AS PAY_PERIOD /* '缴费期限' ,*/ ,s1.PAY_PERIOD AS PAY_PERIOD -- '缴费期限' ,
,s1.PAY_PERIOD_UNITID AS PAY_PERIOD_UNITID /* '缴费年期类型 || Y D M A' ,*/ ,s1.PAY_PERIOD_UNITID AS PAY_PERIOD_UNITID -- '缴费年期类型 || Y D M A' ,
,s1.ORGID AS ORGID /* '分支机构' ,*/ ,s1.ORGID AS ORGID -- '分支机构' ,
,s2.CHNL AS BUSY_CHAN /* '销售渠道代码' ,*/ ,s2.CHNL AS BUSY_CHAN -- '销售渠道代码' ,
,s1.PLC_B_DATE AS PLC_B_DATE /* '保单生效日' ,*/ ,s1.PLC_B_DATE AS PLC_B_DATE -- '保单生效日' ,
,s1.SIGN_DATE AS SIGN_DATE /* '签单日期' ,*/ ,s1.SIGN_DATE AS SIGN_DATE -- '签单日期' ,
,cast(s1.STAND_PREM as decimal(18,4)) AS STAND_PREM /* '标准保费' ,*/ ,cast(s1.STAND_PREM as decimal(18,4)) AS STAND_PREM -- '标准保费' ,
,s1.N_SIX AS N_SIX /* '被保人性别 || 0 1 2' ,*/ ,s1.N_SIX AS N_SIX -- '被保人性别 || 0 1 2' ,
,s1.N_AGE AS N_AGE /* '被保险人投保时年龄' ,*/ ,s1.N_AGE AS N_AGE -- '被保险人投保时年龄' ,
,cast(s1.YEAR_COVER as decimal(18,4)) AS YEAR_COVER /* '初始保额' ,*/ ,cast(s1.YEAR_COVER as decimal(18,4)) AS YEAR_COVER -- '初始保额' ,
,s1.DIVID_COLL_METHOD AS DIVID_COLL_METHOD /* '生存金领取方式 || 满期一次性领取' ,*/ ,s1.DIVID_COLL_METHOD AS DIVID_COLL_METHOD -- '生存金领取方式 || 满期一次性领取' ,
,s1.N_CDX AS N_CDX /* '长短险标识 || M L' ,*/ ,s1.N_CDX AS N_CDX -- '长短险标识 || M L' ,
,s1.STS AS STS /* '保单状态 || 生效 满期终止 签单 保单退保 犹豫期退保'*/ ,s1.STS AS STS -- '保单状态 || 生效 满期终止 签单 保单退保 犹豫期退保'
,s1.PERSONAL_RISK_CODE AS PERSONAL_RISK_CODE /* 个人险种号*/ ,s1.PERSONAL_RISK_CODE AS PERSONAL_RISK_CODE -- 个人险种号
,LEFT(s1.SIGN_DATE,4) AS N_CYEAR_D /* '发单年度'*/ ,LEFT(s1.SIGN_DATE,4) AS N_CYEAR_D -- '发单年度'
,s2.RISKCLASS AS N_RISKCLASS /* '风险类别|| 保障型 储蓄型' ,*/ ,s2.RISKCLASS AS N_RISKCLASS -- '风险类别|| 保障型 储蓄型' ,
,s2.PRDTYPE AS N_PRDTYPE /* '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' ,*/ ,s2.PRDTYPE AS N_PRDTYPE -- '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' ,
,s2.MDL AS MDL /* '适用模型|| BBA VFA PAA '*/ ,s2.MDL AS MDL -- '适用模型|| BBA VFA PAA '
,LOCALTIMESTAMP AS MEA_TIME /* '计量时间'*/ ,LOCALTIMESTAMP AS MEA_TIME -- '计量时间'
,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*/ -- IFRS17_HAODS_SRDB IFRS17_HADWS_SRDB IFRS17_HAODS_MYSQL
FROM db_ifrs17hengan.HAODS_TEAM_PLCRICK s1 /*保单险种明细数据_团险*/
LEFT JOIN db_ifrs17hengan.HADIM_PRDINFO s2 /* 产品基本信息*/ FROM IFRS17.IFRS17_HAODS_MYSQL.HAODS_TEAM_PLCRICK s1 --保单险种明细数据_团险
LEFT JOIN IFRS17.IFRS17_HAODS_MYSQL.HADIM_PRDINFO s2 -- 产品基本信息
ON s1.PLC_RISK_CODE = s2.PRDCODE ON s1.PLC_RISK_CODE = s2.PRDCODE
and s2.CHNL = 'GP' /* 团险得渠道全是团险 BK 没数据*/ and s2.CHNL = 'BK' -- 团险得渠道全是团险
WHERE s2.PRDCODE is not null WHERE s2.PRDCODE is not null
......
HAPOC/3-HADWS_1/HADWS_TEAM_PLCRICK_OUT--团险现金流输出接口表.sql → HAPOC/3-HADWS/back/HADWS_TEAM_PLCRICK_OUT--团险现金流输出接口表.sql
View file @ bd9e5dfa
/* HADWS_TEAM_PLCRICK_OUT HADWS_团险现金流输出接口表*/ -- HADWS_TEAM_PLCRICK_OUT HADWS_团险现金流输出接口表
INSERT INTO db_ifrs17hengan.HADWS_TEAM_PLCRICK_OUT /*团险现金流输出接口表*/ INSERT INTO IFRS17.IFRS17_HAODS_MYSQL.HADWS_TEAM_PLCRICK_OUT --团险现金流输出接口表
SELECT SELECT
DATAPKID AS DATAPKID /* 物理主键*/ DATAPKID AS DATAPKID -- 物理主键
,cast( '202401' 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 -- '保单号' ,
,s1.N_PRD_CODE AS N_PRD_CODE /* '产品代码' ,*/ ,s1.N_PRD_CODE AS N_PRD_CODE -- '产品代码' ,
,s1.PLC_RISK_CODE AS PLC_RISK_CODE /* '险种号' ,*/ ,s1.PLC_RISK_CODE AS PLC_RISK_CODE -- '险种号' ,
,s1.GUAR_PERIOD AS GUAR_PERIOD /* '保障年期' ,*/ ,s1.GUAR_PERIOD AS GUAR_PERIOD -- '保障年期' ,
,s1.GUAR_PERIOD_UNITID AS GUAR_PERIOD_UNITID /* '保障年期类型 || Y D M A' ,*/ ,s1.GUAR_PERIOD_UNITID AS GUAR_PERIOD_UNITID -- '保障年期类型 || Y D M A' ,
,s1.PAY_FREQ AS PAY_FREQ /* '缴费频率 || 趸缴 月缴 不定期缴 年缴 季缴 半年缴' ,*/ ,s1.PAY_FREQ AS PAY_FREQ -- '缴费频率 || 趸缴 月缴 不定期缴 年缴 季缴 半年缴' ,
,s1.PAY_PERIOD AS PAY_PERIOD /* '缴费期限' ,*/ ,s1.PAY_PERIOD AS PAY_PERIOD -- '缴费期限' ,
,s1.PAY_PERIOD_UNITID AS PAY_PERIOD_UNITID /* '缴费年期类型 || Y D M A' ,*/ ,s1.PAY_PERIOD_UNITID AS PAY_PERIOD_UNITID -- '缴费年期类型 || Y D M A' ,
,s1.ORGID AS ORGID /* '分支机构' ,*/ ,s1.ORGID AS ORGID -- '分支机构' ,
,s1.BUSY_CHAN AS BUSY_CHAN /* '销售渠道代码' ,*/ ,s1.BUSY_CHAN AS BUSY_CHAN -- '销售渠道代码' ,
,s1.PLC_B_DATE AS PLC_B_DATE /* '保单生效日' ,*/ ,s1.PLC_B_DATE AS PLC_B_DATE -- '保单生效日' ,
,s1.SIGN_DATE AS SIGN_DATE /* '签单日期' ,*/ ,s1.SIGN_DATE AS SIGN_DATE -- '签单日期' ,
,s1.STAND_PREM AS STAND_PREM /* '标准保费' ,*/ ,s1.STAND_PREM AS STAND_PREM -- '标准保费' ,
,s1.N_SIX AS N_SIX /* '被保人性别 || 0 1 2' ,*/ ,s1.N_SIX AS N_SIX -- '被保人性别 || 0 1 2' ,
,s1.N_AGE AS N_AGE /* '被保险人投保时年龄' ,*/ ,s1.N_AGE AS N_AGE -- '被保险人投保时年龄' ,
,s1.YEAR_COVER AS YEAR_COVER /* '初始保额' ,*/ ,s1.YEAR_COVER AS YEAR_COVER -- '初始保额' ,
,s1.DIVID_COLL_METHOD AS DIVID_COLL_METHOD /* '生存金领取方式 || 满期一次性领取' ,*/ ,s1.DIVID_COLL_METHOD AS DIVID_COLL_METHOD -- '生存金领取方式 || 满期一次性领取' ,
,s1.N_CDX AS N_CDX /* '长短险标识 || M L' ,*/ ,s1.N_CDX AS N_CDX -- '长短险标识 || M L' ,
,s1.STS AS STS /* '保单状态 || 生效 满期终止 签单 保单退保 犹豫期退保'*/ ,s1.STS AS STS -- '保单状态 || 生效 满期终止 签单 保单退保 犹豫期退保'
,s1.PERSONAL_RISK_CODE AS PERSONAL_RISK_CODE /* 个人险种号*/ ,s1.PERSONAL_RISK_CODE AS PERSONAL_RISK_CODE -- 个人险种号
,s4.N_CYEAR_D AS N_CYEAR_D /* '发单年度'*/ ,s4.N_CYEAR_D AS N_CYEAR_D -- '发单年度'
,s4.N_RISKCLASS AS N_RISKCLASS /* '风险类别|| 保障型 储蓄型' ,*/ ,s4.N_RISKCLASS AS N_RISKCLASS -- '风险类别|| 保障型 储蓄型' ,
,s4.N_PRDTYPE AS N_PRDTYPE /* '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' ,*/ ,s4.N_PRDTYPE AS N_PRDTYPE -- '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' ,
,s4.MDL AS MDL /* '适用模型|| BBA VFA PAA '*/ ,s4.MDL AS MDL -- '适用模型|| BBA VFA PAA '
,s3.PROFIT_FLAG AS N_PROFIT_FLAG /* 营利性代码|| 1 2 3*/ ,s3.PROFIT_FLAG AS N_PROFIT_FLAG -- 营利性代码|| 1 2 3
,s4.GRP_ID AS GRP_ID /* '合同组号' ,*/ ,s4.GRP_ID AS GRP_ID -- '合同组号' ,
,s4.N_GRP__ID AS N_GRP__ID /* '合同组合号' ,*/ ,s4.N_GRP__ID AS N_GRP__ID -- '合同组合号' ,
,concat( ,ConcatObjUDF(
s4.N_PRDTYPE ,',' s4.N_PRDTYPE
,s4.N_CYEAR_D,',' ,s4.N_CYEAR_D
,s4.N_PROFIT_FLAG,',' ,s4.N_PROFIT_FLAG
,s4.N_CHNL,',' ,s4.N_CHNL
,s4.N_RISKCLASS ,s4.N_RISKCLASS
) AS GRP_ID_INSIDE /* '合同组号-内部' ,*/ ) AS GRP_ID_INSIDE -- '合同组号-内部' ,
,LOCALTIMESTAMP AS MEA_TIME /* '计量时间'*/ ,LOCALTIMESTAMP AS MEA_TIME -- '计量时间'
,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 -- IFRS17_HAODS_SRDB IFRS17_HADWS_SRDB IFRS17_HAODS_MYSQL
*/
FROM db_ifrs17hengan.HADWS_TEAM_PLCRICK_IN s1 /* 团险现金流输入接口表*/ FROM IFRS17.IFRS17_HAODS_MYSQL.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
LEFT JOIN db_ifrs17hengan.HADIM_SRISKPROF s3 /*短险营利性配置信息*/ LEFT JOIN IFRS17.IFRS17_HAODS_MYSQL.HADIM_SRISKPROF s3 --短险营利性配置信息
ON s1.N_CDX ='M' and s1.PLC_RISK_CODE = s3.PRDCODE ON s1.N_CDX ='M' and s1.PLC_RISK_CODE = s3.PRDCODE
LEFT JOIN db_ifrs17hengan.HAODS_EXT_CONCATINFO s4 /*合同分组基本信息*/ LEFT JOIN IFRS17.IFRS17_HAODS_MYSQL.HAODS_EXT_CONCATINFO s4 --合同分组基本信息
ON s1.N_PRDTYPE = s4.N_PRDTYPE ON s1.N_PRDTYPE = s4.N_PRDTYPE
and s1.N_CYEAR_D = s4.N_CYEAR_D and s1.N_CYEAR_D = s4.N_CYEAR_D
and s3.PROFIT_FLAG = s4.N_PROFIT_FLAG and s3.PROFIT_FLAG = s4.N_PROFIT_FLAG
...@@ -58,7 +58,7 @@ LEFT JOIN db_ifrs17hengan.HAODS_EXT_CONCATINFO s4 /*合同分组基本信息*/ ...@@ -58,7 +58,7 @@ LEFT JOIN db_ifrs17hengan.HAODS_EXT_CONCATINFO s4 /*合同分组基本信息*/
where where
s4.GRP_ID is NOT NULL s4.GRP_ID is NOT NULL
AND s1.MEA_YM = cast('202401' as int) AND s1.MEA_YM = cast('${MEA_YM}' as int)
HAPOC/3-HADWS_1/HADWS_CONTACT_MEAS_REL--合同组计量内外关系表.sql deleted 100644 → 0
View file @ a5a204c9
/* HADWS_CONTACT_MEAS_REL HADWS_合同组计量内外关系表*/
INSERT INTO db_ifrs17hengan.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 db_ifrs17hengan.HADWS_CONTACT_MEAS_INPUT a1 /*团险投资成分拆分数据表*/
where a1.MEA_YM = cast('202401' 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

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