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

import java.util.List;
import com.dukascopy.api.*;
import com.dukascopy.api.util.*;

/*
 このストラテジーは、現在保有中のポジションに対して、
オープン価格の＋5pips上の価格レベルをティックレベルで何回上抜け又は下抜けしたかをカウントします。
その為、ストラテジー起動前に最低限1つ以上のポジションを保有している必要があります。

*/ 

public class PriceBreachAccordingToOrder implements IStrategy {
    
    @Configurable("通貨ペア")
    public Instrument instrument = Instrument.EURUSD;
    
    private IHistory history;
    private IConsole console;
    private IEngine engine;
    
    enum Location {
        ABOVE,     // 上
        BELOW      // 下
    }
    
    private Location priceLocation;
    private double priceLevel;

    @Override
    public void onStart(IContext context) throws JFException {
        history = context.getHistory();
        console = context.getConsole();   
        engine  = context.getEngine();
        context.setSubscribedInstruments(java.util.Collections.singleton(Instrument.EURUSD), true);
        
        ITick lastTick = history.getLastTick(instrument);
        for(IOrder order : engine.getOrders(instrument)){
            int breachCount = 0;
            int fallCount   = 0;
            // priceLevelにオープン価格＋5pipsをセット
            priceLevel = order.getOpenPrice() + instrument.getPipValue() * 5;

            List<ITick> ticks = history.getTicks(instrument, order.getFillTime(), lastTick.getTime());

            if(ticks == null || ticks.size() == 0){
                console.getErr().println("オーダー約定された時刻〜ラストティック時刻の間にティックがありませんでした。");
                continue;
            }
            
            priceLocation = ticks.get(0).getBid() >= priceLevel 
                    ? Location.ABOVE     // 最も古いティック価格が、priceLevelより上回っている
                    : Location.BELOW;

            ticks.remove(0); // 既に比較済みのティックについて、次のfor拡張ループで比較しないように削除
            
            for(ITick tick : ticks){
                if(priceLocation == Location.ABOVE && tick.getBid() < priceLevel){
                    priceLocation = Location.BELOW;
                    fallCount++;
                } else if(priceLocation == Location.BELOW && tick.getBid() > priceLevel){
                    priceLocation = Location.ABOVE;
                    breachCount++;
                }
            }
            console.getOut().println(String.format(
                "%sに約定された%sラベルのオーダーは、価格レベル%.5fを%s回上抜けし、%s回下抜けしました。", 
                DateUtils.format(order.getFillTime()),order.getLabel(),  priceLevel, breachCount, fallCount
            ));
        }
    }


    @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 onMessage(IMessage message) throws JFException {}

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

    @Override
    public void onStop() throws JFException {}

}