From b99df3cd570cc5e5acbab949332bf1c819a01650 Mon Sep 17 00:00:00 2001
From: tqs <56479841@qq.com>
Date: 星期二, 08 十月 2024 13:07:22 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/asrs/task/handler/OrderSyncHandler.java | 141 ++---------------------------------------------
1 files changed, 6 insertions(+), 135 deletions(-)
diff --git a/src/main/java/com/zy/asrs/task/handler/OrderSyncHandler.java b/src/main/java/com/zy/asrs/task/handler/OrderSyncHandler.java
index 0f716ab..43b50b1 100644
--- a/src/main/java/com/zy/asrs/task/handler/OrderSyncHandler.java
+++ b/src/main/java/com/zy/asrs/task/handler/OrderSyncHandler.java
@@ -2,8 +2,9 @@
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
+import com.core.common.Cools;
+import com.core.common.DateUtils;
import com.core.exception.CoolException;
-import com.zy.asrs.entity.DiaphragmInfo;
import com.zy.asrs.entity.DocType;
import com.zy.asrs.entity.Order;
import com.zy.asrs.entity.OrderDetl;
@@ -13,19 +14,17 @@
import com.zy.asrs.service.OrderService;
import com.zy.asrs.task.AbstractHandler;
import com.zy.asrs.task.core.ReturnT;
+import com.zy.common.constant.MesConstant;
+import com.zy.common.model.MesPakinParam;
+import com.zy.common.model.MesPakoutParam;
import com.zy.common.utils.HttpHandler;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Value;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
-import java.math.BigDecimal;
-import java.util.HashMap;
import java.util.List;
-import java.util.Map;
-import java.util.stream.Collectors;
/**
* Created by vincent on 2020/7/7
@@ -45,18 +44,6 @@
@Autowired
private DocTypeService docTypeService;
- @Value("${mes.pakin-sync.uri}")
- private String pakinUri;
-
- @Value("${mes.pakin-sync.path}")
- private String pakinPath;
-
- @Value("${mes.pakout-sync.uri}")
- private String pakoutUri;
-
- @Value("${mes.pakout-sync.path}")
- private String pakoutPath;
-
@Transactional
public ReturnT<String> start(Order order) {
DocType docType = docTypeService.selectById(order.getDocType());
@@ -66,7 +53,6 @@
List<OrderDetl> orderDetls = orderDetlService.selectByOrderId(order.getId());
// 鍏ュ簱瀹屾垚涓婃姤
if (docType.getPakin() == 1) {
- /*
MesPakinParam pakinParam = new MesPakinParam();
pakinParam.setPakinTime(DateUtils.convert(order.getUpdateTime()));
pakinParam.setLgortFrom("5008");
@@ -112,13 +98,10 @@
success
);
} catch (Exception e) { log.error("", e); }
- } */
-
- return orderPakinSync(order,docType.getDocName(),orderDetls);
+ }
}
// 鍑哄簱瀹屾垚涓婃姤
if (docType.getPakout() == 1) {
- /*
MesPakoutParam pakoutParam = new MesPakoutParam();
pakoutParam.setTag(!order.getDocType$().equalsIgnoreCase("鎵嬪姩鍑哄簱鍗�"));
pakoutParam.setPakoutTime(DateUtils.convert(order.getUpdateTime()));
@@ -170,120 +153,8 @@
);
} catch (Exception e) { log.error("", e); }
}
- */
-
- return orderPakoutSync(order,docType.getDocName(),orderDetls);
}
return SUCCESS;
- }
-
- private ReturnT<String> orderPakoutSync (Order order, String orderType, List<OrderDetl> orderDetls){
- Map<String,Object> requestMap = getRequestMap(order,orderType,orderDetls);
- String response = "";
- boolean success = false;
- try {
- response = new HttpHandler.Builder()
- .setUri(pakoutUri)
- .setPath(pakoutPath)
- .setJson(JSON.toJSONString(requestMap))
- .build()
- .doPost();
- success = orderSettleUpdate(response,order);
- } catch (Exception e) {
- log.error("fail", e);
-// TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
- return FAIL.setMsg(e.getMessage());
- } finally {
- try {
- // 淇濆瓨鎺ュ彛鏃ュ織
- apiLogService.save(
- "鎴愬搧搴撳嚭搴撲笂鎶�",
- pakoutUri + pakoutPath,
- null,
- "127.0.0.1",
- JSON.toJSONString(requestMap),
- response,
- success
- );
- } catch (Exception e) { log.error("", e); }
- }
-
- return SUCCESS;
- }
-
- private ReturnT<String> orderPakinSync (Order order, String orderType, List<OrderDetl> orderDetls){
- Map<String,Object> requestMap = getRequestMap(order,orderType,orderDetls);
-
- String response = "";
- boolean success = false;
-
- try {
- response = new HttpHandler.Builder()
- .setUri(pakinUri)
- .setPath(pakinPath)
- .setJson(JSON.toJSONString(requestMap))
- .build()
- .doPost();
- success = orderSettleUpdate(response,order);
- } catch (Exception e) {
- log.error("fail", e);
-// TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
- return FAIL.setMsg(e.getMessage());
- } finally {
- try {
- // 淇濆瓨鎺ュ彛鏃ュ織
- apiLogService.save(
- "鎴愬搧搴撳叆搴撲笂鎶�",
- pakinUri + pakinPath,
- null,
- "127.0.0.1",
- JSON.toJSONString(requestMap),
- response,
- success
- );
- } catch (Exception e) { log.error("", e); }
- }
-
- return SUCCESS;
-
- }
-
- private Map<String,Object> getRequestMap(Order order,String orderType, List<OrderDetl> orderDetls){
- Map<String,Object> requestMap = new HashMap<>();
- requestMap.put("orderNo",order.getOrderNo());
- requestMap.put("orderTime",order.getOrderTime());
- requestMap.put("orderType",orderType);
- requestMap.put("storage",order.getShipName());
-
- List<DiaphragmInfo> diaphragmInfoList = orderDetls.stream().map(od -> {
- DiaphragmInfo diaphragmInfo = new DiaphragmInfo();
- diaphragmInfo.setBatchNo(od.getBatch());
- diaphragmInfo.setItemCode(od.getMatnr());
- diaphragmInfo.setBarCode(od.getQrCode());
- diaphragmInfo.setQuantity(new BigDecimal(od.getAnfme()));
- diaphragmInfo.setAssQuantity(new BigDecimal(od.getQty()));
- return diaphragmInfo;
- }).collect(Collectors.toList());
-
- requestMap.put("orderDetails",diaphragmInfoList);
-
- return requestMap;
- }
-
- private boolean orderSettleUpdate(String response, Order order){
- JSONObject jsonObject = JSON.parseObject(response);
- if (jsonObject.getInteger("code").equals(200)) {
- //success = true;
- // 淇敼璁㈠崟鐘舵�� 4.瀹屾垚 ===>> 6.宸蹭笂鎶�
- if (!orderService.updateSettle(order.getId(), 6L, null)) {
- throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳");
- }
- } else {
- //log.error("璇锋眰鎺ュ彛澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", MesConstant.URL+MesConstant.PAKIN_URL, JSON.toJSONString(requestMap), response);
- throw new CoolException("涓婃姤mes绯荤粺澶辫触");
- }
-
- return true;
}
}
--
Gitblit v1.9.1