|
|
@@ -94,7 +94,7 @@ public class HandleTask {
|
|
|
// 在线交易,调用消费记录入库的接口
|
|
|
// 在查询一次 消费记录,如果有则不再执行
|
|
|
List<XfConsumeDetailVo> list = consumeDetailService.queryByTermNoAndRecordId(Long.valueOf(vo.getTermNo()), Long.valueOf(vo.getTermRecordId()));
|
|
|
- if(CollectionUtils.isEmpty(vos)){
|
|
|
+ if(CollectionUtils.isEmpty(list)){
|
|
|
rs = remoteConsumeService.dealHikUploadRecord(remoteBo);
|
|
|
}else{
|
|
|
log.info("消费机事件,已经存在消费记录,不再处理:{}", vo);
|
|
|
@@ -112,7 +112,7 @@ public class HandleTask {
|
|
|
log.error("定时处理 TransactionRecordEvent事件失败:{}, 参数: {}", e.getMessage(), JSONObject.toJSONString(vo));
|
|
|
}
|
|
|
if(result){
|
|
|
- // 如果成功则更新status为f
|
|
|
+ // 如果成功则更新status为s
|
|
|
XfFailedRecordBo recordBo = new XfFailedRecordBo();
|
|
|
recordBo.setId(vo.getId());
|
|
|
recordBo.setStatus("s");
|