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 | 76 ++++++++++++++++++++++++++++++++++++++ 1 files changed, 76 insertions(+), 0 deletions(-) diff --git a/src/test/java/com/gs/xky/XkyApplicationTests.java b/src/test/java/com/gs/xky/XkyApplicationTests.java index 7344742..5cf4208 100644 --- a/src/test/java/com/gs/xky/XkyApplicationTests.java +++ b/src/test/java/com/gs/xky/XkyApplicationTests.java @@ -1,11 +1,20 @@ package com.gs.xky; +import cn.hutool.core.collection.ListUtil; +import com.alibaba.fastjson2.JSON; +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 { @@ -14,10 +23,77 @@ @Autowired private XkyService xkyService; + @Autowired + private ApiService apiService; + + @Autowired + private MesStaffService staffService; + @Test void contextLoads() throws IOException { xkyService.GetSaveDetail(); } + @Test + void cs() throws IOException { + XkyCommonParam param = XkyCommonParam.GetInit(); + + // 鍒涘缓 BodyParam 瀵硅薄骞惰祴鍊� + BodyParam bodyParam = new BodyParam(); + + bodyParam.setErpCode(DataAcquisitionConfiguration.TEST_ERP_CODE); + bodyParam.setDeliveryNo("22250212VVWU"); + + param.setBody(bodyParam); + + ApiResponse<XkyDetail> noList = apiService.sendListRequest(param, XkyDetail.class, "https://openapi.xiekeyun.com/delivery/getDetail.json"); + + 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