From 42129f215fa6c937c79c0e4ca69560508ebc875e Mon Sep 17 00:00:00 2001 From: "kuang.yifei@iwhalecloud.com" Date: Tue, 19 Jul 2022 09:56:27 +0800 Subject: [PATCH 1/2] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E8=B6=85=E6=97=B6+?= =?UTF-8?q?=E8=87=AA=E5=8A=A8=E5=AE=8C=E6=88=90=E8=AE=A2=E5=8D=95=E6=8F=90?= =?UTF-8?q?=E7=8E=B0=E6=93=8D=E4=BD=9C?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- ghy-quartz/pom.xml | 10 +++++++++ .../java/com/ghy/quartz/task/OrderTask.java | 22 +++++++++++++++++++ 2 files changed, 32 insertions(+) create mode 100644 ghy-quartz/src/main/java/com/ghy/quartz/task/OrderTask.java diff --git a/ghy-quartz/pom.xml b/ghy-quartz/pom.xml index 28bc6cd5..21b44f24 100644 --- a/ghy-quartz/pom.xml +++ b/ghy-quartz/pom.xml @@ -35,6 +35,16 @@ ghy-common + + com.ghy + ghy-order + + + + com.ghy + ghy-payment + + \ No newline at end of file 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 new file mode 100644 index 00000000..2b33f501 --- /dev/null +++ b/ghy-quartz/src/main/java/com/ghy/quartz/task/OrderTask.java @@ -0,0 +1,22 @@ +package com.ghy.quartz.task; + +import org.springframework.stereotype.Component; + +@Component("orderTask") +public class OrderTask { + + /** + * 超时状态刷新 + * */ + public void overTimeOrder(){ + + } + + /** + * 自动确认完成订单 + * */ + public void finishOrder(){ + + } + +} From 3518269ae378f07554f5f5bc9cadc274f1340456 Mon Sep 17 00:00:00 2001 From: "kuang.yifei@iwhalecloud.com" Date: Tue, 19 Jul 2022 11:04:23 +0800 Subject: [PATCH 2/2] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E8=B6=85=E6=97=B6+?= =?UTF-8?q?=E8=87=AA=E5=8A=A8=E5=AE=8C=E6=88=90=E8=AE=A2=E5=8D=95=E6=8F=90?= =?UTF-8?q?=E7=8E=B0=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(); + } } }