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.QwCheckinData;
|
import com.gs.dingtalk.mapper.QwCheckinDataMapper;
|
import com.gs.dingtalk.service.QwCheckinDataService;
|
import com.gs.dingtalk.service.WorkWXService;
|
import lombok.RequiredArgsConstructor;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.io.IOException;
|
import java.util.Date;
|
import java.util.List;
|
|
/**
|
* @description 针对表【QW_CHECKIN_DATA】企业微信打卡数据的数据库操作Service实现
|
*/
|
@Service
|
@RequiredArgsConstructor
|
public class QwCheckinDataServiceImpl extends ServiceImpl<QwCheckinDataMapper, QwCheckinData>
|
implements QwCheckinDataService {
|
|
private static final Logger log = LoggerFactory.getLogger(QwCheckinDataServiceImpl.class);
|
|
private final WorkWXService workWXService;
|
|
@Override
|
public QwCheckinData convertToEntity(WorkWXService.CheckinData checkinData) {
|
if (checkinData == null) {
|
return null;
|
}
|
|
QwCheckinData entity = new QwCheckinData();
|
entity.setUserid(checkinData.getUserid());
|
entity.setGroupname(checkinData.getGroupname());
|
entity.setCheckinType(checkinData.getCheckinType());
|
entity.setExceptionType(checkinData.getExceptionType());
|
entity.setCheckinTime(checkinData.getCheckinTime());
|
entity.setLocationTitle(checkinData.getLocationTitle());
|
entity.setLocationDetail(checkinData.getLocationDetail());
|
entity.setWifiname(checkinData.getWifiname());
|
entity.setNotes(checkinData.getNotes());
|
entity.setWifimac(checkinData.getWifimac());
|
entity.setDeviceid(checkinData.getDeviceid());
|
|
// 转换Unix时间戳为Date
|
if (checkinData.getCheckinTime() != null) {
|
entity.setCheckinDate(new Date(checkinData.getCheckinTime() * 1000));
|
}
|
if (checkinData.getSchCheckinTime() != null) {
|
entity.setSchCheckinTime(checkinData.getSchCheckinTime());
|
entity.setSchCheckinDate(new Date(checkinData.getSchCheckinTime() * 1000));
|
}
|
|
// 转换经纬度（接口返回的是Double，需要转为Long存储）
|
if (checkinData.getLat() != null) {
|
entity.setLat(checkinData.getLat().longValue());
|
}
|
if (checkinData.getLng() != null) {
|
entity.setLng(checkinData.getLng().longValue());
|
}
|
|
// 转换mediaids列表为逗号分隔的字符串
|
if (checkinData.getMediaids() != null && !checkinData.getMediaids().isEmpty()) {
|
entity.setMediaids(String.join(",", checkinData.getMediaids()));
|
}
|
|
// 转换groupid、scheduleId、timelineId
|
if (checkinData.getGroupid() != null) {
|
entity.setGroupid(checkinData.getGroupid().longValue());
|
}
|
if (checkinData.getScheduleId() != null) {
|
entity.setScheduleId(checkinData.getScheduleId().longValue());
|
}
|
if (checkinData.getTimelineId() != null) {
|
entity.setTimelineId(checkinData.getTimelineId().longValue());
|
}
|
|
entity.setCreateTime(new Date());
|
return entity;
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public int saveCheckinDataBatch(List<WorkWXService.CheckinData> checkinDataList) {
|
if (checkinDataList == null || checkinDataList.isEmpty()) {
|
return 0;
|
}
|
|
int insertCount = 0;
|
for (WorkWXService.CheckinData checkinData : checkinDataList) {
|
// 检查是否已存在（根据userid、checkin_time、checkin_type判断）
|
LambdaQueryWrapper<QwCheckinData> queryWrapper = new LambdaQueryWrapper<>();
|
queryWrapper.eq(QwCheckinData::getUserid, checkinData.getUserid())
|
.eq(QwCheckinData::getCheckinTime, checkinData.getCheckinTime())
|
.eq(QwCheckinData::getCheckinType, checkinData.getCheckinType());
|
|
if (this.count(queryWrapper) == 0) {
|
QwCheckinData entity = convertToEntity(checkinData);
|
this.save(entity);
|
insertCount++;
|
}
|
}
|
|
log.info("批量保存打卡数据完成，总数: {}, 新增: {}, 跳过(已存在): {}",
|
checkinDataList.size(), insertCount, checkinDataList.size() - insertCount);
|
return insertCount;
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public int syncCheckinData(long startTime, long endTime) throws IOException {
|
log.info("开始同步打卡数据，时间范围: {} - {}", new Date(startTime * 1000), new Date(endTime * 1000));
|
|
List<WorkWXService.CheckinData> checkinDataList = workWXService.getCheckinDataByQwStaff(startTime, endTime);
|
|
if (checkinDataList == null || checkinDataList.isEmpty()) {
|
log.info("未获取到打卡数据");
|
return 0;
|
}
|
|
log.info("获取到打卡数据 {} 条，开始保存到数据库", checkinDataList.size());
|
return saveCheckinDataBatch(checkinDataList);
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public int syncYesterdayCheckinData() throws IOException {
|
long currentTime = System.currentTimeMillis() / 1000;
|
long oneDaySeconds = 86400;
|
|
// 昨天开始时间（00:00:00）
|
long startTime = ((currentTime / oneDaySeconds) - 1) * oneDaySeconds;
|
// 昨天结束时间（23:59:59）
|
long endTime = startTime + oneDaySeconds - 1;
|
|
log.info("同步昨天打卡数据，时间范围: {} - {}", new Date(startTime * 1000), new Date(endTime * 1000));
|
return syncCheckinData(startTime, endTime);
|
}
|
}
|
