From d18505cc87fa30a5b202057bbcc4236986efc80a Mon Sep 17 00:00:00 2001
From: pang.jiabao <pang_jiabao@163.com>
Date: 星期三, 11 三月 2026 13:16:55 +0800
Subject: [PATCH] 纽维盛wms初始化-截至现在wms2.0已完善(带数据库)
---
src/main/java/com/zy/asrs/task/handler/OrderPakinSyncHandler.java | 77 +++++++++++++++++++++++++++++++++-----
1 files changed, 67 insertions(+), 10 deletions(-)
diff --git a/src/main/java/com/zy/asrs/task/handler/OrderPakinSyncHandler.java b/src/main/java/com/zy/asrs/task/handler/OrderPakinSyncHandler.java
index 2797bac..fe1f8e8 100644
--- a/src/main/java/com/zy/asrs/task/handler/OrderPakinSyncHandler.java
+++ b/src/main/java/com/zy/asrs/task/handler/OrderPakinSyncHandler.java
@@ -1,5 +1,8 @@
package com.zy.asrs.task.handler;
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
import com.zy.asrs.entity.DocType;
import com.zy.asrs.entity.OrderDetlPakin;
import com.zy.asrs.entity.OrderPakin;
@@ -9,11 +12,15 @@
import com.zy.asrs.service.OrderPakinService;
import com.zy.asrs.task.AbstractHandler;
import com.zy.asrs.task.core.ReturnT;
+import com.zy.common.utils.HttpHandler;
+import com.zy.system.timer.LoadingConfigTimer;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
+import javax.annotation.Resource;
+import java.util.Date;
import java.util.List;
/**
@@ -29,20 +36,70 @@
private OrderDetlPakinService orderDetlPakinService;
@Autowired
private ApiLogService apiLogService;
- @Autowired
- private DocTypeService docTypeService;
+
+ @Resource
+ private LoadingConfigTimer loadingConfigTimer;
@Transactional
- public ReturnT<String> startOrderReport(OrderPakin order) {
- DocType docType = docTypeService.selectById(order.getDocType());
- if (null == docType) {
- return SUCCESS;
- }
- long settle = 6L;
- List<OrderDetlPakin> orderDetls = orderDetlPakinService.selectByOrderId(order.getId());
+ public void startOrderReport(OrderPakin order) {
- return SUCCESS;
+ // 鏋勯�犺姹備綋
+ JSONObject param = new JSONObject();
+ param.put("orderNo", order.getOrderNo());
+ List<OrderDetlPakin> orderDetls = orderDetlPakinService.selectByOrderId(order.getId());
+ JSONArray detl = new JSONArray();
+ for (OrderDetlPakin orderDetlPakin : orderDetls) {
+ JSONObject object = new JSONObject();
+ object.put("matnr", orderDetlPakin.getMatnr());
+ object.put("batch", orderDetlPakin.getBatch());
+ object.put("anfme", orderDetlPakin.getQty());
+ detl.add(object);
+ }
+ param.put("matList", detl);
+
+ String response = "";
+ boolean success = false;
+ String errorMsg = null;
+ String requestJson = param.toJSONString();
+ String url = loadingConfigTimer.getErpReportURL() + loadingConfigTimer.getErpInReportPath();
+ String nameSpaces = "鍏ュ簱鍗曚笂鎶�";
+ try {
+
+// response = new HttpHandler.Builder()
+// .setUri(loadingConfigTimer.getErpReportURL())
+// .setPath(loadingConfigTimer.getErpInReportPath())
+// .setJson(requestJson)
+// .build()
+// .doPost();
+// JSONObject jsonObject = JSON.parseObject(response);
+// if (jsonObject.getString("code") != null && jsonObject.getString("code").equals("200")) {
+ orderPakinService.updateSettle(order.getId(), 6L, null);
+ log.info("鍏ュ簱鍗曟嵁涓婃姤鎴愬姛锛屽崟鎹紪鍙凤細{}", order.getOrderNo());
+ success = true;
+// } else {
+// errorMsg = response;
+// log.error(nameSpaces + "璋冪敤澶栭儴鎺ュ彛澶辫触锛寀rl锛歿}锛宺equest锛歿}锛宺esponse锛歿}", url, requestJson, response);
+// }
+ } catch (Exception e) {
+ errorMsg = e.getMessage();
+ log.error(nameSpaces + "璋冪敤澶栭儴鎺ュ彛寮傚父锛寀rl锛歿}锛宺equest锛歿}锛宺esponse锛歿}", url, requestJson, response, e);
+ } finally {
+ try {
+ apiLogService.save(
+ nameSpaces,
+ url,
+ null,
+ "127.0.0.1",
+ requestJson,
+ response,
+ success,
+ errorMsg
+ );
+ } catch (Exception e) {
+ log.error(nameSpaces + "淇濆瓨鎺ュ彛鏃ュ織澶辫触", e);
+ }
+ }
}
}
--
Gitblit v1.9.1