FX自動売買の自作

    private static String userName = "username"; // DEMO口座のログインID
    private static String password = "password"; // DEMO口座のパスワード
    instruments.add(Instrument.EURUSD); // tickデータの種類を指定、ドル円の場合はUSDJPYを設定
  

  oid execute(Parameter parameter) {
    process(
        () -> {
          try {
            var instrument = parameter.get("instrument", "USDJPY");
            if (parameter.is("from") && parameter.is("to")) {
              System.out.println("from to!");
              var from = parameter.getLocalDate("from");
              var to = parameter.getLocalDate("to");
              download(instrument, from, to);
            } else {
              System.out.println("date!");
              var date =
                  parameter.getLocalDate("date", dateTimeService.getLocalDate().minusDays(1));
              download(instrument, date);
            }
            System.out.println("download!");
          } catch (Exception e) {
            e.printStackTrace();
          }
        });
  }

  void download(String instrument, LocalDate from, LocalDate to)
      throws IOException, InterruptedException {
    System.out.println("from to !!");
    if (from.isAfter(to)) {
      throw new IllegalArgumentException("from <= to");
    }
    for (var date = from; date.isBefore(to); date = date.plusDays(1)) {
      System.out.println("date !!");
      download(instrument, date);
    }
  }

  void download(String instrument, LocalDate date) throws IOException, InterruptedException {
    System.out.println("download !!");

    for (int i = 0; i < 24; i++) {
      var file =
          new File(
              String.format("./%1$s/%2$tY/%2$tm/%2$td/%3$02dh_ticks.bi5", instrument, date, i));
      if (file.exists()) {
        System.out.println("ダウンロード済み:" + file.getCanonicalPath());
        continue;
      }
      download(
          String.format(
              "/%1$s/%2$tY/%3$02d/%2$td/%4$02dh_ticks.bi5",
              instrument, date, date.getMonthValue() - 1, i),
          file);
    }
  }

  /** 非同期だと503になるので */
  void download(String path, File saveFile) throws IOException, InterruptedException {
    System.out.println(path);
    var request = createRequestBuilder(path).GET().build();
    var response = client.send(request, BodyHandlers.ofByteArray());
    // .thenAccept(
    //         response -> {
    System.out.println("download!!!" + response.statusCode());
    if (response.statusCode() != 200) {
      return;
    }
    System.out.println("mkdirs:" + saveFile.getParentFile().mkdirs());
    try (var fos = new FileOutputStream(saveFile)) {
      fos.write(response.body());
      fos.flush();
    } catch (Exception e) {
      e.printStackTrace();
    }
    // });
  }

  HttpRequest.Builder createRequestBuilder(String path) {
    return HttpRequest.newBuilder().uri(createUri(path));
  }

  URI createUri(String path) {
    return URI.create("https://datafeed.dukascopy.com/datafeed" + path);
  }
}