信用概览调度测试通过

信用分相关/建表语句/credit.txt

--------------------credit_total-------------------------------
+-------------------credit_total-------------------------------
@@ -143,7 +143,7 @@ location '/app/traffic/credit_change_analysis_day';
 create table IF NOT EXISTS app.credit_radar (
 create table IF NOT EXISTS app.credit_radar (
 indicator_type string,
 indicator_type string,
 indicator_name  string,
 indicator_name  string,
-indicator_score double,
+indicator_score decimal(10,2),
 date_time string,
 date_time string,
 update_time string,
 update_time string,
 type string COMMENT'1为激活，0为所有'
 type string COMMENT'1为激活，0为所有'

信用分相关/建表语句/脚本.txt

---credit_activate_stat天表
+--credit_activate_stat天表
@@ -135,20 +135,20 @@ credit_action_times_coe WHERE eval_day=current_date() ) b  on a.id_card=b.idcard
 )tab
 )tab
 GROUP BY act_type2,act_type1,score_type,eval_day ;
 GROUP BY act_type2,act_type1,score_type,eval_day ;
 --信用雷达-----------------------------
 --信用雷达-----------------------------
-insert overwrite table app.credit_radar select 1,'违法行为',avg(crime_percent_rank),date_add(eval_day,-1),current_date(),'0' from default.credit_score_mining_out  where eval_day=current_date()  group by eval_day;
-insert into table app.credit_radar select 1,'违法行为',avg(crime_percent_rank),date_add(eval_day,-1),current_date(),'1' from 
+insert overwrite table app.credit_radar select 1,'违法行为',avg(crime_percent_rank),date_add(eval_day,-1),current_timestamp(),'0' from default.credit_score_mining_out  where eval_day=current_date()  group by eval_day;
+insert into table app.credit_radar select 1,'违法行为',avg(crime_percent_rank),date_add(eval_day,-1),current_timestamp(),'1' from 
 (select * from default.app_activate_credit a inner join (select * from default.credit_score_mining_out  where eval_day=current_date())b on a.id_card=b.idcard_no)tab  group by eval_day;
 (select * from default.app_activate_credit a inner join (select * from default.credit_score_mining_out  where eval_day=current_date())b on a.id_card=b.idcard_no)tab  group by eval_day;
-insert into app.credit_radar select 2,'安全行驶',avg(accident_percent_rank),date_add(eval_day,-1),current_date(),'0' from default.credit_score_mining_out where eval_day=current_date()  group by eval_day;
-insert into app.credit_radar select 2,'安全行驶',avg(accident_percent_rank),date_add(eval_day,-1),current_date(),'1' from 
+insert into app.credit_radar select 2,'安全行驶',avg(accident_percent_rank),date_add(eval_day,-1),current_timestamp(),'0' from default.credit_score_mining_out where eval_day=current_date()  group by eval_day;
+insert into app.credit_radar select 2,'安全行驶',avg(accident_percent_rank),date_add(eval_day,-1),current_timestamp(),'1' from 
 (select * from default.app_activate_credit a inner join (select * from default.credit_score_mining_out  where eval_day=current_date())b on a.id_card=b.idcard_no)tab  group by eval_day;
 (select * from default.app_activate_credit a inner join (select * from default.credit_score_mining_out  where eval_day=current_date())b on a.id_card=b.idcard_no)tab  group by eval_day;
-insert into app.credit_radar select 3,'基础信息',avg(per_info_rank),date_add(eval_day,-1), current_date(),'0' from default.credit_score_mining_out where eval_day=current_date()  group by eval_day;
-insert into app.credit_radar select 3,'基础信息',avg(per_info_rank),date_add(eval_day,-1), current_date(),'1' from 
+insert into app.credit_radar select 3,'基础信息',avg(per_info_rank),date_add(eval_day,-1), current_timestamp(),'0' from default.credit_score_mining_out where eval_day=current_date()  group by eval_day;
+insert into app.credit_radar select 3,'基础信息',avg(per_info_rank),date_add(eval_day,-1), current_timestamp(),'1' from 
 (select * from default.app_activate_credit a inner join (select * from default.credit_score_mining_out  where eval_day=current_date())b on a.id_card=b.idcard_no)tab   group by eval_day;
 (select * from default.app_activate_credit a inner join (select * from default.credit_score_mining_out  where eval_day=current_date())b on a.id_card=b.idcard_no)tab   group by eval_day;
-insert into app.credit_radar select 4,'文明活动',avg(good_act_rank),date_add(eval_day,-1),current_date(),'0' from default.credit_score_mining_out where eval_day=current_date()  group by eval_day;
-insert into app.credit_radar select 4,'文明活动',avg(good_act_rank),date_add(eval_day,-1),current_date(),'1' from 
+insert into app.credit_radar select 4,'文明活动',avg(good_act_rank),date_add(eval_day,-1),current_timestamp(),'0' from default.credit_score_mining_out where eval_day=current_date()  group by eval_day;
+insert into app.credit_radar select 4,'文明活动',avg(good_act_rank),date_add(eval_day,-1),current_timestamp(),'1' from 
 (select * from default.app_activate_credit a inner join (select * from default.credit_score_mining_out  where eval_day=current_date())b on a.id_card=b.idcard_no)tab  group by eval_day;
 (select * from default.app_activate_credit a inner join (select * from default.credit_score_mining_out  where eval_day=current_date())b on a.id_card=b.idcard_no)tab  group by eval_day;
-insert into app.credit_radar select 5,'信用履约',avg(task_percent_rank),date_add(eval_day,-1) ,current_date(),'0' from default.credit_score_mining_out where eval_day=current_date()  group by eval_day;
-insert into app.credit_radar select 5,'信用履约',avg(task_percent_rank),date_add(eval_day,-1) ,current_date(),'1' from 
+insert into app.credit_radar select 5,'信用履约',avg(task_percent_rank),date_add(eval_day,-1) ,current_timestamp(),'0' from default.credit_score_mining_out where eval_day=current_date()  group by eval_day;
+insert into app.credit_radar select 5,'信用履约',avg(task_percent_rank),date_add(eval_day,-1) ,current_timestamp(),'1' from 
 (select * from default.app_activate_credit a inner join (select * from default.credit_score_mining_out  where eval_day=current_date())b on a.id_card=b.idcard_no)tab group by eval_day;
 (select * from default.app_activate_credit a inner join (select * from default.credit_score_mining_out  where eval_day=current_date())b on a.id_card=b.idcard_no)tab group by eval_day;
 --score_record---------------------------
 --score_record---------------------------
 insert overwrite table app.credit_score_record_day  SELECT idcard_no,eval_day,substr(eval_day,1,7),b_score,per_info_score+total_no_bad_score+total_task_add_score+total_good_act_score,abs(total_crime_score+total_acci_score+total_task_m_score),crime_percent_rank,accident_percent_rank,per_info_rank,good_act_rank,task_percent_rank,b_rank,cast((tb.num-b_rank)/tb.num as decimal(38,6))*10000 FROM (select * from default.credit_score_mining_out where eval_day=current_date()) a  INNER JOIN (SELECT count(1) num from default.credit_score_mining_out WHERE eval_day=current_date() )  tb on 1=1;
 insert overwrite table app.credit_score_record_day  SELECT idcard_no,eval_day,substr(eval_day,1,7),b_score,per_info_score+total_no_bad_score+total_task_add_score+total_good_act_score,abs(total_crime_score+total_acci_score+total_task_m_score),crime_percent_rank,accident_percent_rank,per_info_rank,good_act_rank,task_percent_rank,b_rank,cast((tb.num-b_rank)/tb.num as decimal(38,6))*10000 FROM (select * from default.credit_score_mining_out where eval_day=current_date()) a  INNER JOIN (SELECT count(1) num from default.credit_score_mining_out WHERE eval_day=current_date() )  tb on 1=1;