指标计算承保字段调整

XF_CK/DDL元数据/CAR_JIANGSU_LXT.sql

--- CAR_JIANGSU_LXT 老系统江苏省车险下发结果表
-create table CAR_JIANGSU_LXT(
-    systemName             varchar(128) ,
-    systemCode             varchar(128) ,
-    sendTime               varchar(128) ,
-    msgCode                varchar(128) ,
-    msgName                varchar(128) ,
-    frameNo                varchar(128) ,
-    agentComCode           varchar(128) ,
-    licenseNo              varchar(128) ,
-    endDate                varchar(128) ,
-    newPolicyFlag          varchar(128) ,
-    policyNo               varchar(128) ,
-    policySort             varchar(128) ,
-    ownerId                varchar(128) ,
-    artifSelfPricesRat     varchar(128) ,
-    ownerName              varchar(128) ,
-    modelCode              varchar(128) ,
-    comCode                varchar(128) ,
-    insuredName            varchar(128) ,
-    transferPolicyFlag     varchar(128) ,
-    riskCode               varchar(128) ,
-    agentNetFee            varchar(128) ,
-    agentComName           varchar(128) ,
-    businessNature         varchar(128) ,
-    useNatureCode          varchar(128) ,
-    appliName              varchar(128) ,
-    newChnlType            varchar(128) ,
-    carKindCode            varchar(128) ,
-    sumPremium             varchar(128) ,
-    underWriteEndDate      varchar(128) ,
-    hpersonName            varchar(128) ,
-    autoTransreNewFlag     varchar(128) ,
-    agentRegNo             varchar(128) ,
-    transreNewFlag         varchar(128) ,
-    comName                varchar(128) ,
-    startDate              varchar(128)  ,
-    log_time varchar(32)  -- 用于记录数据同步时间
-
-)
\ No newline at end of file

XF_CK/DDL元数据/CAR_LXT_JSON.sql

--- USER3200NEWDATA_JIANGSU 老系统江苏省车险下发结果表JSON
-create table CAR_JIANGSU_LXT(
-    systemName             varchar(128) ,
-    systemCode             varchar(128) ,
-    sendTime               varchar(128) ,
-    msgCode                varchar(128) ,
-    msgName                varchar(128) ,
-    data [{
-        frameNo                varchar(128) ,
-        agentComCode           varchar(128) ,
-        licenseNo              varchar(128) ,
-        endDate                varchar(128) ,
-        newPolicyFlag          varchar(128) ,
-        policyNo               varchar(128) ,
-        policySort             varchar(128) ,
-        ownerId                varchar(128) ,
-        artifSelfPricesRat     varchar(128) ,
-        ownerName              varchar(128) ,
-        modelCode              varchar(128) ,
-        comCode                varchar(128) ,
-        insuredName            varchar(128) ,
-        transferPolicyFlag     varchar(128) ,
-        riskCode               varchar(128) ,
-        agentNetFee            varchar(128) ,
-        agentComName           varchar(128) ,
-        businessNature         varchar(128) ,
-        useNatureCode          varchar(128) ,
-        appliName              varchar(128) ,
-        newChnlType            varchar(128) ,
-        carKindCode            varchar(128) ,
-        sumPremium             varchar(128) ,
-        underWriteEndDate      varchar(128) ,
-        hpersonName            varchar(128) ,
-        autoTransreNewFlag     varchar(128) ,
-        agentRegNo             varchar(128) ,
-        transreNewFlag         varchar(128) ,
-        comName                varchar(128) ,
-        startDate              varchar(128)
-    }]
-    log_time varchar(32)  -- 用于记录数据同步时间
-
-)
\ No newline at end of file

XF_CK/DDL元数据/CAR_JIANGSU_JGPT.sql → XF_CK/DDL元数据/kafka/CAR_ENDOR_JSON.sql

--- CAR_JIANGSU_JGPT 加工平台江苏省车险下发结果表
-create table CAR_JIANGSU_JGPT(
+-- CAR_ENDOR_JSON 车险批单下发JSON结构
+create table CAR_ENDOR_JSON(
     systemName varchar(256) ,
     systemCode varchar(256) ,
     sendTime   varchar(256) ,

XF_CK/DDL元数据/kafka/CAR_POLICY_JSON.sql

+-- CAR_POLICY_JSON 车险保单下发JSON结构
+create table CAR_POLICY_JSON(
+    systemName varchar(256) ,
+    systemCode varchar(256) ,
+    sendTime   varchar(256) ,
+    msgCode    varchar(256) ,
+    msgName    varchar(256) ,
+    data       String
+
+)
\ No newline at end of file

XF_CK/DDL元数据/kafka/CAR_REGIST_JSON.sql

+-- CAR_REGIST_JSON 车险报案下发JSON结构
+create table CAR_REGIST_JSON(
+    systemName varchar(256) ,
+    systemCode varchar(256) ,
+    sendTime   varchar(256) ,
+    msgCode    varchar(256) ,
+    msgName    varchar(256) ,
+    data       String
+
+)
\ No newline at end of file

XF_CK/DDL元数据/XF_ENDOR_RESOULT.sql → XF_CK/DDL元数据/mysql/DETAIL_CAR_ENDOR.sql

--- XF_ENDOR_RESOULT    批单下发结果
+-- DETAIL_CAR_ENDOR    批单下发结果
 
-create  table XF_ENDOR_RESOULT
+create  table DETAIL_CAR_ENDOR
 (
     systemName           varchar(128)
     ,systemCode          varchar(64)

XF_CK/DDL元数据/XF_POLICY_RESOULT.sql → XF_CK/DDL元数据/mysql/DETAIL_CAR_POLICY.sql

-    -- XF_POLICY_RESOULT    保单下发结果
+-- DETAIL_CAR_POLICY    保单下发结果
 
-create table XF_POLICY_RESOULT
+create table DETAIL_CAR_POLICY
 (
     systemName          varchar(128)
     ,systemCode         varchar(64)

XF_CK/DDL元数据/XF_REGIST_RESOULT.sql → XF_CK/DDL元数据/mysql/DETAIL_CAR_REGIST.sql

--- XF_REGIST_RESOULT    车险报案下发结果
+-- DETAIL_CAR_REGIST    车险报案下发结果
 
-create table  XF_REGIST_RESOULT
+create table  DETAIL_CAR_REGIST
 (
     systemName           varchar(128)
     ,systemCode          varchar(64)

XF_CK/DDL元数据/mysql/LXT_CAR_ENDOR.sql

+-- DETAIL_CAR_ENDOR    批单下发结果
+
+create  table DETAIL_CAR_ENDOR
+(
+    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_CK/DDL元数据/mysql/LXT_CAR_POLICY.sql

+-- DETAIL_CAR_POLICY    保单下发结果
+
+create table DETAIL_CAR_POLICY
+(
+    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

XF_CK/DDL元数据/mysql/LXT_CAR_REGIST.sql

+-- DETAIL_CAR_REGIST    车险报案下发结果
+
+create table  DETAIL_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)
+    ,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/DDL元数据/CAR_LXT.sql → XF_CK/DDL元数据/mysql/TAB_COMMEN.sql

--- CAR_LXT 老系统车险通用数据结构
-create table CAR_LXT(
-comname varchar(128 ) ,
+-- TAB_COMMEN 下发结果通用元对象
+create table TAB_COMMEN(
+    comname varchar(128 ) ,
     systemName             varchar(128) ,
     systemCode             varchar(128) ,
     sendTime               varchar(128) ,

XF_CK/数据同步/XF_CK_CAR_JIANGSU_LXT.sql

--- XF_CK_CAR_JIANGSU_LXT XF_CK_老系统江苏省车险下发结果表
-insert into XF_CK.XF_CK_MYSQL.CAR_JIANGSU_LXT
-select
-    systemName ,
-    systemCode ,
-    sendTime   ,
-    msgCode    ,
-    msgName    ,
-    data
-from XF_CK.XF_CK_KAFKA_LXT.CAR_JIANGSU_LXT
-;

XF_CK/数据同步/XF_ENDOR_RESOULT.sql → XF_CK/数据同步/XF_CK_DETAIL_CAR_ENDOR.sql

--- XF_ENDOR_RESOULT    XF_ENDOR_下发结果同步任务
+-- XF_CK_DETAIL_CAR_ENDOR    XF_CK_DETAIL_下发结果车险理赔清单数据
 
-insert into XF_CK.XF_CK_MYSQL.XF_ENDOR_RESOULT
+insert into XF_CK.XF_CK_MYSQL.DETAIL_CAR_ENDOR
 select 
     systemName                   AS systemName
     ,systemCode                  AS systemCode 
@@ -37,6 +37,6 @@ select
     ,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
+from XF_ODS.XF_ODS_KAFKA.CAR_ENDOR_JSON s1
 where s1.msgCode = 'carEndorse'
   and s1.msgName = '新核心车险批单信息'

XF_CK/数据同步/XF_POLICY_RESOULT.sql → XF_CK/数据同步/XF_CK_DETAIL_CAR_POLICY.sql

--- XF_POLICY_RESOULT    XF_POLICY_下发结果同步任务
+-- XF_CK_DETAIL_CAR_POLICY  XF_CK_DETAIL_下发结果车险保单清单数据
 
 
-insert into XF_CK.XF_CK_MYSQL.XF_POLICY_RESOULT
+insert into XF_CK.XF_CK_MYSQL.DETAIL_CAR_POLICY
 select
      systemName                          AS systemName
     ,systemCode                          AS systemCode
@@ -41,6 +41,6 @@ select
     ,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
+from XF_ODS.XF_ODS_KAFKA.CAR_POLICY_JSON s1
 where s1.msgCode = 'carpolicy'
   and s1.msgName = '新核心车险保单信息'
\ No newline at end of file

XF_CK/数据同步/XF_REGIST_RESOULT.sql → XF_CK/数据同步/XF_CK_DETAIL_CAR_REGIST.sql

--- XF_REGIST_RESOULT    XF_REGIST_下发结果同步任务
+-- XF_CK_DETAIL_CAR_REGIST    XF_CK_DETAIL_下发结果车险报案清单数据
 
-insert into XF_CK.XF_CK_MYSQL.XF_REGIST_RESOULT
+insert into XF_CK.XF_CK_MYSQL.DETAIL_CAR_REGIST
 select 
     systemName                   AS systemName
     ,systemCode                  AS systemCode 
@@ -30,6 +30,6 @@ select
     ,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
+from XF_ODS.XF_ODS_KAFKA.CAR_REGIST_JSON s1
 where s1.msgCode = 'CarClaimCase-RegistCar'
   and s1.msgName = '车险报案环节信息'

XF_CK/数据同步/XF_CK_LXT_CAR_ENDOR.sql

+-- XF_CK_LXT_CAR_ENDOR   XF_CK_LXT_下发结果车险批单清单数据
+
+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].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_LXT.CAR_REGIST_JSON s1
+

XF_CK/数据同步/XF_CK_LXT_CAR_POLICY.sql

+-- XF_CK_LXT_CAR_POLICY    XF_CK_LXT_下发结果车险保单清单数据
+
+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].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_LXT.CAR_REGIST_JSON s1
+

XF_CK/数据同步/XF_CK_LXT_CAR_REGIST.sql

+-- XF_CK_LXT_CAR_REGIST    XF_CK_LXT_下发结果车险报案清单数据
+
+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].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_LXT.CAR_REGIST_JSON s1
+

XF_CK/数据同步/XF_CK_CAR_LXT.sql → XF_CK/数据同步/XF_CK_TAB_COMMEN.sql

--- XF_CK_CAR_LXT XF_CK_老系统下发结果表
-insert into XF_CK.XF_CK_MYSQL.CAR_LXT -- 动态调整TOPIC
+-- XF_CK_TAB_COMMEN XF_CK_下发结果表
+insert into XF_CK.XF_CK_MYSQL.TAB_COMMEN -- 动态调整TOPIC
 select
     '江苏' as comname ,
     systemName ,
@@ -8,5 +8,5 @@ select
     msgCode    ,
     msgName    ,
     data
-from XF_CK.XF_CK_KAFKA_LXT.CAR_LXT
+from XF_CK.XF_CK_KAFKA_LXT.TAB_COMMEN
 ;

XF_DWD/XF_DWD_ENDOR.sql → XF_DWD/XF_DWD_CAR_ENDOR.sql

--- XF_DWD_ENDOR XF_DWD_批单业务数据
+-- XF_DWD_CAR_ENDOR XF_DWD_车险批单业务数据
 select
 	s1.endorseNo                   ,                  -- 1 批单号
 	s1.businessOffice              ,                  -- 新核心车险批单-保单归属机构代码

XF_DWD/XF_DWD_POLICY.sql → XF_DWD/XF_DWD_CAR_POLICY.sql

--- XF_DWD_POLICY XF_DWD_保单业务数据
+-- XF_DWD_CAR_POLICY XF_DWD_车险保单业务数据
 select
 	s1.policyNo                   ,                       -- 2 保单号
 	s1.businessNo                 ,                       -- 3 业务号

XF_DWD/XF_DWD_REGIST.sql → XF_DWD/XF_DWD_CAR_REGIST.sql

--- XF_DWD_REGIST XF_DWD_理赔报案业务数据
+-- XF_DWD_CAR_REGIST XF_DWD_车险理赔报案业务数据
 select
     s1.actualData  ,
     DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd HH:mm:ss')      as log_time , -- 加工平台处理数据时间