~tjx/xiekeyun.git

			@@ -1,20 +1,19 @@
			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.config.ApiResponse;
			import com.gs.xky.config.BodyParam;
			import com.gs.xky.config.DataAcquisitionConfiguration;
			import com.gs.xky.config.XkyCommonParam;
			import com.gs.xky.dto.BarcodeDeliveryNo;
			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 com.gs.xky.entity.MesInvItemArn;
			import com.gs.xky.service.*;
			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 {
			@@ -29,10 +28,22 @@
			@Autowired
			private MesStaffService staffService;

			@Autowired
			private DeliveryNoticeService deliveryNoticeService;

			@Autowired
			private TblBarcodeInformationService barcodeInformationService;

			@Autowired
			private MesInvItemArnService invItemArnService;

			@Test
			void contextLoads() throws IOException {

			xkyService.GetSaveDetail();
			List<MesInvItemArn> itemArnMinus = invItemArnService.getItemArnMinus();

			deliveryNoticeService.processMesInvItemArnStatusAsync(itemArnMinus);

			}

			@Test
			@@ -43,51 +54,82 @@
			BodyParam bodyParam = new BodyParam();

			bodyParam.setErpCode(DataAcquisitionConfiguration.TEST_ERP_CODE);
			bodyParam.setDeliveryNo("22250212VVWU");
			bodyParam.setDeliveryNo("222504279H65");
			bodyParam.setStatus(new int[]{1, 6});

			param.setBody(bodyParam);

			ApiResponse<XkyDetail> noList = apiService.sendListRequest(param, XkyDetail.class, "https://openapi.xiekeyun.com/delivery/getDetail.json");
			ApiResponse<XkyDetail> detail = apiService.sendListRequest(param, XkyDetail.class, "https://openapi.xiekeyun.com/delivery/getDetail.json");

			System.out.println(JSON.toJSONString(noList.getData()));
			XkyDetail deliveryNo = detail.getData();
			// List<LineList> collect = deliveryNo.getLineList().stream().filter(s -> "1".equals(s.getStatus())).collect(Collectors.toList());
			// System.out.println(JSON.toJSONString(collect));
			deliveryNoticeService.saveDeliveryNotice(deliveryNo);
			List<BarcodeDeliveryNo> barcodeDeliveryNos = GetBarcodeInformation(deliveryNo.getDeliveryNo());
			barcodeInformationService.SaveBarcodeInformation(barcodeDeliveryNos, deliveryNo.getDeliveryNo());

			deliveryNoticeService.callPdaReceiptBtn("送货单签收[BTNOK[PL017[" + deliveryNo.getDeliveryNo(), "");
			}

			private List<BarcodeDeliveryNo> GetBarcodeInformation(String deliveryNo) throws IOException {
			XkyCommonParam param = XkyCommonParam.GetInit();

			// 创建 BodyParam 对象并赋值
			BodyParam bodyParam = new BodyParam();

			bodyParam.setErpCode(DataAcquisitionConfiguration.TEST_ERP_CODE);
			bodyParam.setDeliveryNo(deliveryNo);

			param.setBody(bodyParam);


			ApiResponse<BarcodeDeliveryNo> noList = apiService.sendListRequest(param, BarcodeDeliveryNo.class, "https://openapi.xiekeyun.com/barcode/byDeliveryNo.json");

			return noList.getDataList();
			}

			@Test
			void cs1() throws IOException {
			DingTalkParam dingTalkParam = new DingTalkParam();

			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);
			});
			// 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);
			// 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);
			// });

			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\\\":[{}]}}\"}";

			}
			}