| | |
|---|
| | | import com.ruoyi.integration.api.feignClient.UploadRealTimeMonitoringDataClient; |
|---|
| | | import com.ruoyi.integration.api.model.ChargingOrderAndUploadRealTimeMonitoringDataDto; |
|---|
| | | import com.ruoyi.integration.api.model.UploadRealTimeMonitoringPageData; |
|---|
| | | import com.ruoyi.order.api.dto.ChargingStatisticeDTO; |
|---|
| | | import com.ruoyi.order.api.model.*; |
|---|
| | | import com.ruoyi.order.api.query.ChargingOrderQuery; |
|---|
| | | import com.ruoyi.common.core.dto.MongoChargingOrderQuery; |
|---|
| | |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 远程调用 监管平台查询前一天用能统计 |
|---|
| | | * @return |
|---|
| | | */ |
|---|
| | | @ResponseBody |
|---|
| | | @PostMapping(value = "/getChargingStatistics") |
|---|
| | | public R<List<TChargingOrder>> getChargingStatistics(@RequestBody ChargingStatisticeDTO dto) { |
|---|
| | | List<Long> collect = chargingOrderAccountingStrategyService.lambdaQuery().between(TChargingOrderAccountingStrategy::getCreateTime, dto.getStartTime(), dto.getEndTime()) |
|---|
| | | .list().stream().map(TChargingOrderAccountingStrategy::getChargingOrderId).collect(Collectors.toList()); |
|---|
| | | if (!collect.isEmpty()){ |
|---|
| | | List<TChargingOrder> list = chargingOrderService.lambdaQuery() |
|---|
| | | .in(TChargingOrder::getId,collect).list(); |
|---|
| | | return R.ok(list); |
|---|
| | | } |
|---|
| | | return R.ok(new ArrayList<TChargingOrder>()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 远程调用 增加管理后台赠送会员记录 |
|---|
