预算机制，递归计算

#!/usr/bin/perl

###############################################################################

# Program : estimateScore.pl 计算评分卡的得分

# Scrpition: 执行本数据字段批量检查需要以下几个步骤

#  1.得到所有的评分卡以及评分卡下的所有的评分组。

#　   2.根据评分组ID 得到所有的规则组信息

#     3.根据规则组信息&＃xff0c;在check_result基础数据表中得到所有的规则组信息 每一个规则组有一个维度&＃xff0c;不同的维度有不同的权重

#  4.从检查结果表check_result中得到规则组得分 insert into rulegroup_score 

#  5.根据规则组得分表中的map_id 计算出 叶子节点的得分&＃xff0c;插入到评分卡得分表 estimate_card_score 

#     6.递归计算所有的节点的得分

# Writer  : suhongyun

# Version :

# 

# ------评分卡与评分组的关系的历史记录的维护&＃xff0c;就要在表中添加日期的字段

# ------评分卡的频率的使用参照规则的频率

# ------

# ------

###############################################################################

use strict;#对语法做严格限制&＃xff0c;如变量必须先用my声明

use DBI;

use Time::Local;

my $dbh;#与数据库的连接

my &＃64;Fieldrow;

# my $logFile;

# #日志文件目录

# #一个大于号&＃xff0c;表示覆盖原有文件的内容

# #两个大于号表示在原有文件内容之后添加

# my $lfnowtime &＃61;GetNowDate();

# open $logFile,">checkLog$lfnowtime.txt";

# select $logFile;

#连接TD数据库

sub TDCconnect(){

$dbh &＃61; DBI->connect("dbi:ODBC:td_mds_VM_db", "", "") or "Can&＃39;t connect to sample database: $DBI::errstr";

print "Connection is successful !!\n";

return $dbh;

}

#当前机构及其下属机构检查涉及的规则得分

sub calRuleGroupScore{

print("-----------------------------calRuleGroupScore begin-----------------------------\n");

my ($orgId,$rundate )&＃61; &＃64;_; 

print("calRuleGroupScore para : $orgId & $rundate \n");

my $orgInfoSQL &＃61; " WITH  recursive temporg(id,name,pid,leveld) as( ".

" select a.branch_id,a.branch_name,a.par_branch_id,0 from  bohz_appmds.tap_c_branch_all  a where branch_id &＃61; $orgId union all ".

"select a.branch_id,a.branch_name,a.par_branch_id,c.leveld&＃43;1 from bohz_appmds.tap_c_branch_all a ,temporg c where  c.id &＃61; a.par_branch_id and leveld<7)".

"select id from temporg";

my $sth &＃61; $dbh->prepare($orgInfoSQL) or return -1;

my $ret &＃61; $sth->execute() or return -1;  

my $orgInfo &＃61; $sth->fetchall_arrayref();

$sth->finish();

my $orgPin ;

for(my $i &＃61; 0 ;$i<$#${orgInfo};$i&＃43;&＃43;){

$orgPin &＃61; $orgPin."&＃39;".$orgInfo->[$i][0]."&＃39;,";

}

$orgPin &＃61; $orgPin."&＃39;".$orgInfo->[$#${orgInfo}][0]."&＃39;";

#1.通过日期和机构条件锁定数据范围&＃xff0c;然后计算得到每条规则的得分情况

#2.关联规则表&＃xff0c;得到规则的权重信息&＃xff0c;进而求得规则的权重得分&＃xff08;ws&＃xff09;

#3.group by mapId&＃xff0c;再sum&＃xff08;ws&＃xff09;&＃xff0c;求得规则组的得分情况

my $resultSQL &＃61; 

"select map_id ,sum(rett) as rg_score from".

"(select main.map_id,main.check_id, ".

"CASE WHEN r.rule_weight &＃61;  &＃39;0&＃39; THEN case when r.CheckDimension &＃61; &＃39;01&＃39; then 0.2

when r.CheckDimension &＃61;&＃39;05&＃39;  then  0.2

when r.CheckDimension &＃61;&＃39;02&＃39;  then 0.2

when r.CheckDimension &＃61;&＃39;03&＃39;  then 0.2

when r.CheckDimension &＃61;&＃39;04&＃39;  then 0.2

when r.CheckDimension &＃61;&＃39;06&＃39; then  0.2

else null end

ELSE r.rule_weight END as weight,score,score*weight as rett ".

"from ".

"(select map_id,check_id,cast(sum(passcount) as DEC(8,2))/sum(effect_count) as score ".

"from appdqc.check_result".

" where rundate&＃61;date&＃39;$rundate&＃39; and org_id in ($orgPin) group by map_id,check_id) main ".

"inner join appdqc.rule r on main.check_id &＃61; r.check_id) tt group by map_id" ;

my $ruleScoresth &＃61; $dbh->prepare($resultSQL) or return -1;

my $ret &＃61; $ruleScoresth->execute() or return -1;  

#将每一个规则组的得分&＃xff0c;按照机构&＃xff0c;日期的维度进行存储

while (&＃64;Fieldrow &＃61; $ruleScoresth->fetchrow() ) { # Fieldrow一维数组

my $Map_Id &＃61; "$Fieldrow[0]"; 

my $score &＃61; "$Fieldrow[1]";

print("map_id: $Map_Id,score : $score  \n");

my $insertGroupSQL &＃61; "insert into appdqc.rulegroup_score values(date&＃39;$rundate&＃39;,&＃39;$Map_Id&＃39;,&＃39;$orgId&＃39;,&＃39;$score&＃39;)";

my $sth &＃61; $dbh->prepare($insertGroupSQL) or  return -1;

my $ret &＃61; $sth->execute() or return -1;  

$sth->finish();

}

$ruleScoresth->finish();

print("----------------------calRuleGroupScore  End--------------------\n");

return 0;

}

sub calNodeScore{

print("--------------------------calNodeScore---------------------\n");

my ($curr_folder_id,$orgId,$rundate) &＃61; &＃64;_;#定义的变量需要用括号括起来&＃xff0c;因为&＃64;_得到的是一个数组

my $ret;

my $broLength;

my $gs;

my $averageGs;

#得到当前评分卡下的节点&＃xff08;评分组&＃xff09;的信息

print("curr_folder_id:$curr_folder_id \n");

my $pfkSQL &＃61; "select folder_id,isleaf,weight from appdqc.estimate_group where status&＃61;1 and par_folder_id&＃61;&＃39;$curr_folder_id&＃39;";

my $Nodesth &＃61; $dbh->prepare($pfkSQL) or  return -1;

$broLength &＃61; $Nodesth->execute() or return -1;  #broLength直接是结果集的长度

print("length : $broLength\n");

my $nodeCount;

if($broLength &＃61;&＃61; 0){

print("$curr_folder_id no rulegroup or estimategroup");

}else{

while(my &＃64;Fieldrow &＃61; $Nodesth->fetchrow()){

my $child_folder_id &＃61; "$Fieldrow[0]";

my $isleaf &＃61; "$Fieldrow[1]";

#my $weight &＃61; "$Fieldrow[2]";

if("0" eq $isleaf ){# &&broLength eq 0  没有下级的节点是没有意义的

#当前节点的非叶子子节点的计算结果

my $ret &＃61; calNodeScore($child_folder_id,$orgId,$rundate);

$gs &＃43;&＃61; $ret;

$averageGs &＃61; $gs;

}else{

# 当前节点的叶子子节点

print ("$child_folder_id is  leafNode and  broLength &＃61; $broLength\n");

# 结果集理论只有一条

# my $leafScoreSQL &＃61; "select * from appdqc.estimate_card_score ec inner join estimate_card on ec.folder_id&＃61;$child_folder_id "

# ."and ec.org_Id&＃61;&＃39;3400008888&＃39; and and RunDate&＃61;&＃39;20160530&＃39;";

my $leafScoreSQL &＃61; "select * from appdqc.estimate_card_score ec inner join estimate_group on ec.folder_id&＃61;&＃39;$child_folder_id&＃39; "

."and ec.org_Id&＃61;&＃39;$orgId&＃39; and rundate &＃61; date&＃39;$rundate&＃39; ";

my $Leafsth &＃61; $dbh->prepare($leafScoreSQL) or  return -1;

$Leafsth->execute() or return -1;  

my &＃64;Fieldrow &＃61; $Leafsth->fetchrow();

my  $s &＃61; "$Fieldrow[6]";

print("leaf score   :$s  \n");

my $w  &＃61;  "$Fieldrow[5]";

$gs &＃43;&＃61; $s ;

#$averageGs &＃61; ($gs/$broLength);

print("leaf score average : $gs \n");

$Leafsth ->finish();

}

}

$averageGs &＃61; ($gs/$broLength);

}

# print $logFile ("insert into estiamte_card_score  $orgId $rundate $averageGs   $curr_folder_id  \n");

my $insertNodeScoreSQL &＃61; "insert into appdqc.estimate_card_score  ".

"select &＃39;$orgId&＃39;,date&＃39;$rundate&＃39;,folder_id,par_folder_id,folder_name,&＃39;&＃39;,&＃39;$averageGs&＃39; from appdqc.estimate_group  ".

" where folder_id &＃61; $curr_folder_id";

my $insertNodesth &＃61; $dbh->prepare($insertNodeScoreSQL) or return -1;

$insertNodesth  ->execute() or return -1;

$insertNodesth ->finish();

$Nodesth->finish();

#my $cardScoreinsert &＃61; "select sum(score/3) from estimate_card_score where par_folder_id&＃61; &＃39;$curr_folder_id&＃39;";

print("-------------------------------calNodeScore  End----------------------\n");

#计算树形节点的得分&＃xff0c;并插入到estimate_card_score树形节点得分信息表中

return $averageGs;

}

#计算评分卡值得入口

sub calCardscore{

print("--------------------------------calCardscore begin --------------------------\n");

my ($nodeId,$runDate,$orgId) &＃61; &＃64;_;

print(" calCardscore  para :$nodeId,$runDate,$orgId \n");

#递归计算评分卡节点下的所有叶子评分组

my $cardGroupsql &＃61; "WITH  recursive temptab(id,name,pid,isleaf,leveld) as(".

" select a.folder_id,a.folder_name,a.par_folder_id,a.isleaf,0 from appdqc.estimate_group a where par_folder_id &＃61;&＃39;$nodeId&＃39; union all ".

" select a.folder_id,a.folder_name,a.par_folder_id,a.isleaf,c.leveld&＃43;1 from appdqc.estimate_group a ,temptab c".

" where  c.id &＃61; a.par_folder_id and status&＃61;&＃39;1&＃39; and leveld<7)".

" select id from temptab where isleaf &＃61; &＃39;1&＃39; ";

my $cardGroupsqlSth &＃61; $dbh->prepare($cardGroupsql) or return -1;

$cardGroupsqlSth ->execute() or return -1;

while(my &＃64;Fieldrow &＃61; $cardGroupsqlSth->fetchrow()){

my $groupId &＃61; "$Fieldrow[0]";

my $gs &＃61; "0";

#得到叶子规则组的权重和规则组的得分 

my $groupId_rulegroup_sql &＃61; "select er.map_id,er.weight,rgs.score from appdqc.estimate_mapid_relation er ".

" inner join rulegroup_score rgs on er.map_id &＃61; rgs.map_id  " . "where group_Id&＃61;&＃39;$groupId&＃39; ".

" and status &＃61; &＃39;1&＃39; "; 

my $groupId_rulegroupsth &＃61; $dbh->prepare($groupId_rulegroup_sql) or return -1;

my $length &＃61; $groupId_rulegroupsth ->execute() or return -1;

my $gs &＃61; "0";

# 在评分组下的规则组的权重和得分加权求和之后得到叶子评分组的得分 &＃xff08;gs&＃xff09;

while(&＃64;Fieldrow &＃61; $groupId_rulegroupsth->fetchrow()){

my $s &＃61; "$Fieldrow[2]";

print(" score : $s \n");

my $w &＃61; "$Fieldrow[1]";

$gs &＃43;&＃61; $s;

}

my $average &＃61; ($gs/$length);

$groupId_rulegroupsth ->finish();

print(" folder_id : $groupId ,average : $average ");

#将每一个叶子节点的得分插入到estimate_card_score 节点得分表中,变量中不加单引号&＃xff0c;会出现插入数据表中的数据结尾出现‘.’

# estiamte_card_score 联合唯一主键  orgId rundate folder_id

my $insertCardScoreSQL  &＃61; "insert into appdqc.estimate_card_score ".

"select &＃39;$orgId&＃39;,date&＃39;$runDate&＃39;,folder_id,par_folder_id,folder_name,&＃39;&＃39;,&＃39;$average&＃39; from appdqc.estimate_group ".

" where folder_id&＃61;&＃39;$groupId&＃39; and status &＃61; &＃39;1&＃39; ";

my $insertCardScoresth &＃61; $dbh->prepare($insertCardScoreSQL) or return -1;

$insertCardScoresth ->execute() or return -1;

$insertCardScoresth ->finish();

}

$cardGroupsqlSth->finish();

my $cardScore &＃61; calNodeScore($nodeId,$orgId,$runDate);#通过调用递归的计算节点的得分&＃xff0c;最终求得评分卡最终的得分

my $cardScoreinsert &＃61; "insert into appdqc.estimate_card_score ".

"select &＃39;$orgId&＃39;,date&＃39;$runDate&＃39;,folder_id,par_folder_id,folder_name,&＃39;&＃39;,&＃39;$cardScore&＃39; from appdqc.estimate_card ".

" where folder_id&＃61;&＃39;$nodeId&＃39;";

my $cardScoresth &＃61; $dbh->prepare($cardScoreinsert) or return -1;

$cardScoresth ->execute() or return -1;

$cardScoresth->finish(); 

print("-----------------------------calCardscore End------------------------\n");

}

sub main{

print "-----------------------------main begin----------------------------- ";

#得到数据库连接----TD库连接

TDconnect();

# if()

my $rundatesql &＃61; "select max(rundate) from appdqc.check_result ";

my $rundateSth &＃61; $dbh->prepare($rundatesql) or return -1;

$rundateSth ->execute() or return -1;

my &＃64;Fieldrow &＃61; $rundateSth->fetchrow();

#my $rundate &＃61; "$Fieldrow[0]";

$rundateSth ->finish();

my $rundate &＃61; "2016-06-01";

print("rundate : $rundate  \n");

my $deleteHistory  &＃61; "delete from appdqc.estimate_card_score where rundate &＃61; date&＃39;$rundate&＃39; ;".

"delete from appdqc.rulegroup_score where rundate &＃61; date&＃39;$rundate&＃39; ;";

my $deleteHistorySth &＃61; $dbh ->prepare($deleteHistory) or return -1;

$deleteHistorySth ->execute() or return -1;

$deleteHistorySth ->finish();

print("deleteHistory : fininsh  \n");

#计算规则组得分&＃xff0c;并插入到规则组得分信息表中

#传入参数&＃xff1a;机构、日期&＃xff0c;节点

#得到所有的农商行机构信息&＃xff08;包含总行机构&＃xff09;&＃xff0c;使用循环对每一个机构计算评分卡得分

my $getOrg &＃61; "select branch_id from  bohz_appmds.tap_c_branch where branch_id in ( &＃39;3401020316&＃39;,&＃39;3401040438&＃39;,&＃39;3401030216&＃39;,&＃39;3400008888&＃39;,&＃39;3401010008&＃39;)order by branch_id " ;

my $getOrgsth &＃61; $dbh->prepare($getOrg) or return -1;

$getOrgsth ->execute() or return -1;

while(my &＃64;Fieldrow &＃61; $getOrgsth->fetchrow()){

my $branchId &＃61; "$Fieldrow[0]";

calRuleGroupScore($branchId,$rundate);

my $cardInfo &＃61; "select folder_id from appdqc.estimate_card where status &＃61; &＃39;1&＃39;";

my $cardInfoSth &＃61; $dbh ->prepare($cardInfo) or return -1;

$cardInfoSth->execute() or return -1;

while(my &＃64;Fieldrow &＃61; $cardInfoSth->fetchrow()){

my $cardId &＃61; "$Fieldrow[0]";

# print("cardId : $cardId \n");

#递归计算树形节点的得分&＃xff0c;并插入到estimate_card_score树形节点得分信息表中

calCardscore($cardId ,$rundate,$branchId);#参数为用户的输入节点ID

}

}

$getOrgsth ->finish();

print "-----------------------------main end -------------------------------";

}

#找到当前的日期&＃xff0c;月份要加1&＃xff0c;年份是从1900开始算的

sub GetNowDate{

my ($sec, $min, $hour, $day, $mon, $year, $wday, $yday, $isdst) &＃61; localtime(); 

$mon &＃61; sprintf("%02d", $mon&＃43;1);

$day &＃61; sprintf("%02d", $day);

my $stime &＃61; ($year&＃43;1900).$mon.$day;

return $stime;

}

my $rc &＃61; main();#函数的入口

exit($rc);