切换ods承保机构码表

ODS/DDL元数据/CD_COM_ALL.sql

+-- CD_COM_ALL	承保机构码表
+
+CREATE TABLE CD_COM_ALL (
+	COMCODE VARCHAR(10) primary key,
+	COMNAME VARCHAR(128),
+	LEVEL1COMCODE VARCHAR(10),
+	LEVEL2COMCODE VARCHAR(10),
+	LEVEL3COMCODE VARCHAR(10),
+	LEVEL4COMCODE VARCHAR(10),
+	LEVEL5COMCODE VARCHAR(10),
+	LEVEL1COMDESC VARCHAR(128),
+	LEVEL2COMDESC VARCHAR(128),
+	LEVEL3COMDESC VARCHAR(128),
+	LEVEL4COMDESC VARCHAR(128),
+	LEVEL5COMDESC VARCHAR(128),
+	COMLEVEL  decimal(38,0),
+	VALIDFLAG VARCHAR(1)
+);

ODS/DDL元数据/CD_COM_ALL_MIDDLE.sql

+-- CD_COM_ALL_MIDDLE	承保机构过程码表
+
+CREATE TABLE CD_COM_ALL_MIDDLE (
+	COMCODE VARCHAR(10) primary key,
+	COMNAME VARCHAR(128),
+	LEVEL1COMCODE VARCHAR(10),
+	LEVEL2COMCODE VARCHAR(10),
+	LEVEL3COMCODE VARCHAR(10),
+	LEVEL4COMCODE VARCHAR(10),
+	LEVEL5COMCODE VARCHAR(10),
+	LEVEL1COMDESC VARCHAR(128),
+	LEVEL2COMDESC VARCHAR(128),
+	LEVEL3COMDESC VARCHAR(128),
+	LEVEL4COMDESC VARCHAR(128),
+	LEVEL5COMDESC VARCHAR(128),
+	COMLEVEL  decimal(38,0),
+	VALIDFLAG VARCHAR(1)
+);

ODS/DDL元数据/COM_CHANGE_MQ .sql

+-- COM_CHANGE_MQ	rabbitMQ消费信息
+
+CREATE TABLE COM_CHANGE_MQ(
+      updateTime varchar,
+      updateType varchar
+);

ODS/DDL元数据/MQ_MIDDLE.sql

+-- MQ_MIDDLE	rabbitMQ消费信息
+
+CREATE TABLE MQ_MIDDLE(
+      updateTime varchar,
+      updateType varchar
+);

ODS/码表同步/ODS_CD_COM_ALL.sql

+-- ODS_CD_COM_ALL ODS_承保机构_全量
+insert into ODS.ODS_MYSQL.CD_COM_ALL
+select
+s1.COMCODE        
+,s1.COMNAME        
+,s1.LEVEL1COMCODE  
+,s1.LEVEL2COMCODE  
+,s1.LEVEL3COMCODE  
+,s1.LEVEL4COMCODE  
+,s1.LEVEL5COMCODE  
+,s1.LEVEL1COMDESC  
+,s1.LEVEL2COMDESC  
+,s1.LEVEL3COMDESC  
+,s1.LEVEL4COMDESC  
+,s1.LEVEL5COMDESC  
+,s1.COMLEVEL       
+,s1.VALIDFLAG          
+from (
+	select
+		 COMCODE        
+		,COMNAME        
+		,LEVEL1COMCODE  
+		,LEVEL2COMCODE  
+		,LEVEL3COMCODE  
+		,LEVEL4COMCODE  
+		,LEVEL5COMCODE  
+		,LEVEL1COMDESC  
+		,LEVEL2COMDESC  
+		,LEVEL3COMDESC  
+		,LEVEL4COMDESC  
+		,LEVEL5COMDESC  
+		,COMLEVEL       
+		,VALIDFLAG
+		,MD5(ConcatObjUDF(
+			 COMCODE        
+			,COMNAME        
+			,LEVEL1COMCODE  
+			,LEVEL2COMCODE  
+			,LEVEL3COMCODE  
+			,LEVEL4COMCODE  
+			,LEVEL5COMCODE  
+			,LEVEL1COMDESC  
+			,LEVEL2COMDESC  
+			,LEVEL3COMDESC  
+			,LEVEL4COMDESC  
+			,LEVEL5COMDESC  
+			,COMLEVEL       
+			,VALIDFLAG
+		))    AS MD5
+	from ODS.ODS_SOURCE_ORACLE_ANAREPORT11.CD_COM_ALL
+	
+) s1
+left join (
+	select
+		 COMCODE        
+		,COMNAME        
+		,LEVEL1COMCODE  
+		,LEVEL2COMCODE  
+		,LEVEL3COMCODE  
+		,LEVEL4COMCODE  
+		,LEVEL5COMCODE  
+		,LEVEL1COMDESC  
+		,LEVEL2COMDESC  
+		,LEVEL3COMDESC  
+		,LEVEL4COMDESC  
+		,LEVEL5COMDESC  
+		,COMLEVEL       
+		,VALIDFLAG
+		,MD5(ConcatObjUDF(
+			 COMCODE        
+			,COMNAME        
+			,LEVEL1COMCODE  
+			,LEVEL2COMCODE  
+			,LEVEL3COMCODE  
+			,LEVEL4COMCODE  
+			,LEVEL5COMCODE  
+			,LEVEL1COMDESC  
+			,LEVEL2COMDESC  
+			,LEVEL3COMDESC  
+			,LEVEL4COMDESC  
+			,LEVEL5COMDESC  
+			,COMLEVEL       
+			,VALIDFLAG
+		))    AS MD5
+	from ODS.ODS_MYSQL.CD_COM_ALL
+
+) s2 on s1.COMCODE = s2.COMCODE and s1.MD5 = s2.MD5
+where s2.COMCODE is null
\ No newline at end of file

ODS/码表同步/ODS_CD_COM_ALL_ZL.sql

+-- ODS_CD_COM_ALL_ZL
+-- ODS_承保机构_增量
+
+
+insert into ODS.ODS_MYSQL.CD_COM_ALL
+select
+    t1.COMCODE
+     ,t1.COMNAME
+     ,t1.LEVEL1COMCODE
+     ,t1.LEVEL2COMCODE
+     ,t1.LEVEL3COMCODE
+     ,t1.LEVEL4COMCODE
+     ,t1.LEVEL5COMCODE
+     ,t1.LEVEL1COMDESC
+     ,t1.LEVEL2COMDESC
+     ,t1.LEVEL3COMDESC
+     ,t1.LEVEL4COMDESC
+     ,t1.LEVEL5COMDESC
+     ,t1.COMLEVEL
+     ,case when s1.`status` = 'Discarded' then '0'
+           when s1.`status` = 'Effective' then '1'
+    end  as  VALIDFLAG
+from (
+         select
+             u1.`sign`
+              ,u1.`partyId`
+              ,u1.`name`
+              ,u1.`status`
+              ,u1.`rolePartyId`
+              ,m1.proctime
+         from ODS.ODS_MQ.COM_CHANGE_MQ m1
+                  cross join lateral table(MqPushMySqlUDTF(m1.updateTime
+						, m1.updateType
+						, 'http://9.23.28.25/rbac/service/hr/core/structure/structureChanges'
+		)) u1(`sign`, `partyId`, `name`, `status`, `rolePartyId`)
+         where u1.`sign` = 'structureChangeList'
+     ) s1
+         left join ODS.ODS_MYSQL.CD_COM_ALL for system_time as of s1.proctime as  t1 on s1.`partyId` = t1.COMCODE
+;
+
+-- structureRlshipChangeList 有效数据视图
+CREATE TEMPORARY VIEW VIEW_ODS_CD_COM_ALL_TUANDUI AS
+select
+    t1.COMCODE
+     ,t1.COMNAME
+     ,t1.LEVEL1COMCODE
+     ,t1.LEVEL2COMCODE
+     ,t1.LEVEL3COMCODE
+     ,t1.LEVEL4COMCODE
+     ,t1.LEVEL5COMCODE
+     ,t1.LEVEL1COMDESC
+     ,t1.LEVEL2COMDESC
+     ,t1.LEVEL3COMDESC
+     ,t1.LEVEL4COMDESC
+     ,t1.LEVEL5COMDESC
+     ,t1.COMLEVEL
+     ,t1.VALIDFLAG
+     ,s1.`partyId`
+     ,s1.`name`
+     ,s1.`status`
+     ,s1.`rolePartyId`
+from (
+         select
+             u1.`sign`
+              ,u1.`partyId`
+              ,u1.`name`
+              ,u1.`status`
+              ,u1.`rolePartyId`
+              ,m1.proctime
+         from ODS.ODS_MQ.COM_CHANGE_MQ m1
+                  cross join lateral table(MqPushMySqlUDTF(m1.updateTime
+						, m1.updateType
+						, 'http://9.23.28.25/rbac/service/hr/core/structure/structureChanges'
+		)) u1(`sign`, `partyId`, `name`, `status`, `rolePartyId`)
+         where u1.`sign` = 'structureRlshipChangeList'
+           and u1.`status` = 'Effective'
+     ) s1
+         left join ODS.ODS_MYSQL.CD_COM_ALL for system_time as of s1.proctime as t1 on s1.`rolePartyId` = t1.COMCODE
+;
+
+
+-- structureRlshipChangeList 有效数据插入
+insert into ODS.ODS_MYSQL.CD_COM_ALL
+select
+    s1.COMCODE
+     ,s1.COMNAME
+     ,s1.LEVEL1COMCODE
+     ,s1.LEVEL2COMCODE
+     ,s1.LEVEL3COMCODE
+     ,s1.LEVEL4COMCODE
+     ,s1.LEVEL5COMCODE
+     ,s1.LEVEL1COMDESC
+     ,s1.LEVEL2COMDESC
+     ,s1.LEVEL3COMDESC
+     ,s1.LEVEL4COMDESC
+     ,s1.LEVEL5COMDESC
+     ,s1.COMLEVEL
+     ,s1.VALIDFLAG
+from (
+         select
+             a1.`partyId`     as COMCODE
+              ,a1.`name`        as COMNAME
+              ,a1.LEVEL1COMCODE as LEVEL1COMCODE
+              ,a1.LEVEL2COMCODE as LEVEL2COMCODE
+              ,a1.`partyId`     as LEVEL3COMCODE
+              ,a1.`partyId`     as LEVEL4COMCODE
+              ,a1.`partyId`     as LEVEL5COMCODE
+              ,a1.LEVEL1COMDESC as LEVEL1COMDESC
+              ,a1.LEVEL2COMDESC as LEVEL2COMDESC
+              ,a1.`name`        as LEVEL3COMDESC
+              ,a1.`name`        as LEVEL4COMDESC
+              ,a1.`name`        as LEVEL5COMDESC
+              ,a1.COMLEVEL +1   as COMLEVEL
+              ,'1'              as VALIDFLAG
+         from VIEW_ODS_CD_COM_ALL_TUANDUI a1
+         where a1.COMCODE  = a1.LEVEL2COMCODE
+         union all
+         select
+             a1.`partyId`     as COMCODE
+              ,a1.`name`        as COMNAME
+              ,a1.LEVEL1COMCODE as LEVEL1COMCODE
+              ,a1.LEVEL2COMCODE as LEVEL2COMCODE
+              ,a1.LEVEL3COMCODE as LEVEL3COMCODE
+              ,a1.`partyId`     as LEVEL4COMCODE
+              ,a1.`partyId`     as LEVEL5COMCODE
+              ,a1.LEVEL1COMDESC as LEVEL1COMDESC
+              ,a1.LEVEL2COMDESC as LEVEL2COMDESC
+              ,a1.LEVEL3COMDESC as LEVEL3COMDESC
+              ,a1.`name`        as LEVEL4COMDESC
+              ,a1.`name`        as LEVEL5COMDESC
+              ,a1.COMLEVEL +1   as COMLEVEL
+              ,'1'              as VALIDFLAG
+         from VIEW_ODS_CD_COM_ALL_TUANDUI a1
+         where a1.COMCODE <> a1.LEVEL2COMCODE
+           and a1.COMCODE = a1.LEVEL3COMCODE
+         union all
+         select
+             a1.`partyId`     as COMCODE
+              ,a1.`name`        as COMNAME
+              ,a1.LEVEL1COMCODE as LEVEL1COMCODE
+              ,a1.LEVEL2COMCODE as LEVEL2COMCODE
+              ,a1.LEVEL3COMCODE as LEVEL3COMCODE
+              ,a1.LEVEL4COMCODE as LEVEL4COMCODE
+              ,a1.`partyId`     as LEVEL5COMCODE
+              ,a1.LEVEL1COMDESC as LEVEL1COMDESC
+              ,a1.LEVEL2COMDESC as LEVEL2COMDESC
+              ,a1.LEVEL3COMDESC as LEVEL3COMDESC
+              ,a1.LEVEL4COMDESC as LEVEL4COMDESC
+              ,a1.`name`        as LEVEL5COMDESC
+              ,a1.COMLEVEL +1   as COMLEVEL
+              ,'1'              as VALIDFLAG
+         from VIEW_ODS_CD_COM_ALL_TUANDUI a1
+         where a1.COMCODE <> a1.LEVEL2COMCODE
+           and a1.COMCODE <> a1.LEVEL3COMCODE
+           and a1.COMCODE = a1.LEVEL4COMCODE
+     ) s1
+;
+
+
+insert into ODS_CK.ODS_CK_MYSQL.MQ_MIDDLE
+select
+    updateTime
+     ,updateType
+from ODS.ODS_MQ.COM_CHANGE_MQ
+;
\ No newline at end of file

ODS/码表过程同步/ODS_CD_COM_ALL_MIDDLE.sql

+-- ODS_CD_COM_ALL_MIDDLE
+-- ODS_承保机构_过程
+
+insert into ODS_CK.ODS_CK_MYSQL.MQ_MIDDLE
+select
+    updateTime
+    ,updateType
+from ODS.ODS_MQ.COM_CHANGE_MQ  
+;
+
+
+
+insert into ODS_CK.ODS_CK_MYSQL.CD_COM_ALL_MIDDLE
+select
+    t1.COMCODE
+     ,t1.COMNAME
+     ,t1.LEVEL1COMCODE
+     ,t1.LEVEL2COMCODE
+     ,t1.LEVEL3COMCODE
+     ,t1.LEVEL4COMCODE
+     ,t1.LEVEL5COMCODE
+     ,t1.LEVEL1COMDESC
+     ,t1.LEVEL2COMDESC
+     ,t1.LEVEL3COMDESC
+     ,t1.LEVEL4COMDESC
+     ,t1.LEVEL5COMDESC
+     ,t1.COMLEVEL
+     ,case when s1.`status` = 'Discarded' then '0'
+           when s1.`status` = 'Effective' then '1'
+    end  as  VALIDFLAG
+from (
+         select
+             u1.`sign`
+              ,u1.`partyId`
+              ,u1.`name`
+              ,u1.`status`
+              ,u1.`rolePartyId`
+         from ODS.ODS_MQ.COM_CHANGE_MQ m1
+                  cross join lateral table(MqPushMySqlUDTF(m1.updateTime
+						, m1.updateType
+						, 'http://9.23.28.25/rbac/service/hr/core/structure/structureChanges'
+		)) u1(`sign`, `partyId`, `name`, `status`, `rolePartyId`)
+         where u1.`sign` = 'structureChangeList'
+     ) s1
+         left join ODS.ODS_MYSQL.CD_COM_ALL  t1 on s1.`partyId` = t1.COMCODE
+;
+
+-- structureRlshipChangeList 有效数据视图
+CREATE TEMPORARY VIEW VIEW_ODS_CD_COM_ALL_TUANDUI AS
+select
+    t1.COMCODE
+     ,t1.COMNAME
+     ,t1.LEVEL1COMCODE
+     ,t1.LEVEL2COMCODE
+     ,t1.LEVEL3COMCODE
+     ,t1.LEVEL4COMCODE
+     ,t1.LEVEL5COMCODE
+     ,t1.LEVEL1COMDESC
+     ,t1.LEVEL2COMDESC
+     ,t1.LEVEL3COMDESC
+     ,t1.LEVEL4COMDESC
+     ,t1.LEVEL5COMDESC
+     ,t1.COMLEVEL
+     ,t1.VALIDFLAG
+     ,s1.`partyId`
+     ,s1.`name`
+     ,s1.`status`
+     ,s1.`rolePartyId`
+from (
+         select
+             u1.`sign`
+              ,u1.`partyId`
+              ,u1.`name`
+              ,u1.`status`
+              ,u1.`rolePartyId`
+         from ODS.ODS_MQ.COM_CHANGE_MQ m1
+                  cross join lateral table(MqPushMySqlUDTF(m1.updateTime
+						, m1.updateType
+						, 'http://9.23.28.25/rbac/service/hr/core/structure/structureChanges'
+		)) u1(`sign`, `partyId`, `name`, `status`, `rolePartyId`)
+         where u1.`sign` = 'structureRlshipChangeList'
+           and u1.`status` = 'Effective'
+     ) s1
+         left join ODS.ODS_MYSQL.CD_COM_ALL  t1 on s1.`rolePartyId` = t1.COMCODE
+;
+
+
+-- structureRlshipChangeList 有效数据插入
+insert into ODS_CK.ODS_CK_MYSQL.CD_COM_ALL_MIDDLE
+select
+    s1.COMCODE
+     ,s1.COMNAME
+     ,s1.LEVEL1COMCODE
+     ,s1.LEVEL2COMCODE
+     ,s1.LEVEL3COMCODE
+     ,s1.LEVEL4COMCODE
+     ,s1.LEVEL5COMCODE
+     ,s1.LEVEL1COMDESC
+     ,s1.LEVEL2COMDESC
+     ,s1.LEVEL3COMDESC
+     ,s1.LEVEL4COMDESC
+     ,s1.LEVEL5COMDESC
+     ,s1.COMLEVEL
+     ,s1.VALIDFLAG
+from (
+         select
+             a1.`partyId`     as COMCODE
+              ,a1.`name`        as COMNAME
+              ,a1.LEVEL1COMCODE as LEVEL1COMCODE
+              ,a1.LEVEL2COMCODE as LEVEL2COMCODE
+              ,a1.`partyId`     as LEVEL3COMCODE
+              ,a1.`partyId`     as LEVEL4COMCODE
+              ,a1.`partyId`     as LEVEL5COMCODE
+              ,a1.LEVEL1COMDESC as LEVEL1COMDESC
+              ,a1.LEVEL2COMDESC as LEVEL2COMDESC
+              ,a1.`name`        as LEVEL3COMDESC
+              ,a1.`name`        as LEVEL4COMDESC
+              ,a1.`name`        as LEVEL5COMDESC
+              ,a1.COMLEVEL +1   as COMLEVEL
+              ,'1'              as VALIDFLAG
+         from VIEW_ODS_CD_COM_ALL_TUANDUI a1
+         where a1.COMCODE  = a1.LEVEL2COMCODE
+         union all
+         select
+             a1.`partyId`     as COMCODE
+              ,a1.`name`        as COMNAME
+              ,a1.LEVEL1COMCODE as LEVEL1COMCODE
+              ,a1.LEVEL2COMCODE as LEVEL2COMCODE
+              ,a1.LEVEL3COMCODE as LEVEL3COMCODE
+              ,a1.`partyId`     as LEVEL4COMCODE
+              ,a1.`partyId`     as LEVEL5COMCODE
+              ,a1.LEVEL1COMDESC as LEVEL1COMDESC
+              ,a1.LEVEL2COMDESC as LEVEL2COMDESC
+              ,a1.LEVEL3COMDESC as LEVEL3COMDESC
+              ,a1.`name`        as LEVEL4COMDESC
+              ,a1.`name`        as LEVEL5COMDESC
+              ,a1.COMLEVEL +1   as COMLEVEL
+              ,'1'              as VALIDFLAG
+         from VIEW_ODS_CD_COM_ALL_TUANDUI a1
+         where a1.COMCODE <> a1.LEVEL2COMCODE
+           and a1.COMCODE = a1.LEVEL3COMCODE
+         union all
+         select
+             a1.`partyId`     as COMCODE
+              ,a1.`name`        as COMNAME
+              ,a1.LEVEL1COMCODE as LEVEL1COMCODE
+              ,a1.LEVEL2COMCODE as LEVEL2COMCODE
+              ,a1.LEVEL3COMCODE as LEVEL3COMCODE
+              ,a1.LEVEL4COMCODE as LEVEL4COMCODE
+              ,a1.`partyId`     as LEVEL5COMCODE
+              ,a1.LEVEL1COMDESC as LEVEL1COMDESC
+              ,a1.LEVEL2COMDESC as LEVEL2COMDESC
+              ,a1.LEVEL3COMDESC as LEVEL3COMDESC
+              ,a1.LEVEL4COMDESC as LEVEL4COMDESC
+              ,a1.`name`        as LEVEL5COMDESC
+              ,a1.COMLEVEL +1   as COMLEVEL
+              ,'1'              as VALIDFLAG
+         from VIEW_ODS_CD_COM_ALL_TUANDUI a1
+         where a1.COMCODE <> a1.LEVEL2COMCODE
+           and a1.COMCODE <> a1.LEVEL3COMCODE
+           and a1.COMCODE = a1.LEVEL4COMCODE
+     ) s1
+;
\ No newline at end of file

XF_DWD/XF_DWD_CAR_ENDOR.sql

@@ -49,7 +49,7 @@ select
     s1.handlerName                                             -- 寿险销售人员名称
 
 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
+left join ODS.ODS_MYSQL.CD_COM_ALL for system_time as of s1.proctime as t1 on s1.businessOffice = t1.COMCODE
 where left(s1.productCode,2) ='05'
 
 

XF_DWD/XF_DWD_CAR_POLICY.sql

@@ -50,7 +50,7 @@ select
     s1.handlerName                                             -- 寿险销售人员名称
 
 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
+left join ODS.ODS_MYSQL.CD_COM_ALL for system_time as of s1.proctime as t1 on s1.businessOffice = t1.COMCODE
 where left(s1.productCode,2) ='05'
 
 

XF_DWD/XF_DWD_FC_ENDOR.sql

@@ -60,7 +60,7 @@ select
     s1.handlerCode,                                            -- 寿险销售人员代码
     s1.handlerName                                             -- 寿险销售人员名称
 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
+left join ODS.ODS_MYSQL.CD_COM_ALL for system_time as of s1.proctime as t1 on s1.businessOffice = t1.COMCODE
 where left(s1.productCode,2) <>'05'
 
 

XF_DWD/XF_DWD_FC_POLICY.sql

@@ -60,7 +60,7 @@ select
     s1.handlerCode,                                            -- 寿险销售人员代码
     s1.handlerName                                             -- 寿险销售人员名称
 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
+left join ODS.ODS_MYSQL.CD_COM_ALL for system_time as of s1.proctime as t1 on s1.businessOffice = t1.COMCODE
 where left(s1.productCode,2) <>'05'
 ;
 

ZB_ODS/承保同步/ZB_ODS_CBDATA.sql

@@ -130,7 +130,7 @@ from (
     and cast(plpEndorse.netPremiumVariation as decimal(30,4)) <> 0
 
 ) 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
+left join ODS.ODS_MYSQL.CD_COM_ALL for system_time as of s1.proctime as t1 on s1.businessOffice = t1.COMCODE
 left join ZB_ODS.ZB_ODS_MYSQL.CD_NEWCHNLTYPE for system_time as of s1.proctime as t2 on s1.businessChannelCode = t2.NEWCHNLTYPE
 left join ZB_ODS.ZB_ODS_MYSQL.CD_REALTIME_RISK for system_time as of s1.proctime as t3 on s1.productCode = t3.RISKCODE
 left join ZB_ODS.ZB_ODS_MYSQL.CD_BUSINESSNATURE for system_time as of s1.proctime as t4 on s1.businessNatureCode = t4.CODE

ZB_ODS/理赔同步/ZB_ODS_LPDATA.sql

@@ -65,7 +65,7 @@ from (
     from ZB_ODS.ZB_SOURCE_KAFKA_WJPK.WJPK  -- 批单业务数据
 
 ) 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
+left join ODS.ODS_MYSQL.CD_COM_ALL for system_time as of s1.proctime as t1 on s1.businessOffice = t1.COMCODE
 left join ZB_ODS.ZB_ODS_MYSQL.CD_NEWCHNLTYPE for system_time as of s1.proctime as t2 on s1.businessChannelCode = t2.NEWCHNLTYPE
 left join ZB_ODS.ZB_ODS_MYSQL.CD_REALTIME_RISK for system_time as of s1.proctime as t3 on s1.productCode = t3.RISKCODE
 left join ZB_ODS.ZB_ODS_MYSQL.CD_BUSINESSNATURE for system_time as of s1.proctime as t4 on s1.businessNatureCode = t4.CODE