From 433a59bf4404b35d94108b2c9986db7ddea6f0b5 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=88=98=E4=BA=9A=E6=B4=B2=EF=BC=88A=EF=BC=89?= Date: Thu, 19 Jun 2025 13:49:44 +0800 Subject: [PATCH] =?UTF-8?q?refactor(ai-analytic-center):=20=E9=87=8D?= =?UTF-8?q?=E6=9E=84=E4=BB=A3=E7=A0=81=E5=B9=B6=E7=A7=BB=E9=99=A4=E6=9C=AA?= =?UTF-8?q?=E4=BD=BF=E7=94=A8=E7=9A=84=E5=8A=9F=E8=83=BD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 删除了多个类中的冗余代码和未使用的属性- 移除了未使用的 AI 解析相关代码和接口 - 优化了部分代码结构，提高了代码可读性和维护性 - 删除了未使用的 constant 字符串 - 添加一些注释 --- .../analytic/center/config/KafkaConfig.java | 13 +++- .../controller/NameplateCorpusController.java | 5 +- .../center/controller/TestController.java | 6 +- .../center/job/NameplateCorpusJob.java | 36 +---------- .../mq/AnalysisDifyCallbackMqConsumer.java | 10 +-- .../center/mq/AnalysisDifyMqConsumer.java | 16 +---- .../center/mq/CorpusDccMqConsumer.java | 6 +- .../center/mq/CorpusProcessKafkaProducer.java | 2 +- .../center/mq/CorpushIsLikeConsumer.java | 7 +- .../mq/IntelligentCustomerMqConsumer.java | 5 +- .../center/mq/NameplateKafkaConsumer.java | 11 +--- .../service/TmNameplateCorpusService.java | 2 - .../impl/IntelligentCustomerServiceImpl.java | 44 ------------- .../impl/TmNameplateCorpusServiceImpl.java | 64 ------------------- .../impl/TmTelephoneCorpusServiceImpl.java | 10 --- .../ai/analytic/center/utils/ConstantStr.java | 2 +- 16 files changed, 25 insertions(+), 214 deletions(-) diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/config/KafkaConfig.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/config/KafkaConfig.java index 0624b4b..6533109 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/config/KafkaConfig.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/config/KafkaConfig.java @@ -23,7 +23,9 @@ public class KafkaConfig { - // 第一个Kafka配置 + /** + * 湖仓Kafka配置，用途：mock数据 + */ @Bean(name = "dccKafkaTemplate") public KafkaTemplate dccKafkaTemplate( @Value("${spring.kafka.bootstrap-servers}") String bootstrapServers, @@ -39,7 +41,9 @@ public class KafkaConfig { } - // 第二个Kafka配置 + /** + * 分支中心kafka配置，湖仓Kafka配置 + */ @Bean(name = "analyticCenterKafkaTemplate") public KafkaTemplate analyticCenterKafkaTemplate( @Value("${analyticCenterKafka.bootstrap-servers}") String bootstrapServers, @@ -54,6 +58,10 @@ public class KafkaConfig { return new KafkaTemplate<>(factory); } + + /** + * 分支中心kafka消费者配置 + */ @Bean(name = "analyticCenterConsumerFactory") public ConcurrentKafkaListenerContainerFactory analyticCenterConsumerFactory( @Value("${analyticCenterKafka.bootstrap-servers}") String bootstrapServers, @@ -75,7 +83,6 @@ public class KafkaConfig { new ConcurrentKafkaListenerContainerFactory<>(); factory.setConsumerFactory(new DefaultKafkaConsumerFactory<>(props)); factory.getContainerProperties().setAckMode(ContainerProperties.AckMode.MANUAL_IMMEDIATE); -// factory.setBatchListener(true); return factory; } diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/NameplateCorpusController.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/NameplateCorpusController.java index 979a3df..e1faaba 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/NameplateCorpusController.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/NameplateCorpusController.java @@ -1,6 +1,5 @@ package com.volvo.ai.analytic.center.controller; -import com.volvo.ai.analytic.center.service.AiAnalysisRequestLogsService; import com.volvo.ai.analytic.center.service.TmNameplateCorpusService; import com.volvo.common.core.util.ResultMsg; import io.swagger.annotations.Api; @@ -25,10 +24,8 @@ public class NameplateCorpusController { @Autowired private TmNameplateCorpusService tmNameplateCorpusService; - @Autowired - private AiAnalysisRequestLogsService aiAnalysisRequestLogsService; @PostMapping("/update") - @ApiOperation(value = "更新dify结果") + @ApiOperation(value = "dify发起http 东西网关调用，异步更新dify结果") public ResultMsg updateNameplate(@RequestBody String message) { log.info("updateNameplate message: {}", message); return tmNameplateCorpusService.updateNameplate(message); diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/TestController.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/TestController.java index 6990d21..0d97d7d 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/TestController.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/TestController.java @@ -3,7 +3,6 @@ package com.volvo.ai.analytic.center.controller; import com.alibaba.fastjson.JSONObject; import com.volvo.ai.analytic.center.dto.corpus.AicorpusTelephoneDTO; -import com.volvo.ai.analytic.center.service.AiAnalysisRequestLogsService; import com.volvo.common.core.util.ResultMsg; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; @@ -30,9 +29,6 @@ public class TestController { @Autowired private RocketMQTemplate rocketMQTemplate; - @Autowired - private AiAnalysisRequestLogsService aiAnalysisRequestLogsService; - @Autowired @Qualifier("analyticCenterKafkaTemplate") private KafkaTemplate kafkaProducer; @@ -65,7 +61,7 @@ public class TestController { return ResultMsg.ok("ok"); } @PostMapping("/mockDccKafka") - @ApiOperation(value = "补偿处理消息") + @ApiOperation(value = "手动发送kafka消息，用于开发测试") public ResultMsg mockDccKafka(@RequestBody AicorpusTelephoneDTO message) { for(int i=0;i<20;i++){ diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/NameplateCorpusJob.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/NameplateCorpusJob.java index 4f0955d..2e80f17 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/NameplateCorpusJob.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/NameplateCorpusJob.java @@ -1,15 +1,12 @@ package com.volvo.ai.analytic.center.job; -import com.volvo.ai.analytic.center.mapper.TmTelephoneCorpusMapper; import com.volvo.ai.analytic.center.service.TmNameplateCorpusService; -import com.volvo.ai.analytic.center.service.TmTelephoneCorpusService; import com.volvo.common.core.util.ResultMsg; import com.xxl.job.core.context.XxlJobHelper; import com.xxl.job.core.handler.annotation.XxlJob; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.beans.factory.annotation.Value; import org.springframework.cloud.context.config.annotation.RefreshScope; import org.springframework.stereotype.Component; import org.springframework.web.bind.annotation.PostMapping; @@ -29,39 +26,10 @@ public class NameplateCorpusJob { @Autowired private TmNameplateCorpusService tmNameplateCorpusService; - @Autowired - private TmTelephoneCorpusService tmTelephoneCorpusService; - - @Autowired - private TmTelephoneCorpusMapper tmTelephoneCorpusMapper; - @Value("${dify.corpus.nameplate.isUse}") - private boolean isUse; - /** - * 铭牌语料处理 - */ - @XxlJob("nameplateCorpusTask") - @PostMapping("nameplateCorpusTask") - public ResultMsg nameplateCorpusTask(@RequestBody String paramJson) { - try { - // 获取任务参数 - String param = XxlJobHelper.getJobParam(); - if(StringUtils.isEmpty(param)){ - param = paramJson; - } - // 执行业务逻辑 - XxlJobHelper.log("任务参数: {}", param); - log.info("nameplateCorpusTask 铭牌语料查询处理:{}",param); - tmNameplateCorpusService.runNameplateCorpusDify(param); - } catch (Exception e) { - log.error("nameplateCorpusTask 定时任务补偿处理消息异常",e.getMessage()); - } - return ResultMsg.ok(); - } - /** - * 铭牌语料处理失败重试 - * @param paramJson + * 手动铭牌语料处理失败重试 + * @param paramJson （statTime，endTime，customerFlowIds） * @return */ @XxlJob("nameplateCorpusTaskFailRetry") diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/AnalysisDifyCallbackMqConsumer.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/AnalysisDifyCallbackMqConsumer.java index c8aa099..5f7ab81 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/AnalysisDifyCallbackMqConsumer.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/AnalysisDifyCallbackMqConsumer.java @@ -24,7 +24,7 @@ import org.springframework.web.client.RestTemplate; /** * @ClassName AnalysisDifyMqConsumer - * @Description AI解析MQ-Callback处理 + * @Description AI解析MQ-Callback处理 （暂时未用） * @Author renzhen * @Date 2025-03-04 10:18 * @Version 1.0 @@ -44,17 +44,9 @@ public class AnalysisDifyCallbackMqConsumer implements RocketMQListener { - @Autowired - private AiAnalysisRequestLogsService aiAnalysisRequestLogsService; - - @Value("${dify.corpus.checkDccRepeat}") - private String checkDccRepeat; - @Value("${rocketmq.consumer.analysisDify.difyLimit}") private int difyLimit; @@ -58,14 +49,9 @@ public class AnalysisDifyMqConsumer implements RocketMQListener { @Autowired private DiFyService diFyService; - @Autowired - private RedisCounterRateLimiter redisCounterRateLimiter; - @Autowired private AiAnalysisErrorsService aiAnalysisErrorsService; - @Autowired - private RedisTemplate redisTemplate; @Autowired private RedisZSetUtil redisZSetUtil; diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusDccMqConsumer.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusDccMqConsumer.java index 4c0d351..bf451b1 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusDccMqConsumer.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusDccMqConsumer.java @@ -4,7 +4,6 @@ package com.volvo.ai.analytic.center.mq; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.ObjectMapper; import com.volvo.ai.analytic.center.dto.corpus.AicorpusTelephoneDTO; -import com.volvo.ai.analytic.center.service.AiAnalysisRequestLogsService; import com.volvo.ai.analytic.center.service.TmTelephoneCorpusService; import lombok.extern.slf4j.Slf4j; import org.apache.rocketmq.common.message.MessageExt; @@ -16,7 +15,7 @@ import org.springframework.stereotype.Component; import org.springframework.web.bind.annotation.RestController; /** - * @ClassName CorpusProcessKafkaConsumer + * @ClassName 湖仓发送过来的kafka消息自己发MQ自己消费 DCC通话记录 （目前接入的需求：4IN1的智能工单-电话场景，LTO跟进记录AI总结） * @Description * @Author renzhen * @Date 2025-03-04 10:18 @@ -37,9 +36,6 @@ public class CorpusDccMqConsumer implements RocketMQListener { @Autowired private TmTelephoneCorpusService tmTelephoneCorpusService; - @Autowired - private AiAnalysisRequestLogsService aiAnalysisRequestLogsService; - private final ObjectMapper objectMapper = new ObjectMapper(); @Override diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusProcessKafkaProducer.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusProcessKafkaProducer.java index 047ce3e..7803125 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusProcessKafkaProducer.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusProcessKafkaProducer.java @@ -30,7 +30,7 @@ import java.util.concurrent.Executors; /** * @ClassName CorpusProcessKafkaConsumer - * @Description + * @Description 消费湖仓同步的DCC通话记录kafka消息 * @Author renzhen * @Date 2025-03-04 10:18 * @Version 1.0 diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpushIsLikeConsumer.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpushIsLikeConsumer.java index 565894e..a1c1d9d 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpushIsLikeConsumer.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpushIsLikeConsumer.java @@ -4,7 +4,6 @@ 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; @@ -19,6 +18,9 @@ import java.util.Arrays; import java.util.Date; import java.util.List; +/** + * LTO跟进记录AI总结的点赞点踩 + */ @Slf4j @Component @RocketMQMessageListener(consumerGroup = "${rocketmq.consumer.corpus.isLikeTpoicGroup}", @@ -29,9 +31,6 @@ public class CorpushIsLikeConsumer implements RocketMQListener{ @Autowired private TmAnalysisResultService tmAnalysisResultService; - @Autowired - private AiAnalysisRequestLogsMapper aiAnalysisRequestLogsMapper; - @Autowired private TtAnalysisResultInfoMapper ttAnalysisResultInfoMapper; @Override diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/IntelligentCustomerMqConsumer.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/IntelligentCustomerMqConsumer.java index 1288ed5..fb63b53 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/IntelligentCustomerMqConsumer.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/IntelligentCustomerMqConsumer.java @@ -4,7 +4,6 @@ package com.volvo.ai.analytic.center.mq; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.ObjectMapper; import com.volvo.ai.analytic.center.dto.req.FourInOneRequestDTO; -import com.volvo.ai.analytic.center.service.AiAnalysisRequestLogsService; import com.volvo.ai.analytic.center.service.IntelligentCustomerService; import lombok.extern.slf4j.Slf4j; import org.apache.rocketmq.common.message.MessageExt; @@ -17,7 +16,7 @@ import org.springframework.web.bind.annotation.RestController; /** * @ClassName CorpusProcessKafkaConsumer - * @Description 智能客服 语料解析 四合一 + * @Description 消费4In1智能工单-在线客服的语料消息 * @Author renzhen * @Date 2025-03-04 10:18 * @Version 1.0 @@ -37,8 +36,6 @@ public class IntelligentCustomerMqConsumer implements RocketMQListener { - void runNameplateCorpusDify(String paramJson); - void runNameplateCorpusDifyRetry(String paramJson); void processItem(TmNameplateCorpus item); diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/IntelligentCustomerServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/IntelligentCustomerServiceImpl.java index a2c4d7c..14f6969 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/IntelligentCustomerServiceImpl.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/IntelligentCustomerServiceImpl.java @@ -54,8 +54,6 @@ public class IntelligentCustomerServiceImpl implements IntelligentCustomerServic private String topic; @Value("${dify.intelligentCustomer.fourInOneToken}") private String fourInOneToken; - @Autowired - private RemoteCarModelClient remoteCarModelClient; @Autowired private DataMaskingRuleService dataMaskingRuleService; @@ -66,13 +64,6 @@ public class IntelligentCustomerServiceImpl implements IntelligentCustomerServic @Autowired private AiAnalysisErrorsService aiAnalysisErrorsService; - @Autowired - private AiAnalysisErrorsMapper aiAnalysisErrorsMapper; - - @Autowired - private TcIntelligentCustomerMapper tcIntelligentCustomerMapper; - - private Map> tcIntelligentCustomer = Collections.EMPTY_MAP; @Override public void fourInOneMqService(FourInOneRequestDTO fourInOneRequestDTO) { @@ -148,39 +139,4 @@ public class IntelligentCustomerServiceImpl implements IntelligentCustomerServic }, 10000); } - // 咨询类【201】/投诉类【202】/投诉类型【203】 过滤 - /** private String fourInOneMqServiceFilter(String customerType,String customerValue){ - if(tcIntelligentCustomer.isEmpty()){ - queryTcIntelligentCustomer(); - } - List typeValues = tcIntelligentCustomer.get(customerType); - if(!typeValues.contains(customerValue)){ - return ""; - } - return customerValue; - } - - - public Map> queryTcIntelligentCustomer() { - LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); - queryWrapper.eq(TcIntelligentCustomer::getIsDeleted, "0"); - List tcIntelligentCustomerList =tcIntelligentCustomerMapper.selectList(queryWrapper); - tcIntelligentCustomer = tcIntelligentCustomerList.stream() - .collect(Collectors.groupingBy( - TcIntelligentCustomer::getIntelligentCustomerType, // 按照 IntelligentCustomerType 分组 - Collectors.mapping( - customer -> { - if (customer.getIntelligentCustomerType().equals(IntelligentCustomerTypeEnum.CONSULT_TYPE.getCode())) { - return customer.getTypeOne(); // 如果是咨询类型，返回 TypeOne - } else { - return customer.getTypeOne().concat("#").concat(customer.getTypeTwo()).concat("#").concat(customer.getTypeThree()); // 其他类型，拼接 TypeOne、TypeTwo、TypeThree - } - }, - Collectors.toList() - ) - )); - return tcIntelligentCustomer; - } -**/ - } \ No newline at end of file diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmNameplateCorpusServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmNameplateCorpusServiceImpl.java index 67eb639..36dd015 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmNameplateCorpusServiceImpl.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmNameplateCorpusServiceImpl.java @@ -10,10 +10,8 @@ import com.volvo.ai.analytic.center.dto.req.RunMaskingRuleInput; 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; import com.volvo.ai.analytic.center.service.*; import com.volvo.ai.analytic.center.utils.ConstantStr; @@ -21,13 +19,11 @@ import com.volvo.common.core.util.ResultMsg; import lombok.extern.slf4j.Slf4j; import org.apache.commons.collections.CollectionUtils; import org.apache.commons.lang3.StringUtils; -import org.apache.rocketmq.spring.core.RocketMQTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.cloud.context.config.annotation.RefreshScope; import org.springframework.stereotype.Service; -import javax.annotation.Resource; import java.time.LocalDate; import java.util.*; import java.util.concurrent.CompletableFuture; @@ -45,8 +41,6 @@ import java.util.concurrent.Executors; @Service public class TmNameplateCorpusServiceImpl extends ServiceImpl implements TmNameplateCorpusService { - @Autowired - private TmOdsVdqwMessagearchivingMapper tmOdsVdqwMessagearchivingMapper; @Autowired private TmNameplateCorpusMapper tmNameplateCorpusMapper; @@ -63,72 +57,14 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl messageList = tmNameplateCorpusMapper.queryTmNameplateCorpusByData(statTime, endTime, offset, pageSize); - // 处理查询到的数据 - // 使用 CompletableFuture 并行处理 - CompletableFuture[] futures = messageList.stream() - .map(item -> CompletableFuture.runAsync(() -> { - try { - processItem(item); - } catch (Exception e) { - log.error("铭牌语料失败: customerFlowId={}, AcceptUserId={}, 异常: {}", - item.getCustomerFlowId(), e.getMessage(), e); - } - }, executor)) - .toArray(CompletableFuture[]::new); - // 等待所有任务完成 - CompletableFuture.allOf(futures).join(); - } - // 关闭线程池 - executor.shutdown(); - log.info("企微数据跑批结束 耗时：{}",System.currentTimeMillis()-startTime); - } @Override public void runNameplateCorpusDifyRetry(String paramJson) { long startTime = System.currentTimeMillis(); diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java index 081b7d4..85ea52c 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java @@ -18,7 +18,6 @@ import com.volvo.ai.analytic.center.enums.BizEnum; 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.TmTelephoneCorpusMapper; import com.volvo.ai.analytic.center.service.*; import com.volvo.ai.analytic.center.utils.ConstantStr; @@ -77,9 +76,6 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl