智慧建筑大屏
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
无关风月
2026-01-29 e395159a34f973fce6ba08fb22ab2d0b09f64d3a 
 ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/ProjectController.java


@@ -1,8 +1,12 @@


package com.ruoyi.web.controller.api;




import cn.hutool.core.date.DateTime;


import cn.hutool.core.date.DateUtil;


import com.baomidou.mybatisplus.core.conditions.Wrapper;


import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;


import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;


import com.baomidou.mybatisplus.extension.plugins.pagination.Page;


import com.icbc.hsm.utils.StringUtil;


import com.ruoyi.common.core.domain.R;


import com.ruoyi.system.dto.EditHiddenDangerResponsiblePersonDto;


import com.ruoyi.system.enums.DeviceType;


@@ -11,16 +15,29 @@


import com.ruoyi.system.query.*;


import com.ruoyi.system.service.*;


import com.ruoyi.system.vo.*;


import io.swagger.annotations.Api;


import io.swagger.annotations.ApiOperation;


import io.swagger.annotations.*;


import lombok.SneakyThrows;


import org.apache.commons.lang3.StringUtils;


import org.springframework.beans.BeanUtils;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.beans.factory.annotation.Value;


import org.springframework.beans.factory.parsing.Problem;


import org.springframework.core.io.InputStreamResource;


import org.springframework.format.annotation.DateTimeFormat;


import org.springframework.http.HttpHeaders;


import org.springframework.http.MediaType;


import org.springframework.http.ResponseEntity;


import org.springframework.web.bind.annotation.*;




import javax.annotation.PostConstruct;


import javax.annotation.Resource;


import javax.validation.Valid;


import java.io.IOException;


import java.math.BigDecimal;


import java.math.RoundingMode;


import java.net.URLEncoder;


import java.nio.file.Files;


import java.nio.file.Path;


import java.util.*;


import java.util.stream.Collectors;




@@ -62,6 +79,9 @@


    @Autowired


    private ScreenAccountService screenAccountService;




    @Autowired


    private ProjectProgressService projectProgressService;






    @ApiOperation(value = "获取项目/委托方列表",response = LoginNameVo.class)


    @GetMapping("/getLoginNameVoList")


@@ -81,6 +101,38 @@




    }






    @ApiOperation(value = "获取项目最新进度",response = ProjectProgress.class)


    @GetMapping("/getProjectProgress/{projectId}")


    public R<ProjectProgress> getProjectProgress(@PathVariable Integer projectId) {


        ProjectProgress projectProgress = projectProgressService.getOne(new LambdaQueryWrapper<ProjectProgress>().eq(ProjectProgress::getProjectId, projectId).eq(ProjectProgress::getDeleted,0).orderByDesc(ProjectProgress::getTime).last("limit 1"));


        return R.ok(projectProgress);


    }






    @ApiOperation(value = "获取项目进度历史列表",response = ProjectProgress.class)


    @PostMapping("/getProjectProgressList")


    public R<Page<ProjectProgress>> getProjectProgressList(@Valid @RequestBody ProjectProgressQuery query) {


        LambdaQueryWrapper<ProjectProgress> wrapper = new LambdaQueryWrapper<ProjectProgress>().eq(ProjectProgress::getProjectId, query.getProjectId()).eq(ProjectProgress::getDeleted, 0);


        if(query.getContent()!=null && !query.getContent().isEmpty()){


            wrapper.like(ProjectProgress::getDetail, query.getContent());


        }


        if(query.getStartTime()!=null && !query.getStartTime().isEmpty()){


            wrapper.ge(ProjectProgress::getTime, query.getStartTime());


        }


        if(query.getEndTime()!=null && !query.getEndTime().isEmpty()){


            wrapper.le(ProjectProgress::getTime, query.getEndTime());


        }




        wrapper.orderByDesc(ProjectProgress::getTime);


        Page<ProjectProgress> page = projectProgressService.page(new Page<>(query.getPageNum(), query.getPageSize()),wrapper);


        return R.ok(page);


    }


    @ApiOperation(value = "获取项目进度详情",response = ProjectProgress.class)


    @GetMapping("/getProjectProgressDetail/{id}")


    public R<ProjectProgress> getProjectProgressDetail(@PathVariable Integer id) {


        return R.ok(projectProgressService.getById(id));


    }






    @ApiOperation(value = "获取项目详情",response = Project.class)


@@ -102,6 +154,12 @@


        if(task!=null){


            projectVo.setCheckTime(task.getUpdateTime());


        }


        List<DeviceCountVo> list = deviceUsageService.getProjectDeviceCount(id);


        list.forEach(item->{


            DeviceType value = DeviceType.values()[item.getType()];


            item.setName(value.getDesc());


        });


        projectVo.setDeviceCountVos(list);


        return R.ok(projectVo);


    }




@@ -161,10 +219,10 @@


    }






    @ApiOperation(value = "获取隐患详情")


    @GetMapping("/getHiddenDangerDetail/{problemId}")


    public R<?> getHiddenDangerDetail(@PathVariable Integer problemId) {


        var record = recordService.getHiddenDangerDetail(problemId);


    @ApiOperation(value = "获取隐患详情",response = ProblemVo.class)


    @GetMapping("/getHiddenDangerDetail/{id}")


    public R<ProblemVo> getHiddenDangerDetail(@PathVariable Integer id) {


        ProblemVo record = recordService.getHiddenDangerDetail(id);


        return R.ok(record);


    }




@@ -208,13 +266,13 @@


        return R.ok(list);


    }






    @ApiOperation(value = "获取检查资料详情")


    @GetMapping("/getDeviceDetailCheckPlanDetail")


    public R<Check> getDeviceDetailCheckPlanDetail(@RequestParam Integer id) {


        Check check = checkService.getDeviceDetailCheckPlanDetail(id);


        return R.ok(check);


    }








    @ApiOperation(value = "获取大屏人员在岗信息")


@@ -255,6 +313,7 @@


        List<Plan> list = planService.list(new LambdaQueryWrapper<Plan>().eq(Plan::getDeleted, false));


        return R.ok(list);


    }






    @ApiOperation(value = "获取人员在岗列表",response = ProjectPersonOnDutyListVo.class)


    @PostMapping("/getProjectOnDutyList")


@@ -352,4 +411,92 @@


        return R.ok(list);


    }




    @ApiOperation(value = "获取项目列表")


    @GetMapping("/list")


    @ApiImplicitParams({


            @ApiImplicitParam(name = "clientId", value = "委托方ID", dataType = "int", paramType = "query"),


            @ApiImplicitParam(name = "projectName", value = "项目名称", dataType = "string", paramType = "query"),


            @ApiImplicitParam(name = "startDate", value = "开始日期", dataType = "date", paramType = "query"),


            @ApiImplicitParam(name = "endDate", value = "结束日期", dataType = "date", paramType = "query"),


            @ApiImplicitParam(name = "projectCategory", value = "项目类型 ongoing-在建工程，fixed-固定资产 ", dataType = "string", paramType = "query")


    })


    public R<List<Project>> getList(@RequestParam("clientId") Integer clientId, String projectName,


                                    @DateTimeFormat(pattern = "yyyy-MM-dd") Date startDate,


                                    @DateTimeFormat(pattern = "yyyy-MM-dd") Date endDate,


                                    @RequestParam("projectCategory") String projectCategory) {


        LambdaQueryWrapper<Project> queryWrapper = new LambdaQueryWrapper<Project>().eq(Project::getDeleted, false);


        if (clientId != null) {


            queryWrapper.eq(Project::getClientId, clientId);


        }


        if (projectName != null && !projectName.isEmpty()) {


            queryWrapper.like(Project::getName, projectName);


        }


        if (Objects.isNull(startDate)) {


            // 获取本月日期


            Date date = new Date();


            startDate = DateUtil.beginOfMonth(date);


        }


        Date finalStartDate = startDate;


        queryWrapper.and(wrapper -> wrapper


                .eq(Project::getStatus, 1)  // 在建项目


                .or(w -> w


                        .eq(Project::getStatus, 2)  // 已完成项目


                        .ge(Project::getSuccessTime, finalStartDate)  // 完成时间 >= 开始日期// 完成时间 <= 结束日期


                ));


        if ("ongoing".equals(projectCategory)) {


            queryWrapper.ne(Project::getType, 2);


        } else if ("fixed".equals(projectCategory)) {


            queryWrapper.eq(Project::getType, 2);


        }


        List<Project> list = projectService.list(queryWrapper);


        return R.ok(list);




    }






    @Resource


    UserFileService userFileService;




    @SneakyThrows


    @ApiOperation(value = "下载文件（名称）")


    @GetMapping("/download/{name}")


    public ResponseEntity<org.springframework.core.io.Resource> downloadFileByName(@PathVariable String name) {


        var userFile = userFileService.getOne(new LambdaQueryWrapper<UserFile>().eq(UserFile::getName, name));


        return downloadFile(userFile);


    }




    private ResponseEntity<org.springframework.core.io.Resource> downloadFile(UserFile userFile) throws IOException {


        InputStreamResource resource =userFileService.resolveResource(userFile);


        var fileSize = userFile.getSize();


//        if(resource == null) {


//            resource = new InputStreamResource(getClass().getClassLoader().getResourceAsStream("images/wukong.png"));


//            fileSize = 6215360L;// resource.contentLength();


//        }




        String encodedFileName = URLEncoder.encode(userFile.getOriginFileName(), "UTF-8");


        String headerValue = String.format("attachment; filename=\"%s\"", encodedFileName);


        return ResponseEntity.ok()


                .contentType(MediaType.parseMediaType(userFile.getContentType()))


                .contentLength(fileSize)


                .header(HttpHeaders.CONTENT_DISPOSITION, headerValue)


                .body(resource);


    }










    @Value("${file.upload.dir}/files")


    private String UPLOAD_DIR;






//    @PostConstruct


//    void init(){


//        fileLocation  = Path.of(UPLOAD_DIR).toAbsolutePath().normalize();


//        try {


//            Files.createDirectories(this.fileLocation);


//        } catch (Exception ex) {


//            throw new RuntimeException("Could not create the directory where the uploaded files will be stored.", ex);


//        }


//    }




}