package org.jeecg.modules.dncFlow.handler;
|
|
import org.jeecg.common.system.vo.LoginUser;
|
import org.jeecg.modules.dnc.entity.PermissionStreamNew;
|
import org.jeecg.modules.dnc.exception.ExceptionCast;
|
import org.jeecg.modules.dnc.response.CommonCode;
|
import org.jeecg.modules.dnc.service.IDeviceTypeService;
|
import org.jeecg.modules.dnc.service.IPermissionStreamNewService;
|
import org.jeecg.modules.dncFlow.service.PermissionHandler;
|
import org.jeecg.modules.dncFlow.service.StreamTarget;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import java.util.Optional;
|
|
@Component
|
public class PermissionProcessor {
|
@Autowired
|
private IDeviceTypeService deviceTypeService;
|
|
@Autowired
|
private IPermissionStreamNewService permissionStreamNewService;
|
|
public <T> PermissionStreamNew process(
|
String attributionId,
|
LoginUser user,
|
StreamTarget target,
|
PermissionHandler<T> handler
|
) {
|
// 1. 加载业务实体
|
T entity = handler.loadEntity(attributionId);
|
if (entity == null) {
|
ExceptionCast.cast(CommonCode.INVALID_PARAM);
|
}
|
|
// 2. 设置关联关系
|
handler.setRelations(entity, target);
|
|
// 3. 设置设备类型
|
setupDeviceType(target);
|
|
// 4. 获取权限流
|
return permissionStreamNewService.loadPermissionStreamNewByBusinessIdAndUserId(
|
handler.getBusinessId(entity),
|
user.getId(),
|
handler.getTypeCode()
|
);
|
}
|
|
private void setupDeviceType(StreamTarget target) {
|
Optional.ofNullable(deviceTypeService.getById(target.getAttributionId()))
|
.ifPresent(device ->
|
target.setDeviceTypeId(device.getId())
|
);
|
}
|
}
|
