Skip to content

D
dataquality_doc
Commit 36933573 authored by 王东's avatar 王东
Browse files
Options

指标计算承保字段调整

parent cc6f47ca
Expand all Show whitespace changes
Inline Side-by-side
Showing with 250 additions and 166 deletions
CK_ODS/码表同步/CK_ODS_CD_CAR_MODEL.sql
View file @ 36933573
-- CK_ODS_CD_CAR_MODEL CK_ODS_车辆车型码表
insert into CK_ODS.CK_ODS_MYSQL.CD_CAR_MODEL
select
REMARK ,
SEATMAX_TD ,
SEATCOUNT ,
HORSEPOWER ,
FACTORY ,
SERIESCODE ,
SERIESNAME ,
BRANDNAME ,
PURCHASEPRICE ,
PURCHASEPRICETAX ,
CARKIND ,
COMPLETEMASSMAX_TD ,
COMPLETEMASSMIN_TD ,
SYXCLASSID ,
JQXCLASSID ,
SYXCLASSDESC ,
JQXCLASSDESC ,
AIRBAGCOUNT ,
RISKTYPE ,
TRANSMISSIONTYPE ,
MODELNAME ,
MODELCODE ,
BRANDCODE ,
SEATMIN_TD ,
CARSTYLE ,
THEFTPROOF ,
VEHICLEALIAS ,
CARYEAR ,
TONCOUNT ,
EXHAUSTSCALE ,
PRODUCTSTATUS ,
ABSFLAG ,
POWERTYPE ,
POWERTYPECODE
from CK_ODS.CK_SOURCE_TD_PCDEVW.CD_CAR_MODEL
\ No newline at end of file
s1.BRANDNAME ,
s1.MODELNAME ,
s1.MODELCODE ,
s1.BRANDCODE
from CK_ODS.CK_SOURCE_TD_PCDEVW.CD_CAR_MODEL s1
left join CK_ODS.CK_ODS_MYSQL.CD_CAR_MODEL s2 on s1.BRANDCODE = s2.BRANDCODE and s1.MODELCODE = s2.MODELCODE
where s2.BRANDCODE is null
;
ZB_CK/数据存储差异清单导出/ZB_CK_CHECK_CBDATA.sql
View file @ 36933573
......@@ -118,13 +118,16 @@ select
s1.`flag` ,
s1.log_time
from (
select * from ZB_CK.ZB_CK_MYSQL.KAFKA_CBDATA where uwConclueDate = DATE_FORMAT(TIMESTAMPADD(DAY,-1,LOCALTIMESTAMP),'yyyyMMdd')
select * from ZB_CK.ZB_CK_MYSQL.KAFKA_CBDATA
where uwConclueDate = DATE_FORMAT(TIMESTAMPADD(DAY,-1,LOCALTIMESTAMP),'yyyyMMdd')
) s1
left join (
select * from ZB_CK.ZB_CK_ORACLE_ANAQUERY.WEB_REALTIME_BUSINESS_INFO where UNDERWRITEENDDATE like concat(DATE_FORMAT(TIMESTAMPADD(DAY,-1,LOCALTIMESTAMP),'yyyy-MM-dd'),'%')
select * from ZB_CK.ZB_CK_ORACLE_ANAQUERY.WEB_REALTIME_BUSINESS_INFO
where UNDERWRITEENDDATE like concat(DATE_FORMAT(TIMESTAMPADD(DAY,-1,LOCALTIMESTAMP),'yyyy-MM-dd'),'%')
and LOADDATE like concat(DATE_FORMAT(TIMESTAMPADD(DAY,-1,LOCALTIMESTAMP),'yyyy-MM-dd'),'%')
) s2
on s1.`no` = s2.BUSINESSNO
and s1.COMCODE = s2.COMCODE
and cast(s1.cost as decimal(18,0)) = cast(s2.BAOFEI as decimal(18,0))
and cast(s1.cost as decimal(18,2)) - cast(s2.BAOFEI as decimal(18,2)) between -0.1 and 0.1
where s2.BUSINESSNO is null
;
\ No newline at end of file
temp3.json
View file @ 36933573
This diff is collapsed.
tmp.sql
View file @ 36933573
{
"systemName": "流计算平台", //源系统名称，参见 IT 作业平台系统清单
"systemCode": "D030", //源系统编码，参见 IT 作业平台系统清单
"sendTime": "2022-06-01 16:21:05", // 消 息 发 送 时 间
"msgCode": "carEndorse", // 消 息 队 列 管 理 方 指 定
"msgName": "新核心车险批单信息", // 消 息 队 列 管 理 方 指 定
"data":[{ //list 长度不宜过大，请适当控制消息体大小。
"comCode": "", // 归属机构
"comName": "", // 归属机构名称
"riskCode": "", // 险种代码
"endorseNo": "", // 批单号
"policyNo": "", // 保单号
"sumPremium": "", // 不含税保费
"licenseNo": "", // 车牌号
"frameNo": "", // 车架号
"modelCode": "", // 车型
"newVehicleFlag": "", // 新车标识
"appliName": "", // 投保人名称
"insuredName": "", // 被保人名称
"newPolicyFlag": "", // 新保标识
"autoTransreNewFlag": "", // 自动续保标识
"transferPolicyFlag": "", // 转保标识
"transreNewFlag": "", // 续保标识
"artifSelfPricesRat": "", // 自主定价系数
"agentFee": "", // 手续费含税金额
"agentNetFee": "", // 手续费不含税金额
"agentComCode": "", // 代理机构代码
"agentComName": "", // 代理机构名称
"newChnlType": "", // 清分后渠道
"startDate": "", // 起保时间
"endDate": "", // 终保时间
"underWriteEndDate": "", // 核保通过时间
"useNatureCode": "", // 车辆使用性质
"carKindCode": "", // 车辆种类
"chgPremium": "", // 保费变化量
"policySort": "", // 保单种类
"businessNature": "", // 业务来源
{"FLAG":false,"BATCHID":"447612078299382240","MESSAGE":"服务执行异常：日志号码:447612078299382240","EXCEPTION":"null:异常信息：NullPointerException null\r
com.ydwf.bridge.DATAPROCESS.dprunplan.v2.DpRunPlanSave.createDirectory(DpRunPlanSave.java:302)\r
com.ydwf.bridge.DATAPROCESS.dprunplan.v2.DpRunPlanSave.execServer(DpRunPlanSave.java:104)\r
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)\r
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)\r
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)\r
java.lang.reflect.Method.invoke(Method.java:498)\r
com.ydwf.component.baseserver.exec(baseserver.java:1086)\r
com.ydwf.component.baseserver.StartFlow(baseserver.java:883)\r
com.ydwf.cloud.service.ServiceObject.exec(ServiceObject.java:187)\r
com.ydwf.cloud.controller.ServiceController.baseService(ServiceController.java:322)\r
com.ydwf.cloud.controller.ServiceController.service(ServiceController.java:188)\r
sun.reflect.GeneratedMethodAccessor104.invoke(Unknown Source)\r
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)\r
java.lang.reflect.Method.invoke(Method.java:498)\r
org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:190)\r
org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:138)\r
org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:105)\r
org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:893)\r
org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:798)\r
org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:87)\r
org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:1040)\r
org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:943)\r
org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:1006)\r
org.springframework.web.servlet.FrameworkServlet.doPost(FrameworkServlet.java:909)\r
javax.servlet.http.HttpServlet.service(HttpServlet.java:665)\r
org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:883)\r
javax.servlet.http.HttpServlet.service(HttpServlet.java:750)\r
org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:755)\r
org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1617)\r
com.alibaba.druid.support.http.WebStatFilter.doFilter(WebStatFilter.java:123)\r
org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1604)\r
org.springframework.boot.actuate.web.trace.servlet.HttpTraceFilter.doFilterInternal(HttpTraceFilter.java:88)\r
org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119)\r
org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1604)\r
com.ydwf.cloud.filter.ServiceAuthenticationFilter.doFilter(ServiceAuthenticationFilter.java:224)\r
org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1604)\r
org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:100)\r
org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119)\r
org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1604)\r
org.springframework.web.filter.FormContentFilter.doFilterInternal(FormContentFilter.java:93)\r
org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119)\r
org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1604)\r
org.springframework.web.filter.HiddenHttpMethodFilter.doFilterInternal(HiddenHttpMethodFilter.java:94)\r
org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119)\r
org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1604)\r
org.springframework.boot.actuate.metrics.web.servlet.WebMvcMetricsFilter.filterAndRecordMetrics(WebMvcMetricsFilter.java:114)\r
org.springframework.boot.actuate.metrics.web.servlet.WebMvcMetricsFilter.doFilterInternal(WebMvcMetricsFilter.java:104)\r
org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119)\r
org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1604)\r
org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:201)\r
org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119)\r
org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1604)\r
org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:545)\r
org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:143)\r
org.eclipse.jetty.security.SecurityHandler.handle(SecurityHandler.java:590)\r
org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127)\r
org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:235)\r
org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:1607)\r
org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233)\r
org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1297)\r
org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:188)\r
org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:485)\r
org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:1577)\r
org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:186)\r
org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1212)\r
org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141)\r
org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127)\r
org.eclipse.jetty.server.Server.handle(Server.java:500)\r
org.eclipse.jetty.server.HttpChannel.lambda$handle$1(HttpChannel.java:383)\r
org.eclipse.jetty.server.HttpChannel.dispatch(HttpChannel.java:547)\r
org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:375)\r
org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:270)\r
org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:311)\r
org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:103)\r
org.eclipse.jetty.io.ChannelEndPoint$2.run(ChannelEndPoint.java:117)\r
org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.runTask(EatWhatYouKill.java:336)\r
org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.doProduce(EatWhatYouKill.java:313)\r
org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.tryProduce(EatWhatYouKill.java:171)\r
org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.run(EatWhatYouKill.java:129)\r
org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread.run(ReservedThreadExecutor.java:388)\r
org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:806)\r
org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:938)\r
java.lang.Thread.run(Thread.java:748)\r
"}
}]
}
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment

版权所有@2016-2024 北京云端微服科技有限公司