package com.kingdee.eas.custom.facade.leave; import com.grapecity.documents.excel.D; import com.kingdee.bos.dao.IObjectPK; import com.kingdee.bos.dao.ormapping.ObjectUuidPK; import com.kingdee.bos.util.BOSUuid; import com.kingdee.eas.basedata.org.AdminOrgUnitInfo; import com.kingdee.eas.basedata.org.CtrlUnitInfo; import com.kingdee.eas.basedata.org.HROrgUnitInfo; import com.kingdee.eas.basedata.org.PositionInfo; import com.kingdee.eas.basedata.person.PersonInfo; import com.kingdee.eas.custom.bd.param.ParamCollection; import com.kingdee.eas.custom.bd.param.ParamFactory; import com.kingdee.eas.hr.ats.*; import com.kingdee.eas.util.app.ContextUtil; import com.kingdee.util.DateTimeUtils; import org.apache.commons.lang3.StringUtils; import org.apache.log4j.Logger; import java.math.BigDecimal; import java.math.RoundingMode; import java.sql.SQLException; import java.sql.Timestamp; import java.text.ParseException; import java.text.SimpleDateFormat; import java.util.*; import com.kingdee.bos.*; //import com.kingdee.bos.metadata.entity.EntityViewInfo; //import com.kingdee.bos.dao.IObjectPK; import com.kingdee.eas.common.EASBizException; import com.kingdee.eas.framework.CoreBaseCollection; import com.kingdee.eas.util.app.DbUtil; import com.kingdee.jdbc.rowset.IRowSet; /** * 假期额度相关后台事务类 * @author xiaoxin * */ public class LeaveAllowanceFacadeControllerBean extends AbstractLeaveAllowanceFacadeControllerBean { private static Logger logger = Logger.getLogger("com.kingdee.eas.custom.facade.leave.LeaveAllowanceFacadeControllerBean"); // 员工类别 General Administrative Staff private static final String WC_General_Administrative_Staff = "General Administrative Staff"; // 员工类别 Professional Supervisory Staff private static final String WC_Professional_Supervisory_Staff = "Professional Supervisory Staff"; // 员工类别 Senior Administrative Staff private static final String WC_Senior_Administrative_Staff = "Senior Administrative Staff"; private static final String WC_Academic_Staff = "Academic Staff"; private static final String WC_Others = "Others"; // 年假初始值 General_Administrative_Staff private static final int IV_General_Administrative_Staff = 12; // 年假初始值 Professional_Supervisory_Staff private static final int IV_Professional_Supervisory_Staff = 15; // 年假初始值 Senior_Administrative_Staff private static final int IV_Senior_Administrative_Staff = 18; private static final int IV_Year = 2; private static final int IV_YearAddValue = 1; private static final int IV_MAXADD = 8; private static final int MONTH_NUM_12 = 12; // 年假折算方式 private static final String PARAM_ANNUALLEAVE_CONVERSIONMETHOD = "param_001"; // 年假取整方式 private static final String PARAM_ANNUALLEAVE_INTEGERMETHOD = "param_002"; // 年假取整精度 private static final String PARAM_ANNUALLEAVE_INTEGERPERCISION = "param_003"; // 年假结转日期 private static final String PARAM_ANNUALLEAVE_CONVERTDATE = "param_004"; // 生成下年度额度日期 private static final String PARAM_ANNUALLEAVE_GENERATEDAY = "param_005"; // 护理假额度 private static final String PARAM_NURSINGLEAVE_LIMIT = "param_006"; // 育儿假额度 private static final String PARAM_PARENTALLEAVE_LIMIT = "param_007"; // 护理育儿折算方式 private static final String PARAM_NURSINGANDPARENTALLEAVE_CONVERSIONMETHOD = "param_008"; // 护理育儿取整方式 private static final String PARAM_NURSINGANDPARENTALLEAVE_INTEGERMETHOD = "param_009"; // 护理育儿取整精度 private static final String PARAM_NURSINGANDPARENTALLEAVE_INTEGERPERCISION = "param_010"; // 育儿护理多段统计是否更新视图脚本 private static final String PARAM_NURSINGANDPARENTALLEAVE_UPDATESQL = "param_011"; // 折算方式 按日 private static final String CONVERSIONMETHOD_BYDAY = "D"; // 折算方式 按月 private static final String CONVERSIONMETHOD_BYMONTH = "M"; // 取整方式 向上 private static final String INTEGERMETHOD_UP = "U"; // 取整方式 向下 private static final String INTEGERMETHOD_DOWN = "D"; // 取整精度 0.5 private static final double INTEGERPERCISION_HALF = 0.5; // 取整精度 1 private static final double INTEGERPERCISION_ONE = 1; // 年假折算 private static String annualLeaveConversionMethod; // 年假取整 private static String annualLeaveIntegerMethod; // 年假取整精度 private static double annualLeaveIntegerPrecision; // 结转日期 private static String annualLeaveConvertDate; // 下年度额度生成 private static String annualLeaveGenerateDay; // 育儿假额度 private static int nursingLeaveLimit; // 护理假额度 private static int parentalLeaveLimit; // 护理育儿折算 private static String nursingAndParentalLeaveConversionMethod; // 护理育儿取整 private static String nursingAndParentalLeaveIntegerMethod; // 护理育儿取整精度 private static double nursingAndParentalLeaveIntegerPrecision; // 育儿护理多段统计是否更新视图脚本 private static String nursingAndParentalLeaveUpdateSql; /** * 年假额度生成 JQLX000001Y */ @Override protected void _createAnnualLeave(Context ctx, int year, String personNum) throws BOSException { try { // 初始化公共变量 initialGlobalParam(ctx); // 是否生成下年年假额度 Boolean isGenerateNextYearAnnualLeave = false; // 当前时间 Date currentDate = new Date(); if (year != 0) { currentDate = DateTimeUtils.parseDate(year + "-12-31"); } else { year = DateTimeUtils.getYear(currentDate); Date annualLeaveGenerateDay = DateTimeUtils.parseDate(year + "-" + LeaveAllowanceFacadeControllerBean.annualLeaveGenerateDay); if (currentDate.getTime() >= annualLeaveGenerateDay.getTime()) { isGenerateNextYearAnnualLeave = true; } } // 年假额度生成 generateAnnualLeave(ctx, year, personNum, currentDate); // 下年年假额度生成 if (isGenerateNextYearAnnualLeave) { int nextYear = year + 1; Date nextYearCurrentDay = DateTimeUtils.addYear(currentDate, 1); generateAnnualLeave(ctx, nextYear, personNum, nextYearCurrentDay); } } catch (ParseException e) { throw new BOSException(e); } } /** * 年假额度生成 * @param ctx * @param year * @param personNum * @throws BOSException */ private void generateAnnualLeave(Context ctx, int year, String personNum, Date currentDate) throws BOSException { try { Date nowDate = new Date(); // 考勤制度和年假id对应 Map holidayPolicyMap = new HashMap(); String holidayPolicySql = "select hps.FNUMBER, hp.fid from T_HR_ATS_HolidayPolicy hp left join T_HR_ATS_HolidayPolicySet hps on hp.FHOLIDAYPOLICYSETID = hps.fid where FHOLIDAYTYPEID = (select fid from T_HR_ATS_HolidayType where FNUMBER = 'JQLX000001Y')"; IRowSet holidayPolicyRowSet = DbUtil.executeQuery(ctx, holidayPolicySql); while (holidayPolicyRowSet.next()) { holidayPolicyMap.put(holidayPolicyRowSet.getString("FNUMBER"), holidayPolicyRowSet.getString("fid")); } String currentDateStr = DateTimeUtils.format(currentDate, "yyyy-MM-dd"); // 当前年份第一天 Date yearFirstDay = DateTimeUtils.parseDate(DateTimeUtils.getYear(currentDate) + "-01-01"); // 当前年份最后一天 Date yearLastDay = DateTimeUtils.parseDate(DateTimeUtils.getYear(currentDate) + "-12-31"); List personNumberList = new ArrayList(); CoreBaseCollection addList = new CoreBaseCollection(); CoreBaseCollection updateList = new CoreBaseCollection(); List deleteList = new ArrayList<>(); // 重算列表 List> reCalList = new ArrayList<>(); String personNumStr = ""; if (StringUtils.isNotEmpty(personNum)) { String[] personNumArr = personNum.split(","); for (int i = 0; i < personNumArr.length; i++) { personNumberList.add("'" + personNumArr[i] + "'"); } personNumStr = String.join(",",personNumberList); } String dbType = ContextUtil.getDbType(ctx); String sql = " /*dialect*/select * from (select row_number() over (partition by p.fid order by p.fid,eo.feffdt desc) as rn,p.fid,p.fnumber,eo.FADMINORGID,eo.FHRORGUNITID,eo.FPOSITIONID,p.cfftorptid fullOrPartId,fp.fnumber fullOrPartNumber, p.cffae annualleavelimit,case when rb.fid is null then eo.cfworkercategoryid else rbe.CFWcategoryID end workercategoryid,wc.fname_l2 workercategoryname,p.fhiredate, (to_char(to_date('"+currentDateStr+"','yyyy-MM-dd'),'yyyy') - to_char(p.fhiredate,'yyyy')+1)joinDateYear,case when rb.fid is null then null else rbe.FBIZDATE end leaveDate,l.fid limitId,coalesce(l.FADDORSUBLIMIT,0) FADDORSUBLIMIT,coalesce(l.FUSEDLIMIT,0) FUSEDLIMIT,coalesce(l.FREEZELIMIT,0) FREEZELIMIT,coalesce(l.cflastcarryforward,0) cflastcarryforward,coalesce(l.cfcarryforward,0) cfcarryforward,coalesce(l.CFEntitlementLimit,0) CFEntitlementLimit,coalesce(l.CFInitializedLimit,0) CFInitializedLimit, ebe.FPROBATION,ebe.FPLANFORMALDATE,hp.fid holidayPolicyId " + " from T_BD_Person p " + " left join T_HR_EmpOrgRelation eo on p.fid = eo.fpersonid " + " left join CT_MP_Fullorpart fp on fp.fid = p.cfftorptid " + " left join T_HR_ATS_AtsHolidayFile f on f.fproposerid = p.fid " + " left join T_HR_ATS_HolidayPolicySet hps on f.fholidaypolicysetid = hps.fid " + " left join T_HR_ATS_HolidayType ht on ht.FNUMBER = 'JQLX000001Y' " + " left join T_HR_ATS_HolidayPolicy hp on ht.fid = hp.FHOLIDAYTYPEID and hps.fid = hp.fholidaypolicysetid " + " left join T_HR_ATS_HolidayLimit l on hp.fid = l.FHOLIDAYPOLICYID and l.FPROPOSERID = p.fid and l.FCYCLEBEGINDATE >= p.fhiredate and l.FCYCLEBEGINDATE <= p.FLEFFDT and l.fyear = " + year + " left join T_HR_EmpEnrollBizBillEntry ebe on ebe.FPERSONID = p.fid and ebe.FBIZDATE = p.fhiredate " + " left join T_HR_EmpEnrollBizBill eb on ebe.FBILLID = eb.FID and eb.FBILLSTATE = 3 " + " left join T_HR_ResignBizBillEntry rbe on rbe.FPERSONID = p.fid and p.fhiredate = rbe.FENTERDATE " + " left join T_HR_ResignBizBill rb on rb.fid = rbe.FBILLID and rb.FBILLSTATE = 3 " + " left join CT_MP_WorkerCategory wc on (wc.fid = eo.cfworkercategoryid or wc.fid = rbe.CFWcategoryID) " + " where f.fattendfilestate = 1 and fp.fnumber = 'FULL' and eo.fassigntype = 1 and eo.feffdt <= to_date('"+currentDateStr+"','yyyy-MM-dd') and to_char(p.fhiredate, 'yyyy')<="+year+" and to_char(p.FLEFFDT,'yyyy')>="+year+" "; if (StringUtils.equalsIgnoreCase("MS SQL Server", dbType)) { sql = " /*dialect*/select * from (select row_number() over (partition by p.fid order by p.fid,eo.feffdt desc) as rn,p.fid,p.fnumber,eo.FADMINORGID,eo.FHRORGUNITID,eo.FPOSITIONID,p.cfftorptid fullOrPartId,fp.fnumber fullOrPartNumber, p.cffae annualleavelimit,case when rb.fid is null then eo.cfworkercategoryid else rbe.CFWcategoryID end workercategoryid,wc.fname_l2 workercategoryname,p.fhiredate, (year(cast('"+currentDateStr+"' as datetime)) - year(p.fhiredate)+1)joinDateYear,case when rb.fid is null then null else rbe.FBIZDATE end leaveDate,l.fid limitId,isnull(l.FADDORSUBLIMIT,0) FADDORSUBLIMIT,isnull(l.FUSEDLIMIT,0) FUSEDLIMIT,isnull(l.FREEZELIMIT,0) FREEZELIMIT,isnull(l.cflastcarryforward,0) cflastcarryforward,isnull(l.cfcarryforward,0) cfcarryforward,isnull(l.CFEntitlementLimit,0) CFEntitlementLimit,isnull(l.CFInitializedLimit,0) CFInitializedLimit,ebe.FPROBATION,ebe.FPLANFORMALDATE,hp.fid holidayPolicyId " + " from T_BD_Person p " + " left join T_HR_EmpOrgRelation eo on p.fid = eo.fpersonid " + " left join CT_MP_Fullorpart fp on fp.fid = p.cfftorptid " + " left join T_HR_ATS_AtsHolidayFile f on f.fproposerid = p.fid " + " left join T_HR_ATS_HolidayPolicySet hps on f.fholidaypolicysetid = hps.fid " + " left join T_HR_ATS_HolidayType ht on ht.FNUMBER = 'JQLX000001Y' " + " left join T_HR_ATS_HolidayPolicy hp on ht.fid = hp.FHOLIDAYTYPEID and hps.fid = hp.fholidaypolicysetid " + " left join T_HR_ATS_HolidayLimit l on hp.fid = l.FHOLIDAYPOLICYID and l.FPROPOSERID = p.fid and l.FCYCLEBEGINDATE >= p.fhiredate and l.FCYCLEBEGINDATE <= p.FLEFFDT and l.fyear = " + year + " left join T_HR_EmpEnrollBizBillEntry ebe on ebe.FPERSONID = p.fid and ebe.FBIZDATE = p.fhiredate " + " left join T_HR_EmpEnrollBizBill eb on ebe.FBILLID = eb.FID and eb.FBILLSTATE = 3 " + " left join T_HR_ResignBizBillEntry rbe on rbe.FPERSONID = p.fid and p.fhiredate = rbe.FENTERDATE " + " left join T_HR_ResignBizBill rb on rb.fid = rbe.FBILLID and rb.FBILLSTATE = 3 " + " left join CT_MP_WorkerCategory wc on (wc.fid = eo.cfworkercategoryid or wc.fid = rbe.CFWcategoryID) " + " where f.fattendfilestate = 1 and fp.fnumber = 'FULL' and eo.fassigntype = 1 and eo.feffdt <= cast('"+currentDateStr+"' as datetime) and year(p.fhiredate)<="+year+" and year(p.FLEFFDT)>="+year; } if (StringUtils.isNotEmpty(personNumStr)) { sql += " and p.fnumber in (" + personNumStr + ") "; } sql += " ) temp where temp.rn = 1 "; IRowSet iRowSet = DbUtil.executeQuery(ctx, sql); while (iRowSet.next()) { String holidayPolicyId = iRowSet.getString("holidayPolicyId"); if (StringUtils.isEmpty(holidayPolicyId)) { holidayPolicyId = holidayPolicyMap.values().stream().findFirst().get(); continue; } String limitId = iRowSet.getString("limitId"); // 教师年假额度 int annualleavelimit = iRowSet.getInt("annualleavelimit"); // 员工类别 String workercategoryname = iRowSet.getString("workercategoryname"); // 司龄 int joinDateYear = iRowSet.getInt("joinDateYear"); // 入职日期 Date joinDate = iRowSet.getDate("fhiredate"); java.sql.Date fplanformaldate = iRowSet.getDate("FPLANFORMALDATE"); // 离职日期 java.sql.Date leaveDate = iRowSet.getDate("leaveDate"); // 标准额度=额度规则（折算额度）+初始化额度+从去年结转-结转到明年 BigDecimal standardLimit = BigDecimal.ZERO; // 折算标准额度 BigDecimal convertedLimit = BigDecimal.ZERO; // 未折算标准额度 BigDecimal entitlementLimit = BigDecimal.ZERO; // 实际额度 BigDecimal realLimit = BigDecimal.ZERO; // 剩余额度 BigDecimal remainLimit = BigDecimal.ZERO; // 未折算标准额度 BigDecimal entitlementLimitOld = iRowSet.getBigDecimal("CFEntitlementLimit"); // 初始化额度 BigDecimal initializedLimit = iRowSet.getBigDecimal("CFInitializedLimit"); // 从去年结转额度 BigDecimal lastCarryforward = iRowSet.getBigDecimal("CFLastCarryforward"); // 结转到明年 BigDecimal carryforward = iRowSet.getBigDecimal("CFCarryforward"); // 增减额度 BigDecimal addOrSubLimit = iRowSet.getBigDecimal("FADDORSUBLIMIT"); // 已用额度 BigDecimal usedLimit = iRowSet.getBigDecimal("FUSEDLIMIT"); // 在途额度 BigDecimal freezeLimit = iRowSet.getBigDecimal("FreezeLimit"); // 全职行政人员额度规则 if (StringUtils.equalsIgnoreCase(workercategoryname, WC_General_Administrative_Staff) || StringUtils.equalsIgnoreCase(workercategoryname, WC_Professional_Supervisory_Staff) || StringUtils.equalsIgnoreCase(workercategoryname, WC_Senior_Administrative_Staff)) { if (annualleavelimit > 0) { // 如果员工信息-教师年假额度中数值>0,则取值员工信息-教师年假额度值，司龄每满两年加一天，最多加八天(最大值30天) convertedLimit = BigDecimal.valueOf(annualleavelimit + (joinDateYear - 1) / IV_Year * IV_YearAddValue); if (convertedLimit.compareTo(BigDecimal.valueOf(30)) > 0) { convertedLimit = BigDecimal.valueOf(30); } } else { // 员工类别=General Administrative Staff，则初始值为12，司龄每满两年加一天，最多加八天； if (StringUtils.equalsIgnoreCase(workercategoryname, WC_General_Administrative_Staff)) { convertedLimit = BigDecimal.valueOf(IV_General_Administrative_Staff + (joinDateYear - 1) / IV_Year * IV_YearAddValue); if (convertedLimit.compareTo(BigDecimal.valueOf(IV_General_Administrative_Staff + IV_MAXADD)) > 0) { convertedLimit = BigDecimal.valueOf(IV_General_Administrative_Staff + IV_MAXADD); } } // 员工类别=Professional Supervisory Staff，则初始值为15，司龄每满两年加一天，最多加八天； if (StringUtils.equalsIgnoreCase(workercategoryname, WC_Professional_Supervisory_Staff)) { convertedLimit = BigDecimal.valueOf(IV_Professional_Supervisory_Staff + (joinDateYear - 1) / IV_Year * IV_YearAddValue); if (convertedLimit.compareTo(BigDecimal.valueOf(IV_Professional_Supervisory_Staff + IV_MAXADD)) > 0) { convertedLimit = BigDecimal.valueOf(IV_Professional_Supervisory_Staff + IV_MAXADD); } } // 员工类别=Senior Administrative Staff，则初始值为18，司龄每满两年加一天，最多加八天； if (StringUtils.equalsIgnoreCase(workercategoryname, WC_Senior_Administrative_Staff)) { convertedLimit = BigDecimal.valueOf(IV_Senior_Administrative_Staff + (joinDateYear - 1) / IV_Year * IV_YearAddValue); if (convertedLimit.compareTo(BigDecimal.valueOf(IV_Senior_Administrative_Staff + IV_MAXADD)) > 0) { convertedLimit = BigDecimal.valueOf(IV_Senior_Administrative_Staff + IV_MAXADD); } } } } else if (StringUtils.equalsIgnoreCase(workercategoryname, WC_Academic_Staff) || StringUtils.equalsIgnoreCase(workercategoryname, WC_Others)) { // 全职学术人员和全职其他人员 // 取值员工信息-教师年假额度字段 convertedLimit = BigDecimal.valueOf(annualleavelimit); } // 未折算标准额度 entitlementLimit = convertedLimit; // 入职折算 if (DateTimeUtils.getYear(currentDate) == DateTimeUtils.getYear(joinDate) && leaveDate == null) { if (StringUtils.equals(CONVERSIONMETHOD_BYDAY, annualLeaveConversionMethod)) { // TODO 暂时使用按月折算的逻辑 convertedLimit = convertedLimit.multiply(BigDecimal.valueOf(MONTH_NUM_12 - DateTimeUtils.getMonth(joinDate) + 1)).divide(BigDecimal.valueOf(MONTH_NUM_12), 10, BigDecimal.ROUND_HALF_UP); } else { convertedLimit = convertedLimit.multiply(BigDecimal.valueOf(MONTH_NUM_12 - DateTimeUtils.getMonth(joinDate) + 1)).divide(BigDecimal.valueOf(MONTH_NUM_12), 10, BigDecimal.ROUND_HALF_UP); } } // 离职折算 if (leaveDate != null && DateTimeUtils.getYear(currentDate) == DateTimeUtils.getYear(leaveDate)) { if (StringUtils.equals(CONVERSIONMETHOD_BYDAY, annualLeaveConversionMethod)) { // TODO 暂时使按月折算的逻辑 if (DateTimeUtils.getYear(currentDate) == DateTimeUtils.getYear(joinDate)) { convertedLimit = convertedLimit.multiply(BigDecimal.valueOf(DateTimeUtils.getMonth(leaveDate) - DateTimeUtils.getMonth(joinDate) + 1)).divide(BigDecimal.valueOf(MONTH_NUM_12), 10, BigDecimal.ROUND_HALF_UP); } else { convertedLimit = convertedLimit.multiply(BigDecimal.valueOf(DateTimeUtils.getMonth(leaveDate))).divide(BigDecimal.valueOf(MONTH_NUM_12), 10, BigDecimal.ROUND_HALF_UP); } } else { if (DateTimeUtils.getYear(currentDate) == DateTimeUtils.getYear(joinDate)) { convertedLimit = convertedLimit.multiply(BigDecimal.valueOf(DateTimeUtils.getMonth(leaveDate) - DateTimeUtils.getMonth(joinDate) + 1)).divide(BigDecimal.valueOf(MONTH_NUM_12), 10, BigDecimal.ROUND_HALF_UP); } else { convertedLimit = convertedLimit.multiply(BigDecimal.valueOf(DateTimeUtils.getMonth(leaveDate))).divide(BigDecimal.valueOf(MONTH_NUM_12), 10, BigDecimal.ROUND_HALF_UP); } } } // 年假取整 // 整数部分 BigDecimal standardLimitInteger = convertedLimit.setScale(0, RoundingMode.FLOOR); // 小数部分 BigDecimal standardLimitDecimal = convertedLimit.subtract(standardLimitInteger); if (Double.doubleToLongBits(INTEGERPERCISION_HALF) == Double.doubleToLongBits(annualLeaveIntegerPrecision)) { if (StringUtils.equals(INTEGERMETHOD_UP, annualLeaveIntegerMethod)) { if (standardLimitDecimal.compareTo(BigDecimal.valueOf(0.5)) > 0) { convertedLimit = convertedLimit.setScale(0, RoundingMode.CEILING); } else if (standardLimitDecimal.compareTo(BigDecimal.ZERO) > 0){ convertedLimit = standardLimitInteger.add(BigDecimal.valueOf(0.5)); } else { convertedLimit = standardLimitInteger; } } else { if (standardLimitDecimal.compareTo(BigDecimal.valueOf(0.5)) > 0) { convertedLimit = standardLimitInteger.add(BigDecimal.valueOf(0.5)); } else { convertedLimit = convertedLimit.setScale(0, RoundingMode.FLOOR); } } } else { if (StringUtils.equals(INTEGERMETHOD_UP, annualLeaveIntegerMethod)) { convertedLimit = convertedLimit.setScale(0, RoundingMode.CEILING); } else { convertedLimit = convertedLimit.setScale(0, RoundingMode.FLOOR); } } // 未折算标准额度 if (entitlementLimit.compareTo(entitlementLimitOld) != 0 && year <= DateTimeUtils.getYear(nowDate)) { lastCarryforward = BigDecimal.ZERO; Map param = new HashMap<>(); param.put("year", year); param.put("personNum", iRowSet.getString("fnumber")); reCalList.add(param); } // 标准额度 = 额度规则（折算额度）+初始化额度+从去年结转-结转到明年 standardLimit = convertedLimit.add(initializedLimit).add(lastCarryforward).subtract(carryforward); // 实际额度 = 标准额度+增减额度 realLimit = standardLimit.add(addOrSubLimit); // 剩余额度 = 实际额度-已用额度-在途额度 remainLimit = realLimit.subtract(usedLimit).subtract(freezeLimit); if (StringUtils.isNotEmpty(limitId)) { HolidayLimitInfo holidayLimitInfo = new HolidayLimitInfo(); holidayLimitInfo.setId(BOSUuid.read(limitId)); // 标准额度 holidayLimitInfo.setStandardLimit(standardLimit); // 折算标准额度 holidayLimitInfo.setBigDecimal("convertedLimit", convertedLimit); // 未折算标准额度 holidayLimitInfo.setBigDecimal("entitlementLimit", entitlementLimit); holidayLimitInfo.setRealLimit(realLimit); holidayLimitInfo.setRemainLimit(remainLimit); holidayLimitInfo.setBigDecimal("lastCarryforward", lastCarryforward); holidayLimitInfo.setBigDecimal("Carryforward", carryforward); // 默认值 holidayLimitInfo.setCycleBeginDate(yearFirstDay); holidayLimitInfo.setCycleEndDate(yearLastDay); holidayLimitInfo.setEffectDate(yearFirstDay); holidayLimitInfo.setDelayDate(yearLastDay); // 入职情况 if (DateTimeUtils.getYear(currentDate) == DateTimeUtils.getYear(joinDate)) { holidayLimitInfo.setCycleBeginDate(joinDate); int fprobation = iRowSet.getInt("FPROBATION"); if (fprobation > 0) { holidayLimitInfo.setEffectDate(iRowSet.getDate("FPLANFORMALDATE")); } else { holidayLimitInfo.setEffectDate(holidayLimitInfo.getCycleBeginDate()); } } else if ((fplanformaldate != null && DateTimeUtils.getYear(currentDate) == DateTimeUtils.getYear(fplanformaldate))) { int fprobation = iRowSet.getInt("FPROBATION"); if (fprobation > 0) { holidayLimitInfo.setEffectDate(iRowSet.getDate("FPLANFORMALDATE")); } else { holidayLimitInfo.setEffectDate(holidayLimitInfo.getCycleBeginDate()); } } // 离职情况 if (leaveDate != null && DateTimeUtils.getYear(currentDate) == DateTimeUtils.getYear(leaveDate)) { holidayLimitInfo.setCycleEndDate(leaveDate); holidayLimitInfo.setDelayDate(leaveDate); } holidayLimitInfo.setLastUpdateUser(ContextUtil.getCurrentUserInfo(ctx)); holidayLimitInfo.setLastUpdateTime(new Timestamp(nowDate.getTime())); // 如果假期额度在离职日期之后，不生成 if (leaveDate != null && leaveDate.getTime() < holidayLimitInfo.getCycleEndDate().getTime()) { deleteList.add(limitId); continue; } updateList.add(holidayLimitInfo); } else { HolidayLimitInfo holidayLimitInfo = new HolidayLimitInfo(); holidayLimitInfo.setStandardLimit(standardLimit); holidayLimitInfo.setBigDecimal("convertedLimit", convertedLimit); holidayLimitInfo.setBigDecimal("entitlementLimit", entitlementLimit); holidayLimitInfo.setRealLimit(realLimit); holidayLimitInfo.setRemainLimit(remainLimit); holidayLimitInfo.setFreezeLimit(BigDecimal.ZERO); holidayLimitInfo.setUsedLimit(BigDecimal.ZERO); holidayLimitInfo.setAddOrSubLimit(BigDecimal.ZERO); holidayLimitInfo.setPreOverdraftLimit(BigDecimal.ZERO); if (DateTimeUtils.getYear(currentDate) == DateTimeUtils.getYear(joinDate)) { holidayLimitInfo.setCycleBeginDate(joinDate); int fprobation = iRowSet.getInt("FPROBATION"); if (fprobation > 0) { holidayLimitInfo.setEffectDate(iRowSet.getDate("FPLANFORMALDATE")); } else { holidayLimitInfo.setEffectDate(holidayLimitInfo.getCycleBeginDate()); } } else if ((fplanformaldate != null && DateTimeUtils.getYear(currentDate) == DateTimeUtils.getYear(fplanformaldate))) { holidayLimitInfo.setCycleBeginDate(yearFirstDay); int fprobation = iRowSet.getInt("FPROBATION"); if (fprobation > 0) { holidayLimitInfo.setEffectDate(iRowSet.getDate("FPLANFORMALDATE")); } else { holidayLimitInfo.setEffectDate(holidayLimitInfo.getCycleBeginDate()); } } else { holidayLimitInfo.setCycleBeginDate(yearFirstDay); holidayLimitInfo.setEffectDate(holidayLimitInfo.getCycleBeginDate()); } // 离职情况 if (leaveDate != null && DateTimeUtils.getYear(currentDate) == DateTimeUtils.getYear(leaveDate)) { holidayLimitInfo.setCycleEndDate(leaveDate); holidayLimitInfo.setDelayDate(leaveDate); } else { holidayLimitInfo.setCycleEndDate(yearLastDay); holidayLimitInfo.setDelayDate(yearLastDay); } holidayLimitInfo.setYear(DateTimeUtils.getYear(yearFirstDay)); HolidayPolicyInfo holidayPolicyInfo = new HolidayPolicyInfo(); holidayPolicyInfo.setId(BOSUuid.read(holidayPolicyId)); holidayLimitInfo.setHolidayPolicy(holidayPolicyInfo); holidayLimitInfo.setHolidayUnit(HolidayTypeUnitEnum.day); holidayLimitInfo.setEnableCycle(true); PersonInfo personInfo = new PersonInfo(); personInfo.setId(BOSUuid.read(iRowSet.getString("fid"))); holidayLimitInfo.setProposer(personInfo); holidayLimitInfo.setStatus(HolidayLimitStatus.audited); if (StringUtils.isNotEmpty(iRowSet.getString("FADMINORGID"))) { AdminOrgUnitInfo adminOrgUnitInfo = new AdminOrgUnitInfo(); adminOrgUnitInfo.setId(BOSUuid.read(iRowSet.getString("FADMINORGID"))); holidayLimitInfo.setAdminOrgUnit(adminOrgUnitInfo); } if (StringUtils.isNotEmpty(iRowSet.getString("FHRORGUNITID"))) { HROrgUnitInfo hrOrgUnitInfo = new HROrgUnitInfo(); hrOrgUnitInfo.setId(BOSUuid.read(iRowSet.getString("FHRORGUNITID"))); holidayLimitInfo.setHrOrgUnit(hrOrgUnitInfo); } if (StringUtils.isNotEmpty(iRowSet.getString("FPOSITIONID"))) { PositionInfo positionInfo = new PositionInfo(); positionInfo.setId(BOSUuid.read(iRowSet.getString("FPOSITIONID"))); holidayLimitInfo.setPosition(positionInfo); } CtrlUnitInfo ctrlUnitInfo = new CtrlUnitInfo(); ctrlUnitInfo.setId(BOSUuid.read("00000000-0000-0000-0000-000000000000CCE7AED4")); holidayLimitInfo.setCU(ctrlUnitInfo); holidayLimitInfo.setCycleDate(yearLastDay); holidayLimitInfo.setCreator(ContextUtil.getCurrentUserInfo(ctx)); holidayLimitInfo.setCreateTime(new Timestamp(nowDate.getTime())); holidayLimitInfo.setLastUpdateUser(ContextUtil.getCurrentUserInfo(ctx)); holidayLimitInfo.setLastUpdateTime(new Timestamp(nowDate.getTime())); // 如果假期额度在离职日期之后，不生成 if (leaveDate != null && leaveDate.getTime() < holidayLimitInfo.getCycleEndDate().getTime()) { continue; } addList.add(holidayLimitInfo); } } if (addList.size() > 0) { HolidayLimitFactory.getLocalInstance(ctx).addnewBatchData(addList); } if (updateList.size() > 0) { HolidayLimitFactory.getLocalInstance(ctx).updateBatchData(updateList); } if (deleteList.size() > 0) { IObjectPK[] iObjectPKS = new IObjectPK[deleteList.size()]; for (int i = 0; i < deleteList.size(); i++) { iObjectPKS[i] = new ObjectUuidPK(deleteList.get(i)); } HolidayLimitFactory.getLocalInstance(ctx).deleteBatchData(iObjectPKS); } if (reCalList.size() > 0) { for (int i = 0; i < reCalList.size(); i++) { int yearP = (int) reCalList.get(i).get("year"); String personNumP = (String) reCalList.get(i).get("personNum"); String lastYearSql = "/*dialect*/select p.fid,l.fid limitId,l.FSTANDARDLIMIT,l.FADDORSUBLIMIT,l.FUSEDLIMIT,l.FREEZELIMIT, coalesce(l.CFInitializedLimit, 0) CFInitializedLimit,coalesce(l.CFConvertedLimit, 0) CFConvertedLimit, coalesce(l.cflastcarryforward,0) cflastcarryforward,coalesce(l.cfcarryforward,0) cfcarryforward from t_bd_person p\n" + " left join T_HR_ATS_AtsHolidayFile f on f.fproposerid = p.fid \n" + " left join T_HR_ATS_HolidayPolicySet hps on f.fholidaypolicysetid = hps.fid \n" + " left join T_HR_ATS_HolidayType ht on ht.FNUMBER = 'JQLX000001Y' \n" + " left join T_HR_ATS_HolidayPolicy hp on ht.fid = hp.FHOLIDAYTYPEID and hps.fid = hp.fholidaypolicysetid \n" + " left join T_HR_ATS_HolidayLimit l on hp.fid = l.FHOLIDAYPOLICYID and l.FPROPOSERID = p.fid and l.FCYCLEBEGINDATE >= p.fhiredate and l.FCYCLEBEGINDATE <= p.FLEFFDT and l.fyear = "+(yearP-1)+"\n" + " where f.fattendfilestate = 1 and p.fnumber = '"+personNumP+"' and l.fid is not null "; if (StringUtils.equalsIgnoreCase("MS SQL Server", dbType)) { lastYearSql = "/*dialect*/select p.fid,l.fid limitId,l.FSTANDARDLIMIT,l.FADDORSUBLIMIT,l.FUSEDLIMIT,l.FREEZELIMIT, isnull(l.CFInitializedLimit, 0) CFInitializedLimit,isnull(l.CFConvertedLimit, 0) CFConvertedLimit, isnull(l.cflastcarryforward,0) cflastcarryforward,isnull(l.cfcarryforward,0) cfcarryforward from t_bd_person p\n" + " left join T_HR_ATS_AtsHolidayFile f on f.fproposerid = p.fid \n" + " left join T_HR_ATS_HolidayPolicySet hps on f.fholidaypolicysetid = hps.fid \n" + " left join T_HR_ATS_HolidayType ht on ht.FNUMBER = 'JQLX000001Y' \n" + " left join T_HR_ATS_HolidayPolicy hp on ht.fid = hp.FHOLIDAYTYPEID and hps.fid = hp.fholidaypolicysetid \n" + " left join T_HR_ATS_HolidayLimit l on hp.fid = l.FHOLIDAYPOLICYID and l.FPROPOSERID = p.fid and l.FCYCLEBEGINDATE >= p.fhiredate and l.FCYCLEBEGINDATE <= p.FLEFFDT and l.fyear = "+(yearP-1)+"\n" + " where f.fattendfilestate = 1 and p.fnumber = '"+personNumP+"' and l.fid is not null "; } IRowSet lastYearRowSet = DbUtil.executeQuery(ctx, lastYearSql); if (lastYearRowSet.next()) { HolidayLimitInfo lastYearHolidayLimitInfo = new HolidayLimitInfo(); // 标准额度 = 额度规则（折算额度）+初始化额度+从去年结转-结转到明年 BigDecimal lastYearConvertedLimit = lastYearRowSet.getBigDecimal("CFConvertedLimit"); BigDecimal lastYearInitializedLimit = lastYearRowSet.getBigDecimal("CFInitializedLimit"); BigDecimal lastYearLastCarryforward = lastYearRowSet.getBigDecimal("CFLastCarryforward"); BigDecimal lastYearCarryforward = BigDecimal.ZERO; BigDecimal lastYearStandardLimit = lastYearConvertedLimit.add(lastYearInitializedLimit).add(lastYearLastCarryforward).subtract(lastYearCarryforward); lastYearHolidayLimitInfo.setId(BOSUuid.read(lastYearRowSet.getString("limitId"))); lastYearHolidayLimitInfo.setStandardLimit(lastYearStandardLimit); lastYearHolidayLimitInfo.setRealLimit(lastYearHolidayLimitInfo.getStandardLimit().add(lastYearRowSet.getBigDecimal("FADDORSUBLIMIT"))); lastYearHolidayLimitInfo.setRemainLimit(lastYearHolidayLimitInfo.getRealLimit().subtract(lastYearRowSet.getBigDecimal("FUSEDLIMIT")).subtract(lastYearRowSet.getBigDecimal("FreezeLimit"))); lastYearHolidayLimitInfo.setBigDecimal("Carryforward", lastYearCarryforward); lastYearHolidayLimitInfo.setLastUpdateUser(ContextUtil.getCurrentUserInfo(ctx)); lastYearHolidayLimitInfo.setLastUpdateTime(new Timestamp(nowDate.getTime())); HolidayLimitFactory.getLocalInstance(ctx).update(new ObjectUuidPK(lastYearHolidayLimitInfo.getId()), lastYearHolidayLimitInfo); LeaveAllowanceFacadeFactory.getLocalInstance(ctx).carryForwardLeave(yearP, true, personNumP); } } } } catch (SQLException e) { throw new BOSException(e); } catch (ParseException e) { throw new BOSException(e); } catch (EASBizException e) { throw new BOSException(e); } } private void initialGlobalParam(Context ctx) throws BOSException { // 全局变量 Map param = new HashMap(); ParamCollection paramCollection = ParamFactory.getLocalInstance(ctx).getParamCollection(); for (int i = 0; i < paramCollection.size(); i++) { param.put(paramCollection.get(i).getNumber(), paramCollection.get(i).getValue()); } // 年假折算 annualLeaveConversionMethod = param.get(PARAM_ANNUALLEAVE_CONVERSIONMETHOD); // 年假取整 annualLeaveIntegerMethod = param.get(PARAM_ANNUALLEAVE_INTEGERMETHOD); // 年假取整精度 annualLeaveIntegerPrecision = Double.valueOf(param.get(PARAM_ANNUALLEAVE_INTEGERPERCISION)); // 结转日期 annualLeaveConvertDate = param.get(PARAM_ANNUALLEAVE_CONVERTDATE); // 下年度额度生成 annualLeaveGenerateDay = param.get(PARAM_ANNUALLEAVE_GENERATEDAY); // 育儿假额度 nursingLeaveLimit = Integer.parseInt(param.get(PARAM_NURSINGLEAVE_LIMIT)); // 护理假额度 parentalLeaveLimit = Integer.parseInt(param.get(PARAM_PARENTALLEAVE_LIMIT)); // 护理育儿折算 nursingAndParentalLeaveConversionMethod = param.get(PARAM_NURSINGANDPARENTALLEAVE_CONVERSIONMETHOD); // 护理育儿取整 nursingAndParentalLeaveIntegerMethod = param.get(PARAM_NURSINGANDPARENTALLEAVE_INTEGERMETHOD); // 护理育儿取整精度 nursingAndParentalLeaveIntegerPrecision = Double.valueOf(param.get(PARAM_NURSINGANDPARENTALLEAVE_INTEGERPERCISION)); // 育儿护理多段统计是否更新视图脚本 nursingAndParentalLeaveUpdateSql = param.get(PARAM_NURSINGANDPARENTALLEAVE_UPDATESQL); } /** * 设置司龄 */ @Override public void setSeniority(Context ctx) throws BOSException, EASBizException { String hisSql = "update T_HR_PersonPositionHis set FJOINCOMPANYYEARS=CEILING(FJOINCOMPANYYEARS) where year(FJOINDATE) personNumberList = new ArrayList(); CoreBaseCollection lastYearList = new CoreBaseCollection(); CoreBaseCollection thisYearList = new CoreBaseCollection(); String personNumStr = ""; if (StringUtils.isNotEmpty(personNum)) { String[] personNumArr = personNum.split(","); for (int i = 0; i < personNumArr.length; i++) { personNumberList.add("'" + personNumArr[i] + "'"); } personNumStr = String.join(",",personNumberList); } Date annualLeaveConvertDate = DateTimeUtils.parseDate(year + "-" + LeaveAllowanceFacadeControllerBean.annualLeaveConvertDate); if (currentDate.getTime() >= annualLeaveConvertDate.getTime()) { String sql = " /*dialect*/select thisL.fid thisLFid, lastL.fid lastLfID,thisL.FSTANDARDLIMIT, lastL.FREMAINLIMIT,ht.FNUMBER, " + " case when lastL.FREMAINLIMIT + thisL.CFEntitlementLimit <= 30 then coalesce(lastL.FREMAINLIMIT,0) else coalesce(30 - thisL.CFEntitlementLimit,0) end lastnextForward, " + " case when lastL.FREMAINLIMIT + thisL.CFEntitlementLimit <= 30 then coalesce(lastL.FREMAINLIMIT,0) else coalesce(30 - thisL.CFEntitlementLimit,0) end thislastforward, " + " lastL.FStandardLimit lFStandardLimit,coalesce(lastL.cfinitializedlimit,0) lcfinitializedlimit,coalesce(lastL.cfconvertedlimit,0) lcfconvertedlimit,lastL.FADDORSUBLIMIT lFADDORSUBLIMIT,lastL.FUSEDLIMIT lFUSEDLIMIT,lastL.FREEZELIMIT lFREEZELIMIT,coalesce(lastL.cflastcarryforward,0) lcflastcarryforward,coalesce(lastL.cfcarryforward,0) lcfcarryforward, " + " thisL.FStandardLimit tFStandardLimit,coalesce(thisL.cfinitializedlimit,0) tcfinitializedlimit,coalesce(thisL.cfconvertedlimit,0) tcfconvertedlimit,thisL.FADDORSUBLIMIT tFADDORSUBLIMIT,thisL.FUSEDLIMIT tFUSEDLIMIT,thisL.FREEZELIMIT tFREEZELIMIT,coalesce(thisL.cflastcarryforward,0) tcflastcarryforward,coalesce(thisL.cfcarryforward,0) tcfcarryforward " + " from t_bd_person p " + " left join T_HR_ATS_HolidayLimit lastL on p.fid = lastL.FPROPOSERID and lastL.FCYCLEBEGINDATE >= p.fhiredate and lastL.FCYCLEBEGINDATE <= p.FLEFFDT " + " left join T_HR_ATS_HolidayLimit thisL on thisL.FHOLIDAYPOLICYID = lastL.FHOLIDAYPOLICYID and thisL.FPROPOSERID = lastL.FPROPOSERID and thisL.FCYCLEBEGINDATE >= p.fhiredate and thisL.FCYCLEBEGINDATE <= p.FLEFFDT " + " left join T_HR_ATS_AtsHolidayFile hf on hf.fproposerid = p.fid " + " left join T_HR_ATS_HolidayPolicySet hps on hf.fholidaypolicysetid = hps.fid " + " left join T_HR_ATS_HolidayPolicy hp on hps.fid = hp.fholidaypolicysetid and thisL.FHOLIDAYPOLICYID = hp.fid " + " left join T_HR_ATS_HolidayType ht on ht.fid = hp.FHOLIDAYTYPEID and ht.FNUMBER = 'JQLX000001Y' " + " where hf.fattendfilestate = 1 and ht.FNUMBER = 'JQLX000001Y' and (lastL.cfcarryforward is null or lastL.cfcarryforward = 0) and thisL.FYEAR = "+year+" and lastL.fyear = "+(year-1)+""; String dbType = ContextUtil.getDbType(ctx); if (StringUtils.equalsIgnoreCase("MS SQL Server", dbType)) { sql = " /*dialect*/select thisL.fid thisLFid, lastL.fid lastLfID,thisL.FSTANDARDLIMIT, lastL.FREMAINLIMIT,ht.FNUMBER, " + " case when lastL.FREMAINLIMIT + thisL.CFEntitlementLimit <= 30 then isnull(lastL.FREMAINLIMIT,0) else isnull(30 - thisL.CFEntitlementLimit,0) end lastnextForward, " + " case when lastL.FREMAINLIMIT + thisL.CFEntitlementLimit <= 30 then isnull(lastL.FREMAINLIMIT,0) else isnull(30 - thisL.CFEntitlementLimit,0) end thislastforward, " + " lastL.FStandardLimit lFStandardLimit,isnull(lastL.cfinitializedlimit,0) lcfinitializedlimit,isnull(lastL.cfconvertedlimit,0) lcfconvertedlimit,lastL.FADDORSUBLIMIT lFADDORSUBLIMIT,lastL.FUSEDLIMIT lFUSEDLIMIT,lastL.FREEZELIMIT lFREEZELIMIT,isnull(lastL.cflastcarryforward,0) lcflastcarryforward,isnull(lastL.cfcarryforward,0) lcfcarryforward, " + " thisL.FStandardLimit tFStandardLimit,isnull(thisL.cfinitializedlimit,0) tcfinitializedlimit,isnull(thisL.cfconvertedlimit,0) tcfconvertedlimit,thisL.FADDORSUBLIMIT tFADDORSUBLIMIT,thisL.FUSEDLIMIT tFUSEDLIMIT,thisL.FREEZELIMIT tFREEZELIMIT,isnull(thisL.cflastcarryforward,0) tcflastcarryforward,isnull(thisL.cfcarryforward,0) tcfcarryforward " + " from t_bd_person p " + " left join T_HR_ATS_HolidayLimit lastL on p.fid = lastL.FPROPOSERID and lastL.FCYCLEBEGINDATE >= p.fhiredate and lastL.FCYCLEBEGINDATE <= p.FLEFFDT " + " left join T_HR_ATS_HolidayLimit thisL on thisL.FHOLIDAYPOLICYID = lastL.FHOLIDAYPOLICYID and thisL.FPROPOSERID = lastL.FPROPOSERID and thisL.FCYCLEBEGINDATE >= p.fhiredate and thisL.FCYCLEBEGINDATE <= p.FLEFFDT " + " left join T_HR_ATS_AtsHolidayFile hf on hf.fproposerid = p.fid " + " left join T_HR_ATS_HolidayPolicySet hps on hf.fholidaypolicysetid = hps.fid " + " left join T_HR_ATS_HolidayPolicy hp on hps.fid = hp.fholidaypolicysetid and thisL.FHOLIDAYPOLICYID = hp.fid " + " left join T_HR_ATS_HolidayType ht on ht.fid = hp.FHOLIDAYTYPEID and ht.FNUMBER = 'JQLX000001Y' " + " where hf.fattendfilestate = 1 and ht.FNUMBER = 'JQLX000001Y' and (lastL.cfcarryforward is null or lastL.cfcarryforward = 0) and thisL.FYEAR = "+year+" and lastL.fyear = "+(year-1)+""; } if (StringUtils.isNotEmpty(personNumStr)) { sql += " and p.fnumber in (" + personNumStr + ") "; } IRowSet rowSet = DbUtil.executeQuery(ctx, sql); while (rowSet.next()) { HolidayLimitInfo lastYearHolidayLimitInfo = new HolidayLimitInfo(); lastYearHolidayLimitInfo.setId(BOSUuid.read(rowSet.getString("lastLfID"))); lastYearHolidayLimitInfo.setBigDecimal("Carryforward", rowSet.getBigDecimal("lastnextForward")); // 去年 折算标准额度 BigDecimal lastYearConvertedLimit = rowSet.getBigDecimal("lcfconvertedlimit"); // 去年 初始化额度 BigDecimal lastYearInitializedLimit = rowSet.getBigDecimal("lCFInitializedLimit"); // 去年 从去年结转额度 BigDecimal lastYearLastCarryforward = rowSet.getBigDecimal("lCFLastCarryforward"); // 去年 标准额度 = 额度规则（折算额度）+初始化额度+从去年结转-结转到明年 BigDecimal lastYearStandardLimit = lastYearConvertedLimit.add(lastYearInitializedLimit).add(lastYearLastCarryforward).subtract(lastYearHolidayLimitInfo.getBigDecimal("Carryforward")); lastYearHolidayLimitInfo.setStandardLimit(lastYearStandardLimit); lastYearHolidayLimitInfo.setRealLimit(lastYearHolidayLimitInfo.getStandardLimit().add(rowSet.getBigDecimal("LFADDORSUBLIMIT"))); lastYearHolidayLimitInfo.setRemainLimit(lastYearHolidayLimitInfo.getRealLimit().subtract(rowSet.getBigDecimal("LFUSEDLIMIT")).subtract(rowSet.getBigDecimal("lFreezeLimit"))); lastYearHolidayLimitInfo.setLastUpdateUser(ContextUtil.getCurrentUserInfo(ctx)); lastYearHolidayLimitInfo.setLastUpdateTime(new Timestamp(nowDate.getTime())); lastYearList.add(lastYearHolidayLimitInfo); HolidayLimitInfo thisYearHolidayLimitInfo = new HolidayLimitInfo(); thisYearHolidayLimitInfo.setId(BOSUuid.read(rowSet.getString("thisLFid"))); thisYearHolidayLimitInfo.setBigDecimal("LastCarryforward", rowSet.getBigDecimal("thislastforward")); // 今年 折算标准额度 BigDecimal thisYearConvertedLimit = rowSet.getBigDecimal("tcfconvertedlimit"); // 今年 初始化额度 BigDecimal thisYearInitializedLimit = rowSet.getBigDecimal("tCFInitializedLimit"); // 今年 从去年结转额度 TODO xxx BigDecimal thisYearCarryforward = rowSet.getBigDecimal("tCFCarryforward"); // 今年 标准额度 = 额度规则（折算额度）+初始化额度+从去年结转-结转到明年 BigDecimal thisYearStandardLimit = thisYearConvertedLimit.add(thisYearInitializedLimit).add(thisYearHolidayLimitInfo.getBigDecimal("LastCarryforward")).subtract(thisYearCarryforward); thisYearHolidayLimitInfo.setStandardLimit(thisYearStandardLimit); thisYearHolidayLimitInfo.setRealLimit(thisYearHolidayLimitInfo.getStandardLimit().add(rowSet.getBigDecimal("tFADDORSUBLIMIT"))); thisYearHolidayLimitInfo.setRemainLimit(thisYearHolidayLimitInfo.getRealLimit().subtract(rowSet.getBigDecimal("tFUSEDLIMIT")).subtract(rowSet.getBigDecimal("tFreezeLimit"))); thisYearHolidayLimitInfo.setLastUpdateUser(ContextUtil.getCurrentUserInfo(ctx)); thisYearHolidayLimitInfo.setLastUpdateTime(new Timestamp(nowDate.getTime())); thisYearList.add(thisYearHolidayLimitInfo); } } if (lastYearList.size() > 0) { HolidayLimitFactory.getLocalInstance(ctx).updateBatchData(lastYearList); } if (thisYearList.size() > 0) { HolidayLimitFactory.getLocalInstance(ctx).updateBatchData(thisYearList); } } catch (ParseException e) { throw new BOSException(e); } catch (SQLException e) { throw new BOSException(e); } } /** * 护理假额度生成 JQLX000016Y */ @Override protected void _creareNursingLeave(Context ctx, int year, String personNum) throws BOSException { createNursingOrParentalLeave(ctx, year, personNum, "JQLX000016Y", nursingLeaveLimit, "P"); } /** * 育儿假额度生成 JQLX000015Y */ @Override protected void _creareParentalLeave(Context ctx, int year, String personNum) throws BOSException { createNursingOrParentalLeave(ctx, year, personNum, "JQLX000015Y", parentalLeaveLimit, "C"); } private void createNursingOrParentalLeave(Context ctx, int year, String personNum, String policyNumber, int initialLimit,String cnLeave) throws BOSException { try { initialGlobalParam(ctx); String personFamilyTempTable = createPersonFamilyTempTable(ctx, cnLeave); // 当前时间 Date nowDate = new Date(); Date currentDate = new Date(); if (year != 0) { currentDate = DateTimeUtils.parseDate(year + "-12-31"); } else { year = DateTimeUtils.getYear(currentDate); } // 当前年份第一天 String yearFirstDayStr = DateTimeUtils.getYear(currentDate) + "-01-01"; Date yearFirstDay = DateTimeUtils.parseDate(yearFirstDayStr); // 当前年份最后一天 String yearLastDayStr = DateTimeUtils.getYear(currentDate) + "-12-31"; Date yearLastDay = DateTimeUtils.parseDate(yearLastDayStr); List personNumberList = new ArrayList(); CoreBaseCollection addList = new CoreBaseCollection(); CoreBaseCollection updateList = new CoreBaseCollection(); String personNumStr = ""; if (StringUtils.isNotEmpty(personNum)) { String[] personNumArr = personNum.split(","); for (int i = 0; i < personNumArr.length; i++) { personNumberList.add("'" + personNumArr[i] + "'"); } personNumStr = String.join(",",personNumberList); } // 置空相关的假期额度 String clearQuotaSql = " update T_HR_ATS_HolidayLimit set FStandardLimit = 0, FRealLimit = FAddOrSubLimit,FRemainLimit = FAddOrSubLimit-FUsedLimit-FreezeLimit where fid in ( " + " select l.fid from T_HR_ATS_HolidayLimit l " + " left join T_HR_ATS_HolidayPolicy hp on hp.fid = l.FHOLIDAYPOLICYID " + " left join T_HR_ATS_HolidayType ht on hp.FHOLIDAYTYPEID = ht.fid " + " left join t_bd_person p on p.fid = l.FPROPOSERID " + " where ht.FNUMBER = '"+policyNumber+"' and l.FYEAR = "+year+" and l.FCYCLEBEGINDATE >= p.fhiredate and l.FCYCLEBEGINDATE <= p.FLEFFDT "; if (StringUtils.isNotEmpty(personNumStr)) { clearQuotaSql += " and p.fnumber in (" + personNumStr + ")) "; } else { clearQuotaSql += " ) "; } DbUtil.execute(ctx, clearQuotaSql); // 清理空数据 String deleteZeroQuotaSql = "delete from T_HR_ATS_HolidayLimit where FHOLIDAYPOLICYID in (select hp.fid from T_HR_ATS_HolidayPolicy hp " + "left join T_HR_ATS_HolidayType ht on hp.FHOLIDAYTYPEID = ht.fid where ht.FNUMBER = '"+policyNumber+"') and FYEAR = "+year+" and FStandardLimit = 0 and FRealLimit = 0 and FAddOrSubLimit = 0 and FRemainLimit = 0 and FUsedLimit = 0 and FreezeLimit = 0 "; if (StringUtils.isNotEmpty(personNumStr)) { deleteZeroQuotaSql += " and FProposerID in (select fid from t_bd_person where fnumber in ("+personNumStr+") ) "; } DbUtil.execute(ctx, deleteZeroQuotaSql); String sql = "/*dialect*/select f.FPERSONID,p.fnumber, case when to_char(f.CFStartTime,'yyyy') < "+ year +" then to_date('"+ year +"-01-01','yyyy-MM-dd') else f.CFStartTime end CFStartTime," + " case when f.CFEndTime is null or to_char(f.CFEndTime,'yyyy') > "+ year +" then to_date('"+ year +"-12-31','yyyy-MM-dd') else f.CFEndTime end CFEndTime ," + " case when rb.fid is null then null else rbe.FBIZDATE end leaveDate,p.fhiredate,hf.FADMINORGUNITID, hf.FHRORGUNITID ,hf.FPOSITIONID, l.fid limitId,ebe.FPROBATION,ebe.FPLANFORMALDATE,hp.fid holidayPolicyId,l.FADDORSUBLIMIT,l.FUSEDLIMIT,l.FREEZELIMIT,l.FCYCLEBEGINDATE,l.FCYCLEENDDATE from " + personFamilyTempTable + " f " + " left join t_bd_person p on p.fid = f.FPERSONID " + " left join T_HR_ATS_AtsHolidayFile hf on hf.fproposerid = f.FPERSONID " + " left join T_HR_ATS_HolidayPolicySet hps on hf.fholidaypolicysetid = hps.fid " + " left join T_HR_ATS_HolidayType ht on ht.FNUMBER = '"+policyNumber+"' " + " left join T_HR_ATS_HolidayPolicy hp on ht.fid = hp.FHOLIDAYTYPEID and hps.fid = hp.fholidaypolicysetid " + " left join T_HR_ATS_HolidayLimit l on hp.fid = l.FHOLIDAYPOLICYID and l.FPROPOSERID = f.FPERSONID and l.FYEAR = "+ year +" and f.CFStartTime<=l.FCYCLEBEGINDATE and f.CFEndTime>=l.FCYCLEBEGINDATE and l.FCYCLEBEGINDATE >= p.fhiredate and l.FCYCLEENDDATE >= p.fhiredate " + " left join T_HR_EmpEnrollBizBillEntry ebe on ebe.FPERSONID = f.FPERSONID and ebe.FBIZDATE = p.fhiredate " + " left join T_HR_EmpEnrollBizBill eb on ebe.FBILLID = eb.FID and eb.FBILLSTATE = 3 " + " left join T_HR_ResignBizBillEntry rbe on rbe.FPERSONID = f.FPERSONID and (p.fhiredate<=rbe.FBIZDATE or rbe.FBIZDATE is null)" + " left join T_HR_ResignBizBill rb on rb.fid = rbe.FBILLID and rb.FBILLSTATE = 3 " + " where hf.fattendfilestate = 1 and f.CFStartTime <= to_date('"+yearLastDayStr+"','yyyy-MM-dd') and (f.CFEndTime >= to_date('"+yearFirstDayStr+"','yyyy-MM-dd') or f.CFEndTime is null) and to_char(p.fhiredate,'yyyy')<="+year+" and to_char(p.FLEFFDT,'yyyy')>="+year; String dbType = ContextUtil.getDbType(ctx); if (StringUtils.equalsIgnoreCase("MS SQL Server", dbType)) { sql = "/*dialect*/ select f.FPERSONID,p.fnumber, case when year(f.CFStartTime) < "+ year +" then cast('"+ year +"-01-01' as datetime) else f.CFStartTime end CFStartTime," + " case when f.CFEndTime is null or year(f.CFEndTime) > "+ year +" then cast('"+ year +"-12-31' as datetime) else f.CFEndTime end CFEndTime ," + " case when rb.fid is null then null else rbe.FBIZDATE end leaveDate,p.fhiredate,hf.FADMINORGUNITID, hf.FHRORGUNITID ,hf.FPOSITIONID, l.fid limitId,ebe.FPROBATION,ebe.FPLANFORMALDATE,hp.fid holidayPolicyId,l.FADDORSUBLIMIT,l.FUSEDLIMIT,l.FREEZELIMIT,l.FCYCLEBEGINDATE,l.FCYCLEENDDATE from " + personFamilyTempTable + " f " + " left join t_bd_person p on p.fid = f.FPERSONID " + " left join T_HR_ATS_AtsHolidayFile hf on hf.fproposerid = f.FPERSONID " + " left join T_HR_ATS_HolidayPolicySet hps on hf.fholidaypolicysetid = hps.fid " + " left join T_HR_ATS_HolidayType ht on ht.FNUMBER = '"+policyNumber+"' " + " left join T_HR_ATS_HolidayPolicy hp on ht.fid = hp.FHOLIDAYTYPEID and hps.fid = hp.fholidaypolicysetid " + " left join T_HR_ATS_HolidayLimit l on hp.fid = l.FHOLIDAYPOLICYID and l.FPROPOSERID = f.FPERSONID and l.FYEAR = "+ year +" and f.CFStartTime<=l.FCYCLEBEGINDATE and f.CFEndTime>=l.FCYCLEBEGINDATE and l.FCYCLEBEGINDATE >= p.fhiredate and l.FCYCLEENDDATE >= p.fhiredate " + " left join T_HR_EmpEnrollBizBillEntry ebe on ebe.FPERSONID = f.FPERSONID and ebe.FBIZDATE = p.fhiredate " + " left join T_HR_EmpEnrollBizBill eb on ebe.FBILLID = eb.FID and eb.FBILLSTATE = 3 " + " left join T_HR_ResignBizBillEntry rbe on rbe.FPERSONID = f.FPERSONID and (p.fhiredate<=rbe.FBIZDATE or rbe.FBIZDATE is null) " + " left join T_HR_ResignBizBill rb on rb.fid = rbe.FBILLID and rb.FBILLSTATE = 3 " + " where hf.fattendfilestate = 1 and f.CFStartTime <= cast('"+yearLastDayStr+"' as datetime) and (f.CFEndTime >= cast('"+yearFirstDayStr+"' as datetime) or f.CFEndTime is null) and year(p.fhiredate)<="+year+" and year(p.FLEFFDT)>="+year ; } if (StringUtils.isNotEmpty(personNumStr)) { sql += " and p.fnumber in (" + personNumStr + ") "; } IRowSet iRowSet = DbUtil.executeQuery(ctx, sql); while (iRowSet.next()) { String holidayPolicyId = iRowSet.getString("holidayPolicyId"); if (StringUtils.isEmpty(holidayPolicyId)) { continue; } BigDecimal standardLimit = BigDecimal.valueOf(initialLimit); String limitId = iRowSet.getString("limitId"); // 入职日期 java.sql.Date joinDate = iRowSet.getDate("fhiredate"); java.sql.Date fplanformaldate = iRowSet.getDate("FPLANFORMALDATE"); // 离职日期 java.sql.Date leaveDate = iRowSet.getDate("leaveDate"); // 开始日期 java.sql.Date cfStartTime = iRowSet.getDate("CFStartTime"); // 生效日期 java.sql.Date effectDate = iRowSet.getDate("CFStartTime"); // 结束日期 java.sql.Date cfEndTime = iRowSet.getDate("CFEndTime"); // 入职折算 if (DateTimeUtils.getYear(joinDate) == DateTimeUtils.getYear(cfStartTime) && joinDate.getTime() > cfStartTime.getTime()) { cfStartTime = joinDate; effectDate = iRowSet.getDate("FPLANFORMALDATE") != null ? iRowSet.getDate("FPLANFORMALDATE") : joinDate; } else if (fplanformaldate != null && DateTimeUtils.getYear(fplanformaldate) == DateTimeUtils.getYear(cfStartTime) && fplanformaldate.getTime() > cfStartTime.getTime()) { effectDate = fplanformaldate; } // 离职折算 if (leaveDate != null && DateTimeUtils.getYear(currentDate) == DateTimeUtils.getYear(leaveDate)) { if (DateTimeUtils.getYear(leaveDate) == DateTimeUtils.getYear(cfEndTime) && cfEndTime.getTime() > leaveDate.getTime()) { cfEndTime = leaveDate; } } // 开始时间必须小于或等于结束日期 if (cfStartTime.getTime() > cfEndTime.getTime()) { continue; } standardLimit = standardLimit.multiply(BigDecimal.valueOf(DateTimeUtils.getMonth(cfEndTime) - DateTimeUtils.getMonth(cfStartTime) + 1)).divide(BigDecimal.valueOf(MONTH_NUM_12), 10, BigDecimal.ROUND_HALF_UP); // 年假取整 // 整数部分 BigDecimal standardLimitInteger = standardLimit.setScale(0, RoundingMode.FLOOR); // 小数部分 BigDecimal standardLimitDecimal = standardLimit.subtract(standardLimitInteger); if (Double.doubleToLongBits(INTEGERPERCISION_HALF) == Double.doubleToLongBits(nursingAndParentalLeaveIntegerPrecision)) { if (StringUtils.equals(INTEGERMETHOD_UP, nursingAndParentalLeaveIntegerMethod)) { if (standardLimitDecimal.compareTo(BigDecimal.valueOf(0.5)) > 0) { standardLimit = standardLimit.setScale(0, RoundingMode.CEILING); } else if (standardLimitDecimal.compareTo(BigDecimal.ZERO) > 0){ standardLimit = standardLimitInteger.add(BigDecimal.valueOf(0.5)); } else { standardLimit = standardLimitInteger; } } else { if (standardLimitDecimal.compareTo(BigDecimal.valueOf(0.5)) > 0) { standardLimit = standardLimitInteger.add(BigDecimal.valueOf(0.5)); } else { standardLimit = standardLimit.setScale(0, RoundingMode.FLOOR); } } } else { if (StringUtils.equals(INTEGERMETHOD_UP, nursingAndParentalLeaveIntegerMethod)) { standardLimit = standardLimit.setScale(0, RoundingMode.CEILING); } else { standardLimit = standardLimit.setScale(0, RoundingMode.FLOOR); } } if (StringUtils.isNotEmpty(limitId)) { HolidayLimitInfo holidayLimitInfo = new HolidayLimitInfo(); holidayLimitInfo.setId(BOSUuid.read(limitId)); // 标准额度 holidayLimitInfo.setStandardLimit(standardLimit); holidayLimitInfo.setRealLimit(standardLimit.add(iRowSet.getBigDecimal("FADDORSUBLIMIT"))); holidayLimitInfo.setRemainLimit(standardLimit.add(iRowSet.getBigDecimal("FADDORSUBLIMIT")).subtract(iRowSet.getBigDecimal("FUSEDLIMIT")).subtract(iRowSet.getBigDecimal("FreezeLimit"))); holidayLimitInfo.setCycleBeginDate(cfStartTime); holidayLimitInfo.setCycleEndDate(cfEndTime); holidayLimitInfo.setEffectDate(effectDate); holidayLimitInfo.setDelayDate(yearLastDay); if (leaveDate != null && leaveDate.getTime() == cfEndTime.getTime()) { holidayLimitInfo.setDelayDate(cfEndTime); } holidayLimitInfo.setLastUpdateUser(ContextUtil.getCurrentUserInfo(ctx)); holidayLimitInfo.setLastUpdateTime(new Timestamp(nowDate.getTime())); updateList.add(holidayLimitInfo); } else { HolidayLimitInfo holidayLimitInfo = new HolidayLimitInfo(); holidayLimitInfo.setStandardLimit(standardLimit); holidayLimitInfo.setRealLimit(standardLimit); holidayLimitInfo.setRemainLimit(standardLimit); holidayLimitInfo.setFreezeLimit(BigDecimal.ZERO); holidayLimitInfo.setUsedLimit(BigDecimal.ZERO); holidayLimitInfo.setAddOrSubLimit(BigDecimal.ZERO); holidayLimitInfo.setPreOverdraftLimit(BigDecimal.ZERO); holidayLimitInfo.setCycleBeginDate(cfStartTime); holidayLimitInfo.setCycleEndDate(cfEndTime); holidayLimitInfo.setEffectDate(effectDate); holidayLimitInfo.setDelayDate(yearLastDay); if (leaveDate != null && leaveDate.getTime() == cfEndTime.getTime()) { holidayLimitInfo.setDelayDate(cfEndTime); } holidayLimitInfo.setYear(DateTimeUtils.getYear(yearFirstDay)); HolidayPolicyInfo holidayPolicyInfo = new HolidayPolicyInfo(); holidayPolicyInfo.setId(BOSUuid.read(holidayPolicyId)); holidayLimitInfo.setHolidayPolicy(holidayPolicyInfo); holidayLimitInfo.setHolidayUnit(HolidayTypeUnitEnum.day); holidayLimitInfo.setEnableCycle(true); PersonInfo personInfo = new PersonInfo(); personInfo.setId(BOSUuid.read(iRowSet.getString("FPERSONID"))); holidayLimitInfo.setProposer(personInfo); holidayLimitInfo.setStatus(HolidayLimitStatus.audited); if (StringUtils.isNotEmpty(iRowSet.getString("FADMINORGUNITID"))) { AdminOrgUnitInfo adminOrgUnitInfo = new AdminOrgUnitInfo(); adminOrgUnitInfo.setId(BOSUuid.read(iRowSet.getString("FADMINORGUNITID"))); holidayLimitInfo.setAdminOrgUnit(adminOrgUnitInfo); } if (StringUtils.isNotEmpty(iRowSet.getString("FHRORGUNITID"))) { HROrgUnitInfo hrOrgUnitInfo = new HROrgUnitInfo(); hrOrgUnitInfo.setId(BOSUuid.read(iRowSet.getString("FHRORGUNITID"))); holidayLimitInfo.setHrOrgUnit(hrOrgUnitInfo); } if (StringUtils.isNotEmpty(iRowSet.getString("FPOSITIONID"))) { PositionInfo positionInfo = new PositionInfo(); positionInfo.setId(BOSUuid.read(iRowSet.getString("FPOSITIONID"))); holidayLimitInfo.setPosition(positionInfo); } CtrlUnitInfo ctrlUnitInfo = new CtrlUnitInfo(); ctrlUnitInfo.setId(BOSUuid.read("00000000-0000-0000-0000-000000000000CCE7AED4")); holidayLimitInfo.setCU(ctrlUnitInfo); holidayLimitInfo.setCycleDate(yearLastDay); holidayLimitInfo.setCreator(ContextUtil.getCurrentUserInfo(ctx)); holidayLimitInfo.setCreateTime(new Timestamp(nowDate.getTime())); holidayLimitInfo.setLastUpdateUser(ContextUtil.getCurrentUserInfo(ctx)); holidayLimitInfo.setLastUpdateTime(new Timestamp(nowDate.getTime())); addList.add(holidayLimitInfo); } } if (addList.size() > 0) { HolidayLimitFactory.getLocalInstance(ctx).addnewBatchData(addList); } if (updateList.size() > 0) { HolidayLimitFactory.getLocalInstance(ctx).updateBatchData(updateList); } } catch (ParseException | SQLException e) { throw new BOSException(e); } catch (EASBizException e) { throw new BOSException(e); } } /** * 创建社会关系临时表 处理日期区间合并数据 * @param ctx * @param cnLeave * @return * @throws BOSException */ private String createPersonFamilyTempTable(Context ctx, String cnLeave) throws BOSException { String dbType = ContextUtil.getDbType(ctx); String view_pf_PersonFamilyTempTable = ""; // 育儿护理多段统计是否更新视图脚本 if (StringUtils.equalsIgnoreCase(nursingAndParentalLeaveUpdateSql, "Y")) { // 删除视图 if (StringUtils.equalsIgnoreCase("MS SQL Server", dbType)) { String dropView = " IF EXISTS (SELECT * FROM sys.views WHERE name = 'view_pf_DateRanges_"+cnLeave+"') " + " DROP VIEW view_pf_DateRanges_"+cnLeave; DbUtil.execute(ctx, dropView); dropView = " IF EXISTS (SELECT * FROM sys.views WHERE name = 'view_pf_CTE_"+cnLeave+"') " + " DROP VIEW view_pf_CTE_"+cnLeave; DbUtil.execute(ctx, dropView); dropView = " IF EXISTS (SELECT * FROM sys.views WHERE name = 'view_pf_MergedRanges_"+cnLeave+"') " + " DROP VIEW view_pf_MergedRanges_"+cnLeave; DbUtil.execute(ctx, dropView); dropView = " IF EXISTS (SELECT * FROM sys.views WHERE name = 'view_pf_GroupedRanges_"+cnLeave+"') " + " DROP VIEW view_pf_GroupedRanges_"+cnLeave; DbUtil.execute(ctx, dropView); } // 创建视图 String createView = " /*dialect*/create or replace view view_pf_DateRanges_"+cnLeave+" as ( " + " select CFStartTime StartDate,CFEndTime EndDate,FPERSONID PersonID from t_hr_personfamily where CFCnleave = '"+cnLeave+"' " + " ) "; if (StringUtils.equalsIgnoreCase("MS SQL Server", dbType)) { createView = " /*dialect*/create view view_pf_DateRanges_"+cnLeave+" as ( " + " select CFStartTime StartDate,CFEndTime EndDate,FPERSONID PersonID from t_hr_personfamily where CFCnleave = '"+cnLeave+"' " + " ) "; } DbUtil.execute(ctx, createView); createView = " /*dialect*/create or replace view view_pf_CTE_"+cnLeave+" AS ( " + " SELECT PersonID,StartDate, EndDate,LAG(EndDate) OVER (PARTITION BY PersonID ORDER BY StartDate) AS prev_end_date FROM view_pf_DateRanges_"+ cnLeave + ") "; if (StringUtils.equalsIgnoreCase("MS SQL Server", dbType)) { createView = " /*dialect*/create view view_pf_CTE_"+cnLeave+" AS ( " + " SELECT PersonID,StartDate, EndDate,LAG(EndDate) OVER (PARTITION BY PersonID ORDER BY StartDate) AS prev_end_date FROM view_pf_DateRanges_" + cnLeave + ") "; } DbUtil.execute(ctx, createView); createView = " /*dialect*/create or replace view view_pf_MergedRanges_"+cnLeave+" AS ( " + " SELECT PersonID,StartDate,EndDate,CASE WHEN StartDate <= prev_end_date + INTERVAL '1 day' THEN 0 ELSE 1 END AS is_overlap FROM view_pf_CTE_" + cnLeave + ") "; if (StringUtils.equalsIgnoreCase("MS SQL Server", dbType)) { createView = " /*dialect*/create view view_pf_MergedRanges_"+cnLeave+" AS ( " + " SELECT PersonID,StartDate,EndDate,CASE WHEN StartDate <= DATEADD(day, 1, prev_end_date) THEN 0 ELSE 1 END AS is_overlap FROM view_pf_CTE_" + cnLeave + ") "; } DbUtil.execute(ctx, createView); createView = " /*dialect*/create or replace view view_pf_GroupedRanges_"+cnLeave+" AS ( " + " SELECT PersonID,StartDate,EndDate,SUM(is_overlap) OVER (PARTITION BY PersonID ORDER BY StartDate) AS grp FROM view_pf_MergedRanges_" + cnLeave + ") "; if (StringUtils.equalsIgnoreCase("MS SQL Server", dbType)) { createView = " /*dialect*/create view view_pf_GroupedRanges_"+cnLeave+" AS ( " + " SELECT PersonID,StartDate,EndDate,SUM(is_overlap) OVER (PARTITION BY PersonID ORDER BY StartDate) AS grp FROM view_pf_MergedRanges_" + cnLeave + ") "; } DbUtil.execute(ctx, createView); } view_pf_PersonFamilyTempTable = " (SELECT PersonID fpersonid,MIN(StartDate) AS CFStartTime,MAX(EndDate) AS CFEndTime FROM view_pf_GroupedRanges_"+cnLeave+" GROUP BY PersonID, grp ORDER BY PersonID, CFStartTime) "; if (StringUtils.equalsIgnoreCase("MS SQL Server", dbType)) { view_pf_PersonFamilyTempTable = " (SELECT top 100 percent PersonID fpersonid,MIN(StartDate) AS CFStartTime,MAX(EndDate) AS CFEndTime FROM view_pf_GroupedRanges_"+cnLeave+" GROUP BY PersonID, grp ORDER BY PersonID, CFStartTime) "; } return view_pf_PersonFamilyTempTable; } /** * 员工列表 * @param ctx * @param * @return * @throws BOSException * @throws SQLException */ private List getPersonData(Context ctx,String leaveNumber, int year) throws BOSException, SQLException{ String nursingSql = " SELECT a.FPROPOSERID FROM T_HR_ATS_HolidayLimit as a ,T_HR_ATS_HolidayPolicy as b , T_HR_ATS_HolidayType c " + " where a.FHOLIDAYPOLICYID = b.FID and b.FHOLIDAYTYPEID = c.FID and c.FNUMBER = '" + leaveNumber + "' and FYear = "+year+" " ; IRowSet rs = DbUtil.executeQuery(ctx, nursingSql); List personList = new ArrayList(); while(rs.next()){ personList.add(rs.getString("FPROPOSERID")); } return personList; } /** * 开始时间 * @param * @return */ private static Date getStartDate(Date startDate ){ Calendar calendar = Calendar.getInstance(); int year = calendar.get(Calendar.YEAR); calendar.clear(); calendar.set(Calendar.YEAR, year); calendar.add(Calendar.MONTH, 1); calendar.set(Calendar.DAY_OF_MONTH, 0); if(startDate.before(calendar.getTime())){ startDate = calendar.getTime(); } return startDate; } /** * 结束时间 * @param * @return */ private static Date getEndDate(Date endDate){ Calendar calendar = Calendar.getInstance(); int year = calendar.get(Calendar.YEAR); calendar.set(Calendar.YEAR, year); calendar.roll(Calendar.DAY_OF_YEAR, -1); calendar.set(Calendar.MONTH, 11); calendar.set(Calendar.DAY_OF_MONTH, 1); if(endDate.after(calendar.getTime())){ endDate = calendar.getTime(); } return endDate; } /** * 返回休假天数 * @param day * @param month * @return */ public double getLeaveDay(double day,int month) { double leaveDay = day / 12.0 * month; int floorInt = (int) leaveDay; double decimals = leaveDay - floorInt; if(decimals < 0.5) { System.out.print("可休假额度：" + floorInt); return floorInt ; }else { System.out.print("可休假额度：" + floorInt + 0.5); return (floorInt + 0.5); } } /** * 获取假期类型为对应的假期制度id集合 * @param ctx * @param holidayNumber * @return */ public String getHolidayPolicyIds(Context ctx, String holidayNumber) { StringBuffer holidayPolicyIds = new StringBuffer(); try { HolidayTypeCollection holidayTypeCollection = HolidayTypeFactory.getLocalInstance(ctx).getHolidayTypeCollection("where number = '"+holidayNumber+"'"); if(holidayTypeCollection!=null && holidayTypeCollection.size()>0) { HolidayPolicyCollection holidayPolicyCollection = HolidayPolicyFactory.getLocalInstance(ctx).getHolidayPolicyCollection("where holidayType = '"+holidayTypeCollection.get(0).getId().toString()+"'"); for(int i=0;i0) { holidayPolicyIds = holidayPolicyIds.deleteCharAt(holidayPolicyIds.length()-1); } } } catch (BOSException e) { e.printStackTrace(); } return holidayPolicyIds.toString(); } /** * 根据假期额度名称获取id * @param ctx * @param holidayName * @return */ // public String getHolidayPolicyID(Context ctx, String holidayNumber) { // try { // HolidayTypeCollection holidayTypeCollection = HolidayTypeFactory.getLocalInstance(ctx).getHolidayTypeCollection("where number = '"+holidayNumber+"'"); // if(holidayTypeCollection!=null && holidayTypeCollection.size()>0) { // HolidayPolicyCollection holidayPolicyCollection = HolidayPolicyFactory.getLocalInstance(ctx).getHolidayPolicyCollection("where holidayType = '"+holidayTypeCollection.get(0).getId().toString()+"'"); // if(holidayPolicyCollection != null && holidayPolicyCollection.size()>0) { // return holidayPolicyCollection.get(0).getId().toString(); // } // } // } catch (BOSException e) { // e.printStackTrace(); // } // return ""; // } }