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

增加日志&铭牌更新增加error更新

Browse Source
This commit is contained in:
zren25
2025-05-13 20:37:39 +08:00
parent ee36381253
commit e04c21be17
6 changed files with 44 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/config/KafkaConfig.java
View File

@@ -19,7 +19,7 @@ import java.util.Map;
public class KafkaConfig {
// 第一个Kafka配置
@Bean(name = "dccKafkaTemplate")
public KafkaTemplate<String, String> dccProducerFactory(
public KafkaTemplate<String, String> dccKafkaTemplate(
@Value("${kafka.dcc.bootstrap-servers}") String bootstrapServers,
@Value("${kafka.dcc.producer.key-serializer}") String keySerializer,
@Value("${kafka.dcc.producer.value-serializer}") String valueSerializer) {
@@ -35,7 +35,7 @@ public class KafkaConfig {
// 第二个Kafka配置
@Bean(name = "analyticCenterKafkaTemplate")
public KafkaTemplate<String, String> analyticCenterProducerFactory(
public KafkaTemplate<String, String> analyticCenterKafkaTemplate(
@Value("${kafka.analyticCenter.bootstrap-servers}") String bootstrapServers,
@Value("${kafka.analyticCenter.producer.key-serializer}") String keySerializer,
@Value("${kafka.analyticCenter.producer.value-serializer}") String valueSerializer) {

10
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/NameplateCorpusController.java
View File

@@ -27,10 +27,18 @@ public class NameplateCorpusController {
private TmNameplateCorpusService tmNameplateCorpusService;
@Autowired
private AiAnalysisRequestLogsService aiAnalysisRequestLogsService;
@PostMapping("/updateNameplate")
@PostMapping("/update")
@ApiOperation(value = "更新dify结果")
public ResultMsg<Object> updateNameplate(@RequestBody String message) {
log.info("updateNameplate message: {}", message);
return tmNameplateCorpusService.updateNameplate(message);
}
@PostMapping("/mockInsert")
@ApiOperation(value = "更新dify结果")
public ResultMsg<Object> mockInsert(@RequestBody String data) {
log.info("mockInsert: {}", data);
return tmNameplateCorpusService.mockInsert(data);
}
}

2
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/CorpusFailJob.java
View File

@@ -100,7 +100,7 @@ public class CorpusFailJob {
queryWrapper.eq(AiAnalysisRequestLogs::getAiAnalysisRequestId, aiAnalysisErrors.getAiAnalysisRequestId());
AiAnalysisRequestLogs oldAiAnalysisRequestLogs = aiAnalysisRequestLogsMapper.selectOne(queryWrapper);
if (null != oldAiAnalysisRequestLogs) {
if (null != oldAiAnalysisRequestLogs && StringUtils.isNotBlank(oldAiAnalysisRequestLogs.getBusinessResponse())) {
DiFyReq diFyReq = JSONObject.parseObject(oldAiAnalysisRequestLogs.getDifyRequest(), DiFyReq.class);
CorpusReportDTO corpusReportDTO = JSONObject.parseObject(oldAiAnalysisRequestLogs.getBusinessRequest(), CorpusReportDTO.class);
Map<String, String> ltoMap = new HashMap<>();

9
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/NameplateKafkaConsumer.java
View File

@@ -54,16 +54,19 @@ public class NameplateKafkaConsumer {
if(StringUtils.isNotEmpty(recordMessages)){
try {
NameplateTableKafkaDTO tmNameplateCorpus = JSON.parseObject(recordMessages, NameplateTableKafkaDTO.class);
log.info("nameplateKafkaConsumerParseType: {}", tmNameplateCorpus.getType());
if(tmNameplateCorpus.getType().equals("INSERT")){
tmNameplateCorpus.getData().forEach(nameplate -> {
log.info("tmNameplateCorpus customerFlowId: {}",nameplate.getCustomerFlowId());
log.info("nameplateKafkaConsumerCustomerFlowId: {}",nameplate.getCustomerFlowId());
tmNameplateCorpusService.processItem(nameplate);
});
}
} catch (Exception e) {
log.error("tmNameplateCorpus 铭牌解析处理出错: {}", e.getMessage());
log.error("nameplateKafkaConsumer铭牌解析处理出错: {}", e.getMessage());
}
}
log.info("tmNameplateCorpus Kafka 消息处理完成，耗时：{}", System.currentTimeMillis() - startTime);
log.info("nameplateKafkaConsumer消息处理完成，耗时：{}", System.currentTimeMillis() - startTime);
}

2
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/TmNameplateCorpusService.java
View File

@@ -23,5 +23,7 @@ public interface TmNameplateCorpusService extends IService<TmNameplateCorpus> {
ResultMsg<Object> updateNameplate(String message);
ResultMsg<Object> mockInsert(String data);
List<TmNameplateCorpus> queryTelephoneCorpusByCustomerFlowId(List<String> customerFlowIds);
}

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

@@ -7,13 +7,11 @@ import com.volvo.ai.analytic.center.dto.PageDto;
import com.volvo.ai.analytic.center.dto.corpus.CorpusReportDTO;
import com.volvo.ai.analytic.center.dto.req.DiFyReq;
import com.volvo.ai.analytic.center.dto.req.RunMaskingRuleInput;
import com.volvo.ai.analytic.center.entity.AiAnalysisRequestLogs;
import com.volvo.ai.analytic.center.entity.DataMaskingRule;
import com.volvo.ai.analytic.center.entity.TmNameplateCorpus;
import com.volvo.ai.analytic.center.entity.TtNameplateRecord;
import com.volvo.ai.analytic.center.entity.*;
import com.volvo.ai.analytic.center.enums.BusinessTypeEnum;
import com.volvo.ai.analytic.center.enums.CategoryEnum;
import com.volvo.ai.analytic.center.feign.RemoteCarModelClient;
import com.volvo.ai.analytic.center.mapper.AiAnalysisErrorsMapper;
import com.volvo.ai.analytic.center.mapper.TmNameplateCorpusMapper;
import com.volvo.ai.analytic.center.mapper.TmOdsVdqwMessagearchivingMapper;
import com.volvo.ai.analytic.center.mapper.TtNameplateRecordMapper;
@@ -60,6 +58,9 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl<TmNameplateCorpusM
@Autowired
private AiAnalysisRequestLogsService aiAnalysisRequestLogsService;
@Autowired
private AiAnalysisErrorsMapper aiAnalysisErrorsMapper;
@Autowired
private DiFyService diFyService;
@@ -267,12 +268,27 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl<TmNameplateCorpusM
List<TmNameplateCorpus> tmNameplateCorpusList = tmNameplateCorpusMapper.selectList(queryWrapper);
if (CollectionUtils.isNotEmpty(tmNameplateCorpusList)){
sendNameplateLto(difyJson, tmNameplateCorpusList.get(0));
LambdaQueryWrapper<AiAnalysisErrors> errorQueryWrapper = new LambdaQueryWrapper<>();
errorQueryWrapper.eq(AiAnalysisErrors::getAiAnalysisRequestId, aiAnalysisRequestId);
AiAnalysisErrors oldAiAnalysisErrors = aiAnalysisErrorsMapper.selectOne(errorQueryWrapper);
if (oldAiAnalysisErrors != null) {
oldAiAnalysisErrors.setAiAnalysisErrorHandlingStatus("1");
aiAnalysisErrorsMapper.update(oldAiAnalysisErrors, errorQueryWrapper);
}
}
return ResultMsg.ok();
}
return ResultMsg.failed();
}
@Override
public ResultMsg<Object> mockInsert(String data) {
if(StringUtils.isNotEmpty(data)){
TmNameplateCorpus analysisResp = JSONObject.parseObject(data, TmNameplateCorpus.class);
tmNameplateCorpusMapper.insert(analysisResp);
return ResultMsg.ok(analysisResp);
}
return ResultMsg.failed();
}
@Override
public List<TmNameplateCorpus> queryTelephoneCorpusByCustomerFlowId(List<String> customerFlowIds) {
return tmNameplateCorpusMapper.queryTmNameplateCorpusByCustomerFlowIds(customerFlowIds);