Commit e8291549 authored by Bane's avatar Bane

wip simulation remplissage poubelle

parent efe24365
package isima.f2;
import isima.f2.services.ThreadSimulation;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
......@@ -8,6 +9,9 @@ public class RamassagePoubleDepotApplication {
public static void main(String[] args) {
SpringApplication.run(RamassagePoubleDepotApplication.class, args);
System.out.println("=======================>Le nom du thread principal est " + Thread.currentThread().getName());
ThreadSimulation t = new ThreadSimulation();
t.start();
}
}
......@@ -12,4 +12,5 @@ public interface IPoubelle {
public Optional<Poubelle> getPoubelle(Long id);
public List<Poubelle> getPoubelles();
public void viderPoubelle(long id);
public void updateContenuPoubelle(long id, double contenu);
}
......@@ -15,4 +15,10 @@ public interface IPoubelleDAO extends JpaRepository<Poubelle, Long> {
@Query("UPDATE Poubelle p SET p.contenu = 0 WHERE p.id = :id")
int updatePoubelleSetCapacityZero(@Param("id") long id);
@Modifying
@Transactional
@Query("UPDATE Poubelle p SET p.contenu = :contenu WHERE p.id = :id")
int updatePoubelleSetCapacity(@Param("id") long id, @Param("contenu") double contenu);
}
......@@ -16,6 +16,10 @@ public class ImpPoubelle implements IPoubelle{
@Autowired
IPoubelleDAO poubelleDAO ;
public ImpPoubelle(){
}
@Override
public Poubelle ajouterPoubelle(Poubelle poubelle) {
return poubelleDAO.save(poubelle);
......@@ -33,7 +37,7 @@ public class ImpPoubelle implements IPoubelle{
@Override
public Optional<Poubelle> getPoubelle(Long id) {
return null;
return poubelleDAO.findById(id);
}
@Override
......@@ -46,4 +50,9 @@ public class ImpPoubelle implements IPoubelle{
poubelleDAO.updatePoubelleSetCapacityZero(id);
}
@Override
public void updateContenuPoubelle(long id, double contenu) {
poubelleDAO.updatePoubelleSetCapacity(id,contenu);
}
}
package isima.f2.services;
import isima.f2.model.Poubelle;
import org.springframework.beans.factory.annotation.Autowired;
import java.util.Optional;
public class ThreadSimulation extends Thread {
@Autowired
ImpPoubelle poubelleService;
public ThreadSimulation() {
super();
}
public void run() {
long nbGenere;
/*int nbPoubelles = poubelleService.getPoubelles().size();
System.out.println("Le nombre de poubelle dans la base est : " + nbPoubelles);*/
while (true){
//Generation du nombre aléatoire
nbGenere = (long)(Math.random() * ((5 - 1) + 1)) + 1;
//Optional<Poubelle> p = poubelleService.getPoubelle(nbGenere);
//System.out.println("Poubelle : " + p.toString());
System.out.println("=================================> Nombrre generé : " + nbGenere);
//poubelleService.updateContenuPoubelle();
try {
Thread.sleep(2000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment