|
|
|
@ -17,6 +17,7 @@ import com.hzya.frame.web.entity.JsonResultEntity;
|
|
|
|
|
import org.apache.commons.collections.CollectionUtils;
|
|
|
|
|
import org.slf4j.Logger;
|
|
|
|
|
import org.slf4j.LoggerFactory;
|
|
|
|
|
import org.springframework.beans.factory.annotation.Value;
|
|
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
|
|
|
|
import java.util.ArrayList;
|
|
|
|
@ -32,7 +33,8 @@ import java.util.Map;
|
|
|
|
|
@Service
|
|
|
|
|
public class Cbs8ServiceImpl implements ICbs8Service {
|
|
|
|
|
Logger logger = LoggerFactory.getLogger(getClass());
|
|
|
|
|
|
|
|
|
|
@Value("${zt.url}")
|
|
|
|
|
private String zt_url;
|
|
|
|
|
@Override
|
|
|
|
|
public PayResponseDTO payApply(PaymentEntity paymentEntity) {
|
|
|
|
|
Map<String, String> headerMap = MapBuilder.<String, String>create(true)
|
|
|
|
@ -41,7 +43,7 @@ public class Cbs8ServiceImpl implements ICbs8Service {
|
|
|
|
|
.put("secretKey","7Gp6OjHrIaQ6R3tXGPrI4morjQyWL+qu4JJschQnkBRtv26VDgGFVYKOy5kMZfd/j3JzOP8MtA1LSGvL+2BWG8c/o7DKi92S4mr3zcGearA=")
|
|
|
|
|
.put("appId","800026")
|
|
|
|
|
.build();
|
|
|
|
|
String body = HttpRequest.post("http://127.0.0.1:9999/kangarooDataCenterV3/entranceController/externalCallInterfaceToESB").addHeaders(headerMap).body(JSONObject.toJSONString(paymentEntity)).timeout(60000).execute().body();
|
|
|
|
|
String body = HttpRequest.post(zt_url).addHeaders(headerMap).body(JSONObject.toJSONString(paymentEntity)).timeout(60000).execute().body();
|
|
|
|
|
//解密响应报文
|
|
|
|
|
String result = decryptResBody(body);
|
|
|
|
|
if (StrUtil.isNotEmpty(result)){
|
|
|
|
@ -71,7 +73,7 @@ public class Cbs8ServiceImpl implements ICbs8Service {
|
|
|
|
|
.put("secretKey","7Gp6OjHrIaQ6R3tXGPrI4morjQyWL+qu4JJschQnkBRtv26VDgGFVYKOy5kMZfd/j3JzOP8MtA1LSGvL+2BWG8c/o7DKi92S4mr3zcGearA=")
|
|
|
|
|
.put("appId","800026")
|
|
|
|
|
.build();
|
|
|
|
|
String body = HttpRequest.post("http://127.0.0.1:9999/kangarooDataCenterV3/entranceController/externalCallInterfaceToESB").addHeaders(headerMap).body(JSONObject.toJSONString(resultRequestDTO)).timeout(60000).execute().body();
|
|
|
|
|
String body = HttpRequest.post(zt_url).addHeaders(headerMap).body(JSONObject.toJSONString(resultRequestDTO)).timeout(60000).execute().body();
|
|
|
|
|
String result = decryptResBody(body);
|
|
|
|
|
CbsResponseDTO cbsResponseDTO = JSONObject.parseObject(result, CbsResponseDTO.class);
|
|
|
|
|
if (CollectionUtils.isNotEmpty(cbsResponseDTO.getData())){
|
|
|
|
@ -113,7 +115,7 @@ public class Cbs8ServiceImpl implements ICbs8Service {
|
|
|
|
|
.put("secretKey","7Gp6OjHrIaQ6R3tXGPrI4morjQyWL+qu4JJschQnkBRtv26VDgGFVYKOy5kMZfd/j3JzOP8MtA1LSGvL+2BWG8c/o7DKi92S4mr3zcGearA=")
|
|
|
|
|
.put("appId","800026")
|
|
|
|
|
.build();
|
|
|
|
|
String body = HttpRequest.post("http://127.0.0.1:9999/kangarooDataCenterV3/entranceController/externalCallInterfaceToESB").addHeaders(headerMap).body(params).timeout(60000).execute().body();
|
|
|
|
|
String body = HttpRequest.post(zt_url).addHeaders(headerMap).body(params).timeout(60000).execute().body();
|
|
|
|
|
String result = decryptResBody(body);
|
|
|
|
|
if (StrUtil.isNotEmpty(result)){
|
|
|
|
|
CbsResponseDTO cbsResponseDTO = JSONObject.parseObject(result, CbsResponseDTO.class);
|
|
|
|
@ -165,7 +167,7 @@ public class Cbs8ServiceImpl implements ICbs8Service {
|
|
|
|
|
.put("secretKey","7Gp6OjHrIaQ6R3tXGPrI4morjQyWL+qu4JJschQnkBRtv26VDgGFVYKOy5kMZfd/j3JzOP8MtA1LSGvL+2BWG8c/o7DKi92S4mr3zcGearA=")
|
|
|
|
|
.put("appId","800026")
|
|
|
|
|
.build();
|
|
|
|
|
String body = HttpRequest.post("http://127.0.0.1:9999/kangarooDataCenterV3/entranceController/externalCallInterfaceToESB").addHeaders(headerMap).body(params).timeout(60000).execute().body();
|
|
|
|
|
String body = HttpRequest.post(zt_url).addHeaders(headerMap).body(params).timeout(60000).execute().body();
|
|
|
|
|
String result = decryptResBody(body);
|
|
|
|
|
if (StrUtil.isNotEmpty(result)){
|
|
|
|
|
CbsResponseDTO cbsResponseDTO = JSONObject.parseObject(result, CbsResponseDTO.class);
|
|
|
|
@ -200,7 +202,7 @@ public class Cbs8ServiceImpl implements ICbs8Service {
|
|
|
|
|
.put("secretKey","7Gp6OjHrIaQ6R3tXGPrI4morjQyWL+qu4JJschQnkBRtv26VDgGFVYKOy5kMZfd/j3JzOP8MtA1LSGvL+2BWG8c/o7DKi92S4mr3zcGearA=")
|
|
|
|
|
.put("appId","800026")
|
|
|
|
|
.build();
|
|
|
|
|
String body = HttpRequest.post("http://127.0.0.1:9999/kangarooDataCenterV3/entranceController/externalCallInterfaceToESB").addHeaders(headerMap).body(params).timeout(60000).execute().body();
|
|
|
|
|
String body = HttpRequest.post(zt_url).addHeaders(headerMap).body(params).timeout(60000).execute().body();
|
|
|
|
|
String result = decryptResBody(body);
|
|
|
|
|
if (StrUtil.isNotEmpty(result)){
|
|
|
|
|
CbsResponseDTO cbsResponseDTO = JSONObject.parseObject(result, CbsResponseDTO.class);
|
|
|
|
@ -229,7 +231,7 @@ public class Cbs8ServiceImpl implements ICbs8Service {
|
|
|
|
|
.put("appId","800026")
|
|
|
|
|
.build();
|
|
|
|
|
String params = JSON.toJSONString(agentPayResultRequestDTO);
|
|
|
|
|
String body = HttpRequest.post("http://127.0.0.1:9999/kangarooDataCenterV3/entranceController/externalCallInterfaceToESB").addHeaders(headerMap).body(params).timeout(60000).execute().body();
|
|
|
|
|
String body = HttpRequest.post(zt_url).addHeaders(headerMap).body(params).timeout(60000).execute().body();
|
|
|
|
|
//解密报文
|
|
|
|
|
String result = decryptResBody(body);
|
|
|
|
|
if (StrUtil.isNotEmpty(result)){
|
|
|
|
|