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.QwHardwareCheckinData;
|
import com.gs.dingtalk.mapper.QwHardwareCheckinDataMapper;
|
import com.gs.dingtalk.service.QwHardwareCheckinDataService;
|
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 QwHardwareCheckinDataServiceImpl extends ServiceImpl<QwHardwareCheckinDataMapper, QwHardwareCheckinData>
|
implements QwHardwareCheckinDataService {
|
|
private static final Logger log = LoggerFactory.getLogger(QwHardwareCheckinDataServiceImpl.class);
|
|
private final WorkWXService workWXService;
|
|
@Override
|
public QwHardwareCheckinData convertToEntity(WorkWXService.HardwareCheckinData data) {
|
if (data == null) {
|
return null;
|
}
|
|
QwHardwareCheckinData entity = new QwHardwareCheckinData();
|
entity.setUserid(data.getUserid());
|
entity.setCheckinTime(data.getCheckinTime());
|
if (data.getCheckinTime() != null) {
|
entity.setCheckinDatetime(new Date(data.getCheckinTime() * 1000));
|
}
|
entity.setDeviceSn(data.getDeviceSn());
|
entity.setDeviceName(data.getDeviceName());
|
entity.setCreateTime(new Date());
|
|
return entity;
|
}
|
|
@Override
|
public int saveHardwareDataBatch(List<WorkWXService.HardwareCheckinData> dataList) {
|
if (dataList == null || dataList.isEmpty()) {
|
return 0;
|
}
|
|
int insertCount = 0;
|
for (WorkWXService.HardwareCheckinData data : dataList) {
|
QwHardwareCheckinData entity = convertToEntity(data);
|
if (entity == null || entity.getUserid() == null || entity.getCheckinTime() == null) {
|
continue;
|
}
|
|
// 检查是否已存在（按userid + checkin_time + device_sn去重）
|
LambdaQueryWrapper<QwHardwareCheckinData> wrapper = new LambdaQueryWrapper<>();
|
wrapper.eq(QwHardwareCheckinData::getUserid, entity.getUserid())
|
.eq(QwHardwareCheckinData::getCheckinTime, entity.getCheckinTime())
|
.eq(QwHardwareCheckinData::getDeviceSn, entity.getDeviceSn());
|
|
QwHardwareCheckinData existing = this.getOne(wrapper);
|
if (existing != null) {
|
// 已存在则更新
|
entity.setId(existing.getId());
|
this.updateById(entity);
|
log.debug("更新设备打卡数据: userid={}, time={}, device={}",
|
entity.getUserid(), entity.getCheckinDatetime(), entity.getDeviceSn());
|
} else {
|
// 不存在则插入
|
this.save(entity);
|
insertCount++;
|
log.debug("新增设备打卡数据: userid={}, time={}, device={}",
|
entity.getUserid(), entity.getCheckinDatetime(), entity.getDeviceSn());
|
}
|
}
|
|
log.info("设备打卡数据保存完成，新增: {}, 总处理: {}", insertCount, dataList.size());
|
return insertCount;
|
}
|
|
@Override
|
public int syncHardwareData(long startTime, long endTime) throws IOException {
|
List<WorkWXService.HardwareCheckinData> dataList = workWXService.getHardwareCheckinDataByQwStaff(startTime, endTime);
|
return saveHardwareDataBatch(dataList);
|
}
|
|
@Override
|
public int syncYesterdayHardwareData() throws IOException {
|
long currentTime = System.currentTimeMillis() / 1000;
|
long oneDaySeconds = 86400;
|
// 昨天0点
|
long yesterdayStart = ((currentTime / oneDaySeconds) - 1) * oneDaySeconds;
|
// 昨天23:59:59
|
long yesterdayEnd = yesterdayStart + oneDaySeconds - 1;
|
|
log.info("开始同步昨天({} ~ {})的设备打卡数据",
|
new Date(yesterdayStart * 1000), new Date(yesterdayEnd * 1000));
|
return syncHardwareData(yesterdayStart, yesterdayEnd);
|
}
|
}
|
