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-09 18:58:38 +08:00
parent 8fa539cb82
commit 00445aac8d
1 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -7,6 +7,7 @@ import com.volvo.ai.analytic.center.dto.req.FourInOneRequestDTO;
import com.volvo.ai.analytic.center.service.AiAnalysisRequestLogsService; import com.volvo.ai.analytic.center.service.AiAnalysisRequestLogsService;
import com.volvo.ai.analytic.center.service.IntelligentCustomerService; import com.volvo.ai.analytic.center.service.IntelligentCustomerService;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.apache.rocketmq.common.message.MessageExt; import org.apache.rocketmq.common.message.MessageExt;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener; import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener; import org.apache.rocketmq.spring.core.RocketMQListener;
@@ -55,6 +56,10 @@ public class IntelligentCustomerMqConsumer implements RocketMQListener<MessageEx
String message = new String(messageExt.getBody()); String message = new String(messageExt.getBody());
log.info("IntelligentCustomerMqConsumer message: " + message); log.info("IntelligentCustomerMqConsumer message: " + message);
FourInOneRequestDTO fourRequestDTO = objectMapper.readValue(message, FourInOneRequestDTO.class); FourInOneRequestDTO fourRequestDTO = objectMapper.readValue(message, FourInOneRequestDTO.class);
if (StringUtils.isEmpty(fourRequestDTO.getWorkOrderSource()) || StringUtils.isEmpty(fourRequestDTO.getWorkOrderContent())){
log.info("IntelligentCustomerMqConsumer WorkOrderSource or WorkOrderContent 为空不处理 ");
return ;
}
intelligentCustomerService.fourInOneMqService(fourRequestDTO); intelligentCustomerService.fourInOneMqService(fourRequestDTO);
log.info("FourInOneRequestDTO处理完成，耗时：{}", System.currentTimeMillis() - startTime); log.info("FourInOneRequestDTO处理完成，耗时：{}", System.currentTimeMillis() - startTime);
} catch (JsonProcessingException e) { } catch (JsonProcessingException e) {