Update service migrasi pasien

Perbaikan performance update flag status migrasi etl pasien di sistem smart
This commit is contained in:
Salman Manoe 2024-07-31 10:59:04 +07:00
parent 4204302bb5
commit 115bc86893
3 changed files with 23 additions and 5 deletions

View File

@ -5,6 +5,7 @@ import com.jasamedika.medifirst2000.service.MigrasiPasienService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@ -12,6 +13,7 @@ import java.util.List;
import static org.springframework.http.MediaType.APPLICATION_JSON_VALUE;
import static org.springframework.web.bind.annotation.RequestMethod.GET;
import static org.springframework.web.bind.annotation.RequestMethod.POST;
/**
* @author Salman
@ -36,4 +38,14 @@ public class MigrasiPasienController {
List<PasienDto> result = migrasiPasienService.extractAndTransform();
return new ResponseEntity<>(result, HttpStatus.OK);
}
@RequestMapping(value = "/status", method = POST, consumes = APPLICATION_JSON_VALUE, produces = APPLICATION_JSON_VALUE)
public ResponseEntity<Object> setStatus(@RequestBody List<String> noRekamMedisList) {
try {
migrasiPasienService.setStatus(noRekamMedisList);
return new ResponseEntity<>(null, HttpStatus.ACCEPTED);
} catch (Exception e) {
return new ResponseEntity<>(e.getMessage(), HttpStatus.INTERNAL_SERVER_ERROR);
}
}
}

View File

@ -18,5 +18,10 @@ public interface MigrasiPasienDao extends JpaRepository<MigrasiPasien, String> {
@Query("select mp.pasien from MigrasiPasien mp where mp.statusMigrasi in (:listStatusMigrasi)")
List<Pasien> findPasienByStatusMigrasiIn(@Param("listStatusMigrasi") List<StatusMigrasi> statusMigrasiList);
List<MigrasiPasien> findByPasienNoCmIn(List<String> noCmList);
@Query(value = "select mp.* from migrasipasien_t mp " + "inner join pasien_m ps on mp.pasienfk = ps.id "
+ "where mp.statusmigrasi in (:listStatusMigrasi) "
+ "and ps.nocm in (:listNoRekamMedis)", nativeQuery = true)
List<MigrasiPasien> findByStatusMigrasiInAndPasienNoCmIn(
@Param("listStatusMigrasi") List<StatusMigrasi> statusMigrasiList,
@Param("listNoRekamMedis") List<String> noRekamMedisList);
}

View File

@ -297,9 +297,10 @@ public class MigrasiPasienServiceImpl implements MigrasiPasienService {
@Override
public void setStatus(List<String> noRekamMedisList) {
List<MigrasiPasien> byPasienNoCmIn = migrasiPasienDao.findByPasienNoCmIn(noRekamMedisList);
byPasienNoCmIn.stream().filter(migrasiPasien -> !TERKIRIM.equals(migrasiPasien.getStatusMigrasi()))
.forEach(migrasiPasien -> migrasiPasien.setStatusMigrasi(TERKIRIM));
migrasiPasienDao.save(byPasienNoCmIn);
List<StatusMigrasi> statusMigrasiList = new ArrayList<>(Arrays.asList(BELUM_KIRIM, PEMBAHARUAN));
List<MigrasiPasien> listMigrasiPasien = migrasiPasienDao.findByStatusMigrasiInAndPasienNoCmIn(statusMigrasiList,
noRekamMedisList);
listMigrasiPasien.forEach(migrasiPasien -> migrasiPasien.setStatusMigrasi(TERKIRIM));
migrasiPasienDao.save(listMigrasiPasien);
}
}