package cn.com.lzt.dingattendanceinfo.controller; import cn.com.lzt.attendancetemp.service.AttendanceTempTransactionalServiceI; import cn.com.lzt.dingattendanceinfo.entity.DingAttendanceinfoEntity; import cn.com.lzt.dingattendanceinfo.service.DingAttendanceinfoServiceI; import cn.com.lzt.dingattendanceinfo.service.dto.DingAttendanceinfoInDto; import cn.com.lzt.dingattendanceinfo.service.dto.DingAttendanceinfoOutDto; import cn.com.lzt.dingding.service.DingdingService; import cn.com.lzt.dingding.service.DingdingTransactionalService; import cn.com.lzt.leave.service.ModifyServiceI; import cn.com.lzt.personnelbasearchivesmanage.dto.DepartDto; import cn.com.lzt.personnelbasearchivesmanage.service.PersonnelBaseArchivesManageServiceI; import java.util.ArrayList; import java.util.Arrays; import java.util.Collections; import java.util.Date; import java.util.HashSet; import java.util.List; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import javax.servlet.http.HttpSession; import org.apache.log4j.Logger; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Controller; import org.springframework.ui.ModelMap; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.ResponseBody; import org.springframework.web.servlet.ModelAndView; import org.jeecgframework.core.common.controller.BaseController; import org.jeecgframework.core.common.exception.BusinessException; import org.jeecgframework.core.common.hibernate.qbc.CriteriaQuery; import org.jeecgframework.core.common.model.json.AjaxJson; import org.jeecgframework.core.common.model.json.DataGrid; import org.jeecgframework.core.constant.Globals; import org.jeecgframework.core.util.ContextHolderUtils; import org.jeecgframework.core.util.JeecgDataAutorUtils; import org.jeecgframework.core.util.StringUtil; import org.jeecgframework.tag.core.easyui.TagUtil; import org.jeecgframework.web.system.pojo.base.TSUser; import org.jeecgframework.web.system.service.SystemService; import org.jeecgframework.core.util.MyBeanUtils; import org.jeecgframework.minidao.pojo.MiniDaoPage; import org.jeecgframework.poi.excel.ExcelImportUtil; import org.jeecgframework.poi.excel.entity.ExportParams; import org.jeecgframework.poi.excel.entity.ImportParams; import org.jeecgframework.poi.excel.entity.vo.NormalExcelConstants; import org.jeecgframework.core.util.ResourceUtil; import java.io.IOException; import org.springframework.web.bind.annotation.RequestMethod; import org.springframework.web.multipart.MultipartFile; import org.springframework.web.multipart.MultipartHttpServletRequest; import java.util.Map; import org.jeecgframework.core.util.ExceptionUtil; import org.springframework.http.ResponseEntity; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.ResponseStatus; import org.springframework.http.HttpHeaders; import org.springframework.http.HttpStatus; import org.jeecgframework.core.beanvalidator.BeanValidators; import java.util.Set; import java.util.regex.Matcher; import java.util.regex.Pattern; import javax.validation.ConstraintViolation; import javax.validation.Validator; import java.net.URI; import org.springframework.http.MediaType; import org.springframework.web.util.UriComponentsBuilder; /** * @Title: Controller * @Description: 钉钉考勤原始信息表 * @author onlineGenerator * @date 2017-11-06 10:44:33 * @version V1.0 * */ @Controller @RequestMapping("/dingAttendanceinfoController") public class DingAttendanceinfoController extends BaseController { /** * Logger for this class */ private static final Logger logger = Logger.getLogger(DingAttendanceinfoController.class); @Autowired private DingAttendanceinfoServiceI dingAttendanceinfoService; @Autowired private SystemService systemService; @Autowired private Validator validator; @Autowired private DingdingService dingdingService; @Autowired private DingdingTransactionalService dingdingTransactionalService; @Autowired private PersonnelBaseArchivesManageServiceI personnelBaseArchivesManageService; @Autowired private AttendanceTempTransactionalServiceI attendanceTempTransactionalService; @Autowired private ModifyServiceI modifyService; /** * 钉钉考勤原始信息表列表 页面跳转 * * @return */ @RequestMapping(params = "list") public ModelAndView list(HttpServletRequest request) { return new ModelAndView("cn/com/lzt/dingattendanceinfo/dingAttendanceinfoList"); } /** * easyui AJAX请求数据 * * @param request * @param response * @param dataGrid * @param user */ @RequestMapping(params = "datagrid") public void datagrid(DingAttendanceinfoInDto inDto,HttpServletRequest request, HttpServletResponse response, DataGrid dataGrid) { /** CriteriaQuery cq = new CriteriaQuery(DingAttendanceinfoEntity.class, dataGrid); //查询条件组装器 org.jeecgframework.core.extend.hqlsearch.HqlGenerateUtil.installHql(cq, dingAttendanceinfo, request.getParameterMap()); try{ if(StringUtil.isNotEmpty(attendanceStime)) { cq.ge("attendanceTime", attendanceStime); } if(StringUtil.isNotEmpty(attendanceEtime)) { cq.le("attendanceTime", attendanceEtime); } HttpSession session = ContextHolderUtils.getSession(); TSUser tuser = (TSUser)session.getAttribute("LOCAL_CLINET_USER"); String departIds = tuser.getDepartid(); if (StringUtil.isNotEmpty(orgIds)) { departIds = orgIds; } // 页面的单位ID List departIdByPageList = Arrays.asList(departIds.split(",")); // 用于检索的单位ID List departIdBySearchList = new ArrayList(); for(String str : departIdByPageList) { if(StringUtil.isNotEmpty(str)) { departIdBySearchList.add(str); List departDtoList = personnelBaseArchivesManageService.getAllChildrenList(str, null, null); for(DepartDto departDto : departDtoList) { departIdBySearchList.add(departDto.getId()); } } } // List去重复 HashSet h = new HashSet(departIdBySearchList); departIdBySearchList.clear(); departIdBySearchList.addAll(h); cq.in("belongUnitid", departIdBySearchList.toArray()); if(StringUtil.isNotEmpty(userName)) { cq.like("realname", "%" + userName + "%"); } }catch (Exception e) { throw new BusinessException(e.getMessage()); } Map orderMap = new HashMap(); orderMap.put("userId", "asc"); cq.setOrder(orderMap); cq.add(); this.dingAttendanceinfoService.getDataGridReturn(cq, true); List dataResults = dataGrid.getResults(); //for(String :dataResults) TagUtil.datagrid(response, dataGrid); */ // HttpSession session = ContextHolderUtils.getSession(); // TSUser tuser = (TSUser)session.getAttribute("LOCAL_CLINET_USER"); // String departIds = tuser.getDepartid(); String departIds = ""; if (null != inDto.getOrgIds() && StringUtil.isNotEmpty(inDto.getOrgIds())) { departIds = inDto.getOrgIds(); } // 页面的单位ID List departIdByPageList = Arrays.asList(departIds.split(",")); // 用于检索的单位ID List departIdBySearchList = new ArrayList(); for(String str : departIdByPageList) { if(StringUtil.isNotEmpty(str)) { departIdBySearchList.add(str); List departDtoList = personnelBaseArchivesManageService.getAllChildrenList(str, null, null); for(DepartDto departDto : departDtoList) { departIdBySearchList.add(departDto.getId()); } } } // List去重复 HashSet h = new HashSet(departIdBySearchList); departIdBySearchList.clear(); departIdBySearchList.addAll(h); // 重新封装检索用的单位字符串 departIds = ""; for(String str : departIdBySearchList) { departIds += "'" + str + "',"; } if(StringUtil.isNotEmpty(departIds)) { departIds = departIds.substring(0,departIds.length() - 1); } inDto.setOrgIds(departIds); // 获取请求对应的数据权限 String authSql = JeecgDataAutorUtils.loadDataSearchConditonSQLString(); // 從SESSION中獲取用戶信息 String sortorder = ""; String sort = dataGrid.getSort(); // 排序对象 String order = dataGrid.getOrder(); // 排序方式 if (StringUtil.isEmpty(sort)) { sortorder = " attendance_date desc, belong_unitid asc,user_code asc, attendance_time asc"; //默认userid排序 } else { sortorder = humpToLine(sort) + " " + order; // 处理下划线，拼接排序 } if(StringUtil.isNotEmpty(inDto.getAttendanceEtime())) { String attendanceEtime = inDto.getAttendanceEtime(); inDto.setAttendanceEtime(attendanceEtime + " 23:59:59"); } // MiniDao检索 MiniDaoPage list = dingAttendanceinfoService.getDingAttendanceInfoList(inDto, dataGrid.getPage(), dataGrid.getRows(), authSql, sortorder); // 处理出勤时间 for(int i = 0; i < list.getResults().size(); i++) { String attendanceTimeStringOldString = list.getResults().get(i).getAttendanceTimeString(); List attendanceTimeStringOldList = Arrays.asList(attendanceTimeStringOldString.split(",")); Collections.sort(attendanceTimeStringOldList); String attendanceTimeStringNewString = ""; for(String temp : attendanceTimeStringOldList) { attendanceTimeStringNewString += temp.substring(11, 16) + "
"; } attendanceTimeStringNewString = attendanceTimeStringNewString.substring(0, attendanceTimeStringNewString.length() - 5); list.getResults().get(i).setAttendanceTimeString(attendanceTimeStringNewString); // 处理所属单位 String orgId = list.getResults().get(i).getBelongUnitid(); orgId = modifyService.getByorgId(orgId); list.getResults().get(i).setBelongUnitid(orgId); } dataGrid.setTotal(list.getTotal()); dataGrid.setResults(list.getResults()); TagUtil.datagrid(response, dataGrid); } /** * 手动同步 * * @param request * @param response * @param dataGrid * @param user */ @RequestMapping(params = "signRecordSynchronization") @ResponseBody public AjaxJson signRecordSynchronization(String attendanceStime, String attendanceEtime, HttpServletRequest request){ String message = null; AjaxJson j = new AjaxJson(); message = "钉钉考勤原始信息同步成功"; j.setSuccess(true); boolean flg = dingdingTransactionalService.signRecordSynchronization(attendanceStime,attendanceEtime); if(!flg) { message = "钉钉考勤原始信息同步失败"; j.setSuccess(false); } // attendanceTempTransactionalService.attendanceTempInit(new Date(((new Date()).getTime() - 1000*60*60*24))); // attendanceTempTransactionalService.attendanceTempInit(new Date()); // attendanceTempTransactionalService.attendanceTempInit(new Date(((new Date()).getTime() + 1000*60*60*24))); // attendanceTempTransactionalService.attendanceTempSynchronization(); j.setMsg(message); return j; } /** * 驼峰转下划线 * * @param str需要转换的字符串 * @return */ private String humpToLine(String str) { Pattern humpPattern = Pattern.compile("[A-Z]"); Matcher matcher = humpPattern.matcher(str); StringBuffer sb = new StringBuffer(); while (matcher.find()) { matcher.appendReplacement(sb, "_" + matcher.group(0).toLowerCase()); } matcher.appendTail(sb); return sb.toString(); } /** * 删除钉钉考勤原始信息表 * * @return */ @RequestMapping(params = "doDel") @ResponseBody public AjaxJson doDel(DingAttendanceinfoEntity dingAttendanceinfo, HttpServletRequest request) { String message = null; AjaxJson j = new AjaxJson(); dingAttendanceinfo = systemService.getEntity(DingAttendanceinfoEntity.class, dingAttendanceinfo.getId()); message = "钉钉考勤原始信息表删除成功"; try{ dingAttendanceinfoService.delete(dingAttendanceinfo); systemService.addLog(message, Globals.Log_Type_DEL, Globals.Log_Leavel_INFO); }catch(Exception e){ e.printStackTrace(); message = "钉钉考勤原始信息表删除失败"; throw new BusinessException(e.getMessage()); } j.setMsg(message); return j; } /** * 批量删除钉钉考勤原始信息表 * * @return */ @RequestMapping(params = "doBatchDel") @ResponseBody public AjaxJson doBatchDel(String ids,HttpServletRequest request){ String message = null; AjaxJson j = new AjaxJson(); message = "钉钉考勤原始信息表删除成功"; try{ for(String id:ids.split(",")){ DingAttendanceinfoEntity dingAttendanceinfo = systemService.getEntity(DingAttendanceinfoEntity.class, id ); dingAttendanceinfoService.delete(dingAttendanceinfo); systemService.addLog(message, Globals.Log_Type_DEL, Globals.Log_Leavel_INFO); } }catch(Exception e){ e.printStackTrace(); message = "钉钉考勤原始信息表删除失败"; throw new BusinessException(e.getMessage()); } j.setMsg(message); return j; } /** * 添加钉钉考勤原始信息表 * * @param ids * @return */ @RequestMapping(params = "doAdd") @ResponseBody public AjaxJson doAdd(DingAttendanceinfoEntity dingAttendanceinfo, HttpServletRequest request) { String message = null; AjaxJson j = new AjaxJson(); message = "钉钉考勤原始信息表添加成功"; try{ dingAttendanceinfoService.save(dingAttendanceinfo); systemService.addLog(message, Globals.Log_Type_INSERT, Globals.Log_Leavel_INFO); }catch(Exception e){ e.printStackTrace(); message = "钉钉考勤原始信息表添加失败"; throw new BusinessException(e.getMessage()); } j.setMsg(message); return j; } /** * 更新钉钉考勤原始信息表 * * @param ids * @return */ @RequestMapping(params = "doUpdate") @ResponseBody public AjaxJson doUpdate(DingAttendanceinfoEntity dingAttendanceinfo, HttpServletRequest request) { String message = null; AjaxJson j = new AjaxJson(); message = "钉钉考勤原始信息表更新成功"; DingAttendanceinfoEntity t = dingAttendanceinfoService.get(DingAttendanceinfoEntity.class, dingAttendanceinfo.getId()); try { MyBeanUtils.copyBeanNotNull2Bean(dingAttendanceinfo, t); dingAttendanceinfoService.saveOrUpdate(t); systemService.addLog(message, Globals.Log_Type_UPDATE, Globals.Log_Leavel_INFO); } catch (Exception e) { e.printStackTrace(); message = "钉钉考勤原始信息表更新失败"; throw new BusinessException(e.getMessage()); } j.setMsg(message); return j; } /** * 钉钉考勤原始信息表新增页面跳转 * * @return */ @RequestMapping(params = "goAdd") public ModelAndView goAdd(DingAttendanceinfoEntity dingAttendanceinfo, HttpServletRequest req) { if (StringUtil.isNotEmpty(dingAttendanceinfo.getId())) { dingAttendanceinfo = dingAttendanceinfoService.getEntity(DingAttendanceinfoEntity.class, dingAttendanceinfo.getId()); req.setAttribute("dingAttendanceinfoPage", dingAttendanceinfo); } return new ModelAndView("cn/com/lzt/dingattendanceinfo/dingAttendanceinfo-add"); } /** * 钉钉考勤原始信息表编辑页面跳转 * * @return */ @RequestMapping(params = "goUpdate") public ModelAndView goUpdate(DingAttendanceinfoEntity dingAttendanceinfo, HttpServletRequest req) { if (StringUtil.isNotEmpty(dingAttendanceinfo.getId())) { dingAttendanceinfo = dingAttendanceinfoService.getEntity(DingAttendanceinfoEntity.class, dingAttendanceinfo.getId()); req.setAttribute("dingAttendanceinfoPage", dingAttendanceinfo); } return new ModelAndView("cn/com/lzt/dingattendanceinfo/dingAttendanceinfo-update"); } /** * 导入功能跳转 * * @return */ @RequestMapping(params = "upload") public ModelAndView upload(HttpServletRequest req) { req.setAttribute("controller_name","dingAttendanceinfoController"); return new ModelAndView("common/upload/pub_excel_upload"); } /** * 导出excel * * @param request * @param response */ @RequestMapping(params = "exportXls") public String exportXls(DingAttendanceinfoInDto inDto,HttpServletRequest request,HttpServletResponse response , DataGrid dataGrid,ModelMap modelMap) { String departIds = ""; if (null != inDto.getOrgIds() && StringUtil.isNotEmpty(inDto.getOrgIds())) { departIds = inDto.getOrgIds(); } // 页面的单位ID List departIdByPageList = Arrays.asList(departIds.split(",")); // 用于检索的单位ID List departIdBySearchList = new ArrayList(); for(String str : departIdByPageList) { if(StringUtil.isNotEmpty(str)) { departIdBySearchList.add(str); List departDtoList = personnelBaseArchivesManageService.getAllChildrenList(str, null, null); for(DepartDto departDto : departDtoList) { departIdBySearchList.add(departDto.getId()); } } } // List去重复 HashSet h = new HashSet(departIdBySearchList); departIdBySearchList.clear(); departIdBySearchList.addAll(h); // 重新封装检索用的单位字符串 departIds = ""; for(String str : departIdBySearchList) { departIds += "'" + str + "',"; } if(StringUtil.isNotEmpty(departIds)) { departIds = departIds.substring(0,departIds.length() - 1); } inDto.setOrgIds(departIds); // 获取请求对应的数据权限 String authSql = JeecgDataAutorUtils.loadDataSearchConditonSQLString(); // 從SESSION中獲取用戶信息 String sortorder = ""; String sort = dataGrid.getSort(); // 排序对象 String order = dataGrid.getOrder(); // 排序方式 if (StringUtil.isEmpty(sort)) { sortorder = " user_code asc, belong_unitid asc, attendance_date desc, attendance_time asc"; //默认userid排序 } else { sortorder = humpToLine(sort) + " " + order; // 处理下划线，拼接排序 } if(StringUtil.isNotEmpty(inDto.getAttendanceEtime())) { String attendanceEtime = inDto.getAttendanceEtime(); inDto.setAttendanceEtime(attendanceEtime + " 23:59:59"); } // MiniDao检索 MiniDaoPage list = dingAttendanceinfoService.getDingAttendanceInfoList(inDto, dataGrid.getPage(), dataGrid.getRows(), authSql, sortorder); List dingAttendanceinfos = list.getResults(); // 处理出勤时间 for(int i = 0; i < dingAttendanceinfos.size(); i++) { String attendanceTimeStringOldString = dingAttendanceinfos.get(i).getAttendanceTimeString(); List attendanceTimeStringOldList = Arrays.asList(attendanceTimeStringOldString.split(",")); Collections.sort(attendanceTimeStringOldList); String attendanceTimeStringNewString = ""; for(String temp : attendanceTimeStringOldList) { attendanceTimeStringNewString += temp.substring(11, 16) + ","; } attendanceTimeStringNewString = attendanceTimeStringNewString.substring(0, attendanceTimeStringNewString.length() - 1); dingAttendanceinfos.get(i).setAttendanceTimeString(attendanceTimeStringNewString); } modelMap.put(NormalExcelConstants.FILE_NAME,"钉钉考勤原始信息"); modelMap.put(NormalExcelConstants.CLASS,DingAttendanceinfoOutDto.class); modelMap.put(NormalExcelConstants.PARAMS,new ExportParams("钉钉考勤原始信息列表", "导出人:"+ResourceUtil.getSessionUser().getRealName(), "钉钉考勤原始信息列表")); modelMap.put(NormalExcelConstants.DATA_LIST,dingAttendanceinfos); return NormalExcelConstants.JEECG_EXCEL_VIEW; } /** * 导出excel 使模板 * * @param request * @param response */ @RequestMapping(params = "exportXlsByT") public String exportXlsByT(DingAttendanceinfoEntity dingAttendanceinfo,HttpServletRequest request,HttpServletResponse response , DataGrid dataGrid,ModelMap modelMap) { modelMap.put(NormalExcelConstants.FILE_NAME,"钉钉考勤原始信息表"); modelMap.put(NormalExcelConstants.CLASS,DingAttendanceinfoEntity.class); modelMap.put(NormalExcelConstants.PARAMS,new ExportParams("钉钉考勤原始信息表列表", "导出人:"+ResourceUtil.getSessionUser().getRealName(), "导出信息")); modelMap.put(NormalExcelConstants.DATA_LIST,new ArrayList()); return NormalExcelConstants.JEECG_EXCEL_VIEW; } @SuppressWarnings("unchecked") @RequestMapping(params = "importExcel", method = RequestMethod.POST) @ResponseBody public AjaxJson importExcel(HttpServletRequest request, HttpServletResponse response) { AjaxJson j = new AjaxJson(); MultipartHttpServletRequest multipartRequest = (MultipartHttpServletRequest) request; Map fileMap = multipartRequest.getFileMap(); for (Map.Entry entity : fileMap.entrySet()) { MultipartFile file = entity.getValue();// 获取上传文件对象 ImportParams params = new ImportParams(); params.setTitleRows(2); params.setHeadRows(1); params.setNeedSave(true); try { List listDingAttendanceinfoEntitys = ExcelImportUtil.importExcel(file.getInputStream(),DingAttendanceinfoEntity.class,params); for (DingAttendanceinfoEntity dingAttendanceinfo : listDingAttendanceinfoEntitys) { dingAttendanceinfoService.save(dingAttendanceinfo); } j.setMsg("文件导入成功！"); } catch (Exception e) { j.setMsg("文件导入失败！"); logger.error(ExceptionUtil.getExceptionMessage(e)); }finally{ try { file.getInputStream().close(); } catch (IOException e) { e.printStackTrace(); } } } return j; } @RequestMapping(method = RequestMethod.GET) @ResponseBody public List list() { List listDingAttendanceinfos=dingAttendanceinfoService.getList(DingAttendanceinfoEntity.class); return listDingAttendanceinfos; } @RequestMapping(value = "/{id}", method = RequestMethod.GET) @ResponseBody public ResponseEntity get(@PathVariable("id") String id) { DingAttendanceinfoEntity task = dingAttendanceinfoService.get(DingAttendanceinfoEntity.class, id); if (task == null) { return new ResponseEntity(HttpStatus.NOT_FOUND); } return new ResponseEntity(task, HttpStatus.OK); } @RequestMapping(method = RequestMethod.POST, consumes = MediaType.APPLICATION_JSON_VALUE) @ResponseBody public ResponseEntity create(@RequestBody DingAttendanceinfoEntity dingAttendanceinfo, UriComponentsBuilder uriBuilder) { //调用JSR303 Bean Validator进行校验，如果出错返回含400错误码及json格式的错误信息. Set> failures = validator.validate(dingAttendanceinfo); if (!failures.isEmpty()) { return new ResponseEntity(BeanValidators.extractPropertyAndMessage(failures), HttpStatus.BAD_REQUEST); } //保存 try{ dingAttendanceinfoService.save(dingAttendanceinfo); } catch (Exception e) { e.printStackTrace(); return new ResponseEntity(HttpStatus.NO_CONTENT); } //按照Restful风格约定，创建指向新任务的url, 也可以直接返回id或对象. String id = dingAttendanceinfo.getId(); URI uri = uriBuilder.path("/rest/dingAttendanceinfoController/" + id).build().toUri(); HttpHeaders headers = new HttpHeaders(); headers.setLocation(uri); return new ResponseEntity(headers, HttpStatus.CREATED); } @RequestMapping(value = "/{id}", method = RequestMethod.PUT, consumes = MediaType.APPLICATION_JSON_VALUE) public ResponseEntity update(@RequestBody DingAttendanceinfoEntity dingAttendanceinfo) { //调用JSR303 Bean Validator进行校验，如果出错返回含400错误码及json格式的错误信息. Set> failures = validator.validate(dingAttendanceinfo); if (!failures.isEmpty()) { return new ResponseEntity(BeanValidators.extractPropertyAndMessage(failures), HttpStatus.BAD_REQUEST); } //保存 try{ dingAttendanceinfoService.saveOrUpdate(dingAttendanceinfo); } catch (Exception e) { e.printStackTrace(); return new ResponseEntity(HttpStatus.NO_CONTENT); } //按Restful约定，返回204状态码, 无内容. 也可以返回200状态码. return new ResponseEntity(HttpStatus.NO_CONTENT); } @RequestMapping(value = "/{id}", method = RequestMethod.DELETE) @ResponseStatus(HttpStatus.NO_CONTENT) public void delete(@PathVariable("id") String id) { dingAttendanceinfoService.deleteEntityById(DingAttendanceinfoEntity.class, id); } }