string client = 1;
+ * @return The client.
+ */
+ String getClient();
+ /**
+ * string client = 1;
+ * @return The bytes for client.
+ */
+ com.google.protobuf.ByteString
+ getClientBytes();
+
+ /**
+ * .Message.type cmd = 2;
+ * @return The enum numeric value on the wire for cmd.
+ */
+ int getCmdValue();
+ /**
+ * .Message.type cmd = 2;
+ * @return The cmd.
+ */
+ Message.type getCmd();
+
+ /**
+ * string content = 3;
+ * @return The content.
+ */
+ String getContent();
+ /**
+ * string content = 3;
+ * @return The bytes for content.
+ */
+ com.google.protobuf.ByteString
+ getContentBytes();
+ }
+ /**
+ * Protobuf type {@code Message}
+ */
+ public static final class Message extends
+ com.google.protobuf.GeneratedMessageV3 implements
+ // @@protoc_insertion_point(message_implements:Message)
+ MessageOrBuilder {
+ private static final long serialVersionUID = 0L;
+ // Use Message.newBuilder() to construct.
+ private Message(com.google.protobuf.GeneratedMessageV3.Builder builder) {
+ super(builder);
+ }
+ private Message() {
+ client_ = "";
+ cmd_ = 0;
+ content_ = "";
+ }
+
+ @Override
+ @SuppressWarnings({"unused"})
+ protected Object newInstance(
+ UnusedPrivateParameter unused) {
+ return new Message();
+ }
+
+ @Override
+ public final com.google.protobuf.UnknownFieldSet
+ getUnknownFields() {
+ return this.unknownFields;
+ }
+ private Message(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ this();
+ if (extensionRegistry == null) {
+ throw new NullPointerException();
+ }
+ com.google.protobuf.UnknownFieldSet.Builder unknownFields =
+ com.google.protobuf.UnknownFieldSet.newBuilder();
+ try {
+ boolean done = false;
+ while (!done) {
+ int tag = input.readTag();
+ switch (tag) {
+ case 0:
+ done = true;
+ break;
+ case 10: {
+ String s = input.readStringRequireUtf8();
+
+ client_ = s;
+ break;
+ }
+ case 16: {
+ int rawValue = input.readEnum();
+
+ cmd_ = rawValue;
+ break;
+ }
+ case 26: {
+ String s = input.readStringRequireUtf8();
+
+ content_ = s;
+ break;
+ }
+ default: {
+ if (!parseUnknownField(
+ input, unknownFields, extensionRegistry, tag)) {
+ done = true;
+ }
+ break;
+ }
+ }
+ }
+ } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+ throw e.setUnfinishedMessage(this);
+ } catch (java.io.IOException e) {
+ throw new com.google.protobuf.InvalidProtocolBufferException(
+ e).setUnfinishedMessage(this);
+ } finally {
+ this.unknownFields = unknownFields.build();
+ makeExtensionsImmutable();
+ }
+ }
+ public static final com.google.protobuf.Descriptors.Descriptor
+ getDescriptor() {
+ return Payload.internal_static_Message_descriptor;
+ }
+
+ @Override
+ protected FieldAccessorTable
+ internalGetFieldAccessorTable() {
+ return Payload.internal_static_Message_fieldAccessorTable
+ .ensureFieldAccessorsInitialized(
+ Message.class, Builder.class);
+ }
+
+ /**
+ * Protobuf enum {@code Message.type}
+ */
+ public enum type
+ implements com.google.protobuf.ProtocolMessageEnum {
+ /**
+ * + *客户端心跳消息 + *+ * + *
HEARTBEAT_REQUEST = 0;
+ */
+ HEARTBEAT_REQUEST(0),
+ /**
+ * + *服务端心跳消息 + *+ * + *
HEARTBEAT_RESPONSE = 1;
+ */
+ HEARTBEAT_RESPONSE(1),
+ /**
+ * + * 认证 + *+ * + *
AUTH = 2;
+ */
+ AUTH(2),
+ /**
+ * + *请求开始打印命令 + *+ * + *
PRINT = 3;
+ */
+ PRINT(3),
+ /**
+ * + * 打印完成反馈 + *+ * + *
PRINT_DONE = 4;
+ */
+ PRINT_DONE(4),
+ /**
+ * + * 随便是什么 + *+ * + *
WHATEVER = 5;
+ */
+ WHATEVER(5),
+ UNRECOGNIZED(-1),
+ ;
+
+ /**
+ * + *客户端心跳消息 + *+ * + *
HEARTBEAT_REQUEST = 0;
+ */
+ public static final int HEARTBEAT_REQUEST_VALUE = 0;
+ /**
+ * + *服务端心跳消息 + *+ * + *
HEARTBEAT_RESPONSE = 1;
+ */
+ public static final int HEARTBEAT_RESPONSE_VALUE = 1;
+ /**
+ * + * 认证 + *+ * + *
AUTH = 2;
+ */
+ public static final int AUTH_VALUE = 2;
+ /**
+ * + *请求开始打印命令 + *+ * + *
PRINT = 3;
+ */
+ public static final int PRINT_VALUE = 3;
+ /**
+ * + * 打印完成反馈 + *+ * + *
PRINT_DONE = 4;
+ */
+ public static final int PRINT_DONE_VALUE = 4;
+ /**
+ * + * 随便是什么 + *+ * + *
WHATEVER = 5;
+ */
+ public static final int WHATEVER_VALUE = 5;
+
+
+ @Override
+ public final int getNumber() {
+ if (this == UNRECOGNIZED) {
+ throw new IllegalArgumentException(
+ "Can't get the number of an unknown enum value.");
+ }
+ return value;
+ }
+
+ /**
+ * @param value The numeric wire value of the corresponding enum entry.
+ * @return The enum associated with the given numeric wire value.
+ * @deprecated Use {@link #forNumber(int)} instead.
+ */
+ @Deprecated
+ public static type valueOf(int value) {
+ return forNumber(value);
+ }
+
+ /**
+ * @param value The numeric wire value of the corresponding enum entry.
+ * @return The enum associated with the given numeric wire value.
+ */
+ public static type forNumber(int value) {
+ switch (value) {
+ case 0: return HEARTBEAT_REQUEST;
+ case 1: return HEARTBEAT_RESPONSE;
+ case 2: return AUTH;
+ case 3: return PRINT;
+ case 4: return PRINT_DONE;
+ case 5: return WHATEVER;
+ default: return null;
+ }
+ }
+
+ public static com.google.protobuf.Internal.EnumLiteMapstring client = 1;
+ * @return The client.
+ */
+ @Override
+ public String getClient() {
+ Object ref = client_;
+ if (ref instanceof String) {
+ return (String) ref;
+ } else {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ String s = bs.toStringUtf8();
+ client_ = s;
+ return s;
+ }
+ }
+ /**
+ * string client = 1;
+ * @return The bytes for client.
+ */
+ @Override
+ public com.google.protobuf.ByteString
+ getClientBytes() {
+ Object ref = client_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (String) ref);
+ client_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+
+ public static final int CMD_FIELD_NUMBER = 2;
+ private int cmd_;
+ /**
+ * .Message.type cmd = 2;
+ * @return The enum numeric value on the wire for cmd.
+ */
+ @Override public int getCmdValue() {
+ return cmd_;
+ }
+ /**
+ * .Message.type cmd = 2;
+ * @return The cmd.
+ */
+ @Override public type getCmd() {
+ @SuppressWarnings("deprecation")
+ type result = type.valueOf(cmd_);
+ return result == null ? type.UNRECOGNIZED : result;
+ }
+
+ public static final int CONTENT_FIELD_NUMBER = 3;
+ private volatile Object content_;
+ /**
+ * string content = 3;
+ * @return The content.
+ */
+ @Override
+ public String getContent() {
+ Object ref = content_;
+ if (ref instanceof String) {
+ return (String) ref;
+ } else {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ String s = bs.toStringUtf8();
+ content_ = s;
+ return s;
+ }
+ }
+ /**
+ * string content = 3;
+ * @return The bytes for content.
+ */
+ @Override
+ public com.google.protobuf.ByteString
+ getContentBytes() {
+ Object ref = content_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (String) ref);
+ content_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+
+ private byte memoizedIsInitialized = -1;
+ @Override
+ public final boolean isInitialized() {
+ byte isInitialized = memoizedIsInitialized;
+ if (isInitialized == 1) return true;
+ if (isInitialized == 0) return false;
+
+ memoizedIsInitialized = 1;
+ return true;
+ }
+
+ @Override
+ public void writeTo(com.google.protobuf.CodedOutputStream output)
+ throws java.io.IOException {
+ if (!getClientBytes().isEmpty()) {
+ com.google.protobuf.GeneratedMessageV3.writeString(output, 1, client_);
+ }
+ if (cmd_ != type.HEARTBEAT_REQUEST.getNumber()) {
+ output.writeEnum(2, cmd_);
+ }
+ if (!getContentBytes().isEmpty()) {
+ com.google.protobuf.GeneratedMessageV3.writeString(output, 3, content_);
+ }
+ unknownFields.writeTo(output);
+ }
+
+ @Override
+ public int getSerializedSize() {
+ int size = memoizedSize;
+ if (size != -1) return size;
+
+ size = 0;
+ if (!getClientBytes().isEmpty()) {
+ size += com.google.protobuf.GeneratedMessageV3.computeStringSize(1, client_);
+ }
+ if (cmd_ != type.HEARTBEAT_REQUEST.getNumber()) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeEnumSize(2, cmd_);
+ }
+ if (!getContentBytes().isEmpty()) {
+ size += com.google.protobuf.GeneratedMessageV3.computeStringSize(3, content_);
+ }
+ size += unknownFields.getSerializedSize();
+ memoizedSize = size;
+ return size;
+ }
+
+ @Override
+ public boolean equals(final Object obj) {
+ if (obj == this) {
+ return true;
+ }
+ if (!(obj instanceof Message)) {
+ return super.equals(obj);
+ }
+ Message other = (Message) obj;
+
+ if (!getClient()
+ .equals(other.getClient())) return false;
+ if (cmd_ != other.cmd_) return false;
+ if (!getContent()
+ .equals(other.getContent())) return false;
+ if (!unknownFields.equals(other.unknownFields)) return false;
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ if (memoizedHashCode != 0) {
+ return memoizedHashCode;
+ }
+ int hash = 41;
+ hash = (19 * hash) + getDescriptor().hashCode();
+ hash = (37 * hash) + CLIENT_FIELD_NUMBER;
+ hash = (53 * hash) + getClient().hashCode();
+ hash = (37 * hash) + CMD_FIELD_NUMBER;
+ hash = (53 * hash) + cmd_;
+ hash = (37 * hash) + CONTENT_FIELD_NUMBER;
+ hash = (53 * hash) + getContent().hashCode();
+ hash = (29 * hash) + unknownFields.hashCode();
+ memoizedHashCode = hash;
+ return hash;
+ }
+
+ public static Message parseFrom(
+ java.nio.ByteBuffer data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static Message parseFrom(
+ java.nio.ByteBuffer data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static Message parseFrom(
+ com.google.protobuf.ByteString data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static Message parseFrom(
+ com.google.protobuf.ByteString data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static Message parseFrom(byte[] data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static Message parseFrom(
+ byte[] data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static Message parseFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input);
+ }
+ public static Message parseFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input, extensionRegistry);
+ }
+ public static Message parseDelimitedFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseDelimitedWithIOException(PARSER, input);
+ }
+ public static Message parseDelimitedFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseDelimitedWithIOException(PARSER, input, extensionRegistry);
+ }
+ public static Message parseFrom(
+ com.google.protobuf.CodedInputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input);
+ }
+ public static Message parseFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input, extensionRegistry);
+ }
+
+ @Override
+ public Builder newBuilderForType() { return newBuilder(); }
+ public static Builder newBuilder() {
+ return DEFAULT_INSTANCE.toBuilder();
+ }
+ public static Builder newBuilder(Message prototype) {
+ return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
+ }
+ @Override
+ public Builder toBuilder() {
+ return this == DEFAULT_INSTANCE
+ ? new Builder() : new Builder().mergeFrom(this);
+ }
+
+ @Override
+ protected Builder newBuilderForType(
+ BuilderParent parent) {
+ Builder builder = new Builder(parent);
+ return builder;
+ }
+ /**
+ * Protobuf type {@code Message}
+ */
+ public static final class Builder extends
+ com.google.protobuf.GeneratedMessageV3.Builderstring client = 1;
+ * @return The client.
+ */
+ @Override
+ public String getClient() {
+ Object ref = client_;
+ if (!(ref instanceof String)) {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ String s = bs.toStringUtf8();
+ client_ = s;
+ return s;
+ } else {
+ return (String) ref;
+ }
+ }
+ /**
+ * string client = 1;
+ * @return The bytes for client.
+ */
+ @Override
+ public com.google.protobuf.ByteString
+ getClientBytes() {
+ Object ref = client_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (String) ref);
+ client_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+ /**
+ * string client = 1;
+ * @param value The client to set.
+ * @return This builder for chaining.
+ */
+ public Builder setClient(
+ String value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+
+ client_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ * string client = 1;
+ * @return This builder for chaining.
+ */
+ public Builder clearClient() {
+
+ client_ = getDefaultInstance().getClient();
+ onChanged();
+ return this;
+ }
+ /**
+ * string client = 1;
+ * @param value The bytes for client to set.
+ * @return This builder for chaining.
+ */
+ public Builder setClientBytes(
+ com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ checkByteStringIsUtf8(value);
+
+ client_ = value;
+ onChanged();
+ return this;
+ }
+
+ private int cmd_ = 0;
+ /**
+ * .Message.type cmd = 2;
+ * @return The enum numeric value on the wire for cmd.
+ */
+ @Override public int getCmdValue() {
+ return cmd_;
+ }
+ /**
+ * .Message.type cmd = 2;
+ * @param value The enum numeric value on the wire for cmd to set.
+ * @return This builder for chaining.
+ */
+ public Builder setCmdValue(int value) {
+
+ cmd_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ * .Message.type cmd = 2;
+ * @return The cmd.
+ */
+ @Override
+ public type getCmd() {
+ @SuppressWarnings("deprecation")
+ type result = type.valueOf(cmd_);
+ return result == null ? type.UNRECOGNIZED : result;
+ }
+ /**
+ * .Message.type cmd = 2;
+ * @param value The cmd to set.
+ * @return This builder for chaining.
+ */
+ public Builder setCmd(type value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+
+ cmd_ = value.getNumber();
+ onChanged();
+ return this;
+ }
+ /**
+ * .Message.type cmd = 2;
+ * @return This builder for chaining.
+ */
+ public Builder clearCmd() {
+
+ cmd_ = 0;
+ onChanged();
+ return this;
+ }
+
+ private Object content_ = "";
+ /**
+ * string content = 3;
+ * @return The content.
+ */
+ @Override
+ public String getContent() {
+ Object ref = content_;
+ if (!(ref instanceof String)) {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ String s = bs.toStringUtf8();
+ content_ = s;
+ return s;
+ } else {
+ return (String) ref;
+ }
+ }
+ /**
+ * string content = 3;
+ * @return The bytes for content.
+ */
+ @Override
+ public com.google.protobuf.ByteString
+ getContentBytes() {
+ Object ref = content_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (String) ref);
+ content_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+ /**
+ * string content = 3;
+ * @param value The content to set.
+ * @return This builder for chaining.
+ */
+ public Builder setContent(
+ String value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+
+ content_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ * string content = 3;
+ * @return This builder for chaining.
+ */
+ public Builder clearContent() {
+
+ content_ = getDefaultInstance().getContent();
+ onChanged();
+ return this;
+ }
+ /**
+ * string content = 3;
+ * @param value The bytes for content to set.
+ * @return This builder for chaining.
+ */
+ public Builder setContentBytes(
+ com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ checkByteStringIsUtf8(value);
+
+ content_ = value;
+ onChanged();
+ return this;
+ }
+ @Override
+ public final Builder setUnknownFields(
+ final com.google.protobuf.UnknownFieldSet unknownFields) {
+ return super.setUnknownFields(unknownFields);
+ }
+
+ @Override
+ public final Builder mergeUnknownFields(
+ final com.google.protobuf.UnknownFieldSet unknownFields) {
+ return super.mergeUnknownFields(unknownFields);
+ }
+
+
+ // @@protoc_insertion_point(builder_scope:Message)
+ }
+
+ // @@protoc_insertion_point(class_scope:Message)
+ private static final Message DEFAULT_INSTANCE;
+ static {
+ DEFAULT_INSTANCE = new Message();
+ }
+
+ public static Message getDefaultInstance() {
+ return DEFAULT_INSTANCE;
+ }
+
+ private static final com.google.protobuf.Parser+ * 采集器管理（终端） TaskCollectorController 控制器类 + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +@RestController +public class TaskCollectorController implements TaskCollectorApi { + @Resource + private ITaskCollectorService iTaskCollectorService; + + /** + * 按主键查询 + * + * @param id 主键Id + * @return 实体 + */ + @Override + public TaskCollector findById(String id) { + return iTaskCollectorService.findById(id); + } + + /** + * 关键字搜素 + * + * @param searchRequest 搜索参数 + * @return 分页列表 + */ + @Override + public PageResult+ * 采集器版本列表管理（终端） TaskCollectorVersionController 控制器类 + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +@RestController +public class TaskCollectorVersionController implements TaskCollectorVersionApi { + @Resource + private ITaskCollectorVersionService iTaskCollectorVersionService; + + /** + * 按主键查询 + * + * @param id 主键Id + * @return 实体 + */ + @Override + public TaskCollectorVersion findById(String id) { + return iTaskCollectorVersionService.findById(id); + } + + /** + * 关键字搜素 + * + * @param searchRequest 搜索参数 + * @return 分页列表 + */ + @Override + public PageResult+ * 采集器版本列表更新包管理（终端） TaskCollectorVersionFileController 控制器类 + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +@RestController +public class TaskCollectorVersionFileController implements TaskCollectorVersionFileApi { + @Resource + private ITaskCollectorVersionFileService iTaskCollectorVersionFileService; + + /** + * 按主键查询 + * + * @param id 主键Id + * @return 实体 + */ + @Override + public TaskCollectorVersionFile findById(String id) { + return iTaskCollectorVersionFileService.findById(id); + } + + /** + * 关键字搜素 + * + * @param searchRequest 搜索参数 + * @return 分页列表 + */ + @Override + public PageResult+ * 采集器版本更新日志管理（终端） TaskCollectorVersionLogController 控制器类 + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +@RestController +public class TaskCollectorVersionLogController implements TaskCollectorVersionLogApi { + @Resource + private ITaskCollectorVersionLogService iTaskCollectorVersionLogService; + + /** + * 按主键查询 + * + * @param id 主键Id + * @return 实体 + */ + @Override + public TaskCollectorVersionLog findById(String id) { + return iTaskCollectorVersionLogService.findById(id); + } + + /** + * 关键字搜素 + * + * @param searchRequest 搜索参数 + * @return 分页列表 + */ + @Override + public PageResult+ * 采集器（终端）系统参数表 TaskSystemParamsController 控制器类 + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +@RestController +public class TaskSystemParamsController implements TaskSystemParamsApi { + @Resource + private ITaskSystemParamsService iTaskSystemParamsService; + + /** + * 按主键查询 + * + * @param id 主键Id + * @return 实体 + */ + @Override + public TaskSystemParams findById(String id) { + return iTaskSystemParamsService.findById(id); + } + + /** + * 关键字搜素 + * + * @param searchRequest 搜索参数 + * @return 分页列表 + */ + @Override + public PageResult+ * 采集记录表（终端） TaskTerminatorCollectionRecordController 控制器类 + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +@RestController +public class TaskTerminatorCollectionRecordController implements TaskTerminatorCollectionRecordApi { + @Resource + private ITaskTerminatorCollectionRecordService iTaskTerminatorCollectionRecordService; + + /** + * 按主键查询 + * + * @param id 主键Id + * @return 实体 + */ + @Override + public TaskTerminatorCollectionRecord findById(String id) { + return iTaskTerminatorCollectionRecordService.findById(id); + } + + /** + * 关键字搜素 + * + * @param searchRequest 搜索参数 + * @return 分页列表 + */ + @Override + public PageResult+ * 执行管理器（采集器终端） TaskTerminatorController 控制器类 + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +@RestController +public class TaskTerminatorController implements TaskTerminatorApi { + @Resource + private ITaskTerminatorService iTaskTerminatorService; + + /** + * 按主键查询 + * + * @param id 主键Id + * @return 实体 + */ + @Override + public TaskTerminator findById(String id) { + return iTaskTerminatorService.findById(id); + } + + /** + * 关键字搜素 + * + * @param searchRequest 搜索参数 + * @return 分页列表 + */ + @Override + public PageResult+ * 采集器管理（终端） ITaskCollectorDao 数据访问接口 + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +public interface ITaskCollectorDao extends IBaseDao+ * 采集器版本列表管理（终端） ITaskCollectorVersionDao 数据访问接口 + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +public interface ITaskCollectorVersionDao extends IBaseDao+ * 采集器版本列表更新包管理（终端） ITaskCollectorVersionFileDao 数据访问接口 + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +public interface ITaskCollectorVersionFileDao extends IBaseDao+ * 采集器版本更新日志管理（终端） ITaskCollectorVersionLogDao 数据访问接口 + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +public interface ITaskCollectorVersionLogDao extends IBaseDao+ * 采集器（终端）系统参数表 ITaskSystemParamsDao 数据访问接口 + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +public interface ITaskSystemParamsDao extends IBaseDao+ * 采集记录表（终端） ITaskTerminatorCollectionRecordDao 数据访问接口 + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +public interface ITaskTerminatorCollectionRecordDao extends IBaseDao+ * 执行管理器（采集器终端） ITaskTerminatorDao 数据访问接口 + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +public interface ITaskTerminatorDao extends IBaseDao+ * 采集器管理（终端） TaskCollectorDaoImpl 数据访问实现类 + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +@Repository +public class TaskCollectorDaoImpl extends BaseDaoImpl+ * 采集器版本列表管理（终端） TaskCollectorVersionDaoImpl 数据访问实现类 + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +@Repository +public class TaskCollectorVersionDaoImpl extends BaseDaoImpl+ * 采集器版本列表更新包管理（终端） TaskCollectorVersionFileDaoImpl 数据访问实现类 + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +@Repository +public class TaskCollectorVersionFileDaoImpl extends BaseDaoImpl+ * 采集器版本更新日志管理（终端） TaskCollectorVersionLogDaoImpl 数据访问实现类 + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +@Repository +public class TaskCollectorVersionLogDaoImpl extends BaseDaoImpl+ * 采集器（终端）系统参数表 TaskSystemParamsDaoImpl 数据访问实现类 + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +@Repository +public class TaskSystemParamsDaoImpl extends BaseDaoImpl+ * 采集记录表（终端） TaskTerminatorCollectionRecordDaoImpl 数据访问实现类 + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +@Repository +public class TaskTerminatorCollectionRecordDaoImpl extends BaseDaoImpl+ * 执行管理器（采集器终端） TaskTerminatorDaoImpl 数据访问实现类 + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +@Repository +public class TaskTerminatorDaoImpl extends BaseDaoImpl+* 采集器管理（终端） TaskCollectorMapper 接口 +*
+* +* @author AutoGenerator +* @since 2023-07-10 +*/ +@Mapper +public interface TaskCollectorMapper extends BaseMapper+* 采集器版本列表更新包管理（终端） TaskCollectorVersionFileMapper 接口 +*
+* +* @author AutoGenerator +* @since 2023-07-10 +*/ +@Mapper +public interface TaskCollectorVersionFileMapper extends BaseMapper+* 采集器版本更新日志管理（终端） TaskCollectorVersionLogMapper 接口 +*
+* +* @author AutoGenerator +* @since 2023-07-10 +*/ +@Mapper +public interface TaskCollectorVersionLogMapper extends BaseMapper+* 采集器版本列表管理（终端） TaskCollectorVersionMapper 接口 +*
+* +* @author AutoGenerator +* @since 2023-07-10 +*/ +@Mapper +public interface TaskCollectorVersionMapper extends BaseMapper+* 采集器（终端）系统参数表 TaskSystemParamsMapper 接口 +*
+* +* @author AutoGenerator +* @since 2023-07-10 +*/ +@Mapper +public interface TaskSystemParamsMapper extends BaseMapper+* 采集记录表（终端） TaskTerminatorCollectionRecordMapper 接口 +*
+* +* @author AutoGenerator +* @since 2023-07-10 +*/ +@Mapper +public interface TaskTerminatorCollectionRecordMapper extends BaseMapper+* 执行管理器（采集器终端） TaskTerminatorMapper 接口 +*
+* +* @author AutoGenerator +* @since 2023-07-10 +*/ +@Mapper +public interface TaskTerminatorMapper extends BaseMapper+ * 采集器管理（终端） ITaskCollectorService 服务接口 + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +public interface ITaskCollectorService { + + TaskCollector findById(String id); + + boolean add(TaskCollector taskCollector); + + boolean edit(TaskCollector taskCollector); + + int delete(List+ * 采集器版本列表更新包管理（终端） ITaskCollectorVersionFileService 服务接口 + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +public interface ITaskCollectorVersionFileService { + + TaskCollectorVersionFile findById(String id); + + boolean add(TaskCollectorVersionFile taskCollectorVersionFile); + + boolean edit(TaskCollectorVersionFile taskCollectorVersionFile); + + int delete(List+ * 采集器版本更新日志管理（终端） ITaskCollectorVersionLogService 服务接口 + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +public interface ITaskCollectorVersionLogService { + + TaskCollectorVersionLog findById(String id); + + boolean add(TaskCollectorVersionLog taskCollectorVersionLog); + + boolean edit(TaskCollectorVersionLog taskCollectorVersionLog); + + int delete(List+ * 采集器版本列表管理（终端） ITaskCollectorVersionService 服务接口 + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +public interface ITaskCollectorVersionService { + + TaskCollectorVersion findById(String id); + + boolean add(TaskCollectorVersion taskCollectorVersion); + + boolean edit(TaskCollectorVersion taskCollectorVersion); + + int delete(List+ * 采集器（终端）系统参数表 ITaskSystemParamsService 服务接口 + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +public interface ITaskSystemParamsService { + + TaskSystemParams findById(String id); + + boolean add(TaskSystemParams taskSystemParams); + + boolean edit(TaskSystemParams taskSystemParams); + + int delete(List+ * 采集记录表（终端） ITaskTerminatorCollectionRecordService 服务接口 + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +public interface ITaskTerminatorCollectionRecordService { + + TaskTerminatorCollectionRecord findById(String id); + + boolean add(TaskTerminatorCollectionRecord taskTerminatorCollectionRecord); + + boolean edit(TaskTerminatorCollectionRecord taskTerminatorCollectionRecord); + + int delete(List+ * 执行管理器（采集器终端） ITaskTerminatorService 服务接口 + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +public interface ITaskTerminatorService { + + TaskTerminator findById(String id); + + boolean add(TaskTerminator taskTerminator); + + boolean edit(TaskTerminator taskTerminator); + + int delete(List+ * 采集器管理（终端） TaskCollectorServiceImpl 服务实现类 + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +@Service +public class TaskCollectorServiceImpl implements ITaskCollectorService { + @Resource + private ITaskCollectorDao iTaskCollectorDao; + @Resource + private IdService idService; + + /** + * 按主键查询 + * + * @param id 主键Id + * @return 实体 + */ + @Override + public TaskCollector findById(String id) { + return iTaskCollectorDao.findById(id); + } + + /** + * 关键字搜素 + * + * @param searchRequest 搜索参数 + * @return 分页列表 + */ + @Override + public PageResult+ * 采集器版本列表更新包管理（终端） TaskCollectorVersionFileServiceImpl 服务实现类 + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +@Service +public class TaskCollectorVersionFileServiceImpl implements ITaskCollectorVersionFileService { + @Resource + private ITaskCollectorVersionFileDao iTaskCollectorVersionFileDao; + @Resource + private IdService idService; + + /** + * 按主键查询 + * + * @param id 主键Id + * @return 实体 + */ + @Override + public TaskCollectorVersionFile findById(String id) { + return iTaskCollectorVersionFileDao.findById(id); + } + + /** + * 关键字搜素 + * + * @param searchRequest 搜索参数 + * @return 分页列表 + */ + @Override + public PageResult+ * 采集器版本更新日志管理（终端） TaskCollectorVersionLogServiceImpl 服务实现类 + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +@Service +public class TaskCollectorVersionLogServiceImpl implements ITaskCollectorVersionLogService { + @Resource + private ITaskCollectorVersionLogDao iTaskCollectorVersionLogDao; + @Resource + private IdService idService; + /** + * 按主键查询 + * + * @param id 主键Id + * @return 实体 + */ + @Override + public TaskCollectorVersionLog findById(String id) { + return iTaskCollectorVersionLogDao.findById(id); + } + + /** + * 关键字搜素 + * + * @param searchRequest 搜索参数 + * @return 分页列表 + */ + @Override + public PageResult+ * 采集器版本列表管理（终端） TaskCollectorVersionServiceImpl 服务实现类 + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +@Service +public class TaskCollectorVersionServiceImpl implements ITaskCollectorVersionService { + @Resource + private ITaskCollectorVersionDao iTaskCollectorVersionDao; + @Resource + private IdService idService; + + /** + * 按主键查询 + * + * @param id 主键Id + * @return 实体 + */ + @Override + public TaskCollectorVersion findById(String id) { + return iTaskCollectorVersionDao.findById(id); + } + + /** + * 关键字搜素 + * + * @param searchRequest 搜索参数 + * @return 分页列表 + */ + @Override + public PageResult+ * 采集器（终端）系统参数表 TaskSystemParamsServiceImpl 服务实现类 + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +@Service +public class TaskSystemParamsServiceImpl implements ITaskSystemParamsService { + @Resource + private ITaskSystemParamsDao iTaskSystemParamsDao; + + /** + * 按主键查询 + * + * @param id 主键Id + * @return 实体 + */ + @Override + public TaskSystemParams findById(String id) { + return iTaskSystemParamsDao.findById(id); + } + + /** + * 关键字搜素 + * + * @param searchRequest 搜索参数 + * @return 分页列表 + */ + @Override + public PageResult+ * 采集记录表（终端） TaskTerminatorCollectionRecordServiceImpl 服务实现类 + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +@Service +public class TaskTerminatorCollectionRecordServiceImpl implements ITaskTerminatorCollectionRecordService { + @Resource + private ITaskTerminatorCollectionRecordDao iTaskTerminatorCollectionRecordDao; + @Resource + private IdService idService; + + /** + * 按主键查询 + * + * @param id 主键Id + * @return 实体 + */ + @Override + public TaskTerminatorCollectionRecord findById(String id) { + return iTaskTerminatorCollectionRecordDao.findById(id); + } + + /** + * 关键字搜素 + * + * @param searchRequest 搜索参数 + * @return 分页列表 + */ + @Override + public PageResult+ * 执行管理器（采集器终端） TaskTerminatorServiceImpl 服务实现类 + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +@Service +public class TaskTerminatorServiceImpl implements ITaskTerminatorService { + @Resource + private ITaskTerminatorDao iTaskTerminatorDao; + @Resource + private IdService idService; + + /** + * 按主键查询 + * + * @param id 主键Id + * @return 实体 + */ + @Override + public TaskTerminator findById(String id) { + return iTaskTerminatorDao.findById(id); + } + + /** + * 关键字搜素 + * + * @param searchRequest 搜索参数 + * @return 分页列表 + */ + @Override + public PageResult+ * 采集器管理（终端） API + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +@Api(value = "采集器管理（终端）任务管理接口", tags = "采集器管理（终端）任务管理接口") +@FeignClient(value = "collector-scheduling-management", contextId = "collector-scheduling-management.TaskCollectorApi") +@RequestMapping("/taskCollector") +public interface TaskCollectorApi { + + /** + * 按主键查询 + * + * @param id 主键id + * @return 实体 + */ + @ApiOperation("按主键查询") + @GetMapping("/find/{id}") + TaskCollector findById(@PathVariable(value = "id") String id); + + /** + * 关键字搜素 + * + * @param searchRequest 搜索参数 + * @return 分页列表 + */ + @ApiOperation("关键字搜素") + @PostMapping("/search") + PageResult+ * 采集器版本列表管理（终端） API + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +@Api(value = "采集器版本列表管理（终端）任务管理接口", tags = "采集器版本列表管理（终端）任务管理接口") +@FeignClient(value = "collector-scheduling-management", contextId = "collector-scheduling-management.TaskCollectorVersionApi") +@RequestMapping("/taskCollectorVersion") +public interface TaskCollectorVersionApi { + + /** + * 按主键查询 + * + * @param id 主键id + * @return 实体 + */ + @ApiOperation("按主键查询") + @GetMapping("/find/{id}") + TaskCollectorVersion findById(@PathVariable(value = "id") String id); + + /** + * 关键字搜素 + * + * @param searchRequest 搜索参数 + * @return 分页列表 + */ + @ApiOperation("关键字搜素") + @PostMapping("/search") + PageResult+ * 采集器版本列表更新包管理（终端） API + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +@Api(value = "采集器版本列表更新包管理（终端）任务管理接口", tags = "采集器版本列表更新包管理（终端）任务管理接口") +@FeignClient(value = "collector-scheduling-management", contextId = "collector-scheduling-management.TaskCollectorVersionFileApi") +@RequestMapping("/taskCollectorVersionFile") +public interface TaskCollectorVersionFileApi { + + /** + * 按主键查询 + * + * @param id 主键id + * @return 实体 + */ + @ApiOperation("按主键查询") + @GetMapping("/find/{id}") + TaskCollectorVersionFile findById(@PathVariable(value = "id") String id); + + /** + * 关键字搜素 + * + * @param searchRequest 搜索参数 + * @return 分页列表 + */ + @ApiOperation("关键字搜素") + @PostMapping("/search") + PageResult+ * 采集器版本更新日志管理（终端） API + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +@Api(value = "采集器版本更新日志管理（终端）任务管理接口", tags = "采集器版本更新日志管理（终端）任务管理接口") +@FeignClient(value = "collector-scheduling-management", contextId = "collector-scheduling-management.TaskCollectorVersionLogApi") +@RequestMapping("/taskCollectorVersionLog") +public interface TaskCollectorVersionLogApi { + + /** + * 按主键查询 + * + * @param id 主键id + * @return 实体 + */ + @ApiOperation("按主键查询") + @GetMapping("/find/{id}") + TaskCollectorVersionLog findById(@PathVariable(value = "id") String id); + + /** + * 关键字搜素 + * + * @param searchRequest 搜索参数 + * @return 分页列表 + */ + @ApiOperation("关键字搜素") + @PostMapping("/search") + PageResult+ * 采集器（终端）系统参数表 API + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +@Api(value = "采集器（终端）系统参数表任务管理接口", tags = "采集器（终端）系统参数表任务管理接口") +@FeignClient(value = "collector-scheduling-management", contextId = "collector-scheduling-management.TaskSystemParamsApi") +@RequestMapping("/taskSystemParams") +public interface TaskSystemParamsApi { + + /** + * 按主键查询 + * + * @param id 主键id + * @return 实体 + */ + @ApiOperation("按主键查询") + @GetMapping("/find/{id}") + TaskSystemParams findById(@PathVariable(value = "id") String id); + + /** + * 关键字搜素 + * + * @param searchRequest 搜索参数 + * @return 分页列表 + */ + @ApiOperation("关键字搜素") + @PostMapping("/search") + PageResult+ * 执行管理器（采集器终端） API + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +@Api(value = "执行管理器（采集器终端）任务管理接口", tags = "执行管理器（采集器终端）任务管理接口") +@FeignClient(value = "collector-scheduling-management", contextId = "collector-scheduling-management.TaskTerminatorApi") +@RequestMapping("/taskTerminator") +public interface TaskTerminatorApi { + + /** + * 按主键查询 + * + * @param id 主键id + * @return 实体 + */ + @ApiOperation("按主键查询") + @GetMapping("/find/{id}") + TaskTerminator findById(@PathVariable(value = "id") String id); + + /** + * 关键字搜素 + * + * @param searchRequest 搜索参数 + * @return 分页列表 + */ + @ApiOperation("关键字搜素") + @PostMapping("/search") + PageResult+ * 采集记录表（终端） API + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +@Api(value = "采集记录表（终端）任务管理接口", tags = "采集记录表（终端）任务管理接口") +@FeignClient(value = "collector-scheduling-management", contextId = "collector-scheduling-management.TaskTerminatorCollectionRecordApi") +@RequestMapping("/taskTerminatorCollectionRecord") +public interface TaskTerminatorCollectionRecordApi { + + /** + * 按主键查询 + * + * @param id 主键id + * @return 实体 + */ + @ApiOperation("按主键查询") + @GetMapping("/find/{id}") + TaskTerminatorCollectionRecord findById(@PathVariable(value = "id") String id); + + /** + * 关键字搜素 + * + * @param searchRequest 搜索参数 + * @return 分页列表 + */ + @ApiOperation("关键字搜素") + @PostMapping("/search") + PageResult+ * 采集器管理（终端） + *
+* +* @author AutoGenerator +* @since 2023-07-10 +*/ +@Data +@EqualsAndHashCode(callSuper = false) +@TableName("task_collector") +@ApiModel(value="TaskCollector对象", description="采集器管理（终端）") +public class TaskCollector implements Serializable { + + @ApiModelProperty(value = "主键") + @TableId(value = "id", type = IdType.ASSIGN_UUID) + private Long id; + + @ApiModelProperty(value = "采集器版本id") + @TableField("collector_version_id") + private Long collectorVersionId; + + @ApiModelProperty(value = "采集语言") + @TableField("collect_language") + private String collectLanguage; + + @ApiModelProperty(value = "采集器类型") + @TableField("collect_type") + private CollectTypeEnum collectType; + + @ApiModelProperty(value = "启动方式") + @TableField("start_mode") + private String startMode; + + @ApiModelProperty(value = "入库时间") + @TableField("create_time") + private LocalDateTime createTime; + + @ApiModelProperty(value = "入库更新时间") + @TableField("update_time") + private LocalDateTime updateTime; + + +} diff --git a/docus-client-interface/src/main/java/com/docus/server/entity/scheduling.management/TaskCollectorVersion.java b/docus-client-interface/src/main/java/com/docus/server/entity/scheduling.management/TaskCollectorVersion.java new file mode 100644 index 0000000..af6f1ab --- /dev/null +++ b/docus-client-interface/src/main/java/com/docus/server/entity/scheduling.management/TaskCollectorVersion.java @@ -0,0 +1,56 @@ +package com.docus.server.entity.scheduling.management; + +import com.baomidou.mybatisplus.annotation.TableName; +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableId; +import java.time.LocalDateTime; +import com.baomidou.mybatisplus.annotation.TableField; +import java.io.Serializable; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; +import lombok.EqualsAndHashCode; +import lombok.experimental.Accessors; + +import com.docus.server.enums.*; + +/** +*+ * 采集器版本列表管理（终端） + *
+* +* @author AutoGenerator +* @since 2023-07-10 +*/ +@Data +@EqualsAndHashCode(callSuper = false) +@TableName("task_collector_version") +@ApiModel(value="TaskCollectorVersion对象", description="采集器版本列表管理（终端）") +public class TaskCollectorVersion implements Serializable { + + @ApiModelProperty(value = "主键") + @TableId(value = "id", type = IdType.ASSIGN_UUID) + private Long id; + + @ApiModelProperty(value = "采集器管理id") + @TableField("task_collector_id") + private Long taskCollectorId; + + @ApiModelProperty(value = "版本号") + @TableField("collect_version") + private String collectVersion; + + @ApiModelProperty(value = "是否当前版本，0：否，1：是") + @TableField("current_version_flag") + private String currentVersionFlag; + + @ApiModelProperty(value = "入库时间") + @TableField("create_time") + private LocalDateTime createTime; + + @ApiModelProperty(value = "入库更新时间") + @TableField("update_time") + private LocalDateTime updateTime; + + +} diff --git a/docus-client-interface/src/main/java/com/docus/server/entity/scheduling.management/TaskCollectorVersionFile.java b/docus-client-interface/src/main/java/com/docus/server/entity/scheduling.management/TaskCollectorVersionFile.java new file mode 100644 index 0000000..499f576 --- /dev/null +++ b/docus-client-interface/src/main/java/com/docus/server/entity/scheduling.management/TaskCollectorVersionFile.java @@ -0,0 +1,94 @@ +package com.docus.server.entity.scheduling.management; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; +import lombok.EqualsAndHashCode; + +import java.io.Serializable; +import java.time.LocalDateTime; + +/** + *+ * 采集器版本列表更新包管理（终端） + *
+ * + * @author AutoGenerator + * @since 2023-07-10 + */ +@Data +@EqualsAndHashCode(callSuper = false) +@TableName("task_collector_version_file") +@ApiModel(value = "TaskCollectorVersionFile对象", description = "采集器版本列表更新包管理（终端）") +public class TaskCollectorVersionFile implements Serializable { + + @ApiModelProperty(value = "主键") + @TableId(value = "id", type = IdType.ASSIGN_UUID) + private Long id; + + @ApiModelProperty(value = "采集器管理版本id") + @TableField("task_collector_version_id") + private Long taskCollectorVersionId; + + @ApiModelProperty(value = "采集器管理id") + @TableField("task_collector_id") + private Long taskCollectorId; + + @ApiModelProperty(value = "文件标题") + @TableField("file_title") + private String fileTitle; + + @ApiModelProperty(value = "文件目录 单纯文件夹路径，不带文件名") + @TableField("image_path") + private String imagePath; + + @ApiModelProperty(value = "文件名称") + @TableField("scan_page") + private String scanPage; + + @ApiModelProperty(value = "文件大小") + @TableField("file_size") + private Integer fileSize; + + @ApiModelProperty(value = "文件类型") + @TableField("file_type") + private String fileType; + + @ApiModelProperty(value = "文件来源 1:采集器；2：扫描生产软件") + @TableField("file_source") + private String fileSource; + + @ApiModelProperty(value = "1:服务器本地；2：ftp服务器；3：共享文件夹") + @TableField("file_storage_type") + private String fileStorageType; + + @ApiModelProperty(value = "是否作废 1：是；0：否") + @TableField("state") + private Integer state; + + @ApiModelProperty(value = "是否显示1:是;0:否") + @TableField("show_file") + private Integer showFile; + + @ApiModelProperty(value = "文件唯一标识") + @TableField("file_column_1") + private String fileColumn1; + + @ApiModelProperty(value = "原文件名称") + @TableField("original_file_name") + private String originalFileName; + + @ApiModelProperty(value = "入库时间") + @TableField("create_time") + private LocalDateTime createTime; + + @ApiModelProperty(value = "入库更新时间") + @TableField("update_time") + private LocalDateTime updateTime; + + +} diff --git a/docus-client-interface/src/main/java/com/docus/server/entity/scheduling.management/TaskCollectorVersionLog.java b/docus-client-interface/src/main/java/com/docus/server/entity/scheduling.management/TaskCollectorVersionLog.java new file mode 100644 index 0000000..779c891 --- /dev/null +++ b/docus-client-interface/src/main/java/com/docus/server/entity/scheduling.management/TaskCollectorVersionLog.java @@ -0,0 +1,72 @@ +package com.docus.server.entity.scheduling.management; + +import com.baomidou.mybatisplus.annotation.TableName; +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableId; +import java.time.LocalDateTime; +import com.baomidou.mybatisplus.annotation.TableField; +import java.io.Serializable; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; +import lombok.EqualsAndHashCode; +import lombok.experimental.Accessors; + +import com.docus.server.enums.*; + +/** +*+ * 采集器版本更新日志管理（终端） + *
+* +* @author AutoGenerator +* @since 2023-07-10 +*/ +@Data +@EqualsAndHashCode(callSuper = false) +@TableName("task_collector_version_log") +@ApiModel(value="TaskCollectorVersionLog对象", description="采集器版本更新日志管理（终端）") +public class TaskCollectorVersionLog implements Serializable { + + @ApiModelProperty(value = "主键") + @TableId(value = "id", type = IdType.ASSIGN_UUID) + private Long id; + + @ApiModelProperty(value = "采集器管理版本id") + @TableField("task_collector_version_id") + private Long taskCollectorVersionId; + + @ApiModelProperty(value = "采集器管理id") + @TableField("task_collector_id") + private Long taskCollectorId; + + @ApiModelProperty(value = "操作模块") + @TableField("operation_module") + private String operationModule; + + @ApiModelProperty(value = "操作类型") + @TableField("operation_type") + private String operationType; + + @ApiModelProperty(value = "操作描述") + @TableField("operation_desc") + private String operationDesc; + + @ApiModelProperty(value = "操作内容") + @TableField("operation_content") + private String operationContent; + + @ApiModelProperty(value = "执行状态0：成功，1:失败") + @TableField("state") + private Integer state; + + @ApiModelProperty(value = "入库时间") + @TableField("create_time") + private LocalDateTime createTime; + + @ApiModelProperty(value = "入库更新时间") + @TableField("update_time") + private LocalDateTime updateTime; + + +} diff --git a/docus-client-interface/src/main/java/com/docus/server/entity/scheduling.management/TaskSystemParams.java b/docus-client-interface/src/main/java/com/docus/server/entity/scheduling.management/TaskSystemParams.java new file mode 100644 index 0000000..ee428da --- /dev/null +++ b/docus-client-interface/src/main/java/com/docus/server/entity/scheduling.management/TaskSystemParams.java @@ -0,0 +1,68 @@ +package com.docus.server.entity.scheduling.management; + +import com.baomidou.mybatisplus.annotation.TableName; +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableId; +import java.time.LocalDateTime; +import com.baomidou.mybatisplus.annotation.TableField; +import java.io.Serializable; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; +import lombok.EqualsAndHashCode; +import lombok.experimental.Accessors; + +import com.docus.server.enums.*; + +/** +*+ * 采集器（终端）系统参数表 + *
+* +* @author AutoGenerator +* @since 2023-07-10 +*/ +@Data +@EqualsAndHashCode(callSuper = false) +@TableName("task_system_params") +@ApiModel(value="TaskSystemParams对象", description="采集器（终端）系统参数表") +public class TaskSystemParams implements Serializable { + + @ApiModelProperty(value = "系统参数编号") + @TableId(value = "param_code", type = IdType.ASSIGN_UUID) + private String paramCode; + + @ApiModelProperty(value = "系统参数名称") + @TableField("param_name") + private String paramName; + + @ApiModelProperty(value = "系统参数说明，如说明参数值得格式要求") + @TableField("param_info") + private String paramInfo; + + @ApiModelProperty(value = "系统参数值") + @TableField("param_value") + private String paramValue; + + @ApiModelProperty(value = "系统参数分组") + @TableField("param_group") + private String paramGroup; + + @ApiModelProperty(value = "排序号，用于分组内排序") + @TableField("sort_no") + private Integer sortNo; + + @ApiModelProperty(value = "是否需要加密，0：不需要，1：需要") + @TableField("need_encrypt") + private String needEncrypt; + + @ApiModelProperty(value = "入库时间") + @TableField("create_time") + private LocalDateTime createTime; + + @ApiModelProperty(value = "入库更新时间") + @TableField("update_time") + private LocalDateTime updateTime; + + +} diff --git a/docus-client-interface/src/main/java/com/docus/server/entity/scheduling.management/TaskTerminator.java b/docus-client-interface/src/main/java/com/docus/server/entity/scheduling.management/TaskTerminator.java new file mode 100644 index 0000000..27db689 --- /dev/null +++ b/docus-client-interface/src/main/java/com/docus/server/entity/scheduling.management/TaskTerminator.java @@ -0,0 +1,80 @@ +package com.docus.server.entity.scheduling.management; + +import com.baomidou.mybatisplus.annotation.TableName; +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableId; +import java.time.LocalDateTime; +import com.baomidou.mybatisplus.annotation.TableField; +import java.io.Serializable; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; +import lombok.EqualsAndHashCode; +import lombok.experimental.Accessors; + +import com.docus.server.enums.*; + +/** +*+ * 执行管理器（采集器终端） + *
+* +* @author AutoGenerator +* @since 2023-07-10 +*/ +@Data +@EqualsAndHashCode(callSuper = false) +@TableName("task_terminator") +@ApiModel(value="TaskTerminator对象", description="执行管理器（采集器终端）") +public class TaskTerminator implements Serializable { + + @ApiModelProperty(value = "主键") + @TableId(value = "id", type = IdType.ASSIGN_UUID) + private Long id; + + @ApiModelProperty(value = "资源管理器名称") + @TableField("terminator_name") + private String terminatorName; + + @ApiModelProperty(value = "终端重试键") + @TableField("retry_key") + private String retryKey; + + @ApiModelProperty(value = "IP") + @TableField("terminator_ip") + private String terminatorIp; + + @ApiModelProperty(value = "忙闲状态，0：空闲，1：繁忙") + @TableField("busy_state") + private String busyState; + + @ApiModelProperty(value = "在线状态，0：离线，1：在线") + @TableField("online_state") + private String onlineState; + + @ApiModelProperty(value = "最近任务执行时间") + @TableField("last_task_exec_time") + private LocalDateTime lastTaskExecTime; + + @ApiModelProperty(value = "正在执行任务的名称") + @TableField("executing_task_name") + private String executingTaskName; + + @ApiModelProperty(value = "最近一次任务执行失败原因") + @TableField("last_task_error_msg") + private String lastTaskErrorMsg; + + @ApiModelProperty(value = "任务扩展参数") + @TableField("task_params") + private String taskParams; + + @ApiModelProperty(value = "入库时间") + @TableField("create_time") + private LocalDateTime createTime; + + @ApiModelProperty(value = "入库更新时间") + @TableField("update_time") + private LocalDateTime updateTime; + + +} diff --git a/docus-client-interface/src/main/java/com/docus/server/entity/scheduling.management/TaskTerminatorCollectionRecord.java b/docus-client-interface/src/main/java/com/docus/server/entity/scheduling.management/TaskTerminatorCollectionRecord.java new file mode 100644 index 0000000..7c2b961 --- /dev/null +++ b/docus-client-interface/src/main/java/com/docus/server/entity/scheduling.management/TaskTerminatorCollectionRecord.java @@ -0,0 +1,88 @@ +package com.docus.server.entity.scheduling.management; + +import com.baomidou.mybatisplus.annotation.TableName; +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableId; +import java.time.LocalDateTime; +import com.baomidou.mybatisplus.annotation.TableField; +import java.io.Serializable; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; +import lombok.EqualsAndHashCode; +import lombok.experimental.Accessors; + +import com.docus.server.enums.*; + +/** +*+ * 采集记录表（终端） + *
+* +* @author AutoGenerator +* @since 2023-07-10 +*/ +@Data +@EqualsAndHashCode(callSuper = false) +@TableName("task_terminator_collection_record") +@ApiModel(value="TaskTerminatorCollectionRecord对象", description="采集记录表（终端）") +public class TaskTerminatorCollectionRecord implements Serializable { + + @ApiModelProperty(value = "主键") + @TableId(value = "id", type = IdType.ASSIGN_UUID) + private Long id; + + @ApiModelProperty(value = "终端主键") + @TableField("terminator_id") + private Long terminatorId; + + @ApiModelProperty(value = "资源管理器名称 资源管理器名称") + @TableField("terminator_name") + private String terminatorName; + + @ApiModelProperty(value = "任务重试键") + @TableField("retry_key") + private String retryKey; + + @ApiModelProperty(value = "采集器类型") + @TableField("collect_type") + private CollectTypeEnum collectType; + + @ApiModelProperty(value = "任务描述") + @TableField("task_memo") + private String taskMemo; + + @ApiModelProperty(value = "数据起始时间范围") + @TableField("start_time") + private LocalDateTime startTime; + + @ApiModelProperty(value = "数据结束时间范围") + @TableField("end_time") + private LocalDateTime endTime; + + @ApiModelProperty(value = "任务详细信息") + @TableField("task_detail_info") + private String taskDetailInfo; + + @ApiModelProperty(value = "任务执行状态，0：成功，1：失败") + @TableField("task_exec_state") + private String taskExecState; + + @ApiModelProperty(value = "任务其他扩展配置") + @TableField("task_params") + private String taskParams; + + @ApiModelProperty(value = "最近一次任务执行失败原因") + @TableField("last_task_error_msg") + private String lastTaskErrorMsg; + + @ApiModelProperty(value = "入库时间") + @TableField("create_time") + private LocalDateTime createTime; + + @ApiModelProperty(value = "入库更新时间") + @TableField("update_time") + private LocalDateTime updateTime; + + +} diff --git a/pom.xml b/pom.xml index 273ee40..12e66ee 100644 --- a/pom.xml +++ b/pom.xml @@ -13,6 +13,7 @@