From 973322370abdeb79d8f4446de7004436deacf573 Mon Sep 17 00:00:00 2001
From: fddc <coder01@qq.com>
Date: Mon, 31 May 2021 13:06:09 +0800
Subject: [PATCH] =?UTF-8?q?agent=E6=96=B0=E5=A2=9Etag=E5=90=AF=E5=8A=A8?=
 =?UTF-8?q?=E5=8F=82=E6=95=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../processors/impl/script/CMDProcessor.java  | 20 +++++++++++++++++++
 .../tech/powerjob/agent/MainApplication.java  |  4 ++++
 2 files changed, 24 insertions(+)
 create mode 100644 powerjob-official-processors/src/main/java/tech/powerjob/official/processors/impl/script/CMDProcessor.java

diff --git a/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/impl/script/CMDProcessor.java b/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/impl/script/CMDProcessor.java
new file mode 100644
index 00000000..9b7a40b7
--- /dev/null
+++ b/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/impl/script/CMDProcessor.java
@@ -0,0 +1,20 @@
+package tech.powerjob.official.processors.impl.script;
+
+/**
+ * python processor
+ *
+ * @author fddc
+ * @since 2021/5/14
+ */
+public class PowerShellProcessor extends AbstractScriptProcessor {
+
+    @Override
+    protected String getScriptName(Long instanceId) {
+        return String.format("powershell_%d.bat", instanceId);
+    }
+
+    @Override
+    protected String getRunCommand() {
+        return "powershell.exe";
+    }
+}
diff --git a/powerjob-worker-agent/src/main/java/tech/powerjob/agent/MainApplication.java b/powerjob-worker-agent/src/main/java/tech/powerjob/agent/MainApplication.java
index c8ca2e36..b89767f1 100644
--- a/powerjob-worker-agent/src/main/java/tech/powerjob/agent/MainApplication.java
+++ b/powerjob-worker-agent/src/main/java/tech/powerjob/agent/MainApplication.java
@@ -36,6 +36,9 @@ public class MainApplication implements Runnable {
     @Option(names = {"-l", "--length"}, description = "ProcessResult#msg max length")
     private int length = 1024;
 
+    @Option(names = {"-t", "--tag"}, description = "worker-agent's tag")
+    private String tag;
+
     public static void main(String[] args) {
         CommandLine commandLine = new CommandLine(new MainApplication());
         commandLine.execute(args);
@@ -52,6 +55,7 @@ public class MainApplication implements Runnable {
             cfg.setServerAddress(Splitter.on(",").splitToList(server));
             cfg.setStoreStrategy(StoreStrategy.MEMORY.name().equals(storeStrategy) ? StoreStrategy.MEMORY : StoreStrategy.DISK);
             cfg.setMaxResultLength(length);
+            cfg.setTag(tag);
 
             PowerJobWorker worker = new PowerJobWorker();
             worker.setConfig(cfg);