初始化`

HAPOC/0-DDL/0-HADIM/HADIM_PRDINFO--产品基本信息.sql

 -- HADIM_PRDINFO--产品基本信息
 create table HADIM_PRDINFO(
-PRDCODE              varchar(64) default null comment '产品代码' ,
+PRDCODE              varchar(64) default null comment '险种' ,
 PRDNAME              varchar(64) default null comment '产品名称' ,
 CHNL                 varchar(64) default null comment '渠道|| AD BK EC EL FC GP ' ,
 RISKCLASS            varchar(64) default null comment '风险类别|| 保障型 储蓄型' ,

HAPOC/0-DDL/3-HADWS/HADWS_CONCAT_MANAGE--合同组管理费用_直接部分表.sql

@@ -2,7 +2,7 @@
 create table HADWS_CONCAT_MANAGE(
 DATAPKID           varchar(64) not null comment  '物理主键'
 , GRP_ID             varchar(64) not null comment  '合同组号'
-, MEA_YM         varchar(64) default null comment  '评估月 '
+, MEA_YM        int default null comment  '评估月 '
 , N_PRDTYPE         varchar(64) default null comment  '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 '
 , BUSY_CHAN           varchar(64) default null comment   '销售渠道代码'
 , N_CDX               varchar(64) default null comment   '长短险标识 || 长险 短险 极短险'
@@ -13,7 +13,7 @@ DATAPKID           varchar(64) not null comment  '物理主键'
 ,ARC_TIME	             datetime		 default null comment '归档时间'
 ,MEA_BAT	             varchar(64)	 default null comment '计量批次'
 ,ARC_BAT	             varchar(64)	 default null comment '归档批次'
--- ,primary key (GRP_ID)
+-- ,primary key (DATAPKID)
 )
 -- comment '合同组管理费用_直接部分表' charset = utf8mb3
 

HAPOC/0-DDL/3-HADWS/HADWS_PERSONAL_INV_SPLIT--个险投资成分拆分数据表.sql

 -- HADWS_PERSONAL_INV_SPLIT--个险投资成分拆分数据表
 create table HADWS_PERSONAL_INV_SPLIT(
 DATAPKID             varchar(64) not null comment  '物理主键'
-,MEA_YM                     int default null comment  '评估月'
-,N_RISKCLASS        varchar(64) default null comment  '风险类别|| 保障型 储蓄型'
-,N_PRDTYPE          varchar(64) default null comment  '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 '
-,MDL                varchar(64) default null comment  '适用模型|| BBA VFA PAA '
-,N_PROFIT_FLAG      varchar(64) default null comment  '营利性代码|| 1 2 3'
-,GRP_ID             varchar(64) default null comment  '合同组号'
-,N_GRP__ID          varchar(64) default null comment  '合同组合号'
+,MEA_YM                     int not null comment  '评估月'
+,N_RISKCLASS        varchar(64) not null comment  '风险类别|| 保障型 储蓄型'
+,N_PRDTYPE          varchar(64) not null comment  '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 '
+,MDL                varchar(64) not null comment  '适用模型|| BBA VFA PAA '
+,N_PROFIT_FLAG      varchar(64) not null comment  '营利性代码|| 1 2 3'
+,GRP_ID             varchar(64) not null comment  '合同组号'
+,N_GRP__ID          varchar(64) not null comment  '合同组合号'
 ,CLM_OUT_CSM     decimal(18,4) default null comment  '期初_实际_当期_赔付及费用_投资部分'
 ,CLM_OUT         decimal(18,4) default null comment  '期初_实际_当期_赔付及费用'
 ,PREM_INC        decimal(18,4) default null comment  '期初_预期_当期_保费收入'

HAPOC/0-DDL/3-HADWS/HADWS_PERSONAL_PLCRICK_IN--个险现金流输入接口表.sql

@@ -34,7 +34,8 @@ DATAPKID             varchar(64) not null comment  '物理主键'
 )
 -- comment '个险现金流输入接口表' charset = utf8mb3
 
-
+PRIMARY KEY (DATAPKID)
+DISTRIBUTED BY HASH (DATAPKID)
 ;
 
 

HAPOC/3-HADWS/HADWS_CONCAT_MANAGE--合同组管理费用_直接部分表.sql

 -- HADWS_CONCAT_MANAGE  HADWS_合同组管理费用_直接部分表
 INSERT INTO IFRS17.IFRS17_HAODS_MYSQL.HADWS_CONCAT_MANAGE -- 合同组管理费用_直接部分表
 SELECT
-ConcatObjUDF(s1.GRP_ID,'${MEA_YM}','1')                         AS DATAPKID             -- 物理主键
+ConcatObjUDF(s1.GRP_ID   ,s1.MEA_YM   ,s1.N_PRDTYPE,s1.BUSY_CHAN,s1.N_CDX    ,'1'    )
+                                                AS DATAPKID             -- 物理主键
 ,s1.GRP_ID                                                   AS GRP_ID               -- '合同组号' ,
-,cast( '${MEA_YM}'    as int)                                  AS MEA_YM               --'评估月'
+,s1.MEA_YM                                                   AS MEA_YM               -- '评估月'
 ,s1.N_PRDTYPE                                                AS N_PRDTYPE            -- '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' ,
 ,s1.BUSY_CHAN                                                AS BUSY_CHAN            -- '销售渠道代码' ,
 ,s1.N_CDX                                                    AS N_CDX                -- '长短险标识 || 长险 短险 极短险' ,
-,'1'                                                         AS P_FLAG            -- '团险个险标记|| 1--个单, 2--团单',
+,'1'                                                         AS P_FLAG            -- '团险个险标记|| 1 个单, 2 团单',
 ,0                                                           AS IACF_INS_OUT       -- 期末_实际_IACF_直接部分,
 ,0                                                           AS ISE_INS_OUT        -- 期末_实际_当期_维持费用_直接部分
 ,LOCALTIMESTAMP                                              AS MEA_TIME	        --  '计量时间'
@@ -23,22 +24,23 @@ where s1.MEA_YM =  cast('${MEA_YM}' as int)
 -- ,s1.BUSY_CHAN
 -- ,s1.N_CDX
 union all
+
 SELECT
-ConcatObjUDF(s1.GRP_ID,'${MEA_YM}','2')
-                                                             AS DATAPKID             -- 物理主键
+ConcatObjUDF(s1.GRP_ID   ,s1.MEA_YM   ,s1.N_PRDTYPE,s1.BUSY_CHAN,s1.N_CDX    ,'2'    )
+                                                                  AS DATAPKID             -- 物理主键
 ,s1.GRP_ID                                                   AS GRP_ID               -- '合同组号' ,
-, cast('${MEA_YM}' as int)                                  AS MEA_YM               --'评估月'
+,s1.MEA_YM                                                  AS MEA_YM               -- '评估月'
 ,s1.N_PRDTYPE                                                AS N_PRDTYPE            -- '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' ,
 ,s1.BUSY_CHAN                                                AS BUSY_CHAN            -- '销售渠道代码' ,
 ,s1.N_CDX                                                    AS N_CDX                -- '长短险标识 || 长险 短险 极短险' ,
-,'2'                                                         AS P_FLAG            -- '团险个险标记|| 1--个单, 2--团单',
+,'2'                                                         AS P_FLAG            -- '团险个险标记|| 1 个单, 2 团单',
 ,0                                                           AS IACF_INS_OUT       -- 期末_实际_IACF_直接部分,
 ,0                                                           AS ISE_INS_OUT        -- 期末_实际_当期_维持费用_直接部分
 ,LOCALTIMESTAMP                                              AS MEA_TIME	        --  '计量时间'
 ,LOCALTIMESTAMP                                              AS ARC_TIME	        --  '归档时间'
 ,''                                                          AS MEA_BAT	            --  '计量批次'
 ,''                                                          AS ARC_BAT	            --  '归档批次'
-FROM IFRS17.IFRS17_HAODS_MYSQL.HADWS_TEAM_PLCRICK_OUT s1 --团险现金流输出接口表
+FROM IFRS17.IFRS17_HAODS_MYSQL.HADWS_TEAM_PLCRICK_OUT s1 -- 团险现金流输出接口表
 where s1.MEA_YM =  cast('${MEA_YM}' as int)
 -- group by
 -- s1.GRP_ID

HAPOC/3-HADWS/HADWS_CONTACT_MEAS_INPUT--合同组计量输入接口表.sql

 -- HADWS_CONTACT_MEAS_INPUT  HADWS_合同组计量输入接口表
 INSERT INTO IFRS17.IFRS17_HAODS_MYSQL.HADWS_CONTACT_MEAS_INPUT --团险投资成分拆分数据表
 SELECT
-ConcatObjUDF(a1.GRP_ID,a1.MEA_YM,a1.P_FLAG)
+md5(ConcatObjUDF(a1.GRP_ID,a1.MEA_YM,a1.N_PRDTYPE      , a1.N_PROFIT_FLAG  , a1.N_RISKCLASS    , a1.MDL     ,a1.P_FLAG)       )
                                     AS DATAPKID             -- 物理主键
 , a1.GRP_ID                            --  '合同组号'
 , a1.MEA_YM                            -- '评估月'

HAPOC/3-HADWS/HADWS_PERSONAL_PLCRICK_IN--个险现金流输入接口表.sql

 -- HADWS_PERSONAL_PLCRICK_IN  HADWS_个险现金流输入接口表
-INSERT INTO IFRS17.IFRS17_HADWS_SRDB.HADWS_PERSONAL_PLCRICK_IN -- 个险现金流输入接口表
+INSERT INTO IFRS17.IFRS17_HAODS_MYSQL.HADWS_PERSONAL_PLCRICK_IN -- 个险现金流输入接口表
 SELECT
-ConcatObjUDF( '${MEA_YM}',PLC_ID)
+ConcatObjUDF( '${MEA_YM}',s1.PLC_ID)
                                     AS DATAPKID             -- 物理主键
 ,cast('${MEA_YM}'    as int)                                  AS MEA_YM               --'评估月'
 ,s1.PLC_ID                                                   AS PLC_ID               -- '保单号' ,
@@ -29,12 +29,12 @@ ConcatObjUDF( '${MEA_YM}',PLC_ID)
 ,s2.PRDTYPE                                                  AS N_PRDTYPE            -- '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' ,
 ,s2.MDL                                                      AS MDL                  -- '适用模型|| BBA VFA PAA '
 ,LOCALTIMESTAMP     AS      MEA_TIME	        --  '计量时间'
-,null               AS      ARC_TIME	        --  '归档时间'
+,LOCALTIMESTAMP     AS      ARC_TIME	        --  '归档时间'
 ,''                 AS      MEA_BAT	            --  '计量批次'
 ,''                 AS      ARC_BAT	            --  '归档批次'
-FROM IFRS17.IFRS17_HAODS_SRDB.HAODS_PERSONAL_PLCRICK s1 -- 保单险种明细_个人业务
-LEFT JOIN IFRS17.IFRS17_HAODS_SRDB.HADIM_PRDINFO s2 -- 产品基本信息
-ON s1.N_PRD_CODE = s2.PRDCODE and s1.BUSY_CHAN = s2.CHNL
+FROM IFRS17.IFRS17_HAODS_MYSQL.HAODS_PERSONAL_PLCRICK s1 -- 保单险种明细_个人业务
+LEFT JOIN IFRS17.IFRS17_HAODS_MYSQL.HADIM_PRDINFO s2 -- 产品基本信息
+ON s1.PLC_RISK_CODE = s2.PRDCODE and s1.BUSY_CHAN = s2.CHNL
 
 
 

HAPOC/3-HADWS/HADWS_PERSONAL_PLCRICK_OUT--个险现金流输出接口表.sql

 -- HADWS_PERSONAL_PLCRICK_OUT  HADWS_个险现金流输出接口表
-INSERT INTO IFRS17.HADWS_SRDB.HADWS_PERSONAL_PLCRICK_OUT -- 个险现金流输出接口表
+INSERT INTO IFRS17.IFRS17_HAODS_MYSQL.HADWS_PERSONAL_PLCRICK_OUT -- 个险现金流输出接口表
 SELECT
 ConcatObjUDF( '${MEA_YM}',s1.PLC_ID)
                                     AS DATAPKID             -- 物理主键
@@ -25,24 +25,24 @@ ConcatObjUDF( '${MEA_YM}',s1.PLC_ID)
 ,s1.STS                                                      AS STS                  -- '保单状态' || 生效 满期终止 签单 保单退保 犹豫期退保'
 ,s1.N_CYEAR_D                                                AS N_CYEAR_D            --'发单年度'
 ,s1.N_CYEAR_D_PROFIT                                         AS N_CYEAR_D_PROFIT     --'发单年度-营利性'
-,s1.RISKCLASS                                                AS N_RISKCLASS          -- '风险类别|| 保障型 储蓄型' ,
+,s1.N_RISKCLASS                                                AS N_RISKCLASS          -- '风险类别|| 保障型 储蓄型' ,
 ,s1.N_PRDTYPE                                                  AS N_PRDTYPE            -- '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' ,
 ,s1.MDL                                                      AS MDL                  -- '适用模型|| BBA VFA PAA '
-,IFNULL(s2.PROFIT_FLAG ,s3.PROFIT_FLAG )                     AS N_PROFIT_FLAG        -- 营利性代码|| 1 2 3
+,COALESCE (s2.PROFIT_FLAG ,s3.PROFIT_FLAG )                     AS N_PROFIT_FLAG        -- 营利性代码|| 1 2 3
 ,s4.GRP_ID                                                   AS GRP_ID               -- '合同组号' ,
 ,s4.N_GRP__ID                                                AS N_GRP__ID            -- '合同组合号' ,
 ,LOCALTIMESTAMP     AS      MEA_TIME	        --  '计量时间'
-,null               AS      ARC_TIME	        --  '归档时间'
+,LOCALTIMESTAMP     AS      ARC_TIME	        --  '归档时间'
 ,''                 AS      MEA_BAT	            --  '计量批次'
 ,''                 AS      ARC_BAT	            --  '归档批次'
-FROM IFRS17.IFRS17_HADWS_SRDB.HADWS_PERSONAL_PLCRICK_IN s1-- 个险现金流输入接口表
-LEFT JOIN IFRS17.IFRS17_HAODS_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
-LEFT JOIN IFRS17.IFRS17_HAODS_SRDB.HADIM_SRISKPROF s3 --短险营利性配置信息
-ON s1.N_CDX ='短险'  and s1.N_PRD_CODE = s3.PRDCODE
-LEFT JOIN IFRS17.IFRS17_HAODS_SRDB. HAODS_EXT_CONCATINFO  s4 --合同分组基本信息
+FROM IFRS17.IFRS17_HAODS_MYSQL.HADWS_PERSONAL_PLCRICK_IN s1   -- 个险现金流输入接口表
+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
+LEFT JOIN IFRS17.IFRS17_HAODS_MYSQL.HADIM_SRISKPROF s3 --短险营利性配置信息
+ON s1.N_CDX ='短险'  and s1.PLC_RISK_CODE = s3.PRDCODE
+LEFT JOIN IFRS17.IFRS17_HAODS_MYSQL.HAODS_EXT_CONCATINFO  s4 --合同分组基本信息
 ON s1.N_PRDTYPE = s4.N_PRDTYPE  and s1.N_CYEAR_D = s4.N_CYEAR_D
-and s1.IFNULL(s2.PROFIT_FLAG ,s3.PROFIT_FLAG )  = s4.N_PROFIT_FLAG
+and COALESCE(s2.PROFIT_FLAG ,s3.PROFIT_FLAG )  = s4.N_PROFIT_FLAG
 where s1.MEA_YM = cast('${MEA_YM}' as int)
 
 

HAPOC/3-HADWS/HADWS_TEAM_PLCRICK_IN--团险现金流输入接口表.sql

 -- HADWS_TEAM_PLCRICK_IN  HADWS_团险现金流输入接口表
-INSERT INTO IFRS17.HADWS_SRDB.HADWS_TEAM_PLCRICK_IN     --团险现金流输入接口表
+INSERT INTO IFRS17.IFRS17_HAODS_MYSQL.HADWS_TEAM_PLCRICK_IN     --团险现金流输入接口表
 SELECT
 ConcatObjUDF('${MEA_YM}',s1.GRP_INS_PLC_ID)
                                     AS DATAPKID             -- 物理主键
@@ -28,13 +28,13 @@ ConcatObjUDF('${MEA_YM}',s1.GRP_INS_PLC_ID)
 ,s2.PRDTYPE                                                  AS N_PRDTYPE            -- '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' ,
 ,s2.MDL                                                      AS MDL                  -- '适用模型|| BBA VFA PAA '
 ,LOCALTIMESTAMP     AS      MEA_TIME	        --  '计量时间'
-,null               AS      ARC_TIME	        --  '归档时间'
+,LOCALTIMESTAMP               AS      ARC_TIME	        --  '归档时间'
 ,''                 AS      MEA_BAT	            --  '计量批次'
 ,''                 AS      ARC_BAT	            --  '归档批次'
 
-FROM IFRS17.IFRS17_HAODS_SRDB.HAODS_TEAM_PLCRICK s1   --保单险种明细数据_团险
-LEFT JOIN IFRS17.IFRS17_HAODS_SRDB.HADIM_PRDINFO s2 -- 产品基本信息
-ON s1.N_PRD_CODE = s2.PRDCODE and s1.BUSY_CHAN = s2.CHNL
+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 and s1.BUSY_CHAN = s2.CHNL
 
 
 

HAPOC/3-HADWS/HADWS_TEAM_PLCRICK_OUT--团险现金流输出接口表.sql

 -- HADWS_TEAM_PLCRICK_OUT  HADWS_团险现金流输出接口表
-INSERT INTO IFRS17.HADWS_SRDB.HADWS_TEAM_PLCRICK_OUT --团险现金流输出接口表
+INSERT INTO IFRS17.IFRS17_HAODS_MYSQL.HADWS_TEAM_PLCRICK_OUT --团险现金流输出接口表
 SELECT
 ConcatObjUDF( '${MEA_YM}',s1.GRP_INS_PLC_ID)
                                     AS DATAPKID             -- 物理主键
@@ -24,24 +24,24 @@ ConcatObjUDF( '${MEA_YM}',s1.GRP_INS_PLC_ID)
 ,s1.N_CDX                                                    AS N_CDX                -- '长短险标识 || M L' ,
 ,s1.STS                                                      AS STS                  -- '保单状态 || 生效 满期终止 签单 保单退保 犹豫期退保'
 ,s1.N_CYEAR_D                                                AS N_CYEAR_D            -- '发单年度'
-,s1.RISKCLASS                                                AS N_RISKCLASS          -- '风险类别|| 保障型 储蓄型' ,
+,s1.N_RISKCLASS                                                AS N_RISKCLASS          -- '风险类别|| 保障型 储蓄型' ,
 ,s1.N_PRDTYPE                                                  AS N_PRDTYPE            -- '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' ,
 ,s1.MDL                                                      AS MDL                  -- '适用模型|| BBA VFA PAA '
 ,s3.PROFIT_FLAG                                              AS N_PROFIT_FLAG        --  营利性代码|| 1 2 3
 ,s4.GRP_ID                                                   AS GRP_ID               -- '合同组号' ,
 ,s4.N_GRP__ID                                                AS N_GRP__ID            -- '合同组合号' ,
 ,LOCALTIMESTAMP     AS      MEA_TIME	        --  '计量时间'
-,null               AS      ARC_TIME	        --  '归档时间'
+,LOCALTIMESTAMP               AS      ARC_TIME	        --  '归档时间'
 ,''                 AS      MEA_BAT	            --  '计量批次'
 ,''                 AS      ARC_BAT	            --  '归档批次'
 
-FROM IFRS17.IFRS17_HADWS_SRDB.HADWS_TEAM_PLCRICK_OUT s1 -- 团险现金流输入接口表
+FROM IFRS17.IFRS17_HAODS_MYSQL.HADWS_TEAM_PLCRICK_IN s1 -- 团险现金流输入接口表
 -- 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
-LEFT JOIN IFRS17.IFRS17_HAODS_SRDB.HADIM_SRISKPROF s3 --短险营利性配置信息
-ON s1.N_CDX ='短险'  and s1.N_PRD_CODE = s3.PRDCODE
-LEFT JOIN IFRS17.IFRS17_HAODS_SRDB.HAODS_EXT_CONCATINFO  s4 --合同分组基本信息
-ON s1.N_PRDTYPE = s4.N_PRDTYPE  and s1.N_CYEAR_D = s4.N_CYEAR_D
+LEFT JOIN IFRS17.IFRS17_HAODS_MYSQL.HADIM_SRISKPROF s3 --短险营利性配置信息
+ON s1.N_CDX ='短险'  and s1.PLC_RISK_CODE = s3.PRDCODE
+LEFT JOIN IFRS17.IFRS17_HAODS_MYSQL.HAODS_EXT_CONCATINFO  s4 --合同分组基本信息
+ON s1.PLC_RISK_CODE = s4.N_PRDTYPE  and s1.N_CYEAR_D = s4.N_CYEAR_D
 and s3.PROFIT_FLAG   = s4.N_PROFIT_FLAG
 where s1.MEA_YM = cast('${MEA_YM}' as int)