hongtaiyang/websrc/com/kingdee/eas/hr/perf/handler/EvaResultSummaryManagerListHandlerExEx.java

package com.kingdee.eas.hr.perf.handler;


import cn.hutool.core.util.StrUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
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.metadata.entity.*;
import com.kingdee.bos.metadata.query.util.CompareType;
import com.kingdee.bos.rabbitmq.guava.Lists;
import com.kingdee.eas.common.EASBizException;
import com.kingdee.eas.custom.performanceScoring.handler.EvaResultSummaryManagerListHandlerEx;
import com.kingdee.eas.framework.CoreBaseCollection;
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.MSFServiceFacadeFactory;
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.*;
import com.kingdee.shr.perfweb.app.exception.SHRPerfWebBizException;
import com.kingdee.shr.perfweb.app.resource.SHRPerfWebResource;
import com.kingdee.shr.perfweb.util.*;
import com.kingdee.util.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.ui.ModelMap;
import org.springframework.util.CollectionUtils;

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.Month;
import java.time.Year;
import java.time.format.DateTimeFormatter;
import java.util.*;

public class EvaResultSummaryManagerListHandlerExEx extends EvaResultSummaryManagerListHandlerEx {

    private static final Logger logger = LoggerFactory.getLogger(EvaResultSummaryManagerListHandlerExEx.class);


    public void batchSaveReviseDataAction(HttpServletRequest request, HttpServletResponse response, ModelMap modelMap, BatchMessageTipsHeader batchMessageTipsHeader) throws SHRWebException {
        Context ctx = SHRContext.getInstance().getContext();
        List unValidIds;
        try {
            unValidIds = EvaResultSummaryBillUtil.validEvaResultSummaryBill(ctx, (String) null, request.getParameter("billId"), "10");
            if (unValidIds.size() > 0) {
                addBatchMessageTips(unValidIds, SHRPerfWebResourceUtil.getRes(SHRPerfWebResource.CANNOTENTRYREVISEBYBILLSTATE, ctx), batchMessageTipsHeader);
            }
        } catch (BOSException var12) {
            logger.error("【PERFWEB--batchSaveReviseDataAction】-it is failed to get state of summary bill,e=", var12);
            throw new ShrWebBizException(SHRPerfWebResourceUtil.getRes(SHRPerfWebResource.CANNOTENTRYREVISEBYBILLSTATE, ctx));
        }

        try {
            String datas = request.getParameter("datas");
            if (!StringUtils.isEmpty(datas)) {
                if (!CollectionUtils.isEmpty(unValidIds)) {
                    List<HashMap> reviseDataList = JSONArray.parseArray(datas, HashMap.class);
                    List<HashMap> rightDatas = new ArrayList(reviseDataList.size());
                    Iterator var10 = reviseDataList.iterator();

                    while (var10.hasNext()) {
                        HashMap map = (HashMap) var10.next();
                        if (!unValidIds.contains(map.get("id"))) {
                            rightDatas.add(map);
                        }
                    }

                    datas = JSONArray.toJSONString(rightDatas);
                }

                this._batchSaveReviseData(ctx, datas, batchMessageTipsHeader);
            }
        } catch (Exception var13) {
            logger.error("batchSaveReviseDataAction is error: ", var13);
        }
    }

    protected void _batchSaveReviseData(Context ctx, String reviseDataJson, BatchMessageTipsHeader batchMessageTipsHeader) throws BOSException, EASBizException {
        List<HashMap> reviseDataList = JSONArray.parseArray(reviseDataJson, HashMap.class);
        CoreBaseCollection evaResultSummaryCollection = new CoreBaseCollection();
        if (!CollectionUtils.isEmpty(reviseDataList)) {
            Set<String> summaryIds = new HashSet(reviseDataList.size());
            Set<String> summaryErrIds = new HashSet(reviseDataList.size());
            Iterator var7 = reviseDataList.iterator();

            while (var7.hasNext()) {
                HashMap reviseData = (HashMap) var7.next();
                EvaResultSummaryInfo evaResultSummaryInfo = new EvaResultSummaryInfo();
                summaryIds.add((String) reviseData.get("id"));
                evaResultSummaryInfo.put("id", reviseData.get("id"));
                if (reviseData.get("reviseSumScore") != null && org.apache.commons.lang.StringUtils.isNotBlank(String.valueOf(reviseData.get("reviseSumScore")))) {
                    evaResultSummaryInfo.put("reviseSumScore", reviseData.get("reviseSumScore"));
                }

                evaResultSummaryInfo.put("reviseGradeLevel", reviseData.get("reviseGradeLevel"));
                evaResultSummaryInfo.put("reviseReason", reviseData.get("reviseReason"));

                Object perCoefficientObj = reviseData.get("perCoefficient");
                Object perMaxCoefficientObj = reviseData.get("perMaxCoefficient");
                Object perMinCoefficientObj = reviseData.get("perMinCoefficient");

                if (null == perCoefficientObj || null == perMaxCoefficientObj || null == perMinCoefficientObj) {
                    evaResultSummaryCollection.add(evaResultSummaryInfo);
                } else {
                    evaResultSummaryInfo.put("perCoefficient", perCoefficientObj);
                    evaResultSummaryInfo.put("perMaxCoefficient", perMaxCoefficientObj);
                    evaResultSummaryInfo.put("perMinCoefficient", perMinCoefficientObj);
                    BigDecimal perMaxCoefficient = new BigDecimal(perMaxCoefficientObj.toString());
                    BigDecimal perMinCoefficient = new BigDecimal(perMinCoefficientObj.toString());
                    BigDecimal perCoefficient = new BigDecimal(perCoefficientObj.toString());
                    if (!(perCoefficient.compareTo(perMaxCoefficient) <= 0
                            && perCoefficient.compareTo(perMinCoefficient) >= 0)) {
                        summaryErrIds.add((String) reviseData.get("id"));
                        addBatchMessageTip((String) reviseData.get("id"), "所修改的绩效系数，大于最大绩效系数或者小于最小绩效系数！", batchMessageTipsHeader);
                    } else {
                        evaResultSummaryCollection.add(evaResultSummaryInfo);
                    }
                }
            }

            Object periodId = ((HashMap) reviseDataList.get(0)).get("periodId");
            List unValidIds;
            if (periodId != null) {
                unValidIds = EvaResultSummaryBillUtil.batchCheckScore(ctx, evaResultSummaryCollection, (String) periodId, batchMessageTipsHeader);
            } else {
                unValidIds = EvaResultSummaryBillUtil.batchCheckScoreBySummary(ctx, evaResultSummaryCollection, (String) ((HashMap) reviseDataList.get(0)).get("perfSummarySchemeBaseId"), batchMessageTipsHeader);
            }

            if (!CollectionUtils.isEmpty(unValidIds)) {
                summaryIds.removeAll(unValidIds);
            }
            if (!CollectionUtils.isEmpty(summaryErrIds)) {
                summaryIds.removeAll(summaryErrIds);
            }
            if (CollectionUtils.isEmpty(summaryIds)) {
                return;
            }
            IEvaResultSummary resultSummary = EvaResultSummaryFactory.getLocalInstance(ctx);
            EntityViewInfo entityViewInfo = new EntityViewInfo();
            FilterInfo filterInfo = new FilterInfo();
            filterInfo.getFilterItems().add(new FilterItemInfo("id", summaryIds, CompareType.INCLUDE));
            entityViewInfo.setFilter(filterInfo);
            EvaResultSummaryCollection summaryCollection = resultSummary.getEvaResultSummaryCollection(entityViewInfo);
            CoreBaseCollection oldSummaryCollection = new CoreBaseCollection();
            if (summaryCollection != null && summaryCollection.size() > 0) {
                for (int i = 0; i < summaryCollection.size(); ++i) {
                    oldSummaryCollection.add(summaryCollection.get(i));
                }
            }

            EvaResultSumRevisionLogService evaResultSumRevisionLogService = new EvaResultSumRevisionLogService();
            CoreBaseCollection evaResultSumRevisionLogCollection = evaResultSumRevisionLogService.packageResultSumRevisionLog(EvaResultSumLogSourceEnum.ENTRYREVISE, oldSummaryCollection, evaResultSummaryCollection, false);
            System.out.println("evaResultSummaryCollection:" + evaResultSummaryCollection);
            resultSummary.save(evaResultSummaryCollection);
            evaResultSumRevisionLogService.generatedEvaResultSumRevisionLog(ctx, evaResultSumRevisionLogCollection);
        }
    }

    /**
     * 项目经理校验
     *
     * @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);
    }

    private static PerfEvaObjectCollection getPerfEvaObjectCollectionByIds(Set<String> billIds) throws BOSException {
        FilterInfo filterInfo = new FilterInfo();
        filterInfo.getFilterItems().add(new FilterItemInfo("id", billIds, CompareType.INCLUDE));
        EntityViewInfo evi = new EntityViewInfo();
        evi.setFilter(filterInfo);
        IPerfEvaObject iPerfEvaObject = PerfEvaObjectFactory.getRemoteInstance();
        return iPerfEvaObject.getPerfEvaObjectCollection(evi);
    }

    public void batchAssignGroupAction(HttpServletRequest request, HttpServletResponse response, ModelMap modelMap, BatchMessageTipsHeader batchMessageTipsHeader) throws SHRWebException, BOSException {
        String group = request.getParameter("group");
        String billIds = (String) this.getBillId(request);
        Context ctx = SHRContext.getInstance().getContext();
        if (StringUtils.isEmpty(billIds) && StringUtils.isEmpty(group)) {
            throw new ShrWebBizException((new SHRPerfWebBizException(SHRPerfWebBizException.INDECATORNOTSAVEDINSELECTGROUP)).getMessage());
        } else {
            try {
                Set<String> fails = new HashSet();
                List<String> idList = Lists.newArrayList();
                List<String> idsessList = Lists.newArrayList();
                String[] ids = billIds.split(",");
                for (String id : ids) {
                    idList.add(id);
                }
                StringBuilder selParamId = new StringBuilder("''");
                for (int i = 0; i < idList.size(); i++) {
                    selParamId.append(",?");

                }
                StringBuilder sql = new StringBuilder();
                sql.append(" select FEVAOBJID,fid from T_EVA_EvaResultSummary where FBILLSTATE!=3 and fid in ( ");
                sql.append(selParamId);
                sql.append(" ) ");
                IRowSet rowSet = DbUtil.executeQuery(ctx, sql.toString(), idList.toArray());
                while (rowSet.next()) {
                    String fid = rowSet.getString("fid");
                    String upd = "update T_EVA_EvaResultSummary set cfgroup=? where fid=?";
                    DbUtil.execute(ctx, upd, new String[]{group, fid});
                    idsessList.add(fid);
                }

                idList.removeAll(idsessList);
                fails.addAll(idList);
                if (fails.size() > 0) {
                    addBatchMessageTips(fails, "只有未审核的数据才能指定分组。", batchMessageTipsHeader);
                }


            } catch (BOSException var22) {
                logger.error("", var22);
                throw new ShrWebBizException((new SHRPerfWebBizException(SHRPerfWebBizException.SYSTEMERR)).getMessage());
            } catch (SQLException var24) {
                logger.error("", var24);
                throw new ShrWebBizException((new SHRPerfWebBizException(SHRPerfWebBizException.SYSTEMERR)).getMessage());
            }
        }
    }

    public void clearBelongGroupAction(HttpServletRequest request, HttpServletResponse response, ModelMap modelMap, BatchMessageTipsHeader batchMessageTipsHeader) throws SHRWebException, BOSException {
        String billId = this.getBillId(request);
        if (!StringUtils.isEmpty(billId)) {
            try {
                Context ctx = SHRContext.getInstance().getContext();

                List<String> idList = Lists.newArrayList();
                List<String> idsessList = Lists.newArrayList();
                String[] ids = billId.split(",");
                for (String id : ids) {
                    idList.add(id);
                }
                StringBuilder selParamId = new StringBuilder("''");
                for (int i = 0; i < idList.size(); i++) {
                    selParamId.append(",?");
                }
                StringBuilder sql = new StringBuilder();
                sql.append(" select FEVAOBJID,fid from T_EVA_EvaResultSummary where FBILLSTATE!=3 and fid in ( ");
                sql.append(selParamId);
                sql.append(" ) ");
                IRowSet rowSet = DbUtil.executeQuery(ctx, sql.toString(), idList.toArray());
                while (rowSet.next()) {
                    String fid = rowSet.getString("fid");
                    String upd = "update T_EVA_EvaResultSummary set cfgroup=? where fid=?";
                    DbUtil.execute(ctx, upd, new String[]{"", fid});
                    idsessList.add(fid);
                }
                idList.removeAll(idsessList);

                if (idList.size() > 0) {
                    addBatchMessageTips(idList, "只有未审核的数据才能清除分组。", batchMessageTipsHeader);
                }
            } catch (BOSException var22) {
                logger.error("", var22);
                throw new ShrWebBizException((new SHRPerfWebBizException(SHRPerfWebBizException.SYSTEMERR)).getMessage());
            } catch (SQLException var24) {
                logger.error("", var24);
                throw new ShrWebBizException((new SHRPerfWebBizException(SHRPerfWebBizException.SYSTEMERR)).getMessage());
            }
        }
    }

    public Map<String, Map<String, Object>> getPerformanceLevelByLevelAction(HttpServletRequest request, HttpServletResponse response, ModelMap modelMap) throws ShrWebBizException {

        Map<String, Map<String, Object>> result = Maps.newHashMap();
        try {
            Context ctx = SHRContext.getInstance().getContext();
            String sql = "select CFLEVEL,CFCOEFFICIENT,CFMAXCOEFFICIENT,CFMINCOEFFICIENT from CT_PER_PerformanceLevel ";
            IRowSet rs = DbUtil.executeQuery(ctx, sql.toString());
            while (rs.next()) {
                Map<String, Object> map = Maps.newHashMap();
                String CFLEVEL = rs.getString("CFLEVEL");
                BigDecimal CFCOEFFICIENT = rs.getBigDecimal("CFCOEFFICIENT");
                BigDecimal CFMAXCOEFFICIENT = rs.getBigDecimal("CFMAXCOEFFICIENT");
                BigDecimal CFMINCOEFFICIENT = rs.getBigDecimal("CFMINCOEFFICIENT");
                map.put("level", CFLEVEL);
                map.put("coefficient", CFCOEFFICIENT);
                map.put("maxcoefficient", CFMAXCOEFFICIENT);
                map.put("mincoefficient", CFMINCOEFFICIENT);
                result.put(CFLEVEL, map);
            }
        } catch (Exception e) {
            e.printStackTrace();
            throw new ShrWebBizException(e.getMessage());
        }
        return result;
    }

    /**
     * 获取绩效系数
     *
     * @param request
     * @param response
     * @param modelMap
     */
    public void performanceLevelAction(HttpServletRequest request, HttpServletResponse response, ModelMap modelMap, BatchMessageTipsHeader batchMessageTipsHeader) throws BOSException, SHRWebException {
        Context ctx = SHRContext.getInstance().getContext();
        List<String> idList = Lists.newArrayList();
        String ids = (String) this.getBillId(request);
        String period = (String) request.getParameter("period");
        String planId = (String) request.getParameter("planId");
        List<String> idsessList = Lists.newArrayList();
        for (String id : ids.split(",")) {
            idList.add(id);
        }
        StringBuilder selParamId = new StringBuilder("''");
        for (int i = 0; i < idList.size(); i++) {
            selParamId.append(",?");
        }
        try {
            StringBuilder sqlsel = new StringBuilder();
            sqlsel.append(" select fid from T_EVA_EvaResultSummary where FBILLSTATE !=3 and fid in ( ");
            sqlsel.append(selParamId);
            sqlsel.append(" ) ");
            IRowSet rs = DbUtil.executeQuery(ctx, sqlsel.toString(), idList.toArray());
            while (rs.next()) {
                idsessList.add(rs.getString("fid"));
            }
            StringBuilder selsessParamId = new StringBuilder("''");
            for (int i = 0; i < idsessList.size(); i++) {
                selsessParamId.append(",?");
            }
            StringBuilder sqlpl = new StringBuilder();
            //sqlpl.append(" update T_EVA_EvaResultSummary set CFGROUP=(select CFCOEFFICIENT from CT_PER_PerformanceLevel where CFLEVEL=isnull(FREVISEGRADELEVEL,FGRADELEVEL)) ");
            sqlpl.append(" update T_EVA_EvaResultSummary set CFPERCOEFFICIENT=(select CFCOEFFICIENT from CT_PER_PerformanceLevel where CFLEVEL=isnull(FREVISEGRADELEVEL,FGRADELEVEL)), ");
            sqlpl.append(" CFPERMAXCOEFFICIENT=(select CFMAXCOEFFICIENT from CT_PER_PerformanceLevel where CFLEVEL=isnull(FREVISEGRADELEVEL,FGRADELEVEL)), ");
            sqlpl.append(" CFPERMINCOEFFICIENT=(select CFMINCOEFFICIENT from CT_PER_PerformanceLevel where CFLEVEL=isnull(FREVISEGRADELEVEL,FGRADELEVEL)) ");
            sqlpl.append(" where FEVAPLANID =? and FPERIODID =? and fid in ( ");
            sqlpl.append(selsessParamId);
            sqlpl.append(" ) ");
            idsessList.add(0, planId);
            idsessList.add(1, period);
            DbUtil.execute(ctx, sqlpl.toString(), idsessList.toArray());

            idList.removeAll(idsessList);
            if (idList.size() > 0) {
                addBatchMessageTips(idList, "当前已经审核通过获取更新失败", batchMessageTipsHeader);
            }
        } catch (Exception e) {
            e.printStackTrace();
            addBatchMessageTips(idList, e.getMessage(), batchMessageTipsHeader);
        }
    }

    @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", "");
            }
            initData.put("performanceLevel", this.getPerformanceLevelByLevelAction(request, response, modelMap));
        } 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, StringBuilder selParamId) 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, StringBuilder selParamId, List<String> idList) throws BOSException, SQLException {

        Map<String, Map<String, String>> personLevelMap = Maps.newHashMap();
        StringBuilder orgLevelSql = new StringBuilder();
        orgLevelSql.append(" select count(*) lens,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=?  and s1.fid in (");
        orgLevelSql.append(selParamId);
        orgLevelSql.append(") ");
        orgLevelSql.append(" ) t ");
        orgLevelSql.append(" group by  FPERIODID,FEVAPLANID,revLevel ");
        List<String> pam = Lists.newArrayList();
        pam.add(period);
        pam.add(planId);
        pam.addAll(idList);
        IRowSet orgLevelRs = DbUtil.executeQuery(ctx, orgLevelSql.toString(), pam.toArray());
        //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 = 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,selParamId, idList);
            //获取人员等级分组
            Map<String, Map<String, String>> personLevelMap = this.getPersonProjectLevelLensMap(ctx, period, planId, selParamId, idList);

            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");
                if (StrUtil.isBlank(revLevel)) {
                    //String msg = String.format("%s绩效等级为空", CFPROJECTNAME);
                    batchMessage.put(fid, "绩效等级为空,请维护后再审批");
                    continue;
                }

                //项目绩效等级
                String projectLevel = rs.getString("CFProjectLevel");
                if (StrUtil.isBlank(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);
                Map<String, BigDecimal> leveList = Maps.newHashMap();

                //获取等级D人数
                String keyRevLevelD = FPERIODID + FEVAPLANID + "D";
                Map<String, String> personMapD = personLevelMap.get(keyRevLevelD);
                BigDecimal dLens = BigDecimal.ZERO;
                if (null != personMapD) {
                    dLens = new BigDecimal(personMapD.get("lens"));
                    leveList.put("D", dLens);
                }
                //获取等级C人数
                String keyRevLevelC = FPERIODID + FEVAPLANID + "C";
                Map<String, String> personMapC = personLevelMap.get(keyRevLevelC);
                BigDecimal cLens = BigDecimal.ZERO;
                if (null != personMapC) {
                    cLens = new BigDecimal(personMapC.get("lens"));
                    leveList.put("C", cLens);
                }
                //获取等级B人数
                String keyRevLevelB = FPERIODID + FEVAPLANID + "B";
                Map<String, String> personMapB = personLevelMap.get(keyRevLevelB);
                BigDecimal bLens = BigDecimal.ZERO;
                if (null != personMapB) {
                    bLens = new BigDecimal(personMapB.get("lens"));
                    leveList.put("B", bLens);
                }
                //获取等级A人数
                String keyRevLevelA = FPERIODID + FEVAPLANID + "A";
                Map<String, String> personMapA = personLevelMap.get(keyRevLevelA);
                BigDecimal aLens = BigDecimal.ZERO;
                if (null != personMapA) {
                    aLens = new BigDecimal(personMapA.get("lens"));
                    leveList.put("A", aLens);
                }
                //获取等级S人数
                String keyRevLevelS = FPERIODID + FEVAPLANID + "S";
                Map<String, String> personMapS = personLevelMap.get(keyRevLevelS);
                BigDecimal sLens = BigDecimal.ZERO;
                if (null != personMapS) {
                    sLens = new BigDecimal(personMapS.get("lens"));
                    leveList.put("S", sLens);
                }

                //总人数
                BigDecimal alls = new BigDecimal(idList.size());

                //当前等级正态分布比例
                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_HALF_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_HALF_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_HALF_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_HALF_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_HALF_UP));
                bigsList.put("D", bigD);

                //已占用数
                BigDecimal lens = BigDecimal.ZERO;
                //进行额度加减

                    BigDecimal personSize = BigDecimal.ZERO;
                    BigDecimal personMaxSize = BigDecimal.ZERO;
                    BigDecimal personMinSize = BigDecimal.ZERO;
                    List<String> ldrs = Lists.newArrayList();
                    Map<String,String> ldrcd = Maps.newHashMap();
                    switch (revLevel) {
                        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");
                        case "B":
                        case "C":
                            if ("C".equals(revLevel)) {
                                personMinSize = personMinSize.add((bigC));
                            } else {
                                personMinSize = personMinSize.add((bigC).subtract(cLens));
                            }
                            ldrcd.put("C","C最少"+(personMinSize.compareTo(BigDecimal.ZERO) > 0?personMinSize.toPlainString():'0')+"人，");
                            //bigsList.remove("C");
                        case "D":
//                            if (bigD.compareTo(dLens) > 0) {
//                                ldrcd.add("D最少" + bigD.toPlainString() + "人，");
//                            }
                            if ("D".equals(revLevel)) {
                                personMinSize = personMinSize.add((bigD));
                            } else {
                                personMinSize = personMinSize.add((bigD).subtract(dLens));
                            }
                            ldrcd.put("D","D最少"+(personMinSize.compareTo(BigDecimal.ZERO) > 0?personMinSize.toPlainString():'0')+"人，");
                    }
                    String ld = "当前周期绩效等级为%l的人数为%maxs人,";
                    if (personMinSize.compareTo(BigDecimal.ZERO) > 0 || personSize.compareTo(BigDecimal.ZERO) < 0) {
                        if(ldrs.size()>0) {
                            String ldrstr = ldrs.get(0);
                            ld += ldrstr;
                            ld = ld.replace("%" + revLevel, (personMaxSize.compareTo(BigDecimal.ZERO) > 0 ? (personMaxSize) : BigDecimal.ZERO).toPlainString());
                        }
                        ld = ld.replace("%l", revLevel);
                        ld = ld.replace("%maxs", (leveList.get(revLevel) == null ? BigDecimal.ZERO : leveList.get(revLevel)).toPlainString());

                        for (Map.Entry<String,String> entry : ldrcd.entrySet()) {
                            String eKey = entry.getKey();
                            String ldr= entry.getValue();
                            ld += ldr;
                        }
                        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 ( ");
        orgSql.append("  select  ( ");
        orgSql.append("     select top 1 adcount.fid from T_ORG_Admin child ");
        orgSql.append("     left join T_ORG_Admin adcount on (charindex(concat(adcount.flongnumber,'!'),child.flongnumber) = 1 or adcount.flongnumber = child.flongnumber) ");
        orgSql.append("     where child.fid=ers.FADMINORGUNITID ");
        orgSql.append("     and adcount.FLAYERTYPEID='00000000-0000-0000-0000-00000000000362824988' ");
        orgSql.append("     order by adcount.fsortcode) FADMINORGUNITID, ");
        orgSql.append("  ers.FPERIODID,ers.FEVAPLANID from T_EVA_EvaResultSummary ers ");
        orgSql.append(" where ers.FPERIODID=? and ers.FEVAPLANID=? ");
        orgSql.append(" ) t ");
        orgSql.append(" group by FADMINORGUNITID, FPERIODID, FEVAPLANID ");

        //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, StringBuilder selParamId, List<String> idList) throws BOSException, SQLException {

        Map<String, Map<String, String>> personLevelMap = Maps.newHashMap();
        StringBuilder orgLevelSql = new StringBuilder();
        orgLevelSql.append(" select count(*) lens, ");
        //orgLevelSql.append(" FADMINORGUNITID, ");
        orgLevelSql.append(" FPERIODID,FEVAPLANID,revLevel from ( ");
        orgLevelSql.append("     select ");
//        orgLevelSql.append("      (select top 1 adcount.fid from T_ORG_Admin child ");
//        orgLevelSql.append("       left join T_ORG_Admin adcount on (charindex(concat(adcount.flongnumber,'!'),child.flongnumber) = 1 or adcount.flongnumber = child.flongnumber) ");
//        orgLevelSql.append("       where child.fid=s1.FADMINORGUNITID ");
//        orgLevelSql.append("       and adcount.FLAYERTYPEID='00000000-0000-0000-0000-00000000000362824988' ");
//        orgLevelSql.append("       order by adcount.fsortcode) FADMINORGUNITID, ");
        orgLevelSql.append("       s1.FPERIODID,s1.FEVAPLANID,isnull(s1.FREVISEGRADELEVEL,s1.FGRADELEVEL) revLevel  ");
        orgLevelSql.append("     from T_EVA_EvaResultSummary s1 ");
        orgLevelSql.append("  where  s1.FPERIODID=? and s1.FEVAPLANID=? and s1.fid in (");
        orgLevelSql.append(selParamId);
        orgLevelSql.append(") ");
        orgLevelSql.append(" ) t ");
        orgLevelSql.append(" group by  ");
        //orgLevelSql.append(" FADMINORGUNITID,");
        orgLevelSql.append(" FPERIODID,FEVAPLANID,revLevel ");
        List<String> pam = Lists.newArrayList();
        pam.add(period);
        pam.add(planId);
        pam.addAll(idList);
        IRowSet orgLevelRs = DbUtil.executeQuery(ctx, orgLevelSql.toString(), pam.toArray());
        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;
            String key = FPERIODID + FEVAPLANID + revLevel;
            map.put("lens", orgLevelRs.getString("lens"));
            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);
        }
    }

    /**
     * 结果直接审核、结果工作流审核，绩效等级分布比例校验人数由整个绩效考核计划的人数改为按选择的人数进行分布比例校验。
     *
     * @param ctx
     * @param period
     * @param planId
     * @param idList
     * @return
     * @throws BOSException
     * @throws SQLException
     */
    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, selParamId, idList);
            StringBuilder sel = new StringBuilder();
            sel.append(" select ers.fid,ers.FADMINORGNAME,  ");
//            sel.append(" (select top 1 adcount.fid from T_ORG_Admin child ");
//            sel.append(" left join T_ORG_Admin adcount on (charindex(concat(adcount.flongnumber,'!'),child.flongnumber) = 1 or adcount.flongnumber = child.flongnumber) ");
//            sel.append(" where child.fid=ers.FADMINORGUNITID ");
//            sel.append("  and adcount.FLAYERTYPEID='00000000-0000-0000-0000-00000000000362824988' ");
//            sel.append("  order by adcount.fsortcode) FADMINORGUNITID, ");
            sel.append("  ers.FPERIODID, ers.FEVAPLANID,isnull(ers.FREVISEGRADELEVEL, ers.FGRADELEVEL) revLevel,ers.CFOrgLevel  ");

            sel.append(" from T_EVA_EvaResultSummary ers where ers.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");
                if (StrUtil.isBlank(revLevel)) {
                    batchMessage.put(fid, "绩效等级为空,请维护后再审批");
                    continue;
                }

                //上季度组织绩效等级
                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);
                Map<String, BigDecimal> leveList = Maps.newHashMap();
                //获取等级D人数
                String keyRevLevelD = FPERIODID + FEVAPLANID + "D";
                Map<String, String> personMapD = personLevelMap.get(keyRevLevelD);
                BigDecimal dLens = BigDecimal.ZERO;
                if (null != personMapD) {
                    dLens = new BigDecimal(personMapD.get("lens"));
                    leveList.put("D", dLens);
                }
                //获取等级C人数
                String keyRevLevelC = FPERIODID + FEVAPLANID + "C";
                Map<String, String> personMapC = personLevelMap.get(keyRevLevelC);
                BigDecimal cLens = BigDecimal.ZERO;
                if (null != personMapC) {
                    cLens = new BigDecimal(personMapC.get("lens"));
                    leveList.put("C", cLens);
                }
                //获取等级B人数
                String keyRevLevelB = FPERIODID + FEVAPLANID + "B";
                Map<String, String> personMapB = personLevelMap.get(keyRevLevelB);
                BigDecimal bLens = BigDecimal.ZERO;
                if (null != personMapB) {
                    bLens = new BigDecimal(personMapB.get("lens"));
                    leveList.put("B", bLens);
                }
                //获取等级A人数
                String keyRevLevelA = FPERIODID + FEVAPLANID + "A";
                Map<String, String> personMapA = personLevelMap.get(keyRevLevelA);
                BigDecimal aLens = BigDecimal.ZERO;
                if (null != personMapA) {
                    aLens = new BigDecimal(personMapA.get("lens"));
                    leveList.put("A", aLens);
                }
                //获取等级S人数
                String keyRevLevelS = FPERIODID + FEVAPLANID + "S";
                Map<String, String> personMapS = personLevelMap.get(keyRevLevelS);
                BigDecimal sLens = BigDecimal.ZERO;
                if (null != personMapS) {
                    sLens = new BigDecimal(personMapS.get("lens"));
                    leveList.put("S", sLens);
                }

                //总人数
                BigDecimal alls = new BigDecimal(idList.size());

                //当前等级正态分布比例
                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_HALF_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_HALF_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_HALF_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_HALF_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_HALF_UP));
                bigsList.put("D", bigD);

                //已占用数
                BigDecimal lens = BigDecimal.ZERO;
                //进行额度加减
                //if ("S".equals(revLevel) || "A".equals(revLevel)||"B".equals(revLevel) || "C".equals(revLevel) || "D".equals(revLevel)) {
                    BigDecimal personSize = BigDecimal.ZERO;
                    BigDecimal personMaxSize = BigDecimal.ZERO;
                    BigDecimal personMinSize = BigDecimal.ZERO;
                    List<String> ldrs = Lists.newArrayList();
                    Map<String,String> ldrcd = Maps.newHashMap();
                    switch (revLevel) {
                        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");
                        case "B":
                        case "C":
                            if ("C".equals(revLevel)) {
                                personMinSize = personMinSize.add((bigC));
                            } else {
                                personMinSize = personMinSize.add((bigC).subtract(cLens));
                            }
                            ldrcd.put("C","C最少"+(personMinSize.compareTo(BigDecimal.ZERO) > 0?personMinSize.toPlainString():'0')+"人，");
                            //bigsList.remove("C");
                        case "D":
//                            if (bigD.compareTo(dLens) > 0) {
//                                ldrcd.add("D最少" + bigD.toPlainString() + "人，");
//                            }
                            if ("D".equals(revLevel)) {
                                personMinSize = personMinSize.add((bigD));
                            } else {
                                personMinSize = personMinSize.add((bigD).subtract(dLens));
                            }
                            ldrcd.put("D","D最少"+(personMinSize.compareTo(BigDecimal.ZERO) > 0?personMinSize.toPlainString():'0')+"人，");
                    }
                    String ld = "当前周期绩效等级为%l的人数为%maxs人,";
                    if (personMinSize.compareTo(BigDecimal.ZERO) > 0 || personSize.compareTo(BigDecimal.ZERO) < 0) {
                        if(ldrs.size()>0){
                            String ldrstr = ldrs.get(0);
                            ld += ldrstr;
                            ld = ld.replace("%" + revLevel, (personMaxSize.compareTo(BigDecimal.ZERO) > 0 ? (personMaxSize) : BigDecimal.ZERO).toPlainString());
                        }
                        ld = ld.replace("%l", revLevel);
                        ld = ld.replace("%maxs", (leveList.get(revLevel) == null ? BigDecimal.ZERO : leveList.get(revLevel)).toPlainString());

                        for (Map.Entry<String,String> entry : ldrcd.entrySet()) {
                            String eKey = entry.getKey();
                            String ldr= entry.getValue();
                            ld += ldr;
                        }
                        ld += "请修正后重新审核.";
                        batchMessage.put(fid, ld);
                    }
            }
        }
        return batchMessage;
    }

    //    public boolean validatePerformanceRatings(Map<String, String> batchMessage,Map<String, BigDecimal> bigsList,BigDecimal alls) {
//        // 统计各绩效等级的数量
//        long totalEmployees = employeeRatings.size();
//        long sCount = employeeRatings.values().stream().filter(rating -> "S".equals(rating)).count();
//        long aCount = employeeRatings.values().stream().filter(rating -> "A".equals(rating)).count();
//        long bCount = employeeRatings.values().stream().filter(rating -> "B".equals(rating)).count();
//        long cCount = employeeRatings.values().stream().filter(rating -> "C".equals(rating)).count();
//        long dCount = employeeRatings.values().stream().filter(rating -> "D".equals(rating)).count();
//
//        // 计算满员时 S 等级的最大人数
//        int maxSCount = (int) Math.floor(totalEmployees * 0.1);
//        // 计算 S 等级未满员时，可以分配到 A 等级的人数
//        int remainingSCount = maxSCount - (int) sCount;
//        // 如果 S 等级未满员，将剩余名额加到 A 等级的人数中
//        long adjustedACount = aCount + remainingSCount;
//
//        // 计算各绩效等级的比例
//        double sPercentage = totalEmployees == 0 ? 0 : (double) sCount / totalEmployees * 100;
//        double aPercentage = totalEmployees == 0 ? 0 : (double) adjustedACount / totalEmployees * 100;
//        double cPercentage = totalEmployees == 0 ? 0 : (double) cCount / totalEmployees * 100;
//        double dPercentage = totalEmployees == 0 ? 0 : (double) dCount / totalEmployees * 100;
//
//        // 校验各绩效等级比例是否符合要求
//        boolean sValid = sPercentage <= 10;
//        boolean aValid = aPercentage <= 20;
//        boolean cValid = cPercentage >= 10;
//        boolean dValid = dPercentage >= 5;
//
//        // 输出各绩效等级的比例和校验结果
//        System.out.println("绩效等级 S 的比例为：" + String.format("%.2f", sPercentage) + "%，" +
//                "是否符合要求：" + sValid + "，未满员可分配到 A 等级的人数：" + remainingSCount);
//        System.out.println("绩效等级 A 的比例为：" + String.format("%.2f", aPercentage) + "%，" +
//                "是否符合要求：" + aValid);
//        System.out.println("绩效等级 C 的比例为：" + String.format("%.2f", cPercentage) + "%，" +
//                "是否符合要求：" + cValid);
//        System.out.println("绩效等级 D 的比例为：" + String.format("%.2f", dPercentage) + "%，" +
//                "是否符合要求：" + dValid);
//
//        return sValid && aValid && cValid && dValid;
//    }
    @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);
            }
        }
    }

    /**
     * 获取上季度组织等级批量
     * WholeCommentOSFService
     *
     * @description:
     * @author: lhbj
     * @date: 2025/1/10 18:18
     * @param: null
     * @return:null
     **/
    public void bindWholeCommentAction(HttpServletRequest request, HttpServletResponse response, ModelMap modelMap) throws SHRWebException {
        Context ctx = SHRContext.getInstance().getContext();
        try {
            Object obj = MSFServiceFacadeFactory.getLocalInstance(ctx).processService("wholeComment", new HashMap());
            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.FBILLSTATE,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");
                    String FBILLSTATE = rsSql.getString("FBILLSTATE");
                    if (!"3".equals(FBILLSTATE)) {
                        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);
                        }
                    } else {
                        batchMessage.put(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.FBILLSTATE, ");
                sql.append(" (select top 1 adcount.fid from T_ORG_Admin child   ");
                sql.append(" left join T_ORG_Admin adcount on (charindex(concat(adcount.flongnumber,'!'),child.flongnumber) = 1 or adcount.flongnumber = child.flongnumber) ");
                sql.append(" where child.fid=ers.FADMINORGUNITID  ");
                sql.append(" and adcount.FLAYERTYPEID='00000000-0000-0000-0000-00000000000362824988' ");
                sql.append(" order by adcount.fsortcode)  FADMINORGUNITID ");
                sql.append(" ,ers.FADMINORGNAME,pp.FYEAR,pp.FTIMEPERIOD, ");
                sql.append(" 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(" ) ");

                IRowSet rsSql = DbUtil.executeQuery(ctx, sql.toString());
                boolean faist = true;
                Map<String, Object> cycleMap = null;
                Map<String, Object> cycleMap2 = null;
                while (rsSql.next()) {
                    String id = rsSql.getString("fid");
                    String orgId = rsSql.getString("FADMINORGUNITID");
                    IRowSet rs = DbUtil.executeQuery(ctx, "select fname_l2 from t_org_admin where fid='" + orgId + "'");
                    String orgName = rsSql.getString("FADMINORGNAME");
                    String orgName_l2 = orgName;
                    if (rs.next()) {
                        orgName_l2 = rs.getString("fname_l2");
                    }

                    String FBILLSTATE = rsSql.getString("FBILLSTATE");

                    if (faist) {
                        faist = false;
                        int FCYCLETYPE = rsSql.getInt("FCYCLETYPE");
                        Date FPENDDATE = rsSql.getDate("FPENDDATE");
                        Date FPSTARTDATE = rsSql.getDate("FPSTARTDATE");

                        cycleMap = this.getCycletype(sf.format(FPSTARTDATE), sf.format(FPENDDATE), EvalplanCycleTypeEnum.QUARTER_VALUE);
                        cycleMap2 = this.getCycletype(sf.format(FPSTARTDATE), sf.format(FPENDDATE), EvalplanCycleTypeEnum.FULL_YEAR_VALUE);
                    }
                    id_orgIdMap.put(id, orgId + "!" + orgName_l2 + "!" + FBILLSTATE);
                }
                List<String> sess = Lists.newArrayList();
                EvalplanCycleTypeEnum cycleTypeEnum = (EvalplanCycleTypeEnum) cycleMap.get("cycleType");
                LocalDate endDate = (LocalDate) cycleMap.get("endDate");
                LocalDate startDate = (LocalDate) cycleMap.get("startDate");
                int year = (int) cycleMap.get("year");
                int quarter = (int) cycleMap.get("quarter");
                EvalplanCycleTypeEnum cycleTypeEnum2 = (EvalplanCycleTypeEnum) cycleMap2.get("cycleType");
                LocalDate endDate2 = (LocalDate) cycleMap2.get("endDate");
                LocalDate startDate2 = (LocalDate) cycleMap2.get("startDate");
                int year2 = (int) cycleMap2.get("year");
                int quarter2 = (int) cycleMap2.get("quarter");
                Map<String, Map<String, String>> mapMap = this.getOrgEvaResultLevel(ctx, startDate, endDate, cycleTypeEnum, year, quarter);
                Map<String, Map<String, String>> mapMap2 = this.getOrgEvaResultLevel(ctx, startDate2, endDate2, cycleTypeEnum2, year2, quarter2);
                for (Map.Entry<String, String> ee : id_orgIdMap.entrySet()) {
                    String[] orgs = ee.getValue().split("!");
                    String orgId = orgs[0];
                    String orgName = orgs[1];
                    String FBILLSTATE = orgs[2];
                    String id = ee.getKey();
                    if (!"3".equals(FBILLSTATE)) {
                        Map<String, String> orgLevelMap = mapMap.get(orgId);
                        if (null == orgLevelMap) {
                            orgLevelMap = mapMap2.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);
                        }
                    } else {
                        batchMessage.put(id, "当前已经审核通过获取更新失败！");
                    }
                }
            } catch (Exception e) {
                e.printStackTrace();
                throw new Exception(e);
            }
        }
        return batchMessage;
    }

    public static 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;
            int month = startDate.getMonthValue();
            //获取为季度
            int quarter = (month - 1) / 3;
            int year = endDate.getYear();

            map.put("year", year);
            map.put("quarter", 1);
        } else if (EvalplanCycleTypeEnum.HALF_YEAR_VALUE == cycletype) {
            //周期为半年度
            endDate = endDate.plusMonths(-6);
            startDate = startDate.plusMonths(-6);
            cycleTypeEnum = EvalplanCycleTypeEnum.HALF_YEAR;
            int month = startDate.getMonthValue();
            //获取为季度
            int quarter = (month - 1) / 3;
            int year = endDate.getYear();
            if (0 == quarter) {
                year = year - 1;
                quarter = 4;
            }
            map.put("year", year);
            map.put("quarter", month < 7 ? 1 : 2);
        } else if (EvalplanCycleTypeEnum.QUARTER_VALUE == cycletype) {

            int month = startDate.getMonthValue();

            //获取为季度0~3季度
            int quarter = (month - 1) / 3;
            //当前季度为第一季度，则需取上一年度的季度
            int year = endDate.getYear();
            if (0 == quarter) {
                year = year - 1;
                quarter = 4;
            }
            Month endMonth = Month.of(quarter * 3);
            endDate = LocalDate.of(year, endMonth, endMonth.length(endDate.isLeapYear()));
            Month startMonth = Month.of(endMonth.getValue() - 2);
            startDate = LocalDate.of(year, startMonth, 1);
            cycleTypeEnum = EvalplanCycleTypeEnum.QUARTER;
            map.put("year", year);
            map.put("quarter", quarter);
        } else if (EvalplanCycleTypeEnum.MONTHLY_VALUE == cycletype) {
            //获取为季度
            endDate = endDate.plusMonths(-1);
            startDate = startDate.plusMonths(-1);
            cycleTypeEnum = EvalplanCycleTypeEnum.MONTHLY;
            int month = startDate.getMonthValue();
            //获取为季度
            int quarter = (month - 1) / 3;
            int year = endDate.getYear();
            if (0 == quarter) {
                year = year - 1;
                quarter = 4;
            }
            map.put("year", year);
            map.put("quarter", quarter);
        }
        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, EvalplanCycleTypeEnum cycletype, int year, int quarter) throws BOSException, SQLException {
        //202404J
        String FPERIODNAME = "";
        if (EvalplanCycleTypeEnum.FULL_YEAR == cycletype) {
            FPERIODNAME = year + "M";
        } else if (EvalplanCycleTypeEnum.HALF_YEAR == cycletype) {
            FPERIODNAME = year + "0" + quarter + "H";
        } else if (EvalplanCycleTypeEnum.QUARTER == cycletype) {
            FPERIODNAME = year + "0" + quarter + "J";
        } else if (EvalplanCycleTypeEnum.MONTHLY == cycletype) {
            FPERIODNAME = year + (quarter > 9 ? ("" + quarter) : ("0" + quarter)) + "M";
        }
        return this.getOrgEvaResultLevel(ctx, startDate, endDate, cycletype, FPERIODNAME, year, quarter);
    }

    protected Map<String, Map<String, String>> getOrgEvaResultLevel(Context ctx, LocalDate startDate, LocalDate endDate) throws BOSException, SQLException {
        return this.getOrgEvaResultLevel(ctx, startDate, endDate, EvalplanCycleTypeEnum.QUARTER, "", 2000, 1);
    }

    protected Map<String, Map<String, String>> getOrgEvaResultLevel(Context ctx, LocalDate startDate, LocalDate endDate, EvalplanCycleTypeEnum cycletype, String FPERIODNAME, int year, int quarter) throws BOSException, SQLException {
        Map<String, Map<String, String>> mapMap = Maps.newHashMap();
        StringBuffer selSql = new StringBuffer();
        selSql.append(" select oers.fid oersId, ");
        selSql.append(" oers.FADMINORGUNITID FADMINORGUNITID, ");
        selSql.append(" 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' ");
        selSql.append(" and oers.FADMINORGUNITID in( ");
        selSql.append(" select adcount.fid from T_ORG_Admin child ");
        selSql.append(" left join T_ORG_Admin adcount on (charindex(concat(adcount.flongnumber,'!'),child.flongnumber) = 1 or adcount.flongnumber = child.flongnumber) ");
        selSql.append(" where child.fid=oers.FADMINORGUNITID   and adcount.FLAYERTYPEID='00000000-0000-0000-0000-00000000000362824988' ");
        selSql.append(" ) ");
        selSql.append(" UNION all ");
        selSql.append(" select fid oersId, ");
        selSql.append("         FADMINORGUNITID , ");
        selSql.append("         FLASTGRADELEVEL,(FPERIODYEAR||'-'||(FPERIODTIME*3-2)||'-'||'01')||'T'|| (FPERIODYEAR||'-'||(FPERIODTIME*3)||'-'||?)  PERIOD ");
        selSql.append(" from T_EVA_OrgEvaResultSummary where FEVAPLANNAME='手工录入' ");
        selSql.append(" and FADMINORGUNITID  in( ");
        selSql.append("         select adcount.fid from T_ORG_Admin child ");
        selSql.append("         left join T_ORG_Admin adcount on (charindex(concat(adcount.flongnumber,'!'),child.flongnumber) = 1 or adcount.flongnumber = child.flongnumber) ");
        selSql.append("         where child.fid=FADMINORGUNITID   and adcount.FLAYERTYPEID='00000000-0000-0000-0000-00000000000362824988' ");
        selSql.append(" ) ");
        selSql.append(" and FPERIODTIMENUMBER like ? ");
        Month endMonth = Month.of(quarter * 3);
        Year year1 = Year.of(year);
        int days = endMonth.length(year1.isLeap());
        String[] param = new String[]{startDate.format(DateTimeFormatter.ISO_LOCAL_DATE),
                endDate.format(DateTimeFormatter.ISO_LOCAL_DATE),
                String.valueOf(cycletype.getValue()),
                ((days > 9) ? String.valueOf(days) : ("0" + String.valueOf(days))),
                (FPERIODNAME + "%")
        };
        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]);
        i = selSql.indexOf("?");
        selSql.replace(i, i + 1, param[2]);
        i = selSql.indexOf("?");
        selSql.replace(i, i + 1, param[3]);
        i = selSql.indexOf("?");
        selSql.replace(i, i + 1, param[4]);
        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 = "2024-10-01";
        String penddate = "2024-10-31";
        int cycletype = 300;

        System.out.println(getCycletype(pstartdate, penddate, cycletype));


       String strs = "[{\"evaResult.pnumber\":\"0000381\",\"evaResult.pname\":\"谭梓傲\",\"evaResult.positionName\":\"物资岗\",\"evaResult.evaObj.perfFile.adminOrgUnit.company.name\":\"湖南红太阳光电科技有限公司\",\"evaResult.evaObj.perfFile.adminOrgUnit.department.name\":\"综合管理\",\"evaResult.sumScore\":\"<span></span>\",\"evaResult.gradeLevel\":\"\",\"evaResult.auditSumScore\":\"<span value=\\\\\"86\\\\\">86.00</span>\",\"evaResult.auditGradeLevel\":\"C\",\"evaResult.auditReason\":\"<div class=\\\\\"cell-height scrollbarthin\\\\\">正态分布更新结果</div>\",\"evaResult.reviseSumScore\":\"<span value=\\\\\"86\\\\\">86.00</span>\", \"evaResult.reviseGradeLevel\":\"C\",\"evaResult.reviseReason\":\"正态分布更新结果\", \"id\":\"KQukJy27Skiy1rPPghjkJBdK16Q=\",\"evaResult.id\":\"Ka7FkRQuTAaPlTaLvJSD3IESG3Q=\",\"bill.id\":\"m85zTeeDSmaAU2QLbYWMUoZLdW4=\",\"evaResult.evaObj.id\":\"gjX3giS2RKurkJVjPhnwa4GI54s=\",\"reviseGradeLevelSelect\":\"[{\\\\\"value\\\\\":\\\\\"S\\\\\",\\\\\"alias\\\\\":\\\\\"S\\\\\"},{\\\\\"value\\\\\":\\\\\"A\\\\\",\\\\\"alias\\\\\":\\\\\"A\\\\\"},{\\\\\"value\\\\\":\\\\\"B\\\\\",\\\\\"alias\\\\\":\\\\\"B\\\\\"},{\\\\\"value\\\\\":\\\\\"C\\\\\",\\\\\"alias\\\\\":\\\\\"C\\\\\"},{\\\\\"value\\\\\":\\\\\"D\\\\\",\\\\\"alias\\\\\":\\\\\"D\\\\\"}]\",\"levelScoreKVInfo\":\"{\\\\n  \\\\\"90.00~100.00\\\\\": \\\\\"S\\\\\",\\\\n  \\\\\"80.00~90.00\\\\\": \\\\\"A\\\\\",\\\\n  \\\\\"70.00~80.00\\\\\": \\\\\"B\\\\\",\\\\n  \\\\\"60.00~70.00\\\\\": \\\\\"C\\\\\",\\\\n  \\\\\"0.00~60.00\\\\\": \\\\\"D\\\\\"\\\\n}\",\"scoreLowLimit\":\"0\",\"scoreUpLimit\":\"100\",\"evaResult.period.id\":\"q6myAjHaQLK+wnczfdLCJEUaiOU=\",\"evaResult.reviseFlag\":\"是\",\"evaResult.auditFlag\":\"否\"},{\"evaResult.pnumber\":\"0000355\",\"evaResult.pname\":\"罗建荣\",\"evaResult.positionName\":\"叉车岗\",\"evaResult.evaObj.perfFile.adminOrgUnit.company.name\":\"湖南红太阳光电科技有限公司\",\"evaResult.evaObj.perfFile.adminOrgUnit.department.name\":\"设备总装\",\"evaResult.sumScore\":\"<span></span>\",\"evaResult.gradeLevel\":\"\",\"evaResult.auditSumScore\":\"<span value=\\\\\"87\\\\\">87.00</span>\",\"evaResult.auditGradeLevel\":\"<div class=\\\\\"ui-select-frame\\\\\" style=\\\\\"width: 99%;\\\\\"><div class=\\\\\"ui-select-layout\\\\\"><div class=\\\\\"ui-select-inputframe\\\\\"><input type=\\\\\"hidden\\\\\" id=\\\\\"2_evaResult.auditGradeLevel_el\\\\\" name=\\\\\"undefined_el\\\\\" value=\\\\\"A\\\\\" autocomplete=\\\\\"off\\\\\" data-value=\\\\\"A\\\\\"><input id=\\\\\"2_evaResult.auditGradeLevel\\\\\" type=\\\\\"text\\\\\" maxlength=\\\\\"200\\\\\" class=\\\\\"block-father input-height cursor-pointer\\\\\" ctrlrole=\\\\\"select\\\\\" readonly=\\\\\"readonly\\\\\" style=\\\\\"width: 100%;\\\\\" title=\\\\\"A\\\\\"></div><div class=\\\\\"ui-select-icon\\\\\"><i class=\\\\\"icon-remove\\\\\" style=\\\\\"color: rgb(156, 178, 188); font-size: 16px; padding: 0px; vertical-align: middle; display: none;\\\\\"></i><i class=\\\\\"icon-chevron-down\\\\\" style=\\\\\"color: rgb(121, 144, 155);\\\\\"></i></div></div></div>\",\"evaResult.auditReason\":\"<div class=\\\\\"cell-height scrollbarthin\\\\\">正态分布更新结果</div>\",\"evaResult.reviseSumScore\":\"<span value=\\\\\"87\\\\\">87.00</span>\", \"evaResult.reviseGradeLevel\":\"C\",\"evaResult.reviseReason\":\"正态分布更新结果\", \"id\":\"MBMgAczuRfeGJ0APPqoJTxdK16Q=\",\"evaResult.id\":\"3USiI6FbQ5mtaXC9qUk3NIESG3Q=\",\"bill.id\":\"m85zTeeDSmaAU2QLbYWMUoZLdW4=\",\"evaResult.evaObj.id\":\"gEO59hOoSlaBEVulLZaDOoGI54s=\",\"reviseGradeLevelSelect\":\"[{\\\\\"value\\\\\":\\\\\"S\\\\\",\\\\\"alias\\\\\":\\\\\"S\\\\\"},{\\\\\"value\\\\\":\\\\\"A\\\\\",\\\\\"alias\\\\\":\\\\\"A\\\\\"},{\\\\\"value\\\\\":\\\\\"B\\\\\",\\\\\"alias\\\\\":\\\\\"B\\\\\"},{\\\\\"value\\\\\":\\\\\"C\\\\\",\\\\\"alias\\\\\":\\\\\"C\\\\\"},{\\\\\"value\\\\\":\\\\\"D\\\\\",\\\\\"alias\\\\\":\\\\\"D\\\\\"}]\",\"levelScoreKVInfo\":\"{\\\\n  \\\\\"90.00~100.00\\\\\": \\\\\"S\\\\\",\\\\n  \\\\\"80.00~90.00\\\\\": \\\\\"A\\\\\",\\\\n  \\\\\"70.00~80.00\\\\\": \\\\\"B\\\\\",\\\\n  \\\\\"60.00~70.00\\\\\": \\\\\"C\\\\\",\\\\n  \\\\\"0.00~60.00\\\\\": \\\\\"D\\\\\"\\\\n}\",\"scoreLowLimit\":\"0\",\"scoreUpLimit\":\"100\",\"evaResult.period.id\":\"q6myAjHaQLK+wnczfdLCJEUaiOU=\",\"evaResult.reviseFlag\":\"是\",\"evaResult.auditFlag\":\"否\"}]";
        JSONArray entryList  = JSON.parseArray(strs);
        System.out.println( );
    }
}