|
@@ -63,8 +63,8 @@ public class ConsumeUploadCheck {
|
|
|
public R<ErrorInfo> checkBill(ConsumptionBo bo, RemoteUserAccountVo userAccountVo,
|
|
public R<ErrorInfo> checkBill(ConsumptionBo bo, RemoteUserAccountVo userAccountVo,
|
|
|
XfTermVo useTermVo, List<PtBagVo> bagVoList, RemoteMealTypeVo mealTypeVo) {
|
|
XfTermVo useTermVo, List<PtBagVo> bagVoList, RemoteMealTypeVo mealTypeVo) {
|
|
|
// 检验之前先检查这条记录是否上传过,如果上传过则返回已上传的错误,如未上传,将记录Id存入缓存
|
|
// 检验之前先检查这条记录是否上传过,如果上传过则返回已上传的错误,如未上传,将记录Id存入缓存
|
|
|
- String detailId = RecordIdUtils.getRecordId(bo.getConsumeDate(), bo.getTermNo().shortValue(),
|
|
|
|
|
- bo.getTermRecordId().shortValue(), bo.getUserNo().intValue(), 0);
|
|
|
|
|
|
|
+ String detailId = RecordIdUtils.getRecordId(bo.getConsumeDate(), bo.getTermNo().intValue(),
|
|
|
|
|
+ bo.getTermRecordId().intValue(), bo.getUserNo().intValue(), 0);
|
|
|
//Set<String> detailIdSet = RedisUtils.getCacheSet(CacheNames.XF_DETAIL_ID);
|
|
//Set<String> detailIdSet = RedisUtils.getCacheSet(CacheNames.XF_DETAIL_ID);
|
|
|
String detailIdSet = RedisUtils.getCacheMapValue(CacheNames.XF_DETAIL_ID,detailId);
|
|
String detailIdSet = RedisUtils.getCacheMapValue(CacheNames.XF_DETAIL_ID,detailId);
|
|
|
|
|
|
|
@@ -104,9 +104,9 @@ public class ConsumeUploadCheck {
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
private R<ErrorInfo> checkOriginalRecord(ConsumptionBo bo, RemoteUserAccountVo userAccountVo) {
|
|
private R<ErrorInfo> checkOriginalRecord(ConsumptionBo bo, RemoteUserAccountVo userAccountVo) {
|
|
|
- String originalId = RecordIdUtils.getRecordId(bo.getConsumeDate(), bo.getTermNo().shortValue(),
|
|
|
|
|
- bo.getTermRecordId().shortValue(), bo.getUserNo().intValue(), 0);
|
|
|
|
|
- // 补偿性措施:防止消费时间错乱问题(在线模式)
|
|
|
|
|
|
|
+ String originalId = RecordIdUtils.getRecordId(bo.getConsumeDate(), bo.getTermNo().intValue(),
|
|
|
|
|
+ bo.getTermRecordId().intValue(), userAccountVo.getUserNo().intValue(), 0);
|
|
|
|
|
+ // 补偿性措施:防止消费时间错乱问题(在线模式)
|
|
|
int recordType = bo.getRecordStatus().intValue();
|
|
int recordType = bo.getRecordStatus().intValue();
|
|
|
long uniqueRecordId = bo.getRecordId();
|
|
long uniqueRecordId = bo.getRecordId();
|
|
|
bo.setOriginalId(originalId);
|
|
bo.setOriginalId(originalId);
|
|
@@ -266,8 +266,8 @@ public class ConsumeUploadCheck {
|
|
|
if (bo.getRecordId() == 0) {
|
|
if (bo.getRecordId() == 0) {
|
|
|
if (bo.getConsumeDate().getTime() > currentDate.getTime()) {
|
|
if (bo.getConsumeDate().getTime() > currentDate.getTime()) {
|
|
|
bo.setConsumeDate(currentDate);
|
|
bo.setConsumeDate(currentDate);
|
|
|
- originalId = RecordIdUtils.getRecordId(bo.getConsumeDate(), bo.getTermNo().shortValue(),
|
|
|
|
|
- bo.getTermRecordId().shortValue(), bo.getUserNo().intValue(), 0);
|
|
|
|
|
|
|
+ originalId = RecordIdUtils.getRecordId(bo.getConsumeDate(), bo.getTermNo().intValue(),
|
|
|
|
|
+ bo.getTermRecordId().intValue(), bo.getUserNo().intValue(), 0);
|
|
|
bo.setOriginalId(originalId);
|
|
bo.setOriginalId(originalId);
|
|
|
}
|
|
}
|
|
|
vo = new XfConsumeDetailOriginalVo();
|
|
vo = new XfConsumeDetailOriginalVo();
|