48 lines
1.3 KiB
Java
48 lines
1.3 KiB
Java
package com.platform.service.thread;
|
|
|
|
import com.base.Custom4exception;
|
|
import com.base.CustomException;
|
|
import com.platform.entities.OracleConnectorParams;
|
|
import com.platform.form.OracleForm;
|
|
import com.platform.service.IOracleExtractService;
|
|
import com.platform.utils.CacheSetCantDelete;
|
|
|
|
/** oracle汇总库抽取
|
|
* @author chen
|
|
*
|
|
*/
|
|
public class ThreadExtractOracle extends Thread {
|
|
|
|
private IOracleExtractService OracleExtract;
|
|
|
|
private OracleForm form;
|
|
|
|
/** oracle汇总库抽取
|
|
* @param form
|
|
* @param OracleExtract
|
|
*/
|
|
public ThreadExtractOracle(OracleForm form, IOracleExtractService OracleExtract) {
|
|
this.setDaemon(true);
|
|
this.OracleExtract = OracleExtract;
|
|
this.form = form;
|
|
}
|
|
|
|
@Override
|
|
public void run() {
|
|
//保存 正zai汇总的数据id
|
|
for (OracleConnectorParams element : form.getInneed()) {
|
|
CacheSetCantDelete.addExtractId(element.getDataId());
|
|
}
|
|
try {
|
|
OracleExtract.extractOracle(form.getName(), form.getInneed(),form.getTarget());
|
|
} catch (Exception e) {
|
|
new CustomException(Custom4exception.threadVolume_Oracle_Except,e,form,OracleExtract);
|
|
}
|
|
//删除 汇总完成的数据id
|
|
for (OracleConnectorParams element : form.getInneed()) {
|
|
CacheSetCantDelete.removeExtractId(element.getDataId());
|
|
}
|
|
}
|
|
|
|
}
|