slhaf/Partner
1
0
Fork 0
mirror of https://github.com/slhaf/Partner.git synced 2026-05-12 08:43:02 +08:00
Code Issues Packages Projects Releases Wiki Activity

refactor(perceive): remove legacy user storage in perceive core

Browse Source
This commit is contained in:
slhafzjw
2026-03-19 23:14:20 +08:00
parent e0b20ce414
commit ccb7041093
1 changed files with 0 additions and 68 deletions
Download Patch File Download Diff File Expand all files Collapse all files

68
Partner-Core/src/main/java/work/slhaf/partner/core/perceive/PerceiveCore.java
View File

@@ -6,18 +6,12 @@ import lombok.Setter;
import work.slhaf.partner.api.agent.factory.capability.annotation.CapabilityCore;
import work.slhaf.partner.api.agent.factory.capability.annotation.CapabilityMethod;
import work.slhaf.partner.core.PartnerCore;
import work.slhaf.partner.core.cognation.exception.UserNotExistsException;
import work.slhaf.partner.core.perceive.pojo.User;
import java.io.IOException;
import java.io.Serial;
import java.time.Instant;
import java.time.ZoneId;
import java.time.format.DateTimeFormatter;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.UUID;
import java.util.concurrent.locks.ReentrantLock;
@EqualsAndHashCode(callSuper = true)
@@ -32,71 +26,9 @@ public class PerceiveCore extends PartnerCore<PerceiveCore> {
private Instant lastInteractTime;
/**
* 用户列表
*/
private List<User> users = new ArrayList<>();
public PerceiveCore() throws IOException, ClassNotFoundException {
}
@CapabilityMethod
public User getUser(String userInfo, String platform) {
User resultUser = null;
usersLock.lock();
for (User user : users) {
HashMap<String, String> info = user.getInfo();
if (info.containsKey(platform)) {
if (info.get(platform).equals(userInfo)) {
resultUser = user;
}
}
}
usersLock.unlock();
return resultUser;
}
@CapabilityMethod
public User addUser(String userInfo, String platform, String userNickName) {
User user = new User();
user.addInfo(platform, userInfo);
user.setNickName(userNickName);
user.setUuid(UUID.randomUUID().toString());
usersLock.lock();
users.add(user);
usersLock.unlock();
return user;
}
@CapabilityMethod
public User getUser(String id) {
usersLock.lock();
User resultUser = null;
for (User user : users) {
if (user.getUuid().equals(id)) {
resultUser = user;
}
}
usersLock.unlock();
if (resultUser == null) {
throw new UserNotExistsException("[PerceiveCore] 用户不存在: " + id);
}
return resultUser;
}
@CapabilityMethod
public void updateUser(User temp) {
usersLock.lock();
User user = getUser(temp.getUuid());
user.setRelation(temp.getRelation());
user.setImpressions(temp.getImpressions());
user.setAttitude(temp.getAttitude());
user.setStaticMemory(temp.getStaticMemory());
user.updateRelationChange(user.getRelationChange());
usersLock.unlock();
}
@CapabilityMethod
public String refreshInteract() {
String last = lastInteractTime.atZone(ZoneId.systemDefault()).format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));