定位不推lto。加日志getFlowId
This commit is contained in:
@@ -70,7 +70,7 @@ public class DiFyServiceImpl implements DiFyService{
|
|||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public synchronized JSONObject executeDifyFlow(DiFyReq diFyReq, String businessType, String businessData, String oldAiAnalysisRequestId) {
|
public JSONObject executeDifyFlow(DiFyReq diFyReq, String businessType, String businessData, String oldAiAnalysisRequestId) {
|
||||||
String aiAnalysisRequestId = StringUtils.isEmpty(oldAiAnalysisRequestId)? AiAnalysisUtils.getAiAnalysisRequestId(businessType):oldAiAnalysisRequestId;
|
String aiAnalysisRequestId = StringUtils.isEmpty(oldAiAnalysisRequestId)? AiAnalysisUtils.getAiAnalysisRequestId(businessType):oldAiAnalysisRequestId;
|
||||||
try {
|
try {
|
||||||
Map<String, String> inputMap = JSON.parseObject(JSONObject.toJSONString(diFyReq.getInputs()),Map.class);
|
Map<String, String> inputMap = JSON.parseObject(JSONObject.toJSONString(diFyReq.getInputs()),Map.class);
|
||||||
|
|||||||
@@ -193,6 +193,7 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
|
|||||||
CompletableFuture.runAsync(() -> {
|
CompletableFuture.runAsync(() -> {
|
||||||
try {
|
try {
|
||||||
log.info("铭牌语料可用许可授权数,客户画像场景={}", semaphore.availablePermits());
|
log.info("铭牌语料可用许可授权数,客户画像场景={}", semaphore.availablePermits());
|
||||||
|
Thread.sleep(2000);
|
||||||
// 获取许可 - 如果没有可用许可会阻塞等待
|
// 获取许可 - 如果没有可用许可会阻塞等待
|
||||||
semaphore.acquire();
|
semaphore.acquire();
|
||||||
// 创建新的DiFyReq对象以避免线程安全问题
|
// 创建新的DiFyReq对象以避免线程安全问题
|
||||||
|
|||||||
Reference in New Issue
Block a user