|
@@ -50,7 +50,7 @@ public class MeterReadRecordDao extends BaseDao<MeterReadRecord, String> impleme
|
|
* @param id, readDate
|
|
* @param id, readDate
|
|
* @return com.zcxk.rmcp.api.vo.MeterReadRecordVo
|
|
* @return com.zcxk.rmcp.api.vo.MeterReadRecordVo
|
|
**/
|
|
**/
|
|
- public MeterReadRecordVo findMeterReadRecord(String id, String readDate){
|
|
|
|
|
|
+ public MeterReadRecordVo findMeterReadRecord(Long id, String readDate){
|
|
AggregationOptions aggregationOptions = AggregationOptions.builder().allowDiskUse(true).build();
|
|
AggregationOptions aggregationOptions = AggregationOptions.builder().allowDiskUse(true).build();
|
|
Aggregation agg = Aggregation.newAggregation(
|
|
Aggregation agg = Aggregation.newAggregation(
|
|
Aggregation.match(Criteria.where("id").is(id)),
|
|
Aggregation.match(Criteria.where("id").is(id)),
|
|
@@ -96,7 +96,7 @@ public class MeterReadRecordDao extends BaseDao<MeterReadRecord, String> impleme
|
|
Update update = new Update();
|
|
Update update = new Update();
|
|
update.set("data.$.readData",dto.getReadData());
|
|
update.set("data.$.readData",dto.getReadData());
|
|
update.set("data.$.readStatus", ReadStatusEnum.READ.getCode());
|
|
update.set("data.$.readStatus", ReadStatusEnum.READ.getCode());
|
|
- update.set("data.$.readTime", LocalDateTime.now());
|
|
|
|
|
|
+ update.set("data.$.readTime", System.currentTimeMillis());
|
|
update.set("data.$.lastCost", BigDecimalUtils.subtract(meterReadRecordVo.getData().getLastValid(), new BigDecimal(dto.getReadData())));
|
|
update.set("data.$.lastCost", BigDecimalUtils.subtract(meterReadRecordVo.getData().getLastValid(), new BigDecimal(dto.getReadData())));
|
|
update.set("data.$.createBy", UserUtil.getCurrentUser().getUsername());
|
|
update.set("data.$.createBy", UserUtil.getCurrentUser().getUsername());
|
|
return upsert(query,update).getModifiedCount();
|
|
return upsert(query,update).getModifiedCount();
|