School/WasteInformationServer
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'origin/master'

Browse Source
This commit is contained in:
lukas-heiligenbrunner 2019-12-06 12:24:58 +01:00
commit f132ca9602
5 changed files with 35 additions and 38 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
.idea/misc.xml generated
View File

@ -1,7 +1,10 @@
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="ExternalStorageConfigurationManager" enabled="true" />
<component name="ProjectRootManager" version="2" languageLevel="JDK_13" project-jdk-name="13" project-jdk-type="JavaSDK">
<component name="JavaScriptSettings">
<option name="languageLevel" value="ES6" />
</component>
<component name="ProjectRootManager" version="2" languageLevel="JDK_11" project-jdk-name="11" project-jdk-type="JavaSDK">
<output url="file://$PROJECT_DIR$/out" />
</component>
</project>

33
src/java/com/wasteinformationserver/main.java
View File

@ -13,42 +13,41 @@ public class main {
Log.setLevel(Log.DEBUG);
Runtime.getRuntime().addShutdownHook(new Thread(() -> {
Runtime.getRuntime().addShutdownHook(new Thread(() -> {
try {
Thread.sleep(200);
Log.warning("Shutting down ...");
//shutdown routine
} catch (InterruptedException e) {
} catch (InterruptedException e) {
e.printStackTrace();
}
}));
//initial connect to db
//initial connect to db
Log.message("initial login to db");
new Thread(() -> {
try {
JDCB.init("users", "kOpaIJUjkgb9ur6S", "wasteinformation","192.168.65.15",3306);
} catch (IOException e) {
//e.printStackTrace();
Log.error("no connection to db");
}
}).start();
new Thread(() -> {
try {
JDCB.init("users", "kOpaIJUjkgb9ur6S", "wasteinformation", "192.168.65.15", 3306);
} catch (IOException e) {
//e.printStackTrace();
Log.error("no connection to db");
}
}).start();
//startup web server
//startup web server
Thread mythread = new Thread(() -> new Webserver().startserver());
mythread.start();
//startup mqtt service
Log.message("starting mqtt service");
try{
try {
mqtt m = new mqtt();
m.notifymessage();
}catch (Exception e){
e.printStackTrace();
} catch (Exception e) {
Log.debug("An error was happened in the class mqtt");
}
}
}

24
src/java/com/wasteinformationserver/mqtt/mqtt.java
View File

@ -33,7 +33,7 @@ public class mqtt {
client.connect(connOpts);
} catch (MqttException e) {
e.printStackTrace();
Log.error("Connection to the ESB was failes");
}
mqttreceiver mr = new mqttreceiver(client);
@ -56,7 +56,7 @@ public class mqtt {
try {
Database = JDCB.getInstance();
} catch (IOException e) {
//e.printStackTrace();
Log.error("No Connection to the databank");
}
//new JDCB("placeuser", "eaL956R6yFItQVBl", "wasteinformation");
ResultSet result = Database.executeQuery(message);
@ -77,23 +77,22 @@ public class mqtt {
String tempyearnew = yearsplit[1];
String newDate = parts[2] + "." + parts[1] + ".20" + tempyearnew;
String[] partstwo = date.split(" ");
String Datetomorrow=nexDayDate();
String Datetomorrow = nexDayDate();
int abholtag;
if (partstwo[0].contains(newDate)||partstwo[0].contains(Datetomorrow)) {
if (partstwo[0].contains(newDate) || partstwo[0].contains(Datetomorrow)) {
abholtag = 1;
transmitmessageAbfallart(clientidentify + "," + wastetyp + "," + abholtag);
}else {
abholtag=0;
} else {
abholtag = 0;
transmitmessageAbfallart(clientidentify + "," + wastetyp + "," + abholtag);
}
}
}
} catch (SQLException e) {
System.out.println("Exception");
e.printStackTrace();
Log.error("No data from databank");
}
}
@ -116,12 +115,9 @@ public class mqtt {
c.add(Calendar.DATE, 1);
Date currentDatePlusOne = c.getTime();
String temp=dateFormat.format(currentDatePlusOne);
String split[]=temp.split("/");
String newDate=split[2]+"."+split[1]+"."+split[0];
String temp = dateFormat.format(currentDatePlusOne);
String split[] = temp.split("/");
String newDate = split[2] + "." + split[1] + "." + split[0];
return newDate;
}
}

8
src/java/com/wasteinformationserver/mqtt/mqttreceiver.java
View File

@ -24,15 +24,15 @@ public class mqttreceiver {
public String getmessage() {
try {
client.setCallback(new MqttCallback() {
client.setCallback(new MqttCallback() {
@Override
public void connectionLost(Throwable throwable) {
Log.error("connection lost");
Log.error("connection lost");
}
@Override
public void messageArrived(String s, MqttMessage mqttMessage) throws Exception {
message =new String(mqttMessage.getPayload());
message = new String(mqttMessage.getPayload());
notifylisteners(message);
}
@ -45,7 +45,7 @@ Log.error("connection lost");
client.subscribe("TopicIn");
Log.debug("subscribed topic");
} catch (MqttException e) {
e.printStackTrace();
Log.error("Connection to the ESB was failed");
}
return message;
}

3
src/java/com/wasteinformationserver/mqtt/mqtttransmitter.java
View File

@ -12,7 +12,7 @@ public class mqtttransmitter {
MqttClient client;
public mqtttransmitter(MqttClient client) {
this.client=client;
this.client = client;
}
public void sendmessage(String temp) {
@ -36,7 +36,6 @@ public class mqtttransmitter {
Log.debug("loc " + me.getLocalizedMessage());
Log.debug("cause " + me.getCause());
Log.debug("excep " + me);
me.printStackTrace();
}
}
}