This allows me to sync to main PC
This commit is contained in:
@ -6,8 +6,11 @@ import com.mongodb.client.MongoClient;
|
|||||||
import com.mongodb.client.MongoClients;
|
import com.mongodb.client.MongoClients;
|
||||||
import com.mongodb.client.MongoCollection;
|
import com.mongodb.client.MongoCollection;
|
||||||
import com.mongodb.client.MongoDatabase;
|
import com.mongodb.client.MongoDatabase;
|
||||||
|
import com.mongodb.client.model.Filters;
|
||||||
|
import com.mongodb.client.model.Updates;
|
||||||
import org.bson.Document;
|
import org.bson.Document;
|
||||||
|
|
||||||
|
import static com.mongodb.client.model.Filters.eq;
|
||||||
import static java.util.concurrent.TimeUnit.SECONDS;
|
import static java.util.concurrent.TimeUnit.SECONDS;
|
||||||
|
|
||||||
public class delegationServices {
|
public class delegationServices {
|
||||||
@ -21,10 +24,35 @@ public class delegationServices {
|
|||||||
static MongoClient dClient = MongoClients.create(scReadsettings);
|
static MongoClient dClient = MongoClients.create(scReadsettings);
|
||||||
static MongoDatabase dClientDatabase = dClient.getDatabase("DelegationRequest");
|
static MongoDatabase dClientDatabase = dClient.getDatabase("DelegationRequest");
|
||||||
static MongoCollection<Document> dCollection = dClientDatabase.getCollection("accountRequest");
|
static MongoCollection<Document> dCollection = dClientDatabase.getCollection("accountRequest");
|
||||||
|
|
||||||
//still need to config
|
//still need to config
|
||||||
public static void delegationProcesser () {
|
public static void delegationProcesser() {
|
||||||
System.out.println("delegation Trigger Set");
|
System.out.println("delegation Trigger Set");
|
||||||
|
|
||||||
delegationTimer.trigger();
|
delegationTimer.trigger();
|
||||||
}
|
}
|
||||||
}
|
public static void clearMute ()
|
||||||
|
{
|
||||||
|
Document userLookMutedLookUp = dCollection.find(eq("complete", false)).first();
|
||||||
|
System.out.println(userLookMutedLookUp + "This is a debug Print at line 37");
|
||||||
|
try {
|
||||||
|
userAuthetication(userLookMutedLookUp);
|
||||||
|
} catch (NullPointerException NPE) {
|
||||||
|
System.out.println("There were no users to unmute");
|
||||||
|
delegationTimer.trigger();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
public static void userAuthetication (Document doc){
|
||||||
|
String tmpU = null;
|
||||||
|
tmpU = (String) doc.get("User");
|
||||||
|
dCollection.updateOne(eq("User", tmpU), Updates.set("npMUTE", false));
|
||||||
|
dCollection.updateOne(eq("User", tmpU), Updates.set("wordRC", 1));
|
||||||
|
dCollection.updateOne(eq("User", tmpU), Updates.set("Credits", 1000));
|
||||||
|
try {
|
||||||
|
clearMute();
|
||||||
|
} catch (Exception exr) {
|
||||||
|
System.out.println("Pending Authentication Completed");
|
||||||
|
delegationTimer.trigger();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
Reference in New Issue
Block a user