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

Update service migrasi pasien

Browse Source 
Perbaikan etl pasien di sisi smart untuk scheduler set status terkirim dan flag status persiapan migrasi
This commit is contained in:
Salman Manoe 2024-08-01 13:22:40 +07:00
parent 115bc86893
commit 29e591871f
3 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
jasamedika-bridging/src/main/java/com/jasamedika/medifirst2000/task/schedule/MigrasiPasienTask.java
View File

@ -44,14 +44,14 @@ public class MigrasiPasienTask {
@Value("${app.etl.migrasi.pasien}") @Value("${app.etl.migrasi.pasien}")
String baseUrl; String baseUrl;
@Scheduled(cron = "0 10/30 * * * ?") @Scheduled(cron = "0 30 0/1 * * ?")
public void newMigrate() { public void newMigrate() {
LOGGER.info("Task MigrasiPasienTask.newMigrate {}", LocalDateTime.now()); LOGGER.info("Task MigrasiPasienTask.newMigrate {}", LocalDateTime.now());
migrasiPasienService.newMigrate(); migrasiPasienService.newMigrate();
} }
@Scheduled(cron = "0 0/30 * * * ?") @Scheduled(cron = "0 0 0/1 * * ?")
public void setStatusTerkirim() throws URISyntaxException { public void setStatusTerkirim() throws URISyntaxException {
LOGGER.info("Task MigrasiPasienTask.setStatusTerkirim {}", LocalDateTime.now()); LOGGER.info("Task MigrasiPasienTask.setStatusTerkirim {}", LocalDateTime.now());

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

@ -15,13 +15,14 @@ import java.util.List;
* @since 06/11/2023 * @since 06/11/2023
*/ */
public interface MigrasiPasienDao extends JpaRepository<MigrasiPasien, String> { public interface MigrasiPasienDao extends JpaRepository<MigrasiPasien, String> {
@Query("select mp.pasien from MigrasiPasien mp where mp.statusMigrasi in (:listStatusMigrasi)") @Query("select ps from MigrasiPasien mp " + "inner join mp.pasien ps "
+ "where mp.statusMigrasi in (:listStatusMigrasi) "
+ "and (ps.noIdentitas is not null or ps.noidentitas <> '')")
List<Pasien> findPasienByStatusMigrasiIn(@Param("listStatusMigrasi") List<StatusMigrasi> statusMigrasiList); List<Pasien> findPasienByStatusMigrasiIn(@Param("listStatusMigrasi") List<StatusMigrasi> statusMigrasiList);
@Query(value = "select mp.* from migrasipasien_t mp " + "inner join pasien_m ps on mp.pasienfk = ps.id " @Query(value = "select mp.* from migrasipasien_t mp " + "inner join pasien_m ps on mp.pasienfk = ps.id "
+ "where mp.statusmigrasi in (:listStatusMigrasi) " + "where mp.statusmigrasi in (:listStatusMigrasi) "
+ "and ps.nocm in (:listNoRekamMedis)", nativeQuery = true) + "and ps.nocm in (:listNoRekamMedis)", nativeQuery = true)
List<MigrasiPasien> findByStatusMigrasiInAndPasienNoCmIn( List<MigrasiPasien> findByStatusMigrasiInAndPasienNoCmIn(@Param("listStatusMigrasi") List<String> statusMigrasiList,
@Param("listStatusMigrasi") List<StatusMigrasi> statusMigrasiList,
@Param("listNoRekamMedis") List<String> noRekamMedisList); @Param("listNoRekamMedis") List<String> noRekamMedisList);
} }

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

@ -297,7 +297,8 @@ public class MigrasiPasienServiceImpl implements MigrasiPasienService {
@Override @Override
public void setStatus(List<String> noRekamMedisList) { public void setStatus(List<String> noRekamMedisList) {
List<StatusMigrasi> statusMigrasiList = new ArrayList<>(Arrays.asList(BELUM_KIRIM, PEMBAHARUAN)); List<String> statusMigrasiList = new ArrayList<>(Arrays.asList(BELUM_KIRIM, PEMBAHARUAN)).stream()
.map(Enum::toString).collect(Collectors.toList());
List<MigrasiPasien> listMigrasiPasien = migrasiPasienDao.findByStatusMigrasiInAndPasienNoCmIn(statusMigrasiList, List<MigrasiPasien> listMigrasiPasien = migrasiPasienDao.findByStatusMigrasiInAndPasienNoCmIn(statusMigrasiList,
noRekamMedisList); noRekamMedisList);
listMigrasiPasien.forEach(migrasiPasien -> migrasiPasien.setStatusMigrasi(TERKIRIM)); listMigrasiPasien.forEach(migrasiPasien -> migrasiPasien.setStatusMigrasi(TERKIRIM));