job.h

/*
** Copyright 2007-2024, RTE (https://www.rte-france.com)
** See AUTHORS.txt
** SPDX-License-Identifier: MPL-2.0
** This file is part of Antares-Simulator,
** Adequacy and Performance assessment for interconnected energy networks.
**
** Antares_Simulator is free software: you can redistribute it and/or modify
** it under the terms of the Mozilla Public Licence 2.0 as published by
** the Mozilla Foundation, either version 2 of the License, or
** (at your option) any later version.
**
** Antares_Simulator is distributed in the hope that it will be useful,
** but WITHOUT ANY WARRANTY; without even the implied warranty of
** MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
** Mozilla Public Licence 2.0 for more details.
**
** You should have received a copy of the Mozilla Public Licence 2.0
** along with Antares_Simulator. If not, see <https://opensource.org/license/mpl-2-0/>.
*/
#ifndef __STUDY_JOB_AGGREGATOR_JOB_H__
#define __STUDY_JOB_AGGREGATOR_JOB_H__
 
#include <memory>
 
#include <yuni/yuni.h>
#include <yuni/core/string.h>
#include <yuni/io/file.h>
#include <yuni/job/job.h>
#include <yuni/job/queue/service.h>
 
#include "antares/solver/ts-generator/xcast/studydata.h"
 
#include "datafile.h"
#include "output.h"
 
class JobFileReader final: public Yuni::Job::IJob
{
public:
    using Ptr = std::shared_ptr<JobFileReader>;
 
    enum
    {
        maxRows = 8800,
    };
 
    static bool RemainJobsToExecute();
 
public:
 
 
    JobFileReader();
    virtual ~JobFileReader();
 
public:
    uint year;
    DataFile::Ptr datafile;
    Output::Ptr output;
    StudyData::Ptr studydata;
    Yuni::String path;
 
protected:
    virtual void onExecute() override;
 
private:
    bool openCSVFile();
    bool prepareJumpTable();
 
    bool readRawData();
 
    void readLine(const AnyString& line, uint y);
 
    bool storeResults();
 
    void resizeJumpTable(uint newsize);
 
private:
    using TemporaryColumnData = CellData*;
    using BufferType = Yuni::CString<65536>;
    using JumpTable = std::vector<uint>;
 
private:
    BufferType buffer;
    Yuni::IO::File::Stream pFile;
    Yuni::String pFilename;
    JumpTable pJumpTable;
    bool* pVariablesOn;
    uint pDataOffset;
    TemporaryColumnData* pTmpResults;
    uint pLineCount;
 
}; // class JobFileReader
 
extern Yuni::Job::QueueService queueService;
 
#include "job.hxx"
 
#endif // __STUDY_JOB_AGGREGATOR_JOB_H__