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

增加日志，增加mock方法

Browse Source
This commit is contained in:
zren25
2025-05-15 14:34:11 +08:00
parent 31efa3dc0c
commit bd72767f99
2 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -10,6 +10,7 @@ import org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory;
import org.springframework.kafka.core.DefaultKafkaConsumerFactory; import org.springframework.kafka.core.DefaultKafkaConsumerFactory;
import org.springframework.kafka.core.DefaultKafkaProducerFactory; import org.springframework.kafka.core.DefaultKafkaProducerFactory;
import org.springframework.kafka.core.KafkaTemplate; import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.kafka.listener.ContainerProperties;
import java.util.HashMap; import java.util.HashMap;
import java.util.Map; import java.util.Map;
@@ -86,6 +87,7 @@ public class KafkaConfig {
ConcurrentKafkaListenerContainerFactory<String, String> factory = ConcurrentKafkaListenerContainerFactory<String, String> factory =
new ConcurrentKafkaListenerContainerFactory<>(); new ConcurrentKafkaListenerContainerFactory<>();
factory.setConsumerFactory(new DefaultKafkaConsumerFactory<>(props)); factory.setConsumerFactory(new DefaultKafkaConsumerFactory<>(props));
factory.getContainerProperties().setAckMode(ContainerProperties.AckMode.MANUAL_IMMEDIATE);
return factory; return factory;
} }

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

@@ -285,7 +285,11 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl<TmNameplateCorpusM
public ResultMsg<Object> mockInsert(String data) { public ResultMsg<Object> mockInsert(String data) {
if(StringUtils.isNotEmpty(data)){ if(StringUtils.isNotEmpty(data)){
TmNameplateCorpus analysisResp = JSONObject.parseObject(data, TmNameplateCorpus.class); TmNameplateCorpus analysisResp = JSONObject.parseObject(data, TmNameplateCorpus.class);
tmNameplateCorpusMapper.insert(analysisResp); for(int i=0;i<100;i++){
analysisResp.setCustomerFlowId(analysisResp.getCustomerFlowId()+i);
tmNameplateCorpusMapper.insert(analysisResp);
}
return ResultMsg.ok(analysisResp); return ResultMsg.ok(analysisResp);
} }
return ResultMsg.failed(); return ResultMsg.failed();