fix: 修复工单消息的一些问题
This commit is contained in:
parent
0607c578e0
commit
ee02a03772
|
|
@ -1,6 +1,7 @@
|
||||||
package com.nflg.mobilebroken.admin.controller;
|
package com.nflg.mobilebroken.admin.controller;
|
||||||
|
|
||||||
import cn.hutool.core.collection.CollectionUtil;
|
import cn.hutool.core.collection.CollectionUtil;
|
||||||
|
import cn.hutool.core.date.DatePattern;
|
||||||
import cn.hutool.core.util.StrUtil;
|
import cn.hutool.core.util.StrUtil;
|
||||||
import com.itextpdf.html2pdf.ConverterProperties;
|
import com.itextpdf.html2pdf.ConverterProperties;
|
||||||
import com.itextpdf.html2pdf.HtmlConverter;
|
import com.itextpdf.html2pdf.HtmlConverter;
|
||||||
|
|
@ -38,6 +39,8 @@ import java.io.IOException;
|
||||||
import java.net.URLEncoder;
|
import java.net.URLEncoder;
|
||||||
import java.nio.charset.StandardCharsets;
|
import java.nio.charset.StandardCharsets;
|
||||||
import java.time.Instant;
|
import java.time.Instant;
|
||||||
|
import java.time.ZoneId;
|
||||||
|
import java.time.format.DateTimeFormatter;
|
||||||
import java.util.*;
|
import java.util.*;
|
||||||
import java.util.stream.Collectors;
|
import java.util.stream.Collectors;
|
||||||
|
|
||||||
|
|
@ -390,16 +393,35 @@ public class TicketController extends ControllerBase {
|
||||||
.setAttachments(request.getAttachments())
|
.setAttachments(request.getAttachments())
|
||||||
.setImages(request.getImages())
|
.setImages(request.getImages())
|
||||||
.setQuote(request.getQuote());
|
.setQuote(request.getQuote());
|
||||||
// ticketChatService.pushMessage(request.getTicketId(),message);
|
|
||||||
// TicketChat chat=ticketChatService.findByTicketId(request.getTicketId());
|
|
||||||
// chat.getMessages().add(message);
|
|
||||||
// ticketChatService.save(chat);
|
|
||||||
ticketChatService.addMessage(request.getTicketId(), message);
|
ticketChatService.addMessage(request.getTicketId(), message);
|
||||||
//推送消息
|
//推送消息
|
||||||
try {
|
try {
|
||||||
|
String zone = MultilingualUtil.getZone();
|
||||||
|
ZoneId zoneId = ZoneId.of(Objects.isNull(zone) ? "Asia/Shanghai" : zone);
|
||||||
|
DateTimeFormatter formatter = DateTimeFormatter.ofPattern(DatePattern.NORM_DATETIME_PATTERN).withZone(zoneId);
|
||||||
|
ChatMessageVO messageVO = new ChatMessageVO()
|
||||||
|
.setId(message.getId())
|
||||||
|
.setFrom(message.getFrom())
|
||||||
|
.setSenderId(message.getSenderId())
|
||||||
|
.setSenderName(message.getSenderName())
|
||||||
|
.setSenderAvatar(message.getSenderAvatar())
|
||||||
|
.setContent(message.getContent())
|
||||||
|
.setCreateTime(formatter.format(message.getCreateTime()))
|
||||||
|
.setImages(message.getImages())
|
||||||
|
.setAttachments(message.getAttachments())
|
||||||
|
.setQuote(Objects.isNull(message.getQuote()) ? null : new ChatMessageVO()
|
||||||
|
.setId(message.getQuote().getId())
|
||||||
|
.setFrom(message.getQuote().getFrom())
|
||||||
|
.setSenderId(message.getQuote().getSenderId())
|
||||||
|
.setSenderName(message.getQuote().getSenderName())
|
||||||
|
.setSenderAvatar(message.getQuote().getSenderAvatar())
|
||||||
|
.setContent(message.getQuote().getContent())
|
||||||
|
.setAttachments(message.getQuote().getAttachments())
|
||||||
|
.setImages(message.getQuote().getImages())
|
||||||
|
.setCreateTime(formatter.format(message.getQuote().getCreateTime())));
|
||||||
SSEMessageDTO messageDTO = new SSEMessageDTO()
|
SSEMessageDTO messageDTO = new SSEMessageDTO()
|
||||||
.setType(1)
|
.setType(1)
|
||||||
.setData(message);
|
.setData(messageVO);
|
||||||
sseManagerService.send(ticket.getUserId(), messageDTO);
|
sseManagerService.send(ticket.getUserId(), messageDTO);
|
||||||
} catch (IOException e) {
|
} catch (IOException e) {
|
||||||
log.error("发送SSE消息出错", e);
|
log.error("发送SSE消息出错", e);
|
||||||
|
|
|
||||||
|
|
@ -50,15 +50,16 @@ public class TicketChatService {
|
||||||
.setImages(m.getImages())
|
.setImages(m.getImages())
|
||||||
.setCreateTime(formatter.format(m.getCreateTime()))
|
.setCreateTime(formatter.format(m.getCreateTime()))
|
||||||
.setQuote(Objects.isNull(m.getQuote()) ? null : new ChatMessageVO()
|
.setQuote(Objects.isNull(m.getQuote()) ? null : new ChatMessageVO()
|
||||||
.setId(m.getId())
|
.setId(m.getQuote().getId())
|
||||||
.setFrom(m.getFrom())
|
.setFrom(m.getQuote().getFrom())
|
||||||
.setSenderId(m.getSenderId())
|
.setSenderId(m.getQuote().getSenderId())
|
||||||
.setSenderName(m.getSenderName())
|
.setSenderName(m.getQuote().getSenderName())
|
||||||
.setSenderAvatar(m.getSenderAvatar())
|
.setSenderAvatar(m.getQuote().getSenderAvatar())
|
||||||
.setContent(m.getContent())
|
.setContent(m.getQuote().getContent())
|
||||||
.setAttachments(m.getAttachments())
|
.setAttachments(m.getQuote().getAttachments())
|
||||||
.setImages(m.getImages()))
|
.setImages(m.getQuote().getImages())
|
||||||
.setCreateTime(formatter.format(m.getCreateTime())))
|
.setCreateTime(formatter.format(m.getQuote().getCreateTime())))
|
||||||
|
)
|
||||||
.collect(Collectors.toList());
|
.collect(Collectors.toList());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue