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-04-03 15:11:53 +08:00
parent 2bc9cedb94
commit 301e261b41
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/IntelligentCustomerMqConsumer.java
View File

@@ -60,14 +60,14 @@ public class IntelligentCustomerMqConsumer implements RocketMQListener<MessageEx
intelligentCustomerService.fourInOneMqService(fourRequestDTO); intelligentCustomerService.fourInOneMqService(fourRequestDTO);
log.info("FourInOneRequestDTO处理完成，耗时：{}", System.currentTimeMillis() - startTime); log.info("FourInOneRequestDTO处理完成，耗时：{}", System.currentTimeMillis() - startTime);
} catch (JsonProcessingException e) { } catch (JsonProcessingException e) {
log.info(" dcc mq 处理失败：{}", e.getMessage()); log.info("intelligentCustomerMqConsumer mq 处理失败：{}", e.getMessage());
} }
} }
@PostMapping("ntelligentCustomerMqConsumer") @PostMapping("intelligentCustomerMqConsumer")
public void onMessage(@RequestBody String message) { public void intelligentCustomerMqConsumer(@RequestBody String message) {
long startTime = System.currentTimeMillis(); long startTime = System.currentTimeMillis();
try { try {
log.info("intelligentCustomerMqConsumer 当前线程: {}, 线程ID: {}", Thread.currentThread().getName(), Thread.currentThread().getId()); log.info("intelligentCustomerMqConsumer 当前线程: {}, 线程ID: {}", Thread.currentThread().getName(), Thread.currentThread().getId());

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

@@ -56,7 +56,7 @@ public class IntelligentCustomerServiceImpl implements IntelligentCustomerServic
@Resource @Resource
private RocketMQTemplate rocketMqTemplate; private RocketMQTemplate rocketMqTemplate;
@Value("${rocketmq.producer.corpus.topic}") @Value("${rocketmq.producer.intelligentCustomer.topic}")
private String topic; private String topic;
@Value("${dify.intelligentCustomer.fourInOneToken}") @Value("${dify.intelligentCustomer.fourInOneToken}")
private String fourInOneToken; private String fourInOneToken;