前処理のソースコード

#include <fstream>
#include <string>
#include <vector>
#include <iostream>
#include "1_preprocessing_function.h"
#include "csv_import.h"

using namespace std;

// ==================================================================================
// 実行プログラム
// ==================================================================================
int main()
{
    //-------------------------------------------------------------------------------
    // インターフェース
    string input_file_name;
    cout << "Enter raw data file name" << endl;
    cin  >> input_file_name;

    //-------------------------------------------------------------------------------
    // csv取り込み
    vector<float> time, input, output;
    vector< vector<float> >  data = csv_import( input_file_name );
    
    for (int k=0; k<data[0].size(); k++ )
    {
          time.push_back( data[0][k] );
         input.push_back( data[1][k] );
        output.push_back( data[2][k] );
    }

    //-------------------------------------------------------------------------------
    // トレンド除去
    vector<float>  input_remove_trend  = remove_trend( input  );
    vector<float>  output_remove_trend = remove_trend( output );

    //-------------------------------------------------------------------------------
    // ローパスフィルタ
    ifstream inputfile( "./data_strage/0_0_condition.csv" );
    string   line;

    getline(inputfile, line);
    vector<string> strvec = split(line, ',');  
    float band_width = stof( strvec[1] ); // カットオフ周波数の読み取り
    float sampling   = time[1] - time[0]; // サンプリング周期の読み取り

    vector<float> input_LPF  = low_pass_filter( input_remove_trend,  band_width, sampling );
    vector<float> output_LPF = low_pass_filter( output_remove_trend, band_width, sampling );
    
    //-------------------------------------------------------------------------------
    // csv出力（全データ）
    ofstream outputfile("./data_strage/1_process_data_all.csv");

    outputfile << "time[sec]" << "," << "input" << "," << "output" << endl;
    for ( int k=0; k<time.size(); k++ )
    {
        outputfile << time[k]       << ",";
        outputfile << input_LPF[k]  << ",";
        outputfile << output_LPF[k] << endl;
    }

    //-------------------------------------------------------------------------------
    // csv出力（クロスバリデーション）
    ofstream outputfile1("./data_strage/1_process_data_analysis.csv");
    ofstream outputfile2("./data_strage/1_process_data_validation.csv");

    outputfile1 << "time[sec]" << "," << "input" << "," << "output" << endl;
    outputfile2 << "time[sec]" << "," << "input" << "," << "output" << endl;
    for ( int k=0; k<time.size(); k++ )
    {
        // 解析用データ
        if ( ( time[k]>=1 )&&( time[k]<=time[ time.size()*0.5 + 0.5*1/sampling ] ) )
        {
            outputfile1 << time[k]       << ",";
            outputfile1 << input_LPF[k]  << ",";
            outputfile1 << output_LPF[k] << ",";
            outputfile1 << endl;
        }

        // バリデーション用データ
        else
        {
            outputfile2 << time[k]       << ",";
            outputfile2 << input_LPF[k]  << ",";
            outputfile2 << output_LPF[k] << ",";
            outputfile2 << endl;
        }
    }

    cout << "Preprocessing is completed" << endl;
}

#include <vector>
using namespace std;

// 平均値計算------------------------------------------------------------------------------------
float average_calc( vector<float> input );

// トレンドの除去--------------------------------------------------------------------------------
vector<float> remove_trend( vector<float> input );

// ローパスフィルタ------------------------------------------------------------------------------
vector<float> low_pass_filter( vector<float> input, float band_width, float sampling );

#include <vector>
using namespace std;

// 平均値計算---------------------------------------------------------------------------------
float average_calc( vector<float> data )
{
    float sum = 0, result = 0;

    for ( int k = 0; k<data.size(); k++ )
    {
        sum += data[k];
    }
    result = sum / data.size();
    return result;
}

#include <vector>
#include "1_preprocessing_function.h"
using namespace std;

// トレンドの除去--------------------------------------------------------------
vector<float> remove_trend( vector<float> data )
{
    float average_value = average_calc( data );
    vector<float> result;

    for ( int k=0; k<data.size(); k++ )
    {
        result.push_back( data[k] - average_value );
    }
    return result;
}

#include <vector>
#include <bits/stdc++.h>
using namespace std;

const double  pi = acos(-1);

// ローパスフィルタ--------------------------------------------------------------------------------
vector<float> low_pass_filter( vector<float> data, float band_width, float sampling )
{
    vector<float> result;
    float time_constant = 1 / ( 2*pi*band_width );
    float             a = time_constant / ( sampling - time_constant );

    result.push_back( data[0] );

    for ( int k=1; k<data.size(); k++ )
    {
        result.push_back( a * result[k-1] + ( 1-a ) * data[k] );
    }
    return result;
}