Project Job plus a sparkle of Task Assigning

[Andrea Perdonò]

Hello everyone!

I am working on building a scheduler that operates through REST calls. The objective is to handle N projects, each having temporal constraints for start and end dates, and consisting of N tasks with a predefined sequence (no need to order the tasks). The goal is to determine the start and end dates for individual tasks, considering their expected duration, delayed duration, and potential temporal buffer to be applied to the subsequent task. Additionally, once the scheduling is defined, the next step is to assign the optimal resource to each task based on department, required skills, while attempting to balance the overall workload.

To implement this, I'm contemplating whether to create a hybrid solution that combines aspects of Project Job Scheduling (PJ) and Task Assignment Scheduling (TA). Currently, I have defined a class SchedulerPJ as the @PlanningSolution, a class Project as @ProblemFact,  a class Task as @PlanningEntity. The Task has startDate and resource as @PlanningVariable:

1. @PlanningVariable(valueRangeProviderRefs = {"risorsaRange"})
2. private Risorsa risorsa;
4. @JsonIgnore
5. private Task taskPrecedente;
6. @JsonProperty("idTaskPrecedente")
7. private Long idTaskPrecedente;
9. @JsonIgnore
10. private Task taskSuccessiva;
11. @JsonProperty("idTaskSuccessiva")
12. private Long idTaskSuccessiva;
14. @ShadowVariable(variableListenerClass = PredecessorDoneDateUpdatingVariableListener.class,
15. sourceVariableName = "risorsa")
16. public LocalDate dataInizioBuffer;
18. @JsonFormat(shape=JsonFormat.Shape.STRING, pattern="yyyy-MM-dd")
19. @PiggybackShadowVariable(shadowVariableName = "dataInizioBuffer")
20. private LocalDate dataFine;
22. @JsonFormat(shape=JsonFormat.Shape.STRING, pattern="yyyy-MM-dd")
23. @PiggybackShadowVariable(shadowVariableName = "dataInizioBuffer")
24. private LocalDate dataInizio;
26. private LocalDate dataDiFineIdeale;
27. 
    

 A class named Resource which has an 

1. @InverseRelationShadowVariable(sourceVariableName = "risorsa")
2. private List<Task> tasks = new ArrayList<>();
3. 
   

and I have also implementede a VAriableListener thats update the Stard and End date of a Task:

1. @Override
2. public void afterEntityAdded(ScoreDirector<SchedulerPJ> scoreDirector, Task task) {
3. updateDataInizio(scoreDirector, task);
4. }
5. 
   
6. @Override
7. public void afterEntityRemoved(ScoreDirector<SchedulerPJ> scoreDirector, Task task) {
8. updateDataInizio(scoreDirector, task);
9. }
11. private void updateDataInizio(ScoreDirector<SchedulerPJ> scoreDirector, Task task) {
12. Task taskPrecedente = task.getTaskPrecedente();
13. Task taskSuccessiva = task.getTaskSuccessiva();
14. LocalDate dataInizioBuffer;
15. LocalDate dataInizio;
17. if (taskPrecedente == null) {
18. dataInizioBuffer = task.getDataInizioBuffer();
19. dataInizio = task.getProgetto().getDataInizio();
20. } else {
21. dataInizioBuffer = taskPrecedente.getDataFine();
22. dataInizio = taskPrecedente.getDurataBuffer() > 0 ? dataInizioBuffer.plusDays(taskPrecedente.getDurataBuffer()) : dataInizioBuffer;
23. }
25. for (Task shadowTaskCorrente = task;
26. shadowTaskCorrente != null && (!Objects.equals(shadowTaskCorrente.getDataInizioBuffer(), dataInizioBuffer)
27. || !Objects.equals(shadowTaskCorrente.getDataInizio(), dataInizio));) {
28. scoreDirector.beforeVariableChanged(shadowTaskCorrente, "dataInizioBuffer");
29. shadowTaskCorrente.setDataInizioBuffer(dataInizioBuffer);
30. scoreDirector.afterVariableChanged(shadowTaskCorrente, "dataInizioBuffer");
31. scoreDirector.beforeVariableChanged(shadowTaskCorrente, "dataInizio");
33. // Se la dataInizio è un fine settimana (sabato o domenica), salta al prossimo lunedì
34. assert dataInizio != null;
35. if (dataInizio.getDayOfWeek() == DayOfWeek.SATURDAY) {
36. dataInizio = dataInizio.plusDays(2); // Salta il sabato e la domenica
37. } else if (dataInizio.getDayOfWeek() == DayOfWeek.SUNDAY) {
38. dataInizio = dataInizio.plusDays(1); // Salta la domenica
39. }
40. shadowTaskCorrente.setDataInizio(dataInizio);
41. scoreDirector.afterVariableChanged(shadowTaskCorrente, "dataInizio");
42. scoreDirector.beforeVariableChanged(shadowTaskCorrente, "dataFine");
44. shadowTaskCorrente.setDataFine(getProssimaDataLavorativa(dataInizio, shadowTaskCorrente.getDurataGiorni()));
45. scoreDirector.afterVariableChanged(shadowTaskCorrente, "dataFine");
47. LocalDate endDateTime = shadowTaskCorrente.getDataFine();
49. taskPrecedente = shadowTaskCorrente; //Imposto la task precedente con la task attuale
50. shadowTaskCorrente = shadowTaskCorrente.getTaskSuccessiva() != null ? shadowTaskCorrente.getTaskSuccessiva() : null ; //Imposto la task attuale con la task successiva
53. if (shadowTaskCorrente == null || endDateTime == null) {
54. dataInizioBuffer = null;
55. dataInizio = null;
56. } else {
57. dataInizioBuffer = endDateTime;
58. dataInizio = taskPrecedente.getDurataBuffer() > 0 ? dataInizioBuffer.plusDays(taskPrecedente.getDurataBuffer()) : dataInizioBuffer;
60. if (dataInizio.getDayOfWeek() == DayOfWeek.SATURDAY) {
61. dataInizio = dataInizio.plusDays(2); // Salta il sabato e la domenica
62. } else if (dataInizio.getDayOfWeek() == DayOfWeek.SUNDAY) {
63. dataInizio = dataInizio.plusDays(1); // Salta la domenica
64. }
65. shadowTaskCorrente.setDataInizio(dataInizio);
67. Log.info("Task precedente: " + taskPrecedente.getId()
68. + " (Inizio: " + taskPrecedente.getDataInizio()
69. + " | Fine: " + taskPrecedente.getDataFine()
70. + " | Fine ideale: " + taskPrecedente.getDataDiFineIdeale()
71. + " | Durata Prevista: " + taskPrecedente.getDurataGiorni()
72. + " | Durata Reale: " + Period.between(taskPrecedente.getDataInizio(), taskPrecedente.getDataFine()).getDays()
73. + " | Buffer: " + taskPrecedente.getDurataBuffer()
74. + ")"
75. + " Task corrente: " + shadowTaskCorrente.getId()
76. + " (Inizio: " + shadowTaskCorrente.getDataInizio()
77. + " | Fine: " + shadowTaskCorrente.getDataFine()
78. + " | Fine ideale: " + shadowTaskCorrente.getDataDiFineIdeale()
79. + " | Durata Prevista: " + shadowTaskCorrente.getDurataGiorni()
80. + " | Durata Reale: " + Period.between(taskPrecedente.getDataInizio(), taskPrecedente.getDataFine()).getDays()
81. + " | Buffer: " + shadowTaskCorrente.getDurataBuffer()
82. + ")");
84. if(taskPrecedente.getRisorsa() != null){
85. updateCaricoDiLavoro(scoreDirector, taskPrecedente);
86. }
87. }
88. }
90. }
93. private void updateCaricoDiLavoro(ScoreDirector<SchedulerPJ> scoreDirector, Task task) {
94. Risorsa risorsa = task.getRisorsa();
96. if (risorsa == null) {
97. return;
98. }
100. LocalDate dataInizio = task.getDataInizio();
101. LocalDate dataFine = task.getDataFine();
102. int durataGiorni = task.getDurataGiorni();
104. for (CalendarioLavorativo calendarioLavorativo : risorsa.getCalendarioLavorativo()) {
105. LocalDate dataInizioSettimana = calendarioLavorativo.getDataInizioSettimana();
106. LocalDate dataFineSettimana = calendarioLavorativo.getDataFineSettimana();
108. //Data di Inzio e data di Fine della Task ricadono nella stessa settimana
109. if((dataInizio.isAfter(dataInizioSettimana) || dataInizio.isEqual(dataInizioSettimana))
110. && (dataFine.isBefore(dataFineSettimana) || dataFine.isEqual(dataFineSettimana))){
111. int numeroSettimana = calendarioLavorativo.getNumeroSettimana();
112. risorsa.getCaricoDiLavoro().stream().filter(caricoDiLavoro -> caricoDiLavoro.getNumeroSettimana() == numeroSettimana).findFirst().ifPresent(caricoDiLavoro -> {
113. scoreDirector.beforeVariableChanged(task, "risorsa");
114. caricoDiLavoro.setCaricoDiLavoroSettimanale(caricoDiLavoro.getCaricoDiLavoroSettimanale() + colcalaCaricoDilavoro(durataGiorni));
115. scoreDirector.afterVariableChanged(task, "risorsa");
116. });
117. }
118. //
119. }
120. Log.info("Carico di lavoro della risorsa " + risorsa.getId() + " aggiornato: " +
121. risorsa.getCaricoDiLavoro().stream()
122. .filter(carico -> carico.getCaricoDiLavoroSettimanale() > 0)
123. .map(carico -> carico.getCaricoDiLavoroSettimanale() + "%")
124. .collect(Collectors.joining(", "))
125. + " | Task: " + task.getId() + " | Durata: " + durataGiorni + " giorni");
126. 
     
127. }

With the Idea of updating also the caricoDiLavoro variable of Resource (Risorsa). But honestly? I have no idea if I'm using this tool correctly. Do you have any suggestion on how I can procced to realize this project? Thank you!