// 構造体型宣言
struct struct_rci_data {                         // RCI算出用構造体
    datetime date_value;                        // 日付
    double   rate_value;                        // 価格
    int      rank_date;                         // 日付順位
    int      rank_rate;                         // 価格順位
    double   rank_adjust_rate;                  // 価格順位(調整後)
};

// enum列挙型宣言
enum ENUM_LINECOUNT {                           // RCI表示本数
    RCI_DISPLINE_1 = 1,                         // 1本(短期のみ)
    RCI_DISPLINE_2,                             // 2本(短期,中期)
    RCI_DISPLINE_3                              // 3本(短期,中期,長期)
};

// インプットパラメータ
input  int              _InputCalPeriod_S      = 9;                 // 算出期間[短期]
input  int              _InputCalPeriod_M      = 26;                // 算出期間[中期]
input  int              _InputCalPeriod_L      = 52;                // 算出期間[長期]
sinput ENUM_LINECOUNT _InputLineCount        = RCI_DISPLINE_3;  // RCI表示本数

    // temp_indname = StringFormat( "%s(%d)" , file_name , _InputCalPeriod ); // インジケータ短縮名

/*
        double get_value = iRSI (           // RSI算出
                             Symbol(),      // 通貨ペア
                             Period(),      // 時間軸
                             _InputCalPeriod, // 算出期間
                             PRICE_CLOSE,   // 適用価格
                             icount          // シフト
                        );
        _IndBuffer1[icount] = get_value;       // インジケータ1に算出結果を設定
*/

// インジケータプロパティ設定
#property  indicator_buffers    3               // カスタムインジケータのバッファ数
#property  indicator_color1     clrWhite      // インジケータ1の色
#property  indicator_width1     1               // インジケータ1の太さ

#property  indicator_color2     clrYellow      // インジケータ2の色
#property  indicator_width2     1               // インジケータ2の太さ

#property  indicator_color3     clrMagenta     // インジケータ3の色
#property  indicator_width3     1               // インジケータ3の太さ

#property  indicator_minimum  -100               // サブウインドウスケール下限値設定
#property  indicator_maximum   100               // サブウインドウスケール上限値設定

// レベルライン設定
#property  indicator_level1     0                 // レベルライン1
#property  indicator_level2    80                 // レベルライン2
#property  indicator_level3   -80                 // レベルライン3

//+------------------------------------------------------------------+
//| インジケータ短縮名を取得する
//+------------------------------------------------------------------+
string GetShortName()
{
    string file_name;                           // ファイル名(拡張子無し)
    string str_array[];                         // 文字列分離取得用動的配列
    string input_str;                           // インプットパラメータ用文字列
    string ret_name;                            // インジケータ短縮名
    int    get_arraycount;                      // 分割配列数
    
    get_arraycount = StringSplit( __FILE__ , '.' , str_array );  // ファイル名を拡張子で分離
    
    if ( get_arraycount > 0 ) {                 // 文字列分離成功していた場合
        file_name = str_array[0];               // ファイル名に分離した最初の文字列を設定
    }
    
    // インプットパラメータ値を結合した文字列を作成
    input_str = (string)_InputCalPeriod_S;

    if ( _InputLineCount >= RCI_DISPLINE_2 ) {
        input_str += StringFormat( ",%d" , _InputCalPeriod_M );
    }

    if ( _InputLineCount >= RCI_DISPLINE_3 ) {
        input_str += StringFormat( ",%d" , _InputCalPeriod_L );
    }
    
    ret_name = StringFormat( "%s(%s)" , file_name , input_str ); // インジケータ短縮名

    return ret_name;

}

//+------------------------------------------------------------------+
//| OnInit(初期化)イベント
//+------------------------------------------------------------------+
int OnInit()
{
    IndicatorSetString( INDICATOR_SHORTNAME  , GetShortName() );// インジケータ短縮名設定

    SetIndexBuffer( 0, _IndBuffer1 );     // インジケータ1表示用動的配列をインジケータ1にバインドする

    return( INIT_SUCCEEDED );           // 戻り値：初期化成功
}

// インジケータ表示用動的配列
double     _IndBuffer1[];                          // インジケータ1表示用動的配列
double     _IndBuffer2[];                          // インジケータ2表示用動的配列
double     _IndBuffer3[];                          // インジケータ3表示用動的配列

    SetIndexBuffer( 0, _IndBuffer1 );     // インジケータ1表示用動的配列をインジケータ1にバインドする
    SetIndexBuffer( 1, _IndBuffer2 );     // インジケータ2表示用動的配列をインジケータ2にバインドする
    SetIndexBuffer( 2, _IndBuffer3 );     // インジケータ3表示用動的配列をインジケータ3にバインドする

//+------------------------------------------------------------------+
//| RCI(Rank Correlation Index)を算出する[配列ベース]
//+------------------------------------------------------------------+
double CalRCI( 
                const double &in_array[],         // インプット変数配列アドレス
                       int     in_time_period ,    // 算出期間
                       int     in_index            // インデックス
                       )
{
    double ret = 0;   // 戻り値

    int    array_count = ArraySize(in_array);       // 配列要素数取得
    int    end_index = in_index + in_time_period;    // ループエンド

    if ( end_index < array_count ) {                  // 配列範囲内チェック

        //ここに処理を追加する

    }

    return ret;       // 戻り値を返す
}

    struct_rci_data  temp_st_rci[];                                         // RCI算出用構造体動的配列
    int arrayst_count = ArrayResize(                    // 動的配列サイズ変更
                                       temp_st_rci ,      // 変更する配列
                                       in_time_period ,   // 新しい配列サイズ
                                       0                  // 予備サイズ
                                      );

        // データ設定
        int temp_rank = 1;
        int arr_count = 0;
        for ( int icount = in_index ; icount < end_index ; icount++  ) {
            temp_st_rci[arr_count].date_value = Time[icount];        // 日付データ設定
            temp_st_rci[arr_count].rate_value = in_array[icount];    // 価格データ設定
            temp_st_rci[arr_count].rank_date  = temp_rank;           // 日付順位(ランク)設定
            temp_rank++;
            arr_count++;
        }

        // 価格順ソート
        for ( int main_count = 0; main_count < arrayst_count - 1 ; main_count++ ) {
            for ( int sub_count = main_count + 1; sub_count < arrayst_count ; sub_count++ ) {

                // 次の配列メンバと比較して小さい場合
                if ( temp_st_rci[main_count].rate_value < temp_st_rci[sub_count].rate_value ) {

                    // 構造体配列を入れ替える
                    struct_rci_data temp_swap  = temp_st_rci[main_count];      // 比較元のデータ退避
                    temp_st_rci[main_count]    = temp_st_rci[sub_count];       // 比較元のデータ入れ替え
                    temp_st_rci[sub_count]     = temp_swap;                    // 比較先に退避データをセット
                }
            }
        }

        // 価格RANK設定
        for( int main_count = 0; main_count < arrayst_count ; main_count++ ) {
            int temp_set_rank = main_count + 1;
            temp_st_rci[main_count].rank_rate        = temp_set_rank;
            temp_st_rci[main_count].rank_adjust_rate = (double)temp_set_rank;
        }

        // 価格RANKの同値調整
        for ( int main_count = 0 ; main_count < arrayst_count - 1 ; main_count++ ) {
            double sum_rank   = (double)temp_st_rci[main_count].rank_rate;     // ランクサマリー
            int    same_count = 0;                                              // 同値検出カウント

            for ( int sub_count = main_count + 1 ; sub_count < arrayst_count ; sub_count++ ) {

                if ( temp_st_rci[main_count].rate_value == temp_st_rci[sub_count].rate_value ) { // 同値の場合
                    sum_rank += (double)temp_st_rci[sub_count].rank_rate;       // ランクサマリーにランクを加算
                    same_count++;                                                // 同値検出カウントをインクリメント
                } else {                                                        // 同値以外の場合

                    break;                                                      // 同値の場合forループから抜ける
                }
            }

            if ( same_count >= 1 ) {                                             // 同値価格が1つ以上ある場合
                double set_adjust_rank = sum_rank / ((double)same_count + 1);   // ランクの中間値を算出

                for( int ad_count = 0 ; ad_count <= same_count; ad_count++ ) {  // 同値検出カウント分ループ
                    // 価格順位(調整後)に中間値を設定
                    temp_st_rci[ad_count + main_count].rank_adjust_rate = set_adjust_rank; 
                }

                main_count += same_count;                         // メインループを同値検出カウント分スキップさせる
            }
        }

    if ( temp_st_rci[main_count].rate_value == temp_st_rci[sub_count].rate_value ) { // 同値の場合

        // RCIのd算出
        double sum_d     = 0;
        double temp_diff = 0;
        for( int main_count = 0; main_count < arrayst_count ; main_count++ ) {
            temp_diff = (double)temp_st_rci[main_count].rank_date - temp_st_rci[main_count].rank_adjust_rate;
            sum_d += MathPow( temp_diff , 2 );
        }

        // RCIのn(n^2 - 1)算出
        int temp_div = in_time_period * ( (int)MathPow( in_time_period , 2 ) - 1 );

        // RCIを算出
        if ( temp_div > 0) {            // 0除算対策
            ret = 100 * ( 1 - ( 6 * sum_d / (double)temp_div ) );
        }

         double get_value;

         // 短期RCIを算出してインジケータバッファに設定
         get_value = CalRCI (                   // RCI算出
                             Close,            // 変数配列アドレス
                             _InputCalPeriod_S, // 算出期間
                             icount             // シフト
                        );

        _IndBuffer1[icount] = get_value;       // インジケータ1に算出結果を設定

        // 中期RCIを算出してインジケータバッファに設定
        if ( _InputLineCount >= RCI_DISPLINE_2 ) {
             get_value = CalRCI (                   // RCI算出
                                 Close,            // 変数配列アドレス
                                 _InputCalPeriod_M, // 算出期間
                                 icount             // シフト
                            );

            _IndBuffer2[icount] = get_value;       // インジケータ2に算出結果を設定
        }

        // 長期RCIを算出してインジケータバッファに設定
        if ( _InputLineCount >= RCI_DISPLINE_3 ) {
             get_value = CalRCI (                   // RCI算出
                                 Close,            // 変数配列アドレス
                                 _InputCalPeriod_L, // 算出期間
                                 icount             // シフト
                            );

            _IndBuffer3[icount] = get_value;       // インジケータ3に算出結果を設定
        }

//+------------------------------------------------------------------+
//|                                               TestSubSelfRCI.mq4 |
//|                                                             yuki |
//|                                      https://yukifx.web.fc2.com/ |
//+------------------------------------------------------------------+
#property copyright "yuki"
#property link      "https://yukifx.web.fc2.com/"
#property version   "1.00"
#property strict // strictは絶対に削除しない事
#property indicator_separate_window // カスタムインジケータをサブウインドウに表示する

// インジケータプロパティ設定
#property  indicator_buffers    3               // カスタムインジケータのバッファ数
#property  indicator_color1     clrWhite      // インジケータ1の色
#property  indicator_width1     1               // インジケータ1の太さ

#property  indicator_color2     clrYellow     // インジケータ2の色
#property  indicator_width2     1               // インジケータ2の太さ

#property  indicator_color3     clrMagenta    // インジケータ3の色
#property  indicator_width3     1               // インジケータ3の太さ

#property  indicator_minimum  -100              // サブウインドウスケール下限値設定
#property  indicator_maximum   100              // サブウインドウスケール上限値設定

// レベルライン設定
#property  indicator_level1     0               // レベルライン1
#property  indicator_level2    80               // レベルライン2
#property  indicator_level3   -80               // レベルライン3

#property  indicator_levelcolor   clrGray     // レベルラインの色
#property  indicator_levelstyle STYLE_DOT     // レベルラインの種類
#property  indicator_levelwidth         1      // レベルラインの太さ


// マクロ定義
#define    IND_MIN_INDEX         2               // 最小バー数

// インジケータ表示用動的配列
double     _IndBuffer1[];                          // インジケータ1表示用動的配列
double     _IndBuffer2[];                          // インジケータ2表示用動的配列
double     _IndBuffer3[];                          // インジケータ3表示用動的配列

// 構造体型宣言
struct struct_rci_data {                         // RCI算出用構造体
    datetime date_value;                        // 日付
    double   rate_value;                         // 価格
    int      rank_date;                          // 日付順位
    int      rank_rate;                          // 価格順位
    double   rank_adjust_rate;                  // 価格順位(調整後)
};

// enum列挙型宣言
enum ENUM_LINECOUNT {                           // RCI表示本数
    RCI_DISPLINE_1 = 1,                         // 1本(短期のみ)
    RCI_DISPLINE_2,                             // 2本(短期,中期)
    RCI_DISPLINE_3                              // 3本(短期,中期,長期)
};

// インプットパラメータ
input  int              _InputCalPeriod_S      = 9;                  // 算出期間[短期]
input  int              _InputCalPeriod_M      = 26;                 // 算出期間[中期]
input  int              _InputCalPeriod_L      = 52;                 // 算出期間[長期]
sinput ENUM_LINECOUNT _InputLineCount        = RCI_DISPLINE_3;   // RCI表示本数

//+------------------------------------------------------------------+
//| OnInit(初期化)イベント
//+------------------------------------------------------------------+
int OnInit()
{
    IndicatorSetString( INDICATOR_SHORTNAME  , GetShortName() );// インジケータ短縮名設定

    SetIndexBuffer( 0, _IndBuffer1 );     // インジケータ1表示用動的配列をインジケータ1にバインドする
    SetIndexBuffer( 1, _IndBuffer2 );     // インジケータ2表示用動的配列をインジケータ2にバインドする
    SetIndexBuffer( 2, _IndBuffer3 );     // インジケータ3表示用動的配列をインジケータ3にバインドする

    return( INIT_SUCCEEDED );      // 戻り値：初期化成功
}

//+------------------------------------------------------------------+
//| OnCalculate(tick受信)イベント
//| カスタムインジケータ専用のイベント関数
//+------------------------------------------------------------------+
int OnCalculate(const int     rates_total,      // 入力された時系列のバー数
                const int       prev_calculated,  // 計算済み(前回呼び出し時)のバー数
                const datetime &time[],          // 時間
                const double   &open[],          // 始値
                const double   &high[],          // 高値
                const double   &low[],           // 安値
                const double   &close[],         // 終値
                const long     &tick_volume[],   // Tick出来高
                const long     &volume[],        // Real出来高
                const int      &spread[])        // スプレッド
{
    int end_index = Bars - prev_calculated;  // バー数取得(未計算分)
    if ( end_index <= IND_MIN_INDEX ) {    // 直近数本は常時更新
        end_index = IND_MIN_INDEX;
    }

    if ( Bars <= IND_MIN_INDEX ) {         // ヒストリカルデータ不足時
        return 0;                            // 全て再計算が必要なので、計算済みバー数を0にして終了する
    }

    for( int icount = 0 ; icount < end_index ; icount++ ) {
         double get_value;

         // 短期RCIを算出してインジケータバッファに設定
         get_value = CalRCI (                   // RCI算出
                             Close,            // 変数配列アドレス
                             _InputCalPeriod_S, // 算出期間
                             icount             // シフト
                        );

        _IndBuffer1[icount] = get_value;       // インジケータ1に算出結果を設定

        // 中期RCIを算出してインジケータバッファに設定
        if ( _InputLineCount >= RCI_DISPLINE_2 ) {
             get_value = CalRCI (                   // RCI算出
                                 Close,            // 変数配列アドレス
                                 _InputCalPeriod_M, // 算出期間
                                 icount             // シフト
                            );

            _IndBuffer2[icount] = get_value;       // インジケータ2に算出結果を設定
        }

        // 長期RCIを算出してインジケータバッファに設定
        if ( _InputLineCount >= RCI_DISPLINE_3 ) {
             get_value = CalRCI (                   // RCI算出
                                 Close,            // 変数配列アドレス
                                 _InputCalPeriod_L, // 算出期間
                                 icount             // シフト
                            );

            _IndBuffer3[icount] = get_value;       // インジケータ3に算出結果を設定
        }
    }

   return( rates_total ); // 戻り値設定：次回OnCalculate関数が呼ばれた時のprev_calculatedの値に渡される
}

//+------------------------------------------------------------------+
//| RCI(Rank Correlation Index)を算出する[配列ベース]
//+------------------------------------------------------------------+
double CalRCI( 
                const double &in_array[],         // インプット変数配列アドレス
                       int     in_time_period ,    // 算出期間
                       int     in_index            // インデックス
                       )
{
    double ret = 0;   // 戻り値

    int    array_count = ArraySize(in_array);       // 配列要素数取得
    int    end_index = in_index + in_time_period;    // ループエンド

    if ( end_index < array_count ) {                  // 配列範囲内チェック

        struct_rci_data  temp_st_rci[];                       // RCI算出用構造体動的配列
        int arrayst_count = ArrayResize(                    // 動的配列サイズ変更
                                           temp_st_rci ,      // 変更する配列
                                           in_time_period ,   // 新しい配列サイズ
                                           0                  // 予備サイズ
                                          );

        // データ設定
        int temp_rank = 1;
        int arr_count = 0;
        for ( int icount = in_index ; icount < end_index ; icount++  ) {
            temp_st_rci[arr_count].date_value = Time[icount];        // 日付データ設定
            temp_st_rci[arr_count].rate_value = in_array[icount];    // 価格データ設定
            temp_st_rci[arr_count].rank_date  = temp_rank;           // 日付順位(ランク)設定
            temp_rank++;
            arr_count++;
        }


        // 価格順ソート
        for ( int main_count = 0; main_count < arrayst_count - 1 ; main_count++ ) {
            for ( int sub_count = main_count + 1; sub_count < arrayst_count ; sub_count++ ) {

                // 次の配列メンバと比較して小さい場合
                if ( temp_st_rci[main_count].rate_value < temp_st_rci[sub_count].rate_value ) {

                    // 構造体配列を入れ替える
                    struct_rci_data temp_swap  = temp_st_rci[main_count];      // 比較元のデータ退避
                    temp_st_rci[main_count]    = temp_st_rci[sub_count];       // 比較元のデータ入れ替え
                    temp_st_rci[sub_count]     = temp_swap;                    // 比較先に退避データをセット
                }
            }
        }


        // 価格RANK設定
        for( int main_count = 0; main_count < arrayst_count ; main_count++ ) {
            int temp_set_rank = main_count + 1;
            temp_st_rci[main_count].rank_rate = temp_set_rank;
            temp_st_rci[main_count].rank_adjust_rate = (double)temp_set_rank;
        }


        // 価格RANKの同値調整
        for ( int main_count = 0 ; main_count < arrayst_count - 1 ; main_count++ ) {
            double sum_rank   = (double)temp_st_rci[main_count].rank_rate;     // ランクサマリー
            int    same_count = 0;                                              // 同値検出カウント

            for ( int sub_count = main_count + 1 ; sub_count < arrayst_count ; sub_count++ ) {

                if ( temp_st_rci[main_count].rate_value == temp_st_rci[sub_count].rate_value ) { // 同値の場合
                    sum_rank += (double)temp_st_rci[sub_count].rank_rate;       // ランクサマリーにランクを加算
                    same_count++;                                                // 同値検出カウントをインクリメント
                } else {                                                        // 同値以外の場合

                    break;                                                      // 同値の場合forループから抜ける
                }
            }

            if ( same_count >= 1 ) {                                             // 同値価格が1つ以上ある場合
                double set_adjust_rank = sum_rank / ((double)same_count + 1);   // ランクの中間値を算出

                for( int ad_count = 0 ; ad_count <= same_count; ad_count++ ) {  // 同値検出カウント分ループ
                    // 価格順位(調整後)に中間値を設定
                    temp_st_rci[ad_count + main_count].rank_adjust_rate = set_adjust_rank; 
                }

                main_count += same_count;                         // メインループを同値検出カウント分スキップさせる
            }
        }


        // RCIのd算出
        double sum_d = 0;
        double temp_diff = 0;
        for( int main_count = 0; main_count < arrayst_count ; main_count++ ) {
            temp_diff = (double)temp_st_rci[main_count].rank_date - temp_st_rci[main_count].rank_adjust_rate;
            sum_d += MathPow( temp_diff , 2 );
        }

        // RCIのn(n^2 - 1)算出
        int temp_div = in_time_period * ( (int)MathPow( in_time_period , 2 ) - 1 );

        // RCIを算出
        if ( temp_div > 0) {            // 0除算対策
            ret = 100 * ( 1 - ( 6 * sum_d / (double)temp_div ) );
        }


    }

    return ret;       // 戻り値を返す
}

//+------------------------------------------------------------------+
//| インジケータ短縮名を取得する
//+------------------------------------------------------------------+
string GetShortName()
{
    string file_name;                           // ファイル名(拡張子無し)
    string str_array[];                         // 文字列分離取得用動的配列
    string input_str;                           // インプットパラメータ用文字列
    string ret_name;                            // インジケータ短縮名
    int    get_arraycount;                      // 分割配列数
    
    get_arraycount = StringSplit( __FILE__ , '.' , str_array );  // ファイル名を拡張子で分離
    
    if ( get_arraycount > 0 ) {                 // 文字列分離成功していた場合
        file_name = str_array[0];               // ファイル名に分離した最初の文字列を設定
    }
    
    // インプットパラメータ値を結合した文字列を作成
    input_str = (string)_InputCalPeriod_S;

    if ( _InputLineCount >= RCI_DISPLINE_2 ) {
        input_str += StringFormat( ",%d" , _InputCalPeriod_M );
    }

    if ( _InputLineCount >= RCI_DISPLINE_3 ) {
        input_str += StringFormat( ",%d" , _InputCalPeriod_L );
    }
    
    ret_name = StringFormat( "%s(%s)" , file_name , input_str ); // インジケータ短縮名

    return ret_name;

}