终于把个人覆盖率统计搞清楚了，还一鱼两吃

packagecom.github;
importcom.github.domain.AuthorStats;
importcom.github.domain.BlamedFile;
importcom.github.domain.BlamedJacocoLine;
importcom.github.domain.Line;
importorg.eclipse.jgit.api.BlameCommand;
importorg.eclipse.jgit.api.Git;
importorg.eclipse.jgit.api.errors.GitAPIException;
importorg.eclipse.jgit.blame.BlameResult;
importorg.eclipse.jgit.lib.PersonIdent;
importorg.eclipse.jgit.lib.Repository;
importjava.io.File;
importjava.io.IOException;
importjava.nio.file.Files;
importjava.nio.file.Path;
importjava.nio.file.Paths;
importjava.util.ArrayList;
importjava.util.List;
importjava.util.Map;
importjava.util.concurrent.ConcurrentHashMap;
importjava.util.concurrent.ExecutorService;
importjava.util.concurrent.Executors;
importjava.util.concurrent.TimeUnit;
importjava.util.stream.Collectors;
importjava.util.stream.Stream;
publicclassGitBlameConcurrentProcessor{
publicstaticList<BlamedJacocoLine>blamedJacocoLines=newArrayList<>();
/*
1）通过GitBlame可以拿到每个代码文件的每一行的行号、内容、最后修改者、commit等数据
2）通过Jacoco获取到(增量）代码覆盖率报告
3）缝合两者的数据，通过行号关联人+覆盖的数据
4）根据人聚合出每个开发人员应该负责代码行数和被覆盖的代码行数
5）计算出谁的行覆盖率没达标
6）分支覆盖也类似套路
*/
publicstaticvoidmain(String[]args)throwsIOException{
longstart=System.currentTimeMillis();
StringjacocoReportPath="D:\\antony\\repo\\redis-embedded-server\\target\\site\\jacoco\\jacoco.xml";
StringgitRepoPath="D:\\antony\\repo\\redis-embedded-server";
ConcurrentHashMap<String,BlamedFile>resultMap=newConcurrentHashMap<>();
//1-通过GitBlame可以拿到每个代码文件的每一行的行号、内容、最后修改者、commit等数据
gitBlamedFiles(gitRepoPath,resultMap);
//2-通过Jacoco获取到(增量）代码覆盖率报告
List<XmlReportParser.SourceFile>sourceFiles=
(newXmlReportParser(Paths.get(jacocoReportPath))).parse();
//上述parser是从sonar-jacoco-plugin项目里扒拉过来的一个工具类
//3-缝合两者的数据，通过行号关联人+覆盖的数据
bindJacocoWithBlameResult(sourceFiles,resultMap);
//结果保存到了List<BlamedJacocoLine>blamedJacocoLines中
//如果2中提供的是生成的增量覆盖率报告，则此处得到的也就是增量的个人报告了
//4-找出每个开发人员的代码覆盖率
//每个author的汇总
Map<String,AuthorStats>authorStatsMap=getAuthorTotalCoverage(blamedJacocoLines);
System.out.println("totalfilesblamed:"+sourceFiles.size());
System.out.println(authorStatsMap);
System.out.println("totaltimeused(second):"+(System.currentTimeMillis()-start)/1000);
}
staticMap<String,AuthorStats>getAuthorTotalCoverage(List<BlamedJacocoLine>blamedJacocoLines){
Map<String,AuthorStats>authorStatsMap=blamedJacocoLines.stream()
.collect(Collectors.groupingBy(BlamedJacocoLine::getAuthor,
Collectors.collectingAndThen(
Collectors.partitioningBy(line->line.getCoveredInstrs()>0,Collectors.counting()),
partitioningByResult->
AuthorStats.builder()
.coveredLines(partitioningByResult.get(true))
.missedLines(partitioningByResult.get(false))
.build())));
returnauthorStatsMap;
}
publicstaticvoidgitBlamedFiles(StringgitRepoPath,ConcurrentHashMap<String,BlamedFile>resultMap)throwsIOException{
longstart=System.currentTimeMillis();
//InitializeJGitRepository
Repositoryrepository=initRepository(gitRepoPath);
ExecutorServiceexecutorService=Executors.newFixedThreadPool(20);
List<String>fileNames=walkFiles(gitRepoPath);
List<String>converted=relativePath(fileNames,gitRepoPath);
for(StringfileName:converted){
executorService.execute(()->{
BlameResultblameResult=runBlameCommand(repository,fileName);
if(blameResult!=null){
BlamedFileblamedFile=BlamedFile.builder().name(fileName).lines(newArrayList<>()).build();
processBlameResult(blameResult,blamedFile);
resultMap.put(fileName,blamedFile);
}
});
}
executorService.shutdown();
try{
executorService.awaitTermination(Long.MAX_VALUE,TimeUnit.NANOSECONDS);
}catch(InterruptedExceptione){
e.printStackTrace();
}
//Don'tforgettoclosetherepositorywhendone
repository.close();
System.out.println("totalfilesblamed:"+converted.size());
System.out.println("totaltimeused(second):"+(System.currentTimeMillis()-start)/1000);
}
publicstaticvoidbindJacocoWithBlameResult(List<XmlReportParser.SourceFile>sourceFiles,ConcurrentHashMap<String,BlamedFile>resultMap){
for(XmlReportParser.SourceFilesourceFile:sourceFiles){//package+filename
StringfullName=("src/main/java/"+sourceFile.packageName()+"/"+sourceFile.name()).replace('\\','/');
if(resultMap.containsKey(fullName)){
System.out.println("matched::"+fullName);
BlamedFilefile=resultMap.get(fullName);
List<Line>blamedLines=file.getLines();
for(XmlReportParser.Lineline:sourceFile.lines()){
BlamedJacocoLineblamedJacocoLine=BlamedJacocoLine.builder()
.coveredBranches(line.coveredBranches())
.missedBranches(line.missedBranches())
.coveredInstrs(line.coveredInstrs())
.missedInstrs(line.missedInstrs())
.fileName(fullName).build();
for(LineblamedLine:blamedLines){
if(line.number()==blamedLine.getNumber()){
blamedJacocoLine.setAuthor(blamedLine.getAuthor());
blamedJacocoLine.setCommit(blamedLine.getCommit());
blamedJacocoLine.setWhen(blamedLine.getWhen());
blamedJacocoLine.setNumber(blamedLine.getNumber());
}
}
blamedJacocoLines.add(blamedJacocoLine);
}
}
}
}
publicstaticList<String>walkFiles(StringrepoPath)throwsIOException{
Pathbase=Paths.get(repoPath);
Stream<Path>walk=Files.walk(base);
List<String>fileList=walk.map(x->x.toString())
.filter(f->f.endsWith(".java"))
.collect(Collectors.toList());
returnfileList;
}
publicstaticList<String>relativePath(List<String>files,StringrepoPath){
List<String>relativePathFiles=newArrayList<>();
Pathbase=Paths.get(repoPath);
for(Stringfile:files){
PathrelativePath=base.relativize(Paths.get(file));
StringfileReplaced=relativePath.toString().replace('\\','/');
relativePathFiles.add(fileReplaced);
}
returnrelativePathFiles;
}
privatestaticRepositoryinitRepository(StringgitRepoPath){
try{
returnGit.open(newFile(gitRepoPath)).getRepository();
}catch(IOExceptione){
e.printStackTrace();
returnnull;
}
}
privatestaticBlameResultrunBlameCommand(Repositoryrepository,StringfileName){
try{
BlameCommandblameCommand=newBlameCommand(repository);
blameCommand.setFilePath(fileName);
returnblameCommand.call();
}catch(GitAPIExceptione){
e.printStackTrace();
returnnull;
}
}
privatestaticvoidprocessBlameResult(BlameResultblameResult,BlamedFileblamedFile){
//ProcesstheblameResultandreturnthedesiredinformation
for(inti=0;i<blameResult.getResultContents().size();i++){
PersonIdentpersonIdent=blameResult.getSourceAuthor(i);
intnumber=i+1;//linenumstartwith1
Stringauthor=personIdent.getEmailAddress();
Stringcommit=blameResult.getSourceCommit(i).getName();
Stringdate=personIdent.getWhen().toString();
//TODO:fixtimeZone
Lineline=Line.builder().author(author).commit(commit).when(date).number(number).build();
blamedFile.getLines().add(line);
}}}