dtgitea
/
dataops
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add workflow 荟聚API_2,dev

This commit is contained in:
root 2024-06-18 16:01:30 +08:00
parent 4eb1c54862
commit 27bd1734fd
3 changed files with 186 additions and 186 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

186
dev/workflow/TK_Cust/tk_api_2/dq检查/dysql_dq_result.sql
View File

@ -33,9 +33,9 @@ SELECT 'Cons1_1' AS Check_Id
,CURRENT_TIMESTAMP AS Check_End_Time
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'s01_bd_sap_marc' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'p60_mart' AS Src_Schema_Name
,'v_cust_all_info' AS Src_Table_Name
,'' AS Src_Column_Name
,'' AS ETL_Job_Name
,COUNT(1) AS Src_Table_Total_Rec
,SUM(case when mobile_phone_availability = '1' then 1 else 0 end) AS Src_Table_Excpt_Rec
@ -72,9 +72,9 @@ SELECT 'Cons1_2' AS Check_Id
,CURRENT_TIMESTAMP AS Check_End_Time
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'s01_bd_sap_marc' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'p60_mart' AS Src_Schema_Name
,'v_cust_all_info' AS Src_Table_Name
,'' AS Src_Column_Name
,'' AS ETL_Job_Name
,COUNT(1) AS Src_Table_Total_Rec
,SUM(case when email_availability = '1' then 1 else 0 end) AS Src_Table_Excpt_Rec
@ -111,9 +111,9 @@ SELECT 'Cons1_3' AS Check_Id
,CURRENT_TIMESTAMP AS Check_End_Time
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'s01_bd_sap_marc' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'p60_mart' AS Src_Schema_Name
,'v_cust_all_info' AS Src_Table_Name
,'' AS Src_Column_Name
,'' AS ETL_Job_Name
,COUNT(1) AS Src_Table_Total_Rec
,SUM(case when ((full_name ~ '^[\u4e00-\u9fa5]{1}\.[\u4e00-\u9fa5]{1,2}$')
@ -152,9 +152,9 @@ SELECT 'Cons1_4' AS Check_Id
,CURRENT_TIMESTAMP AS Check_End_Time
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'s01_bd_sap_marc' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'p60_mart' AS Src_Schema_Name
,'v_cust_all_info' AS Src_Table_Name
,'' AS Src_Column_Name
,'' AS ETL_Job_Name
,COUNT(1) AS Src_Table_Total_Rec
,SUM(case when (company ~ '^[\u4e00-\u9fa5]+公司$'
@ -194,9 +194,9 @@ SELECT 'Integ10_1' AS Check_Id
,CURRENT_TIMESTAMP AS Check_End_Time
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'s01_bd_sap_marc' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'p60_mart' AS Src_Schema_Name
,'v_cust_all_info' AS Src_Table_Name
,'' AS Src_Column_Name
,'' AS ETL_Job_Name
,COUNT(1) AS Src_Table_Total_Rec
,SUM(case when (mobile = ''
@ -234,9 +234,9 @@ SELECT 'Integ10_2' AS Check_Id
,CURRENT_TIMESTAMP AS Check_End_Time
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'s01_bd_sap_marc' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'p60_mart' AS Src_Schema_Name
,'v_cust_all_info' AS Src_Table_Name
,'' AS Src_Column_Name
,'' AS ETL_Job_Name
,COUNT(1) AS Src_Table_Total_Rec
,SUM(case when (email = ''
@ -275,9 +275,9 @@ SELECT 'Integ10_3' AS Check_Id
,CURRENT_TIMESTAMP AS Check_End_Time
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'s01_bd_sap_marc' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'p60_mart' AS Src_Schema_Name
,'v_cust_all_info' AS Src_Table_Name
,'' AS Src_Column_Name
,'' AS ETL_Job_Name
,COUNT(1) AS Src_Table_Total_Rec
,SUM(case when (full_name = ''
@ -317,9 +317,9 @@ SELECT 'Integ10_4' AS Check_Id
,CURRENT_TIMESTAMP AS Check_End_Time
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'s01_bd_sap_marc' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'p60_mart' AS Src_Schema_Name
,'v_cust_all_info' AS Src_Table_Name
,'' AS Src_Column_Name
,'' AS ETL_Job_Name
,COUNT(1) AS Src_Table_Total_Rec
,SUM(case when (company = ''
@ -358,9 +358,9 @@ SELECT 'Integ10_5' AS Check_Id
,CURRENT_TIMESTAMP AS Check_End_Time
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'s01_bd_sap_marc' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'p60_mart' AS Src_Schema_Name
,'v_cust_all_info' AS Src_Table_Name
,'' AS Src_Column_Name
,'' AS ETL_Job_Name
,COUNT(1) AS Src_Table_Total_Rec
,SUM(case when (prov_name = ''
@ -399,9 +399,9 @@ SELECT 'Integ10_6' AS Check_Id
,CURRENT_TIMESTAMP AS Check_End_Time
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'s01_bd_sap_marc' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'p60_mart' AS Src_Schema_Name
,'v_cust_all_info' AS Src_Table_Name
,'' AS Src_Column_Name
,'' AS ETL_Job_Name
,COUNT(1) AS Src_Table_Total_Rec
,SUM(case when (city_name = ''
@ -440,9 +440,9 @@ SELECT 'Integ10_7' AS Check_Id
,CURRENT_TIMESTAMP AS Check_End_Time
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'s01_bd_sap_marc' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'p60_mart' AS Src_Schema_Name
,'v_cust_all_info' AS Src_Table_Name
,'' AS Src_Column_Name
,'' AS ETL_Job_Name
,COUNT(1) AS Src_Table_Total_Rec
,SUM(case when (industry = ''
@ -481,9 +481,9 @@ SELECT 'Cons22_1' AS Check_Id
,CURRENT_TIMESTAMP AS Check_End_Time
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'s01_bd_sap_marc' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'p60_mart' AS Src_Schema_Name
,'v_cust_all_info' AS Src_Table_Name
,'' AS Src_Column_Name
,'' AS ETL_Job_Name
,COUNT(1) AS Src_Table_Total_Rec
,SUM(case when (company <> ''
@ -522,9 +522,9 @@ SELECT 'Cons22_2' AS Check_Id
,CURRENT_TIMESTAMP AS Check_End_Time
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'s01_bd_sap_marc' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'p60_mart' AS Src_Schema_Name
,'v_cust_all_info' AS Src_Table_Name
,'' AS Src_Column_Name
,'' AS ETL_Job_Name
,COUNT(1) AS Src_Table_Total_Rec
,SUM(case when (company <> account) then 1 else 0 end) AS Src_Table_Excpt_Rec
@ -561,9 +561,9 @@ SELECT 'Cons22_5' AS Check_Id
,CURRENT_TIMESTAMP AS Check_End_Time
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'s01_bd_sap_marc' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'p60_mart' AS Src_Schema_Name
,'v_cust_all_info' AS Src_Table_Name
,'' AS Src_Column_Name
,'' AS ETL_Job_Name
,COUNT(1) AS Src_Table_Total_Rec
,SUM(case when (p2.crm_contact_id is not null) then 1 else 0 end) AS Src_Table_Excpt_Rec
@ -646,9 +646,9 @@ SELECT 'Cons22_6' AS Check_Id
,CURRENT_TIMESTAMP AS Check_End_Time
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'s01_bd_sap_marc' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'p60_mart' AS Src_Schema_Name
,'v_cust_all_info' AS Src_Table_Name
,'' AS Src_Column_Name
,'' AS ETL_Job_Name
,COUNT(1) AS Src_Table_Total_Rec
,SUM(case when (p2.crm_contact_id is not null) then 1 else 0 end) AS Src_Table_Excpt_Rec
@ -727,9 +727,9 @@ SELECT 'Cons22_7' AS Check_Id
,CURRENT_TIMESTAMP AS Check_End_Time
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'s01_bd_sap_marc' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'p30_common' AS Src_Schema_Name
,'d_xx_contact' AS Src_Table_Name
,'' AS Src_Column_Name
,'' AS ETL_Job_Name
,COUNT(1) AS Src_Table_Total_Rec
,SUM(case when (p1.email <> p2.email ) then 1 else 0 end) AS Src_Table_Excpt_Rec
@ -769,9 +769,9 @@ SELECT 'Cons22_8' AS Check_Id
,CURRENT_TIMESTAMP AS Check_End_Time
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'s01_bd_sap_marc' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'p30_common' AS Src_Schema_Name
,'d_xx_contact' AS Src_Table_Name
,'' AS Src_Column_Name
,'' AS ETL_Job_Name
,COUNT(1) AS Src_Table_Total_Rec
,SUM(case when (p1.mobile_phone <> p2.mobile_phone ) then 1 else 0 end) AS Src_Table_Excpt_Rec
@ -811,9 +811,9 @@ SELECT 'Cons22_9' AS Check_Id
,CURRENT_TIMESTAMP AS Check_End_Time
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'s01_bd_sap_marc' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'p30_common' AS Src_Schema_Name
,'d_xx_contact' AS Src_Table_Name
,'' AS Src_Column_Name
,'' AS ETL_Job_Name
,COUNT(1) AS Src_Table_Total_Rec
,SUM(case when (p1.email <> p2.email ) then 1 else 0 end) AS Src_Table_Excpt_Rec
@ -855,9 +855,9 @@ SELECT 'Cons22_10' AS Check_Id
,CURRENT_TIMESTAMP AS Check_End_Time
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'s01_bd_sap_marc' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'p30_common' AS Src_Schema_Name
,'d_xx_contact' AS Src_Table_Name
,'' AS Src_Column_Name
,'' AS ETL_Job_Name
,COUNT(1) AS Src_Table_Total_Rec
,SUM(case when (p1.mobile_phone <> p2.mobile_phone ) then 1 else 0 end) AS Src_Table_Excpt_Rec
@ -900,9 +900,9 @@ SELECT 'Cons22_11' AS Check_Id
,CURRENT_TIMESTAMP AS Check_End_Time
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'s01_bd_sap_marc' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'p30_common' AS Src_Schema_Name
,'d_xx_contact' AS Src_Table_Name
,'' AS Src_Column_Name
,'' AS ETL_Job_Name
,COUNT(1) AS Src_Table_Total_Rec
,SUM(case when (p1.email <> p2.email
@ -947,9 +947,9 @@ SELECT 'Cons22_12' AS Check_Id
,CURRENT_TIMESTAMP AS Check_End_Time
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'s01_bd_sap_marc' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'p30_common' AS Src_Schema_Name
,'d_xx_contact' AS Src_Table_Name
,'' AS Src_Column_Name
,'' AS ETL_Job_Name
,COUNT(1) AS Src_Table_Total_Rec
,SUM(case when (p1.mobile_phone <> p2.mobile_phone
@ -995,9 +995,9 @@ SELECT 'Cons22_13' AS Check_Id
,CURRENT_TIMESTAMP AS Check_End_Time
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'s01_bd_sap_marc' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'p30_common' AS Src_Schema_Name
,'d_xx_contact' AS Src_Table_Name
,'' AS Src_Column_Name
,'' AS ETL_Job_Name
,COUNT(1) AS Src_Table_Total_Rec
,SUM(case when (p1.email <> p2.email
@ -1045,9 +1045,9 @@ SELECT 'Cons22_14' AS Check_Id
,CURRENT_TIMESTAMP AS Check_End_Time
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'s01_bd_sap_marc' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'p30_common' AS Src_Schema_Name
,'d_xx_contact' AS Src_Table_Name
,'' AS Src_Column_Name
,'' AS ETL_Job_Name
,COUNT(1) AS Src_Table_Total_Rec
,SUM(case when (p1.mobile_phone <> p2.mobile_phone
@ -1095,9 +1095,9 @@ SELECT 'Cons22_15' AS Check_Id
,CURRENT_TIMESTAMP AS Check_End_Time
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'s01_bd_sap_marc' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'p30_common' AS Src_Schema_Name
,'d_xx_contact' AS Src_Table_Name
,'' AS Src_Column_Name
,'' AS ETL_Job_Name
,COUNT(1) AS Src_Table_Total_Rec
,SUM(case when (p1.email <> p2.email ) then 1 else 0 end) AS Src_Table_Excpt_Rec
@ -1137,9 +1137,9 @@ SELECT 'Cons22_16' AS Check_Id
,CURRENT_TIMESTAMP AS Check_End_Time
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'s01_bd_sap_marc' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'p30_common' AS Src_Schema_Name
,'d_xx_contact' AS Src_Table_Name
,'' AS Src_Column_Name
,'' AS ETL_Job_Name
,COUNT(1) AS Src_Table_Total_Rec
,SUM(case when (p1.mobile_phone <> p2.mobile_phone ) then 1 else 0 end) AS Src_Table_Excpt_Rec
@ -1179,9 +1179,9 @@ SELECT 'Cons22_17' AS Check_Id
,CURRENT_TIMESTAMP AS Check_End_Time
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'s01_bd_sap_marc' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'p30_common' AS Src_Schema_Name
,'d_xx_contact' AS Src_Table_Name
,'' AS Src_Column_Name
,'' AS ETL_Job_Name
,COUNT(1) AS Src_Table_Total_Rec
,SUM(case when (p1.email <> p2.email ) then 1 else 0 end) AS Src_Table_Excpt_Rec
@ -1223,9 +1223,9 @@ SELECT 'Cons22_18' AS Check_Id
,CURRENT_TIMESTAMP AS Check_End_Time
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'s01_bd_sap_marc' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'p30_common' AS Src_Schema_Name
,'d_xx_contact' AS Src_Table_Name
,'' AS Src_Column_Name
,'' AS ETL_Job_Name
,COUNT(1) AS Src_Table_Total_Rec
,SUM(case when (p1.mobile_phone <> p2.mobile_phone ) then 1 else 0 end) AS Src_Table_Excpt_Rec
@ -1268,9 +1268,9 @@ SELECT 'Cons22_19' AS Check_Id
,CURRENT_TIMESTAMP AS Check_End_Time
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'s01_bd_sap_marc' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'p30_common' AS Src_Schema_Name
,'d_xx_contact' AS Src_Table_Name
,'' AS Src_Column_Name
,'' AS ETL_Job_Name
,COUNT(1) AS Src_Table_Total_Rec
,SUM(case when (p1.email <> p2.email ) then 1 else 0 end) AS Src_Table_Excpt_Rec
@ -1310,9 +1310,9 @@ SELECT 'Cons22_20' AS Check_Id
,CURRENT_TIMESTAMP AS Check_End_Time
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'s01_bd_sap_marc' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'p30_common' AS Src_Schema_Name
,'d_xx_contact' AS Src_Table_Name
,'' AS Src_Column_Name
,'' AS ETL_Job_Name
,COUNT(1) AS Src_Table_Total_Rec
,SUM(case when (p1.mobile_phone <> p2.mobile_phone ) then 1 else 0 end) AS Src_Table_Excpt_Rec
@ -1352,9 +1352,9 @@ SELECT 'Cons22_21' AS Check_Id
,CURRENT_TIMESTAMP AS Check_End_Time
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'s01_bd_sap_marc' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'p30_common' AS Src_Schema_Name
,'d_xx_contact' AS Src_Table_Name
,'' AS Src_Column_Name
,'' AS ETL_Job_Name
,COUNT(1) AS Src_Table_Total_Rec
,SUM(case when (p1.email <> p2.email ) then 1 else 0 end) AS Src_Table_Excpt_Rec
@ -1396,9 +1396,9 @@ SELECT 'Cons22_22' AS Check_Id
,CURRENT_TIMESTAMP AS Check_End_Time
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'s01_bd_sap_marc' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'p30_common' AS Src_Schema_Name
,'d_xx_contact' AS Src_Table_Name
,'' AS Src_Column_Name
,'' AS ETL_Job_Name
,COUNT(1) AS Src_Table_Total_Rec
,SUM(case when (p1.mobile_phone <> p2.mobile_phone ) then 1 else 0 end) AS Src_Table_Excpt_Rec

90
dev/workflow/TK_Cust/tk_api_2/客户dq检查结果明细/dysql_dq_result_detail_cust_info.sql
View File

@ -7,7 +7,7 @@
DELETE FROM p51_dqc.DQ_CHECK_RESULT_DETAIL
WHERE CHECK_ID ='Cons1_1'
AND CHECK_TYPE_CD = 'Cons1'
AND Check_Run_Date = CURRENT_DATE;
;
INSERT INTO p51_dqc.DQ_CHECK_RESULT_DETAIL(
CHECK_ID
,CHECK_TYPE_CD
@ -26,9 +26,9 @@ SELECT 'Cons1_1' AS Check_Id
,CURRENT_DATE AS Check_Run_Date
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'p60_mart' AS Src_Schema_Name
,'v_cust_all_info' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'' AS Src_Column_Name
,1 AS Src_Table_Total_Rec
,row_to_json(p1)
,'' AS Remark
@ -39,7 +39,7 @@ and mobile_phone_availability = '1';
DELETE FROM p51_dqc.DQ_CHECK_RESULT_DETAIL
WHERE CHECK_ID ='Cons1_2'
AND CHECK_TYPE_CD = 'Cons1'
AND Check_Run_Date = CURRENT_DATE;
;
INSERT INTO p51_dqc.DQ_CHECK_RESULT_DETAIL(
CHECK_ID
,CHECK_TYPE_CD
@ -59,9 +59,9 @@ SELECT 'Cons1_2' AS Check_Id
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'p60_mart' AS Src_Schema_Name
,'v_cust_all_info' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'' AS Src_Column_Name
,1 AS Src_Table_Total_Rec
,row_to_json(p1)
@ -74,7 +74,7 @@ and email_availability = '1';
DELETE FROM p51_dqc.DQ_CHECK_RESULT_DETAIL
WHERE CHECK_ID ='Cons1_3'
AND CHECK_TYPE_CD = 'Cons1'
AND Check_Run_Date = CURRENT_DATE;
;
INSERT INTO p51_dqc.DQ_CHECK_RESULT_DETAIL(
CHECK_ID
,CHECK_TYPE_CD
@ -94,9 +94,9 @@ SELECT 'Cons1_3' AS Check_Id
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'p60_mart' AS Src_Schema_Name
,'v_cust_all_info' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'' AS Src_Column_Name
,1 AS Src_Table_Total_Rec
,row_to_json(p1)
@ -111,7 +111,7 @@ and ((full_name ~ '^[\u4e00-\u9fa5]{1}\.[\u4e00-\u9fa5]{1,2}$')
DELETE FROM p51_dqc.DQ_CHECK_RESULT_DETAIL
WHERE CHECK_ID ='Cons1_4'
AND CHECK_TYPE_CD = 'Cons1'
AND Check_Run_Date = CURRENT_DATE;
;
INSERT INTO p51_dqc.DQ_CHECK_RESULT_DETAIL(
CHECK_ID
,CHECK_TYPE_CD
@ -131,9 +131,9 @@ SELECT 'Cons1_4' AS Check_Id
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'p60_mart' AS Src_Schema_Name
,'v_cust_all_info' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'' AS Src_Column_Name
,1 AS Src_Table_Total_Rec
,row_to_json(p1)
@ -149,7 +149,7 @@ and (company ~ '^[\u4e00-\u9fa5]+公司$'
DELETE FROM p51_dqc.DQ_CHECK_RESULT_DETAIL
WHERE CHECK_ID ='Integ10_1'
AND CHECK_TYPE_CD = 'Integ10'
AND Check_Run_Date = CURRENT_DATE;
;
INSERT INTO p51_dqc.DQ_CHECK_RESULT_DETAIL(
CHECK_ID
,CHECK_TYPE_CD
@ -169,9 +169,9 @@ SELECT 'Integ10_1' AS Check_Id
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'p60_mart' AS Src_Schema_Name
,'v_cust_all_info' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'' AS Src_Column_Name
,1 AS Src_Table_Total_Rec
,row_to_json(p1)
@ -185,7 +185,7 @@ or mobile is NULL);
DELETE FROM p51_dqc.DQ_CHECK_RESULT_DETAIL
WHERE CHECK_ID ='Integ10_2'
AND CHECK_TYPE_CD = 'Integ10'
AND Check_Run_Date = CURRENT_DATE;
;
INSERT INTO p51_dqc.DQ_CHECK_RESULT_DETAIL(
CHECK_ID
,CHECK_TYPE_CD
@ -205,9 +205,9 @@ SELECT 'Integ10_2' AS Check_Id
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'p60_mart' AS Src_Schema_Name
,'v_cust_all_info' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'' AS Src_Column_Name
,1 AS Src_Table_Total_Rec
,row_to_json(p1)
@ -222,7 +222,7 @@ or email is NULL);
DELETE FROM p51_dqc.DQ_CHECK_RESULT_DETAIL
WHERE CHECK_ID ='Integ10_3'
AND CHECK_TYPE_CD = 'Integ10'
AND Check_Run_Date = CURRENT_DATE;
;
INSERT INTO p51_dqc.DQ_CHECK_RESULT_DETAIL(
CHECK_ID
,CHECK_TYPE_CD
@ -242,9 +242,9 @@ SELECT 'Integ10_3' AS Check_Id
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'p60_mart' AS Src_Schema_Name
,'v_cust_all_info' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'' AS Src_Column_Name
,1 AS Src_Table_Total_Rec
,row_to_json(p1)
@ -260,7 +260,7 @@ or full_name = '0');
DELETE FROM p51_dqc.DQ_CHECK_RESULT_DETAIL
WHERE CHECK_ID ='Integ10_4'
AND CHECK_TYPE_CD = 'Integ10'
AND Check_Run_Date = CURRENT_DATE;
;
INSERT INTO p51_dqc.DQ_CHECK_RESULT_DETAIL(
CHECK_ID
,CHECK_TYPE_CD
@ -280,9 +280,9 @@ SELECT 'Integ10_4' AS Check_Id
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'p60_mart' AS Src_Schema_Name
,'v_cust_all_info' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'' AS Src_Column_Name
,1 AS Src_Table_Total_Rec
,row_to_json(p1)
@ -297,7 +297,7 @@ or company is NULL);
DELETE FROM p51_dqc.DQ_CHECK_RESULT_DETAIL
WHERE CHECK_ID ='Integ10_5'
AND CHECK_TYPE_CD = 'Integ10'
AND Check_Run_Date = CURRENT_DATE;
;
INSERT INTO p51_dqc.DQ_CHECK_RESULT_DETAIL(
CHECK_ID
,CHECK_TYPE_CD
@ -317,9 +317,9 @@ SELECT 'Integ10_5' AS Check_Id
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'p60_mart' AS Src_Schema_Name
,'v_cust_all_info' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'' AS Src_Column_Name
,1 AS Src_Table_Total_Rec
,row_to_json(p1)
@ -334,7 +334,7 @@ or prov_name is NULL);
DELETE FROM p51_dqc.DQ_CHECK_RESULT_DETAIL
WHERE CHECK_ID ='Integ10_6'
AND CHECK_TYPE_CD = 'Integ10'
AND Check_Run_Date = CURRENT_DATE;
;
INSERT INTO p51_dqc.DQ_CHECK_RESULT_DETAIL(
CHECK_ID
,CHECK_TYPE_CD
@ -354,9 +354,9 @@ SELECT 'Integ10_6' AS Check_Id
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'p60_mart' AS Src_Schema_Name
,'v_cust_all_info' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'' AS Src_Column_Name
,1 AS Src_Table_Total_Rec
,row_to_json(p1)
@ -371,7 +371,7 @@ or city_name is NULL);
DELETE FROM p51_dqc.DQ_CHECK_RESULT_DETAIL
WHERE CHECK_ID ='Integ10_7'
AND CHECK_TYPE_CD = 'Integ10'
AND Check_Run_Date = CURRENT_DATE;
;
INSERT INTO p51_dqc.DQ_CHECK_RESULT_DETAIL(
CHECK_ID
,CHECK_TYPE_CD
@ -391,9 +391,9 @@ SELECT 'Integ10_7' AS Check_Id
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'p60_mart' AS Src_Schema_Name
,'v_cust_all_info' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'' AS Src_Column_Name
,1 AS Src_Table_Total_Rec
,row_to_json(p1)
@ -408,7 +408,7 @@ or industry is NULL);
DELETE FROM p51_dqc.DQ_CHECK_RESULT_DETAIL
WHERE CHECK_ID ='Cons22_1'
AND CHECK_TYPE_CD = 'Cons22'
AND Check_Run_Date = CURRENT_DATE;
;
INSERT INTO p51_dqc.DQ_CHECK_RESULT_DETAIL(
CHECK_ID
,CHECK_TYPE_CD
@ -428,9 +428,9 @@ SELECT 'Cons22_1' AS Check_Id
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'p60_mart' AS Src_Schema_Name
,'v_cust_all_info' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'' AS Src_Column_Name
,1 AS Src_Table_Total_Rec
,row_to_json(p1)
@ -445,7 +445,7 @@ AND company = account);
DELETE FROM p51_dqc.DQ_CHECK_RESULT_DETAIL
WHERE CHECK_ID ='Cons22_2'
AND CHECK_TYPE_CD = 'Cons22'
AND Check_Run_Date = CURRENT_DATE;
;
INSERT INTO p51_dqc.DQ_CHECK_RESULT_DETAIL(
CHECK_ID
,CHECK_TYPE_CD
@ -465,9 +465,9 @@ SELECT 'Cons22_2' AS Check_Id
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'p60_mart' AS Src_Schema_Name
,'v_cust_all_info' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'' AS Src_Column_Name
,1 AS Src_Table_Total_Rec
,row_to_json(p1)
@ -480,7 +480,7 @@ and (company <> account);
DELETE FROM p51_dqc.DQ_CHECK_RESULT_DETAIL
WHERE CHECK_ID ='Cons22_5'
AND CHECK_TYPE_CD = 'Cons22'
AND Check_Run_Date = CURRENT_DATE;
;
INSERT INTO p51_dqc.DQ_CHECK_RESULT_DETAIL(
CHECK_ID
,CHECK_TYPE_CD
@ -500,9 +500,9 @@ SELECT 'Cons22_5' AS Check_Id
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'p60_mart' AS Src_Schema_Name
,'v_cust_all_info' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'' AS Src_Column_Name
,1 AS Src_Table_Total_Rec
,row_to_json(p1)
@ -561,7 +561,7 @@ and (p2.crm_contact_id is not null) ;
DELETE FROM p51_dqc.DQ_CHECK_RESULT_DETAIL
WHERE CHECK_ID ='Cons22_6'
AND CHECK_TYPE_CD = 'Cons22'
AND Check_Run_Date = CURRENT_DATE;
;
INSERT INTO p51_dqc.DQ_CHECK_RESULT_DETAIL(
CHECK_ID
,CHECK_TYPE_CD
@ -581,9 +581,9 @@ SELECT 'Cons22_6' AS Check_Id
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'p60_mart' AS Src_Schema_Name
,'v_cust_all_info' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'' AS Src_Column_Name
,1 AS Src_Table_Total_Rec
,row_to_json(p1)

96
dev/workflow/TK_Cust/tk_api_2/联系信息dq检查/dysql_dq_check_contact.sql
View File

@ -8,7 +8,7 @@
DELETE FROM p51_dqc.DQ_CHECK_RESULT_DETAIL
WHERE CHECK_ID ='Cons22_7'
AND CHECK_TYPE_CD = 'Cons22'
AND Check_Run_Date = CURRENT_DATE;
;
INSERT INTO p51_dqc.DQ_CHECK_RESULT_DETAIL(
CHECK_ID
,CHECK_TYPE_CD
@ -27,9 +27,9 @@ SELECT 'Cons22_7' AS Check_Id
,CURRENT_DATE AS Check_Run_Date
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'p30_common' AS Src_Schema_Name
,'contact' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'' AS Src_Column_Name
,1 AS Src_Table_Total_Rec
,ROW_TO_JSON(P1)
,'' AS Remark
@ -52,7 +52,7 @@ and (p1.email <> p2.email ))P1;
DELETE FROM p51_dqc.DQ_CHECK_RESULT_DETAIL
WHERE CHECK_ID ='Cons22_8'
AND CHECK_TYPE_CD = 'Cons22'
AND Check_Run_Date = CURRENT_DATE;
;
INSERT INTO p51_dqc.DQ_CHECK_RESULT_DETAIL(
CHECK_ID
,CHECK_TYPE_CD
@ -72,9 +72,9 @@ SELECT 'Cons22_8' AS Check_Id
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'p30_common' AS Src_Schema_Name
,'contact' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'' AS Src_Column_Name
,1 AS Src_Table_Total_Rec
,ROW_TO_JSON(P1)
@ -98,7 +98,7 @@ and (p1.mobile_phone <> p2.mobile_phone ) )P1;
DELETE FROM p51_dqc.DQ_CHECK_RESULT_DETAIL
WHERE CHECK_ID ='Cons22_9'
AND CHECK_TYPE_CD = 'Cons22'
AND Check_Run_Date = CURRENT_DATE;
;
INSERT INTO p51_dqc.DQ_CHECK_RESULT_DETAIL(
CHECK_ID
,CHECK_TYPE_CD
@ -118,9 +118,9 @@ SELECT 'Cons22_9' AS Check_Id
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'p30_common' AS Src_Schema_Name
,'contact' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'' AS Src_Column_Name
,1 AS Src_Table_Total_Rec
,ROW_TO_JSON(P1)
@ -147,7 +147,7 @@ and (p1.email <> p2.email ))P1;
DELETE FROM p51_dqc.DQ_CHECK_RESULT_DETAIL
WHERE CHECK_ID ='Cons22_10'
AND CHECK_TYPE_CD = 'Cons22'
AND Check_Run_Date = CURRENT_DATE;
;
INSERT INTO p51_dqc.DQ_CHECK_RESULT_DETAIL(
CHECK_ID
,CHECK_TYPE_CD
@ -167,9 +167,9 @@ SELECT 'Cons22_10' AS Check_Id
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'p30_common' AS Src_Schema_Name
,'contact' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'' AS Src_Column_Name
,1 AS Src_Table_Total_Rec
,ROW_TO_JSON(P1)
@ -197,7 +197,7 @@ and (p1.mobile_phone <> p2.mobile_phone ))P1;
DELETE FROM p51_dqc.DQ_CHECK_RESULT_DETAIL
WHERE CHECK_ID ='Cons22_11'
AND CHECK_TYPE_CD = 'Cons22'
AND Check_Run_Date = CURRENT_DATE;
;
INSERT INTO p51_dqc.DQ_CHECK_RESULT_DETAIL(
CHECK_ID
,CHECK_TYPE_CD
@ -217,9 +217,9 @@ SELECT 'Cons22_11' AS Check_Id
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'p30_common' AS Src_Schema_Name
,'contact' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'' AS Src_Column_Name
,1 AS Src_Table_Total_Rec
,ROW_TO_JSON(P1)
@ -249,7 +249,7 @@ or p2.email <> p3.email ))P1;
DELETE FROM p51_dqc.DQ_CHECK_RESULT_DETAIL
WHERE CHECK_ID ='Cons22_12'
AND CHECK_TYPE_CD = 'Cons22'
AND Check_Run_Date = CURRENT_DATE;
;
INSERT INTO p51_dqc.DQ_CHECK_RESULT_DETAIL(
CHECK_ID
,CHECK_TYPE_CD
@ -269,9 +269,9 @@ SELECT 'Cons22_12' AS Check_Id
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'p30_common' AS Src_Schema_Name
,'contact' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'' AS Src_Column_Name
,1 AS Src_Table_Total_Rec
,ROW_TO_JSON(P1)
@ -302,7 +302,7 @@ or p2.mobile_phone <> p3.mobile_phone))P1;
DELETE FROM p51_dqc.DQ_CHECK_RESULT_DETAIL
WHERE CHECK_ID ='Cons22_13'
AND CHECK_TYPE_CD = 'Cons22'
AND Check_Run_Date = CURRENT_DATE;
;
INSERT INTO p51_dqc.DQ_CHECK_RESULT_DETAIL(
CHECK_ID
,CHECK_TYPE_CD
@ -322,9 +322,9 @@ SELECT 'Cons22_13' AS Check_Id
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'p30_common' AS Src_Schema_Name
,'contact' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'' AS Src_Column_Name
,1 AS Src_Table_Total_Rec
,ROW_TO_JSON(P1)
@ -357,7 +357,7 @@ or p2.email <> p3.email ))P1;
DELETE FROM p51_dqc.DQ_CHECK_RESULT_DETAIL
WHERE CHECK_ID ='Cons22_14'
AND CHECK_TYPE_CD = 'Cons22'
AND Check_Run_Date = CURRENT_DATE;
;
INSERT INTO p51_dqc.DQ_CHECK_RESULT_DETAIL(
CHECK_ID
,CHECK_TYPE_CD
@ -377,9 +377,9 @@ SELECT 'Cons22_14' AS Check_Id
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'p30_common' AS Src_Schema_Name
,'contact' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'' AS Src_Column_Name
,1 AS Src_Table_Total_Rec
,ROW_TO_JSON(P1)
@ -412,7 +412,7 @@ or p2.mobile_phone <> p3.mobile_phone))P1;
DELETE FROM p51_dqc.DQ_CHECK_RESULT_DETAIL
WHERE CHECK_ID ='Cons22_15'
AND CHECK_TYPE_CD = 'Cons22'
AND Check_Run_Date = CURRENT_DATE;
;
INSERT INTO p51_dqc.DQ_CHECK_RESULT_DETAIL(
CHECK_ID
,CHECK_TYPE_CD
@ -432,9 +432,9 @@ SELECT 'Cons22_15' AS Check_Id
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'p30_common' AS Src_Schema_Name
,'contact' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'' AS Src_Column_Name
,1 AS Src_Table_Total_Rec
,ROW_TO_JSON(P1)
@ -459,7 +459,7 @@ and (p1.email <> p2.email ))P1;
DELETE FROM p51_dqc.DQ_CHECK_RESULT_DETAIL
WHERE CHECK_ID ='Cons22_16'
AND CHECK_TYPE_CD = 'Cons22'
AND Check_Run_Date = CURRENT_DATE;
;
INSERT INTO p51_dqc.DQ_CHECK_RESULT_DETAIL(
CHECK_ID
,CHECK_TYPE_CD
@ -479,9 +479,9 @@ SELECT 'Cons22_16' AS Check_Id
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'p30_common' AS Src_Schema_Name
,'contact' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'' AS Src_Column_Name
,1 AS Src_Table_Total_Rec
,ROW_TO_JSON(P1)
@ -506,7 +506,7 @@ and (p1.mobile_phone <> p2.mobile_phone ))P1;
DELETE FROM p51_dqc.DQ_CHECK_RESULT_DETAIL
WHERE CHECK_ID ='Cons22_17'
AND CHECK_TYPE_CD = 'Cons22'
AND Check_Run_Date = CURRENT_DATE;
;
INSERT INTO p51_dqc.DQ_CHECK_RESULT_DETAIL(
CHECK_ID
,CHECK_TYPE_CD
@ -526,9 +526,9 @@ SELECT 'Cons22_17' AS Check_Id
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'p30_common' AS Src_Schema_Name
,'contact' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'' AS Src_Column_Name
,1 AS Src_Table_Total_Rec
,ROW_TO_JSON(P1)
@ -555,7 +555,7 @@ and (p1.email <> p2.email ))P1;
DELETE FROM p51_dqc.DQ_CHECK_RESULT_DETAIL
WHERE CHECK_ID ='Cons22_18'
AND CHECK_TYPE_CD = 'Cons22'
AND Check_Run_Date = CURRENT_DATE;
;
INSERT INTO p51_dqc.DQ_CHECK_RESULT_DETAIL(
CHECK_ID
,CHECK_TYPE_CD
@ -575,9 +575,9 @@ SELECT 'Cons22_18' AS Check_Id
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'p30_common' AS Src_Schema_Name
,'contact' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'' AS Src_Column_Name
,1 AS Src_Table_Total_Rec
,ROW_TO_JSON(P1)
@ -605,7 +605,7 @@ and (p1.mobile_phone <> p2.mobile_phone ))P1;
DELETE FROM p51_dqc.DQ_CHECK_RESULT_DETAIL
WHERE CHECK_ID ='Cons22_19'
AND CHECK_TYPE_CD = 'Cons22'
AND Check_Run_Date = CURRENT_DATE;
;
INSERT INTO p51_dqc.DQ_CHECK_RESULT_DETAIL(
CHECK_ID
,CHECK_TYPE_CD
@ -625,9 +625,9 @@ SELECT 'Cons22_19' AS Check_Id
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'p30_common' AS Src_Schema_Name
,'contact' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'' AS Src_Column_Name
,1 AS Src_Table_Total_Rec
,ROW_TO_JSON(P1)
@ -652,7 +652,7 @@ and (p1.email <> p2.email ))P1;
DELETE FROM p51_dqc.DQ_CHECK_RESULT_DETAIL
WHERE CHECK_ID ='Cons22_20'
AND CHECK_TYPE_CD = 'Cons22'
AND Check_Run_Date = CURRENT_DATE;
;
INSERT INTO p51_dqc.DQ_CHECK_RESULT_DETAIL(
CHECK_ID
,CHECK_TYPE_CD
@ -672,9 +672,9 @@ SELECT 'Cons22_20' AS Check_Id
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'p30_common' AS Src_Schema_Name
,'contact' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'' AS Src_Column_Name
,1 AS Src_Table_Total_Rec
,ROW_TO_JSON(P1)
@ -699,7 +699,7 @@ and (p1.mobile_phone <> p2.mobile_phone ))P1;
DELETE FROM p51_dqc.DQ_CHECK_RESULT_DETAIL
WHERE CHECK_ID ='Cons22_21'
AND CHECK_TYPE_CD = 'Cons22'
AND Check_Run_Date = CURRENT_DATE;
;
INSERT INTO p51_dqc.DQ_CHECK_RESULT_DETAIL(
CHECK_ID
,CHECK_TYPE_CD
@ -719,9 +719,9 @@ SELECT 'Cons22_21' AS Check_Id
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'p30_common' AS Src_Schema_Name
,'contact' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'' AS Src_Column_Name
,1 AS Src_Table_Total_Rec
,ROW_TO_JSON(P1)
@ -748,7 +748,7 @@ and (p1.email <> p2.email ))P1;
DELETE FROM p51_dqc.DQ_CHECK_RESULT_DETAIL
WHERE CHECK_ID ='Cons22_22'
AND CHECK_TYPE_CD = 'Cons22'
AND Check_Run_Date = CURRENT_DATE;
;
INSERT INTO p51_dqc.DQ_CHECK_RESULT_DETAIL(
CHECK_ID
,CHECK_TYPE_CD
@ -768,9 +768,9 @@ SELECT 'Cons22_22' AS Check_Id
,'TDVM' AS Src_Sys_Brief_Name
,'p51_dqc' AS Src_DB_Name
,'' AS Src_Schema_Name
,'p30_common' AS Src_Schema_Name
,'contact' AS Src_Table_Name
,'dismm' AS Src_Column_Name
,'' AS Src_Column_Name
,1 AS Src_Table_Total_Rec
,ROW_TO_JSON(P1)