src/main/java/repository/json/JsonAccountRepositoryImpl.java - master - borlok/ConsoleCrudWithPatternsAndJson

src/main/java/repository/json/JsonAccountRepositoryImpl.java

87 строк3 KB

Ерофеевский Юрий Александрович

+Фассад, +JsonSerializer

17 ноя 2020, 16:40

17 ноя 2020, 16:403f0f43b

package repository.json;

import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
import com.google.gson.reflect.TypeToken;
import model.Account;
import model.AccountStatus;
import repository.AccountRepository;

import java.io.FileReader;
import java.io.IOException;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.util.ArrayList;
import java.util.List;

public class JsonAccountRepositoryImpl implements AccountRepository {
    private final String FILE_PATH = "./src/main/resources/files/accounts.json";
    private final Path PATH = Paths.get(FILE_PATH);
    private final Gson saverLoader = new GsonBuilder().create();

    @Override
    public Account create(Account account) {
        List<Account> accounts = getAll();
        accounts.add(account);
        saveAccountsCollectionToFile(accounts);
        return account;
    }

    private void saveAccountsCollectionToFile(List<Account> accounts) {
        JsonUtils.saveCollectionToJsonFile(accounts, PATH);
    }

    @Override
    public Account getById(Integer id) {
        return getAll()
                .stream()
                .filter(x -> x.getId() == id)
                .findFirst()
                .orElse(isNotInRepository());
    }

    @Override
    public Account update(Account account, Integer id) {
        List<Account> accounts = getAll();
        accounts.set(
                accounts.indexOf(accounts.stream()
                        .filter(x -> x.getId() == id)
                        .findFirst()
                        .orElse(isNotInRepository())), account);
        saveAccountsCollectionToFile(accounts);
        return account;
    }

    private Account isNotInRepository() {
        return new Account("DELETED", AccountStatus.DELETED);
    }

    @Override
    public List<Account> getAll() {
        List<Account> collection = new ArrayList<>();
        try (FileReader reader = new FileReader(PATH.toFile())) {
            collection = saverLoader.fromJson(reader, new TypeToken<List<Account>>() {
            }.getType());
        } catch (IOException | NullPointerException e) {
            System.err.println("Ошибка чтения файла: " + e);
        }
        return collection;
    }

    @Override
    public void delete(Integer id) {
        List<Account> accounts = getAll();
        Account account = isNotInRepository();
        account.setId(id);
        accounts.set(accounts.indexOf(accounts.stream()
                .filter(x -> x.getId() == id)
                .findFirst()
                .orElse(isNotInRepository())), account);
        saveAccountsCollectionToFile(accounts);
    }

    @Override
    public String toString() {
        return "JsonAccountRepositoryImpl";
    }
}