DWD部分加工规则-替换数据源

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

 -- HADWS_CONCAT_MANAGE  HADWS_合同组管理费用_直接部分表
-INSERT INTO IFRS17.IFRS17_HAODS_MYSQL.HADWS_CONCAT_MANAGE -- 合同组管理费用_直接部分表
+INSERT INTO IFRS17.IFRS17_HADWS_SRDB.HADWS_CONCAT_MANAGE -- 合同组管理费用_直接部分表
 SELECT
 ConcatObjUDF(s1.GRP_ID   ,s1.MEA_YM   ,s1.N_PRDTYPE,s1.BUSY_CHAN,s1.N_CDX    ,'1'    )
                                                 AS DATAPKID             -- 物理主键
@@ -16,7 +16,7 @@ ConcatObjUDF(s1.GRP_ID   ,s1.MEA_YM   ,s1.N_PRDTYPE,s1.BUSY_CHAN,s1.N_CDX    ,'1
 ,''                                                          AS MEA_BAT	            --  '计量批次'
 ,''                                                          AS ARC_BAT	            --  '归档批次'
 
-FROM IFRS17.IFRS17_HAODS_MYSQL.HADWS_PERSONAL_PLCRICK_OUT s1 -- 个险现金流输出接口表
+FROM IFRS17.IFRS17_HADWS_SRDB.HADWS_PERSONAL_PLCRICK_OUT s1 -- 个险现金流输出接口表
 where s1.MEA_YM =  cast('${MEA_YM}' as int)
 -- group by
 -- s1.GRP_ID
@@ -40,7 +40,7 @@ ConcatObjUDF(s1.GRP_ID   ,s1.MEA_YM   ,s1.N_PRDTYPE,s1.BUSY_CHAN,s1.N_CDX    ,'2
 ,LOCALTIMESTAMP                                              AS ARC_TIME	        --  '归档时间'
 ,''                                                          AS MEA_BAT	            --  '计量批次'
 ,''                                                          AS ARC_BAT	            --  '归档批次'
-FROM IFRS17.IFRS17_HAODS_MYSQL.HADWS_TEAM_PLCRICK_OUT s1 -- 团险现金流输出接口表
+FROM IFRS17.IFRS17_HADWS_SRDB.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 --团险投资成分拆分数据表
+INSERT INTO IFRS17.IFRS17_HADWS_SRDB.HADWS_CONTACT_MEAS_INPUT --团险投资成分拆分数据表
 SELECT
 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             -- 物理主键
@@ -138,7 +138,7 @@ FROM
         , CLM_OUT_LIC       AS CLM_OUT_LIC          --   期末_实际_当期_赔付及费用待支付_LIC部分
         , CLM_OUT_CSM_LIC   AS CLM_OUT_CSM_LIC      --   期末_实际_当期_赔付及费用待支付_投资部分_LIC部分
         ,IF(MDL = 'PAA',QM_PREM_INC,0) AS PAA_PREM_IN --  '期末_PAA_保险服务收入'
-    FROM IFRS17.IFRS17_HAODS_MYSQL.HADWS_PERSONAL_INV_SPLIT  s1 --个险投资成分拆分数据表
+    FROM IFRS17.IFRS17_HADWS_SRDB.HADWS_PERSONAL_INV_SPLIT  s1 --个险投资成分拆分数据表
     where s1.MEA_YM = cast('${MEA_YM}' as int)
     union all
     SELECT
@@ -161,7 +161,7 @@ FROM
         , CLM_OUT_CSM_LIC   AS CLM_OUT_CSM_LIC      --   期末_实际_当期_赔付及费用待支付_投资部分_LIC部分
         , IF(MDL = 'PAA',QM_PREM_INC,0) AS PAA_PREM_IN --  '期末_PAA_保险服务收入'
 
-    FROM IFRS17.IFRS17_HAODS_MYSQL.HADWS_TEAM_INV_SPLIT s1 --团险投资成分拆分数据表
+    FROM IFRS17.IFRS17_HADWS_SRDB.HADWS_TEAM_INV_SPLIT s1 --团险投资成分拆分数据表
     where s1.MEA_YM =  cast('${MEA_YM}' as int)
 ) a1
 LEFT JOIN (
@@ -170,7 +170,7 @@ LEFT JOIN (
         , MEA_YM                                 --  '评估月'
         , CAST(IFIE_UI_PL  AS DECIMAL(18, 2)) AS IFIE_UI_PL   -- '期末_实际_UI投资收益_PL部分'
         , CAST(IFIE_UI_OCI  AS DECIMAL(18, 2)) AS  IFIE_UI_OCI             -- '期末_实际_UI投资收益_OCI部分'
-    FROM IFRS17.IFRS17_HAODS_MYSQL.HADWS_EXT_QMSJTZSY s1 --期末实际投资收益合同组原子指标
+    FROM IFRS17.IFRS17_HAODS_SRDB.HADWS_EXT_QMSJTZSY s1 --期末实际投资收益合同组原子指标
     where s1.MEA_YM =  cast('${MEA_YM}' as int)
 
 )a2 on a1.GRP_ID= a2.GRP_ID

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

 -- HADWS_EXT_JSXJLSJ  HADWS_精算现金流数据合同组原子指标
-INSERT INTO IFRS17.IFRS17_HAODS_MYSQL.HADWS_EXT_JSXJLSJ --精算现金流数据合同组原子指标
+INSERT INTO IFRS17.IFRS17_HADWS_SRDB.HADWS_EXT_JSXJLSJ --精算现金流数据合同组原子指标
 SELECT
 GRP_ID                  -- '合同组号'
 ,cast('${MEA_YM}' as int)    AS MEA_YM -- '评估月'
@@ -73,5 +73,5 @@ GRP_ID                  -- '合同组号'
 ,LOCALTIMESTAMP     AS      ARC_TIME	        --  '归档时间'
 ,''                 AS      MEA_BAT	            --  '计量批次'
 ,''                 AS      ARC_BAT	            --  '归档批次'
-FROM IFRS17.IFRS17_HAODS_MYSQL.HADWS_EXT_JSXJLSJ --精算现金流数据合同组原子指标
+FROM IFRS17.IFRS17_HAODS_SRDB.HADWS_EXT_JSXJLSJ --精算现金流数据合同组原子指标
 

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

 -- HADWS_EXT_QMSJTZSY  HADWS_期末实际投资收益合同组原子指标
-INSERT INTO IFRS17.IFRS17_HAODS_MYSQL.HADWS_EXT_QMSJTZSY -- 期末实际投资收益合同组原子指标
+INSERT INTO IFRS17.IFRS17_HADWS_SRDB.HADWS_EXT_QMSJTZSY -- 期末实际投资收益合同组原子指标
 SELECT
  GRP_ID              -- '合同组号'
 , cast('${MEA_YM}' as int)    AS MEA_YM -- '评估月'
@@ -16,4 +16,4 @@ SELECT
 ,LOCALTIMESTAMP     AS      ARC_TIME	        --  '归档时间'
 ,''                 AS      MEA_BAT	            --  '计量批次'
 ,''                 AS      ARC_BAT	            --  '归档批次'
-FROM IFRS17.IFRS17_HAODS_MYSQL.HADWS_EXT_QMSJTZSY -- 期末实际投资收益合同组原子指标
+FROM IFRS17.IFRS17_HAODS_SRDB.HADWS_EXT_QMSJTZSY -- 期末实际投资收益合同组原子指标

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

 -- HADWS_PERSONAL_INV_SPLIT  个险投资成分拆分数据表
-INSERT INTO IFRS17.IFRS17_HAODS_MYSQL.HADWS_PERSONAL_INV_SPLIT --个险投资成分拆分数据表
+INSERT INTO IFRS17.IFRS17_HADWS_SRDB.HADWS_PERSONAL_INV_SPLIT --个险投资成分拆分数据表
 SELECT
 MD5(ConcatObjUDF(
     MEA_YM ,N_RISKCLASS,N_PRDTYPE,MDL,N_PROFIT_FLAG,GRP_ID,N_GRP__ID
@@ -116,10 +116,10 @@ FROM (
             ,s2.N_GRP__ID                       AS N_GRP__ID            -- '合同组合号' ,
             ,s2.N_CDX                           AS N_CDX                -- '长短险标识 || 长险 短险 极短险' ,
             ,cast(s3.ACCI_DAY_CV as decimal)    AS ACCI_DAY_CV          -- '保单现价' ,
-            FROM IFRS17.IFRS17_HAODS_MYSQL.HAODS_PERSONAL_PAY s1 --现金流_个人业务
-            LEFT JOIN IFRS17.IFRS17_HAODS_MYSQL.HADWS_PERSONAL_PLCRICK_OUT s2 -- 个险现金流输出接口表
+            FROM IFRS17.IFRS17_HAODS_SRDB.HAODS_PERSONAL_PAY s1 --现金流_个人业务
+            LEFT JOIN IFRS17.IFRS17_HADWS_SRDB.HADWS_PERSONAL_PLCRICK_OUT s2 -- 个险现金流输出接口表
             ON s1.PLC_ID = s2.PLC_ID
-            LEFT JOIN IFRS17.IFRS17_HAODS_MYSQL.HAODS_PERSONAL_LP s3 --理赔数据_个人业务
+            LEFT JOIN IFRS17.IFRS17_HAODS_SRDB.HAODS_PERSONAL_LP s3 --理赔数据_个人业务
             ON s1.PLC_ID = s3.PLC_OD and s1.BUSI_NO = s3.CLAIM_NO
             where s2.PLC_ID is not null
             and s2.MEA_YM = cast('${MEA_YM}' as int)