抽取云南下发数据脚本

XF_CK/DDL元数据/TAB_COMMEN_YN.sql

+-- TAB_COMMEN_YN 车险下发云南结构
+create table TAB_COMMEN_YN(
+    systemName          varchar(256) ,
+    systemCode          varchar(256) ,
+    sendTime            varchar(256) ,
+    msgCode             varchar(256) ,
+    msgName             varchar(256) ,
+    frameNo             varchar(256) ,
+    agentComCode        varchar(256) ,
+    licenseNo           varchar(256) ,
+    endDate             varchar(256) ,
+    newPolicyFlag       varchar(256) ,
+    policyNo            varchar(256) ,
+    policySort          varchar(256) ,
+    agentFee            varchar(256) ,
+    artifSelfPricesRat  varchar(256) ,
+    modelCode           varchar(256) ,
+    comCode             varchar(256) ,
+    insuredName         varchar(256) ,
+    transferPolicyFlag  varchar(256) ,
+    chgPremium          varchar(256) ,
+    endorseNo           varchar(256) ,
+    riskCode            varchar(256) ,
+    agentNetFee         varchar(256) ,
+    agentComName        varchar(256) ,
+    businessNature      varchar(256) ,
+    useNatureCode       varchar(256) ,
+    appliName           varchar(256) ,
+    newChnlType         varchar(256) ,
+    carKindCode         varchar(256) ,
+    sumPremium          varchar(256) ,
+    underWriteEndDate   varchar(256) ,
+    autoTransreNewFlag  varchar(256) ,
+    newVehicleFlag      varchar(256) ,
+    transreNewFlag      varchar(256) ,
+    comName             varchar(256) ,
+    startDate           varchar(256) 
+
+)
\ No newline at end of file

XF_CK/数据同步/XF_CK_CAR_YN.sql

+-- XF_CK_TAB_COMMEN_YN XF_CK_云南下发结果表
+insert into XF_CK.XF_CK_MYSQL.TAB_COMMEN_YN 
+select
+    systemName
+     ,systemCode
+     ,sendTime
+     ,msgCode
+     ,msgName
+     ,data[1].frameNo
+     ,data[1].agentComCode
+     ,data[1].licenseNo
+     ,data[1].endDate
+     ,data[1].newPolicyFlag
+     ,data[1].policyNo
+     ,data[1].policySort
+     ,data[1].agentFee
+     ,data[1].artifSelfPricesRat
+     ,data[1].modelCode
+     ,data[1].comCode
+     ,data[1].insuredName
+     ,data[1].transferPolicyFlag
+     ,data[1].chgPremium
+     ,data[1].endorseNo
+     ,data[1].riskCode
+     ,data[1].agentNetFee
+     ,data[1].agentComName
+     ,data[1].businessNature
+     ,data[1].useNatureCode
+     ,data[1].appliName
+     ,data[1].newChnlType
+     ,data[1].carKindCode
+     ,data[1].sumPremium
+     ,data[1].underWriteEndDate
+     ,data[1].autoTransreNewFlag
+     ,data[1].newVehicleFlag
+     ,data[1].transreNewFlag
+     ,data[1].comName
+     ,data[1].startDate
+from XF_CK.XF_CK_KAFKA_LXT.TAB_COMMEN_YN_KAFKA
+where left(sendTime,10) = '2023-01-30'
+;