|
|
@ -38,6 +38,7 @@ import org.springframework.stereotype.Service; |
|
|
import org.springframework.transaction.annotation.Transactional; |
|
|
import org.springframework.transaction.annotation.Transactional; |
|
|
import org.springframework.util.CollectionUtils; |
|
|
import org.springframework.util.CollectionUtils; |
|
|
|
|
|
|
|
|
|
|
|
import javax.naming.LinkLoopException; |
|
|
import java.math.BigDecimal; |
|
|
import java.math.BigDecimal; |
|
|
import java.math.RoundingMode; |
|
|
import java.math.RoundingMode; |
|
|
import java.util.*; |
|
|
import java.util.*; |
|
|
@ -183,7 +184,7 @@ public class FactOriginProjectLogDailyServiceImpl extends BaseServiceImpl<FactOr |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/** |
|
|
/** |
|
|
* @Description 查询机关单位经手的项目数，去重 |
|
|
* @Description 办结率 |
|
|
* @param agencies |
|
|
* @param agencies |
|
|
* @param dimId |
|
|
* @param dimId |
|
|
* @param dateType - 日期维度类型 month date week quarter year |
|
|
* @param dateType - 日期维度类型 month date week quarter year |
|
|
@ -192,59 +193,88 @@ public class FactOriginProjectLogDailyServiceImpl extends BaseServiceImpl<FactOr |
|
|
* @date 2020.09.23 10:06 |
|
|
* @date 2020.09.23 10:06 |
|
|
**/ |
|
|
**/ |
|
|
@Override |
|
|
@Override |
|
|
public Map<String, Integer> getCountOfDealingAgency(List<String> agencies, String customerId,String dimId, String dateType) { |
|
|
public Map<String, BigDecimal> getHandlingRatio(List<String> agencies, String customerId,String dimId, String dateType) { |
|
|
Map<String,Integer> result = new HashMap<>(); |
|
|
//计算方式：“评价周期内被吹哨且办结(无论是哪一级办结)的项目数”/“评价周期内被吹哨的所有项目数”
|
|
|
List<ProjectParticipatedAgencyResultDTO> projectAgencyCount = baseDao.selectProjectParticipatedAgency(agencies,customerId,dimId); |
|
|
|
|
|
|
|
|
Map<String,BigDecimal> result = new HashMap<>(); |
|
|
|
|
|
List<ProjectParticipatedAgencyResultDTO> projectAgencyCount = baseDao.selectWhistledAgencyClosedProjectCount(agencies,customerId,dimId); |
|
|
if(!CollectionUtils.isEmpty(projectAgencyCount)){ |
|
|
if(!CollectionUtils.isEmpty(projectAgencyCount)){ |
|
|
result = projectAgencyCount.stream().collect(Collectors.toMap(ProjectParticipatedAgencyResultDTO::getAgencyId,ProjectParticipatedAgencyResultDTO::getCount)); |
|
|
Map<String,Integer> whistledAndHandledProjectTotalMap = projectAgencyCount.stream().collect(Collectors.toMap(ProjectParticipatedAgencyResultDTO::getAgencyId,ProjectParticipatedAgencyResultDTO::getCount)); |
|
|
|
|
|
List<ProjectParticipatedAgencyResultDTO> whistledProjectTotal = baseDao.selectAgencyWhistledCount(agencies,customerId,dimId); |
|
|
|
|
|
Map<String,Integer> whistledProjectTotalMap = whistledProjectTotal.stream().collect(Collectors.toMap(ProjectParticipatedAgencyResultDTO::getAgencyId,ProjectParticipatedAgencyResultDTO::getCount)); |
|
|
|
|
|
whistledAndHandledProjectTotalMap.forEach((agencyId,count) -> { |
|
|
|
|
|
//分母 被吹哨项目数
|
|
|
|
|
|
Integer denominator = whistledProjectTotalMap.get(agencyId); |
|
|
|
|
|
if(null == denominator || NumConstant.ZERO == denominator){ |
|
|
|
|
|
result.put(agencyId,BigDecimal.ZERO); |
|
|
|
|
|
}else{ |
|
|
|
|
|
result.put(agencyId,new BigDecimal(count).divide(new BigDecimal(denominator), NumConstant.SIX, RoundingMode.HALF_UP)); |
|
|
|
|
|
} |
|
|
|
|
|
}); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
return result; |
|
|
return result; |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
/** |
|
|
/** |
|
|
* @Description 计算机关办结项目效率 |
|
|
* @Description 计算机关办结项目效率 |
|
|
* @param agencies |
|
|
* @param |
|
|
* @return |
|
|
* @return |
|
|
* @author wangc |
|
|
* @author wangc |
|
|
* @date 2020.09.21 02:16 |
|
|
* @date 2020.09.21 02:16 |
|
|
**/ |
|
|
**/ |
|
|
@Override |
|
|
@Override |
|
|
public Map<String, BigDecimal> getAgencyWorkPieceRatio(List<String> agencies, String customerId,String dimId, String dateType) { |
|
|
public Map<String, BigDecimal> getAgencyWorkPieceRatio(String customerId,String dimId, String dateType) { |
|
|
//网格、部门的办结系数
|
|
|
//计算方法 : 评价周期内办结项目的平均处理时长的倒数
|
|
|
List<OrgResponseTimeResultDTO> gridDeptResponse = projectOrgPeriodDailyDao.selectSubOrgResponseCoefficient(customerId, dimId, dateType); |
|
|
|
|
|
//机关的办结系数
|
|
|
|
|
|
List<OrgResponseTimeResultDTO> agencyResponse = projectOrgPeriodDailyDao.selectAgencyResponseCoefficient(customerId, dimId, dateType); |
|
|
//1.评价周期内结案了的项目
|
|
|
Map<String,BigDecimal> consumingMap = new HashMap<>(); |
|
|
List<ProjectParticipatedAgencyResultDTO> projectsHandledByAgency = baseDao.selectProjectIdHandledByAgency(customerId,dimId); |
|
|
Map<String,BigDecimal> timeMap = new HashMap<>(); |
|
|
|
|
|
if(!CollectionUtils.isEmpty(agencyResponse)){ |
|
|
|
|
|
agencyResponse.forEach(response -> { |
|
|
|
|
|
consumingMap.put(response.getAgencyId(),response.getResponseTime()); |
|
|
|
|
|
//注意，这里取的是去重后的项目次数，例如一个部门被项目流转了多次，项目数只算一次
|
|
|
|
|
|
//如果需要改成不去重，只需response.getProjectTotal()
|
|
|
|
|
|
timeMap.put(response.getAgencyId(),response.getDistinctProjectTotal()); |
|
|
|
|
|
}); |
|
|
|
|
|
} |
|
|
|
|
|
if(!CollectionUtils.isEmpty(gridDeptResponse)){ |
|
|
|
|
|
gridDeptResponse.forEach(response -> { |
|
|
|
|
|
if(null != consumingMap.get(response.getAgencyId())){ |
|
|
|
|
|
consumingMap.put(response.getAgencyId(),consumingMap.get(response.getAgencyId()).add(response.getResponseTime())); |
|
|
|
|
|
timeMap.put(response.getAgencyId(),timeMap.get(response.getAgencyId()).add(response.getDistinctProjectTotal())); |
|
|
|
|
|
}else{ |
|
|
|
|
|
consumingMap.put(response.getAgencyId(),response.getResponseTime()); |
|
|
|
|
|
timeMap.put(response.getAgencyId(),response.getDistinctProjectTotal()); |
|
|
|
|
|
} |
|
|
|
|
|
}); |
|
|
|
|
|
} |
|
|
|
|
|
//效率map
|
|
|
|
|
|
Map<String,BigDecimal> efficiencyMap = new HashMap<>(); |
|
|
Map<String,BigDecimal> efficiencyMap = new HashMap<>(); |
|
|
if(!CollectionUtils.isEmpty(consumingMap)) { |
|
|
if(!CollectionUtils.isEmpty(projectsHandledByAgency)){ |
|
|
consumingMap.keySet().forEach(agencyId -> { |
|
|
Map<String,List<String>> agencyProjectsMap = new HashMap<>(); |
|
|
efficiencyMap.put(agencyId, consumingMap.get(agencyId).divide(timeMap.get(agencyId), NumConstant.SIX, RoundingMode.HALF_UP)); |
|
|
|
|
|
|
|
|
projectsHandledByAgency.forEach(o -> { |
|
|
|
|
|
String agencyId = o.getAgencyId(); |
|
|
|
|
|
String projectId = o.getProjectId(); |
|
|
|
|
|
if(CollectionUtils.isEmpty(agencyProjectsMap.get(agencyId))){ |
|
|
|
|
|
List<String> projectUnit = new LinkedList<>(); |
|
|
|
|
|
projectUnit.add(projectId); |
|
|
|
|
|
agencyProjectsMap.put(agencyId,projectUnit); |
|
|
|
|
|
}else{ |
|
|
|
|
|
agencyProjectsMap.get(agencyId).add(projectId); |
|
|
|
|
|
} |
|
|
|
|
|
}); |
|
|
|
|
|
|
|
|
|
|
|
List<String> projects = new LinkedList<>(); |
|
|
|
|
|
agencyProjectsMap.forEach((key,value) -> {projects.addAll(value);}); |
|
|
|
|
|
//2.结案项目的总耗时
|
|
|
|
|
|
List<ProjectParticipatedAgencyResultDTO> costTimes = baseDao.selectProjectCostTime(projects); |
|
|
|
|
|
|
|
|
|
|
|
Map<String,Integer> projectCostTime = costTimes.stream().collect(Collectors.toMap(ProjectParticipatedAgencyResultDTO::getProjectId,ProjectParticipatedAgencyResultDTO::getCount)); |
|
|
|
|
|
agencyProjectsMap.forEach((k,v) -> { |
|
|
|
|
|
//k -> agencyId v -> projects
|
|
|
|
|
|
int total = NumConstant.ZERO; |
|
|
|
|
|
if(!CollectionUtils.isEmpty(v)){ |
|
|
|
|
|
for(String p : v){ |
|
|
|
|
|
Integer cost = projectCostTime.get(p); |
|
|
|
|
|
total = total + (null == cost ? NumConstant.ZERO : cost); |
|
|
|
|
|
} |
|
|
|
|
|
//每个机关的项目平均耗时
|
|
|
|
|
|
BigDecimal avgCost = new BigDecimal(total).divide(new BigDecimal(v.size()),4, BigDecimal.ROUND_HALF_UP); |
|
|
|
|
|
|
|
|
|
|
|
efficiencyMap.put(k,BigDecimal.ONE.divide(avgCost,4, BigDecimal.ROUND_HALF_UP)); |
|
|
|
|
|
|
|
|
|
|
|
}else{ |
|
|
|
|
|
efficiencyMap.put(k,BigDecimal.ZERO); |
|
|
|
|
|
} |
|
|
}); |
|
|
}); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
return efficiencyMap; |
|
|
return efficiencyMap; |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
@Override |
|
|
public List<OrgStatisticsResultDTO> getGridResponse(String customerId, String monthId) { |
|
|
public List<OrgStatisticsResultDTO> getGridResponse(String customerId, String monthId) { |
|
|
return baseDao.selectGridResponse(customerId, monthId); |
|
|
return baseDao.selectGridResponse(customerId, monthId); |
|
|
|
jianjun
5 years ago