指标计算承保字段调整

XF_DWD/XF_DWD_ENDOR.sql

@@ -41,6 +41,6 @@ select
     s1.businessNo                  ,                        -- 业务单号
 
     t1.LEVEL1COMCODE  -- 分公司代码
-from  ODS.ODS_KAFKA.ENDOR s1
-left join ZB_ODS.ZB_ODS_MYSQL.CD_COM_ALL for system_time as of s1.proctime as t1 on s1.businessOffice = t1.COMCODE
+from  XF_ODS.XF_ODS_KAFKA.ENDOR s1
+left join XF_ODS.XF_ODS_MYSQL.CD_COM_ALL for system_time as of s1.proctime as t1 on s1.businessOffice = t1.COMCODE
 

XF_DWD/XF_DWD_POLICY.sql

@@ -42,8 +42,8 @@ select
     s1.actualId                   ,                        -- 指标新增_唯一标识需验证
 
     t1.LEVEL1COMCODE  -- 分公司代码
-from  ODS.ODS_KAFKA.POLICY s1
-left join ZB_ODS.ZB_ODS_MYSQL.CD_COM_ALL for system_time as of s1.proctime as t1 on s1.businessOffice = t1.COMCODE
+from  XF_ODS.XF_ODS_KAFKA.POLICY s1
+left join XF_ODS.XF_ODS_MYSQL.CD_COM_ALL for system_time as of s1.proctime as t1 on s1.businessOffice = t1.COMCODE
 
 
 

XF_DWD/XF_DWD_REGIST.sql

@@ -4,7 +4,7 @@ select
     DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd HH:mm:ss')      as log_time , -- 加工平台处理数据时间
 
     t1.LEVEL1COMCODE  -- 分公司代码
-from  ODS.ODS_KAFKA.POLICY s1
-left join ZB_ODS.ZB_ODS_MYSQL.CD_COM_ALL for system_time as of s1.proctime as t1 on s1.businessOffice = t1.COMCODE
+from  XF_ODS.XF_ODS_KAFKA.POLICY s1
+left join XF_ODS.XF_ODS_MYSQL.CD_COM_ALL for system_time as of s1.proctime as t1 on s1.businessOffice = t1.COMCODE