|  | @ -338,34 +338,37 @@ public class DatacollectService implements IDatacollectService {
 | 
	
		
			
				|  |  |                 //增量采集
 | 
	
		
			
				|  |  |                 String maxKey = "0";
 | 
	
		
			
				|  |  |                 String keyValue = ds.getJobDatasetKeyvalue();
 | 
	
		
			
				|  |  |                 if(key!=null && key.length()>0 &&(keyValue!=null&&!keyValue.equals("null")))
 | 
	
		
			
				|  |  |                 if(key!=null && key.length()>0)
 | 
	
		
			
				|  |  |                 {
 | 
	
		
			
				|  |  |                     maxKey = key;
 | 
	
		
			
				|  |  | 
 | 
	
		
			
				|  |  |                     if(keytype.toUpperCase().equals("DATE")) //时间类型
 | 
	
		
			
				|  |  |                     {
 | 
	
		
			
				|  |  |                         Date keyDate = new Date();
 | 
	
		
			
				|  |  |                         if(keyvalue!=null && keyvalue.length()>0) {
 | 
	
		
			
				|  |  |                             //字符串转时间
 | 
	
		
			
				|  |  |                             keyDate = DateConvert.toDate(keyvalue);
 | 
	
		
			
				|  |  |                             //根据数据库类型获取时间sql
 | 
	
		
			
				|  |  |                             strWhere += " and "+ key + ">'"+getDateSqlByDBType(dbType,keyDate)+"'";
 | 
	
		
			
				|  |  |                             strWhere += " order by "+ key;
 | 
	
		
			
				|  |  |                         }
 | 
	
		
			
				|  |  |                         //根据数据库类型获取时间sql
 | 
	
		
			
				|  |  |                         strWhere += " and "+ key + ">'"+getDateSqlByDBType(dbType,keyDate)+"'";
 | 
	
		
			
				|  |  |                         strWhere += " order by "+ key;
 | 
	
		
			
				|  |  | 
 | 
	
		
			
				|  |  |                     }
 | 
	
		
			
				|  |  |                     else if(keytype.toUpperCase().equals("VARCHAR")) //字符串类型
 | 
	
		
			
				|  |  |                     {
 | 
	
		
			
				|  |  |                         maxKey = getToNumberSqlByDBType(dbType,key);
 | 
	
		
			
				|  |  |                         if(keyvalue!=null && keyvalue.length()>0) {
 | 
	
		
			
				|  |  |                             strWhere += " and "+ maxKey + ">'" + keyvalue + "'";
 | 
	
		
			
				|  |  |                             strWhere += " order by "+ maxKey;
 | 
	
		
			
				|  |  |                         }
 | 
	
		
			
				|  |  |                         strWhere += " order by "+ maxKey;
 | 
	
		
			
				|  |  |                     }
 | 
	
		
			
				|  |  |                     else{
 | 
	
		
			
				|  |  |                         if(keyvalue!=null && keyvalue.length()>0) {
 | 
	
		
			
				|  |  |                             strWhere += " and "+ key + ">'" + keyvalue + "'";
 | 
	
		
			
				|  |  |                             strWhere += " order by "+ key;
 | 
	
		
			
				|  |  |                         }
 | 
	
		
			
				|  |  |                         strWhere += " order by "+ key;
 | 
	
		
			
				|  |  |                     }
 | 
	
		
			
				|  |  | 
 | 
	
		
			
				|  |  |                 }
 | 
	
		
			
				|  |  |                 strSql += strWhere;
 | 
	
		
			
				|  |  |                 //总条数和最大值查询
 | 
	
	
		
			
				|  | @ -560,7 +563,7 @@ public class DatacollectService implements IDatacollectService {
 | 
	
		
			
				|  |  |                     //增量采集
 | 
	
		
			
				|  |  |                     String maxKey = "0";
 | 
	
		
			
				|  |  |                     String keyValue = ds.getJobDatasetKeyvalue();
 | 
	
		
			
				|  |  |                     if (key != null && key.length() > 0 && (keyValue != null && !keyValue.equals("null"))) {
 | 
	
		
			
				|  |  |                     if (key != null && key.length() > 0) {
 | 
	
		
			
				|  |  |                         maxKey = key;
 | 
	
		
			
				|  |  |                         if (keytype.toUpperCase().equals("DATE")) //时间类型
 | 
	
		
			
				|  |  |                         {
 | 
	
	
		
			
				|  | @ -568,22 +571,23 @@ public class DatacollectService implements IDatacollectService {
 | 
	
		
			
				|  |  |                             if (keyvalue != null && keyvalue.length() > 0) {
 | 
	
		
			
				|  |  |                                 //字符串转时间
 | 
	
		
			
				|  |  |                                 keyDate = DateConvert.toDate(keyvalue);
 | 
	
		
			
				|  |  |                                 //根据数据库类型获取时间sql
 | 
	
		
			
				|  |  |                                 strWhere += " and " + key + ">'" + getDateSqlByDBType(dbType, keyDate) + "'";
 | 
	
		
			
				|  |  |                                 strWhere += " order by " + key;
 | 
	
		
			
				|  |  |                             }
 | 
	
		
			
				|  |  |                             //根据数据库类型获取时间sql
 | 
	
		
			
				|  |  |                             strWhere += " and " + key + ">'" + getDateSqlByDBType(dbType, keyDate) + "'";
 | 
	
		
			
				|  |  |                             strWhere += " order by " + key;
 | 
	
		
			
				|  |  | 
 | 
	
		
			
				|  |  |                         } else if (keytype.toUpperCase().equals("VARCHAR")) //字符串类型
 | 
	
		
			
				|  |  |                         {
 | 
	
		
			
				|  |  |                             maxKey = getToNumberSqlByDBType(dbType, key);
 | 
	
		
			
				|  |  |                             if (keyvalue != null && keyvalue.length() > 0) {
 | 
	
		
			
				|  |  |                                 strWhere += " and " + maxKey + ">'" + keyvalue + "'";
 | 
	
		
			
				|  |  |                                 strWhere += " order by " + maxKey;
 | 
	
		
			
				|  |  |                             }
 | 
	
		
			
				|  |  |                             strWhere += " order by " + maxKey;
 | 
	
		
			
				|  |  |                         } else {
 | 
	
		
			
				|  |  |                             if (keyvalue != null && keyvalue.length() > 0) {
 | 
	
		
			
				|  |  |                                 strWhere += " and " + key + ">'" + keyvalue + "'";
 | 
	
		
			
				|  |  |                                 strWhere += " order by " + key;
 | 
	
		
			
				|  |  |                             }
 | 
	
		
			
				|  |  |                             strWhere += " order by " + key;
 | 
	
		
			
				|  |  |                         }
 | 
	
		
			
				|  |  |                     }
 | 
	
		
			
				|  |  |                     strSql += strWhere;
 |