数据下发脚本修改

fd87e7be · 胡涛 · 14a01540 · fd87e7be · fd87e7be · fd87e7be
Commit fd87e7be authored Nov 02, 2022 by 胡涛
15 changed files
--- a/XF_CK/DDL元数据/mysql/DETAIL_CAR_ENDOR.sql
+++ b/XF_CK/DDL元数据/mysql/DETAIL_CAR_ENDOR.sql
@@ -10,6 +10,7 @@ create  table DETAIL_CAR_ENDOR
    ,comCode            varchar(64)
    ,comName            varchar(128)
    ,riskCode           varchar(64)
+    ,businessNature     varchar(64)
    ,endorseNo          varchar(64)
    ,policyNo           varchar(64)
    ,sumPremium         varchar(64)
@@ -23,10 +24,10 @@ create  table DETAIL_CAR_ENDOR
    ,autoTransreNewFlag varchar(64)
    ,transferPolicyFlag varchar(64)
    ,transreNewFlag     varchar(64)
-    ,artifSelfPricesRat  varchar(64)
-    ,artifReviewPrem     varchar(64)
-    ,agentFee            varchar(64)
-    ,agentNetFee         varchar(64)
+    ,artifSelfPricesRat varchar(128)
+    ,artifReviewPrem    varchar(128)
+    ,agentFee           varchar(128)
+    ,agentNetFee        varchar(128)
    ,agentComCode       varchar(64)
    ,agentComName       varchar(128)
    ,newChnlType        varchar(64)

--- a/XF_CK/DDL元数据/mysql/DETAIL_CAR_POLICY.sql
+++ b/XF_CK/DDL元数据/mysql/DETAIL_CAR_POLICY.sql
@@ -8,7 +8,6 @@ create table DETAIL_CAR_POLICY
    ,msgCode            varchar(64)
    ,msgName            varchar(128)
    ,policyNo           varchar(64)
-    ,businessNo         varchar(64)
    ,underWriteEndDate  varchar(64)
    ,comCode            varchar(64)
    ,comName            varchar(128)
@@ -28,10 +27,10 @@ create table DETAIL_CAR_POLICY
    ,autoTransreNewFlag varchar(64)
    ,transferPolicyFlag varchar(64)
    ,transreNewFlag     varchar(64)
-    ,artifSelfPricesRat varchar(64)
-    ,artifReviewPrem    varchar(64)
-    ,agentFee           varchar(64)
-    ,agentNetFee        varchar(64)
+    ,artifSelfPricesRat varchar(128)
+    ,artifReviewPrem    varchar(128)
+    ,agentFee           varchar(128)
+    ,agentNetFee        varchar(128)
    ,agentComCode       varchar(64)
    ,agentComName       varchar(128)
    ,newChnlType        varchar(64)

--- a/XF_CK/DDL元数据/mysql/DETAIL_CAR_REGIST.sql
+++ b/XF_CK/DDL元数据/mysql/DETAIL_CAR_REGIST.sql
@@ -7,29 +7,28 @@ create table  DETAIL_CAR_REGIST
    ,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)
+    ,accidentNo        varchar(64)
+    ,damageStartDate   varchar(64)
+    ,modelCode         varchar(128)
+    ,brandCode         varchar(128)
    ,deptName          varchar(128)
+    ,reportorPhone     varchar(128)
    ,reportorName      varchar(128)
-    ,reportorPhone       varchar(64)
    ,linkerName        varchar(128)
-    ,phoneNumber         varchar(64)
-    ,comCode             varchar(64)
-    ,comName             varchar(128)
-    ,riskCode            varchar(64)
+    ,policyNo          varchar(128)
+    ,registNo          varchar(128)
+    ,claimComCode      varchar(128)
    ,riskName          varchar(128)
    ,licenseNo         varchar(64)
-    ,brandCode           varchar(64)
-    ,modelCode           varchar(64)
+    ,riskCode          varchar(64)
+    ,comCode           varchar(64)
+    ,comName           varchar(128)
+    ,phoneNumber       varchar(128)
    ,longitude         varchar(128)
    ,latitude          varchar(128)
    ,damageTypeDesc    varchar(128)
    ,damageCourse      varchar(128) 
-
 );

--- a/XF_CK/DDL元数据/mysql/LXT_CAR_ENDOR.sql
+++ b/XF_CK/DDL元数据/mysql/LXT_CAR_ENDOR.sql
-- DETAIL_CAR_ENDOR    批单下发结果
+-- LXT_CAR_ENDOR    批单下发结果

-create  table DETAIL_CAR_ENDOR
+create  table LXT_CAR_ENDOR
 (
     systemName         varchar(128)
    ,systemCode         varchar(64)
@@ -10,6 +10,7 @@ create  table DETAIL_CAR_ENDOR
    ,comCode            varchar(64)
    ,comName            varchar(128)
    ,riskCode           varchar(64)
+    ,businessNature     varchar(64)
    ,endorseNo          varchar(64)
    ,policyNo           varchar(64)
    ,sumPremium         varchar(64)
@@ -23,10 +24,10 @@ create  table DETAIL_CAR_ENDOR
    ,autoTransreNewFlag varchar(64)
    ,transferPolicyFlag varchar(64)
    ,transreNewFlag     varchar(64)
-    ,artifSelfPricesRat  varchar(64)
-    ,artifReviewPrem     varchar(64)
-    ,agentFee            varchar(64)
-    ,agentNetFee         varchar(64)
+    ,artifSelfPricesRat varchar(128)
+    ,artifReviewPrem    varchar(128)
+    ,agentFee           varchar(128)
+    ,agentNetFee        varchar(128)
    ,agentComCode       varchar(64)
    ,agentComName       varchar(128)
    ,newChnlType        varchar(64)

--- a/XF_CK/DDL元数据/mysql/LXT_CAR_POLICY.sql
+++ b/XF_CK/DDL元数据/mysql/LXT_CAR_POLICY.sql
-- DETAIL_CAR_POLICY    保单下发结果
+-- LXT_CAR_POLICY    保单下发结果

-create table DETAIL_CAR_POLICY
+create table LXT_CAR_POLICY
 (
    systemName         varchar(128)
    ,systemCode         varchar(64)
@@ -8,7 +8,6 @@ create table DETAIL_CAR_POLICY
    ,msgCode            varchar(64)
    ,msgName            varchar(128)
    ,policyNo           varchar(64)
-    ,businessNo         varchar(64)
    ,underWriteEndDate  varchar(64)
    ,comCode            varchar(64)
    ,comName            varchar(128)
@@ -28,10 +27,10 @@ create table DETAIL_CAR_POLICY
    ,autoTransreNewFlag varchar(64)
    ,transferPolicyFlag varchar(64)
    ,transreNewFlag     varchar(64)
-    ,artifSelfPricesRat varchar(64)
-    ,artifReviewPrem    varchar(64)
-    ,agentFee           varchar(64)
-    ,agentNetFee        varchar(64)
+    ,artifSelfPricesRat varchar(128)
+    ,artifReviewPrem    varchar(128)
+    ,agentFee           varchar(128)
+    ,agentNetFee        varchar(128)
    ,agentComCode       varchar(64)
    ,agentComName       varchar(128)
    ,newChnlType        varchar(64)

--- a/XF_CK/DDL元数据/mysql/LXT_CAR_REGIST.sql
+++ b/XF_CK/DDL元数据/mysql/LXT_CAR_REGIST.sql
-- DETAIL_CAR_REGIST    车险报案下发结果
+-- LXT_CAR_REGIST    车险报案下发结果

-create table  DETAIL_CAR_REGIST
+create table  LXT_CAR_REGIST
 (
    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)
+    ,accidentNo        varchar(64)
+    ,damageStartDate   varchar(64)
+    ,modelCode         varchar(128)
+    ,brandCode         varchar(128)
    ,deptName          varchar(128)
+    ,reportorPhone     varchar(128)
    ,reportorName      varchar(128)
-    ,reportorPhone       varchar(64)
    ,linkerName        varchar(128)
-    ,phoneNumber         varchar(64)
-    ,comCode             varchar(64)
-    ,comName             varchar(128)
-    ,riskCode            varchar(64)
+    ,policyNo          varchar(128)
+    ,registNo          varchar(128)
+    ,claimComCode      varchar(128)
    ,riskName          varchar(128)
    ,licenseNo         varchar(64)
-    ,brandCode           varchar(64)
-    ,modelCode           varchar(64)
+    ,riskCode          varchar(64)
+    ,comCode           varchar(64)
+    ,comName           varchar(128)
+    ,phoneNumber       varchar(128)
    ,longitude         varchar(128)
    ,latitude          varchar(128)
    ,damageTypeDesc    varchar(128)

--- a/XF_CK/数据同步/XF_CK_DETAIL_CAR_ENDOR.sql
+++ b/XF_CK/数据同步/XF_CK_DETAIL_CAR_ENDOR.sql
-- XF_CK_DETAIL_CAR_ENDOR    XF_CK_DETAIL_下发结果车险理赔清单数据
+-- XF_CK_DETAIL_CAR_ENDOR    XF_CK_DETAIL_下发结果车险批单清单数据

 insert into XF_CK.XF_CK_MYSQL.DETAIL_CAR_ENDOR
 select 
@@ -10,6 +10,7 @@ select
    ,data[1].comCode             AS comCode
    ,data[1].comName             AS comName
    ,data[1].riskCode            AS riskCode
+    ,data[1].businessNature      AS businessNature
    ,data[1].endorseNo           AS endorseNo
    ,data[1].policyNo            AS policyNo
    ,data[1].sumPremium          AS sumPremium
@@ -37,6 +38,50 @@ select
    ,data[1].carKindCode         AS carKindCode
    ,data[1].chgPremium          AS chgPremium
    ,data[1].policySort          AS policySort     
-from XF_ODS.XF_ODS_KAFKA.CAR_ENDOR_JSON s1
+from XF_CK.XF_CK_KAFKA.CAR_ENDOR_JSON s1
 where s1.msgCode = 'carEndorse'
  and s1.msgName = '新核心车险批单信息'
+;
+
+insert into XF_CK.XF_CK_MYSQL.DETAIL_CAR_ENDOR
+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].businessNature      AS businessNature
+     ,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_CK.XF_CK_KAFKA_BJ.CAR_ENDOR_JSON s1
+where s1.msgCode = 'carEndorse'
+  and s1.msgName = '新核心车险批单信息'
+;
\ No newline at end of file
--- a/XF_CK/数据同步/XF_CK_DETAIL_CAR_POLICY.sql
+++ b/XF_CK/数据同步/XF_CK_DETAIL_CAR_POLICY.sql
@@ -9,7 +9,6 @@ select
    ,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                 
@@ -41,6 +40,53 @@ select
    ,data[1].policySort                  AS policySort             
    ,data[1].actualvalue                 AS actualvalue           
    ,data[1].businessType                AS businessType          
-from XF_ODS.XF_ODS_KAFKA.CAR_POLICY_JSON s1
+from XF_CK.XF_CK_KAFKA.CAR_POLICY_JSON s1
 where s1.msgCode = 'carpolicy'
  and s1.msgName = '新核心车险保单信息'
+;
+
+
+
+insert into XF_CK.XF_CK_MYSQL.DETAIL_CAR_POLICY
+select
+    systemName                          AS systemName
+     ,systemCode                          AS systemCode
+     ,sendTime                            AS sendTime
+     ,msgCode                             AS msgCode
+     ,msgName                             AS msgName
+     ,data[1].policyNo                    AS policyNo
+     ,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_CK.XF_CK_KAFKA_BJ.CAR_POLICY_JSON s1
+where s1.msgCode = 'carpolicy'
+  and s1.msgName = '新核心车险保单信息'
+;
\ No newline at end of file
--- a/XF_CK/数据同步/XF_CK_DETAIL_CAR_REGIST.sql
+++ b/XF_CK/数据同步/XF_CK_DETAIL_CAR_REGIST.sql
@@ -7,29 +7,62 @@ select
    ,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].accidentNo          AS accidentNo            
+    ,data[1].damageStartDate     AS damageStartDate           
+    ,data[1].modelCode           AS modelCode           
+    ,data[1].brandCode           AS brandCode       
+    ,data[1].deptName            AS deptName           
+    ,data[1].reportorPhone       AS reportorPhone       
+    ,data[1].reportorName        AS reportorName      
+    ,data[1].linkerName          AS linkerName         
    ,data[1].policyNo            AS policyNo        
    ,data[1].registNo            AS registNo            
    ,data[1].claimComCode        AS claimComCode            
+    ,data[1].riskName            AS riskName           
+    ,data[1].licenseNo           AS licenseNo           
+    ,data[1].riskCode            AS riskCode          
+    ,data[1].comCode             AS comCode          
+    ,data[1].comName             AS comName
+    ,data[1].phoneNumber         AS phoneNumber
+    ,data[1].longitude           AS longitude          
+    ,data[1].latitude            AS latitude           
+    ,data[1].damageTypeDesc      AS damageTypeDesc     
+    ,data[1].damageCourse        AS damageCourse       
+from XF_CK.XF_CK_KAFKA.CAR_REGIST_JSON s1
+;
+
+
+insert into XF_CK.XF_CK_MYSQL.DETAIL_CAR_REGIST
+select
+    systemName                   AS systemName
+     ,systemCode                  AS systemCode
+     ,sendTime                    AS sendTime
+     ,msgCode                     AS msgCode
+     ,msgName                     AS msgName
+     ,data[1].reportDate          AS reportDate
+     ,data[1].damageAddress       AS damageAddress
+     ,data[1].accidentNo          AS accidentNo
+     ,data[1].damageStartDate     AS damageStartDate
+     ,data[1].modelCode           AS modelCode
+     ,data[1].brandCode           AS brandCode
     ,data[1].deptName            AS deptName
-    ,data[1].reportorName        AS reportorName       
     ,data[1].reportorPhone       AS reportorPhone
+     ,data[1].reportorName        AS reportorName
     ,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].policyNo            AS policyNo
+     ,data[1].registNo            AS registNo
+     ,data[1].claimComCode        AS claimComCode
     ,data[1].riskName            AS riskName
     ,data[1].licenseNo           AS licenseNo
-    ,data[1].brandCode           AS brandCode          
-    ,data[1].modelCode           AS modelCode          
+     ,data[1].riskCode            AS riskCode
+     ,data[1].comCode             AS comCode
+     ,data[1].comName             AS comName
+     ,data[1].phoneNumber         AS phoneNumber
     ,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.CAR_REGIST_JSON s1
-where s1.msgCode = 'CarClaimCase-RegistCar'
-  and s1.msgName = '车险报案环节信息'
+from XF_CK.XF_CK_KAFKA_BJ.CAR_REGIST_JSON s1
+;
--- a/XF_CK/数据同步/XF_CK_LXT_CAR_ENDOR.sql
+++ b/XF_CK/数据同步/XF_CK_LXT_CAR_ENDOR.sql
@@ -7,28 +7,80 @@ select
     ,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].businessNature      AS businessNature
+     ,data[1].endorseNo           AS endorseNo
+     ,data[1].policyNo            AS policyNo
+     ,data[1].sumPremium          AS sumPremium
     ,data[1].licenseNo           AS licenseNo
-    ,data[1].brandCode           AS brandCode
+     ,data[1].frameNo             AS frameNo
     ,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_LXT.CAR_REGIST_JSON s1
+     ,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_CK.XF_CK_KAFKA_LXT.CAR_ENDOR_JSON s1
+where s1.msgCode = 'carEndorse'
+;

+
+insert into XF_CK.XF_CK_MYSQL.LXT_CAR_ENDOR
+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].businessNature      AS businessNature
+     ,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_CK.XF_CK_KAFKA_LXT_BJ.CAR_ENDOR_JSON s1
+where s1.msgCode = 'carEndorse'
+;
\ No newline at end of file
--- a/XF_CK/数据同步/XF_CK_LXT_CAR_POLICY.sql
+++ b/XF_CK/数据同步/XF_CK_LXT_CAR_POLICY.sql
@@ -7,28 +7,83 @@ select
     ,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].underWriteEndDate           AS underWriteEndDate
     ,data[1].comCode                     AS comCode
     ,data[1].comName                     AS comName
     ,data[1].riskCode                    AS riskCode
-    ,data[1].riskName            AS riskName
+     ,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].brandCode           AS brandCode
+     ,data[1].frameNo                     AS frameNo
     ,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_LXT.CAR_REGIST_JSON s1
+     ,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_CK.XF_CK_KAFKA_LXT.CAR_POLICY_JSON s1
+where s1.msgCode = 'carpolicy'
+;

+
+
+insert into XF_CK.XF_CK_MYSQL.LXT_CAR_POLICY
+select
+    systemName                          AS systemName
+     ,systemCode                          AS systemCode
+     ,sendTime                            AS sendTime
+     ,msgCode                             AS msgCode
+     ,msgName                             AS msgName
+     ,data[1].policyNo                    AS policyNo
+     ,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_CK.XF_CK_KAFKA_LXT_BJ.CAR_POLICY_JSON s1
+where s1.msgCode = 'carpolicy'
+;
--- a/XF_CK/数据同步/XF_CK_LXT_CAR_REGIST.sql
+++ b/XF_CK/数据同步/XF_CK_LXT_CAR_REGIST.sql
@@ -7,28 +7,63 @@ select
     ,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].accidentNo          AS accidentNo
+     ,data[1].damageStartDate     AS damageStartDate
+     ,data[1].modelCode           AS modelCode
+     ,data[1].brandCode           AS brandCode
+     ,data[1].deptName            AS deptName
+     ,data[1].reportorPhone       AS reportorPhone
+     ,data[1].reportorName        AS reportorName
+     ,data[1].linkerName          AS linkerName
     ,data[1].policyNo            AS policyNo
     ,data[1].registNo            AS registNo
     ,data[1].claimComCode        AS claimComCode
+     ,data[1].riskName            AS riskName
+     ,data[1].licenseNo           AS licenseNo
+     ,data[1].riskCode            AS riskCode
+     ,data[1].comCode             AS comCode
+     ,data[1].comName             AS comName
+     ,data[1].phoneNumber         AS phoneNumber
+     ,data[1].longitude           AS longitude
+     ,data[1].latitude            AS latitude
+     ,data[1].damageTypeDesc      AS damageTypeDesc
+     ,data[1].damageCourse        AS damageCourse
+from XF_CK.XF_CK_KAFKA_LXT.CAR_REGIST_JSON s1
+;
+
+
+
+insert into XF_CK.XF_CK_MYSQL.LXT_CAR_REGIST
+select
+    systemName                   AS systemName
+     ,systemCode                  AS systemCode
+     ,sendTime                    AS sendTime
+     ,msgCode                     AS msgCode
+     ,msgName                     AS msgName
+     ,data[1].reportDate          AS reportDate
+     ,data[1].damageAddress       AS damageAddress
+     ,data[1].accidentNo          AS accidentNo
+     ,data[1].damageStartDate     AS damageStartDate
+     ,data[1].modelCode           AS modelCode
+     ,data[1].brandCode           AS brandCode
     ,data[1].deptName            AS deptName
-    ,data[1].reportorName        AS reportorName
     ,data[1].reportorPhone       AS reportorPhone
+     ,data[1].reportorName        AS reportorName
     ,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].policyNo            AS policyNo
+     ,data[1].registNo            AS registNo
+     ,data[1].claimComCode        AS claimComCode
     ,data[1].riskName            AS riskName
     ,data[1].licenseNo           AS licenseNo
-    ,data[1].brandCode           AS brandCode
-    ,data[1].modelCode           AS modelCode
+     ,data[1].riskCode            AS riskCode
+     ,data[1].comCode             AS comCode
+     ,data[1].comName             AS comName
+     ,data[1].phoneNumber         AS phoneNumber
     ,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_LXT.CAR_REGIST_JSON s1
-
+from XF_CK.XF_CK_KAFKA_LXT_BJ.CAR_REGIST_JSON s1
+;
--- a/XF_DWD/新核心车险保单-FM.ftl
+++ b/XF_DWD/新核心车险保单-FM.ftl
-{"systemName":"流计算平台","systemCode":"D030","sendTime":"${.now?string("yyyy-MM-dd HH:mm:ss")}","msgCode":"carpolicy","msgName":"新核心车险保单信息","data":[{"policyNo":"${policyNo!}" <#-- 保单号 -->,"businessNo":"${businessNo!}" <#-- 业务号 -->,"underWriteEndDate":"${policyCreatDate!}" <#-- 核保通过时间 -->,"comCode":"${businessOffice!}" <#-- 保单归属机构代码 -->,"comName":"${businessOfficeName!}"  <#-- 保单归属机构名称 -->,"riskCode":"${productCode!}" <#-- 险种代码 -->,"businessNature":"${businessNatureCode!}" <#-- 业务来源 -->,"startDate":"${startTime!}" <#-- 起保时间 -->,"endDate":"${endTime!}" <#-- 终保时间 -->,"sumPremium":"${netPremium!}" <#-- 不含税保费  -->,"premium":"${premium!}" <#-- 含税保费 -->,"licenseNo":"<#if plcCar05??>${plcCar05.licensePlateNo!}</#if>" <#-- 车牌号 -->,"frameNo":"<#if plcCar05??>${plcCar05.frameNo!}</#if>" <#-- 车架号 -->,"modelCode":"<#if plcCar05??>${plcCar05.vehicleId!}</#if>" <#-- 车型 -->,"newVehicleFlag":"<#if plcCar05??>${plcCar05.newVehicleFlag!}</#if>" <#-- 新车标识 -->,"appliName":"<#if plcApplicant??><#list plcApplicant as s1>${s1.customerName!}<#if plcApplicant?size-1 gt s1?index >|</#if></#list></#if>"  <#-- 投保人名称 -->,"insuredName":"<#if plcPublicInsurant??><#list plcPublicInsurant as s1>${s1.customerName!}<#if plcPublicInsurant?size-1 gt s1?index >|</#if></#list></#if>"  <#-- 被保人名称 -->,"newPolicyFlag":"${newPolicyFlag!}" <#-- 新保标识 -->,"autoTransreNewFlag":"${autoTransrenewFlag!}" <#-- 自动续保标识 -->,"transferPolicyFlag":"${transferPolicyFlag!}" <#-- 转保标识 -->,"transreNewFlag":"${transrenewFlag!}" <#-- 续保标识 -->,"artifSelfPricesRat":"<#if plcSolution??><#list plcSolution as s1>${s1.PlcRation.artifSelfPricesRat!}<#if plcSolution?size-1 gt s1?index >|</#if></#list></#if>" <#-- 自主定价系数  -->,"artifReviewPrem":"<#if plcSolution??><#list plcSolution as s1>${s1.PlcRation.artifReviewPrem!}<#if plcSolution?size-1 gt s1?index >|</#if></#list></#if>" <#-- 总保费 -->,"agentFee":"<#if plcSolution??><#list plcSolution as s1><#if s1.plcCommissionDetail??><#list s1.plcCommissionDetail as item>${item.agentFee!}<#if s1.plcCommissionDetail?size-1 gt item?index >|</#if></#list></#if></#list></#if>" <#-- 手续费含税金额 -->,"agentNetFee":"<#if plcSolution??><#list plcSolution as s1><#if s1.plcCommissionDetail??><#list s1.plcCommissionDetail as item>${item.agentNetFee!}<#if s1.plcCommissionDetail?size-1 gt item?index >|</#if></#list></#if></#list></#if>" <#-- 手续费不含税金额 -->,"agentComCode":"${saleaman!}" <#-- 代理机构代码 -->,"agentComName":"${saleamanName!}" <#-- 代理机构名称 -->,"newChnlType":"${businessChannelCode!}" <#-- 清分后渠道 -->,"carKindCode":"<#if plcCar05??>${plcCar05.carKindCode!}</#if>" <#-- 车辆种类 -->,"useNatureCode":"<#if plcCar05??>${plcCar05.carUserNatureCode!}</#if>" <#-- 车辆使用性质 -->,"policySort":"${policySort!}" <#-- 保单种类 -->,"actualvalue":"<#if plcCar05??>${plcCar05.actualvalue!}</#if>" <#-- 实际价值 -->,"businessType":"${businessType!}" <#-- 业务类型-->}]}
+{"systemName":"流计算平台","systemCode":"D030","sendTime":"${.now?string("yyyy-MM-dd HH:mm:ss")}","msgCode":"carpolicy","msgName":"新核心车险保单信息","data":[{"policyNo":"<#if policyNo??>${policyNo!}<#else>${businessNo!}</#if>" <#-- 保单号 -->,"underWriteEndDate":"${policyCreatDate!}" <#-- 核保通过时间 -->,"comCode":"${businessOffice!}" <#-- 保单归属机构代码 -->,"comName":"${businessOfficeName!}"  <#-- 保单归属机构名称 -->,"riskCode":"${productCode!}" <#-- 险种代码 -->,"businessNature":"${businessNatureCode!}" <#-- 业务来源 -->,"startDate":"${startTime!}" <#-- 起保时间 -->,"endDate":"${endTime!}" <#-- 终保时间 -->,"sumPremium":"${netPremium!}" <#-- 不含税保费  -->,"premium":"${premium!}" <#-- 含税保费 -->,"licenseNo":"<#if plcCar05??>${plcCar05.licensePlateNo!}</#if>" <#-- 车牌号 -->,"frameNo":"<#if plcCar05??>${plcCar05.frameNo!}</#if>" <#-- 车架号 -->,"modelCode":"<#if plcCar05??>${plcCar05.vehicleId!}</#if>" <#-- 车型 -->,"newVehicleFlag":"<#if plcCar05??>${plcCar05.newVehicleFlag!}</#if>" <#-- 新车标识 -->,"appliName":"<#if plcApplicant??><#list plcApplicant as s1>${s1.customerName!}<#if plcApplicant?size-1 gt s1?index >|</#if></#list></#if>"  <#-- 投保人名称 -->,"insuredName":"<#if plcPublicInsurant??><#list plcPublicInsurant as s1>${s1.customerName!}<#if plcPublicInsurant?size-1 gt s1?index >|</#if></#list></#if>"  <#-- 被保人名称 -->,"newPolicyFlag":"${newPolicyFlag!}" <#-- 新保标识 -->,"autoTransreNewFlag":"${autoTransrenewFlag!}" <#-- 自动续保标识 -->,"transferPolicyFlag":"${transferPolicyFlag!}" <#-- 转保标识 -->,"transreNewFlag":"${transrenewFlag!}" <#-- 续保标识 -->,"artifSelfPricesRat":"<#if plcSolution??><#list plcSolution as s1>${s1.PlcRation.artifSelfPricesRat!}<#if plcSolution?size-1 gt s1?index >|</#if></#list></#if>" <#-- 自主定价系数  -->,"artifReviewPrem":"<#if plcSolution??><#list plcSolution as s1>${s1.PlcRation.artifReviewPrem!}<#if plcSolution?size-1 gt s1?index >|</#if></#list></#if>" <#-- 总保费 -->,"agentFee":"<#if plcSolution??><#list plcSolution as s1><#if s1.plcCommissionDetail??><#list s1.plcCommissionDetail as item>${item.agentFee!}<#if s1.plcCommissionDetail?size-1 gt item?index >|</#if></#list></#if></#list></#if>" <#-- 手续费含税金额 -->,"agentNetFee":"<#if plcSolution??><#list plcSolution as s1><#if s1.plcCommissionDetail??><#list s1.plcCommissionDetail as item>${item.agentNetFee!}<#if s1.plcCommissionDetail?size-1 gt item?index >|</#if></#list></#if></#list></#if>" <#-- 手续费不含税金额 -->,"agentComCode":"${saleaman!}" <#-- 代理机构代码 -->,"agentComName":"${saleamanName!}" <#-- 代理机构名称 -->,"newChnlType":"${businessChannelCode!}" <#-- 清分后渠道 -->,"carKindCode":"<#if plcCar05??>${plcCar05.carKindCode!}</#if>" <#-- 车辆种类 -->,"useNatureCode":"<#if plcCar05??>${plcCar05.carUserNatureCode!}</#if>" <#-- 车辆使用性质 -->,"policySort":"${policySort!}" <#-- 保单种类 -->,"actualvalue":"<#if plcCar05??>${plcCar05.actualvalue!}</#if>" <#-- 实际价值 -->,"businessType":"${businessType!}" <#-- 业务类型-->}]}


 {

--- a/XF_DWD/新核心车险批单-FM.ftl
+++ b/XF_DWD/新核心车险批单-FM.ftl
 {"systemName": "流计算平台","data": [{"comCode":"${businessOffice!}" <#-- "xx",//归属机构 -->,"comName":"${businessOfficeName!}" <#-- "xx",//归属机构名称 -->,"riskCode":"${productCode!}" <#-- "xx",//险种代码 -->,"businessNature":"${businessNatureCode!}" <#-- 业务来源 -->,"endorseNo":"${endorseNo!}" <#-- "xx",//批单号 -->,"policyNo":"${policyNo!}" <#-- "xx",//保单号 -->,"sumPremium":"${netPremium!}" <#-- "xx",//不含税保费 -->,"licenseNo":"<#if plcCar05??>${plcCar05.licensePlateNo!}</#if>" <#-- "xx",//车牌号 -->,"frameNo":"<#if plcCar05??>${plcCar05.frameNo!}</#if>" <#-- "xx",//车架号 -->,"modelCode":"<#if plcCar05??>${plcCar05.vehicleId!}</#if>" <#-- "xx",//车型 -->,"newVehicleFlag":"<#if plcCar05??>${plcCar05.newVehicleFlag!}</#if>" <#-- "xx",//新车标识 -->,"appliName":"<#if plcApplicant??><#list plcApplicant as s1>${s1.customerName}<#if plcApplicant?size-1 gt s1?index >|</#if></#list></#if>"<#-- "xx",//投保人名称 -->,"insuredName":"<#if plcPublicInsurant??><#list plcPublicInsurant as s1>${s1.customerName}<#if plcPublicInsurant?size-1 gt s1?index >|</#if></#list></#if>" <#-- "xx",//被保人名称 -->,"newPolicyFlag":"${newPolicyFlag!}" <#-- "xx",//新保标识 -->,"autoTransreNewFlag":"${autoTransrenewFlag!}" <#-- "xx",//自动续保标识 -->,"transferPolicyFlag":"${transferPolicyFlag!}" <#-- "xx",//转保标识 -->,"transreNewFlag":"${transrenewFlag!}" <#-- "xx",//续保标识 -->,"artifSelfPricesRat":"<#if plcSolution??><#list plcSolution as s1><#if s1.PlcRation.artifSelfPricesRat??>${s1.PlcRation.artifSelfPricesRat}</#if><#if plcSolution?size-1 gt s1?index >|</#if></#list></#if>" <#-- "xx",//自主定价系数 -->,"artifReviewPrem":"<#if plcSolution??><#list plcSolution as s1><#if s1.PlcRation.artifReviewPrem??>${s1.PlcRation.artifReviewPrem}</#if><#if plcSolution?size-1 gt s1?index >|</#if></#list></#if>" <#-- "xx",//总保费 -->,"agentFee":"<#if plcSolution??><#list plcSolution as s1><#if s1.plcCommissionDetail??><#list s1.plcCommissionDetail as item>${item.agentFee}<#if s1.plcCommissionDetail?size-1 gt item?index >|</#if></#list></#if></#list></#if>" <#-- "xx",//手续费含税金额 -->,"agentNetFee":"<#if plcSolution??><#list plcSolution as s1><#if s1.plcCommissionDetail??><#list s1.plcCommissionDetail as item>${item.agentNetFee}<#if s1.plcCommissionDetail?size-1 gt item?index >|</#if></#list></#if></#list></#if>" <#-- "xx",//手续费不含税金额 -->,"agentComCode":"${saleaman!}" <#-- "xx",//代理机构代码 -->,"agentComName":"${saleamanName!}" <#-- "xx",//代理机构名称 -->,"newChnlType":"${businessChannelCode!}" <#-- "xx",//清分后渠道 -->,"startDate":"${startTime!}" <#-- "xx",//起保时间 -->,"endDate":"${endTime!}" <#-- "xx",//终保时间 -->,"underWriteEndDate":"${policyCreatDate!}" <#-- "xx",//核保通过时间 -->,"useNatureCode":"<#if plcCar05??>${plcCar05.carUserNatureCode!}</#if>" <#-- "xx",//车辆使用性质 -->,"carKindCode":"<#if plcCar05??>${plcCar05.carKindCode!}</#if>" <#-- "xx",//车辆种类 -->,"chgPremium":"<#if sigAndStaExchangeRate??><#if coinsRate??>${plpEndorse.netPremiumVariation!?number * sigAndStaExchangeRate!?number * coinsRate!?number}</#if></#if>" <#-- "xx",//保费变化量 -->,"policySort":"${policySort!}" <#-- "xx",//保单种类 -->}],"systemCode": "D030","msgName": "新核心车险批单信息","msgCode": "carEndorse","sendTime": "${.now?string("yyyy-MM-dd HH:mm:ss")}"}


-
 {
    "systemName": "流计算平台",
    "data": [{

--- a/XF_DWD/新核心非车险保单-FM.ftl
+++ b/XF_DWD/新核心非车险保单-FM.ftl
-{"systemName":"流计算平台","systemCode":"D030","sendTime":"${.now?string("yyyy-MM-dd HH:mm:ss")}","msgCode":"fcPolicy","msgName":"新核心非车险保单信息","data":[{"transreNewFlag":"${transrenewFlag!}" <#-- 续保标识 -->,"signDate":"${signDate!}" <#-- 签单日期 -->,"uwConclueDate":"${uwConclueDate!}" <#-- 核保通过时间 -->,"channelType":"${channelType!}" <#-- 清分后渠道 -->,"agentComCode":"${saleaman!}" <#-- 代理机构代码 -->,"agentComName":"${saleamanName!}" <#-- 代理机构名称 -->,"startDate":"${startTime!}" <#-- 起保时间 -->,"endDate":"${endTime!}" <#-- 终保时间 -->,"businessNature":"${businessNatureCode!}" <#-- 业务来源 -->,"comCode":"${businessOffice!}" <#-- 保单归属机构代码 -->,"comName":"${businessOfficeName!}"  <#-- 保单归属机构名称 -->,"appliName":"<#if plcApplicant??><#list plcApplicant as s1>${s1.customerName!}<#if plcApplicant?size-1 gt s1?index >|</#if></#list></#if>"  <#-- 投保人名称 -->,"insuredName":"<#if plcPublicInsurant??><#list plcPublicInsurant as s1>${s1.customerName!}<#if plcPublicInsurant?size-1 gt s1?index >|</#if></#list></#if>"  <#-- 被保人名称 -->,"newPolicyFlag":"${newPolicyFlag!}" <#-- 新保标识 -->,"autoTransreNewFlag":"${autoTransrenewFlag!}" <#-- 自动续保标识 -->,"transferPolicyFlag":"${transferPolicyFlag!}" <#-- 转保标识 -->,"sigAndStaExchangeRate":"${sigAndStaExchangeRate!}" <#-- 汇率 -->,"amount":"${amount!}" <#-- 保额 -->,"sumPremium":"${netPremium!}" <#-- 不含税保费  -->,"coinsRate":"${coinsRate!}" <#-- 联共保比例 *** 特殊处理 ***-->,"agentNetFee":"<#if plcSolution??><#list plcSolution as s1><#if s1.plcCommissionDetail??><#list s1.plcCommissionDetail as item>${item.agentNetFee!}<#if s1.plcCommissionDetail?size-1 gt item?index >|</#if></#list></#if></#list></#if>" <#-- 手续费不含税金额 -->,"policyNo":"<#if policyNo??>${policyNo!}<#else>${businessNo!}</#if>" <#-- 保单号 -->,"salesmanCode":"<#if plcSales??><#list plcSales as s1>${s1.salesmanCode!}<#if plcSales?size-1 gt s1?index >|</#if></#list></#if>"  <#-- 归属业务员代码 -->,"salesmanCodeName":"<#if plcSales??><#list plcSales as s1>${s1.salesmanCodeName!}<#if plcSales?size-1 gt s1?index >|</#if></#list></#if>"  <#-- 归属业务员名称 -->,"handlerCode":"<#if plcSales??><#list plcSales as s1>${s1.handlerCode!}<#if plcSales?size-1 gt s1?index >|</#if></#list></#if>"  <#-- 寿险销售人员代码 -->,"handlerName":"<#if plcSales??><#list plcSales as s1>${s1.handlerName!}<#if plcSales?size-1 gt s1?index >|</#if></#list></#if>"  <#-- 寿险销售人员名称 -->,"riskCode":"${productCode!}" <#-- "xx",//险种代码 -->}]}
+{"systemName":"流计算平台","systemCode":"D030","sendTime":"${.now?string("yyyy-MM-dd HH:mm:ss")}","msgCode":"fcPolicy","msgName":"新核心非车险保单信息","data":[{"transreNewFlag":"${transrenewFlag!}" <#-- 续保标识 -->,"signDate":"${signDate!}" <#-- 签单日期 -->,"uwConclueDate":"${uwConclueDate!}" <#-- 核保通过时间 -->,"channelType":"${channelType!}" <#-- 清分后渠道 -->,"agentComCode":"${saleaman!}" <#-- 代理机构代码 -->,"agentComName":"${saleamanName!}" <#-- 代理机构名称 -->,"startDate":"${startTime!}" <#-- 起保时间 -->,"endDate":"${endTime!}" <#-- 终保时间 -->,"businessNature":"${businessNatureCode!}" <#-- 业务来源 -->,"comCode":"${businessOffice!}" <#-- 保单归属机构代码 -->,"comName":"${businessOfficeName!}"  <#-- 保单归属机构名称 -->,"appliName":"<#if plcApplicant??><#list plcApplicant as s1>${s1.customerName!}<#if plcApplicant?size-1 gt s1?index >|</#if></#list></#if>"  <#-- 投保人名称 -->,"insuredName":"<#if plcBasic??>${plcBasic.insurantName!}</#if>"  <#-- 被保人名称 -->,"newPolicyFlag":"${newPolicyFlag!}" <#-- 新保标识 -->,"autoTransreNewFlag":"${autoTransrenewFlag!}" <#-- 自动续保标识 -->,"transferPolicyFlag":"${transferPolicyFlag!}" <#-- 转保标识 -->,"sigAndStaExchangeRate":"${sigAndStaExchangeRate!}" <#-- 汇率 -->,"amount":"${amount!}" <#-- 保额 -->,"sumPremium":"${netPremium!}" <#-- 不含税保费  -->,"coinsRate":"${coinsRate!}" <#-- 联共保比例 *** 特殊处理 ***-->,"agentNetFee":"<#if plcSolution??><#list plcSolution as s1><#if s1.plcCommissionDetail??><#list s1.plcCommissionDetail as item>${item.agentNetFee!}<#if s1.plcCommissionDetail?size-1 gt item?index >|</#if></#list></#if></#list></#if>" <#-- 手续费不含税金额 -->,"policyNo":"<#if policyNo??>${policyNo!}<#else>${businessNo!}</#if>" <#-- 保单号 -->,"salesmanCode":"<#if plcSales??><#list plcSales as s1>${s1.salesmanCode!}<#if plcSales?size-1 gt s1?index >|</#if></#list></#if>"  <#-- 归属业务员代码 -->,"salesmanCodeName":"<#if plcSales??><#list plcSales as s1>${s1.salesmanCodeName!}<#if plcSales?size-1 gt s1?index >|</#if></#list></#if>"  <#-- 归属业务员名称 -->,"handlerCode":"<#if plcSales??><#list plcSales as s1>${s1.handlerCode!}<#if plcSales?size-1 gt s1?index >|</#if></#list></#if>"  <#-- 寿险销售人员代码 -->,"handlerName":"<#if plcSales??><#list plcSales as s1>${s1.handlerName!}<#if plcSales?size-1 gt s1?index >|</#if></#list></#if>"  <#-- 寿险销售人员名称 -->,"riskCode":"${productCode!}" <#-- "xx",//险种代码 -->}]}


 {