111

tjx

17 小时以前 95e16a3a6877d104d61cb0f99321a31784fcceda

 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;
@@ -21,7 +22,6 @@
class DeviceReceivingApplicationTests {



    @Autowired
    private VwCjScSjTsBbService vwCjScSjTsBbService;

@@ -30,6 +30,9 @@

    @Autowired
    private QwStaffMapper qwStaffMapper;

    @Autowired
    private QwCheckinDataService qwCheckinDataService;

    /**
     * 测试导出生产数据并发送钉钉消息
@@ -62,15 +65,103 @@
    void testGetCheckinDataByQwStaff() {
        System.out.println("=== 开始测试通过QW_STAFF表获取打卡数据 ===");

        // 企业微信打卡接口限制：
        // 1. 获取记录时间跨度不超过30天
        // 2. 用户列表不超过100个。若用户超过100个，请分批获取（已在Service层实现自动分批）
        // 3. 接口返回最多3000条打卡数据
        // 4. 标准打卡时间只对于固定排班和自定义排班两种类型有效
        // 5. 接口调用频率限制为600次/分钟（已在Service层实现批次间延迟）

        //接口返回的原始数据
        //{
        //   "errcode":0,
        //   "errmsg":"ok",
        //   "checkindata": [{
        //      "userid" : "james",
        //      "groupname" : "打卡一组",
        //      "checkin_type" : "上班打卡",
        //      "exception_type" : "地点异常",
        //      "checkin_time" : 1492617610,
        //      "location_title" : "依澜府",
        //      "location_detail" : "四川省成都市武侯区益州大道中段784号附近",
        //      "wifiname" : "办公一区",
        //      "notes" : "路上堵车，迟到了5分钟",
        //      "wifimac" : "3c:46:d8:0c:7a:70",
        //      "mediaids":["WWCISP_G8PYgRaOVHjXWUWFqchpBqqqUpGj0OyR9z6WTwhnMZGCPHxyviVstiv_2fTG8YOJq8L8zJT2T2OvTebANV-2MQ"],
        //      "sch_checkin_time" : 1492617610,
        //      "groupid" : 1,
        //      "schedule_id" : 0,
        //      "timeline_id" : 2
        //   },{
        //      "userid" : "paul",
        //      "groupname" : "打卡二组",
        //      "checkin_type" : "外出打卡",
        //      "exception_type" : "时间异常",
        //      "checkin_time" : 1492617620,
        //      "location_title" : "重庆出口加工区",
        //      "location_detail" : "重庆市渝北区金渝大道101号金渝大道",
        //      "wifiname" : "办公室二区",
        //      "notes" : "",
        //      "wifimac" : "3c:46:d8:0c:7a:71",
        //      "mediaids":["WWCISP_G8PYgRaOVHjXWUWFqchpBqqqUpGj0OyR9z6WTwhnMZGCPHxyviVstiv_2fTG8YOJq8L8zJT2T2OvTebANV-2MQ"],
        //      "lat": 30547645,
        //        "lng": 104063236,
        //      "deviceid":"E5FA89F6-3926-4972-BE4F-4A7ACF4701E2",
        //      "sch_checkin_time" : 1492617610,
        //      "groupid" : 2,
        //      "schedule_id" : 3,
        //      "timeline_id" : 1
        //   }]
        //}

        //checkindata的字段说明
        //userid   用户id
        //groupname   打卡规则名称
        //checkin_type   打卡类型。字符串，目前有：上班打卡，下班打卡，外出打卡，仅记录打卡时间和位置
        //exception_type   异常类型，字符串，包括：时间异常，地点异常，未打卡，wifi异常，非常用设备。如果有多个异常，以分号间隔
        //checkin_time   打卡时间。Unix时间戳
        //location_title   打卡地点title
        //location_detail   打卡地点详情
        //wifiname   打卡wifi名称
        //notes   打卡备注
        //wifimac   打卡的MAC地址/bssid
        //mediaids   打卡的附件media_id，可使用media/get获取附件
        //lat   位置打卡地点纬度，是实际纬度的1000000倍，与腾讯地图一致采用GCJ-02坐标系统标准
        //lng   位置打卡地点经度，是实际经度的1000000倍，与腾讯地图一致采用GCJ-02坐标系统标准
        //deviceid   打卡设备id
        //sch_checkin_time   标准打卡时间，指此次打卡时间对应的标准上班时间或标准下班时间
        //groupid   规则id，表示打卡记录所属规则的id
        //schedule_id   班次id，表示打卡记录所属规则中，所属班次的id
        //timeline_id   时段id，表示打卡记录所属规则中，某一班次中的某一时段的id，如上下班时间为9:00-12:00、13:00-18:00的班次中，9:00-12:00为其中一组时段

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

            long endTime = (currentTime / oneDaySeconds) * oneDaySeconds - 1;
            long startTime = endTime - oneDaySeconds + 1;

            // 验证时间跨度不超过30天
            long timeSpan = endTime - startTime;
            if (timeSpan > thirtyDaysSeconds) {
                System.out.println("✗ 时间跨度超过30天限制: " + (timeSpan / oneDaySeconds) + "天");
                return;
            }

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

            // 获取用户总数
            long totalUsers = qwStaffMapper.selectCount(new LambdaQueryWrapper<QwStaff>()
                    .isNotNull(QwStaff::getAccount)
                    .ne(QwStaff::getAccount, ""));
            System.out.println("  - QW_STAFF表用户总数: " + totalUsers);
            if (totalUsers > 100) {
                int batchCount = (int) ((totalUsers + 99) / 100);
                System.out.println("  - 将自动分批处理: " + batchCount + "批 (每批≤100用户)");
            }

            List<WorkWXService.CheckinData> checkinDataList = workWXService.getCheckinDataByQwStaff(startTime, endTime);

@@ -85,6 +176,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表无数据或时间范围内无打卡记录）");
            }
@@ -112,12 +208,26 @@
        try {
            long currentTime = System.currentTimeMillis() / 1000;
            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;

            System.out.println("  - 开始时间: " + new java.util.Date(startTime * 1000));
            System.out.println("  - 结束时间: " + new java.util.Date(endTime * 1000));
            long endTime = yesterdayEnd;
            long startTime = twentyDaysAgoStart;

            // 验证时间跨度不超过30天
            long timeSpan = endTime - startTime;
            if (timeSpan > thirtyDaysSeconds) {
                System.out.println("✗ 时间跨度超过30天限制: " + (timeSpan / oneDaySeconds) + "天");
                return;
            }

            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());
@@ -172,24 +282,16 @@
    }

    @Test
    void testGetUserDetail() {
        System.out.println("=== 开始测试获取用户详情 ===");
    void testSyncUsersToQwStaff() {
        System.out.println("=== 开始测试同步企业微信用户到QW_STAFF表 ===");

        try {
            String userid = "ShenJuanYue";
            WorkWXService.WorkWXUserDetail userDetail = workWXService.getUserDetail(userid);
            int insertCount = workWXService.syncUsersToQwStaff();

            if (userDetail != null && userDetail.getErrcode() == 0) {
                System.out.println("✓ 成功获取用户详情");
                System.out.println("  - userid: " + userDetail.getUserid());
                System.out.println("  - 姓名: " + userDetail.getName());
                System.out.println("  - 手机号: " + userDetail.getMobile());
                System.out.println("  - 职位: " + userDetail.getPosition());
            } else {
                System.out.println("✗ 获取用户详情失败");
            }
            System.out.println("✓ 同步完成");
            System.out.println("  - 新增用户数: " + insertCount);
        } catch (IOException e) {
            System.out.println("✗ 获取用户详情失败: " + e.getMessage());
            System.out.println("✗ 同步用户失败: " + e.getMessage());
            e.printStackTrace();
        }