From 878014fe71ae76d4bfbc885f1daab8921c60f6ac Mon Sep 17 00:00:00 2001
From: lty <876263681@qq.com>
Date: 星期六, 13 十二月 2025 17:26:24 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/asrs/task/kingdee/handler/SaveOrderSyncHandler.java | 105 +++++++++++++++++++++++++++++++++++++++++-----------
1 files changed, 83 insertions(+), 22 deletions(-)
diff --git a/src/main/java/com/zy/asrs/task/kingdee/handler/SaveOrderSyncHandler.java b/src/main/java/com/zy/asrs/task/kingdee/handler/SaveOrderSyncHandler.java
index c8f8fdd..69f920a 100644
--- a/src/main/java/com/zy/asrs/task/kingdee/handler/SaveOrderSyncHandler.java
+++ b/src/main/java/com/zy/asrs/task/kingdee/handler/SaveOrderSyncHandler.java
@@ -36,6 +36,10 @@
@Value("${erp.address.imPurinbillAdd}")
private String imPurinbillAdd;
+ @Value("${erp.address.imOtheroutbill}")
+ private String imOtheroutbill;
+ @Value("${erp.address.imOtherinbill}")
+ private String imOtherinbill;
@Autowired
private OrderService orderService;
@@ -82,7 +86,8 @@
private JSONObject buildRequestParams(Order order, KingDeeUtilType kingDeeUtilType, SimpleDateFormat sdf1, SimpleDateFormat sdf2) {
List<OrderDetl> orderDetlList = orderDetlService.selectList(new EntityWrapper<OrderDetl>().eq("order_no",order.getOrderNo()));
- if(kingDeeUtilType == null){
+ if (kingDeeUtilType == null || kingDeeUtilType.formId == null) {
+ log.warn("kingDeeUtilType 涓虹┖锛屽凡璺宠繃鏈鍚屾锛�");
return null;
}
switch (kingDeeUtilType.formId) {
@@ -92,8 +97,9 @@
JSONArray billentryArray = new JSONArray(); // 鐢ㄤ簬瀛樺偍 billentry 瀵硅薄
String suppCode = null; // 渚涘簲鍟�
String boxType2 = null; // 璐т富/璐ф簮
-
// 閬嶅巻璁㈠崟璇︽儏
+ Date now = new Date();
+
for (OrderDetl orderDetl : orderDetlList) {
suppCode = orderDetl.getSuppCode();
boxType2 = orderDetl.getBoxType2();
@@ -101,8 +107,7 @@
continue;
}
// JSONArray idArr = new JSONArray();
-// idArr.add(0L); // 鉁� 娉ㄦ剰蹇呴』鏄� Long 绫诲瀷鐨� 0L
-// Double reportNum = orderDetl.getQty() - orderDetl.getWorkQty();//涓婃姤鏁伴噺鍑忓幓宸蹭笂鎶ユ暟閲�
+// idArr.add(0L);
// 鍒涘缓 billentry_lk 瀵硅薄
JSONObject billentryLk = new JSONObject()
.fluentPut("id", 0L)
@@ -124,11 +129,9 @@
.fluentPut("qty", orderDetl.getQty()) // 鏁伴噺
.fluentPut("material_number", orderDetl.getMatnr()) // 鐗╂枡缂栧彿
.fluentPut("billentry_lk", billentryLkArray);
+
billentryArray.add(billentry);
-// orderDetl.setWorkQty(orderDetl.getQty());
-// orderDetlService.updateById(orderDetl);//灏嗕笂鎶ユ暟瑕嗙洊鍒板巻鍙蹭笂
}
- Date now = new Date();
return new JSONObject()
.fluentPut("data", new JSONArray(Arrays.asList(
new JSONObject()
@@ -146,9 +149,73 @@
.fluentPut("supplier_number", suppCode) // 渚涘簲鍟嗙紪鍙�
.fluentPut("billentry", billentryArray) // 灏� billentry 鏁扮粍娣诲姞鍒拌姹傚弬鏁�
)));
-
+ case "STK_MISCELLANEOUS": // 鍏朵粬鍏ュ簱鍗�
+ path = imOtherinbill;
+ billentryArray = new JSONArray();
+ for (OrderDetl orderDetl : orderDetlList) {
+ if (orderDetl.getQty() == 0) {
+ continue;
+ }
+ JSONObject billentry = new JSONObject()
+ .fluentPut("id", 0L)
+ .fluentPut("material_number", orderDetl.getMatnr()) // 鐗╂枡缂栫爜
+ .fluentPut("qty", orderDetl.getQty()) // 鏁伴噺
+ .fluentPut("warehouse_number", "CK001") // 浠撳簱
+ .fluentPut("invstatus_number", "110")
+ .fluentPut("invtype_number", "110")
+ .fluentPut("outinvstatus_number", "110")
+ .fluentPut("outinvtype_number", "110")
+ .fluentPut("linetype_number", "010");
+ billentryArray.add(billentry);
+ }
+ Date nowMis = new Date();
+ return new JSONObject()
+ .fluentPut("data", new JSONArray(Arrays.asList(
+ new JSONObject()
+// .fluentPut("id", 0L)
+ .fluentPut("billno", order.getOrderNo())
+// .fluentPut("bookdate", sdf1.format(nowMis))
+ .fluentPut("biztime", sdf1.format(nowMis))
+ .fluentPut("biztype_number", "354")
+ .fluentPut("billtype_number", "im_OtherInBill_STD_BT_S")
+ .fluentPut("org_number", "BU-00001")
+ .fluentPut("invscheme_number", "354")
+ .fluentPut("billentry", billentryArray)
+ )));
+ case "STK_MisDelivery": // 鍏朵粬鍑哄簱鍗�
+ path = imOtheroutbill;
+ billentryArray = new JSONArray();
+ Date nowOut = new Date();
+ for (OrderDetl orderDetl : orderDetlList) {
+ if (orderDetl.getQty() == 0) {
+ continue;
+ }
+ JSONObject billentry = new JSONObject()
+ .fluentPut("id", 0L)
+ .fluentPut("material_number", orderDetl.getMatnr()) // 鐗╂枡缂栫爜
+ .fluentPut("qty", orderDetl.getQty()) // 鏁伴噺
+ .fluentPut("warehouse_number", "CK001") // 浠撳簱
+ .fluentPut("invstatus_number", "110")
+ .fluentPut("invtype_number", "110")
+ .fluentPut("outinvstatus_number", "110")
+ .fluentPut("outinvtype_number", "110")
+ .fluentPut("linetype_number", "010");
+ billentryArray.add(billentry);
+ }
+ return new JSONObject()
+ .fluentPut("data", new JSONArray(Arrays.asList(
+ new JSONObject()
+// .fluentPut("id", 0L)
+ .fluentPut("billno", order.getOrderNo())
+// .fluentPut("bookdate", sdf1.format(nowMis))
+ .fluentPut("biztime", sdf1.format(nowOut))
+ .fluentPut("biztype_number", "354")
+ .fluentPut("billtype_number", "im_OtherInBill_STD_BT_S")
+ .fluentPut("org_number", "BU-00001")
+ .fluentPut("invscheme_number", "354")
+ .fluentPut("billentry", billentryArray)
+ )));
default:
- // 榛樿澶勭悊锛氬彲浠ユ姏鍑哄紓甯告垨杩斿洖绌哄璞�
throw new IllegalArgumentException("Unsupported formId: " + kingDeeUtilType.formId);
}
}
@@ -157,11 +224,9 @@
private ReturnT<String> sendRequestAndProcessResponse(Order order, ErpSecret erpSecret, JSONObject add) {
String response = "";
boolean success = false;
-
try {
// 璁剧疆璇锋眰澶�
HashMap<String, Object> headers = buildRequestHeaders(erpSecret);
-
// 鍙戦�佽姹傦紝灏� JSONObject 杞崲涓� String
response = new HttpHandler.Builder()
.setHeaders(headers)
@@ -170,10 +235,8 @@
.setJson(add.toJSONString()) // 灏� JSONObject 杞崲涓� String
.build()
.doPost();
-
// 瑙ｆ瀽鍝嶅簲
JSONObject jsonResponse = JSON.parseObject(response);
-
// 鍒ゆ柇鏄惁鍥犱负 token 杩囨湡 (errorCode = 401)
if ("401".equals(jsonResponse.getString("errorCode"))) {
log.error("璁よ瘉澶辫触锛屽皾璇曢噸鏂拌幏鍙� Token");
@@ -190,18 +253,15 @@
.build()
.doPost();
}
-
// 瑙ｆ瀽杩斿洖鐨勫搷搴�
JSONObject data = jsonResponse.getJSONObject("data");
String errorCode = jsonResponse.getString("errorCode");
boolean status = jsonResponse.getBooleanValue("status");
-
// 妫�鏌ユ帴鍙ｈ皟鐢ㄧ殑鏁翠綋鐘舵��
if ("0".equals(errorCode) && status) {
// 鑾峰彇鎴愬姛涓庡け璐ョ殑鏁伴噺
int successCount = data.getInteger("successCount");
int failCount = data.getInteger("failCount");
-
if (failCount == 0) {
success = true;
log.info("鎺ュ彛璋冪敤鎴愬姛锛屾垚鍔熺殑鎿嶄綔鏁伴噺: {}", successCount);
@@ -211,10 +271,12 @@
JSONObject resultItem = resultArray.getJSONObject(i);
String billNo = resultItem.getString("number"); // 鑾峰彇杩斿洖鐨勫崟鎹彿
String billId = resultItem.getString("id"); // 鑾峰彇杩斿洖鐨処D
- order.setNumber(billId);
- orderService.updateById(order);
- log.info("璁㈠崟鍙� {} 涓庤繑鍥炵殑鍗曟嵁鍙峰尮閰嶏紝璁剧疆璁㈠崟 ID 涓� {}", order.getOrderNo(), billId);
-
+ // 鍒ゆ柇杩斿洖鐨勫崟鎹彿涓庤鍗曞彿鏄惁涓�鑷�
+ if (billNo != null && billNo.equals(order.getOrderNo())) {
+ // 濡傛灉涓�鑷达紝璁剧疆璁㈠崟鐨� number
+ order.setNumber(billId);
+ log.info("璁㈠崟鍙� {} 涓庤繑鍥炵殑鍗曟嵁鍙峰尮閰嶏紝璁剧疆璁㈠崟 ID 涓� {}", order.getOrderNo(), billId);
+ }
}
} else {
log.error("鎺ュ彛璋冪敤澶辫触锛屽け璐ョ殑鎿嶄綔鏁伴噺: {}", failCount);
@@ -242,7 +304,6 @@
// 淇濆瓨鎺ュ彛鏃ュ織
saveApiLog(add, response, success);
}
-
return success ? SUCCESS : FAIL;
}
@@ -256,7 +317,7 @@
private void saveApiLog(JSONObject add, String response, boolean success) {
try {
apiLogService.save(
- "杩涗粨閫氱煡鍗曚笂鎶ユ柊澧�",
+ "鍏ュ簱涓婃姤鏂板",
URL + path,
null,
"127.0.0.1",
--
Gitblit v1.9.1