| | |
| | | } |
| | | |
| | | public List<LightTaskDto> listLightTask(BaseConditionVO conditionVO, String keyword, Integer order, Integer seq) { |
| | | LambdaQueryWrapper<LightTask> wrapper = Wrappers.lambdaQuery(LightTask.class); |
| | | if (StrUtil.isNotBlank(keyword)) { |
| | | wrapper.like(LightTask::getTaskName, keyword); |
| | | } |
| | | //不是超管需要筛选 |
| | | if (SecurityUtils.getClientId() != null) { |
| | | wrapper.eq(LightTask::getClientId, SecurityUtils.getUserId()).or(w -> { |
| | | w.eq(LightTask::getUserId, SecurityUtils.getUserId()); |
| | | }); |
| | | } |
| | | |
| | | //排序字段 |
| | | String orderByResult = "task_id"; |
| | |
| | | String orderBy = orderByResult + " " + orderBySeq; |
| | | |
| | | PageHelper.startPage(conditionVO.getPageNo(), conditionVO.getPageSize(), orderBy); |
| | | List<LightTask> list = list(wrapper); |
| | | List<LightTask> list = baseMapper.listTask(SecurityUtils.getClientId(),keyword,orderBy); |
| | | |
| | | |
| | | Page<LightTaskDto> page = new Page<>(); |
| | | BeanUtils.copyProperties(list, page); |
| | |
| | | LightTaskDto lightTaskDto = new LightTaskDto(); |
| | | BeanUtils.copyProperties(lightTask, lightTaskDto); |
| | | lightTaskDto.setWeekList(TaskOrderUtil.parseLightWeek2List(lightTask.getWeek())); |
| | | //下发成功的灯杆数量 |
| | | Integer successCount = baseMapper.successCount(lightTaskDto.getTaskId()); |
| | | ///任务中总的灯杆数量 |
| | | Integer toTalCount = baseMapper.toTalCount(lightTaskDto.getTaskId()); |
| | | if (successCount == null) { |
| | | successCount = 0; |
| | | } |
| | | if (toTalCount == null) { |
| | | toTalCount = 0; |
| | | } |
| | | if (toTalCount == 0) { |
| | | //任务中没有灯杆 |
| | | lightTaskDto.setSyncStatus("未同步"); |
| | | } else { |
| | | //任务中有灯杆 |
| | | if (successCount == 0) { |
| | | //下发成功未0 |
| | | lightTaskDto.setSyncStatus("未同步"); |
| | | } else if (successCount != 0 && successCount < toTalCount) { |
| | | //存在下发成功 但并未全部成功 |
| | | lightTaskDto.setSyncStatus("部分同步"); |
| | | } else if (toTalCount.equals(successCount) && toTalCount != 0 && successCount != 0) { |
| | | //全部成功 |
| | | lightTaskDto.setSyncStatus("已同步"); |
| | | } else { |
| | | //未知类型 |
| | | lightTaskDto.setSyncStatus("同步状态出错"); |
| | | } |
| | | } |
| | | page.add(lightTaskDto); |
| | | } |
| | | return page; |
| | |
| | | throw new BusinessException("删除任务失败"); |
| | | } |
| | | |
| | | boolean del; |
| | | // 删除绑定灯杆 |
| | | // if (!lightTaskPoleRelationService.remove(Wrappers.lambdaQuery(LightTaskPoleRelation.class).notIn(LightTaskPoleRelation::getTaskId, taskIdList))) { |
| | | // throw new BusinessException("未找到任务/灯杆绑定关系"); |
| | | // } |
| | | // lightTaskPoleRelationService.remove(Wrappers.lambdaQuery(LightTaskPoleRelation.class).in(LightTaskPoleRelation::getTaskId, taskIdList)); |
| | | taskIdList.forEach(taskId -> { |
| | | lightTaskPoleRelationService.remove(Wrappers.lambdaQuery(LightTaskPoleRelation.class).eq(LightTaskPoleRelation::getTaskId, taskId)); |
| | | }); |
| | | |
| | | /** |
| | | * 删除控灯任务日志记录开始 |
| | | */ |
| | |
| | | for (LightTaskPoleRelationBo bean : list) { |
| | | |
| | | LightTaskDto lightTaskDto = new LightTaskDto(); |
| | | //TODO |
| | | BeanUtils.copyProperties(bean, lightTaskDto); |
| | | lightTaskDto.setWeekList(TaskOrderUtil.parseLightWeek2List(bean.getWeek())); |
| | | BigDecimal energySaving; |