moliparty/peko-java
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

线程池-云信发批量房间消息-发消息前生成msgId

Browse Source
This commit is contained in:
khalil
2025-05-08 11:24:04 +08:00
parent 1394c86730
commit 3d11f6f792
2 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
accompany-base/accompany-core/src/main/java/com/accompany/common/netease/neteaseacc/dto/BaseChatRoomMsg.java
View File

@@ -8,7 +8,7 @@ import lombok.Data;
@Data
public class BaseChatRoomMsg {
private String msgId;
//private String msgId;
/**
* 0: 文本消息，1: 图片，2: 语音，3: 视频，4: 地理位置信息，6: 文件，10: 提示消息（Tips），100: 自定义消息
*/

11
accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/SendSysMsgService.java
View File

@@ -550,7 +550,8 @@ public class SendSysMsgService extends BaseService {
public void sendSingleRoomMessage(Room room, BaseChatRoomMsg msg) {
try {
this.erBanNetEaseService.sendChatRoomMsg(room.getRoomId(), msg.getMsgId(), room.getUid().toString(),
String msgId = UUIDUtil.get();
this.erBanNetEaseService.sendChatRoomMsg(room.getRoomId(), msgId, room.getUid().toString(),
msg.getMsgType(), msg.getAttach(), msg.getExt());
} catch (Exception e) {
log.error("发送房间消息失败[roomId : {}, fromAccId : {}, message : {}]",
@@ -606,8 +607,8 @@ public class SendSysMsgService extends BaseService {
asyncExecutor.execute(() -> {
for (Room room : vaildRoomList) {
try {
msg.setMsgId(UUIDUtil.get());
this.erBanNetEaseService.sendChatRoomMsg(room.getRoomId(), msg.getMsgId(), room.getUid().toString(),
String msgId = UUIDUtil.get();
this.erBanNetEaseService.sendChatRoomMsg(room.getRoomId(), msgId, room.getUid().toString(),
msg.getMsgType(), msg.getAttach(), msg.getExt());
} catch (Exception e) {
log.error("批量发送房间消息失败[room={}, message={}]", JSON.toJSONString(room), msg, e);
@@ -629,8 +630,8 @@ public class SendSysMsgService extends BaseService {
asyncExecutor.execute(() -> {
for (Room room : vaildRoomList) {
try {
msg.setMsgId(UUIDUtil.get());
this.erBanNetEaseService.sendChatRoomMsg(room.getRoomId(), msg.getMsgId(), room.getUid().toString(),
String msgId = UUIDUtil.get();
this.erBanNetEaseService.sendChatRoomMsg(room.getRoomId(), msgId, room.getUid().toString(),
msg.getMsgType(), msg.getAttach(), msg.getExt());
} catch (Exception e) {
log.error("批量发送房间消息失败[room={}, message={}]", JSON.toJSONString(room), msg, e);