部分表归档

HAPOC/0-DDL/1-HAODS-sr/HAODS_EXT_CS--待分摊费用获取费用&维护费用-Y9.sql

 -- HAODS_EXT_CS--待分摊费用获取费用&维护费用
 create table HAODS_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) default null comment '待分摊项金额'
-,LOGTIME            datetime default null comment '记录时间'
+     `N_CHNL` varchar(64) NOT NULL COMMENT "渠道|| 多元 个险 银保 团险 互联网",
+     `N_CDX` varchar(64) NOT NULL COMMENT "长短险|| 长险 短险",
+     `CS_ITEM` varchar(64) NOT NULL COMMENT "待分摊项|| 获取费用 维持费用",
+     `MEA_YM` int(11) NOT NULL COMMENT "评估月",
+     `CS_AMONT` decimal(18, 4) NULL COMMENT "待分摊项金额",
+     `LOGTIME` datetime NULL COMMENT "记录时间"
 
 )
 -- comment '待分摊费用获取费用&维护费用' charset = utf8mb3

HAPOC/0-DDL/1-HAODS-sr/HAODS_EXT_SHARECS--资产份额与账户价值分摊载体.sql

 -- HAODS_EXT_SHARECS-资产份额与账户价值分摊载体
 create table HAODS_EXT_SHARECS(
--- SPCODE,Product,AS_IF_VAL,AV_IF_VAL,ALL
-N_SPCODE                  varchar(64) not null comment 'N_SPCODE     ' ,
-N_PRODUCT                 varchar(64) not 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        ',
-LOGTIME     datetime default null comment '记录时间'
+  `N_SPCODE` varchar(64) NOT NULL COMMENT "N_SPCODE     ",
+  `N_PRODUCT` varchar(64) NOT NULL COMMENT "N_PRODUCT    ",
+  `MEA_YM` int(11) NOT NULL COMMENT "评估月    ",
+  `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        ",
+  `LOGTIME` datetime NULL COMMENT "记录时间"
 
 )
 -- comment '资产份额与账户价值分摊载体' charset = utf8mb3

HAPOC/0-DDL/1-HAODS-sr/HAODS_EXT_SHAREVAL--资产份额与账户价值数据.sql

 -- HAODS_EXT_SHAREVAL-资产份额与账户价值数据
 create table HAODS_EXT_SHAREVAL(
 -- #资产份额,账户价值
-N_SHARE                     varchar(64) not null comment '资产份额' ,
-N_CV                        varchar(64) default null comment '账户价值',
-LOGTIME     datetime default null comment '记录时间'
+   `MEA_YM` int(11) NOT NULL COMMENT "评估月",
+   `N_SHARE` varchar(64) NOT NULL COMMENT "资产份额",
+   `N_CV` varchar(64) NULL COMMENT "账户价值",
+   `LOGTIME` datetime NULL COMMENT "记录时间"
 
 
 )

HAPOC/0-DDL/4-HAHIS/HAODS_EXT_CONCATINFO_HIS--合同分组基本信息_HIS.sql

+/*-- HAODS_EXT_CONCATINFO_HIS --合同分组基本信息_HIS*/
+create table HAODS_EXT_CONCATINFO_HIS(
+MEA_YM              int not null comment  '评估月',
+GRP_ID               varchar(64) not   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' ,
+LOGTIME     datetime default null comment '记录时间'
+,ARC_TIME	             datetime		 default null comment '归档时间'
+,ARC_BAT	             varchar(64)	 default null comment '归档批次'
+
+
+-- primary key (GRP_ID)
+)
+-- comment '合同分组基本信息' charset = utf8mb3
+
+PRIMARY KEY (MEA_YM,GRP_ID)
+DISTRIBUTED BY HASH (GRP_ID)
+
+;

HAPOC/0-DDL/4-HAHIS/HAODS_EXT_CS_HIS--待分摊费用获取费用&维护费用_HIS-Y9.sql

+/*-- HAODS_EXT_CS_HIS--待分摊费用获取费用&维护费用_HIS*/
+create table HAODS_EXT_CS_HIS(
+MEA_YM              int not null comment  '评估月'
+,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) 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,N_CHNL,N_CDX,CS_ITEM)
+DISTRIBUTED BY HASH (N_CHNL)
+;
+

HAPOC/0-DDL/4-HAHIS/HAODS_EXT_INCURRED_HIS-法定准备金数据_HIS.sql

+/*-- HAODS_EXT_INCURRED_HIS-法定准备金数据_HIS*/
+create table HAODS_EXT_INCURRED_HIS(
+MEA_YM              int not null comment  '评估月',
+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) 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',
+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,N_CYEAR,N_CHNL,N_PRDCODE)
+DISTRIBUTED BY HASH (N_PRDCODE)
+;

HAPOC/0-DDL/4-HAHIS/HAODS_EXT_SHARECS_HIS--资产份额与账户价值分摊载体_HIS.sql

+/*-- HAODS_EXT_SHARECS_HIS-资产份额与账户价值分摊载体_HIS*/
+create table HAODS_EXT_SHARECS_HIS(
+MEA_YM              int not null comment  '评估月',
+N_SPCODE                  varchar(64) not null comment 'N_SPCODE     ' ,
+N_PRODUCT                 varchar(64) not 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        ',
+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,N_SPCODE,N_PRODUCT)
+DISTRIBUTED BY HASH (N_PRODUCT)
+;
+
+

HAPOC/0-DDL/4-HAHIS/HAODS_EXT_SHAREVAL_HIS--资产份额与账户价值数据_HIS.sql

+/*-- HAODS_EXT_SHAREVAL_HIS-资产份额与账户价值数据_HIS*/
+create table HAODS_EXT_SHAREVAL_HIS(
+-- #资产份额,账户价值
+   `MEA_YM` int(11) NOT NULL COMMENT "评估月",
+   `N_SHARE` varchar(64) NOT NULL COMMENT "资产份额",
+   `N_CV` varchar(64) NULL COMMENT "账户价值",
+   `LOGTIME` datetime NULL COMMENT "记录时间"
+    ,ARC_TIME	             datetime		 default null comment '归档时间'
+    ,ARC_BAT	             varchar(64)	 default null comment '归档批次'
+
+
+)
+-- comment '资产份额与账户价值数据' charset = utf8mb3
+
+PRIMARY KEY (MEA_YM,N_SHARE)
+DISTRIBUTED BY HASH (N_SHARE)
+;
+
+

HAPOC/0-DDL/4-HAHIS/HAODS_PERSONAL_PAY_HIS--现金流_个人业务_HIS.sql

+-- HAODS_PERSONAL_PAY_HIS--现金流_个人业务_HIS
+create table HAODS_PERSONAL_PAY_HIS(
+MEA_YM              int not null comment  '评估月',
+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 '业务场景编号 || 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 '业务日期',
+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,ID)
+DISTRIBUTED BY HASH (ID)
+
+;
+

HAPOC/0-DDL/4-HAHIS/HAODS_PERSONAL_PLCRICK_HIS--保单险种明细_个人业务_HIS.sql

+-- HAODS_PERSONAL_PLCRICK_HIS--保单险种明细_个人业务_HIS
+create table HAODS_PERSONAL_PLCRICK_HIS(
+MEA_YM              int not null comment  '评估月',
+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 '保障年期类型 || 按年保 按年龄保' ,
+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 '保单状态 || 生效 满期终止 签单 保单退保 犹豫期退保',
+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,PLC_ID,N_PRD_CODE,PLC_RISK_CODE)
+DISTRIBUTED BY HASH (PLC_ID)
+;
+
+
+

HAPOC/0-DDL/4-HAHIS/HAODS_XDYKJG_HIS--新单盈亏结果_HIS.sql

+/*-- HAODS_XDYKJG_HIS--新单盈亏结果_HIS*/
+create table db_ifrs17hengan.HAODS_XDYKJG_HIS
+(
+    `MEA_YM` int(11) NOT NULL COMMENT "评估月",
+    SPLIC           varchar(255) not null ,
+    SPCODE          varchar(255) not null ,
+    MODEL_POINT     varchar(255) not null ,
+    CHANNEL         varchar(255) not null ,
+    COMPCODE        varchar(255) not null ,
+    I17_CSM_PL_SUM  varchar(255) null,
+    I17_GPV_PL_SUM  varchar(255) null,
+    I17_LC_PL_SUM   varchar(255) null,
+    I17_RA_PL_SUM   varchar(255) null,
+    I17_TVOG_PL_SUM varchar(255) null
+    ,ARC_TIME	             datetime		 default null comment '归档时间'
+    ,ARC_BAT	             varchar(64)	 default null comment '归档批次'
+)
+-- comment '险种盈亏结果表' charset = utf8mb3
+
+PRIMARY KEY (MEA_YM,SPLIC,SPCODE,MODEL_POINT,CHANNEL,COMPCODE)
+DISTRIBUTED BY HASH (SPCODE)
+
+;
+

HAPOC/4-HAHIS/HAODS_EXT_CONCATINFO_HIS --合同分组基本信息_HIS.sql

+/*-- HAODS_EXT_CONCATINFO_HIS --合同分组基本信息_HIS*/
+INSERT INTO db_ifrs17hengan.HAODS_EXT_CONCATINFO_HIS
+SELECT
+    cast('${MEA_YM}' as int )          MEA_YM
+    ,GRP_ID
+    ,N_GRP__ID
+    ,N_CYEAR_D
+    ,N_PROFIT_FLAG
+    ,MDL
+    ,N_PRDTYPE
+    ,N_RISKCLASS
+    ,N_CHNL
+    ,N_CYEAR
+    ,PROFIT_LOSS_FLAG
+    ,METHOD
+    ,LOGTIME
+    , LOCALTIMESTAMP                     AS ARC_TIME	       /*  '归档时间'*/
+    , cast('${MEA_YM}' as varchar)       AS ARC_BAT	       /*       '归档批次'*/
+from db_ifrs17hengan.HAODS_EXT_CONCATINFO
\ No newline at end of file

HAPOC/4-HAHIS/HAODS_EXT_CS_HIS--待分摊费用获取费用&维护费用_HIS.sql

+/*-- HAODS_EXT_CS_HIS--待分摊费用获取费用&维护费用_HIS*/
+INSERT INTO db_ifrs17hengan.HAODS_EXT_CS_HIS
+SELECT
+    MEA_YM
+    ,N_CHNL
+    ,N_CDX
+    ,CS_ITEM
+    ,CS_AMONT
+    ,LOGTIME
+    ,LOCALTIMESTAMP                     AS ARC_TIME	       /*  '归档时间'*/
+    ,cast('${MEA_YM}' as varchar)       AS ARC_BAT	       /*       '归档批次'*/
+from db_ifrs17hengan.HAODS_EXT_CS
+where MEA_YM =  cast( '${MEA_YM}' as int)
\ No newline at end of file

HAPOC/4-HAHIS/HAODS_EXT_INCURRED_HIS-法定准备金数据_HIS.sql

+/*-- HAODS_EXT_INCURRED_HIS-法定准备金数据_HIS*/
+INSERT INTO db_ifrs17hengan.HAODS_EXT_INCURRED_HIS
+SELECT
+cast('${MEA_YM}' as int )          MEA_YM
+,N_CYEAR
+,N_CHNL
+,N_PRDCODE
+,N_INCURRED
+,LOGTIME
+,LOCALTIMESTAMP                     AS ARC_TIME	       /*  '归档时间'*/
+,cast('${MEA_YM}' as varchar)       AS ARC_BAT	       /*       '归档批次'*/
+from db_ifrs17hengan.HAODS_EXT_INCURRED
\ No newline at end of file

HAPOC/4-HAHIS/HAODS_EXT_SHARECS_HIS-资产份额与账户价值分摊载体_HIS.sql

+/*-- HAODS_EXT_SHARECS_HIS-资产份额与账户价值分摊载体_HIS*/
+INSERT INTO db_ifrs17hengan.HAODS_EXT_SHARECS_HIS
+SELECT
+     MEA_YM
+     ,N_SPCODE
+     ,N_PRODUCT
+     ,N_AS_IF_VAL
+     ,N_AV_IF_VAL
+     ,N_ALL
+     ,LOGTIME
+     ,LOCALTIMESTAMP                     AS ARC_TIME	       /*  '归档时间'*/
+     ,cast('${MEA_YM}' as varchar)       AS ARC_BAT	       /*       '归档批次'*/
+from db_ifrs17hengan.HAODS_EXT_SHARECS
+where MEA_YM =  cast( '${MEA_YM}' as int)
\ No newline at end of file

HAPOC/4-HAHIS/HAODS_EXT_SHAREVAL_HIS-资产份额与账户价值数据_HIS.sql

+/*-- HAODS_EXT_SHAREVAL_HIS-资产份额与账户价值数据_HIS*/
+INSERT INTO db_ifrs17hengan.HAODS_EXT_SHAREVAL_HIS
+SELECT
+    MEA_YM
+    ,N_SHARE
+    ,N_CV
+    ,LOGTIME
+    ,LOCALTIMESTAMP                     AS ARC_TIME	       /*  '归档时间'*/
+    ,cast('${MEA_YM}' as varchar)       AS ARC_BAT	       /*       '归档批次'*/
+from db_ifrs17hengan.HAODS_EXT_SHAREVAL
+where MEA_YM =  cast( '${MEA_YM}' as int)
\ No newline at end of file

HAPOC/4-HAHIS/HAODS_PERSONAL_PAY_HIS--现金流_个人业务_HIS.sql

+/*   HAODS_PERSONAL_PAY_HIS--现金流_个人业务_HIS*/
+INSERT INTO db_ifrs17hengan.HAODS_PERSONAL_PAY_HIS
+SELECT
+    cast('${MEA_YM}' as int )          MEA_YM
+    ,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
+    ,LOGTIME
+    , LOCALTIMESTAMP                     AS ARC_TIME	       /*  '归档时间'*/
+    , cast('${MEA_YM}' as varchar)       AS ARC_BAT	       /*       '归档批次'*/
+from db_ifrs17hengan.HAODS_PERSONAL_PAY
+

HAPOC/4-HAHIS/HAODS_PERSONAL_PLCRICK_HIS--保单险种明细_个人业务_HIS.sql

+/* HAODS_PERSONAL_PLCRICK_HIS--保单险种明细_个人业务_HIS*/
+INSERT INTO db_ifrs17hengan.HAODS_PERSONAL_PLCRICK_HIS
+SELECT
+    cast('${MEA_YM}' as int )          MEA_YM
+    ,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
+    ,LOGTIME
+    , LOCALTIMESTAMP                     AS ARC_TIME	       /*  '归档时间'*/
+    , cast('${MEA_YM}' as varchar)       AS ARC_BAT	       /*       '归档批次'*/
+from db_ifrs17hengan.HAODS_PERSONAL_PLCRICK
+

HAPOC/4-HAHIS/HAODS_XDYKJG_HIS--新单盈亏结果_HIS.sql

+/* HAODS_XDYKJG_HIS--新单盈亏结果_HIS*/
+INSERT INTO db_ifrs17hengan.HAODS_XDYKJG_HIS
+SELECT
+    cast('${MEA_YM}' as int )          MEA_YM
+     ,SPLIC
+     ,SPCODE
+     ,MODEL_POINT
+     ,CHANNEL
+     ,COMPCODE
+     ,I17_CSM_PL_SUM
+     ,I17_GPV_PL_SUM
+     ,I17_LC_PL_SUM
+     ,I17_RA_PL_SUM
+     ,I17_TVOG_PL_SUM
+     , LOCALTIMESTAMP                     AS ARC_TIME	       /*  '归档时间'*/
+     , cast('${MEA_YM}' as varchar)       AS ARC_BAT	       /*       '归档批次'*/
+from db_ifrs17hengan.HAODS_XDYKJG
+