dfdf
修改密码漏洞修复完成
6 months ago
parent
ba7deb683c
commit
d407de3865
@ -0,0 +1,8 @@
|
||||
package com.rehome.mqttclienttemperature.service;
|
||||
|
||||
import com.rehome.mqttclienttemperature.dto.ResponseDto;
|
||||
import com.rehome.mqttclienttemperature.entity.Temperature;
|
||||
|
||||
public interface OracleTemperatureService {
|
||||
ResponseDto saveTemperature(Temperature temperature);
|
||||
}
|
||||
@ -0,0 +1,65 @@
|
||||
package com.rehome.mqttclienttemperature.service.impl;
|
||||
|
||||
import com.google.gson.Gson;
|
||||
import com.rehome.mqttclienttemperature.datasource.DataSource;
|
||||
import com.rehome.mqttclienttemperature.dto.ResponseDto;
|
||||
import com.rehome.mqttclienttemperature.entity.Temperature;
|
||||
import com.rehome.mqttclienttemperature.service.OracleTemperatureService;
|
||||
import com.rehome.mqttclienttemperature.utils.JdbcUtil;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
import java.text.SimpleDateFormat;
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
import java.util.concurrent.CompletableFuture;
|
||||
import java.util.concurrent.ExecutorService;
|
||||
import java.util.concurrent.Executors;
|
||||
|
||||
@Slf4j
|
||||
@Service
|
||||
public class OracleTemperatureServiceImpl implements OracleTemperatureService {
|
||||
public static DataSource ds = new DataSource();
|
||||
static {
|
||||
//配置数据源
|
||||
ds.setId("200");
|
||||
ds.setName("oracle");
|
||||
ds.setUrl("jdbc:oracle:thin:@192.168.3.9:1521/orcl");
|
||||
ds.setUsername("appserver");
|
||||
ds.setPassword("appserver");
|
||||
ds.setDriver("oracle.jdbc.driver.OracleDriver");
|
||||
}
|
||||
|
||||
@Override
|
||||
public ResponseDto saveTemperature(Temperature temperature) {
|
||||
// 自定义一个线程池,内部包含8个线程
|
||||
ExecutorService customPool = Executors.newFixedThreadPool(8);
|
||||
CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
|
||||
String sql = "insert into temperature(id,temperature, humidity, data_date, data_hour, data_minute, topic, location_desc, create_date) values(temperature_seq_appserver.NEXTVAL, ?, ?, ?, ?, ?, ?, ?, CURRENT_TIMESTAMP)";
|
||||
List<Object> jdbcParamValues = new ArrayList<>();
|
||||
|
||||
jdbcParamValues.add(temperature.getTemperature());
|
||||
jdbcParamValues.add(temperature.getHumidity());
|
||||
jdbcParamValues.add(temperature.getDataDate());
|
||||
jdbcParamValues.add(temperature.getDataHour());
|
||||
jdbcParamValues.add(temperature.getDataMinute());
|
||||
jdbcParamValues.add(temperature.getTopic());
|
||||
jdbcParamValues.add(temperature.getLocationDesc());
|
||||
//jdbcParamValues.add(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(temperature.getCreateDate()));
|
||||
|
||||
Gson gson = new Gson();
|
||||
ResponseDto responseDto = JdbcUtil.executeSql(ds, sql, jdbcParamValues);
|
||||
String dbQueryResult = gson.toJson(responseDto);
|
||||
log.info(dbQueryResult);
|
||||
jdbcParamValues.clear();
|
||||
|
||||
return "数据库同步成功";
|
||||
}, customPool);
|
||||
|
||||
future.thenApply(result -> {
|
||||
log.info("Result: " + result);
|
||||
return ResponseDto.successWithMsg(result);
|
||||
}).join();
|
||||
return ResponseDto.successWithMsg("数据库正在同步...");
|
||||
}
|
||||
}
|
||||
Loading…
Reference in New Issue