diff --git a/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/dto/req/CommunityTargetDTO.java b/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/dto/req/CommunityTargetDTO.java index 694372b..2fa70d6 100644 --- a/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/dto/req/CommunityTargetDTO.java +++ b/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/dto/req/CommunityTargetDTO.java @@ -11,6 +11,7 @@ public class CommunityTargetDTO { private String targetType; private String targetId; + private String communityRequestId; private List content; @Setter diff --git a/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/dto/req/DifyCommunityTargetDTO.java b/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/dto/req/DifyCommunityTargetDTO.java index 2832598..1a4bbb0 100644 --- a/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/dto/req/DifyCommunityTargetDTO.java +++ b/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/dto/req/DifyCommunityTargetDTO.java @@ -29,4 +29,10 @@ public class DifyCommunityTargetDTO { * 社区请求id */ private String communityRequestId; + + + /** + * 舆情事件 + */ + private String sentiment; } diff --git a/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/entity/TtAnalysisResultInfo.java b/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/entity/TtAnalysisResultInfo.java new file mode 100644 index 0000000..1123a82 --- /dev/null +++ b/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/entity/TtAnalysisResultInfo.java @@ -0,0 +1,103 @@ +package com.volvo.ai.analytic.center.entity; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import lombok.AllArgsConstructor; +import lombok.Builder; +import lombok.Data; +import lombok.NoArgsConstructor; + +import java.util.Date; + +/** + * @description AI解析反馈明细表 + * @author BEJSON + * @date 2025-03-11 + */ +@Data +@TableName("tt_analysis_result_info") +@Builder +@AllArgsConstructor +@NoArgsConstructor +public class TtAnalysisResultInfo { + + private static final long serialVersionUID = 1L; + + /** + * 主键id + */ + @TableId(value="id", type = IdType.AUTO) + private Long id; + @TableField(value="analysis_result_id") + private Long analysisResultId; + /** + * 语料Id + */ + @TableField("ai_analysis_request_id") + private String aiAnalysisRequestId; + + /** + * 语料类型【1：企业微信，2：电话】 + */ + @TableField("analysis_type") + private String analysisType; + + /** + * corpus_time + */ + @TableField("analysis_result") + private String analysisResult; + + + /** + * 删除标识（0-未删除，1-已删除） + */ + @TableField("is_deleted") + private Integer isDeleted; + + /** + * 记录版本号，即乐观锁 + */ + @TableField("version") + private Integer version; + + /** + * 创建人 + */ + @TableField("create_by") + private String createBy; + + /** + * 更新人 + */ + @TableField("update_by") + private String updateBy; + + /** + * 创建sql人 + */ + @TableField("create_sqlby") + private String createSqlby; + + /** + * 更新sql人 + */ + @TableField("update_sqlby") + private String updateSqlby; + + /** + * 创建时间 + */ + @TableField("create_time") + private Date createTime; + + /** + * 更新时间 + */ + @TableField("update_time") + private Date updateTime; + + +} \ No newline at end of file diff --git a/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/enums/BusinessTypeEnum.java b/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/enums/BusinessTypeEnum.java index a0ed9dc..2f3b50f 100644 --- a/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/enums/BusinessTypeEnum.java +++ b/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/enums/BusinessTypeEnum.java @@ -20,6 +20,9 @@ public enum BusinessTypeEnum { //索赔检核配置类型 AUDITRULES("AuditRules", "审计规则配置"), + + CASE("case", "舆情事件"), + SMART_ASSISTANT_NAMEPLATE("SMART_ASSISTANT_NAMEPLATE", "智能助手-铭牌") ; diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/config/AsyncTaskExecutePool.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/config/AsyncTaskExecutePool.java new file mode 100644 index 0000000..51254a4 --- /dev/null +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/config/AsyncTaskExecutePool.java @@ -0,0 +1,68 @@ +package com.volvo.ai.analytic.center.config; + +import lombok.extern.slf4j.Slf4j; +import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler; +import org.springframework.beans.factory.annotation.Value; +import org.springframework.context.annotation.Bean; +import org.springframework.scheduling.annotation.AsyncConfigurer; +import org.springframework.scheduling.annotation.EnableAsync; +import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; +import org.springframework.stereotype.Component; + +import java.util.concurrent.*; + +/** + * 异步任务线程池装配类 + * @author gubin + * @date 2022-04-14 + */ +@EnableAsync +@Slf4j +@Component +public class AsyncTaskExecutePool implements AsyncConfigurer { + + @Value("${task.pool.corePoolSize}") + private int corePoolSize; + + @Value("${task.pool.maxPoolSize}") + private int maxPoolSize; + + @Value("${task.pool.queueCapacity}") + private int queueCapacity; + + @Value("${task.pool.keepAliveSeconds}") + private int keepAliveSeconds; + + + @Bean + @Override + public Executor getAsyncExecutor() { + ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); + //核心线程池大小 + executor.setCorePoolSize(corePoolSize); + //最大线程数 + executor.setMaxPoolSize(maxPoolSize); + //队列容量 + executor.setQueueCapacity(queueCapacity); + //活跃时间 + executor.setKeepAliveSeconds(keepAliveSeconds); + //线程名字前缀 + executor.setThreadNamePrefix("async-task-"); + // setRejectedExecutionHandler：当pool已经达到max size的时候，如何处理新任务 + // CallerRunsPolicy：不在新线程中执行任务，而是由调用者所在的线程来执行 + executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); + executor.initialize(); + return executor; + } + + @Override + public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() { + return (throwable, method, objects) -> { + log.error("===="+throwable.getMessage()+"====", throwable); + log.error("exception method:"+method.getName()); + }; + } + + + +} diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mapper/TtAnalysisResultInfoMapper.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mapper/TtAnalysisResultInfoMapper.java new file mode 100644 index 0000000..3b15cf0 --- /dev/null +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mapper/TtAnalysisResultInfoMapper.java @@ -0,0 +1,16 @@ +package com.volvo.ai.analytic.center.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.volvo.ai.analytic.center.entity.TtAnalysisResultInfo; +import org.apache.ibatis.annotations.Mapper; + +/** + * @description Ai分析结果明细表 + * @author BEJSON + * @date 2025-03-04 + */ +@Mapper +public interface TtAnalysisResultInfoMapper extends BaseMapper { + + +} \ No newline at end of file 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 1ac1fb0..565894e 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 @@ -2,7 +2,10 @@ package com.volvo.ai.analytic.center.mq; 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; import org.apache.commons.lang3.StringUtils; @@ -12,7 +15,9 @@ import org.apache.rocketmq.spring.core.RocketMQListener; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; +import java.util.Arrays; import java.util.Date; +import java.util.List; @Slf4j @Component @@ -26,6 +31,9 @@ public class CorpushIsLikeConsumer implements RocketMQListener{ @Autowired private AiAnalysisRequestLogsMapper aiAnalysisRequestLogsMapper; + + @Autowired + private TtAnalysisResultInfoMapper ttAnalysisResultInfoMapper; @Override public void onMessage(MessageExt messageExt) { @@ -44,13 +52,20 @@ public class CorpushIsLikeConsumer implements RocketMQListener{ log.info(" 回调的aiAnalysisRequestType为空：{} ", aiAnalysisRequestType); return; } - //   "isLike": "1" // 1：点赞，2：点踩 - tmAnalysisResultService.saveTmCorpusReport(TmAnalysisResult.builder() + TmAnalysisResult tmAnalysisResult = TmAnalysisResult.builder() .aiAnalysisRequestId(execDifyFlow.getString("analysisRecordId")) .analysisResult(execDifyFlow.toJSONString()) .analysisType(aiAnalysisRequestType) .updateTime(new Date()) - .build()); + .build(); + //   "isLike": "1" // 1：点赞，2：点踩 + tmAnalysisResultService.saveTmCorpusReport(tmAnalysisResult); + List aiAnalysisRequestIdList = Arrays.asList(BusinessTypeEnum.SMART_ASSISTANT.getCode(),BusinessTypeEnum.SMART_ASSISTANT_QIWEI.getCode(),BusinessTypeEnum.SMART_ASSISTANT_NAMEPLATE.getCode()); + if(aiAnalysisRequestIdList.contains(aiAnalysisRequestType)){ + // 保存明细 + ttAnalysisResultInfoMapper.insert(TtAnalysisResultInfo.builder().analysisResultId(tmAnalysisResult.getId()).analysisType(aiAnalysisRequestType).aiAnalysisRequestId(analysisRecordId).analysisResult(execDifyFlow.toJSONString()).build()); + + } } catch (Exception e) { log.info(" corpushIsLikeConsumer AI结果回传处理异常：{} ", e); } diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DataMaskingRuleServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DataMaskingRuleServiceImpl.java index 71e65ac..6ec258c 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DataMaskingRuleServiceImpl.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DataMaskingRuleServiceImpl.java @@ -24,7 +24,6 @@ public class DataMaskingRuleServiceImpl extends ServiceImpl dataMaskingRuleList = this.lambdaQuery() .like(DataMaskingRule::getApplicationChannel, applicationChannel) - .eq(DataMaskingRule::getApplicationChannel, applicationChannel) .eq(DataMaskingRule::getRuleStatus, YesOrNoConstants.YES) .eq(DataMaskingRule::getIsDeleted, YesOrNoConstants.NO) .list(); diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/MqMessageRecordServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/MqMessageRecordServiceImpl.java index d0331b7..5e2ce92 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/MqMessageRecordServiceImpl.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/MqMessageRecordServiceImpl.java @@ -3,10 +3,12 @@ package com.volvo.ai.analytic.center.service.impl; import cn.hutool.core.date.DateUtil; import com.alibaba.cloud.commons.lang.StringUtils; import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; +import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.volvo.ai.analytic.center.constant.Constant; import com.volvo.ai.analytic.center.dto.req.*; @@ -15,6 +17,7 @@ import com.volvo.ai.analytic.center.entity.*; import com.volvo.ai.analytic.center.enums.*; import com.volvo.ai.analytic.center.mapper.AiAnalysisErrorsMapper; import com.volvo.ai.analytic.center.mapper.AiAnalysisRequestLogsMapper; +import com.volvo.ai.analytic.center.mapper.AiAnalyticBusinessConfigMapper; import com.volvo.ai.analytic.center.mapper.MqMessageRecordMapper; import com.volvo.ai.analytic.center.service.DataMaskingRuleService; import com.volvo.ai.analytic.center.service.DiFyService; @@ -35,6 +38,9 @@ import org.springframework.util.CollectionUtils; import java.text.SimpleDateFormat; import java.time.LocalDateTime; import java.util.*; +import java.util.concurrent.CompletableFuture; +import java.util.concurrent.ExecutionException; +import java.util.concurrent.Executor; import java.util.stream.Collectors; @Slf4j @@ -65,8 +71,14 @@ public class MqMessageRecordServiceImpl extends ServiceImpl NodeTypeEnum.IMAGE.getCode().equals(contentNode.getNodeType())); @@ -112,28 +136,19 @@ public class MqMessageRecordServiceImpl extends ServiceImpl caseWorkFlow = CompletableFuture.supplyAsync(() -> callCaseCommunityWorkFlow(difyCommunityTargetDTO,user, caseToken),getAsyncExecutor); + + // 内容主题关键词打标 + CompletableFuture keywordWorkFlow = CompletableFuture.supplyAsync(() -> callCommunityWorkFlow(difyCommunityTargetDTO,user, keywordToken),getAsyncExecutor); + + // litecrm线索分析 + CompletableFuture clueAnalysisWorkFlow = CompletableFuture.supplyAsync(() -> callCommunityWorkFlow(difyCommunityTargetDTO,user, clueAnalysisToken),getAsyncExecutor); + + CompletableFuture allFutures = CompletableFuture.allOf(caseWorkFlow, keywordWorkFlow, clueAnalysisWorkFlow); + // 等待所有API调用完成 + allFutures.get(); + // 获取各个API的结果 + JSONObject caseResult = caseWorkFlow.get(); + JSONObject keywordResult = keywordWorkFlow.get(); + JSONObject clueAnalysisResult = clueAnalysisWorkFlow.get(); + difyResult.add(caseResult); + difyResult.add(keywordResult); + difyResult.add(clueAnalysisResult); + //处理结果 + processingCommunityDifyResponse(caseResult,keywordResult,clueAnalysisResult, aiAnalysisRequestId,difyCommunityTargetDTO.getCommunityRequestId()); + } + + /** + * 调用案件，关键词，线索工作流 + */ + private JSONObject callCommunityWorkFlow(DifyCommunityTargetDTO difyCommunityTargetDTO ,String user, String token) { + log.info("开始调用关键词，线索工作流,token: {}",token); + DiFyReq diFyReq = new DiFyReq(); + diFyReq.setUser(user); + diFyReq.setInputs(difyCommunityTargetDTO); + diFyReq.setFlowId(token); + JSONObject difResult = (JSONObject) diFyService.getDiFyObject(diFyReq); + return difResult; + } + + /** + * 调用案件工作流 + */ + private JSONObject callCaseCommunityWorkFlow(DifyCommunityTargetDTO difyCommunityTargetDTO ,String user, String token) { + List aiAnalyticBusinessConfigs = aiAnalyticBusinessConfigMapper.selectList( + Wrappers.lambdaQuery() + .eq(AiAnalyticBusinessConfig::getBusinessLine, BusinessTypeEnum.COMMUNITYTARGET.getCode()) + .eq(AiAnalyticBusinessConfig::getConfigType, BusinessTypeEnum.CASE.getCode()) + .eq(AiAnalyticBusinessConfig::getIsDeleted, 0) + .eq(AiAnalyticBusinessConfig::getConfigVersion, 1) + ); + log.info("开始调用案件工作流,token: {}",token); + + //取出aiAnalyticBusinessConfigs里的所有configData + String configDataString = aiAnalyticBusinessConfigs.stream() + .map(AiAnalyticBusinessConfig::getConfigData) + .collect(Collectors.joining(" ")); + difyCommunityTargetDTO.setSentiment(configDataString); + DiFyReq diFyReq = new DiFyReq(); + diFyReq.setUser(user); + diFyReq.setInputs(difyCommunityTargetDTO); + diFyReq.setFlowId(token); + JSONObject difResult = (JSONObject) diFyService.getDiFyObject(diFyReq); + return difResult; + } + /** * 舆情数据脱敏 * @param textContent @@ -187,25 +265,28 @@ public class MqMessageRecordServiceImpl extends ServiceImpl().set("dify_response", caseResult.toJSONString()) + .eq("ai_analysis_request_id", aiAnalysisRequestId)); } } @@ -216,19 +297,12 @@ public class MqMessageRecordServiceImpl extends ServiceImpl().set("dify_response", difResult.toJSONString()) - .eq("ai_analysis_request_id", aiAnalysisRequestId)); - } - @Async protected void syncSaveRequestLogs(String message, String aiAnalysisRequestId) { aiAnalysisRequestLogsMapper.insert(AiAnalysisRequestLogs.builder() .aiAnalysisRequestId(aiAnalysisRequestId) .businessRequest(message) - .difyAgentKey(flowId) + .difyAgentKey(clueAnalysisToken+keywordToken+caseToken) .aiAnalysisRequestType(BusinessTypeEnum.COMMUNITYTARGET.getCode()) .build()); } @@ -434,7 +508,7 @@ public class MqMessageRecordServiceImpl extends ServiceImpl aiAnalysisErrors = aiAnalysisErrorsMapper.selectList(new LambdaQueryWrapper() .eq(AiAnalysisErrors::getAiAnalysisRequestType, BusinessTypeEnum.COMMUNITYTARGET.getCode()) .eq(AiAnalysisErrors::getAiAnalysisErrorHandlingStatus, "0") - .lt(AiAnalysisErrors::getRetryCount, 4)); + .lt(AiAnalysisErrors::getRetryCount, maxRetryCount)); if (aiAnalysisErrors != null && aiAnalysisErrors.size() > 0) { //根据ai_analysis_request_id获取AiAnalysisRequestLogs表中的对应的dify_request字段 for (AiAnalysisErrors aiAnalysisError : aiAnalysisErrors) { @@ -588,26 +662,25 @@ public class MqMessageRecordServiceImpl extends ServiceImpl() .eq(AiAnalysisErrors::getAiAnalysisRequestId, aiAnalysisError.getAiAnalysisRequestId()) .set(AiAnalysisErrors::getRetryCount, aiAnalysisError.getRetryCount() + 1) .set(AiAnalysisErrors::getAiAnalysisErrorHandlingStatus, "1")); + //根据ai_analysis_request_id更新tt_ai_analysis_request_logs表中的dify_response字段 + aiAnalysisRequestLogsMapper.update(new AiAnalysisRequestLogs(), new LambdaUpdateWrapper() + .eq(AiAnalysisRequestLogs::getAiAnalysisRequestId, aiAnalysisError.getAiAnalysisRequestId()) + .set(AiAnalysisRequestLogs::getDifyResponse, difyResult.toJSONString())); }else{ aiAnalysisErrorsMapper.update(new AiAnalysisErrors(), new LambdaUpdateWrapper() .eq(AiAnalysisErrors::getAiAnalysisRequestId, aiAnalysisError.getAiAnalysisRequestId()) diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmAnalysisResultServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmAnalysisResultServiceImpl.java index 4e6af71..81116b4 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmAnalysisResultServiceImpl.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmAnalysisResultServiceImpl.java @@ -24,6 +24,7 @@ public class TmAnalysisResultServiceImpl extends ServiceImpl 0; } else { + tmAnalysisResult.setId(oldTmCorpusReport.getId()); return tmCorpusReportMapper.update(tmAnalysisResult, queryWrapper) > 0; } } diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/utils/AiAnalysisUtils.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/utils/AiAnalysisUtils.java index 1d284ce..bf629f2 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/utils/AiAnalysisUtils.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/utils/AiAnalysisUtils.java @@ -1,18 +1,33 @@ package com.volvo.ai.analytic.center.utils; +import cn.hutool.core.lang.Snowflake; import cn.hutool.core.util.IdUtil; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Component; +import javax.annotation.PostConstruct; +import java.net.InetAddress; +import java.net.UnknownHostException; + @Slf4j @Component public class AiAnalysisUtils { - /** - * 生成ai分析请求id - * @param businessType - * @return - */ + private static Snowflake snowflake; + + @PostConstruct + public void init() { + try { + // 使用 IP 生成唯一的 workerId + long workerId = ipToWorkerId(getLocalHostIP()); + snowflake = IdUtil.getSnowflake(workerId, 0); // datacenterId = 0 + log.info("Initialized Snowflake with workerId: {}", workerId); + } catch (Exception e) { + log.error("Failed to initialize Snowflake", e); + throw new RuntimeException("Snowflake initialization failed"); + } + } + public static String getAiAnalysisRequestId(String businessType) { if (businessType == null || businessType.trim().isEmpty()) { log.error("businessType is null or empty, using default value 'unknown'"); @@ -20,18 +35,26 @@ public class AiAnalysisUtils { } try { - long snowflakeId = IdUtil.getSnowflakeNextId(); - if (snowflakeId == 0) { - log.error("Failed to generate Snowflake ID"); - throw new RuntimeException("Failed to generate Snowflake ID"); - } + // 使用自定义的 Snowflake 实例生成 ID + long snowflakeId = snowflake.nextId(); String aiAnalysisRequestId = businessType + "-" + snowflakeId; log.info("Generated AI analysis request ID: {}", aiAnalysisRequestId); return aiAnalysisRequestId; } catch (Exception e) { log.error("Error generating AI analysis request ID", e); - //生成唯一字符串 - return businessType + "-"+IdUtil.fastSimpleUUID(); + return businessType + "-" + IdUtil.fastSimpleUUID(); } } + + // 获取本机 IP + private static String getLocalHostIP() throws UnknownHostException { + return InetAddress.getLocalHost().getHostAddress(); + } + + // 将 IP 转换为合法的 workerId (0 ~ 31) + private static long ipToWorkerId(String ip) { + String[] parts = ip.replaceAll("[^\\d.]", "").split("\\."); + int lastOctet = Integer.parseInt(parts[parts.length - 1]); + return lastOctet % 32; // 限制范围 [0, 31] + } }