Commit 6adbd54d authored by 胡涛's avatar 胡涛

指标计算理赔大单字段修改

parent 9d282a93
...@@ -37,13 +37,13 @@ from ( ...@@ -37,13 +37,13 @@ from (
,d1.`LEVEL1COMCODE` as `maincom` ,d1.`LEVEL1COMCODE` as `maincom`
,d1.`no` as `no` ,d1.`no` as `no`
,d1.`claimno` as `claimno` ,d1.`claimno` as `claimno`
,d1.`settledamount` as `cost` ,d1.`lossamout` as `cost`
,d1.`chnl` as `chnl` ,d1.`chnl` as `chnl`
,d1.`chnlname` as `chnlname` ,d1.`chnlname` as `chnlname`
,CONCAT(d1.`LEVEL1COMCODE`,'/',d1.`claimno`,'/',d1.`no`) as `mainkey` ,CONCAT(d1.`LEVEL1COMCODE`,'/',d1.`claimno`,'/',d1.`no`) as `mainkey`
,d1.`risk` as `risk` ,d1.`risk` as `risk`
,d1.`riskname` as `riskname` ,d1.`riskname` as `riskname`
,ROW_NUMBER() OVER(PARTITION BY d1.`setdate` ORDER BY d1.`settledamount` DESC) as rownum ,ROW_NUMBER() OVER(PARTITION BY d1.`setdate` ORDER BY d1.`lossamout` DESC) as rownum
from ZB_ODS.ZB_ODS_KAFKA.LPDATA d1 from ZB_ODS.ZB_ODS_KAFKA.LPDATA d1
where d1.`COMNAME` is not null where d1.`COMNAME` is not null
and d1.`flag` in ('wj','yjwj') and d1.`flag` in ('wj','yjwj')
...@@ -90,20 +90,20 @@ from ( ...@@ -90,20 +90,20 @@ from (
select select
d1.`setdate` as `setdate` d1.`setdate` as `setdate`
,d1.`LEVEL1COMCODE` as `group_com` ,d1.`LEVEL1COMCODE` as `group_com`
,d1.`LEVEL1COMCODE` as `com` ,d1.`LEVEL2COMCODE` as `com`
,d1.`LEVEL1COMDESC` as `comname` ,d1.`LEVEL1COMDESC` as `comname`
,d1.`LEVEL1COMCODE` as `maincom` ,d1.`LEVEL2COMCODE` as `maincom`
,d1.`LEVEL2COMCODE` as `city` ,d1.`LEVEL2COMCODE` as `city`
,d1.`LEVEL2COMDESC` as `cityname` ,d1.`LEVEL2COMDESC` as `cityname`
,d1.`no` as `no` ,d1.`no` as `no`
,d1.`claimno` as `claimno` ,d1.`claimno` as `claimno`
,d1.`settledamount` as `cost` ,d1.`lossamout` as `cost`
,d1.`chnl` as `chnl` ,d1.`chnl` as `chnl`
,d1.`chnlname` as `chnlname` ,d1.`chnlname` as `chnlname`
,CONCAT(d1.`LEVEL1COMCODE`,'/',d1.`claimno`,'/',d1.`no`) as `mainkey` ,CONCAT(d1.`LEVEL1COMCODE`,'/',d1.`claimno`,'/',d1.`no`) as `mainkey`
,d1.`risk` as `risk` ,d1.`risk` as `risk`
,d1.`riskname` as `riskname` ,d1.`riskname` as `riskname`
,ROW_NUMBER() OVER(PARTITION BY d1.`LEVEL1COMCODE`,d1.`setdate` ORDER BY d1.`settledamount` DESC) as rownum ,ROW_NUMBER() OVER(PARTITION BY d1.`LEVEL1COMCODE`,d1.`setdate` ORDER BY d1.`lossamout` DESC) as rownum
from ZB_ODS.ZB_ODS_KAFKA.LPDATA d1 from ZB_ODS.ZB_ODS_KAFKA.LPDATA d1
where d1.`COMNAME` is not null where d1.`COMNAME` is not null
and d1.`flag` = 'wj' and d1.`flag` = 'wj'
...@@ -152,22 +152,22 @@ from ( ...@@ -152,22 +152,22 @@ from (
select select
d1.`setdate` as `setdate` d1.`setdate` as `setdate`
,d1.`LEVEL2COMCODE` as `group_com` ,d1.`LEVEL2COMCODE` as `group_com`
,d1.`LEVEL1COMCODE` as `com` ,d1.`LEVEL3COMCODE` as `com`
,d1.`LEVEL1COMDESC` as `comname` ,d1.`LEVEL1COMDESC` as `comname`
,d1.`LEVEL1COMCODE` as `maincom` ,d1.`LEVEL3COMCODE` as `maincom`
,d1.`LEVEL2COMCODE` as `city` ,d1.`LEVEL2COMCODE` as `city`
,d1.`LEVEL2COMDESC` as `cityname` ,d1.`LEVEL2COMDESC` as `cityname`
,d1.`LEVEL3COMCODE` as `country` ,d1.`LEVEL3COMCODE` as `country`
,d1.`LEVEL3COMDESC` as `countryname` ,d1.`LEVEL3COMDESC` as `countryname`
,d1.`no` as `no` ,d1.`no` as `no`
,d1.`claimno` as `claimno` ,d1.`claimno` as `claimno`
,d1.`settledamount` as `cost` ,d1.`lossamout` as `cost`
,d1.`chnl` as `chnl` ,d1.`chnl` as `chnl`
,d1.`chnlname` as `chnlname` ,d1.`chnlname` as `chnlname`
,CONCAT(d1.`LEVEL1COMCODE`,'/',d1.`claimno`,'/',d1.`no`) as `mainkey` ,CONCAT(d1.`LEVEL1COMCODE`,'/',d1.`claimno`,'/',d1.`no`) as `mainkey`
,d1.`risk` as `risk` ,d1.`risk` as `risk`
,d1.`riskname` as `riskname` ,d1.`riskname` as `riskname`
,ROW_NUMBER() OVER(PARTITION BY d1.`LEVEL2COMCODE`,d1.`setdate` ORDER BY d1.`settledamount` DESC) as rownum ,ROW_NUMBER() OVER(PARTITION BY d1.`LEVEL2COMCODE`,d1.`setdate` ORDER BY d1.`lossamout` DESC) as rownum
from ZB_ODS.ZB_ODS_KAFKA.LPDATA d1 from ZB_ODS.ZB_ODS_KAFKA.LPDATA d1
where d1.`COMNAME` is not null where d1.`COMNAME` is not null
and d1.`flag` = 'wj' and d1.`flag` = 'wj'
......
...@@ -36,13 +36,13 @@ from ( ...@@ -36,13 +36,13 @@ from (
,d1.`LEVEL1COMCODE` as `maincom` ,d1.`LEVEL1COMCODE` as `maincom`
,d1.`no` as `no` ,d1.`no` as `no`
,d1.`claimno` as `claimno` ,d1.`claimno` as `claimno`
,d1.`settledamount` as `cost` ,d1.`lossamout` as `cost`
,d1.`chnl` as `chnl` ,d1.`chnl` as `chnl`
,d1.`chnlname` as `chnlname` ,d1.`chnlname` as `chnlname`
,CONCAT(d1.`LEVEL1COMCODE`,'/',d1.`claimno`,'/',d1.`no`) as `mainkey` ,CONCAT(d1.`LEVEL1COMCODE`,'/',d1.`claimno`,'/',d1.`no`) as `mainkey`
,d1.`risk` as `risk` ,d1.`risk` as `risk`
,d1.`riskname` as `riskname` ,d1.`riskname` as `riskname`
,ROW_NUMBER() OVER(PARTITION BY d1.`setdate` ORDER BY d1.`settledamount` DESC) as rownum ,ROW_NUMBER() OVER(PARTITION BY d1.`setdate` ORDER BY d1.`lossamout` DESC) as rownum
from ZB_ODS.ZB_ODS_KAFKA.LPDATA d1 from ZB_ODS.ZB_ODS_KAFKA.LPDATA d1
where d1.`COMNAME` is not null where d1.`COMNAME` is not null
and d1.`flag` in ('wj','yjwj') and d1.`flag` in ('wj','yjwj')
...@@ -89,20 +89,20 @@ from ( ...@@ -89,20 +89,20 @@ from (
select select
d1.`setdate` as `setdate` d1.`setdate` as `setdate`
,d1.`LEVEL1COMCODE` as `group_com` ,d1.`LEVEL1COMCODE` as `group_com`
,d1.`LEVEL1COMCODE` as `com` ,d1.`LEVEL2COMCODE` as `com`
,d1.`LEVEL1COMDESC` as `comname` ,d1.`LEVEL1COMDESC` as `comname`
,d1.`LEVEL1COMCODE` as `maincom` ,d1.`LEVEL2COMCODE` as `maincom`
,d1.`LEVEL2COMCODE` as `city` ,d1.`LEVEL2COMCODE` as `city`
,d1.`LEVEL2COMDESC` as `cityname` ,d1.`LEVEL2COMDESC` as `cityname`
,d1.`no` as `no` ,d1.`no` as `no`
,d1.`claimno` as `claimno` ,d1.`claimno` as `claimno`
,d1.`settledamount` as `cost` ,d1.`lossamout` as `cost`
,d1.`chnl` as `chnl` ,d1.`chnl` as `chnl`
,d1.`chnlname` as `chnlname` ,d1.`chnlname` as `chnlname`
,CONCAT(d1.`LEVEL1COMCODE`,'/',d1.`claimno`,'/',d1.`no`) as `mainkey` ,CONCAT(d1.`LEVEL1COMCODE`,'/',d1.`claimno`,'/',d1.`no`) as `mainkey`
,d1.`risk` as `risk` ,d1.`risk` as `risk`
,d1.`riskname` as `riskname` ,d1.`riskname` as `riskname`
,ROW_NUMBER() OVER(PARTITION BY d1.`LEVEL1COMCODE`,d1.`setdate` ORDER BY d1.`settledamount` DESC) as rownum ,ROW_NUMBER() OVER(PARTITION BY d1.`LEVEL1COMCODE`,d1.`setdate` ORDER BY d1.`lossamout` DESC) as rownum
from ZB_ODS.ZB_ODS_KAFKA.LPDATA d1 from ZB_ODS.ZB_ODS_KAFKA.LPDATA d1
where d1.`COMNAME` is not null where d1.`COMNAME` is not null
and d1.`flag` = 'wj' and d1.`flag` = 'wj'
...@@ -151,22 +151,22 @@ from ( ...@@ -151,22 +151,22 @@ from (
select select
d1.`setdate` as `setdate` d1.`setdate` as `setdate`
,d1.`LEVEL2COMCODE` as `group_com` ,d1.`LEVEL2COMCODE` as `group_com`
,d1.`LEVEL1COMCODE` as `com` ,d1.`LEVEL3COMCODE` as `com`
,d1.`LEVEL1COMDESC` as `comname` ,d1.`LEVEL1COMDESC` as `comname`
,d1.`LEVEL1COMCODE` as `maincom` ,d1.`LEVEL3COMCODE` as `maincom`
,d1.`LEVEL2COMCODE` as `city` ,d1.`LEVEL2COMCODE` as `city`
,d1.`LEVEL2COMDESC` as `cityname` ,d1.`LEVEL2COMDESC` as `cityname`
,d1.`LEVEL3COMCODE` as `country` ,d1.`LEVEL3COMCODE` as `country`
,d1.`LEVEL3COMDESC` as `countryname` ,d1.`LEVEL3COMDESC` as `countryname`
,d1.`no` as `no` ,d1.`no` as `no`
,d1.`claimno` as `claimno` ,d1.`claimno` as `claimno`
,d1.`settledamount` as `cost` ,d1.`lossamout` as `cost`
,d1.`chnl` as `chnl` ,d1.`chnl` as `chnl`
,d1.`chnlname` as `chnlname` ,d1.`chnlname` as `chnlname`
,CONCAT(d1.`LEVEL1COMCODE`,'/',d1.`claimno`,'/',d1.`no`) as `mainkey` ,CONCAT(d1.`LEVEL1COMCODE`,'/',d1.`claimno`,'/',d1.`no`) as `mainkey`
,d1.`risk` as `risk` ,d1.`risk` as `risk`
,d1.`riskname` as `riskname` ,d1.`riskname` as `riskname`
,ROW_NUMBER() OVER(PARTITION BY d1.`LEVEL2COMCODE`,d1.`setdate` ORDER BY d1.`settledamount` DESC) as rownum ,ROW_NUMBER() OVER(PARTITION BY d1.`LEVEL2COMCODE`,d1.`setdate` ORDER BY d1.`lossamout` DESC) as rownum
from ZB_ODS.ZB_ODS_KAFKA.LPDATA d1 from ZB_ODS.ZB_ODS_KAFKA.LPDATA d1
where d1.`COMNAME` is not null where d1.`COMNAME` is not null
and d1.`flag` = 'wj' and d1.`flag` = 'wj'
......
...@@ -29,13 +29,13 @@ select ...@@ -29,13 +29,13 @@ select
) as `val` ) as `val`
from ( from (
select select
d1.`setdate` as `setdate` d1.`setdate` as `setdate`
,d1.`LEVEL1COMCODE` as `com` ,d1.`LEVEL1COMCODE` as `com`
,d1.`LEVEL1COMDESC` as `comname` ,d1.`LEVEL1COMDESC` as `comname`
,d1.`LEVEL1COMCODE` as `maincom` ,d1.`LEVEL1COMCODE` as `maincom`
,d1.`no` as `no` ,d1.`no` as `no`
,d1.`claimno` as `claimno` ,d1.`claimno` as `claimno`
,d1.`settledamount` as `cost` ,d1.`lossamout` as `cost`
,d1.`chnl` as `chnl` ,d1.`chnl` as `chnl`
,d1.`chnlname` as `chnlname` ,d1.`chnlname` as `chnlname`
,CONCAT(d1.`LEVEL1COMCODE`,'/',d1.`claimno`,'/',d1.`no`) as `mainkey` ,CONCAT(d1.`LEVEL1COMCODE`,'/',d1.`claimno`,'/',d1.`no`) as `mainkey`
...@@ -78,16 +78,16 @@ select ...@@ -78,16 +78,16 @@ select
) as `val` ) as `val`
from ( from (
select select
d1.`setdate` as `setdate` d1.`setdate` as `setdate`
,d1.`LEVEL1COMCODE` as `group_com` ,d1.`LEVEL1COMCODE` as `group_com`
,d1.`LEVEL1COMCODE` as `com` ,d1.`LEVEL2COMCODE` as `com`
,d1.`LEVEL1COMDESC` as `comname` ,d1.`LEVEL1COMDESC` as `comname`
,d1.`LEVEL1COMCODE` as `maincom` ,d1.`LEVEL2COMCODE` as `maincom`
,d1.`LEVEL2COMCODE` as `city` ,d1.`LEVEL2COMCODE` as `city`
,d1.`LEVEL2COMDESC` as `cityname` ,d1.`LEVEL2COMDESC` as `cityname`
,d1.`no` as `no` ,d1.`no` as `no`
,d1.`claimno` as `claimno` ,d1.`claimno` as `claimno`
,d1.`settledamount` as `cost` ,d1.`lossamout` as `cost`
,d1.`chnl` as `chnl` ,d1.`chnl` as `chnl`
,d1.`chnlname` as `chnlname` ,d1.`chnlname` as `chnlname`
,CONCAT(d1.`LEVEL1COMCODE`,'/',d1.`claimno`,'/',d1.`no`) as `mainkey` ,CONCAT(d1.`LEVEL1COMCODE`,'/',d1.`claimno`,'/',d1.`no`) as `mainkey`
...@@ -133,16 +133,16 @@ from ( ...@@ -133,16 +133,16 @@ from (
select select
d1.`setdate` as `setdate` d1.`setdate` as `setdate`
,d1.`LEVEL2COMCODE` as `group_com` ,d1.`LEVEL2COMCODE` as `group_com`
,d1.`LEVEL1COMCODE` as `com` ,d1.`LEVEL3COMCODE` as `com`
,d1.`LEVEL1COMDESC` as `comname` ,d1.`LEVEL1COMDESC` as `comname`
,d1.`LEVEL1COMCODE` as `maincom` ,d1.`LEVEL3COMCODE` as `maincom`
,d1.`LEVEL2COMCODE` as `city` ,d1.`LEVEL2COMCODE` as `city`
,d1.`LEVEL2COMDESC` as `cityname` ,d1.`LEVEL2COMDESC` as `cityname`
,d1.`LEVEL3COMCODE` as `country` ,d1.`LEVEL3COMCODE` as `country`
,d1.`LEVEL3COMDESC` as `countryname` ,d1.`LEVEL3COMDESC` as `countryname`
,d1.`no` as `no` ,d1.`no` as `no`
,d1.`claimno` as `claimno` ,d1.`claimno` as `claimno`
,d1.`settledamount` as `cost` ,d1.`lossamout` as `cost`
,d1.`chnl` as `chnl` ,d1.`chnl` as `chnl`
,d1.`chnlname` as `chnlname` ,d1.`chnlname` as `chnlname`
,CONCAT(d1.`LEVEL1COMCODE`,'/',d1.`claimno`,'/',d1.`no`) as `mainkey` ,CONCAT(d1.`LEVEL1COMCODE`,'/',d1.`claimno`,'/',d1.`no`) as `mainkey`
...@@ -186,13 +186,13 @@ select ...@@ -186,13 +186,13 @@ select
) as `val` ) as `val`
from ( from (
select select
d1.`setdate` as `setdate` d1.`setdate` as `setdate`
,d1.`LEVEL1COMCODE` as `com` ,d1.`LEVEL1COMCODE` as `com`
,d1.`LEVEL1COMDESC` as `comname` ,d1.`LEVEL1COMDESC` as `comname`
,d1.`LEVEL1COMCODE` as `maincom` ,d1.`LEVEL1COMCODE` as `maincom`
,d1.`no` as `no` ,d1.`no` as `no`
,d1.`claimno` as `claimno` ,d1.`claimno` as `claimno`
,d1.`settledamount` as `cost` ,d1.`lossamout` as `cost`
,d1.`chnl` as `chnl` ,d1.`chnl` as `chnl`
,d1.`chnlname` as `chnlname` ,d1.`chnlname` as `chnlname`
,CONCAT(d1.`LEVEL1COMCODE`,'/',d1.`claimno`,'/',d1.`no`) as `mainkey` ,CONCAT(d1.`LEVEL1COMCODE`,'/',d1.`claimno`,'/',d1.`no`) as `mainkey`
...@@ -235,16 +235,16 @@ select ...@@ -235,16 +235,16 @@ select
) as `val` ) as `val`
from ( from (
select select
d1.`setdate` as `setdate` d1.`setdate` as `setdate`
,d1.`LEVEL1COMCODE` as `group_com` ,d1.`LEVEL1COMCODE` as `group_com`
,d1.`LEVEL1COMCODE` as `com` ,d1.`LEVEL2COMCODE` as `com`
,d1.`LEVEL1COMDESC` as `comname` ,d1.`LEVEL1COMDESC` as `comname`
,d1.`LEVEL1COMCODE` as `maincom` ,d1.`LEVEL2COMCODE` as `maincom`
,d1.`LEVEL2COMCODE` as `city` ,d1.`LEVEL2COMCODE` as `city`
,d1.`LEVEL2COMDESC` as `cityname` ,d1.`LEVEL2COMDESC` as `cityname`
,d1.`no` as `no` ,d1.`no` as `no`
,d1.`claimno` as `claimno` ,d1.`claimno` as `claimno`
,d1.`settledamount` as `cost` ,d1.`lossamout` as `cost`
,d1.`chnl` as `chnl` ,d1.`chnl` as `chnl`
,d1.`chnlname` as `chnlname` ,d1.`chnlname` as `chnlname`
,CONCAT(d1.`LEVEL1COMCODE`,'/',d1.`claimno`,'/',d1.`no`) as `mainkey` ,CONCAT(d1.`LEVEL1COMCODE`,'/',d1.`claimno`,'/',d1.`no`) as `mainkey`
...@@ -289,18 +289,18 @@ select ...@@ -289,18 +289,18 @@ select
) as `val` ) as `val`
from ( from (
select select
d1.`setdate` as `setdate` d1.`setdate` as `setdate`
,d1.`LEVEL2COMCODE` as `group_com` ,d1.`LEVEL2COMCODE` as `group_com`
,d1.`LEVEL1COMCODE` as `com` ,d1.`LEVEL3COMCODE` as `com`
,d1.`LEVEL1COMDESC` as `comname` ,d1.`LEVEL1COMDESC` as `comname`
,d1.`LEVEL1COMCODE` as `maincom` ,d1.`LEVEL3COMCODE` as `maincom`
,d1.`LEVEL2COMCODE` as `city` ,d1.`LEVEL2COMCODE` as `city`
,d1.`LEVEL2COMDESC` as `cityname` ,d1.`LEVEL2COMDESC` as `cityname`
,d1.`LEVEL3COMCODE` as `country` ,d1.`LEVEL3COMCODE` as `country`
,d1.`LEVEL3COMDESC` as `countryname` ,d1.`LEVEL3COMDESC` as `countryname`
,d1.`no` as `no` ,d1.`no` as `no`
,d1.`claimno` as `claimno` ,d1.`claimno` as `claimno`
,d1.`settledamount` as `cost` ,d1.`lossamout` as `cost`
,d1.`chnl` as `chnl` ,d1.`chnl` as `chnl`
,d1.`chnlname` as `chnlname` ,d1.`chnlname` as `chnlname`
,CONCAT(d1.`LEVEL1COMCODE`,'/',d1.`claimno`,'/',d1.`no`) as `mainkey` ,CONCAT(d1.`LEVEL1COMCODE`,'/',d1.`claimno`,'/',d1.`no`) as `mainkey`
......
-- ZB_DM_CXDD ZB_DM_车险未决大单
-- bigclpbdt/日期
-- 估损调整日期在今天,按照估损金额排序,取前20,车险riskcode 05开头,其他为非车,
-- 总公司 -- 总公司
insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR
select select
CONCAT('bigclpbdt/',s1.`setdate`) as `key` CONCAT('bigclpbdt/',s1.`setdate`) as `key`
,topNUDF( ,topNUDF(
CONCAT('bigclpbdt/',s1.`setdate`) CONCAT('bigclpbdt/',s1.`setdate`)
,s1.`cost` ,s1.`cost`
,concat( ,concat(
'com' ,':' ,s1.`com` ,',' 'com' ,':' ,coalesce(s1.`com`,' ') ,','
,'maincom' ,':' ,s1.`maincom` ,',' ,'maincom' ,':' ,coalesce(s1.`maincom`,' ') ,','
,'no' ,':' ,s1.`no` ,',' ,'no' ,':' ,coalesce(s1.`no`,' ') ,','
,'claimno' ,':' ,s1.`claimno` ,',' ,'claimno' ,':' ,coalesce(s1.`claimno`,' ') ,','
,'cost' ,':' ,s1.`cost` ,',' ,'cost' ,':' ,coalesce(s1.`cost`,' ') ,','
,'comname' ,':' ,s1.`comname` ,',' ,'comname' ,':' ,coalesce(s1.`comname`,' ') ,','
,'chnl' ,':' ,s1.`chnl` ,',' ,'chnl' ,':' ,coalesce(s1.`chnl`,' ') ,','
,'mainkey' ,':' ,s1.`mainkey` ,',' ,'mainkey' ,':' ,coalesce(s1.`mainkey`,' ') ,','
,'riskname' ,':' ,s1.`riskname` ,',' ,'riskname' ,':' ,coalesce(s1.`riskname`,' ') ,','
,'chnlname' ,':' ,s1.`chnlname` ,',' ,'chnlname' ,':' ,coalesce(s1.`chnlname`,' ') ,','
,'risk' ,':' ,s1.`risk` ,'risk' ,':' ,coalesce(s1.`risk`,' ')
) )
,20 ,20
,s1.`setdate` ,s1.`setdate`
) as `val` ) as `val`
from ( from (
select select
d1.`setdate` as `setdate` d1.`setdate` as `setdate`
,d1.`LEVEL1COMCODE` as `com` ,d1.`LEVEL1COMCODE` as `com`
,d1.`LEVEL1COMDESC` as `comname` ,d1.`LEVEL1COMDESC` as `comname`
,d1.`LEVEL1COMCODE` as `maincom` ,d1.`LEVEL1COMCODE` as `maincom`
,d1.`no` as `no` ,d1.`no` as `no`
,d1.`claimno` as `claimno` ,d1.`claimno` as `claimno`
,d1.`settledamount` as `cost` ,d1.`lossamout` as `cost`
,d1.`chnl` as `chnl` ,d1.`chnl` as `chnl`
,d1.`chnlname` as `chnlname` ,d1.`chnlname` as `chnlname`
,CONCAT(d1.`LEVEL1COMCODE`,'/',d1.`claimno`,'/',d1.`no`) as `mainkey` ,CONCAT(d1.`LEVEL1COMCODE`,'/',d1.`claimno`,'/',d1.`no`) as `mainkey`
,d1.`risk` as `risk` ,d1.`risk` as `risk`
,d1.`riskname` as `riskname` ,d1.`riskname` as `riskname`
from ZB_ODS.ZB_ODS_KAFKA.LPDATA d1 from ZB_ODS.ZB_ODS_KAFKA.LPDATA d1
where d1.`COMNAME` is not null where d1.`COMNAME` is not null
and d1.`flag` in ('wj','yjwj') and d1.`flag` in ('wj','yjwj')
and LEFT(d1.`setdate`,8) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd') and LEFT(d1.`setdate`,8) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and LEFT(d1.`risk`,2) = '05' and LEFT(d1.`risk`,2) = '05'
) s1 ) s1
; ;
-- 分公司 -- 分公司
insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR
select select
CONCAT('bigcitylpbdt/',s1.`setdate`,'/',s1.`group_com`) as `key` CONCAT('bigcitylpbdt/',s1.`setdate`,'/',s1.`group_com`) as `key`
,topNUDF( ,topNUDF(
CONCAT('bigcitylpbdt/',s1.`setdate`,'/',s1.`group_com`) CONCAT('bigcitylpbdt/',s1.`setdate`,'/',s1.`group_com`)
,s1.`cost` ,s1.`cost`
,concat( ,concat(
'com' ,':' ,s1.`com` ,',' 'com' ,':' ,coalesce(s1.`com`,' ') ,','
,'maincom' ,':' ,s1.`maincom` ,',' ,'maincom' ,':' ,coalesce(s1.`maincom`,' ') ,','
,'city' ,':' ,s1.`city` ,',' ,'city' ,':' ,coalesce(s1.`city`,' ') ,','
,'cityname' ,':' ,s1.`cityname` ,',' ,'cityname' ,':' ,coalesce(s1.`cityname`,' ') ,','
,'no' ,':' ,s1.`no` ,',' ,'no' ,':' ,coalesce(s1.`no`,' ') ,','
,'claimno' ,':' ,s1.`claimno` ,',' ,'claimno' ,':' ,coalesce(s1.`claimno`,' ') ,','
,'cost' ,':' ,s1.`cost` ,',' ,'cost' ,':' ,coalesce(s1.`cost`,' ') ,','
,'comname' ,':' ,s1.`comname` ,',' ,'comname' ,':' ,coalesce(s1.`comname`,' ') ,','
,'chnl' ,':' ,s1.`chnl` ,',' ,'chnl' ,':' ,coalesce(s1.`chnl`,' ') ,','
,'mainkey' ,':' ,s1.`mainkey` ,',' ,'mainkey' ,':' ,coalesce(s1.`mainkey`,' ') ,','
,'riskname' ,':' ,s1.`riskname` ,',' ,'riskname' ,':' ,coalesce(s1.`riskname`,' ') ,','
,'chnlname' ,':' ,s1.`chnlname` ,',' ,'chnlname' ,':' ,coalesce(s1.`chnlname`,' ') ,','
,'risk' ,':' ,s1.`risk` ,'risk' ,':' ,coalesce(s1.`risk`,' ')
) )
,20 ,20
,s1.`setdate` ,s1.`setdate`
) as `val` ) as `val`
from ( from (
select select
d1.`setdate` as `setdate` d1.`setdate` as `setdate`
,d1.`LEVEL1COMCODE` as `group_com` ,d1.`LEVEL1COMCODE` as `group_com`
,d1.`LEVEL1COMCODE` as `com` ,d1.`LEVEL2COMCODE` as `com`
,d1.`LEVEL1COMDESC` as `comname` ,d1.`LEVEL1COMDESC` as `comname`
,d1.`LEVEL1COMCODE` as `maincom` ,d1.`LEVEL2COMCODE` as `maincom`
,d1.`LEVEL2COMDESC` as `city` ,d1.`LEVEL2COMCODE` as `city`
,d1.`LEVEL2COMCODE` as `cityname` ,d1.`LEVEL2COMDESC` as `cityname`
,d1.`no` as `no` ,d1.`no` as `no`
,d1.`claimno` as `claimno` ,d1.`claimno` as `claimno`
,d1.`settledamount` as `cost` ,d1.`lossamout` as `cost`
,d1.`chnl` as `chnl` ,d1.`chnl` as `chnl`
,d1.`chnlname` as `chnlname` ,d1.`chnlname` as `chnlname`
,CONCAT(d1.`LEVEL1COMCODE`,'/',d1.`claimno`,'/',d1.`no`) as `mainkey` ,CONCAT(d1.`LEVEL1COMCODE`,'/',d1.`claimno`,'/',d1.`no`) as `mainkey`
,d1.`risk` as `risk` ,d1.`risk` as `risk`
,d1.`riskname` as `riskname` ,d1.`riskname` as `riskname`
from ZB_ODS.ZB_ODS_KAFKA.LPDATA d1 from ZB_ODS.ZB_ODS_KAFKA.LPDATA d1
where d1.`COMNAME` is not null where d1.`COMNAME` is not null
and d1.`flag` = 'wj' and d1.`flag` = 'wj'
and LEFT(d1.`setdate`,8) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd') and LEFT(d1.`setdate`,8) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and LEFT(d1.`risk`,2) = '05' and LEFT(d1.`risk`,2) = '05'
) s1 ) s1
; ;
...@@ -107,52 +101,51 @@ insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR ...@@ -107,52 +101,51 @@ insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR
select select
CONCAT('bigcountrylpbdt/',s1.`setdate`,'/',s1.`group_com`) as `key` CONCAT('bigcountrylpbdt/',s1.`setdate`,'/',s1.`group_com`) as `key`
,topNUDF( ,topNUDF(
CONCAT('bigcountrylpbdt/',s1.`setdate`,'/',s1.`group_com`) CONCAT('bigcountrylpbdt/',s1.`setdate`,'/',s1.`group_com`)
,s1.`cost` ,s1.`cost`
,concat( ,concat(
'com' ,':' ,s1.`com` ,',' 'com' ,':' ,coalesce(s1.`com`,' ') ,','
,'maincom' ,':' ,s1.`maincom` ,',' ,'maincom' ,':' ,coalesce(s1.`maincom`,' ') ,','
,'city' ,':' ,s1.`city` ,',' ,'city' ,':' ,coalesce(s1.`city`,' ') ,','
,'cityname' ,':' ,s1.`cityname` ,',' ,'cityname' ,':' ,coalesce(s1.`cityname`,' ') ,','
,'country' ,':' ,s1.`country` ,',' ,'country' ,':' ,coalesce(s1.`country`,' ') ,','
,'countryname' ,':' ,s1.`countryname` ,',' ,'countryname' ,':' ,coalesce(s1.`countryname`,' ') ,','
,'no' ,':' ,s1.`no` ,',' ,'no' ,':' ,coalesce(s1.`no`,' ') ,','
,'claimno' ,':' ,s1.`claimno` ,',' ,'claimno' ,':' ,coalesce(s1.`claimno`,' ') ,','
,'cost' ,':' ,s1.`cost` ,',' ,'cost' ,':' ,coalesce(s1.`cost`,' ') ,','
,'comname' ,':' ,s1.`comname` ,',' ,'comname' ,':' ,coalesce(s1.`comname`,' ') ,','
,'chnl' ,':' ,s1.`chnl` ,',' ,'chnl' ,':' ,coalesce(s1.`chnl`,' ') ,','
,'mainkey' ,':' ,s1.`mainkey` ,',' ,'mainkey' ,':' ,coalesce(s1.`mainkey`,' ') ,','
,'riskname' ,':' ,s1.`riskname` ,',' ,'riskname' ,':' ,coalesce(s1.`riskname`,' ') ,','
,'chnlname' ,':' ,s1.`chnlname` ,',' ,'chnlname' ,':' ,coalesce(s1.`chnlname`,' ') ,','
,'risk' ,':' ,s1.`risk` ,'risk' ,':' ,coalesce(s1.`risk`,' ')
) )
,20 ,20
,s1.`setdate` ,s1.`setdate`
) as `val` ) as `val`
from ( from (
select select
d1.`setdate` as `setdate` d1.`setdate` as `setdate`
,d1.`LEVEL2COMCODE` as `group_com` ,d1.`LEVEL2COMCODE` as `group_com`
,d1.`LEVEL1COMCODE` as `com` ,d1.`LEVEL3COMCODE` as `com`
,d1.`LEVEL1COMDESC` as `comname` ,d1.`LEVEL1COMDESC` as `comname`
,d1.`LEVEL1COMCODE` as `maincom` ,d1.`LEVEL3COMCODE` as `maincom`
,d1.`LEVEL2COMDESC` as `city` ,d1.`LEVEL2COMCODE` as `city`
,d1.`LEVEL2COMCODE` as `cityname` ,d1.`LEVEL2COMDESC` as `cityname`
,d1.`LEVEL3COMCODE` as `country` ,d1.`LEVEL3COMCODE` as `country`
,d1.`LEVEL3COMDESC` as `countryname` ,d1.`LEVEL3COMDESC` as `countryname`
,d1.`no` as `no` ,d1.`no` as `no`
,d1.`claimno` as `claimno` ,d1.`claimno` as `claimno`
,d1.`settledamount` as `cost` ,d1.`lossamout` as `cost`
,d1.`chnl` as `chnl` ,d1.`chnl` as `chnl`
,d1.`chnlname` as `chnlname` ,d1.`chnlname` as `chnlname`
,CONCAT(d1.`LEVEL1COMCODE`,'/',d1.`claimno`,'/',d1.`no`) as `mainkey` ,CONCAT(d1.`LEVEL1COMCODE`,'/',d1.`claimno`,'/',d1.`no`) as `mainkey`
,d1.`risk` as `risk` ,d1.`risk` as `risk`
,d1.`riskname` as `riskname` ,d1.`riskname` as `riskname`
from ZB_ODS.ZB_ODS_KAFKA.LPDATA d1 from ZB_ODS.ZB_ODS_KAFKA.LPDATA d1
where d1.`COMNAME` is not null where d1.`COMNAME` is not null
and d1.`flag` = 'wj' and d1.`flag` = 'wj'
and LEFT(d1.`setdate`,8) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd') and LEFT(d1.`setdate`,8) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and LEFT(d1.`risk`,2) = '05' and LEFT(d1.`risk`,2) = '05'
) s1 ) s1
; ;
\ No newline at end of file
...@@ -5,99 +5,99 @@ ...@@ -5,99 +5,99 @@
-- 总公司 -- 总公司
insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR
select select
CONCAT('bigfclpbdt/',s1.`setdate`) as `key` CONCAT('bigfclpbdt/',s1.`setdate`) as `key`
,topNUDF( ,topNUDF(
CONCAT('bigfclpbdt/',s1.`setdate`) CONCAT('bigfclpbdt/',s1.`setdate`)
,s1.`cost` ,s1.`cost`
,concat( ,concat(
'com' ,':' ,s1.`com` ,',' 'com' ,':' ,coalesce(s1.`com`,' ') ,','
,'maincom' ,':' ,s1.`maincom` ,',' ,'maincom' ,':' ,coalesce(s1.`maincom`,' ') ,','
,'no' ,':' ,s1.`no` ,',' ,'no' ,':' ,coalesce(s1.`no`,' ') ,','
,'claimno' ,':' ,s1.`claimno` ,',' ,'claimno' ,':' ,coalesce(s1.`claimno`,' ') ,','
,'cost' ,':' ,s1.`cost` ,',' ,'cost' ,':' ,coalesce(s1.`cost`,' ') ,','
,'comname' ,':' ,s1.`comname` ,',' ,'comname' ,':' ,coalesce(s1.`comname`,' ') ,','
,'chnl' ,':' ,s1.`chnl` ,',' ,'chnl' ,':' ,coalesce(s1.`chnl`,' ') ,','
,'mainkey' ,':' ,s1.`mainkey` ,',' ,'mainkey' ,':' ,coalesce(s1.`mainkey`,' ') ,','
,'riskname' ,':' ,s1.`riskname` ,',' ,'riskname' ,':' ,coalesce(s1.`riskname`,' ') ,','
,'chnlname' ,':' ,s1.`chnlname` ,',' ,'chnlname' ,':' ,coalesce(s1.`chnlname`,' ') ,','
,'risk' ,':' ,s1.`risk` ,'risk' ,':' ,coalesce(s1.`risk`,' ')
) )
,20 ,20
,s1.`setdate` ,s1.`setdate`
) as `val` ) as `val`
from ( from (
select select
d1.`setdate` as `setdate` d1.`setdate` as `setdate`
,d1.`LEVEL1COMCODE` as `com` ,d1.`LEVEL1COMCODE` as `com`
,d1.`LEVEL1COMDESC` as `comname` ,d1.`LEVEL1COMDESC` as `comname`
,d1.`LEVEL1COMCODE` as `maincom` ,d1.`LEVEL1COMCODE` as `maincom`
,d1.`no` as `no` ,d1.`no` as `no`
,d1.`claimno` as `claimno` ,d1.`claimno` as `claimno`
,d1.`settledamount` as `cost` ,d1.`lossamout` as `cost`
,d1.`chnl` as `chnl` ,d1.`chnl` as `chnl`
,d1.`chnlname` as `chnlname` ,d1.`chnlname` as `chnlname`
,CONCAT(d1.`LEVEL1COMCODE`,'/',d1.`claimno`,'/',d1.`no`) as `mainkey` ,CONCAT(d1.`LEVEL1COMCODE`,'/',d1.`claimno`,'/',d1.`no`) as `mainkey`
,d1.`risk` as `risk` ,d1.`risk` as `risk`
,d1.`riskname` as `riskname` ,d1.`riskname` as `riskname`
from ZB_ODS.ZB_ODS_KAFKA.LPDATA d1 from ZB_ODS.ZB_ODS_KAFKA.LPDATA d1
where d1.`COMNAME` is not null where d1.`COMNAME` is not null
and d1.`flag` in ('wj','yjwj') and d1.`flag` in ('wj','yjwj')
and LEFT(d1.`setdate`,8) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd') and LEFT(d1.`setdate`,8) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and LEFT(d1.`risk`,2) <> '05' and LEFT(d1.`risk`,2) <> '05'
) s1 ) s1
; ;
-- 分公司 -- 分公司
insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR
select select
CONCAT('bigfcitylpbdt/',s1.`setdate`,'/',s1.`group_com`) as `key` CONCAT('bigfcitylpbdt/',s1.`setdate`,'/',s1.`group_com`) as `key`
,topNUDF( ,topNUDF(
CONCAT('bigfcitylpbdt/',s1.`setdate`,'/',s1.`group_com`) CONCAT('bigfcitylpbdt/',s1.`setdate`,'/',s1.`group_com`)
,s1.`cost` ,s1.`cost`
,concat( ,concat(
'com' ,':' ,s1.`com` ,',' 'com' ,':' ,coalesce(s1.`com`,' ') ,','
,'maincom' ,':' ,s1.`maincom` ,',' ,'maincom' ,':' ,coalesce(s1.`maincom`,' ') ,','
,'city' ,':' ,s1.`city` ,',' ,'city' ,':' ,coalesce(s1.`city`,' ') ,','
,'cityname' ,':' ,s1.`cityname` ,',' ,'cityname' ,':' ,coalesce(s1.`cityname`,' ') ,','
,'no' ,':' ,s1.`no` ,',' ,'no' ,':' ,coalesce(s1.`no`,' ') ,','
,'claimno' ,':' ,s1.`claimno` ,',' ,'claimno' ,':' ,coalesce(s1.`claimno`,' ') ,','
,'cost' ,':' ,s1.`cost` ,',' ,'cost' ,':' ,coalesce(s1.`cost`,' ') ,','
,'comname' ,':' ,s1.`comname` ,',' ,'comname' ,':' ,coalesce(s1.`comname`,' ') ,','
,'chnl' ,':' ,s1.`chnl` ,',' ,'chnl' ,':' ,coalesce(s1.`chnl`,' ') ,','
,'mainkey' ,':' ,s1.`mainkey` ,',' ,'mainkey' ,':' ,coalesce(s1.`mainkey`,' ') ,','
,'riskname' ,':' ,s1.`riskname` ,',' ,'riskname' ,':' ,coalesce(s1.`riskname`,' ') ,','
,'chnlname' ,':' ,s1.`chnlname` ,',' ,'chnlname' ,':' ,coalesce(s1.`chnlname`,' ') ,','
,'risk' ,':' ,s1.`risk` ,'risk' ,':' ,coalesce(s1.`risk`,' ')
) )
,20 ,20
,s1.`setdate` ,s1.`setdate`
) as `val` ) as `val`
from ( from (
select select
d1.`setdate` as `setdate` d1.`setdate` as `setdate`
,d1.`LEVEL1COMCODE` as `group_com` ,d1.`LEVEL1COMCODE` as `group_com`
,d1.`LEVEL1COMCODE` as `com` ,d1.`LEVEL2COMCODE` as `com`
,d1.`LEVEL1COMDESC` as `comname` ,d1.`LEVEL1COMDESC` as `comname`
,d1.`LEVEL1COMCODE` as `maincom` ,d1.`LEVEL2COMCODE` as `maincom`
,d1.`LEVEL2COMDESC` as `city` ,d1.`LEVEL2COMCODE` as `city`
,d1.`LEVEL2COMCODE` as `cityname` ,d1.`LEVEL2COMDESC` as `cityname`
,d1.`no` as `no` ,d1.`no` as `no`
,d1.`claimno` as `claimno` ,d1.`claimno` as `claimno`
,d1.`settledamount` as `cost` ,d1.`lossamout` as `cost`
,d1.`chnl` as `chnl` ,d1.`chnl` as `chnl`
,d1.`chnlname` as `chnlname` ,d1.`chnlname` as `chnlname`
,CONCAT(d1.`LEVEL1COMCODE`,'/',d1.`claimno`,'/',d1.`no`) as `mainkey` ,CONCAT(d1.`LEVEL1COMCODE`,'/',d1.`claimno`,'/',d1.`no`) as `mainkey`
,d1.`risk` as `risk` ,d1.`risk` as `risk`
,d1.`riskname` as `riskname` ,d1.`riskname` as `riskname`
from ZB_ODS.ZB_ODS_KAFKA.LPDATA d1 from ZB_ODS.ZB_ODS_KAFKA.LPDATA d1
where d1.`COMNAME` is not null where d1.`COMNAME` is not null
and d1.`flag` = 'wj' and d1.`flag` = 'wj'
and LEFT(d1.`setdate`,8) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd') and LEFT(d1.`setdate`,8) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and LEFT(d1.`risk`,2) <> '05' and LEFT(d1.`risk`,2) <> '05'
) s1 ) s1
; ;
...@@ -107,52 +107,51 @@ insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR ...@@ -107,52 +107,51 @@ insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR
select select
CONCAT('bigfcountrylpbdt/',s1.`setdate`,'/',s1.`group_com`) as `key` CONCAT('bigfcountrylpbdt/',s1.`setdate`,'/',s1.`group_com`) as `key`
,topNUDF( ,topNUDF(
CONCAT('bigfcountrylpbdt/',s1.`setdate`,'/',s1.`group_com`) CONCAT('bigfcountrylpbdt/',s1.`setdate`,'/',s1.`group_com`)
,s1.`cost` ,s1.`cost`
,concat( ,concat(
'com' ,':' ,s1.`com` ,',' 'com' ,':' ,coalesce(s1.`com`,' ') ,','
,'maincom' ,':' ,s1.`maincom` ,',' ,'maincom' ,':' ,coalesce(s1.`maincom`,' ') ,','
,'city' ,':' ,s1.`city` ,',' ,'city' ,':' ,coalesce(s1.`city`,' ') ,','
,'cityname' ,':' ,s1.`cityname` ,',' ,'cityname' ,':' ,coalesce(s1.`cityname`,' ') ,','
,'country' ,':' ,s1.`country` ,',' ,'country' ,':' ,coalesce(s1.`country`,' ') ,','
,'countryname' ,':' ,s1.`countryname` ,',' ,'countryname' ,':' ,coalesce(s1.`countryname`,' ') ,','
,'no' ,':' ,s1.`no` ,',' ,'no' ,':' ,coalesce(s1.`no`,' ') ,','
,'claimno' ,':' ,s1.`claimno` ,',' ,'claimno' ,':' ,coalesce(s1.`claimno`,' ') ,','
,'cost' ,':' ,s1.`cost` ,',' ,'cost' ,':' ,coalesce(s1.`cost`,' ') ,','
,'comname' ,':' ,s1.`comname` ,',' ,'comname' ,':' ,coalesce(s1.`comname`,' ') ,','
,'chnl' ,':' ,s1.`chnl` ,',' ,'chnl' ,':' ,coalesce(s1.`chnl`,' ') ,','
,'mainkey' ,':' ,s1.`mainkey` ,',' ,'mainkey' ,':' ,coalesce(s1.`mainkey`,' ') ,','
,'riskname' ,':' ,s1.`riskname` ,',' ,'riskname' ,':' ,coalesce(s1.`riskname`,' ') ,','
,'chnlname' ,':' ,s1.`chnlname` ,',' ,'chnlname' ,':' ,coalesce(s1.`chnlname`,' ') ,','
,'risk' ,':' ,s1.`risk` ,'risk' ,':' ,coalesce(s1.`risk`,' ')
) )
,20 ,20
,s1.`setdate` ,s1.`setdate`
) as `val` ) as `val`
from ( from (
select select
d1.`setdate` as `setdate` d1.`setdate` as `setdate`
,d1.`LEVEL2COMCODE` as `group_com` ,d1.`LEVEL2COMCODE` as `group_com`
,d1.`LEVEL1COMCODE` as `com` ,d1.`LEVEL3COMCODE` as `com`
,d1.`LEVEL1COMDESC` as `comname` ,d1.`LEVEL1COMDESC` as `comname`
,d1.`LEVEL1COMCODE` as `maincom` ,d1.`LEVEL3COMCODE` as `maincom`
,d1.`LEVEL2COMDESC` as `city` ,d1.`LEVEL2COMCODE` as `city`
,d1.`LEVEL2COMCODE` as `cityname` ,d1.`LEVEL2COMDESC` as `cityname`
,d1.`LEVEL3COMCODE` as `country` ,d1.`LEVEL3COMCODE` as `country`
,d1.`LEVEL3COMDESC` as `countryname` ,d1.`LEVEL3COMDESC` as `countryname`
,d1.`no` as `no` ,d1.`no` as `no`
,d1.`claimno` as `claimno` ,d1.`claimno` as `claimno`
,d1.`settledamount` as `cost` ,d1.`lossamout` as `cost`
,d1.`chnl` as `chnl` ,d1.`chnl` as `chnl`
,d1.`chnlname` as `chnlname` ,d1.`chnlname` as `chnlname`
,CONCAT(d1.`LEVEL1COMCODE`,'/',d1.`claimno`,'/',d1.`no`) as `mainkey` ,CONCAT(d1.`LEVEL1COMCODE`,'/',d1.`claimno`,'/',d1.`no`) as `mainkey`
,d1.`risk` as `risk` ,d1.`risk` as `risk`
,d1.`riskname` as `riskname` ,d1.`riskname` as `riskname`
from ZB_ODS.ZB_ODS_KAFKA.LPDATA d1 from ZB_ODS.ZB_ODS_KAFKA.LPDATA d1
where d1.`COMNAME` is not null where d1.`COMNAME` is not null
and d1.`flag` = 'wj' and d1.`flag` = 'wj'
and LEFT(d1.`setdate`,8) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd') and LEFT(d1.`setdate`,8) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and LEFT(d1.`risk`,2) <> '05' and LEFT(d1.`risk`,2) <> '05'
) s1 ) s1
; ;
\ 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