diff --git a/src/main/java/cn/org/bjca/trust/java/imserver/entitys/Conversation.java b/src/main/java/cn/org/bjca/trust/java/imserver/entitys/Conversation.java index d0b9087..f3e1ea3 100644 --- a/src/main/java/cn/org/bjca/trust/java/imserver/entitys/Conversation.java +++ b/src/main/java/cn/org/bjca/trust/java/imserver/entitys/Conversation.java @@ -24,4 +24,7 @@ public class Conversation extends AbstractBaseTimeEntity { @OneToOne @JoinColumn private UserInfo userInfo; + @OneToOne + @JoinColumn + private UserInfo self; } diff --git a/src/main/java/cn/org/bjca/trust/java/imserver/im/ImManager.java b/src/main/java/cn/org/bjca/trust/java/imserver/im/ImManager.java index 652c0ea..0787496 100644 --- a/src/main/java/cn/org/bjca/trust/java/imserver/im/ImManager.java +++ b/src/main/java/cn/org/bjca/trust/java/imserver/im/ImManager.java @@ -124,6 +124,7 @@ public class ImManager { conversation.setGroup(szyxMessage.isGroup()); conversation.setSender(!szyxMessage.isArrive()); conversation.setMessage(szyxMessage); + conversation.setSelf(userRepository.findFirstByUserIdAndOsTypeAndAppId(szyxMessage.getUserName(), szyxMessage.getOsType(), szyxMessage.getAppId())); if (szyxMessage.isGroup()) { conversation.setGroupEntity(groupRepository.findFirstByAppIdAndGroupId(szyxMessage.getAppId(), szyxMessage.getGroupID())); } else {