指标计算承保字段调整

ODS/DDL元数据/REGIST.sql

@@ -55,7 +55,8 @@ REGIST_ACTUALDATA_PRPLCDAMAGE_PRPLDAMAGEADDRESS
             damageCourse    String   -- 出险经过
         )
     ),
-    log_time,
-    nodeCode
+    log_time   String         ,
+
+    nodeCode   String
 
 }
\ No newline at end of file

ODS/数据去重/DUPLICK_ENDOR.sql

@@ -42,7 +42,7 @@ select
     actualId                    ,                        -- 指标新增_唯一标识需验证
     businessNo                                          -- 业务单号
 from ODS.ODS_KAFKA_FIRSTHAND.ENDOR   -- topic MQENDOR
-where DuplicateCheckingEndorUDF(MD5(ConcatObjUDF(COALESCE(endorseNo,businessNo),businessOffice,`netPremium`))) is not true
+where DuplicateCheckingEndorUDF(MD5(ConcatObjUDF(COALESCE(endorseNo,businessNo),businessOffice,plpEndorse.netPremiumVariation))) is not true
 
 ;
 

ODS/数据同步/ODS_REGIST.sql

@@ -2,7 +2,8 @@
 insert into ODS.ODS_KAFKA_FIRSTHAND.REGIST -- topic REGIST 无需去重
 select
     s1.actualData  ,
-    DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd HH:mm:ss')      as log_time  -- 加工平台处理数据时间
+    DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd HH:mm:ss')      as log_time , -- 加工平台处理数据时间
+    nodeCode
 
 from  ODS.SOURCE_KAFKA_REGIST_PRD.REGIST s1
 ;