admin/vlv-ai-analytic-center
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

处理空指针

Browse Source
This commit is contained in:
jie.lu
2025-07-21 12:06:55 +08:00
parent 3c9cb6a943
commit 633f7308ca
1 changed files with 10 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmOdsImRealtimeMessageCurServiceImpl.java
View File

@@ -140,6 +140,9 @@ public class TmOdsImRealtimeMessageCurServiceImpl extends ServiceImpl<TmOdsImRea
// 组装语料信息 // 组装语料信息
StringBuffer chatList = new StringBuffer(); StringBuffer chatList = new StringBuffer();
contetnList.forEach(contentItem -> { contetnList.forEach(contentItem -> {
if (item.getMsgTimestamp() == null) {
item.setMsgTimestamp(endTime);
}
String title = ""; String title = "";
if(ImCustomTypeEnums.CUSTOMER.getCode().equals(contentItem.getCustomerType())){ if(ImCustomTypeEnums.CUSTOMER.getCode().equals(contentItem.getCustomerType())){
title="客户:"; title="客户:";
@@ -158,7 +161,7 @@ public class TmOdsImRealtimeMessageCurServiceImpl extends ServiceImpl<TmOdsImRea
inputMap.put("chat", chatList.toString()); inputMap.put("chat", chatList.toString());
inputMap.put("businessType", BusinessTypeEnum.IM_CORPUS_ANALYSIS.getCode()); inputMap.put("businessType", BusinessTypeEnum.IM_CORPUS_ANALYSIS.getCode());
inputMap.put("sourceCorpusId", item.getSessionId()); inputMap.put("sourceCorpusId", item.getSessionId());
inputMap.put("sourceCorpusTime", timeStampToLocalDateTime(item.getMsgTimestamp(), formatter)); inputMap.put("sourceCorpusTime", item.getMsgTimestamp() != null ? timeStampToLocalDateTime(item.getMsgTimestamp(), formatter) : null);
DiFyReq diFyImageReq = new DiFyReq(); DiFyReq diFyImageReq = new DiFyReq();
diFyImageReq.setUser(ConstantStr.corpus_user); diFyImageReq.setUser(ConstantStr.corpus_user);
@@ -194,6 +197,9 @@ public class TmOdsImRealtimeMessageCurServiceImpl extends ServiceImpl<TmOdsImRea
* @return * @return
*/ */
private Long stringTimeToTimeStamp(String stringTime, DateTimeFormatter formatter) { private Long stringTimeToTimeStamp(String stringTime, DateTimeFormatter formatter) {
if (StringUtils.isBlank(stringTime)) {
return null;
}
LocalDateTime localDateTime = LocalDateTime.parse(stringTime, formatter); LocalDateTime localDateTime = LocalDateTime.parse(stringTime, formatter);
// 转换为秒级时间戳 // 转换为秒级时间戳
@@ -207,6 +213,9 @@ public class TmOdsImRealtimeMessageCurServiceImpl extends ServiceImpl<TmOdsImRea
* @return * @return
*/ */
private String timeStampToLocalDateTime(Long timeStamp, DateTimeFormatter formatter) { private String timeStampToLocalDateTime(Long timeStamp, DateTimeFormatter formatter) {
if (timeStamp == null) {
return null;
}
Instant instant = Instant.ofEpochSecond(timeStamp); Instant instant = Instant.ofEpochSecond(timeStamp);
LocalDateTime localDateTime = LocalDateTime.ofInstant(instant, ZoneId.systemDefault()); LocalDateTime localDateTime = LocalDateTime.ofInstant(instant, ZoneId.systemDefault());
return localDateTime.format(formatter); return localDateTime.format(formatter);