增加机器命令

iot-machine-data-event/pom.xml

@@ -23,6 +23,12 @@
     </properties>
 
     <dependencies>
+        <dependency>
+            <groupId>com.qniao</groupId>
+            <artifactId>ddd-event</artifactId>
+            <version>0.0.1-SNAPSHOT</version>
+        </dependency>
+
         <!-- Apache Flink dependencies -->
         <!-- These dependencies are provided, because they should not be packaged into the JAR file. -->
         <dependency>

iot-machine-data-event/src/main/java/com/qniao/iot/machine/command/CompleteMachineOutputCommand.java

@@ -0,0 +1,26 @@
+package com.qniao.iot.machine.command;
+
+import com.qniao.domain.BaseCommand;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.NoArgsConstructor;
+
+/**
+ * 完成机器产量命令
+ */
+@EqualsAndHashCode(callSuper = true)
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class CompleteMachineOutputCommand extends BaseCommand {
+    /**
+     * 机器标识
+     */
+    private Long id;
+
+    /**
+     * 当前总产量
+     */
+    private Long currTotalOutput;
+}

iot-machine-data-event/src/main/java/com/qniao/iot/machine/command/PowerOffMachineCommand.java

@@ -0,0 +1,28 @@
+package com.qniao.iot.machine.command;
+
+import com.qniao.domain.BaseCommand;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.NoArgsConstructor;
+
+/**
+ * 机器断电命令
+ */
+@EqualsAndHashCode(callSuper = true)
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class PowerOffMachineCommand extends BaseCommand {
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 机器标识
+     */
+    private Long id;
+
+    /**
+     * 当前总产量
+     */
+    private Long currTotalOutput;
+}

iot-machine-data-event/src/main/java/com/qniao/iot/machine/command/PowerOnMachineCommand.java

@@ -0,0 +1,28 @@
+package com.qniao.iot.machine.command;
+
+import com.qniao.domain.BaseCommand;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.NoArgsConstructor;
+
+/**
+ * 机器通电命令
+ */
+@EqualsAndHashCode(callSuper = true)
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class PowerOnMachineCommand extends BaseCommand {
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 机器标识
+     */
+    private Long id;
+
+    /**
+     * 当前总产量
+     */
+    private Long currTotalOutput;
+}

iot-machine-data-event/src/main/java/com/qniao/iot/machine/command/StartMachineWorkingCommand.java

@@ -0,0 +1,28 @@
+package com.qniao.iot.machine.command;
+
+import com.qniao.domain.BaseCommand;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.NoArgsConstructor;
+
+/**
+ * 机器开始工作命令
+ */
+@EqualsAndHashCode(callSuper = true)
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class StartMachineWorkingCommand extends BaseCommand {
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 机器标识
+     */
+    private Long id;
+
+    /**
+     * 当前总产量
+     */
+    private Long currTotalOutput;
+}

iot-machine-data-event/src/main/java/com/qniao/iot/machine/command/StopMachineWorkingCommand.java

@@ -0,0 +1,28 @@
+package com.qniao.iot.machine.command;
+
+import com.qniao.domain.BaseCommand;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.NoArgsConstructor;
+
+/**
+ * 停止机器工作命令
+ */
+@EqualsAndHashCode(callSuper = true)
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class StopMachineWorkingCommand extends BaseCommand {
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 机器标识
+     */
+    private Long id;
+
+    /**
+     * 当前总产量
+     */
+    private Long currTotalOutput;
+}

iot-machine-state-event-generator-job/pom.xml

@@ -21,11 +21,6 @@
     </properties>
 
     <dependencies>
-        <dependency>
-            <groupId>com.qniao</groupId>
-            <artifactId>printing-packaging-factory-service-event</artifactId>
-            <version>0.0.1-SNAPSHOT</version>
-        </dependency>
         <dependency>
             <groupId>com.qniao</groupId>
             <artifactId>iot-machine-data-event</artifactId>