lihongjie/coal
1
0
Fork 0
mirror of https://codeup.aliyun.com/64f7d6b8ce01efaafef1e678/coal/coal.git synced 2026-01-25 15:55:18 +08:00
Code Issues Packages Projects Releases Wiki Activity

删除数据关联校验

Browse Source
This commit is contained in:
lihongjie0209
2024-04-23 17:30:34 +08:00
parent 3f47ddc960
commit d3b5df8980
33 changed files with 218 additions and 42 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/main/java/cn/lihongjie/coal/acDevice/repository/AcDeviceRepository.java
View File

@@ -3,7 +3,15 @@ package cn.lihongjie.coal.acDevice.repository;
import cn.lihongjie.coal.acDevice.entity.AcDeviceEntity;
import cn.lihongjie.coal.base.dao.BaseRepository;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;
import org.springframework.stereotype.Repository;
import java.util.List;
@Repository
public interface AcDeviceRepository extends BaseRepository<AcDeviceEntity> {}
public interface AcDeviceRepository extends BaseRepository<AcDeviceEntity> {
@Query("select exists(select 1 from AcDeviceDataEntity e where e.device.id in :ids union all select 1 from AcAppointmentEntity e where e.device.id in :ids) ")
boolean isLinked(@Param("ids") List<String> ids);
}

22
src/main/java/cn/lihongjie/coal/acDevice/service/AcDeviceService.java
View File

@@ -1,6 +1,5 @@
package cn.lihongjie.coal.acDevice.service;
import cn.lihongjie.coal.acAppointment.entity.AcAppointmentEntity;
import cn.lihongjie.coal.acAppointment.service.AcAppointmentService;
import cn.lihongjie.coal.acDevice.dto.AcDeviceDto;
import cn.lihongjie.coal.acDevice.dto.CreateAcDeviceDto;
@@ -8,14 +7,12 @@ import cn.lihongjie.coal.acDevice.dto.UpdateAcDeviceDto;
import cn.lihongjie.coal.acDevice.entity.AcDeviceEntity;
import cn.lihongjie.coal.acDevice.mapper.AcDeviceMapper;
import cn.lihongjie.coal.acDevice.repository.AcDeviceRepository;
import cn.lihongjie.coal.acDeviceData.entity.AcDeviceDataEntity;
import cn.lihongjie.coal.acDeviceData.service.AcDeviceDataService;
import cn.lihongjie.coal.base.dto.CommonQuery;
import cn.lihongjie.coal.base.dto.IdRequest;
import cn.lihongjie.coal.base.service.BaseService;
import cn.lihongjie.coal.dbFunctions.DbFunctionService;
import cn.lihongjie.coal.exception.BizException;
import cn.lihongjie.coal.exception.DataLinkedException;
import lombok.extern.slf4j.Slf4j;
@@ -24,7 +21,6 @@ import org.springframework.core.convert.ConversionService;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Sort;
import org.springframework.data.jpa.domain.Specification;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
@@ -68,23 +64,11 @@ public class AcDeviceService extends BaseService<AcDeviceEntity, AcDeviceReposit
throw new BizException("部分数据已归档，无法编辑或删除");
}
if (acDeviceDataService.count(
(Specification<AcDeviceDataEntity>)
(root, query, criteriaBuilder) ->
criteriaBuilder.and(
root.get("device").get("id").in(request.getIds())))
> 0) {
throw new DataLinkedException();
if (this.repository.isLinked(request.getIds())) {
throw new BizException("部分数据已关联，无法编辑或删除");
}
if (acAppointmentService.count(
(Specification<AcAppointmentEntity>)
(root, query, criteriaBuilder) ->
criteriaBuilder.and(
root.get("device").get("id").in(request.getIds())))
> 0) {
throw new DataLinkedException();
}

11
src/main/java/cn/lihongjie/coal/acDeviceSupplier/repository/AcDeviceSupplierRepository.java
View File

@@ -3,7 +3,16 @@ package cn.lihongjie.coal.acDeviceSupplier.repository;
import cn.lihongjie.coal.acDeviceSupplier.entity.AcDeviceSupplierEntity;
import cn.lihongjie.coal.base.dao.BaseRepository;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;
import org.springframework.stereotype.Repository;
import java.util.List;
@Repository
public interface AcDeviceSupplierRepository extends BaseRepository<AcDeviceSupplierEntity> {}
public interface AcDeviceSupplierRepository extends BaseRepository<AcDeviceSupplierEntity> {
@Query("select exists(select 1 from AcDeviceEntity e where e.supplier.id in :ids)")
boolean isLinked(@Param("ids") List<String> ids);
}

12
src/main/java/cn/lihongjie/coal/acDeviceSupplier/service/AcDeviceSupplierService.java
View File

@@ -1,6 +1,5 @@
package cn.lihongjie.coal.acDeviceSupplier.service;
import cn.lihongjie.coal.acDevice.entity.AcDeviceEntity;
import cn.lihongjie.coal.acDevice.service.AcDeviceService;
import cn.lihongjie.coal.acDeviceSupplier.dto.AcDeviceSupplierDto;
import cn.lihongjie.coal.acDeviceSupplier.dto.CreateAcDeviceSupplierDto;
@@ -13,7 +12,6 @@ import cn.lihongjie.coal.base.dto.IdRequest;
import cn.lihongjie.coal.base.service.BaseService;
import cn.lihongjie.coal.dbFunctions.DbFunctionService;
import cn.lihongjie.coal.exception.BizException;
import cn.lihongjie.coal.exception.DataLinkedException;
import lombok.extern.slf4j.Slf4j;
@@ -22,7 +20,6 @@ import org.springframework.core.convert.ConversionService;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Sort;
import org.springframework.data.jpa.domain.Specification;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
@@ -65,13 +62,8 @@ public class AcDeviceSupplierService
throw new BizException("部分数据已归档，无法编辑或删除");
}
if (acDeviceService.count(
(Specification<AcDeviceEntity>) (root, query, criteriaBuilder) -> criteriaBuilder.and(
criteriaBuilder
.in(root.get("supplier").get("id"))
.value(request.getIds())))
> 0) {
throw new DataLinkedException();
if (this.repository.isLinked(request.getIds())) {
throw new BizException("部分数据已关联，无法编辑或删除");
}
this.repository.deleteAllById(request.getIds());

10
src/main/java/cn/lihongjie/coal/coalInfo/repository/CoalInfoRepository.java
View File

@@ -3,7 +3,15 @@ package cn.lihongjie.coal.coalInfo.repository;
import cn.lihongjie.coal.base.dao.BaseRepository;
import cn.lihongjie.coal.coalInfo.entity.CoalInfoEntity;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;
import org.springframework.stereotype.Repository;
import java.util.List;
@Repository
public interface CoalInfoRepository extends BaseRepository<CoalInfoEntity> {}
public interface CoalInfoRepository extends BaseRepository<CoalInfoEntity> {
@Query("select exists(select 1 from CoalAnalysisEntity e where e.coalInfo.id in :ids)")
boolean isLinked(@Param("ids") List<String> ids);
}

6
src/main/java/cn/lihongjie/coal/coalInfo/service/CoalInfoService.java
View File

@@ -11,6 +11,7 @@ import cn.lihongjie.coal.coalInfo.mapper.CoalInfoMapper;
import cn.lihongjie.coal.coalInfo.repository.CoalInfoRepository;
import cn.lihongjie.coal.coalPrice.entity.CoalPriceEntity;
import cn.lihongjie.coal.coalPrice.service.CoalPriceService;
import cn.lihongjie.coal.exception.BizException;
import lombok.extern.slf4j.Slf4j;
@@ -65,6 +66,11 @@ class CoalInfoService extends BaseService<CoalInfoEntity, CoalInfoRepository> {
}
public void delete(IdRequest request) {
if (this.repository.isLinked(request.getIds())) {
throw new BizException("部分数据已关联，无法编辑或删除");
}
this.repository.deleteAllById(request.getIds());
}

29
src/main/java/cn/lihongjie/coal/dataCollector/repository/DataCollectorRepository.java
View File

@@ -3,9 +3,38 @@ package cn.lihongjie.coal.dataCollector.repository;
import cn.lihongjie.coal.base.dao.BaseRepository;
import cn.lihongjie.coal.dataCollector.entity.DataCollectorEntity;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;
import org.springframework.stereotype.Repository;
import java.util.List;
@Repository
public interface DataCollectorRepository extends BaseRepository<DataCollectorEntity> {
DataCollectorEntity findByAppKey(String appKey);
@Query("""
select exists(
select 1 from AcDeviceEntity e where e.dataCollector.id in :ids
union all
select 1 from WeightDeviceEntity e where e.dataCollector.id in :ids
union all
select 1 from PdcDeviceEntity e where e.dataCollector.id in :ids
)
""")
boolean isLinked(@Param("ids") List<String> ids);
}

6
src/main/java/cn/lihongjie/coal/dataCollector/service/DataCollectorService.java
View File

@@ -10,6 +10,7 @@ import cn.lihongjie.coal.dataCollector.entity.DataCollectorEntity;
import cn.lihongjie.coal.dataCollector.mapper.DataCollectorMapper;
import cn.lihongjie.coal.dataCollector.repository.DataCollectorRepository;
import cn.lihongjie.coal.dbFunctions.DbFunctionService;
import cn.lihongjie.coal.exception.BizException;
import jakarta.annotation.PostConstruct;
@@ -134,6 +135,11 @@ public class DataCollectorService
}
public void delete(IdRequest request) {
if (this.repository.isLinked(request.getIds())) {
throw new BizException("部分数据已关联，无法编辑或删除");
}
this.repository.deleteAllById(request.getIds());
}

4
src/main/java/cn/lihongjie/coal/department/repository/DepartmentRepository.java
View File

@@ -29,4 +29,8 @@ public interface DepartmentRepository extends BaseRepository<DepartmentEntity> {
""", nativeQuery = true)
List<Map> empIds(@Param("ids") List<String> ids);
@Query("select exists(select 1 from EmployeeEntity e where e.department.id in :ids)")
boolean isLinked(@Param("ids") List<String> ids);
}

6
src/main/java/cn/lihongjie/coal/department/service/DepartmentService.java
View File

@@ -15,6 +15,7 @@ import cn.lihongjie.coal.department.dto.UpdateDepartmentDto;
import cn.lihongjie.coal.department.entity.DepartmentEntity;
import cn.lihongjie.coal.department.mapper.DepartmentMapper;
import cn.lihongjie.coal.department.repository.DepartmentRepository;
import cn.lihongjie.coal.exception.BizException;
import jakarta.annotation.PostConstruct;
import jakarta.persistence.EntityManager;
@@ -69,6 +70,11 @@ class DepartmentService extends BaseService<DepartmentEntity, DepartmentReposito
public void delete(IdRequest request) {
if (this.repository.isLinked(request.getIds())){
throw new BizException("部分数据已关联，无法删除");
}
this.repository.deleteAllById(request.getIds());
}

10
src/main/java/cn/lihongjie/coal/device/repository/DeviceRepository.java
View File

@@ -3,7 +3,15 @@ package cn.lihongjie.coal.device.repository;
import cn.lihongjie.coal.base.dao.BaseRepository;
import cn.lihongjie.coal.device.entity.DeviceEntity;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;
import org.springframework.stereotype.Repository;
import java.util.List;
@Repository
public interface DeviceRepository extends BaseRepository<DeviceEntity> {}
public interface DeviceRepository extends BaseRepository<DeviceEntity> {
@Query("select exists(select 1 from DeviceWorkOrderEntity e where e.device.id in :ids)")
boolean isLinked(@Param("ids") List<String> ids);
}

5
src/main/java/cn/lihongjie/coal/device/service/DeviceService.java
View File

@@ -54,6 +54,11 @@ public class DeviceService extends BaseService<DeviceEntity, DeviceRepository> {
if (this.repository.containArchived(request)){
throw new BizException("部分数据已归档，无法编辑或删除");
}
if (this.repository.isLinked(request.getIds())) {
throw new BizException("部分数据已关联，无法编辑或删除");
}
this.repository.deleteAllById(request.getIds());
}

2
src/main/java/cn/lihongjie/coal/deviceCategory/repository/DeviceCategoryRepository.java
View File

@@ -29,4 +29,6 @@ public interface DeviceCategoryRepository extends BaseRepository<DeviceCategoryE
""", nativeQuery = true)
List<Map> deviceIds(@Param("ids") List<String> ids);
@Query("select exists(select 1 from DeviceEntity e where e.category.id in :ids)")
boolean isLinked(@Param("ids") List<String> ids);
}

6
src/main/java/cn/lihongjie/coal/deviceCategory/service/DeviceCategoryService.java
View File

@@ -14,6 +14,7 @@ import cn.lihongjie.coal.deviceCategory.dto.UpdateDeviceCategoryDto;
import cn.lihongjie.coal.deviceCategory.entity.DeviceCategoryEntity;
import cn.lihongjie.coal.deviceCategory.mapper.DeviceCategoryMapper;
import cn.lihongjie.coal.deviceCategory.repository.DeviceCategoryRepository;
import cn.lihongjie.coal.exception.BizException;
import lombok.extern.slf4j.Slf4j;
@@ -61,6 +62,11 @@ public class DeviceCategoryService
}
public void delete(IdRequest request) {
if (this.repository.isLinked(request.getIds())) {
throw new BizException("部分数据已关联，无法编辑或删除");
}
this.repository.deleteAllById(request.getIds());
}

9
src/main/java/cn/lihongjie/coal/deviceSupplier/repository/DeviceSupplierRepository.java
View File

@@ -3,7 +3,14 @@ package cn.lihongjie.coal.deviceSupplier.repository;
import cn.lihongjie.coal.base.dao.BaseRepository;
import cn.lihongjie.coal.deviceSupplier.entity.DeviceSupplierEntity;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;
import org.springframework.stereotype.Repository;
import java.util.List;
@Repository
public interface DeviceSupplierRepository extends BaseRepository<DeviceSupplierEntity> {}
public interface DeviceSupplierRepository extends BaseRepository<DeviceSupplierEntity> {
@Query("select exists(select 1 from DeviceEntity e where e.supplier.id in :ids)")
boolean isLinked(@Param("ids") List<String> ids);
}

5
src/main/java/cn/lihongjie/coal/deviceSupplier/service/DeviceSupplierService.java
View File

@@ -55,6 +55,11 @@ public class DeviceSupplierService
if (this.repository.containArchived(request)){
throw new BizException("部分数据已归档，无法编辑或删除");
}
if (this.repository.isLinked(request.getIds())){
throw new BizException("部分数据已关联，无法编辑或删除");
}
this.repository.deleteAllById(request.getIds());
}

3
src/main/java/cn/lihongjie/coal/jobPost/repository/JobPostRepository.java
View File

@@ -23,6 +23,9 @@ select e.jobPost.id as id, array_agg(e.id) as empIds from EmployeeEntity e
""")
List<Map> getSelfEmpIds(@Param("ids") List<String> ids);
@Query("select exists(select 1 from EmployeeEntity e where e.jobPost.id in :ids)")
boolean isLinked(@Param("ids") List<String> ids);
record JobPostEmpDto(String id, List<String> empIds) {
}
}

7
src/main/java/cn/lihongjie/coal/jobPost/service/JobPostService.java
View File

@@ -6,6 +6,7 @@ import cn.lihongjie.coal.base.entity.BaseEntity;
import cn.lihongjie.coal.base.service.BaseService;
import cn.lihongjie.coal.common.CollectionUtils;
import cn.lihongjie.coal.common.Ctx;
import cn.lihongjie.coal.exception.BizException;
import cn.lihongjie.coal.jobPost.dto.CreateJobPostDto;
import cn.lihongjie.coal.jobPost.dto.JobPostDto;
import cn.lihongjie.coal.jobPost.dto.UpdateJobPostDto;
@@ -53,6 +54,12 @@ public class JobPostService extends BaseService<JobPostEntity, JobPostRepository
}
public void delete(IdRequest request) {
if (this.repository.isLinked(request.getIds())){
throw new BizException("部分数据已关联，无法编辑或删除");
}
this.repository.deleteAllById(request.getIds());
}

9
src/main/java/cn/lihongjie/coal/meter/repository/MeterRepository.java
View File

@@ -3,7 +3,14 @@ package cn.lihongjie.coal.meter.repository;
import cn.lihongjie.coal.base.dao.BaseRepository;
import cn.lihongjie.coal.meter.entity.MeterEntity;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;
import org.springframework.stereotype.Repository;
import java.util.List;
@Repository
public interface MeterRepository extends BaseRepository<MeterEntity> {}
public interface MeterRepository extends BaseRepository<MeterEntity> {
@Query("select exists(select 1 from MeterLogEntity e where e.meter.id in :ids)")
boolean isLinked(@Param("ids") List<String> ids);
}

6
src/main/java/cn/lihongjie/coal/meter/service/MeterService.java
View File

@@ -3,6 +3,7 @@ package cn.lihongjie.coal.meter.service;
import cn.lihongjie.coal.base.dto.CommonQuery;
import cn.lihongjie.coal.base.dto.IdRequest;
import cn.lihongjie.coal.base.service.BaseService;
import cn.lihongjie.coal.exception.BizException;
import cn.lihongjie.coal.meter.dto.CreateMeterDto;
import cn.lihongjie.coal.meter.dto.MeterDto;
import cn.lihongjie.coal.meter.dto.UpdateMeterDto;
@@ -48,6 +49,11 @@ class MeterService extends BaseService<MeterEntity, MeterRepository> {
}
public void delete(IdRequest request) {
if (this.repository.isLinked(request.getIds())) {
throw new BizException("部分数据已关联，无法编辑或删除");
}
this.repository.deleteAllById(request.getIds());
}

3
src/main/java/cn/lihongjie/coal/organization/dto/CreateOrganizationDto.java
View File

@@ -7,6 +7,7 @@ import lombok.Data;
import org.hibernate.annotations.Comment;
import java.time.LocalDateTime;
import java.util.List;
@Data
public class CreateOrganizationDto extends CommonDto {
@@ -25,4 +26,6 @@ public class CreateOrganizationDto extends CommonDto {
@Comment("过期时间")
private LocalDateTime expireTime;
private List<String> permissions;
}

4
src/main/java/cn/lihongjie/coal/organization/dto/UpdateOrganizationDto.java
View File

@@ -7,6 +7,7 @@ import lombok.Data;
import org.hibernate.annotations.Comment;
import java.time.LocalDateTime;
import java.util.List;
@Data
public class UpdateOrganizationDto extends CommonDto {
@@ -21,4 +22,7 @@ public class UpdateOrganizationDto extends CommonDto {
@Comment("过期时间")
private LocalDateTime expireTime;
private List<String> permissions;
}

4
src/main/java/cn/lihongjie/coal/organization/entity/OrganizationEntity.java
View File

@@ -1,6 +1,7 @@
package cn.lihongjie.coal.organization.entity;
import cn.lihongjie.coal.base.entity.CommonEntity;
import cn.lihongjie.coal.permission.entity.PermissionEntity;
import com.fasterxml.jackson.annotation.JsonBackReference;
import com.fasterxml.jackson.annotation.JsonManagedReference;
@@ -40,7 +41,8 @@ public class OrganizationEntity extends CommonEntity {
private LocalDateTime expireTime;
@ManyToMany
private List<PermissionEntity> permissions;

12
src/main/java/cn/lihongjie/coal/permission/repository/PermissionRepository.java
View File

@@ -4,6 +4,7 @@ import cn.lihongjie.coal.base.dao.BaseRepository;
import cn.lihongjie.coal.permission.entity.PermissionEntity;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;
import org.springframework.stereotype.Repository;
import java.util.List;
@@ -14,9 +15,14 @@ public interface PermissionRepository extends BaseRepository<PermissionEntity> {
List<PermissionEntity> findAllByPermissionTypeIn(String[] types);
@Query("select count(p) > 0 from PermissionEntity p inner join p.resources r on r.id = ?1 where p.permissionType = '0' ")
@Query(
"select count(p) > 0 from PermissionEntity p inner join p.resources r on r.id = ?1 where p.permissionType = '0' ")
boolean isAnonymousByResourceId(String resourceId);
@Query("select count(p) > 0 from PermissionEntity p inner join p.resources r on r.id = ?1 where p.permissionType in ?2 ")
boolean hasPermission( String resourceId, List<String> permissionType);
@Query(
"select count(p) > 0 from PermissionEntity p inner join p.resources r on r.id = ?1 where p.permissionType in ?2 ")
boolean hasPermission(String resourceId, List<String> permissionType);
@Query("select exists(select 1 from RoleEntity e join PermissionEntity p where p.id in :ids)")
boolean isLinked(@Param("ids") List<String> ids);
}

5
src/main/java/cn/lihongjie/coal/permission/service/PermissionService.java
View File

@@ -4,6 +4,7 @@ import cn.lihongjie.coal.base.dto.CommonQuery;
import cn.lihongjie.coal.base.dto.IdRequest;
import cn.lihongjie.coal.base.service.BaseService;
import cn.lihongjie.coal.common.Constants;
import cn.lihongjie.coal.exception.BizException;
import cn.lihongjie.coal.permission.dto.CreatePermissionDto;
import cn.lihongjie.coal.permission.dto.PermissionDto;
import cn.lihongjie.coal.permission.dto.PermissionExportDto;
@@ -59,6 +60,10 @@ public class PermissionService extends BaseService<PermissionEntity, PermissionR
public void delete(IdRequest request) {
if (this.repository.isLinked(request.getIds())) {
throw new BizException("部分数据已关联，无法编辑或删除");
}
this.repository.deleteAllById(request.getIds());
}

8
src/main/java/cn/lihongjie/coal/resource/repository/ResourceRepository.java
View File

@@ -5,6 +5,7 @@ import cn.lihongjie.coal.resource.dto.ResourceDto;
import cn.lihongjie.coal.resource.entity.ResourceEntity;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;
import org.springframework.stereotype.Repository;
import java.util.List;
@@ -12,11 +13,16 @@ import java.util.List;
@Repository
public interface ResourceRepository extends BaseRepository<ResourceEntity> {
@Query(
"select exists(select 1 from PermissionEntity e join ResourceEntity r where r.id in :ids)")
boolean isLinked(@Param("ids") List<String> ids);
// @EntityGraph(attributePaths = {"children"})
List<ResourceEntity> findAllByTypeAndParentIsNullOrderBySortKey(String type);
ResourceEntity findByUrlAndType(String url, String type);
@Query("select new cn.lihongjie.coal.resource.dto.ResourceDto(r.id, r.code, r.name, r.type, r.anonymous, r.orgAdmin, r.sysAdmin, r.signCheck, r.rateLimit, r.submitToken) from ResourceEntity r where r.code = ?1 and r.type = ?2 ")
@Query(
"select new cn.lihongjie.coal.resource.dto.ResourceDto(r.id, r.code, r.name, r.type, r.anonymous, r.orgAdmin, r.sysAdmin, r.signCheck, r.rateLimit, r.submitToken) from ResourceEntity r where r.code = ?1 and r.type = ?2 ")
ResourceDto findByCodeAndType(String code, String type);
}

6
src/main/java/cn/lihongjie/coal/resource/service/ResourceService.java
View File

@@ -8,6 +8,7 @@ import cn.lihongjie.coal.base.dto.CommonQuery;
import cn.lihongjie.coal.base.dto.IdRequest;
import cn.lihongjie.coal.base.service.BaseService;
import cn.lihongjie.coal.common.Constants;
import cn.lihongjie.coal.exception.BizException;
import cn.lihongjie.coal.permission.service.PermissionService;
import cn.lihongjie.coal.resource.dto.*;
import cn.lihongjie.coal.resource.entity.ResourceEntity;
@@ -72,6 +73,11 @@ public class ResourceService extends BaseService<ResourceEntity, ResourceReposit
public void delete(IdRequest request) {
if (this.repository.isLinked(request.getIds())) {
throw new BizException("部分数据已关联，无法编辑或删除");
}
this.repository.deleteAllById(request.getIds());
Cache cache = entityManager.unwrap(Session.class).getSessionFactory().getCache();

5
src/main/java/cn/lihongjie/coal/role/repository/RoleRepository.java
View File

@@ -3,6 +3,8 @@ package cn.lihongjie.coal.role.repository;
import cn.lihongjie.coal.base.dao.BaseRepository;
import cn.lihongjie.coal.role.entity.RoleEntity;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;
import org.springframework.stereotype.Repository;
import java.util.List;
@@ -13,4 +15,7 @@ public interface RoleRepository extends BaseRepository<RoleEntity> {
List<RoleEntity> findAllByIsSysDefault(Boolean isSysDefault);
List<RoleEntity> findAllByIsOrgAdmin(Boolean isOrgAdmin);
@Query("select exists(select 1 from UserEntity e join RoleEntity r where r.id in :ids)")
boolean isLinked(@Param("ids") List<String> ids);
}

4
src/main/java/cn/lihongjie/coal/role/service/RoleService.java
View File

@@ -3,6 +3,7 @@ package cn.lihongjie.coal.role.service;
import cn.lihongjie.coal.base.dto.CommonQuery;
import cn.lihongjie.coal.base.dto.IdRequest;
import cn.lihongjie.coal.base.service.BaseService;
import cn.lihongjie.coal.exception.BizException;
import cn.lihongjie.coal.role.dto.CreateRoleDto;
import cn.lihongjie.coal.role.dto.RoleDto;
import cn.lihongjie.coal.role.dto.UpdateRoleDto;
@@ -60,6 +61,9 @@ class RoleService extends BaseService<RoleEntity, RoleRepository> {
@CacheEvict(cacheNames = "userResources", allEntries = true)
public void delete(IdRequest request) {
if (this.repository.isLinked(request.getIds())) {
throw new BizException("部分数据已关联，无法编辑或删除");
}
this.repository.deleteAllById(request.getIds());
}

10
src/main/java/cn/lihongjie/coal/weightDevice/repository/WeightDeviceRepository.java
View File

@@ -3,7 +3,15 @@ package cn.lihongjie.coal.weightDevice.repository;
import cn.lihongjie.coal.base.dao.BaseRepository;
import cn.lihongjie.coal.weightDevice.entity.WeightDeviceEntity;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;
import org.springframework.stereotype.Repository;
import java.util.List;
@Repository
public interface WeightDeviceRepository extends BaseRepository<WeightDeviceEntity> {}
public interface WeightDeviceRepository extends BaseRepository<WeightDeviceEntity> {
@Query("select exists(select 1 from WeightDeviceDataEntity e where e.device.id in :ids)")
boolean isLinked(@Param("ids") List<String> ids);
}

6
src/main/java/cn/lihongjie/coal/weightDevice/service/WeightDeviceService.java
View File

@@ -4,6 +4,7 @@ import cn.lihongjie.coal.base.dto.CommonQuery;
import cn.lihongjie.coal.base.dto.IdRequest;
import cn.lihongjie.coal.base.service.BaseService;
import cn.lihongjie.coal.dbFunctions.DbFunctionService;
import cn.lihongjie.coal.exception.BizException;
import cn.lihongjie.coal.weightDevice.dto.CreateWeightDeviceDto;
import cn.lihongjie.coal.weightDevice.dto.UpdateWeightDeviceDto;
import cn.lihongjie.coal.weightDevice.dto.WeightDeviceDto;
@@ -50,6 +51,11 @@ public class WeightDeviceService extends BaseService<WeightDeviceEntity, WeightD
}
public void delete(IdRequest request) {
if (this.repository.isLinked(request.getIds())) {
throw new BizException("部分数据已关联，无法编辑或删除");
}
this.repository.deleteAllById(request.getIds());
}

10
src/main/java/cn/lihongjie/coal/weightDeviceSupplier/repository/WeightDeviceSupplierRepository.java
View File

@@ -3,8 +3,16 @@ package cn.lihongjie.coal.weightDeviceSupplier.repository;
import cn.lihongjie.coal.base.dao.BaseRepository;
import cn.lihongjie.coal.weightDeviceSupplier.entity.WeightDeviceSupplierEntity;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;
import org.springframework.stereotype.Repository;
import java.util.List;
@Repository
public interface WeightDeviceSupplierRepository
extends BaseRepository<WeightDeviceSupplierEntity> {}
extends BaseRepository<WeightDeviceSupplierEntity> {
@Query("select exists(select 1 from WeightDeviceEntity e where e.supplier.id in :ids)")
boolean isLinked(@Param("ids") List<String> ids);
}

5
src/main/java/cn/lihongjie/coal/weightDeviceSupplier/service/WeightDeviceSupplierService.java
View File

@@ -4,6 +4,7 @@ import cn.lihongjie.coal.base.dto.CommonQuery;
import cn.lihongjie.coal.base.dto.IdRequest;
import cn.lihongjie.coal.base.service.BaseService;
import cn.lihongjie.coal.dbFunctions.DbFunctionService;
import cn.lihongjie.coal.exception.BizException;
import cn.lihongjie.coal.weightDeviceSupplier.dto.CreateWeightDeviceSupplierDto;
import cn.lihongjie.coal.weightDeviceSupplier.dto.UpdateWeightDeviceSupplierDto;
import cn.lihongjie.coal.weightDeviceSupplier.dto.WeightDeviceSupplierDto;
@@ -51,6 +52,10 @@ public class WeightDeviceSupplierService
}
public void delete(IdRequest request) {
if (this.repository.isLinked(request.getIds())) {
throw new BizException("部分数据已关联，无法编辑或删除");
}
this.repository.deleteAllById(request.getIds());
}