指标计算承保字段调整

CK_ODS/DDL元数据/DATACHECK_USER_RELATION.sql

+-- DATACHECK_USER_RELATION 质量校验规则与人员关系表
+-- 通过 TB_DP_RULE_DATACHECK、TB_DP_RULE_DATACHECK_USER关联获得
+create table CK_ODS.DATACHECK_USER_RELATION
+(
+	CHECK_RULE_NO varchar(50)  comment '校验规则编号',
+	DATA_CHECK_TYPE varchar(8) null comment '校验规则类型',
+	CHECK_ATTR_NAME varchar(50) null comment '校验的属性名称',
+	CHECK_ATTR_ID varchar(32) null comment '字段值',
+	CHECK_MESSAGE text null comment '校验提示信息',
+	USER_NAME  varchar(50) null comment '联系人姓名',
+	USER_IDNO  varchar(50)  comment '联系人身份证号',
+	primary key(CHECK_RULE_NO,USER_IDNO)
+)
+;
+

CK_ODS/DDL元数据/TB_DP_RULE_DATACHECK.sql

--- TB_DP_RULE_DATACHECK 质量校验
-create table TB_DP_RULE_DATACHECK
+-- TB_DP_RULE_DATACHECK 质量校验规则列表
+create table db_dataprocess.TB_DP_RULE_DATACHECK (加工平台自带)
 (
-
 	CHECK_RULE_NO varchar(50) null comment '校验规则编号',
 	DATA_CHECK_TYPE varchar(8) null comment '校验规则类型',
 	CHECK_ATTR_NAME varchar(50) null comment '校验的属性名称',
 	CHECK_ATTR_ID varchar(32) null comment '字段值',
 	CHECK_MESSAGE text null comment '校验提示信息',
 	STATUS varchar(2) null comment '规则状态(0无效，1有效)'
+
 )
 ;
 

CK_ODS/DDL元数据/TB_DP_RULE_DATACHECK_USER.sql

+-- TB_DP_RULE_DATACHECK_USER 质量校验规则人员表
+create table CK_ODS.TB_DP_RULE_DATACHECK_USER
+(
+	CHECK_RULE_NO varchar(50)  comment '校验规则编号',
+	USER_NAME  varchar(50) null comment '联系人姓名',
+	USER_IDNO  varchar(50)  comment '联系人身份证号',
+	STATUS varchar(2)  comment '规则状态(0无效，1有效)',
+	primary key(CHECK_RULE_NO,USER_IDNO,STATUS)
+)
+;
+

CK_ODS/码表同步/CK_ODS_DATACHECK_USER_RELATION.sql

+-- CK_ODS_DATACHECK_USER_RELATION CK_ODS_校验规则与人员关系表
+
+insert into CK_ODS.CK_ODS_MYSQL.DATACHECK_USER_RELATION
+select
+	 s1.CHECK_RULE_NO     --  '校验规则编号',
+	, s1.DATA_CHECK_TYPE   --  '校验规则类型',
+	, s1.CHECK_ATTR_NAME   --  '校验的属性名称',
+	, s1.CHECK_ATTR_ID     --  '字段值',
+	, s1.CHECK_MESSAGE     --  '校验提示信息',
+	, s2.USER_NAME         --  '联系人姓名',
+	, s2.USER_IDNO         --  '联系人身份证号',
+from CK_ODS.CK_ODS_MYSQL_DATAPROCESS.TB_DP_RULE_DATACHECK s1
+left join CK_ODS.CK_ODS_MYSQL.TB_DP_RULE_DATACHECK_USER s2
+on s1.CHECK_RULE_NO = s2.CHECK_RULE_NO
+where
+    s1.STATUS = '1'
+    and s2.STATUS = '1'
+    and s2.CHECK_RULE_NO is not null
+
+;
\ No newline at end of file

CK_TS/DDL元数据/CKTSTEMPLATE.sql

+-- CKTSTEMPLATE 校验预警推送模板对象
+
+create table CKTSTEMPLATE(   --topic GSCWECHART
+    PKID               varchar(64)  primary key   , -- pk
+    CHECK_RULE_NO      varchar(64)      , -- 规则代码
+    CHECK_SUM          varchar(64)      , -- 规则统计错误数量
+    CEECK_DETAILLIST   longtext         , -- 规则统计错误数据清单
+    CHECK_MESSAGE      varchar(1000)    , -- 规则统计错误描述
+    USER_NAME          varchar(64)      , -- 联系人姓名
+    USER_IDNO          varchar(64)      , -- 联系人身份证号
+    LOG_TIME           varchar(32)        -- 数据记录时间
+)
\ No newline at end of file

XF_DWD/新核心车险批单-FM.ftl

@@ -8,6 +8,7 @@
         "comCode":"${businessOffice!}" <#-- "xx",//归属机构 -->
         ,"comName":"${businessOfficeName!}" <#-- "xx",//归属机构名称 -->
         ,"riskCode":"${productCode!}" <#-- "xx",//险种代码 -->
+        ,"businessNature":"${businessNatureCode!}" <#-- 业务来源 -->
         ,"endorseNo":"${endorseNo!}" <#-- "xx",//批单号 -->
         ,"policyNo":"${policyNo!}" <#-- "xx",//保单号 -->
         ,"sumPremium":"${netPremium!}" <#-- "xx",//不含税保费 -->

XF_DWD/新核心非车险保单-FM.ftl

+{
+"systemName":"流计算平台",
+"systemCode":"D030",
+"sendTime":"${.now?string("yyyy-MM-dd HH:mm:ss")}",
+"msgCode":"fcPolicy",
+"msgName":"新核心非车险保单信息",
+"data":[{
+ "transreNewFlag":"${transrenewFlag!}" <#-- 续保标识 -->
+,"classcode":"${classcode!}" <#-- 险类 -->
+,"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":"${policyNo!}" <#-- 保单号 -->
+,"salesmanCode":"${PlcSales.salesmanCode!}" <#-- 保单号 归属业务员代码 *** 新增可暂时不配置 *** -->
+,"salesmanCodeName":"${PlcSales.salesmanCodeName!}" <#-- 保单号 归属业务员名称 *** 新增可暂时不配置 ***  -->
+,"handlerCode":"${PlcSales.handlerCode!}" <#-- 保单号 寿险销售人员代码 *** 新增可暂时不配置 *** -->
+,"handlerName":"${PlcSales.handlerName!}" <#-- 保单号 寿险销售人员名称 *** 新增可暂时不配置 *** -->
+,"riskCode":"${productCode!}" <#-- "xx",//险种代码 -->
+
+}]
+}

XF_DWD/新核心非车险批单-FM.ftl

+{
+"systemName": "流计算平台",
+"systemCode": "D030",
+"msgName": "新核心非车险批单信息",
+"msgCode": "fcEndorse",
+"sendTime": "${.now?string("yyyy-MM-dd HH:mm:ss")}",
+"data": [{
+ "policyNo":"${policyNo!}" <#-- "xx",//保单号 -->
+,"endorseNo":"${endorseNo!}" <#-- "xx",//批单号 -->
+,"comCode":"${businessOffice!}" <#-- "xx",//归属机构 -->
+,"comName":"${businessOfficeName!}" <#-- "xx",//归属机构名称 -->
+,"agentComCode":"${saleaman!}" <#-- "xx",//代理机构代码 -->
+,"agentComName":"${saleamanName!}" <#-- "xx",//代理机构名称 -->
+,"riskCode":"${productCode!}" <#-- "xx",//险种代码 -->
+,"businessNature":"${businessNatureCode!}" <#-- 业务来源 -->
+,"channelType":"${channelType!}" <#-- 清分后渠道 -->
+,"uwConclueDate":"${uwConclueDate!}" <#-- "xx",//核批通过时间 -->
+,"endorseEffectiveTime":"<#if plpEndorse??>${plpEndorse.endorseEffectiveTime!}</#if>" <#-- "xx",//核批完成时间 -->
+,"recordClerkCode":"${recordClerkCode!}" <#-- 归属业务员ID -->
+,"recordClerkName":"${recordClerkName!}" <#-- 归属业务员名称 -->
+,"handlerCode":"${PlcSales.handlerCode!}" <#-- 保单号 寿险销售人员代码 *** 新增可暂时不配置 *** -->
+,"handlerName":"${PlcSales.handlerName!}" <#-- 保单号 寿险销售人员名称 *** 新增可暂时不配置 *** -->
+,"netPremiumVariation":"<#if plpEndorse??>${plpEndorse.netPremiumVariation!}</#if>" <#-- 不含税保费变化量 -->
+,"coinsRate":"${coinsRate!}" <#-- 联共保比例 *** 特殊处理 ***-->
+,"newPolicyFlag":"${newPolicyFlag!}" <#-- "xx",//新保标识 -->
+,"autoTransreNewFlag":"${autoTransrenewFlag!}" <#-- "xx",//自动续保标识 -->
+,"transferPolicyFlag":"${transferPolicyFlag!}" <#-- "xx",//转保标识 -->
+,"transreNewFlag":"${transrenewFlag!}" <#-- "xx",//续保标识 -->
+,"premiumVariation":"<#if plpEndorse??>${plpEndorse.premiumVariation!}</#if>" <#-- 保费变化量 -->
+,"sigAndStaExchangeRate":"${sigAndStaExchangeRate!}" <#-- 汇率 -->
+
+}]
+
+}
\ No newline at end of file