111

tjx

昨天 ab0994824a3b26a82c4333bf0b45315a944a25fc

 src/test/java/com/gs/dingtalk/DeviceReceivingApplicationTests.java

@@ -4,6 +4,7 @@
import com.gs.dingtalk.config.URLEncoder;
import com.gs.dingtalk.entity.QwStaff;
import com.gs.dingtalk.mapper.QwStaffMapper;
import com.gs.dingtalk.service.QwCheckinDataService;
import com.gs.dingtalk.service.SendDingtalkService;
import com.gs.dingtalk.service.SimpleExample;
import com.gs.dingtalk.service.VwCjScSjTsBbService;
@@ -29,6 +30,9 @@

    @Autowired
    private QwStaffMapper qwStaffMapper;

    @Autowired
    private QwCheckinDataService qwCheckinDataService;

    /**
     * 测试导出生产数据并发送钉钉消息
@@ -110,6 +114,11 @@
                            ", 异常类型: " + data.getExceptionType() +
                            ", 地点: " + data.getLocationDetail());
                });

                // 保存到数据库
                System.out.println("  - 开始保存到数据库...");
                int insertCount = qwCheckinDataService.saveCheckinDataBatch(checkinDataList);
                System.out.println("✓ 保存完成，新增记录数: " + insertCount + ", 跳过(已存在): " + (checkinDataList.size() - insertCount));
            } else {
                System.out.println("✗ 获取的打卡数据为空（可能QW_STAFF表无数据或时间范围内无打卡记录）");
            }
@@ -139,8 +148,13 @@
            long oneDaySeconds = 86400;
            long thirtyDaysSeconds = 30 * oneDaySeconds;

            long endTime = (currentTime / oneDaySeconds) * oneDaySeconds - 1;
            long startTime = endTime - oneDaySeconds + 1;
            // 昨天结束时间（23:59:59）
            long yesterdayEnd = ((currentTime / oneDaySeconds) - 1) * oneDaySeconds + oneDaySeconds - 1;
            // 20天前开始时间（00:00:00）
            long twentyDaysAgoStart = yesterdayEnd - 20 * oneDaySeconds + 1;

            long endTime = yesterdayEnd;
            long startTime = twentyDaysAgoStart;

            // 验证时间跨度不超过30天
            long timeSpan = endTime - startTime;
@@ -149,8 +163,9 @@
                return;
            }

            System.out.println("  - 开始时间: " + new java.util.Date(startTime * 1000));
            System.out.println("  - 结束时间: " + new java.util.Date(endTime * 1000));
            System.out.println("  - 开始时间: " + new java.util.Date(startTime * 1000) + " (20天前)");
            System.out.println("  - 结束时间: " + new java.util.Date(endTime * 1000) + " (昨天)");
            System.out.println("  - 时间跨度: " + (timeSpan / oneDaySeconds) + "天");

            List<String> useridList = new java.util.ArrayList<>();
            useridList.add(qwStaff.getAccount());
@@ -221,4 +236,181 @@
        System.out.println("=== 测试结束 ===");
    }

    /**
     * 测试获取打卡日报数据
     * 接口限制：100次/分钟，时间跨度不超过30天
     */
    @Test
    void testGetCheckinDayData() {
        System.out.println("=== 开始测试获取打卡日报数据 ===");

        try {
            long currentTime = System.currentTimeMillis() / 1000;
            long oneDaySeconds = 86400;

            // 获取昨天的日报数据（starttime和endtime需要是同一天）
            long yesterdayStart = ((currentTime / oneDaySeconds) - 1) * oneDaySeconds;
            long startTime = yesterdayStart;
            long endTime = yesterdayStart;  // 日报接口starttime和endtime需相同

            System.out.println("  - 查询日期: " + new java.util.Date(startTime * 1000));

            // 获取用户总数
            long totalUsers = qwStaffMapper.selectCount(new LambdaQueryWrapper<QwStaff>()
                    .isNotNull(QwStaff::getAccount)
                    .ne(QwStaff::getAccount, ""));
            System.out.println("  - QW_STAFF表用户总数: " + totalUsers);

            List<WorkWXService.CheckinDayData> dayDataList = workWXService.getCheckinDayDataByQwStaff(startTime, endTime);

            if (dayDataList != null && !dayDataList.isEmpty()) {
                System.out.println("✓ 成功获取打卡日报数据");
                System.out.println("  - 日报记录总数: " + dayDataList.size());
                System.out.println("  - 前5条数据:");
                dayDataList.stream().limit(5).forEach(data -> {
                    WorkWXService.BaseInfo baseInfo = data.getBaseInfo();
                    WorkWXService.SummaryInfo summaryInfo = data.getSummaryInfo();
                    System.out.println("    * 姓名: " + (baseInfo != null ? baseInfo.getName() : "N/A") +
                            ", 账号: " + (baseInfo != null ? baseInfo.getAcctid() : "N/A") +
                            ", 部门: " + (baseInfo != null ? baseInfo.getDepartsName() : "N/A") +
                            ", 打卡次数: " + (summaryInfo != null ? summaryInfo.getCheckinCount() : 0) +
                            ", 实际工时(秒): " + (summaryInfo != null ? summaryInfo.getRegularWorkSec() : 0) +
                            ", 标准工时(秒): " + (summaryInfo != null ? summaryInfo.getStandardWorkSec() : 0));

                    // 打印异常信息
                    if (data.getExceptionInfos() != null && !data.getExceptionInfos().isEmpty()) {
                        data.getExceptionInfos().forEach(ex -> {
                            String exType = getExceptionTypeName(ex.getException());
                            System.out.println("      异常: " + exType + ", 次数: " + ex.getCount() + ", 时长(秒): " + ex.getDuration());
                        });
                    }
                });
            } else {
                System.out.println("✗ 获取的打卡日报数据为空");
            }
        } catch (IOException e) {
            System.out.println("✗ 获取打卡日报数据失败: " + e.getMessage());
            e.printStackTrace();
        }

        System.out.println("=== 测试结束 ===");
    }

    /**
     * 测试获取指定员工的打卡日报数据
     */
    @Test
    void testGetCheckinDayDataById() {
        System.out.println("=== 开始测试获取指定员工打卡日报数据 ===");

        QwStaff qwStaff = qwStaffMapper.selectById(3);

        if (qwStaff == null || qwStaff.getAccount() == null || qwStaff.getAccount().isEmpty()) {
            System.out.println("✗ 未找到ID为3的员工或员工account为空");
            return;
        }

        System.out.println("  - 员工姓名: " + qwStaff.getName());
        System.out.println("  - 员工账号: " + qwStaff.getAccount());

        try {
            long currentTime = System.currentTimeMillis() / 1000;
            long oneDaySeconds = 86400;

            // 获取昨天的日报
            long yesterdayStart = ((currentTime / oneDaySeconds) - 1) * oneDaySeconds;
            long startTime = yesterdayStart;
            long endTime = yesterdayStart;

            System.out.println("  - 查询日期: " + new java.util.Date(startTime * 1000));

            List<String> useridList = new java.util.ArrayList<>();
            useridList.add(qwStaff.getAccount());

            List<WorkWXService.CheckinDayData> dayDataList = workWXService.getCheckinDayData(startTime, endTime, useridList);

            if (dayDataList != null && !dayDataList.isEmpty()) {
                System.out.println("✓ 成功获取打卡日报数据");
                dayDataList.forEach(data -> {
                    WorkWXService.BaseInfo baseInfo = data.getBaseInfo();
                    WorkWXService.SummaryInfo summaryInfo = data.getSummaryInfo();

                    System.out.println("  基础信息:");
                    System.out.println("    - 姓名: " + (baseInfo != null ? baseInfo.getName() : "N/A"));
                    System.out.println("    - 部门: " + (baseInfo != null ? baseInfo.getDepartsName() : "N/A"));
                    System.out.println("    - 规则: " + (baseInfo != null && baseInfo.getRuleInfo() != null ? baseInfo.getRuleInfo().getGroupname() : "N/A"));

                    System.out.println("  汇总信息:");
                    System.out.println("    - 打卡次数: " + (summaryInfo != null ? summaryInfo.getCheckinCount() : 0));
                    System.out.println("    - 实际工时: " + (summaryInfo != null ? formatSeconds(summaryInfo.getRegularWorkSec()) : "0"));
                    System.out.println("    - 标准工时: " + (summaryInfo != null ? formatSeconds(summaryInfo.getStandardWorkSec()) : "0"));

                    if (data.getExceptionInfos() != null && !data.getExceptionInfos().isEmpty()) {
                        System.out.println("  异常信息:");
                        data.getExceptionInfos().forEach(ex -> {
                            String exType = getExceptionTypeName(ex.getException());
                            System.out.println("    - " + exType + ": " + ex.getCount() + "次, 时长: " + formatSeconds(ex.getDuration()));
                        });
                    }

                    if (data.getOtInfo() != null && data.getOtInfo().getOtStatus() != null && data.getOtInfo().getOtStatus() > 0) {
                        System.out.println("  加班信息:");
                        System.out.println("    - 加班时长: " + formatSeconds(data.getOtInfo().getOtDuration()));
                    }
                });
            } else {
                System.out.println("✗ 该员工在指定日期无打卡日报数据");
            }
        } catch (IOException e) {
            System.out.println("✗ 获取打卡日报数据失败: " + e.getMessage());
            e.printStackTrace();
        }

        System.out.println("=== 测试结束 ===");
    }

    /**
     * 格式化秒数为时分秒
     */
    private String formatSeconds(Integer seconds) {
        if (seconds == null || seconds == 0) {
            return "0秒";
        }
        int hours = seconds / 3600;
        int minutes = (seconds % 3600) / 60;
        int secs = seconds % 60;

        StringBuilder sb = new StringBuilder();
        if (hours > 0) sb.append(hours).append("小时");
        if (minutes > 0) sb.append(minutes).append("分钟");
        if (secs > 0) sb.append(secs).append("秒");
        return sb.toString();
    }

    /**
     * 获取异常类型名称
     * @param exceptionType 异常类型代码：1-迟到；2-早退；3-缺卡；4-旷工；5-地点异常；6-设备异常
     */
    private String getExceptionTypeName(Integer exceptionType) {
        if (exceptionType == null) {
            return "未知";
        }
        switch (exceptionType) {
            case 1:
                return "迟到";
            case 2:
                return "早退";
            case 3:
                return "缺卡";
            case 4:
                return "旷工";
            case 5:
                return "地点异常";
            case 6:
                return "设备异常";
            default:
                return "未知";
        }
    }

}