|
|
|
|
@ -40,53 +40,56 @@ public class TemperatureServiceImpl implements TemperatureService {
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
public void saveTemperature(String temperatureAndHumidityData,String topic) {
|
|
|
|
|
if(temperatureAndHumidityData!=null&&temperatureAndHumidityData.length()>0){
|
|
|
|
|
String[] strDataTemperature = temperatureAndHumidityData.split(" ");
|
|
|
|
|
Date now = new Date();
|
|
|
|
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
|
|
|
|
SimpleDateFormat sdfHour = new SimpleDateFormat("yyyy-MM-dd HH");
|
|
|
|
|
SimpleDateFormat sdfMinute = new SimpleDateFormat("yyyy-MM-dd HH:mm");
|
|
|
|
|
SimpleDateFormat sdfSecond = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|
|
|
|
|
|
|
|
|
String nowDate = sdf.format(now);
|
|
|
|
|
String nowHour = sdfHour.format(now);
|
|
|
|
|
String dataMinute = sdfMinute.format(now);
|
|
|
|
|
String dataSecond = sdfSecond.format(now);
|
|
|
|
|
Temperature temperature = new Temperature();
|
|
|
|
|
temperature.setCreateDate(now);
|
|
|
|
|
temperature.setDataDate(nowDate);
|
|
|
|
|
temperature.setDataHour(nowHour);
|
|
|
|
|
temperature.setDataMinute(dataMinute);
|
|
|
|
|
if(topic!=null){
|
|
|
|
|
temperature.setTopic(topic);
|
|
|
|
|
if(topic.equals("WifiSHT/7C87CE9CA4E6/SHT20")){
|
|
|
|
|
temperature.setLocationDesc("广东省珠海市高新区唐家湾镇东岸村水风三街28号501");
|
|
|
|
|
try {
|
|
|
|
|
if(temperatureAndHumidityData!=null&&temperatureAndHumidityData.length()>0){
|
|
|
|
|
String[] strDataTemperature = temperatureAndHumidityData.split(" ");
|
|
|
|
|
Date now = new Date();
|
|
|
|
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
|
|
|
|
SimpleDateFormat sdfHour = new SimpleDateFormat("yyyy-MM-dd HH");
|
|
|
|
|
SimpleDateFormat sdfMinute = new SimpleDateFormat("yyyy-MM-dd HH:mm");
|
|
|
|
|
SimpleDateFormat sdfSecond = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|
|
|
|
|
|
|
|
|
String nowDate = sdf.format(now);
|
|
|
|
|
String nowHour = sdfHour.format(now);
|
|
|
|
|
String dataMinute = sdfMinute.format(now);
|
|
|
|
|
String dataSecond = sdfSecond.format(now);
|
|
|
|
|
Temperature temperature = new Temperature();
|
|
|
|
|
temperature.setCreateDate(now);
|
|
|
|
|
temperature.setDataDate(nowDate);
|
|
|
|
|
temperature.setDataHour(nowHour);
|
|
|
|
|
temperature.setDataMinute(dataMinute);
|
|
|
|
|
if(topic!=null){
|
|
|
|
|
temperature.setTopic(topic);
|
|
|
|
|
if(topic.equals("WifiSHT/7C87CE9CA4E6/SHT20")){
|
|
|
|
|
temperature.setLocationDesc("广东省珠海市高新区唐家湾镇东岸村水风三街28号501");
|
|
|
|
|
}
|
|
|
|
|
if(topic.equals("WifiSHT/7C87CE9F5CBF/SHT20")){
|
|
|
|
|
temperature.setLocationDesc("广东省珠海市金湾区三灶镇百川路1号1栋1单元1508房");
|
|
|
|
|
}
|
|
|
|
|
if(topic.equals("WifiSHT/4CEBD686B6AA/SHT20")){
|
|
|
|
|
temperature.setLocationDesc("广西壮族自治区崇左市天等县天等镇荣华村弄在屯113号");
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
if(topic.equals("WifiSHT/7C87CE9F5CBF/SHT20")){
|
|
|
|
|
temperature.setLocationDesc("广东省珠海市金湾区三灶镇百川路1号1栋1单元1508房");
|
|
|
|
|
}
|
|
|
|
|
if(topic.equals("WifiSHT/4CEBD686B6AA/SHT20")){
|
|
|
|
|
temperature.setLocationDesc("广西壮族自治区崇左市天等县天等镇荣华村弄在屯113号");
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
temperature.setHumidity(strDataTemperature[0]);
|
|
|
|
|
temperature.setTemperature(strDataTemperature[1]);
|
|
|
|
|
temperature.setHumidity(strDataTemperature[0]);
|
|
|
|
|
temperature.setTemperature(strDataTemperature[1]);
|
|
|
|
|
|
|
|
|
|
this.temperatureRepository.save(temperature);
|
|
|
|
|
mysqlTemperatureService.saveTemperature(temperature);
|
|
|
|
|
this.temperatureRepository.save(temperature);
|
|
|
|
|
mysqlTemperatureService.saveTemperature(temperature);
|
|
|
|
|
|
|
|
|
|
ResponseDto responseDtoOracle = this.oracleTemperatureService.saveTemperature(temperature);
|
|
|
|
|
log.info(new Gson().toJson(responseDtoOracle));
|
|
|
|
|
ResponseDto responseDtoOracle = this.oracleTemperatureService.saveTemperature(temperature);
|
|
|
|
|
log.info(new Gson().toJson(responseDtoOracle));
|
|
|
|
|
|
|
|
|
|
ResponseDto responseDtoSqlserver = this.sqlServerTemperatureService.saveTemperature(temperature);
|
|
|
|
|
log.info(new Gson().toJson(responseDtoSqlserver));
|
|
|
|
|
ResponseDto responseDtoSqlserver = this.sqlServerTemperatureService.saveTemperature(temperature);
|
|
|
|
|
log.info(new Gson().toJson(responseDtoSqlserver));
|
|
|
|
|
|
|
|
|
|
// ResponseDto responseDtoKingBase = this.kingbaseTemperatureService.saveTemperature(temperature);
|
|
|
|
|
// log.info(new Gson().toJson(responseDtoKingBase));
|
|
|
|
|
|
|
|
|
|
ResponseDto responseDtoSPg = this.postgresSqlTemperatureService.saveTemperature(temperature);
|
|
|
|
|
log.info(new Gson().toJson(responseDtoSPg));
|
|
|
|
|
|
|
|
|
|
ResponseDto responseDtoSPg = this.postgresSqlTemperatureService.saveTemperature(temperature);
|
|
|
|
|
log.info(new Gson().toJson(responseDtoSPg));
|
|
|
|
|
}
|
|
|
|
|
}catch (Exception e){
|
|
|
|
|
e.printStackTrace();
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|