#96 coffee annotation changed

i-Cell-Mobilsoft-Open-Source · Feb 2, 2024 · b07af06 · b07af06
1 parent b26d3a0
commit b07af06
Show file tree

Hide file tree

Showing 3 changed files with 38 additions and 0 deletions.
diff --git a/...src/main/java/hu/icellmobilsoft/sampler/sample/jpaservice/action/JpaSamplePostAction.java b/...src/main/java/hu/icellmobilsoft/sampler/sample/jpaservice/action/JpaSamplePostAction.java
@@ -145,6 +145,10 @@ public SampleResponse sampleWriteRead(SampleRequest sampleRequest) throws BaseEx
             throw new TechnicalException("Unexpected data integrity error, some mandatory field is empty or not equal!");
         }
 
+        transactionHelper.executeWithTransaction(() -> {
+            sampleEntityService.updateAllStatusAndInputValue(SampleStatus.DONE, "done");
+        });
+
         SampleResponse response = new SampleResponse();
         response.setSample(sampleTypeConverter.convert(readed));
 

diff --git a/...n/java/hu/icellmobilsoft/sampler/sample/jpaservice/repository/SampleEntityRepository.java b/...n/java/hu/icellmobilsoft/sampler/sample/jpaservice/repository/SampleEntityRepository.java
@@ -24,7 +24,9 @@
 import jakarta.persistence.QueryHint;
 
 import org.apache.deltaspike.data.api.EntityRepository;
+import org.apache.deltaspike.data.api.Modifying;
 import org.apache.deltaspike.data.api.Query;
+import org.apache.deltaspike.data.api.QueryParam;
 import org.apache.deltaspike.data.api.Repository;
 import org.apache.deltaspike.data.api.criteria.CriteriaSupport;
 import org.hibernate.jpa.HibernateHints;
@@ -74,4 +76,15 @@ public interface SampleEntityRepository extends EntityRepository<SampleEntity, S
     // @Query(value = "SELECT s FROM SampleEntity s WHERE s.status = ?1")
     List<SampleEntity> findAllByStatus(SampleStatus status);
 
+    /**
+     * update all sampleEntity by params
+     *
+     * @param status status
+     * @param inputValue input value
+     * @return status of update
+     */
+    @Modifying
+    @Query("UPDATE SampleEntity s SET s.status = :status,  s.inputValue = :inputValue")
+    int updateAllSampleStatusAndInputValue(@QueryParam("status") SampleStatus status, @QueryParam("inputValue") String inputValue);
+
 }
diff --git a/...rc/main/java/hu/icellmobilsoft/sampler/sample/jpaservice/service/SampleEntityService.java b/...rc/main/java/hu/icellmobilsoft/sampler/sample/jpaservice/service/SampleEntityService.java
@@ -29,6 +29,7 @@
 import hu.icellmobilsoft.coffee.dto.exception.BaseException;
 import hu.icellmobilsoft.sampler.common.system.jpa.service.BaseService;
 import hu.icellmobilsoft.sampler.model.sample.SampleEntity;
+import hu.icellmobilsoft.sampler.model.sample.SampleEntity_;
 import hu.icellmobilsoft.sampler.model.sample.enums.SampleStatus;
 import hu.icellmobilsoft.sampler.sample.jpaservice.repository.SampleEntityRepository;
 
@@ -60,4 +61,24 @@ public class SampleEntityService extends BaseService<SampleEntity> {
     public List<SampleEntity> findAllByStatus(SampleStatus status) throws BaseException {
         return wrapListValidated(sampleEntityRepository::findAllByStatus, status, "findAllByStatus", "status");
     }
+
+    /**
+     * Updates all SampleEntity entity with the given params
+     *
+     * @param sampleStatus new sampleStatus
+     * @param inputValue   new inputValue
+     * @return status of update
+     * @throws BaseException on error
+     */
+    public int updateAllStatusAndInputValue(SampleStatus sampleStatus, String inputValue) throws BaseException {
+
+        return wrapValidated(
+                sampleEntityRepository::updateAllSampleStatusAndInputValue,
+                sampleStatus,
+                inputValue,
+                "updateAllSampleStatusAndInputValue",
+                SampleEntity_.STATUS,
+                SampleEntity_.INPUT_VALUE
+        );
+    }
 }