|
@@ -32,7 +32,6 @@ import java.time.format.DateTimeFormatter;
|
|
|
import java.util.ArrayList;
|
|
|
import java.util.Date;
|
|
|
import java.util.List;
|
|
|
-import java.util.Map;
|
|
|
|
|
|
@Slf4j
|
|
|
@Service
|
|
@@ -165,7 +164,7 @@ public class SyncData {
|
|
|
meterReadRecordList.clear();
|
|
|
}
|
|
|
}
|
|
|
- if(meterReadRecordList.size() != 0){
|
|
|
+ if(!meterReadRecordList.isEmpty()){
|
|
|
int insert = meterReadRecordMapper.batchInsert(meterReadRecordList);
|
|
|
i = i+insert ;
|
|
|
meterReadRecordList.clear();
|
|
@@ -252,7 +251,7 @@ public class SyncData {
|
|
|
meterReadRecord.setReadTime(changeDateType(meterRecord.getReadingTime()));
|
|
|
meterReadRecord.setReadData(reading);
|
|
|
BigDecimal todayCost = BigDecimal.valueOf(calculateTodayCost(reading,
|
|
|
- new Double(meterReadRecord.getLastValid()),meterReadRecord));
|
|
|
+ new Double(meterReadRecord.getLastValid())));
|
|
|
|
|
|
todayCost = todayCost.setScale(3,BigDecimal.ROUND_HALF_UP);
|
|
|
meterReadRecord.setLastCost(todayCost);
|
|
@@ -263,12 +262,12 @@ public class SyncData {
|
|
|
}
|
|
|
|
|
|
}
|
|
|
- private Double calculateTodayCost(String currentReading,Double lastValid,MeterReadRecord record){
|
|
|
+ private Double calculateTodayCost(String currentReading,Double lastValid){
|
|
|
|
|
|
|
|
|
Double currentValid = new Double(currentReading);
|
|
|
- Double cost = currentValid-lastValid;
|
|
|
- return cost ;
|
|
|
+ return currentValid-lastValid;
|
|
|
+
|
|
|
}
|
|
|
/**
|
|
|
* 获取水表最后止度,先从缓存中获取止度,缓存无数据则从数据库中获取
|
|
@@ -330,15 +329,13 @@ public class SyncData {
|
|
|
* @return
|
|
|
*/
|
|
|
protected String getMeterLastDataFromCache(Long deviceId){
|
|
|
- Map<String, MeasuringData> data = null;
|
|
|
return redisUtil.get(Constants.PREFIX_CACHE_FLAG+deviceId);
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
public MeterReadRecord findRecordByMeterIdAndReadDate(WaterMeter waterMeter, Integer readDate) {
|
|
|
- MeterReadRecord record = meterReadRecordMapper.findRecordByReadDayAndDeviceId(waterMeter.getDeviceId(), readDate);
|
|
|
- return record;
|
|
|
+ return meterReadRecordMapper.findRecordByReadDayAndDeviceId(waterMeter.getDeviceId(), readDate);
|
|
|
}
|
|
|
protected void setMeterLastDataToCache(Long deviceId ,String measuringData){
|
|
|
redisUtil.set(Constants.PREFIX_CACHE_FLAG+deviceId,measuringData);
|