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

src/main/java/repository/json/JsonCustomerRepositoryImpl.java
92 строки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 model.Customer;
import repository.CustomerRepository;

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.HashSet;
import java.util.List;

public class JsonCustomerRepositoryImpl implements CustomerRepository {
    private final String FILE_PATH = "./src/main/resources/files/customer.json";
    private final Path PATH = Paths.get(FILE_PATH);
    private final Gson saverLoader = new GsonBuilder()
            .registerTypeAdapter(Customer.class,new CustomerDeserializer())
            .create();

    @Override
    public Customer create(Customer customer) {
        List<Customer> customers = getAll();
        customers.add(customer);
        saveCustomerCollectionToFile(customers);
        return customer;
    }

    private void saveCustomerCollectionToFile(List<Customer> customers) {
        JsonUtils.saveCollectionToJsonFile(customers,PATH);
    }

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

    @Override
    public Customer update(Customer customer, Integer id) {
        List<Customer> customers = getAll();
        customers.set(
                customers.indexOf(customers.stream()
                        .filter(x -> x.getId() == id)
                        .findFirst()
                        .orElse(isNotInRepository())), customer);
        saveCustomerCollectionToFile(customers);
        return customer;
    }

    private Customer isNotInRepository() {
        return new Customer(new HashSet<>(), new Account("DELETED", AccountStatus.DELETED));
    }

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

    @Override
    public void delete(Integer id) {
        List<Customer> customers = getAll();
        Customer customer = isNotInRepository();
        customer.setId(id);
        customer.getAccount().setId(getById(id).getAccount().getId());
        customers.set(customers.indexOf(customers.stream()
                .filter(x -> x.getId() == id)
                .findFirst()
                .orElse(isNotInRepository())), customer);
        saveCustomerCollectionToFile(customers);
    }

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