package com.product.administration.service;
|
|
import java.text.SimpleDateFormat;
|
import java.util.Calendar;
|
import java.util.Date;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.product.administration.config.CmnConst;
|
import com.product.administration.util.WorkDayUtil;
|
import com.product.common.lang.StringUtils;
|
import com.product.core.dao.BaseDao;
|
import com.product.core.entity.DataTableEntity;
|
import com.product.core.entity.FieldSetEntity;
|
import com.product.core.permission.PermissionService;
|
import com.product.core.service.support.AbstractBaseService;
|
import com.product.core.service.support.QueryFilterService;
|
import com.product.core.spring.context.SpringMVCContextHolder;
|
import com.product.util.BaseUtil;
|
|
@Component
|
public class WorkAttendanceService extends AbstractBaseService {
|
|
@Autowired
|
BaseDao baseDao;
|
@Autowired
|
PermissionService permissionService;
|
@Autowired
|
QueryFilterService queryFilterService;
|
|
/**
|
* 考勤信息列表
|
*
|
* @param fse
|
* @return
|
*/
|
public DataTableEntity listAttendanceInfo(FieldSetEntity fse) {
|
String queryFilter = null;
|
if (!BaseUtil.dataTableIsEmpty(fse.getSubDataTable("systemSeniorQueryString"))) {
|
queryFilter = queryFilterService.getQueryFilter(fse);
|
}
|
//String dataFilter = permissionService.getDataFilter(CmnConst.ORG_LEVEL_UUID);
|
//周杰 2022-02-17 条件由ORG_LEVEL_UUID改为CREATE_BY
|
String dataFilter = permissionService.getDataFilter(fse.getTableName(),CmnConst.CREATED_BY);
|
if (!StringUtils.isEmpty(dataFilter)) {
|
if (StringUtils.isEmpty(queryFilter)) {
|
queryFilter = dataFilter;
|
} else {
|
queryFilter += " AND " + dataFilter;
|
}
|
}
|
|
DataTableEntity dt = baseDao.listTable(CmnConst.PRODUCT_OA_ATTENDANCE_INFO, queryFilter, null, null, null,
|
fse.getInteger(CmnConst.PAGESIZE), fse.getInteger(CmnConst.CPAGE));
|
baseDao.loadPromptData(dt);
|
return dt;
|
}
|
|
/**
|
* 考勤信息详情
|
*
|
* @param uuid
|
* @return
|
*/
|
public FieldSetEntity findAttendanceInfo(String uuid) {
|
return baseDao.getFieldSetEntity(CmnConst.PRODUCT_OA_ATTENDANCE_INFO, uuid, false);
|
}
|
|
/**
|
* 考勤信息保存
|
*
|
* @param fse
|
* @return
|
*/
|
public String saveAttendanceInfo(FieldSetEntity fse) {
|
if (StringUtils.isEmpty(fse.getUUID())) {
|
return baseDao.add(fse);
|
} else {
|
fse.setValue(CmnConst.UPDATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
|
fse.setValue(CmnConst.UPDATED_UTC_DATETIME, new Date());
|
baseDao.update(fse);
|
return fse.getUUID();
|
}
|
}
|
|
/**
|
* 考勤信息删除
|
*
|
* @param uuid
|
* @return
|
*/
|
public boolean deleteAttendanceInfo(String uuid) {
|
return baseDao.delete(CmnConst.PRODUCT_OA_ATTENDANCE_INFO, "uuid=?", new Object[] { uuid });
|
}
|
|
/**
|
* 获取员工工作信息
|
* @param user_id
|
* @param yearAndMonth
|
* @return
|
*/
|
public JSONObject getStaffWorkInfo(Integer user_id, String yearAndMonth) {
|
//信息汇总
|
JSONObject jsonWorkInfo=new JSONObject();
|
|
//获取年月日
|
if (yearAndMonth.length() > 10) {
|
yearAndMonth = yearAndMonth.substring(0, 10);
|
}
|
|
//获取当月工作时长
|
int totalHours=WorkDayUtil.queryMonthDay(yearAndMonth) * 7;
|
jsonWorkInfo.put("should_arrived_hours", WorkDayUtil.queryMonthDay(yearAndMonth) * 7); //该月应工作小时
|
|
//获取请假信息
|
Integer [] leaveHours = getLeaveHours(user_id, yearAndMonth);
|
jsonWorkInfo.put("casual_leave_hours", leaveHours[1] * 7); //事假时长
|
jsonWorkInfo.put("sick_leave_hours", leaveHours[2] * 7); //病假时长
|
jsonWorkInfo.put("paid_leave_hours", leaveHours[3] * 7); //带薪休假时长
|
jsonWorkInfo.put("have_arrived_hours", totalHours-leaveHours[0] * 7); //该月实工作小时
|
|
//获取出差信息
|
int tripHours = getBusinessTripHours(user_id, yearAndMonth);
|
jsonWorkInfo.put("business_trip_hours", tripHours * 7); //出差时长
|
|
return jsonWorkInfo;
|
}
|
|
/**
|
* 获取请假时长
|
* @param user_id
|
* @param yearAndMonth
|
* @return
|
*/
|
public Integer[] getLeaveHours(Integer user_id, String yearAndMonth) {
|
StringBuilder sb=new StringBuilder();
|
sb.append(" SELECT ");
|
sb.append(" SUM(day) t0, ");
|
sb.append(" SUM(CASE WHEN leave_type=1 THEN day ELSE 0 END ) t1, ");
|
sb.append(" SUM(CASE WHEN leave_type=2 THEN day ELSE 0 END ) t2, ");
|
sb.append(" SUM(CASE WHEN leave_type <>1 and leave_type<>2 THEN day ELSE 0 END ) t3 ");
|
sb.append(" FROM product_oa_ask_for_leave ");
|
sb.append(" WHERE flow_flag=2 ");
|
sb.append(" AND DATE_FORMAT(start_time,'%Y-%m') =? ");
|
sb.append(" AND created_by=? ");
|
FieldSetEntity fse=baseDao.getFieldSetEntityBySQL(sb.toString(), new Object[] {yearAndMonth.substring(0, 7), user_id}, false);
|
return new Integer[] {fse.getInteger("t0")==null?0:fse.getInteger("t0"), fse.getInteger("t1")==null?0:fse.getInteger("t1"), fse.getInteger("t2")==null?0:fse.getInteger("t2"), fse.getInteger("t3")==null?0:fse.getInteger("t3")};
|
}
|
|
/**
|
* 获取出差时长
|
* @param user_id
|
* @param yearAndMonth
|
* @return
|
*/
|
public Integer getBusinessTripHours(Integer user_id, String yearAndMonth) {
|
String sql="SELECT SUM(total_days)total FROM product_oa_business_trip WHERE flow_flag=2 AND DATE_FORMAT(business_start_time,'%Y-%m') = ? AND applicant=?";
|
FieldSetEntity fse=baseDao.getFieldSetEntityBySQL(sql, new Object[] {yearAndMonth.substring(0, 7), user_id}, false);
|
return fse.getInteger("total")==null?0:fse.getInteger("total");
|
}
|
}
|
