记得上下班打卡 | git大法好,push需谨慎

Commit e771528f authored by 张国柄's avatar 张国柄

~API:迁移调整验票代码(kylin to merchant, 去除登录登出,新增权限逻辑);

parent 8ba80223
...@@ -186,12 +186,23 @@ public class MerchantStationController { ...@@ -186,12 +186,23 @@ public class MerchantStationController {
String currentUid = CurrentUtil.getCurrentUid(); String currentUid = CurrentUtil.getCurrentUid();
log.info("验票:下载验票数据[UID:{},performanceId:{}]", currentUid, performanceId); log.info("验票:下载验票数据[UID:{},performanceId:{}]", currentUid, performanceId);
ResponseDto<MerchantStationCheckRefreshVo> responseDto = this.downloadRefreshTicketDataValid(currentUid, performanceId); // 查取当前用户下关联演出ID列表
if (!responseDto.isSuccess()) { List<MerchantAuthorizationPerformanceVo> authorizationPerformanceVoList = merchantStationService.getCheckUserRelationVo(currentUid);
return responseDto; if (CollectionUtils.isEmpty(authorizationPerformanceVoList)) {
return ResponseDto.failure(ErrorMapping.get("130901"));
} }
List<MerchantAuthorizationPerformanceVo> targetAuthPerformanceVoList =
authorizationPerformanceVoList.stream().filter(r -> r.getPerformanceId().equals(performanceId)).collect(Collectors.toList());
if (CollectionUtils.isEmpty(targetAuthPerformanceVoList)) {
return ResponseDto.failure(ErrorMapping.get("130902"));
}
MerchantAuthorizationPerformanceVo authorizationPerformanceVo = targetAuthPerformanceVoList.get(0);
// LocalDateTime canDownDt = DateUtil.Formatter.yyyyMMddHHmmss.parse(relationParam.getCanDownTime());
// if (canDownDt.isAfter(LocalDateTime.now())) {
// return ResponseDto.failure(ErrorMapping.get("130903"));
// }
return ResponseDto.success(merchantStationService.downloadRefreshTicketData(performanceId, null)); return ResponseDto.success(merchantStationService.downloadRefreshTicketData(authorizationPerformanceVo, performanceId, null));
} }
@ApiOperationSupport(order = 3) @ApiOperationSupport(order = 3)
...@@ -208,12 +219,23 @@ public class MerchantStationController { ...@@ -208,12 +219,23 @@ public class MerchantStationController {
String currentUid = CurrentUtil.getCurrentUid(); String currentUid = CurrentUtil.getCurrentUid();
log.info("验票:刷新验票数据[UID:{},performanceId:{},latestUpdateAt:{}]", currentUid, performanceId, latestUpdateAt); log.info("验票:刷新验票数据[UID:{},performanceId:{},latestUpdateAt:{}]", currentUid, performanceId, latestUpdateAt);
ResponseDto<MerchantStationCheckRefreshVo> responseDto = this.downloadRefreshTicketDataValid(currentUid, performanceId); // 查取当前用户下关联演出ID列表
if (!responseDto.isSuccess()) { List<MerchantAuthorizationPerformanceVo> authorizationPerformanceVoList = merchantStationService.getCheckUserRelationVo(currentUid);
return responseDto; if (CollectionUtils.isEmpty(authorizationPerformanceVoList)) {
return ResponseDto.failure(ErrorMapping.get("130901"));
}
List<MerchantAuthorizationPerformanceVo> targetAuthPerformanceVoList =
authorizationPerformanceVoList.stream().filter(r -> r.getPerformanceId().equals(performanceId)).collect(Collectors.toList());
if (CollectionUtils.isEmpty(targetAuthPerformanceVoList)) {
return ResponseDto.failure(ErrorMapping.get("130902"));
} }
MerchantAuthorizationPerformanceVo authorizationPerformanceVo = targetAuthPerformanceVoList.get(0);
// LocalDateTime canDownDt = DateUtil.Formatter.yyyyMMddHHmmss.parse(relationParam.getCanDownTime());
// if (canDownDt.isAfter(LocalDateTime.now())) {
// return ResponseDto.failure(ErrorMapping.get("130903"));
// }
return ResponseDto.success(merchantStationService.downloadRefreshTicketData(performanceId, latestUpdateAt)); return ResponseDto.success(merchantStationService.downloadRefreshTicketData(authorizationPerformanceVo, performanceId, latestUpdateAt));
} }
@ApiOperationSupport(order = 4) @ApiOperationSupport(order = 4)
...@@ -251,30 +273,4 @@ public class MerchantStationController { ...@@ -251,30 +273,4 @@ public class MerchantStationController {
// } // }
/* ------------------------------------------------------------------ */ /* ------------------------------------------------------------------ */
/**
* 下载、更新验票数据逻辑校验
*
* @param currentUid UID
* @param performanceId 演出ID
* @return ResponseDto<MerchantStationCheckRefreshVo>
*/
public ResponseDto<MerchantStationCheckRefreshVo> downloadRefreshTicketDataValid(String currentUid, String performanceId) {
// 查取当前用户下关联演出ID列表
List<MerchantAuthorizationPerformanceVo> authorizationPerformanceVoList = merchantStationService.getCheckUserRelationVo(currentUid);
if (CollectionUtils.isEmpty(authorizationPerformanceVoList)) {
return ResponseDto.failure(ErrorMapping.get("130901"));
}
List<MerchantAuthorizationPerformanceVo> targetAuthPerformanceVoList =
authorizationPerformanceVoList.stream().filter(r -> r.getPerformanceId().equals(performanceId)).collect(Collectors.toList());
if (CollectionUtils.isEmpty(targetAuthPerformanceVoList)) {
return ResponseDto.failure(ErrorMapping.get("130902"));
}
// MerchantAuthorizationPerformanceVo authorizationPerformanceVo = targetAuthPerformanceVoList.get(0);
// LocalDateTime canDownDt = DateUtil.Formatter.yyyyMMddHHmmss.parse(relationParam.getCanDownTime());
// if (canDownDt.isAfter(LocalDateTime.now())) {
// return ResponseDto.failure(ErrorMapping.get("130903"));
// }
return ResponseDto.success();
}
} }
...@@ -174,11 +174,12 @@ public class MerchantStationService { ...@@ -174,11 +174,12 @@ public class MerchantStationService {
/** /**
* 下载、更新验票数据 * 下载、更新验票数据
* *
* @param performanceId 演出ID * @param authorizationPerformanceVo 用户演出权限
* @param latestUpdateAt 最近更新时间(仅当更新时必传,下载时传null) * @param performanceId 演出ID
* @param latestUpdateAt 最近更新时间(仅当更新时必传,下载时传null)
* @return MerchantStationCheckRefreshVo * @return MerchantStationCheckRefreshVo
*/ */
public MerchantStationCheckRefreshVo downloadRefreshTicketData(String performanceId, String latestUpdateAt) { public MerchantStationCheckRefreshVo downloadRefreshTicketData(MerchantAuthorizationPerformanceVo authorizationPerformanceVo, String performanceId, String latestUpdateAt) {
Criteria criteria = Criteria.where("performanceId").is(performanceId).and("isPayment").is(1); Criteria criteria = Criteria.where("performanceId").is(performanceId).and("isPayment").is(1);
if (StringUtils.isNotEmpty(latestUpdateAt)) { if (StringUtils.isNotEmpty(latestUpdateAt)) {
criteria.and("updatedAt").gte(latestUpdateAt); criteria.and("updatedAt").gte(latestUpdateAt);
...@@ -200,8 +201,6 @@ public class MerchantStationService { ...@@ -200,8 +201,6 @@ public class MerchantStationService {
} }
} }
MerchantStationCheckRefreshVo stationCheckRefreshVo = MerchantStationCheckRefreshVo.getNew();
stationCheckRefreshVo.setCheckOrderVos(checkOrderVos);
// 查取演出信息 // 查取演出信息
MerchantStationPerformanceVo performanceVo = mongoTemplate.findOne(Query.query(Criteria.where("performancesId").is(performanceId)), MerchantStationPerformanceVo performanceVo = mongoTemplate.findOne(Query.query(Criteria.where("performancesId").is(performanceId)),
MerchantStationPerformanceVo.class, KylinPerformanceVo.class.getSimpleName()); MerchantStationPerformanceVo.class, KylinPerformanceVo.class.getSimpleName());
...@@ -220,8 +219,12 @@ public class MerchantStationService { ...@@ -220,8 +219,12 @@ public class MerchantStationService {
ticketVoList.add(stationTicketVo); ticketVoList.add(stationTicketVo);
} }
performanceVo.setPermissionIds(StringUtils.join(authorizationPerformanceVo.getPermissionIds().toArray(), "."));
performanceVo.setTicketTimeList(null); performanceVo.setTicketTimeList(null);
performanceVo.setTicketVoList(ticketVoList); performanceVo.setTicketVoList(ticketVoList);
MerchantStationCheckRefreshVo stationCheckRefreshVo = MerchantStationCheckRefreshVo.getNew();
stationCheckRefreshVo.setCheckOrderVos(checkOrderVos);
stationCheckRefreshVo.setPerformanceVo(performanceVo); stationCheckRefreshVo.setPerformanceVo(performanceVo);
return stationCheckRefreshVo; return stationCheckRefreshVo;
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment