heheng
2024-11-07 3ca43826a747fda1447b2501901f84fc1a9019dd
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
package com.gkhy.labRiskManage.domain.riskReport.repository.jpa;
 
import com.gkhy.labRiskManage.api.controller.riskReport.dto.repDto.RiskUnitListReqBO;
import com.gkhy.labRiskManage.domain.riskReport.entity.RiskUnit;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
import org.springframework.data.jpa.repository.Query;
import org.springframework.stereotype.Repository;
 
import java.util.List;
 
 
/**
 * 实验风险单元
 */
@Repository
public interface RiskUnitRepository extends JpaRepository<RiskUnit, Long>, JpaSpecificationExecutor<RiskUnit> {
 
    /**
     * 实验风险单元 - 查询 by code
     */
    @Query(value = "select t from RiskUnit t where t.riskCode = :riskCode and t.experimentId = :experimentId and t.deleteStatus = 0")
    RiskUnit getUnitByCode(String riskCode,Long experimentId);
    /**
     * 风险单元 - 查询 by id
     */
    @Query(value = "select t from RiskUnit t where t.id = :id and t.deleteStatus = 0")
    RiskUnit getUnitById(Long id);
    /**
     * 风险单元 - 查询by name
     */
    @Query(value = "select * from risk_unit where risk_name = :riskUnitName and delete_status = 0",nativeQuery = true)
    List<RiskUnit> getRiskUnitByName(String riskUnitName);
    /**
     * 基础风险单元管理 - 列表查询
     */
    @Query(value = "select * from risk_unit where delete_status = 0 and evaluate_status = 1",nativeQuery = true)
    List<RiskUnit>  listRiskUnit();
    /**
     * 基础风险单元管理 - 列表查询
     */
    @Query(value = "select * from risk_unit where create_by_user_id = :currentUserId and delete_status = 0 and evaluate_status = 1",nativeQuery = true)
    List<RiskUnit>  listRiskUnitByUserId(Long currentUserId);
 
    /**
     * 基础风险单元管理 - 已添加评估计划的unit
     */
    @Query(value = "select * from risk_unit where delete_status = 0",nativeQuery = true)
    List<RiskUnit> listAssessRiskUnit();
 
 
    @Query(value = "select * from risk_unit where delete_status = 0 and experiment_id = :id",nativeQuery = true)
    List<RiskUnit> getRiskUnitByExperimentId(Long id);
 
    @Query(value = "select * from risk_unit where delete_status = 0 and risk_source_type < 4",nativeQuery = true)
    List<RiskUnit> listInherentRiskUnit();
    /**
     * 基础风险单元管理 - 列表查询
     */
    @Query(value = "select * from risk_unit where delete_status = 0 and evaluate_status = 1 and experiment_id = :#{#reqBO.ExperimentId}",nativeQuery = true)
    List<RiskUnit> listRiskUnitByExperiment(RiskUnitListReqBO reqBO);
    /**
     * 基础风险单元管理 - 列表查询
     */
    @Query(value = "select * from risk_unit where create_by_user_id = :currentUserId and delete_status = 0 and evaluate_status = 1 and experiment_id = :#{#reqBO.ExperimentId}",nativeQuery = true)
    List<RiskUnit> listRiskUnitByExperimentAndUserId(Long currentUserId, RiskUnitListReqBO reqBO);
}