| | |
|---|
| | | @Override |
|---|
| | | @Transactional(rollbackFor = {BusinessException.class,Exception.class}) |
|---|
| | | public int mqttLockInfoEvent(Locks locks){ |
|---|
| | | if( locks.getCode() !=null ||StringUtils.isBlank(locks.getSiteId())){ |
|---|
| | | if( locks.getCode() ==null ||StringUtils.isBlank(locks.getSiteId())){ |
|---|
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"锁头信息上报参数错误！"); |
|---|
| | | } |
|---|
| | | //判断检查处理站点锁头信息 |
|---|
| | |
|---|
| | | memberRides.forEach(s->{ |
|---|
| | | Integer between = DateUtil.between(s.getCreateDate(), new Date()); |
|---|
| | | // 大于阈值 |
|---|
| | | if (between > 2){ |
|---|
| | | if (between >= 2){ |
|---|
| | | s.setStatus(Constants.MEMBER_RIDES_STATUS.LOCKING_DEFEAT.getKey()); |
|---|
| | | s.setEditDate(new Date()); |
|---|
| | | memberRidesMapper.updateById(s); |
|---|
