| | |
| | | |
| | | import cn.hutool.core.date.DateTime; |
| | | import cn.hutool.core.date.DateUtil; |
| | | import com.alibaba.fastjson2.JSONObject; |
| | | import com.baomidou.mybatisplus.core.conditions.Wrapper; |
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
| | | import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; |
| | |
| | | import java.nio.file.Path; |
| | | import java.util.*; |
| | | import java.util.stream.Collectors; |
| | | import java.util.stream.Stream; |
| | | |
| | | import static java.util.stream.Collectors.groupingBy; |
| | | |
| | |
| | | BeanUtils.copyProperties(project,projectVo); |
| | | |
| | | List<String> properties = deviceUsageService.getDeviceUsageList(id); |
| | | properties = properties.stream().filter(e -> JSONObject.parseObject(e).containsKey("工程起重机械租赁单位") && JSONObject.parseObject(e).getString("工程起重机械租赁单位") != null && !JSONObject.parseObject(e).getString("工程起重机械租赁单位").isEmpty()).collect(Collectors.toList()); |
| | | projectVo.setProperties( properties); |
| | | |
| | | ProjectInfo projectInfo = projectInfoService.getOne(new LambdaUpdateWrapper<ProjectInfo>().eq(ProjectInfo::getProjectId, id).eq(ProjectInfo::getDeleted,false).orderByDesc(ProjectInfo::getCreateTime).last("limit 1")); |
| | |
| | | List<Integer> taskIds = list.stream().map(Task::getId).collect(Collectors.toList()); |
| | | // 0是一级隐患 |
| | | List<Record> records = recordService.list(new LambdaQueryWrapper<Record>().eq(Record::getLevel, 0).eq(Record::getDeleted, 0).in(Record::getCheckTaskId, taskIds)); |
| | | hiddenDangerVo.setSerious(records.size()); |
| | | int rectified = records.stream().filter(Record::getReformed).collect(Collectors.toList()).size(); |
| | | hiddenDangerVo.setRectified(rectified); |
| | | hiddenDangerVo.setUnRectified(records.size()-rectified); |
| | | } |
| | | return R.ok(hiddenDangerVo); |
| | | } |
| | | |
| | | @ApiOperation(value = "获取项目所有隐患数量",response = HiddenDangerVo.class) |
| | | @GetMapping("/getProjectHiddenDangerCountAll/{id}") |
| | | public R<HiddenDangerVo> getProjectHiddenDangerCountAll(@PathVariable Integer id) { |
| | | HiddenDangerVo hiddenDangerVo = new HiddenDangerVo(); |
| | | List<Task> list = taskService.list(new LambdaQueryWrapper<Task>().eq(Task::getProjectId, id)); |
| | | if(!list.isEmpty()){ |
| | | List<Integer> taskIds = list.stream().map(Task::getId).collect(Collectors.toList()); |
| | | // 0是一级隐患 |
| | | List<Record> records = recordService.list(new LambdaQueryWrapper<Record>().eq(Record::getDeleted, 0).in(Record::getCheckTaskId, taskIds)); |
| | | hiddenDangerVo.setSerious(records.size()); |
| | | int rectified = records.stream().filter(Record::getReformed).collect(Collectors.toList()).size(); |
| | | hiddenDangerVo.setRectified(rectified); |
| | |
| | | |
| | | @ApiOperation(value = "获取计划下拉框信息",response = Plan.class) |
| | | @GetMapping("/getPlanList") |
| | | public R<List<Plan>> getPlanList() { |
| | | List<Plan> list = planService.list(new LambdaQueryWrapper<Plan>().eq(Plan::getDeleted, false)); |
| | | public R<List<Plan>> getPlanList(Integer projectId) { |
| | | List<Plan> list = planService.list(new LambdaQueryWrapper<Plan>().eq(projectId!=null,Plan::getProjectId,projectId).eq(Plan::getDeleted, false)); |
| | | return R.ok(list); |
| | | } |
| | | |
| | | |
| | | @ApiOperation(value = "获取计划下拉框信息",response = Plan.class) |
| | | @GetMapping("/getPlanListFromOnDuty") |
| | | public R<List<Plan>> getPlanListFromOnDuty(Integer projectId) { |
| | | List<OnDuty> list = onDutyService.list(new LambdaQueryWrapper<OnDuty>().eq(OnDuty::getProjectId, projectId)); |
| | | if(list.isEmpty()){ |
| | | return R.ok(new ArrayList<>()); |
| | | } |
| | | List<Integer> ids = list.stream().map(OnDuty::getPlanId).toList(); |
| | | List<Plan> resultList = planService.list(new LambdaQueryWrapper<Plan>().in(Plan::getId,ids).eq(Plan::getDeleted, false)); |
| | | return R.ok(resultList); |
| | | } |
| | | |
| | | |
| | | @ApiOperation(value = "获取人员在岗列表",response = ProjectPersonOnDutyListVo.class) |
| | | @PostMapping("/getProjectOnDutyList") |
| | | public R<Page<ProjectPersonOnDutyListVo>> getProjectOnDutyList(@RequestBody @Valid ProjectPersonListQuery query) { |