From 466462c7d3b5652c017fe2ac518a4eb23412efc1 Mon Sep 17 00:00:00 2001
From: Guoqs <123@jsowell.com>
Date: Fri, 27 Dec 2024 14:34:31 +0800
Subject: [PATCH] =?UTF-8?q?=E5=88=A4=E6=96=AD=E8=AF=A5=E8=AE=A2=E5=8D=95?=
 =?UTF-8?q?=E6=98=AF=E5=90=A6=E9=9C=80=E8=A6=81=E4=B8=8B=E5=8F=91=E4=BC=98?=
 =?UTF-8?q?=E6=83=A0=E5=88=B8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../UploadRealTimeMonitorHandler.java         | 30 +++++++++----------
 1 file changed, 15 insertions(+), 15 deletions(-)

diff --git a/jsowell-netty/src/main/java/com/jsowell/netty/handler/yunkuaichong/UploadRealTimeMonitorHandler.java b/jsowell-netty/src/main/java/com/jsowell/netty/handler/yunkuaichong/UploadRealTimeMonitorHandler.java
index b2d535597..1e041cd9c 100644
--- a/jsowell-netty/src/main/java/com/jsowell/netty/handler/yunkuaichong/UploadRealTimeMonitorHandler.java
+++ b/jsowell-netty/src/main/java/com/jsowell/netty/handler/yunkuaichong/UploadRealTimeMonitorHandler.java
@@ -320,27 +320,27 @@ public class UploadRealTimeMonitorHandler extends AbstractYkcHandler {
                 if (updateFlag) {
                     orderBasicInfoService.updateOrderBasicInfo(orderInfo);
                 }
+
+                // 判断该订单是否需要下发优惠券
+                String redisKey = CacheConstants.CAR_BIND_COUPON_BY_ORDER_CODE + orderInfo.getOrderCode();
+                Object cacheObject = redisCache.getCacheObject(redisKey);
+                if (cacheObject == null && sumChargingTime >= 10) {
+                    // 异步绑定优惠券并设置缓存
+                    CompletableFuture.runAsync(() -> {
+                        try {
+                            commonService.bindCoupon(orderInfo);
+                            redisCache.setCacheObject(redisKey, Boolean.TRUE, 24, TimeUnit.HOURS);
+                        } catch (Exception e) {
+                            log.error("异步绑定车辆优惠券 error,", e);
+                        }
+                    }, executor);
+                }
             }
 
             // 充电时保存实时数据到redis
             if (saveRedisFlag) {
                 pileBasicInfoService.saveRealTimeMonitorData2Redis(realTimeMonitorData);
             }
-            // 判断该订单是否需要下发优惠券
-            String redisKey = CacheConstants.CAR_BIND_COUPON_BY_ORDER_CODE + orderInfo.getOrderCode();
-            Object cacheObject = redisCache.getCacheObject(redisKey);
-            if (cacheObject == null && sumChargingTime >= 10) {
-                // 异步绑定优惠券并设置缓存
-                CompletableFuture.runAsync(() -> {
-                    try {
-                        commonService.bindCoupon(orderInfo);
-                        redisCache.setCacheObject(redisKey, Boolean.TRUE, 24, TimeUnit.HOURS);
-                    } catch (Exception e) {
-                        log.error("异步绑定车辆优惠券 error,", e);
-                    }
-                }, executor);
-            }
-
         }
 
         // 异步推送第三方平台实时数据