feat: 添加ai任务命令 (jetlinks#105)

* feat: 添加ai任务命令

* feat: 优化

Author: goten7

jetlinks-sdk-api/src/main/java/org/jetlinks/sdk/server/ai/llm/agent/StartTaskCommand.java

@@ -0,0 +1,26 @@
+package org.jetlinks.sdk.server.ai.llm.agent;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import org.jetlinks.core.command.AbstractCommand;
+import reactor.core.publisher.Flux;
+
+import java.util.Optional;
+
+@Schema(title = "任务命令")
+public class StartTaskCommand extends AbstractCommand<Flux<TaskResponse>, StartTaskCommand> {
+
+
+    @Schema(title = "是否异步执行")
+    public boolean getAsync() {
+        return Optional.ofNullable(getOrNull("async", Boolean.class)).orElse(true);
+    }
+
+    public StartTaskCommand setAsync(boolean async) {
+        return with("async", async);
+    }
+
+    public ChatRequest<?> asRequest() {
+        return as(ChatRequest.class);
+    }
+
+}

jetlinks-sdk-api/src/main/java/org/jetlinks/sdk/server/ai/llm/agent/TaskResponse.java

@@ -0,0 +1,57 @@
+package org.jetlinks.sdk.server.ai.llm.agent;
+
+import com.fasterxml.jackson.annotation.JsonAnyGetter;
+import com.fasterxml.jackson.annotation.JsonAnySetter;
+import lombok.NoArgsConstructor;
+import org.hswebframework.ezorm.core.Extendable;
+import org.jetlinks.core.GenericHeaderSupport;
+import org.jetlinks.core.utils.SerializeUtils;
+
+import java.io.Externalizable;
+import java.io.IOException;
+import java.io.ObjectInput;
+import java.io.ObjectOutput;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+@NoArgsConstructor
+public class TaskResponse extends GenericHeaderSupport<TaskResponse> implements Extendable, Externalizable {
+
+    private volatile Map<String, Object> extensions;
+
+    public TaskResponse(Map<String, Object> extensions) {
+        this.extensions = new ConcurrentHashMap<>(extensions);
+    }
+
+    @Override
+    public void writeExternal(ObjectOutput out) throws IOException {
+        SerializeUtils.writeKeyValue(getHeaders(), out);
+        SerializeUtils.writeKeyValue(extensions, out);
+    }
+
+    @Override
+    public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException {
+        SerializeUtils.readKeyValue(in, this::addHeader);
+        SerializeUtils.readKeyValue(in,this::setExtension);
+    }
+
+
+    @Override
+    @JsonAnyGetter
+    public Map<String, Object> extensions() {
+        return extensions;
+    }
+
+    @Override
+    @JsonAnySetter
+    public void setExtension(String property, Object value) {
+        if (extensions == null) {
+            synchronized (this) {
+                if (extensions == null) {
+                    extensions = new ConcurrentHashMap<>();
+                }
+            }
+        }
+        extensions.put(property, value);
+    }
+}