diff --git a/im-center-api/src/main/java/cn/axzo/im/center/api/feign/ChatUserApi.java b/im-center-api/src/main/java/cn/axzo/im/center/api/feign/ChatUserApi.java new file mode 100644 index 0000000..5a90836 --- /dev/null +++ b/im-center-api/src/main/java/cn/axzo/im/center/api/feign/ChatUserApi.java @@ -0,0 +1,42 @@ +package cn.axzo.im.center.api.feign; + +import cn.axzo.framework.domain.web.result.ApiResult; +import cn.axzo.im.center.api.vo.req.chatuser.BatchCreateChatUserHistoryReq; +import cn.axzo.im.center.api.vo.req.chatuser.CreateChatUserHistoryReq; +import cn.axzo.im.center.api.vo.req.chatuser.QueryChatUserHistoryReq; +import cn.axzo.im.center.api.vo.resp.chatuser.QueryChatUserHistoryResp; +import org.springframework.cloud.openfeign.FeignClient; +import org.springframework.validation.annotation.Validated; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestBody; + +import java.util.List; + +/** + * 私聊 + * + * @author xudawei@axzo.cn + * @date 2024/11/04 + */ +@FeignClient(name = "im-center", url = "${axzo.service.im-center:http://im-center:8080}") +public interface ChatUserApi { + + /** + * 创建聊天用户记录 + */ + @PostMapping("api/im/chat/user/createChatUserHistory") + ApiResult createChatUserHistory(@RequestBody @Validated CreateChatUserHistoryReq req); + + /** + * 批量-创建历史聊天用户 + */ + @PostMapping("api/im/chat/user/batchCreateChatUserHistory") + ApiResult batchCreateChatUserHistory(@RequestBody @Validated BatchCreateChatUserHistoryReq req); + + /** + * 获取聊天用户记录 + */ + @PostMapping("api/im/chat/user/searchChatUserHistory") + ApiResult> searchChatUserHistory(@RequestBody @Validated QueryChatUserHistoryReq req); + +} diff --git a/im-center-api/src/main/java/cn/axzo/im/center/api/vo/req/chatuser/BatchCreateChatUserHistoryReq.java b/im-center-api/src/main/java/cn/axzo/im/center/api/vo/req/chatuser/BatchCreateChatUserHistoryReq.java new file mode 100644 index 0000000..7054307 --- /dev/null +++ b/im-center-api/src/main/java/cn/axzo/im/center/api/vo/req/chatuser/BatchCreateChatUserHistoryReq.java @@ -0,0 +1,25 @@ +package cn.axzo.im.center.api.vo.req.chatuser; + +import lombok.AllArgsConstructor; +import lombok.Builder; +import lombok.Data; +import lombok.NoArgsConstructor; + +import javax.validation.constraints.NotEmpty; +import java.util.List; + +/** + * 创建聊天用户记录 + * @author xudawei + * @date 2024/12/27 + */ +@Data +@Builder +@AllArgsConstructor +@NoArgsConstructor +public class BatchCreateChatUserHistoryReq { + + @NotEmpty(message = "集合不能为空") + private List reqList; + +} diff --git a/im-center-api/src/main/java/cn/axzo/im/center/api/vo/req/chatuser/CreateChatUserHistoryReq.java b/im-center-api/src/main/java/cn/axzo/im/center/api/vo/req/chatuser/CreateChatUserHistoryReq.java new file mode 100644 index 0000000..b9588fd --- /dev/null +++ b/im-center-api/src/main/java/cn/axzo/im/center/api/vo/req/chatuser/CreateChatUserHistoryReq.java @@ -0,0 +1,74 @@ +package cn.axzo.im.center.api.vo.req.chatuser; + +import cn.axzo.im.center.api.vo.req.ComplaintCreateReq; +import cn.axzo.im.center.common.enums.AppTypeEnum; +import cn.axzo.im.center.common.enums.WorkspaceOrOuEnum; +import lombok.AllArgsConstructor; +import lombok.Builder; +import lombok.Data; +import lombok.NoArgsConstructor; + +/** + * 创建聊天用户记录 + * @author xudawei + * @date 2024/12/27 + */ +@Data +@Builder +@AllArgsConstructor +@NoArgsConstructor +public class CreateChatUserHistoryReq { + + /** + * 发送人IM账号 + */ + private String senderImAccount; + + /** + * 发送人PersonId + */ + private Long senderPersonId; + + /** + * 发送人单位Id + */ + private Long senderOuId; + + private AppTypeEnum imSenderAccountAppType; + + /** + * 接收人IM账号 + */ + private String receiverImAccount; + + /** + * 接收人personId + */ + private Long receiverPersonId; + + /** + * 接收人单位Id + */ + private Long receiverOuId; + + /** + * 接收人项目Id + */ + private Long receiverWorkspaceId; + + /** + * 接收人类型，WORKSPACE:项目；OU:单位 + */ + private WorkspaceOrOuEnum receiverType; + + /** + * 类型,PRIVATE:私聊,GROUP:群聊 + */ + private ComplaintCreateReq.ChatTypeEnum chatType; + + /** + * 创建人 + */ + private Long creator; + +} diff --git a/im-center-api/src/main/java/cn/axzo/im/center/api/vo/req/chatuser/QueryChatUserHistoryReq.java b/im-center-api/src/main/java/cn/axzo/im/center/api/vo/req/chatuser/QueryChatUserHistoryReq.java new file mode 100644 index 0000000..61f60a5 --- /dev/null +++ b/im-center-api/src/main/java/cn/axzo/im/center/api/vo/req/chatuser/QueryChatUserHistoryReq.java @@ -0,0 +1,39 @@ +package cn.axzo.im.center.api.vo.req.chatuser; + +import lombok.AllArgsConstructor; +import lombok.Builder; +import lombok.Data; +import lombok.NoArgsConstructor; + +import javax.validation.constraints.NotBlank; + +/** + * 聊天用户历史记录 + * @author xudawei + * @date 2024/12/27 + */ +@Data +@Builder +@AllArgsConstructor +@NoArgsConstructor +public class QueryChatUserHistoryReq { + + /** + * 发送人IM账号 + */ + @NotBlank(message = "发送人IM账号不能为空") + private String senderImAccount; + /** + * 接收人项目Id + */ + private Long receiverWorkspaceId; + /** + * 接收人单位Id + */ + private Long receiverOuId; + + /** + * 接收人Id + */ + private Long receiverPersonId; +} diff --git a/im-center-api/src/main/java/cn/axzo/im/center/api/vo/resp/chatuser/QueryChatUserHistoryResp.java b/im-center-api/src/main/java/cn/axzo/im/center/api/vo/resp/chatuser/QueryChatUserHistoryResp.java new file mode 100644 index 0000000..38dad2a --- /dev/null +++ b/im-center-api/src/main/java/cn/axzo/im/center/api/vo/resp/chatuser/QueryChatUserHistoryResp.java @@ -0,0 +1,56 @@ +package cn.axzo.im.center.api.vo.resp.chatuser; + +import cn.axzo.im.center.api.vo.req.ComplaintCreateReq; +import cn.axzo.im.center.common.enums.WorkspaceOrOuEnum; +import lombok.AllArgsConstructor; +import lombok.Builder; +import lombok.Data; +import lombok.NoArgsConstructor; + +/** + * 聊天用户历史记录 + * @author xudawei + * @date 2024/12/27 + */ +@Data +@Builder +@AllArgsConstructor +@NoArgsConstructor +public class QueryChatUserHistoryResp { + + /** + * 发送人IM账号 + */ + private String senderImAccount; + + /** + * 发送人PersonId + */ + private Long senderPersonId; + + /** + * 发送人单位Id + */ + private Long senderOuId; + + /** + * 接收人personId + */ + private Long receiverPersonId; + + /** + * 接收人单位Id + */ + private Long receiverOuId; + + /** + * 接收人项目Id + */ + private Long receiverWorkspaceId; + + /** + * 类型,PRIVATE:私聊,GROUP:群聊 + */ + private ComplaintCreateReq.ChatTypeEnum chatType; + +} diff --git a/im-center-common/src/main/java/cn/axzo/im/center/common/enums/WorkspaceOrOuEnum.java b/im-center-common/src/main/java/cn/axzo/im/center/common/enums/WorkspaceOrOuEnum.java new file mode 100644 index 0000000..570f962 --- /dev/null +++ b/im-center-common/src/main/java/cn/axzo/im/center/common/enums/WorkspaceOrOuEnum.java @@ -0,0 +1,31 @@ +package cn.axzo.im.center.common.enums; + +import lombok.AccessLevel; +import lombok.AllArgsConstructor; +import lombok.Getter; + + +/** + * 项目或者单位 + * @author xudawei@axzo.cn + * @date 2024/12/30 + */ +@Getter +@AllArgsConstructor(access = AccessLevel.PRIVATE) +public enum WorkspaceOrOuEnum { + + /** + * 项目 + */ + WORKSPACE("workspace", "项目"), + /** + * 单位 + */ + OU("ou", "单位") + ; + + private final String code; + + private final String message; + +} diff --git a/im-center-server/src/main/java/cn/axzo/im/controller/ChatUserController.java b/im-center-server/src/main/java/cn/axzo/im/controller/ChatUserController.java new file mode 100644 index 0000000..b894a4b --- /dev/null +++ b/im-center-server/src/main/java/cn/axzo/im/controller/ChatUserController.java @@ -0,0 +1,58 @@ +package cn.axzo.im.controller; + +import cn.axzo.framework.domain.web.result.ApiResult; +import cn.axzo.im.center.api.feign.ChatUserApi; +import cn.axzo.im.center.api.vo.req.chatuser.BatchCreateChatUserHistoryReq; +import cn.axzo.im.center.api.vo.req.chatuser.CreateChatUserHistoryReq; +import cn.axzo.im.center.api.vo.req.chatuser.QueryChatUserHistoryReq; +import cn.axzo.im.center.api.vo.resp.chatuser.QueryChatUserHistoryResp; +import cn.axzo.im.service.ChatUserHistoryService; +import com.alibaba.fastjson.JSON; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.cloud.context.config.annotation.RefreshScope; +import org.springframework.web.bind.annotation.RestController; + +import java.util.List; + +/** + * 私聊 + * @author xudawei@axzo.cn + * @date 2024/12/27 + */ +@Slf4j +@RestController +@RequiredArgsConstructor +@RefreshScope +public class ChatUserController implements ChatUserApi { + + private final ChatUserHistoryService chatUserHistoryService; + + /** + * 创建历史聊天用户 + */ + @Override + public ApiResult createChatUserHistory(CreateChatUserHistoryReq req) { + chatUserHistoryService.create(req); + return ApiResult.ok(); + } + + /** + * 批量-创建历史聊天用户 + */ + @Override + public ApiResult batchCreateChatUserHistory(BatchCreateChatUserHistoryReq req) { + log.info("batchCreateChatUserHistory,params:{}", JSON.toJSONString(req)); + chatUserHistoryService.batchCreate(req); + return ApiResult.ok(); + } + + /** + * 查询历史聊天用户 + */ + @Override + public ApiResult> searchChatUserHistory(QueryChatUserHistoryReq req) { + List list = chatUserHistoryService.searchChatUserHistory(req, 10); + return ApiResult.ok(list); + } +} diff --git a/im-center-server/src/main/java/cn/axzo/im/dao/mapper/ChatUserHistoryMapper.java b/im-center-server/src/main/java/cn/axzo/im/dao/mapper/ChatUserHistoryMapper.java new file mode 100644 index 0000000..b2fdc7b --- /dev/null +++ b/im-center-server/src/main/java/cn/axzo/im/dao/mapper/ChatUserHistoryMapper.java @@ -0,0 +1,33 @@ +package cn.axzo.im.dao.mapper; + +import cn.axzo.im.center.api.vo.req.chatuser.CreateChatUserHistoryReq; +import cn.axzo.im.entity.ChatUserHistory; +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import org.apache.ibatis.annotations.Param; +import org.apache.ibatis.annotations.Select; + +import java.util.List; + +/** + * @author xudawei@axzo.cn + * @date 2024/11/05 + * @desc 历史聊天用户 + */ +public interface ChatUserHistoryMapper extends BaseMapper { + + + @Select("") + List findBySenderReceiver( + @Param("reqList") List reqList); + +} diff --git a/im-center-server/src/main/java/cn/axzo/im/dao/repository/ChatUserHistoryDao.java b/im-center-server/src/main/java/cn/axzo/im/dao/repository/ChatUserHistoryDao.java new file mode 100644 index 0000000..fb415a2 --- /dev/null +++ b/im-center-server/src/main/java/cn/axzo/im/dao/repository/ChatUserHistoryDao.java @@ -0,0 +1,24 @@ +package cn.axzo.im.dao.repository; + +import cn.axzo.im.dao.mapper.ChatUserHistoryMapper; +import cn.axzo.im.dao.mapper.MessageHistoryMapper; +import cn.axzo.im.entity.ChatUserHistory; +import cn.axzo.im.entity.MessageHistory; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import org.apache.commons.collections4.CollectionUtils; +import org.springframework.stereotype.Repository; + +import java.util.Collections; +import java.util.List; + +/** + * im-center + * + * @author xudawei@axzo.cn + * @date 2025/01/08 + */ + +@Repository("chatUserHistoryDao") +public class ChatUserHistoryDao extends ServiceImpl { + +} diff --git a/im-center-server/src/main/java/cn/axzo/im/entity/ChatUserHistory.java b/im-center-server/src/main/java/cn/axzo/im/entity/ChatUserHistory.java new file mode 100644 index 0000000..f4d77fd --- /dev/null +++ b/im-center-server/src/main/java/cn/axzo/im/entity/ChatUserHistory.java @@ -0,0 +1,123 @@ +package cn.axzo.im.entity; + +import cn.axzo.im.center.api.vo.req.ComplaintCreateReq; +import cn.axzo.im.center.api.vo.req.chatuser.CreateChatUserHistoryReq; +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; +import lombok.experimental.Accessors; +import lombok.experimental.SuperBuilder; + +import java.io.Serializable; +import java.util.Date; + +/** + * 历史聊天用户 + * @author xudawei@axzo.cn + * @date 2024/12/27 + */ +@TableName("im_chat_user_history") +@Data +@SuperBuilder +@Accessors(chain = true) +@NoArgsConstructor +@AllArgsConstructor +public class ChatUserHistory implements Serializable { + + private static final long serialVersionUID = 1L; + + @TableId(type = IdType.AUTO) + private Long id; + + /** + * 发送人IM账号 + */ + @TableField("sender_im_account") + private String senderImAccount; + + /** + * 发送人PersonId + */ + @TableField("sender_person_id") + private Long senderPersonId; + + /** + * 发送人单位Id + */ + @TableField("sender_ou_id") + private Long senderOuId; + + /** + * 接收人personId + */ + @TableField("receiver_person_id") + private Long receiverPersonId; + + /** + * 接收人单位Id + */ + @TableField("receiver_ou_id") + private Long receiverOuId; + + /** + * 接收人项目Id + */ + @TableField("receiver_workspace_id") + private Long receiverWorkspaceId; + + /** + * 类型,PRIVATE:私聊,GROUP:群聊 + */ + @TableField("chat_type") + private ComplaintCreateReq.ChatTypeEnum chatType; + + /** + * 备注 + */ + @TableField("remark") + private String remark; + + /** + * 创建人 + */ + @TableField("creator") + private Long creator; + + /** + * 是否删除 + */ + @TableField("is_delete") + private Long isDelete; + + /** + * 创建时间 + */ + @TableField("create_at") + private Date createAt; + + /** + * 更新时间 + */ + @TableField("update_at") + private Date updateAt; + + /** + * 创建对象 + */ + public static ChatUserHistory create(CreateChatUserHistoryReq req) { + return ChatUserHistory.builder() + .senderImAccount(req.getSenderImAccount()) + .senderPersonId(req.getSenderPersonId()) + .senderOuId(req.getSenderOuId()) + .receiverPersonId(req.getReceiverPersonId()) + .receiverOuId(req.getReceiverOuId()) + .receiverWorkspaceId(req.getReceiverWorkspaceId()) + .chatType(req.getChatType()) + .creator(req.getCreator()) + .isDelete(0L).build(); + } +} \ No newline at end of file diff --git a/im-center-server/src/main/java/cn/axzo/im/event/payload/SaasRoleUserRelation.java b/im-center-server/src/main/java/cn/axzo/im/event/payload/SaasRoleUserRelation.java new file mode 100644 index 0000000..54d7d5a --- /dev/null +++ b/im-center-server/src/main/java/cn/axzo/im/event/payload/SaasRoleUserRelation.java @@ -0,0 +1,90 @@ +package cn.axzo.im.event.payload; + +import cn.axzo.basics.profiles.common.enums.IdentityType; +import cn.axzo.tyr.client.model.enums.SaasJobTypeEnum; +import lombok.AllArgsConstructor; +import lombok.Builder; +import lombok.Data; +import lombok.NoArgsConstructor; + +import java.io.Serializable; +import java.util.Date; + +@Data +@AllArgsConstructor +@NoArgsConstructor +@Builder +public class SaasRoleUserRelation implements Serializable { + + /** + * 身份Id + */ + private Long identityId; + /** + * 身份类型 1:工人 2:从业人员 3:班组长 4:运营人员 5:政务人员 + */ + private IdentityType identityType; + /** + * 角色Id + */ + private Long roleId; + /** + * 自然人Id + */ + private Long naturalPersonId; + /** + * 创建者 + */ + private Long createBy; + /** + * 更新者 + */ + private Long updateBy; + + /** + * 所属单位Id 用户在当前工作台的所属单位 + */ + private Long ouId; + + /** + * 工作台Id + */ + private Long workspaceId; + + /** + * 资源类型 + */ + private Integer resourceType; + + /** + * 资源Id + */ + private Long resourceId; + + /** + * 岗位类型 1:主岗 2:兼岗 + * 一个人在一个工作台内，除非 特殊的角色(超管,无权限角色等)必定有且只有一个主岗，可以有N个兼岗 + */ + private SaasJobTypeEnum jobType; + + /** + * id + */ + private Long id; + + /** + * 创建时间 + */ + private Date createAt; + + /** + * 修改时间 + */ + private Date updateAt; + + /** + * 是否删除 0正常，1删除 + */ + private Long isDelete = 0L; + +} diff --git a/im-center-server/src/main/java/cn/axzo/im/event/payload/SaasRoleUserRelationRemovePayload.java b/im-center-server/src/main/java/cn/axzo/im/event/payload/SaasRoleUserRelationRemovePayload.java index 9b53f02..617126b 100644 --- a/im-center-server/src/main/java/cn/axzo/im/event/payload/SaasRoleUserRelationRemovePayload.java +++ b/im-center-server/src/main/java/cn/axzo/im/event/payload/SaasRoleUserRelationRemovePayload.java @@ -1,6 +1,5 @@ package cn.axzo.im.event.payload; -import cn.axzo.basics.auth.dto.SaasRoleUserRelation; import lombok.AllArgsConstructor; import lombok.Builder; import lombok.Data; diff --git a/im-center-server/src/main/java/cn/axzo/im/event/payload/SaasRoleUserRelationUpsertPayload.java b/im-center-server/src/main/java/cn/axzo/im/event/payload/SaasRoleUserRelationUpsertPayload.java index 1b099f5..fb05f4a 100644 --- a/im-center-server/src/main/java/cn/axzo/im/event/payload/SaasRoleUserRelationUpsertPayload.java +++ b/im-center-server/src/main/java/cn/axzo/im/event/payload/SaasRoleUserRelationUpsertPayload.java @@ -1,6 +1,5 @@ package cn.axzo.im.event.payload; -import cn.axzo.basics.auth.dto.SaasRoleUserRelation; import cn.axzo.tyr.client.model.roleuser.dto.SaasRoleUserV2DTO; import lombok.AllArgsConstructor; import lombok.Builder; diff --git a/im-center-server/src/main/java/cn/axzo/im/handler/chatgroup/ChatGroupChangeOwnerEventHandler.java b/im-center-server/src/main/java/cn/axzo/im/handler/chatgroup/ChatGroupChangeOwnerEventHandler.java index 8a2f68c..692cc74 100644 --- a/im-center-server/src/main/java/cn/axzo/im/handler/chatgroup/ChatGroupChangeOwnerEventHandler.java +++ b/im-center-server/src/main/java/cn/axzo/im/handler/chatgroup/ChatGroupChangeOwnerEventHandler.java @@ -1,6 +1,5 @@ package cn.axzo.im.handler.chatgroup; -import cn.axzo.basics.auth.dto.SaasRoleUserRelation; import cn.axzo.basics.common.exception.ServiceException; import cn.axzo.framework.rocketmq.Event; import cn.axzo.framework.rocketmq.EventConsumer; @@ -11,6 +10,7 @@ import cn.axzo.im.center.common.enums.AppTypeEnum; import cn.axzo.im.center.common.enums.ChatGroupUserDataSourceEnum; import cn.axzo.im.entity.ChatGroup; import cn.axzo.im.event.inner.EventTypeEnum; +import cn.axzo.im.event.payload.SaasRoleUserRelation; import cn.axzo.im.event.payload.SaasRoleUserRelationUpsertPayload; import cn.axzo.im.gateway.TyrApiGateway; import cn.axzo.im.service.ChatGroupService; diff --git a/im-center-server/src/main/java/cn/axzo/im/service/ChatUserHistoryService.java b/im-center-server/src/main/java/cn/axzo/im/service/ChatUserHistoryService.java new file mode 100644 index 0000000..2f12a5a --- /dev/null +++ b/im-center-server/src/main/java/cn/axzo/im/service/ChatUserHistoryService.java @@ -0,0 +1,33 @@ +package cn.axzo.im.service; + +import cn.axzo.im.center.api.vo.req.chatuser.BatchCreateChatUserHistoryReq; +import cn.axzo.im.center.api.vo.req.chatuser.CreateChatUserHistoryReq; +import cn.axzo.im.center.api.vo.req.chatuser.QueryChatUserHistoryReq; +import cn.axzo.im.center.api.vo.resp.chatuser.QueryChatUserHistoryResp; +import cn.axzo.im.entity.ChatUserHistory; +import com.baomidou.mybatisplus.extension.service.IService; + +import java.util.List; + +/** + * @author xudawei@axzo.cn + * @date 2024/12/27 + * @desc 历史聊天用户 + */ +public interface ChatUserHistoryService extends IService { + + /** + * 创建历史聊天用户 + */ + Boolean create(CreateChatUserHistoryReq req); + + /** + * 批量创建历史聊天用户 + */ + Boolean batchCreate(BatchCreateChatUserHistoryReq req); + + /** + * 查询历史聊天用户 + */ + List searchChatUserHistory(QueryChatUserHistoryReq req, int limitSize); +} diff --git a/im-center-server/src/main/java/cn/axzo/im/service/impl/ChatUserHistoryServiceImpl.java b/im-center-server/src/main/java/cn/axzo/im/service/impl/ChatUserHistoryServiceImpl.java new file mode 100644 index 0000000..fe307fb --- /dev/null +++ b/im-center-server/src/main/java/cn/axzo/im/service/impl/ChatUserHistoryServiceImpl.java @@ -0,0 +1,169 @@ +package cn.axzo.im.service.impl; + +import cn.axzo.im.center.api.vo.req.AccountAbsentQuery; +import cn.axzo.im.center.api.vo.req.chatuser.BatchCreateChatUserHistoryReq; +import cn.axzo.im.center.api.vo.req.chatuser.CreateChatUserHistoryReq; +import cn.axzo.im.center.api.vo.req.chatuser.QueryChatUserHistoryReq; +import cn.axzo.im.center.api.vo.resp.UserAccountResp; +import cn.axzo.im.center.api.vo.resp.chatuser.QueryChatUserHistoryResp; +import cn.axzo.im.dao.mapper.ChatUserHistoryMapper; +import cn.axzo.im.dao.repository.ChatUserHistoryDao; +import cn.axzo.im.entity.ChatUserHistory; +import cn.axzo.im.service.AccountService; +import cn.axzo.im.service.ChatUserHistoryService; +import cn.hutool.core.bean.BeanUtil; +import com.alibaba.fastjson.JSON; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.apache.commons.collections.CollectionUtils; +import org.apache.commons.compress.utils.Lists; +import org.springframework.cloud.context.config.annotation.RefreshScope; +import org.springframework.stereotype.Service; +import org.springframework.util.StringUtils; + +import java.util.Date; +import java.util.List; +import java.util.Map; +import java.util.Objects; +import java.util.stream.Collectors; + +/** + * @author xudawei@axzo.cn + * @date 2024/11/05 + * @desc 历史聊天用户 + */ +@Slf4j +@Service +@RefreshScope +@RequiredArgsConstructor +public class ChatUserHistoryServiceImpl extends ServiceImpl + implements ChatUserHistoryService { + + private final ChatUserHistoryDao chatUserHistoryDao; + + private final AccountService accountService; + + /** + * 创建历史聊天用户 + */ + @Override + public Boolean create(CreateChatUserHistoryReq req) { + return this.saveOrUpdate(ChatUserHistory.create(req)); + } + + + + /** + * 批量创建历史聊天用户 + */ + @Override + public Boolean batchCreate(BatchCreateChatUserHistoryReq req) { + if (CollectionUtils.isEmpty(req.getReqList())) { + return false; + } + + List historyList = this.buildHistory(req); + log.info("batchCreate-historyList:{}", JSON.toJSONString(historyList)); + try { + return this.saveOrUpdateBatch(historyList); + } catch (Exception e) { + log.warn("batchCreateChatUserHistory-expcetion,req:{}", JSON.toJSONString(req), e); + } + return false; + } + + /** + * 构建历史聊天用户 + */ + private List buildHistory(BatchCreateChatUserHistoryReq req) { + // 非空校验 + if (Objects.isNull(req) || CollectionUtils.isEmpty(req.getReqList())) { + return Lists.newArrayList(); + } + //根据Req构建entity对象 + List historyList = req.getReqList().stream() + .map(item -> { + //im账号为空则重新设置Im账号 + this.rechangeSenderImAccount(item); + //创建历史聊天对象 + return ChatUserHistory.create(item); + }) + .collect(Collectors.toList()); + //从db中获取历史聊天用户 + List bySenderReceiver = chatUserHistoryDao.getBaseMapper().findBySenderReceiver(req.getReqList()); + if (CollectionUtils.isEmpty(bySenderReceiver)) { + return historyList; + } + + //db已经有聊天用户记录的则，重新设置id，更新时间 + //db没有聊天用户记录的则，插入记录 + Map imAccountMap = bySenderReceiver.stream() + .collect(Collectors.toMap((this::buildChatHistoryKey), (v -> v.getId()), (x, y) -> x)); + for (ChatUserHistory history : historyList) { + Long id = imAccountMap.get(this.buildChatHistoryKey(history)); + if (Objects.nonNull(id)) { + history.setId(id); + history.setUpdateAt(new Date()); + } + } + return historyList; + } + + /** + * 重新设置IM账号 + */ + private void rechangeSenderImAccount(CreateChatUserHistoryReq req) { + if (!StringUtils.hasText(req.getSenderImAccount())) { + String senderImAccount = this.registerAccountIfAbsent(req.getImSenderAccountAppType().getCode(), req.getSenderPersonId(), req.getSenderOuId()); + req.setSenderImAccount(senderImAccount); + } + } + + /** + * 注册IM账号(支持幂等性) + */ + private String registerAccountIfAbsent(String appType, Long personId, Long ouId) { + AccountAbsentQuery query = new AccountAbsentQuery(); + query.setAppType(appType); + query.setPersonId(personId.toString()); + query.setOuId(ouId); + //1 注册IM账号 + List userAccountResps = accountService.registerAccountIfAbsent(query); + if (org.apache.commons.collections4.CollectionUtils.isNotEmpty(userAccountResps)) { + return userAccountResps.get(0).getImAccount(); + } + return ""; + } + + /** + * 构建Key + */ + private String buildChatHistoryKey(ChatUserHistory history) { + if (Objects.isNull(history)) { + return ""; + } + StringBuilder builder = new StringBuilder(); + builder.append(StringUtils.hasText(history.getSenderImAccount()) ? history.getSenderImAccount() : "-") + .append(Objects.nonNull(history.getReceiverPersonId()) ? history.getReceiverPersonId() : "-") + .append(Objects.nonNull(history.getReceiverOuId()) ? history.getReceiverOuId() : "-") + .append(Objects.nonNull(history.getReceiverWorkspaceId()) ? history.getReceiverWorkspaceId() : "-"); + return builder.toString(); + } + + /** + * 查询历史聊天用户 + */ + @Override + public List searchChatUserHistory(QueryChatUserHistoryReq req, int limitSize) { + List list = this.lambdaQuery() + .eq(StringUtils.hasText(req.getSenderImAccount()), ChatUserHistory::getSenderImAccount, req.getSenderImAccount()) + .eq(Objects.nonNull(req.getReceiverOuId()), ChatUserHistory::getReceiverOuId, req.getReceiverOuId()) + .eq(Objects.nonNull(req.getReceiverWorkspaceId()), ChatUserHistory::getReceiverWorkspaceId, req.getReceiverWorkspaceId()) + .eq(Objects.nonNull(req.getReceiverPersonId()), ChatUserHistory::getReceiverPersonId, req.getReceiverPersonId()) + .orderByDesc(ChatUserHistory::getUpdateAt) + .last(" limit " + limitSize) + .list(); + return BeanUtil.copyToList(list, QueryChatUserHistoryResp.class); + } +}