From 8f05d5882f6abec664bdd1a7c4c31e96d9da383c Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E7=A3=B7=E5=8F=B6?=
 <14103883+leaf-phos@user.noreply.gitee.com>
Date: Wed, 7 May 2025 16:10:30 +0800
Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0=E7=BB=9F=E8=AE=A1=E6=95=B0?=
 =?UTF-8?q?=E6=8D=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ruoyi/common/constant/RoleConstants.java  |  2 +
 .../com/ruoyi/bst/area/mapper/AreaMapper.xml  |  3 +-
 .../ruoyi/bst/bonus/service/BonusService.java |  8 +++
 .../bonus/service/impl/BonusServiceImpl.java  | 11 +++-
 .../ruoyi/bst/order/mapper/OrderMapper.xml    |  2 +-
 .../order/service/impl/OrderServiceImpl.java  | 51 ++++++++++++++++---
 .../com/ruoyi/web/bst/BonusController.java    |  9 ++++
 7 files changed, 75 insertions(+), 11 deletions(-)

diff --git a/common-ruoyi/ruoyi-common/src/main/java/com/ruoyi/common/constant/RoleConstants.java b/common-ruoyi/ruoyi-common/src/main/java/com/ruoyi/common/constant/RoleConstants.java
index c3fb4e6..22113a3 100644
--- a/common-ruoyi/ruoyi-common/src/main/java/com/ruoyi/common/constant/RoleConstants.java
+++ b/common-ruoyi/ruoyi-common/src/main/java/com/ruoyi/common/constant/RoleConstants.java
@@ -14,5 +14,7 @@ public class RoleConstants {
     public static final String MCH = "mch";   
     // 加盟商
     public static final String JOIN = "join";
+    // 系统管理员
+    public static final String SYS_ADMIN = "sys_admin";
 
 }
diff --git a/ruoyi-service/src/main/java/com/ruoyi/bst/area/mapper/AreaMapper.xml b/ruoyi-service/src/main/java/com/ruoyi/bst/area/mapper/AreaMapper.xml
index f481b00..a6139ce 100644
--- a/ruoyi-service/src/main/java/com/ruoyi/bst/area/mapper/AreaMapper.xml
+++ b/ruoyi-service/src/main/java/com/ruoyi/bst/area/mapper/AreaMapper.xml
@@ -314,7 +314,8 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
     <select id="selectSimpleList">
         select
             ba.id,
-            ba.name
+            ba.name,
+            su.nick_name as user_name
         from <include refid="searchTables"/>
         <where>
             <include refid="searchCondition"/>
diff --git a/ruoyi-service/src/main/java/com/ruoyi/bst/bonus/service/BonusService.java b/ruoyi-service/src/main/java/com/ruoyi/bst/bonus/service/BonusService.java
index d663e0c..c10d6c9 100644
--- a/ruoyi-service/src/main/java/com/ruoyi/bst/bonus/service/BonusService.java
+++ b/ruoyi-service/src/main/java/com/ruoyi/bst/bonus/service/BonusService.java
@@ -144,4 +144,12 @@ public interface BonusService {
      */
     public List<Bonus> preview(Long deviceId);
 
+    /**
+     * 预分成
+     *
+     * @param id 分成明细ID
+     * @return 结果
+     */
+    public int prepayBonus(Long id);
+
 }
diff --git a/ruoyi-service/src/main/java/com/ruoyi/bst/bonus/service/impl/BonusServiceImpl.java b/ruoyi-service/src/main/java/com/ruoyi/bst/bonus/service/impl/BonusServiceImpl.java
index 4713ce3..c1d2073 100644
--- a/ruoyi-service/src/main/java/com/ruoyi/bst/bonus/service/impl/BonusServiceImpl.java
+++ b/ruoyi-service/src/main/java/com/ruoyi/bst/bonus/service/impl/BonusServiceImpl.java
@@ -217,7 +217,7 @@ public class BonusServiceImpl implements BonusService {
                 if (user == null) {
                     continue;
                 }
-                bonus.setPrePayTime(now.plusHours(user.getBonusDelay()));
+                bonus.setPrePayTime(now.plusHours(user.getBonusDelay()).plusMinutes(1));
             } else {
                 bonus.setPrePayTime(now);
             }
@@ -409,4 +409,13 @@ public class BonusServiceImpl implements BonusService {
 
         return bonusConverter.toBaseBonusListPlatform(device, partners, join);
     }
+
+    @Override
+    public int prepayBonus(Long id) { 
+        BonusVO bonus = this.selectBonusById(id);
+        if (bonus == null) {
+            return 0;
+        }
+        return prepay(Collections.singletonList(bonus));
+    }
 }
diff --git a/ruoyi-service/src/main/java/com/ruoyi/bst/order/mapper/OrderMapper.xml b/ruoyi-service/src/main/java/com/ruoyi/bst/order/mapper/OrderMapper.xml
index 2f9c928..f336f00 100644
--- a/ruoyi-service/src/main/java/com/ruoyi/bst/order/mapper/OrderMapper.xml
+++ b/ruoyi-service/src/main/java/com/ruoyi/bst/order/mapper/OrderMapper.xml
@@ -458,7 +458,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         select
             bo.area_id,
             ba.name as area_name,
-            sum(<include refid="actualAmount"/>) as actual_amount,
+            sum(if(bo.status = 'PROCESSING', 0, <include refid="actualAmount"/>)) as actual_amount,
             count(bo.id) as `count`,
             sum(if(bo.status = 'PROCESSING', 1, 0)) as processing_count
         from <include refid="searchTables"/>
diff --git a/ruoyi-service/src/main/java/com/ruoyi/bst/order/service/impl/OrderServiceImpl.java b/ruoyi-service/src/main/java/com/ruoyi/bst/order/service/impl/OrderServiceImpl.java
index 1085591..49f31e1 100644
--- a/ruoyi-service/src/main/java/com/ruoyi/bst/order/service/impl/OrderServiceImpl.java
+++ b/ruoyi-service/src/main/java/com/ruoyi/bst/order/service/impl/OrderServiceImpl.java
@@ -21,11 +21,13 @@ import com.ruoyi.bst.bonus.domain.Bonus;
 import com.ruoyi.bst.bonus.domain.enums.BonusBstType;
 import com.ruoyi.bst.bonus.service.BonusConverter;
 import com.ruoyi.bst.bonus.service.BonusService;
+import com.ruoyi.bst.device.domain.Device;
 import com.ruoyi.bst.device.domain.DeviceVO;
 import com.ruoyi.bst.device.domain.enums.DeviceUnLockType;
 import com.ruoyi.bst.device.domain.vo.DeviceIotVO;
 import com.ruoyi.bst.device.service.DeviceIotService;
 import com.ruoyi.bst.device.service.DeviceService;
+import com.ruoyi.bst.device.service.impl.DeviceValidatorImpl;
 import com.ruoyi.bst.fault.domain.Fault;
 import com.ruoyi.bst.fault.service.FaultConverter;
 import com.ruoyi.bst.fault.service.FaultService;
@@ -77,6 +79,8 @@ import com.ruoyi.common.utils.StringUtils;
 import com.ruoyi.common.utils.collection.CollectionUtils;
 import com.ruoyi.system.user.service.UserService;
 
+import lombok.extern.slf4j.Slf4j;
+
 /**
  * 订单Service业务层处理
  *
@@ -84,7 +88,10 @@ import com.ruoyi.system.user.service.UserService;
  * @date 2025-03-24
  */
 @Service
+@Slf4j
 public class OrderServiceImpl implements OrderService {
+
+    private final DeviceValidatorImpl deviceValidatorImpl;
     @Autowired
     private OrderMapper orderMapper;
 
@@ -145,6 +152,10 @@ public class OrderServiceImpl implements OrderService {
     @Autowired
     private SmsService smsService;
 
+    OrderServiceImpl(DeviceValidatorImpl deviceValidatorImpl) {
+        this.deviceValidatorImpl = deviceValidatorImpl;
+    }
+
     /**
      * 查询订单
      *
@@ -400,6 +411,12 @@ public class OrderServiceImpl implements OrderService {
         OrderInParkingVO inParkingVO = bo.getInParkingVO();
         AreaVO area = bo.getArea();
         OrderDeviceVO orderDevice = bo.getOrderDevice();
+        DeviceVO device = bo.getDevice();
+
+        // 处理其他线程操作
+        scheduledExecutorService.execute(() -> {
+            this.handleDeviceLocation(device, dto);
+        });
 
         // 设置订单数据
         order.setEndTime(LocalDateTime.now()); // 结束时间
@@ -448,15 +465,36 @@ public class OrderServiceImpl implements OrderService {
 
         boolean isSuccess = result != null && result == 1;
         if (isSuccess && OrderStatus.FINISHED.getCode().equals(order.getStatus())) {
-            scheduledExecutorService.schedule(() -> {
-                int refund = this.refundRemainAmount(order);
-                ServiceUtil.assertion(refund != 1, "ID为%s的订单退还剩余金额失败", order.getId());
-            }, 10, TimeUnit.SECONDS);
+            this.handleFinished(order);
         }
 
         return vo;
     }
 
+    // 使用手机定位设置设备定位
+    private void handleDeviceLocation(DeviceVO device, OrderEndDTO dto) {
+        if (dto.getLon() != null && dto.getLat() != null 
+        && dto.getLon().compareTo(BigDecimal.ZERO) != 0 
+        && dto.getLat().compareTo(BigDecimal.ZERO) != 0) {
+            Device data = new Device();
+            data.setId(device.getId());
+            data.setLongitude(dto.getLon());
+            data.setLatitude(dto.getLat());
+            int rows = deviceService.updateDevice(data);
+            if (rows != 1) {
+                log.error("通过手机定位修改设备定位失败deviceId={}", device.getId());
+            }
+        }
+    }
+
+    // 处理订单完成
+    private void handleFinished(OrderVO order) {
+        scheduledExecutorService.schedule(() -> {
+            int refund = this.refundRemainAmount(order);
+            ServiceUtil.assertion(refund != 1, "ID为%s的订单退还剩余金额失败", order.getId());
+        }, 10, TimeUnit.SECONDS);
+    }
+
     // 设置订单状态
     private void setOrderStatus(OrderVO order, String returnType) {
         // 根据是否需要审核，设置订单状态
@@ -750,10 +788,7 @@ public class OrderServiceImpl implements OrderService {
 
         // 若审核通过，则退还剩余金额
         if (pass && result != null && result > 0) {
-            scheduledExecutorService.schedule(() -> {
-                int refund = this.refundRemainAmount(order);
-                ServiceUtil.assertion(refund != 1, "ID为%s的订单退还剩余金额失败", order.getId());
-            }, 10, TimeUnit.SECONDS);
+            this.handleFinished(order);
         }
 
         return result == null ? 0 : result;
diff --git a/ruoyi-web/src/main/java/com/ruoyi/web/bst/BonusController.java b/ruoyi-web/src/main/java/com/ruoyi/web/bst/BonusController.java
index 9758e5f..764bbe1 100644
--- a/ruoyi-web/src/main/java/com/ruoyi/web/bst/BonusController.java
+++ b/ruoyi-web/src/main/java/com/ruoyi/web/bst/BonusController.java
@@ -107,4 +107,13 @@ public class BonusController extends BaseController
         return success(bonusService.payBonus(id));
     }
 
+    /**
+     * 预分成
+     */
+    @PreAuthorize("@ss.hasPermi('bst:bonus:prepay')")
+    @PutMapping("/prepay")
+    @Log(title = "预支付分成", businessType = BusinessType.OTHER, bizIdName = "arg0", bizType = LogBizType.BONUS )
+    public AjaxResult prepay(Long id) {
+        return success(bonusService.prepayBonus(id));
+    }
 }