From fca00ddabb395a44c99b0a39b47a7cd2955aede0 Mon Sep 17 00:00:00 2001
From: puzhibing <393733352@qq.com>
Date: 星期五, 18 十月 2024 10:51:32 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'

---
 ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/controller/TChargingOrderController.java |  102 +++++++++++++++++++++++++++-----------------------
 1 files changed, 55 insertions(+), 47 deletions(-)

diff --git a/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/controller/TChargingOrderController.java b/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/controller/TChargingOrderController.java
index 114a346..c38aabe 100644
--- a/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/controller/TChargingOrderController.java
+++ b/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/controller/TChargingOrderController.java
@@ -1,6 +1,5 @@
 package com.ruoyi.order.controller;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
-import com.google.common.collect.Lists;
 
 import java.math.BigDecimal;
 import java.math.RoundingMode;
@@ -21,29 +20,24 @@
 import com.ruoyi.chargingPile.api.model.Site;
 import com.ruoyi.chargingPile.api.model.TChargingGun;
 import com.ruoyi.chargingPile.api.model.TChargingPile;
-import com.ruoyi.chargingPile.api.model.TParkingRecord;
-import com.ruoyi.chargingPile.api.vo.SiteVO;
 import com.ruoyi.common.core.domain.R;
 import com.ruoyi.common.core.dto.ChargingOrderGroup;
 import com.ruoyi.common.core.dto.ChargingPercentProvinceDto;
-import com.ruoyi.common.core.utils.DateUtils;
 import com.ruoyi.common.redis.service.RedisService;
 import com.ruoyi.common.security.service.TokenService;
 import com.ruoyi.common.core.web.domain.AjaxResult;
-import com.ruoyi.common.core.web.page.BasePage;
 import com.ruoyi.common.core.web.page.PageInfo;
 import com.ruoyi.integration.api.model.UploadRealTimeMonitoringData;
 import com.ruoyi.common.security.utils.SecurityUtils;
 import com.ruoyi.integration.api.feignClient.UploadRealTimeMonitoringDataClient;
 import com.ruoyi.integration.api.model.ChargingOrderAndUploadRealTimeMonitoringDataDto;
-import com.ruoyi.integration.api.model.UploadRealTimeMonitoringData;
 import com.ruoyi.order.api.model.*;
 import com.ruoyi.order.api.query.ChargingOrderQuery;
+import com.ruoyi.common.core.dto.MongoChargingOrderQuery;
 import com.ruoyi.order.api.query.TChargingCountQuery;
 import com.ruoyi.order.api.query.UploadRealTimeMonitoringDataQuery;
 import com.ruoyi.order.api.vo.*;
 import com.ruoyi.order.api.vo.ChargingOrderInfoVO;
-import com.ruoyi.order.api.vo.ChargingOrderVO;
 import com.ruoyi.order.api.vo.GetChargingOrderByLicensePlate;
 import com.ruoyi.order.api.vo.TCharingOrderVO;
 import com.ruoyi.order.dto.GetMyChargingOrderList;
@@ -53,17 +47,14 @@
 import com.ruoyi.order.dto.OrderEvaluateVo;
 import com.ruoyi.order.dto.*;
 import com.ruoyi.order.service.*;
-import com.ruoyi.order.service.impl.TChargingOrderServiceImpl;
 import com.ruoyi.order.util.PreviousSixMonths;
+import com.ruoyi.order.vo.EndOfChargePageInfo;
 import com.ruoyi.payment.api.feignClient.AliPaymentClient;
 import com.ruoyi.payment.api.feignClient.WxPaymentClient;
 import com.ruoyi.payment.api.vo.AliQueryOrder;
-import com.ruoyi.payment.api.vo.WxRefundNotifyResp;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiImplicitParam;
 import io.swagger.annotations.ApiImplicitParams;
-import io.swagger.models.auth.In;
-import jdk.nashorn.internal.runtime.ListAdapter;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.BeanUtils;
@@ -72,15 +63,12 @@
 import org.springframework.web.bind.annotation.*;
 
 import javax.annotation.Resource;
-import javax.servlet.ServletInputStream;
-import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletResponse;
 import java.io.PrintWriter;
 import java.time.YearMonth;
 import java.time.format.DateTimeFormatter;
 import java.time.temporal.ChronoUnit;
 import java.time.temporal.TemporalAdjusters;
-import java.util.*;
 import java.util.*;
 import java.util.List;
 import java.util.stream.Collectors;
@@ -143,6 +131,9 @@
     private AppUserCarClient appUserCarClient;
     @Resource
     private TChargingOrderAccountingStrategyService chargingOrderAccountingStrategyService;
+    
+    @Resource
+    private TOrderInvoiceService invoiceService;
 
 
     /**
@@ -575,6 +566,17 @@
     }
     
     
+    /**
+     * 停止充电返回账单后计算费用
+     * @param vo
+     */
+    @PostMapping("/endChargeBillingCharge")
+    public void endChargeBillingCharge(@RequestBody TransactionRecordMessageVO vo){
+        log.error("-------------------停止充电返回账单后计算费用及修改业务状态-------------------:" + vo);
+        chargingOrderService.endChargeBillingCharge(vo);
+    }
+    
+    
     
 
     @ResponseBody
@@ -676,34 +678,37 @@
     @ResponseBody
     @PostMapping(value = "/watch/chargingOrder")
     @ApiOperation(value = "监控订单", tags = {"管理后台-订单管理"})
-    public R<List<ChargingOrderAndUploadRealTimeMonitoringDataDto>> watchChargingOrder(@RequestBody ChargingOrderQuery dto) {
-        Integer page = dto.getPageCurr();
-        Integer pageSize = dto.getPageSize();
-        List<Long> data = appUserClient.getUserIdsByPhone(dto.getPhone()).getData();
-        dto.setUserIds(data);
-        dto.setPageCurr(1);
-        dto.setPageSize(99999);
-        TCharingOrderVO res = chargingOrderService.chargingOrder(dto);
-        Map<String,TChargingOrder> map = new HashMap<>();
-        //吧list放入map中
-        for (ChargingOrderVO record : res.getList().getRecords()) {
-            map.put(record.getCode(),record);
-        }
-        Set<String> strings = map.keySet();
+    public R watchChargingOrder(@RequestBody MongoChargingOrderQuery mongoChargingOrderQuery) {
+//        Integer page = dto.getPageCurr();
+//        Integer pageSize = dto.getPageSize();
+//        List<Long> data = appUserClient.getUserIdsByPhone(dto.getPhone()).getData();
+//        dto.setUserIds(data);
+//        dto.setPageCurr(1);
+//        dto.setPageSize(99999);
+//        TCharingOrderVO res = chargingOrderService.chargingOrder(dto);
+//        Map<String,TChargingOrder> map = new HashMap<>();
+//        //吧list放入map中
+//        for (ChargingOrderVO record : res.getList().getRecords()) {
+//            map.put(record.getCode(),record);
+//        }
+//        Set<String> strings = map.keySet();
 
 
-        List<UploadRealTimeMonitoringData> data1 = uploadRealTimeMonitoringDataClient.getAll(strings, page, pageSize).getData();
+        List<UploadRealTimeMonitoringData> data1 = uploadRealTimeMonitoringDataClient.getAll(mongoChargingOrderQuery).getData();
 
-        List<ChargingOrderAndUploadRealTimeMonitoringDataDto> dtos = new ArrayList<>();
-        for (UploadRealTimeMonitoringData uploadRealTimeMonitoringData : data1) {
-            ChargingOrderAndUploadRealTimeMonitoringDataDto dataDto = new ChargingOrderAndUploadRealTimeMonitoringDataDto();
-            BeanUtils.copyProperties(uploadRealTimeMonitoringData,dataDto);
-            BeanUtils.copyProperties(map.get(uploadRealTimeMonitoringData.getCharging_pile_code()),dataDto);
-            dtos.add(dataDto);
-        }
+//        List<ChargingOrderAndUploadRealTimeMonitoringDataDto> dtos = new ArrayList<>();
+//        for (UploadRealTimeMonitoringData uploadRealTimeMonitoringData : data1) {
+//            ChargingOrderAndUploadRealTimeMonitoringDataDto dataDto = new ChargingOrderAndUploadRealTimeMonitoringDataDto();
+//            BeanUtils.copyProperties(uploadRealTimeMonitoringData,dataDto);
+//            TChargingOrder tChargingOrder = map.get(uploadRealTimeMonitoringData.getCharging_pile_code());
+//            if (tChargingOrder!=null) {
+//                BeanUtils.copyProperties(tChargingOrder, dataDto);
+//            }
+//            dtos.add(dataDto);
+//        }
 
 
-        return R.ok(dtos);
+        return R.ok(data1);
     }
     
     
@@ -1302,8 +1307,7 @@
 
     }
 
-    @Resource
-    private TOrderInvoiceService invoiceService;
+    
     @ResponseBody
     @GetMapping(value = "/work/shopOrder")
     @ApiOperation(value = "购物订单统计", tags = {"管理后台-工作台"})
@@ -1348,14 +1352,6 @@
         return R.ok(gunIds);
     }
 
-    public static void main(String[] args) {
-        // 示例数据
-        List<TChargingOrder> list = getSampleData();
-        System.err.println(list);
-        List<Map<String, BigDecimal>> result = processData(list);
-
-        result.forEach(System.out::println);
-    }
 
 
     private static List<TChargingOrder> getSampleData() {
@@ -1443,4 +1439,16 @@
         chargingOrderService.updateById(chargingOrder);
         return R.ok();
     }
+    
+    
+    @ResponseBody
+    @GetMapping(value = "/getEndOfChargePageInfo/{id}")
+    @ApiOperation(value = "获取充电结束页面数据", tags = {"小程序-扫一扫"})
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "id", value = "订单id", required = true)
+    })
+    public AjaxResult<EndOfChargePageInfo> getEndOfChargePageInfo(@PathVariable("id") String id){
+        EndOfChargePageInfo endOfChargePageInfo = chargingOrderService.getEndOfChargePageInfo(id);
+        return AjaxResult.success(endOfChargePageInfo);
+    }
 }

--
Gitblit v1.7.1