Ver código fonte

新增单元测试类用于立即执行批处理任务

lvjian 1 ano atrás
pai
commit
308879be38
3 arquivos alterados com 95 adições e 0 exclusões
  1. 13 0
      README.md
  2. 7 0
      build.gradle
  3. 75 0
      src/test/java/com/emato/cus/supervise/ScheduleTest.java

+ 13 - 0
README.md

@@ -16,6 +16,19 @@
 1. 参见系统classes/application.yml中【jobs.schedule】节点配置
 2. 【jobs.schedule】节点参数配置,必须征得负责人同意方可修改
 
+
+## 执行定时器任务
+如遇到一些情况需要立即运行定时器中的批处理任务,可以使用单元的测试类 `ScheduleTest`。
+
+运行单元测试时,需要更改 `build.gradle` 中的 `test.enabled` 设置为 true
+```
+test {
+    enabled = true
+    useJUnitPlatform()
+}
+```
+
+
 ## Mysql数据库配置
 1. 因为系统向`mysql`数据库写入数据量大,必须配置`mysql`的`max_allowed_packet`参数值。
 2. 如果配置参数少于写入数据大小,`mysql`会报`Could not send query: stream size 50664717 is >= to max_allowed_packet (4194304)`异常;

+ 7 - 0
build.gradle

@@ -115,3 +115,10 @@ dependencies {
 	// 读取yml文件
 	implementation("org.yaml:snakeyaml:${snakeyaml}")
 }
+
+/* gradle test 编译器 */
+test {
+	// 运行单元测试时置为 true
+	enabled = false
+	useJUnitPlatform()
+}

+ 75 - 0
src/test/java/com/emato/cus/supervise/ScheduleTest.java

@@ -0,0 +1,75 @@
+package com.emato.cus.supervise;
+
+import com.emato.cus.supervise.schedule.AcqGoodsMoveSchedule;
+import com.emato.cus.supervise.schedule.AcqGoodsSeatSchedule;
+import com.emato.cus.supervise.schedule.AcqInventoryInfoSchedule;
+import com.emato.cus.supervise.schedule.AcqShelfLoadSchedule;
+import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+
+/**
+ * ScheduleTest 定时器单元测试
+ *
+ * @author frankeleyn
+ * @email lvjian@qhdswl.com
+ * @Date 2024/2/4 10:00
+ */
+@SpringBootTest
+public class ScheduleTest {
+
+    @Autowired
+    private AcqGoodsMoveSchedule acqGoodsMoveTask;
+
+    @Autowired
+    private AcqGoodsSeatSchedule acqGoodsSeatTask;
+
+    @Autowired
+    private AcqInventoryInfoSchedule acqInventoryInfoTask;
+
+    @Autowired
+    private AcqShelfLoadSchedule shelfLoadTask;
+
+    /**
+     * 货物库位移动数据上架
+     */
+    @Test
+    public void testAcqGoodsMoveTask(){
+        acqGoodsMoveTask.timerUp();
+    }
+
+    /**
+     * 库位货物数据
+     */
+    @Test
+    public void testAcqGoodsSeatTask(){
+        acqGoodsSeatTask.timerUp();
+    }
+
+    /**
+     * 货物库存数据
+     */
+    @Test
+    public void testAcqInventoryInfoTask(){
+        acqInventoryInfoTask.timer();
+    }
+
+    /**
+     * 上下架数据--上架
+     */
+    @Test
+    public void testShelfLoadUpTask(){
+        shelfLoadTask.timerUp();
+    }
+
+    /**
+     * 上下架数据--下架
+     */
+    @Test
+    public void testShelfLoadDownTask(){
+        shelfLoadTask.timerDown();
+    }
+
+
+
+}