|
|
@@ -16,9 +16,7 @@ import org.rex.RMap
|
|
|
|
|
|
import javax.annotation.Resource
|
|
|
import java.time.LocalDateTime
|
|
|
-import java.util.concurrent.ExecutionException
|
|
|
import java.util.concurrent.TimeUnit
|
|
|
-import java.util.concurrent.TimeoutException
|
|
|
|
|
|
class BE_Call_QueryFee implements BusinessExecutor<ProcessMapItem, QueryFeeResponse> {
|
|
|
private final Logger logger = LogManager.getLogger(this.getClass().getSimpleName())
|
|
|
@@ -81,11 +79,12 @@ class BE_Call_QueryFee implements BusinessExecutor<ProcessMapItem, QueryFeeRespo
|
|
|
|
|
|
try {
|
|
|
String resp = HttpTools.postHttpContentAsync(invoker.invokerUrl, header, jsonConvert.convertTo(body)).get(20, TimeUnit.SECONDS)
|
|
|
+ logger.info("[查询欠费]商户返回信息:" + resp)
|
|
|
|
|
|
QueryFeeResponse response = jsonConvert.convertFrom(resp)
|
|
|
return RetResult.<QueryFeeResponse> successT().result(response)
|
|
|
- } catch (InterruptedException | ExecutionException | TimeoutException e) {
|
|
|
- logger.error(app.appName + "请求[查询欠费]接口失败")
|
|
|
+ } catch (Exception e) {
|
|
|
+ logger.error(app.appName + "请求[查询欠费]接口失败:" + e.message)
|
|
|
return RetResult.<QueryFeeResponse> successT().result(new QueryFeeResponse.Builder()
|
|
|
.respCode("DEF0006")
|
|
|
.respMsg("系统错误")
|