+ ProfileDAO dao = DB.get()
+ .getProfileDAO();
+ AsyncTask.execute(() -> dao.deleteSync(dao.getByIdSync(id)));
+ }
+ public LedgerTransaction loadTransaction(int transactionId) {
+ LedgerTransaction tr = new LedgerTransaction(transactionId, this.id);
+ tr.loadData(App.getDatabase());
+
+ return tr;
+ }
+ public int getThemeHue() {
+// debug("profile", String.format("Profile.getThemeHue() returning %d", themeHue));
+ return this.themeHue;
+ }
+ public void setThemeHue(Object o) {
+ setThemeId(Integer.parseInt(String.valueOf(o)));
+ }
+ public void setThemeId(int themeHue) {
+// debug("profile", String.format("Profile.setThemeHue(%d) called", themeHue));
+ this.themeHue = themeHue;
+ }
+ public int getNextTransactionsGeneration(SQLiteDatabase db) {
+ try (Cursor c = db.rawQuery(
+ "SELECT generation FROM transactions WHERE profile_id=? LIMIT 1",
+ new String[]{String.valueOf(id)}))
+ {
+ if (c.moveToFirst())
+ return c.getInt(0) + 1;
+ }
+ return 1;
+ }
+ private void deleteNotPresentTransactions(SQLiteDatabase db, int generation) {
+ Logger.debug("db/benchmark", "Deleting obsolete transactions");
+ db.execSQL(
+ "DELETE FROM transaction_accounts WHERE (select t.profile_id from transactions t " +
+ "where t.id=transaction_accounts.transaction_id)=? AND generation" + " <> ?",
+ new Object[]{id, generation});
+ db.execSQL("DELETE FROM transactions WHERE profile_id=? AND generation <> ?",
+ new Object[]{id, generation});
+ Logger.debug("db/benchmark", "Done deleting obsolete transactions");
+ }
+ @Transaction
+ public void wipeAllDataSync() {
+ OptionDAO optDao = DB.get()
+ .getOptionDAO();
+ optDao.deleteSync(optDao.allForProfileSync(id));
+
+ AccountDAO accDao = DB.get()
+ .getAccountDAO();
+ accDao.deleteSync(accDao.allForProfileSync(id));
+
+ TransactionDAO trnDao = DB.get()
+ .getTransactionDAO();
+ trnDao.deleteSync(trnDao.allForProfileSync(id));
+
+ DescriptionHistoryDAO descDao = DB.get()
+ .getDescriptionHistoryDAO();
+ descDao.sweepSync();
+ }
+ public void wipeAllData() {
+ AsyncTask.execute(this::wipeAllDataSync);
+ }
+ public List<Currency> getCurrencies() {
+ SQLiteDatabase db = App.getDatabase();
+
+ ArrayList<Currency> result = new ArrayList<>();
+
+ try (Cursor c = db.rawQuery("SELECT c.id, c.name, c.position, c.has_gap FROM currencies c",
+ new String[]{}))
+ {
+ while (c.moveToNext()) {
+ Currency currency = new Currency(c.getInt(0), c.getString(1),
+ Currency.Position.valueOf(c.getString(2)), c.getInt(3) == 1);
+ result.add(currency);
+ }
+ }
+
+ return result;
+ }
+ Currency loadCurrencyByName(String name) {
+ SQLiteDatabase db = App.getDatabase();
+ Currency result = tryLoadCurrencyByName(db, name);
+ if (result == null)
+ throw new RuntimeException(String.format("Unable to load currency '%s'", name));
+ return result;
+ }
+ private Currency tryLoadCurrencyByName(SQLiteDatabase db, String name) {
+ try (Cursor cursor = db.rawQuery(
+ "SELECT c.id, c.name, c.position, c.has_gap FROM currencies c WHERE c.name=?",
+ new String[]{name}))
+ {
+ if (cursor.moveToFirst()) {
+ return new Currency(cursor.getInt(0), cursor.getString(1),
+ Currency.Position.valueOf(cursor.getString(2)), cursor.getInt(3) == 1);
+ }
+ return null;
+ }
+ }
+ public void storeAccountAndTransactionListAsync(List<LedgerAccount> accounts,
+ List<LedgerTransaction> transactions) {
+ if (accountAndTransactionListSaver != null)
+ accountAndTransactionListSaver.interrupt();
+
+ accountAndTransactionListSaver =
+ new AccountAndTransactionListSaver(this, accounts, transactions);
+ accountAndTransactionListSaver.start();
+ }
+ private Currency tryLoadCurrencyById(SQLiteDatabase db, int id) {
+ try (Cursor cursor = db.rawQuery(
+ "SELECT c.id, c.name, c.position, c.has_gap FROM currencies c WHERE c.id=?",
+ new String[]{String.valueOf(id)}))
+ {
+ if (cursor.moveToFirst()) {
+ return new Currency(cursor.getInt(0), cursor.getString(1),
+ Currency.Position.valueOf(cursor.getString(2)), cursor.getInt(3) == 1);
+ }
+ return null;
+ }
+ }
+ public Currency loadCurrencyById(int id) {
+ SQLiteDatabase db = App.getDatabase();
+ Currency result = tryLoadCurrencyById(db, id);
+ if (result == null)
+ throw new RuntimeException(String.format("Unable to load currency with id '%d'", id));
+ return result;
+ }
+
+ public enum FutureDates {
+ None(0), OneWeek(7), TwoWeeks(14), OneMonth(30), TwoMonths(60), ThreeMonths(90),
+ SixMonths(180), OneYear(365), All(-1);
+ private static final SparseArray<FutureDates> map = new SparseArray<>();
+
+ static {
+ for (FutureDates item : FutureDates.values()) {
+ map.put(item.value, item);
+ }
+ }
+
+ private final int value;
+ FutureDates(int value) {
+ this.value = value;
+ }
+ public static FutureDates valueOf(int i) {
+ return map.get(i, None);
+ }
+ public int toInt() {
+ return this.value;
+ }
+ public String getText(Resources resources) {
+ switch (value) {
+ case 7:
+ return resources.getString(R.string.future_dates_7);
+ case 14:
+ return resources.getString(R.string.future_dates_14);
+ case 30:
+ return resources.getString(R.string.future_dates_30);
+ case 60:
+ return resources.getString(R.string.future_dates_60);
+ case 90:
+ return resources.getString(R.string.future_dates_90);
+ case 180:
+ return resources.getString(R.string.future_dates_180);
+ case 365:
+ return resources.getString(R.string.future_dates_365);
+ case -1:
+ return resources.getString(R.string.future_dates_all);
+ default:
+ return resources.getString(R.string.future_dates_none);
+ }
+ }
+ }
+
+ private static class AccountAndTransactionListSaver extends Thread {
+ private final MobileLedgerProfile profile;
+ private final List<LedgerAccount> accounts;
+ private final List<LedgerTransaction> transactions;
+ AccountAndTransactionListSaver(MobileLedgerProfile profile, List<LedgerAccount> accounts,
+ List<LedgerTransaction> transactions) {
+ this.accounts = accounts;
+ this.transactions = transactions;
+ this.profile = profile;
+ }
+ public int getNextDescriptionsGeneration(SQLiteDatabase db) {
+ int generation = 1;
+ try (Cursor c = db.rawQuery("SELECT generation FROM description_history LIMIT 1",
+ null))
+ {
+ if (c.moveToFirst()) {
+ generation = c.getInt(0) + 1;
+ }
+ }
+ return generation;
+ }
+ void deleteNotPresentDescriptions(SQLiteDatabase db, int generation) {
+ Logger.debug("db/benchmark", "Deleting obsolete descriptions");
+ db.execSQL("DELETE FROM description_history WHERE generation <> ?",
+ new Object[]{generation});
+ db.execSQL("DELETE FROM description_history WHERE generation <> ?",
+ new Object[]{generation});
+ Logger.debug("db/benchmark", "Done deleting obsolete descriptions");
+ }
+ @Override
+ public void run() {
+ SQLiteDatabase db = App.getDatabase();
+ db.beginTransactionNonExclusive();
+ try {
+ int transactionsGeneration = profile.getNextTransactionsGeneration(db);
+ if (isInterrupted())
+ return;
+
+ for (LedgerTransaction tr : transactions) {
+ profile.storeTransaction(db, transactionsGeneration, tr);
+ if (isInterrupted())
+ return;
+ }
+
+ profile.deleteNotPresentTransactions(db, transactionsGeneration);
+ if (isInterrupted()) {
+ return;
+ }
+
+ Map<String, Boolean> unique = new HashMap<>();
+
+ debug("descriptions", "Starting refresh");
+ int descriptionsGeneration = getNextDescriptionsGeneration(db);
+ try (Cursor c = db.rawQuery("SELECT distinct description from transactions",
+ null))
+ {
+ while (c.moveToNext()) {
+ String description = c.getString(0);
+ String descriptionUpper = description.toUpperCase();
+ if (unique.containsKey(descriptionUpper))
+ continue;
+
+ storeDescription(db, descriptionsGeneration, description, descriptionUpper);
+
+ unique.put(descriptionUpper, true);
+ }
+ }
+ deleteNotPresentDescriptions(db, descriptionsGeneration);
+
+ db.setTransactionSuccessful();
+ }
+ finally {
+ db.endTransaction();
+ }
+
+ AsyncTask.execute(() -> {
+ List<AccountWithAmounts> list = new ArrayList<>();
+
+ final AccountDAO dao = DB.get()
+ .getAccountDAO();
+
+ for (LedgerAccount acc : accounts) {
+ AccountWithAmounts rec = new AccountWithAmounts();
+ rec.account = acc.toDBO();
+
+ if (isInterrupted())
+ return;
+
+ rec.amounts = new ArrayList<>();
+ for (LedgerAmount amt : acc.getAmounts()) {
+ AccountValue av = new AccountValue();
+ av.setCurrency(amt.getCurrency());
+ av.setValue(amt.getAmount());
+
+ rec.amounts.add(av);
+ }
+
+ list.add(rec);
+ }
+
+ if (isInterrupted())
+ return;
+
+ dao.storeAccountsSync(list, profile.getId());
+ });
+ }
+ private void storeDescription(SQLiteDatabase db, int generation, String description,
+ String descriptionUpper) {
+ db.execSQL("UPDATE description_history SET description=?, generation=? WHERE " +
+ "description_upper=?", new Object[]{description, generation, descriptionUpper
+ });
+ db.execSQL(
+ "INSERT INTO description_history(description, description_upper, generation) " +
+ "select ?,?,? WHERE (select changes() = 0)",
+ new Object[]{description, descriptionUpper, generation
+ });
+ }