From b8b017c64b4b05a596b95406fed7b1af9f4c6ba8 Mon Sep 17 00:00:00 2001 From: 啊鑫 <t2856754968@163.com> Date: 星期一, 26 五月 2025 20:07:28 +0800 Subject: [PATCH] 添加srm与U9订单数据的对比 --- src/test/java/com/gs/xky/XkyApplicationTests.java | 143 +++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 142 insertions(+), 1 deletions(-) diff --git a/src/test/java/com/gs/xky/XkyApplicationTests.java b/src/test/java/com/gs/xky/XkyApplicationTests.java index 7344742..b56bdd9 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 com.gs.xky.service.XkyService; +import com.alibaba.fastjson.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.dto.BarcodeDeliveryNo; +import com.gs.xky.dto.XkyDetail; +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; @SpringBootTest class XkyApplicationTests { @@ -14,10 +23,142 @@ @Autowired private XkyService xkyService; + @Autowired + private ApiService apiService; + + @Autowired + private MesStaffService staffService; + + @Autowired + private DeliveryNoticeService deliveryNoticeService; + + @Autowired + private TblBarcodeInformationService barcodeInformationService; + + @Autowired + private MesInvItemArnService invItemArnService; + @Autowired + private PurchaseService service; + @Test void contextLoads() throws IOException { + List<MesInvItemArn> itemArnMinus = invItemArnService.getItemArnMinus(); + + deliveryNoticeService.processMesInvItemArnStatusAsync(itemArnMinus); + + } + + @Test + public void getDeviceRealTimeData() throws IOException { xkyService.GetSaveDetail(); } + @Test + void cs() throws IOException { + + String str = "22250510W8LC"; + + + String[] split = str.split(";"); + + for (String s : split) { + XkyCommonParam param = XkyCommonParam.GetInit(); + + // 鍒涘缓 BodyParam 瀵硅薄骞惰祴鍊� + BodyParam bodyParam = new BodyParam(); + + bodyParam.setErpCode(DataAcquisitionConfiguration.TEST_ERP_CODE); + bodyParam.setDeliveryNo(s); + + param.setBody(bodyParam); + + ApiResponse<XkyDetail> detail = apiService.sendListRequest(param, XkyDetail.class, "https://openapi.xiekeyun.com/delivery/getDetail.json"); + + XkyDetail deliveryNo = detail.getData(); + if ("6".equals(deliveryNo.getStatus()) || "0".equals(deliveryNo.getLogisticsStatus())) { +// remove(deliveryNo); + } else if ("1".equals(deliveryNo.getStatus()) && ("2".equals(deliveryNo.getLogisticsStatus()) || "1".equals(deliveryNo.getLogisticsStatus()))) { + XkyDetail detail1 = deliveryNo; + deliveryNoticeService.saveDeliveryNotice(detail1); + List<BarcodeDeliveryNo> barcodeDeliveryNos = GetBarcodeInformation(deliveryNo.getDeliveryNo()); + barcodeInformationService.SaveBarcodeInformation(barcodeDeliveryNos, deliveryNo.getDeliveryNo()); + if ("2".equals(deliveryNo.getLogisticsStatus())) { + deliveryNoticeService.callPdaReceiptBtn("閫佽揣鍗曠鏀禰BTNOK[PL017[" + deliveryNo.getDeliveryNo(), ""); + } + } +// 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(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); +// }); + XkyCommonParam param = XkyCommonParam.GetInit(); + String jsonString = JSON.toJSONString(param); + System.out.println(jsonString); + } + + @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 { + + service.syncPurchaseOrderDetails(); + } } \ No newline at end of file -- Gitblit v1.9.3