package com.gs.dingtalk.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.gs.dingtalk.entity.QwCheckinDayData;
|
import com.gs.dingtalk.mapper.QwCheckinDayDataMapper;
|
import com.gs.dingtalk.service.QwCheckinDayDataService;
|
import com.gs.dingtalk.service.WorkWXService;
|
import lombok.RequiredArgsConstructor;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.stereotype.Service;
|
|
import java.io.IOException;
|
import java.util.Date;
|
import java.util.List;
|
|
/**
|
* 企业微信打卡日报数据Service实现
|
*/
|
@Service
|
@RequiredArgsConstructor
|
public class QwCheckinDayDataServiceImpl extends ServiceImpl<QwCheckinDayDataMapper, QwCheckinDayData>
|
implements QwCheckinDayDataService {
|
|
private static final Logger log = LoggerFactory.getLogger(QwCheckinDayDataServiceImpl.class);
|
|
private final WorkWXService workWXService;
|
|
@Override
|
public QwCheckinDayData convertToEntity(WorkWXService.CheckinDayData dayData) {
|
if (dayData == null) {
|
return null;
|
}
|
|
QwCheckinDayData entity = new QwCheckinDayData();
|
|
// 基础信息
|
WorkWXService.BaseInfo baseInfo = dayData.getBaseInfo();
|
if (baseInfo != null) {
|
entity.setReportDate(baseInfo.getDate());
|
if (baseInfo.getDate() != null) {
|
entity.setReportDatetime(new Date(baseInfo.getDate() * 1000));
|
}
|
entity.setAcctid(baseInfo.getAcctid());
|
entity.setName(baseInfo.getName());
|
entity.setNameEx(baseInfo.getNameEx());
|
entity.setDepartsName(baseInfo.getDepartsName());
|
entity.setRecordType(baseInfo.getRecordType());
|
entity.setDayType(baseInfo.getDayType());
|
|
// 规则信息
|
WorkWXService.RuleInfo ruleInfo = baseInfo.getRuleInfo();
|
if (ruleInfo != null) {
|
entity.setGroupid(ruleInfo.getGroupid());
|
entity.setGroupname(ruleInfo.getGroupname());
|
entity.setScheduleid(ruleInfo.getScheduleid());
|
entity.setSchedulename(ruleInfo.getSchedulename());
|
}
|
}
|
|
// 汇总信息
|
WorkWXService.SummaryInfo summaryInfo = dayData.getSummaryInfo();
|
if (summaryInfo != null) {
|
entity.setCheckinCount(summaryInfo.getCheckinCount());
|
entity.setRegularWorkSec(summaryInfo.getRegularWorkSec());
|
entity.setStandardWorkSec(summaryInfo.getStandardWorkSec());
|
entity.setEarliestTime(summaryInfo.getEarliestTime());
|
entity.setLastestTime(summaryInfo.getLastestTime());
|
}
|
|
// 异常信息 - 初始化默认值
|
entity.setLateCount(0);
|
entity.setLateDuration(0);
|
entity.setEarlyLeaveCount(0);
|
entity.setEarlyLeaveDuration(0);
|
entity.setAbsentCount(0);
|
entity.setAbsenteeismCount(0);
|
entity.setAbsenteeismDuration(0);
|
entity.setLocationExCount(0);
|
entity.setDeviceExCount(0);
|
|
// 解析异常信息
|
List<WorkWXService.ExceptionInfo> exceptionInfos = dayData.getExceptionInfos();
|
if (exceptionInfos != null && !exceptionInfos.isEmpty()) {
|
for (WorkWXService.ExceptionInfo ex : exceptionInfos) {
|
if (ex.getException() == null) continue;
|
switch (ex.getException()) {
|
case 1: // 迟到
|
entity.setLateCount(ex.getCount() != null ? ex.getCount() : 0);
|
entity.setLateDuration(ex.getDuration() != null ? ex.getDuration() : 0);
|
break;
|
case 2: // 早退
|
entity.setEarlyLeaveCount(ex.getCount() != null ? ex.getCount() : 0);
|
entity.setEarlyLeaveDuration(ex.getDuration() != null ? ex.getDuration() : 0);
|
break;
|
case 3: // 缺卡
|
entity.setAbsentCount(ex.getCount() != null ? ex.getCount() : 0);
|
break;
|
case 4: // 旷工
|
entity.setAbsenteeismCount(ex.getCount() != null ? ex.getCount() : 0);
|
entity.setAbsenteeismDuration(ex.getDuration() != null ? ex.getDuration() : 0);
|
break;
|
case 5: // 地点异常
|
entity.setLocationExCount(ex.getCount() != null ? ex.getCount() : 0);
|
break;
|
case 6: // 设备异常
|
entity.setDeviceExCount(ex.getCount() != null ? ex.getCount() : 0);
|
break;
|
}
|
}
|
}
|
|
// 加班信息
|
entity.setOtStatus(0);
|
entity.setOtDuration(0);
|
WorkWXService.OtInfo otInfo = dayData.getOtInfo();
|
if (otInfo != null) {
|
entity.setOtStatus(otInfo.getOtStatus() != null ? otInfo.getOtStatus() : 0);
|
entity.setOtDuration(otInfo.getOtDuration() != null ? otInfo.getOtDuration() : 0);
|
}
|
|
entity.setCreateTime(new Date());
|
return entity;
|
}
|
|
@Override
|
public int saveDayDataBatch(List<WorkWXService.CheckinDayData> dayDataList) {
|
if (dayDataList == null || dayDataList.isEmpty()) {
|
return 0;
|
}
|
|
int insertCount = 0;
|
for (WorkWXService.CheckinDayData dayData : dayDataList) {
|
QwCheckinDayData entity = convertToEntity(dayData);
|
if (entity == null || entity.getAcctid() == null || entity.getReportDate() == null) {
|
continue;
|
}
|
|
// 检查是否已存在（按acctid + report_date去重）
|
LambdaQueryWrapper<QwCheckinDayData> wrapper = new LambdaQueryWrapper<>();
|
wrapper.eq(QwCheckinDayData::getAcctid, entity.getAcctid())
|
.eq(QwCheckinDayData::getReportDate, entity.getReportDate());
|
|
QwCheckinDayData existing = this.getOne(wrapper);
|
if (existing != null) {
|
// 已存在则更新
|
entity.setId(existing.getId());
|
this.updateById(entity);
|
log.debug("更新打卡日报数据: acctid={}, date={}", entity.getAcctid(), entity.getReportDatetime());
|
} else {
|
// 不存在则插入
|
this.save(entity);
|
insertCount++;
|
log.debug("新增打卡日报数据: acctid={}, date={}", entity.getAcctid(), entity.getReportDatetime());
|
}
|
}
|
|
log.info("打卡日报数据保存完成，新增: {}, 总处理: {}", insertCount, dayDataList.size());
|
return insertCount;
|
}
|
|
@Override
|
public int syncDayData(long date) throws IOException {
|
List<WorkWXService.CheckinDayData> dayDataList = workWXService.getCheckinDayDataByQwStaff(date, date);
|
return saveDayDataBatch(dayDataList);
|
}
|
|
@Override
|
public int syncYesterdayDayData() throws IOException {
|
long currentTime = System.currentTimeMillis() / 1000;
|
long oneDaySeconds = 86400;
|
long yesterdayStart = ((currentTime / oneDaySeconds) - 1) * oneDaySeconds;
|
|
log.info("开始同步昨天({})的打卡日报数据", new Date(yesterdayStart * 1000));
|
return syncDayData(yesterdayStart);
|
}
|
}
|
