企微企微语料问题 ,加日志
This commit is contained in:
@@ -69,6 +69,10 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl<TmNameplateCorpusM
|
|||||||
@Autowired
|
@Autowired
|
||||||
private DataMaskingRuleService dataMaskingRuleService;
|
private DataMaskingRuleService dataMaskingRuleService;
|
||||||
|
|
||||||
|
private String outputsFinal = "outputs";
|
||||||
|
private String aiAnalysisRequestIdFinal = "aiAnalysisRequestId";
|
||||||
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void runNameplateCorpusDifyRetry(String paramJson) {
|
public void runNameplateCorpusDifyRetry(String paramJson) {
|
||||||
long startTime = System.currentTimeMillis();
|
long startTime = System.currentTimeMillis();
|
||||||
@@ -162,7 +166,7 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl<TmNameplateCorpusM
|
|||||||
|
|
||||||
// 使用多线程并行执行两个业务场景
|
// 使用多线程并行执行两个业务场景
|
||||||
ExecutorService executorService = Executors.newFixedThreadPool(2);
|
ExecutorService executorService = Executors.newFixedThreadPool(2);
|
||||||
log.info("第1个业务场景, 优先执行。 ");
|
log.info("铭牌语料第1个业务场景, 优先执行。 ");
|
||||||
long startTime = System.currentTimeMillis();
|
long startTime = System.currentTimeMillis();
|
||||||
CompletableFuture.runAsync(() -> {
|
CompletableFuture.runAsync(() -> {
|
||||||
//第一个业务场景 开始: 总结和分类业务场景
|
//第一个业务场景 开始: 总结和分类业务场景
|
||||||
@@ -205,8 +209,6 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl<TmNameplateCorpusM
|
|||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
String outputsFinal = "outputs";
|
|
||||||
String aiAnalysisRequestIdFinal = "aiAnalysisRequestId";
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void sendNameplateLto(JSONObject execDifyFlow, String aiAnalysisRequestId, TmNameplateCorpus tmNameplateCorpus, String businessType) {
|
public void sendNameplateLto(JSONObject execDifyFlow, String aiAnalysisRequestId, TmNameplateCorpus tmNameplateCorpus, String businessType) {
|
||||||
|
|||||||
Reference in New Issue
Block a user