- 浏览: 31263 次
- 性别:
- 来自: 上海
-
最近访客 更多访客>>
最新评论
-
punan7005：
这不就是我们公司吗
转（坚决抛弃powerdesigner建模） -
jkluooop：
我尝试过啊，很郁闷，在第一次访问的时候IE跟FFX下老弹出登录 ...
JCIFS相关 -
every：
你好
请教2008 ad 如何配置ssl
AD、CA、SSL，绑定keystore
CREATE OR REPLACE PACKAGE BODY NETS_TCIMS_UNION_RESULT
IS
/***********************************************************
--功能说明:
--参数说明:
--调用函数:
--修改记录： EX-LIUJIALI001
--注意事项： 顺序在 所有清洗、功能完成之后 屏蔽 操作之前
--*********************************************************/
PROCEDURE SP_UNITE_PC_ENTER_RESULT_0
IS
p_id NUMBER; -- 日志记录id
p_errmsg VARCHAR2(500); -- 错误记录
BEGIN
-- 操作记录
NETS_TCIMS_COMM.SP_LOG_RECORDER(p_id,54,NULL,'01',NULL,NULL,NULL,NULL);
--清空结果临时表
NETS_TCIMS_COMM.SP_TRUNCATE('TCIMSLOGTMP','PC_ENTER_RESULT_STG_0_TMP');
INSERT /*+APPEND*/
INTO PC_ENTER_RESULT_STG_0_TMP
(
SYS_ID,
VT_FACTORY,
VEHICLE_STATUS,
CITY,
SECONDARY_ORG,
THIRD_ORG,
LIST_TYPE
)
SELECT /*+PARALLEL(A 2) PARALLEL(B 2) PARALLEL(C 2)*/
A.SYS_ID,
A.VT_FACTORY,
A.VEHICLE_STATUS,
NVL(B.CITY,A.CITY) CITY,
NVL(B.SECONDARY_ORG,A.SECONDARY_ORG) SECONDARY_ORG,
NVL(B.THIRD_ORG,A.THIRD_ORG) THIRD_ORG,
NVL(B.LIST_TYPE,A.LIST_TYPE) LIST_TYPE
FROM IDL_SEP_SRC_DATA A,
PC_CLEAN_SH_YDC_FLAG_STG_TMP B,
IDL_EX_BATCH C
WHERE A.SYS_ID = B.SYS_ID(+)
AND NOT EXISTS(SELECT 1 FROM PC_CLEAN_CITY_STG_TMP E
WHERE A.SYS_ID = E.SYS_ID)
AND NOT EXISTS(SELECT 1 FROM PC_COMPARE_REPEAT_STG_TMP D
WHERE A.SYS_ID = D.SYS_ID)
AND A.TCIMS_BATCH_ID = C.TCIMS_BATCH_ID
AND C.SERIES_TYPE = '01'
AND C.BATCH_STATUS = '14'
AND C.PREPARE_FLAG = '1';
COMMIT;
-- 更新本次操作日志
NETS_TCIMS_COMM.SP_LOG_RECORDER(p_id,54,NULL,'02',NULL,NULL,NULL,NULL);
EXCEPTION
WHEN OTHERS THEN
p_errmsg := substr(sqlerrm,1,500);
NETS_TCIMS_COMM.SP_LOG_RECORDER(p_id,54,NULL,'03',p_errmsg,NULL,NULL,NULL);
RAISE;
END SP_UNITE_PC_ENTER_RESULT_0;
/***********************************************************
--功能说明:
--参数说明:
--调用函数:
--修改记录： EX-LIUJIALI001
--注意事项： 顺序在 SP_UNITE_PC_ENTER_RESULT_0 功能完成之后
--*********************************************************/
PROCEDURE SP_UNITE_PC_ENTER_RESULT_1
IS
p_id NUMBER; -- 日志记录id
p_errmsg VARCHAR2(500); -- 错误记录
BEGIN
-- 操作记录
NETS_TCIMS_COMM.SP_LOG_RECORDER(p_id,70,NULL,'01',NULL,NULL,NULL,NULL);
--清空结果临时表
NETS_TCIMS_COMM.SP_TRUNCATE('TCIMSLOGTMP','PC_ENTER_RESULT_STG_1_TMP');
INSERT /*+APPEND*/
INTO PC_ENTER_RESULT_STG_1_TMP
(
SYS_ID,
VEHICLE_NO,
VEHICLE_NO_INTEGRITY,
TEL_NO,
BRAND_TYPE_CODE
)
SELECT /*+PARALLEL(A 2) PARALLEL(B 2) PARALLEL(C 2) PARALLEL(D 2)*/
A.SYS_ID,
B.VEHICLE_NO,
B.VEHICLE_NO_INTEGRITY,
C.TEL_NO,
D.BRAND_TYPE_CODE
FROM PC_ENTER_RESULT_STG_0_TMP A,
(SELECT SYS_ID,
VEHICLE_NO,
CITY,
VEHICLE_NO_INTEGRITY
FROM PC_CLEAN_VEHICLE_NO_STG_TMP
WHERE CLEAN_STATUS = '1') B,
(SELECT SYS_ID,
TEL_NO,
CITY
FROM PC_CLEAN_TELEPHONE_STG_TMP
WHERE CLEAN_STATUS = '1') C,
(SELECT SYS_ID,
BRAND_TYPE_CODE
FROM PC_CLEAN_BRAND_TYPE_CD_STG_TMP
WHERE CLEAN_STATUS = '1') D
WHERE A.SYS_ID = B.SYS_ID(+)
AND A.SYS_ID = C.SYS_ID(+)
AND A.SYS_ID = D.SYS_ID(+);
COMMIT;
-- 更新本次操作日志
NETS_TCIMS_COMM.SP_LOG_RECORDER(P_ID,70,NULL,'02',NULL,NULL,NULL,NULL);
EXCEPTION
WHEN OTHERS THEN
P_ERRMSG := SUBSTR(SQLERRM,1,500);
NETS_TCIMS_COMM.SP_LOG_RECORDER(P_ID,70,NULL,'03',P_ERRMSG,NULL,NULL,NULL);
RAISE;
END SP_UNITE_PC_ENTER_RESULT_1;
/***********************************************************
--功能说明:
--参数说明:
--调用函数:
--修改记录： EX-LIUJIALI001
--注意事项： 顺序在 SP_UNITE_PC_ENTER_RESULT_0 功能完成之后
--*********************************************************/
PROCEDURE SP_UNITE_PC_ENTER_RESULT_2
IS
p_id NUMBER; -- 日志记录id
p_errmsg VARCHAR2(500); -- 错误记录
BEGIN
-- 操作记录
NETS_TCIMS_COMM.SP_LOG_RECORDER(p_id,71,NULL,'01',NULL,NULL,NULL,NULL);
--清空结果临时表
NETS_TCIMS_COMM.SP_TRUNCATE('TCIMSLOGTMP','PC_ENTER_RESULT_STG_2_TMP');
INSERT /*+APPEND*/
INTO PC_ENTER_RESULT_STG_2_TMP
(
SYS_ID,
USAGE_CODE,
ENGINE_NUMBER,
VEHICLE_FRAME
)
SELECT /*+PARALLEL(A 2) PARALLEL(B 2) PARALLEL(C 2) PARALLEL(D 2)*/
A.SYS_ID,
B.USAGE_CODE,
C.ENGINE_NUMBER,
D.VEHICLE_FRAME
FROM PC_ENTER_RESULT_STG_0_TMP A,
(SELECT SYS_ID,
USAGE_CODE,
USAGE_ATTRIBUTE
FROM PC_CLEAN_USAGE_CODE_STG_TMP
WHERE CLEAN_STATUS = '1') B,
PC_CLEAN_ENGINE_NO_STG_TMP C,
PC_CLEAN_VEHICLE_FRAME_STG_TMP D
WHERE A.SYS_ID = B.SYS_ID(+)
AND A.SYS_ID = C.SYS_ID(+)
AND A.SYS_ID = D.SYS_ID(+);
COMMIT;
-- 更新本次操作日志
NETS_TCIMS_COMM.SP_LOG_RECORDER(P_ID,71,NULL,'02',NULL,NULL,NULL,NULL);
EXCEPTION
WHEN OTHERS THEN
P_ERRMSG := SUBSTR(SQLERRM,1,500);
NETS_TCIMS_COMM.SP_LOG_RECORDER(P_ID,71,NULL,'03',P_ERRMSG,NULL,NULL,NULL);
RAISE;
END SP_UNITE_PC_ENTER_RESULT_2;
/***********************************************************
--功能说明:
--参数说明:
--调用函数:
--修改记录： EX-LIUJIALI001
--注意事项： 顺序在 SP_UNITE_PC_ENTER_RESULT_0 功能完成之后
--*********************************************************/
PROCEDURE SP_UNITE_PC_ENTER_RESULT_3
IS
p_id NUMBER; -- 日志记录id
p_errmsg VARCHAR2(500); -- 错误记录
BEGIN
-- 操作记录
NETS_TCIMS_COMM.SP_LOG_RECORDER(p_id,72,NULL,'01',NULL,NULL,NULL,NULL);
--清空结果临时表
NETS_TCIMS_COMM.SP_TRUNCATE('TCIMSLOGTMP','PC_ENTER_RESULT_STG_3_TMP');
INSERT /*+APPEND*/
INTO PC_ENTER_RESULT_STG_3_TMP
(
SYS_ID,
VEHICLE_TYPE_CODE,
SALUTATION,
ADDRESS,
IS_ADDRESS_VALID
)
SELECT /*+PARALLEL(A 2) PARALLEL(B 2) PARALLEL(C 2) PARALLEL(D 2)*/
A.SYS_ID,
B.VEHICLE_TYPE_CODE,
C.SALUTATION,
D.ADDRESS,
D.IS_ADDRESS_VALID
FROM PC_ENTER_RESULT_STG_0_TMP A,
(SELECT SYS_ID,
VEHICLE_TYPE_CODE,
VEHICLE_TYPE
FROM PC_CLEAN_VEHIC_TYPE_CD_STG_TMP
WHERE CLEAN_STATUS = '1') B,
PC_CLEAN_SALUTATION_STG_TMP C,
PC_CLEAN_ADDRESS_STG_TMP D
WHERE A.SYS_ID = B.SYS_ID(+)
AND A.SYS_ID = C.SYS_ID(+)
AND A.SYS_ID = D.SYS_ID(+);
COMMIT;
-- 更新本次操作日志
NETS_TCIMS_COMM.SP_LOG_RECORDER(P_ID,72,NULL,'02',NULL,NULL,NULL,NULL);
EXCEPTION
WHEN OTHERS THEN
P_ERRMSG := SUBSTR(SQLERRM,1,500);
NETS_TCIMS_COMM.SP_LOG_RECORDER(P_ID,72,NULL,'03',P_ERRMSG,NULL,NULL,NULL);
RAISE;
END SP_UNITE_PC_ENTER_RESULT_3;
/***********************************************************
--功能说明:
--参数说明:
--调用函数:
--修改记录： EX-LIUJIALI001
--注意事项： 顺序在 SP_UNITE_PC_ENTER_RESULT_0 功能完成之后
--*********************************************************/
PROCEDURE SP_UNITE_PC_ENTER_RESULT_4
IS
p_id NUMBER; -- 日志记录id
p_errmsg VARCHAR2(500); -- 错误记录
BEGIN
-- 操作记录
NETS_TCIMS_COMM.SP_LOG_RECORDER(p_id,73,NULL,'01',NULL,NULL,NULL,NULL);
--清空结果临时表
NETS_TCIMS_COMM.SP_TRUNCATE('TCIMSLOGTMP','PC_ENTER_RESULT_STG_4_TMP');
INSERT /*+APPEND*/
INTO PC_ENTER_RESULT_STG_4_TMP
(
SYS_ID,
MAIN_DRIVER_SEX,
TON_NUMBER,
SEAT_NUMBER,
VEHICLE_VALUE,
EXHAUST,
VEHICLE_BODY_COLOR
)
SELECT /*+PARALLEL(A 2) PARALLEL(B 2) PARALLEL(C 2) PARALLEL(D 2)*/
A.SYS_ID,
B.MAIN_DRIVER_SEX,
C.TON_NUMBER,
C.SEAT_NUMBER,
C.VEHICLE_VALUE,
C.EXHAUST,
D.VEHICLE_BODY_COLOR
FROM PC_ENTER_RESULT_STG_0_TMP A,
PC_CLEAN_DRIVER_SEX_STG_TMP B,
PC_CLEAN_SOME_NUMBER_STG_TMP C,
PC_CLEAN_CAR_COLOR_STG_TMP D
WHERE A.SYS_ID = B.SYS_ID(+)
AND A.SYS_ID = C.SYS_ID(+)
AND A.SYS_ID = D.SYS_ID(+);
COMMIT;
-- 更新本次操作日志
NETS_TCIMS_COMM.SP_LOG_RECORDER(P_ID,73,NULL,'02',NULL,NULL,NULL,NULL);
EXCEPTION
WHEN OTHERS THEN
P_ERRMSG := SUBSTR(SQLERRM,1,500);
NETS_TCIMS_COMM.SP_LOG_RECORDER(P_ID,73,NULL,'03',P_ERRMSG,NULL,NULL,NULL);
RAISE;
END SP_UNITE_PC_ENTER_RESULT_4;
/***********************************************************
--功能说明:
--参数说明:
--调用函数:
--修改记录： EX-LIUJIALI001
--注意事项： 顺序在 SP_UNITE_PC_ENTER_RESULT_0 功能完成之后
--*********************************************************/
PROCEDURE SP_UNITE_PC_ENTER_RESULT_5
IS
p_id NUMBER; -- 日志记录id
p_errmsg VARCHAR2(500); -- 错误记录
BEGIN
-- 操作记录
NETS_TCIMS_COMM.SP_LOG_RECORDER(p_id,74,NULL,'01',NULL,NULL,NULL,NULL);
--清空结果临时表
NETS_TCIMS_COMM.SP_TRUNCATE('TCIMSLOGTMP','PC_ENTER_RESULT_STG_5_TMP');
INSERT /*+APPEND*/
INTO PC_ENTER_RESULT_STG_5_TMP
(
SYS_ID,
ID_NUMBER,
SEX,
CUST_DOB
)
SELECT /*+ PUSH_SUBQ PARALLEL(A 2) PARALLEL(B 2) PARALLEL(C 2) PARALLEL(D 2)*/
A.SYS_ID,
B.ID_NUMBER,
NVL(B.SEX,C.SEX) SEX,
NVL(B.CUST_DOB,TO_DATE(D.CUST_DOB,'YYYY-MM-DD')) CUST_DOB
FROM PC_ENTER_RESULT_STG_0_TMP A,
(SELECT SYS_ID,ID_NUMBER,SEX,CUST_DOB
FROM PC_CLEAN_ID_NUMBER_STG_TMP
WHERE CLEAN_STATUS = '1') B, -- 改生日 客户性别
(SELECT SYS_ID,SEX
FROM PC_CLEAN_SEX_STG_TMP ) C,
(SELECT SYS_ID,CUST_DOB
FROM PC_CLEAN_CUST_DOB_STG_TMP
WHERE CLEAN_STATUS = '1' ) D
WHERE A.SYS_ID = B.SYS_ID(+)
AND A.SYS_ID = C.SYS_ID(+)
AND A.SYS_ID = D.SYS_ID(+);
COMMIT;
-- 更新本次操作日志
NETS_TCIMS_COMM.SP_LOG_RECORDER(P_ID,74,NULL,'02',NULL,NULL,NULL,NULL);
EXCEPTION
WHEN OTHERS THEN
P_ERRMSG := SUBSTR(SQLERRM,1,500);
NETS_TCIMS_COMM.SP_LOG_RECORDER(P_ID,74,NULL,'03',P_ERRMSG,NULL,NULL,NULL);
RAISE;
END SP_UNITE_PC_ENTER_RESULT_5;
/***********************************************************
--功能说明:
--参数说明:
--调用函数:
--修改记录： EX-LIUJIALI001
--注意事项： 顺序在 SP_UNITE_PC_ENTER_RESULT_0 功能完成之后
--*********************************************************/
PROCEDURE SP_UNITE_PC_ENTER_RESULT_6
IS
p_id NUMBER; -- 日志记录id
p_errmsg VARCHAR2(500); -- 错误记录
BEGIN
-- 操作记录
NETS_TCIMS_COMM.SP_LOG_RECORDER(p_id,75,NULL,'01',NULL,NULL,NULL,NULL);
--清空结果临时表
NETS_TCIMS_COMM.SP_TRUNCATE('TCIMSLOGTMP','PC_ENTER_RESULT_STG_6_TMP');
INSERT /*+APPEND*/
INTO PC_ENTER_RESULT_STG_6_TMP
(
SYS_ID,
FIRST_REGISTER_DATE,
POLICY_END_DATE,
POLICY_EFFECTIVE_DATE,
MAIN_DRIVER_DOB,
DRIVER_LICENSE_FST_ISSUE_DATE
)
SELECT /*+PARALLEL(A 2) PARALLEL(B 2) PARALLEL(C 2) PARALLEL(D 2) PARALLEL(E 2) PARALLEL(F 2)*/
A.SYS_ID,
TO_DATE(B.FIRST_REGISTER_DATE,'YYYY-MM-DD') FIRST_REGISTER_DATE,
TO_DATE(C.POLICY_END_DATE,'YYYY-MM-DD') POLICY_END_DATE,
TO_DATE(D.POLICY_EFFECTIVE_DATE,'YYYY-MM-DD') POLICY_EFFECTIVE_DATE,
TO_DATE(E.MAIN_DRIVER_DOB,'YYYY-MM-DD') MAIN_DRIVER_DOB,
TO_DATE(F.DRIVER_LICENSE_FST_ISSUE_DATE,'YYYY-MM-DD') DRIVER_LICENSE_FST_ISSUE_DATE
FROM PC_ENTER_RESULT_STG_0_TMP A,
(SELECT SYS_ID,FIRST_REGISTER_DATE,POLICY_END_DATE
FROM PC_CLEAN_FST_REG_DATE_STG_TMP
WHERE CLEAN_STATUS = '1') B,
(SELECT SYS_ID,POLICY_END_DATE
FROM PC_CLEAN_POLI_END_DATE_STG_TMP
WHERE CLEAN_STATUS = '1') C,
(SELECT SYS_ID,POLICY_EFFECTIVE_DATE
FROM PC_CLEAN_POLI_EFC_DATE_STG_TMP
WHERE CLEAN_STATUS = '1') D,
(SELECT SYS_ID,MAIN_DRIVER_DOB
FROM PC_CLEAN_MAIN_DRIV_DOB_STG_TMP
WHERE CLEAN_STATUS = '1') E,
(SELECT SYS_ID,DRIVER_LICENSE_FST_ISSUE_DATE
FROM PC_CLEAN_LIC_ISUE_DATE_STG_TMP
WHERE CLEAN_STATUS = '1') F
WHERE A.SYS_ID = B.SYS_ID(+)
AND A.SYS_ID = C.SYS_ID(+)
AND A.SYS_ID = D.SYS_ID(+)
AND A.SYS_ID = E.SYS_ID(+)
AND A.SYS_ID = F.SYS_ID(+);
COMMIT;
-- 更新本次操作日志
NETS_TCIMS_COMM.SP_LOG_RECORDER(P_ID,75,NULL,'02',NULL,NULL,NULL,NULL);
EXCEPTION
WHEN OTHERS THEN
P_ERRMSG := SUBSTR(SQLERRM,1,500);
NETS_TCIMS_COMM.SP_LOG_RECORDER(P_ID,75,NULL,'03',P_ERRMSG,NULL,NULL,NULL);
RAISE;
END SP_UNITE_PC_ENTER_RESULT_6;
/***********************************************************
--功能说明:
--参数说明:
--调用函数:
--修改记录： EX-LIUJIALI001
--注意事项： 顺序在 SP_UNITE_PC_ENTER_RESULT_0 功能完成之后
--*********************************************************/
PROCEDURE SP_UNITE_PC_ENTER_RESULT_7
IS
p_id NUMBER; -- 日志记录id
p_errmsg VARCHAR2(500); -- 错误记录
BEGIN
-- 操作记录
NETS_TCIMS_COMM.SP_LOG_RECORDER(p_id,76,NULL,'01',NULL,NULL,NULL,NULL);
--清空结果临时表
NETS_TCIMS_COMM.SP_TRUNCATE('TCIMSLOGTMP','PC_ENTER_RESULT_STG_7_TMP');
INSERT /*+APPEND*/
INTO PC_ENTER_RESULT_STG_7_TMP --- 后续更新需要 判断更新
(
SYS_ID,
CITY,
SECONDARY_ORG,
THIRD_ORG,
LIST_TYPE,
C01_PHONE_RESULT,
C01_SALE_STAGE,
C01_SALE_DECISION,
C01_ADDED_EXPLAIN,
C51_PHONE_RESULT,
C51_SALE_STAGE,
C51_SALE_DECISION,
C51_ADDED_EXPLAIN,
C01_SALE_RESULT_CLASS,
C51_SALE_RESULT_CLASS,
SALE_RESULT_CLASS,
CUST_CLASS
)
SELECT /*+PARALLEL(A 2) PARALLEL(C 2) PARALLEL(D 2)*/
A.SYS_ID,
A.CITY,
A.SECONDARY_ORG,
A.THIRD_ORG,
A.LIST_TYPE,
C.C01_PHONE_RESULT,
C.C01_SALE_STAGE,
C.C01_SALE_DECISION,
C.C01_ADDED_EXPLAIN,
C.C51_PHONE_RESULT,
C.C51_SALE_STAGE,
C.C51_SALE_DECISION,
C.C51_ADDED_EXPLAIN,
C.C01_SALE_RESULT_CLASS,
C.C51_SALE_RESULT_CLASS,
C.SALE_RESULT_CLASS,
D.CUST_CLASS
FROM PC_ENTER_RESULT_STG_0_TMP A,
--PC_CLEAN_SH_YDC_FLAG_STG_TMP B, (PC_ENTER_RESULT_STG_0_TMP 中已经包含了）
(SELECT SYS_ID,C51_PHONE_RESULT,C51_SALE_STAGE,C51_SALE_DECISION,C51_ADDED_EXPLAIN,
C01_PHONE_RESULT,C01_SALE_STAGE,C01_SALE_DECISION,C01_ADDED_EXPLAIN,
C51_SALE_RESULT_CLASS,C01_SALE_RESULT_CLASS,SALE_RESULT_CLASS
FROM PC_CLEAN_SALE_RESULT_STG_TMP
WHERE CLEAN_STATUS = '1') C,
PC_CLEAN_CUST_CLASS_STG_TMP D
WHERE --A.SYS_ID = B.SYS_ID(+) AND
A.SYS_ID = C.SYS_ID(+)
AND A.SYS_ID = D.SYS_ID(+);
COMMIT;
-- 更新本次操作日志
NETS_TCIMS_COMM.SP_LOG_RECORDER(P_ID,76,NULL,'02',NULL,NULL,NULL,NULL);
EXCEPTION
WHEN OTHERS THEN
P_ERRMSG := SUBSTR(SQLERRM,1,500);
NETS_TCIMS_COMM.SP_LOG_RECORDER(P_ID,76,NULL,'03',P_ERRMSG,NULL,NULL,NULL);
RAISE;
END SP_UNITE_PC_ENTER_RESULT_7;
/***********************************************************
--功能说明:
--参数说明:
--调用函数:
--修改记录： EX-LIUJIALI001
--注意事项： 顺序在 SP_UNITE_PC_ENTER_RESULT_0 功能完成之后
--*********************************************************/
PROCEDURE SP_UNITE_PC_ENTER_RESULT_8
IS
p_id NUMBER; -- 日志记录id
p_errmsg VARCHAR2(500); -- 错误记录
BEGIN
-- 操作记录
NETS_TCIMS_COMM.SP_LOG_RECORDER(p_id,77,NULL,'01',NULL,NULL,NULL,NULL);
--清空结果临时表
NETS_TCIMS_COMM.SP_TRUNCATE('TCIMSLOGTMP','PC_ENTER_RESULT_STG_8_TMP');
INSERT /*+APPEND*/
INTO PC_ENTER_RESULT_STG_8_TMP --- 后续更新需要 判断更新
(
SYS_ID,
AUTOMODEL_NAME,
PURCHASE_PRICE,
FACTORY_LOGO,
VEHICLE_SERIES,
VEHICLE_CLASS_CODE,
CRM_AREA_FLAG,
CUST_NAME,
ORG_FLAG
)
SELECT /*+PARALLEL(A 2) PARALLEL(B 2) PARALLEL(C 2) PARALLEL(D 2)*/
A.SYS_ID,
B.AUTOMODEL_NAME,
B.PURCHASE_PRICE,
B.FACTORY_LOGO,
B.VEHICLE_SERIES,
B.VEHICLE_CLASS_CODE,
C.CRM_AREA_FLAG,
D.CUST_NAME,
D.ORG_FLAG
FROM PC_ENTER_RESULT_STG_0_TMP A,
(SELECT SYS_ID,AUTOMODEL_NAME,PURCHASE_PRICE,FACTORY_LOGO,
VEHICLE_SERIES,VEHICLE_CLASS_CODE,IS_PRICE_VALID
FROM PC_CLEAN_CAR_NAME_PRIC_STG_TMP
WHERE CLEAN_STATUS = '1') B,
PC_CLEAN_CRM_AREA_FLAG_STG_TMP C,
(SELECT SYS_ID,CUST_NAME,ORG_FLAG
FROM PC_CLEAN_CUST_NAME_STG_TMP
WHERE CLEAN_STATUS = '1') D
WHERE A.SYS_ID = B.SYS_ID(+)
AND A.SYS_ID = C.SYS_ID(+)
AND A.SYS_ID = D.SYS_ID(+);
COMMIT;
-- 更新本次操作日志
NETS_TCIMS_COMM.SP_LOG_RECORDER(P_ID,77,NULL,'02',NULL,NULL,NULL,NULL);
EXCEPTION
WHEN OTHERS THEN
P_ERRMSG := SUBSTR(SQLERRM,1,500);
NETS_TCIMS_COMM.SP_LOG_RECORDER(P_ID,77,NULL,'03',P_ERRMSG,NULL,NULL,NULL);
RAISE;
END SP_UNITE_PC_ENTER_RESULT_8;
/***********************************************************
--功能说明:
--参数说明:
--调用函数:
--修改记录： EX-LIUJIALI001
--注意事项： 顺序在 SP_UNITE_PC_ENTER_RESULT_1 ,,8 功能完成之后
--*********************************************************/
PROCEDURE SP_UNITE_PC_ENTER_RESULT_9
IS
p_id NUMBER; -- 日志记录id
p_errmsg VARCHAR2(500); -- 错误记录
BEGIN
-- 操作记录
NETS_TCIMS_COMM.SP_LOG_RECORDER(p_id,78,NULL,'01',NULL,NULL,NULL,NULL);
--清空结果临时表
NETS_TCIMS_COMM.SP_TRUNCATE('TCIMSLOGTMP','PC_ENTER_RESULT_STG_9_TMP');
INSERT /*+APPEND*/
INTO PC_ENTER_RESULT_STG_9_TMP --- 后续更新需要 判断更新
(
SYS_ID,
VEHICLE_NO,
VEHICLE_NO_INTEGRITY,
TEL_NO,
BRAND_TYPE_CODE,
USAGE_CODE,
ENGINE_NUMBER,
VEHICLE_FRAME,
VEHICLE_TYPE_CODE,
SALUTATION,
ADDRESS,
IS_ADDRESS_VALID,
MAIN_DRIVER_SEX,
TON_NUMBER,
SEAT_NUMBER,
VEHICLE_VALUE,
EXHAUST,
VEHICLE_BODY_COLOR
)
SELECT /*+PARALLEL(A 2) PARALLEL(B 2) PARALLEL(C 2) PARALLEL(D 2) PARALLEL(E 2)*/
A.SYS_ID,
B.VEHICLE_NO,
B.VEHICLE_NO_INTEGRITY,
B.TEL_NO,
B.BRAND_TYPE_CODE,
C.USAGE_CODE,
C.ENGINE_NUMBER,
C.VEHICLE_FRAME,
D.VEHICLE_TYPE_CODE,
D.SALUTATION,
D.ADDRESS,
D.IS_ADDRESS_VALID,
E.MAIN_DRIVER_SEX,
E.TON_NUMBER,
E.SEAT_NUMBER,
E.VEHICLE_VALUE,
E.EXHAUST,
E.VEHICLE_BODY_COLOR
FROM PC_ENTER_RESULT_STG_0_TMP A,
PC_ENTER_RESULT_STG_1_TMP B,
PC_ENTER_RESULT_STG_2_TMP C,
PC_ENTER_RESULT_STG_3_TMP D,
PC_ENTER_RESULT_STG_4_TMP E
WHERE A.SYS_ID = B.SYS_ID
AND A.SYS_ID = C.SYS_ID
AND A.SYS_ID = D.SYS_ID
AND A.SYS_ID = E.SYS_ID;
COMMIT;
-- 更新本次操作日志
NETS_TCIMS_COMM.SP_LOG_RECORDER(P_ID,78,NULL,'02',NULL,NULL,NULL,NULL);
EXCEPTION
WHEN OTHERS THEN
P_ERRMSG := SUBSTR(SQLERRM,1,500);
NETS_TCIMS_COMM.SP_LOG_RECORDER(P_ID,78,NULL,'03',P_ERRMSG,NULL,NULL,NULL);
RAISE;
END SP_UNITE_PC_ENTER_RESULT_9;
/***********************************************************
--功能说明:
--参数说明:
--调用函数:
--修改记录： EX-LIUJIALI001
--注意事项： 顺序在 SP_UNITE_PC_ENTER_RESULT_1 ,,8 功能完成之后
--*********************************************************/
PROCEDURE SP_UNITE_PC_ENTER_RESULT_10
IS
p_id NUMBER; -- 日志记录id
p_errmsg VARCHAR2(500); -- 错误记录
BEGIN
-- 操作记录
NETS_TCIMS_COMM.SP_LOG_RECORDER(p_id,79,NULL,'01',NULL,NULL,NULL,NULL);
--清空结果临时表
NETS_TCIMS_COMM.SP_TRUNCATE('TCIMSLOGTMP','PC_ENTER_RESULT_STG_10_TMP');
INSERT /*+APPEND*/
INTO PC_ENTER_RESULT_STG_10_TMP --- 后续更新需要 判断更新
(
SYS_ID,
ID_NUMBER,
SEX,
CUST_DOB,
FIRST_REGISTER_DATE,
POLICY_END_DATE,
POLICY_EFFECTIVE_DATE,
MAIN_DRIVER_DOB,
DRIVER_LICENSE_FST_ISSUE_DATE,
CITY,
SECONDARY_ORG,
THIRD_ORG,
LIST_TYPE,
C01_PHONE_RESULT,
C01_SALE_STAGE,
C01_SALE_DECISION,
C01_ADDED_EXPLAIN,
C51_PHONE_RESULT,
C51_SALE_STAGE,
C51_SALE_DECISION,
C51_ADDED_EXPLAIN,
C01_SALE_RESULT_CLASS,
C51_SALE_RESULT_CLASS,
SALE_RESULT_CLASS,
CUST_CLASS,
AUTOMODEL_NAME,
PURCHASE_PRICE,
FACTORY_LOGO,
VEHICLE_SERIES,
VEHICLE_CLASS_CODE,
CRM_AREA_FLAG,
CUST_NAME,
ORG_FLAG
)
SELECT /*+PARALLEL(A 2) PARALLEL(B 2) PARALLEL(C 2) PARALLEL(D 2) PARALLEL(E 2)*/
A.SYS_ID,
B.ID_NUMBER,
B.SEX,
B.CUST_DOB,
C.FIRST_REGISTER_DATE,
C.POLICY_END_DATE,
C.POLICY_EFFECTIVE_DATE,
C.MAIN_DRIVER_DOB,
C.DRIVER_LICENSE_FST_ISSUE_DATE,
D.CITY,
D.SECONDARY_ORG,
D.THIRD_ORG,
D.LIST_TYPE,
D.C01_PHONE_RESULT,
D.C01_SALE_STAGE,
D.C01_SALE_DECISION,
D.C01_ADDED_EXPLAIN,
D.C51_PHONE_RESULT,
D.C51_SALE_STAGE,
D.C51_SALE_DECISION,
D.C51_ADDED_EXPLAIN,
D.C01_SALE_RESULT_CLASS,
D.C51_SALE_RESULT_CLASS,
D.SALE_RESULT_CLASS,
D.CUST_CLASS,
E.AUTOMODEL_NAME,
E.PURCHASE_PRICE,
E.FACTORY_LOGO,
E.VEHICLE_SERIES,
E.VEHICLE_CLASS_CODE,
E.CRM_AREA_FLAG,
E.CUST_NAME,
E.ORG_FLAG
FROM PC_ENTER_RESULT_STG_0_TMP A,
PC_ENTER_RESULT_STG_5_TMP B,
PC_ENTER_RESULT_STG_6_TMP C,
PC_ENTER_RESULT_STG_7_TMP D,
PC_ENTER_RESULT_STG_8_TMP E
WHERE A.SYS_ID = B.SYS_ID
AND A.SYS_ID = C.SYS_ID
AND A.SYS_ID = D.SYS_ID
AND A.SYS_ID = E.SYS_ID;
COMMIT;
-- 更新本次操作日志
NETS_TCIMS_COMM.SP_LOG_RECORDER(P_ID,79,NULL,'02',NULL,NULL,NULL,NULL);
EXCEPTION
WHEN OTHERS THEN
P_ERRMSG := SUBSTR(SQLERRM,1,500);
NETS_TCIMS_COMM.SP_LOG_RECORDER(P_ID,79,NULL,'03',P_ERRMSG,NULL,NULL,NULL);
RAISE;
END SP_UNITE_PC_ENTER_RESULT_10;
/***********************************************************
--功能说明: 清洗、屏蔽结束后的整合，供库存比对使用(产险)
--参数说明:
--调用函数:
--修改记录： EX-LIUJIALI001
--注意事项： 顺序在 所有清洗、屏蔽 功能完成之后
--*********************************************************/
PROCEDURE SP_UNITE_PC_ENTER_RESULT
IS
P_ID NUMBER; -- 日志记录ID
P_ERRMSG VARCHAR2(500); -- 错误记录
BEGIN
-- 操作记录
NETS_TCIMS_COMM.SP_LOG_RECORDER(P_ID,83,NULL,'01',NULL,NULL,NULL,NULL);
--清空结果临时表
NETS_TCIMS_COMM.SP_TRUNCATE('TCIMSLOGTMP','PC_STG_DATA_TMP');
--清洗合并 与比对结果合并 PC_COMPARE_REPEAT_STG_TMP PC_STG_DATA_TMP
INSERT /*+APPEND*/
INTO PC_STG_DATA_TMP
(
SYS_ID,
TCIMS_BATCH_ID,
TCIMS_CUST_ID,
TCIMS_VT_ID,
CITY,
SECONDARY_ORG,
THIRD_ORG,
AREA_INFO,
SRC_TYPE,
LIST_TYPE,
PROVINCE,
CUST_CLASS,
CUST_TYPE,
APPLICANT_PARTY_NO,
CIF2_ID,
CIF2_ID_TYPE,
CUST_NAME,
SEX,
SALUTATION,
MARITAL_STATUS,
CUST_DOB,
POSITION,
ID_TYPE,
ID_NUMBER,
CONTACT_NAME,
TELEPHONE_NUMBER,
FAX_AREA_CODE,
FAX_NUM,
APPLICANT_EMAIL,
ZIP_CODE,
ADDRESS,
REMARK,
DRIVER_LICENSE_NO,
DRIVER_LICENSE_FST_ISSUE_DATE,
DRIVE_VEHICLE_TYPE_CODE,
VEHICLE_NO,
BRAND_TYPE,
BRAND_TYPE_CODE,
USAGE_ATTRIBUTE,
USAGE_CODE,
ATTRIBUTE_CODE,
VEHICLE_TYPE,
VEHICLE_TYPE_CODE,
VEHICLE_CLASS_CODE,
VEHICLE_BODY_COLOR,
AUTOMODEL_NAME,
VEHICLE_MODEL_NAME_CN,
VEHICLE_MODEL_NO,
FACTORY_LOGO,
VEHICLE_SERIES,
PURCHASE_PRICE,
BRAND_TYPE_FIRST_SALE_DATE,
SEAT_NUMBER,
TON_NUMBER,
FULL_CAPACITY,
EXHAUST,
FOREIGN_VEHICLE_NO,
ENGINE_NUMBER,
VEHICLE_FRAME,
DEV_CODE,
REFIX_DESC,
VEHICLE_VALUE,
VEHICLE_REMARK,
VEHICLE_GENERAL_TYPE_CODE,
VEHICLE_SPECIFIC_TYPE_CODE,
MANUFACTURE_COUNTRY,
VT_FACTORY,
VEHICLE_STATUS,
USED_YEARS,
FIRST_REGISTER_DATE,
LEAVE_FACTORY_DATE,
BUY_VEHICLE_DATE,
VEHICLE_RANK_CODE,
VEHICLE_OWNER,
LICENSE_ISSUE_DATE,
MAIN_DRIVER_NO,
MAIN_DRIVER_DOB,
MAIN_DRIVER_SEX,
MAIN_DRIVER_NAME,
DRIVE_AREA_CODE,
INSURED_PERSON_NAME,
INSURED_PERSON_ADDRESS,
C01_POLICY_NO,
C01_DEPARTMENT_CODE,
C01_DEPARTMENT_CHINESE_NAME,
C01_LAST_POLICY_NO,
C01_LAST_YEAR_APPLY_COMPANY,
C01_VALUE_CHINESE_NAME,
C01_SALE_AGENT_CODE,
C01_EMPLOYEE_NAME,
C01_BUSINESS_SRC_CODE,
C01_BUSINESS_SRC_NAME,
C01_BUSINESS_SRC_DETAIL_CODE,
C01_BUSINESS_SRC_DETAIL_NAME,
C01_CHANNEL_SRC_CODE,
C01_CHANNEL_SRC_NAME,
C01_CHANNEL_SRC_DETAIL_CODE,
C01_CHANNEL_SRC_DETAIL_NAME,
C01_INSURANCE_BEGIN_TIME,
C01_INSURANCE_END_TIME,
C01_TOTAL_ACTUAL_PREMIUM,
C01_PREMIUM_INFO,
C01_APPLY_TIME,
C01_UNDERWRITE_TIME,
C01_INPUT_BY_ID,
C01_INPUT_BY,
C51_POLICY_NO,
C51_DEPARTMENT_CODE,
C51_DEPARTMENT_CHINESE_NAME,
C51_LAST_POLICY_NO,
C51_LAST_YEAR_APPLY_COMPANY,
C51_VALUE_CHINESE_NAME,
C51_SALE_AGENT_CODE,
C51_EMPLOYEE_NAME,
C51_BUSINESS_SRC_CODE,
C51_BUSINESS_SRC_NAME,
C51_BUSINESS_SRC_DETAIL_CODE,
C51_BUSINESS_SRC_DETAIL_NAME,
C51_CHANNEL_SRC_CODE,
C51_CHANNEL_SRC_NAME,
C51_CHANNEL_SRC_DETAIL_CODE,
C51_CHANNEL_SRC_DETAIL_NAME,
C51_INSURANCE_BEGIN_TIME,
C51_INSURANCE_END_TIME,
C51_TOTAL_ACTUAL_PREMIUM,
C51_PREMIUM_INFO,
C51_APPLY_TIME,
C51_UNDERWRITE_TIME,
C51_INPUT_BY_ID,
C51_INPUT_BY,
VIOLATION_RATIO,
CLAIM_RATIO,
VIOLATION_PREMIUM_CHANGE,
INSURANCE_TYPE_FLAG,
POLICY_EFFECTIVE_DATE,
POLICY_END_DATE,
PA_APPLY_HISTORY,
PA_LIFE_CLIENT,
BIZ_MODEL,
SUB_BIZMODEL,
EXPIRED_DATE,
CAMPAIGN_ID,
CAMPAIGN_NAME,
GROUP_ID,
CAMPAIGN_SPLIT_NAME,
BATCH_NAME,
TASK_GROUP_ID,
TASK_ID,
IS_CONTACTED,
C51_PHONE_RESULT,
C51_SALE_STAGE,
C51_SALE_DECISION,
C51_ADDED_EXPLAIN,
C01_PHONE_RESULT,
C01_SALE_STAGE,
C01_SALE_DECISION,
C01_ADDED_EXPLAIN,
C01_SALE_RESULT_CLASS,
C51_SALE_RESULT_CLASS,
SALE_RESULT_CLASS,
IS_AGENCY_PHONE,
IS_ADDRESS_VALID,
SHIELD_FLAG,
RISK_TIMES,
LIST_PRIORITY,
VEHICLE_NO_INTEGRITY,
ENGINE_NUMBER_SUBL6,
VEHICLE_FRAME_SUB17,
LIST_TYPE_CODE,
SRC_TYPE_CODE,
CITY_CODE
)
SELECT /*+PARALLEL(A 2) PARALLEL(B 2) PARALLEL(C 2) PARALLEL(D 2) PARALLEL(E 2) PARALLEL(F 2)*/
A.SYS_ID,
A.TCIMS_BATCH_ID,
A.TCIMS_CUST_ID,
A.TCIMS_VT_ID,
C.CITY,
C.SECONDARY_ORG,
C.THIRD_ORG,
C.CRM_AREA_FLAG AREA_INFO,
A.SRC_TYPE,
C.LIST_TYPE,
A.PROVINCE,
C.CUST_CLASS,
C.ORG_FLAG CUST_TYPE,
A.APPLICANT_PARTY_NO,
A.CIF2_ID,
A.CIF2_ID_TYPE,
C.CUST_NAME,
C.SEX,
B.SALUTATION,
A.MARITAL_STATUS,
C.CUST_DOB,
A.POSITION,
A.ID_TYPE,
C.ID_NUMBER,
A.CONTACT_NAME,
B.TEL_NO TELEPHONE_NUMBER,
A.FAX_AREA_CODE,
A.FAX_NUM,
A.APPLICANT_EMAIL,
A.ZIP_CODE,
B.ADDRESS,
A.REMARK,
A.DRIVER_LICENSE_NO,
C.DRIVER_LICENSE_FST_ISSUE_DATE,
A.DRIVE_VEHICLE_TYPE_CODE,
B.VEHICLE_NO,
A.BRAND_TYPE,
B.BRAND_TYPE_CODE,
A.USAGE_ATTRIBUTE,
B.USAGE_CODE,
A.ATTRIBUTE_CODE,
A.VEHICLE_TYPE,
B.VEHICLE_TYPE_CODE,
C.VEHICLE_CLASS_CODE,
B.VEHICLE_BODY_COLOR,
C.AUTOMODEL_NAME,
A.VEHICLE_MODEL_NAME_CN,
A.VEHICLE_MODEL_NO,
C.FACTORY_LOGO,
C.VEHICLE_SERIES,
C.PURCHASE_PRICE,
A.BRAND_TYPE_FIRST_SALE_DATE,
B.SEAT_NUMBER,
B.TON_NUMBER,
A.FULL_CAPACITY,
B.EXHAUST,
FOREIGN_VEHICLE_NO,
B.ENGINE_NUMBER,
B.VEHICLE_FRAME,
A.DEV_CODE,
A.REFIX_DESC,
B.VEHICLE_VALUE,
A.VEHICLE_REMARK,
A.VEHICLE_GENERAL_TYPE_CODE,
A.VEHICLE_SPECIFIC_TYPE_CODE,
A.MANUFACTURE_COUNTRY,
A.VT_FACTORY,
A.VEHICLE_STATUS,
A.USED_YEARS,
C.FIRST_REGISTER_DATE,
A.LEAVE_FACTORY_DATE,
A.BUY_VEHICLE_DATE,
A.VEHICLE_RANK_CODE,
A.VEHICLE_OWNER,
A.LICENSE_ISSUE_DATE,
A.MAIN_DRIVER_NO,
C.MAIN_DRIVER_DOB,
B.MAIN_DRIVER_SEX,
A.MAIN_DRIVER_NAME,
A.DRIVE_AREA_CODE,
A.INSURED_PERSON_NAME,
A.INSURED_PERSON_ADDRESS,
A.C01_POLICY_NO,
A.C01_DEPARTMENT_CODE,
A.C01_DEPARTMENT_CHINESE_NAME,
A.C01_LAST_POLICY_NO,
A.C01_LAST_YEAR_APPLY_COMPANY,
A.C01_VALUE_CHINESE_NAME,
A.C01_SALE_AGENT_CODE,
A.C01_EMPLOYEE_NAME,
A.C01_BUSINESS_SRC_CODE,
A.C01_BUSINESS_SRC_NAME,
A.C01_BUSINESS_SRC_DETAIL_CODE,
A.C01_BUSINESS_SRC_DETAIL_NAME,
A.C01_CHANNEL_SRC_CODE,
A.C01_CHANNEL_SRC_NAME,
A.C01_CHANNEL_SRC_DETAIL_CODE,
A.C01_CHANNEL_SRC_DETAIL_NAME,
A.C01_INSURANCE_BEGIN_TIME,
A.C01_INSURANCE_END_TIME,
A.C01_TOTAL_ACTUAL_PREMIUM,
A.C01_PREMIUM_INFO,
A.C01_APPLY_TIME,
A.C01_UNDERWRITE_TIME,
A.C01_INPUT_BY_ID,
A.C01_INPUT_BY,
A.C51_POLICY_NO,
A.C51_DEPARTMENT_CODE,
A.C51_DEPARTMENT_CHINESE_NAME,
A.C51_LAST_POLICY_NO,
A.C51_LAST_YEAR_APPLY_COMPANY,
A.C51_VALUE_CHINESE_NAME,
A.C51_SALE_AGENT_CODE,
A.C51_EMPLOYEE_NAME,
A.C51_BUSINESS_SRC_CODE,
A.C51_BUSINESS_SRC_NAME,
A.C51_BUSINESS_SRC_DETAIL_CODE,
A.C51_BUSINESS_SRC_DETAIL_NAME,
A.C51_CHANNEL_SRC_CODE,
A.C51_CHANNEL_SRC_NAME,
A.C51_CHANNEL_SRC_DETAIL_CODE,
A.C51_CHANNEL_SRC_DETAIL_NAME,
A.C51_INSURANCE_BEGIN_TIME,
A.C51_INSURANCE_END_TIME,
A.C51_TOTAL_ACTUAL_PREMIUM,
A.C51_PREMIUM_INFO,
A.C51_APPLY_TIME,
A.C51_UNDERWRITE_TIME,
A.C51_INPUT_BY_ID,
A.C51_INPUT_BY,
A.VIOLATION_RATIO,
A.CLAIM_RATIO,
A.VIOLATION_PREMIUM_CHANGE,
A.INSURANCE_TYPE_FLAG,
C.POLICY_EFFECTIVE_DATE,
C.POLICY_END_DATE,
A.PA_APPLY_HISTORY,
A.PA_LIFE_CLIENT,
A.BIZ_MODEL,
A.SUB_BIZMODEL,
A.EXPIRED_DATE,
A.CAMPAIGN_ID,
A.CAMPAIGN_NAME,
A.GROUP_ID,
A.CAMPAIGN_SPLIT_NAME,
A.BATCH_NAME,
A.TASK_GROUP_ID,
A.TASK_ID,
A.IS_CONTACTED,
C.C51_PHONE_RESULT,
C.C51_SALE_STAGE,
C.C51_SALE_DECISION,
C.C51_ADDED_EXPLAIN,
C.C01_PHONE_RESULT,
C.C01_SALE_STAGE,
C.C01_SALE_DECISION,
C.C01_ADDED_EXPLAIN,
C.C01_SALE_RESULT_CLASS,
C.C51_SALE_RESULT_CLASS,
C.SALE_RESULT_CLASS,
A.IS_AGENCY_PHONE,
B.IS_ADDRESS_VALID,
D.SHIELD_FLAG,
A.RISK_TIMES,
E.SRC_CREDIBILITY ,
B.VEHICLE_NO_INTEGRITY,
CASE
WHEN LENGTH(B.ENGINE_NUMBER) >= 6 THEN
SUBSTR(B.ENGINE_NUMBER,-6)
ELSE
NULL
END ENGINE_NUMBER_SUBL6,
CASE
WHEN LENGTH(B.VEHICLE_FRAME) = 17 THEN
B.VEHICLE_FRAME
ELSE
NULL
END VEHICLE_FRAME_SUB17,
C.LIST_TYPE,
A.SRC_TYPE,
C.CITY
FROM IDL_SEP_SRC_DATA A,
PC_ENTER_RESULT_STG_9_TMP B,
PC_ENTER_RESULT_STG_10_TMP C,
PC_IN_SHIELD_UNITE_STG_TMP D, -- 可能存在重复记录
(select t.src_type_code,t.src_credibility from bdl_com_src_type t
where t.data_type='PC') E,
IDL_EX_BATCH F
WHERE A.SYS_ID = B.SYS_ID
AND A.SYS_ID = C.SYS_ID
AND A.SYS_ID = D.SYS_ID(+)
AND A.SRC_TYPE = E.SRC_TYPE_CODE(+)
AND A.TCIMS_BATCH_ID = F.TCIMS_BATCH_ID
AND F.SERIES_TYPE = '01'
AND F.BATCH_STATUS = '14'
AND F.PREPARE_FLAG = '1';
COMMIT;
-- 更新批次状态，及数据信息
UPDATE /*+PARALLE(A 4)*/
IDL_EX_BATCH A
SET A.BATCH_STATUS = '13',
A.UPDATED_DATE = SYSDATE,
A.UPDATED_BY = 'SYSTEM'
WHERE A.BATCH_STATUS = '14'
AND A.SERIES_TYPE = '01'
AND A.PREPARE_FLAG = '1';
COMMIT;
-- 更新本次操作日志
NETS_TCIMS_COMM.SP_LOG_RECORDER(P_ID,83,NULL,'02',NULL,NULL,NULL,NULL);
EXCEPTION
WHEN OTHERS THEN
P_ERRMSG := SUBSTR(SQLERRM,1,500);
NETS_TCIMS_COMM.SP_LOG_RECORDER(P_ID,83,NULL,'03',P_ERRMSG,NULL,NULL,NULL);
RAISE;
END SP_UNITE_PC_ENTER_RESULT;
/***********************************************************
--功能说明: 寿险合并
--参数说明:
--调用函数:
--修改记录： EX-LIUJIALI001
--注意事项： 顺序在 所有清洗、功能完成之后 屏蔽 操作之前
--*********************************************************/
PROCEDURE SP_UNITE_LA_ENTER_RESULT_0
IS
p_id NUMBER; -- 日志记录id
p_errmsg VARCHAR2(500); -- 错误记录
BEGIN
-- 操作记录
NETS_TCIMS_COMM.SP_LOG_RECORDER(p_id,55,NULL,'01',NULL,NULL,NULL,NULL);
--清空结果临时表
NETS_TCIMS_COMM.SP_TRUNCATE('TCIMSLOGTMP','LA_ENTER_RESULT_STG_0_TMP');
INSERT /*+APPEND*/
INTO LA_ENTER_RESULT_STG_0_TMP
(
SYS_ID,
DEPARTMENT_CHINESE_NAME,
CONTACT_ADDRESS
)
SELECT /*+PARALLEL(A 2) PARALLEL(B 2)*/
A.SYS_ID,
A.DEPARTMENT_CHINESE_NAME,
A.CONTACT_ADDRESS
FROM IDL_SEL_SRC_DATA A,
IDL_EX_BATCH B
WHERE NOT EXISTS(SELECT 1 FROM LA_CLEAN_CITY_STG_TMP C
WHERE A.SYS_ID = C.SYS_ID)
AND NOT EXISTS(SELECT 1 FROM LA_COMPARE_REPEAT_STG_TMP D
WHERE A.SYS_ID = D.SYS_ID)
AND A.TCIMS_BATCH_ID = B.TCIMS_BATCH_ID
AND B.SERIES_TYPE = '02'
AND B.BATCH_STATUS = '14'
AND B.PREPARE_FLAG = '1';
COMMIT;
-- 更新本次操作日志
NETS_TCIMS_COMM.SP_LOG_RECORDER(p_id,55,NULL,'02',NULL,NULL,NULL,NULL);
EXCEPTION
WHEN OTHERS THEN
p_errmsg := substr(sqlerrm,1,500);
NETS_TCIMS_COMM.SP_LOG_RECORDER(p_id,55,NULL,'03',p_errmsg,NULL,NULL,NULL);
RAISE;
END SP_UNITE_LA_ENTER_RESULT_0;
/***********************************************************
--功能说明: 寿险合并
--参数说明:
--调用函数:
--修改记录： EX-LIUJIALI001
--注意事项： 顺序在 所有清洗、功能完成之后 屏蔽 操作之前
--*********************************************************/
PROCEDURE SP_UNITE_LA_ENTER_RESULT_1
IS
p_id NUMBER; -- 日志记录id
p_errmsg VARCHAR2(500); -- 错误记录
BEGIN
-- 操作记录
NETS_TCIMS_COMM.SP_LOG_RECORDER(p_id,80,NULL,'01',NULL,NULL,NULL,NULL);
--清空结果临时表
NETS_TCIMS_COMM.SP_TRUNCATE('TCIMSLOGTMP','LA_ENTER_RESULT_STG_1_TMP');
INSERT /*+APPEND*/
INTO LA_ENTER_RESULT_STG_1_TMP
(
SYS_ID,
TEL_NO,
ID_NUMBER,
ID_NUMBER_UPGRADE,
CUST_NAME
)
SELECT /*+PARALLEL(A 2) PARALLEL(B 2) PARALLEL(C 2) PARALLEL(D 2)*/
A.SYS_ID,
B.TEL_NO ,
C.ID_NUMBER ,
C.ID_NUMBER_UPGRADE ,
D.CUST_NAME
FROM LA_ENTER_RESULT_STG_0_TMP A,
(SELECT SYS_ID ,TEL_NO, CITY, CLEAN_STATUS
FROM LA_CLEAN_TELEPHONE_STG_TMP
WHERE CLEAN_STATUS = '1') B,
LA_CLEAN_ID_NUMBER_STG_TMP C,
LA_CLEAN_CUST_NAME_STG_TMP D
WHERE A.SYS_ID = B.SYS_ID
AND A.SYS_ID = C.SYS_ID(+)
AND A.SYS_ID = D.SYS_ID(+);
COMMIT;
-- 更新本次操作日志
NETS_TCIMS_COMM.SP_LOG_RECORDER(P_ID,80,NULL,'02',NULL,NULL,NULL,NULL);
EXCEPTION
WHEN OTHERS THEN
P_ERRMSG := SUBSTR(SQLERRM,1,500);
NETS_TCIMS_COMM.SP_LOG_RECORDER(P_ID,80,NULL,'03',P_ERRMSG,NULL,NULL,NULL);
RAISE;
END SP_UNITE_LA_ENTER_RESULT_1;
/***********************************************************
--功能说明: 寿险合并
--参数说明:
--调用函数:
--修改记录： EX-LIUJIALI001
--注意事项： 顺序在 所有清洗、功能完成之后 屏蔽 操作之前
--*********************************************************/
PROCEDURE SP_UNITE_LA_ENTER_RESULT_2
IS
p_id NUMBER; -- 日志记录id
p_errmsg VARCHAR2(500); -- 错误记录
BEGIN
-- 操作记录
NETS_TCIMS_COMM.SP_LOG_RECORDER(p_id,81,NULL,'01',NULL,NULL,NULL,NULL);
--清空结果临时表
NETS_TCIMS_COMM.SP_TRUNCATE('TCIMSLOGTMP','LA_ENTER_RESULT_STG_2_TMP');
INSERT /*+APPEND*/
INTO LA_ENTER_RESULT_STG_2_TMP
(
SYS_ID,
ADDRESS,
IS_ADDRESS_VALID,
CUST_DOB,
SUCCESS_DATE
)
SELECT /*+PARALLEL(A 2) PARALLEL(B 2) PARALLEL(C 2) PARALLEL(D 2)*/
A.SYS_ID,
B.ADDRESS,
B.IS_ADDRESS_VALID,
C.CUST_DOB,
D.SUCCESS_DATE
FROM LA_ENTER_RESULT_STG_0_TMP A,
LA_CLEAN_ADDRESS_STG_TMP B,
LA_CLEAN_CUST_DOB_STG_TMP C,
LA_CLEAN_SUCCESS_DATE_STG_TMP D
WHERE A.SYS_ID = B.SYS_ID(+)
AND A.SYS_ID = C.SYS_ID(+)
AND A.SYS_ID = D.SYS_ID(+);
COMMIT;
-- 更新本次操作日志
NETS_TCIMS_COMM.SP_LOG_RECORDER(P_ID,81,NULL,'02',NULL,NULL,NULL,NULL);
EXCEPTION
WHEN OTHERS THEN
P_ERRMSG := SUBSTR(SQLERRM,1,500);
NETS_TCIMS_COMM.SP_LOG_RECORDER(P_ID,81,NULL,'03',P_ERRMSG,NULL,NULL,NULL);
RAISE;
END SP_UNITE_LA_ENTER_RESULT_2;
/***********************************************************
--功能说明: 寿险合并
--参数说明:
--调用函数:
--修改记录： EX-LIUJIALI001
--注意事项： 顺序在 所有清洗、功能完成之后 屏蔽 操作之前
--*********************************************************/
PROCEDURE SP_UNITE_LA_ENTER_RESULT_3
IS
p_id NUMBER; -- 日志记录id
p_errmsg VARCHAR2(500); -- 错误记录
BEGIN
-- 操作记录
NETS_TCIMS_COMM.SP_LOG_RECORDER(p_id,82,NULL,'01',NULL,NULL,NULL,NULL);
--清空结果临时表
NETS_TCIMS_COMM.SP_TRUNCATE('TCIMSLOGTMP','LA_ENTER_RESULT_STG_3_TMP');
INSERT /*+APPEND*/
INTO LA_ENTER_RESULT_STG_3_TMP
(
SYS_ID,
TRANSF_SUC_DAY,
SUBMIT_DATE,
LIST_STATUS_CODE
)
SELECT /*+PARALLEL(A 2) PARALLEL(B 2) PARALLEL(C 2) PARALLEL(D 2)*/
A.SYS_ID,
B.TRANSF_SUC_DAY ,
C.SUBMIT_DATE ,
D.LIST_STATUS_CODE
FROM LA_ENTER_RESULT_STG_0_TMP A,
LA_CLEAN_TRANS_SUC_DAY_STG_TMP B,
LA_CLEAN_SUBMIT_DATE_STG_TMP C,
LA_CLEAN_LIST_STATUS_STG_TMP D
WHERE A.SYS_ID = B.SYS_ID(+)
AND A.SYS_ID = C.SYS_ID(+)
AND A.SYS_ID = D.SYS_ID(+);
COMMIT;
-- 更新本次操作日志
NETS_TCIMS_COMM.SP_LOG_RECORDER(P_ID,82,NULL,'02',NULL,NULL,NULL,NULL);
EXCEPTION
WHEN OTHERS THEN
P_ERRMSG := SUBSTR(SQLERRM,1,500);
NETS_TCIMS_COMM.SP_LOG_RECORDER(P_ID,82,NULL,'03',P_ERRMSG,NULL,NULL,NULL);
RAISE;
END SP_UNITE_LA_ENTER_RESULT_3;
/***********************************************************
--功能说明: 清洗、屏蔽结束后的整合，供库存比对使用(寿险)
--参数说明:
--调用函数:
--修改记录： EX-LIUJIALI001
--注意事项： 顺序在 所有清洗、屏蔽 功能完成之后
--*********************************************************/
PROCEDURE SP_UNITE_LA_ENTER_RESULT
IS
P_ID NUMBER; -- 日志记录ID
P_ERRMSG VARCHAR2(500); -- 错误记录
BEGIN
-- 操作记录
NETS_TCIMS_COMM.SP_LOG_RECORDER(P_ID,84,NULL,'01',NULL,NULL,NULL,NULL);
--清空结果临时表
NETS_TCIMS_COMM.SP_TRUNCATE('TCIMSLOGTMP','LA_STG_DATA_TMP');
INSERT /*+APPEND*/
INTO LA_STG_DATA_TMP
(
SYS_ID,
TCIMS_CUST_ID,
CUST_NAME,
SEX,
ID_TYPE,
ID_NUMBER,
CUST_DOB,
CONTACT_ADDRESS,
CONTACT_ZIPCODE,
ADDRESS,
ZIP_CODE,
WORK_UNIT,
TELEPHONE_NUMBER,
DEPARTMENT_CHINESE_NAME,
CLIENT_NO,
APPLICANT_PARTY_NO,
CAMPAIGN_NAME,
BATCH_NAME,
SUPERVISOR_ID,
TEAM_LEADER_ID,
TMR_UM_ID,
PRODUCT_NAME,
CONTACT_DATE,
CALL_RESULT,
SUBMIT_DATE,
CALL_BACK_REMARK,
SUCCESS_DATE,
TRANSFER_SUCCESS_DAY,
LIST_STATUS,
CREDIT_CARD_CALL_DATE,
LIST_CREATED_DATE,
EDUCATIONAL_BACKGROUND,
MARITAL_STATUS,
PROF_GRADE,
ANNUAL_INCOME,
SHIELD_FLAG,
LIST_TYPE,
REGION_CODE,
EMAIL,
TCIMS_BATCH_ID,
LIST_PRIORITY,
SRC_TYPE,
IS_INSURE_FLAG,
IS_SUBMIT_FLAG,
IS_FREE_FLAG,
C
- src.rar (3.8 MB)
- 下载次数: 0
发表评论
-
resin3.1配置说明
2010-12-14 16:07 851<!-- Resin 3.1 配置文件. --> ... -
resion 2.x配置
2010-12-14 16:06 1166resion 2.x配置 1. <http h ... -
sqlserver 递归查询
2010-12-01 17:20 794WITH read_tree (id,department ... -
20个非常有用的Java程序片段
2010-08-31 22:58 1382下面是20个非常有用的Java程序片段，希望能对你有用。1. ... -
ajax post提交乱码
2010-08-10 17:28 15946月30日 jQuery ajax乱码问题解决 一、测试环 ... -
IE注册表设置安全项
2010-07-30 17:16 2256Windows安全设置之注册表项在IE4.0以上的版本中，IE ... -
AD、CA、SSL，绑定keystore
2010-04-12 22:37 2636本文原文出处：http://blog.csdn.net/fre ... -
理解REST软件架构（转）
2010-01-01 23:47 860一种思维方式影响了软件行业的发展。REST软件架构是当今世界上 ... -
数据整合_SP
2009-12-18 14:50 757CREATE OR REPLACE PACKAGE BODY ... -
屏蔽数据_SP
2009-12-18 14:46 744CREATE OR REPLACE PACKAGE BODY ... -
数据抽取_SP
2009-12-18 14:44 926CREATE OR REPLACE PACKAGE BODY ... -
合并清洗
2009-12-18 14:41 740CREATE OR REPLACE PACKAGE BODY ... -
test_help_sp
2009-12-18 08:24 715CREATE OR REPLACE PACKAGE BODY ... -
数据清洗2
2009-12-18 08:23 811create or replace package body ... -
数据清洗3
2009-12-18 08:22 819CREATE OR REPLACE PACKAGE BODY ... -
dwr reverse-ajax 实例解析(初步认识)
2009-10-30 15:20 1036在网上找了一个老外写的dwr reverse-ajax的例子 ... -
java反射
2009-10-17 21:46 971Reflection 是Java被视为动态（或准动态）语言 ... -
oracle sql
2009-09-23 10:29 630select * from PDS_DELIVERY_REQU ... -
开闭原则 思考(转)
2009-09-17 12:56 855开闭原则的定义 Software entities shou ... -
oracle函数
2009-09-16 23:38 1025oracle时间函数 相信很多人都有过统计某些数据的经历，比 ...
相关推荐
3. **MATLAB编程**：用于处理、分析和可视化数据，可能包括数据导入、数据清洗、统计分析、绘图等操作。 4. **Excel应用**：作为数据整理和初步分析的工具，Excel在此处可能用于记录测试参数、计算平均值、标准差等...
1. 数据清洗：去除无关信息，如HTML标签，统一数据格式。 2. 缺失值处理：根据实际情况选择填充平均值、中位数或使用其他方法。 3. 类型转换：将非数值特征转化为数值类型，如One-Hot编码处理类别变量。 4. 特征工程...
出租车结算中心系统不仅将这些数据转发给中央结算系统进行清洗处理，而且还需从中央结算系统下载运营参数文件、清算结果文件以及对账文件等。同时，该系统自身还需对所有接收的交易记录进行统计和分析，并生成相应的...
2. 数据预处理：清洗数据，处理缺失值，进行日期排序，可能还需要对时间序列进行归一化或标准化。 3. 特征工程：根据业务理解，可能需要创建新的特征，比如移动平均或指数移动平均，来捕捉趋势和周期性。 4. 模型...
接着，进行数据清洗，处理缺失值（如填充或删除），异常值检查，以及数据类型转换，确保数据质量。 2. 数据探索性分析（EDA）：使用pandas和matplotlib或seaborn库进行可视化，探究不同变量之间的关系，如购买金额...
为了进一步分析这个数据，我们需要使用相应的数据分析工具，例如Python的pandas库，或者Excel等软件，将数据导入后进行清洗、处理和可视化。 其次，"readme.txt"是一个常见的文本文件，通常包含关于数据集的重要...
通过这个项目，学习者可以掌握网页抓取的基本原理和实践技巧，同时了解如何利用Python进行数据清洗、分析和可视化。对于希望涉足金融数据分析或者提升编程技能的人来说，这是一个非常实用的学习资源。
2. 数据预处理：清洗数据，处理缺失值，将数据转换为适合分析的格式。 3. 相关系数计算：使用Pandas的`corr()`函数计算每对股票的价格变动的相关性。 4. 协整检验：可能使用Engle-Granger方法或者Johansen测试来确认...
- **PCB信息**：在进行基板编辑时，首先需要输入PCB的基本信息，包括PCB的尺寸等数据。这些信息通常基于板子的拼版计算得出，确保信息的准确性至关重要。 - **轨道调宽**：根据输入的PCB信息，自动或手动调节轨道...
2. 数据预处理：在数据挖掘之前，通常需要对原始数据进行预处理，包括清洗（处理缺失值、异常值）、转换（标准化、归一化）和整合。例如，书中可能涉及如何使用R中的dplyr包进行数据筛选、合并和重塑。 3. 数据挖掘...
- **数据预处理**：内置丰富的数据清洗、转换和集成工具，简化数据准备流程，确保分析数据的质量。 - **元数据管理**：提供了强大的元数据管理功能，帮助用户理解数据含义，提升数据分析的准确性和效率。 3. **...
- **数据整合与清洗**：通过对原始数据进行清洗、转换等预处理步骤，确保数据质量，使其符合数据仓库的要求。 #### 二、数据仓库的特点 - **当前与历史数据存储**：数据仓库不仅能存储最新的交易数据，还能保存历史...
1. **数据处理**：XDPS2.0可能是为了处理大量数据而设计的，它可能提供了高效的数据导入、导出、清洗、转换等功能，以满足用户对数据预处理的需求。 2. **数据库管理**：作为一款专业软件，它可能包含了完善的...
首先，让我们来了解两个核心的数据文件：`SP_train.csv`和`SP_test.csv`。这两个CSV文件分别代表了训练数据集和测试数据集。训练数据集用于构建和训练机器学习模型，它包含了已知的结果（即学生的实际成绩），模型将...
【标题】"项目数据集2-SP"是一个与软件开发或数据分析相关的项目，其中"SP"可能代表"Software Project"或者特定的技术栈如"Statistical Processing"。这个数据集是项目的一部分，通常用于训练机器学习模型、进行数据...
在创建DTS包时，需要注意数据类型和格式的匹配，以及数据清洗规则的设定，确保数据的准确性和完整性。 ### 2. 利用Bcp命令行工具 Bcp是SQL Server自带的一个强大的批处理工具，主要用于数据的导入导出。它支持快速...