SsProject/websrc/com/kingdee/eas/custom/ot/util/OverTimeAgainstApproveUtil.java

package com.kingdee.eas.custom.ot.util;

import com.google.common.collect.Maps;
import com.kingdee.bos.BOSException;
import com.kingdee.bos.Context;
import com.kingdee.bos.dao.ObjectNotFoundException;
import com.kingdee.bos.dao.ormapping.ObjectUuidPK;
import com.kingdee.bos.metadata.entity.SelectorItemCollection;
import com.kingdee.bos.metadata.entity.SelectorItemInfo;
import com.kingdee.bos.util.BOSUuid;
import com.kingdee.eas.base.permission.UserInfo;
import com.kingdee.eas.common.EASBizException;
import com.kingdee.eas.framework.CoreBaseCollection;
import com.kingdee.eas.hr.ats.*;
import com.kingdee.eas.hr.ats.dataLog.util.DataLogsRecordUtil;
import com.kingdee.eas.hr.ats.takeWorkLimit.impl.GenerateTakeWorkLimit;
import com.kingdee.eas.hr.ats.thread.ExecutorService.TaskPool;
import com.kingdee.eas.hr.ats.thread.executor.Callable;
import com.kingdee.eas.hr.ats.util.AtsDateUtils;
import com.kingdee.eas.hr.ats.util.AtsServerCalUtils;
import com.kingdee.eas.hr.ats.util.SHRBillServerUtil;
import com.kingdee.eas.hr.ats.util.common.MLUtile;
import com.kingdee.eas.util.app.DbUtil;
import com.kingdee.jdbc.rowset.IRowSet;
import com.kingdee.shr.ats.bill.util.AtsBillSourceTypeUtil;
import com.kingdee.shr.ats.service.result.AttendCalculateParent;
import com.kingdee.shr.ats.service.vo.AtsOverTimeVo;
import com.kingdee.shr.base.syssetting.app.osf.OSFAppUtil;
import com.kingdee.shr.base.syssetting.exception.SHRWebException;
import com.kingdee.shr.base.syssetting.exception.ShrWebBizException;
import org.apache.commons.lang.StringUtils;
import org.apache.log4j.Logger;

import javax.servlet.http.HttpServletRequest;
import java.math.BigDecimal;
import java.sql.Timestamp;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.concurrent.ThreadPoolExecutor;

/**
 * 加班单
 * 反审批
 *
 * @ lhbj
 */
public class OverTimeAgainstApproveUtil {
    private static Logger logger = Logger.getLogger(OverTimeAgainstApproveUtil.class);

    public String getBillIds(HttpServletRequest request) throws ShrWebBizException {
        String billId = (String) request.getAttribute("billId");
        if (StringUtils.isEmpty(billId)) {
            billId = request.getParameter("billId");
        }

        if (StringUtils.isEmpty(billId)) {
            billId = request.getParameter("billID");
        }
        if (StringUtils.isEmpty(billId)) {
            billId = (String) request.getAttribute("billID");
        }
        if (StringUtils.isEmpty(billId)) {
            throw new ShrWebBizException(new AtsCommonBizException(AtsCommonBizException.NULLBILLID));
        } else {
            return billId;
        }
    }

    /**
     * 取消核通过的单据分录变更
     * @param ctx
     * @param billId
     * @param entryId
     * @return
     * @throws SHRWebException
     */
    public Map<String, Object> unChangeOTEntry(Context ctx, String billId, String entryId) throws BOSException {
        Map<String, Object> res = Maps.newHashMap();
//        IAtsOverTimeBill iBill = AtsOverTimeBillFactory.getLocalInstance(ctx);
//        IAtsOverTimeBillEntry iBillEntry = AtsOverTimeBillEntryFactory.getLocalInstance(ctx);
        //删除新单据分录
        String updEntry2 = "delete from T_HR_ATS_OverTimeBillEntry where fid=?";
        DbUtil.execute(ctx, updEntry2, new String[]{entryId.toString()});
        //新单据
//        String delNewBill = "delete from T_HR_ATS_OverTimeBill where fid=?";
//        DbUtil.execute(ctx, delNewBill, new String[]{billId.toString()});
        return res;
    }

    /**
     * 变更审批通过的分录
     * 第一步：生成一样数据进行
     *
     * @param ctx
     * @param billId
     * @param entryId
     * @return
     */
    public Map<String, Object> changeOTEntry(Context ctx, String billId, String entryId) throws BOSException {
        System.out.println("changeOTEntry");
        Map<String, Object> res = Maps.newHashMap();
        IAtsOverTimeBill iBill = AtsOverTimeBillFactory.getLocalInstance(ctx);
        IAtsOverTimeBillEntry iBillEntry = AtsOverTimeBillEntryFactory.getLocalInstance(ctx);
        //更新id
        BOSUuid newId = null;
        BOSUuid newEntryId = null;

        res.put("code", "err");
        res.put("msg", "失败");
        try {
            System.out.println("changeOTEntry:" + billId + "-" + entryId);
            SelectorItemCollection selectorItemCollection = new SelectorItemCollection();
            selectorItemCollection.add(new SelectorItemInfo("*"));
            //获取原单分录
            AtsOverTimeBillEntryInfo oldEntryInfo = iBillEntry.getAtsOverTimeBillEntryInfo(new ObjectUuidPK(entryId), selectorItemCollection);
            //获取原单
            AtsOverTimeBillInfo oldBillInfo = iBill.getAtsOverTimeBillInfo(new ObjectUuidPK(billId), selectorItemCollection);
            System.out.println("changeOTEntry");
            //创建新单
            AtsOverTimeBillInfo newBillInfo = (AtsOverTimeBillInfo) oldBillInfo.clone();
            newBillInfo.setSourceBillId(newBillInfo.getId().toString());
            //更新为单人编辑界面
            newBillInfo.setBillSubmitType(BillSubmitTypeEnum.common);
            System.out.println("changeOTEntry");
            //更新id
            newId = BOSUuid.create(oldBillInfo.getBOSType());
            newBillInfo.setId(newId);
            //创建新单分录集合
            AtsOverTimeBillEntryCollection newEntryCollection = new AtsOverTimeBillEntryCollection();
            //添加待变更分录
            AtsOverTimeBillEntryInfo newEntryInfo = (AtsOverTimeBillEntryInfo) oldEntryInfo.clone();
            //变更分录id
            newEntryId = BOSUuid.create(oldEntryInfo.getBOSType());
            newEntryInfo.setId(newEntryId);
            newEntryInfo.setBill(newBillInfo);
            newEntryCollection.add(newEntryInfo);
            newBillInfo.put("entries", newEntryCollection);
            System.out.println("changeOTEntry4" + newBillInfo);
            iBill.addnew(new ObjectUuidPK(newId), newBillInfo);
            //更新新单为审批通过
            String updBill = "update T_HR_ATS_OverTimeBill set FBillState=3 where fid=?";
            DbUtil.execute(ctx, updBill, new String[]{newId.toString()});
            System.out.println("changeOTEntry5" + newId.toString());
            //反审批校验
            Map<String, Object> bres = this.beforeAgainstApproveAction(ctx, newId.toString());
            System.out.println("changeOTEntry6" + bres.toString());
            res.putAll(bres);
            String errorMsgList = (String) bres.get("errorMsgList");
            if (StringUtils.isNotBlank(errorMsgList)) {
                //校验失败
                res.put("code", "err");
                res.put("msg", errorMsgList);
            } else {
                //更新新单为未提交状态
                String updBill2 = "update T_HR_ATS_OverTimeBill set FBillState=0 where fid=?";
                DbUtil.execute(ctx, updBill2, new String[]{newId.toString()});
                res.put("msg", "成功");
                res.put("billID", newId.toString());
                res.put("entryId", newEntryId.toString());
                res.put("oldBillID", billId.toString());
                res.put("oldEntryId", entryId.toString());
                res.put("code", "ses");
            }
            //反审批失败处理
            if ("err".equals(res.get("code"))) {
                //删除新单据分录
                String updEntry2 = "delete from T_HR_ATS_OverTimeBillEntry where fid=?";
                DbUtil.execute(ctx, updEntry2, new String[]{newEntryId.toString()});
                //新单据
                String delNewBill = "delete from T_HR_ATS_OverTimeBill where fid=?";
                DbUtil.execute(ctx, delNewBill, new String[]{newId.toString()});
            } else {
                //需要等待专员变更后处理
            }
        } catch (Exception e) {
            e.printStackTrace();
            res.put("msg", e.getMessage());
            //删除新单据分录
            String updEntry2 = "delete from T_HR_ATS_OverTimeBillEntry where fid=?";
            DbUtil.execute(ctx, updEntry2, new String[]{newEntryId.toString()});
            //新单据
            String delNewBill = "delete from T_HR_ATS_OverTimeBill where fid=?";
            DbUtil.execute(ctx, delNewBill, new String[]{newId.toString()});
            logger.error(e);
        } finally {
            System.out.println("deleteOTEntry.finally:" + res);
        }
        return res;
    }

    /**
     * 删除审批通过的分录
     *
     * @param ctx
     * @param billId
     * @param entryId
     * @return
     */
    public Map<String, Object> deleteOTEntry(Context ctx, String billId, String entryId) throws BOSException, EASBizException {
        System.out.println("deleteOTEntry");
        Map<String, Object> res = Maps.newHashMap();
        IAtsOverTimeBill iBill = AtsOverTimeBillFactory.getLocalInstance(ctx);
        IAtsOverTimeBillEntry iBillEntry = AtsOverTimeBillEntryFactory.getLocalInstance(ctx);
        //更新id
        BOSUuid newId = null;
        res.put("code", "err");
        res.put("msg", "失败");
        try {
            System.out.println("deleteOTEntry:" + billId + "-" + entryId);
            SelectorItemCollection selectorItemCollection = new SelectorItemCollection();
            selectorItemCollection.add(new SelectorItemInfo("*"));
            //获取原单分录
            AtsOverTimeBillEntryInfo oldEntryInfo = iBillEntry.getAtsOverTimeBillEntryInfo(new ObjectUuidPK(entryId), selectorItemCollection);
            //获取原单
            AtsOverTimeBillInfo oldBillInfo = iBill.getAtsOverTimeBillInfo(new ObjectUuidPK(billId), selectorItemCollection);
            System.out.println("deleteOTEntry1");
            //创建新单
            AtsOverTimeBillInfo newBillInfo = (AtsOverTimeBillInfo) oldBillInfo.clone();
            newBillInfo.setSourceBillId(newBillInfo.getId().toString());
            System.out.println("deleteOTEntry2");
            //更新id
            newId = BOSUuid.create(oldBillInfo.getBOSType());
            newBillInfo.setId(newId);
            //创建新单分录集合
            AtsOverTimeBillEntryCollection newEntryCollection = new AtsOverTimeBillEntryCollection();
            //添加待删除分录
            newBillInfo.put("entries", newEntryCollection);
            System.out.println("deleteOTEntry4" + newBillInfo);
            iBill.addnew(new ObjectUuidPK(newId), newBillInfo);
            //更新原单分录为新单据分录
            String updEntry = "update T_HR_ATS_OverTimeBillEntry set fbillid=? where fid=?";
            DbUtil.execute(ctx, updEntry, new String[]{newId.toString(), entryId});
            System.out.println("deleteOTEntry3");

            //更新新单为审批通过
            String updBill = "update T_HR_ATS_OverTimeBill set FBillState=3 where fid=?";
            DbUtil.execute(ctx, updBill, new String[]{newId.toString()});
            System.out.println("deleteOTEntry5" + newId.toString());
            //反审批校验
            Map<String, Object> bres = this.beforeAgainstApproveAction(ctx, newId.toString());
            System.out.println("deleteOTEntry6" + bres.toString());
            res.putAll(bres);
            String errorMsgList = (String) bres.get("errorMsgList");
            if (StringUtils.isNotBlank(errorMsgList)) {
                //校验失败
                res.put("code", "err");
                res.put("msg", errorMsgList);
            } else {
                Map<String, Object> ares = this.againstApproveAction(ctx, "删除分录", newId.toString());
                res.putAll(ares);
                Set<String> successIds = (Set<String>) ares.get("successIds");
                if (1 != successIds.size()) {
                    //反审批失败
                    res.put("code", "err");
                } else {
                    res.put("code", "ses");
                }
            }
            //反审批失败处理
            if ("err".equals(res.get("code"))) {
                //更新新单据分录为原单分录
                String updEntry2 = "update T_HR_ATS_OverTimeBillEntry set fbillid=? where fid=?";
                DbUtil.execute(ctx, updEntry2, new String[]{billId, entryId});
                //新单据
                String delNewBill = "delete from T_HR_ATS_OverTimeBill where fid=?";
                DbUtil.execute(ctx, delNewBill, new String[]{newId.toString()});
            } else {
                //新单据
                String delNewBill = "delete from T_HR_ATS_OverTimeBill where fid=?";
                DbUtil.execute(ctx, delNewBill, new String[]{newId.toString()});
                //新单据
                String delNewEntry = "delete from T_HR_ATS_OverTimeBillEntry where fid=?";
                DbUtil.execute(ctx, delNewEntry, new String[]{entryId.toString()});
            }
        } catch (Exception e) {
            e.printStackTrace();
            res.put("msg", e.getMessage());
            //更新新单据分录为原单分录
            String updEntry2 = "update T_HR_ATS_OverTimeBillEntry set fbillid=? where fid=?";
            DbUtil.execute(ctx, updEntry2, new String[]{billId, entryId});
            logger.error(e);
        } finally {
            System.out.println("deleteOTEntry.finally:" + res);
            String delNewBill = "delete from T_HR_ATS_OverTimeBill where fid=?";
            DbUtil.execute(ctx, delNewBill, new String[]{newId.toString()});
        }
        return res;
    }


    /**
     * 反审批前校验
     *
     * @param ctx
     * @param billIds
     * @return {"turned":15,"errorMsgList":"[贺加贝]的选中记录中存在加班单参与了加班转调休计算，反审批后调休额度的剩余额度小于0且假期制度不允许超额请假，请先将请假单反审批再操作!","turnedInfos":"[刘光辉 2025-07-01]、[Mike 2025-07-01]、[王斌 2025-07-01]、[周芳 2025-07-01]、[刘浔 2025-07-01]、[simone 2025-07-01]、[曹浪 2025-07-01]、[唐建强 2025-07-01]、[田文立 2025-07-01]、[张晗 2025-07-01]、[张大利 2025-07-01]、[Vincent 2025-07-01]、[高爽 2025-07-01]、[贺加贝 2025-07-01]、[张三01 2025-07-01]"}
     * @throws SHRWebException
     * @throws BOSException
     * @throws EASBizException
     */
    public Map<String, Object> beforeAgainstApproveAction(Context ctx, String billIds) throws SHRWebException, BOSException, EASBizException {
        Map<String, Object> res = new HashMap();
        String flag = "true";

        if (StringUtils.isBlank(billIds)) {
            throw new ShrWebBizException(new AtsCommonBizException(AtsCommonBizException.ILLEGALID));
        } else {
            IAtsOverTimeBill iAtsOverTimeInfo = AtsOverTimeBillFactory.getRemoteInstance();
            String[] ids = billIds.split(",");
            Map<String, BigDecimal> limitDeductMap = new HashMap();
            if (ids != null && ids.length > 0) {
                for (int i = 0; i < ids.length; ++i) {
                    String billId = ids[i];
                    if ("true".equals(flag)) {
                        StringBuffer checkSB = new StringBuffer("");
                        checkSB.append("select sum.fid from T_HR_ATS_AttendanceResultSum sum inner join T_HR_ATS_OverTimeBillEntry lbe on lbe.fpersonId = sum.fproposerId and lbe.fadminOrgUnitId = sum.fadminOrgUnitId and sum.FSalaryStatus = 1 ");
                        checkSB.append("inner join T_HR_ATS_OverTimeBill lb on lb.fid = lbe.FBillID inner join T_HR_ATS_AttendancePeriod ap on ap.fid = sum.FAttendancePeriodID and lbe.FRealEndTime < DATEADD(DAY,1,ap.FEndDate) ");
                        checkSB.append(" where lb.fid = '" + billId + "' ");
                        IRowSet row = DbUtil.executeQuery(ctx, checkSB.toString());
                        if (row.size() > 0) {
                            throw new ShrWebBizException(new AtsAgainstApprove(AtsAgainstApprove.EXCEPTIONOVER));
                        }
                    }

                    AtsOverTimeBillInfo billInfo = iAtsOverTimeInfo.getAtsOverTimeBillInfo(new ObjectUuidPK(billId));
                    if (billInfo.getBillState().getValue() != 3) {
                        throw new ShrWebBizException(new AtsOTBizException(AtsOTBizException.CANCERAUDITNOTMATHAUDIT));
                    }

                    this.isTurned(ctx, billInfo, res, limitDeductMap);
                }

                String turnedInfos = (String) res.get("turnedInfos");
                if (turnedInfos != null && turnedInfos.length() > 0) {
                    turnedInfos = turnedInfos.substring(0, turnedInfos.length() - 1);
                    res.put("turnedInfos", turnedInfos);
                }
            }

            return res;
        }
    }

    public void isTurned(Context ctx, AtsOverTimeBillInfo billInfo, Map<String, Object> res, Map<String, BigDecimal> limitDeductMap) {
        Map<String, OTtoTakeWorkDetailInfo> toTakeWorkDetailMap = new HashMap();
        AtsOverTimeBillEntryCollection entries = billInfo.getEntries();
        Map<String, Date> otDates = new HashMap();
        Set<String> entryPersonIds = new HashSet();
        Map<String, BigDecimal> detailInfosMap = new HashMap();
        if (entries != null && entries.size() > 0) {
            for (int i = 0; i < entries.size(); ++i) {
                String personId = entries.get(i).getPerson().getId().toString();
                entryPersonIds.add(personId);
                otDates.put(personId, entries.get(i).getOtDate());

                try {
                    OTtoTakeWorkDetailCollection detailInfos = OTtoTakeWorkDetailFactory.getLocalInstance(ctx).getOTtoTakeWorkDetailCollection("select id, proposer.id,proposer.name,proposer.number,limit,limitValue where sourceBillID = '" + entries.get(i).getId() + "' and state = 0 ");
                    if (detailInfos != null && detailInfos.size() > 0) {
                        toTakeWorkDetailMap.put(personId, detailInfos.get(0));
                        String limitId = detailInfos.get(0).getLimit();
                        if (limitDeductMap.get(limitId) == null) {
                            limitDeductMap.put(limitId, detailInfos.get(0).getLimitValue());
                        } else {
                            limitDeductMap.put(limitId, ((BigDecimal) limitDeductMap.get(limitId)).add(detailInfos.get(0).getLimitValue()));
                        }
                    } else {
                        AttendanceResultCollection results = AttendanceResultFactory.getLocalInstance(ctx).getAttendanceResultCollection("select id where attenceDate = '" + entries.get(i).getOtDate() + "' and proposer.id = '" + entries.get(i).getPerson().getId().toString() + "'");
                        if (results.size() > 0) {
                            detailInfos = OTtoTakeWorkDetailFactory.getLocalInstance(ctx).getOTtoTakeWorkDetailCollection("select id, proposer.id,proposer.name,proposer.number,limit,limitValue where sourceBillID = '" + results.get(0).getId() + "' and state = 0 ");
                            if (detailInfos.size() > 0) {
                                toTakeWorkDetailMap.put(personId, detailInfos.get(0));
                                if (detailInfosMap.get(detailInfos.get(0).getId().toString()) == null) {
                                    String limitId = detailInfos.get(0).getLimit();
                                    detailInfosMap.put(detailInfos.get(0).getId().toString(), detailInfos.get(0).getLimitValue());
                                    if (limitDeductMap.get(limitId) == null) {
                                        limitDeductMap.put(limitId, detailInfos.get(0).getLimitValue());
                                    } else {
                                        limitDeductMap.put(limitId, ((BigDecimal) limitDeductMap.get(limitId)).add(detailInfos.get(0).getLimitValue()));
                                    }
                                }
                            }
                        }
                    }
                } catch (ObjectNotFoundException e) {
                    e.printStackTrace();
                } catch (BOSException e) {
                    e.printStackTrace();
                }
            }
        }

        int turned = res.get("turned") == null ? 0 : (Integer) res.get("turned");
        String turnedInfos = res.get("turnedInfos") == null ? "" : (String) res.get("turnedInfos");
        if (!toTakeWorkDetailMap.isEmpty()) {
            for (String key : toTakeWorkDetailMap.keySet()) {
                ++turned;
                turnedInfos = turnedInfos + "[" + ((OTtoTakeWorkDetailInfo) toTakeWorkDetailMap.get(key)).getProposer().getName() + " " + AtsDateUtils.dateShortToString((Date) otDates.get(key)) + "]、";
            }

            this.checkRemainLimit(ctx, res, limitDeductMap);
        }

        res.put("turned", turned);
        res.put("turnedInfos", turnedInfos);
    }

    private void checkRemainLimit(Context ctx, Map<String, Object> res, Map<String, BigDecimal> limitDeductMap) {
        StringBuffer sb = new StringBuffer();

        try {
            IRowSet rs = DbUtil.executeQuery(ctx, "SELECT LI.FREMAINLIMIT,LI.FID ,PO.FIsOver, PERSON.FNAME" + MLUtile.getMlFlag(ctx) + " AS personName FROM T_HR_ATS_HOLIDAYLIMIT LI  INNER JOIN T_HR_ATS_HolidayPolicy PO ON LI.FHOLIDAYPOLICYID = PO.FID  INNER JOIN T_BD_PERSON PERSON ON PERSON.FID = LI.FPROPOSERID  WHERE LI.FID IN (" + AtsUtil.convertSetToString(limitDeductMap.keySet()) + ")");

            while (rs.next()) {
                String limitId = rs.getString("FID");
                BigDecimal remainLimit = rs.getBigDecimal("FREMAINLIMIT");
                int isOver = rs.getInt("FIsOver");
                BigDecimal deductLimit = (BigDecimal) limitDeductMap.get(limitId);
                if (deductLimit != null && isOver == 0 && remainLimit.subtract(deductLimit).compareTo(BigDecimal.ZERO) < 0) {
                    sb.append("[" + rs.getString("personName") + "]");
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }

        if (StringUtils.isNotEmpty(sb.toString())) {
            res.put("errorMsgList", MLUtile.getRes(AtsOverTimeBillResEnum.existsOTDetailAndRemainLimitLessThanZero, ctx, new Object[]{sb.toString()}));
        }

    }

    public String doAgainApprove(Context ctx, String billId, String aiReason) throws EASBizException, BOSException, SHRWebException {
        IAtsOverTimeBill iAtsOverTimeInfo = AtsOverTimeBillFactory.getRemoteInstance();
        AtsOverTimeBillInfo billInfo = iAtsOverTimeInfo.getAtsOverTimeBillInfo(new ObjectUuidPK(billId));
        CoreBaseCollection detailColl = new CoreBaseCollection();
        AtsOverTimeBillEntryCollection entries = billInfo.getEntries();
        boolean isCreateTagISAuto = false;
        if (entries != null && entries.size() > 0) {
            for (int i = 0; i < entries.size(); ++i) {
                OverTimeCreateTag createTag = entries.get(i).getCreateTag();
                entries.get(i).setCreateTag(OverTimeCreateTag.userCreate);
                if (null != createTag && createTag.getValue() == 3) {
                    isCreateTagISAuto = true;
                }

                if (null != createTag && createTag.getValue() == 2) {
                    isCreateTagISAuto = true;
                }

                OTtoTakeWorkDetailInfo detailInfo = null;

                try {
                    detailInfo = OTtoTakeWorkDetailFactory.getLocalInstance(ctx).getOTtoTakeWorkDetailInfo(" where sourceBillID = '" + entries.get(i).getId().toString() + "' and state = 0 ");
                } catch (ObjectNotFoundException e) {
                    e.printStackTrace();
                }

                if (detailInfo != null) {
                    detailInfo.setState(OTtoTakeWorkDetailStatus.invalid);
                    detailColl.add(detailInfo);
                }
            }
        }

        OTtoTakeWorkDetailFactory.getLocalInstance(ctx).save(detailColl);
        if (SHRBillServerUtil.overTimeControl(ctx, billInfo.getHrOrgUnit().getId().toString()) && !isCreateTagISAuto) {
            try {
                String serviceName = "calculatePersonOTLimit";
                Map param = new HashMap();
                param.put("billId", billId);
                param.put("operator", "against");
                OSFAppUtil.callService(ctx, serviceName, (HashMap) param);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }

        String successId = this.callOverTimeBillAgainstApproveJob(ctx, billInfo, aiReason);
        AtsBillSourceTypeUtil.uptBillSourceTypeWithBack(ctx, billId);
        DataLogsRecordUtil.processListObjectsLog(billInfo, OperActionEnum.againstApprove, ctx);
        return successId;
    }

    private String callOverTimeBillAgainstApproveJob(Context ctx, AtsOverTimeBillInfo billInfo, String aiReason) throws EASBizException, BOSException {
        AtsOverTimeBillEntryCollection entrysInfo = billInfo.getEntries();
        IAtsOverTimeBillEntry iAtsOverTimeBillEntry = AtsOverTimeBillEntryFactory.getRemoteInstance();
        CoreBaseCollection colls = new CoreBaseCollection();
        List<String> personIds = new ArrayList();
        Date minOtDate = null;
        Date maxOtDate = null;

        for (int i = 0; i < entrysInfo.size(); ++i) {
            AtsOverTimeBillEntryInfo entryInfo = entrysInfo.get(i);
            entryInfo.setCalculateState(false);
            entryInfo.setHolidayLimit((HolidayLimitInfo) null);
            entryInfo.setLastUpdateUser((UserInfo) ctx.get("UserInfo"));
            entryInfo.setLastUpdateTime(AtsDateUtils.dateToTimestamp(new Date()));
            colls.add(entryInfo);
            personIds.add(entryInfo.getPerson().getId().toString());
            if (null == minOtDate) {
                minOtDate = entryInfo.getOtDate();
                maxOtDate = entryInfo.getOtDate();
            } else {
                if (entryInfo.getOtDate().compareTo(minOtDate) < 0) {
                    minOtDate = entryInfo.getOtDate();
                }

                if (entryInfo.getOtDate().compareTo(maxOtDate) > 0) {
                    maxOtDate = entryInfo.getOtDate();
                }
            }
        }

        if (!colls.isEmpty()) {
            iAtsOverTimeBillEntry.update(colls);
        }

        String billId = billInfo.getId().toString();
        String sql = " update t_hr_ats_overTimeBill set fbillstate = 0,faireason=? ,fLastUpdateTime=?,fLastUpdateUserId=? where fid = ?";
        Object[] params = new Object[]{aiReason, new Timestamp(System.currentTimeMillis()), ctx.getCaller().toString(), billId};
        DbUtil.execute(ctx, sql, params);
        AtsOverTimeVo atsOverTimeVo = new AtsOverTimeVo();
        atsOverTimeVo.setMaxOtDate(maxOtDate);
        atsOverTimeVo.setMinOtDate(minOtDate);
        atsOverTimeVo.setPersonIds(personIds);
        atsOverTimeVo.setEntrysInfo(entrysInfo);

        try {
            ThreadPoolExecutor pool = TaskPool.getFixedInstance("updateHolidayLimit", 1, 10L);
            pool.submit((Callable) (new Callable<Object>() {
                public Object call() throws Exception {
                    AtsOverTimeVo overTimeVo = (AtsOverTimeVo) this.getDependency();
                    AttendCalculateParent cal = new AttendCalculateParent();
                    String personIdsStr = AtsServerCalUtils.getPersonIdsNoQuote(overTimeVo.getPersonIds());
                    cal.calAttendResultByAdminOrgPersonAndDate(this.ctx, overTimeVo.getMinOtDate(), overTimeVo.getMaxOtDate(), 1, (String) null, personIdsStr, 0, "", 1);
                    AtsOverTimeBillEntryCollection entrysInfo = overTimeVo.getEntrysInfo();

                    for (int i = 0; i < entrysInfo.size(); ++i) {
                        Map<String, String> param = new HashMap();
                        param.put("adminOrgUnitNum", "");
                        param.put("personNum", entrysInfo.get(i).getPerson().getId().toString());
                        param.put("cycleDate", AtsDateUtils.dateShortToString(entrysInfo.get(i).getOtDate()));
                        GenerateTakeWorkLimit service = new GenerateTakeWorkLimit(this.ctx);
                        service.generateTakeWorkLimitBackGround(this.ctx, param);
                    }

                    return null;
                }
            }).setDependency(atsOverTimeVo).setCtx(ctx));
        } catch (Exception e) {
            e.printStackTrace();
        }

        return billId;
    }

    /**
     * 反审批
     *
     * @param ctx
     * @param aiReason
     * @param billIds
     * @return
     * @throws SHRWebException
     * @throws BOSException
     * @throws EASBizException
     */
    public Map<String, Object> againstApproveAction(Context ctx, String aiReason, String billIds) throws SHRWebException, BOSException, EASBizException {
        List<String> atsInfoIds = new ArrayList();
        Map<String, Object> res = new HashMap();

        SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
        aiReason = sf.format(new Date()) + "," + ctx.getUserName() + ":" + aiReason;
        Set<String> successIds = new HashSet();
        res.put("successIds", successIds);

        String[] ids = billIds.split(",");
        if (ids != null && ids.length > 0) {
            for (int t = 0; t < ids.length; ++t) {
                String billId = ids[t].trim();
                if (!atsInfoIds.contains(billId)) {
                    atsInfoIds.add(billId);
                    successIds.add(this.doAgainApprove(ctx, billId, aiReason));
                }
            }
        }

        res.put("msg", MLUtile.getRes(AtsOverTimeBillResEnum.againstApproveSuccess, ctx));

        return res;
    }
}