bonus
/
hn_task
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

8月考勤数据定时任务

This commit is contained in:
cwchen 2025-08-27 13:06:30 +08:00
parent e1d37a754c
commit d5635e0387
6 changed files with 429 additions and 33 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

50
src/main/java/com/bonus/ahsbs/base/dao/IAttSyncDao.java Normal file
View File

@ -0,0 +1,50 @@
package com.bonus.ahsbs.base.dao;
import com.bonus.ahsbs.base.entity.FcFaceContrastOldBean;
import org.springframework.stereotype.Repository;
import org.apache.ibatis.annotations.Param;
import java.util.List;
/**
* @className:IAttSyncDao
* @author:cwchen
* @date:2025-08-26-16:48
* @version:1.0
* @description:8月份考勤数据同步
*/
@Repository(value = "IAttSyncDao")
public interface IAttSyncDao {
int countByTimeRange(@Param("startTime") String startTime, @Param("endTime") String endTime);
/**
* 查询8月份考勤数据
* @param startTime
* @param endTime
* @param offset
* @param limit
* @return List<FcFaceContrastOldBean>
* @author cwchen
* @date 2025/8/26 17:40
*/
List<FcFaceContrastOldBean> pageByTimeRange(@Param("startTime") String startTime,
@Param("endTime") String endTime,
@Param("offset") int offset,
@Param("limit") int limit);
/**
* 8月份数据考勤是否已经添加完成
* @return int
* @author cwchen
* @date 2025/8/26 17:54
*/
int isAddData(@Param("startTime") String startTime, @Param("endTime") String endTime);
/**
* 添加8月份考勤数据
* @param list
* @return void
* @author cwchen
* @date 2025/8/26 17:58
*/
void addAttData(@Param("list") List<FcFaceContrastOldBean> list);
}

72
src/main/java/com/bonus/ahsbs/base/entity/FcFaceContrastOldBean.java Normal file
View File

@ -0,0 +1,72 @@
package com.bonus.ahsbs.base.entity;
import lombok.Data;
import java.math.BigDecimal;
/**
* @className:FcFaceContrastBean
* @author:cwchen
* @date:2025-07-09-11:13
* @version:1.0
* @description:人员考勤-vo
*/
@Data
public class FcFaceContrastOldBean {
/**身份证号*/
private String idCard;
/**姓名*/
private String userName;
/**工程ID*/
private Long proId;
/**分包ID*/
private Long subId;
/**班组ID*/
private Long teamId;
/**组织ID*/
private Long orgId;
/**岗位ID*/
private Long postId;
/**银行卡信息*/
private String bankCard;
/**施工人员合同ID*/
private String contractId;
/**工资标准*/
private BigDecimal wageCriterion = BigDecimal.ZERO;
/**绩效-max*/
private BigDecimal maxAchievementsMoney = BigDecimal.ZERO;
/**绩效-min*/
private BigDecimal minAchievementsMoney = BigDecimal.ZERO;
/**合同生效日期*/
private String effectDate;
/**工种名称*/
private String workName;
/**工种类型*/
private String workType;
private String isRepair;
private String address;
private String lat;
private String lon;
private String overHours;
private String workHours;
private String auditRemark;
private String auditStatus;
private String auditTime;
private String auditor;
private String isSuccess;
private String uploadType;
private String photoPath;
private String uploadTime;
private String addTime;
private String currentDay;
private String dataType;
private String checkMoney;
private String userId;
private String remark;
}

112
src/main/java/com/bonus/ahsbs/base/task/AttSyncTask.java Normal file
View File

@ -0,0 +1,112 @@
package com.bonus.ahsbs.base.task;
import com.bonus.ahsbs.base.dao.IAttSyncDao;
import com.bonus.ahsbs.base.entity.FcFaceContrastOldBean;
import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.util.List;
/**
* @className:AttSyncTask
* @author:cwchen
* @date:2025-08-26-16:46
* @version:1.0
* @description:8月份考勤数据同步
*/
@Component
@Slf4j
@EnableScheduling
@EnableAsync
public class AttSyncTask {
@Resource(name = "IAttSyncDao")
private IAttSyncDao dao;
/**
* 定时任务：每日 02:10 触发一次，同步当前自然月数据（[当月1号00:00:00, 次月1号00:00:00)）
*/
// @Scheduled(cron = "0 0/1 1-18 * * ?") // 本地调试
@Scheduled(cron = "0 0/30 23 * * ?") // 生产
public void scheduledSyncCurrentMonth() {
String startTime = "2025-08-01";
String endTime = "2025-08-31";
int pageSize = 1000;
boolean addData = isAddData(startTime, endTime);
if(!addData){
log.info("定时任务开始：考勤数据分页同步，区间[{}, {}]，pageSize={}", startTime, endTime, pageSize);
syncByPages(startTime, endTime, pageSize);
log.info("定时任务结束：考勤数据分页同步");
}else {
log.info("8月份考勤数据已补");
}
}
/**
* 8月份数据考勤是否已经添加完成
*/
public boolean isAddData(String startTime, String endTime) {
try {
int num = dao.isAddData(startTime,endTime);
if(num > 0){
return true;
}
return false;
} catch (Exception e) {
log.error(e.toString(), e);
}
return true;
}
/**
* 先查询总数，再按页查询
* @param startTime 开始时间，例如 2025-08-01
* @param endTime 结束时间，例如 2025-08-31
* @param pageSize 每页大小
*/
public void syncByPages(String startTime, String endTime, int pageSize) {
// 查询总条数
int total = dao.countByTimeRange(startTime, endTime);
if (total <= 0) {
log.info("区间内无数据，无需同步。startTime={}, endTime={}", startTime, endTime);
return;
}
int pages = (total + pageSize - 1) / pageSize;
log.info("开始分页同步，总数={}，页大小={}，总页数={}，区间[{}, {}]", total, pageSize, pages, startTime, endTime);
for (int pageIndex = 0; pageIndex < pages; pageIndex++) {
int offset = pageIndex * pageSize;
List<FcFaceContrastOldBean> rows = dao.pageByTimeRange(startTime, endTime, offset, pageSize);
try {
if (rows == null || rows.isEmpty()) {
log.info("第{}页无数据，跳过。", pageIndex + 1);
continue;
}
// 在此处处理分页数据 rows，例如批量写入目标库/下游系统
handlePageData(rows, pageIndex + 1, pages);
} finally {
// 释放已处理数据并触发垃圾回收
if (rows != null) {
rows.clear();
}
rows = null;
System.gc();
}
}
log.info("分页同步完成，总数={}，区间[{}, {}]", total, startTime, endTime);
}
private void handlePageData(List<FcFaceContrastOldBean> rows, int currentPage, int totalPages) {
log.info("处理第{}/{}页，记录数={}", currentPage, totalPages, rows.size());
try {
// 添加8月份考勤数据
dao.addAttData(rows);
} catch (Exception e) {
log.error(e.toString(), e);
}
}
}

108
src/main/java/com/bonus/ahsbs/base/task/AttendanceTask.java
View File

@ -128,31 +128,50 @@ public class AttendanceTask {
@Scheduled(cron = "0 0/5 7-20 * * ?") // 生产
// @Scheduled(cron = "0 0/1 7-20 * * ?") // 本地调试
@Async
public void newEntryByToday(){
public void newEntryByToday() {
log.info("今日新入场施工人员，并且已经签订合同 考勤数据入库定时任务开始执行");
List<FcFaceContrastBean> newEntryWorkers = null;
List<FcFaceContrastBean> bePutInStorage = null;
List<FcFaceContrastBean> missDataList = null;
List<FcFaceContrastBean> updateDataList = null;
try {
String day = DateTimeHelper.getNowDate();
// 1.查询今日新入场，并且已经签订合同的施工人员
List<FcFaceContrastBean> newEntryWorkers = dao.getNewEntryWorkers(day);
newEntryWorkers = dao.getNewEntryWorkers(day);
// 2.查询已经入考勤库的人员
List<FcFaceContrastBean> bePutInStorage= dao.getBePutInStorage(day);
bePutInStorage = dao.getBePutInStorage(day);
// 3.比对出未入考勤库人员
List<FcFaceContrastBean> missDataList = findMissingInB(bePutInStorage, newEntryWorkers);
missDataList = findMissingInB(bePutInStorage, newEntryWorkers);
// 4.已入考勤库人员，并对基本信息进行更新
List<FcFaceContrastBean> updateDataList = findExitInB(bePutInStorage, newEntryWorkers);
updateDataList = findExitInB(bePutInStorage, newEntryWorkers);
// 5. 添加未入考勤库人员数据
int result = 0;
if(CollectionUtils.isNotEmpty(missDataList)){
if (CollectionUtils.isNotEmpty(missDataList)) {
result = dao.addAttData(missDataList, day);
}
// 6. 更新已入考勤库人员数据
int result2 = 0;
if(CollectionUtils.isNotEmpty(updateDataList)){
if (CollectionUtils.isNotEmpty(updateDataList)) {
result2 = dao.updateData(updateDataList, day);
}
log.info("考勤数据入库成功，新入场数据："+result+"条，更新数据："+result2+"条");
log.info("考勤数据入库成功，新入场数据：" + result + "条，更新数据：" + result2 + "条");
} catch (Exception e) {
log.error(e.toString(),e);
log.error(e.toString(), e);
} finally {
// 释放已处理数据并触发垃圾回收
if (CollectionUtils.isNotEmpty(newEntryWorkers)) {
newEntryWorkers.clear();
}
if (CollectionUtils.isNotEmpty(bePutInStorage)) {
bePutInStorage.clear();
}
if (CollectionUtils.isNotEmpty(missDataList)) {
missDataList.clear();
}
if (CollectionUtils.isNotEmpty(updateDataList)) {
updateDataList.clear();
}
System.gc();
}
log.info("今日新入场施工人员，并且已经签订合同 考勤数据入库定时任务结束执行");
}
@ -166,29 +185,56 @@ public class AttendanceTask {
*/
public void addData(List<String> dates){
for (String day : dates) {
// 1.查询已出场的施工人员（按日期）
List<String> idNumbers = dao.getExitWorkerByDay(day);
if(CollectionUtils.isNotEmpty(idNumbers)){
// 2.删除已经出场施工人员，并且已入考勤库的数据（未打卡）
dao.delAttByExitData(day,idNumbers);
List<String> idNumbers = null;
List<FcFaceContrastBean> workers = null;
List<FcFaceContrastBean> bePutInStorage = null;
List<FcFaceContrastBean> missDataList = null;
List<FcFaceContrastBean> updateDataList = null;
try {
// 1.查询已出场的施工人员（按日期）
idNumbers = dao.getExitWorkerByDay(day);
if (CollectionUtils.isNotEmpty(idNumbers)) {
// 2.删除已经出场施工人员，并且已入考勤库的数据（未打卡）
dao.delAttByExitData(day, idNumbers);
}
// 3.查询未出场的施工人员（有施工合同）
workers = dao.getWorkersByDay(day);
// 4.查询已经入考勤库的人员
bePutInStorage = dao.getBePutInStorage(day);
// 5.比对出未入考勤库人员
missDataList = findMissingInB(bePutInStorage, workers);
// 6.已入考勤库人员，并对基本信息进行更新
updateDataList = findExitInB(bePutInStorage, workers);
// 7. 添加未入考勤库人员数据
if (CollectionUtils.isNotEmpty(missDataList)) {
dao.addAttData(missDataList, day);
}
// 8. 更新已入考勤库人员数据
if (CollectionUtils.isNotEmpty(updateDataList)) {
dao.updateData(updateDataList, day);
}
log.info("考勤数据入库成功，新增数据：" + missDataList.size() + "条，更新数据：" + updateDataList.size() + "条");
} catch (Exception e) {
throw new RuntimeException(e);
} finally {
// 释放已处理数据并触发垃圾回收
if (CollectionUtils.isNotEmpty(idNumbers)) {
idNumbers.clear();
}
if (CollectionUtils.isNotEmpty(workers)) {
workers.clear();
}
if (CollectionUtils.isNotEmpty(bePutInStorage)) {
bePutInStorage.clear();
}
if (CollectionUtils.isNotEmpty(missDataList)) {
missDataList.clear();
}
if (CollectionUtils.isNotEmpty(updateDataList)) {
updateDataList.clear();
}
System.gc();
}
// 3.查询未出场的施工人员（有施工合同）
List<FcFaceContrastBean> workers = dao.getWorkersByDay(day);
// 4.查询已经入考勤库的人员
List<FcFaceContrastBean> bePutInStorage= dao.getBePutInStorage(day);
// 5.比对出未入考勤库人员
List<FcFaceContrastBean> missDataList = findMissingInB(bePutInStorage, workers);
// 6.已入考勤库人员，并对基本信息进行更新
List<FcFaceContrastBean> updateDataList = findExitInB(bePutInStorage, workers);
// 7. 添加未入考勤库人员数据
if(CollectionUtils.isNotEmpty(missDataList)){
dao.addAttData(missDataList, day);
}
// 8. 更新已入考勤库人员数据
if(CollectionUtils.isNotEmpty(updateDataList)){
dao.updateData(updateDataList, day);
}
log.info("考勤数据入库成功，新增数据："+missDataList.size()+"条，更新数据："+updateDataList.size()+"条");
}
}

9
src/main/java/com/bonus/ahsbs/base/task/WorkNumTask.java
View File

@ -83,8 +83,8 @@ public class WorkNumTask {
* @date 2025/7/10 13:12
*/
public void addData(List<String> dates){
List<WorkNumVo> dataList = new ArrayList<>();
try {
List<WorkNumVo> dataList = new ArrayList<>();
// 1.查询所有工程
List<WorkNumVo> list = Optional.ofNullable(dao.getAllProData()).orElseGet(ArrayList::new);
for (String day : dates) {
@ -114,9 +114,14 @@ public class WorkNumTask {
if(CollectionUtils.isNotEmpty(dataList)){
dao.batchInsertOrUpdate(dataList);
}
dataList.clear();
} catch (Exception e) {
log.error(e.toString(), e);
}finally {
// 释放已处理数据并触发垃圾回收
if (CollectionUtils.isNotEmpty(dataList)) {
dataList.clear();
}
System.gc();
}
}

111
src/main/resources/mappers/base/AttSyncMapper.xml Normal file
View File

@ -0,0 +1,111 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.bonus.ahsbs.base.dao.IAttSyncDao">
<!--添加8月份考勤数据-->
<insert id="addAttData">
INSERT INTO xbg_user_attendance(
id_card, user_id, user_name, data_type, check_time, check_image,
check_money, lat, lon, address, gx_id, gx_name, contract_id,
work_name, work_type, wage_criterion, min_perfor, max_perfor,
audit_status, audti_user, audit_time, audit_remark, team_id,
is_repair, repair_time, repair_remark, pro_id, sub_id, remark,
create_date, create_user, create_time, effect_date, bank_card,
post_id
)
VALUES
<foreach collection="list" item="item" index="index" separator=",">
(
#{item.idCard}, #{item.userId}, #{item.userName}, #{item.dataType}, #{item.uploadTime}, #{item.photoPath},
#{item.checkMoney}, #{item.lat}, #{item.lon}, #{item.address}, NULL, NULL, #{item.contractId},
#{item.workName}, #{item.workType}, #{item.wageCriterion}, #{item.minAchievementsMoney}, #{item.maxAchievementsMoney},
#{item.auditStatus}, #{item.auditor}, #{item.auditTime}, #{item.auditRemark}, #{item.teamId},
#{item.isRepair}, NULL,NULL, #{item.proId}, #{item.subId}, #{item.remark},
#{item.currentDay}, 1, NOW(), #{item.effectDate}, #{item.bankCard},
#{item.postId}
)
</foreach>
</insert>
<!--查询总条数-->
<select id="countByTimeRange" resultType="java.lang.Integer">
SELECT COUNT(1)
FROM fc_face_contrast
WHERE CURRENT_DAY BETWEEN #{startTime} AND #{endTime}
</select>
<select id="pageByTimeRange" resultType="com.bonus.ahsbs.base.entity.FcFaceContrastOldBean">
SELECT
ffc.ID_NUMBER AS idCard,
ffc.USER_ID AS userId,
ffc.NAME AS userName,
ffc.SUB_ID AS subId,
ffc.PRO_ID AS proId,
ffc.TEAM_ID AS teamId,
ffc.CURRENT_DAY AS currentDay,
ffc.ADD_TIME AS addTime,
IF(ffc.AUDIT_STATUS IN ('0','1'),ffc.upload_time,NULL) AS uploadTime,
ffc.PHOTO_PATH AS photoPath,
ffc.UPLOAD_TYPE AS uploadType,
ffc.IS_SUCCESS AS isSuccess,
ffc.AUDITOR AS auditor,
ffc.AUDIT_REMARK AS auditRemark,
ffc.AUDIT_TIME AS auditTime,
ffc.WORK_HOURS AS workHours,
ffc.OVER_HOURS AS overHours,
ffc.lon AS lon,
ffc.lat AS lat,
ffc.address AS address,
ffc.post_id AS postId,
ffc.effect_date AS effectDate,
ffc.wage_criterion AS wageCriterion,
ffc.min_achievements_money AS minAchievementsMoney,
ffc.max_achievements_money AS maxAchievementsMoney,
ffc.bank_card AS bankCard,
ffc.is_repair AS isRepair,
sdd.job_type AS workType,
sdd.remark,
CASE sdd.job_type WHEN '1' THEN '普工'
WHEN '2' THEN '技工'
ELSE '0'
END AS workName,
IF(ffc.AUDIT_STATUS IN ('0','1'),ffc.wage_criterion,'0') AS checkMoney,
CASE ffc.AUDIT_STATUS WHEN '0' THEN 1
WHEN '1' THEN 1
WHEN '2' THEN 1
WHEN '3' THEN 4
WHEN '4' THEN 5
ELSE '5'
END AS dataType,
CASE ffc.AUDIT_STATUS WHEN '0' THEN 0
WHEN '1' THEN 1
WHEN '2' THEN 2
ELSE 0
END AS auditStatus,
A.id AS contractId
FROM fc_face_contrast ffc
LEFT JOIN sys_dic_detail sdd ON ffc.post_id = sdd.id
LEFT JOIN (
SELECT c1.pro_id,c1.idCard,c1.id
FROM bm_worker_contract c1
INNER JOIN (
SELECT idCard, MAX(upload_time) AS latest_upload
FROM bm_worker_contract
WHERE is_audit = '1'
GROUP BY idCard,pro_id
) c2 ON c1.idCard = c2.idCard AND c1.upload_time = c2.latest_upload
WHERE c1.is_audit = '1'
) A ON ffc.ID_NUMBER = A.idCard AND ffc.pro_id = A.pro_id
WHERE CURRENT_DAY BETWEEN #{startTime} AND #{endTime}
ORDER BY ffc.id
LIMIT #{limit} OFFSET #{offset}
</select>
<!--8月份数据考勤是否已经添加完成-->
<select id="isAddData" resultType="java.lang.Integer">
SELECT COUNT(1)
FROM xbg_user_attendance
WHERE create_date BETWEEN #{startTime} AND #{endTime}
</select>
</mapper>