| | |
|---|
| | | update.setBackType(Constants.ONE); |
|---|
| | | update.setStatus(Constants.MEMBER_RIDES_STATUS.BACK_CYCLING.getKey()); |
|---|
| | | update.setBackSiteId(collect.get(Constants.FORCE_BACK_SITE).getCode()); |
|---|
| | | update.setBackLockId(collect.get(Constants.FORCE_BACK_LOCK).getCode()); |
|---|
| | | update.setBackLockId(Constants.formatIntegerFromStr(collect.get(Constants.FORCE_BACK_LOCK).getCode())); |
|---|
| | | Integer freeRentTime = Integer.valueOf(collect.get(Constants.FREE_RENT_TIME).getCode()); |
|---|
| | | Integer rideTime = DateUtil.betweenMin(model.getRentDate(), update.getBackDate()); |
|---|
| | | //计算骑行计费时长 |
|---|
| | |
|---|
| | | //查询锁头是否存在车辆 以及是否正常 |
|---|
| | | if (Constants.formatIntegerNum(locks.getStatus())!=Constants.ZERO) { |
|---|
| | | locks =new Locks(); |
|---|
| | | locks.setCode(codes[1]); |
|---|
| | | locks.setCode(Constants.formatIntegerFromStr(codes[1])); |
|---|
| | | locks.setSiteId(codes[0]); |
|---|
| | | deviceService.getLockInfo(locks); |
|---|
| | | throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "当前扫码锁头状态错误，已尝试更新锁头状态，请稍后重试！"); |
|---|
| | | throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "当前车辆暂时无法使用，请稍后重试或更换其它车辆~"); |
|---|
| | | } |
|---|
| | | if (StringUtils.isBlank(locks.getBikeCode())) { |
|---|
| | | locks =new Locks(); |
|---|
| | | locks.setCode(codes[1]); |
|---|
| | | locks.setCode(Constants.formatIntegerFromStr(codes[1])); |
|---|
| | | locks.setSiteId(codes[0]); |
|---|
| | | deviceService.getLockInfo(locks); |
|---|
| | | throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "当前扫码锁头无车辆信息，已尝试更新锁头状态，请稍后重试！"); |
|---|
| | | throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "当前车辆暂时无法使用，请稍后重试或更换其它车辆！"); |
|---|
| | | } |
|---|
| | | MemberRides memberRides = new MemberRides(); |
|---|
| | | //根据车型查询计价方案 |
|---|
| | |
|---|
| | | @Override |
|---|
| | | @Transactional(rollbackFor = {BusinessException.class,Exception.class}) |
|---|
| | | public int mqttLockInfoEvent(Locks locks){ |
|---|
| | | if(StringUtils.isBlank(locks.getCode()) ||StringUtils.isBlank(locks.getSiteId())){ |
|---|
| | | if( locks.getCode() !=null ||StringUtils.isBlank(locks.getSiteId())){ |
|---|
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"锁头信息上报参数错误！"); |
|---|
| | | } |
|---|
| | | //判断检查处理站点锁头信息 |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | private void mqttCloseBikeEventDo(MemberRides bikes) { |
|---|
| | | if(StringUtils.isBlank(bikes.getBikeCode()) ||StringUtils.isBlank(bikes.getBackLockId())||StringUtils.isBlank(bikes.getBackSiteId())){ |
|---|
| | | if(StringUtils.isBlank(bikes.getBikeCode()) || bikes.getBackLockId() == null ||StringUtils.isBlank(bikes.getBackSiteId())){ |
|---|
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"还车上报参数错误！"); |
|---|
| | | } |
|---|
| | | QueryWrapper<MemberRides> wrapper = new QueryWrapper<>(); |
|---|
