| | |
| | | || Objects.isNull(dto.getType())){ |
| | | return jkCabinetGridList; |
| | | }else{ |
| | | JkCabinet jkCabinet = jkCabinetMapper.selectById(dto.getCabinetId()); |
| | | JkCabinet jkCabinet = jkCabinetMapper.selectJoinOne(JkCabinet.class,new MPJLambdaWrapper<JkCabinet>() |
| | | .selectAll(JkCabinet.class) |
| | | .select("now()",JkCabinet::getNow) |
| | | .eq(JkCabinet::getId,dto.getCabinetId())); |
| | | if(Objects.isNull(jkCabinet)){ |
| | | return jkCabinetGridList; |
| | | } |
| | |
| | | //判断当前时间是否处于保洁时段内 |
| | | String cleanConfig = systemDictDataBiz.queryByCode(Constants.CABINET_CONFIG,Constants.CLEAN_TIME).getCode(); |
| | | String earlyConfig = systemDictDataBiz.queryByCode(Constants.CABINET_CONFIG,Constants.EARLY_CONFIG).getCode(); |
| | | Boolean isCleanTime = Constants.betweenTimeConfig(cleanConfig); |
| | | Boolean isCleanTime = Constants.betweenTimeConfig(cleanConfig,jkCabinet.getNow()); |
| | | List<Integer> girdIdList = new ArrayList<>(); |
| | | //查询根据任务可以领取的数据 |
| | | jkCabinetGridList = jkCabinetGridMapper.selectJoinList(JkCabinetGrid.class, |
| | |
| | | .eq(JkKeys::getRoleType,Constants.ONE) |
| | | // .eq(Cars::getMemberId,dto.getMemberId()) |
| | | .isNotNull(JkCabinetGrid::getKeyId) |
| | | .apply(" t2.code in ( select c.car_code from car_use_book c where c.isdeleted = 0 and NOW() > DATE_SUB(c.START_TIME, INTERVAL "+earlyConfig+" MINUTE) and now() < c.end_time and c.DRIVER_ID = "+dto.getMemberId()+" ) ") |
| | | .apply(" ( t2.code in ( select c.car_code from car_use_book c where c.isdeleted = 0 and NOW() > DATE_SUB(c.START_TIME, INTERVAL "+earlyConfig+" MINUTE) and now() < c.end_time " + |
| | | " and c.DRIVER_ID = "+dto.getMemberId()+" )" + |
| | | " or t2.code in ( select c.car_code from car_use_book c inner join cars c1 on c.CAR_ID = c1.ID where c1.MEMBER_ID = 6611 AND NOW() > DATE_SUB( c.START_TIME, INTERVAL 30 MINUTE ) AND now() < c.end_time )" + |
| | | " )" + |
| | | " ") |
| | | ); |
| | | |
| | | for (JkCabinetGrid jkCabinetGrid:jkCabinetGridList) { |
| | |
| | | List<SyncGridDTO> gridSyncList = gridDTOList.stream().filter(i->StringUtils.isNotBlank(i.getBoardCode())&& |
| | | StringUtils.isNotBlank(i.getChannelCode())&&StringUtils.isNotBlank(i.getActualLable())&&i.getBoardCode().equals(jkCabinetGrid.getBoardCode()) |
| | | && i.getChannelCode().equals(jkCabinetGrid.getChannelCode())).collect(Collectors.toList()); |
| | | if(CollectionUtils.isEmpty(gridDTOList)){ |
| | | if(CollectionUtils.isEmpty(gridSyncList)){ |
| | | continue; |
| | | } |
| | | SyncGridDTO syncGridDTO = gridSyncList.get(Constants.ZERO); |