From 1be4f8bcb1ce6031838094164dd00bbd1766ebfa054ed80f404b2faaf05bbe1d Mon Sep 17 00:00:00 2001
From: PC <2413103649@qq.com>
Date: Fri, 27 Feb 2026 10:45:06 +0800
Subject: [PATCH] =?UTF-8?q?=E5=AE=9A=E6=9C=9F=E5=B7=A1=E6=A3=80=EF=BC=9A?=
 =?UTF-8?q?=E5=9F=BA=E7=A1=80=E6=94=AF=E6=8C=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../SafeOrderExpirationListener.java          |  8 ++++---
 .../service/EbikeBikeOrderService.java        |  6 +++++
 .../impl/EbikeBikeOrderServiceImpl.java       | 24 +++++++++++++++++++
 3 files changed, 35 insertions(+), 3 deletions(-)

diff --git a/ebike-operations/src/main/java/com/cdzy/operations/component/SafeOrderExpirationListener.java b/ebike-operations/src/main/java/com/cdzy/operations/component/SafeOrderExpirationListener.java
index f176802..54f954b 100644
--- a/ebike-operations/src/main/java/com/cdzy/operations/component/SafeOrderExpirationListener.java
+++ b/ebike-operations/src/main/java/com/cdzy/operations/component/SafeOrderExpirationListener.java
@@ -234,9 +234,11 @@ public class SafeOrderExpirationListener {
      */
     private void processCreateInspectionOrderBusiness(String bikeCode) {
         try {
-            //TODO: 生成巡检工单
-//            orderService.createInspectionSwapOrder(bikeCode);
-            System.out.println("生成巡检工单");
+            //生成巡检工单
+            orderService.createInspectionOrderByBikeCode(bikeCode);
+            //重新添加Key，实现循环定期巡检
+            log.info("重新添加定期巡检任务: bikeCode={}",bikeCode );
+            redisUtil.saveInspectionOrder(bikeCode,null,30L,TimeUnit.DAYS);
         } catch (Exception e) {
             log.error("生成巡检工单业务异常: orderId={}", bikeCode, e);
             throw e;
diff --git a/ebike-operations/src/main/java/com/cdzy/operations/service/EbikeBikeOrderService.java b/ebike-operations/src/main/java/com/cdzy/operations/service/EbikeBikeOrderService.java
index bce732d..b69929f 100644
--- a/ebike-operations/src/main/java/com/cdzy/operations/service/EbikeBikeOrderService.java
+++ b/ebike-operations/src/main/java/com/cdzy/operations/service/EbikeBikeOrderService.java
@@ -171,4 +171,10 @@ public interface EbikeBikeOrderService extends IService<EbikeBikeOrder> {
      * @param dispatchVo 调度信息
      */
     void batchFinishDispatch(EbikeBatchDispatchVo dispatchVo);
+
+    /**
+     * 根据车辆编号生成巡检工单
+     * @param bikeCode 车辆编号
+     */
+    void createInspectionOrderByBikeCode(String bikeCode);
 }
diff --git a/ebike-operations/src/main/java/com/cdzy/operations/service/impl/EbikeBikeOrderServiceImpl.java b/ebike-operations/src/main/java/com/cdzy/operations/service/impl/EbikeBikeOrderServiceImpl.java
index 9a8f749..8273454 100644
--- a/ebike-operations/src/main/java/com/cdzy/operations/service/impl/EbikeBikeOrderServiceImpl.java
+++ b/ebike-operations/src/main/java/com/cdzy/operations/service/impl/EbikeBikeOrderServiceImpl.java
@@ -1035,6 +1035,30 @@ public class EbikeBikeOrderServiceImpl extends ServiceImpl<EbikeBikeOrderMapper,
         }
     }
 
+    @Override
+    public void createInspectionOrderByBikeCode(String bikeCode) {
+        EbikeBikeInfo bikeInfo = checkBikeCode(bikeCode);
+        QueryWrapper queryWrapper = QueryWrapper.create()
+                .where(EBIKE_BIKE_ORDER.BIKE_CODE.eq(bikeInfo.getBikeCode()))
+                .where(EBIKE_BIKE_ORDER.ORDER_TYPE.eq(BikeOrderType.INSPECTION))
+                .where(EBIKE_BIKE_ORDER.HANDLE_STATE.eq(OrderHandleState.UNPROCESSED).or(EBIKE_BIKE_ORDER.HANDLE_STATE.eq(OrderHandleState.ACCEPTED)));
+        EbikeBikeOrder bikeOrder = this.mapper.selectOneByQuery(queryWrapper);
+        if (bikeOrder != null) {
+            log.error("车辆已存在巡检工单 ,bikeCode={} ", bikeInfo.getBikeCode());
+           return;
+        }
+        EbikeBikeOrder ebikeBikeOrder = EbikeBikeOrder.builder()
+                .bikeCode(bikeInfo.getBikeCode())
+                .orderCode(snowFlakeIDKeyGenerator.nextId())
+                .orderType(BikeOrderType.INSPECTION)
+                .operatorId(bikeInfo.getOperatorId())
+                .remarks("定期巡检任务")
+                .handleState(OrderHandleState.UNPROCESSED)
+                .isUserReporting(Boolean.FALSE)
+                .build();
+        this.mapper.insert(ebikeBikeOrder);
+    }
+
     EbikeBikeInfo checkBikeCode(String bikeCode) {
         QueryWrapper queryWrapper = QueryWrapper.create()
                 .where(EBIKE_BIKE_INFO.BIKE_CODE.eq(bikeCode))