|
@@ -63,7 +63,7 @@ public class ConsumptionEventHandler implements HikEventHandler {
|
|
|
// 调用现有原始消费请求接口
|
|
// 调用现有原始消费请求接口
|
|
|
RemoteConsumeBo remoteBo = setParamBo(receive, consumptionEvent);
|
|
RemoteConsumeBo remoteBo = setParamBo(receive, consumptionEvent);
|
|
|
remoteBo.setTermNo(termVo.getTermNo());
|
|
remoteBo.setTermNo(termVo.getTermNo());
|
|
|
- log.info("transactionPreprocessingRequest 调用消费服务的消费请求接口,入参:{}", JSONUtil.toJsonStr(remoteBo));
|
|
|
|
|
|
|
+// log.info("transactionPreprocessingRequest 调用消费服务的消费请求接口,入参:{}", JSONUtil.toJsonStr(remoteBo));
|
|
|
//RemoteResultDto result = remoteConsumeService.dealHikRequestConsume(remoteBo);
|
|
//RemoteResultDto result = remoteConsumeService.dealHikRequestConsume(remoteBo);
|
|
|
//R<ErrorInfo> errorInfo = result.getErrorInfo();
|
|
//R<ErrorInfo> errorInfo = result.getErrorInfo();
|
|
|
//RemoteConsumeBo updatedRemoteBo = result.getUpdatedRemoteBo();
|
|
//RemoteConsumeBo updatedRemoteBo = result.getUpdatedRemoteBo();
|
|
@@ -99,7 +99,7 @@ public class ConsumptionEventHandler implements HikEventHandler {
|
|
|
if (cancel != null && cancel) {
|
|
if (cancel != null && cancel) {
|
|
|
log.info("消费机消费请求确认事件,取消交易:{}", JSONUtil.toJsonStr(receive));
|
|
log.info("消费机消费请求确认事件,取消交易:{}", JSONUtil.toJsonStr(receive));
|
|
|
// 将原始记录标记为删除 termVo.getTermNo() consumptionEvent.getSerialNo() TermRecordId
|
|
// 将原始记录标记为删除 termVo.getTermNo() consumptionEvent.getSerialNo() TermRecordId
|
|
|
- remoteConsumeService.cancleDeal(termVo.getTermNo(), consumptionEvent.getSerialNo());
|
|
|
|
|
|
|
+// remoteConsumeService.cancleDeal(termVo.getTermNo(), consumptionEvent.getSerialNo());
|
|
|
return rs;
|
|
return rs;
|
|
|
}
|
|
}
|
|
|
|
|
|