固有风险按照楼栋筛选20230728

censoft-rongtong/src/main/java/com/censoft/censoftrongtong/controller/RiskPlanInherentListController.java

 package com.censoft.censoftrongtong.controller;
 
+import java.util.ArrayList;
+import java.util.Arrays;
 import java.util.List;
+import java.util.stream.Collectors;
 import javax.servlet.http.HttpServletResponse;
+
+import com.censoft.censoftrongtong.domain.RiskPlan;
+import com.censoft.censoftrongtong.service.IRiskPlanService;
+import com.ruoyi.common.constant.HttpStatus;
+import com.ruoyi.common.core.page.PageDomain;
+import com.ruoyi.common.core.page.TableSupport;
 import org.springframework.security.access.prepost.PreAuthorize;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.GetMapping;
@@ -33,6 +42,8 @@ public class RiskPlanInherentListController extends BaseController
 {
     @Autowired
     private IRiskPlanInherentListService riskPlanInherentListService;
+    @Autowired
+    private IRiskPlanService riskPlanService;
 
     /**
      * 查询固有风险信息列表
@@ -41,9 +52,39 @@ public class RiskPlanInherentListController extends BaseController
     @GetMapping("/list")
     public TableDataInfo list(RiskPlanInherentList riskPlanInherentList)
     {
-        startPage();
+
+        PageDomain pageDomain = TableSupport.buildPageRequest();
+        Integer pageNum = pageDomain.getPageNum();
+        Integer pageSize = pageDomain.getPageSize();
+
+        List<String> listBuilds=new ArrayList<>();
+        List<RiskPlanInherentList> listRs=new ArrayList<>();
+        if(riskPlanInherentList.getPlanId()!=null){
+            RiskPlan riskPlan=riskPlanService.selectRiskPlanById(riskPlanInherentList.getPlanId());
+            listBuilds= Arrays.asList(riskPlan.getBuildingIds().split(","));
+        }
+        riskPlanInherentList.setPlanId(null);//查询所有
         List<RiskPlanInherentList> list = riskPlanInherentListService.selectRiskPlanInherentListList(riskPlanInherentList);
-        return getDataTable(list);
+        //筛选任务关联楼栋风险信息
+        if (listBuilds.size()>0) {
+            for (RiskPlanInherentList planInherentList : list) {
+                if (listBuilds.contains(planInherentList.getBuildingId())) {
+                    listRs.add(planInherentList);
+                }
+            }
+        }
+
+        int num = listRs.size();
+        listRs = listRs.stream()
+                .skip((pageNum - 1) * pageSize)
+                .limit(pageSize)
+                .collect(Collectors.toList());
+        TableDataInfo rspData = new TableDataInfo();
+        rspData.setCode(HttpStatus.SUCCESS);
+        rspData.setRows(listRs);
+        rspData.setTotal(num);
+
+        return rspData;
     }
 
 

censoft-rongtong/src/main/java/com/censoft/censoftrongtong/domain/RiskPlan.java

@@ -83,6 +83,12 @@ public class RiskPlan extends BaseEntityClean
     /** 删除标志（0代表存在 1代表删除） */
     private String delFlag;
 
+    /**
+     * 项目名称
+     */
+    @TableField(exist = false)
+    private String projectName;
+
 
 
 

censoft-rongtong/src/main/resources/mapper/system/RiskPlanMapper.xml

@@ -27,7 +27,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
     </resultMap>
 
     <sql id="selectRiskPlanVo">
-        select id, name, no, project_id, building_ids, create_user_id, create_dept_id,dept_id, leader_user_id, work_user_ids,approve_user_id, start_time, end_time, status, del_flag, create_by, create_time, update_by, update_time from risk_plan
+        select id, name, no, project_id,(SELECT lp.NAME from ledger_project lp where project_id=lp.id)  'project_name', building_ids, create_user_id, create_dept_id,dept_id, leader_user_id, work_user_ids,approve_user_id, start_time, end_time, status, del_flag, create_by, create_time, update_by, update_time from risk_plan
     </sql>
 
     <select id="selectRiskPlanList" parameterType="com.censoft.censoftrongtong.domain.RiskPlan" resultType="com.censoft.censoftrongtong.domain.dto.RiskPlanAppTaskDetailsDto" >