| 
					
				 | 
			
			
				@ -12,6 +12,7 @@ import com.yihu.iot.datainput.util.RowKeyUtils; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				import com.yihu.iot.service.device.IotDeviceService; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				import com.yihu.jw.iot.device.IotDeviceDO; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				import com.yihu.jw.util.date.DateUtil; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				import org.apache.commons.lang.StringUtils; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				import org.apache.http.client.utils.DateUtils; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				import org.slf4j.Logger; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				import org.slf4j.LoggerFactory; 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@ -168,6 +169,9 @@ public class DataInputService { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            Map<String, Map<String, String>> family = new HashMap<>(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            Map<String, String> columnsB = new HashMap<>(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            for(String key:data.keySet()){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                if(StringUtils.equalsIgnoreCase("rid",key)){ //存到hbase里的数据不需要rid 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                    continue; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                columnsB.put(key,data.getString(key)); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            if(data.containsKey("ecg")){ 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@ -199,7 +203,7 @@ public class DataInputService { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				        JSONObject result = new JSONObject(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				        JSONArray rids = new JSONArray(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				        rids.addAll(rowkeyList); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				        result.put("id",rids); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				        result.put("rid",rids); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				        result.put("upload_time",DateUtils.formatDate(new Date(), DateUtil.yyyy_MM_dd_HH_mm_ss)); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				        return result.toJSONString(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				    } 
			 |