package weaver.interfaces.sskj.job; import cn.hutool.core.date.DateUtil; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; import com.alipay.api.domain.RecordDetail; import com.engine.kq.biz.KQFormatBiz; import com.engine.kq.biz.KQLeaveRulesComInfo; import com.engine.kq.timer.KQQueue; import com.engine.kq.timer.KQTaskBean; import com.engine.kq.wfset.util.SplitActionUtil; import com.engine.sskj.util.SskjUtil; import com.github.pagehelper.dialect.helper.InformixDialect; import com.google.common.collect.Lists; import com.google.common.collect.Maps; import com.jayway.jsonpath.Configuration; import com.jayway.jsonpath.JsonPath; import org.apache.commons.lang3.StringUtils; import weaver.conn.BatchRecordSet; import weaver.conn.RecordSet; import weaver.general.BaseBean; import weaver.general.Util; import weaver.interfaces.schedule.BaseCronJob; import java.text.DateFormat; import java.text.SimpleDateFormat; import java.time.LocalTime; import java.time.temporal.ChronoUnit; import java.util.*; import java.util.stream.Collectors; import static weaver.interfaces.sskj.util.HttpsUtil.doPostJsonRequest; /** * Created with IntelliJ IDEA. * 处理加班时长扣减培训时长 * @Auther: chenwnj * @Date: 2023/11/27 * @Description: */ public class DeductTrainTimesJob extends BaseCronJob { @Override public void execute() { BaseBean bb = new BaseBean(); bb.writeLog("-----DeductTrainTimesJob start-----"); try { RecordSet rs = new RecordSet(); //获取当前年月日 String nowDay = DateUtil.format(new Date(),"yyyy-MM-dd"); String firstDayOfMonth = DateUtil.format(DateUtil.beginOfMonth(new Date()),"yyyy-MM-dd"); //获取培训数据 Map trainInfo = new HashMap<>(); List< Map> trainInfos = new ArrayList<>(); String acqTrainInfoSql = "select a.pxsj, a.kssj1, a.jssj1, b.xm, b.id " + " from uf_pxjl a " + " left join uf_pxjl_dt1 b " + " on b.mainid = a.id " + " where (b.isdeduct is null or b.isdeduct = 0) and b.xm is not null " + " and a.pxsj is not null and a.kssj1 is not null and a.jssj1 is not null " + " and a.pxsj >='" + firstDayOfMonth + "' and a.pxsj <='" + nowDay + "' "; bb.writeLog("acqTrainInfoSql: " + acqTrainInfoSql); rs.executeQuery(acqTrainInfoSql); while ( rs.next()) { String pxsj = Util.null2String(rs.getString("pxsj")); String kssj = Util.null2String(rs.getString("kssj1")); String jssj = Util.null2String(rs.getString("jssj1")); String xm = Util.null2String(rs.getString("xm")); String detailId = Util.null2String(rs.getString("id")); trainInfo.put("detailId",detailId); trainInfo.put("pxsj",pxsj); trainInfo.put("kssj",kssj); trainInfo.put("jssj",jssj); trainInfo.put("xm",xm); trainInfos.add(trainInfo); } if ( trainInfos.size() > 0) { List deduIdList = new ArrayList<>();//记录满足减去培训时长的加班数据 Map< String, Object > deduTiaoxiuMap = new HashMap<>();//记录调休扣减的数据 Map< String, Integer > overtimeTiaoxiuMap = new HashMap<>();//记录加班和调休id List< List > deduOvertimeList = new ArrayList<>();//批量修改加班时长的数据 for ( Map train: trainInfos) { String detailId = Util.null2String(train.get("detailId")); String pxsj = Util.null2String(train.get("pxsj")); String kssj = Util.null2String(train.get("kssj")); String jssj = Util.null2String(train.get("jssj")); String xm = Util.null2String(train.get("xm")); String acqOverTimeSql = "select id, duration_min, tiaoxiuid from kq_flow_overtime where resourceid = ? and belongdate = ? " + "and fromtimedb <='" + kssj + "' and totimedb >='" + jssj + "' "; rs.executeQuery(acqOverTimeSql, xm, pxsj); while ( rs.next()) { Integer id = Util.getIntValue(Util.null2String(rs.getString("id"))); Integer durationMin = Util.getIntValue(Util.null2String(rs.getString("duration_min"))); String tiaoxiuid = Util.null2String(rs.getString("tiaoxiuid")); //加班时长减去培训时长 long minutesDifference = 0; if ( durationMin> 0 ) { List deduId = new ArrayList(); deduId.add(detailId); deduIdList.add(deduId); LocalTime timeStart = LocalTime.parse(pxsj +" " + kssj); LocalTime timeEnd = LocalTime.parse(pxsj +" " + jssj); minutesDifference = ChronoUnit.MINUTES.between(timeStart, timeEnd); durationMin = durationMin - ((int) minutesDifference); if ( durationMin < 0) { durationMin = 0; } } List deduOvertime = new ArrayList<>(); deduOvertime.add(durationMin); deduOvertime.add(id); deduOvertimeList.add(deduOvertime); //记录调休id if (StringUtils.isNotBlank(tiaoxiuid)) { deduTiaoxiuMap.put(tiaoxiuid,minutesDifference); //记录加班和调休id overtimeTiaoxiuMap.put(tiaoxiuid,id); } } } //先扣除掉加班的时长 String subOverTimeSql = "update kq_flow_overtime set duration_min = ? where id = ?"; boolean subOverTimeSqlFlag = rs.executeBatchSql(subOverTimeSql, deduOvertimeList); bb.writeLog("subOverTimeSqlFlag: " + subOverTimeSqlFlag); //再回写培训台账 String syncTrainSql = "update uf_pxjl set isdeduct = 1 where id = ? "; boolean syncTrainSqlFlag = rs.executeBatchSql(syncTrainSql, deduIdList); bb.writeLog("syncTrainSqlFlag: " + syncTrainSqlFlag); //处理调休时长 String tiaoxiuLeaveId = Util.null2String(bb.getPropValue("project_sskj","tiaoxiuleaveid")); String casualLeaveId = Util.null2String(bb.getPropValue("project_sskj","casualleaveid")); if (StringUtils.isNotBlank(tiaoxiuLeaveId) && StringUtils.isNotBlank(casualLeaveId) ) { String overtimeSubTrainModeId = bb.getPropValue("project_sskj", "overtimeSubTrainModeId"); Integer modedatacreater = 1; Integer modedatacreatertype = 0; String modedatacreatedate = DateUtil.format(new Date(), "yyyy-MM-dd"); String modedatacreatetime = DateUtil.format(new Date(), "HH:mm:ss"); //获取在职员工的信息 Map> resInfos = new HashMap<>(); String acqResSql = "select id, subcompanyid1, departmentid, jobtitle from hrmresource where status in (0,1,2,3)"; rs.executeQuery(acqResSql); while ( rs.next()) { String id = Util.null2String(rs.getString("id")); String subcompanyid = Util.null2String(rs.getString("subcompanyid1")); String departmentid = Util.null2String(rs.getString("departmentid")); String jobtitle = Util.null2String(rs.getString("jobtitle")); List infos = new ArrayList<>(); infos.add(subcompanyid); infos.add(departmentid); infos.add(jobtitle); resInfos.put(id, infos); } //获取事假最小请假单位 String minimumUnit = new KQLeaveRulesComInfo().getMinimumUnit(casualLeaveId); //调休时长扣减 List tiaoxiuSubList = new ArrayList<>(); //转事假 List casualLeaveList = new ArrayList<>(); //变动记录 List changeLogList = new ArrayList<>(); String leaveDetailIds = deduTiaoxiuMap.keySet().stream() .map(Object::toString) .collect(Collectors.joining(",")); String acqTiaoxiuSql = "select id, tiaoxiuamount, usedAmount, resourceId from kq_balanceofleave where id in (" + leaveDetailIds + ")"; rs.executeQuery(acqTiaoxiuSql); while ( rs.next()) { double tiaoxiuAmount = Util.getDoubleValue(Util.null2String(rs.getString("tiaoxiuamount"))); double usedAmount = Util.getDoubleValue(Util.null2String(rs.getString("usedAmount"))); int resourceId = Util.getIntValue(Util.null2String(rs.getString("resourceId"))); int id = Util.getIntValue(Util.null2String(rs.getString("id")));//调休表id double duration = Util.getDoubleValue(Util.null2String(deduTiaoxiuMap.get(id))); if ( (tiaoxiuAmount - usedAmount - duration) >=0 ) {//调休 List tiaoxiuSub = new ArrayList(); tiaoxiuSub.add(tiaoxiuAmount - duration); tiaoxiuSub.add(id); tiaoxiuSubList.add(tiaoxiuSub); List changeLog = new ArrayList(); changeLog.add(resourceId); Integer overtimeId = overtimeTiaoxiuMap.get(String.valueOf(id)); changeLog.add(overtimeId); changeLog.add(id); changeLog.add(duration); changeLog.add(tiaoxiuAmount); changeLog.add(tiaoxiuAmount - duration); changeLog.add(tiaoxiuLeaveId); changeLogList.add(changeLog); } else {//事假 List casualLeave = new ArrayList(); casualLeave.add(resourceId);//resourceid casualLeave.add(resourceId);//fromdate casualLeave.add(resourceId);//fromtime casualLeave.add(resourceId);//todate casualLeave.add(resourceId);//totime casualLeave.add(casualLeaveId);//newleavetype casualLeave.add(duration);//duration casualLeave.add(minimumUnit);//durationrule casualLeave.add(resourceId);//fromdatedb casualLeave.add(resourceId);//fromtimedb casualLeave.add(resourceId);//todatedb casualLeave.add(resourceId);//totimedb casualLeave.add(duration);//durationdb casualLeave.add(resourceId);//belongdate List infos = resInfos.get(resourceId); String subcompanyid = infos.get(0); String departmentid = infos.get(1); String jobtitle = infos.get(2); casualLeave.add(subcompanyid);//subcompanyid casualLeave.add(departmentid);//departmentid casualLeave.add(jobtitle);//jobtitle casualLeave.add(resourceId);//changetype casualLeaveList.add(casualLeave); List changeLog = new ArrayList(); changeLog.add(resourceId); Integer overtimeId = overtimeTiaoxiuMap.get(String.valueOf(id)); changeLog.add(overtimeId); changeLog.add("0"); changeLog.add(duration); changeLog.add("0.0000"); changeLog.add(duration); changeLog.add(casualLeaveId); changeLog.add(overtimeSubTrainModeId); changeLog.add(modedatacreater); changeLog.add(modedatacreatertype); changeLog.add(modedatacreatedate); changeLog.add(modedatacreatetime); String uuid = UUID.randomUUID().toString(); changeLog.add(uuid); changeLogList.add(changeLog); } } //调休扣减 String subTiaoxiuSql = "update kq_balanceofleave set tiaoxiuamount = ? where id = ?"; boolean subTiaoxiuSqlFlag = rs.executeBatchSql(subTiaoxiuSql, tiaoxiuSubList); bb.writeLog("subTiaoxiuSqlFlag: " + subTiaoxiuSqlFlag); //事假扣减 String addCasSql = "insert into kq_flow_split_leave " + " (resourceid, fromdate, fromtime, todate, totime, newleavetype, duration, durationrule, fromdatedb, fromtimedb, todatedb, totimedb," + " durationdb, belongdate, subcompanyid, departmentid, jobtitle, changetype )" + " values (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)"; boolean addCasSqlFlag = rs.executeBatchSql(addCasSql, casualLeaveList); bb.writeLog("addCasSqlFlag: " + addCasSqlFlag); //变动记录 String syncChangeSql = "insert into uf_overtimesubtrain " + " (resourceId, overtimedataId, tiaoxiudataId, subduration, beforeduration, afterduration, leavetype, " + " formmodeid, modedatacreater, modedatacreatertype, modedatacreatedate, modedatacreatetime, MODEUUID ) " + " values (?,?,?,?,?,?,?,?,?,?,?,?,?)"; bb.writeLog("syncChangeSql：" + syncChangeSql); boolean syncChangeSqlFlag = rs.executeBatchSql(syncChangeSql, changeLogList); bb.writeLog("addFlag：" + syncChangeSqlFlag); if (syncChangeSqlFlag) { for ( List changeLog: changeLogList) { String uuid = Util.null2String(changeLog.get(changeLog.size() - 1)); String billid = "-1"; String acqModeIdSql = "select id from uf_NoOutEmpNum where MODEUUID = ?"; rs.executeQuery(acqModeIdSql, uuid); while (rs.next()) { billid = Util.null2String(rs.getString("id")); } bb.writeLog("billid：" + billid); SskjUtil sskjUtil = new SskjUtil(); sskjUtil.modePerRecon(modedatacreater, overtimeSubTrainModeId, billid); } } } } } catch (Exception e) { e.printStackTrace(); bb.writeLog(e); bb.writeLog("DeductTrainTimesJob Exception: "+e); } } }