|
@ -144,12 +144,19 @@ public class DatacollectDao extends SQLGeneralDAO implements IDatacollectDao {
|
|
|
*/
|
|
|
public List<DtoJobDataset> getDatacollectDataset(String jobId) throws Exception
|
|
|
{
|
|
|
//通过jobId获取机构版本号
|
|
|
String sqlVersion ="select a.adapter_std_version\n" +
|
|
|
"from rs_job_config c,(SELECT s.adapter_std_version,v.version from adapter_scheme s,adapter_scheme_version v where s.id=v.scheme_id) a\n" +
|
|
|
"where a.version = c.scheme_version\n" +
|
|
|
"and c.id='"+jobId+"'";
|
|
|
String version = super.scalarBySql(sqlVersion,String.class);
|
|
|
|
|
|
String sql = "select d.*,\n" +
|
|
|
"t.datasource_id,t.datasource_name,t.config,t.type,t.org_code\n" +
|
|
|
"from rs_job_dataset d\n" +
|
|
|
"LEFT JOIN (select s.dataset_id,s.datasource_id,ss.name as datasource_name,ss.config,ss.type,ss.org_code \n" +
|
|
|
"\tfrom rs_datasource_dataset s,(select ds.id,ds.name,ds.config,ds.type,o.code as org_code from system_datasource ds,system_organization o where ds.org_id=o.id) ss where s.datasource_id=ss.id) t \n" +
|
|
|
"on d.job_dataset_id = t.dataset_id\n" +
|
|
|
"\tfrom rs_datasource_dataset s,(select ds.id,ds.name,ds.config,ds.type,o.code as org_code from system_datasource ds,system_organization o where ds.org_id=o.id) ss where s.datasource_id=ss.id and s.Std_version='"+version+"') t \n" +
|
|
|
"on d.job_dataset_id = t.dataset_id \n" +
|
|
|
"where d.job_id='"+jobId+"'\n" +
|
|
|
"order by d.sort";
|
|
|
return super.queryListBySql(sql,DtoJobDataset.class);
|