初始化6

1.sql

+insert into ODS_CK.ODS_CK_MYSQL.callback
+select
+--     '1'        as frameNo
+--     ,text	as errorMessage
+    JsonValueUDF(text,'frameNo')        as frameNo
+    ,JsonValueUDF(text,'errorMessage')	as errorMessage
+    ,'0'		as requestType
+    ,'0'		as requestTime
+    ,'0'		as insurerCompanyType
+    ,'0'		as insurerCode
+    ,'0'		as insurerName
+    ,'0'		as lastStartTime
+    ,'0'		as lastEndTime
+
+    -- ,coalesce(pltCompetitionReinsureEOList[1].requestType,'')         as requestType
+    -- ,coalesce(pltCompetitionReinsureEOList[1].requestTime,'')					as requestTime
+    -- ,coalesce(pltCompetitionReinsureEOList[1].insurerCompanyType,'')	as insurerCompanyType
+    -- ,coalesce(pltCompetitionReinsureEOList[1].insurerCode,'')					as insurerCode
+    -- ,coalesce(pltCompetitionReinsureEOList[1].insurerName,'')					as insurerName
+    -- ,coalesce(pltCompetitionReinsureEOList[1].lastStartTime,'')				as lastStartTime
+    -- ,coalesce(pltCompetitionReinsureEOList[1].lastEndTime,'')					as lastEndTime
+from  ODS.source_callback.CALLBACK
+;
\ No newline at end of file

HAPOC/0-DDL/0-HASOURCE/HASOURCE_EXT_CONCATINFO--合同分组基本信息.sql → HAPOC/0-DDL/0-HASOURCE-mysql/HASOURCE_EXT_CONCATINFO--合同分组基本信息.sql

@@ -11,5 +11,7 @@ create table db_ifrs17hengan.hasource_ext_concatinfo
     N_CYEAR          varchar(64) null comment '发单年',
     PROFIT_LOSS_FLAG varchar(64) null comment '盈亏 || 亏损组 盈利组 厚利组 ',
     METHOD           varchar(64) null comment '过渡方法 || FVA MRA'
-);
+)
+    comment '法定准备金数据' charset = utf8mb3;
+
 

HAPOC/0-DDL/0-HASOURCE/HASOURCE_EXT_CS--待分摊费用获取费用&维护费用-Y9.sql → HAPOC/0-DDL/0-HASOURCE-mysql/HASOURCE_EXT_CS--待分摊费用获取费用&维护费用-Y9.sql

@@ -4,5 +4,7 @@ create table db_ifrs17hengan.hasource_ext_cs
     N_CDX    varchar(64)    not null comment '长短险|| 长险 短险',
     CS_ITEM  varchar(64)    not null comment '待分摊项|| 获取费用 维持费用',
     CS_AMONT decimal(18, 4) null comment '待分摊项金额'
-);
+)
+    comment '理赔数据_团险' charset = utf8mb3;
+
 

HAPOC/0-DDL/0-HASOURCE/HASOURCE_EXT_INCURRED-法定准备金数据.sql → HAPOC/0-DDL/0-HASOURCE-mysql/HASOURCE_EXT_INCURRED-法定准备金数据.sql

@@ -4,5 +4,7 @@ create table db_ifrs17hengan.hasource_ext_incurred
     N_CHNL     varchar(64) not null comment '渠道 || BK FC AD GP EC EL ',
     N_PRDCODE  varchar(64) not null comment '产品代码',
     N_INCURRED varchar(64) null comment '法定准备金'
-);
+)
+    comment '理赔数据_团险' charset = utf8mb3;
+
 

HAPOC/0-DDL/0-HASOURCE/HASOURCE_EXT_JSXJLSJ--精算现金流数据合同组原子指标-dws.sql → HAPOC/0-DDL/0-HASOURCE-mysql/HASOURCE_EXT_JSXJLSJ--精算现金流数据合同组原子指标-dws.sql

@@ -68,5 +68,7 @@ create table db_ifrs17hengan.hasource_ext_jsxjlsj
     TVOG_ACTL_BS_EOP     decimal(18, 4) null comment '期末_当前利率_未来_TVOG',
     TVOG_EXPC            decimal(18, 4) null comment '期末_预期_TVOG'
 
-);
+)
+    comment '期末实际投资收益合同组原子指标' charset = utf8mb3;
+
 

HAPOC/0-DDL/0-HASOURCE/HASOURCE_EXT_QMSJTZSY--期末实际投资收益合同组原子指标-dws.sql → HAPOC/0-DDL/0-HASOURCE-mysql/HASOURCE_EXT_QMSJTZSY--期末实际投资收益合同组原子指标-dws.sql

@@ -12,5 +12,6 @@ create table db_ifrs17hengan.hasource_ext_qmsjtzsy
     IFIE_UI_PL       varchar(64) null comment '期末_实际_UI投资收益_PL部分',
     IFIE_UI_OCI      varchar(64) null comment '期末_实际_UI投资收益_OCI部分'
 
-);
+)    comment '理赔数据_团险' charset = utf8mb3;
+
 

HAPOC/0-DDL/0-HASOURCE/HASOURCE_EXT_SHARECS--资产份额与账户价值分摊载体.sql → HAPOC/0-DDL/0-HASOURCE-mysql/HASOURCE_EXT_SHARECS--资产份额与账户价值分摊载体.sql

@@ -5,5 +5,7 @@ create table db_ifrs17hengan.hasource_ext_sharecs
     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        '
-);
+)
+    comment '资产份额与账户价值数据' charset = utf8mb3;
+
 

HAPOC/0-DDL/0-HASOURCE/HASOURCE_EXT_SHAREVAL--资产份额与账户价值数据.sql → HAPOC/0-DDL/0-HASOURCE-mysql/HASOURCE_EXT_SHAREVAL--资产份额与账户价值数据.sql

@@ -2,5 +2,7 @@ create table db_ifrs17hengan.hasource_ext_shareval
 (
     N_SHARE varchar(64) not null comment '资产份额' ,
     N_CV    varchar(64) null comment '账户价值'
-);
+)
+
+    comment '理赔数据_团险' charset = utf8mb3;
 

HAPOC/0-DDL/0-HASOURCE/HASOURCE_PERSONAL_LP--理赔数据_个人业务.sql → HAPOC/0-DDL/0-HASOURCE-mysql/HASOURCE_PERSONAL_LP--理赔数据_个人业务.sql

@@ -9,5 +9,7 @@ create table db_ifrs17hengan.hasource_personal_lp
     CLAIM_PAY_AMNT    varchar(64) null comment '理赔金额',
     ACCI_DATE         varchar(64) null comment '出险日期',
     CLOSE_DATE        varchar(64) null comment '核赔通过日期'
-);
+)
+    comment '现金流_个人业务' charset = utf8mb3;
+
 

HAPOC/0-DDL/0-HASOURCE/HASOURCE_PERSONAL_PAY--现金流_个人业务.sql → HAPOC/0-DDL/0-HASOURCE-mysql/HASOURCE_PERSONAL_PAY--现金流_个人业务.sql

@@ -15,5 +15,7 @@ create table db_ifrs17hengan.hasource_personal_pay
     N_CURRENCY          varchar(64) null comment '币种 || 人民币',
     AMNT                varchar(64) null comment '金额',
     N_BUS_DATE          varchar(64) null comment '业务日期'
-);
+)
+    comment '理赔数据_团险' charset = utf8mb3;
+
 

HAPOC/0-DDL/0-HASOURCE/HASOURCE_PERSONAL_PLCRICK--保单险种明细_个人业务.sql → HAPOC/0-DDL/0-HASOURCE-mysql/HASOURCE_PERSONAL_PLCRICK--保单险种明细_个人业务.sql

@@ -19,5 +19,7 @@ create table db_ifrs17hengan.hasource_personal_plcrick
     DIVID_COLL_METHOD  varchar(64) null comment '生存金领取方式 || 自动给付 累计生息',
     N_CDX              varchar(64) null comment '长短险标识 || 长险 短险 极短险',
     STS                varchar(64) null comment '保单状态 || 生效 满期终止 签单 保单退保 犹豫期退保'
-);
+)
+    comment '保单险种明细_个人业务' charset = utf8mb3;
+
 

HAPOC/0-DDL/0-HASOURCE-mysql/HASOURCE_XDYKJG--新单盈亏结果.sql

+create table db_ifrs17hengan.HASOURCE_XDYKJG
+(
+    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
+)
+comment '险种盈亏结果表' charset = utf8mb3
+
+-- PRIMARY KEY (SPLIC,SPCODE,MODEL_POINT,CHANNEL,COMPCODE)
+-- DISTRIBUTED BY HASH (SPCODE)
+
+;
+

HAPOC/0-DDL/1-HAODS/HAODS_XDYKJG--新单盈亏结果.sql

+create table db_ifrs17hengan.HAODS_XDYKJG
+(
+    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
+)
+-- comment '险种盈亏结果表' charset = utf8mb3
+
+PRIMARY KEY (SPLIC,SPCODE,MODEL_POINT,CHANNEL,COMPCODE)
+DISTRIBUTED BY HASH (SPCODE)
+
+;
+

HAPOC/1-HAODS/HAODS_PERSONAL_PAY--现金流_个人业务.sql

@@ -18,4 +18,4 @@ SELECT
      ,N_BUS_DATE             -- '业务日期'
      ,LOCALTIMESTAMP   AS   LOGTIME
 
-FROM IFRS17_DP.IFRS17_HASOURCE_MYSQL.HAODS_PERSONAL_PAY  -- 现金流_个人业务
+FROM IFRS17_DP.IFRS17_HASOURCE_MYSQL.HAODS_PERSONAL_PAY  -- 现金流_个人业务
\ No newline at end of file

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

@@ -119,6 +119,7 @@ FROM (
                 AND s1.RISK_CODE = s2.PLC_RISK_CODE
                 and s2.MEA_YM = cast('${MEA_YM}' as int)
                 and s1.PERSONAL_RISK_CODE = s2.PERSONAL_RISK_CODE
+
             LEFT JOIN (
                     SELECT
                     GRP_INS_PLC_ID