|
|
@@ -0,0 +1,659 @@
|
|
|
+package com.malk.fengkaili.service.impl;
|
|
|
+
|
|
|
+import cn.hutool.core.util.ObjectUtil;
|
|
|
+import com.malk.fengkaili.repository.dao.FKLDdContactDao;
|
|
|
+import com.malk.fengkaili.repository.entity.FKLDdContactPo;
|
|
|
+import com.malk.fengkaili.service.FKLService;
|
|
|
+import com.malk.service.dingtalk.DDClient;
|
|
|
+import com.malk.service.dingtalk.DDClient_Attendance;
|
|
|
+import com.malk.service.dingtalk.DDClient_Contacts;
|
|
|
+import com.malk.service.dingtalk.DDService;
|
|
|
+import com.malk.utils.UtilDateTime;
|
|
|
+import com.malk.utils.UtilList;
|
|
|
+import com.malk.utils.UtilMap;
|
|
|
+import com.malk.utils.UtilNumber;
|
|
|
+import lombok.extern.slf4j.Slf4j;
|
|
|
+import org.apache.commons.lang3.ObjectUtils;
|
|
|
+import org.apache.commons.lang3.StringUtils;
|
|
|
+import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+import org.springframework.data.domain.Page;
|
|
|
+import org.springframework.data.domain.PageRequest;
|
|
|
+import org.springframework.data.domain.Pageable;
|
|
|
+import org.springframework.data.domain.Sort;
|
|
|
+import org.springframework.data.jpa.domain.Specification;
|
|
|
+import org.springframework.stereotype.Service;
|
|
|
+
|
|
|
+import javax.persistence.criteria.Predicate;
|
|
|
+import java.time.Duration;
|
|
|
+import java.time.LocalDate;
|
|
|
+import java.time.LocalDateTime;
|
|
|
+import java.util.*;
|
|
|
+import java.util.concurrent.atomic.AtomicReference;
|
|
|
+import java.util.stream.Collectors;
|
|
|
+
|
|
|
+@Service
|
|
|
+@Slf4j
|
|
|
+public class FKLImplService implements FKLService {
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private DDClient ddClient;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private DDClient_Contacts ddClient_contacts;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private FKLDdContactDao fklDdContactDao;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private DDClient_Attendance ddClient_attendance;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private DDService ddService;
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 同步用户信息
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public void syncUserInfo() {
|
|
|
+ // 匹配部门信息, 全量
|
|
|
+ ddClient_contacts.getDepartmentId_all(ddClient.getAccessToken(), true).forEach(deptId -> {
|
|
|
+ // String deptName = ddClient_contacts.getDepartmentInfo(ddClient.getAccessToken(), deptId).getDefault("name").toString();
|
|
|
+ List<String> userIds = ddClient_contacts.listDepartmentUserId(ddClient.getAccessToken(), deptId);
|
|
|
+ if (userIds.size() > 0) {
|
|
|
+ // 获取部门层级拼接
|
|
|
+ String deptName = ddService.getUserDepartmentHierarchyJoin(ddClient.getAccessToken(), userIds.get(0), "-");
|
|
|
+ for (String userId : userIds) {
|
|
|
+ // 牧语
|
|
|
+ if ("0953580166811961653".equals(userId)) {
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ Map userinfo = ddClient_contacts.getUserInfoById(ddClient.getAccessToken(), userId);
|
|
|
+ // 员工信息表, 落库
|
|
|
+ FKLDdContactPo contactPo = FKLDdContactPo.builder()
|
|
|
+ .userId(userId)
|
|
|
+ .name(UtilMap.getString(userinfo, "name"))
|
|
|
+ .jobNumber(UtilMap.getString(userinfo, "job_number"))
|
|
|
+ .deptId(deptId)
|
|
|
+ .deptName(deptName)
|
|
|
+ .mobile(UtilMap.getString(userinfo, "mobile"))
|
|
|
+ .hiredDate(userinfo.containsKey("hired_date") ? new Date(UtilMap.getLong(userinfo, "hired_date")) : null)
|
|
|
+ .remark(UtilMap.getString(userinfo, "remark")) // 无需打卡 标记
|
|
|
+ .build();
|
|
|
+ FKLDdContactPo po = fklDdContactDao.findByUserId(userId);
|
|
|
+ // 员工更新, 组织架构调整
|
|
|
+ if (ObjectUtil.isNotNull(po)) {
|
|
|
+ contactPo.id = po.id;
|
|
|
+ contactPo.setCreateTime(po.getCreateTime());
|
|
|
+ }
|
|
|
+ fklDdContactDao.save(contactPo);
|
|
|
+ log.info("同步人员, {}", contactPo);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ });
|
|
|
+
|
|
|
+ // 同步离职人员, 标记离职日期
|
|
|
+ Date start = UtilDateTime.convertToDateFromLocalDateTime(UtilDateTime.firstDayOfLastMonth(LocalDateTime.now()));
|
|
|
+ ddClient_contacts.getLeaveEmployeeRecords(ddClient.getAccessToken(), start, null).forEach(item -> {
|
|
|
+ log.info("同步#离职人员, {}", item);
|
|
|
+ fklDdContactDao.updateLeaveDate(item.get("userId"), UtilDateTime.parse(item.get("leaveTime"), "yyyy-MM-dd'T'HH:mm:ss"));
|
|
|
+ });
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 查询用户列表
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public Page<FKLDdContactPo> queryUserInfos(int page, int size, String name, List<Long> deptIds, Date sDate) {
|
|
|
+
|
|
|
+ // 分页 & 排序
|
|
|
+ Sort sort = Sort.by(Sort.Direction.ASC, "deptName");
|
|
|
+ Pageable pageable = PageRequest.of(page - 1, size, sort);
|
|
|
+
|
|
|
+ // 查询条件: 姓名, 所属部门
|
|
|
+ Specification<FKLDdContactPo> specification = (root, criteriaQuery, criteriaBuilder) -> {
|
|
|
+ List<Predicate> predicateList = new ArrayList<>();
|
|
|
+ if (StringUtils.isNotBlank(name)) {
|
|
|
+ predicateList.add(criteriaBuilder.equal(root.get("name"), name));
|
|
|
+ }
|
|
|
+ if (UtilList.isNotEmpty(deptIds)) {
|
|
|
+ predicateList.add(criteriaBuilder.in(root.get("deptId")).value(deptIds));
|
|
|
+ }
|
|
|
+ // 2月前离职人员过滤 [or语法]
|
|
|
+ predicateList.add(criteriaBuilder.or(criteriaBuilder.isNull(root.get("leaveDate")), criteriaBuilder.greaterThan(root.get("leaveDate"), sDate)));
|
|
|
+ return criteriaBuilder.and(predicateList.toArray(new javax.persistence.criteria.Predicate[predicateList.size()]));
|
|
|
+ };
|
|
|
+ // 无数据时返回空列表
|
|
|
+ return fklDdContactDao.findAll(specification, pageable);
|
|
|
+ }
|
|
|
+
|
|
|
+ /// 累计月度汇总数字
|
|
|
+ private Object _reduceAttendance(Map column, String name, String keyList) {
|
|
|
+ Object value;
|
|
|
+ List<Map> vals = (List<Map>) column.get(keyList);
|
|
|
+ // 异常信息, 保留备注
|
|
|
+ if (name.equals("考勤结果")) {
|
|
|
+ List<String> tmps = new ArrayList<>(); // 同行出差会重复, 考勤结果要过滤
|
|
|
+ vals.stream().forEach(item -> {
|
|
|
+ // prd 异常补录当前日期
|
|
|
+ String content = UtilMap.getString(item, "value");
|
|
|
+ String svalue = content;
|
|
|
+ if (!content.contains("-")) {
|
|
|
+ content += UtilMap.getString(item, "date").split(" ")[0];
|
|
|
+ }
|
|
|
+ content = content.replace("未打卡,", "").replace("正常,", "").replace("休息并打卡,", "").replace("休息,", "");
|
|
|
+ // 休息有外出/出差 , 正常带其他状态情况 || 超过90未打卡静默用户 || 被添加为协同人后, 钉钉也会记录一条出差
|
|
|
+ if (content.contains("出差")) {
|
|
|
+ // 兼容出差中还有其他考勤结果, 以及还存在跨天的情况下
|
|
|
+ List<String> arr = new ArrayList<>();
|
|
|
+ for (String t : content.split(",")) {
|
|
|
+ if (!arr.contains(t) && !tmps.stream().filter(s -> s.contains(t)).findAny().isPresent()) {
|
|
|
+ arr.add(t);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (arr.size() == 0) {
|
|
|
+ return;
|
|
|
+ }
|
|
|
+ content = String.join(",", arr);
|
|
|
+ }
|
|
|
+ boolean isFuture = UtilDateTime.parseLocalDateTime(UtilMap.getString(item, "date")).isAfter(LocalDateTime.now());
|
|
|
+ if (!isFuture && StringUtils.isNotBlank(svalue) && !tmps.contains(content) && !content.contains("休息") && !svalue.equals("正常") && !svalue.equals("未打卡")) {
|
|
|
+ tmps.add(content);
|
|
|
+ }
|
|
|
+ });
|
|
|
+ value = String.join("; ", tmps);
|
|
|
+ } else {
|
|
|
+ value = vals.stream().map(item -> UtilMap.getFloat(item, "value")).reduce(0.f, (a, b) -> {
|
|
|
+ // ddExt: 出差默认是可重复提交, 且若被添加为协同人, 也会多累计一天出差 [但工作时长是正常]. 可开启不允许重复提交, 同样的同行人会冲突
|
|
|
+ if (name.equals("出差时长") && b > 1.0f) {
|
|
|
+ b = 1.0f;
|
|
|
+ }
|
|
|
+ return a + b;
|
|
|
+ });
|
|
|
+ }
|
|
|
+ return value;
|
|
|
+ }
|
|
|
+
|
|
|
+ /// 缓存考勤自定义列
|
|
|
+ private List<Map> columns;
|
|
|
+
|
|
|
+ List<Map> getColumns() {
|
|
|
+ if (UtilList.isEmpty(columns)) {
|
|
|
+ columns = ddClient_attendance.getAttColumns(ddClient.getAccessToken());
|
|
|
+ }
|
|
|
+ return columns;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 考勤数据统计
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public List<Map> queryAttendanceList(String start, String end, List<FKLDdContactPo> userInfos, List<String> days) {
|
|
|
+
|
|
|
+ // 考勤列, 假期信息定义
|
|
|
+ List<String> columnNames = Arrays.asList("旷工天数", "出勤天数", "工作时长", "考勤结果", "出差时长", "迟到次数", "早退次数", "下班缺卡次数", "上班缺卡次数", "外出时长", "休息日加班", "工作日加班", "节假日加班", "严重迟到次数", "应出勤天数");
|
|
|
+ AtomicReference<String> fileId_attendance_days = new AtomicReference<>(""); // 出勤天数字段id
|
|
|
+ AtomicReference<String> fileId_attendance_result = new AtomicReference<>(""); // 考勤结果字段id
|
|
|
+ List<Map> columns = getColumns();
|
|
|
+ Map columnIds = new HashMap();
|
|
|
+ // 假期单独返回, 钉钉产品规则
|
|
|
+ List<String> leaveNames = columns.stream().filter(column -> {
|
|
|
+ if ("出勤天数".equals(column.get("name"))) {
|
|
|
+ fileId_attendance_days.set(String.valueOf(column.get("id")));
|
|
|
+ }
|
|
|
+ if ("考勤结果".equals(column.get("name"))) {
|
|
|
+ fileId_attendance_result.set(String.valueOf(column.get("id")));
|
|
|
+ }
|
|
|
+ // 列类型储存id映射名称为map, 考勤数据返回仅保留列id
|
|
|
+ if (columnNames.contains(column.get("name"))) {
|
|
|
+ columnIds.put(column.get("id").toString(), column.get("name"));
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+ return column.get("alias").equals("leave_");
|
|
|
+ }
|
|
|
+ ).map(column -> String.valueOf(column.get("name"))).collect(Collectors.toList());
|
|
|
+
|
|
|
+ // 考勤汇总数据
|
|
|
+ List<Map> attendanceInfos = new ArrayList<>();
|
|
|
+ List<String> queryIds = new ArrayList<>(columnIds.keySet()); // 考勤列定义
|
|
|
+ userInfos.forEach(po -> {
|
|
|
+ Map attendanceInfo = UtilMap.map("员工ID, 员工姓名, 员工工号, 所属部门, 考勤状态", po.getUserId(), po.getName(), po.getJobNumber(), po.getDeptName(), po.getRemark());
|
|
|
+ // 累计月度汇总
|
|
|
+ List<Map> attendanceList = ddClient_attendance.getAttColumnVal(ddClient.getAccessToken(), po.getUserId(), queryIds, start, end);
|
|
|
+ attendanceList.forEach(column -> {
|
|
|
+ String id = ((Map) column.get("column_vo")).get("id").toString();
|
|
|
+ String name = String.valueOf(columnIds.get(id)); // 接口仅返回列id, 通过map映射
|
|
|
+ attendanceInfo.put(name, _reduceAttendance(column, name, "column_vals"));
|
|
|
+ // prd [sheet2]每天考勤结果统计
|
|
|
+ if (!Objects.isNull(days) && name.equals("考勤结果")) {
|
|
|
+ List<Map> vals = (List<Map>) column.get("column_vals");
|
|
|
+ int index = 0;
|
|
|
+ for (Map<String, String> val : vals) {
|
|
|
+ index++;
|
|
|
+ String date = val.get("date").replace(" 00:00:00", "").replace(LocalDate.now().getYear() + "-", "");
|
|
|
+ String result = val.get("value").replace("休息并打卡,", "").replace("休息,", ""); // 休息有外出/出差;
|
|
|
+ // prd 5.27 人员到岗后, 未办理入职但已经有出差
|
|
|
+ if (result.contains("不在考勤组并打卡") && !result.equals("不在考勤组并打卡")) {
|
|
|
+ result = result.replace("不在考勤组并打卡,", "");
|
|
|
+ }
|
|
|
+ // prd 11.26 未排班并打卡 场景兼容
|
|
|
+ if (result.contains("未排班并打卡")) {
|
|
|
+ result = "";
|
|
|
+ }
|
|
|
+ log.info("人员明细, {} - {}, {}", date, po.getName(), val.get("value"));
|
|
|
+ String day_1 = "zc", day_2 = "zc", type = "zc"; // 异常类型
|
|
|
+ if (result.contains("休息") || result.contains("加班") || (val.get("value").contains("休息,") && (!result.contains("出差") && !result.contains("婚假") && !result.contains("产假")))) {
|
|
|
+ type = "公假"; // 包含休息, 休息加班打卡, 忽略跨休息日连续请假情况, prd 钉钉后台配置: 产假, 婚假按自然日
|
|
|
+ day_1 = type;
|
|
|
+ day_2 = type;
|
|
|
+ } else if (StringUtils.isBlank(result) || result.equals("不在考勤组并打卡")) {
|
|
|
+ if (StringUtils.isBlank(result)) {
|
|
|
+ type = "/"; // 新入职
|
|
|
+ } else {
|
|
|
+ type = "zc"; // 新入职
|
|
|
+ }
|
|
|
+ day_1 = type;
|
|
|
+ day_2 = type;
|
|
|
+ } else if (result.equals("正常") || (result.split(",").length == 2 && result.contains("外勤") && result.contains("补卡")) || result.equals("下班外勤") || result.equals("上班外勤") || result.equals("上班外勤,下班外勤")) {
|
|
|
+ // 包含补卡, 一次外勤补卡, 外勤考勤情况 [调休会被标识为考勤正常]
|
|
|
+ type = "zc";
|
|
|
+ day_1 = type;
|
|
|
+ day_2 = type;
|
|
|
+ }
|
|
|
+ // prd 250205 请假为半天模式, 全天计算有误
|
|
|
+// else if (result.contains("产假") || result.contains("陪产假") || result.contains("婚假") || result.contains("丧假") || result.contains("育儿假")) {
|
|
|
+// type = result.split("假")[0] + "假"; // 按天请假
|
|
|
+// day_1 = type;
|
|
|
+// day_2 = type;
|
|
|
+// }
|
|
|
+ else if (result.contains("旷工") || result.equals("未打卡")) {
|
|
|
+ type = "旷工"; // 兼容异常情况
|
|
|
+ day_1 = type;
|
|
|
+ day_2 = type;
|
|
|
+ } else if (result.contains("缺卡") && !result.contains("到")) {
|
|
|
+ // prd 8点上班, 8点后请假或外出都是缺卡记录
|
|
|
+ if (result.equals("上班缺卡")) {
|
|
|
+ type = "缺卡";
|
|
|
+ day_1 = type;
|
|
|
+ }
|
|
|
+ if (result.equals("下班缺卡")) {
|
|
|
+ // prd 离职操作是直接删除, 会有一次打卡, 符合标记为zc
|
|
|
+ if (ObjectUtil.isNotNull(po.getLeaveDate()) && date.equals(UtilDateTime.format(po.getLeaveDate(), "MM-dd"))) {
|
|
|
+ type = type.length() > 0 ? type : "zc";
|
|
|
+ day_2 = "zc";
|
|
|
+ } else {
|
|
|
+ type = "缺卡";
|
|
|
+ day_2 = type;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ } else if (result.split(",").length <= 2 && (result.contains("迟到") || result.contains("早退"))) {
|
|
|
+ // 兼容早退和迟到情况下, 还存在请假情况
|
|
|
+ if (result.contains("迟到") && !result.contains("补卡申请")) {
|
|
|
+ type = "迟到"; // 迟到状态标记
|
|
|
+ float exception_duration = Float.valueOf((result.split(",")[0].split("分钟")[0].replace("上班迟到", "").replace("上班严重迟到", "")));
|
|
|
+ if (exception_duration >= 180f) {
|
|
|
+ // 设置早退、迟到3小时以上则在表中记录为早退、迟到. 保留迟到次数记录
|
|
|
+ day_1 = "迟到";
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (result.contains("早退") && !result.contains("补卡申请")) {
|
|
|
+ type += type.length() > 0 ? " 早退" : "早退"; // 早退状态标记
|
|
|
+ float exception_duration = Float.valueOf((result.split(",")[result.split(",").length - 1].split("分钟")[0].replace("下班早退", "")));
|
|
|
+ if (exception_duration >= 180f) {
|
|
|
+ // 设置早退、迟到3小时以上则在表中记录为早退、迟到. 保留迟到次数记录
|
|
|
+ day_2 = "早退";
|
|
|
+ }
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ type = "";
|
|
|
+ day_1 = "";
|
|
|
+ day_2 = "";
|
|
|
+ // 请假 & 出差
|
|
|
+ for (String status : result.split(",")) {
|
|
|
+ /// 过滤异常情况 & 未打卡判定为status, 非result & 外勤又外出情况
|
|
|
+ if (status.contains("补卡申请") || status.contains("正常") || status.equals("未打卡") || status.contains("外勤")) {
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ if (status.contains("缺卡") || status.equals("未打卡") || status.contains("迟到") || status.contains("早退")) {
|
|
|
+ if (status.equals("上班缺卡")) {
|
|
|
+ type = "缺卡";
|
|
|
+ day_1 = "缺卡";
|
|
|
+ }
|
|
|
+ if (status.equals("下班缺卡")) {
|
|
|
+ type += "缺卡";
|
|
|
+ day_2 = "缺卡";
|
|
|
+ }
|
|
|
+ // 兼容早退和迟到情况下, 还存在请假情况
|
|
|
+ if (status.contains("迟到") || status.contains("早退")) {
|
|
|
+ if (status.contains("迟到")) {
|
|
|
+ type = "迟到"; // 迟到状态标记
|
|
|
+ float exception_duration = Float.valueOf((status.split(",")[0].split("分钟")[0].replace("上班迟到", "").replace("上班严重迟到", "")));
|
|
|
+ if (exception_duration >= 180f) {
|
|
|
+ // 设置早退、迟到3小时以上则在表中记录为早退、迟到. 保留迟到次数记录
|
|
|
+ day_1 = "迟到";
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (status.contains("早退")) {
|
|
|
+ type += type.length() > 0 ? " 早退" : "早退"; // 早退状态标记
|
|
|
+ float exception_duration = Float.valueOf((status.split(",")[0].split("分钟")[0].replace("下班早退", "")));
|
|
|
+ if (exception_duration >= 180f) {
|
|
|
+ // 设置早退、迟到3小时以上则在表中记录为早退、迟到. 保留迟到次数记录
|
|
|
+ day_2 = "早退";
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ /// 请假数据处理 [小时情况]
|
|
|
+ String tmp = status.contains("调休") ? "调休" : status.split("假")[0] + "假"; // 异常类型
|
|
|
+ if (status.contains("外出") || Arrays.asList("调休", "哺乳假", "事假").contains(tmp)) {
|
|
|
+ if (result.contains("外出")) {
|
|
|
+ tmp = "外出";
|
|
|
+ }
|
|
|
+ // 外出, 调休, 事假, 哺乳假: 兼容9点申请, 排班是8点情况, 不记录缺卡
|
|
|
+ if (day_1.equals("缺卡") && result.contains("09:00")) {
|
|
|
+ day_1 = "";
|
|
|
+ }
|
|
|
+ // prd 请假3小时以内标记为zc, 按照小时请假 [调休, 哺乳假, 事假];
|
|
|
+ String[] arr = status.split(" ");
|
|
|
+ float hour = Float.valueOf((arr[arr.length - 1].replace("小时", "")));
|
|
|
+ if (hour < 3.0f && !tmp.equals("外出")) { // <3 同时9点申请标识zc, 避免不能统计外出情况
|
|
|
+ continue;
|
|
|
+ } else {
|
|
|
+ // prd 请假3小时以内标记为zc, 区分上午与下午, 午休从12-13分割
|
|
|
+ String sStart = status.split(" ")[1].split("到")[0].replace(":", "");
|
|
|
+ type = type.length() > 0 && !tmp.equals(type) ? type + " " + tmp : tmp; // 兼容一天提交两次外出情况
|
|
|
+ // 兼容跨天请假场景
|
|
|
+ boolean sDate = date.equals(status.split(" ")[0].replace(tmp, ""));
|
|
|
+ boolean eDate = date.equals(status.split(" ")[1].split("到")[1]);
|
|
|
+ if (Integer.valueOf(sStart) >= 1200 && sDate) {
|
|
|
+ day_2 = tmp;
|
|
|
+ } else {
|
|
|
+ String sEnd = status.split(" ")[2].replace(":", "");
|
|
|
+ if (Integer.valueOf(sStart) < 800 || !sDate) {
|
|
|
+ sStart = "0800";
|
|
|
+ }
|
|
|
+ float hourZao = Duration.between(UtilDateTime.parseLocal(sStart, "HHmm"), UtilDateTime.parseLocal("1200", "HHmm")).toMinutes() / 60f;
|
|
|
+ if (hourZao >= 3.0f || (hourZao > 0f && tmp.equals("外出"))) {
|
|
|
+ day_1 += day_1.length() > 0 ? " " + tmp : tmp;
|
|
|
+ }
|
|
|
+ if (Integer.valueOf(sEnd) > 1700 || !eDate) {
|
|
|
+ sEnd = "1700";
|
|
|
+ }
|
|
|
+ float hourWan = Duration.between(UtilDateTime.parseLocal("1300", "HHmm"), UtilDateTime.parseLocal(sEnd, "HHmm")).toMinutes() / 60f;
|
|
|
+ if (hourWan > 3.0f || (hourWan > 0f && tmp.equals("外出"))) {
|
|
|
+ day_2 += day_2.length() > 0 ? " " + tmp : tmp;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ } else if (status.contains("出差")) {
|
|
|
+ // 出差兼容, 半天, 外出, 请假等情况
|
|
|
+ type += type.length() > 0 ? (type.contains("出差") ? "" : " 出差") : "出差";
|
|
|
+ // 半天出差场景以及被添加为协同人后, 钉钉也会记录一条出差; 均循环进行处理, 即时出差覆盖即当天多次出差也可兼容
|
|
|
+ int sStart = Integer.valueOf(status.split(" ")[1].split("到")[0].replace(":", ""));
|
|
|
+ int sEnd = Integer.valueOf(status.split(" ")[2].replace(":", ""));
|
|
|
+ if (val.get("value").contains("休息")) {
|
|
|
+ day_1 = day_1.equals("") ? "公假" : day_1;
|
|
|
+ day_2 = day_2.equals("") ? "公假" : day_2;
|
|
|
+ }
|
|
|
+ if (sStart >= 1200 && date.equals(status.split(" ")[0].replace("出差", ""))) {
|
|
|
+ // 跨天: 日期相等, 且下午时间
|
|
|
+ day_2 = "出差";
|
|
|
+ } else if (sEnd <= 1300 && date.equals(status.split(" ")[1].split("到")[1])) {
|
|
|
+ // 跨天: 日期相等, 且上午时间
|
|
|
+ day_1 = "出差";
|
|
|
+ } else {
|
|
|
+ day_1 = "出差";
|
|
|
+ day_2 = "出差";
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ /// 非小时假, 请假数据处理 [半天情况]
|
|
|
+ String[] arr = status.split(" ");
|
|
|
+ int sstart = Integer.valueOf(status.split(" ")[1].split("到")[0].replace(":", ""));
|
|
|
+ float day = Float.valueOf((arr[arr.length - 1].replace("天", "")));
|
|
|
+ // prd 250205 部分返回异常数据日期含有年, 需去除
|
|
|
+ if (date.split("-").length > 2) {
|
|
|
+ date = date.split("-")[1] + "-" + date.split("-")[2];
|
|
|
+ }
|
|
|
+ boolean sDate = date.equals(status.split(" ")[0].replace(tmp, ""));
|
|
|
+ boolean eDate = date.equals(status.split(" ")[1].split("到")[1]);
|
|
|
+ type = tmp;
|
|
|
+ // 兼容跨天请假场景
|
|
|
+ int sEnd = Integer.valueOf(status.split(" ")[2].replace(":", ""));
|
|
|
+ if ((day >= 1.0f && ((sDate && eDate) || (sDate & sstart <= 800) || (eDate && sEnd >= 1700))) || (!sDate && !eDate)) {
|
|
|
+ day_1 = type;
|
|
|
+ day_2 = type;
|
|
|
+ } else {
|
|
|
+ if (sEnd >= 1700) {
|
|
|
+ day_2 = type;
|
|
|
+ } else {
|
|
|
+ day_1 = type;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ // prd 9/29 存在请假半天, 早退或迟到情况, 3小时以上才算次数 [兼容早退和迟到情况下, 还存在请假情况]
|
|
|
+ if (type.contains(",")) {
|
|
|
+ for (String tmp : type.split(",")) {
|
|
|
+ if (tmp.contains("迟到") || tmp.contains("早退")) {
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ type = tmp;
|
|
|
+ day_1 = tmp;
|
|
|
+ day_2 = tmp;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ // 日期动态列头
|
|
|
+ if (!days.contains(date)) {
|
|
|
+ days.add(date);
|
|
|
+ }
|
|
|
+ attendanceInfo.put(date, type.length() == 0 ? "zc" : type);
|
|
|
+ attendanceInfo.put("day" + index + "_1", day_1.length() == 0 ? "zc" : day_1);
|
|
|
+ attendanceInfo.put("day" + index + "_2", day_2.length() == 0 ? "zc" : day_2);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ });
|
|
|
+ // 累计假期数据
|
|
|
+ float leave_duration = 0f; // 法定假期调整时长: 分钟
|
|
|
+ float leave_all = 0f; // 请假总时长: 天 [屏蔽3小时以内] - 新, 仅事假扣除出勤, 通过字段配置解决
|
|
|
+ for (Map column : ddClient_attendance.getLeaveTimeByNames(ddClient.getAccessToken(), po.getUserId(), leaveNames, start, end)) {
|
|
|
+ String name = ((Map) column.get("columnvo")).get("name").toString(); // 接口返回列名称
|
|
|
+ float value = (Float) _reduceAttendance(column, name, "columnvals");
|
|
|
+ // prd 法定假期[除病假、事件、调休、产假外]请假时长 [调休, 事假, 哺乳假为小时, 其余半天为最小单位]
|
|
|
+ if (!Arrays.asList("病假", "事假", "调休", "产假").contains(name)) {
|
|
|
+ if (name.equals("哺乳假")) {
|
|
|
+ leave_duration += value * 60f;
|
|
|
+ } else {
|
|
|
+ leave_duration += value * 60f * 8f;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ // prd 病假,产假,事假扣除出勤天数. 因事假按照小时请假, 3小时内记录为出勤, 3-4小时为半天, 4小时以上记录为一天, 因此钉钉后台未设置自动扣减
|
|
|
+ if (Arrays.asList("病假", "产假", "事假").contains(name)) {
|
|
|
+ if (name.equals("事假")) {
|
|
|
+ // 系统已自动过滤, 午休时间 [跨天场景]
|
|
|
+ if (value > 8f) {
|
|
|
+ leave_all += Math.floor(value / 8f);
|
|
|
+ }
|
|
|
+ float hours = value % 8;
|
|
|
+ if (hours > 0f) {
|
|
|
+ // prd 1. 3小时以下不扣除; 2. 大于等于3,小于6为半天; 3. 大于等于6为1天
|
|
|
+ if (hours >= 6.0f) {
|
|
|
+ leave_all += 1.0f;
|
|
|
+ } else if (hours >= 3f) {
|
|
|
+ leave_all += 0.5f;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ leave_all += value;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ attendanceInfo.put(name, value);
|
|
|
+ }
|
|
|
+ // 数据处理, 请假折算天
|
|
|
+ float overTime = UtilMap.getFloat(attendanceInfo, "节假日加班") + UtilMap.getFloat(attendanceInfo, "节假日加班") + UtilMap.getFloat(attendanceInfo, "节假日加班");
|
|
|
+ attendanceInfo.put("加班总时长", UtilNumber.formatPrecisionValue(overTime));
|
|
|
+ attendanceInfo.put("事假天", UtilNumber.formatPrecisionValue(UtilMap.getFloat(attendanceInfo, "事假") / 8f));
|
|
|
+ attendanceInfo.put("哺乳假天", UtilNumber.formatPrecisionValue(UtilMap.getFloat(attendanceInfo, "哺乳假") / 8f));
|
|
|
+ attendanceInfo.put("调休天", UtilNumber.formatPrecisionValue(UtilMap.getFloat(attendanceInfo, "调休") / 8f));
|
|
|
+ // prd 标记人离职时间, 提示异常考勤
|
|
|
+ float exception_duration = 0f;
|
|
|
+ if (ObjectUtils.isNotEmpty(po.getHiredDate()) && UtilDateTime.beforeAndEqual(UtilDateTime.parseDateTime(start), po.getHiredDate()) && UtilDateTime.afterAndEqual(UtilDateTime.parseDateTime(end), po.getHiredDate())) {
|
|
|
+ Optional optional = Arrays.stream(attendanceInfo.get("考勤结果").toString().split("; ")).filter(item -> item.contains("迟到") && item.contains(UtilDateTime.formatDate(po.getHiredDate()))).findAny();
|
|
|
+ if (optional.isPresent()) {
|
|
|
+ exception_duration = Float.valueOf((optional.get().toString().split("分钟")[0].replace("上班迟到", "").replace("上班严重迟到", "")));
|
|
|
+ attendanceInfo.put("迟到次数", UtilNumber.formatPrecisionValue(UtilMap.getFloat(attendanceInfo, "迟到次数") - 1));
|
|
|
+ }
|
|
|
+ attendanceInfo.put("考勤结果", "入职日期" + UtilDateTime.formatDate(po.getHiredDate()) + "; " + attendanceInfo.get("考勤结果"));
|
|
|
+ }
|
|
|
+ attendanceInfo.put("缺卡次数", UtilNumber.formatPrecisionValue(UtilMap.getFloat(attendanceInfo, "上班缺卡次数") + UtilMap.getFloat(attendanceInfo, "下班缺卡次数")));
|
|
|
+ attendanceInfo.put("出勤天数_sys", attendanceInfo.get("出勤天数")); // prd 离职1号计算, 请假扣除, 部分员工旷工算出勤, 扣除休息打卡出勤
|
|
|
+ if (ObjectUtils.isNotEmpty(po.getLeaveDate()) && UtilDateTime.parseDateTime(start).before(po.getLeaveDate()) && UtilDateTime.parseDateTime(end).after(po.getLeaveDate())) {
|
|
|
+ // prd 离职员工出勤天数是否可以只记录员工离职当月1号
|
|
|
+ Optional option = attendanceList.stream().filter(item -> {
|
|
|
+ /// 线程安全, 对象获取值
|
|
|
+ String id = (((Map) item.get("column_vo"))).get("id").toString();
|
|
|
+ return fileId_attendance_days.get().equals(id);
|
|
|
+ }).findAny();
|
|
|
+ if (option.isPresent()) {
|
|
|
+ List<Map> dataList = (List<Map>) ((Map) option.get()).get("column_vals");
|
|
|
+ for (Map data : dataList) {
|
|
|
+ if (UtilDateTime.parseDate(data.get("date").toString()).getMonth() != UtilDateTime.parseDate(end).getMonth()) {
|
|
|
+ log.info("离职从1号计算出勤, {}, {}, {}, {}", po.getName(), data.get("date"), UtilMap.getFloat(attendanceInfo, "出勤天数_sys"), UtilMap.getFloat(data, "value"));
|
|
|
+ attendanceInfo.put("出勤天数_sys", UtilNumber.formatPrecisionValue(UtilMap.getFloat(attendanceInfo, "出勤天数_sys") - UtilMap.getFloat(data, "value")));
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ // 缺卡补录
|
|
|
+ Optional optional = Arrays.stream(attendanceInfo.get("考勤结果").toString().split("; ")).filter(item -> item.equals("下班缺卡" + UtilDateTime.formatDate(po.getLeaveDate()))).findAny();
|
|
|
+ if (optional.isPresent()) {
|
|
|
+ exception_duration = 480f;
|
|
|
+ attendanceInfo.put("缺卡次数", UtilNumber.formatPrecisionValue(UtilMap.getFloat(attendanceInfo, "缺卡次数") - 1));
|
|
|
+ }
|
|
|
+ attendanceInfo.put("考勤结果", "离职日期" + UtilDateTime.formatDate(po.getLeaveDate()) + "; " + attendanceInfo.get("考勤结果"));
|
|
|
+ }
|
|
|
+ attendanceInfo.put("缺卡调整时长", UtilNumber.formatPrecisionValue(exception_duration));
|
|
|
+ // prd 总时长 = 工作时长 + 法定假期[除病假、事件、调休、产假外]请假时长 + 调休时长 - 加班时长【出差、外出不考勤但需要计入总工时,以申请时长为准,但外出可能为不足一天情况, 当天还有打卡: 目前先取系统默认】
|
|
|
+ float system_duration = UtilMap.getFloat(attendanceInfo, "工作时长");
|
|
|
+ float tiaoxiu_duration = UtilMap.getFloat(attendanceInfo, "调休") * 60f;
|
|
|
+ attendanceInfo.put("调休时长", UtilNumber.formatPrecisionValue(tiaoxiu_duration));
|
|
|
+ attendanceInfo.put("法定假调整时长", UtilNumber.formatPrecisionValue(leave_duration));
|
|
|
+ // prd [新] 汇总表: 不取系统调休。总时长计算取 0,返回列表也为 0
|
|
|
+ attendanceInfo.put("总时长", UtilNumber.formatPrecisionValue(system_duration + leave_duration + exception_duration - overTime));
|
|
|
+ // prd 请假扣除出勤天数 ppExt 钉钉接口休息如出差半天系统也返回出勤天数1, 存在异常; 休息日加班也会记录为出勤, 考勤字段调整无效
|
|
|
+ attendanceInfo.put("出勤天数_sys", UtilNumber.formatPrecisionValue(UtilMap.getFloat(attendanceInfo, "出勤天数_sys") - leave_all));
|
|
|
+ // prd 公假打卡的天数无需记录到出勤天数中, 包含出差部分
|
|
|
+ Optional optional = attendanceList.stream().filter(item -> {
|
|
|
+ /// 线程安全, 对象获取值
|
|
|
+ String id = (((Map) item.get("column_vo"))).get("id").toString();
|
|
|
+ return fileId_attendance_result.get().equals(id);
|
|
|
+ }).findAny();
|
|
|
+ if (optional.isPresent()) {
|
|
|
+ List<Map> dataList = (List<Map>) ((Map) optional.get()).get("column_vals");
|
|
|
+ int days_overTime = dataList.stream().filter(item -> String.valueOf(item.get("value")).contains("休息并打卡") || String.valueOf(item.get("value")).contains("休息,出差")).collect(Collectors.toList()).size();
|
|
|
+ attendanceInfo.put("出勤天数_sys", UtilNumber.formatPrecisionValue(UtilMap.getFloat(attendanceInfo, "出勤天数_sys") - days_overTime));
|
|
|
+ }
|
|
|
+ attendanceInfos.add(attendanceInfo);
|
|
|
+ });
|
|
|
+ // prd 26-25周期非自然月逻辑 [获取出现最多次作为法定应出勤天数] 考勤应出勤天数和班组 + 人员挂钩, ppExt 排班天数钉钉查询没有接口
|
|
|
+ float workMin = (Float) UtilList.maxFrequencyObject(attendanceInfos.stream().map(item -> UtilMap.getFloat(item, "出勤天数")).collect(Collectors.toList())) * 60 * 8;
|
|
|
+
|
|
|
+ // prd 数据处理 [ppExt 月度汇总统计真实数据, 月度明细按照zc规则统计]
|
|
|
+ int order = 0;
|
|
|
+ for (Map attendance : attendanceInfos) {
|
|
|
+ if (attendance.containsKey("总时长") && workMin > 0) {
|
|
|
+ attendance.put("勤勉度系数", UtilNumber.formatPrecisionValue(UtilMap.getFloat(attendance, "总时长") / workMin));
|
|
|
+ }
|
|
|
+ order++;
|
|
|
+ attendance.put("序号", String.valueOf(order));
|
|
|
+ // 调休按照半天\一天进行取整, 补充尾差
|
|
|
+ attendance.put("出勤天数_sys", UtilNumber.roundHalf(UtilMap.getFloat(attendance, "出勤天数_sys")));
|
|
|
+ // prd 月度汇总表和月度明细表是否可实现部分无需打卡的员工
|
|
|
+ if ("无需打卡".equals(attendance.get("考勤状态"))) {
|
|
|
+ if (!Objects.isNull(days)) {
|
|
|
+ attendance.put("旷工天数", 0);
|
|
|
+ attendance.put("缺卡次数", 0);
|
|
|
+ attendance.put("上班缺卡次数", 0);
|
|
|
+ attendance.put("上班缺卡次数", 0);
|
|
|
+ attendance.put("下班缺卡次数", 0);
|
|
|
+ attendance.put("迟到次数", 0);
|
|
|
+ attendance.put("早退次数", 0);
|
|
|
+ for (Object key : attendance.keySet()) {
|
|
|
+ String prop = String.valueOf(key);
|
|
|
+ if (prop.contains("_") || prop.contains("-")) {
|
|
|
+ String val = String.valueOf(attendance.get(prop)).replace("旷工", "").replace("缺卡", "").replace("迟到", "").replace("早退", "").trim();
|
|
|
+ // 忽略考勤异常 | 考勤静默用户
|
|
|
+ if (StringUtils.isBlank(val) || val.equals("/")) {
|
|
|
+ attendance.put(prop, "zc");
|
|
|
+ } else {
|
|
|
+ attendance.put(prop, val);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ List<String> vals = new ArrayList<>();
|
|
|
+ for (String cont : String.valueOf(attendance.get("考勤结果")).split("; ")) {
|
|
|
+ // 缺卡情况下, 存在请假, 需要保留
|
|
|
+ if (cont.contains("缺卡,") || (!cont.contains("旷工") && !cont.contains("缺卡") && !cont.contains("迟到") && !cont.contains("早退"))) {
|
|
|
+ vals.add(cont);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ attendance.put("考勤结果", String.join("; ", vals));
|
|
|
+ // prd 部分无需打卡的员工旷工、缺卡、迟到、早退的天数需要记录到出勤天数中
|
|
|
+ attendance.put("出勤天数_sys", UtilNumber.formatPrecisionValue(UtilMap.getFloat(attendance, "出勤天数_sys") + UtilMap.getFloat(attendance, "旷工天数")));
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (!Objects.isNull(days)) {
|
|
|
+ // prd 异常与假期统计对应状态数据, 出勤天数就是实际到公司工作的天数[zc状态], 兼容3小时需求逻辑
|
|
|
+ AtomicReference<Float> days_rest = new AtomicReference<>(0f);
|
|
|
+ AtomicReference<Float> days_tiaoxiu = new AtomicReference<>(0f);
|
|
|
+ AtomicReference<Float> days_shijia = new AtomicReference<>(0f);
|
|
|
+ AtomicReference<Float> days_burujia = new AtomicReference<>(0f);
|
|
|
+ AtomicReference<Float> days_chidao = new AtomicReference<>(0f);
|
|
|
+ AtomicReference<Float> days_zaotui = new AtomicReference<>(0f);
|
|
|
+ AtomicReference<Float> days_kuangong = new AtomicReference<>(0f);
|
|
|
+ AtomicReference<Float> days_addition = new AtomicReference<>(0f);
|
|
|
+ attendance.put("出勤天数_prd", attendance.keySet().stream().reduce(0f, (acc, cur) -> {
|
|
|
+ if (cur.toString().contains("_")) {
|
|
|
+ // prd 2.29 新增 = 出差 + 外出 + zc [Excel添加公式导出不直接显示, 需要触发回车才会更新]
|
|
|
+ if (Arrays.asList("zc", "外出", "出差").contains(attendance.get(cur))) {
|
|
|
+ days_addition.updateAndGet(v -> new Float((float) (v + 0.5)));
|
|
|
+ }
|
|
|
+ // 累计汇总天数 [出勤天数包含 外出, 缺卡, zc]; ppExt 未加入考勤组人员, 会全月统计为zc, 钉钉返回为空, 没有判断条件. 因此需要手动调整 [极端情况]
|
|
|
+ if (Arrays.asList("zc", "缺卡", "外出").contains(attendance.get(cur))) {
|
|
|
+ return Float.valueOf(String.valueOf(acc)) + 0.5;
|
|
|
+ } else if (attendance.get(cur).equals("公假")) {
|
|
|
+ days_rest.updateAndGet(v -> new Float((float) (v + 0.5)));
|
|
|
+ } else if (attendance.get(cur).equals("调休")) {
|
|
|
+ days_tiaoxiu.updateAndGet(v -> new Float((float) (v + 0.5)));
|
|
|
+ } else if (attendance.get(cur).equals("事假")) {
|
|
|
+ days_shijia.updateAndGet(v -> new Float((float) (v + 0.5)));
|
|
|
+ } else if (attendance.get(cur).equals("哺乳假")) {
|
|
|
+ days_burujia.updateAndGet(v -> new Float((float) (v + 0.5)));
|
|
|
+ } else if (attendance.get(cur).equals("迟到")) {
|
|
|
+ days_chidao.updateAndGet(v -> new Float((float) (v + 0.5)));
|
|
|
+ } else if (attendance.get(cur).equals("早退")) {
|
|
|
+ days_zaotui.updateAndGet(v -> new Float((float) (v + 0.5)));
|
|
|
+ } else if (attendance.get(cur).equals("旷工")) {
|
|
|
+ days_kuangong.updateAndGet(v -> new Float((float) (v + 0.5)));
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return acc;
|
|
|
+ }));
|
|
|
+ attendance.put("公假(新增)_prd", days_addition.get());
|
|
|
+ attendance.put("公假天数_prd", days_rest.get());
|
|
|
+ attendance.put("调休天数_prd", days_tiaoxiu.get());
|
|
|
+ attendance.put("事假天数_prd", days_shijia.get());
|
|
|
+ attendance.put("哺乳假天数_prd", days_burujia.get());
|
|
|
+ attendance.put("迟到次数_prd", days_chidao.get());
|
|
|
+ attendance.put("早退次数_prd", days_zaotui.get());
|
|
|
+ attendance.put("旷工天数_prd", days_kuangong.get());
|
|
|
+ }
|
|
|
+ }
|
|
|
+ // 记录月度明细日期, 进行排序 [接口返回已排序]
|
|
|
+// if (UtilList.isNotEmpty(days)) {
|
|
|
+// Collections.sort(days, Comparator.comparingLong(o -> Long.valueOf(o.replace("-", ""))));
|
|
|
+// }
|
|
|
+ return UtilList.ignoreListMapZero(attendanceInfos);
|
|
|
+ }
|
|
|
+}
|