// Copyright (c) 2009 Dukascopy (Suisse) SA. All Rights Reserved.
package jforex.orders.sl;

import com.dukascopy.api.*;
import com.dukascopy.api.IEngine.OrderCommand;

/*
IMessage.Reasonsをチェックする為に以下2つのオーダーを行います。
  ・ ストップロスによるクローズ用のオーダー
  ・ 他要因(手動によるクローズ等)によるクローズ用のオーダー
*/
public class OrderClosedBySL implements IStrategy {

    private IConsole console;
    private IEngine engine;
    private IHistory history;
    private Instrument instrument = Instrument.EURUSD;

    @Override
    public void onStart(IContext context) throws JFException {
        console = context.getConsole();
        engine = context.getEngine();
        history = context.getHistory();

        // 成行買いオーダー(ストップロスでクローズする用)
        context.setSubscribedInstruments(java.util.Collections.singleton(instrument), true);
        IOrder order = engine.submitOrder("orderCloseBySL", instrument, OrderCommand.BUY, 0.001);
        order.waitForUpdate(2000, IOrder.State.FILLED);
        // 直ぐにストップロスに到達するように、近くにストップロスを設定する
        double slPrice = history.getLastTick(instrument).getAsk() + instrument.getPipValue() * 10;
        order.setStopLossPrice(slPrice);

        // 成行買いオーダー(手動でクローズする用)
        order = engine.submitOrder("orderUnconditionalClose", instrument, OrderCommand.BUY, 0.001);
        order.waitForUpdate(2000, IOrder.State.FILLED);
        order.close();
    }

    @Override
    public void onMessage(IMessage message) throws JFException {
        IOrder order = message.getOrder();
        if (order == null) {
            return;
        }
        console.getOut().println(message);
        if (message.getType() == IMessage.Type.ORDER_CLOSE_OK) {
            if (message.getReasons().contains(IMessage.Reason.ORDER_CLOSED_BY_SL)) {
                console.getInfo().println(order.getLabel() + " ストップロスによるクローズ");
            } else {
                console.getInfo().println(order.getLabel() + " ストップロス以外によるクローズ");
            }
        }
    }
    

    @Override
    public void onTick(Instrument instrument, ITick tick) throws JFException {}

    @Override
    public void onBar(Instrument instrument, Period period, IBar askBar, IBar bidBar) throws JFException {}

    @Override
    public void onAccount(IAccount account) throws JFException {}

    @Override
    public void onStop() throws JFException {}
}