From 3518269ae378f07554f5f5bc9cadc274f1340456 Mon Sep 17 00:00:00 2001
From: "kuang.yifei@iwhalecloud.com" <kuang.yifei@iwhalecloud.com>
Date: Tue, 19 Jul 2022 11:04:23 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E8=B6=85=E6=97=B6+=E8=87=AA?=
 =?UTF-8?q?=E5=8A=A8=E5=AE=8C=E6=88=90=E8=AE=A2=E5=8D=95=E6=8F=90=E7=8E=B0?=
 =?UTF-8?q?=E6=93=8D=E4=BD=9C?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/ghy/quartz/service/OrderService.java  | 11 ++++++
 .../quartz/service/impl/OrderServiceImpl.java | 35 +++++++++++++++++++
 .../java/com/ghy/quartz/task/OrderTask.java   | 24 +++++++++++--
 3 files changed, 67 insertions(+), 3 deletions(-)
 create mode 100644 ghy-quartz/src/main/java/com/ghy/quartz/service/OrderService.java
 create mode 100644 ghy-quartz/src/main/java/com/ghy/quartz/service/impl/OrderServiceImpl.java

diff --git a/ghy-quartz/src/main/java/com/ghy/quartz/service/OrderService.java b/ghy-quartz/src/main/java/com/ghy/quartz/service/OrderService.java
new file mode 100644
index 00000000..dc3267fc
--- /dev/null
+++ b/ghy-quartz/src/main/java/com/ghy/quartz/service/OrderService.java
@@ -0,0 +1,11 @@
+package com.ghy.quartz.service;
+
+public interface OrderService {
+
+    // 更新超时环境订单
+    void overTimeOrder(String orderStatus);
+
+    // 自动完成和分账
+    void finishOrder();
+
+}
diff --git a/ghy-quartz/src/main/java/com/ghy/quartz/service/impl/OrderServiceImpl.java b/ghy-quartz/src/main/java/com/ghy/quartz/service/impl/OrderServiceImpl.java
new file mode 100644
index 00000000..dea627d6
--- /dev/null
+++ b/ghy-quartz/src/main/java/com/ghy/quartz/service/impl/OrderServiceImpl.java
@@ -0,0 +1,35 @@
+package com.ghy.quartz.service.impl;
+
+import com.ghy.order.service.OrderMasterService;
+import com.ghy.payment.service.FinancialMasterService;
+import com.ghy.quartz.service.OrderService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+@Service
+public class OrderServiceImpl implements OrderService {
+
+    @Autowired
+    private OrderMasterService orderMasterService;
+
+    @Autowired
+    private FinancialMasterService financialMasterService;
+
+    @Override
+    public void overTimeOrder(String orderStatus) {
+        // 查询符合超时的单
+
+        // 更新对应单的状态
+
+        // 生成对应的扣款明细
+    }
+
+    @Override
+    public void finishOrder() {
+        // 查询符合自动确认的订单
+
+        // 更新符合自动确认订单的状态
+
+        // 调用分账动作
+    }
+}
diff --git a/ghy-quartz/src/main/java/com/ghy/quartz/task/OrderTask.java b/ghy-quartz/src/main/java/com/ghy/quartz/task/OrderTask.java
index 2b33f501..6b5aa618 100644
--- a/ghy-quartz/src/main/java/com/ghy/quartz/task/OrderTask.java
+++ b/ghy-quartz/src/main/java/com/ghy/quartz/task/OrderTask.java
@@ -1,22 +1,40 @@
 package com.ghy.quartz.task;
 
+import com.ghy.common.utils.ExceptionUtil;
+import com.ghy.quartz.service.OrderService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
+@Slf4j
 @Component("orderTask")
 public class OrderTask {
 
+    @Autowired
+    private OrderService orderService;
+
     /**
      * 超时状态刷新
      * */
-    public void overTimeOrder(){
-
+    public void overTimeOrder(String orderStatus){
+        try {
+            orderService.overTimeOrder(orderStatus);
+        }catch (Exception e){
+            log.error("over time order task error is {}", ExceptionUtil.getExceptionMessage(e));
+            e.printStackTrace();
+        }
     }
 
     /**
      * 自动确认完成订单
      * */
     public void finishOrder(){
-
+        try {
+            orderService.finishOrder();
+        }catch (Exception e){
+            log.error("auto finish order task error is {}", ExceptionUtil.getExceptionMessage(e));
+            e.printStackTrace();
+        }
     }
 
 }