package com.cloud.attendance.controller;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.cloud.attendance.model.AttDay;
|
import com.cloud.attendance.model.EsAttExcelData;
|
import com.cloud.attendance.service.AttDayService;
|
import com.cloud.attendance.service.QueryEsService;
|
import com.cloud.attendance.utils.EnumStr;
|
import com.cloud.attendance.utils.ExportExcelUtils;
|
import com.cloud.model.common.Result;
|
import io.swagger.annotations.*;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang3.StringUtils;
|
import org.apache.poi.xssf.usermodel.XSSFWorkbook;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.format.annotation.DateTimeFormat;
|
import org.springframework.http.MediaType;
|
import org.springframework.web.bind.annotation.*;
|
|
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpServletResponse;
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
import java.util.List;
|
import java.util.Map;
|
|
@Slf4j
|
@Api( value = "AttDayController",description = "考勤记录查询")
|
@RestController
|
@RequestMapping("/api-a/att")
|
public class AttDayController {
|
|
@Autowired
|
private AttDayService attDayService;
|
@Autowired
|
private QueryEsService queryEsService;
|
|
private String queryEsParam = "queryEsParam";
|
|
private SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
private SimpleDateFormat sdfTime = new SimpleDateFormat("HH:mm:ss");
|
private SimpleDateFormat sdfDate = new SimpleDateFormat("yyyy-MM-dd");
|
@ApiOperation(value = "查询单人某月考勤记录", notes = "查询考勤记录", httpMethod = "POST", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "mouthDate", value = "年-月 2018-11", required = true, dataType = "string", paramType = "query" ,example="2018-11"),
|
@ApiImplicitParam(name = "personId", value = "查询人id 9f25143b-2663-52cf-973b-72295c19fae1", required = true, dataType = "string", paramType = "query",example="5767")
|
})
|
@PostMapping("/queryperson")
|
public Result queryperson( String mouthDate, String personId){
|
try{
|
log.info("mouthDate:"+mouthDate+"personId:"+personId);
|
return Result.ok("查询单人某月考勤记录成功", attDayService.findPerDayRecord(mouthDate,personId));
|
}catch(Exception e){
|
log.error(e.getLocalizedMessage());
|
return Result.error(e);
|
}
|
}
|
|
@ApiOperation(value = "导出单人某月考勤记录", notes = "导出单人某月考勤记录", httpMethod = "GET", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "mouthDate", value = "年-月 2018-11", required = true, dataType = "string", paramType = "query" ,example="2018-11"),
|
@ApiImplicitParam(name = "personId", value = "查询人id 9f25143b-2663-52cf-973b-72295c19fae1", required = true, dataType = "string", paramType = "query",example="5767")
|
})
|
@GetMapping("/poiPersonMouuthDataExcel")
|
public void excelPersonData(String mouthDate,String personId,HttpServletResponse response,HttpServletRequest req){
|
personId = req.getParameter("personId");
|
mouthDate = req.getParameter("mouthDate");
|
log.info("mouthDate:"+mouthDate+"personId:"+personId);
|
Map<String, Object> perDayRecord = attDayService.findPerDayRecord(mouthDate, personId);
|
Object employeeName = perDayRecord.get("employeeName");
|
Object identity = perDayRecord.get("identity");
|
EsAttExcelData<List<Object>> data = new EsAttExcelData<List<Object>>();
|
data.setName(""+employeeName+mouthDate+"月考勤记录");
|
List<String> titles = new ArrayList();
|
// {"pid","pname","photo","identity","indeviceid","indevicename","onlinetime","Snapshotpath"}
|
titles.add("日期");titles.add("考勤时间（首次）"); titles.add("首次考勤位置");
|
titles.add("考勤时间（末次）");// titles.add("人员Id");
|
titles.add("末次考勤位置");titles.add("考勤状态");
|
data.setTitles(titles);
|
List<List<Object>> rows = new ArrayList();
|
List<AttDay> attDays = ( List<AttDay>) perDayRecord.get("dayList");
|
for (AttDay attDay : attDays) {
|
ArrayList<Object> obj = new ArrayList<>();
|
obj.add(attDay.getSignDate()!=null?sdfDate.format(attDay.getSignDate()):"");
|
obj.add(attDay.getInTime()!=null?sdfTime.format(attDay.getInTime()):"");
|
obj.add(attDay.getInDeviceName());
|
obj.add(attDay.getOutTime()!=null?sdfTime.format(attDay.getOutTime()):"");
|
obj.add(attDay.getOutDeviceName());
|
obj.add(attDay.getDayStatus());
|
rows.add(obj);
|
}
|
try {
|
data.setRows(rows);
|
String fileName = "" + (employeeName==null?"":employeeName) + mouthDate + "月考勤记录.xlsx"; // .xlsx + (identity==null?"":identity)
|
String s = new String((fileName).getBytes("utf-8"), "utf-8");
|
ExportExcelUtils.exportObjectExcel(response,fileName,data);
|
// return Result.ok("导出单人某月考勤记录成功","导出单人某月考勤记录");
|
} catch (Exception e){
|
e.printStackTrace();
|
}
|
}
|
@ApiOperation(value = "查询多人某月考勤记录", notes = "查询多人某月考勤记录", httpMethod = "POST", produces = MediaType.APPLICATION_JSON_UTF8_VALUE
|
, response = Result.class)
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "mouthDate", value = "年-月 2018-11", required = true, dataType = "String", paramType = "query"),
|
@ApiImplicitParam(name = "gradeValue", value = "年级 暂无", required = false, dataType = "String", paramType = "query"),
|
@ApiImplicitParam(name = "classValue", value = "班级 暂无", required = false, dataType = "String", paramType = "query"),
|
@ApiImplicitParam(name = "identity", value = "身份 student/teacher", required = true, dataType = "String", paramType = "query"),
|
@ApiImplicitParam(name = "delFlag", value = "是否已删除 true包含/false不包含", required = false, dataType = "boolean", paramType = "query"),
|
@ApiImplicitParam(name = "days", value = "30 默认30", required = false, dataType = "long", paramType = "query"),
|
@ApiImplicitParam(name = "orgIds", value = "组织机构id集合", required = false, dataType = "String", paramType = "query")
|
})
|
@PostMapping("/morequery")
|
public Result save(@RequestParam String mouthDate,@RequestParam(required = false) String gradeValue,
|
@RequestParam(required = false) String classValue,
|
@RequestParam(required = false) String orgIds,@RequestParam(required = false) Boolean delFlag, // 是否包含已删除
|
@RequestParam(required = false,defaultValue ="30") Integer days
|
,@RequestParam(required = true) String identity){
|
if ("".equals(gradeValue)||"all".equalsIgnoreCase(gradeValue)){ gradeValue =null; }
|
if ("".equals(classValue)||"all".equalsIgnoreCase(classValue))classValue = null;
|
log.info("mouthDate:"+mouthDate+"gradeValue:"+gradeValue+"classValue:"+classValue+"identity:"+identity+"days"+days+"orgIds:"+orgIds);
|
return Result.ok("查询多人"+mouthDate+"月考勤记录成功", attDayService.findAllDayRecord(mouthDate,gradeValue,classValue,identity,days,delFlag,orgIds));
|
}
|
|
@ApiOperation(value = "请假或补签接口", notes = "修改某人某天考勤记录---暂不用18-11-09", httpMethod = "POST", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "recordId", value = "考勤记录Id", required = true, dataType = "long", paramType = "query"),
|
@ApiImplicitParam(name = "mouthDay", value = "年-月-日", required = false,dataType = "date", paramType = "query"),
|
@ApiImplicitParam(name = "leaveOrRepair", value = "leave 请假 repair 补签", required = true, dataType = "String", paramType = "query")
|
})
|
@PostMapping("/updateRecord")
|
public Result updateRecord(@RequestParam Long recordId,
|
@RequestParam(required = false) Date mouthDay,
|
@RequestParam String leaveOrRepair){
|
if ("".equals(mouthDay)){
|
mouthDay = null;
|
}
|
log.info("recordId:"+recordId+"mouthDay:"+mouthDay+"leaveOrRepair"+leaveOrRepair);
|
return Result.ok("请假或补签成功", attDayService.updateDayRecord(recordId,mouthDay,leaveOrRepair));
|
}
|
|
@ApiOperation(value = "流水记录查询接口", notes = "流水记录查询", httpMethod = "POST", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "contentValue", value = "姓名/身份证号/学号 曹 1211", required = false, dataType = "string", paramType = "query"),
|
@ApiImplicitParam(name = "location", value = "位置 北门考勤机", required = false, dataType = "string", paramType = "query"),
|
@ApiImplicitParam(name = "identity", value = "身份 学生student老师teacher", required = false, dataType = "string", paramType = "query"),
|
@ApiImplicitParam(name = "orgIds", value = "组织机构id 集合", required = false, dataType = "string", paramType = "query"),
|
@ApiImplicitParam(name = "gradeValue", value = "年级", required = false, dataType = "String", paramType = "query"),
|
@ApiImplicitParam(name = "classValue", value = "班级", required = false, dataType = "String", paramType = "query"),
|
@ApiImplicitParam(name = "order", value = "排序 descending ascending", required = false, dataType = "String", paramType = "query"),
|
@ApiImplicitParam(name = "orderName", value = "排序列 pname identity indevicename onlinetime", required = false, dataType = "String", paramType = "query"),
|
@ApiImplicitParam(name = "delFlag", value = "是否包含已上除 true包含/false", required = false, dataType = "boolean", paramType = "query"),
|
@ApiImplicitParam(name = "startTime", value = "起始时间 2018/11/03 12:00:00", required = true, dataType = "date",
|
paramType = "query",example = "2018/11/30 12:00:00"),
|
@ApiImplicitParam(name = "endTime", value = "结束时间 2018/11/29 12:00:00", required = true, dataType = "date", paramType = "query"
|
,example = "2018/11/29 12:00:00"),
|
@ApiImplicitParam(name = "page", value = "页数 1", required = false, dataType = "int32", paramType = "query"),
|
@ApiImplicitParam(name = "size", value = "每页条数 10", required = false, dataType = "int32", paramType = "query")
|
})
|
@PostMapping("/queryEsRecord")
|
public Result queryEsRecord(
|
@RequestParam(required = false) String contentValue,@RequestParam(required = false) String location,
|
@RequestParam(required = false) String identity,@RequestParam(required = false) String gradeValue,
|
@RequestParam(required = false) String classValue, @RequestParam(required = false) String orgIds, // 多组织机构数据 , 拼接
|
@RequestParam(name = "order",required = false,defaultValue = "descending") String sortDate,
|
@RequestParam(name = "delFlag",required = false,defaultValue = "false") Boolean delFlag,
|
@RequestParam Date startTime, // @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
|
@RequestParam Date endTime, // @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
|
@RequestParam(required = false,defaultValue = "1") Integer page,String orderName,
|
@RequestParam(required = false,defaultValue = "10") Integer size, HttpServletRequest request){
|
if ("".equals(contentValue)){contentValue =null;}
|
if ("".equals(location)){location =null;}
|
if ("".equals(identity)||"all".equalsIgnoreCase(identity)){identity = null;}
|
if ("".equals(gradeValue)||"all".equalsIgnoreCase(gradeValue)){gradeValue = null;}
|
if ("".equals(classValue)||"all".equalsIgnoreCase(classValue)){classValue = null;}
|
if (sortDate.equalsIgnoreCase("descending")){
|
sortDate = "desc";
|
}else { sortDate = "asc"; }
|
List<String> orgIdList = new ArrayList<>();
|
if (!StringUtils.isBlank(orgIds)){
|
String[] ids = orgIds.split(",");
|
orgIdList = Arrays.asList(ids);
|
}
|
Map<String,Object> map = new HashMap<String, Object>();
|
map.put("contentValue",contentValue); map.put("location",location); map.put("identity",identity);
|
map.put("delFlag",delFlag); map.put("orgIds",orgIdList);map.put("orderName",orderName);
|
map.put("gradeValue",gradeValue); map.put("classValue",classValue );map.put("sortDate",sortDate);
|
map.put("startTime",startTime);map.put("endTime",endTime); map.put("page",page); map.put("size",size);
|
request.getSession().setAttribute(queryEsParam,map);
|
log.info("流水记录查询 参数:"+map);
|
return Result.ok("流水记录查询成功", queryEsService.queryAttRecord(contentValue,location,
|
identity,gradeValue,classValue,delFlag,orgIdList,orderName,sortDate,startTime,endTime, page, size));
|
}
|
@ApiOperation(value = "搜索流水记录导出接口", notes = "流水记录导出", httpMethod = "GET", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
|
@ApiImplicitParams({
|
})
|
@RequestMapping(value = "/searchExcel", method = RequestMethod.GET)
|
public void poiEsRecord( HttpServletResponse response,HttpServletRequest request){
|
EsAttExcelData<JSONObject> data = new EsAttExcelData<JSONObject>();
|
data.setName("考勤流水记录");
|
List<String> titles = new ArrayList();
|
String contentValue=null,location=null,identity=null,gradeValue =null,classValue =null,sortDate=null,orderName = null;
|
Date startTime =null,endTime =null;Integer page = null,size =null; Boolean delFlag = false;List<String> orgIds = null;
|
// {"pid","pname","photo","identity","indeviceid","indevicename","onlinetime","Snapshotpath"}
|
titles.add("人员Id"); titles.add("姓名");titles.add("身份证号");titles.add("人员属性");titles.add("考勤时间");
|
// titles.add("人员图片");
|
titles.add("设备Id");titles.add("设备名称");titles.add("设备地址");
|
// titles.add("抓拍图片");
|
data.setTitles(titles);
|
Map<String,Object> params = (Map<String, Object>) request.getSession().getAttribute(queryEsParam);
|
if(params !=null){
|
contentValue = (String) params.get("contentValue");
|
location = (String) params.get("location");
|
identity = (String) params.get("identity");
|
gradeValue = (String) params.get("gradeValue");
|
classValue = (String) params.get("classValue");
|
delFlag = (Boolean) params.get("delFlag");
|
orgIds = (List<String>) params.get("orgIds");
|
sortDate = (String) params.get("sortDate");
|
orderName = (String) params.get("orderName");
|
startTime = (Date) params.get("startTime");
|
endTime = (Date) params.get("endTime");
|
page = (Integer) params.get("page");
|
size = (Integer) params.get("size");
|
}else{
|
RuntimeException re = new RuntimeException("导出考勤数据失败,请重新搜索数据再导出。");
|
throw re;
|
}
|
Map<String, Object> record = queryEsService.queryAttRecord(contentValue, location,
|
identity, gradeValue, classValue,delFlag,orgIds, orderName, sortDate,startTime, endTime, 1, 10000);
|
List<List<Object>> rows = new ArrayList();
|
List<JSONObject> esAttList = (List<JSONObject>) record.get("esAttList");
|
|
data.setRows(esAttList);
|
try {
|
String s = new String(("考勤记录.xlsx").getBytes("utf-8"), "utf-8");
|
ExportExcelUtils.exportExcel(response,s,data);
|
// return Result.ok("导出考勤数据成功！",null);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
|
}
|
/* @ApiOperation(value = "流水记录导出接口", notes = "流水记录导出--暂不用", httpMethod = "GET", produces = MediaType.APPLICATION_FORM_URLENCODED_VALUE)
|
@ApiImplicitParams({
|
})*/
|
// @RequestMapping(value = "/AllRecordExcel", method = RequestMethod.GET)
|
public Result poiAllEsRecord( HttpServletResponse response,HttpServletRequest request){
|
XSSFWorkbook wb =null;
|
EsAttExcelData data = new EsAttExcelData();
|
data.setName("考勤流水记录");
|
List<String> titles = new ArrayList();
|
String contentValue=null,location=null,identity=null,gradeValue =null,classValue =null,sortDate = null,orderName = null;
|
Date startTime =null,endTime =null;Integer page = null,size =null;Boolean delFlag = false;List<String> orgIds = null;
|
// {"pid","pname","photo","identity","indeviceid","indevicename","onlinetime","Snapshotpath"}
|
titles.add("人员Id"); titles.add("名字"); titles.add("人员图片");titles.add("身份");
|
titles.add("设备Id");titles.add("设备名称"); titles.add("考勤时间");titles.add("抓拍图片");
|
data.setTitles(titles);
|
Map<String,Object> params = (Map<String, Object>) request.getSession().getAttribute("queryEsParam");
|
if(params !=null){
|
contentValue = (String) params.get("contentValue");location = (String) params.get("location");
|
identity = (String) params.get("identity");gradeValue = (String) params.get("gradeValue");
|
classValue = (String) params.get("classValue");delFlag = (Boolean) params.get("delFlag");
|
orgIds = (List<String>) params.get("orgIds");sortDate = (String) params.get("sortDate");
|
orderName = (String) params.get("orderName");startTime = (Date) params.get("startTime");
|
endTime = (Date) params.get("endTime");page = (Integer) params.get("page");
|
size = (Integer) params.get("size");
|
}else{
|
RuntimeException re = new RuntimeException("导出考勤数据失败！");
|
throw re;
|
}
|
Map<String, Object> record = queryEsService.queryAttRecord(contentValue, location,
|
identity, gradeValue, classValue,delFlag,orgIds, orderName, sortDate, startTime, endTime, 1, 10000);
|
Integer total = (Integer) record.get("total");
|
if (total>0){
|
List<JSONObject> esAttList = null; page = 2;
|
do {
|
/* for (int i=0,item = esAttList.size(); i<item;i++){
|
List<Object> row = new ArrayList();
|
row.add("id"+i);
|
row.add("名字"+i);
|
row.add("http://192.168.1.203"+i);
|
row.add(sdf.format(new Date()));
|
rows.add(row);
|
}*/
|
esAttList = (List<JSONObject>) record.get("esAttList");
|
data.setRows(esAttList);
|
//生成本地
|
/*File f = new File("c:/test.xlsx");
|
FileOutputStream out = new FileOutputStream(f);
|
ExportExcelUtils.exportExcel(data, out);
|
out.close();*/
|
try {
|
ExportExcelUtils.exportMoreExcel(response, "多人考勤流水记录" + (page - 1) + ".xlsx", data);
|
record = queryEsService.queryAttRecord(contentValue, location,
|
identity, gradeValue, classValue,delFlag,orgIds, orderName, sortDate, startTime, endTime, page++, 10000);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}while(esAttList.size()>0 || page >9);
|
}
|
return Result.ok("导出考勤数据成功！",null);
|
}
|
|
@ApiOperation(value = "查询个人单日考勤流水接口", notes = "查询个人单日考勤流水查询", httpMethod = "POST", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "id", value = "personId 9f25143b-2663-52cf-973b-72295c19fae1", required = true, dataType = "string", paramType = "query"),
|
@ApiImplicitParam(name = "beginTime", value = "起始时间 2019-03-21", required = true, dataType = "date",
|
paramType = "query",example = "2018/11/06"),
|
@ApiImplicitParam(name = "endTime", value = "结束时间 2019-03-21", required = true, dataType = "date", paramType = "query"
|
,example = "2018/11/06")
|
})
|
// @AuthNoneIgnore
|
@PostMapping("/queryPersonById")
|
public Result queryPersonById(@RequestParam String id,@RequestParam @DateTimeFormat(pattern = "yyyy-MM-dd") Date beginTime,
|
@RequestParam @DateTimeFormat(pattern = "yyyy-MM-dd") Date endTime){
|
try{
|
return Result.ok("查询个人单日考勤流水成功！",
|
queryEsService.queryPersonById(id,beginTime,endTime));
|
}catch (Exception e){
|
e.printStackTrace();
|
log.error(e.getLocalizedMessage());
|
return Result.error(e);
|
}
|
}
|
|
@ApiOperation(value = "导出单人单日考勤记录", notes = "导出单人单日考勤记录", httpMethod = "GET", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "id", value = "personId 9f25143b-2663-52cf-973b-72295c19fae1", required = true, dataType = "string", paramType = "query"),
|
@ApiImplicitParam(name = "dayTime", value = "起始时间 2018-11-06", required = true, dataType = "date",
|
paramType = "query",example = "2018-11-06")
|
})
|
@RequestMapping(value = "/poiPersonDayDataExcel",method = RequestMethod.GET)
|
public void excelPersonDayData(@RequestParam(value = "id") String personId,
|
@RequestParam @DateTimeFormat(pattern = "yyyy-MM-dd") Date dayTime,
|
HttpServletResponse response,
|
HttpServletRequest req){
|
try{
|
String id = req.getParameter("id");
|
log.info(id+"id参数变化");
|
String mouthDate = sdfDate.format(dayTime);
|
log.info("导出单人单日参数：beginTime:"+mouthDate+"personId:"+id);
|
Map<String, Object> perDayRecord = queryEsService.queryPersonById(id, dayTime, dayTime);
|
Object employeeName = perDayRecord.get(EnumStr.pnameShow);
|
Object idCard = perDayRecord.get(EnumStr.idCardField);if (idCard == null){idCard ="";}
|
EsAttExcelData<List<Object>> data = new EsAttExcelData<List<Object>>();
|
String fileName = ""+(employeeName==null||"".equals(employeeName)?idCard:employeeName)+mouthDate+"考勤记录"; // (identity==null?"":identity)+
|
data.setName(fileName);
|
log.info("employeeName:"+employeeName+"idCard:"+idCard+"mouthDate:"+mouthDate);
|
List<String> titles = new ArrayList();
|
// {"pid","pname","photo","identity","indeviceid","indevicename","onlinetime","Snapshotpath"}
|
// titles.add("人员Id"); titles.add("设备ID"); // 2018-12-21
|
titles.add("考勤时间"); titles.add("考勤位置");
|
// titles.add("抓拍图片");
|
data.setTitles(titles);
|
List<List<Object>> rows = new ArrayList();
|
List<JSONObject> attDays = (List<JSONObject>) perDayRecord.get("dayList");
|
for (JSONObject attDay : attDays) {
|
ArrayList<Object> obj = new ArrayList<>();
|
// obj.add(attDay.getString("pid"));
|
// obj.add(attDay.getString("indeviceid"));
|
obj.add(attDay.getString("onlinetime"));
|
obj.add(attDay.getString("indevicename")); // indevicename
|
// obj.add(attDay.getString("Snapshotpath"));
|
rows.add(obj);
|
}
|
data.setRows(rows);
|
String s = new String((fileName+".xlsx").getBytes("utf-8"), "utf-8");
|
ExportExcelUtils.exportObjectExcel(response,s,data);
|
// return Result.ok("导出单人单日考勤记录成功","导出单人单日考勤记录");
|
}catch(Exception e){
|
log.error(e.getLocalizedMessage());
|
// return Result.error(e);
|
}
|
}
|
|
}
|
