feature:电商02回推添加请求头

release
gaorl 2 years ago
parent 5e3af15b05
commit 32e790b7e8
  1. 3
      order-management-base-service/src/main/java/com/dxhy/order/baseservice/config/BaseServiceConfig.java
  2. 10
      order-management-common/src/main/java/com/dxhy/order/utils/HttpUtils.java
  3. 4
      order-management-consumer/src/main/java/com/dxhy/order/consumer/modules/manager/service/impl/PushInvoiceServiceImpl.java

@ -289,6 +289,9 @@ public class BaseServiceConfig{
@Value("${order.push.po.url:}")
private String poUrl;
@Value("${order.push.po.ecKey:}")
private String ecKey;
/**
* 调用山能PO username
*/

@ -78,6 +78,16 @@ public class HttpUtils {
log.debug("{}以字符串调用post请求url:{},耗时:{}", LOGGER_MSG, url, endTime - startTime);
return body;
}
public static String sendPoWithHead(String url, String request,String userName,String password,Map<String, String> header) {
long startTime = System.currentTimeMillis();
HttpRequest httpRequest = new HttpRequest(url);
httpRequest.basicAuth(userName,password);
String body = httpRequest.addHeaders(header).body(request).timeout(300000).execute().body();
long endTime = System.currentTimeMillis();
log.debug("{}以字符串调用post请求url:{},耗时:{}", LOGGER_MSG, url, endTime - startTime);
return body;
}
/**
* 上传文件
*

@ -441,7 +441,9 @@ public class PushInvoiceServiceImpl implements PushInvoiceService {
result = HttpUtils.sendPo(pushInfo.getPushUrl(), fptsParam,baseServiceConfig.getPoUserName(),baseServiceConfig.getPoPassword());
} else if (OrderInfoEnum.SYS_SOURCE_DSXT02.getKey().equals(orderProcessInfo.getXtly()) && StringUtils.isNotBlank(pushInfo.getByzd1())
&& pushInfo.getByzd1().equals(orderProcessInfo.getXtly())) {
result = HttpUtils.sendPo(pushInfo.getPushUrl(), fptsParam,baseServiceConfig.getPoUserName(),baseServiceConfig.getPoPassword());
Map map = Maps.newHashMap();
map.put("ec-key",baseServiceConfig.getEcKey());
result = HttpUtils.sendPoWithHead(pushInfo.getPushUrl(), fptsParam,baseServiceConfig.getPoUserName(),baseServiceConfig.getPoPassword(),map);
}
} else {
result = HttpUtils.doPost(pushInfo.getPushUrl(), requestMap);

Loading…
Cancel
Save