tiennm99/BSK-All-in-One-Clinic-Management-System
1
0 Fork 0
mirror of https://github.com/tiennm99/BSK-All-in-One-Clinic-Management-System.git synced 2026-10-12 20:15:28 +00:00
Code Issues Packages Projects Releases Wiki Activity

[add]! : new patient to checkup line

Browse Source
This commit is contained in:
lds217 committed 2025-02-17 02:18:13 -05:00
1 parent a072cc687b
commit 999ca16428
5 files changed
+163 -11
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

src/main/java/BsK/server/network/handler/ServerHandler.java
+24 -1
View File
@@ -333,10 +333,11 @@ public class ServerHandler extends SimpleChannelInboundHandler<TextWebSocketFram
String customerGender = rs.getString("customer_gender");
String result = String.join("|", customerId, customerLastName + " " + customerFirstName,
year, customerNumber, customerAddress, customerGender);
year, customerNumber, customerAddress, customerGender, customerDob);
resultList.add(result);
}
String[] resultString = resultList.toArray(new String[0]);
String[][] resultArray = new String[resultString.length][];
for (int i = 0; i < resultString.length; i++) {
@@ -453,6 +454,28 @@ public class ServerHandler extends SimpleChannelInboundHandler<TextWebSocketFram
throw new RuntimeException(e);
}
}
if (packet instanceof AddPatientRequest addPatientRequest) {
log.debug("Received AddPatientRequest");
try {
PreparedStatement preparedStatement = Server.connection.prepareStatement(
"INSERT INTO Customer (customer_last_name, customer_first_name, customer_dob, customer_number, customer_address, customer_gender) VALUES (?, ?, ?, ?, ?, ?)"
);
preparedStatement.setString(1, addPatientRequest.getPatientLastName());
preparedStatement.setString(2, addPatientRequest.getPatientFirstName());
preparedStatement.setLong(3, addPatientRequest.getPatientDob()); // DOB as long
preparedStatement.setString(4, addPatientRequest.getPatientPhone());
preparedStatement.setString(5, addPatientRequest.getPatientAddress());
preparedStatement.setString(6, addPatientRequest.getPatientGender());
preparedStatement.executeUpdate();
UserUtil.sendPacket(user.getSessionId(), new AddPatientResponse(true, "Thêm bệnh nhân thành công"));
} catch (SQLException e) {
String errorMessage = e.getMessage();
UserUtil.sendPacket(user.getSessionId(), new AddPatientResponse(false, "Lỗi: " + errorMessage));
throw new RuntimeException(e);
}
}
}
}