| | |
| | | WcsDiagnosisRequest request = aiUtils.makeAiRequest(1000, "对当前系统进行巡检,如果有异常情况就进行详细的分析,如果没有异常情况则当成一次检查\n\n"); |
| | | wcsDiagnosisService.diagnoseStream(request, emitter); |
| | | } catch (Exception e) { |
| | | emitter.completeWithError(e); |
| | | try { emitter.complete(); } catch (Exception ignore) {} |
| | | } |
| | | }).start(); |
| | | |
| | |
| | | WcsDiagnosisRequest request = aiUtils.makeAiRequest(100, null); |
| | | wcsDiagnosisService.askStream(request, prompt, chatId, reset, emitter); |
| | | } catch (Exception e) { |
| | | emitter.completeWithError(e); |
| | | try { emitter.complete(); } catch (Exception ignore) {} |
| | | } |
| | | }).start(); |
| | | return emitter; |