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/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 new file mode 100644 index 00000000..6b5aa618 --- /dev/null +++ b/ghy-quartz/src/main/java/com/ghy/quartz/task/OrderTask.java @@ -0,0 +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(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(); + } + } + +}