|
|
@ -151,12 +151,13 @@ public class DataModelController extends BaseController {
|
|
|
|
ThreadGainOracleConnect thOrcl = new ThreadGainOracleConnect(form, OracleExtract);
|
|
|
|
ThreadGainOracleConnect thOrcl = new ThreadGainOracleConnect(form, OracleExtract);
|
|
|
|
thOrcl.start();
|
|
|
|
thOrcl.start();
|
|
|
|
for (int i = 0; i < 10; i++) {
|
|
|
|
for (int i = 0; i < 10; i++) {
|
|
|
|
|
|
|
|
Thread.sleep(400);
|
|
|
|
isConnect = thOrcl.isConnect();
|
|
|
|
isConnect = thOrcl.isConnect();
|
|
|
|
if (isConnect) {
|
|
|
|
if (isConnect) {
|
|
|
|
break;
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
else {
|
|
|
|
Thread.sleep(500);
|
|
|
|
Thread.sleep(100);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
@ -165,7 +166,7 @@ public class DataModelController extends BaseController {
|
|
|
|
else
|
|
|
|
else
|
|
|
|
req.setStatus(500);
|
|
|
|
req.setStatus(500);
|
|
|
|
// 开始抽取数据到汇总库
|
|
|
|
// 开始抽取数据到汇总库
|
|
|
|
if (null != form.getInneed() && form.getInneed().size() > 0) {
|
|
|
|
if (isConnect && null != form.getInneed() && form.getInneed().size() > 0) {
|
|
|
|
ThreadExtractOracle thExtra = new ThreadExtractOracle(form, OracleExtract);
|
|
|
|
ThreadExtractOracle thExtra = new ThreadExtractOracle(form, OracleExtract);
|
|
|
|
thExtra.start();
|
|
|
|
thExtra.start();
|
|
|
|
// OracleExtract.extractOracle(form.getName(), form.getInneed(),
|
|
|
|
// OracleExtract.extractOracle(form.getName(), form.getInneed(),
|
|
|
|