[add]订单超时自动取消

jeecg-boot-module-system/src/main/java/org/jeecg/modules/demo/erp/mapper/OrderMapper.java

@@ -5,6 +5,8 @@ import org.jeecg.modules.demo.erp.entity.Order;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import org.jeecg.modules.demo.erp.vo.OrderStateVo;
 
+import java.util.List;
+
 /**
  * @Description: 订单
  * @Author: jeecg-boot
@@ -19,4 +21,10 @@ public interface OrderMapper extends BaseMapper<Order> {
      */
     OrderStateVo queryState(@Param("userId") String userId);
 
+    /**
+     * 获取超时订单
+     * @return
+     */
+    public List<Order> getTimeoutOrder();
+
 }

jeecg-boot-module-system/src/main/java/org/jeecg/modules/demo/erp/mapper/xml/OrderMapper.xml

@@ -18,5 +18,14 @@
 
     </select>
 
+    <select id="getTimeoutOrder" resultType="org.jeecg.modules.demo.erp.entity.Order">
+        select * from orders o
+        <where>
+            o.state = 0
+            <![CDATA[
+              and o.create_time < DATE_SUB(now(),INTERVAL 48 HOUR);
+            ]]>
+        </where>
+    </select>
 
 </mapper>

jeecg-boot-module-system/src/main/java/org/jeecg/modules/demo/erp/service/IOrderService.java

@@ -54,4 +54,10 @@ public interface IOrderService extends IService<Order> {
 	 */
 	public void delBatchMain (Collection<? extends Serializable> idList);
 
+	/**
+	 * 获取超时订单
+	 * @return
+	 */
+	public List<Order> getTimeoutOrder();
+
 }

jeecg-boot-module-system/src/main/java/org/jeecg/modules/demo/erp/service/JeecgJobService.java

@@ -0,0 +1,12 @@
+package org.jeecg.modules.demo.erp.service;
+
+/**
+ * @author NH-LHG
+ */
+public interface JeecgJobService {
+    /**
+     * 自动取消订单
+     *
+     */
+    public void autoCancelOrder();
+}

jeecg-boot-module-system/src/main/java/org/jeecg/modules/demo/erp/service/impl/JeecgJobServiceImpl.java

@@ -0,0 +1,39 @@
+package org.jeecg.modules.demo.erp.service.impl;
+
+import lombok.extern.slf4j.Slf4j;
+import org.jeecg.modules.demo.erp.entity.Order;
+import org.jeecg.modules.demo.erp.service.IOrderService;
+import org.jeecg.modules.demo.erp.service.JeecgJobService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+/**
+ * @author NH-LHG
+ */
+@Slf4j
+@Component
+public class JeecgJobServiceImpl implements JeecgJobService {
+    @Autowired
+    private IOrderService iOrderService;
+    /**
+     * 自动取消订单
+     */
+    @Override
+    @Async
+    @Scheduled(cron = "0 */1 * * * ?")
+    public void autoCancelOrder() {
+        log.info("执行autoCancelOrder()订单失效处理开始......");
+        List<Order> orderList = iOrderService.getTimeoutOrder();
+        if (null != orderList && orderList.size() > 0) {
+            orderList.forEach(e -> {
+                e.setState(5);
+            });
+            iOrderService.saveOrUpdateBatch(orderList);
+        }
+        log.info("执行autoCancelOrder()订单失效处理结束......");
+    }
+}

jeecg-boot-module-system/src/main/java/org/jeecg/modules/demo/erp/service/impl/OrderServiceImpl.java

@@ -82,4 +82,14 @@ public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements
 		}
 	}
 
+	/**
+	 * 获取超时订单
+	 *
+	 * @return
+	 */
+	@Override
+	public List<Order> getTimeoutOrder() {
+		return orderMapper.getTimeoutOrder();
+	}
+
 }