树形节点层次得分计算

#!/usr/bin/perl

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

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

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

# Version :

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

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

use DBI;

use Time::Local;

 

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

my @Fieldrow;

# my $logFile;

# #日志文件目录

# #一个大于号，表示覆盖原有文件的内容

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

# my $lfnowtime =GetNowDate();

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

# select $logFile;

 

 

#连接TD数据库

sub TDconnect(){

$dbh = DBI->connect("dbi:ODBC:mds_192.168.174.129", "dbc", "dbc") or "Can't connect to sample database: $DBI::errstr";

print "Connection is successful !!\n";

return $dbh;

}

 

 

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

sub calRuleScore{

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

my ($orgId,$rundate,$cardId )= @_; 

print("calRuleScore para : $orgId  \n");

my $orgInfoSQL = " 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 = $orgId union all ".

"select a.branch_id,a.branch_name,a.par_branch_id,c.leveld+1 from bohz_appmds.tap_c_branch_all a ,temporg c where  c.id = a.par_branch_id and leveld<7)".

"select id from temporg";

 

my $sth = $dbh->prepare($orgInfoSQL) or return -1;

my $ret = $sth->execute() or return -1;  

my $orgInfo = $sth->fetchall_arrayref();

$sth->finish();

my $orgPin ;

for(my $i = 0 ;$i<$#${orgInfo};$i++){

 

$orgPin = $orgPin."'".$orgInfo->[$i][0]."',";

}

$orgPin = $orgPin."'".$orgInfo->[$#${orgInfo}][0]."'";

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

 

#1.当前机构的通过率，应该是包含所有下级的统计值

my $resultSQL = 

"select main.check_id, weight,main.pass_rate,main.pass_rate*weight*100 as score ".

"from ".

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

"from appdqc.check_result where rundate=date'$rundate' and org_id in ($orgPin) group by check_id) main ".

"inner join appdqc.estimate_checkid_relation r on main.check_id = r.check_id" ;

 

 

my $ruleScoresth = $dbh->prepare($resultSQL) or return -1;

my $ret = $ruleScoresth->execute() or return -1;  

 

#将每一个规则的得分，按照机构，日期的维度进行存储

while (@Fieldrow = $ruleScoresth->fetchrow() ) { # Fieldrow一维数组

 

my $check_id = "$Fieldrow[0]"; 

my $score = "$Fieldrow[3]";

print("check_id: $check_id,org_id: $orgId,score : $score  \n");

my $insertGroupSQL = "insert into appdqc.rule_score values(date'$rundate','$check_id','$orgId','$score','$cardId')";

my $sth = $dbh->prepare($insertGroupSQL) or  return -1;

my $ret = $sth->execute() or return -1;  

$sth->finish();

}

$ruleScoresth->finish();

print("-----------------------------calRuleScore   end -----------------------------\n");

return 0;

 

}

 

sub calNodeScore{

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

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

my $currNodeScore;

my $maxScore;

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

 

#计算当前节点的得分（需要递归计算所有下级的得分）

my $pfkSQL = "select folder_id,isleaf,weight from appdqc.estimate_group where status=1 and par_folder_id='$curr_folder_id'";

my $Nodesth = $dbh->prepare($pfkSQL) or  return -1;

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

while(my @Fieldrow = $Nodesth->fetchrow()){

my $child_folder_id = "$Fieldrow[0]";

my $isleaf = "$Fieldrow[1]";

if("0" eq $isleaf ){

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

my $scoreAndMaxScore = calNodeScore($child_folder_id,$orgId,$rundate);

my @childNodeScoreArr = split("#",$scoreAndMaxScore);

my $childNodeScore = @childNodeScoreArr[0];

my $childNodeMaxScore = @childNodeScoreArr[1];

$currNodeScore += $childNodeScore;

$maxScore += $childNodeMaxScore;

}else{

# 当前节点的叶子子节点

print ("$child_folder_id is  leafNode \n");

# 结果集理论只有一条

my $leafScoreSQL = "select ec.score,ec.weight from appdqc.estimate_card_score ec inner join estimate_group eg on ec.folder_id='$child_folder_id' "

."and ec.org_Id='$orgId' and rundate = date'$rundate' ";

 

my $Leafsth = $dbh->prepare($leafScoreSQL) or  return -1;

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

my @Fieldrow = $Leafsth->fetchrow();

my $s = "$Fieldrow[0]";

my $ms = "$Fieldrow[1]";

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

$currNodeScore += $s ;

$maxScore += $ms;

$Leafsth ->finish();

}

}

my $insertNodeScoreSQL = "insert into appdqc.estimate_card_score  ".

"select '$orgId',date'$rundate',folder_id,par_folder_id,folder_name,'$maxScore','$currNodeScore' from appdqc.estimate_group  ".

" where folder_id = $curr_folder_id";

my $insertNodesth = $dbh->prepare($insertNodeScoreSQL) or return -1;

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

$insertNodesth ->finish();

$Nodesth->finish();

 

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

return $currNodeScore."#".$maxScore;

}

 

#计算评分卡值得入口

sub calCardscore{

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

my ($nodeId,$runDate,$orgId) = @_;

my $cardScoreStr = calNodeScore($nodeId,$orgId,$runDate);#通过调用递归的计算节点的得分，最终求得评分卡最终的得分

my @cardScoreArr = split("#",$cardScoreStr);

my $cardScore = @cardScoreArr[0];

my $cardScoreMax = @cardScoreArr[1];

 

my $cardScoreinsert = "insert into appdqc.estimate_card_score ".

"select '$orgId',date'$runDate',folder_id,par_folder_id,folder_name,'$cardScoreMax','$cardScore' from appdqc.estimate_card ".

" where folder_id='$nodeId' and status='1' ";

 

my $cardScoresth = $dbh->prepare($cardScoreinsert) or return -1;

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

$cardScoresth->finish(); 

 

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

 

}

 

sub calLeafNodeScore{

my ($nodeId,$runDate,$orgId) = @_;

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

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

my $cardGroupsql = "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 ='$nodeId' union all ".

" select a.folder_id,a.folder_name,a.par_folder_id,a.isleaf,c.leveld+1 from appdqc.estimate_group a ,temptab c".

" where  c.id = a.par_folder_id and status='1' and leveld<7)".

" select id from temptab where isleaf = '1' ";

my $cardGroupsqlSth = $dbh->prepare($cardGroupsql) or return -1;

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

 

while(my @Fieldrow = $cardGroupsqlSth->fetchrow()){

my $groupId = "$Fieldrow[0]";

my $gs = "0";

my $groupId_rule_sql = "select er.check_id,er.weight*100,rs.score from appdqc.estimate_checkid_relation er ".

" inner join rule_score rs on er.check_id = rs.check_id  " . "where folder_id='$groupId' ".

" and status = '1' and org_id = '$orgId' and rundate = date'$runDate'"; 

my $groupId_rulegroupsth = $dbh->prepare($groupId_rule_sql) or return -1;

my $length = $groupId_rulegroupsth ->execute() or return -1;

 

my $maxScore="0";

my $gs = "0";

# 在评分组下的规则的权重和得分加权求和之后得到叶子评分组的得分

while(@Fieldrow = $groupId_rulegroupsth->fetchrow()){

my $s = "$Fieldrow[2]";

my $max = "$Fieldrow[1]";

$gs += $s;

$maxScore += $max;

}

$groupId_rulegroupsth ->finish();

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

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

# estiamte_card_score 联合唯一主键  orgId rundate folder_id

my $insertCardScoreSQL  = "insert into appdqc.estimate_card_score ".

"select '$orgId',date'$runDate',folder_id,par_folder_id,folder_name,'$maxScore','$gs' from appdqc.estimate_group ".

" where folder_id='$groupId' and status = '1' ";

# print "$insertCardScoreSQL \n";

my $insertCardScoresth = $dbh->prepare($insertCardScoreSQL) or return -1;

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

$insertCardScoresth ->finish();

 

}

$cardGroupsqlSth->finish();

print("--------------------------------calLeafNodeScore end  --------------------------\n");

}

 

sub main{

print "--------------------------------------------main begin--------------------------------------------\n ";

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

TDconnect();

 

my $rundatesql = "select max(rundate) from appdqc.check_result ";

my $rundateSth = $dbh->prepare($rundatesql) or return -1;

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

my @Fieldrow = $rundateSth->fetchrow();

#my $rundate = "$Fieldrow[0]";

$rundateSth ->finish();

my $rundate = $ARGV[0];

 

my $deleteHistory  = "delete from appdqc.estimate_card_score where rundate = date'$rundate' ;".

"delete from appdqc.rule_score where rundate = date'$rundate' ;";

 

my $deleteHistorySth = $dbh ->prepare($deleteHistory) or return -1;

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

$deleteHistorySth ->finish();

print("deleteHistory : succeed  \n");

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

 

#需要计算到三级机构的得分

 

my $getOrg = "select branch_id from  bohz_appmds.tap_c_branch where branch_id in ( '3401020316','3401040438','3401030216','3400008888','3401010008')order by branch_id " ;

my $getOrgsth = $dbh->prepare($getOrg) or return -1;

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

while(my @Fieldrow = $getOrgsth->fetchrow()){

my $branchId = "$Fieldrow[0]";

#print "*****一次只能计算一个评分卡 *********\n";

my $cardInfo = "select folder_id from appdqc.estimate_card where status = '1' and folder_id='1' ";

my $cardInfoSth = $dbh ->prepare($cardInfo) or return -1;

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

while(my @Fieldrow = $cardInfoSth->fetchrow()){

my $cardId = "$Fieldrow[0]";

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

calRuleScore($branchId,$rundate,$cardId);

calLeafNodeScore($cardId ,$rundate,$branchId);

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

}

 

}

$getOrgsth ->finish();

print "--------------------------------------------main end --------------------------------------------\n ";

}

 

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

sub GetNowDate{

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

$mon = sprintf("%02d", $mon+1);

$day = sprintf("%02d", $day);

my $stime = ($year+1900).$mon.$day;

return $stime;

}

 

my $rc = main();#函数的入口

exit($rc);