|
@@ -267,6 +267,7 @@ public class GenerateInstructionService {
|
|
getInstructAnswerDTO.setClaims(claimStrs);
|
|
getInstructAnswerDTO.setClaims(claimStrs);
|
|
generateInstructAnswerVO = this.getAnswerFromAI(getInstructAnswerDTO);
|
|
generateInstructAnswerVO = this.getAnswerFromAI(getInstructAnswerDTO);
|
|
String answer = generateInstructAnswerVO.getAnswer();
|
|
String answer = generateInstructAnswerVO.getAnswer();
|
|
|
|
+ System.out.println("answer:"+answer);
|
|
generateTechnicalVO = JSONObject.parseObject(answer, GenerateTechnicalVO.class);
|
|
generateTechnicalVO = JSONObject.parseObject(answer, GenerateTechnicalVO.class);
|
|
} catch (Exception e) {
|
|
} catch (Exception e) {
|
|
e.printStackTrace();
|
|
e.printStackTrace();
|
|
@@ -277,12 +278,15 @@ public class GenerateInstructionService {
|
|
generateInstructAnswerVO.setTechnical(generateTechnicalVO.getTechnical());
|
|
generateInstructAnswerVO.setTechnical(generateTechnicalVO.getTechnical());
|
|
|
|
|
|
String message = "";
|
|
String message = "";
|
|
|
|
+
|
|
if (ifError) {
|
|
if (ifError) {
|
|
message = getFluxMessage(FIELD_TITLE, ERROR, "生成标题异常");
|
|
message = getFluxMessage(FIELD_TITLE, ERROR, "生成标题异常");
|
|
} else {
|
|
} else {
|
|
message = getFluxMessage(FIELD_TITLE, MESSAGE, generateTechnicalVO.getTitle());
|
|
message = getFluxMessage(FIELD_TITLE, MESSAGE, generateTechnicalVO.getTitle());
|
|
}
|
|
}
|
|
|
|
+ System.out.println("send Message:"+message);
|
|
fluxSink.next(message);
|
|
fluxSink.next(message);
|
|
|
|
+ System.out.println("send Message End");
|
|
String endMessage = getFluxMessage(FIELD_TITLE, END, "");
|
|
String endMessage = getFluxMessage(FIELD_TITLE, END, "");
|
|
fluxSink.next(endMessage);
|
|
fluxSink.next(endMessage);
|
|
String startMessage2 = getFluxMessage(FIELD_TECHNICAL, START, "");
|
|
String startMessage2 = getFluxMessage(FIELD_TECHNICAL, START, "");
|
|
@@ -484,6 +488,7 @@ public class GenerateInstructionService {
|
|
Integer cycle = 0;
|
|
Integer cycle = 0;
|
|
Boolean flag = false;
|
|
Boolean flag = false;
|
|
String re = "";
|
|
String re = "";
|
|
|
|
+ System.out.println("start request");
|
|
while (cycle < 5 && flag == false) {
|
|
while (cycle < 5 && flag == false) {
|
|
re = difyService.chatMessage(difyChatMessageDTO, gInstructionKey);
|
|
re = difyService.chatMessage(difyChatMessageDTO, gInstructionKey);
|
|
JSONObject jsonObject = JSONObject.parseObject(re);
|
|
JSONObject jsonObject = JSONObject.parseObject(re);
|
|
@@ -499,7 +504,7 @@ public class GenerateInstructionService {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
-
|
|
|
|
|
|
+ System.out.println("end request");
|
|
return generateInstructAnswerVO;
|
|
return generateInstructAnswerVO;
|
|
}
|
|
}
|
|
|
|
|