初始化12

HAPOC/0-DDL/0-HADIM/HADIM_LRISKPROF--长险营利性配置信息.sql

@@ -10,6 +10,6 @@ PROFIT_FLAG          varchar(64) default null comment '盈利性代码|| 1 2 3'
 -- comment '长险营利性配置信息' charset = utf8mb3
 
 PRIMARY KEY (PRDCODE,CHNL,CYEAR)
-DISTRIBUTED BY HASH (N_CHNL)
+DISTRIBUTED BY HASH (CHNL)
 ;
 

HAPOC/0-DDL/0-HADIM/HADIM_SRISKPROF--短险营利性配置信息.sql

@@ -6,7 +6,7 @@ PROFIT_FLAG          varchar(64) default null comment '盈利性代码|| 1 2 3'
 -- comment '短险营利性配置信息' charset = utf8mb3
 
 
-PRIMARY KEY (PRDCODEL)
+PRIMARY KEY (PRDCODE)
 DISTRIBUTED BY HASH (PRDCODE)
 ;
 

HAPOC/0-DDL/1-HAODS-sr/HAODS_TEAM_PLCRICK--保单险种明细_团险.sql

@@ -27,8 +27,8 @@ LOGTIME     datetime default null comment '记录时间'
 )
 -- comment '保单险种明细数据_团险' charset = utf8mb3
 
-PRIMARY KEY (ID)
-DISTRIBUTED BY HASH (ID)
+PRIMARY KEY (DATAPKID)
+DISTRIBUTED BY HASH (DATAPKID)
 ;
 
 

HAPOC/0-DDL/4-HAHIS/HADIM_LRISKPROF_HIS--长险营利性配置信息_HIS.sql

+-- HADIM_LRISKPROF_HIS--长险营利性配置信息_HIS
+create table HADIM_LRISKPROF_HIS(
+-- 产品代码,渠道,发单年,盈利性代码
+MEA_YM              int not null comment  '评估月',
+
+PRDCODE              varchar(64) not null     comment '产品代码 （险种）' ,
+CHNL                 varchar(64) not null     comment '渠道|| AD BK EC EL FC GP ' ,
+CYEAR                varchar(64) not null     comment '发单年|| 2021 2022 2023 2024 ' ,
+PROFIT_FLAG          varchar(64) default null comment '盈利性代码|| 1 2 3'
+,ARC_TIME	             datetime		 default null comment '归档时间'
+,ARC_BAT	             varchar(64)	 default null comment '归档批次'
+)
+-- comment '长险营利性配置信息' charset = utf8mb3
+
+PRIMARY KEY (MEA_YM,PRDCODE,CHNL,CYEAR)
+DISTRIBUTED BY HASH (CHNL)
+;
+

HAPOC/0-DDL/4-HAHIS/HADIM_PRDINFO_HIS--产品基本信息_HIS.sql

+-- HADIM_PRDINFO_HIS--产品基本信息_HIS
+create table HADIM_PRDINFO_HIS(
+MEA_YM              int not null comment  '评估月',
+
+PRDCODE              String not null comment '险种' ,
+CHNL                 String not null comment '渠道|| AD BK EC EL FC GP ',
+PRDNAME              String not null comment '产品名称' ,
+RISKCLASS            String default null comment '风险类别|| 保障型 储蓄型' ,
+PRDTYPE              String default null comment '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' ,
+CDX                  String default null comment '长短险|| 短险 长险' ,
+MDL                  String default null comment '适用模型|| BBA VFA PAA '
+,ARC_TIME	             datetime		 default null comment '归档时间'
+,ARC_BAT	             varchar(64)	 default null comment '归档批次'
+-- 产品大类<>新准则模型 || BBA|传统险,VFA|分红险,VFA|万能险,PAA|短期险,PAA|再保险
+)
+-- comment '产品基本信息' charset = utf8mb3
+
+PRIMARY KEY (MEA_YM,PRDCODE,CHNL)
+DISTRIBUTED BY HASH (PRDCODE)
+;

HAPOC/0-DDL/4-HAHIS/HADIM_SRISKPROF_HIS--短险营利性配置信息_HIS.sql

+-- HADIM_SRISKPROF_HIS--短险营利性配置信息_HIS
+create table HADIM_SRISKPROF_HIS(
+MEA_YM              int not null comment  '评估月',
+
+PRDCODE              varchar(64) not null comment '产品代码 （险种）' ,
+PROFIT_FLAG          varchar(64) default null comment '盈利性代码|| 1 2 3'
+,ARC_TIME	             datetime		 default null comment '归档时间'
+,ARC_BAT	             varchar(64)	 default null comment '归档批次'
+)
+-- comment '短险营利性配置信息' charset = utf8mb3
+
+
+PRIMARY KEY (MEA_YM,PRDCODE)
+DISTRIBUTED BY HASH (PRDCODE)
+;
+

HAPOC/0-DDL/4-HAHIS/HAODS_TEAM_LP_HIS--理赔数据_团险_HIS.sql

+-- HAODS_TEAM_LP_HIS--理赔数据_团险_HIS
+create table HAODS_TEAM_LP_HIS(
+MEA_YM              int not null comment  '评估月',
+
+DATAPKID           varchar(64) not 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 '核赔通过日期',
+PERSONAL_RISK_CODE  varchar(64) default null comment '个人险种号',
+LOGTIME     datetime default null comment '记录时间'
+,ARC_TIME	             datetime		 default null comment '归档时间'
+,ARC_BAT	             varchar(64)	 default null comment '归档批次'
+)
+-- comment '理赔数据_团险' charset = utf8mb3
+
+PRIMARY KEY (MEA_YM,DATAPKID)
+DISTRIBUTED BY HASH (DATAPKID)
+;
+

HAPOC/0-DDL/4-HAHIS/HAODS_TEAM_PAY_HIS--现金流_团险_HIS.sql

+-- HAODS_TEAM_PAY_HIS--现金流_团险_HIS
+create table HAODS_TEAM_PAY_HIS(
+MEA_YM              int not null comment  '评估月',
+
+DATAPKID                     varchar(64) not null comment 'ID 备注：这个字段原始数据没有' ,
+ID                     varchar(64) not 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 '业务日期',
+PERSONAL_RISK_CODE  varchar(64) default null comment '个人险种号',
+
+LOGTIME     datetime default null comment '记录时间'
+,ARC_TIME	             datetime		 default null comment '归档时间'
+,ARC_BAT	             varchar(64)	 default null comment '归档批次'
+
+)
+-- comment '现金流_团险' charset = utf8mb3
+
+PRIMARY KEY (MEA_YM,DATAPKID)
+DISTRIBUTED BY HASH (DATAPKID)
+;
+

HAPOC/0-DDL/4-HAHIS/HAODS_TEAM_PLCRICK_HIS--保单险种明细_团险_HIS.sql

+-- HAODS_TEAM_PLCRICK_HIS--保单险种明细_团险_HIS
+create table HAODS_TEAM_PLCRICK_HIS(
+MEA_YM              int not null comment  '评估月',
+
+DATAPKID                     varchar(64) not null comment 'ID 备注：这个字段原始数据没有' ,
+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) 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 '保单状态 || 生效 满期终止 签单 保单退保 犹豫期退保',
+PERSONAL_RISK_CODE        varchar(64) default null comment '个人险种号',
+BF                        varchar(64) default null comment '保费',
+LOGTIME     datetime default null comment '记录时间'
+,ARC_TIME	             datetime		 default null comment '归档时间'
+,ARC_BAT	             varchar(64)	 default null comment '归档批次'
+)
+-- comment '保单险种明细数据_团险' charset = utf8mb3
+
+PRIMARY KEY (MEA_YM,DATAPKID)
+DISTRIBUTED BY HASH (DATAPKID)
+;
+
+
+

HAPOC/0-HADIM/HADIM_SRISKPROF_2--短险营利性配置信息_2.sql

-/*HADIM_SRISKPROF_2 短险营利性配置信息*/
+/*HADIM_SRISKPROF_2 HADIM_短险营利性配置信息_2*/
 INSERT INTO db_ifrs17hengan.HADIM_SRISKPROF /* HADIM_短险营利性配置信息_2 */
 SELECT
   COMPCODE                   as PRDCODE        /* '产品代码 （险种）' , */

HAPOC/4-HAHIS/HADIM_LRISKPROF_HIS--长险营利性配置信息_HIS.sql

+-- HADIM_LRISKPROF_HIS--长险营利性配置信息_HIS
+INSERT INTO db_ifrs17hengan.HADIM_LRISKPROF_HIS
+SELECT
+cast('${MEA_YM}' as int )          MEA_YM
+, PRDCODE
+, CHNL
+, CYEAR
+, PROFIT_FLAG
+, LOCALTIMESTAMP                     AS ARC_TIME	       /*  '归档时间'*/
+, cast('${MEA_YM}' as varchar)       AS ARC_BAT	       /*       '归档批次'*/
+from db_ifrs17hengan.HADIM_LRISKPROF

HAPOC/4-HAHIS/HADIM_PRDINFO_HIS--产品基本信息_HIS.sql

+-- HADIM_PRDINFO_HIS--产品基本信息_HIS
+INSERT INTO db_ifrs17hengan.HADIM_PRDINFO_HIS
+SELECT
+cast('${MEA_YM}' as int )          MEA_YM
+, PRDCODE
+, CHNL
+, PRDNAME
+, RISKCLASS
+, PRDTYPE
+, CDX
+, MDL
+, LOCALTIMESTAMP                     AS ARC_TIME	       /*  '归档时间'*/
+, cast('${MEA_YM}' as varchar)       AS ARC_BAT	       /*       '归档批次'*/
+from db_ifrs17hengan.HADIM_PRDINFO

HAPOC/4-HAHIS/HADIM_SRISKPROF_HIS--短险营利性配置信息_HIS.sql

+-- HADIM_SRISKPROF_HIS--短险营利性配置信息_HIS
+INSERT INTO db_ifrs17hengan.HADIM_SRISKPROF_HIS
+SELECT
+cast('${MEA_YM}' as int )          MEA_YM
+, PRDCODE
+, PROFIT_FLAG
+, LOCALTIMESTAMP                     AS ARC_TIME	       /*  '归档时间'*/
+, cast('${MEA_YM}' as varchar)       AS ARC_BAT	       /*       '归档批次'*/
+from db_ifrs17hengan.HADIM_SRISKPROF

HAPOC/4-HAHIS/HAODS_TEAM_LP_HIS--理赔数据_团险_HIS.sql

+/*   HAODS_TEAM_LP_HIS  理赔数据_团险_HIS*/
+INSERT INTO db_ifrs17hengan.HAODS_TEAM_LP_HIS
+SELECT
+cast('${MEA_YM}' as int )          MEA_YM
+,DATAPKID
+,GRP_INS_PLC_ID
+,N_PRD_CODE
+,CLAIM_REVIEW_CODE
+,CLAIM_NO
+,ACCI_DAY_CV
+,CLAIM_PAY_AMNT
+,ACCI_DATE
+,CLOSE_DATE
+,PERSONAL_RISK_CODE
+,LOGTIME
+, LOCALTIMESTAMP                     AS ARC_TIME	       /*  '归档时间'*/
+, cast('${MEA_YM}' as varchar)       AS ARC_BAT	       /*       '归档批次'*/
+from db_ifrs17hengan.HAODS_TEAM_LP

HAPOC/4-HAHIS/HAODS_TEAM_PAY_HIS--现金流_团险_HIS.sql

+/*   HAODS_TEAM_PAY_HIS  现金流_团险_HIS*/
+INSERT INTO db_ifrs17hengan.HAODS_TEAM_PAY_HIS
+SELECT
+cast('${MEA_YM}' as int )          MEA_YM
+,DATAPKID
+,ID
+,GRP_INS_PLC_ID
+,PLC_ID
+,BUSI_NO
+,RISK_CODE
+,N_ORG_4
+,N_COST_CODE
+,N_BUSY_CHAN
+,N_CLAIM_REVIEW_CODE
+,N_TYPE
+,BUSI_TYPE
+,N_BUSI_TYPE_DESC
+,N_CURRENCY
+,AMNT
+,N_BUS_DATE
+,PERSONAL_RISK_CODE
+,LOGTIME
+
+, LOCALTIMESTAMP                     AS ARC_TIME	       /*  '归档时间'*/
+, cast('${MEA_YM}' as varchar)       AS ARC_BAT	       /*       '归档批次'*/
+from db_ifrs17hengan.HAODS_TEAM_PAY
+
+

HAPOC/4-HAHIS/HAODS_TEAM_PLCRICK_HIS--保单险种明细_团险_HIS.sql

+/*   HAODS_TEAM_PLCRICK_HIS  保单险种明细_团险_HIS*/
+INSERT INTO db_ifrs17hengan.HAODS_TEAM_PLCRICK_HIS
+SELECT
+cast('${MEA_YM}' as int )          MEA_YM
+,DATAPKID
+,GRP_INS_PLC_ID
+,N_PRD_CODE
+,PLC_RISK_CODE
+,GUAR_PERIOD
+,GUAR_PERIOD_UNITID
+,PAY_FREQ
+,PAY_PERIOD
+,PAY_PERIOD_UNITID
+,ORGID
+,BUSY_CHAN
+,PLC_B_DATE
+,SIGN_DATE
+,STAND_PREM
+,N_SIX
+,N_AGE
+,YEAR_COVER
+,DIVID_COLL_METHOD
+,N_CDX
+,STS
+,PERSONAL_RISK_CODE
+,BF
+,LOGTIME
+
+, LOCALTIMESTAMP                     AS ARC_TIME	       /*  '归档时间'*/
+, cast('${MEA_YM}' as varchar)       AS ARC_BAT	       /*       '归档批次'*/
+from db_ifrs17hengan.HAODS_TEAM_PLCRICK
+
+
+
+