Просмотр исходного кода

采集数据存入redis的数据类型调整

chenwen 1 год назад
Родитель
Сommit
0029a30b81

+ 3 - 3
src/main/java/com/hb/proj/gather/business/DataTransRepSingleTask.java

@@ -69,10 +69,10 @@ public class DataTransRepSingleTask implements Runnable{
 	}
 	}
 	
 	
 	
 	
-	private Map<String,String> buildRedisDatas(List<SingleInsertPO> insPOs) {
-		Map<String,String> rtn=new HashMap<>(insPOs.size());
+	private Map<String,Float> buildRedisDatas(List<SingleInsertPO> insPOs) {
+		Map<String,Float> rtn=new HashMap<>(insPOs.size());
 		for(SingleInsertPO po : insPOs) {
 		for(SingleInsertPO po : insPOs) {
-			rtn.put(po.getParamCode(), String.valueOf(po.getDataVal()));
+			rtn.put(po.getParamCode(), po.getDataVal());
 		}
 		}
 		return rtn;
 		return rtn;
 	}
 	}

+ 3 - 3
src/main/java/com/hb/proj/gather/rep/RedisRepComponent.java

@@ -15,15 +15,15 @@ import org.springframework.stereotype.Component;
 public class RedisRepComponent {
 public class RedisRepComponent {
 
 
 	@Autowired
 	@Autowired
-	private RedisTemplate<String,String> redisTemplate;
+	private RedisTemplate<String,Object> redisTemplate;
 	
 	
 	/**
 	/**
 	 * 实时数据入redis
 	 * 实时数据入redis
 	 * @param wellId
 	 * @param wellId
 	 * @param datas
 	 * @param datas
 	 */
 	 */
-	public void put(String wellId,Map<String,String> datas) {
-		HashOperations<String, String, String>  ops=redisTemplate.opsForHash();
+	public void put(String wellId,Map<String,Float> datas) {
+		HashOperations<String, String, Float>  ops=redisTemplate.opsForHash();
 		ops.putAll(wellId, datas);
 		ops.putAll(wellId, datas);
 	}
 	}
 }
 }