Add: services huertos

This commit is contained in:
Jose
2025-04-03 03:19:07 +02:00
parent 73a25a94d1
commit 38ffa4a755
10 changed files with 269 additions and 3 deletions

View File

@@ -31,6 +31,27 @@
<attribute name="maven.pomderived" value="true"/>
</attributes>
</classpathentry>
<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER"/>
<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/JavaSE-23">
<attributes>
<attribute name="maven.pomderived" value="true"/>
</attributes>
</classpathentry>
<classpathentry kind="src" path="target/generated-sources/annotations">
<attributes>
<attribute name="optional" value="true"/>
<attribute name="maven.pomderived" value="true"/>
<attribute name="ignore_optional_problems" value="true"/>
<attribute name="m2e-apt" value="true"/>
</attributes>
</classpathentry>
<classpathentry kind="src" output="target/test-classes" path="target/generated-test-sources/test-annotations">
<attributes>
<attribute name="optional" value="true"/>
<attribute name="maven.pomderived" value="true"/>
<attribute name="ignore_optional_problems" value="true"/>
<attribute name="m2e-apt" value="true"/>
<attribute name="test" value="true"/>
</attributes>
</classpathentry>
<classpathentry kind="output" path="target/classes"/>
</classpath>

View File

@@ -20,4 +20,15 @@
<nature>org.eclipse.jdt.core.javanature</nature>
<nature>org.eclipse.m2e.core.maven2Nature</nature>
</natures>
<filteredResources>
<filter>
<id>1743640810478</id>
<name></name>
<type>30</type>
<matcher>
<id>org.eclipse.core.resources.regexFilterMatcher</id>
<arguments>node_modules|\.git|__CREATED_BY_JAVA_LANGUAGE_SERVER__</arguments>
</matcher>
</filter>
</filteredResources>
</projectDescription>

View File

@@ -0,0 +1,2 @@
eclipse.preferences.version=1
org.eclipse.jdt.apt.aptEnabled=false

View File

@@ -9,5 +9,6 @@ org.eclipse.jdt.core.compiler.debug.sourceFile=generate
org.eclipse.jdt.core.compiler.problem.enablePreviewFeatures=disabled
org.eclipse.jdt.core.compiler.problem.forbiddenReference=warning
org.eclipse.jdt.core.compiler.problem.reportPreviewFeatures=warning
org.eclipse.jdt.core.compiler.processAnnotations=disabled
org.eclipse.jdt.core.compiler.release=disabled
org.eclipse.jdt.core.compiler.source=23

View File

@@ -1,5 +1,44 @@
package net.miarma.api.huertos.services;
public class AnnounceService {
import java.util.List;
import io.vertx.core.Future;
import io.vertx.sqlclient.Pool;
import net.miarma.api.huertos.dao.AnnounceDAO;
import net.miarma.api.huertos.entities.AnnounceEntity;
public class AnnounceService {
private final AnnounceDAO announceDAO;
public AnnounceService(Pool pool) {
this.announceDAO = new AnnounceDAO(pool);
}
public Future<List<AnnounceEntity>> getAll() {
return announceDAO.getAll();
}
public Future<AnnounceEntity> getById(Integer id) {
return getAll().compose(announces -> {
AnnounceEntity announce = announces.stream()
.filter(a -> a.getAnnounce_id().equals(id))
.findFirst()
.orElse(null);
return Future.succeededFuture(announce);
});
}
public Future<AnnounceEntity> create(AnnounceEntity announce) {
return announceDAO.insert(announce);
}
public Future<AnnounceEntity> update(AnnounceEntity announce) {
return announceDAO.update(announce);
}
public Future<AnnounceEntity> delete(Integer id) {
return announceDAO.delete(id);
}
}

View File

@@ -1,5 +1,45 @@
package net.miarma.api.huertos.services;
public class BalanceService {
import io.vertx.core.Future;
import io.vertx.sqlclient.Pool;
import net.miarma.api.huertos.dao.BalanceDAO;
import net.miarma.api.huertos.entities.BalanceEntity;
public class BalanceService {
private final BalanceDAO balanceDAO;
public BalanceService(Pool pool) {
this.balanceDAO = new BalanceDAO(pool);
}
public Future<BalanceEntity> getBalance() {
return balanceDAO.getAll().compose(balanceList -> {
if (balanceList.isEmpty()) {
return Future.failedFuture("No balance found");
} else {
return Future.succeededFuture(balanceList.get(0));
}
});
}
public Future<BalanceEntity> update(BalanceEntity balance) {
return balanceDAO.update(balance).compose(updatedBalance -> {
if (updatedBalance == null) {
return Future.failedFuture("Failed to update balance");
} else {
return Future.succeededFuture(updatedBalance);
}
});
}
public Future<BalanceEntity> create(BalanceEntity balance) {
return balanceDAO.insert(balance).compose(createdBalance -> {
if (createdBalance == null) {
return Future.failedFuture("Failed to create balance");
} else {
return Future.succeededFuture(createdBalance);
}
});
}
}

View File

@@ -1,5 +1,43 @@
package net.miarma.api.huertos.services;
import java.util.List;
import io.vertx.core.Future;
import io.vertx.sqlclient.Pool;
import net.miarma.api.huertos.dao.ExpenseDAO;
import net.miarma.api.huertos.entities.ExpenseEntity;
public class ExpenseService {
private final ExpenseDAO expenseDAO;
public ExpenseService(Pool pool) {
this.expenseDAO = new ExpenseDAO(pool);
}
public Future<List<ExpenseEntity>> getAll() {
return expenseDAO.getAll();
}
public Future<ExpenseEntity> getById(Integer id) {
return getAll().compose(expenses -> {
ExpenseEntity expense = expenses.stream()
.filter(e -> e.getExpense_id().equals(id))
.findFirst()
.orElse(null);
return Future.succeededFuture(expense);
});
}
public Future<ExpenseEntity> create(ExpenseEntity expense) {
return expenseDAO.insert(expense);
}
public Future<ExpenseEntity> update(ExpenseEntity expense) {
return expenseDAO.update(expense);
}
public Future<ExpenseEntity> delete(Integer id) {
return expenseDAO.delete(id);
}
}

View File

@@ -1,5 +1,43 @@
package net.miarma.api.huertos.services;
import java.util.List;
import io.vertx.core.Future;
import io.vertx.sqlclient.Pool;
import net.miarma.api.huertos.dao.IncomeDAO;
import net.miarma.api.huertos.entities.IncomeEntity;
public class IncomeService {
private final IncomeDAO incomeDAO;
public IncomeService(Pool pool) {
this.incomeDAO = new IncomeDAO(pool);
}
public Future<List<IncomeEntity>> getAll() {
return incomeDAO.getAll();
}
public Future<IncomeEntity> getById(Integer id) {
return getAll().compose(incomes -> {
IncomeEntity income = incomes.stream()
.filter(i -> i.getIncome_id().equals(id))
.findFirst()
.orElse(null);
return Future.succeededFuture(income);
});
}
public Future<IncomeEntity> create(IncomeEntity income) {
return incomeDAO.insert(income);
}
public Future<IncomeEntity> update(IncomeEntity income) {
return incomeDAO.update(income);
}
public Future<IncomeEntity> delete(Integer id) {
return incomeDAO.delete(id);
}
}

View File

@@ -1,5 +1,43 @@
package net.miarma.api.huertos.services;
import java.util.List;
import io.vertx.core.Future;
import io.vertx.sqlclient.Pool;
import net.miarma.api.huertos.dao.PreUserDAO;
import net.miarma.api.huertos.entities.PreUserEntity;
public class PreUserService {
private final PreUserDAO preUserDAO;
public PreUserService(Pool pool) {
this.preUserDAO = new PreUserDAO(pool);
}
public Future<List<PreUserEntity>> getAll() {
return preUserDAO.getAll();
}
public Future<PreUserEntity> getById(Integer id) {
return getAll().compose(preUsers -> {
PreUserEntity preUser = preUsers.stream()
.filter(p -> p.getPre_user_id().equals(id))
.findFirst()
.orElse(null);
return Future.succeededFuture(preUser);
});
}
public Future<PreUserEntity> create(PreUserEntity preUser) {
return preUserDAO.insert(preUser);
}
public Future<PreUserEntity> update(PreUserEntity preUser) {
return preUserDAO.update(preUser);
}
public Future<PreUserEntity> delete(Integer id) {
return preUserDAO.delete(id);
}
}

View File

@@ -1,5 +1,43 @@
package net.miarma.api.huertos.services;
import java.util.List;
import io.vertx.core.Future;
import io.vertx.sqlclient.Pool;
import net.miarma.api.huertos.dao.RequestDAO;
import net.miarma.api.huertos.entities.RequestEntity;
public class RequestService {
private final RequestDAO requestDAO;
public RequestService(Pool pool) {
this.requestDAO = new RequestDAO(pool);
}
public Future<List<RequestEntity>> getAll() {
return requestDAO.getAll();
}
public Future<RequestEntity> getById(Integer id) {
return getAll().compose(requests -> {
RequestEntity request = requests.stream()
.filter(r -> r.getRequest_id().equals(id))
.findFirst()
.orElse(null);
return Future.succeededFuture(request);
});
}
public Future<RequestEntity> create(RequestEntity request) {
return requestDAO.insert(request);
}
public Future<RequestEntity> update(RequestEntity request) {
return requestDAO.update(request);
}
public Future<RequestEntity> delete(Integer id) {
return requestDAO.delete(id);
}
}