salmanoe/SC-be-java
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update service migrasi pasien

Browse Source 
Pembuatan service kirim ke db baru
This commit is contained in:
Salman Manoe 2023-11-06 19:51:08 +07:00
parent 0d80bf59a9
commit a4a73eb9ef
3 changed files with 17 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
jasamedika-business/src/main/java/com/jasamedika/medifirst2000/dao/MigrasiPasienDao.java
View File

@ -1,12 +1,17 @@
package com.jasamedika.medifirst2000.dao; package com.jasamedika.medifirst2000.dao;
import com.jasamedika.medifirst2000.entities.MigrasiPasien; 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 org.springframework.data.jpa.repository.JpaRepository;
import java.util.List;
/** /**
* @author Salman * @author Salman
* @version 1.0.0 * @version 1.0.0
* @since 06/11/2023 * @since 06/11/2023
*/ */
public interface MigrasiPasienDao extends JpaRepository<MigrasiPasien, String> { public interface MigrasiPasienDao extends JpaRepository<MigrasiPasien, String> {
List<Pasien> findPasienByStatusMigrasiIn(List<StatusMigrasi> statusMigrasiList);
} }

1
jasamedika-business/src/main/java/com/jasamedika/medifirst2000/service/MigrasiPasienService.java
View File

@ -7,4 +7,5 @@ package com.jasamedika.medifirst2000.service;
*/ */
public interface MigrasiPasienService { public interface MigrasiPasienService {
void init(); void init();
void sendToNewDb();
} }

11
jasamedika-business/src/main/java/com/jasamedika/medifirst2000/service/impl/MigrasiPasienServiceImpl.java
View File

@ -4,15 +4,20 @@ import com.jasamedika.medifirst2000.dao.MigrasiPasienDao;
import com.jasamedika.medifirst2000.dao.PasienDao; import com.jasamedika.medifirst2000.dao.PasienDao;
import com.jasamedika.medifirst2000.entities.MigrasiPasien; import com.jasamedika.medifirst2000.entities.MigrasiPasien;
import com.jasamedika.medifirst2000.entities.Pasien; import com.jasamedika.medifirst2000.entities.Pasien;
import com.jasamedika.medifirst2000.etl.pasien.constant.StatusMigrasi;
import com.jasamedika.medifirst2000.service.MigrasiPasienService; import com.jasamedika.medifirst2000.service.MigrasiPasienService;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Arrays;
import java.util.List; import java.util.List;
import java.util.stream.Collectors; 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 * @author Salman
* @version 1.0.0 * @version 1.0.0
@ -43,4 +48,10 @@ public class MigrasiPasienServiceImpl implements MigrasiPasienService {
}); });
migrasiPasienDao.save(models); migrasiPasienDao.save(models);
} }
@Override
public void sendToNewDb() {
List<StatusMigrasi> statusMigrasiList = new ArrayList<>(Arrays.asList(BELUM_KIRIM, PEMBAHARUAN));
List<Pasien> listPasien = migrasiPasienDao.findPasienByStatusMigrasiIn(statusMigrasiList);
}
} }