From a2380a4a31c84a993a0e097c65ec9a69e778b6b0 Mon Sep 17 00:00:00 2001 From: JSQui Date: Thu, 18 Aug 2022 08:29:31 -0700 Subject: [PATCH] Sends out message for service termination, when that time comes if ever. --- .../delegationServices.java | 52 +++++++++++++------ 1 file changed, 37 insertions(+), 15 deletions(-) diff --git a/src/main/java/com/jamesquinley/DelegationServices/delegationServices.java b/src/main/java/com/jamesquinley/DelegationServices/delegationServices.java index 97afbb1..ba6a06e 100644 --- a/src/main/java/com/jamesquinley/DelegationServices/delegationServices.java +++ b/src/main/java/com/jamesquinley/DelegationServices/delegationServices.java @@ -120,22 +120,44 @@ public class delegationServices { String blockedRG = (String) Filter.get("rgflag"); if ((Boolean)Filter.get("serviceState") == false) { - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("rid", Lrequest.get("rid")); + if ((Boolean)Filter.get("serviceTermination") == true) + { + BasicDBObject searchQuery = new BasicDBObject(); + searchQuery.append("rid", Lrequest.get("rid")); + + BasicDBObject updateQuery = new BasicDBObject(); + BasicDBObject updateQuery1 = new BasicDBObject(); + BasicDBObject updateQuery2 = new BasicDBObject(); + updateQuery.append("$set", + new BasicDBObject().append("type", 60)); + updateQuery2.append("$set", + new BasicDBObject().append("dn",Filter.get("serviceTerminationNotes"))); + updateQuery1.append("$set", + new BasicDBObject().append("status", true)); + dCollection.updateOne(searchQuery, updateQuery); + dCollection.updateOne(searchQuery, updateQuery2); + dCollection.updateOne(searchQuery, updateQuery1); + delegationTimer.DeleteTargetRequest(ClientID); + } else + { + BasicDBObject searchQuery = new BasicDBObject(); + searchQuery.append("rid", Lrequest.get("rid")); + + BasicDBObject updateQuery = new BasicDBObject(); + BasicDBObject updateQuery1 = new BasicDBObject(); + BasicDBObject updateQuery2 = new BasicDBObject(); + updateQuery.append("$set", + new BasicDBObject().append("type", 52)); + updateQuery2.append("$set", + new BasicDBObject().append("dn",Filter.get("deniedmsg"))); + updateQuery1.append("$set", + new BasicDBObject().append("status", true)); + dCollection.updateOne(searchQuery, updateQuery); + dCollection.updateOne(searchQuery, updateQuery2); + dCollection.updateOne(searchQuery, updateQuery1); + delegationTimer.DeleteTargetRequest(ClientID); + } - BasicDBObject updateQuery = new BasicDBObject(); - BasicDBObject updateQuery1 = new BasicDBObject(); - BasicDBObject updateQuery2 = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("type", 52)); - updateQuery2.append("$set", - new BasicDBObject().append("dn",Filter.get("deniedmsg"))); - updateQuery1.append("$set", - new BasicDBObject().append("status", true)); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery2); - dCollection.updateOne(searchQuery, updateQuery1); - delegationTimer.DeleteTargetRequest(ClientID); } else { if (blockedRG.contains(RG)) { BasicDBObject searchQuery = new BasicDBObject();