diff --git a/jasamedika-business/src/main/java/com/jasamedika/medifirst2000/dao/MigrasiPasienDao.java b/jasamedika-business/src/main/java/com/jasamedika/medifirst2000/dao/MigrasiPasienDao.java index 0ee4077b..12ca07aa 100644 --- a/jasamedika-business/src/main/java/com/jasamedika/medifirst2000/dao/MigrasiPasienDao.java +++ b/jasamedika-business/src/main/java/com/jasamedika/medifirst2000/dao/MigrasiPasienDao.java @@ -1,12 +1,17 @@ package com.jasamedika.medifirst2000.dao; import com.jasamedika.medifirst2000.entities.MigrasiPasien; +import com.jasamedika.medifirst2000.entities.Pasien; +import com.jasamedika.medifirst2000.etl.pasien.constant.StatusMigrasi; import org.springframework.data.jpa.repository.JpaRepository; +import java.util.List; + /** * @author Salman * @version 1.0.0 * @since 06/11/2023 */ public interface MigrasiPasienDao extends JpaRepository { + List findPasienByStatusMigrasiIn(List statusMigrasiList); } diff --git a/jasamedika-business/src/main/java/com/jasamedika/medifirst2000/service/MigrasiPasienService.java b/jasamedika-business/src/main/java/com/jasamedika/medifirst2000/service/MigrasiPasienService.java index 4a6b15a1..148ec492 100644 --- a/jasamedika-business/src/main/java/com/jasamedika/medifirst2000/service/MigrasiPasienService.java +++ b/jasamedika-business/src/main/java/com/jasamedika/medifirst2000/service/MigrasiPasienService.java @@ -7,4 +7,5 @@ package com.jasamedika.medifirst2000.service; */ public interface MigrasiPasienService { void init(); + void sendToNewDb(); } diff --git a/jasamedika-business/src/main/java/com/jasamedika/medifirst2000/service/impl/MigrasiPasienServiceImpl.java b/jasamedika-business/src/main/java/com/jasamedika/medifirst2000/service/impl/MigrasiPasienServiceImpl.java index 5f185c80..151c4c92 100644 --- a/jasamedika-business/src/main/java/com/jasamedika/medifirst2000/service/impl/MigrasiPasienServiceImpl.java +++ b/jasamedika-business/src/main/java/com/jasamedika/medifirst2000/service/impl/MigrasiPasienServiceImpl.java @@ -4,15 +4,20 @@ import com.jasamedika.medifirst2000.dao.MigrasiPasienDao; import com.jasamedika.medifirst2000.dao.PasienDao; import com.jasamedika.medifirst2000.entities.MigrasiPasien; import com.jasamedika.medifirst2000.entities.Pasien; +import com.jasamedika.medifirst2000.etl.pasien.constant.StatusMigrasi; import com.jasamedika.medifirst2000.service.MigrasiPasienService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.util.ArrayList; +import java.util.Arrays; import java.util.List; import java.util.stream.Collectors; +import static com.jasamedika.medifirst2000.etl.pasien.constant.StatusMigrasi.BELUM_KIRIM; +import static com.jasamedika.medifirst2000.etl.pasien.constant.StatusMigrasi.PEMBAHARUAN; + /** * @author Salman * @version 1.0.0 @@ -43,4 +48,10 @@ public class MigrasiPasienServiceImpl implements MigrasiPasienService { }); migrasiPasienDao.save(models); } + + @Override + public void sendToNewDb() { + List statusMigrasiList = new ArrayList<>(Arrays.asList(BELUM_KIRIM, PEMBAHARUAN)); + List listPasien = migrasiPasienDao.findPasienByStatusMigrasiIn(statusMigrasiList); + } }