wangli/im-center
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

REQ-3201: 定义entity

Browse Source
This commit is contained in:
yanglin 2024-12-10 10:25:25 +08:00
parent e8b1779c30
commit f7ec87b869
3 changed files with 27 additions and 37 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
im-center-server/src/main/java/cn/axzo/im/channel/netease/dto/MessageCustomBody.java
View File

@ -1,7 +1,6 @@
package cn.axzo.im.channel.netease.dto;
import cn.axzo.im.center.common.enums.BizTypeEnum;
import cn.axzo.im.center.common.enums.TemplatedMsgType;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
@ -37,29 +36,4 @@ public class MessageCustomBody {
*/
private String payload;
/**
* 业务消息id, 用于接口拉取最新消息内容
*/
private String bizMessageId;
/**
* 数据版本
*/
private Long dataVersion;
/**
* 最原始的网易云信消息id, 更新的哪条消息
*/
private String initMessageId;
/**
* 更新的消息类型
*/
private TemplatedMsgType msgType;
/**
* 端信息
*/
private Peer peer;
}

17
im-center-server/src/main/java/cn/axzo/im/updatable/UpdateSupport.java
View File

@ -4,10 +4,8 @@ import cn.axzo.im.center.api.feign.SendPriority;
import cn.axzo.im.center.api.vo.ApiChannel;
import cn.axzo.im.center.api.vo.req.MessageUpdateInfo;
import cn.axzo.im.center.common.enums.BizTypeEnum;
import cn.axzo.im.center.common.enums.YesOrNo;
import cn.axzo.im.channel.IMChannelProvider;
import cn.axzo.im.channel.netease.dto.MessageCustomBody;
import cn.axzo.im.channel.netease.dto.Peer;
import cn.axzo.im.dao.repository.UpdatableMessageDao;
import cn.axzo.im.entity.HistoryRecordExt;
import cn.axzo.im.entity.MessageHistory;
@ -17,6 +15,7 @@ import cn.axzo.im.enums.MessageHistoryStatus;
import cn.axzo.im.enums.UpdatableMessageState;
import cn.axzo.im.updatable.collector.CardManipulateCollector;
import cn.axzo.im.updatable.collector.CardManipulateCollectorFactory;
import cn.axzo.im.updatable.domain.MessageUpdateBody;
import cn.axzo.im.utils.UUIDUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
@ -72,16 +71,12 @@ public class UpdateSupport {
messageBody.setToImAccount(message.getToAccount());
messageBody.setPersonId(message.getReceiverPersonId());
messageBody.setBizType(BizTypeEnum.MESSAGE_UPDATE);
messageBody.setPayload("{}");
messageBody.setBizMessageId(message.bizMessageId());
messageBody.setDataVersion(messageUpdate.getDataVersion());
messageBody.setInitMessageId(message.getNimMessageId());
messageBody.setMsgType(message.getMsgType());
messageBody.setPeer(new Peer());
messageBody.getPeer().setSenderRobot(message.getIsSenderRobot() == YesOrNo.YES);
messageBody.getPeer().setSenderPersonId(message.senderPersonIdAsLong());
messageBody.getPeer().setReceiverPersonId(message.receiverPersonIdAsLong());
MessageUpdateBody imBody = new MessageUpdateBody();
imBody.setBizMessageId(message.bizMessageId());
imBody.setDataVersion(messageUpdate.getDataVersion());
imBody.setInitMessageId(message.getNimMessageId());
messageBody.setPayload(JSON.toJSONString(imBody));
history.setMessageBody(JSON.toJSONString(messageBody));
messageUpdate.setBizBody(setDataVersion(update.bizBody(), message));

21
im-center-server/src/main/java/cn/axzo/im/updatable/domain/MessageUpdateBody.java Normal file
View File

@ -0,0 +1,21 @@
package cn.axzo.im.updatable.domain;
import com.alibaba.fastjson.JSON;
import lombok.Getter;
import lombok.Setter;
/**
* @author yanglin
*/
@Setter
@Getter
public class MessageUpdateBody {
private String bizMessageId;
private Long dataVersion;
private String initMessageId;
@Override
public String toString() {
return JSON.toJSONString(this);
}
}