From c86ed59bbb89f1a83425a380735a2c788e45d054 Mon Sep 17 00:00:00 2001
From: liuhaonan <31457034@qq.com>
Date: 星期五, 26 八月 2022 10:47:45 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'

---
 ximon-admin/src/main/java/com/sandu/ximon/admin/manager/iot/amqp/processor/c3ChargingProcessor.java |   15 +++++++++------
 1 files changed, 9 insertions(+), 6 deletions(-)

diff --git a/ximon-admin/src/main/java/com/sandu/ximon/admin/manager/iot/amqp/processor/c3ChargingProcessor.java b/ximon-admin/src/main/java/com/sandu/ximon/admin/manager/iot/amqp/processor/c3ChargingProcessor.java
index 0e43c46..7645eec 100644
--- a/ximon-admin/src/main/java/com/sandu/ximon/admin/manager/iot/amqp/processor/c3ChargingProcessor.java
+++ b/ximon-admin/src/main/java/com/sandu/ximon/admin/manager/iot/amqp/processor/c3ChargingProcessor.java
@@ -12,7 +12,6 @@
 import com.sandu.ximon.admin.service.*;
 import com.sandu.ximon.admin.utils.LogUtils;
 import com.sandu.ximon.admin.utils.RedisUtils;
-import com.sandu.ximon.dao.domain.C3mCharging;
 import com.sandu.ximon.dao.domain.C3mOrder;
 import com.sandu.ximon.dao.domain.Pole;
 import com.sandu.ximon.dao.enums.OrderStatus;
@@ -60,10 +59,10 @@
                 //淇濆瓨鍏呯數妗╃‖浠朵俊鎭�
                 boolean b = SpringContextHolder.getBean(C3ChargingService.class).saveReporEquipment(deviceName, netRequestFrame.getMcuUdid(), netRequestFrame.getDestinationAddress());
                 //妫�鏌ユ槸鍚︽湁姝e湪杩涜鐨勮鍗曪紝鏈夌殑璇濈户缁厖鐢�
-                SpringContextHolder.getBean(C3mOrderService.class).recoverContinueCharing(netRequestFrame.getDestinationAddress(), netRequestFrame.getMcuUdid());
-                if (!b) {
-                    return;
-                }
+//                SpringContextHolder.getBean(C3mOrderService.class).recoverContinueCharing(netRequestFrame.getDestinationAddress(), netRequestFrame.getMcuUdid());
+//                if (!b) {
+//                    return;
+//                }
             }
         } else if (C3ChargingEnum.QR_CODE_REQUEST.getCode().equals(functionCode)) {
             //  缃戦〉鎿嶄綔浜岀淮鐮佽姹�(41)
@@ -113,7 +112,7 @@
             /**
              * 璇诲彇蹇冭烦鍖咃紝鍒ゆ柇鍓╀綑閲戦鍜屽凡鍏呯數閲忥紝缁熻鍒扮紦瀛樹腑姝e湪杩涜鐨勮鍗曘��
              */
-            A5C3HeartbeatReportInnerFrame.HeartBeatDataPackage aPackage = c3ChargingService.ReadTheHeartbeatPackage(completeRequestFrame.getDestinationAddress());
+            A5C3HeartbeatReportInnerFrame.HeartBeatDataPackage aPackage = c3ChargingService.ReadTheHeartbeatPackage(completeRequestFrame.getDestinationAddress(), true);
             if (aPackage == null) {
                 LogUtils.error("{ 鍏呯數妗�(" + completeRequestFrame.getDestinationAddress() + ")鍏呯數缁撴潫涓婃姤璇诲彇蹇冭烦鍖呭け璐ワ紝璇锋鏌ュ厖鐢垫々鏄惁鍑虹幇鏁呴殰! }");
                 return;
@@ -174,6 +173,10 @@
             lastOrderByC3Mac.setChargingStates(1);
             //璁剧疆鍓╀綑閲戦
             lastOrderByC3Mac.setSurplusAmount(Double.parseDouble(aPackage.getRemainingAmount()));
+            //璁剧疆閫�娆鹃噾棰�
+            lastOrderByC3Mac.setRefundAmount(Double.parseDouble(aPackage.getRemainingAmount()));
+            //鍏呯數鏃堕暱
+            lastOrderByC3Mac.setAlreadyChargingTime(aPackage.getAlreadyChargingTime());
             SpringContextHolder.getBean(C3mOrderService.class).updateById(lastOrderByC3Mac);
         }
     }

--
Gitblit v1.9.3