From 0f5c3c1ea0dd5b853ec6ae44b191822ca76cefa0 Mon Sep 17 00:00:00 2001
From: zangkun <t04041143@163.com>
Date: Tue, 12 Jul 2022 11:56:29 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E6=9C=BA=E5=99=A8=E5=91=BD?=
 =?UTF-8?q?=E4=BB=A4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 iot-machine-data-event/pom.xml                |  6 ++++
 .../command/CompleteMachineOutputCommand.java | 26 +++++++++++++++++
 .../command/PowerOffMachineCommand.java       | 28 +++++++++++++++++++
 .../command/PowerOnMachineCommand.java        | 28 +++++++++++++++++++
 .../command/StartMachineWorkingCommand.java   | 28 +++++++++++++++++++
 .../command/StopMachineWorkingCommand.java    | 28 +++++++++++++++++++
 iot-machine-state-event-generator-job/pom.xml |  5 ----
 7 files changed, 144 insertions(+), 5 deletions(-)
 create mode 100644 iot-machine-data-event/src/main/java/com/qniao/iot/machine/command/CompleteMachineOutputCommand.java
 create mode 100644 iot-machine-data-event/src/main/java/com/qniao/iot/machine/command/PowerOffMachineCommand.java
 create mode 100644 iot-machine-data-event/src/main/java/com/qniao/iot/machine/command/PowerOnMachineCommand.java
 create mode 100644 iot-machine-data-event/src/main/java/com/qniao/iot/machine/command/StartMachineWorkingCommand.java
 create mode 100644 iot-machine-data-event/src/main/java/com/qniao/iot/machine/command/StopMachineWorkingCommand.java

diff --git a/iot-machine-data-event/pom.xml b/iot-machine-data-event/pom.xml
index 0c2587c..76418e6 100644
--- a/iot-machine-data-event/pom.xml
+++ b/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>
diff --git a/iot-machine-data-event/src/main/java/com/qniao/iot/machine/command/CompleteMachineOutputCommand.java b/iot-machine-data-event/src/main/java/com/qniao/iot/machine/command/CompleteMachineOutputCommand.java
new file mode 100644
index 0000000..7448fdd
--- /dev/null
+++ b/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;
+}
diff --git a/iot-machine-data-event/src/main/java/com/qniao/iot/machine/command/PowerOffMachineCommand.java b/iot-machine-data-event/src/main/java/com/qniao/iot/machine/command/PowerOffMachineCommand.java
new file mode 100644
index 0000000..8220c2d
--- /dev/null
+++ b/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;
+}
diff --git a/iot-machine-data-event/src/main/java/com/qniao/iot/machine/command/PowerOnMachineCommand.java b/iot-machine-data-event/src/main/java/com/qniao/iot/machine/command/PowerOnMachineCommand.java
new file mode 100644
index 0000000..fc089ad
--- /dev/null
+++ b/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;
+}
diff --git a/iot-machine-data-event/src/main/java/com/qniao/iot/machine/command/StartMachineWorkingCommand.java b/iot-machine-data-event/src/main/java/com/qniao/iot/machine/command/StartMachineWorkingCommand.java
new file mode 100644
index 0000000..5f735d0
--- /dev/null
+++ b/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;
+}
\ No newline at end of file
diff --git a/iot-machine-data-event/src/main/java/com/qniao/iot/machine/command/StopMachineWorkingCommand.java b/iot-machine-data-event/src/main/java/com/qniao/iot/machine/command/StopMachineWorkingCommand.java
new file mode 100644
index 0000000..59f1771
--- /dev/null
+++ b/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;
+}
diff --git a/iot-machine-state-event-generator-job/pom.xml b/iot-machine-state-event-generator-job/pom.xml
index b7b021b..e1fab28 100644
--- a/iot-machine-state-event-generator-job/pom.xml
+++ b/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>