初始化`

HAPOC/0-DDL/1-HAODS/HAODS_EXT_CONCATINFO--合同分组基本信息.sql

@@ -13,6 +13,7 @@ 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 '记录时间'
+primary key (GRP_ID)
 )
 -- comment '合同分组基本信息' charset = utf8mb3
 

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

--- HADWS_CONCAT_MANAGE--合同组管理费用_直接部分表
-INSERT INTO IFRS17.HAODS_SRDB.HADWS_CONCAT_MANAGE --合同组管理费用_直接部分表
+-- HADWS_CONCAT_MANAGE--HADWS_合同组管理费用_直接部分表
+INSERT INTO IFRS17.HADWS_SRDB.HADWS_CONCAT_MANAGE --合同组管理费用_直接部分表
 SELECT
 ConcatObjUDF(MGRP_ID,${MEA_YM})
                                                              AS DATAPKID             -- 物理主键
@@ -16,7 +16,7 @@ ConcatObjUDF(MGRP_ID,${MEA_YM})
 ,''                                                          AS MEA_BAT	            --  '计量批次'
 ,''                                                          AS ARC_BAT	            --  '归档批次'
 
-FROM IFRS17.HAODS_SRDB.HADWS_PERSONAL_PLCRICK_OUT s1-- 个险现金流输出接口表
+FROM IFRS17.HADWS_SRDB.HADWS_PERSONAL_PLCRICK_OUT s1-- 个险现金流输出接口表
 where s1.MEA_YM = ${MEA_YM
 group by
 s1.GRP_ID
@@ -39,7 +39,7 @@ ConcatObjUDF(MGRP_ID,${MEA_YM})
 ,null                                                        AS ARC_TIME	        --  '归档时间'
 ,''                                                          AS MEA_BAT	            --  '计量批次'
 ,''                                                          AS ARC_BAT	            --  '归档批次'
-FROM IFRS17.HAODS_SRDB.HADWS_TEAM_PLCRICK_OUT--团险现金流输出接口表
+FROM IFRS17.HADWS_SRDB.HADWS_TEAM_PLCRICK_OUT--团险现金流输出接口表
 where s1.MEA_YM = ${MEA_YM}
 s1.GRP_ID
 ,s1.N_PRDTYPE

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

 -- HADWS_CONTACT_MEAS_INPUT--合同组计量输入接口表
-create table HADWS_CONTACT_MEAS_INPUT(
- DATAPKID                      varchar(64) not null comment  '物理主键'
-, GRP_ID                       varchar(64) not null comment   '合同组号'
-, MEA_YM                               int not null comment  '评估月'
-, N_PRDTYPE                varchar(64) default null comment   '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 '
-, N_PROFIT_FLAG            varchar(64) default null comment   '营利性代码|| 1 2 3'
-, N_RISKCLASS              varchar(64) default null comment   '风险类别|| 保障型 储蓄型'
-, MDL                      varchar(64) default null comment   '适用模型|| BBA VFA PAA '
+INSERT INTO IFRS17.HADWS_SRDB.HADWS_TEAM_INV_SPLIT --团险投资成分拆分数据表
+SELECT
+ DATAPKID                           -- '物理主键'
+, GRP_ID                            --  '合同组号'
+, MEA_YM                            -- '评估月'
+, N_PRDTYPE                         --  '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 '
+, N_PROFIT_FLAG                     --  '营利性代码|| 1 2 3'
+, N_RISKCLASS                       --  '风险类别|| 保障型 储蓄型'
+, MDL                               --  '适用模型|| BBA VFA PAA '
 ,null   as CSM_CARR_RELS            -- 'CSM_当期_释放比例分子'
 ,null   as CSM_CARR_TOT             -- 'CSM_当期_释放比例分母'
 ,null   as CSM_IF                   -- 'CSM_期初'
@@ -115,5 +116,22 @@ create table HADWS_CONTACT_MEAS_INPUT(
 ,null                               AS ARC_TIME	        --  '归档时间'
 ,''                                 AS MEA_BAT	            --  '计量批次'
 ,''                                 AS ARC_BAT	            --  '归档批次'
-FROM IFRS17.HAODS_SRDB.HADWS_TEAM_PLCRICK_OUT--团险现金流输出接口表
+FROM
+(
+SELECT
+      GRP_ID                            --  '合同组号'
+    , MEA_YM                            -- '评估月'
+    , N_PRDTYPE                         --  '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 '
+    , N_PROFIT_FLAG                     --  '营利性代码|| 1 2 3'
+    , N_RISKCLASS                       --  '风险类别|| 保障型 储蓄型'
+    , MDL                               --  '适用模型|| BBA VFA PAA '
+    , QM_PREM_INC       AS  PREM_INC                           --  '期末_实际_当期_保费收入'
+    , QM_CLM_OUT        AS  CLM_OUT                            --  '期末_实际_当期_赔付及费用'
+    , QMCLM_OUT_CSM     AS  CLM_OUT_CSM                        --  '期末_实际_当期_赔付及费用_投资部分'分
+    , SB_OUT            AS  SB_OUT                             --  '期末_实际_当期_生存金支出'
+    , SB_OUT_CSM        AS  SB_OUT_CSM                         --  '期末_实际_当期_生存金支出_投资部分'分
+    , SUR_OUT           AS  SUR_OUT                            --  '期末_实际_当期_退保支出'
+FROM IFRS17.HAODS_SRDB.HADWS_PERSONAL_INV_SPLIT  s1 --个险投资成分拆分数据表
+
+)
 where s1.MEA_YM = ${MEA_YM}

HAPOC/3-HADWS/HADWS_EXT_JSXJLSJ--精算现金流数据合同组原子指标-Y8.sql

--- HADWS_EXT_JSXJLSJ--精算现金流数据合同组原子指标
-INSERT INTO IFRS17.HAODS_SRDB.HADWS_EXT_JSXJLSJ --精算现金流数据合同组原子指标
+-- HADWS_EXT_JSXJLSJ--HADWS_精算现金流数据合同组原子指标
+INSERT INTO IFRS17.HADWS_SRDB.HADWS_EXT_JSXJLSJ --精算现金流数据合同组原子指标
 SELECT
 GRP_ID                  -- '合同组号'
 ,MEA_YM                 -- '评估月'
@@ -73,5 +73,5 @@ GRP_ID                  -- '合同组号'
 ,null               AS      ARC_TIME	        --  '归档时间'
 ,''                 AS      MEA_BAT	            --  '计量批次'
 ,''                 AS      ARC_BAT	            --  '归档批次'
-FROM IFRS17.HASOURCE_FILE.HADWS_EXT_JSXJLSJ --精算现金流数据合同组原子指标
+FROM IFRS17.HAODS_MYSQL.HADWS_EXT_JSXJLSJ --精算现金流数据合同组原子指标
 

HAPOC/3-HADWS/HADWS_EXT_QMSJTZSY--期末实际投资收益合同组原子指标-Y10.sql

--- HADWS_EXT_QMSJTZSY--期末实际投资收益合同组原子指标
-INSERT INTO IFRS17.HAODS_SRDB.HADWS_EXT_QMSJTZSY -- 期末实际投资收益合同组原子指标
+-- HADWS_EXT_QMSJTZSY--HADWS_期末实际投资收益合同组原子指标
+INSERT INTO IFRS17.HADWS_SRDB.HADWS_EXT_QMSJTZSY -- 期末实际投资收益合同组原子指标
 SELECT
  GRP_ID              -- '合同组号'
 , MEA_YM             -- '评估月'
@@ -16,4 +16,4 @@ SELECT
 ,null               AS      ARC_TIME	        --  '归档时间'
 ,''                 AS      MEA_BAT	            --  '计量批次'
 ,''                 AS      ARC_BAT	            --  '归档批次'
-FROM IFRS17.HASOURCE_FILE.HADWS_EXT_QMSJTZSY -- 期末实际投资收益合同组原子指标
+FROM IFRS17.HAODS_MYSQL.HADWS_EXT_QMSJTZSY -- 期末实际投资收益合同组原子指标

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

--- HADWS_PERSONAL_INV_SPLIT--个险投资成分拆分数据表
-INSERT INTO IFRS17.HAODS_SRDB.HADWS_PERSONAL_INV_SPLIT --个险投资成分拆分数据表
+-- HADWS_PERSONAL_INV_SPLIT--HADWS_个险投资成分拆分数据表
+INSERT INTO IFRS17.HADWS_SRDB.HADWS_PERSONAL_INV_SPLIT --个险投资成分拆分数据表
 SELECT
 ConcatObjUDF(MEA_YM,N_RISKCLASS,N_PRDTYPE,MDL,N_PROFIT_FLAG,GRP_ID,N_GRP__ID)
                                     AS DATAPKID             -- 物理主键

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

--- HADWS_PERSONAL_PAY_IN--个险现金流输入接口表
-INSERT INTO IFRS17.HADWS_SRDB.HADWS_PERSONAL_PAY_IN -- 个险现金流输入接口表
+-- HADWS_PERSONAL_PLCRICK_IN--HADWS_个险现金流输入接口表
+INSERT INTO IFRS17.HADWS_SRDB.HADWS_PERSONAL_PLCRICK_IN -- 个险现金流输入接口表
 SELECT
 ConcatObjUDF(MEA_YM,PLC_ID)
                                     AS DATAPKID             -- 物理主键

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

--- HADWS_PERSONAL_PLCRICK_OUT--个险现金流输出接口表
+-- HADWS_PERSONAL_PLCRICK_OUT--HADWS_个险现金流输出接口表
 INSERT INTO IFRS17.HADWS_SRDB.HADWS_PERSONAL_PLCRICK_OUT -- 个险现金流输出接口表
 SELECT
 ConcatObjUDF(MEA_YM,PLC_ID)
@@ -35,12 +35,12 @@ ConcatObjUDF(MEA_YM,PLC_ID)
 ,null               AS      ARC_TIME	        --  '归档时间'
 ,''                 AS      MEA_BAT	            --  '计量批次'
 ,''                 AS      ARC_BAT	            --  '归档批次'
-FROM IFRS17.HAODS_SRDB.HADWS_PERSONAL_PLCRICK_IN s1-- 个险现金流输入接口表
-LEFT JOIN IFRS17.HASOURCE_SRDB.HADIM_LRISKPROF s2 -- 长险营利性配置信息
+FROM IFRS17.HADWS_SRDB.HADWS_PERSONAL_PLCRICK_IN s1-- 个险现金流输入接口表
+LEFT JOIN 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.HASOURCE_SRDB.HADIM_SRISKPROF s3 --短险营利性配置信息
+LEFT JOIN IFRS17.HAODS_SRDB.HADIM_SRISKPROF s3 --短险营利性配置信息
 ON s1.N_CDX ='短险'  and s1.N_PRD_CODE = s3.PRDCODE
-LEFT JOIN IFRS17.HASOURCE_SRDB. HAODS_EXT_CONCATINFO  s4 --合同分组基本信息
+LEFT JOIN IFRS17.HAODS_SRDB. 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
 where s1.MEA_YM = ${MEA_YM}

HAPOC/3-HADWS/HADWS_TEAM_INV_SPLIT--团险投资成分拆分数据表.sql

--- HADWS_TEAM_INV_SPLIT--团险投资成分拆分数据表
+-- HADWS_TEAM_INV_SPLIT--HADWS_团险投资成分拆分数据表
 INSERT INTO IFRS17.HADWS_SRDB.HADWS_TEAM_INV_SPLIT --团险投资成分拆分数据表
 SELECT
 ConcatObjUDF(MEA_YM,N_RISKCLASS,N_PRDTYPE,MDL,N_PROFIT_FLAG,GRP_ID,N_GRP__ID)
@@ -95,7 +95,7 @@ FROM (
         ,cast(s3.ACCI_DAY_CV as decimal)    AS ACCI_DAY_CV          -- '保单现价' ,
         ,s3.CLAIM_REVIEW_CODE               AS CLAIM_REVIEW_CODE    -- '给付责任类型 || 理赔 理赔（豁免） 生存金' ,
         FROM IIFRS17.HAODS_SRDB.HAODS_TEAM_PAY s1 --现金流_团险
-        LEFT JOIN IFRS17.HAODS_SRDB.HADWS_TEAM_PLCRICK_OUT s2-- 团险现金流输出接口表
+        LEFT JOIN IFRS17.HADWS_SRDB.HADWS_TEAM_PLCRICK_OUT s2-- 团险现金流输出接口表
         ON s1.GRP_INS_PLC_ID = s2.GRP_INS_PLC_ID
         LEFT JOIN IFRS17.HAODS_SRDB.HAODS_TEAM_LP s3 --理赔数据_团险
         ON s1.GRP_INS_PLC_ID = s2.GRP_INS_PLC_ID and s1.BUSI_NO = s2.CLAIM_NO

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

--- HADWS_TEAM_PLCRICK_IN--团险现金流输入接口表
+-- HADWS_TEAM_PLCRICK_IN--HADWS_团险现金流输入接口表
 INSERT INTO IFRS17.HADWS_SRDB.HADWS_TEAM_PLCRICK_IN     --团险现金流输入接口表
 SELECT
 ConcatObjUDF(MEA_YM,GRP_INS_PLC_ID)

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

--- HADWS_TEAM_PLCRICK_OUT--团险现金流输出接口表
+-- HADWS_TEAM_PLCRICK_OUT--HADWS_团险现金流输出接口表
 INSERT INTO IFRS17.HADWS_SRDB.HADWS_TEAM_PLCRICK_OUT --团险现金流输出接口表
 SELECT
 ConcatObjUDF(MEA_YM,GRP_INS_PLC_ID)
@@ -35,12 +35,12 @@ ConcatObjUDF(MEA_YM,GRP_INS_PLC_ID)
 ,''                 AS      MEA_BAT	            --  '计量批次'
 ,''                 AS      ARC_BAT	            --  '归档批次'
 
-FROM IFRS17.HAODS_SRDB.HADWS_TEAM_PLCRICK_OUT s1 -- 团险现金流输入接口表
+FROM IFRS17.HADWS_SRDB.HADWS_TEAM_PLCRICK_OUT 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.HASOURCE_SRDB.HADIM_SRISKPROF s3 --短险营利性配置信息
+LEFT JOIN IFRS17.HAODS_SRDB.HADIM_SRISKPROF s3 --短险营利性配置信息
 ON s1.N_CDX ='短险'  and s1.N_PRD_CODE = s3.PRDCODE
-LEFT JOIN IFRS17.HASOURCE_SRDB. HAODS_EXT_CONCATINFO  s4 --合同分组基本信息
+LEFT JOIN IFRS17.HAODS_SRDB. HAODS_EXT_CONCATINFO  s4 --合同分组基本信息
 ON s1.N_PRDTYPE = s4.N_PRDTYPE  and s1.N_CYEAR_D = s4.N_CYEAR_D
 and s3.PROFIT_FLAG   = s4.N_PROFIT_FLAG
 where s1.MEA_YM = ${MEA_YM}