From 945c1097aa75fa921a6f697246deb9d91f5da96e Mon Sep 17 00:00:00 2001
From: yuyang <2265829957@qq.com>
Date: Tue, 16 Nov 2021 16:36:08 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E5=88=A0=E9=99=A4pushOrder?=
 =?UTF-8?q?=EF=BC=9A=E8=AE=A2=E5=8D=95=E5=8F=B7?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/xhpc/order/api/XhpcPileOrderController.java     | 5 +++++
 .../order/service/impl/XhpcRealTimeOrderServiceImpl.java     | 4 ++++
 2 files changed, 9 insertions(+)

diff --git a/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/api/XhpcPileOrderController.java b/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/api/XhpcPileOrderController.java
index 2337dc5f..c154b6b3 100644
--- a/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/api/XhpcPileOrderController.java
+++ b/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/api/XhpcPileOrderController.java
@@ -30,6 +30,8 @@ import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
+import static com.xhpc.common.data.redis.StaticBeanUtil.REDIS;
+
 @RestController
 public class XhpcPileOrderController extends BaseController {
 
@@ -248,6 +250,7 @@ public class XhpcPileOrderController extends BaseController {
             //费率计费模型
             List<XhpcRate> rateModelList = xhpcChargeOrderService.getRateModelId(xhpcChargeOrder.getRateModelId());
             for (XhpcRate xhpcRate:rateModelList) {
+                System.out.println(">>>>>>"+xhpcRate.getRateValue());
                 if("00".equals(xhpcRate.getRateValue())){
                     t1powerFee = xhpcRate.getPowerFee();
                 }
@@ -373,6 +376,8 @@ public class XhpcPileOrderController extends BaseController {
             map.put("userId", userId);
             JSONObject json = new JSONObject(map);
             webSocketService.getMessage(userId+"",json.toString());
+
+
         }catch (Exception e){
             e.printStackTrace();
             return R.fail(500,"添加订单回调失败");
diff --git a/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/service/impl/XhpcRealTimeOrderServiceImpl.java b/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/service/impl/XhpcRealTimeOrderServiceImpl.java
index 42a04ff4..26a549ee 100644
--- a/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/service/impl/XhpcRealTimeOrderServiceImpl.java
+++ b/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/service/impl/XhpcRealTimeOrderServiceImpl.java
@@ -26,6 +26,8 @@ import java.util.*;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 
+import static com.xhpc.common.data.redis.StaticBeanUtil.REDIS;
+
 /**
  * @author yuyang
  * @date 2021/8/7 15:07
@@ -440,6 +442,8 @@ public class XhpcRealTimeOrderServiceImpl implements IXhpcRealTimeOrderService {
         xhpcHistoryOrderService.insert(xhpcHistoryOrder);
 
         xhpcChargeOrderService.updateXhpcChargeOrder(xhpcChargeOrder);
+
+        redisService.deleteObject("pushOrder:"+xhpcChargeOrder.getSerialNumber());
     }