From f2b62569198d9afd1604a1617ab1e0a3e11f74bf Mon Sep 17 00:00:00 2001
From: tjx <t2856754968@163.com>
Date: 星期四, 30 十月 2025 18:40:22 +0800
Subject: [PATCH] 增加条码的持久化逻辑
---
src/test/java/com/gs/xiaomi/XiaomiApplicationTests.java | 197 ++++++++++++++++++++++++++++++++----------------
1 files changed, 130 insertions(+), 67 deletions(-)
diff --git a/src/test/java/com/gs/xiaomi/XiaomiApplicationTests.java b/src/test/java/com/gs/xiaomi/XiaomiApplicationTests.java
index 43af6d3..955ab01 100644
--- a/src/test/java/com/gs/xiaomi/XiaomiApplicationTests.java
+++ b/src/test/java/com/gs/xiaomi/XiaomiApplicationTests.java
@@ -1,88 +1,151 @@
package com.gs.xiaomi;
-import com.alibaba.fastjson.JSON;
-import com.gs.xiaomi.config.DataAcquisitionConfiguration;
-import com.gs.xiaomi.dto.BizDocument;
-import com.gs.xiaomi.dto.BizDocumentResult;
-import com.gs.xiaomi.dto.ZfmWsApiRequest;
-import com.gs.xiaomi.util.SoapXmlBuilder;
+import cn.hutool.crypto.digest.DigestUtil;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.gs.xiaomi.dto.BCS101Request;
+import com.gs.xiaomi.dto.BCS101Response;
+import com.gs.xiaomi.dto.NumbericalDto;
+import com.gs.xiaomi.dto.SnListItemDto;
+import com.gs.xiaomi.entity.DeliveryMain;
+import com.gs.xiaomi.entity.SnListItem;
+import com.gs.xiaomi.service.BCS101ApiService;
+import com.gs.xiaomi.service.BCS101Service;
+import com.gs.xiaomi.service.DeliveryMainService;
+import com.gs.xiaomi.service.SnListItemService;
+import com.gs.xiaomi.service.Xm104Service;
+import com.gs.xiaomi.util.SnListItemConverter;
import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
-import javax.xml.bind.JAXBContext;
-import javax.xml.bind.Unmarshaller;
-import java.io.StringReader;
+import java.io.IOException;
+import java.util.List;
+import java.util.stream.Collectors;
@SpringBootTest
class XiaomiApplicationTests {
+ @Autowired
+ private Xm104Service xm104Service;
+
+ @Autowired
+ private BCS101ApiService bcs101ApiService;
+
+ @Autowired
+ private DeliveryMainService deliveryMainService;
+
+ @Autowired
+ private SnListItemService snListItemService;
+
+ @Autowired
+ private BCS101Service bcs101Service;
+
@Test
void contextLoads() throws Exception {
- ZfmWsApiRequest req = new ZfmWsApiRequest();
- req.setIvCode(DataAcquisitionConfiguration.IV_CODEXM104);
- req.setIvEvent("");
- req.setIvFlag("");
- BizDocument doc = new BizDocument();
- doc.setBizDate("2025-04-01");
- doc.setLifnr(DataAcquisitionConfiguration.LIFNR);
- req.setIvInfo(doc);
- req.setIvPass(DataAcquisitionConfiguration.getIvPass(DataAcquisitionConfiguration.IV_CODEXM104));
- req.setIvUser(DataAcquisitionConfiguration.IV_USER);
- String soapXml = SoapXmlBuilder.build(req);
- System.out.println(soapXml);
+ xm104Service.getDb();
+ }
+
+ //manualSynchronization
+ @Test
+ void contextLoads1() throws Exception {
+ NumbericalDto barcode = new NumbericalDto();
+ barcode.setAsn("9316702418");
+ xm104Service.manualSynchronization(barcode);
}
@Test
- void contextLoads2() throws Exception {
- String bodyStr = "<SOAP:Envelope xmlns:SOAP='http://schemas.xmlsoap.org/soap/envelope/'>" +
- " <SOAP:Header/>" +
- " <SOAP:Body xmlns:urn='urn:sap-com:document:sap:rfc:functions'>" +
- " <n0:ZFM_WS_APIResponse xmlns:n0='urn:sap-com:document:sap:rfc:functions' xmlns:prx='urn:sap.com:proxy:FRD:/1SAI/TAS82FD47019F21003C052D:752'>" +
- " <EV_CODE>Y</EV_CODE>" +
- " <EV_EVENT/>" +
- " <EV_FLAG/>" +
- " <EV_RESULT><?xml version=\"1.0\" encoding=\"utf-8\"?><document><et_headers type=\"h\"><et_header idx=\"1\"><zzasn>9311031471</zzasn><zzasn_type>BL</zzasn_type><imclr></imclr><lifnr>0000177301</lifnr><vendor_name>娴欐睙灏忔鍑鸿鏈夐檺鍏徃</vendor_name><zzship_addr>娴嬭瘯</zzship_addr><zzship_name>11</zzship_name><zzship_phon>1111</zzship_phon><zzship_date>2025-04-01</zzship_date><zzwarehouse_id>0000017560</zzwarehouse_id><zzwarehouse>涓皬浠�-鍖椾含涓績浠�</zzwarehouse><zzreceive_addr>鍖椾含甯傚ぇ鍏村尯缁忔祹寮�鍙戝尯绉戝垱鍗佽鍗佷簲鍙�(浜﹀簞灏忕背浜т笟鍥�)T1妤�1灞�</zzreceive_addr><zzcarrier></zzcarrier><zzdriver_name></zzdriver_name><zzdriver_phon></zzdriver_phon><zzarrive_time>20250402</zzarrive_time><zzarrive_time1>00:00:00</zzarrive_time1><zzcarrier_no></zzcarrier_no><road_transport_no></road_transport_no><zztrans_model></zztrans_model><zzdriver_license></zzdriver_license><zzlicense_numb></zzlicense_numb><zzseal_no></zzseal_no><zzcanceled></zzcanceled><ship_email>11@163.com</ship_email><lifnr_dg></lifnr_dg><short_name></short_name><reserve_date></reserve_date><reserve_time></reserve_time><bukrs>1110</bukrs><asn_desc></asn_desc><price_stat></price_stat><final_contact></final_contact><final_phone></final_phone><final_addr></final_addr><final_company></final_company><status>S002</status><status_sn></status_sn><purchase_mode></purchase_mode><hub_lifnr></hub_lifnr><items type=\"h\"><item idx=\"1\"><zzasn>9311031471</zzasn><zzitem_id>0000000010</zzitem_id><zzpo_no>4500173648</zzpo_no><zzpo_item_id>0000000010</zzpo_item_id><zzreqnr></zzreqnr><zzreqln></zzreqln><zzproduct_id>950102000010</zzproduct_id><zzvproduct_id></zzvproduct_id><zzsku>BHR4008CN</zzsku><zzquantity>5.000</zzquantity><zzunit>ST</zzunit><brand></brand><place></place><brand_type></brand_type><is_identification></is_identification><zzopen_qty>5.000</zzopen_qty><changed_at>20250401071304</changed_at><created_at>20250401071304</created_at><app_models>11-AD</app_models><ext_doc_no>8897300</ext_doc_no><ext_doc_item>2884654</ext_doc_item><address_detail>鍖椾含甯傚ぇ鍏村尯缁忔祹寮�鍙戝尯绉戝垱鍗佽鍗佷簲鍙�(浜﹀簞灏忕背浜т笟鍥�)T1妤�1灞�</address_detail><batch_id></batch_id><batch_row></batch_row><xmsto_no></xmsto_no><xmsto_item_no></xmsto_item_no><modelnumber></modelnumber><shipment_id></shipment_id><shipmentid_num>0</shipmentid_num><maktx>绫冲鏅鸿兘渚у惛娌圭儫鏈�</maktx><bednr></bednr><ware_type_from></ware_type_from><ware_type_to></ware_type_to><act_gr_qty>0.000</act_gr_qty><pn_matnr_l></pn_matnr_l><pn_matnr_name></pn_matnr_name></item></items><box_items type=\"h\"></box_items><box_sums type=\"h\"></box_sums><purchase_mode2></purchase_mode2><receiver>鏉ㄤ腹涓�,鍛ㄦ櫒鍏�</receiver><receive_phone>18811578183,13002157815</receive_phone><receive_addr>鍖椾含甯傚ぇ鍏村尯缁忔祹寮�鍙戝尯绉戝垱鍗佽鍗佷簲鍙�(浜﹀簞灏忕背浜т笟鍥�)T1妤�1灞�</receive_addr><receive_warehouse_id>0000017560</receive_warehouse_id><receive_warehouse_short>涓皬浠�-鍖椾含涓績浠�</receive_warehouse_short><product_type>GM</product_type><ekorg>2120</ekorg><ekotx></ekotx><stock_org_from></stock_org_from><stock_org_from_desc></stock_org_from_desc><stock_org_to>MI_IOT</stock_org_to><stock_org_to_desc>鐢熸�侀摼搴撳瓨缁勭粐(IOT)</stock_org_to_desc><migo_type></migo_type><zrproject>A1</zrproject><logistics_no></logistics_no><logistics_company></logistics_company><last4_phone_number></last4_phone_number><logistics_company_name></logistics_company_name><business_model></business_model></et_header></et_headers><ev_message></ev_message><ev_msgty>S</ev_msgty></document></EV_RESULT>" +
- " </n0:ZFM_WS_APIResponse>" +
- " </SOAP:Body>" +
- "</SOAP:Envelope>";
-
- String evCode = extractEvCode(bodyStr);
- if (!"Y".equalsIgnoreCase(evCode)) {
- throw new RuntimeException("SOAP business failed, EV_CODE: " + evCode);
- }
-
- String decodedXml = decodeXmlEntities(bodyStr);
-
- String innerXml = extractCdata(decodedXml);
- if (innerXml == null) throw new RuntimeException("No CDATA <document> found in response");
-
-
- JAXBContext context = JAXBContext.newInstance(BizDocumentResult.class);
- Unmarshaller unmarshaller = context.createUnmarshaller();
- BizDocumentResult unmarshal = (BizDocumentResult) unmarshaller.unmarshal(new StringReader(innerXml));
- System.out.println(JSON.toJSONString(unmarshal));
+ void test() {
+// String str = ",,";
+// String[] parts = str.split(",");
+// for (String part : parts) {
+// System.out.println(part);
+// }
+ System.out.println(DigestUtil.md5Hex("VDATA.XM104/177301/c5Kl}xN&i(").toUpperCase());
}
- private String extractEvCode(String xml) {
- int start = xml.indexOf("<EV_CODE>");
- int end = xml.indexOf("</EV_CODE>", start);
- if (start == -1 || end == -1) return null;
- return xml.substring(start + 9, end).trim();
+ @Test
+ void testBCS101ApiService() throws Exception {
+
+ List<DeliveryMain> list = deliveryMainService.list();
+
+ //List<String> collect = list.stream().map(DeliveryMain::getZzasn).collect(Collectors.toList());
+
+ list.forEach(s -> {
+ System.out.println(String.valueOf(Integer.parseInt(s.getLifnr())) + ":" + s.getZzasn());
+ // 鍒涘缓娴嬭瘯璇锋眰鍙傛暟
+ BCS101Request request = new BCS101Request();
+ request.setSupplierId(String.valueOf(Integer.parseInt(s.getHubLifnr())));
+ request.setDocNo(s.getZzasn());
+ request.setDocType("ASNGR");
+ request.setPageNo(1);
+ request.setPageSize(1000);
+
+ // 璋冪敤API鑾峰彇鍘熷JSON瀛楃涓�
+ String bcs101Data = null;
+ try {
+ bcs101Data = bcs101ApiService.getBCS101Data(request);
+ } catch (IOException e) {
+ throw new RuntimeException(e);
+ }
+ System.out.println("鍘熷鍝嶅簲: " + bcs101Data);
+
+ // 瑙ｆ瀽JSON涓築CS101Response瀵硅薄
+ ObjectMapper objectMapper = new ObjectMapper();
+ try {
+ BCS101Response response = objectMapper.readValue(bcs101Data, BCS101Response.class);
+
+ // 妫�鏌ュ搷搴旀槸鍚︽垚鍔�
+ if (response.isSuccess()) {
+ // 鑾峰彇snList鏁版嵁
+ List<SnListItemDto> snList = response.getBody().getSnList();
+
+ if (snList != null && !snList.isEmpty()) {
+ System.out.println("鑾峰彇鍒� " + snList.size() + " 鏉N鏁版嵁锛屽紑濮嬫寔涔呭寲...");
+
+ // 杞崲DTO涓篍ntity锛屽苟璁剧疆鍏宠仈淇℃伅
+ List<SnListItem> entityList = SnListItemConverter.toEntityList(
+ snList,
+ s.getId(), // deliveryMainId - 閫佽揣鍗曚富琛↖D
+ s.getZzasn() // zzasn - 閫佽揣鍗曞彿
+ );
+
+ // 鍏堝垹闄よ閫佽揣鍗曞凡鏈夌殑SN鏁版嵁锛堥伩鍏嶉噸澶嶏級
+ snListItemService.lambdaUpdate()
+ .eq(SnListItem::getZzasn, s.getZzasn())
+ .remove();
+
+ // 鎵归噺淇濆瓨鍒版暟鎹簱
+ boolean saved = snListItemService.saveBatch(entityList);
+
+ if (saved) {
+ System.out.println("鎴愬姛淇濆瓨 " + entityList.size() + " 鏉N鏁版嵁鍒版暟鎹簱");
+ } else {
+ System.err.println("淇濆瓨SN鏁版嵁澶辫触锛�");
+ }
+ } else {
+ System.out.println("鍝嶅簲涓病鏈塖N鏁版嵁");
+ }
+ } else {
+ System.err.println("BCS101鎺ュ彛璋冪敤澶辫触: " + response.getErrorDesc());
+ }
+
+ } catch (JsonProcessingException e) {
+ throw new RuntimeException(e);
+ }
+ });
}
- private String decodeXmlEntities(String xml) {
- return xml.replace("<", "<")
- .replace(">", ">")
- .replace("<", "<")
- .replace(">", ">")
- .replace("&", "&");
- }
- private String extractCdata(String xml) {
- int cdataStart = xml.indexOf("<EV_RESULT>");
- int cdataEnd = xml.indexOf("</EV_RESULT>", cdataStart);
- if (cdataStart == -1 || cdataEnd == -1) return null;
- return xml.substring(cdataStart + 11, cdataEnd).trim();
+ /**
+ * 娴嬭瘯BCS101鏁版嵁鍚屾 - 浣跨敤BCS101Service
+ * @param asn 閫佽揣鍗曞彿
+ * @throws Exception 寮傚父
+ */
+ @Test
+ void testGetBCS101() throws Exception {
+ // 鐩存帴璋冪敤BCS101Service杩涜鏁版嵁鍚屾
+ bcs101Service.syncBCS101DataByAsn("9316702418");
}
-
}
--
Gitblit v1.9.3