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:
zren25
2025-05-19 14:06:57 +08:00
parent ad8f517ff9
commit 1557279250
5 changed files with 142 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mapper/TtAnalysisResultInfoMapper.java Normal file
View File

@@ -0,0 +1,16 @@
package com.volvo.ai.analytic.center.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.volvo.ai.analytic.center.entity.TtAnalysisResultInfo;
import org.apache.ibatis.annotations.Mapper;
/**
* @description Ai分析结果明细表
* @author BEJSON
* @date 2025-03-04
*/
@Mapper
public interface TtAnalysisResultInfoMapper extends BaseMapper<TtAnalysisResultInfo> {
}

21
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpushIsLikeConsumer.java
View File

@@ -2,7 +2,10 @@ package com.volvo.ai.analytic.center.mq;
import com.alibaba.fastjson.JSONObject;
import com.volvo.ai.analytic.center.entity.TmAnalysisResult;
import com.volvo.ai.analytic.center.entity.TtAnalysisResultInfo;
import com.volvo.ai.analytic.center.enums.BusinessTypeEnum;
import com.volvo.ai.analytic.center.mapper.AiAnalysisRequestLogsMapper;
import com.volvo.ai.analytic.center.mapper.TtAnalysisResultInfoMapper;
import com.volvo.ai.analytic.center.service.TmAnalysisResultService;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
@@ -12,7 +15,9 @@ import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.util.Arrays;
import java.util.Date;
import java.util.List;
@Slf4j
@Component
@@ -26,6 +31,9 @@ public class CorpushIsLikeConsumer implements RocketMQListener<MessageExt>{
@Autowired
private AiAnalysisRequestLogsMapper aiAnalysisRequestLogsMapper;
@Autowired
private TtAnalysisResultInfoMapper ttAnalysisResultInfoMapper;
@Override
public void onMessage(MessageExt messageExt) {
@@ -44,13 +52,20 @@ public class CorpushIsLikeConsumer implements RocketMQListener<MessageExt>{
log.info(" 回调的aiAnalysisRequestType为空：{} ", aiAnalysisRequestType);
return;
}
//   "isLike": "1" // 1：点赞，2：点踩
tmAnalysisResultService.saveTmCorpusReport(TmAnalysisResult.builder()
TmAnalysisResult tmAnalysisResult = TmAnalysisResult.builder()
.aiAnalysisRequestId(execDifyFlow.getString("analysisRecordId"))
.analysisResult(execDifyFlow.toJSONString())
.analysisType(aiAnalysisRequestType)
.updateTime(new Date())
.build());
.build();
//   "isLike": "1" // 1：点赞，2：点踩
tmAnalysisResultService.saveTmCorpusReport(tmAnalysisResult);
List<String> aiAnalysisRequestIdList = Arrays.asList(BusinessTypeEnum.SMART_ASSISTANT.getCode(),BusinessTypeEnum.SMART_ASSISTANT_QIWEI.getCode(),BusinessTypeEnum.SMART_ASSISTANT_NAMEPLATE.getCode());
if(aiAnalysisRequestIdList.contains(aiAnalysisRequestType)){
// 保存明细
ttAnalysisResultInfoMapper.insert(TtAnalysisResultInfo.builder().analysisResultId(tmAnalysisResult.getId()).analysisType(aiAnalysisRequestType).aiAnalysisRequestId(analysisRecordId).analysisResult(execDifyFlow.toJSONString()).build());
}
} catch (Exception e) {
log.info(" corpushIsLikeConsumer AI结果回传处理异常：{} ", e);
}

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

@@ -24,6 +24,7 @@ public class TmAnalysisResultServiceImpl extends ServiceImpl<TmAnalysisResultMap
if (oldTmCorpusReport == null) {
return tmCorpusReportMapper.insert(tmAnalysisResult) > 0;
} else {
tmAnalysisResult.setId(oldTmCorpusReport.getId());
return tmCorpusReportMapper.update(tmAnalysisResult, queryWrapper) > 0;
}
}