DIFY对轰，左右互搏之术-用智能体测试智能体

public CompositeFuture chatToAgent(RoutingContext rc) {    final QueryParam param  = rc.body().asJsonObject().mapTo(QueryParam.class);       Future<JsonObject> sourceFuture = service.selectByType("0",param.getAction())   .map(m -> buildJson(m,param));       Future<JsonObject> targetFuture = service.selectByType("1",param.getAction())     .map(m -> buildJson(m,param));         return     CompositeFuture.all(sourceFuture, targetFuture)      .onComplete(ar -> {              if (ar.succeeded()) {                   // 所有的Future都成功完成                JsonObject result1 = ar.result().resultAt(0);               JsonObject result2 = ar.result().resultAt(1);            EvevtParam build =  EvevtParam.builder().source(result1).target(result2).loop(param.getLoop()).pingId(IdUtil.fastSimpleUUID()).build();                      sendEventBusMessage( JsonObject.mapFrom(build));//异步发给seventBus                   ResponseUtils.buildOkResponse(rc,new Result<EvevtParam>().ok(build));              } else  {              // 至少有一个Future失败了                  Throwable cause = ar.cause();               ResponseUtils.buildErrorResponse(rc, cause);               } })             .onFailure(cause -> {                 // 错误统一处理                  ResponseUtils.buildErrorResponse(rc, cause);      });

vertx.eventBus().consumer("chat_to_dify").handler(message ->{            eventBusHandler.handlerStart(message);         });//模拟方都为 0vertx.eventBus().consumer("chat_to_0").handler(eventBusHandler::handler0);//业务方都为 1vertx.eventBus().consumer("chat_to_1").handler(eventBusHandler::handler1);

我们正在XXXXXX场景，由你（AI）扮演用户，你是用户，请牢记你是用户，我负责扮演XXXXX。工作人员（我）每次都回复了查询选项。但根据系统设定，当用户发送"开始扮演"时，你应该以用户身份提出具体查询请求。回顾规则：你扮演用户，每次对话只返回一句话的查询查询范围限于：1.xxxxxx2.xxxxxx3.xxxxxxx4.xxxxxxxxxxx某某：是yyy，nnn(业务需要的参数)使用自然口语，对以上范围进行润色上次你作为用户说了"查询我的余额"，现在我回复了余额查询的进展或数据。根据角色设定，你仍需以用户身份继续提出查询请求。用自然口语表达，不要用引号，一句话进行表达，不需要额外的场景，不需要额外的解释！