| | |
| | | //车辆记录 |
| | | Bikes bikes = dealBikesByParam(model); |
| | | //状态,0闭合, 1打开,2运行中, 3异常 |
| | | if(locks.getStatus() == Constants.LockStatus.open){ |
| | | if(Constants.formatIntegerNum(locks.getStatus()) == Constants.LockStatus.open){ |
| | | //如果是开锁业务,判断是否有开锁中的信息 |
| | | MemberRides memberRides = new MemberRides(); |
| | | memberRides.setStatus(Constants.MEMBER_RIDES_STATUS.LOCKING.getKey()); |
| | |
| | | update.setId(memberRides.getId()); |
| | | //(更新请求开锁中的锁头关联的骑行记录) |
| | | memberRidesMapper.updateById( update); |
| | | }else if(locks.getStatus() == Constants.LockStatus.closed ){ |
| | | }else if(Constants.formatIntegerNum(locks.getStatus()) == Constants.LockStatus.closed ){ |
| | | //如果是关锁业务,判断触发还车 |
| | | if(StringUtils.isNotBlank(locks.getBikeCode())){ |
| | | MemberRides mbikes = new MemberRides(); |
| | |
| | | |
| | | @Override |
| | | public void autoRefreshLockStatus() { |
| | | // memberRidesMapper.update(null,new UpdateWrapper<MemberRides>().lambda() |
| | | // .eq(MemberRides::getStatus,Constants.MEMBER_RIDES_STATUS.LOCKING.getKey()) |
| | | // .apply("" ) |
| | | // .set(MemberRides::getStatus, Constants.MEMBER_RIDES_STATUS.LOCKING_DEFEAT.getKey())) |
| | | |
| | | QueryWrapper<MemberRides> wrapper = new QueryWrapper<>(); |
| | | wrapper.lambda() |
| | |
| | | List<MemberRides> memberRides = memberRidesMapper.selectList(wrapper); |
| | | if (!CollectionUtils.isEmpty(memberRides)){ |
| | | memberRides.forEach(s->{ |
| | | Integer between = DateUtil.between(s.getCreateDate(), new Date()); |
| | | Integer between = DateUtil.betweenSeconds(s.getCreateDate(), new Date()); |
| | | // 大于阈值 |
| | | if (between >= 2){ |
| | | if (between >= 20){ |
| | | s.setStatus(Constants.MEMBER_RIDES_STATUS.LOCKING_DEFEAT.getKey()); |
| | | s.setEditDate(new Date()); |
| | | memberRidesMapper.updateById(s); |
| | |
| | | if(Objects.nonNull(sites)){ |
| | | Sites sites1 = new Sites(); |
| | | sites1.setId(sites.getId()); |
| | | sites1.setLockNum(sites.getLockNum()+1); |
| | | sites1.setLockNum(Constants.formatIntegerNum(sites.getLockNum())+1); |
| | | sitesMapper.updateById(sites1); |
| | | } |
| | | }else{ |