elink-star
/
esua-epdc-cloud
8
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
Browse Source

代码调整

feature/dangjian
yujintao 6 years ago
parent
3bce400f9e
commit
b5ef022149
6 changed files with 319 additions and 342 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 1
      esua-epdc/epdc-module/epdc-kpi/epdc-kpi-client/src/main/java/com/elink/esua/epdc/constant/KpiFieldConstant.java
  2. 5
      esua-epdc/epdc-module/epdc-kpi/epdc-kpi-server/src/main/java/com/elink/esua/epdc/controller/KpiRuleController.java
  3. 2
      esua-epdc/epdc-module/epdc-kpi/epdc-kpi-server/src/main/java/com/elink/esua/epdc/service/KpiRuleService.java
  4. 18
      esua-epdc/epdc-module/epdc-kpi/epdc-kpi-server/src/main/java/com/elink/esua/epdc/service/impl/KpiMetaDataServiceImpl.java
  5. 588
      esua-epdc/epdc-module/epdc-kpi/epdc-kpi-server/src/main/java/com/elink/esua/epdc/service/impl/KpiRuleServiceImpl.java
  6. 47
      esua-epdc/epdc-module/epdc-kpi/epdc-kpi-server/src/main/java/com/elink/esua/epdc/utils/KpiLocalDateUtils.java

1
esua-epdc/epdc-module/epdc-kpi/epdc-kpi-client/src/main/java/com/elink/esua/epdc/constant/KpiFieldConstant.java
View File

@ -15,6 +15,7 @@ public interface KpiFieldConstant {
String START_DATE = "START_DATE";
String END_DATE = "END_DATE";
String DEPT_ID = "DEPT_ID";
String KPI_CYCLE = "KPI_CYCLE";
String REFERENCE_ID = "REFERENCE_ID";
String DATA_CODE = "DATA_CODE";

5
esua-epdc/epdc-module/epdc-kpi/epdc-kpi-server/src/main/java/com/elink/esua/epdc/controller/KpiRuleController.java
View File

@ -158,7 +158,8 @@ public class KpiRuleController {
* @date 2019/12/17 17:04
*/
@GetMapping("calcByCode/{ruleCode}")
public Result<List<KpiRuleDTO>> calcByRuleCode(@PathVariable("ruleCode") String ruleCode) {
return kpiRuleService.calcByRuleCode(ruleCode);
public Result calcByRuleCode(@PathVariable("ruleCode") String ruleCode) {
kpiRuleService.calcByRuleCode(ruleCode);
return new Result();
}
}

2
esua-epdc/epdc-module/epdc-kpi/epdc-kpi-server/src/main/java/com/elink/esua/epdc/service/KpiRuleService.java
View File

@ -150,5 +150,5 @@ public interface KpiRuleService extends BaseService<KpiRuleEntity> {
**/
Result<List<KpiRuleDTO>> listKpiRuleDTO();
Result<List<KpiRuleDTO>> calcByRuleCode(String ruleCode);
void calcByRuleCode(String ruleCode);
}

18
esua-epdc/epdc-module/epdc-kpi/epdc-kpi-server/src/main/java/com/elink/esua/epdc/service/impl/KpiMetaDataServiceImpl.java
View File

@ -42,6 +42,7 @@ import com.elink.esua.epdc.enums.KpiMetaDataEnum;
import com.elink.esua.epdc.feign.EventFeignClient;
import com.elink.esua.epdc.service.KpiMetaDataService;
import com.elink.esua.epdc.utils.DeptUtils;
import com.elink.esua.epdc.utils.KpiLocalDateUtils;
import com.google.common.collect.Lists;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
@ -168,27 +169,14 @@ public class KpiMetaDataServiceImpl extends BaseServiceImpl<KpiMetaDataDao, KpiM
* @date 2019/12/20 09:13
*/
private KpiMetaDataOfEventsFormDTO initKpiParam(String kpiCycle, String methodName) {
LocalDate startDate = null;
YearMonth now = YearMonth.now();
if (KpiCycleEnum.KPI_CYCLE_MONTH.getValue().equals(kpiCycle)) {
startDate = now.minusMonths(NumConstant.ONE).atDay(NumConstant.ONE);
} else if (KpiCycleEnum.KPI_CYCLE_QUARTER.getValue().equals(kpiCycle)) {
int monthValue = now.getMonthValue();
if (monthValue == NumConstant.ONE || monthValue == NumConstant.FOUR || monthValue == NumConstant.SEVEN || monthValue == NumConstant.TEN) {
startDate = now.minusMonths(NumConstant.THREE).atDay(NumConstant.ONE);
}
} else if (KpiCycleEnum.KPI_CYCLE_YEAR.getValue().equals(kpiCycle)) {
if (now.getMonthValue() == NumConstant.ONE) {
startDate = now.minusMonths(NumConstant.TWELVE).atDay(NumConstant.ONE);
}
}
Date startDate = KpiLocalDateUtils.getKpiCycoleStartDate(kpiCycle);
if (null == startDate) {
log.error("当前时间：{}，无法按照{}执行绩效考核{}", LocalDateTime.now().toString(), kpiCycle, methodName);
return null;
}
log.info("开始执行：{}，当前时间：{}，考核周期：{}", methodName, LocalDateTime.now().toString(), kpiCycle);
KpiMetaDataOfEventsFormDTO metaDataFormDto = new KpiMetaDataOfEventsFormDTO();
metaDataFormDto.setStartDate(LocalDateUtils.localDateToDate(startDate));
metaDataFormDto.setStartDate(startDate);
metaDataFormDto.setEndDate(LocalDateUtils.localDateToDate(YearMonth.now().minusMonths(NumConstant.ONE).atEndOfMonth()));
return metaDataFormDto;
}

588
esua-epdc/epdc-module/epdc-kpi/epdc-kpi-server/src/main/java/com/elink/esua/epdc/service/impl/KpiRuleServiceImpl.java
View File

@ -19,10 +19,11 @@ package com.elink.esua.epdc.service.impl;
import cn.hutool.core.collection.CollUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.elink.esua.epdc.commons.mybatis.service.impl.BaseServiceImpl;
import com.elink.esua.epdc.commons.tools.constant.NumConstant;
import com.elink.esua.epdc.commons.tools.constant.OrganizationTypeConstant;
import com.elink.esua.epdc.commons.tools.constant.StrConstant;
import com.elink.esua.epdc.commons.tools.enums.YesOrNoEnum;
import com.elink.esua.epdc.commons.tools.exception.RenException;
import com.elink.esua.epdc.commons.tools.page.PageData;
@ -31,16 +32,16 @@ import com.elink.esua.epdc.commons.tools.constant.FieldConstant;
import com.elink.esua.epdc.commons.tools.utils.LocalDateUtils;
import com.elink.esua.epdc.commons.tools.utils.Result;
import com.elink.esua.epdc.constant.KpiFieldConstant;
import com.elink.esua.epdc.constant.KpiScheduleCodeConstant;
import com.elink.esua.epdc.dao.*;
import com.elink.esua.epdc.dto.*;
import com.elink.esua.epdc.dto.form.KpiMetaDataOfEventsFormDTO;
import com.elink.esua.epdc.dto.form.KpiRuleSaveOrUpdateFormDTO;
import com.elink.esua.epdc.dto.result.KpiRuleQueryResultDTO;
import com.elink.esua.epdc.entity.*;
import com.elink.esua.epdc.enums.KpiCycleEnum;
import com.elink.esua.epdc.enums.KpiRuleModeEnum;
import com.elink.esua.epdc.service.KpiRuleService;
import com.elink.esua.epdc.utils.DeptUtils;
import com.elink.esua.epdc.utils.KpiLocalDateUtils;
import com.google.common.collect.Lists;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
@ -54,7 +55,6 @@ import javax.script.Invocable;
import javax.script.ScriptEngine;
import javax.script.ScriptEngineManager;
import java.math.BigDecimal;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.YearMonth;
import java.util.*;
@ -69,24 +69,36 @@ import java.util.*;
@Service
public class KpiRuleServiceImpl extends BaseServiceImpl<KpiRuleDao, KpiRuleEntity> implements KpiRuleService {
private Logger logger = LoggerFactory.getLogger(getClass());
//公式参数表
/**
* 公式参数表
*/
@Autowired
private KpiRuleParamDao kpiRuleParamDao;
//绩效考核公式表
/**
* 绩效考核公式表
*/
@Autowired
private KpiFormulaDao kpiFormulaDao;
//考核规则表
/**
* 考核规则表
*/
@Autowired
private KpiRuleDao kpiRuleDao;
//绩效考核元数据表
/**
* 绩效考核元数据表
*/
@Autowired
private KpiMetaDataDao kpiMetaDataDao;
//网格考核最终得分表
/**
* 网格考核最终得分表
*/
@Autowired
private KpiResultGridDao kpiResultGridDao;
@Autowired
private DeptUtils deptUtils;
//网格考核最终得分
/**
* 网格考核最终得分
*/
@Autowired
private KpiResultSuperiorDao kpiResultSuperiorDao;
@ -291,361 +303,289 @@ public class KpiRuleServiceImpl extends BaseServiceImpl<KpiRuleDao, KpiRuleEntit
}
@Override
public Result<List<KpiRuleDTO>> calcByRuleCode(String ruleCode) {
if ("month_grid_work_score".equals(ruleCode)){ //计算 月度网格考核之平时工作成效
return this.calcWorkScoreByRuleCode(ruleCode);
}else if ("calcBaseGridFinalScore".equals(ruleCode)){ //计算 计算基础网格月度、季度、年度总得分
return this.calcBaseGridFinalScoreByRuleCode(ruleCode);
}else if ("calcDistrictStreetGeneralRule".equals(ruleCode)){ //计算区直/街道考核最终得分(总规则)
return this.calcDistrictStreetGeneralRule(ruleCode);
}
return new Result();
}
/**
* @Description: 计算 月度网格考核之平时工作成效
* @Param: [ruleCode]
* @return: com.elink.esua.epdc.commons.tools.utils.Result
* @Author: zy
* @Date: 2019-12-19
*/
public Result calcWorkScoreByRuleCode(String ruleCode){
public void calcByRuleCode(String ruleCode) {
// 查询考核规则表
KpiRuleDTO kpiRuleDTO = kpiRuleDao.queryKpiRuleMetaFormula(ruleCode);
//每次JOB启动时，根据当前时间，获取时间范围
Map<String, Date> mapDate = this.initKpiParam(kpiRuleDTO.getKpiCycle(), "calcWorkScoreByRuleCode");
if (mapDate != null){
// 根据 考核规则表-外键(公式id)，查询绩效考核公式表，待运行公式方法
KpiFormulaDTO kpiFormulaDTO = kpiFormulaDao.queryFormula(kpiRuleDTO.getReferenceId());
// 根据 考核规则表-主键，查询公式参数表,排序：1,2,3,4,5
List<KpiRuleParamDTO> ruleParamList = kpiRuleParamDao.queryFormulaParam(kpiRuleDTO.getId());
List<String> metaDateCodeList = Lists.newArrayList();
for (int i = 0; i < ruleParamList.size(); i++) {
metaDateCodeList.add(ruleParamList.get(i).getMetaDataCode());
}
int pageSize = NumConstant.THIRTY;
int pageIndex = NumConstant.ONE;
List<Long> deptIdList = deptUtils.getDeptIdList(OrganizationTypeConstant.ORG_TYPE_GRID_PARTY, pageSize, pageIndex);
do {
for (Long deptId : deptIdList) {
BigDecimal[] paramValue = selectArrayOfMetaDate(deptId, mapDate.get("startDate"), mapDate.get("endDate"), metaDateCodeList);
//参数准备完全时，执行js运算
if (paramValue.length == kpiFormulaDTO.getParamAmount()) {
BigDecimal workScore;
try {
//获得一个javascipt的执行引擎
ScriptEngine engine = new ScriptEngineManager().getEngineByName("javascript");
//执行js代码:参数为：公式运行方法
engine.eval(kpiFormulaDTO.getFormula());
//是否可调用方法
boolean flag = engine instanceof Invocable;
if (!flag) {
return new Result().error("运行方法异常");
}
Invocable in = (Invocable) engine;
//执行js中的函数 参数：js方法名 + 参数
Double result = (Double) in.invokeFunction(kpiFormulaDTO.getFunctionName(), paramValue);
Double workScoreDoouble = (double) Math.round(result * 100) / 100;
workScore = new BigDecimal(workScoreDoouble);
// 网格考核最终得分 表操作
KpiResultGridEntity kpiManualScoreEntity = new KpiResultGridEntity();
kpiManualScoreEntity.setWorkScore(workScore);
kpiManualScoreEntity.setGridId(deptId);
kpiManualScoreEntity.setStartDate(mapDate.get("startDate"));
kpiManualScoreEntity.setEndDate(mapDate.get("endDate"));
kpiManualScoreEntity.setKpiCycle(kpiRuleDTO.getKpiCycle());
this.saveOrUpdateKpiResult(kpiManualScoreEntity);
} catch (Exception e) {
e.printStackTrace();
return new Result().error("运行方法异常" + e.getMessage());
}
}
}
pageIndex++;
deptIdList = deptUtils.getDeptIdList(OrganizationTypeConstant.ORG_TYPE_GRID_PARTY, pageSize, pageIndex);
} while (CollUtil.isNotEmpty(deptIdList));
KpiRuleDTO kpiRule = kpiRuleDao.queryKpiRuleMetaFormula(ruleCode);
String ruleMode = kpiRule.getRuleMode();
if (StringUtils.isBlank(ruleMode) || !ruleMode.equals(KpiRuleModeEnum.FORMULA.value())) {
logger.error("规则编码{}对应的ruleMode不合法，方法中止。", ruleCode);
return;
}
return new Result();
}
/**
* @Description: 按规则代码计算基本网格最终分数
* @Param: [ruleCode]
* @return: com.elink.esua.epdc.commons.tools.utils.Result
* @Author: zy
* @Date: 2019-12-19
*/
public Result calcBaseGridFinalScoreByRuleCode(String ruleCode){
KpiResultGridEntity kpiResultGridEntity = new KpiResultGridEntity();
// 查询考核规则表
KpiRuleDTO kpiRuleDTO = kpiRuleDao.queryKpiRuleMetaFormula(ruleCode);
String kpiCycle = kpiRule.getKpiCycle();
Date startDate = KpiLocalDateUtils.getKpiCycoleStartDate(kpiCycle);
if (null == startDate) {
logger.error("当前时间：{}，无法按照规则编码{}计算绩效考核得分", LocalDateTime.now().toString(), ruleCode);
return;
}
// 考核结束日
Date endDate = LocalDateUtils.localDateToDate(YearMonth.now().minusMonths(NumConstant.ONE).atEndOfMonth());
// 根据 考核规则表-外键(公式id)，查询绩效考核公式表，待运行公式方法
KpiFormulaDTO kpiFormulaDTO = kpiFormulaDao.queryFormula(kpiRuleDTO.getReferenceId());
// 考核周期
String kpiCycle = kpiRuleDTO.getKpiCycle();
//每次JOB启动时，根据当前时间，获取时间范围
Map<String, Date> mapDate = this.initKpiParam(kpiCycle, "calcBaseGridFinalScoreByRuleCode");
if (mapDate != null) {
kpiResultGridEntity.setEndDate(mapDate.get("endDate"));
kpiResultGridEntity.setStartDate(mapDate.get("startDate"));
//查询网格最终得分:所有网格
List<KpiResultGridEntity> resultGrid = kpiResultGridDao.selectKpiResultGrid(kpiResultGridEntity);
for (KpiResultGridEntity kpi : resultGrid){
BigDecimal finalScore;
try {
//获得一个javascipt的执行引擎
ScriptEngine engine = new ScriptEngineManager().getEngineByName("javascript");
//执行js代码:参数为：公式运行方法
engine.eval(kpiFormulaDTO.getFormula());
//是否可调用方法
boolean flag = engine instanceof Invocable;
if (!flag) {
return new Result().error("运行方法异常");
KpiFormulaDTO kpiFormula = kpiFormulaDao.queryFormula(kpiRule.getReferenceId());
// 初始化JavaScript引擎
Invocable invocable = this.initInvocable(kpiFormula.getFormula(), ruleCode);
// 公式所有参数对应的元数据编码、升序排列
List<String> metaDateCodeList = this.getRuleParmOfMetaDateCodeList(kpiRule.getId());
// 公式参数数量
Integer paramAmount = kpiFormula.getParamAmount();
// 公式方法名
String functionName = kpiFormula.getFunctionName();
// 部门类别
String[] deptTypeKeyArray = kpiRule.getDeptTypeKey().split(StrConstant.COMMA);
if (deptTypeKeyArray.length > NumConstant.ZERO) {
for (String deptTypeKey : deptTypeKeyArray) {
int pageIndex = NumConstant.ONE;
List<Long> deptIdList = deptUtils.getDeptIdList(deptTypeKey, NumConstant.TWENTY, pageIndex);
do {
for (Long deptId : deptIdList) {
BigDecimal[] paramValue = selectArrayOfMetaDataValue(deptId, startDate, endDate, metaDateCodeList);
// 参数准备完全时，执行js运算
if (paramValue.length == paramAmount) {
// 执行js中的函数 参数：js方法名 + 参数
Double score = this.calcByJavaScript(invocable, functionName, ruleCode, paramValue);
this.packageFormulaResultToSaveOrUpdate(deptId, ruleCode, score, startDate, endDate, kpiCycle);
}
}
Invocable in = (Invocable) engine;
//执行js中的函数 参数：js方法名 + 参数
Double result = (Double) in.invokeFunction(kpiFormulaDTO.getFunctionName(), kpi.getManualScore(),kpi.getWorkScore());
Double finalScoreDoouble = (double) Math.round(result * 100) / 100;
finalScore = new BigDecimal(finalScoreDoouble);
// 网格考核最终得分 表操作
KpiResultGridEntity kpiManualScore = new KpiResultGridEntity();
kpiManualScore.setFinalScore(finalScore);
kpiManualScore.setId(kpi.getId());
kpiResultGridDao.updateById(kpiManualScore);
} catch (Exception e) {
e.printStackTrace();
return new Result().error("运行方法异常" + e.getMessage());
}
pageIndex++;
deptIdList = deptUtils.getDeptIdList(deptTypeKey, NumConstant.TWENTY, pageIndex);
} while (CollUtil.isNotEmpty(deptIdList));
}
}
return new Result();
}
private BigDecimal[] selectArrayOfMetaDate(Long deptId, Date startDate, Date endDate, List<String> metaDateCodeList) {
QueryWrapper<KpiMetaDataEntity> wrapper = new QueryWrapper<>();
wrapper.eq(KpiFieldConstant.START_DATE, startDate)
.eq(KpiFieldConstant.END_DATE, endDate)
.eq(KpiFieldConstant.DEPT_ID, deptId)
.in(KpiFieldConstant.DATA_CODE, metaDateCodeList);
List<KpiMetaDataEntity> metaDataList = kpiMetaDataDao.selectList(wrapper);
BigDecimal[] metaDataValueArray = new BigDecimal[metaDataList.size()];
/**
* 执行保存得分操作
*
* @param deptId 部门id
* @param ruleCode 考核规则编码
* @param score 得分
* @param startDate 开始日
* @param endDate 结束日
* @param kpiCycle 考核周期
* @return void
* @author work@yujt.net.cn
* @date 2019/12/25 10:56
*/
private void packageFormulaResultToSaveOrUpdate(Long deptId, String ruleCode, Double score, Date startDate, Date endDate, String kpiCycle) {
switch (ruleCode) {
/**
* 基础网格平时工作成效
*/
case KpiScheduleCodeConstant.GRID_WORK_SCORE_MONTH:
case KpiScheduleCodeConstant.GRID_WORK_SCORE_QUARTER:
case KpiScheduleCodeConstant.GRID_WORK_SCORE_YEAR:
this.saveOrUpdateGridKpiResult(deptId, score, startDate, endDate, kpiCycle);
break;
/**
* 基础网格考核最终得分
*/
case KpiScheduleCodeConstant.GRID_FINAL_SCORE_MONTH:
case KpiScheduleCodeConstant.GRID_FINAL_SCORE_QUARTER:
case KpiScheduleCodeConstant.GRID_FINAL_SCORE_YEAR:
this.updateGridKpiFinalScore(deptId, score, startDate, endDate, kpiCycle);
break;
/**
* 区直/街道考核最终得分
*/
case KpiScheduleCodeConstant.SUPERIOR_FINAL_SCORE_MONTH:
case KpiScheduleCodeConstant.SUPERIOR_FINAL_SCORE_QUARTER:
case KpiScheduleCodeConstant.SUPERIOR_FINAL_SCORE_YEAR:
this.saveSuperiorKpiResult(deptId, score, startDate, endDate, kpiCycle);
break;
default:
return;
}
}
String metaDataCode;
for (int i = 0; i < metaDateCodeList.size(); i++) {
metaDataCode = metaDateCodeList.get(i);
for (KpiMetaDataEntity kpiMetaDataEntity : metaDataList) {
if (kpiMetaDataEntity.getDataCode().equals(metaDataCode)) {
metaDataValueArray[i] = kpiMetaDataEntity.getDataValue();
}
}
/**
* 使用JavaScriptEngine执行运算方法
*
* @param invocable JavaScriptEngine引擎
* @param functionName JavaScript方法名
* @param ruleCode 考核规则编码
* @param paramValue JavaScript方法所需所有参数
* @return java.lang.Double
* @author work@yujt.net.cn
* @date 2019/12/25 10:28
*/
private Double calcByJavaScript(Invocable invocable, String functionName, String ruleCode, BigDecimal[] paramValue) {
try {
return (Double) invocable.invokeFunction(functionName, paramValue);
} catch (Exception e) {
logger.error("javascipt执行失败，当前时间：{}，考核规则编码：{}", LocalDateTime.now().toString(), ruleCode);
throw new RenException("绩效考核定时任务执行失败2");
}
return metaDataValueArray;
}
/**
* 更新或插入考核结果
* 更新网格考核结果表平时工作成效字段，更新失败则执行插入
*
* @param kpiResultGridEntity ： deptId, scoreStartDate, scoreEndDate, workScore
* @param deptId 网格id
* @param score 得分
* @param startDate 开始日
* @param endDate 结束日
* @param kpiCycle 考核周期
* @return void
* @author zhangyong
* @date 2019/12/18 15:56
* @author work@yujt.net.cn
* @date 2019/12/25 10:35
*/
private void saveOrUpdateKpiResult(KpiResultGridEntity kpiResultGridEntity) {
//运算结果存储在 网格考核最终得分表 manual_score字段,:唯一性条件(deptId,scoreStartDate,scoreEndDate)
KpiResultGridDTO kpiResultGridDto = getKpiresultGrid(kpiResultGridEntity.getGridId(), kpiResultGridEntity.getStartDate(), kpiResultGridEntity.getEndDate());
DeptLevelAndLeaderDTO deptLevelInfo = deptUtils.getDeptLevelInfo(kpiResultGridEntity.getGridId(), YesOrNoEnum.YES);
if (kpiResultGridDto != null) {
kpiResultGridEntity.setId(kpiResultGridDto.getId());
kpiResultGridEntity.setLeaderName(deptLevelInfo.getLeaderName());
kpiResultGridDao.updateById(kpiResultGridEntity);
} else {
kpiResultGridEntity.setParentDeptIds(deptLevelInfo.getParentDeptIds());
kpiResultGridEntity.setParentDeptNames(deptLevelInfo.getParentDeptNames());
kpiResultGridEntity.setAllDeptIds(deptLevelInfo.getAllDeptIds());
kpiResultGridEntity.setAllDeptNames(deptLevelInfo.getAllDeptNames());
kpiResultGridEntity.setLeaderName(deptLevelInfo.getLeaderName());
kpiResultGridDao.insert(kpiResultGridEntity);
private void saveOrUpdateGridKpiResult(Long deptId, Double score, Date startDate, Date endDate, String kpiCycle) {
KpiResultGridEntity gridKpiResultEntity = new KpiResultGridEntity();
BigDecimal kpiScore = BigDecimal.valueOf(score).setScale(NumConstant.TWO, BigDecimal.ROUND_HALF_UP);
gridKpiResultEntity.setWorkScore(kpiScore);
int update = kpiResultGridDao.update(gridKpiResultEntity, this.updateGridKpiResultWrapper(deptId, startDate, endDate, kpiCycle));
if (update == NumConstant.ZERO) {
gridKpiResultEntity.setGridId(deptId);
gridKpiResultEntity.setStartDate(startDate);
gridKpiResultEntity.setEndDate(endDate);
gridKpiResultEntity.setKpiCycle(kpiCycle);
kpiResultGridDao.insert(gridKpiResultEntity);
}
}
/**
* 查询考核结果
* 更新网格考核最终的得分字段
*
* @param deptId 部门id
* @param stateDate 开始日期
* @param endDate 结束日期
* @return com.elink.esua.epdc.dto.KpiResultGridDTO
* @author zy
* @date 2019/12/19 15:56
* @param deptId 网格id
* @param score 得分
* @param startDate 开始日
* @param endDate 结束日
* @param kpiCycle 考核周期
* @return void
* @author work@yujt.net.cn
* @date 2019/12/25 10:50
*/
private KpiResultGridDTO getKpiresultGrid(Long deptId, Date stateDate, Date endDate) {
Map<String, Object> map = new HashMap<>();
map.put("deptId", deptId);
map.put("scoreStartDate", stateDate);
map.put("scoreEndDate", endDate);
return kpiResultGridDao.selectManualScoringISExist(map);
private void updateGridKpiFinalScore(Long deptId, Double score, Date startDate, Date endDate, String kpiCycle) {
KpiResultGridEntity gridKpiResultEntity = new KpiResultGridEntity();
BigDecimal kpiScore = BigDecimal.valueOf(score).setScale(NumConstant.TWO, BigDecimal.ROUND_HALF_UP);
gridKpiResultEntity.setFinalScore(kpiScore);
kpiResultGridDao.update(gridKpiResultEntity, this.updateGridKpiResultWrapper(deptId, startDate, endDate, kpiCycle));
}
/**
* @Description: 计算区直/街道考核最终得分(总规则)
* @Param: [ruleCode]
* @return: com.elink.esua.epdc.commons.tools.utils.Result
* @Author: zy
* @Date: 2019-12-23
* 组装更新网格考核结果表的wrapper
*
* @param deptId 网格id
* @param startDate 开始日
* @param endDate 结束日
* @param kpiCycle 考核周期
* @return com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper<com.elink.esua.epdc.entity.KpiResultGridEntity>
* @author work@yujt.net.cn
* @date 2019/12/25 10:49
*/
public Result calcDistrictStreetGeneralRule(String ruleCode){
private UpdateWrapper<KpiResultGridEntity> updateGridKpiResultWrapper(Long deptId, Date startDate, Date endDate, String kpiCycle) {
UpdateWrapper<KpiResultGridEntity> wrapper = new UpdateWrapper<>();
wrapper.eq(FieldConstant.GRID_ID, deptId)
.eq(KpiFieldConstant.START_DATE, startDate)
.eq(KpiFieldConstant.END_DATE, endDate)
.eq(KpiFieldConstant.KPI_CYCLE, kpiCycle);
return wrapper;
}
/**
* 插入 街道/区直考核结果表
*
* @param deptId 部门id
* @param score 得分
* @param startDate 开始日
* @param endDate 结束日
* @param kpiCycle 考核周期
* @return void
* @author work@yujt.net.cn
* @date 2019/12/25 10:54
*/
private void saveSuperiorKpiResult(Long deptId, Double score, Date startDate, Date endDate, String kpiCycle) {
DeptLevelAndLeaderDTO deptLevelInfo = deptUtils.getDeptLevelInfo(deptId, YesOrNoEnum.YES);
KpiResultSuperiorEntity kpiResultSuperiorEntity = new KpiResultSuperiorEntity();
KpiRuleDTO kpiRuleDTO = kpiRuleDao.queryKpiRuleMetaFormula(ruleCode);// 查询考核规则表
// 考核周期
String kpiCycle = kpiRuleDTO.getKpiCycle();
//每次JOB启动时，根据当前时间，获取时间范围
Map<String, Date> mapDate = this.initKpiParam(kpiCycle, "calcDistrictStreetGeneralRule");
if (mapDate != null) {
kpiResultSuperiorEntity.setEndDate(mapDate.get("endDate"));
kpiResultSuperiorEntity.setStartDate(mapDate.get("startDate"));
kpiResultSuperiorEntity.setKpiCycle(kpiCycle);
// 根据 考核规则表-主键，查询公式参数表,排序：1,2,3,4,5,6
List<KpiRuleParamDTO> ruleParamList = kpiRuleParamDao.queryFormulaParam(kpiRuleDTO.getId());
List<String> metaDateCodeList = Lists.newArrayList();
for (int i = 0; i < ruleParamList.size(); i++) {
metaDateCodeList.add(ruleParamList.get(i).getMetaDataCode());
}
//区 考核最终得分计算
this.assessmentScoreCalculation(kpiRuleDTO.getReferenceId(),
kpiResultSuperiorEntity.getStartDate(),kpiResultSuperiorEntity.getEndDate(),
metaDateCodeList,OrganizationTypeConstant.ORG_TYPE_DISTRICT_DEPT,kpiCycle);
//街区 考核最终得分计算
this.assessmentScoreCalculation(kpiRuleDTO.getReferenceId(),
kpiResultSuperiorEntity.getStartDate(),kpiResultSuperiorEntity.getEndDate(),
metaDateCodeList,OrganizationTypeConstant.ORG_TYPE_STREET_DEPT,kpiCycle);
}
return new Result();
kpiResultSuperiorEntity.setStartDate(startDate);
kpiResultSuperiorEntity.setEndDate(endDate);
kpiResultSuperiorEntity.setKpiCycle(kpiCycle);
kpiResultSuperiorEntity.setFinalScore(BigDecimal.valueOf(score).setScale(NumConstant.TWO, BigDecimal.ROUND_HALF_UP));
kpiResultSuperiorEntity.setDeptId(deptId);
kpiResultSuperiorEntity.setDeptTypeKey(deptLevelInfo.getTypeKey());
kpiResultSuperiorEntity.setParentDeptIds(deptLevelInfo.getParentDeptIds());
kpiResultSuperiorEntity.setParentDeptNames(deptLevelInfo.getParentDeptNames());
kpiResultSuperiorEntity.setAllDeptIds(deptLevelInfo.getAllDeptIds());
kpiResultSuperiorEntity.setAllDeptNames(deptLevelInfo.getAllDeptNames());
kpiResultSuperiorDao.insert(kpiResultSuperiorEntity);
}
/**
* @Description: 根据 区直/街道考核最终得分 JS函数，得出总数
* @Param: [referenceId] 考核规则表:公式ID
* metaDateCodeList 公式参数表：元数据编码
* startDate 考核开始时间
* endDate 考核结束时间
* typeKey 部门类型
* String kpiCycle 考核周期
* @return: BigDecimal
* @Author: zy
* @Date: 2019-12-23
*/
public Result assessmentScoreCalculation(String referenceId,Date startDate, Date endDate,List<String> metaDateCodeList,String typeKey,String kpiCycle){
// 根据 考核规则表-外键(公式id)，查询绩效考核公式表，待运行公式方法
KpiFormulaDTO kpiFormulaDTO = kpiFormulaDao.queryFormula(referenceId);
int pageSize = NumConstant.THIRTY;
int pageIndex = NumConstant.ONE;
List<Long> deptIdList = deptUtils.getDeptIdList(typeKey, pageSize, pageIndex);
do {
for (Long deptId : deptIdList) {
BigDecimal[] paramValue = selectArrayOfMetaDate(deptId, startDate, endDate, metaDateCodeList);
//参数准备完全时，执行js运算
if (paramValue.length == kpiFormulaDTO.getParamAmount()) {
BigDecimal calculationScore;
Result<BigDecimal> score = this.runJavaScriptFunction(kpiFormulaDTO,paramValue);
calculationScore = score.getData();
//插入到：街道或区直绩效考核最终得分表
DeptLevelAndLeaderDTO deptLevelInfo = deptUtils.getDeptLevelInfo(deptId, YesOrNoEnum.YES);
KpiResultSuperiorEntity kpiResultSuperiorEntity = new KpiResultSuperiorEntity();
kpiResultSuperiorEntity.setStartDate(startDate);
kpiResultSuperiorEntity.setEndDate(endDate);
kpiResultSuperiorEntity.setKpiCycle(kpiCycle);
kpiResultSuperiorEntity.setFinalScore(calculationScore);
kpiResultSuperiorEntity.setDeptId(deptId);
kpiResultSuperiorEntity.setDeptTypeKey(typeKey);
kpiResultSuperiorEntity.setParentDeptIds(deptLevelInfo.getParentDeptIds());
kpiResultSuperiorEntity.setParentDeptNames(deptLevelInfo.getParentDeptNames());
kpiResultSuperiorEntity.setAllDeptIds(deptLevelInfo.getAllDeptIds());
kpiResultSuperiorEntity.setAllDeptNames(deptLevelInfo.getAllDeptNames());
kpiResultSuperiorDao.insert(kpiResultSuperiorEntity);
}
}
pageIndex++;
deptIdList = deptUtils.getDeptIdList(typeKey, pageSize, pageIndex);
} while (CollUtil.isNotEmpty(deptIdList));
return new Result();
/**
* 获取公式所有参数对应的元数据编码、升序排列
*
* @param ruleId 规则id
* @return java.util.List<java.lang.String>
* @author work@yujt.net.cn
* @date 2019/12/25 09:53
*/
private List<String> getRuleParmOfMetaDateCodeList(String ruleId) {
// 根据 考核规则表-主键，查询公式参数表,排序：1,2,3,4,5
List<KpiRuleParamDTO> ruleParamList = kpiRuleParamDao.queryFormulaParam(ruleId);
List<String> metaDateCodeList = Lists.newArrayList();
for (int i = 0; i < ruleParamList.size(); i++) {
metaDateCodeList.add(ruleParamList.get(i).getMetaDataCode());
}
return metaDateCodeList;
}
/**
* @Description: js函数运行
* @Param: [kpiFormulaDTO, paramValue]
* @return: com.elink.esua.epdc.commons.tools.utils.Result<BigDecimal>
* @Author: zy
* @Date: 2019-12-23
* 初始化javascipt的执行引擎
*
* @param formula 公式运行方法（Javascript）
* @param ruleCode 规则编码
* @return javax.script.Invocable
* @author work@yujt.net.cn
* @date 2019/12/24 17:22
*/
public Result<BigDecimal> runJavaScriptFunction(KpiFormulaDTO kpiFormulaDTO,BigDecimal[] paramValue){
BigDecimal calculationScore = new BigDecimal(0);
private Invocable initInvocable(String formula, String ruleCode) {
ScriptEngine engine = new ScriptEngineManager().getEngineByName("javascript");
//执行js代码:参数为：公式运行方法
try {
//获得一个javascipt的执行引擎
ScriptEngine engine = new ScriptEngineManager().getEngineByName("javascript");
//执行js代码:参数为：公式运行方法
engine.eval(kpiFormulaDTO.getFormula());
//是否可调用方法
boolean flag = engine instanceof Invocable;
if (!flag) {
return new Result().error("运行方法异常");
}
Invocable in = (Invocable) engine;
//执行js中的函数 参数：js方法名 + 参数
Double result = (Double) in.invokeFunction(kpiFormulaDTO.getFunctionName(), paramValue);
Double workScoreDoouble = (double) Math.round(result * 100) / 100;
calculationScore = new BigDecimal(workScoreDoouble);
engine.eval(formula);
} catch (Exception e) {
e.printStackTrace();
return new Result().error("运行方法异常" + e.getMessage());
logger.error("初始化javascipt执行引擎失败，当前时间：{}，考核规则编码：{}", LocalDateTime.now().toString(), ruleCode);
throw new RenException("绩效考核定时任务执行失败1");
}
// 是否可调用方法
boolean flag = engine instanceof Invocable;
if (!flag) {
logger.error("初始化javascipt执行引擎失败，当前时间：{}，考核规则编码：{}", LocalDateTime.now().toString(), ruleCode);
throw new RenException("绩效考核定时任务执行失败1");
}
return new Result().ok(calculationScore);
return (Invocable) engine;
}
/**
* 根据月、季、年 以及当前月份，初始化统计元数据值的参数，用于模块间调用
* 根据公式参数，获取公式参数对应的元数据值
*
* @param kpiCycle 月、季、年
* @param methodName 调用此方法的方法名，用于日志打印
* @return java.util.Date 若返回空值：当前月份无法针对传入的考核周期进行考核
* @author zhangyong
* @date 2019/12/24
* @param deptId 部门id
* @param startDate 考核周期开始日
* @param endDate 考核周期结束日
* @param metaDateCodeList 所有公式参数对应的元数据编码
* @return java.math.BigDecimal[]
* @author work@yujt.net.cn
* @date 2019/12/25 11:02
*/
private Map<String,Date> initKpiParam(String kpiCycle, String methodName) {
LocalDate startDate = null;
YearMonth now = YearMonth.now();
if (KpiCycleEnum.KPI_CYCLE_MONTH.getValue().equals(kpiCycle)) {
startDate = now.minusMonths(NumConstant.ONE).atDay(NumConstant.ONE);
} else if (KpiCycleEnum.KPI_CYCLE_QUARTER.getValue().equals(kpiCycle)) {
int monthValue = now.getMonthValue();
if (monthValue == NumConstant.ONE || monthValue == NumConstant.FOUR || monthValue == NumConstant.SEVEN || monthValue == NumConstant.TEN) {
startDate = now.minusMonths(NumConstant.THREE).atDay(NumConstant.ONE);
}
} else if (KpiCycleEnum.KPI_CYCLE_YEAR.getValue().equals(kpiCycle)) {
if (now.getMonthValue() == NumConstant.ONE) {
startDate = now.minusMonths(NumConstant.TWELVE).atDay(NumConstant.ONE);
private BigDecimal[] selectArrayOfMetaDataValue(Long deptId, Date startDate, Date endDate, List<String> metaDateCodeList) {
QueryWrapper<KpiMetaDataEntity> wrapper = new QueryWrapper<>();
wrapper.eq(KpiFieldConstant.START_DATE, startDate)
.eq(KpiFieldConstant.END_DATE, endDate)
.eq(KpiFieldConstant.DEPT_ID, deptId)
.in(KpiFieldConstant.DATA_CODE, metaDateCodeList);
List<KpiMetaDataEntity> metaDataList = kpiMetaDataDao.selectList(wrapper);
BigDecimal[] metaDataValueArray = new BigDecimal[metaDataList.size()];
String metaDataCode;
for (int i = 0; i < metaDateCodeList.size(); i++) {
metaDataCode = metaDateCodeList.get(i);
for (KpiMetaDataEntity kpiMetaDataEntity : metaDataList) {
if (kpiMetaDataEntity.getDataCode().equals(metaDataCode)) {
metaDataValueArray[i] = kpiMetaDataEntity.getDataValue();
}
}
}
if (null == startDate) {
log.error("当前时间：{}，无法按照{}执行绩效考核{}", LocalDateTime.now().toString(), kpiCycle, methodName);
return null;
}
log.info("开始执行：{}，当前时间：{}，考核周期：{}", methodName, LocalDateTime.now().toString(), kpiCycle);
Map<String,Date> map = new HashMap<String, Date>();
map.put("startDate", LocalDateUtils.localDateToDate(startDate));
map.put("endDate", LocalDateUtils.localDateToDate(YearMonth.now().minusMonths(NumConstant.ONE).atEndOfMonth()));
return map;
return metaDataValueArray;
}
}

47
esua-epdc/epdc-module/epdc-kpi/epdc-kpi-server/src/main/java/com/elink/esua/epdc/utils/KpiLocalDateUtils.java
View File

@ -0,0 +1,47 @@
package com.elink.esua.epdc.utils;
import com.elink.esua.epdc.commons.tools.constant.NumConstant;
import com.elink.esua.epdc.commons.tools.utils.LocalDateUtils;
import com.elink.esua.epdc.enums.KpiCycleEnum;
import java.time.LocalDate;
import java.time.YearMonth;
import java.util.Date;
/**
* 绩效考核相关日期工具
*
* @author work@yujt.net.cn
* @date 2019/12/24 17:26
*/
public class KpiLocalDateUtils {
/**
* 获取考核周期开始日
*
* @param kpiCycle 考核周期 月、季、年
* @return java.util.Date
* @author work@yujt.net.cn
* @date 2019/12/24 17:28
*/
public static Date getKpiCycoleStartDate(String kpiCycle) {
LocalDate startDate = null;
YearMonth now = YearMonth.now();
if (KpiCycleEnum.KPI_CYCLE_MONTH.getValue().equals(kpiCycle)) {
startDate = now.minusMonths(NumConstant.ONE).atDay(NumConstant.ONE);
} else if (KpiCycleEnum.KPI_CYCLE_QUARTER.getValue().equals(kpiCycle)) {
int monthValue = now.getMonthValue();
if (monthValue == NumConstant.ONE || monthValue == NumConstant.FOUR || monthValue == NumConstant.SEVEN || monthValue == NumConstant.TEN) {
startDate = now.minusMonths(NumConstant.THREE).atDay(NumConstant.ONE);
}
} else if (KpiCycleEnum.KPI_CYCLE_YEAR.getValue().equals(kpiCycle)) {
if (now.getMonthValue() == NumConstant.ONE) {
startDate = now.minusMonths(NumConstant.TWELVE).atDay(NumConstant.ONE);
}
}
if (null == startDate) {
return null;
}
return LocalDateUtils.localDateToDate(startDate);
}
}
Write Preview
Loading…
Cancel
Save