package com.flexsoft.fs.dataprocessing.service.loading.debtors;
import com.flexsoft.fs.dataprocessing.service.loading.debtors.DebtorsLoader;
import com.flexsoft.fs.dataprocessing.service.history.History

public class TerritoriaComforta extends DebtorsLoader{
   
    //Номер провайдера в системе (обязательное поле)
    long providerId = 500011L;
    //путь до каталога с реестрами задолжников (обязательное поле)
    String sourcePath = 'imp/source/territoria_comforta';
    //путь до каталога с историей загрузок (обязательное поле)
    String historyPath = 'imp/history/territoria_comforta';
    
    //Разделитель полей в файле
    String separator = ';';

    //Первый шаг - Инициализация необходимых объектов и добавление их в карту
    //Реализованный метод абстрактного класса DebtorsLoader
    @Override
    public Map init(History history, File file){
        def args = [:] as HashMap;
        def reader = file.newReader('cp1251');
        args['reader'] = reader;
        args['header'] = parseHeader(reader);
        args['summa'] = new BigDecimal(0);
        return args;
    }
    
    //Второй шаг - Чтение строк реестра. 
    //Возвращает карту, где ключ = 100, 101, 102, ... - номера полей в системе
    //Ключ 0 зарезервирован под поле для поиска
    //Реализованный метод абстрактного класса DebtorsLoader
    @Override
    public Iterator<Map<Integer, String>> iterator(History history, Map map) {
        
        //анонимный класс
        //методы вызываются столько же сколько записей в реестре
        Iterator<Map<Integer, String>> it = new Iterator<Map<Integer, String>>() {
            
            @Override
            public boolean hasNext() {
                //имеются ли ешё записи?
                //если да, то вызывается метод next
                return map.reader.ready();
            }

            @Override
            public Map<Integer, String> next() {
                //следующая запись
                return parseLine(map);
            }

            @Override
            public void remove() {
                 //просто оставляем пустым, поэтому оставляем пустым
            }
        };
        return it;
    }
    
    //Реализованный метод абстрактного класса DebtorsLoader
    @Override
    public void completion(History history, Map map){
        history.append('The amount in the document %s', map.header.Filesum);
        history.append('Amount of records actually: %s', map.summa);
        map.reader.close();
    }
    
    //Разбор заголовка файла
    def parseHeader(reader){
        def header = [:] as HashMap;
        for(i in 1..4){
            def pair = reader.readLine().tokenize(' ');
            switch(pair[0].toString()){
                case '#FILESUM':
                    header['Filesum'] = pair[1];
                    break;
                case '#TYPE':
                    header['Type'] = pair[1];
                    break;
                case '#SERVICE':
                    header['Service'] = pair[1];
                    break;
//                case '#NOTE':
//                    header['Note'] = pair[1];
//                    break;
            }
        }
        return header;
    }
    
    //Формирование карты для последующей записи в базу
    def parseLine(map){
        //чтение строки
        def line = map.reader.readLine();
        //разделение строки с помощью символа ";"
        def parsedRecord = line.split(separator);
        //создание карты
        def record = [:] as HashMap;
        record[100] = parsedRecord[0]; //ФИО
        record[101] = parsedRecord[1]; //Адрес
        record[102] = parsedRecord[2]; //Счёт
        record[103] = parsedRecord[3]; //Сумма
        record[104] = parsedRecord[4] ?: ''; //Текст
        record[105] = parsedRecord[5] ?: ''; //Дата начала
        record[106] = parsedRecord[6] ?: ''; //Дата конца
        
        record[0] = parsedRecord[2]; //Поле используемое в поиске
        
        //суммирование по всем записям
        map.summa = map.summa.add(new BigDecimal(parsedRecord[3]));
        
        return record;
    }
}