增加接口

src/src/main/java/com/my/graphiteDigesterBg/diframe/DiActuator.java

@@ -0,0 +1,4 @@
+package com.my.graphiteDigesterBg.diframe;
+public interface DiActuator {
+
+}

src/src/main/java/com/my/graphiteDigesterBg/diframe/actuator/DiActuatorBase.java → src/src/main/java/com/my/graphiteDigesterBg/diframe/DiActuatorBase.java

@@ -1,4 +1,7 @@
-package com.my.graphiteDigesterBg.diframe.actuator;
+package com.my.graphiteDigesterBg.diframe;
+
+import com.my.graphiteDigesterBg.diframe.DiActuator;
+
 abstract public class DiActuatorBase implements DiActuator {
     // mid
     protected Integer mid;

src/src/main/java/com/my/graphiteDigesterBg/diframe/DiApplicationRunner.java

@@ -0,0 +1,22 @@
+package com.my.graphiteDigesterBg.diframe;
+import jakarta.annotation.Resource;
+import org.springframework.boot.ApplicationArguments;
+import org.springframework.boot.ApplicationRunner;
+import org.springframework.core.annotation.Order;
+import org.springframework.stereotype.Component;
+@Order(1)
+@Component
+public class DiApplicationRunner implements ApplicationRunner {
+    @Resource
+    private DiDevice device;
+
+    @Override
+    public void run(ApplicationArguments args) throws Exception {
+        this.scanAndRegisterTasks();
+    }
+
+    // scan tasks
+    private void scanAndRegisterTasks() {
+        System.out.println("DiApplicationRunner.scanAndRegisterTasks()");
+    }
+}

src/src/main/java/com/my/graphiteDigesterBg/diframe/DiDevice.java

@@ -7,11 +7,14 @@ public class DiDevice {
     private DiDeviceIOManager io;
     // actuator manager
     private DiDeviceActuatorManager actuators;
+    // task executor
+    private DiTaskExecutor taskExecutor;
 
     @PostConstruct
     public void init() {
         this.io = new DiDeviceIOManager(this);
         this.actuators = new DiDeviceActuatorManager(this);
+        this.taskExecutor = new DiTaskExecutor(this);
     }
 
     // get io manager
@@ -23,4 +26,9 @@ public class DiDevice {
     public DiDeviceActuatorManager getActuators() {
         return this.actuators;
     }
+
+    // get task executor
+    public DiTaskExecutor getTaskExecutor() {
+        return this.taskExecutor;
+    }
 }

src/src/main/java/com/my/graphiteDigesterBg/diframe/DiDeviceActuatorManager.java

@@ -1,5 +1,4 @@
 package com.my.graphiteDigesterBg.diframe;
-import com.my.graphiteDigesterBg.diframe.actuator.DiActuator;
 import java.util.HashMap;
 import java.util.Map;
 public class DiDeviceActuatorManager {

src/src/main/java/com/my/graphiteDigesterBg/diframe/DiTask.java

@@ -0,0 +1,5 @@
+package com.my.graphiteDigesterBg.diframe;
+public interface DiTask {
+    // run
+    void run();
+}

src/src/main/java/com/my/graphiteDigesterBg/diframe/DiTaskBase.java

@@ -0,0 +1,16 @@
+package com.my.graphiteDigesterBg.diframe;
+import java.util.List;
+import java.util.Map;
+abstract public class DiTaskBase {
+    // parameter
+    private Map<String,Object> parameter;
+    // steps
+    private List<DiTaskStep> steps;
+    // step index
+    private Integer stepIndex;
+
+    // run
+    public void run() {
+        // do something
+    }
+}

src/src/main/java/com/my/graphiteDigesterBg/diframe/DiTaskExecutor.java

@@ -0,0 +1,10 @@
+package com.my.graphiteDigesterBg.diframe;
+public class DiTaskExecutor {
+    // device instance
+    private DiDevice device;
+
+    // constructor
+    public DiTaskExecutor(DiDevice device) {
+        this.device = device;
+    }
+}

src/src/main/java/com/my/graphiteDigesterBg/diframe/DiTaskStep.java

@@ -0,0 +1,4 @@
+package com.my.graphiteDigesterBg.diframe;
+
+public interface DiTaskStep {
+}

src/src/main/java/com/my/graphiteDigesterBg/diframe/actuator/DiActMotor.java

@@ -1,4 +1,7 @@
 package com.my.graphiteDigesterBg.diframe.actuator;
+
+import com.my.graphiteDigesterBg.diframe.DiActuatorBase;
+
 public class DiActMotor extends DiActuatorBase {
     public void moveTo( Integer pos ) {}
     public void moveBy( Integer delta ) {}

src/src/main/java/com/my/graphiteDigesterBg/diframe/actuator/DiActPeristalticPump.java

@@ -1,3 +1,6 @@
 package com.my.graphiteDigesterBg.diframe.actuator;
+
+import com.my.graphiteDigesterBg.diframe.DiActuatorBase;
+
 public class DiActPeristalticPump extends DiActuatorBase {
 }

src/src/main/java/com/my/graphiteDigesterBg/diframe/actuator/DiActServo.java

@@ -1,3 +1,6 @@
 package com.my.graphiteDigesterBg.diframe.actuator;
+
+import com.my.graphiteDigesterBg.diframe.DiActuatorBase;
+
 public class DiActServo extends DiActuatorBase {
 }

src/src/main/java/com/my/graphiteDigesterBg/diframe/actuator/DiActuator.java

@@ -1,4 +0,0 @@
-package com.my.graphiteDigesterBg.diframe.actuator;
-public interface DiActuator {
-
-}

src/src/main/java/com/my/graphiteDigesterBg/diframe/api/ApiConsumable.java

@@ -0,0 +1,4 @@
+package com.my.graphiteDigesterBg.diframe.api;
+
+public class ApiConsumable {
+}

src/src/main/java/com/my/graphiteDigesterBg/diframe/api/ApiDevice.java

@@ -0,0 +1,8 @@
+package com.my.graphiteDigesterBg.diframe.api;
+public class ApiDevice {
+    public void init() {}
+    public void start() {}
+    public void stop() {}
+    public void pause() {}
+    public void resume() {}
+}

src/src/main/java/com/my/graphiteDigesterBg/diframe/api/ApiTask.java

@@ -0,0 +1,4 @@
+package com.my.graphiteDigesterBg.diframe.api;
+public class ApiTask {
+    public void append( String name, Object params ) {}
+}

src/src/main/java/com/my/graphiteDigesterBg/diframe/api/ApiUser.java

@@ -0,0 +1,5 @@
+package com.my.graphiteDigesterBg.diframe.api;
+public class ApiUser {
+    public void login() {}
+    public void logout() {}
+}

src/src/main/java/com/my/graphiteDigesterBg/task/TaskDigestion.java

@@ -0,0 +1,8 @@
+package com.my.graphiteDigesterBg.task;
+import com.my.graphiteDigesterBg.diframe.DiTaskBase;
+public class TaskDigestion extends DiTaskBase {
+    @Override
+    public void run() {
+        System.out.println("TaskDigestion.run()");
+    }
+}