sql脚本

XF_DWD/XF_DWD_ENDOR.sql

@@ -46,5 +46,6 @@ select
               end  as varchar )   as  coinsrate            -- 系数
 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
+where left(s1.productCode,2) ='05'
 
 

XF_DWD/XF_DWD_POLICY.sql

@@ -46,7 +46,7 @@ select
     t1.LEVEL1COMCODE  -- 分公司代码
 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
-
+where left(s1.productCode,2) ='05'
 
 
 

XF_DWD/XF_DWD_REGIST.sql

@@ -3,6 +3,11 @@ select
     s1.actualData  ,
     DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd HH:mm:ss')      as log_time , -- 加工平台处理数据时间
     s1.nodecode,
+    JsonArrayConcatUDF(s1.actualData.prplpolicy,'isSelected','1','comCode')    as comCode   ,
+    JsonArrayConcatUDF(s1.actualData.prplpolicy,'isSelected','1','comName')    as comName   ,
+    JsonArrayConcatUDF(s1.actualData.prplpolicy,'isSelected','1','riskCode')   as riskCode  ,
+    JsonArrayConcatUDF(s1.actualData.prplpolicy,'isSelected','1','riskName')   as riskName  ,
+    JsonArrayConcatUDF(s1.actualData.prplpolicy,'isSelected','1','licenseNo')  as licenseNo ,
     t1.LEVEL1COMCODE  -- 分公司代码
 from  XF_ODS.XF_ODS_KAFKA.REGIST s1
 left join XF_ODS.XF_ODS_MYSQL.CD_COM_CLAIM for system_time as of s1.proctime as t1 on s1.actualData.prplcregist[CARDINALITY(s1.actualData.prplcregist)].deptCode = t1.COMCODE

XF_DWD/下发结果同步任务/XF_ENDOR_RESOULT.sql

+-- XF_ENDOR_RESOULT    XF_ENDOR_下发结果同步任务
+
+insert into XF_CK.XF_CK_MYSQL.XF_ENDOR_RESOULT
+select 
+    systemName                   AS systemName
+    ,systemCode                  AS systemCode 
+    ,sendTime                    AS sendTime   
+    ,msgCode                     AS msgCode    
+    ,msgName                     AS msgName    
+    ,data[1].comCode             AS comCode          
+    ,data[1].comName             AS comName          
+    ,data[1].riskCode            AS riskCode         
+    ,data[1].endorseNo           AS endorseNo        
+    ,data[1].policyNo            AS policyNo         
+    ,data[1].sumPremium          AS sumPremium       
+    ,data[1].licenseNo           AS licenseNo        
+    ,data[1].frameNo             AS frameNo          
+    ,data[1].modelCode           AS modelCode        
+    ,data[1].newVehicleFlag      AS newVehicleFlag   
+    ,data[1].appliName           AS appliName        
+    ,data[1].insuredName         AS insuredName      
+    ,data[1].newPolicyFlag       AS newPolicyFlag    
+    ,data[1].autoTransreNewFlag  AS autoTransreNewFlag
+    ,data[1].transferPolicyFlag  AS transferPolicyFlag
+    ,data[1].transreNewFlag      AS transreNewFlag   
+    ,data[1].artifSelfPricesRat  AS artifSelfPricesRat
+    ,data[1].artifReviewPrem     AS artifReviewPrem  
+    ,data[1].agentFee            AS agentFee         
+    ,data[1].agentNetFee         AS agentNetFee      
+    ,data[1].agentComCode        AS agentComCode     
+    ,data[1].agentComName        AS agentComName     
+    ,data[1].newChnlType         AS newChnlType      
+    ,data[1].startDate           AS startDate        
+    ,data[1].endDate             AS endDate          
+    ,data[1].underWriteEndDate   AS underWriteEndDate
+    ,data[1].useNatureCode       AS useNatureCode    
+    ,data[1].carKindCode         AS carKindCode      
+    ,data[1].chgPremium          AS chgPremium       
+    ,data[1].policySort          AS policySort       
+from XF_ODS.XF_ODS_KAFKA.XF_ENDOR_RESOULT s1
+where s1.msgCode = 'carEndorse'
+  and s1.msgName = '新核心车险批单信息'

XF_DWD/下发结果同步任务/XF_POLICY_RESOULT.sql

+-- XF_POLICY_RESOULT    XF_POLICY_下发结果同步任务
+
+
+insert into XF_CK.XF_CK_MYSQL.XF_POLICY_RESOULT
+select
+     systemName                          AS systemName
+    ,systemCode                          AS systemCode
+    ,sendTime                            AS sendTime  
+    ,msgCode                             AS msgCode   
+    ,msgName                             AS msgName   
+    ,data[1].policyNo                    AS policyNo               
+    ,data[1].businessNo                  AS businessNo          
+    ,data[1].underWriteEndDate           AS underWriteEndDate   
+    ,data[1].comCode                     AS comCode                 
+    ,data[1].comName                     AS comName                 
+    ,data[1].riskCode                    AS riskCode                
+    ,data[1].businessNature              AS businessNature        
+    ,data[1].startDate                   AS startDate              
+    ,data[1].endDate                     AS endDate                
+    ,data[1].sumPremium                  AS sumPremium             
+    ,data[1].premium                     AS premium                  
+    ,data[1].licenseNo                   AS licenseNo                
+    ,data[1].frameNo                     AS frameNo                 
+    ,data[1].modelCode                   AS modelCode             
+    ,data[1].newVehicleFlag              AS newVehicleFlag        
+    ,data[1].appliName                   AS appliName             
+    ,data[1].insuredName                 AS insuredName             
+    ,data[1].newPolicyFlag               AS newPolicyFlag        
+    ,data[1].autoTransreNewFlag          AS autoTransreNewFlag 
+    ,data[1].transferPolicyFlag          AS transferPolicyFlag 
+    ,data[1].transreNewFlag              AS transreNewFlag     
+    ,data[1].artifSelfPricesRat          AS artifSelfPricesRat 
+    ,data[1].artifReviewPrem             AS artifReviewPrem    
+    ,data[1].agentFee                    AS agentFee             
+    ,data[1].agentNetFee                 AS agentNetFee         
+    ,data[1].agentComCode                AS agentComCode         
+    ,data[1].agentComName                AS agentComName          
+    ,data[1].newChnlType                 AS newChnlType          
+    ,data[1].carKindCode                 AS carKindCode           
+    ,data[1].useNatureCode               AS useNatureCode         
+    ,data[1].policySort                  AS policySort             
+    ,data[1].actualvalue                 AS actualvalue           
+    ,data[1].businessType                AS businessType          
+from XF_ODS.XF_ODS_KAFKA.XF_POLICY_RESOULT s1
+where s1.msgCode = 'carpolicy'
+  and s1.msgName = '新核心车险保单信息'
\ No newline at end of file

XF_DWD/下发结果同步任务/元数据/XF_ENDOR_RESOULT.sql

+-- XF_ENDOR_RESOULT    批单下发结果
+
+create  table XF_ENDOR_RESOULT
+(
+    systemName           varchar(128)
+    ,systemCode          varchar(64)
+    ,sendTime            varchar(64)
+    ,msgCode             varchar(64)
+    ,msgName             varchar(128)
+    ,comCode             varchar(64)
+    ,comName             varchar(128)
+    ,riskCode            varchar(64)
+    ,endorseNo           varchar(64)
+    ,policyNo            varchar(64)
+    ,sumPremium          varchar(64)
+    ,licenseNo           varchar(64)
+    ,frameNo             varchar(64)
+    ,modelCode           varchar(64)
+    ,newVehicleFlag      varchar(64)
+    ,appliName           varchar(128)
+    ,insuredName         varchar(128)
+    ,newPolicyFlag       varchar(64)
+    ,autoTransreNewFlag  varchar(64)
+    ,transferPolicyFlag  varchar(64)
+    ,transreNewFlag      varchar(64)
+    ,artifSelfPricesRat  varchar(64)
+    ,artifReviewPrem     varchar(64)
+    ,agentFee            varchar(64)
+    ,agentNetFee         varchar(64)
+    ,agentComCode        varchar(64)
+    ,agentComName        varchar(128)
+    ,newChnlType         varchar(64)
+    ,startDate           varchar(64)
+    ,endDate             varchar(64)
+    ,underWriteEndDate   varchar(64)
+    ,useNatureCode       varchar(64)
+    ,carKindCode         varchar(64)
+    ,chgPremium          varchar(64)
+    ,policySort          varchar(64)
+);

XF_DWD/下发结果同步任务/元数据/XF_POLICY_RESOULT.sql

+-- XF_POLICY_RESOULT    保单下发结果
+
+create table XF_POLICY_RESOULT
+(
+    systemName          varchar(128)
+    ,systemCode         varchar(64)
+    ,sendTime           varchar(64)
+    ,msgCode            varchar(64)
+    ,msgName            varchar(128)
+    ,policyNo           varchar(64)
+    ,businessNo         varchar(64)
+    ,underWriteEndDate  varchar(64)
+    ,comCode            varchar(64)
+    ,comName            varchar(128)
+    ,riskCode           varchar(64)
+    ,businessNature     varchar(64)
+    ,startDate          varchar(64)
+    ,endDate            varchar(64)
+    ,sumPremium         varchar(64)
+    ,premium            varchar(64)
+    ,licenseNo          varchar(64)
+    ,frameNo            varchar(64)
+    ,modelCode          varchar(64)
+    ,newVehicleFlag     varchar(64)
+    ,appliName          varchar(128)
+    ,insuredName        varchar(128)
+    ,newPolicyFlag      varchar(64)
+    ,autoTransreNewFlag varchar(64)
+    ,transferPolicyFlag varchar(64)
+    ,transreNewFlag     varchar(64)
+    ,artifSelfPricesRat varchar(64)
+    ,artifReviewPrem    varchar(64)
+    ,agentFee           varchar(64)
+    ,agentNetFee        varchar(64)
+    ,agentComCode       varchar(64)
+    ,agentComName       varchar(128)
+    ,newChnlType        varchar(64)
+    ,carKindCode        varchar(64)
+    ,useNatureCode      varchar(64)
+    ,policySort         varchar(64)
+    ,actualvalue        varchar(64)
+    ,businessType       varchar(64)
+);
\ No newline at end of file