| | |
| | | public MemberRides findJoinById(String id) { |
| | | |
| | | MPJLambdaWrapper<MemberRides> queryWrapper = new MPJLambdaWrapper<>(); |
| | | queryWrapper.leftJoin(BaseParam.class,BaseParam::getId,MemberRides::getParamId); |
| | | queryWrapper.leftJoin(BaseParam.class,BaseParam::getId,MemberRides::getParamId) |
| | | .leftJoin(Member.class,Member::getId,MemberRides::getMemberId); |
| | | queryWrapper.eq(MemberRides::getId, id); |
| | | queryWrapper.selectAll(MemberRides.class); |
| | | queryWrapper.selectAs(BaseParam::getName,MemberRidesDTO::getBikeType) ; |
| | | queryWrapper.selectAs(BaseParam::getName,MemberRidesDTO::getBikeType); |
| | | queryWrapper.selectAs(Member::getOpenid,MemberRides::getMemberOpenid); |
| | | queryWrapper.last("limit 1"); |
| | | |
| | | return memberRidesJoinMapper.selectJoinOne(MemberRides.class, queryWrapper); |
| | |
| | | //车辆记录 |
| | | Bikes bikes = dealBikesByParam(model); |
| | | //状态,0闭合, 1打开,2运行中, 3异常 |
| | | if(model.getStatus() == Constants.LockStatus.open){ |
| | | if(locks.getStatus() == Constants.LockStatus.open){ |
| | | //如果是开锁业务,判断是否有开锁中的信息 |
| | | MemberRides memberRides = new MemberRides(); |
| | | memberRides.setStatus(Constants.MEMBER_RIDES_STATUS.LOCKING.getKey()); |
| | |
| | | // 大于阈值 |
| | | if (between > 2){ |
| | | s.setStatus(Constants.MEMBER_RIDES_STATUS.LOCKING_DEFEAT.getKey()); |
| | | s.setEditDate(new Date()); |
| | | memberRidesMapper.updateById(s); |
| | | } |
| | | }); |
| | |
| | | if(bikes != null ) { |
| | | if ( !StringUtils.equals(model.getBikeCode(), bikes.getCode())){ |
| | | //如果绑定车辆信息发生编号,更换绑定关系 |
| | | String type =getBileTypeByCode(model.getBikeCode()); |
| | | UpdateWrapper<Bikes> updateWrapper = new UpdateWrapper<>(); |
| | | updateWrapper.lambda().eq(Bikes::getId, bikes.getId()); |
| | | updateWrapper.lambda().set(Bikes::getCode,model.getBikeCode()); |
| | | updateWrapper.lambda().set(Bikes::getParamId,getBileTypeByCode(model.getBikeCode())); |
| | | updateWrapper.lambda().set(Bikes::getParamId,type); |
| | | //更新自行站点锁头绑定自行车信息 |
| | | bikesMapper.update(null,updateWrapper); |
| | | bikes.setCode(model.getBikeCode()); |
| | | bikes.setParamId(model.getBikeType()); |
| | | } |
| | | }else{ |
| | | bikes = new Bikes(); |
| | |
| | | updateWrapper.lambda().set(Locks::getEditDate, new Date() ); |
| | | updateWrapper.lambda().set(Locks::getIsdeleted, Constants.ZERO); |
| | | locksMapper.update(null,updateWrapper); |
| | | model.setStatus(locks.getStatus()); |
| | | model.setBikeCode(locks.getBikeCode()); |
| | | } |
| | | model.setSites(sites); |
| | | return model; |
| | |
| | | locks.setCode(bikes.getBackLockId()); |
| | | locks.setBikeCode(bikes.getBikeCode()); |
| | | locks.setInfo(bikes.getBackCommondId()); |
| | | locks.setStatus(bikes.getStatus()); |
| | | //处理锁头数据 |
| | | mqttLockInfoEvent(locks); |
| | | //免费骑行时长查询,数据字典配置 |