From 9f41157c7f75c5f60109ee7dce0422f693d9e1d1 Mon Sep 17 00:00:00 2001 From: 啊鑫 <t2856754968@163.com> Date: 星期四, 20 三月 2025 10:51:02 +0800 Subject: [PATCH] 钉钉获取人员的接口 --- src/test/java/com/gs/xky/XkyApplicationTests.java | 57 +++++++++++++++++++++++++++++++++++++++++++++++++++++---- 1 files changed, 53 insertions(+), 4 deletions(-) diff --git a/src/test/java/com/gs/xky/XkyApplicationTests.java b/src/test/java/com/gs/xky/XkyApplicationTests.java index 83d8dec..5cf4208 100644 --- a/src/test/java/com/gs/xky/XkyApplicationTests.java +++ b/src/test/java/com/gs/xky/XkyApplicationTests.java @@ -1,18 +1,20 @@ package com.gs.xky; +import cn.hutool.core.collection.ListUtil; import com.alibaba.fastjson2.JSON; -import com.gs.xky.config.ApiResponse; -import com.gs.xky.config.BodyParam; -import com.gs.xky.config.DataAcquisitionConfiguration; -import com.gs.xky.config.XkyCommonParam; +import com.gs.xky.config.*; +import com.gs.xky.dto.EmployeeInfo; import com.gs.xky.dto.XkyDetail; import com.gs.xky.service.ApiService; +import com.gs.xky.service.MesStaffService; import com.gs.xky.service.XkyService; import org.junit.jupiter.api.Test; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; import java.io.IOException; +import java.util.List; +import java.util.stream.Collectors; @SpringBootTest class XkyApplicationTests { @@ -23,6 +25,9 @@ @Autowired private ApiService apiService; + + @Autowired + private MesStaffService staffService; @Test void contextLoads() throws IOException { @@ -47,4 +52,48 @@ System.out.println(JSON.toJSONString(noList.getData())); } + @Test + void cs1() throws IOException { +// DingTalkParam dingTalkParam = new DingTalkParam(0); +// +// DingTalkResponse<EmployeeInfo> employeeInfoDingTalkResponse = apiService.sendListRequest(dingTalkParam, EmployeeInfo.class, "http://192.168.1.64/eHR/eHRExternalService/Service.ashx"); +// +// //閫犳ⅵ鑰咃紙娴欐睙锛夌鎶�鏈夐檺鍏徃 cUnitName +// //http://192.168.1.64/eHR +// List<EmployeeInfo> collect = employeeInfoDingTalkResponse.getData().stream().filter(s -> "閫犳ⅵ鑰咃紙娴欐睙锛夌鎶�鏈夐檺鍏徃".equals(s.getCUnitName())).collect(Collectors.toList()); +// System.out.println(collect.size()); +// +// List<List<EmployeeInfo>> partition = ListUtil.partition(collect, 500); +// +// partition.forEach(list -> { +// staffService.SaveStaff(list); +// }); + + } + + + @Test + void cs2() throws IOException { + DingTalkParam dingTalkParam = new DingTalkParam(1); + + DingTalkResponse<EmployeeInfo> employeeInfoDingTalkResponse = apiService.sendListRequest(dingTalkParam, EmployeeInfo.class, "http://192.168.1.64/eHR/eHRExternalService/Service.ashx"); + + //閫犳ⅵ鑰咃紙娴欐睙锛夌鎶�鏈夐檺鍏徃 cUnitName + //http://192.168.1.64/eHR + List<EmployeeInfo> collect = employeeInfoDingTalkResponse.getData().stream().filter(s -> "閫犳ⅵ鑰咃紙娴欐睙锛夌鎶�鏈夐檺鍏徃".equals(s.getCUnitName())).collect(Collectors.toList()); + System.out.println(collect.size()); + + List<List<EmployeeInfo>> partition = ListUtil.partition(collect, 100); + + partition.forEach(list -> { + staffService.UpdateStaff(list); + }); + + } + + @Test + void cs3() throws IOException { + String str = "{\"state\":\"500\",\"msg\":\"{\\\"Result\\\":{\\\"ResponseStatus\\\":{\\\"ErrorCode\\\":500,\\\"IsSuccess\\\":false,\\\"Errors\\\":[{\\\"FieldName\\\":null,\\\"Message\\\":\\\"鏄庣粏淇℃伅绗�1琛岀殑鐢熶骇閫氱煡鍗曞�间负:銆�127147銆戜笉瀛樺湪锛沑\\\r\\\\n\\\",\\\"DIndex\\\":0}],\\\"SuccessEntitys\\\":[],\\\"SuccessMessages\\\":[],\\\"MsgCode\\\":11},\\\"Id\\\":\\\"\\\",\\\"Number\\\":\\\"\\\",\\\"NeedReturnData\\\":[{}]}}\"}"; + + } } \ No newline at end of file -- Gitblit v1.9.3