|
|
@@ -1,8 +1,10 @@
|
|
|
package com.malk.taisen.service.sap.impl;
|
|
|
|
|
|
import com.alibaba.fastjson.JSON;
|
|
|
+import com.alibaba.fastjson.JSONArray;
|
|
|
import com.malk.taisen.service.sap.SapCustomerClient;
|
|
|
import com.malk.utils.UtilHttp;
|
|
|
+import lombok.extern.slf4j.Slf4j;
|
|
|
import org.apache.commons.lang3.StringUtils;
|
|
|
import org.springframework.beans.factory.annotation.Value;
|
|
|
import org.springframework.stereotype.Component;
|
|
|
@@ -14,48 +16,100 @@ import java.util.Map;
|
|
|
* SAP customer information atomic HTTP client.
|
|
|
*/
|
|
|
@Component
|
|
|
+@Slf4j
|
|
|
public class SapCustomerClientImpl implements SapCustomerClient {
|
|
|
|
|
|
- @Value("${sap.customer-balance-url:}")
|
|
|
- private String customerBalanceUrl;
|
|
|
- @Value("${sap.customer-unlock-order-url:}")
|
|
|
- private String customerUnlockOrderUrl;
|
|
|
+ @Value("${sap.customer-inquiry-url:}")
|
|
|
+ private String customerInquiryUrl;
|
|
|
+ @Value("${sap.customer-inquiry-token:}")
|
|
|
+ private String customerInquiryToken;
|
|
|
|
|
|
/**
|
|
|
* Query customer balance.
|
|
|
*
|
|
|
+ * @param requestId unique request identifier
|
|
|
* @param customerNumber SAP customer number
|
|
|
* @return raw SAP response
|
|
|
* @apiNote SAP interface URL pending confirmation
|
|
|
*/
|
|
|
@Override
|
|
|
- public Map queryBalance(String customerNumber) {
|
|
|
- return query(customerBalanceUrl, customerNumber);
|
|
|
+ public Map queryBalance(String requestId, String customerNumber) {
|
|
|
+ return query("OTC002", requestId, customerNumber);
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* Query customer payment-unlocked sales orders.
|
|
|
*
|
|
|
+ * @param requestId unique request identifier
|
|
|
* @param customerNumber SAP customer number
|
|
|
* @return raw SAP response
|
|
|
* @apiNote SAP interface URL pending confirmation
|
|
|
*/
|
|
|
@Override
|
|
|
- public Map queryUnlockOrders(String customerNumber) {
|
|
|
- return query(customerUnlockOrderUrl, customerNumber);
|
|
|
+ public Map queryUnlockOrders(String requestId, String customerNumber) {
|
|
|
+ return query("OTC004", requestId, customerNumber);
|
|
|
}
|
|
|
|
|
|
- private Map query(String url, String customerNumber) {
|
|
|
- if (StringUtils.isBlank(url)) {
|
|
|
+ private Map query(String interfaceNo, String requestId, String customerNumber) {
|
|
|
+ if (StringUtils.isBlank(customerInquiryUrl)) {
|
|
|
return null;
|
|
|
}
|
|
|
+ Map<String, Object> param = new HashMap<>();
|
|
|
+ param.put("bearer_token", customerInquiryToken);
|
|
|
+ param.put("interface_no", interfaceNo);
|
|
|
+ param.put("requestID", requestId);
|
|
|
Map<String, Object> body = new HashMap<>();
|
|
|
body.put("CUSTOMER_NUMBER", customerNumber);
|
|
|
- String response = UtilHttp.doPost_S(url, null, null, body);
|
|
|
- Map result = JSON.parseObject(response, Map.class);
|
|
|
+ log.info("SAP客户查询请求: endpoint={}, query={}, body={}", endpoint(customerInquiryUrl), safeParam(param), body);
|
|
|
+ String response = UtilHttp.doPost_S(customerInquiryUrl, null, param, body);
|
|
|
+ log.info("SAP客户查询响应: endpoint={}, response={}", endpoint(customerInquiryUrl), response);
|
|
|
+ assertJsonResponse(response);
|
|
|
+ Object parsed = JSON.parse(response);
|
|
|
+ Map result;
|
|
|
+ if (parsed instanceof JSONArray) {
|
|
|
+ JSONArray items = (JSONArray) parsed;
|
|
|
+ result = items.isEmpty() ? null : items.getObject(0, Map.class);
|
|
|
+ } else {
|
|
|
+ result = JSON.parseObject(response, Map.class);
|
|
|
+ }
|
|
|
if (result == null) {
|
|
|
throw new IllegalStateException("SAP客户查询接口返回为空");
|
|
|
}
|
|
|
+ result.remove("original");
|
|
|
+ assertSuccess(result);
|
|
|
return result;
|
|
|
}
|
|
|
+
|
|
|
+ private void assertJsonResponse(String response) {
|
|
|
+ if (StringUtils.isBlank(response)) {
|
|
|
+ throw new IllegalStateException("SAP查询服务未返回数据");
|
|
|
+ }
|
|
|
+ String content = response.trim().toLowerCase();
|
|
|
+ if (content.startsWith("<") || content.contains("502 bad gateway") || content.contains("503 service unavailable")) {
|
|
|
+ throw new IllegalStateException("SAP查询服务暂时不可用，请稍后重试");
|
|
|
+ }
|
|
|
+ if (!content.startsWith("{") && !content.startsWith("[")) {
|
|
|
+ throw new IllegalStateException("SAP查询服务返回格式异常");
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ private void assertSuccess(Map result) {
|
|
|
+ String status = result.get("STATUS") == null ? "" : String.valueOf(result.get("STATUS"));
|
|
|
+ if (!"S".equalsIgnoreCase(status) && StringUtils.isNotBlank(status)) {
|
|
|
+ String message = result.get("MESSAGE") == null ? "" : String.valueOf(result.get("MESSAGE"));
|
|
|
+ throw new IllegalStateException(StringUtils.isBlank(message)
|
|
|
+ ? "SAP客户查询失败，状态=" + status : message);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ private Map<String, Object> safeParam(Map<String, Object> param) {
|
|
|
+ Map<String, Object> safe = new HashMap<>(param);
|
|
|
+ safe.put("bearer_token", "***");
|
|
|
+ return safe;
|
|
|
+ }
|
|
|
+
|
|
|
+ private String endpoint(String url) {
|
|
|
+ int queryStart = url.indexOf('?');
|
|
|
+ return queryStart >= 0 ? url.substring(0, queryStart) : url;
|
|
|
+ }
|
|
|
}
|
lfx