修复数据推送bug

iot-data-processor/src/main/java/com/zcxk/zoniot/data/processor/service/impl/CacheDataProcessor.java

@@ -57,7 +57,7 @@ public class CacheDataProcessor extends DeviceDataProcessor {
             measuringDataMap.put(Constants.TIME_MEASURING_CODE,timeMeasuringData);
             // 2,将数据缓存到Redis中
             Long deviceId = data.getDeviceId();
-            String cacheKey = Constants.DATA_CACHE_PREFIX + deviceId ;
+            String cacheKey = String.valueOf(deviceId);
             redisUtil.set(cacheKey, JSON.toJSONString(measuringDataMap));
             // 3,将最后更新时间更新到数据库
             Device update = new Device();

iot-data-processor/src/main/java/com/zcxk/zoniot/data/processor/service/impl/WaterMeterDataProcessor.java

@@ -152,6 +152,7 @@ public class WaterMeterDataProcessor extends DeviceDataProcessor{
         meterReadRecord.setReadStatus(2);
         meterReadRecord.setSiteId(deviceData.getSiteId());
         meterReadRecord.setReadData(getReadData(deviceData,waterMeterType));
+        meterReadRecord.setStatus(1);
         return meterReadRecord ;
     }