|
@@ -192,7 +192,6 @@ public class WxApiService {
|
|
|
}
|
|
|
TradeVectorUtil.add(tradeNo);
|
|
|
JSONObject obj = retryService.queryOrderStateFromTencent(tradeNo);
|
|
|
- dao.incrementQueryTimesByTradeNo(tradeNo);
|
|
|
String tradeState = obj.getString("trade_state");
|
|
|
if ("SUCCESS".equals(tradeState)) {
|
|
|
String successTime = obj.getString("success_time")
|
|
@@ -219,6 +218,7 @@ public class WxApiService {
|
|
|
break;
|
|
|
}
|
|
|
TradeVectorUtil.remove(tradeNo);
|
|
|
+ dao.incrementQueryTimesByTradeNo(tradeNo);
|
|
|
return CompletableFuture.completedFuture(saveRet);
|
|
|
}
|
|
|
String message;
|
|
@@ -256,6 +256,7 @@ public class WxApiService {
|
|
|
break;
|
|
|
}
|
|
|
TradeVectorUtil.remove(tradeNo);
|
|
|
+ dao.incrementQueryTimesByTradeNo(tradeNo);
|
|
|
return CompletableFuture.completedFuture(ResultVoUtil.fail(ExceptionEnum.INTERNAL_SERVER_ERROR, message));
|
|
|
}
|
|
|
|
|
@@ -338,7 +339,6 @@ public class WxApiService {
|
|
|
httpPost.setEntity(entity);
|
|
|
httpPost.addHeader("Content-Type", "application/json;charset=UTF-8");
|
|
|
httpPost.addHeader("Accept", "application/json");
|
|
|
- //完成签名并执行请求
|
|
|
CloseableHttpClient httpClient = WxHttpUtil.getClosableHttpClient();
|
|
|
CloseableHttpResponse response = httpClient.execute(httpPost);
|
|
|
int statusCode = response.getStatusLine().getStatusCode();
|