更新系统

ruoyi-modules/ruoyi-job/pom.xml

@@ -0,0 +1,37 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <groupId>org.dromara</groupId>
+        <artifactId>ruoyi-modules</artifactId>
+        <version>${revision}</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+    <packaging>jar</packaging>
+    <artifactId>ruoyi-job</artifactId>
+
+    <description>
+        任务调度
+    </description>
+
+    <dependencies>
+
+        <!-- 通用工具-->
+        <dependency>
+            <groupId>org.dromara</groupId>
+            <artifactId>ruoyi-common-json</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.dromara</groupId>
+            <artifactId>ruoyi-common-job</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.dromara</groupId>
+            <artifactId>ruoyi-mall</artifactId>
+        </dependency>
+    </dependencies>
+
+</project>
+

ruoyi-modules/ruoyi-job/src/main/java/org/dromara/job/package-info.java

@@ -0,0 +1 @@
+package org.dromara.job;

ruoyi-modules/ruoyi-job/src/main/java/org/dromara/job/snailjob/OrderStatusJobExecutor.java

@@ -0,0 +1,52 @@
+package org.dromara.job.snailjob;
+
+import com.aizuda.snailjob.client.job.core.annotation.JobExecutor;
+import com.aizuda.snailjob.client.model.ExecuteResult;
+import lombok.RequiredArgsConstructor;
+import org.dromara.mall.domain.HyOrderItem;
+import org.dromara.mall.domain.bo.HyOrderItemBo;
+import org.dromara.mall.domain.vo.HyOrderItemVo;
+import org.dromara.mall.service.IHyOrderItemService;
+import org.springframework.stereotype.Component;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @author Maosw
+ * @date 2025-02-17
+ */
+@Component
+@RequiredArgsConstructor
+@JobExecutor(name = "orderStatusJobExecutor")
+public class OrderStatusJobExecutor {
+
+    private final IHyOrderItemService hyOrderItemService;
+
+
+    /**
+     * 更新订单状态（订单状态发货后7天自动变成待评价）
+     * @return
+     */
+    public ExecuteResult jobExecute() {
+        // 获取订单id
+        HyOrderItemBo bo = new HyOrderItemBo();
+        bo.setStatus(3L);
+        List<HyOrderItemVo> list = hyOrderItemService.queryList(bo);
+
+        List<HyOrderItem> list1 = new ArrayList<>();
+        for (HyOrderItemVo hyOrderItemVo : list) {
+            HyOrderItem orderItem = new HyOrderItem();
+            //判断发货时间对比当前时间超过7天，则更新订单状态为待评价
+            if (hyOrderItemVo.getDvyTime().getTime() + 7 * 24 * 60 * 60 * 1000 <= System.currentTimeMillis()) {
+                orderItem.setId(hyOrderItemVo.getId());
+                orderItem.setStatus(4);
+                list1.add(orderItem);
+            }
+        }
+        // 批量更新订单状态为待评价
+        boolean success = hyOrderItemService.updateBatchById(list1);
+        return ExecuteResult.success("更新订单调度成功");
+    }
+
+}

ruoyi-modules/ruoyi-job/src/main/java/org/dromara/job/snailjob/TestAnnoJobExecutor.java

@@ -0,0 +1,24 @@
+package org.dromara.job.snailjob;
+
+import com.aizuda.snailjob.client.job.core.annotation.JobExecutor;
+import com.aizuda.snailjob.client.job.core.dto.JobArgs;
+import com.aizuda.snailjob.client.model.ExecuteResult;
+import com.aizuda.snailjob.common.core.util.JsonUtil;
+import com.aizuda.snailjob.common.log.SnailJobLog;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author opensnail
+ * @date 2024-05-17
+ */
+@Component
+@JobExecutor(name = "testJobExecutor")
+public class TestAnnoJobExecutor {
+
+    public ExecuteResult jobExecute(JobArgs jobArgs) {
+        SnailJobLog.LOCAL.info("testJobExecutor. jobArgs:{}", JsonUtil.toJsonString(jobArgs));
+        SnailJobLog.REMOTE.info("testJobExecutor. jobArgs:{}", JsonUtil.toJsonString(jobArgs));
+        return ExecuteResult.success("测试成功");
+    }
+
+}

ruoyi-modules/ruoyi-job/src/main/java/org/dromara/job/snailjob/TestClassJobExecutor.java

@@ -0,0 +1,19 @@
+package org.dromara.job.snailjob;
+
+import com.aizuda.snailjob.client.job.core.dto.JobArgs;
+import com.aizuda.snailjob.client.job.core.executor.AbstractJobExecutor;
+import com.aizuda.snailjob.client.model.ExecuteResult;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author opensnail
+ * @date 2024-05-17
+ */
+@Component
+public class TestClassJobExecutor extends AbstractJobExecutor {
+
+    @Override
+    protected ExecuteResult doJobExecute(JobArgs jobArgs) {
+        return ExecuteResult.success("TestJobExecutor测试成功");
+    }
+}