upsert into
impala_kudu_model.t_m_cms_service_main (party_id,serviceno,source_system)
select
max(dis.party_id),main.serviceno,main.source_system
from impala_kudu_model.t_m_cus_fact_dis dis
INNER join impala_hive_dhyz.t_m_cms_service_main main
on main.complainantidno = dis.identify_no
and main.complainantidtype = dis.identify_type
and main.complainantname = dis.customer_name
and main.complainantGender = dis.sex_code
and substr(main.complainantidNo,7,8) =CONCAT(substr(dis.BIRTH_DATE,1,4),substr(dis.BIRTH_DATE,6,2),substr(dis.BIRTH_DATE,9,2))
group by main.serviceno,main.source_system;
--根据证件号码和名字
upsert into
impala_kudu_model.t_m_cms_service_main (party_id,serviceno,source_system)
select
max(dis.party_id),main.serviceno,main.source_system
from impala_kudu_model.t_m_cus_fact_dis dis
INNER join impala_hive_dhyz.t_m_cms_service_main main
on main.complainantidno = dis.identify_no
where main.complainantname = dis.customer_name
group by main.serviceno,main.source_system;
--根据保单号+名字
upsert into
impala_kudu_model.t_m_cms_service_main (party_id,serviceno,source_system,c_src_customer)
select
max(ply.party_id),main.serviceno,main.source_system,ply.c_src_customer_no
from impala_kudu_model.t_m_bus_ply_dis ply
INNER join impala_hive_dhyz.t_m_cms_service_main main
on main.policyno = ply.c_ply_no
and main.complainantName= ply.name
group by main.serviceno,main.source_system,ply.c_src_customer_no;
--根据保单号+电话
upsert into
impala_kudu_model.t_m_cms_service_main (party_id,serviceno,source_system)
select
max(ply.party_id),main.serviceno,main.source_system
from impala_kudu_model.t_m_bus_ply_dis ply
inner join impala_kudu_model.t_m_cus_tch rel
on ply.party_id = rel.party_id
INNER join impala_hive_dhyz.t_m_cms_service_main main
on main.policyno = ply.c_ply_no
and main.moiblenumber = rel.contact
group by main.serviceno,main.source_system;
-->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>投诉信息 end <<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<--
你这是什么业务，为什么写的这么复杂。
请各位大神说下，谢谢
帮你把代码优化好后，估计你都已执行完成了