舆情自动化入参校验

This commit is contained in:
lxu75
2025-05-13 17:29:01 +08:00
parent 6aa26915a4
commit 876569bbb0

View File

@@ -106,8 +106,11 @@ public class MqMessageRecordServiceImpl extends ServiceImpl<MqMessageRecordMappe
public boolean processMessageByMQ(String message) { public boolean processMessageByMQ(String message) {
log.info("communityProcessMessageByMQ message: {}", message); log.info("communityProcessMessageByMQ message: {}", message);
CommunityTargetDTO communityTargetDTO = JSON.parseObject(message, CommunityTargetDTO.class); CommunityTargetDTO communityTargetDTO = JSON.parseObject(message, CommunityTargetDTO.class);
if (communityTargetDTO == null) { if (communityTargetDTO == null
log.error("communityProcessMessageByMQ message is null"); || StringUtils.isBlank(communityTargetDTO.getTargetId())
|| StringUtils.isBlank(communityTargetDTO.getTargetType())
|| communityTargetDTO.getContent().isEmpty()) {
log.error("社区舆情自动化校验失败入参异常:{}",JSON.toJSONString(communityTargetDTO));
return false; return false;
} }
// 生成ai分析请求id // 生成ai分析请求id