车险理赔结果同步sql脚本

XF_CK/DDL元数据/XF_REGIST_RESOULT.sql

+-- XF_REGIST_RESOULT    车险报案下发结果
+
+create table  XF_REGIST_RESOULT
+(
+    systemName           varchar(128)
+    ,systemCode          varchar(64)
+    ,sendTime            varchar(64)
+    ,msgCode             varchar(64)
+    ,msgName             varchar(128)
+    ,accidentNo          varchar(64)
+    ,damageStartDate     varchar(64)
+    ,reportDate          varchar(64)
+    ,damageAddress       varchar(128)
+    ,policyNo            varchar(64)
+    ,registNo            varchar(64)
+    ,claimComCode        varchar(64)
+    ,deptName            varchar(128)
+    ,reportorName        varchar(128)
+    ,reportorPhone       varchar(64)
+    ,linkerName          varchar(128)
+    ,phoneNumber         varchar(64)
+    ,comCode             varchar(64)
+    ,comName             varchar(128)
+    ,riskCode            varchar(64)
+    ,riskName            varchar(128)
+    ,licenseNo           varchar(64)
+    ,brandCode           varchar(64)
+    ,modelCode           varchar(64)
+    ,longitude           varchar(128)
+    ,latitude            varchar(128)
+    ,damageTypeDesc      varchar(128)
+    ,damageCourse        varchar(128)
+
+);
+

XF_CK/数据同步/XF_REGIST_RESOULT.sql

+-- XF_REGIST_RESOULT    XF_REGIST_下发结果同步任务
+
+insert into XF_CK.XF_CK_MYSQL.XF_REGIST_RESOULT
+select 
+    systemName                   AS systemName
+    ,systemCode                  AS systemCode 
+    ,sendTime                    AS sendTime   
+    ,msgCode                     AS msgCode    
+    ,msgName                     AS msgName
+    ,data[1].accidentNo          AS accidentNo         
+    ,data[1].damageStartDate     AS damageStartDate    
+    ,data[1].reportDate          AS reportDate         
+    ,data[1].damageAddress       AS damageAddress      
+    ,data[1].policyNo            AS policyNo           
+    ,data[1].registNo            AS registNo           
+    ,data[1].claimComCode        AS claimComCode       
+    ,data[1].deptName            AS deptName           
+    ,data[1].reportorName        AS reportorName       
+    ,data[1].reportorPhone       AS reportorPhone      
+    ,data[1].linkerName          AS linkerName         
+    ,data[1].phoneNumber         AS phoneNumber        
+    ,data[1].comCode             AS comCode            
+    ,data[1].comName             AS comName            
+    ,data[1].riskCode            AS riskCode           
+    ,data[1].riskName            AS riskName           
+    ,data[1].licenseNo           AS licenseNo          
+    ,data[1].brandCode           AS brandCode          
+    ,data[1].modelCode           AS modelCode          
+    ,data[1].longitude           AS longitude          
+    ,data[1].latitude            AS latitude           
+    ,data[1].damageTypeDesc      AS damageTypeDesc     
+    ,data[1].damageCourse        AS damageCourse       
+from XF_ODS.XF_ODS_KAFKA.XF_REGIST_RESOULT s1
+where s1.msgCode = 'CarClaimCase-RegistCar'
+  and s1.msgName = '车险报案环节信息'