opensource/iot-dc3
3
0
Fork 0
mirror of https://gitee.com/pnoker/iot-dc3.git synced 2026-11-04 23:32:48 +08:00
Code Issues Packages Projects Releases Wiki Activity

refactor(tenant): remove redundant hand filter in agentic (covered by interceptor)

Browse Source
This commit is contained in:
pnoker
2026-07-02 17:02:04 +08:00
parent 44f3cde846
commit 196e5cc6ff
6 changed files with 0 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
dc3-common/dc3-common-agentic/src/main/java/io/github/pnoker/common/agentic/service/impl/ActionServiceImpl.java
-2
View File
@@ -152,7 +152,6 @@ public class ActionServiceImpl implements ActionService {
.set(ActionDO::getStatus, nextStatus.getIndex())
.set(ActionDO::getOperateTime, now)
.eq(ActionDO::getId, action.getId())
.eq(ActionDO::getTenantId, header.getTenantId())
.eq(ActionDO::getUserId, header.getUserId())
.eq(ActionDO::getStatus, AgenticActionStatusEnum.PENDING.getIndex())
.and(wrapper -> wrapper.isNull(ActionDO::getExpireTime)
@@ -178,7 +177,6 @@ public class ActionServiceImpl implements ActionService {
private LambdaQueryWrapper<ActionDO> scopedWrapper(RequestHeader.PrincipalHeader header) {
return Wrappers.<ActionDO>query()
.lambda()
.eq(ActionDO::getTenantId, header.getTenantId())
.eq(ActionDO::getUserId, header.getUserId());
}
dc3-common/dc3-common-agentic/src/main/java/io/github/pnoker/common/agentic/service/impl/AttachmentServiceImpl.java
-2
View File
@@ -108,7 +108,6 @@ public class AttachmentServiceImpl implements AttachmentService {
LambdaQueryWrapper<AttachmentDO> wrapper = Wrappers.<AttachmentDO>query()
.lambda()
.eq(AttachmentDO::getConversationId, conversationId)
.eq(AttachmentDO::getTenantId, header.getTenantId())
.eq(AttachmentDO::getUserId, header.getUserId())
.orderByDesc(AttachmentDO::getCreateTime);
return attachmentBuilder.buildBOListByDOList(attachmentManager.list(wrapper));
@@ -122,7 +121,6 @@ public class AttachmentServiceImpl implements AttachmentService {
LambdaQueryWrapper<AttachmentDO> wrapper = Wrappers.<AttachmentDO>query()
.lambda()
.in(AttachmentDO::getId, attachmentIds)
.eq(AttachmentDO::getTenantId, header.getTenantId())
.eq(AttachmentDO::getUserId, header.getUserId());
List<AttachmentDO> attachments = attachmentManager.list(wrapper);
if (attachments.isEmpty()) {
dc3-common/dc3-common-agentic/src/main/java/io/github/pnoker/common/agentic/service/impl/MessageServiceImpl.java
-1
View File
@@ -73,7 +73,6 @@ public class MessageServiceImpl implements MessageService {
LambdaQueryWrapper<MessageDO> wrapper = Wrappers.<MessageDO>query()
.lambda()
.eq(MessageDO::getConversationId, conversationId)
.eq(MessageDO::getTenantId, header.getTenantId())
.eq(MessageDO::getUserId, header.getUserId())
.orderByAsc(MessageDO::getCreateTime)
.orderByAsc(MessageDO::getId);
dc3-common/dc3-common-agentic/src/main/java/io/github/pnoker/common/agentic/service/impl/ModelConfigServiceImpl.java
-1
View File
@@ -200,7 +200,6 @@ public class ModelConfigServiceImpl implements ModelConfigService {
}
modelConfigManager.update(Wrappers.<ModelConfigDO>lambdaUpdate()
.set(ModelConfigDO::getDefaultFlag, DefaultFlagEnum.NOT_DEFAULT.getIndex())
.eq(ModelConfigDO::getTenantId, entityDO.getTenantId())
.eq(ModelConfigDO::getDefaultFlag, DefaultFlagEnum.DEFAULT.getIndex())
.ne(ModelConfigDO::getId, entityDO.getId()));
}
dc3-common/dc3-common-agentic/src/main/java/io/github/pnoker/common/agentic/service/impl/ModelProviderServiceImpl.java
-1
View File
@@ -151,7 +151,6 @@ public class ModelProviderServiceImpl implements ModelProviderService {
}
modelProviderManager.update(Wrappers.<ModelProviderDO>lambdaUpdate()
.set(ModelProviderDO::getDefaultFlag, DefaultFlagEnum.NOT_DEFAULT.getIndex())
.eq(ModelProviderDO::getTenantId, entityDO.getTenantId())
.eq(ModelProviderDO::getDefaultFlag, DefaultFlagEnum.DEFAULT.getIndex())
.ne(ModelProviderDO::getId, entityDO.getId()));
}
dc3-common/dc3-common-agentic/src/main/java/io/github/pnoker/common/agentic/service/impl/SessionServiceImpl.java
-1
View File
@@ -173,7 +173,6 @@ public class SessionServiceImpl implements SessionService {
private LambdaQueryWrapper<SessionDO> fuzzyQuery(SessionQuery query) {
LambdaQueryWrapper<SessionDO> wrapper = Wrappers.<SessionDO>query().lambda();
wrapper.eq(Objects.nonNull(query.getTenantId()), SessionDO::getTenantId, query.getTenantId());
wrapper.eq(FieldUtil.isValidIdField(query.getUserId()), SessionDO::getUserId, query.getUserId());
wrapper.like(StringUtils.isNotEmpty(query.getConversationId()), SessionDO::getConversationId,
query.getConversationId());