初始化10

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

 -- HADIM_LRISKPROF--长险营利性配置信息
 create table HADIM_LRISKPROF(
 -- 产品代码,渠道,发单年,盈利性代码
-PRDCODE              varchar(64) 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'
@@ -13,12 +13,3 @@ PRIMARY KEY (PRDCODE,CHNL,CYEAR)
 DISTRIBUTED BY HASH (N_CHNL)
 ;
 
-
-INSERT INTO IFRS17_DP.IFRS17_HAODS_SRDB.HADIM_LRISKPROF
-SELECT
-  PRDCODE
-, CHNL
-, CYEAR
-, PROFIT_FLAG
-FROM IFRS17_DP.IFRS17_HASOURCE_MYSQL.HADIM_LRISKPROF
-;
\ No newline at end of file

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

@@ -14,15 +14,3 @@ MDL                  String default null comment '适用模型|| BBA VFA PAA '
 PRIMARY KEY (PRDCODE,CHNL)
 DISTRIBUTED BY HASH (PRDCODE)
 ;
-
-
-INSERT INTO IFRS17_DP.IFRS17_HAODS_SRDB.HADIM_PRDINFO
-SELECT
-  PRDCODE
-  , CHNL
-, PRDNAME
-, RISKCLASS
-, PRDTYPE
-, CDX
-, MDL
-FROM IFRS17_DP.IFRS17_HASOURCE_MYSQL.HADIM_PRDINFO

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

 -- HADIM_SRISKPROF--短险营利性配置信息
 create table HADIM_SRISKPROF(
-PRDCODE              varchar(64) not null comment '产品代码' ,
+PRDCODE              varchar(64) not null comment '产品代码 （险种）' ,
 PROFIT_FLAG          varchar(64) default null comment '盈利性代码|| 1 2 3'
 )
 -- comment '短险营利性配置信息' charset = utf8mb3
@@ -10,9 +10,3 @@ PRIMARY KEY (PRDCODEL)
 DISTRIBUTED BY HASH (PRDCODE)
 ;
 
-
-INSERT INTO IFRS17_DP.IFRS17_HAODS_SRDB.HADIM_SRISKPROF
-SELECT
-PRDCODE
-,PROFIT_FLAG
-FROM IFRS17_DP.IFRS17_HASOURCE_MYSQL.HADIM_SRISKPROF

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

+-- HADIM_LRISKPROF--长险营利性配置信息
+INSERT INTO IFRS17_DP.IFRS17_HAODS_SRDB.HADIM_LRISKPROF
+SELECT
+  PRDCODE
+, CHNL
+, CYEAR
+, PROFIT_FLAG
+FROM IFRS17_DP.IFRS17_HASOURCE_MYSQL.HADIM_LRISKPROF
+;
\ No newline at end of file

HAPOC/0-HADIM/HADIM_LRISKPROF_2--长险盈利性配置_2.sql

+/* HADIM_LRISKPROF_2 HADIM_长险盈利性配置_2 */
+INSERT INTO db_ifrs17hengan.HADIM_LRISKPROF /* HADIM_长险盈利性配置_2 */
+SELECT
+  COMPCODE                   as PRDCODE        /* '产品代码 （险种）' , */
+, CHANNEL                    as CHNL           /* '渠道|| AD BK EC EL FC GP ' , */
+, LEFT('${MEA_YM}',4)        as CYEAR          /* '发单年|| 2021 2022 2023 2024 ' , */
+, PROFIT_FLAG                as PROFIT_FLAG    /* '盈利性代码|| 1 2 3' */
+FROM (
+
+    SELECT
+           CHANNEL                  /* 渠道 */
+         , COMPCODE                 /* 险种 */
+         , CASE
+                WHEN ZXD_75_NUM >0 and JXJL_75 > 0   THEN  '1'  /*亏损*/
+                WHEN ZXD_95_NUM >0 and JXJL_95 < 0   THEN  '2'  /*薄利*/
+                WHEN ZXD_75_NUM >0 OR ZXD_95_NUM > 0 THEN  '3'  /*厚利*/
+            ELSE '' end         AS PROFIT_FLAG   /* '盈利性代码|| 1 2 3' */
+                   /* '1' then 'RG' 亏损  , '2' then 'LP' 薄利 , '3' then 'HP' 厚利 */
+    FROM (
+        SELECT
+                 CHANNEL            /* 渠道 */
+               , COMPCODE           /* 险种 */
+               , ZXD_75_NUM                                              AS ZXD_75_NUM  /*75%置信度 用于count计算 */
+               , I17_GPV_PL_SUM_75+I17_RA_PL_SUM_75+I17_TVOG_PL_SUM_75   AS JXJL_75     /*75%净现值*/
+               , ZXD_95_NUM                                              AS ZXD_95_NUM  /*95%置信度 用于count计算 */
+               , I17_GPV_PL_SUM_95+I17_RA_PL_SUM_95+I17_TVOG_PL_SUM_95   AS JXJL_95     /*95%净现值*/
+        FROM (
+            SELECT
+                 CHANNEL            /* 渠道 */
+               , COMPCODE           /* 险种 */
+               , SUM(cast(IF( trim(SPCODE) = '1' ,'1','0')             as decimal(18,4)))     AS ZXD_75_NUM            /* 75%置信度标志 用于count计算 */
+               , SUM(cast(IF( trim(SPCODE) = '1' ,I17_CSM_PL_SUM ,'0') as decimal(18,4)))     AS I17_CSM_PL_SUM_75     /* 75%组合CSM=汇总(产品代码.I17_CSM_PL_SUM）*/
+               , SUM(cast(IF( trim(SPCODE) = '1' ,I17_GPV_PL_SUM ,'0') as decimal(18,4)))     AS I17_GPV_PL_SUM_75     /* 75%组合LC=汇总(产品代码.I17_GPV_PL_SUM) */
+               , SUM(cast(IF( trim(SPCODE) = '1' ,I17_LC_PL_SUM  ,'0') as decimal(18,4)))     AS I17_LC_PL_SUM_75      /* 75%组合现金流=汇总(产品代码.I17_LC_PL_SUM) */
+               , SUM(cast(IF( trim(SPCODE) = '1' ,I17_RA_PL_SUM  ,'0') as decimal(18,4)))     AS I17_RA_PL_SUM_75      /* 75%组合RA=汇总(产品代码.I17_RA_PL_SUM) */
+               , SUM(cast(IF( trim(SPCODE) = '1' ,I17_TVOG_PL_SUM,'0') as decimal(18,4)))     AS I17_TVOG_PL_SUM_75    /* 75%组合TVOG=汇总(产品代码.I17_TVOG_PL_SUM) */
+
+               , SUM(cast(IF( trim(SPCODE) = '2' ,'1','0')             as decimal(18,4)))     AS ZXD_95_NUM            /* 95%置信度标志 用于count计算 */
+               , SUM(cast(IF( trim(SPCODE) = '2' ,I17_CSM_PL_SUM ,'0') as decimal(18,4)))     AS I17_CSM_PL_SUM_95     /* 95%组合CSM=汇总(产品代码.I17_CSM_PL_SUM）*/
+               , SUM(cast(IF( trim(SPCODE) = '2' ,I17_GPV_PL_SUM ,'0') as decimal(18,4)))     AS I17_GPV_PL_SUM_95     /* 95%组合LC=汇总(产品代码.I17_GPV_PL_SUM) */
+               , SUM(cast(IF( trim(SPCODE) = '2' ,I17_LC_PL_SUM  ,'0') as decimal(18,4)))     AS I17_LC_PL_SUM_95      /* 95%组合现金流=汇总(产品代码.I17_LC_PL_SUM) */
+               , SUM(cast(IF( trim(SPCODE) = '2' ,I17_RA_PL_SUM  ,'0') as decimal(18,4)))     AS I17_RA_PL_SUM_95      /* 95%组合RA=汇总(产品代码.I17_RA_PL_SUM) */
+               , SUM(cast(IF( trim(SPCODE) = '2' ,I17_TVOG_PL_SUM,'0') as decimal(18,4)))     AS I17_TVOG_PL_SUM_95    /* 95%组合TVOG=汇总(产品代码.I17_TVOG_PL_SUM) */
+
+            FROM db_ifrs17hengan.HAODS_XDYKJG  s1 /* 险种盈亏结果表 */
+            LEFT JOIN db_ifrs17hengan.HADIM_PRDINFO s2 /* 产品基本信息  */
+            ON s1.CHANNEL = s2.CHNL and s1.COMPCODE = s2.PRDCODE
+            where s2.CDX = '长险'
+            GROUP BY
+                  CHANNEL            /* 渠道 */
+                , COMPCODE           /* 险种 */
+        ) d1
+    ) b1
+) a1
+
+
+
+
+

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

+-- HADIM_PRDINFO--产品基本信息
+INSERT INTO IFRS17_DP.IFRS17_HAODS_SRDB.HADIM_PRDINFO
+SELECT
+  PRDCODE
+, CHNL
+, PRDNAME
+, RISKCLASS
+, PRDTYPE
+, CDX
+, MDL
+FROM IFRS17_DP.IFRS17_HASOURCE_MYSQL.HADIM_PRDINFO
+

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

+-- HADIM_SRISKPROF--短险营利性配置信息
+INSERT INTO IFRS17_DP.IFRS17_HAODS_SRDB.HADIM_SRISKPROF
+SELECT
+PRDCODE
+,PROFIT_FLAG
+FROM IFRS17_DP.IFRS17_HASOURCE_MYSQL.HADIM_SRISKPROF

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

+/*HADIM_SRISKPROF_2 短险营利性配置信息*/
+INSERT INTO db_ifrs17hengan.HADIM_SRISKPROF /* HADIM_短险营利性配置信息_2 */
+SELECT
+  COMPCODE                   as PRDCODE        /* '产品代码 （险种）' , */
+, PROFIT_FLAG                as PROFIT_FLAG    /* '盈利性代码|| 1 2 3' */
+FROM (
+
+    SELECT
+           COMPCODE           /* 险种 */
+         , CASE
+                WHEN ZXD_75_NUM >0 and JXJL_75 > 0   THEN  '1'  /*亏损*/
+                WHEN ZXD_95_NUM >0 and JXJL_95 < 0   THEN  '2'  /*薄利*/
+                WHEN ZXD_75_NUM >0 OR ZXD_95_NUM > 0 THEN  '3'  /*厚利*/
+            ELSE '' end                     AS PROFIT_FLAG  /* '盈利性代码|| 1 2 3' */
+                   /* '1' then 'RG' 亏损  , '2' then 'LP' 薄利 , '3' then 'HP' 厚利 */
+    FROM (
+        SELECT
+                 COMPCODE           /* 险种 */
+               , ZXD_75_NUM                                              AS ZXD_75_NUM  /*75%置信度 用于count计算 */
+               , I17_GPV_PL_SUM_75+I17_RA_PL_SUM_75+I17_TVOG_PL_SUM_75   AS JXJL_75     /*75%净现值*/
+               , ZXD_95_NUM                                              AS ZXD_95_NUM  /*95%置信度 用于count计算 */
+               , I17_GPV_PL_SUM_95+I17_RA_PL_SUM_95+I17_TVOG_PL_SUM_95   AS JXJL_95     /*95%净现值*/
+        FROM (
+            SELECT
+                  COMPCODE           /* 险种 */
+               , SUM(cast(IF( trim(SPCODE) = '1' ,'1','0')             as decimal(18,4)))     AS ZXD_75_NUM            /* 75%置信度标志 用于count计算 */
+               , SUM(cast(IF( trim(SPCODE) = '1' ,I17_CSM_PL_SUM ,'0') as decimal(18,4)))     AS I17_CSM_PL_SUM_75     /* 75%组合CSM=汇总(产品代码.I17_CSM_PL_SUM）*/
+               , SUM(cast(IF( trim(SPCODE) = '1' ,I17_GPV_PL_SUM ,'0') as decimal(18,4)))     AS I17_GPV_PL_SUM_75     /* 75%组合LC=汇总(产品代码.I17_GPV_PL_SUM) */
+               , SUM(cast(IF( trim(SPCODE) = '1' ,I17_LC_PL_SUM  ,'0') as decimal(18,4)))     AS I17_LC_PL_SUM_75      /* 75%组合现金流=汇总(产品代码.I17_LC_PL_SUM) */
+               , SUM(cast(IF( trim(SPCODE) = '1' ,I17_RA_PL_SUM  ,'0') as decimal(18,4)))     AS I17_RA_PL_SUM_75      /* 75%组合RA=汇总(产品代码.I17_RA_PL_SUM) */
+               , SUM(cast(IF( trim(SPCODE) = '1' ,I17_TVOG_PL_SUM,'0') as decimal(18,4)))     AS I17_TVOG_PL_SUM_75    /* 75%组合TVOG=汇总(产品代码.I17_TVOG_PL_SUM) */
+
+               , SUM(cast(IF( trim(SPCODE) = '2' ,'1','0')             as decimal(18,4)))     AS ZXD_95_NUM            /* 95%置信度标志 用于count计算 */
+               , SUM(cast(IF( trim(SPCODE) = '2' ,I17_CSM_PL_SUM ,'0') as decimal(18,4)))     AS I17_CSM_PL_SUM_95     /* 95%组合CSM=汇总(产品代码.I17_CSM_PL_SUM）*/
+               , SUM(cast(IF( trim(SPCODE) = '2' ,I17_GPV_PL_SUM ,'0') as decimal(18,4)))     AS I17_GPV_PL_SUM_95     /* 95%组合LC=汇总(产品代码.I17_GPV_PL_SUM) */
+               , SUM(cast(IF( trim(SPCODE) = '2' ,I17_LC_PL_SUM  ,'0') as decimal(18,4)))     AS I17_LC_PL_SUM_95      /* 95%组合现金流=汇总(产品代码.I17_LC_PL_SUM) */
+               , SUM(cast(IF( trim(SPCODE) = '2' ,I17_RA_PL_SUM  ,'0') as decimal(18,4)))     AS I17_RA_PL_SUM_95      /* 95%组合RA=汇总(产品代码.I17_RA_PL_SUM) */
+               , SUM(cast(IF( trim(SPCODE) = '2' ,I17_TVOG_PL_SUM,'0') as decimal(18,4)))     AS I17_TVOG_PL_SUM_95    /* 95%组合TVOG=汇总(产品代码.I17_TVOG_PL_SUM) */
+
+            FROM db_ifrs17hengan.HAODS_XDYKJG  s1 /* 险种盈亏结果表 */
+            LEFT JOIN db_ifrs17hengan.HADIM_PRDINFO s2 /* 产品基本信息  */
+            ON s1.CHANNEL = s2.CHNL and s1.COMPCODE = s2.PRDCODE
+            where s2.CDX = '短险'
+            GROUP BY
+                COMPCODE           /* 险种 */
+        ) d1
+    ) b1
+) a1
+

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

@@ -7,7 +7,7 @@ md5(concat(       coalesce (js.GRP_ID_INSIDE,'')
                 , coalesce (js.N_PRDTYPE_1,'')
                 , coalesce (js.N_PROFIT_FLAG,'')
                 , coalesce (js.N_RISKCLASS,'')
-                , coalesce (js.MDL    ,'')
+                , coalesce (cast(js.MDL as varchar)    ,'')
                  )       )
                                     AS DATAPKID            /*  物理主键*/
 , coalesce (js.GRP_ID_INSIDE,'') /* '合同组号-内部'*/
@@ -16,11 +16,7 @@ md5(concat(       coalesce (js.GRP_ID_INSIDE,'')
 , js.N_PRDTYPE_1                 /*        '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 '*/
 , js.N_PROFIT_FLAG               /*        '营利性代码|| 1 2 3'*/
 , js.N_RISKCLASS                 /*        '风险类别|| 保障型 储蓄型'*/
-, case
-       when js.MDL = 'VFA'   then 1
-       when js.MDL = 'BBA'   then 2
-       when js.MDL = 'PAA'   then 3
-       else 0 end                   as MDL    /* 适用模型*/
+, js.MDL                           as MDL    /* 适用模型*/
 , js.CSM_CARR_RELS                 as CSM_CARR_RELS            /* 'CSM_当期_释放比例分子'*/
 , js.CSM_CARR_TOT                  as CSM_CARR_TOT             /* 'CSM_当期_释放比例分母'*/
 , js.CSM_IF                        as CSM_IF                   /* 'CSM_期初'*/
@@ -138,11 +134,11 @@ FROM (
                     when con.N_PROFIT_FLAG = '1' then 'RG'   /*亏损*/
                     when con.N_PROFIT_FLAG = '2' then 'LP'   /*薄利*/
                     when con.N_PROFIT_FLAG = '3' then 'HP'   /*厚利*/
-                    else coalesce (con.N_PROFIT_FLAG,'RG') end
+                    else 'RG' end
                 ,','
                 , CASE
                     WHEN con.N_CHNL in ('健康险事业部','寿险险事业部') THEN '事业部'
-                    ELSE coalesce (con.N_CHNL,'个险') END,','
+                    ELSE '个险' END,','
                 ,coalesce (con.N_RISKCLASS,'储蓄型')
                 )                                                   AS GRP_ID_INSIDE   /*  '合同组号-内部'*/
     ,coalesce (con.N_PRDTYPE,'传统险')                              AS N_PRDTYPE_1            /* '产品大类|| 传统险 分红险 累积式分红 投连险 万能险 ' ,*/
@@ -150,10 +146,14 @@ FROM (
         when con.N_PROFIT_FLAG = '1' then 'RG'   /*亏损*/
         when con.N_PROFIT_FLAG = '2' then 'LP'   /*薄利*/
         when con.N_PROFIT_FLAG = '3' then 'HP'   /*厚利*/
-        else coalesce (con.N_PROFIT_FLAG,'RG') end                  AS N_PROFIT_FLAG
+        else 'RG' end                  AS N_PROFIT_FLAG
     ,coalesce (con.N_RISKCLASS  ,'储蓄型')                           AS N_RISKCLASS          /* '风险类别|| 保障型 储蓄型' ,*/
-    ,coalesce (con.MDL          ,'')                                 AS MDL                  /* '适用模型|| BBA VFA PAA '*/
-    ,js.*
+    ,case
+           when con.MDL = 'VFA'   then 1
+           when con.MDL = 'BBA'   then 2
+           when con.MDL = 'PAA'   then 3
+           else 0 end                                                as MDL    /* 适用模型*/
+    , js.*
     FROM db_ifrs17hengan.HADWS_EXT_JSXJLSJ  js /* 精算现金流数据合同组原子指标 */
     LEFT JOIN db_ifrs17hengan.HAODS_EXT_CONCATINFO  con /*合同分组基本信息*/
     ON js.GRP_ID =con.GRP_ID

HAPOC/4-HAHIS/HADWS_CONCAT_MANAGE_HIS--合同组管理费用_直接部分表_HIS.sql

 /*HADWS_CONCAT_MANAGE_HIS  HADWS_合同组管理费用_直接部分表_HIS*/
-INSERT INTO db_ifrs17hengan.HADWS_CONCAT_MANAGE_HIS /* 合同组管理费用_直接部分表_HIS*/
+INSERT INTO db_ifrs17hengan.HADWS_CONCAT_MANAGE_HIS /* HADWS_合同组管理费用_直接部分表_HIS*/
 SELECT
   DATAPKID            /* 物理主键*/
 , GRP_ID              /* '合同组号' ,*/

HAPOC/4-HAHIS/HADWS_CONTACT_MEAS_INPUT_HIS--合同组计量输入接口表_HIS.sql

 /* HADWS_CONTACT_MEAS_INPUT_HIS  HADWS_合同组计量输入接口表_HIS*/
-INSERT INTO db_ifrs17hengan.HADWS_CONTACT_MEAS_INPUT_HIS /*合同组计量输入接口表_HIS*/
+INSERT INTO db_ifrs17hengan.HADWS_CONTACT_MEAS_INPUT_HIS /*HADWS_合同组计量输入接口表_HIS*/
 SELECT
 
    DATAPKID            /*  物理主键*/

HAPOC/4-HAHIS/HADWS_CONTACT_MEAS_OUTPUT_HIS--合同组计量输出接口表_HIS.sql

+/*HADWS_CONTACT_MEAS_OUTPUT_HIS HADWS_合同组计量输出接口表_HIS*/
 INSERT INTO db_ifrs17hengan.HADWS_CONTACT_MEAS_OUTPUT_HIS
 SELECT
 DATAPKID

HAPOC/4-HAHIS/HADWS_EXT_JSXJLSJ_HIS--精算现金流数据合同组原子指标_HIS-Y8.sql

 /* HADWS_EXT_JSXJLSJ_HIS  HADWS_精算现金流数据合同组原子指标_HIS*/
-INSERT INTO db_ifrs17hengan.HADWS_EXT_JSXJLSJ_HIS /*精算现金流数据合同组原子指标_HIS*/
+INSERT INTO db_ifrs17hengan.HADWS_EXT_JSXJLSJ_HIS /*HADWS_精算现金流数据合同组原子指标_HIS*/
 SELECT
 GRP_ID        /*           '合同组号'*/
 ,MEA_YM       /*   '评估月'*/

HAPOC/4-HAHIS/HADWS_EXT_QMSJTZSY_HIS--期末实际投资收益合同组原子指标_HIS-Y10.sql

 /* HADWS_EXT_QMSJTZSY_HIS  HADWS_期末实际投资收益合同组原子指标_HIS*/
-INSERT INTO db_ifrs17hengan.HADWS_EXT_QMSJTZSY_HIS /* 期末实际投资收益合同组原子指标_HIS*/
+INSERT INTO db_ifrs17hengan.HADWS_EXT_QMSJTZSY_HIS /* HADWS_期末实际投资收益合同组原子指标_HIS*/
 SELECT
  GRP_ID              /* '合同组号'*/
 ,  MEA_YM            /* '评估月'*/

HAPOC/4-HAHIS/HADWS_PERSONAL_INV_SPLIT_HIS--个险投资成分拆分数据表_HIS.sql

-/* HADWS_PERSONAL_INV_SPLIT_HIS  个险投资成分拆分数据表_HIS*/
-INSERT INTO db_ifrs17hengan.HADWS_PERSONAL_INV_SPLIT_HIS /* 个险投资成分拆分数据表_HIS*/
+/* HADWS_PERSONAL_INV_SPLIT_HIS  HADWS_个险投资成分拆分数据表_HIS*/
+INSERT INTO db_ifrs17hengan.HADWS_PERSONAL_INV_SPLIT_HIS /* HADWS_个险投资成分拆分数据表_HIS*/
 SELECT
    DATAPKID    /*          物理主键*/
  , MEA_YM          /*   '评估月'*/

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

-/* HADWS_TEAM_INV_SPLIT_HIS  团险投资成分拆分数据表_HIS*/
-INSERT INTO db_ifrs17hengan.HADWS_TEAM_INV_SPLIT_HIS /*团险投资成分拆分数据表_HIS*/
+/* HADWS_TEAM_INV_SPLIT_HIS  HADWS_团险投资成分拆分数据表_HIS*/
+INSERT INTO db_ifrs17hengan.HADWS_TEAM_INV_SPLIT_HIS /*HADWS_团险投资成分拆分数据表_HIS*/
 SELECT
  DATAPKID         /*     物理主键*/
 , MEA_YM           /*  '评估月'*/