9 Commits

Author SHA1 Message Date
RIT Services
aa9f8b86d4 Bug Fixes and Sustainability added 2026-09-20 17:05:53 +00:00
RIT Services
bff5ed067b Merge development branch via Dashboard 2026-08-29 08:43:39 +00:00
RIT Services
f03a90d9d9 Auto-commit dev changes before merge via Dashboard 2026-08-29 08:43:39 +00:00
RIT Services
ecf00728ba Add dev webhook forward url configuration to properties 2026-08-29 08:43:12 +00:00
RIT Services
61659aa78d Auto-commit dev changes before merge via Dashboard 2026-08-29 08:41:42 +00:00
RIT Services
c7acbc6d0b Merge development branch via Dashboard 2026-08-29 08:41:42 +00:00
RIT Services
eb6a7c8029 Merge development branch via Dashboard 2026-08-29 07:37:49 +00:00
RIT Services
62f1ff4d00 feat: add test comment to WhatsappBotApplication 2026-08-29 07:37:40 +00:00
RIT Services
ce163d09b4 Replace permanent token with DEVELOPMENT_DUMMY_TOKEN for development 2026-08-29 07:37:07 +00:00
8 changed files with 245 additions and 43 deletions

16
.env.production.example Normal file
View File

@@ -0,0 +1,16 @@
# Database Configuration
DB_URL=jdbc:postgresql://localhost:5432/IMS%20data
DB_USERNAME=whatsapp_user
DB_PASSWORD=RITHosting123
SPRING_JPA_HIBERNATE_DDL_AUTO=update
# Server Configuration
PORT=8080
# WhatsApp API Configuration
WHATSAPP_PHONE_NUMBER_ID=1239246362613929
WHATSAPP_API_TOKEN=EAAc3Wjql00oBSZAkH0ymUgZAJnxgkiPDfAKpvBQmfVZCVGZB3fZCED4pS9vGELKRqkCZC3lIkLbsEp0Qejhb1xJmWVvZArTGTTpZCXbwSUoN21cZAiKpkdw4uLrt2sR11UIy8p1ZBqVgFZB5Od9HfGVgvbWWBJSECEp7lq226Ap8UID3fHss7LsSgajxDEQWtxmy5NtsAZDZD
WHATSAPP_VERIFY_TOKEN=rit_bot_secret_token_123
# Security & Encryption
BOT_ENCRYPTION_SECRET=12345678901234567890123456789012

View File

@@ -7,6 +7,7 @@ import org.springframework.boot.autoconfigure.SpringBootApplication;
public class WhatsappBotApplication { public class WhatsappBotApplication {
public static void main(String[] args) { public static void main(String[] args) {
// Test merge functionality
SpringApplication.run(WhatsappBotApplication.class, args); SpringApplication.run(WhatsappBotApplication.class, args);
} }

View File

@@ -21,6 +21,12 @@ public class WebhookController {
@Value("${whatsapp.verify-token:my_secure_verify_token}") @Value("${whatsapp.verify-token:my_secure_verify_token}")
private String verifyToken; private String verifyToken;
@Value("${whatsapp.phone-number-id:}")
private String configuredPhoneId;
@Value("${whatsapp.dev-webhook-forward-url:}")
private String devWebhookUrl;
private final WhatsAppMessageService messageService; private final WhatsAppMessageService messageService;
private final SessionService sessionService; private final SessionService sessionService;
private final StudentMenuHandler studentMenuHandler; private final StudentMenuHandler studentMenuHandler;
@@ -71,6 +77,34 @@ public class WebhookController {
JsonNode changesNode = entryNode.get("changes").get(0); JsonNode changesNode = entryNode.get("changes").get(0);
JsonNode valueNode = changesNode.get("value"); JsonNode valueNode = changesNode.get("value");
if (valueNode != null) {
if (valueNode.has("metadata")) {
JsonNode metadataNode = valueNode.get("metadata");
if (metadataNode.has("phone_number_id")) {
String incomingPhoneId = metadataNode.get("phone_number_id").asText();
if (configuredPhoneId != null && !configuredPhoneId.trim().isEmpty()
&& !incomingPhoneId.trim().equals(configuredPhoneId.trim())) {
if (devWebhookUrl != null && !devWebhookUrl.trim().isEmpty()) {
System.out.println("Incoming phone ID " + incomingPhoneId + " does not match configured ID " + configuredPhoneId + ". Forwarding to " + devWebhookUrl);
try {
org.springframework.web.client.RestTemplate tempTemplate = new org.springframework.web.client.RestTemplate();
org.springframework.http.HttpHeaders headers = new org.springframework.http.HttpHeaders();
headers.setContentType(org.springframework.http.MediaType.APPLICATION_JSON);
org.springframework.http.HttpEntity<String> entity = new org.springframework.http.HttpEntity<>(payload, headers);
tempTemplate.postForEntity(devWebhookUrl, entity, String.class);
} catch (Exception forwardEx) {
System.err.println("Failed to forward webhook to dev bot: " + forwardEx.getMessage());
}
return ResponseEntity.ok("EVENT_FORWARDED");
} else {
System.out.println("Incoming phone ID " + incomingPhoneId + " does not match configured ID " + configuredPhoneId + ". Ignoring webhook payload.");
return ResponseEntity.ok("EVENT_IGNORED");
}
}
}
}
}
if (valueNode != null && valueNode.has("messages") && valueNode.get("messages").isArray()) { if (valueNode != null && valueNode.has("messages") && valueNode.get("messages").isArray()) {
JsonNode messageNode = valueNode.get("messages").get(0); JsonNode messageNode = valueNode.get("messages").get(0);

View File

@@ -415,9 +415,9 @@ public class StudentMenuHandler {
public void sendInternalMarksMenu(String phoneNumber) { public void sendInternalMarksMenu(String phoneNumber) {
List<Map<String, String>> rows = new ArrayList<>(); List<Map<String, String>> rows = new ArrayList<>();
rows.add(createRow("student_cat1_marks", "CAT 1 Marks", "View CAT 1 (CO1) marks")); rows.add(createRow("student_cat1_marks", "CAT 1 Marks", "View CAT 1 (CO1 & CO2) marks"));
rows.add(createRow("student_cat2_marks", "CAT 2 Marks", "View CAT 2 (CO2) marks")); rows.add(createRow("student_cat2_marks", "CAT 2 Marks", "View CAT 2 (CO3) marks"));
rows.add(createRow("student_cat3_marks", "CAT 3 Marks", "View CAT 3 (CO3) marks")); rows.add(createRow("student_cat3_marks", "CAT 3 Marks", "View CAT 3 (CO4 & CO5) marks"));
rows.add(createRow("student_assignment_marks", "Assignment Marks", "View assignments 1-5 marks")); rows.add(createRow("student_assignment_marks", "Assignment Marks", "View assignments 1-5 marks"));
Map<String, Object> interactiveList = WhatsAppMessageBuilder.buildListMessage( Map<String, Object> interactiveList = WhatsAppMessageBuilder.buildListMessage(

View File

@@ -22,6 +22,21 @@ public class UserEntity {
@Column(name = "is_faculty", columnDefinition = "boolean default false") @Column(name = "is_faculty", columnDefinition = "boolean default false")
private Boolean isFaculty = false; private Boolean isFaculty = false;
@Column(name = "name")
private String name;
@Column(name = "year")
private Integer year;
@Column(name = "department")
private String department;
@Column(name = "section")
private String section;
@Column(name = "email_id")
private String emailId;
public UserEntity() { public UserEntity() {
} }
@@ -69,4 +84,44 @@ public class UserEntity {
public void setFaculty(Boolean faculty) { public void setFaculty(Boolean faculty) {
isFaculty = faculty; isFaculty = faculty;
} }
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public Integer getYear() {
return year;
}
public void setYear(Integer year) {
this.year = year;
}
public String getDepartment() {
return department;
}
public void setDepartment(String department) {
this.department = department;
}
public String getSection() {
return section;
}
public void setSection(String section) {
this.section = section;
}
public String getEmailId() {
return emailId;
}
public void setEmailId(String emailId) {
this.emailId = emailId;
}
} }

View File

@@ -130,6 +130,16 @@ public class SessionService {
if (studentNames.containsKey(phoneNumber)) { if (studentNames.containsKey(phoneNumber)) {
return studentNames.get(phoneNumber); return studentNames.get(phoneNumber);
} }
// Try getting name from database first
Optional<UserEntity> userOpt = userRepository.findByPhoneNumber(phoneNumber);
if (userOpt.isPresent() && userOpt.get().getName() != null && !userOpt.get().getName().isEmpty()) {
String dbName = userOpt.get().getName();
studentNames.put(phoneNumber, dbName);
return dbName;
}
// Fallback to IMS API
String name; String name;
if (isFaculty(phoneNumber)) { if (isFaculty(phoneNumber)) {
name = imsApiService.getFacultyName(token); name = imsApiService.getFacultyName(token);

View File

@@ -285,6 +285,36 @@ public class MessageFormatter {
return defaultMsg; return defaultMsg;
} }
private static boolean isPresent(String val) {
return val != null && !val.trim().isEmpty() && !val.equalsIgnoreCase("N/A") && !val.equalsIgnoreCase("null");
}
private static Double parseMark(String val) {
if (!isPresent(val)) return null;
try {
return Double.parseDouble(val.trim());
} catch (NumberFormatException e) {
return null;
}
}
private static String formatMarkValue(Double val) {
if (val == null) return "N/A";
if (val == (long) val.doubleValue()) {
return String.format("%d", (long) val.doubleValue());
} else {
return String.format(java.util.Locale.US, "%.1f", val);
}
}
private static String formatDouble(double val) {
if (val == (long) val) {
return String.format("%d", (long) val);
} else {
return String.format(java.util.Locale.US, "%.2f", val);
}
}
public static String formatInternalMarks(String rawCatJson, String rawAssignmentJson) { public static String formatInternalMarks(String rawCatJson, String rawAssignmentJson) {
StringBuilder sb = new StringBuilder(); StringBuilder sb = new StringBuilder();
sb.append("📈 *INTERNAL MARKS REPORT*\n\n"); sb.append("📈 *INTERNAL MARKS REPORT*\n\n");
@@ -312,10 +342,17 @@ public class MessageFormatter {
String code = subject.has("code") ? subject.get("code").asText() : ""; String code = subject.has("code") ? subject.get("code").asText() : "";
String name = subject.has("name") ? subject.get("name").asText() : String name = subject.has("name") ? subject.get("name").asText() :
(subject.has("course_name") ? subject.get("course_name").asText() : "Subject"); (subject.has("course_name") ? subject.get("course_name").asText() : "Subject");
String co1 = subject.has("co1") ? subject.get("co1").asText().trim() : ""; String co1Str = subject.has("co1") ? subject.get("co1").asText().trim() : "";
String co2 = subject.has("co2") ? subject.get("co2").asText().trim() : ""; String co2Str = subject.has("co2") ? subject.get("co2").asText().trim() : "";
String total = subject.has("total") ? subject.get("total").asText().trim() : ""; String co3Str = subject.has("co3") ? subject.get("co3").asText().trim() : "";
String weightage = subject.has("weightage") ? subject.get("weightage").asText().trim() : ""; String co4Str = subject.has("co4") ? subject.get("co4").asText().trim() : "";
String co5Str = subject.has("co5") ? subject.get("co5").asText().trim() : "";
Double co1 = parseMark(co1Str);
Double co2 = parseMark(co2Str);
Double co3 = parseMark(co3Str);
Double co4 = parseMark(co4Str);
Double co5 = parseMark(co5Str);
sb.append("📚 *").append(name).append("*"); sb.append("📚 *").append(name).append("*");
if (!code.isEmpty()) { if (!code.isEmpty()) {
@@ -323,22 +360,39 @@ public class MessageFormatter {
} }
sb.append("\n"); sb.append("\n");
if (!co1.isEmpty() || !co2.isEmpty()) { int activeCos = 0;
sb.append(" ├─ "); double total = 0.0;
if (!co1.isEmpty()) sb.append("CO1: ").append(co1); java.util.List<String> catDetails = new java.util.ArrayList<>();
if (!co1.isEmpty() && !co2.isEmpty()) sb.append(" | ");
if (!co2.isEmpty()) sb.append("CO2: ").append(co2); if (co1 != null || co2 != null) {
sb.append("\n"); catDetails.add(" ├─ *CAT 1 (CO1 & CO2)*: " + formatMarkValue(co1) + " | " + formatMarkValue(co2));
sb.append(" └─ "); if (co1 != null) { total += co1; activeCos++; }
} else { if (co2 != null) { total += co2; activeCos++; }
sb.append(" └─ "); }
if (co3 != null) {
catDetails.add(" ├─ *CAT 2 (CO3)*: " + formatMarkValue(co3));
total += co3;
activeCos++;
}
if (co4 != null || co5 != null) {
catDetails.add(" ├─ *CAT 3 (CO4 & CO5)*: " + formatMarkValue(co4) + " | " + formatMarkValue(co5));
if (co4 != null) { total += co4; activeCos++; }
if (co5 != null) { total += co5; activeCos++; }
} }
sb.append("*Total*: *").append(total.isEmpty() ? "N/A" : total).append("*"); for (String detail : catDetails) {
if (!weightage.isEmpty()) { sb.append(detail).append("\n");
sb.append(" (").append(weightage).append(" wt)"); }
if (activeCos > 0) {
double maxMarks = activeCos * 25.0;
double weightage = total * 8.0 / 75.0;
double maxWeightage = activeCos * 8.0 / 3.0;
sb.append(" └─ *Total*: *").append(formatDouble(total)).append("/").append(formatDouble(maxMarks))
.append("* (").append(formatDouble(weightage)).append("/").append(formatDouble(maxWeightage)).append(" wt)\n\n");
} else {
sb.append(" └─ No CAT marks updated yet.\n\n");
} }
sb.append("\n\n");
foundData = true; foundData = true;
} }
} }
@@ -442,7 +496,8 @@ public class MessageFormatter {
if (targetArray != null && targetArray.size() > 0) { if (targetArray != null && targetArray.size() > 0) {
for (JsonNode subject : targetArray) { for (JsonNode subject : targetArray) {
String co1 = subject.has("co1") ? subject.get("co1").asText().trim() : ""; String co1 = subject.has("co1") ? subject.get("co1").asText().trim() : "";
if (!co1.isEmpty() && !co1.equalsIgnoreCase("N/A") && !co1.equalsIgnoreCase("null")) { String co2 = subject.has("co2") ? subject.get("co2").asText().trim() : "";
if (isPresent(co1) || isPresent(co2)) {
hasAnyCat1Marks = true; hasAnyCat1Marks = true;
break; break;
} }
@@ -458,14 +513,25 @@ public class MessageFormatter {
String code = subject.has("code") ? subject.get("code").asText() : ""; String code = subject.has("code") ? subject.get("code").asText() : "";
String name = subject.has("name") ? subject.get("name").asText() : String name = subject.has("name") ? subject.get("name").asText() :
(subject.has("course_name") ? subject.get("course_name").asText() : "Subject"); (subject.has("course_name") ? subject.get("course_name").asText() : "Subject");
String co1 = subject.has("co1") ? subject.get("co1").asText().trim() : ""; String co1Str = subject.has("co1") ? subject.get("co1").asText().trim() : "";
String co2Str = subject.has("co2") ? subject.get("co2").asText().trim() : "";
Double co1 = parseMark(co1Str);
Double co2 = parseMark(co2Str);
sb.append("📚 *").append(name).append("*"); sb.append("📚 *").append(name).append("*");
if (!code.isEmpty()) { if (!code.isEmpty()) {
sb.append(" (").append(code).append(")"); sb.append(" (").append(code).append(")");
} }
sb.append("\n"); sb.append("\n");
sb.append(" └─ *CAT 1 (CO1)*: *").append(co1.isEmpty() ? "N/A" : co1).append("*\n\n"); sb.append(" ├─ CO1: ").append(formatMarkValue(co1))
.append(" | CO2: ").append(formatMarkValue(co2)).append("\n");
double total = (co1 != null ? co1 : 0.0) + (co2 != null ? co2 : 0.0);
double weightage = total * 8.0 / 75.0;
sb.append(" ├─ *Total*: *").append(formatDouble(total)).append("/50*\n");
sb.append(" └─ *Internal Weightage*: *").append(formatDouble(weightage)).append("/5.33*\n\n");
foundData = true; foundData = true;
} }
} }
@@ -502,8 +568,8 @@ public class MessageFormatter {
boolean hasAnyCat2Marks = false; boolean hasAnyCat2Marks = false;
if (targetArray != null && targetArray.size() > 0) { if (targetArray != null && targetArray.size() > 0) {
for (JsonNode subject : targetArray) { for (JsonNode subject : targetArray) {
String co2 = subject.has("co2") ? subject.get("co2").asText().trim() : ""; String co3 = subject.has("co3") ? subject.get("co3").asText().trim() : "";
if (!co2.isEmpty() && !co2.equalsIgnoreCase("N/A") && !co2.equalsIgnoreCase("null")) { if (isPresent(co3)) {
hasAnyCat2Marks = true; hasAnyCat2Marks = true;
break; break;
} }
@@ -519,14 +585,22 @@ public class MessageFormatter {
String code = subject.has("code") ? subject.get("code").asText() : ""; String code = subject.has("code") ? subject.get("code").asText() : "";
String name = subject.has("name") ? subject.get("name").asText() : String name = subject.has("name") ? subject.get("name").asText() :
(subject.has("course_name") ? subject.get("course_name").asText() : "Subject"); (subject.has("course_name") ? subject.get("course_name").asText() : "Subject");
String co2 = subject.has("co2") ? subject.get("co2").asText().trim() : ""; String co3Str = subject.has("co3") ? subject.get("co3").asText().trim() : "";
Double co3 = parseMark(co3Str);
sb.append("📚 *").append(name).append("*"); sb.append("📚 *").append(name).append("*");
if (!code.isEmpty()) { if (!code.isEmpty()) {
sb.append(" (").append(code).append(")"); sb.append(" (").append(code).append(")");
} }
sb.append("\n"); sb.append("\n");
sb.append(" └─ *CAT 2 (CO2)*: *").append(co2.isEmpty() ? "N/A" : co2).append("*\n\n"); sb.append(" ├─ CO3: ").append(formatMarkValue(co3)).append("\n");
double total = co3 != null ? co3 : 0.0;
double weightage = total * 8.0 / 75.0;
sb.append(" ├─ *Total*: *").append(formatDouble(total)).append("/25*\n");
sb.append(" └─ *Internal Weightage*: *").append(formatDouble(weightage)).append("/2.67*\n\n");
foundData = true; foundData = true;
} }
} }
@@ -563,8 +637,9 @@ public class MessageFormatter {
boolean hasAnyCat3Marks = false; boolean hasAnyCat3Marks = false;
if (targetArray != null && targetArray.size() > 0) { if (targetArray != null && targetArray.size() > 0) {
for (JsonNode subject : targetArray) { for (JsonNode subject : targetArray) {
String co3 = subject.has("co3") ? subject.get("co3").asText().trim() : ""; String co4 = subject.has("co4") ? subject.get("co4").asText().trim() : "";
if (!co3.isEmpty() && !co3.equalsIgnoreCase("N/A") && !co3.equalsIgnoreCase("null")) { String co5 = subject.has("co5") ? subject.get("co5").asText().trim() : "";
if (isPresent(co4) || isPresent(co5)) {
hasAnyCat3Marks = true; hasAnyCat3Marks = true;
break; break;
} }
@@ -580,14 +655,25 @@ public class MessageFormatter {
String code = subject.has("code") ? subject.get("code").asText() : ""; String code = subject.has("code") ? subject.get("code").asText() : "";
String name = subject.has("name") ? subject.get("name").asText() : String name = subject.has("name") ? subject.get("name").asText() :
(subject.has("course_name") ? subject.get("course_name").asText() : "Subject"); (subject.has("course_name") ? subject.get("course_name").asText() : "Subject");
String co3 = subject.has("co3") ? subject.get("co3").asText().trim() : ""; String co4Str = subject.has("co4") ? subject.get("co4").asText().trim() : "";
String co5Str = subject.has("co5") ? subject.get("co5").asText().trim() : "";
Double co4 = parseMark(co4Str);
Double co5 = parseMark(co5Str);
sb.append("📚 *").append(name).append("*"); sb.append("📚 *").append(name).append("*");
if (!code.isEmpty()) { if (!code.isEmpty()) {
sb.append(" (").append(code).append(")"); sb.append(" (").append(code).append(")");
} }
sb.append("\n"); sb.append("\n");
sb.append(" └─ *CAT 3 (CO3)*: *").append(co3.isEmpty() ? "N/A" : co3).append("*\n\n"); sb.append(" ├─ CO4: ").append(formatMarkValue(co4))
.append(" | CO5: ").append(formatMarkValue(co5)).append("\n");
double total = (co4 != null ? co4 : 0.0) + (co5 != null ? co5 : 0.0);
double weightage = total * 8.0 / 75.0;
sb.append(" ├─ *Total*: *").append(formatDouble(total)).append("/50*\n");
sb.append(" └─ *Internal Weightage*: *").append(formatDouble(weightage)).append("/5.33*\n\n");
foundData = true; foundData = true;
} }
} }

View File

@@ -1,22 +1,22 @@
spring.application.name=whatsapp-bot spring.application.name=whatsapp-bot
server.port=8080 server.port=${PORT:8080}
# WhatsApp Verification Token (You provide this to Meta during webhook setup) # WhatsApp Verification Token (You provide this to Meta during webhook setup)
whatsapp.verify-token=rit_bot_secret_token_123 whatsapp.verify-token=${WHATSAPP_VERIFY_TOKEN:rit_bot_secret_token_123}
# WhatsApp Graph API Token (You get this from the Meta developer console)
# WhatsApp Phone Number ID (You get this from the Meta developer console)
whatsapp.phone-number-id=1239246362613929
# WhatsApp Graph API Token & Phone Number ID (You get these from the Meta developer console)
whatsapp.phone-number-id=${WHATSAPP_PHONE_NUMBER_ID:1239246362613929}
whatsapp.api-token=${WHATSAPP_API_TOKEN:EAAc3Wjql00oBSZAkH0ymUgZAJnxgkiPDfAKpvBQmfVZCVGZB3fZCED4pS9vGELKRqkCZC3lIkLbsEp0Qejhb1xJmWVvZArTGTTpZCXbwSUoN21cZAiKpkdw4uLrt2sR11UIy8p1ZBqVgFZB5Od9HfGVgvbWWBJSECEp7lq226Ap8UID3fHss7LsSgajxDEQWtxmy5NtsAZDZD}
whatsapp.dev-webhook-forward-url=${WHATSAPP_DEV_WEBHOOK_FORWARD_URL:http://127.0.0.1:2336/webhook}
# PostgreSQL Database Configuration # PostgreSQL Database Configuration
spring.datasource.url=${DB_URL} spring.datasource.url=${DB_URL:jdbc:postgresql://localhost:5432/IMS%20data}
spring.datasource.driver-class-name=org.postgresql.Driver spring.datasource.driver-class-name=org.postgresql.Driver
spring.datasource.username=${DB_USERNAME} spring.datasource.username=${DB_USERNAME:whatsapp_user}
spring.datasource.password=${DB_PASSWORD} spring.datasource.password=${DB_PASSWORD:RITHosting123}
spring.jpa.database-platform=org.hibernate.dialect.PostgreSQLDialect spring.jpa.database-platform=org.hibernate.dialect.PostgreSQLDialect
spring.jpa.hibernate.ddl-auto=update spring.jpa.hibernate.ddl-auto=${SPRING_JPA_HIBERNATE_DDL_AUTO:update}
# Encryption Secret for Passcodes (Must be 16, 24, or 32 bytes) # Encryption Secret for Passcodes (Must be 16, 24, or 32 bytes)
bot.encryption.secret=12345678901234567890123456789012 bot.encryption.secret=${BOT_ENCRYPTION_SECRET:12345678901234567890123456789012}
whatsapp.api-token=EAAc3Wjql00oBSTlrhFqV7uer16ZAEy5B0c4GXZAForXZCTGp8rUcpyL5yAbQvOFjC2T0ZAgUmTFSMDT00SGbaaQVQLlYqZBOmkd91tqVCSSTGJZCCzBB2pPEHr8ckxTZCSe0srBZAGl7IHX8ucODcwuzQm8TZBy2RrnGG4gAUZB9a0HHO4uFYZAZCyUZAv3i65GVRfainyAZDZD