JamesQ/MatchmakingBackend
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Sends out message for service termination, when that time comes if ever.

Browse Source
This commit is contained in:
JSQui 2022-08-18 08:29:31 -07:00
parent 489196ea2a
commit a2380a4a31
1 changed files with 37 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/main/java/com/jamesquinley/DelegationServices/delegationServices.java
View File

@ -119,6 +119,26 @@ public class delegationServices {
Filter = RGFilter.find(eq("rgkey", "UAROCKS")).first(); Filter = RGFilter.find(eq("rgkey", "UAROCKS")).first();
String blockedRG = (String) Filter.get("rgflag"); String blockedRG = (String) Filter.get("rgflag");
if ((Boolean)Filter.get("serviceState") == false) if ((Boolean)Filter.get("serviceState") == false)
{
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(); BasicDBObject searchQuery = new BasicDBObject();
searchQuery.append("rid", Lrequest.get("rid")); searchQuery.append("rid", Lrequest.get("rid"));
@ -136,6 +156,8 @@ public class delegationServices {
dCollection.updateOne(searchQuery, updateQuery2); dCollection.updateOne(searchQuery, updateQuery2);
dCollection.updateOne(searchQuery, updateQuery1); dCollection.updateOne(searchQuery, updateQuery1);
delegationTimer.DeleteTargetRequest(ClientID); delegationTimer.DeleteTargetRequest(ClientID);
}
} else { } else {
if (blockedRG.contains(RG)) { if (blockedRG.contains(RG)) {
BasicDBObject searchQuery = new BasicDBObject(); BasicDBObject searchQuery = new BasicDBObject();