DingAttendanceinfoController.java 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661
  1. package cn.com.lzt.dingattendanceinfo.controller;
  2. import cn.com.lzt.attendancetemp.service.AttendanceTempTransactionalServiceI;
  3. import cn.com.lzt.dingattendanceinfo.entity.DingAttendanceinfoEntity;
  4. import cn.com.lzt.dingattendanceinfo.service.DingAttendanceinfoServiceI;
  5. import cn.com.lzt.dingattendanceinfo.service.dto.DingAttendanceinfoInDto;
  6. import cn.com.lzt.dingattendanceinfo.service.dto.DingAttendanceinfoOutDto;
  7. import cn.com.lzt.dingding.service.DingdingService;
  8. import cn.com.lzt.dingding.service.DingdingTransactionalService;
  9. import cn.com.lzt.leave.service.ModifyServiceI;
  10. import cn.com.lzt.personnelbasearchivesmanage.dto.DepartDto;
  11. import cn.com.lzt.personnelbasearchivesmanage.service.PersonnelBaseArchivesManageServiceI;
  12. import java.util.ArrayList;
  13. import java.util.Arrays;
  14. import java.util.Collections;
  15. import java.util.Date;
  16. import java.util.HashSet;
  17. import java.util.List;
  18. import javax.servlet.http.HttpServletRequest;
  19. import javax.servlet.http.HttpServletResponse;
  20. import javax.servlet.http.HttpSession;
  21. import org.apache.log4j.Logger;
  22. import org.springframework.beans.factory.annotation.Autowired;
  23. import org.springframework.stereotype.Controller;
  24. import org.springframework.ui.ModelMap;
  25. import org.springframework.web.bind.annotation.RequestMapping;
  26. import org.springframework.web.bind.annotation.ResponseBody;
  27. import org.springframework.web.servlet.ModelAndView;
  28. import org.jeecgframework.core.common.controller.BaseController;
  29. import org.jeecgframework.core.common.exception.BusinessException;
  30. import org.jeecgframework.core.common.hibernate.qbc.CriteriaQuery;
  31. import org.jeecgframework.core.common.model.json.AjaxJson;
  32. import org.jeecgframework.core.common.model.json.DataGrid;
  33. import org.jeecgframework.core.constant.Globals;
  34. import org.jeecgframework.core.util.ContextHolderUtils;
  35. import org.jeecgframework.core.util.JeecgDataAutorUtils;
  36. import org.jeecgframework.core.util.StringUtil;
  37. import org.jeecgframework.tag.core.easyui.TagUtil;
  38. import org.jeecgframework.web.system.pojo.base.TSUser;
  39. import org.jeecgframework.web.system.service.SystemService;
  40. import org.jeecgframework.core.util.MyBeanUtils;
  41. import org.jeecgframework.minidao.pojo.MiniDaoPage;
  42. import org.jeecgframework.poi.excel.ExcelImportUtil;
  43. import org.jeecgframework.poi.excel.entity.ExportParams;
  44. import org.jeecgframework.poi.excel.entity.ImportParams;
  45. import org.jeecgframework.poi.excel.entity.vo.NormalExcelConstants;
  46. import org.jeecgframework.core.util.ResourceUtil;
  47. import java.io.IOException;
  48. import org.springframework.web.bind.annotation.RequestMethod;
  49. import org.springframework.web.multipart.MultipartFile;
  50. import org.springframework.web.multipart.MultipartHttpServletRequest;
  51. import java.util.Map;
  52. import org.jeecgframework.core.util.ExceptionUtil;
  53. import org.springframework.http.ResponseEntity;
  54. import org.springframework.web.bind.annotation.PathVariable;
  55. import org.springframework.web.bind.annotation.RequestBody;
  56. import org.springframework.web.bind.annotation.ResponseStatus;
  57. import org.springframework.http.HttpHeaders;
  58. import org.springframework.http.HttpStatus;
  59. import org.jeecgframework.core.beanvalidator.BeanValidators;
  60. import java.util.Set;
  61. import java.util.regex.Matcher;
  62. import java.util.regex.Pattern;
  63. import javax.validation.ConstraintViolation;
  64. import javax.validation.Validator;
  65. import java.net.URI;
  66. import org.springframework.http.MediaType;
  67. import org.springframework.web.util.UriComponentsBuilder;
  68. /**
  69. * @Title: Controller
  70. * @Description: 钉钉考勤原始信息表
  71. * @author onlineGenerator
  72. * @date 2017-11-06 10:44:33
  73. * @version V1.0
  74. *
  75. */
  76. @Controller
  77. @RequestMapping("/dingAttendanceinfoController")
  78. public class DingAttendanceinfoController extends BaseController {
  79. /**
  80. * Logger for this class
  81. */
  82. private static final Logger logger = Logger.getLogger(DingAttendanceinfoController.class);
  83. @Autowired
  84. private DingAttendanceinfoServiceI dingAttendanceinfoService;
  85. @Autowired
  86. private SystemService systemService;
  87. @Autowired
  88. private Validator validator;
  89. @Autowired
  90. private DingdingService dingdingService;
  91. @Autowired
  92. private DingdingTransactionalService dingdingTransactionalService;
  93. @Autowired
  94. private PersonnelBaseArchivesManageServiceI personnelBaseArchivesManageService;
  95. @Autowired
  96. private AttendanceTempTransactionalServiceI attendanceTempTransactionalService;
  97. @Autowired
  98. private ModifyServiceI modifyService;
  99. /**
  100. * 钉钉考勤原始信息表列表 页面跳转
  101. *
  102. * @return
  103. */
  104. @RequestMapping(params = "list")
  105. public ModelAndView list(HttpServletRequest request) {
  106. return new ModelAndView("cn/com/lzt/dingattendanceinfo/dingAttendanceinfoList");
  107. }
  108. /**
  109. * easyui AJAX请求数据
  110. *
  111. * @param request
  112. * @param response
  113. * @param dataGrid
  114. * @param user
  115. */
  116. @RequestMapping(params = "datagrid")
  117. public void datagrid(DingAttendanceinfoInDto inDto,HttpServletRequest request, HttpServletResponse response, DataGrid dataGrid) {
  118. /**
  119. CriteriaQuery cq = new CriteriaQuery(DingAttendanceinfoEntity.class, dataGrid);
  120. //查询条件组装器
  121. org.jeecgframework.core.extend.hqlsearch.HqlGenerateUtil.installHql(cq, dingAttendanceinfo, request.getParameterMap());
  122. try{
  123. if(StringUtil.isNotEmpty(attendanceStime)) {
  124. cq.ge("attendanceTime", attendanceStime);
  125. }
  126. if(StringUtil.isNotEmpty(attendanceEtime)) {
  127. cq.le("attendanceTime", attendanceEtime);
  128. }
  129. HttpSession session = ContextHolderUtils.getSession();
  130. TSUser tuser = (TSUser)session.getAttribute("LOCAL_CLINET_USER");
  131. String departIds = tuser.getDepartid();
  132. if (StringUtil.isNotEmpty(orgIds)) {
  133. departIds = orgIds;
  134. }
  135. // 页面的单位ID
  136. List<String> departIdByPageList = Arrays.asList(departIds.split(","));
  137. // 用于检索的单位ID
  138. List<String> departIdBySearchList = new ArrayList<String>();
  139. for(String str : departIdByPageList) {
  140. if(StringUtil.isNotEmpty(str)) {
  141. departIdBySearchList.add(str);
  142. List<DepartDto> departDtoList = personnelBaseArchivesManageService.getAllChildrenList(str, null, null);
  143. for(DepartDto departDto : departDtoList) {
  144. departIdBySearchList.add(departDto.getId());
  145. }
  146. }
  147. }
  148. // List去重复
  149. HashSet<String> h = new HashSet<String>(departIdBySearchList);
  150. departIdBySearchList.clear();
  151. departIdBySearchList.addAll(h);
  152. cq.in("belongUnitid", departIdBySearchList.toArray());
  153. if(StringUtil.isNotEmpty(userName)) {
  154. cq.like("realname", "%" + userName + "%");
  155. }
  156. }catch (Exception e) {
  157. throw new BusinessException(e.getMessage());
  158. }
  159. Map<String, Object> orderMap = new HashMap<String, Object>();
  160. orderMap.put("userId", "asc");
  161. cq.setOrder(orderMap);
  162. cq.add();
  163. this.dingAttendanceinfoService.getDataGridReturn(cq, true);
  164. List dataResults = dataGrid.getResults();
  165. //for(String :dataResults)
  166. TagUtil.datagrid(response, dataGrid);
  167. */
  168. // HttpSession session = ContextHolderUtils.getSession();
  169. // TSUser tuser = (TSUser)session.getAttribute("LOCAL_CLINET_USER");
  170. // String departIds = tuser.getDepartid();
  171. String departIds = "";
  172. if (null != inDto.getOrgIds() && StringUtil.isNotEmpty(inDto.getOrgIds())) {
  173. departIds = inDto.getOrgIds();
  174. }
  175. // 页面的单位ID
  176. List<String> departIdByPageList = Arrays.asList(departIds.split(","));
  177. // 用于检索的单位ID
  178. List<String> departIdBySearchList = new ArrayList<String>();
  179. for(String str : departIdByPageList) {
  180. if(StringUtil.isNotEmpty(str)) {
  181. departIdBySearchList.add(str);
  182. List<DepartDto> departDtoList = personnelBaseArchivesManageService.getAllChildrenList(str, null, null);
  183. for(DepartDto departDto : departDtoList) {
  184. departIdBySearchList.add(departDto.getId());
  185. }
  186. }
  187. }
  188. // List去重复
  189. HashSet<String> h = new HashSet<String>(departIdBySearchList);
  190. departIdBySearchList.clear();
  191. departIdBySearchList.addAll(h);
  192. // 重新封装检索用的单位字符串
  193. departIds = "";
  194. for(String str : departIdBySearchList) {
  195. departIds += "'" + str + "',";
  196. }
  197. if(StringUtil.isNotEmpty(departIds)) {
  198. departIds = departIds.substring(0,departIds.length() - 1);
  199. }
  200. inDto.setOrgIds(departIds);
  201. // 获取请求对应的数据权限
  202. String authSql = JeecgDataAutorUtils.loadDataSearchConditonSQLString();
  203. // 從SESSION中獲取用戶信息
  204. String sortorder = "";
  205. String sort = dataGrid.getSort(); // 排序对象
  206. String order = dataGrid.getOrder(); // 排序方式
  207. if (StringUtil.isEmpty(sort)) {
  208. sortorder = " attendance_date desc, belong_unitid asc,user_code asc, attendance_time asc"; //默认userid排序
  209. } else {
  210. sortorder = humpToLine(sort) + " " + order; // 处理下划线,拼接排序
  211. }
  212. if(StringUtil.isNotEmpty(inDto.getAttendanceEtime())) {
  213. String attendanceEtime = inDto.getAttendanceEtime();
  214. inDto.setAttendanceEtime(attendanceEtime + " 23:59:59");
  215. }
  216. // MiniDao检索
  217. MiniDaoPage<DingAttendanceinfoOutDto> list = dingAttendanceinfoService.getDingAttendanceInfoList(inDto, dataGrid.getPage(), dataGrid.getRows(), authSql, sortorder);
  218. // 处理出勤时间
  219. for(int i = 0; i < list.getResults().size(); i++) {
  220. String attendanceTimeStringOldString = list.getResults().get(i).getAttendanceTimeString();
  221. List<String> attendanceTimeStringOldList = Arrays.asList(attendanceTimeStringOldString.split(","));
  222. Collections.sort(attendanceTimeStringOldList);
  223. String attendanceTimeStringNewString = "";
  224. for(String temp : attendanceTimeStringOldList) {
  225. attendanceTimeStringNewString += temp.substring(11, 16) + "</br>";
  226. }
  227. attendanceTimeStringNewString = attendanceTimeStringNewString.substring(0, attendanceTimeStringNewString.length() - 5);
  228. list.getResults().get(i).setAttendanceTimeString(attendanceTimeStringNewString);
  229. // 处理所属单位
  230. String orgId = list.getResults().get(i).getBelongUnitid();
  231. orgId = modifyService.getByorgId(orgId);
  232. list.getResults().get(i).setBelongUnitid(orgId);
  233. }
  234. dataGrid.setTotal(list.getTotal());
  235. dataGrid.setResults(list.getResults());
  236. TagUtil.datagrid(response, dataGrid);
  237. }
  238. /**
  239. * 手动同步
  240. *
  241. * @param request
  242. * @param response
  243. * @param dataGrid
  244. * @param user
  245. */
  246. @RequestMapping(params = "signRecordSynchronization")
  247. @ResponseBody
  248. public AjaxJson signRecordSynchronization(String attendanceStime, String attendanceEtime, HttpServletRequest request){
  249. String message = null;
  250. AjaxJson j = new AjaxJson();
  251. message = "钉钉考勤原始信息同步成功";
  252. j.setSuccess(true);
  253. boolean flg = dingdingTransactionalService.signRecordSynchronization(attendanceStime,attendanceEtime);
  254. if(!flg) {
  255. message = "钉钉考勤原始信息同步失败";
  256. j.setSuccess(false);
  257. }
  258. // attendanceTempTransactionalService.attendanceTempInit(new Date(((new Date()).getTime() - 1000*60*60*24)));
  259. // attendanceTempTransactionalService.attendanceTempInit(new Date());
  260. // attendanceTempTransactionalService.attendanceTempInit(new Date(((new Date()).getTime() + 1000*60*60*24)));
  261. // attendanceTempTransactionalService.attendanceTempSynchronization();
  262. j.setMsg(message);
  263. return j;
  264. }
  265. /**
  266. * 驼峰转下划线
  267. *
  268. * @param str需要转换的字符串
  269. * @return
  270. */
  271. private String humpToLine(String str) {
  272. Pattern humpPattern = Pattern.compile("[A-Z]");
  273. Matcher matcher = humpPattern.matcher(str);
  274. StringBuffer sb = new StringBuffer();
  275. while (matcher.find()) {
  276. matcher.appendReplacement(sb, "_" + matcher.group(0).toLowerCase());
  277. }
  278. matcher.appendTail(sb);
  279. return sb.toString();
  280. }
  281. /**
  282. * 删除钉钉考勤原始信息表
  283. *
  284. * @return
  285. */
  286. @RequestMapping(params = "doDel")
  287. @ResponseBody
  288. public AjaxJson doDel(DingAttendanceinfoEntity dingAttendanceinfo, HttpServletRequest request) {
  289. String message = null;
  290. AjaxJson j = new AjaxJson();
  291. dingAttendanceinfo = systemService.getEntity(DingAttendanceinfoEntity.class, dingAttendanceinfo.getId());
  292. message = "钉钉考勤原始信息表删除成功";
  293. try{
  294. dingAttendanceinfoService.delete(dingAttendanceinfo);
  295. systemService.addLog(message, Globals.Log_Type_DEL, Globals.Log_Leavel_INFO);
  296. }catch(Exception e){
  297. e.printStackTrace();
  298. message = "钉钉考勤原始信息表删除失败";
  299. throw new BusinessException(e.getMessage());
  300. }
  301. j.setMsg(message);
  302. return j;
  303. }
  304. /**
  305. * 批量删除钉钉考勤原始信息表
  306. *
  307. * @return
  308. */
  309. @RequestMapping(params = "doBatchDel")
  310. @ResponseBody
  311. public AjaxJson doBatchDel(String ids,HttpServletRequest request){
  312. String message = null;
  313. AjaxJson j = new AjaxJson();
  314. message = "钉钉考勤原始信息表删除成功";
  315. try{
  316. for(String id:ids.split(",")){
  317. DingAttendanceinfoEntity dingAttendanceinfo = systemService.getEntity(DingAttendanceinfoEntity.class,
  318. id
  319. );
  320. dingAttendanceinfoService.delete(dingAttendanceinfo);
  321. systemService.addLog(message, Globals.Log_Type_DEL, Globals.Log_Leavel_INFO);
  322. }
  323. }catch(Exception e){
  324. e.printStackTrace();
  325. message = "钉钉考勤原始信息表删除失败";
  326. throw new BusinessException(e.getMessage());
  327. }
  328. j.setMsg(message);
  329. return j;
  330. }
  331. /**
  332. * 添加钉钉考勤原始信息表
  333. *
  334. * @param ids
  335. * @return
  336. */
  337. @RequestMapping(params = "doAdd")
  338. @ResponseBody
  339. public AjaxJson doAdd(DingAttendanceinfoEntity dingAttendanceinfo, HttpServletRequest request) {
  340. String message = null;
  341. AjaxJson j = new AjaxJson();
  342. message = "钉钉考勤原始信息表添加成功";
  343. try{
  344. dingAttendanceinfoService.save(dingAttendanceinfo);
  345. systemService.addLog(message, Globals.Log_Type_INSERT, Globals.Log_Leavel_INFO);
  346. }catch(Exception e){
  347. e.printStackTrace();
  348. message = "钉钉考勤原始信息表添加失败";
  349. throw new BusinessException(e.getMessage());
  350. }
  351. j.setMsg(message);
  352. return j;
  353. }
  354. /**
  355. * 更新钉钉考勤原始信息表
  356. *
  357. * @param ids
  358. * @return
  359. */
  360. @RequestMapping(params = "doUpdate")
  361. @ResponseBody
  362. public AjaxJson doUpdate(DingAttendanceinfoEntity dingAttendanceinfo, HttpServletRequest request) {
  363. String message = null;
  364. AjaxJson j = new AjaxJson();
  365. message = "钉钉考勤原始信息表更新成功";
  366. DingAttendanceinfoEntity t = dingAttendanceinfoService.get(DingAttendanceinfoEntity.class, dingAttendanceinfo.getId());
  367. try {
  368. MyBeanUtils.copyBeanNotNull2Bean(dingAttendanceinfo, t);
  369. dingAttendanceinfoService.saveOrUpdate(t);
  370. systemService.addLog(message, Globals.Log_Type_UPDATE, Globals.Log_Leavel_INFO);
  371. } catch (Exception e) {
  372. e.printStackTrace();
  373. message = "钉钉考勤原始信息表更新失败";
  374. throw new BusinessException(e.getMessage());
  375. }
  376. j.setMsg(message);
  377. return j;
  378. }
  379. /**
  380. * 钉钉考勤原始信息表新增页面跳转
  381. *
  382. * @return
  383. */
  384. @RequestMapping(params = "goAdd")
  385. public ModelAndView goAdd(DingAttendanceinfoEntity dingAttendanceinfo, HttpServletRequest req) {
  386. if (StringUtil.isNotEmpty(dingAttendanceinfo.getId())) {
  387. dingAttendanceinfo = dingAttendanceinfoService.getEntity(DingAttendanceinfoEntity.class, dingAttendanceinfo.getId());
  388. req.setAttribute("dingAttendanceinfoPage", dingAttendanceinfo);
  389. }
  390. return new ModelAndView("cn/com/lzt/dingattendanceinfo/dingAttendanceinfo-add");
  391. }
  392. /**
  393. * 钉钉考勤原始信息表编辑页面跳转
  394. *
  395. * @return
  396. */
  397. @RequestMapping(params = "goUpdate")
  398. public ModelAndView goUpdate(DingAttendanceinfoEntity dingAttendanceinfo, HttpServletRequest req) {
  399. if (StringUtil.isNotEmpty(dingAttendanceinfo.getId())) {
  400. dingAttendanceinfo = dingAttendanceinfoService.getEntity(DingAttendanceinfoEntity.class, dingAttendanceinfo.getId());
  401. req.setAttribute("dingAttendanceinfoPage", dingAttendanceinfo);
  402. }
  403. return new ModelAndView("cn/com/lzt/dingattendanceinfo/dingAttendanceinfo-update");
  404. }
  405. /**
  406. * 导入功能跳转
  407. *
  408. * @return
  409. */
  410. @RequestMapping(params = "upload")
  411. public ModelAndView upload(HttpServletRequest req) {
  412. req.setAttribute("controller_name","dingAttendanceinfoController");
  413. return new ModelAndView("common/upload/pub_excel_upload");
  414. }
  415. /**
  416. * 导出excel
  417. *
  418. * @param request
  419. * @param response
  420. */
  421. @RequestMapping(params = "exportXls")
  422. public String exportXls(DingAttendanceinfoInDto inDto,HttpServletRequest request,HttpServletResponse response
  423. , DataGrid dataGrid,ModelMap modelMap) {
  424. String departIds = "";
  425. if (null != inDto.getOrgIds() && StringUtil.isNotEmpty(inDto.getOrgIds())) {
  426. departIds = inDto.getOrgIds();
  427. }
  428. // 页面的单位ID
  429. List<String> departIdByPageList = Arrays.asList(departIds.split(","));
  430. // 用于检索的单位ID
  431. List<String> departIdBySearchList = new ArrayList<String>();
  432. for(String str : departIdByPageList) {
  433. if(StringUtil.isNotEmpty(str)) {
  434. departIdBySearchList.add(str);
  435. List<DepartDto> departDtoList = personnelBaseArchivesManageService.getAllChildrenList(str, null, null);
  436. for(DepartDto departDto : departDtoList) {
  437. departIdBySearchList.add(departDto.getId());
  438. }
  439. }
  440. }
  441. // List去重复
  442. HashSet<String> h = new HashSet<String>(departIdBySearchList);
  443. departIdBySearchList.clear();
  444. departIdBySearchList.addAll(h);
  445. // 重新封装检索用的单位字符串
  446. departIds = "";
  447. for(String str : departIdBySearchList) {
  448. departIds += "'" + str + "',";
  449. }
  450. if(StringUtil.isNotEmpty(departIds)) {
  451. departIds = departIds.substring(0,departIds.length() - 1);
  452. }
  453. inDto.setOrgIds(departIds);
  454. // 获取请求对应的数据权限
  455. String authSql = JeecgDataAutorUtils.loadDataSearchConditonSQLString();
  456. // 從SESSION中獲取用戶信息
  457. String sortorder = "";
  458. String sort = dataGrid.getSort(); // 排序对象
  459. String order = dataGrid.getOrder(); // 排序方式
  460. if (StringUtil.isEmpty(sort)) {
  461. sortorder = " user_code asc, belong_unitid asc, attendance_date desc, attendance_time asc"; //默认userid排序
  462. } else {
  463. sortorder = humpToLine(sort) + " " + order; // 处理下划线,拼接排序
  464. }
  465. if(StringUtil.isNotEmpty(inDto.getAttendanceEtime())) {
  466. String attendanceEtime = inDto.getAttendanceEtime();
  467. inDto.setAttendanceEtime(attendanceEtime + " 23:59:59");
  468. }
  469. // MiniDao检索
  470. MiniDaoPage<DingAttendanceinfoOutDto> list = dingAttendanceinfoService.getDingAttendanceInfoList(inDto, dataGrid.getPage(), dataGrid.getRows(), authSql, sortorder);
  471. List<DingAttendanceinfoOutDto> dingAttendanceinfos = list.getResults();
  472. // 处理出勤时间
  473. for(int i = 0; i < dingAttendanceinfos.size(); i++) {
  474. String attendanceTimeStringOldString = dingAttendanceinfos.get(i).getAttendanceTimeString();
  475. List<String> attendanceTimeStringOldList = Arrays.asList(attendanceTimeStringOldString.split(","));
  476. Collections.sort(attendanceTimeStringOldList);
  477. String attendanceTimeStringNewString = "";
  478. for(String temp : attendanceTimeStringOldList) {
  479. attendanceTimeStringNewString += temp.substring(11, 16) + ",";
  480. }
  481. attendanceTimeStringNewString = attendanceTimeStringNewString.substring(0, attendanceTimeStringNewString.length() - 1);
  482. dingAttendanceinfos.get(i).setAttendanceTimeString(attendanceTimeStringNewString);
  483. }
  484. modelMap.put(NormalExcelConstants.FILE_NAME,"钉钉考勤原始信息");
  485. modelMap.put(NormalExcelConstants.CLASS,DingAttendanceinfoOutDto.class);
  486. modelMap.put(NormalExcelConstants.PARAMS,new ExportParams("钉钉考勤原始信息列表", "导出人:"+ResourceUtil.getSessionUser().getRealName(),
  487. "钉钉考勤原始信息列表"));
  488. modelMap.put(NormalExcelConstants.DATA_LIST,dingAttendanceinfos);
  489. return NormalExcelConstants.JEECG_EXCEL_VIEW;
  490. }
  491. /**
  492. * 导出excel 使模板
  493. *
  494. * @param request
  495. * @param response
  496. */
  497. @RequestMapping(params = "exportXlsByT")
  498. public String exportXlsByT(DingAttendanceinfoEntity dingAttendanceinfo,HttpServletRequest request,HttpServletResponse response
  499. , DataGrid dataGrid,ModelMap modelMap) {
  500. modelMap.put(NormalExcelConstants.FILE_NAME,"钉钉考勤原始信息表");
  501. modelMap.put(NormalExcelConstants.CLASS,DingAttendanceinfoEntity.class);
  502. modelMap.put(NormalExcelConstants.PARAMS,new ExportParams("钉钉考勤原始信息表列表", "导出人:"+ResourceUtil.getSessionUser().getRealName(),
  503. "导出信息"));
  504. modelMap.put(NormalExcelConstants.DATA_LIST,new ArrayList());
  505. return NormalExcelConstants.JEECG_EXCEL_VIEW;
  506. }
  507. @SuppressWarnings("unchecked")
  508. @RequestMapping(params = "importExcel", method = RequestMethod.POST)
  509. @ResponseBody
  510. public AjaxJson importExcel(HttpServletRequest request, HttpServletResponse response) {
  511. AjaxJson j = new AjaxJson();
  512. MultipartHttpServletRequest multipartRequest = (MultipartHttpServletRequest) request;
  513. Map<String, MultipartFile> fileMap = multipartRequest.getFileMap();
  514. for (Map.Entry<String, MultipartFile> entity : fileMap.entrySet()) {
  515. MultipartFile file = entity.getValue();// 获取上传文件对象
  516. ImportParams params = new ImportParams();
  517. params.setTitleRows(2);
  518. params.setHeadRows(1);
  519. params.setNeedSave(true);
  520. try {
  521. List<DingAttendanceinfoEntity> listDingAttendanceinfoEntitys = ExcelImportUtil.importExcel(file.getInputStream(),DingAttendanceinfoEntity.class,params);
  522. for (DingAttendanceinfoEntity dingAttendanceinfo : listDingAttendanceinfoEntitys) {
  523. dingAttendanceinfoService.save(dingAttendanceinfo);
  524. }
  525. j.setMsg("文件导入成功!");
  526. } catch (Exception e) {
  527. j.setMsg("文件导入失败!");
  528. logger.error(ExceptionUtil.getExceptionMessage(e));
  529. }finally{
  530. try {
  531. file.getInputStream().close();
  532. } catch (IOException e) {
  533. e.printStackTrace();
  534. }
  535. }
  536. }
  537. return j;
  538. }
  539. @RequestMapping(method = RequestMethod.GET)
  540. @ResponseBody
  541. public List<DingAttendanceinfoEntity> list() {
  542. List<DingAttendanceinfoEntity> listDingAttendanceinfos=dingAttendanceinfoService.getList(DingAttendanceinfoEntity.class);
  543. return listDingAttendanceinfos;
  544. }
  545. @RequestMapping(value = "/{id}", method = RequestMethod.GET)
  546. @ResponseBody
  547. public ResponseEntity<?> get(@PathVariable("id") String id) {
  548. DingAttendanceinfoEntity task = dingAttendanceinfoService.get(DingAttendanceinfoEntity.class, id);
  549. if (task == null) {
  550. return new ResponseEntity(HttpStatus.NOT_FOUND);
  551. }
  552. return new ResponseEntity(task, HttpStatus.OK);
  553. }
  554. @RequestMapping(method = RequestMethod.POST, consumes = MediaType.APPLICATION_JSON_VALUE)
  555. @ResponseBody
  556. public ResponseEntity<?> create(@RequestBody DingAttendanceinfoEntity dingAttendanceinfo, UriComponentsBuilder uriBuilder) {
  557. //调用JSR303 Bean Validator进行校验,如果出错返回含400错误码及json格式的错误信息.
  558. Set<ConstraintViolation<DingAttendanceinfoEntity>> failures = validator.validate(dingAttendanceinfo);
  559. if (!failures.isEmpty()) {
  560. return new ResponseEntity(BeanValidators.extractPropertyAndMessage(failures), HttpStatus.BAD_REQUEST);
  561. }
  562. //保存
  563. try{
  564. dingAttendanceinfoService.save(dingAttendanceinfo);
  565. } catch (Exception e) {
  566. e.printStackTrace();
  567. return new ResponseEntity(HttpStatus.NO_CONTENT);
  568. }
  569. //按照Restful风格约定,创建指向新任务的url, 也可以直接返回id或对象.
  570. String id = dingAttendanceinfo.getId();
  571. URI uri = uriBuilder.path("/rest/dingAttendanceinfoController/" + id).build().toUri();
  572. HttpHeaders headers = new HttpHeaders();
  573. headers.setLocation(uri);
  574. return new ResponseEntity(headers, HttpStatus.CREATED);
  575. }
  576. @RequestMapping(value = "/{id}", method = RequestMethod.PUT, consumes = MediaType.APPLICATION_JSON_VALUE)
  577. public ResponseEntity<?> update(@RequestBody DingAttendanceinfoEntity dingAttendanceinfo) {
  578. //调用JSR303 Bean Validator进行校验,如果出错返回含400错误码及json格式的错误信息.
  579. Set<ConstraintViolation<DingAttendanceinfoEntity>> failures = validator.validate(dingAttendanceinfo);
  580. if (!failures.isEmpty()) {
  581. return new ResponseEntity(BeanValidators.extractPropertyAndMessage(failures), HttpStatus.BAD_REQUEST);
  582. }
  583. //保存
  584. try{
  585. dingAttendanceinfoService.saveOrUpdate(dingAttendanceinfo);
  586. } catch (Exception e) {
  587. e.printStackTrace();
  588. return new ResponseEntity(HttpStatus.NO_CONTENT);
  589. }
  590. //按Restful约定,返回204状态码, 无内容. 也可以返回200状态码.
  591. return new ResponseEntity(HttpStatus.NO_CONTENT);
  592. }
  593. @RequestMapping(value = "/{id}", method = RequestMethod.DELETE)
  594. @ResponseStatus(HttpStatus.NO_CONTENT)
  595. public void delete(@PathVariable("id") String id) {
  596. dingAttendanceinfoService.deleteEntityById(DingAttendanceinfoEntity.class, id);
  597. }
  598. }