package com.engine.attendance.attendanceanalysis.web; import com.engine.attendance.attendanceanalysis.service.UtilService; import com.engine.attendance.attendanceanalysis.service.impl.UtilServiceImpl; import com.engine.attendance.attendanceanalysis.wrapper.AttendanceAnalysisWrapper; import com.engine.attendance.attendanceplan.service.AttendancePlanService; import com.engine.attendance.attendanceplan.service.impl.AttendancePlanServiceImpl; import com.engine.common.util.*; import com.google.common.collect.Lists; import com.google.common.collect.Maps; import lombok.extern.slf4j.Slf4j; import weaver.general.Util; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import javax.ws.rs.POST; import javax.ws.rs.Path; import javax.ws.rs.Produces; import javax.ws.rs.core.Context; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.stream.Collectors; @Slf4j public class AttendanceanalysisAction { private AttendancePlanService basicsetService = ServiceUtil.getService(AttendancePlanServiceImpl.class); private UtilService utilService = ServiceUtil.getService(UtilServiceImpl.class); private AttendanceAnalysisWrapper attendanceAnalysisService = ServiceUtil.getService(AttendanceAnalysisWrapper.class); /** * 排班分析 * @return */ @POST @Path("/attendanceAnalysisByHrmAndDate") @Produces({"text/plain"}) public String getSchedulingData(@Context HttpServletRequest request, @Context HttpServletResponse response) { try { Map paramMap = ParamUtil.request2Map(request); String startDate = Util.null2String(paramMap.get("startDate")); String startBeforeDate = DateUtil.beforeDay(startDate,1); String endDate = Util.null2String(paramMap.get("endDate")); String endAfterDate = DateUtil.AfterDay(endDate,1); String userIds = Util.null2String(paramMap.get("userIds")); int betweenDays = DateUtil.getBetWeenDays(startDate,endDate); String sql = "select id,userid,signdate,signtime from hrmschedulesign where isincom=1 and userid in ("+userIds+") and signdate >= ? and signdate <= ?"; List> dataList = DbTools.getSqlToList(sql,startBeforeDate,endAfterDate); Map>> collect = dataList.stream().collect(Collectors.groupingBy(e -> Util.null2String(e.get("userid")))); for (String userId : userIds.split(",")){ /**获得人员考勤项目*/ Map param = Maps.newHashMap(); param.put("startDate",""); param.put("endDate",""); param.put("resourceId",userId); Map dataMap = basicsetService.getAttendanceItemsByPerson(param); List> attendanceItems = (List>)dataMap.get("data"); /** 获取人员班次*/ Map classesParamMap = Maps.newHashMap(); classesParamMap.put("tableName","uf_pbjg"); classesParamMap.put("startDate",startBeforeDate); classesParamMap.put("endDate",endAfterDate); classesParamMap.put("pblx","0"); classesParamMap.put("pbdx",userId); classesParamMap.put("current","1"); classesParamMap.put("pageSize",10); classesParamMap.put("recurrence",1); classesParamMap.put("attendanceItems",attendanceItems); Map schedulMap = utilService.getSchedulingInFormation(classesParamMap); for (int i=0; i<=betweenDays;i++){ String date = DateUtil.AfterDay(startDate,i); attendanceAnalysisService.attendanceAnalysisForApi(userId,date,collect.get(userId),attendanceItems,schedulMap); } } return null; }catch (Exception e){ log.error("execute fail,catch error: [{}]",e); return ApiReturnTools.error("500","saveApplicableOrganization error"); } } /** * 获得分析数据 * @return */ @POST @Path("/getAnalysisDate") @Produces({"text/plain"}) public String getAnalysisDate(@Context HttpServletRequest request, @Context HttpServletResponse response) { try { Map paramMap = ParamUtil.request2Map(request); String startDate = Util.null2String(paramMap.get("startDate")); String endDate = Util.null2String(paramMap.get("endDate")); String userIds = Util.null2String(paramMap.get("userIds")); String sql = "select id,userid,signdate,signtime from hrmschedulesign where isincom=1 and userid in ("+userIds+") and signdate >= ? and signdate <= ? order by signdate,signtime"; List> dataList = DbTools.getSqlToList(sql,startDate,endDate); Map>> collect = dataList.stream().collect(Collectors.groupingBy(e -> Util.null2String(e.get("userid")))); //请假记录 sql = "select a.qjry,a.jqlx,a.cxjqj,b.ksrq,b.kssj,b.jsrq,b.jssj,b.qjsc,b.qtj,b.btj from uf_jcl_kq_qjjl a left join uf_jcl_kq_qjjl_dt1 b on a.id = b.mainid where a.qjry in ("+userIds+") and b.ksrq>=? and b.ksrq<=? and (b.cxqj=0 or b.cxqj is null) order by b.ksrq,b.kssj"; List> askforLeaveList = DbTools.getSqlToList(sql,startDate,endDate); Map>> askforLeavecollect = askforLeaveList.stream().collect(Collectors.groupingBy(e -> Util.null2String(e.get("qjry")))); //出差记录 sql = "select b.ccr,a.cclx,a.ccsd,b.ksrq,b.jsrq,b.kssj,b.jssj,b.ccsc,b.qtcc,b.btcc,b.cxcc from uf_jcl_kq_ccjl a left join uf_jcl_kq_ccjl_dt1 b on a.id = b.mainid where b.ccr in ("+userIds+") and b.ksrq>=? and b.ksrq<=? and (b.cxcc=0 or b.cxcc is null) order by b.ksrq,b.kssj"; List> evectionList = DbTools.getSqlToList(sql,startDate,endDate); Map>> evectioncollect = evectionList.stream().collect(Collectors.groupingBy(e -> Util.null2String(e.get("ccr")))); //加班计划 sql = "select b.jbry,b.ksrq,b.kssj,a.jblx,b.jsrq,b.jssj,b.jbsc from uf_jcl_kq_jbjh a left join uf_jcl_kq_jbjh_dt1 b on a.id=b.mainid where b.jbry in ("+userIds+") and b.ksrq>=? and b.ksrq<=? and (b.jbcx=0 or b.jbcx is null) order by b.ksrq,b.kssj"; List> overPlanDataList = DbTools.getSqlToList(sql,startDate,endDate); Map>> overPlancollect = overPlanDataList.stream().collect(Collectors.groupingBy(e -> Util.null2String(e.get("jbry")))); //加班结果 sql = "select szjg,jbry,sjksrq,jbjgly,sjjsrq,sjkssj,sjjssj,sjjbsc,jblx,zt from uf_jcl_kq_jbjg where jbry in ("+userIds+") and sjksrq>=? and sjjsrq<=? order by sjksrq,sjkssj"; List> overPlanResultList = DbTools.getSqlToList(sql,startDate,endDate); Map>> overResultcollect = overPlanResultList.stream().collect(Collectors.groupingBy(e -> Util.null2String(e.get("jbry")))); List> resultList = Lists.newArrayList(); for (String userId : userIds.split(",")){ Map map = Maps.newHashMap(); Map>> map1 = Maps.newHashMap(); map1.put("signDate",collect.get(userId)); map1.put("askforLeave",askforLeavecollect.get(userId)); map1.put("evection",evectioncollect.get(userId)); map1.put("overPlan",overPlancollect.get(userId)); map1.put("overResult",overResultcollect.get(userId)); map.put("userId",userId); map.put("data",map1); resultList.add(map); } return ApiReturnTools.success(resultList); }catch (Exception e){ log.error("execute fail,catch error: [{}]",e); return ApiReturnTools.error("500","saveApplicableOrganization error"); } } }