123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239 |
- package com.kingdee.eas.hr.perf.handler;
- import com.google.common.collect.Maps;
- import com.google.common.collect.Sets;
- import com.kingdee.bos.BOSException;
- import com.kingdee.bos.Context;
- import com.kingdee.bos.rabbitmq.guava.Lists;
- import com.kingdee.eas.custom.performanceScoring.handler.EvaResultSummaryManagerListHandlerEx;
- import com.kingdee.eas.hr.perf.PerformProTeamCollection;
- import com.kingdee.eas.hr.perf.PerformProTeamFactory;
- import com.kingdee.eas.hr.perf.PersonPerformProCollection;
- import com.kingdee.eas.hr.perf.PersonPerformProFactory;
- import com.kingdee.eas.util.app.DbUtil;
- import com.kingdee.jdbc.rowset.IRowSet;
- import com.kingdee.shr.base.syssetting.api.bean.BatchMessageTipsHeader;
- import com.kingdee.shr.base.syssetting.context.SHRContext;
- import com.kingdee.shr.base.syssetting.exception.SHRWebException;
- import com.kingdee.shr.base.syssetting.exception.ShrWebBizException;
- import com.kingdee.shr.perfweb.app.base.evalplan.EvalplanCycleTypeEnum;
- import com.kingdee.shr.perfweb.app.exception.SHRPerfWebBizException;
- import com.kingdee.util.StringUtils;
- import org.slf4j.Logger;
- import org.slf4j.LoggerFactory;
- import org.springframework.ui.ModelMap;
- import javax.servlet.http.HttpServletRequest;
- import javax.servlet.http.HttpServletResponse;
- import java.math.BigDecimal;
- import java.sql.SQLException;
- import java.text.SimpleDateFormat;
- import java.time.LocalDate;
- import java.time.format.DateTimeFormatter;
- import java.util.*;
- public class EvaResultSummaryManagerListHandlerExEx extends EvaResultSummaryManagerListHandlerEx {
- private static final Logger logger = LoggerFactory.getLogger(EvaResultSummaryManagerListHandlerExEx.class);
- /**
- * 项目经理校验
- * @param request
- * @param response
- * @param modelMap
- */
- public void tempAction(HttpServletRequest request, HttpServletResponse response, ModelMap modelMap) throws BOSException, SHRWebException {
- Context ctx = SHRContext.getInstance().getContext();
- List<String> idList = Lists.newArrayList();
- String ids = (String) this.getBillId(request);
- for (String id : ids.split(",")) {
- idList.add(id);
- }
- StringBuilder selParamId = new StringBuilder("''");
- for (int i = 0; i < idList.size(); i++) {
- selParamId.append(",?");
- }
- StringBuilder sql = new StringBuilder();
- sql.append(" select ers.fid,pp.FPSTARTDATE,ers.FADMINORGUNITID,ers.FADMINORGNAME,pp.FYEAR,pp.FTIMEPERIOD, ");
- sql.append(" pp.FCYCLETYPE,pp.FPENDDATE,pp.FPSTARTDATE,ppn.CFPEROBJECTIDID,ppm.CFPROJECTNAME,pmm.CFEMPLOYEEID ");
- sql.append(" from T_EVA_EvaResultSummary ers ");
- sql.append(" left join T_EVA_PerfPlan ppn on ers.FEVAPLANID=ppn.fid ");
- sql.append(" left join T_EVA_PerfPeriod pp on ers.FPERIODID=pp.fid ");
- sql.append(" left join CT_PRO_ProjectManagement ppm on ppn.CFPEROBJECTIDID=ppm.fid ");
- sql.append(" left join CT_PRO_MemberManagement pmm on ppm.fid=pmm.CFPROJECTMANAGEMENID and pmm.CFSTATE=1 ");
- sql.append(" and pmm.CFPTYPEID in( ");
- sql.append(" select fid from CT_PRO_ProjectType where FNUMBER='ProjectManager') ");
- sql.append(" and pmm.CFPROJECTROLEID in( ");
- sql.append(" select fid from CT_PRO_ProjectRole where FNUMBER ='HTY110') ");
- sql.append(" where ers.fid in (");
- sql.append(selParamId);
- sql.append(") ");
- sql.append(" and pmm.CFEMPLOYEEID=ers.fpersonid ");
- IRowSet rs = DbUtil.executeQuery(ctx, sql.toString(), idList.toArray());
- Map<String, String> map = Maps.newHashMap();
- map.put("ProjectManager",rs.size()>0?"1":"0");
- this.writeSuccessData(map);
- }
- @Override
- protected void setInitData(HttpServletRequest request, HttpServletResponse response, ModelMap modelMap, Map<String, Object> initData) throws SHRWebException {
- super.setInitData(request, response, modelMap, initData);
- Context ctx = SHRContext.getInstance().getContext();
- try {
- Map<String, Object> custom_params = (Map<String, Object>) initData.get("custom_params");
- String perfPlanId = (String) custom_params.get("perfPlanId");
- StringBuilder planSql = new StringBuilder();
- planSql.append(" select pp.fid,pp.CFPerobjectIdId,ppm.CFPROJECTNAME from T_EVA_PerfPlan pp ");
- planSql.append(" left join CT_PRO_ProjectManagement ppm on ppm.fid = pp.CFPerobjectIdId where pp.fid=? and pp.CFPerobjectIdId is not null");
- IRowSet rs = DbUtil.executeQuery(ctx, planSql.toString(), new Object[]{perfPlanId});
- if (rs.next()) {
- String perobjectId = rs.getString("CFPerobjectIdId");
- String projectName = rs.getString("CFPROJECTNAME");
- custom_params.put("projectName",projectName);
- custom_params.put("perobjectId",perobjectId);
- initData.put("perobjectId",perobjectId);
- initData.put("projectName",projectName);
- }else {
- custom_params.put("perobjectId","");
- custom_params.put("projectName","");
- initData.put("perobjectId","");
- initData.put("projectName","");
- }
- }catch (Exception e){
- e.printStackTrace();
- }
- }
- /**
- * 获取人员项目正态分布规则
- *
- * @param ctx
- * @param idList 非必填
- * @param batchMessage 非必填
- * @return
- * @throws BOSException
- * @throws SQLException
- */
- public Map<String, Map<String, BigDecimal>> getProjectPerformPro(Context ctx, List<String> idList, Map<String, String> batchMessage) throws BOSException, SQLException {
- //获取正态分布规则
- Map<String, Map<String, BigDecimal>> orgLevelMap = Maps.newHashMap();
- PerformProTeamCollection proCollection = PerformProTeamFactory.getLocalInstance(ctx).getPerformProTeamCollection(" where status=1 ");
- if (proCollection.size() == 1) {
- StringBuilder orgPerSql = new StringBuilder();
- orgPerSql.append(" select fp.fid,fpe.CFS,fpe.CFA,fpe.CFB,fpe.CFC,fpe.CFD,fpe.CFORGPERFORMTYPE ");
- orgPerSql.append(" from CT_PF_PerformProTeam fp ");
- orgPerSql.append(" left join CT_PF_PerformProTeamEntry fpe on fp.fid=fpe.FPARENTID ");
- orgPerSql.append(" where fp.CFSTATUS = 1 ");
- orgPerSql.append(" order by fp.FCREATETIME ");
- IRowSet rs = DbUtil.executeQuery(ctx, orgPerSql.toString());
- while (rs.next()) {
- Map<String, BigDecimal> objectMap = Maps.newHashMap();
- String type = rs.getString("CFORGPERFORMTYPE");
- objectMap.put("S", rs.getBigDecimal("CFS"));
- objectMap.put("A", rs.getBigDecimal("CFA"));
- objectMap.put("B", rs.getBigDecimal("CFB"));
- objectMap.put("C", rs.getBigDecimal("CFC"));
- objectMap.put("D", rs.getBigDecimal("CFD"));
- orgLevelMap.put(type, objectMap);
- }
- } else if (proCollection.size() > 1) {
- if (null != batchMessage && null != idList) {
- for (String key : idList) {
- batchMessage.put(key, "存在多个正态分布规则,请检查!");
- }
- }
- } else {
- if (null != batchMessage && null != idList) {
- for (String key : idList) {
- batchMessage.put(key, "不存在正态分布规则,请检查!");
- }
- }
- }
- return orgLevelMap;
- }
- /**
- * 获取项目分组人数
- *
- * @param ctx
- * @param period
- * @param planId
- * @return
- * @throws BOSException
- * @throws SQLException
- */
- public Map<String, Map<String, String>> getProjectLevelCountMap(Context ctx, String period, String planId) throws BOSException, SQLException {
- // StringBuilder paramSql = new StringBuilder("''");
- // for (int i = 0; i < idList.size(); i++) {
- // paramSql.append(",?");
- // }
- //获取组织分组人数
- StringBuilder orgSql = new StringBuilder();
- orgSql.append(" select pp.CFPerobjectIdId, ers.FPERIODID,ers.FEVAPLANID,count(*) alls from T_EVA_EvaResultSummary ers ");
- orgSql.append(" left join T_EVA_PerfPlan pp on pp.fid=ers.FEVAPLANID ");
- // orgSql.append(paramSql);
- // orgSql.append(" ) ");
- orgSql.append(" where FPERIODID=? and FEVAPLANID=? ");
- orgSql.append(" group by pp.CFPerobjectIdId, ers.FPERIODID, ers.FEVAPLANID ");
- IRowSet rs = DbUtil.executeQuery(ctx, orgSql.toString(), new String[]{period, planId});
- Map<String, Map<String, String>> orgLevelMap = Maps.newHashMap();
- while (rs.next()) {
- Map<String, String> map = Maps.newHashMap();
- String CFPerobjectIdId = rs.getString("CFPerobjectIdId");
- String FPERIODID = rs.getString("FPERIODID");
- String FEVAPLANID = rs.getString("FEVAPLANID");
- String key = CFPerobjectIdId + FPERIODID + FEVAPLANID;
- map.put("CFPerobjectIdId", CFPerobjectIdId);
- map.put("FPERIODID", FPERIODID);
- map.put("FEVAPLANID", FEVAPLANID);
- //当前周期,当前考核计划,当前组织下的总人数
- map.put("alls", rs.getString("alls"));
- orgLevelMap.put(key, map);
- }
- return orgLevelMap;
- }
- /**
- * 获取人员的等级项目分组
- *
- * @param ctx
- * @param period
- * @param planId
- * @return
- * @throws BOSException
- * @throws SQLException
- */
- public Map<String, Map<String, String>> getPersonProjectLevelLensMap(Context ctx, String period, String planId) throws BOSException, SQLException {
- Map<String, Map<String, String>> personLevelMap = Maps.newHashMap();
- StringBuilder orgLevelSql = new StringBuilder();
- orgLevelSql.append(" select count(*) lens,CFPerobjectIdId,FPERIODID,FEVAPLANID,revLevel from ( ");
- orgLevelSql.append(" select pp.CFPerobjectIdId,s1.FPERIODID,s1.FEVAPLANID,isnull(s1.FREVISEGRADELEVEL,s1.FGRADELEVEL) revLevel ");
- orgLevelSql.append(" from T_EVA_EvaResultSummary s1 ");
- orgLevelSql.append(" left join T_EVA_PerfPlan pp on pp.fid=s1.FEVAPLANID ");
- orgLevelSql.append(" where s1.FPERIODID=? and s1.FEVAPLANID=? ");
- orgLevelSql.append(" ) t ");
- orgLevelSql.append(" group by CFPerobjectIdId, FPERIODID,FEVAPLANID,revLevel ");
- IRowSet orgLevelRs = DbUtil.executeQuery(ctx, orgLevelSql.toString(), new String[]{period, planId});
- while (orgLevelRs.next()) {
- Map<String, String> map = Maps.newHashMap();
- String CFPerobjectIdId = orgLevelRs.getString("CFPerobjectIdId");
- String FPERIODID = orgLevelRs.getString("FPERIODID");
- String FEVAPLANID = orgLevelRs.getString("FEVAPLANID");
- String revLevel = orgLevelRs.getString("revLevel");
- String key = CFPerobjectIdId + FPERIODID + FEVAPLANID + revLevel;
- map.put("lens", orgLevelRs.getString("lens"));
- map.put("CFPerobjectIdId", CFPerobjectIdId);
- map.put("FPERIODID", FPERIODID);
- map.put("FEVAPLANID", FEVAPLANID);
- map.put("revLevel", orgLevelRs.getString("revLevel"));
- personLevelMap.put(key, map);
- }
- return personLevelMap;
- }
- public Map<String, String> beforeAuditProjectEvaResut(Context ctx, String period, String planId, List<String> idList) throws BOSException, SQLException {
- Map<String, String> batchMessage = Maps.newHashMap();
- StringBuilder selParamId = new StringBuilder("''");
- for (int i = 0; i < idList.size(); i++) {
- selParamId.append(",?");
- }
- //获取正态分布规则
- Map<String, Map<String, BigDecimal>> personPerformMap = this.getProjectPerformPro(ctx, idList, batchMessage);
- if (null != personPerformMap && personPerformMap.size() > 0) {
- //获取组织分组人数
- Map<String, Map<String, String>> orgLevelMap = this.getProjectLevelCountMap(ctx, period, planId);
- //获取人员等级分组
- Map<String, Map<String, String>> personLevelMap = this.getPersonProjectLevelLensMap(ctx, period, planId);
- StringBuilder sel = new StringBuilder();
- sel.append(" select s1.fid,ppm.CFPROJECTNAME, pp.CFPerobjectIdId, s1.FPERIODID, s1.FEVAPLANID,");
- sel.append(" isnull(s1.FREVISEGRADELEVEL,s1.FGRADELEVEL) revLevel,s1.CFProjectLevel ");
- sel.append(" from T_EVA_EvaResultSummary s1 ");
- sel.append(" left join T_EVA_PerfPlan pp on pp.fid = s1.FEVAPLANID ");
- sel.append(" left join CT_PRO_ProjectManagement ppm on ppm.fid = pp.CFPerobjectIdId ");
- sel.append(" where s1.fid in (");
- sel.append(selParamId);
- sel.append(") ");
- IRowSet rs = DbUtil.executeQuery(ctx, sel.toString(), idList.toArray());
- BigDecimal big100 = new BigDecimal(100);
- while (rs.next()) {
- String fid = rs.getString("fid");
- String CFPROJECTNAME = rs.getString("CFPROJECTNAME");
- String CFPerobjectIdId = rs.getString("CFPerobjectIdId");
- String FPERIODID = rs.getString("FPERIODID");
- String FEVAPLANID = rs.getString("FEVAPLANID");
- String revLevel = rs.getString("revLevel");
- String key = CFPerobjectIdId + FPERIODID + FEVAPLANID;
- //项目绩效等级
- String projectLevel = rs.getString("CFProjectLevel");
- if (null == projectLevel) {
- String msg = String.format("%s项目绩效等级为空", CFPROJECTNAME);
- batchMessage.put(fid, msg);
- continue;
- }
- //该组织的组织绩效等级的正态分布
- Map<String, BigDecimal> personPerform = personPerformMap.get(projectLevel);
- if (null == personPerform) {
- String msg = String.format("没有找到%s项目绩效等级%s的正态分布规则", CFPROJECTNAME, projectLevel);
- batchMessage.put(fid, msg);
- continue;
- }
- //获取该组织下的人员总数
- Map<String, String> orgMap = orgLevelMap.get(key);
- //获取该组织下的人员各个绩效等级分组汇总
- // String keyRevLevel = FADMINORGUNITID + FPERIODID + FEVAPLANID + revLevel;
- // Map<String, String> personMap = personLevelMap.get(keyRevLevel);
- //已占用数
- BigDecimal lens = BigDecimal.ZERO;
- //获取等级D人数
- String keyRevLevelD = CFPerobjectIdId + FPERIODID + FEVAPLANID + "D";
- Map<String, String> personMapD = personLevelMap.get(keyRevLevelD);
- BigDecimal dLens = BigDecimal.ZERO;
- if (null != personMapD) {
- dLens = new BigDecimal(personMapD.get("lens"));
- }
- //获取等级C人数
- String keyRevLevelC = CFPerobjectIdId + FPERIODID + FEVAPLANID + "C";
- Map<String, String> personMapC = personLevelMap.get(keyRevLevelC);
- BigDecimal cLens = BigDecimal.ZERO;
- if (null != personMapC) {
- cLens = new BigDecimal(personMapC.get("lens"));
- }
- //获取等级B人数
- String keyRevLevelB = CFPerobjectIdId + FPERIODID + FEVAPLANID + "B";
- Map<String, String> personMapB = personLevelMap.get(keyRevLevelB);
- BigDecimal bLens = BigDecimal.ZERO;
- if (null != personMapB) {
- bLens = new BigDecimal(personMapB.get("lens"));
- }
- //获取等级A人数
- String keyRevLevelA = CFPerobjectIdId + FPERIODID + FEVAPLANID + "A";
- Map<String, String> personMapA = personLevelMap.get(keyRevLevelA);
- BigDecimal aLens = BigDecimal.ZERO;
- if (null != personMapA) {
- aLens = new BigDecimal(personMapA.get("lens"));
- }
- //获取等级S人数
- String keyRevLevelS = CFPerobjectIdId + FPERIODID + FEVAPLANID + "S";
- Map<String, String> personMapS = personLevelMap.get(keyRevLevelS);
- BigDecimal sLens = BigDecimal.ZERO;
- if (null != personMapS) {
- sLens = new BigDecimal(personMapS.get("lens"));
- }
- //总人数
- BigDecimal alls = new BigDecimal(orgMap.get("alls"));
- //当前等级正态分布比例
- BigDecimal scale = personPerform.get(revLevel);
- //创建每个等级的人数列表
- Map<String, BigDecimal> bigsList = Maps.newHashMap();
- BigDecimal bigS = ((personPerform.get("S").divide(big100, BigDecimal.ROUND_HALF_UP, BigDecimal.ROUND_HALF_UP)).multiply(alls).setScale(0, BigDecimal.ROUND_UP));
- bigsList.put("S", bigS);
- BigDecimal bigA = ((personPerform.get("A").divide(big100, BigDecimal.ROUND_HALF_UP, BigDecimal.ROUND_HALF_UP)).multiply(alls).setScale(0, BigDecimal.ROUND_UP));
- bigsList.put("A", bigA);
- BigDecimal bigB = ((personPerform.get("B").divide(big100, BigDecimal.ROUND_HALF_UP, BigDecimal.ROUND_HALF_UP)).multiply(alls).setScale(0, BigDecimal.ROUND_UP));
- bigsList.put("B", bigB);
- BigDecimal bigC = ((personPerform.get("C").divide(big100, BigDecimal.ROUND_HALF_UP, BigDecimal.ROUND_HALF_UP)).multiply(alls).setScale(0, BigDecimal.ROUND_UP));
- bigsList.put("C", bigC);
- BigDecimal bigD = ((personPerform.get("D").divide(big100, BigDecimal.ROUND_HALF_UP, BigDecimal.ROUND_HALF_UP)).multiply(alls).setScale(0, BigDecimal.ROUND_UP));
- bigsList.put("D", bigD);
- BigDecimal personSize = BigDecimal.ZERO;
- BigDecimal personMaxSize = BigDecimal.ZERO;
- List<String> ldrs = Lists.newArrayList();
- //进行额度加减
- switch (revLevel) {
- case "D":
- personSize = personSize.add(bigD).subtract(dLens);
- lens = lens.add(dLens);
- if(!"D".equals(revLevel)) {
- personMaxSize = personMaxSize.add((bigD));
- }else {
- personMaxSize = personMaxSize.add((bigD).subtract(dLens));
- }
- ldrs.add("D最多%D人,");
- bigsList.remove("D");
- case "C":
- personSize = personSize.add(bigC).subtract(cLens);
- lens = lens.add(cLens);
- if("C".equals(revLevel)) {
- personMaxSize = personMaxSize.add((bigC));
- }else {
- personMaxSize = personMaxSize.add((bigC).subtract(cLens));
- }
- ldrs.add("C最多%C人,");
- bigsList.remove("C");
- case "B":
- personSize = personSize.add(bigB).subtract(bLens);
- lens = lens.add(bLens);
- if("B".equals(revLevel)) {
- personMaxSize = personMaxSize.add((bigB));
- }else {
- personMaxSize = personMaxSize.add((bigB).subtract(bLens));
- }
- ldrs.add("B最多%B人,");
- bigsList.remove("B");
- case "A":
- personSize = personSize.add(bigA).subtract(aLens);
- lens = lens.add(aLens);
- if("A".equals(revLevel)) {
- personMaxSize = personMaxSize.add((bigA));
- }else {
- personMaxSize = personMaxSize.add((bigA).subtract(aLens));
- }
- ldrs.add("A最多%A人,");
- bigsList.remove("A");
- case "S":
- personSize = personSize.add(bigS).subtract(sLens);
- lens = lens.add(sLens);
- if("S".equals(revLevel)) {
- personMaxSize = personMaxSize.add(((bigS)));
- }else {
- personMaxSize = personMaxSize.add(((bigS).subtract(sLens)));
- }
- ldrs.add("S最多%S人,");
- bigsList.remove("S");
- }
- //String ld = "当前周期绩效等级为%l的人数为%maxs人,S最多%S人,A最多%A人,B最多%B人,C最多%C人,D最多%D人,请修正后重新审核.";
- String ld = "当前周期绩效等级为%l的人数为%maxs人,";
- if (personSize.compareTo(BigDecimal.ZERO) < 0) {
- String ldrstr = ldrs.get(0);
- // ldrs.remove(0);
- // for (String ldr : ldrs) {
- // ld = ld.replace(ldr,"");
- // }
- ld += ldrstr;
- ld = ld.replace("%l", revLevel);
- ld = ld.replace("%maxs", lens.toPlainString());
- ld = ld.replace("%" + revLevel, (personMaxSize.compareTo(BigDecimal.ZERO)>0?personMaxSize:BigDecimal.ZERO).toPlainString());
- // for(Map.Entry<String,BigDecimal> entry : bigsList.entrySet()){
- // BigDecimal bigv = entry.getValue();
- // String bigk = entry.getKey();
- // ld=ld.replace("%"+bigk,bigv.toPlainString());
- // }
- ld += "请修正后重新审核.";
- batchMessage.put(fid, ld);
- }
- }
- }
- return batchMessage;
- }
- /**
- * 获取人员组织正态分布规则
- *
- * @param ctx
- * @param idList 非必填
- * @param batchMessage 非必填
- * @return
- * @throws BOSException
- * @throws SQLException
- */
- public Map<String, Map<String, BigDecimal>> getPersonPerformPro(Context ctx, List<String> idList, Map<String, String> batchMessage) throws BOSException, SQLException {
- //获取正态分布规则
- Map<String, Map<String, BigDecimal>> orgLevelMap = Maps.newHashMap();
- PersonPerformProCollection proCollection = PersonPerformProFactory.getLocalInstance(ctx).getPersonPerformProCollection(" where state=1 ");
- if (proCollection.size() == 1) {
- StringBuilder orgPerSql = new StringBuilder();
- orgPerSql.append(" select fp.fid,fpe.CFS,fpe.CFA,fpe.CFB,fpe.CFC,fpe.CFD,fpe.CFORGPERFORMTYPE ");
- orgPerSql.append(" from CT_PF_PersonPerformPro fp ");
- orgPerSql.append(" left join CT_PF_PersonPerformProEntry fpe on fp.fid=fpe.FPARENTID ");
- orgPerSql.append(" where fp.CFSTATE = 1 ");
- orgPerSql.append(" order by fp.FCREATETIME ");
- IRowSet rs = DbUtil.executeQuery(ctx, orgPerSql.toString());
- while (rs.next()) {
- Map<String, BigDecimal> objectMap = Maps.newHashMap();
- String type = rs.getString("CFORGPERFORMTYPE");
- objectMap.put("S", rs.getBigDecimal("CFS"));
- objectMap.put("A", rs.getBigDecimal("CFA"));
- objectMap.put("B", rs.getBigDecimal("CFB"));
- objectMap.put("C", rs.getBigDecimal("CFC"));
- objectMap.put("D", rs.getBigDecimal("CFD"));
- orgLevelMap.put(type, objectMap);
- }
- } else if (proCollection.size() > 1) {
- if (null != batchMessage && null != idList) {
- for (String key : idList) {
- batchMessage.put(key, "存在多个正态分布规则,请检查!");
- }
- }
- } else {
- if (null != batchMessage && null != idList) {
- for (String key : idList) {
- batchMessage.put(key, "不存在正态分布规则,请检查!");
- }
- }
- }
- return orgLevelMap;
- }
- /**
- * 获取组织分组人数
- *
- * @param ctx
- * @param period
- * @param planId
- * @return
- * @throws BOSException
- * @throws SQLException
- */
- public Map<String, Map<String, String>> getOrgLevelCountMap(Context ctx, String period, String planId) throws BOSException, SQLException {
- // StringBuilder paramSql = new StringBuilder("''");
- // for (int i = 0; i < idList.size(); i++) {
- // paramSql.append(",?");
- // }
- //获取组织分组人数
- StringBuilder orgSql = new StringBuilder();
- orgSql.append(" select FADMINORGUNITID, FPERIODID,FEVAPLANID,count(*) alls from T_EVA_EvaResultSummary ");
- // orgSql.append("where fid in ( ");
- // orgSql.append(paramSql);
- // orgSql.append(" ) ");
- orgSql.append(" where FPERIODID=? and FEVAPLANID=? ");
- orgSql.append(" group by FADMINORGUNITID, FPERIODID, FEVAPLANID ");
- IRowSet rs = DbUtil.executeQuery(ctx, orgSql.toString(), new String[]{period, planId});
- Map<String, Map<String, String>> orgLevelMap = Maps.newHashMap();
- while (rs.next()) {
- Map<String, String> map = Maps.newHashMap();
- String FADMINORGUNITID = rs.getString("FADMINORGUNITID");
- String FPERIODID = rs.getString("FPERIODID");
- String FEVAPLANID = rs.getString("FEVAPLANID");
- String key = FADMINORGUNITID + FPERIODID + FEVAPLANID;
- map.put("FADMINORGUNITID", FADMINORGUNITID);
- map.put("FPERIODID", FPERIODID);
- map.put("FEVAPLANID", FEVAPLANID);
- //当前周期,当前考核计划,当前组织下的总人数
- map.put("alls", rs.getString("alls"));
- orgLevelMap.put(key, map);
- }
- return orgLevelMap;
- }
- /**
- * 获取人员的等级组织分组
- *
- * @param ctx
- * @param period
- * @param planId
- * @return
- * @throws BOSException
- * @throws SQLException
- */
- public Map<String, Map<String, String>> getPersonLevelLensMap(Context ctx, String period, String planId) throws BOSException, SQLException {
- Map<String, Map<String, String>> personLevelMap = Maps.newHashMap();
- StringBuilder orgLevelSql = new StringBuilder();
- orgLevelSql.append(" select count(*) lens,FADMINORGUNITID,FPERIODID,FEVAPLANID,revLevel from ( ");
- orgLevelSql.append(" select s1.FADMINORGUNITID,s1.FPERIODID,s1.FEVAPLANID,isnull(s1.FREVISEGRADELEVEL,s1.FGRADELEVEL) revLevel from T_EVA_EvaResultSummary s1 ");
- orgLevelSql.append(" where s1.FPERIODID=? and s1.FEVAPLANID=? ");
- orgLevelSql.append(" ) t ");
- orgLevelSql.append(" group by FADMINORGUNITID, FPERIODID,FEVAPLANID,revLevel ");
- IRowSet orgLevelRs = DbUtil.executeQuery(ctx, orgLevelSql.toString(), new String[]{period, planId});
- while (orgLevelRs.next()) {
- Map<String, String> map = Maps.newHashMap();
- String FADMINORGUNITID = orgLevelRs.getString("FADMINORGUNITID");
- String FPERIODID = orgLevelRs.getString("FPERIODID");
- String FEVAPLANID = orgLevelRs.getString("FEVAPLANID");
- String revLevel = orgLevelRs.getString("revLevel");
- String key = FADMINORGUNITID + FPERIODID + FEVAPLANID + revLevel;
- map.put("lens", orgLevelRs.getString("lens"));
- map.put("FADMINORGUNITID", FADMINORGUNITID);
- map.put("FPERIODID", FPERIODID);
- map.put("FEVAPLANID", FEVAPLANID);
- map.put("revLevel", orgLevelRs.getString("revLevel"));
- personLevelMap.put(key, map);
- }
- return personLevelMap;
- }
- /**
- * 根据上季度的组织等级,校验当前周期,当前考核计划,所选员工的所属组织的员工绩效等级分布校验
- *
- * @param request
- * @param response
- * @param modelMap
- * @param batchMessageTipsHeader
- * @throws SHRWebException
- */
- public void beforeAuditEvaResutAction(HttpServletRequest request, HttpServletResponse response, ModelMap modelMap, BatchMessageTipsHeader batchMessageTipsHeader) throws SHRWebException {
- Context ctx = SHRContext.getInstance().getContext();
- String ids = (String) request.getAttribute("billId");
- String period = (String) request.getParameter("period");
- String planId = (String) request.getParameter("planId");
- if (ids == null) {
- throw new ShrWebBizException(new SHRPerfWebBizException(SHRPerfWebBizException.SYSTEMERR));
- }
- try {
- List<String> idList = Lists.newArrayList();
- Set<String> idSet = Sets.newHashSet(idList);
- for (String id : ids.split(",")) {
- idList.add(id);
- }
- StringBuilder planSql = new StringBuilder();
- planSql.append("select fid,CFPerobjectIdId from T_EVA_PerfPlan where fid=? and CFPerobjectIdId is not null ");
- IRowSet rs = DbUtil.executeQuery(ctx, planSql.toString(), new Object[]{planId});
- if (rs.next()) {
- String CFPerobjectIdId = rs.getString("CFPerobjectIdId");
- Map<String, String> batchMessage = this.beforeAuditProjectEvaResut(ctx, period, planId, idList);
- if (null != batchMessage && batchMessage.size() > 0) {
- for (Map.Entry<String, String> entry : batchMessage.entrySet()) {
- addBatchMessageTip(entry.getKey(), entry.getValue(), batchMessageTipsHeader);
- idSet.remove(entry.getKey());
- }
- }
- } else {
- Map<String, String> batchMessage = this.beforeAuditEvaResut(ctx, period, planId, idList);
- if (null != batchMessage && batchMessage.size() > 0) {
- for (Map.Entry<String, String> entry : batchMessage.entrySet()) {
- addBatchMessageTip(entry.getKey(), entry.getValue(), batchMessageTipsHeader);
- idSet.remove(entry.getKey());
- }
- }
- //addBatchMessageSuccessTips(idSet,"验证成功",batchMessageTipsHeader);
- }
- this.setSuccessMessage("验证成功");
- } catch (Exception e) {
- e.printStackTrace();
- throw new ShrWebBizException(e);
- }
- }
- public Map<String, String> beforeAuditEvaResut(Context ctx, String period, String planId, List<String> idList) throws BOSException, SQLException {
- Map<String, String> batchMessage = Maps.newHashMap();
- StringBuilder selParamId = new StringBuilder("''");
- for (int i = 0; i < idList.size(); i++) {
- selParamId.append(",?");
- }
- //获取正态分布规则
- Map<String, Map<String, BigDecimal>> personPerformMap = this.getPersonPerformPro(ctx, idList, batchMessage);
- if (null != personPerformMap && personPerformMap.size() > 0) {
- //获取组织分组人数
- Map<String, Map<String, String>> orgLevelMap = this.getOrgLevelCountMap(ctx, period, planId);
- //获取人员等级分组
- Map<String, Map<String, String>> personLevelMap = this.getPersonLevelLensMap(ctx, period, planId);
- StringBuilder sel = new StringBuilder();
- sel.append("select fid,FADMINORGNAME, FADMINORGUNITID, FPERIODID, FEVAPLANID,isnull( FREVISEGRADELEVEL, FGRADELEVEL) revLevel,CFOrgLevel from T_EVA_EvaResultSummary where fid in (");
- sel.append(selParamId);
- sel.append(") ");
- IRowSet rs = DbUtil.executeQuery(ctx, sel.toString(), idList.toArray());
- BigDecimal big100 = new BigDecimal(100);
- while (rs.next()) {
- String fid = rs.getString("fid");
- String FADMINORGNAME = rs.getString("FADMINORGNAME");
- String FADMINORGUNITID = rs.getString("FADMINORGUNITID");
- String FPERIODID = rs.getString("FPERIODID");
- String FEVAPLANID = rs.getString("FEVAPLANID");
- String revLevel = rs.getString("revLevel");
- String key = FADMINORGUNITID + FPERIODID + FEVAPLANID;
- //上季度组织绩效等级
- String orgLevel = rs.getString("CFOrgLevel");
- if (null == orgLevel) {
- String msg = String.format("%s上季度组织绩效等级为空", FADMINORGNAME);
- batchMessage.put(fid, msg);
- continue;
- }
- //该组织的组织绩效等级的正态分布
- Map<String, BigDecimal> personPerform = personPerformMap.get(orgLevel);
- if (null == personPerform) {
- String msg = String.format("没有找到%s上季度组织绩效等级%s的正态分布规则", FADMINORGNAME, orgLevel);
- batchMessage.put(fid, msg);
- continue;
- }
- //获取该组织下的人员总数
- Map<String, String> orgMap = orgLevelMap.get(key);
- //获取该组织下的人员各个绩效等级分组汇总
- // String keyRevLevel = FADMINORGUNITID + FPERIODID + FEVAPLANID + revLevel;
- // Map<String, String> personMap = personLevelMap.get(keyRevLevel);
- //已占用数
- BigDecimal lens = BigDecimal.ZERO;
- //获取等级D人数
- String keyRevLevelD = FADMINORGUNITID + FPERIODID + FEVAPLANID + "D";
- Map<String, String> personMapD = personLevelMap.get(keyRevLevelD);
- BigDecimal dLens = BigDecimal.ZERO;
- if (null != personMapD) {
- dLens = new BigDecimal(personMapD.get("lens"));
- }
- //获取等级C人数
- String keyRevLevelC = FADMINORGUNITID + FPERIODID + FEVAPLANID + "C";
- Map<String, String> personMapC = personLevelMap.get(keyRevLevelC);
- BigDecimal cLens = BigDecimal.ZERO;
- if (null != personMapC) {
- cLens = new BigDecimal(personMapC.get("lens"));
- }
- //获取等级B人数
- String keyRevLevelB = FADMINORGUNITID + FPERIODID + FEVAPLANID + "B";
- Map<String, String> personMapB = personLevelMap.get(keyRevLevelB);
- BigDecimal bLens = BigDecimal.ZERO;
- if (null != personMapB) {
- bLens = new BigDecimal(personMapB.get("lens"));
- }
- //获取等级A人数
- String keyRevLevelA = FADMINORGUNITID + FPERIODID + FEVAPLANID + "A";
- Map<String, String> personMapA = personLevelMap.get(keyRevLevelA);
- BigDecimal aLens = BigDecimal.ZERO;
- if (null != personMapA) {
- aLens = new BigDecimal(personMapA.get("lens"));
- }
- //获取等级S人数
- String keyRevLevelS = FADMINORGUNITID + FPERIODID + FEVAPLANID + "S";
- Map<String, String> personMapS = personLevelMap.get(keyRevLevelS);
- BigDecimal sLens = BigDecimal.ZERO;
- if (null != personMapS) {
- sLens = new BigDecimal(personMapS.get("lens"));
- }
- //总人数
- BigDecimal alls = new BigDecimal(orgMap.get("alls"));
- //当前等级正态分布比例
- BigDecimal scale = personPerform.get(revLevel);
- //创建每个等级的人数列表
- Map<String, BigDecimal> bigsList = Maps.newHashMap();
- BigDecimal bigS = ((personPerform.get("S").divide(big100, BigDecimal.ROUND_HALF_UP, BigDecimal.ROUND_HALF_UP)).multiply(alls).setScale(0, BigDecimal.ROUND_UP));
- bigsList.put("S", bigS);
- BigDecimal bigA = ((personPerform.get("A").divide(big100, BigDecimal.ROUND_HALF_UP, BigDecimal.ROUND_HALF_UP)).multiply(alls).setScale(0, BigDecimal.ROUND_UP));
- bigsList.put("A", bigA);
- BigDecimal bigB = ((personPerform.get("B").divide(big100, BigDecimal.ROUND_HALF_UP, BigDecimal.ROUND_HALF_UP)).multiply(alls).setScale(0, BigDecimal.ROUND_UP));
- bigsList.put("B", bigB);
- BigDecimal bigC = ((personPerform.get("C").divide(big100, BigDecimal.ROUND_HALF_UP, BigDecimal.ROUND_HALF_UP)).multiply(alls).setScale(0, BigDecimal.ROUND_UP));
- bigsList.put("C", bigC);
- BigDecimal bigD = ((personPerform.get("D").divide(big100, BigDecimal.ROUND_HALF_UP, BigDecimal.ROUND_HALF_UP)).multiply(alls).setScale(0, BigDecimal.ROUND_UP));
- bigsList.put("D", bigD);
- BigDecimal personSize = BigDecimal.ZERO;
- BigDecimal personMaxSize = BigDecimal.ZERO;
- List<String> ldrs = Lists.newArrayList();
- //进行额度加减
- switch (revLevel) {
- case "D":
- personSize = personSize.add(bigD).subtract(dLens);
- lens = lens.add(dLens);
- if("D".equals(revLevel)) {
- personMaxSize = personMaxSize.add((bigD));
- }else {
- personMaxSize = personMaxSize.add((bigD).subtract(dLens));
- }
- ldrs.add("D最多%D人,");
- bigsList.remove("D");
- case "C":
- personSize = personSize.add(bigC).subtract(cLens);
- lens = lens.add(cLens);
- if("C".equals(revLevel)) {
- personMaxSize = personMaxSize.add((bigC) );
- }else {
- personMaxSize = personMaxSize.add((bigC).subtract(cLens));
- }
- ldrs.add("C最多%C人,");
- bigsList.remove("C");
- case "B":
- personSize = personSize.add(bigB).subtract(bLens);
- lens = lens.add(bLens);
- if("B".equals(revLevel)) {
- personMaxSize = personMaxSize.add((bigB) );
- }else {
- personMaxSize = personMaxSize.add((bigB).subtract(bLens));
- }
- ldrs.add("B最多%B人,");
- bigsList.remove("B");
- case "A":
- personSize = personSize.add(bigA).subtract(aLens);
- lens = lens.add(aLens);
- if( "A".equals(revLevel)) {
- personMaxSize = personMaxSize.add((bigA));
- }else {
- personMaxSize = personMaxSize.add((bigA).subtract(aLens));
- }
- ldrs.add("A最多%A人,");
- bigsList.remove("A");
- case "S":
- personSize = personSize.add(bigS).subtract(sLens);
- lens = lens.add(sLens);
- if("S".equals(revLevel)) {
- personMaxSize = personMaxSize.add((bigS));
- }else {
- personMaxSize = personMaxSize.add((bigS).subtract(sLens));
- }
- ldrs.add("S最多%S人,");
- bigsList.remove("S");
- }
- //String ld = "当前周期绩效等级为%l的人数为%maxs人,S最多%S人,A最多%A人,B最多%B人,C最多%C人,D最多%D人,请修正后重新审核.";
- String ld = "当前周期绩效等级为%l的人数为%maxs人,";
- if (personSize.compareTo(BigDecimal.ZERO) < 0) {
- String ldrstr = ldrs.get(0);
- // ldrs.remove(0);
- // for (String ldr : ldrs) {
- // ld = ld.replace(ldr,"");
- // }
- ld += ldrstr;
- ld = ld.replace("%l", revLevel);
- ld = ld.replace("%maxs", lens.toPlainString());
- ld = ld.replace("%" + revLevel, (personMaxSize.compareTo(BigDecimal.ZERO)>0?personMaxSize:BigDecimal.ZERO).toPlainString());
- // for(Map.Entry<String,BigDecimal> entry : bigsList.entrySet()){
- // BigDecimal bigv = entry.getValue();
- // String bigk = entry.getKey();
- // ld=ld.replace("%"+bigk,bigv.toPlainString());
- // }
- ld += "请修正后重新审核.";
- batchMessage.put(fid, ld);
- }
- }
- }
- return batchMessage;
- }
- @Override
- public void auditEvaResutAction(HttpServletRequest request, HttpServletResponse response, ModelMap modelMap, BatchMessageTipsHeader batchMessageTipsHeader) throws SHRWebException {
- super.auditEvaResutAction(request, response, modelMap, batchMessageTipsHeader);
- }
- /**
- * 获取上季度组织等级批量
- *
- * @description:
- * @author: lhbj
- * @date: 2025/1/10 18:18
- * @param: null
- * @return:null
- **/
- public void bindDep_OR_ProjectBatchAction(HttpServletRequest request, HttpServletResponse response, ModelMap modelMap, BatchMessageTipsHeader batchMessageTipsHeader) throws SHRWebException {
- Context ctx = SHRContext.getInstance().getContext();
- String ids = (String) request.getAttribute("billId");
- String period = (String) request.getParameter("period");
- String planId = (String) request.getParameter("planId");
- if (ids == null) {
- throw new ShrWebBizException(new SHRPerfWebBizException(SHRPerfWebBizException.SYSTEMERR));
- } else {
- try {
- StringBuilder planSql = new StringBuilder();
- planSql.append("select fid,CFPerobjectIdId from T_EVA_PerfPlan where fid=? and CFPerobjectIdId is not null ");
- IRowSet rs = DbUtil.executeQuery(ctx, planSql.toString(), new Object[]{planId});
- if (rs.next()) {
- this.bindProjectBatchAction(request, response, modelMap, batchMessageTipsHeader);
- } else {
- this.bindDepBatchAction(request, response, modelMap, batchMessageTipsHeader);
- }
- this.setSuccessMessage("验证成功");
- } catch (Exception e) {
- e.printStackTrace();
- throw new ShrWebBizException(e);
- }
- }
- }
- /**
- * 获取项目等级批量
- *
- * @description:
- * @author: lhbj
- * @date: 2025/1/10 18:18
- * @param: null
- * @return:null
- **/
- public void bindProjectBatchAction(HttpServletRequest request, HttpServletResponse response, ModelMap modelMap, BatchMessageTipsHeader batchMessageTipsHeader) throws SHRWebException {
- Context ctx = SHRContext.getInstance().getContext();
- String ids = (String) request.getAttribute("billId");
- if (ids == null) {
- throw new ShrWebBizException(new SHRPerfWebBizException(SHRPerfWebBizException.SYSTEMERR));
- } else {
- try {
- List<String> idList = Lists.newArrayList();
- for (String id : ids.split(",")) {
- idList.add(id);
- }
- Set<String> idSet = Sets.newHashSet(idList);
- Map<String, String> map = this.bindProject(ctx, ids);
- for (Map.Entry<String, String> entry : map.entrySet()) {
- addBatchMessageTip(entry.getKey(), entry.getValue(), batchMessageTipsHeader);
- idSet.remove(entry.getKey());
- }
- //addBatchMessageSuccessTips(idSet,"验证成功",batchMessageTipsHeader);
- this.setSuccessMessage("验证成功");
- } catch (Exception e) {
- e.printStackTrace();
- throw new ShrWebBizException(e);
- }
- }
- }
- /**
- * 绑定项目等级
- *
- * @param ctx
- * @param ids
- * @return
- * @throws Exception
- */
- public Map<String, String> bindProject(Context ctx, String ids) throws Exception {
- Map<String, String> batchMessage = Maps.newHashMap();
- List<String> idList = Lists.newArrayList();
- SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd");
- if (ids == null) {
- throw new Exception(new SHRPerfWebBizException(SHRPerfWebBizException.SYSTEMERR));
- } else {
- try {
- StringBuffer sql = new StringBuffer();
- sql.append(" select ers.fid,pp.FPSTARTDATE,ers.FADMINORGUNITID,ers.FADMINORGNAME,pp.FYEAR,pp.FTIMEPERIOD, ");
- sql.append(" pp.FCYCLETYPE,pp.FPENDDATE,pp.FPSTARTDATE,ppn.CFPEROBJECTIDID,ppm.CFPROJECTNAME,pmm.CFEMPLOYEEID ");
- sql.append(" from T_EVA_EvaResultSummary ers ");
- sql.append(" left join T_EVA_PerfPlan ppn on ers.FEVAPLANID=ppn.fid ");
- sql.append(" left join T_EVA_PerfPeriod pp on ers.FPERIODID=pp.fid ");
- sql.append(" left join CT_PRO_ProjectManagement ppm on ppn.CFPEROBJECTIDID=ppm.fid ");
- sql.append(" left join CT_PRO_MemberManagement pmm on ppm.fid=pmm.CFPROJECTMANAGEMENID and pmm.CFSTATE=1 ");
- sql.append(" and pmm.CFPTYPEID in( ");
- sql.append(" select fid from CT_PRO_ProjectType where FNUMBER='ProjectManager') ");
- sql.append(" and pmm.CFPROJECTROLEID in( ");
- sql.append(" select fid from CT_PRO_ProjectRole where FNUMBER ='HTY110') ");
- sql.append(" where pmm.CFEMPLOYEEID is not null and ers.fid in(''");
- for (String id : ids.split(",")) {
- idList.add(id);
- sql.append(",'").append(id).append("'");
- }
- sql.append(" ) ");
- IRowSet rsSql = DbUtil.executeQuery(ctx, sql.toString());
- List<String> sess = Lists.newArrayList();
- while (rsSql.next()) {
- String id = rsSql.getString("fid");
- String personid = rsSql.getString("CFEMPLOYEEID");
- String CFPROJECTNAME = rsSql.getString("CFPROJECTNAME");
- String perobjectid = rsSql.getString("CFPEROBJECTIDID");
- StringBuffer sqlPro = new StringBuffer();
- sqlPro.append(" select isnull(ers.FREVISEGRADELEVEL,ers.FGRADELEVEL) FGRADELEVEL,ers.fid from ");
- sqlPro.append(" T_EVA_EvaResultSummary ers ");
- sqlPro.append(" left join T_EVA_PerfPlan ppn on ers.FEVAPLANID=ppn.fid ");
- sqlPro.append(" left join T_EVA_PerfPeriod pp on ers.FPERIODID=pp.fid ");
- sqlPro.append(" where ers.FBILLSTATE='3' and ers.FPERSONID=? and ppn.CFPEROBJECTIDID=? ");
- sqlPro.append(" order by pp.FPENDDATE desc ");
- IRowSet rsPro = DbUtil.executeQuery(ctx, sqlPro.toString(), new String[]{personid, perobjectid});
- String FGRADELEVEL = "";
- if (rsPro.next()) {
- FGRADELEVEL = rsPro.getString("FGRADELEVEL");
- }
- if (StringUtils.isEmpty(FGRADELEVEL)) {
- batchMessage.put(id, "未找到当前" + CFPROJECTNAME + "项目匹配的绩效等级");
- } else {
- StringBuilder upd = new StringBuilder();
- upd.append("update T_EVA_EvaResultSummary set CFPROJECTLEVEL=? where fid=? ");
- DbUtil.execute(ctx, upd.toString(), new String[]{FGRADELEVEL, id});
- sess.add(id);
- }
- }
- } catch (Exception e) {
- e.printStackTrace();
- throw new Exception(e);
- }
- }
- return batchMessage;
- }
- /**
- * 获取上季度组织等级批量
- *
- * @description:
- * @author: lhbj
- * @date: 2025/1/10 18:18
- * @param: null
- * @return:null
- **/
- public void bindDepBatchAction(HttpServletRequest request, HttpServletResponse response, ModelMap modelMap, BatchMessageTipsHeader batchMessageTipsHeader) throws SHRWebException {
- Context ctx = SHRContext.getInstance().getContext();
- String ids = (String) request.getAttribute("billId");
- if (ids == null) {
- throw new ShrWebBizException(new SHRPerfWebBizException(SHRPerfWebBizException.SYSTEMERR));
- } else {
- try {
- List<String> idList = Lists.newArrayList();
- for (String id : ids.split(",")) {
- idList.add(id);
- }
- Set<String> idSet = Sets.newHashSet(idList);
- Map<String, String> map = this.bindDep(ctx, ids);
- for (Map.Entry<String, String> entry : map.entrySet()) {
- addBatchMessageTip(entry.getKey(), entry.getValue(), batchMessageTipsHeader);
- idSet.remove(entry.getKey());
- }
- //addBatchMessageSuccessTips(idSet,"验证成功",batchMessageTipsHeader);
- this.setSuccessMessage("验证成功");
- } catch (Exception e) {
- e.printStackTrace();
- throw new ShrWebBizException(e);
- }
- }
- }
- /**
- * 绑定部门等级
- *
- * @param ctx
- * @param ids
- * @return
- * @throws Exception
- */
- public Map<String, String> bindDep(Context ctx, String ids) throws Exception {
- Map<String, String> batchMessage = Maps.newHashMap();
- List<String> idList = Lists.newArrayList();
- Map<String, String> id_orgIdMap = Maps.newHashMap();
- SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd");
- if (ids == null) {
- throw new Exception(new SHRPerfWebBizException(SHRPerfWebBizException.SYSTEMERR));
- } else {
- try {
- StringBuffer sql = new StringBuffer();
- sql.append(" select ers.fid,pp.FPSTARTDATE,ers.FADMINORGUNITID,ers.FADMINORGNAME,pp.FYEAR,pp.FTIMEPERIOD," +
- "pp.FCYCLETYPE,pp.FPENDDATE,pp.FPSTARTDATE from ");
- sql.append(" T_EVA_EvaResultSummary ers ");
- sql.append(" left join T_EVA_PerfPeriod pp on ers.FPERIODID=pp.fid ");
- sql.append(" where ers.fid in(''");
- for (String id : ids.split(",")) {
- idList.add(id);
- sql.append(",'").append(id).append("'");
- }
- sql.append(" ) ");
- LocalDate startDate = null;
- LocalDate endDate = null;
- EvalplanCycleTypeEnum cycleTypeEnum = null;
- IRowSet rsSql = DbUtil.executeQuery(ctx, sql.toString());
- boolean faist = true;
- while (rsSql.next()) {
- String id = rsSql.getString("fid");
- String orgId = rsSql.getString("FADMINORGUNITID");
- String orgName = rsSql.getString("FADMINORGNAME");
- if (faist) {
- faist = false;
- int FCYCLETYPE = rsSql.getInt("FCYCLETYPE");
- Date FPENDDATE = rsSql.getDate("FPENDDATE");
- Date FPSTARTDATE = rsSql.getDate("FPSTARTDATE");
- Map<String, Object> cycleMap = this.getCycletype(sf.format(FPSTARTDATE), sf.format(FPENDDATE), FCYCLETYPE);
- cycleTypeEnum = (EvalplanCycleTypeEnum) cycleMap.get("cycleType");
- endDate = (LocalDate) cycleMap.get("endDate");
- startDate = (LocalDate) cycleMap.get("startDate");
- }
- id_orgIdMap.put(id, orgId + "!" + orgName);
- }
- List<String> sess = Lists.newArrayList();
- //T_EVA_OrgEvaResultSummary
- Map<String, Map<String, String>> mapMap = this.getOrgEvaResultLevel(ctx, startDate, endDate, cycleTypeEnum);
- for (Map.Entry<String, String> ee : id_orgIdMap.entrySet()) {
- String[] orgs = ee.getValue().split("!");
- String orgId = orgs[0];
- String orgName = orgs[1];
- String id = ee.getKey();
- Map<String, String> orgLevelMap = mapMap.get(orgId);
- if (null == orgLevelMap) {
- batchMessage.put(id, "未找到当前" + orgName + "部门匹配的组织绩效等级");
- } else {
- String orgLevel = orgLevelMap.get("lastgradeLevel");
- StringBuilder upd = new StringBuilder();
- upd.append("update T_EVA_EvaResultSummary set CFOrgLevel=?,CFOrgLevelEveID=? where fid=? ");
- DbUtil.execute(ctx, upd.toString(), new String[]{orgLevel, orgId, id});
- sess.add(id);
- }
- }
- } catch (Exception e) {
- e.printStackTrace();
- throw new Exception(e);
- }
- }
- return batchMessage;
- }
- public Map<String, Object> getCycletype(String pstartdate, String penddate, int cycletype) {
- Map<String, Object> map = Maps.newHashMap();
- LocalDate startDate = LocalDate.parse(pstartdate, DateTimeFormatter.ISO_LOCAL_DATE);
- LocalDate endDate = LocalDate.parse(penddate, DateTimeFormatter.ISO_LOCAL_DATE);
- EvalplanCycleTypeEnum cycleTypeEnum = EvalplanCycleTypeEnum.getEnum(cycletype);
- if (EvalplanCycleTypeEnum.FULL_YEAR_VALUE == cycletype) {
- //周期为年度
- endDate = endDate.plusYears(-1);
- startDate = startDate.plusYears(-1);
- cycleTypeEnum = EvalplanCycleTypeEnum.FULL_YEAR;
- } else if (EvalplanCycleTypeEnum.HALF_YEAR_VALUE == cycletype) {
- //周期为半年度
- endDate = endDate.plusMonths(-6);
- startDate = startDate.plusMonths(-6);
- cycleTypeEnum = EvalplanCycleTypeEnum.HALF_YEAR;
- } else if (EvalplanCycleTypeEnum.QUARTER_VALUE == cycletype) {
- //获取为季度
- endDate = endDate.plusMonths(-3);
- startDate = startDate.plusMonths(-3);
- cycleTypeEnum = EvalplanCycleTypeEnum.QUARTER;
- } else if (EvalplanCycleTypeEnum.MONTHLY_VALUE == cycletype) {
- //获取为季度
- endDate = endDate.plusMonths(-1);
- startDate = startDate.plusMonths(-1);
- cycleTypeEnum = EvalplanCycleTypeEnum.MONTHLY;
- }
- map.put("cycleType", cycleTypeEnum);
- map.put("endDate", endDate);
- map.put("startDate", startDate);
- return map;
- }
- /**
- * 获取上季度组织等级
- *
- * @description:
- * @author: lhbj
- * @date: 2025/1/10 18:18
- * @param: null
- * @return:null
- **/
- public void bindDepAction(HttpServletRequest request, HttpServletResponse response, ModelMap modelMap) throws SHRWebException {
- Context ctx = SHRContext.getInstance().getContext();
- String ids = this.getBillId(request);
- if (ids == null) {
- throw new ShrWebBizException(new SHRPerfWebBizException(SHRPerfWebBizException.SYSTEMERR));
- } else {
- try {
- Map<String, String> map = this.bindDep(ctx, ids);
- this.writeSuccessData(map);
- } catch (Exception e) {
- e.printStackTrace();
- throw new ShrWebBizException(e);
- }
- }
- }
- protected Map<String, Map<String, String>> getOrgEvaResultLevel(Context ctx, LocalDate startDate, LocalDate endDate) throws BOSException, SQLException {
- return this.getOrgEvaResultLevel(ctx, startDate, endDate, EvalplanCycleTypeEnum.QUARTER);
- }
- protected Map<String, Map<String, String>> getOrgEvaResultLevel(Context ctx, LocalDate startDate, LocalDate endDate, EvalplanCycleTypeEnum cycletype) throws BOSException, SQLException {
- Map<String, Map<String, String>> mapMap = Maps.newHashMap();
- StringBuffer selSql = new StringBuffer();
- selSql.append(" select oers.fid oersId, oers.FADMINORGUNITID,oers.FLASTGRADELEVEL,(case when ppd.fid is null ");
- selSql.append(" then (oers.FPERIODYEAR||'-01-'||'01')||'T'|| (oers.FPERIODYEAR||'-01-'||'01') ");
- selSql.append(" else (to_char(ppd.FPSTARTDATE,'yyyy-MM-dd')||'T'||to_char(ppd.FPENDDATE,'yyyy-MM-dd')) end) PERIOD ");
- selSql.append(" from T_EVA_OrgEvaResultSummary oers ");
- selSql.append(" left join T_EVA_PerfPeriod ppd on ppd.fid = oers.FPERIODID ");
- selSql.append(" where to_char(ppd.FPSTARTDATE,'yyyy-MM-dd') >= ? and to_char(ppd.FPENDDATE,'yyyy-MM-dd') <= ? ");
- selSql.append(" and ppd.FCYCLETYPE = ? and ppd.FREFSTATUS = 100 and oers.FBILLSTATE='3' ");
- String[] param = new String[]{startDate.format(DateTimeFormatter.ISO_LOCAL_DATE),
- endDate.format(DateTimeFormatter.ISO_LOCAL_DATE), String.valueOf(cycletype.getValue())};
- IRowSet rs = DbUtil.executeQuery(ctx, selSql.toString(), param);
- int i = selSql.indexOf("?");
- selSql.replace(i, i + 1, param[0]);
- i = selSql.indexOf("?");
- selSql.replace(i, i + 1, param[1]);
- System.out.println(selSql);
- while (rs.next()) {
- Map<String, String> stringMap = Maps.newHashMap();
- String orgId = rs.getString("FADMINORGUNITID");
- String lastgradeLevel = rs.getString("FLASTGRADELEVEL");
- String period = rs.getString("PERIOD");
- stringMap.put("orgId", orgId);
- stringMap.put("lastgradeLevel", lastgradeLevel);
- stringMap.put("period", period);
- mapMap.put(orgId, stringMap);
- }
- return mapMap;
- }
- public static void main(String[] args) {
- List<String> idList = new ArrayList<>();
- idList.add("W");
- idList.add("A");
- idList.add("C");
- idList.add("B");
- idList.add("D");
- idList.add("S");
- System.out.println(idList);
- Collections.sort(idList);
- System.out.println(idList);
- BigDecimal personSize = BigDecimal.ZERO;
- List<BigDecimal> bigsList = Lists.newArrayList();
- BigDecimal bigD = BigDecimal.valueOf(1);
- bigsList.add(bigD);
- BigDecimal bigC = BigDecimal.valueOf(1);
- bigsList.add(bigC);
- BigDecimal bigB = BigDecimal.valueOf(1);
- bigsList.add(bigB);
- BigDecimal bigA = BigDecimal.valueOf(1);
- bigsList.add(bigA);
- BigDecimal bigS = BigDecimal.valueOf(1);
- bigsList.add(bigS);
- String ld = "S最多%s人,A最多%s人,B最多%s人,C最多%s人,D最多%s人,";
- List<String> ldrs = Lists.newArrayList();
- List<BigDecimal> bigs = Lists.newArrayList();
- switch ("B") {
- case "D":
- personSize = personSize.add(bigD);
- ldrs.add("D最多%s人,");
- bigsList.remove(bigD);
- case "C":
- personSize = personSize.add(bigC);
- ldrs.add("C最多%s人,");
- bigsList.remove(bigC);
- case "B":
- personSize = personSize.add(bigB);
- ldrs.add("B最多%s人,");
- bigsList.remove(bigB);
- case "A":
- personSize = personSize.add(bigA);
- ldrs.add("A最多%s人,");
- bigsList.remove(bigA);
- case "S":
- personSize = personSize.add(bigS);
- ldrs.add("S最多%s人,");
- bigsList.remove(bigS);
- }
- System.out.println(personSize);
- System.out.println(ldrs);
- ldrs.remove(0);
- for (String ldr : ldrs) {
- ld = ld.replace(ldr, "");
- }
- System.out.println(ld);
- System.out.println(bigs);
- System.out.println(bigsList);
- Map<String, Object> map = Maps.newHashMap();
- String pstartdate = "2025-10-01";
- String penddate = "2025-12-31";
- int cycletype = 300;
- LocalDate startDate = LocalDate.parse(pstartdate, DateTimeFormatter.ISO_LOCAL_DATE);
- LocalDate endDate = LocalDate.parse(penddate, DateTimeFormatter.ISO_LOCAL_DATE);
- EvalplanCycleTypeEnum cycleTypeEnum = EvalplanCycleTypeEnum.getEnum(cycletype);
- if (EvalplanCycleTypeEnum.FULL_YEAR_VALUE == cycletype) {
- //周期为年度
- endDate = endDate.plusYears(-1);
- startDate = startDate.plusYears(-1);
- cycleTypeEnum = EvalplanCycleTypeEnum.FULL_YEAR;
- } else if (EvalplanCycleTypeEnum.HALF_YEAR_VALUE == cycletype) {
- //周期为半年度
- endDate = endDate.plusMonths(-6);
- startDate = startDate.plusMonths(-6);
- cycleTypeEnum = EvalplanCycleTypeEnum.HALF_YEAR;
- } else if (EvalplanCycleTypeEnum.QUARTER_VALUE == cycletype) {
- //获取为季度
- endDate = endDate.plusMonths(-3);
- startDate = startDate.plusMonths(-3);
- cycleTypeEnum = EvalplanCycleTypeEnum.QUARTER;
- } else if (EvalplanCycleTypeEnum.MONTHLY_VALUE == cycletype) {
- //获取为季度
- endDate = endDate.plusMonths(-1);
- startDate = startDate.plusMonths(-1);
- cycleTypeEnum = EvalplanCycleTypeEnum.MONTHLY;
- }
- map.put("cycleType", cycleTypeEnum);
- map.put("endDate", endDate);
- map.put("startDate", startDate);
- //System.out.println(map);
- }
- }
|