考勤查询功能

ebc-sea-platform/src/main/java/com/ai/ipu/server/controller/AreaInOutRecordManageController.java

@@ -1,5 +1,6 @@
package com.ai.ipu.server.controller;
import com.github.pagehelper.PageInfo;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
@@ -26,17 +27,16 @@ public class AreaInOutRecordManageController {
	 */
	@ResponseBody
	@RequestMapping("/queryPageAttendanceCount")
	public JMap queryPageAttendanceCount(JMap params) throws Exception {
	public PageInfo queryPageAttendanceCount(JMap params) throws Exception {
		// 当前页数
		int pageNum = params.getInt("pageNum") < 1 ? 1 : params.getInt("pageNum");
		// 每页条数
		int pageSize = params.getInt("pageSize") < 1 ? 10 : params.getInt("pageSize");
		JMap result = areaInOutRecordService.queryPageAttendanceCount(params, pageNum, pageSize);
		PageInfo pageInfo = areaInOutRecordService.queryPageAttendanceCount(params, pageNum, pageSize);
		result.put("pageNum", pageNum);
		result.put("pageSize", pageSize);
		return result;
		return pageInfo;
	}
@@ -64,17 +64,12 @@ public class AreaInOutRecordManageController {
	 */
	@ResponseBody
	@RequestMapping("/queryPageAreaInOutRecord")
	public JMap queryPageAreaInOutRecord(JMap params) throws Exception {
	public PageInfo queryPageAreaInOutRecord(JMap params) throws Exception {
		// 当前页数
		int pageNum = params.getInt("pageNum") < 1 ? 1 : params.getInt("pageNum");
		// 每页条数
		int pageSize = params.getInt("pageSize") < 1 ? 10 : params.getInt("pageSize");
		JMap result = areaInOutRecordService.queryPageAreaInOutRecord(params, pageNum, pageSize);
		result.put("pageNum", pageNum);
		result.put("pageSize", pageSize);
		PageInfo result = areaInOutRecordService.queryPageAreaInOutRecord(params, pageNum, pageSize);
		return result;
	}
}

ebc-sea-platform/src/main/java/com/ai/ipu/server/dao/impl/AreaInOutRecordDaoImpl.java

@@ -6,6 +6,8 @@ import java.util.HashMap;
import java.util.List;
import java.util.Map;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import org.springframework.stereotype.Component;
import com.ai.ipu.common.date.TimeUtil;
@@ -25,7 +27,22 @@ public class AreaInOutRecordDaoImpl extends AbstractBizDao implements AreaInOutR
	}
	@Override
	public JMap queryPageAreaInOutRecord(JMap params, int pageNum, int pageSize) throws Exception {
	public PageInfo queryPageDayAreaInOutRecord(JMap params, int pageNum, int pageSize) throws Exception {
		PageHelper.startPage(pageNum,pageSize);
		ISqlMgmtDao dao1 = SqlMgmtDaoFactory.createFileSqlMgmtDao(connName);
		List<Map<String, Object>> equipmentList= dao1.executeSelect("ipu.AreaInOutRecordDao", "queryPageDayAreaInOutRecord", params);
		PageInfo pageInfo = new PageInfo(equipmentList);
		return pageInfo;
	}
	@Override
	public List<Map<String, Object>> queryPageWeekAreaInOutRecord(JMap params, int pageNum, int pageSize) throws Exception {
		// TODO Auto-generated method stub
		return null;
	}
	@Override
	public List<Map<String, Object>> queryPageMonthAreaInOutRecord(JMap params, int pageNum, int pageSize) throws Exception {
		// TODO Auto-generated method stub
		return null;
	}
@@ -41,6 +58,32 @@ public class AreaInOutRecordDaoImpl extends AbstractBizDao implements AreaInOutR
		// TODO Auto-generated method stub
		return null;
	}
	@Override
	public PageInfo queryPageDayAttendanceCount(JMap params, int pageNum, int pageSize) throws Exception {
		PageHelper.startPage(pageNum,pageSize);
		ISqlMgmtDao dao1 = SqlMgmtDaoFactory.createFileSqlMgmtDao(connName);
		List<Map<String, Object>> equipmentList= dao1.executeSelect("ipu.AreaInOutRecordDao", "queryPageDayAttendanceCount", params);
		PageInfo pageInfo = new PageInfo(equipmentList);
		return pageInfo;
	}
	@Override
	public PageInfo queryPageWeekAttendanceCount(JMap params, int pageNum, int pageSize) throws Exception {
		PageHelper.startPage(pageNum,pageSize);
		ISqlMgmtDao dao1 = SqlMgmtDaoFactory.createFileSqlMgmtDao(connName);
		List<Map<String, Object>> equipmentList= dao1.executeSelect("ipu.AreaInOutRecordDao", "queryPageWeekAttendanceCount", params);
		PageInfo pageInfo = new PageInfo(equipmentList);
		return pageInfo;
	}
	@Override
	public PageInfo queryPageMonthAttendanceCount(JMap params, int pageNum, int pageSize) throws Exception {
		PageHelper.startPage(pageNum,pageSize);
		ISqlMgmtDao dao1 = SqlMgmtDaoFactory.createFileSqlMgmtDao(connName);
		List<Map<String, Object>> equipmentList= dao1.executeSelect("ipu.AreaInOutRecordDao", "queryPageMonthAttendanceCount", params);
		PageInfo pageInfo = new PageInfo(equipmentList);
		return pageInfo;
	}
	@Override
	public List<Map<String, Object>> getBeforeAreaInfo(JMap params) throws Exception {

ebc-sea-platform/src/main/java/com/ai/ipu/server/dao/interfaces/AreaInOutRecordDao.java

@@ -4,6 +4,7 @@ import java.util.List;
import java.util.Map;
import com.ai.ipu.data.JMap;
import com.github.pagehelper.PageInfo;
public interface AreaInOutRecordDao {
@@ -19,6 +20,39 @@ public interface AreaInOutRecordDao {
	JMap queryPageAttendanceCount(JMap params, int pageNum, int pageSize) throws Exception;
	/**
	 * 分页查询日考勤统计分析
	 *
	 * @param params
	 * @param pageNum 当前页数
	 * @param pageSize 每页条数
	 * @return
	 * @throws Exception
	 */
	PageInfo queryPageDayAttendanceCount(JMap params, int pageNum, int pageSize) throws Exception;
	/**
	 * 分页查询周考勤统计分析
	 *
	 * @param params
	 * @param pageNum 当前页数
	 * @param pageSize 每页条数
	 * @return
	 * @throws Exception
	 */
	PageInfo queryPageWeekAttendanceCount(JMap params, int pageNum, int pageSize) throws Exception;
	/**
	 * 分页查询月考勤统计分析
	 *
	 * @param params
	 * @param pageNum 当前页数
	 * @param pageSize 每页条数
	 * @return
	 * @throws Exception
	 */
	PageInfo queryPageMonthAttendanceCount(JMap params, int pageNum, int pageSize) throws Exception;
	/**
	 * 分页查询作业考勤信息详情
	 * 
	 * @param params
@@ -30,7 +64,7 @@ public interface AreaInOutRecordDao {
	JMap queryPageAttendanceRecordDetaile(JMap params, int pageNum, int pageSize) throws Exception;
	/**
	 * 分页查询进出围栏日志
	 * 分页查询日进出围栏日志
	 * 
	 * @param params
	 * @param pageNum 当前页数
@@ -38,7 +72,29 @@ public interface AreaInOutRecordDao {
	 * @return
	 * @throws Exception
	 */
	JMap queryPageAreaInOutRecord(JMap params, int pageNum, int pageSize) throws Exception;
	PageInfo queryPageDayAreaInOutRecord(JMap params, int pageNum, int pageSize) throws Exception;
	/**
	 * 分页查询日进出围栏日志
	 *
	 * @param params
	 * @param pageNum 当前页数
	 * @param pageSize 每页条数
	 * @return
	 * @throws Exception
	 */
	List<Map<String, Object>> queryPageWeekAreaInOutRecord(JMap params, int pageNum, int pageSize) throws Exception;
	/**
	 * 分页查询日进出围栏日志
	 *
	 * @param params
	 * @param pageNum 当前页数
	 * @param pageSize 每页条数
	 * @return
	 * @throws Exception
	 */
	List<Map<String, Object>> queryPageMonthAreaInOutRecord(JMap params, int pageNum, int pageSize) throws Exception;
	/**
	 * 查询之前所在围栏的信息
@@ -66,4 +122,5 @@ public interface AreaInOutRecordDao {
	 */
	boolean updateSameOutTimeAreaOutRecord(String outDate, List<String> recordIdList) throws Exception;
}

ebc-sea-platform/src/main/java/com/ai/ipu/server/enums/UserEnums.java

@@ -19,7 +19,7 @@ public enum UserEnums {
	sixUser(6, "周八", "6666", "搜救", "1", "zhouba", "员工"),
	sevenUser(7, "吴九", "7777", "搜救", "1", "wujiu", "员工"), 
	eightUser(8, "郑十", "8888", "搜救", "1", "zhengshi", "员工"),
	nineUser(9, "刘一", "9999", "搜救", "1", "liuyi", "员工");
	nineUser(0, "刘一", "9999", "搜救", "1", "liuyi", "员工");
	public int id; // id
	public String userName;// 姓名

ebc-sea-platform/src/main/java/com/ai/ipu/server/service/impl/AreaInOutRecordServiceImpl.java

@@ -1,5 +1,8 @@
package com.ai.ipu.server.service.impl;
import com.ai.ipu.server.enums.UserEnums;
import com.ai.ipu.server.util.EbcConstant;
import com.github.pagehelper.PageInfo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@@ -8,6 +11,9 @@ import com.ai.ipu.server.dao.interfaces.AreaInOutRecordDao;
import com.ai.ipu.server.dao.interfaces.MapTagManageDao;
import com.ai.ipu.server.service.interfaces.AreaInOutRecordService;
import java.util.List;
import java.util.Map;
@Service
public class AreaInOutRecordServiceImpl implements AreaInOutRecordService {
@@ -18,8 +24,32 @@ public class AreaInOutRecordServiceImpl implements AreaInOutRecordService {
	MapTagManageDao mapTagManageDao;
	@Override
	public JMap queryPageAreaInOutRecord(JMap params, int pageNum, int pageSize) throws Exception {
		return areaInOutRecordDao.queryPageAreaInOutRecord(params, pageNum, pageSize);
	public PageInfo queryPageAreaInOutRecord(JMap params, int pageNum, int pageSize) throws Exception {
		//调用uspa接口分页模糊查询姓名、职务 现在暂用枚举
		List<Map<String, Object>> userList = UserEnums.getUserList();
		PageInfo pageInfo=null;
		if(EbcConstant.AREA_IN_OUT_RECORD_DAY.equals(params.get("mark"))){
			 pageInfo = areaInOutRecordDao.queryPageDayAreaInOutRecord(params, pageNum, pageSize);
		}else if(EbcConstant.AREA_IN_OUT_RECORD_WEEK.equals(params.get("mark"))){
			areaInOutRecordDao.queryPageWeekAreaInOutRecord(params, pageNum, pageSize);
		}else if(EbcConstant.AREA_IN_OUT_RECORD_MONTH.equals(params.get("mark"))){
			areaInOutRecordDao.queryPageMonthAreaInOutRecord(params, pageNum, pageSize);
		}else {
			return null;
		}
		List<Map<String,Object>> pageInfoList = pageInfo.getList();
		for(Map<String,Object> areaInOutRecord:pageInfoList ){
			for(Map<String,Object> userMap: userList){
				if((int)areaInOutRecord.get("EMPLOYEE_ID")==(int)userMap.get("id")){
					areaInOutRecord.put("userName",userMap.get("userName"));
					areaInOutRecord.put("duty",userMap.get("duty"));
				}
			}
		}
		return pageInfo;
	}
	@Override
@@ -28,8 +58,32 @@ public class AreaInOutRecordServiceImpl implements AreaInOutRecordService {
	}
	@Override
	public JMap queryPageAttendanceCount(JMap params, int pageNum, int pageSize) throws Exception {
		return areaInOutRecordDao.queryPageAttendanceCount(params, pageNum, pageSize);
	public PageInfo queryPageAttendanceCount(JMap params, int pageNum, int pageSize) throws Exception {
		//调用uspa接口分页模糊查询姓名、职务 现在暂用枚举
		List<Map<String, Object>> userList = UserEnums.getUserList();
		PageInfo pageInfo=null;
		if(EbcConstant.AREA_IN_OUT_RECORD_DAY.equals(params.get("mark"))){
			pageInfo = areaInOutRecordDao.queryPageDayAttendanceCount(params, pageNum, pageSize);
		}else if(EbcConstant.AREA_IN_OUT_RECORD_WEEK.equals(params.get("mark"))){
			pageInfo =areaInOutRecordDao.queryPageWeekAttendanceCount(params, pageNum, pageSize);
		}else if(EbcConstant.AREA_IN_OUT_RECORD_MONTH.equals(params.get("mark"))){
			pageInfo =areaInOutRecordDao.queryPageMonthAttendanceCount(params, pageNum, pageSize);
		}else {
			return null;
		}
		List<Map<String,Object>> pageInfoList = pageInfo.getList();
		for(Map<String,Object> areaInOutRecord:pageInfoList ){
			for(Map<String,Object> userMap: userList){
				long employeeId = (long)areaInOutRecord.get("EMPLOYEE_ID");
				int userId = (int)userMap.get("id");
				if((int)employeeId==userId){
					areaInOutRecord.put("userName",userMap.get("userName"));
					areaInOutRecord.put("duty",userMap.get("duty"));
				}
			}
		}
		return pageInfo;
	}
}

ebc-sea-platform/src/main/java/com/ai/ipu/server/service/interfaces/AreaInOutRecordService.java

@@ -1,6 +1,7 @@
package com.ai.ipu.server.service.interfaces;
import com.ai.ipu.data.JMap;
import com.github.pagehelper.PageInfo;
/**
 * 考勤管理
@@ -18,7 +19,7 @@ public interface AreaInOutRecordService {
	 * @return
	 * @throws Exception
	 */
	JMap queryPageAttendanceCount(JMap params, int pageNum, int pageSize) throws Exception;
	PageInfo queryPageAttendanceCount(JMap params, int pageNum, int pageSize) throws Exception;
	/**
	 * 分页查询考勤详细日志
@@ -40,5 +41,5 @@ public interface AreaInOutRecordService {
	 * @return
	 * @throws Exception
	 */
	JMap queryPageAreaInOutRecord(JMap params, int pageNum, int pageSize) throws Exception;
	PageInfo queryPageAreaInOutRecord(JMap params, int pageNum, int pageSize) throws Exception;
}

ebc-sea-platform/src/main/java/com/ai/ipu/server/util/EbcConstant.java

@@ -74,5 +74,14 @@ public class EbcConstant {
	
	//人员状态：SOS(自动)
	public static final String location_status_autosos_ZH="落水告警";
	//考勤查询日
	public static final String  AREA_IN_OUT_RECORD_DAY="day";
	//考勤查询周
	public static final String AREA_IN_OUT_RECORD_WEEK="week";
	//考勤查询月
	public static final String AREA_IN_OUT_RECORD_MONTH="month";
	
}

ebc-sea-platform/src/main/resources/sql/ipu/AreaInOutRecordDao.xml

@@ -57,4 +57,71 @@
		]]>
	</sql>
	<sql name="queryPageDayAttendanceCount">
		<![CDATA[
		<select id="queryPageDayAttendanceCount" resultType="java.util.Map">
	        SELECT
				EMPLOYEE_ID,
				min(cast( IN_DATE AS time )) IN_DATE
			FROM
				LR_AREA_IN_OUT_RECORD
			WHERE
				DATE_FORMAT( IN_DATE, '%Y-%m-%d' )= DATE_FORMAT( #{ currentDate }, '%Y-%m-%d' )
				AND EMPLOYEE_ID IN  ( 0, 1,2,3,4,5 )
				AND RECORD_LOCATION = '作业区域'
			GROUP BY
				EMPLOYEE_ID
		</select>
		]]>
	</sql>
	<sql name="queryPageWeekAttendanceCount">
		<![CDATA[
		<select id="queryPageWeekAttendanceCount" resultType="java.util.Map">
	        SELECT
				EMPLOYEE_ID,
				count( a.date ) gateDays
			FROM
				(
				SELECT DISTINCT
					EMPLOYEE_ID,
					DATE_FORMAT( IN_DATE, '%Y-%m-%d' ) date
				FROM
					LR_AREA_IN_OUT_RECORD
				WHERE
					DATE_SUB( DATE_FORMAT( #{ currentDate }, '%Y-%m-%d' ), INTERVAL 7 DAY ) < DATE_FORMAT( IN_DATE, '%Y-%m-%d' )
					AND DATE_FORMAT( IN_DATE, '%Y-%m-%d' )<= DATE_FORMAT( #{ currentDate }, '%Y-%m-%d' )
					AND EMPLOYEE_ID IN ( 1, 2, 3 ,4,5)
					AND RECORD_LOCATION = '作业区域'
				) a
			GROUP BY
				EMPLOYEE_ID
		</select>
		]]>
	</sql>
	<sql name="queryPageMonthAttendanceCount">
		<![CDATA[
		<select id="queryPageMonthAttendanceCount" resultType="java.util.Map">
	        SELECT
				EMPLOYEE_ID,
				count( a.date ) gateDays
			FROM
				(
				SELECT DISTINCT
					EMPLOYEE_ID,
					DATE_FORMAT( IN_DATE, '%Y-%m-%d' ) date
				FROM
					LR_AREA_IN_OUT_RECORD
				WHERE
					DATE_FORMAT( IN_DATE, '%Y-%m' ) = DATE_FORMAT( STR_TO_DATE( #{ currentDate }, '%Y-%m' ), '%Y-%m' )
					AND EMPLOYEE_ID IN ( 1, 2, 3, 4, 5 )
					AND RECORD_LOCATION = '作业区域'
				) a
			GROUP BY
				EMPLOYEE_ID
		</select>
		]]>
	</sql>
</sqls>