From 4110a57be373f5f3d75e53af7ebd0a1d8303fb15 Mon Sep 17 00:00:00 2001
From: Hoshi <1196756653@qq.com>
Date: Tue, 20 Aug 2024 17:57:31 +0800
Subject: [PATCH] Initial commit all
---
README.md | 1 +
bocloud.tse.booter/pom.xml | 150 +++
.../com/bocloud/tse/booter/Application.java | 19 +
.../booter/config/RabbitMQConfiguration.java | 129 +++
.../booter/config/SwaggerConfiguration.java | 21 +
.../config/WebInterceptorConfiguration.java | 60 ++
.../booter/controller/EngineController.java | 74 ++
.../controller/SchedulerController.java | 93 ++
.../syslog/SysLogAppenderTcpAndUdp.java | 15 +
.../booter/syslog/SysLogLevelConvertor.java | 22 +
.../syslog/SyslogOutputStreamTcpAndUdp.java | 70 ++
.../src/main/resources/application.yml | 104 ++
.../src/main/resources/banner.txt | 8 +
.../src/main/resources/logback-spring.xml | 75 ++
bocloud.tse.core/pom.xml | 43 +
.../com/bocloud/tse/core/annotation/Arg.java | 17 +
.../bocloud/tse/core/annotation/Module.java | 20 +
.../bocloud/tse/core/annotation/Worker.java | 17 +
.../com/bocloud/tse/core/domain/Option.java | 35 +
.../bocloud/tse/core/domain/TargetGroup.java | 28 +
.../bocloud/tse/core/domain/WorkerScript.java | 52 +
.../core/domain/args/maintain/FileArg.java | 24 +
.../domain/args/maintain/HostAllowArg.java | 24 +
.../domain/args/maintain/ScriptLocalArg.java | 16 +
.../core/domain/args/maintain/ScriptsArg.java | 19 +
.../core/domain/args/maintain/ServiceArg.java | 31 +
.../core/domain/args/maintain/UserArg.java | 27 +
.../domain/args/software/ActivemqArg.java | 27 +
.../core/domain/args/software/ApacheArg.java | 44 +
.../args/software/ElasticsearchArg.java | 25 +
.../core/domain/args/software/EtcdArg.java | 33 +
.../domain/args/software/ExporterArg.java | 18 +
.../core/domain/args/software/GitlabArg.java | 25 +
.../tse/core/domain/args/software/JdkArg.java | 24 +
.../core/domain/args/software/JenkinsArg.java | 28 +
.../tse/core/domain/args/software/K8sArg.java | 51 +
.../core/domain/args/software/KafkaArg.java | 88 ++
.../domain/args/software/MemcacheArg.java | 64 ++
.../core/domain/args/software/MongodbArg.java | 62 ++
.../core/domain/args/software/MysqlArg.java | 92 ++
.../tse/core/domain/args/software/NfsArg.java | 24 +
.../core/domain/args/software/NginxArg.java | 61 ++
.../core/domain/args/software/OracleArg.java | 56 +
.../tse/core/domain/args/software/PhpArg.java | 39 +
.../domain/args/software/PostgresqlArg.java | 160 +++
.../domain/args/software/RabbitmqArg.java | 55 +
.../domain/args/software/RacIscsiArg.java | 21 +
.../core/domain/args/software/RedisArg.java | 58 +
.../domain/args/software/RocketmqArg.java | 53 +
.../domain/args/software/SqlserverArg.java | 33 +
.../core/domain/args/software/TomcatArg.java | 34 +
.../domain/args/software/WebSphereArg.java | 27 +
.../domain/args/software/WeblogicArg.java | 35 +
.../domain/args/software/WebspheremqArg.java | 25 +
.../domain/args/software/ZookeeperArg.java | 35 +
.../tse/core/domain/common/NginxConfig.java | 75 ++
.../core/domain/common/NginxHttpParam.java | 39 +
.../tse/core/domain/common/NginxSite.java | 33 +
.../core/domain/common/TomcatInstance.java | 106 ++
.../core/domain/front/maintain/DBFront.java | 52 +
.../core/domain/front/maintain/FileFront.java | 20 +
.../core/domain/front/maintain/GaiaFront.java | 26 +
.../domain/front/maintain/HostAllowFront.java | 22 +
.../core/domain/front/maintain/HttpFront.java | 32 +
.../core/domain/front/maintain/SaltFront.java | 24 +
.../domain/front/maintain/ScriptFront.java | 40 +
.../front/maintain/ScriptLocalFront.java | 40 +
.../domain/front/maintain/ScriptsFront.java | 20 +
.../domain/front/maintain/ServiceFront.java | 19 +
.../domain/front/maintain/TemplateFront.java | 26 +
.../core/domain/front/maintain/UserFront.java | 17 +
.../domain/front/software/ActivemqFront.java | 27 +
.../domain/front/software/ApacheFront.java | 25 +
.../front/software/ElasticsearchFront.java | 23 +
.../core/domain/front/software/EtcdFront.java | 36 +
.../domain/front/software/ExporterFront.java | 13 +
.../domain/front/software/GitlabFront.java | 19 +
.../core/domain/front/software/JdkFront.java | 24 +
.../domain/front/software/JenkinsFront.java | 21 +
.../core/domain/front/software/K8sFront.java | 40 +
.../domain/front/software/KafkaFront.java | 90 ++
.../domain/front/software/KafkaZkFront.java | 27 +
.../domain/front/software/MemcacheFront.java | 44 +
.../domain/front/software/MongodbFront.java | 65 ++
.../domain/front/software/MysqlFront.java | 74 ++
.../core/domain/front/software/NfsFront.java | 29 +
.../domain/front/software/NginxFront.java | 40 +
.../domain/front/software/OracleFront.java | 31 +
.../core/domain/front/software/PhpFront.java | 17 +
.../front/software/PostgresqlFront.java | 117 ++
.../domain/front/software/RabbitmqFront.java | 72 ++
.../domain/front/software/RacIscsiFront.java | 24 +
.../domain/front/software/RedisFront.java | 63 ++
.../domain/front/software/RocketmqFront.java | 45 +
.../domain/front/software/SqlserverFront.java | 33 +
.../domain/front/software/TomcatFront.java | 28 +
.../domain/front/software/WeblogicFront.java | 33 +
.../domain/front/software/WebsphereFront.java | 23 +
.../front/software/WebspheremqFront.java | 19 +
.../domain/front/software/ZookeeperFront.java | 31 +
.../core/domain/group/ElasticsearchGroup.java | 123 +++
.../bocloud/tse/core/domain/group/Group.java | 23 +
.../tse/core/domain/group/GroupHost.java | 21 +
.../tse/core/domain/group/IscsiGroup.java | 45 +
.../tse/core/domain/group/K8sGroup.java | 30 +
.../tse/core/domain/group/KafkaGroup.java | 87 ++
.../tse/core/domain/group/MemcacheGroup.java | 36 +
.../tse/core/domain/group/MongoGroup.java | 111 ++
.../tse/core/domain/group/MysqlGroup.java | 134 +++
.../tse/core/domain/group/NfsGroup.java | 55 +
.../core/domain/group/PostgresqlGroup.java | 77 ++
.../tse/core/domain/group/RabbitmqGroup.java | 49 +
.../tse/core/domain/group/RedisGroup.java | 100 ++
.../tse/core/domain/group/RocketmqGroup.java | 77 ++
.../tse/core/domain/group/ZookeeperGroup.java | 59 ++
.../bocloud/tse/core/domain/input/Depend.java | 17 +
.../bocloud/tse/core/domain/input/Input.java | 31 +
.../bocloud/tse/core/domain/input/Target.java | 33 +
.../domain/input/maintain/BackupInput.java | 18 +
.../core/domain/input/maintain/DBInput.java | 17 +
.../core/domain/input/maintain/GaiaInput.java | 21 +
.../domain/input/maintain/HostAllowInput.java | 19 +
.../core/domain/input/maintain/HttpInput.java | 18 +
.../domain/input/maintain/RecoveryInput.java | 18 +
.../domain/input/maintain/ScriptInput.java | 19 +
.../input/maintain/ScriptLocalInput.java | 19 +
.../domain/input/maintain/ScriptsInput.java | 18 +
.../domain/input/maintain/ServiceInput.java | 16 +
.../domain/input/maintain/TemplateInput.java | 20 +
.../domain/input/maintain/UploadInput.java | 17 +
.../core/domain/input/maintain/UserInput.java | 17 +
.../domain/input/software/ActivemqInput.java | 18 +
.../domain/input/software/ApacheInput.java | 18 +
.../input/software/ElasticsearchInput.java | 18 +
.../core/domain/input/software/EtcdInput.java | 18 +
.../domain/input/software/ExporterInput.java | 18 +
.../domain/input/software/GitlabInput.java | 18 +
.../domain/input/software/IscsiInput.java | 18 +
.../domain/input/software/IscsicInput.java | 18 +
.../domain/input/software/IscsisInput.java | 18 +
.../core/domain/input/software/JdkInput.java | 18 +
.../domain/input/software/JenkinsInput.java | 18 +
.../core/domain/input/software/K8sInput.java | 18 +
.../domain/input/software/KafkaInput.java | 18 +
.../domain/input/software/MemcacheInput.java | 18 +
.../domain/input/software/MongodbInput.java | 18 +
.../domain/input/software/MysqlInput.java | 18 +
.../core/domain/input/software/NfscInput.java | 18 +
.../core/domain/input/software/NfssInput.java | 18 +
.../domain/input/software/NginxInput.java | 18 +
.../domain/input/software/OracleInput.java | 18 +
.../core/domain/input/software/PhpInput.java | 18 +
.../input/software/PostgresqlInput.java | 18 +
.../domain/input/software/RabbitmqInput.java | 18 +
.../domain/input/software/RedisInput.java | 18 +
.../domain/input/software/RocketmqInput.java | 18 +
.../domain/input/software/SqlserverInput.java | 18 +
.../domain/input/software/TomcatInput.java | 18 +
.../domain/input/software/WeblogicInput.java | 18 +
.../domain/input/software/WebsphereInput.java | 18 +
.../input/software/WebspheremqInput.java | 18 +
.../domain/input/software/ZookeeperInput.java | 18 +
.../core/exception/NodeFormatException.java | 30 +
.../core/exception/TaskFormatException.java | 30 +
.../com/bocloud/tse/core/module/Module.java | 29 +
.../core/module/maintain/BackupModule.java | 22 +
.../tse/core/module/maintain/GaiaModule.java | 24 +
.../core/module/maintain/HostAllowModule.java | 22 +
.../core/module/maintain/RecoveryModule.java | 22 +
.../module/maintain/ScriptLocalModule.java | 22 +
.../core/module/maintain/ScriptsModule.java | 22 +
.../core/module/maintain/ServiceModule.java | 19 +
.../core/module/maintain/TemplateModule.java | 22 +
.../core/module/maintain/UploadModule.java | 19 +
.../tse/core/module/maintain/UserModule.java | 22 +
.../core/module/software/ActivemqModule.java | 19 +
.../core/module/software/ApacheModule.java | 19 +
.../module/software/ElasticsearchModule.java | 19 +
.../tse/core/module/software/EtcdModule.java | 19 +
.../core/module/software/ExporterModule.java | 19 +
.../core/module/software/GitlabModule.java | 19 +
.../tse/core/module/software/IscsiModule.java | 19 +
.../tse/core/module/software/JdkModule.java | 18 +
.../core/module/software/JenkinsModule.java | 19 +
.../tse/core/module/software/K8sModule.java | 19 +
.../tse/core/module/software/KafkaModule.java | 19 +
.../core/module/software/MemcacheModule.java | 19 +
.../tse/core/module/software/MongoModule.java | 19 +
.../tse/core/module/software/MysqlModule.java | 19 +
.../tse/core/module/software/NfsModule.java | 19 +
.../tse/core/module/software/NginxModule.java | 19 +
.../core/module/software/OracleModule.java | 19 +
.../tse/core/module/software/PhpModule.java | 19 +
.../module/software/PostgresqlModule.java | 19 +
.../core/module/software/RabbitModule.java | 19 +
.../tse/core/module/software/RedisModule.java | 19 +
.../core/module/software/RocketmqModule.java | 19 +
.../core/module/software/SqlserverModule.java | 19 +
.../core/module/software/TomcatModule.java | 19 +
.../core/module/software/WebSphereModule.java | 19 +
.../core/module/software/WeblogicModule.java | 19 +
.../module/software/WebspheremqModule.java | 19 +
.../core/module/software/ZookeeperModule.java | 19 +
.../com/bocloud/tse/core/utils/CronUtils.java | 100 ++
.../com/bocloud/tse/core/utils/DBDriver.java | 43 +
.../com/bocloud/tse/core/utils/DBTool.java | 64 ++
bocloud.tse.entity/pom.xml | 18 +
.../bocloud/tse/constant/CacheConstant.java | 12 +
.../bocloud/tse/constant/CommonConstant.java | 9 +
.../tse/constant/ExecuteTypeConstant.java | 8 +
.../java/com/bocloud/tse/entity/Command.java | 62 ++
.../bocloud/tse/entity/CommandInstance.java | 37 +
.../bocloud/tse/entity/Identification.java | 120 +++
.../com/bocloud/tse/entity/NodeModule.java | 67 ++
.../com/bocloud/tse/entity/NodeRelation.java | 46 +
.../java/com/bocloud/tse/entity/Task.java | 83 ++
.../bocloud/tse/entity/TaskFailRecord.java | 87 ++
.../java/com/bocloud/tse/entity/TaskHost.java | 324 ++++++
.../com/bocloud/tse/entity/TaskInstance.java | 148 +++
.../bocloud/tse/entity/TaskInstanceHost.java | 48 +
.../bocloud/tse/entity/TaskInstanceJob.java | 39 +
.../java/com/bocloud/tse/entity/TaskNode.java | 110 ++
.../com/bocloud/tse/entity/TaskWorker.java | 70 ++
.../com/bocloud/tse/enums/AuthenMode.java | 40 +
.../java/com/bocloud/tse/enums/Catalog.java | 92 ++
.../java/com/bocloud/tse/enums/Category.java | 142 +++
.../java/com/bocloud/tse/enums/Charset.java | 23 +
.../java/com/bocloud/tse/enums/Status.java | 107 ++
.../com/bocloud/tse/enums/TaskAction.java | 9 +
.../java/com/bocloud/tse/enums/TaskParam.java | 46 +
.../java/com/bocloud/tse/enums/Topic.java | 49 +
.../com/bocloud/tse/model/EngineModule.java | 12 +
.../com/bocloud/tse/model/HostResult.java | 58 +
.../main/java/com/bocloud/tse/model/Job.java | 52 +
.../java/com/bocloud/tse/model/JobResult.java | 31 +
.../com/bocloud/tse/model/NodeConfig.java | 40 +
.../com/bocloud/tse/model/NodeControl.java | 31 +
.../com/bocloud/tse/model/NodePosition.java | 16 +
.../java/com/bocloud/tse/model/NodeSize.java | 17 +
.../com/bocloud/tse/model/SaltCacheModel.java | 50 +
.../java/com/bocloud/tse/model/SaltModel.java | 27 +
.../tse/model/StateApplyResultModel.java | 24 +
.../bocloud/tse/model/TaskActionMessage.java | 29 +
.../java/com/bocloud/tse/model/TaskEdge.java | 55 +
.../java/com/bocloud/tse/model/TaskGraph.java | 32 +
.../com/bocloud/tse/model/TaskMessage.java | 33 +
.../com/bocloud/tse/model/TaskResult.java | 52 +
.../com/bocloud/tse/model/WorkerHost.java | 115 ++
.../bocloud/tse/model/WorkerHostResult.java | 116 ++
.../com/bocloud/tse/model/WorkerLoadInfo.java | 30 +
.../bocloud/tse/model/WorkerMetricInfo.java | 32 +
.../bocloud/tse/model/WorkerWeightInfo.java | 25 +
bocloud.tse.scheduler/pom.xml | 58 +
.../tse/scheduler/core/AbstractScheduler.java | 62 ++
.../bocloud/tse/scheduler/core/DataCache.java | 123 +++
.../tse/scheduler/core/JobChannel.java | 32 +
.../tse/scheduler/core/JobScheduler.java | 143 +++
.../tse/scheduler/core/SchedulerDaemon.java | 135 +++
.../bocloud/tse/scheduler/core/TaskCache.java | 127 +++
.../tse/scheduler/executor/NodeExecutor.java | 303 ++++++
.../tse/scheduler/executor/TaskExecutor.java | 956 +++++++++++++++++
.../failover/TaskFailoverExecutor.java | 139 +++
.../failover/TaskFailoverScheduler.java | 153 +++
.../tse/scheduler/jobclient/JobClient.java | 110 ++
.../jobclient/JobSchedulerHandler.java | 148 +++
.../listener/JobCompletedListener.java | 42 +
.../listener/TaskActionListener.java | 80 ++
.../tse/scheduler/listener/TaskListener.java | 50 +
.../tse/scheduler/selector/NodeSelector.java | 27 +
.../scheduler/selector/TaskNodeSelector.java | 67 ++
.../tse/scheduler/utils/BeanUtils.java | 126 +++
.../bocloud/tse/scheduler/utils/IpUtil.java | 465 ++++++++
.../scheduler/utils/JobFormatDetector.java | 42 +
.../tse/scheduler/utils/JsonParseUtils.java | 33 +
.../tse/scheduler/utils/JudgeCondition.java | 21 +
.../utils/NodeDependencyHandler.java | 288 +++++
.../utils/TaskProgressPublisher.java | 38 +
.../tse/scheduler/worker/AbstractWorker.java | 82 ++
.../tse/scheduler/worker/ParamBuilder.java | 39 +
.../scheduler/worker/WorkerDispatcher.java | 358 +++++++
.../tse/scheduler/worker/WorkerFactory.java | 60 ++
.../scheduler/worker/WorkerLoadPolicy.java | 219 ++++
.../worker/executor/RemoteSaltStack.java | 996 ++++++++++++++++++
.../worker/executor/RemoteWorker.java | 248 +++++
.../executor/WorkerRemoteMQService.java | 45 +
.../worker/executor/WorkerRemoteService.java | 76 ++
.../worker/listener/AbstractTaskListener.java | 51 +
.../scheduler/worker/listener/JobTask.java | 42 +
.../worker/listener/MaintainTaskListener.java | 68 ++
.../listener/ScheduledTaskListener.java | 38 +
.../worker/listener/SoftwareTaskListener.java | 64 ++
.../worker/listener/TaskJobListener.java | 44 +
.../worker/listener/TaskResultListener.java | 33 +
.../worker/locator/ClazzLocator.java | 121 +++
.../worker/locator/InputClassLocator.java | 51 +
.../worker/locator/WorkerClassLocator.java | 51 +
.../worker/maintain/BackupWorker.java | 91 ++
.../worker/maintain/DatabaseWorker.java | 366 +++++++
.../scheduler/worker/maintain/GaiaWorker.java | 73 ++
.../worker/maintain/HostAllowWorker.java | 86 ++
.../worker/maintain/MaintainWorker.java | 274 +++++
.../worker/maintain/MethodWorker.java | 117 ++
.../worker/maintain/RecoveryWorker.java | 92 ++
.../worker/maintain/ScriptLocalWorker.java | 103 ++
.../worker/maintain/ScriptWorker.java | 227 ++++
.../worker/maintain/ScriptsWorker.java | 205 ++++
.../worker/maintain/ServiceWorker.java | 95 ++
.../worker/maintain/TemplateWorker.java | 98 ++
.../worker/maintain/UploadWorker.java | 97 ++
.../scheduler/worker/maintain/UserWorker.java | 134 +++
.../worker/software/ActivemqWorker.java | 105 ++
.../worker/software/ApacheWorker.java | 87 ++
.../worker/software/ElasticsearchWorker.java | 83 ++
.../scheduler/worker/software/EtcdWorker.java | 80 ++
.../worker/software/ExporterWorker.java | 79 ++
.../worker/software/GitlabWorker.java | 87 ++
.../worker/software/IscsiWorker.java | 93 ++
.../worker/software/IscsicWorker.java | 84 ++
.../worker/software/IscsisWorker.java | 85 ++
.../scheduler/worker/software/JdkWorker.java | 84 ++
.../worker/software/JenkinsWorker.java | 87 ++
.../scheduler/worker/software/K8sWorker.java | 89 ++
.../worker/software/KafkaWorker.java | 119 +++
.../worker/software/MemcacheWorker.java | 84 ++
.../worker/software/MongodbWorker.java | 101 ++
.../worker/software/MysqlWorker.java | 120 +++
.../scheduler/worker/software/NfscWorker.java | 83 ++
.../scheduler/worker/software/NfssWorker.java | 80 ++
.../worker/software/NginxWorker.java | 87 ++
.../worker/software/OracleWorker.java | 85 ++
.../scheduler/worker/software/PhpWorker.java | 80 ++
.../worker/software/PostgresqlWorker.java | 128 +++
.../worker/software/RabbitmqWorker.java | 115 ++
.../worker/software/RedisWorker.java | 97 ++
.../worker/software/RocketmqWorker.java | 84 ++
.../worker/software/SoftwareWorker.java | 249 +++++
.../worker/software/SqlserverWorker.java | 83 ++
.../worker/software/TomcatWorker.java | 86 ++
.../worker/software/WeblogicWorker.java | 80 ++
.../worker/software/WebsphereWorker.java | 78 ++
.../worker/software/WebspheremqWorker.java | 80 ++
.../worker/software/ZookeeperWorker.java | 83 ++
.../worker/utils/ResultMessageHandler.java | 58 +
.../worker/utils/SaltClientCache.java | 68 ++
.../worker/utils/SaltClientModel.java | 33 +
bocloud.tse.service/pom.xml | 31 +
.../com/bocloud/tse/intf/CommandService.java | 12 +
.../com/bocloud/tse/intf/EngineService.java | 21 +
.../bocloud/tse/intf/NodeModuleService.java | 17 +
.../bocloud/tse/intf/TaskInstanceService.java | 54 +
.../com/bocloud/tse/intf/TaskNodeService.java | 64 ++
.../com/bocloud/tse/intf/TaskService.java | 34 +
.../repository/CommandInstanceRepository.java | 30 +
.../tse/repository/CommandRepository.java | 27 +
.../repository/IdentificationRepository.java | 32 +
.../tse/repository/NodeModuleRepository.java | 43 +
.../repository/NodeRelationRepository.java | 80 ++
.../repository/TaskFailRecordRepository.java | 60 ++
.../tse/repository/TaskHostRepository.java | 31 +
.../TaskInstanceHostRepository.java | 36 +
.../repository/TaskInstanceJobRepository.java | 57 +
.../repository/TaskInstanceRepository.java | 98 ++
.../tse/repository/TaskNodeRepository.java | 87 ++
.../tse/repository/TaskRepository.java | 61 ++
.../tse/service/CommandServiceImpl.java | 88 ++
.../tse/service/EngineServiceImpl.java | 179 ++++
.../tse/service/NodeModuleServiceImpl.java | 31 +
.../tse/service/TaskInstanceServiceImpl.java | 288 +++++
.../tse/service/TaskNodeServiceImpl.java | 163 +++
.../bocloud/tse/service/TaskServiceImpl.java | 338 ++++++
.../service/internal/TseInternalService.java | 72 ++
.../com/bocloud/tse/utils/NodeHelper.java | 186 ++++
pom.xml | 126 +++
373 files changed, 23896 insertions(+)
create mode 100644 README.md
create mode 100644 bocloud.tse.booter/pom.xml
create mode 100644 bocloud.tse.booter/src/main/java/com/bocloud/tse/booter/Application.java
create mode 100644 bocloud.tse.booter/src/main/java/com/bocloud/tse/booter/config/RabbitMQConfiguration.java
create mode 100644 bocloud.tse.booter/src/main/java/com/bocloud/tse/booter/config/SwaggerConfiguration.java
create mode 100644 bocloud.tse.booter/src/main/java/com/bocloud/tse/booter/config/WebInterceptorConfiguration.java
create mode 100644 bocloud.tse.booter/src/main/java/com/bocloud/tse/booter/controller/EngineController.java
create mode 100644 bocloud.tse.booter/src/main/java/com/bocloud/tse/booter/controller/SchedulerController.java
create mode 100644 bocloud.tse.booter/src/main/java/com/bocloud/tse/booter/syslog/SysLogAppenderTcpAndUdp.java
create mode 100644 bocloud.tse.booter/src/main/java/com/bocloud/tse/booter/syslog/SysLogLevelConvertor.java
create mode 100644 bocloud.tse.booter/src/main/java/com/bocloud/tse/booter/syslog/SyslogOutputStreamTcpAndUdp.java
create mode 100644 bocloud.tse.booter/src/main/resources/application.yml
create mode 100644 bocloud.tse.booter/src/main/resources/banner.txt
create mode 100644 bocloud.tse.booter/src/main/resources/logback-spring.xml
create mode 100644 bocloud.tse.core/pom.xml
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/annotation/Arg.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/annotation/Module.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/annotation/Worker.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/Option.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/TargetGroup.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/WorkerScript.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/args/maintain/FileArg.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/args/maintain/HostAllowArg.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/args/maintain/ScriptLocalArg.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/args/maintain/ScriptsArg.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/args/maintain/ServiceArg.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/args/maintain/UserArg.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/args/software/ActivemqArg.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/args/software/ApacheArg.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/args/software/ElasticsearchArg.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/args/software/EtcdArg.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/args/software/ExporterArg.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/args/software/GitlabArg.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/args/software/JdkArg.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/args/software/JenkinsArg.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/args/software/K8sArg.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/args/software/KafkaArg.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/args/software/MemcacheArg.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/args/software/MongodbArg.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/args/software/MysqlArg.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/args/software/NfsArg.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/args/software/NginxArg.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/args/software/OracleArg.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/args/software/PhpArg.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/args/software/PostgresqlArg.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/args/software/RabbitmqArg.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/args/software/RacIscsiArg.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/args/software/RedisArg.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/args/software/RocketmqArg.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/args/software/SqlserverArg.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/args/software/TomcatArg.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/args/software/WebSphereArg.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/args/software/WeblogicArg.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/args/software/WebspheremqArg.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/args/software/ZookeeperArg.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/common/NginxConfig.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/common/NginxHttpParam.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/common/NginxSite.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/common/TomcatInstance.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/maintain/DBFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/maintain/FileFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/maintain/GaiaFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/maintain/HostAllowFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/maintain/HttpFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/maintain/SaltFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/maintain/ScriptFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/maintain/ScriptLocalFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/maintain/ScriptsFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/maintain/ServiceFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/maintain/TemplateFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/maintain/UserFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/software/ActivemqFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/software/ApacheFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/software/ElasticsearchFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/software/EtcdFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/software/ExporterFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/software/GitlabFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/software/JdkFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/software/JenkinsFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/software/K8sFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/software/KafkaFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/software/KafkaZkFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/software/MemcacheFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/software/MongodbFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/software/MysqlFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/software/NfsFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/software/NginxFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/software/OracleFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/software/PhpFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/software/PostgresqlFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/software/RabbitmqFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/software/RacIscsiFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/software/RedisFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/software/RocketmqFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/software/SqlserverFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/software/TomcatFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/software/WeblogicFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/software/WebsphereFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/software/WebspheremqFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/front/software/ZookeeperFront.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/group/ElasticsearchGroup.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/group/Group.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/group/GroupHost.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/group/IscsiGroup.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/group/K8sGroup.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/group/KafkaGroup.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/group/MemcacheGroup.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/group/MongoGroup.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/group/MysqlGroup.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/group/NfsGroup.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/group/PostgresqlGroup.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/group/RabbitmqGroup.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/group/RedisGroup.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/group/RocketmqGroup.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/group/ZookeeperGroup.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/Depend.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/Input.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/Target.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/maintain/BackupInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/maintain/DBInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/maintain/GaiaInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/maintain/HostAllowInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/maintain/HttpInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/maintain/RecoveryInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/maintain/ScriptInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/maintain/ScriptLocalInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/maintain/ScriptsInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/maintain/ServiceInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/maintain/TemplateInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/maintain/UploadInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/maintain/UserInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/software/ActivemqInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/software/ApacheInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/software/ElasticsearchInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/software/EtcdInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/software/ExporterInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/software/GitlabInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/software/IscsiInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/software/IscsicInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/software/IscsisInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/software/JdkInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/software/JenkinsInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/software/K8sInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/software/KafkaInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/software/MemcacheInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/software/MongodbInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/software/MysqlInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/software/NfscInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/software/NfssInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/software/NginxInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/software/OracleInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/software/PhpInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/software/PostgresqlInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/software/RabbitmqInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/software/RedisInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/software/RocketmqInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/software/SqlserverInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/software/TomcatInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/software/WeblogicInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/software/WebsphereInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/software/WebspheremqInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/domain/input/software/ZookeeperInput.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/exception/NodeFormatException.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/exception/TaskFormatException.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/module/Module.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/module/maintain/BackupModule.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/module/maintain/GaiaModule.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/module/maintain/HostAllowModule.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/module/maintain/RecoveryModule.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/module/maintain/ScriptLocalModule.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/module/maintain/ScriptsModule.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/module/maintain/ServiceModule.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/module/maintain/TemplateModule.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/module/maintain/UploadModule.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/module/maintain/UserModule.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/module/software/ActivemqModule.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/module/software/ApacheModule.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/module/software/ElasticsearchModule.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/module/software/EtcdModule.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/module/software/ExporterModule.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/module/software/GitlabModule.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/module/software/IscsiModule.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/module/software/JdkModule.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/module/software/JenkinsModule.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/module/software/K8sModule.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/module/software/KafkaModule.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/module/software/MemcacheModule.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/module/software/MongoModule.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/module/software/MysqlModule.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/module/software/NfsModule.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/module/software/NginxModule.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/module/software/OracleModule.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/module/software/PhpModule.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/module/software/PostgresqlModule.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/module/software/RabbitModule.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/module/software/RedisModule.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/module/software/RocketmqModule.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/module/software/SqlserverModule.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/module/software/TomcatModule.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/module/software/WebSphereModule.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/module/software/WeblogicModule.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/module/software/WebspheremqModule.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/module/software/ZookeeperModule.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/utils/CronUtils.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/utils/DBDriver.java
create mode 100644 bocloud.tse.core/src/main/java/com/bocloud/tse/core/utils/DBTool.java
create mode 100644 bocloud.tse.entity/pom.xml
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/constant/CacheConstant.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/constant/CommonConstant.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/constant/ExecuteTypeConstant.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/entity/Command.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/entity/CommandInstance.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/entity/Identification.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/entity/NodeModule.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/entity/NodeRelation.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/entity/Task.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/entity/TaskFailRecord.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/entity/TaskHost.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/entity/TaskInstance.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/entity/TaskInstanceHost.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/entity/TaskInstanceJob.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/entity/TaskNode.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/entity/TaskWorker.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/enums/AuthenMode.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/enums/Catalog.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/enums/Category.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/enums/Charset.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/enums/Status.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/enums/TaskAction.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/enums/TaskParam.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/enums/Topic.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/model/EngineModule.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/model/HostResult.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/model/Job.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/model/JobResult.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/model/NodeConfig.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/model/NodeControl.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/model/NodePosition.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/model/NodeSize.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/model/SaltCacheModel.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/model/SaltModel.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/model/StateApplyResultModel.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/model/TaskActionMessage.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/model/TaskEdge.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/model/TaskGraph.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/model/TaskMessage.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/model/TaskResult.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/model/WorkerHost.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/model/WorkerHostResult.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/model/WorkerLoadInfo.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/model/WorkerMetricInfo.java
create mode 100644 bocloud.tse.entity/src/main/java/com/bocloud/tse/model/WorkerWeightInfo.java
create mode 100644 bocloud.tse.scheduler/pom.xml
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/core/AbstractScheduler.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/core/DataCache.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/core/JobChannel.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/core/JobScheduler.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/core/SchedulerDaemon.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/core/TaskCache.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/executor/NodeExecutor.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/executor/TaskExecutor.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/failover/TaskFailoverExecutor.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/failover/TaskFailoverScheduler.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/jobclient/JobClient.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/jobclient/JobSchedulerHandler.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/listener/JobCompletedListener.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/listener/TaskActionListener.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/listener/TaskListener.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/selector/NodeSelector.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/selector/TaskNodeSelector.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/utils/BeanUtils.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/utils/IpUtil.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/utils/JobFormatDetector.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/utils/JsonParseUtils.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/utils/JudgeCondition.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/utils/NodeDependencyHandler.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/utils/TaskProgressPublisher.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/AbstractWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/ParamBuilder.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/WorkerDispatcher.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/WorkerFactory.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/WorkerLoadPolicy.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/executor/RemoteSaltStack.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/executor/RemoteWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/executor/WorkerRemoteMQService.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/executor/WorkerRemoteService.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/listener/AbstractTaskListener.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/listener/JobTask.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/listener/MaintainTaskListener.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/listener/ScheduledTaskListener.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/listener/SoftwareTaskListener.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/listener/TaskJobListener.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/listener/TaskResultListener.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/locator/ClazzLocator.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/locator/InputClassLocator.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/locator/WorkerClassLocator.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/maintain/BackupWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/maintain/DatabaseWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/maintain/GaiaWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/maintain/HostAllowWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/maintain/MaintainWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/maintain/MethodWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/maintain/RecoveryWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/maintain/ScriptLocalWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/maintain/ScriptWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/maintain/ScriptsWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/maintain/ServiceWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/maintain/TemplateWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/maintain/UploadWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/maintain/UserWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/software/ActivemqWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/software/ApacheWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/software/ElasticsearchWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/software/EtcdWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/software/ExporterWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/software/GitlabWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/software/IscsiWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/software/IscsicWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/software/IscsisWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/software/JdkWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/software/JenkinsWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/software/K8sWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/software/KafkaWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/software/MemcacheWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/software/MongodbWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/software/MysqlWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/software/NfscWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/software/NfssWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/software/NginxWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/software/OracleWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/software/PhpWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/software/PostgresqlWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/software/RabbitmqWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/software/RedisWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/software/RocketmqWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/software/SoftwareWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/software/SqlserverWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/software/TomcatWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/software/WeblogicWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/software/WebsphereWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/software/WebspheremqWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/software/ZookeeperWorker.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/utils/ResultMessageHandler.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/utils/SaltClientCache.java
create mode 100644 bocloud.tse.scheduler/src/main/java/com/bocloud/tse/scheduler/worker/utils/SaltClientModel.java
create mode 100644 bocloud.tse.service/pom.xml
create mode 100644 bocloud.tse.service/src/main/java/com/bocloud/tse/intf/CommandService.java
create mode 100644 bocloud.tse.service/src/main/java/com/bocloud/tse/intf/EngineService.java
create mode 100644 bocloud.tse.service/src/main/java/com/bocloud/tse/intf/NodeModuleService.java
create mode 100644 bocloud.tse.service/src/main/java/com/bocloud/tse/intf/TaskInstanceService.java
create mode 100644 bocloud.tse.service/src/main/java/com/bocloud/tse/intf/TaskNodeService.java
create mode 100644 bocloud.tse.service/src/main/java/com/bocloud/tse/intf/TaskService.java
create mode 100644 bocloud.tse.service/src/main/java/com/bocloud/tse/repository/CommandInstanceRepository.java
create mode 100644 bocloud.tse.service/src/main/java/com/bocloud/tse/repository/CommandRepository.java
create mode 100644 bocloud.tse.service/src/main/java/com/bocloud/tse/repository/IdentificationRepository.java
create mode 100644 bocloud.tse.service/src/main/java/com/bocloud/tse/repository/NodeModuleRepository.java
create mode 100644 bocloud.tse.service/src/main/java/com/bocloud/tse/repository/NodeRelationRepository.java
create mode 100644 bocloud.tse.service/src/main/java/com/bocloud/tse/repository/TaskFailRecordRepository.java
create mode 100644 bocloud.tse.service/src/main/java/com/bocloud/tse/repository/TaskHostRepository.java
create mode 100644 bocloud.tse.service/src/main/java/com/bocloud/tse/repository/TaskInstanceHostRepository.java
create mode 100644 bocloud.tse.service/src/main/java/com/bocloud/tse/repository/TaskInstanceJobRepository.java
create mode 100644 bocloud.tse.service/src/main/java/com/bocloud/tse/repository/TaskInstanceRepository.java
create mode 100644 bocloud.tse.service/src/main/java/com/bocloud/tse/repository/TaskNodeRepository.java
create mode 100644 bocloud.tse.service/src/main/java/com/bocloud/tse/repository/TaskRepository.java
create mode 100644 bocloud.tse.service/src/main/java/com/bocloud/tse/service/CommandServiceImpl.java
create mode 100644 bocloud.tse.service/src/main/java/com/bocloud/tse/service/EngineServiceImpl.java
create mode 100644 bocloud.tse.service/src/main/java/com/bocloud/tse/service/NodeModuleServiceImpl.java
create mode 100644 bocloud.tse.service/src/main/java/com/bocloud/tse/service/TaskInstanceServiceImpl.java
create mode 100644 bocloud.tse.service/src/main/java/com/bocloud/tse/service/TaskNodeServiceImpl.java
create mode 100644 bocloud.tse.service/src/main/java/com/bocloud/tse/service/TaskServiceImpl.java
create mode 100644 bocloud.tse.service/src/main/java/com/bocloud/tse/service/internal/TseInternalService.java
create mode 100644 bocloud.tse.service/src/main/java/com/bocloud/tse/utils/NodeHelper.java
create mode 100644 pom.xml
diff --git a/README.md b/README.md
new file mode 100644
index 0000000..8b13789
--- /dev/null
+++ b/README.md
@@ -0,0 +1 @@
+
diff --git a/bocloud.tse.booter/pom.xml b/bocloud.tse.booter/pom.xml
new file mode 100644
index 0000000..f16fb5d
--- /dev/null
+++ b/bocloud.tse.booter/pom.xml
@@ -0,0 +1,150 @@
+
+ 4.0.0
+
+ com.bocloud
+ bocloud.tse
+ 6.5.0-LTS-SZ
+
+ bocloud.tse.booter
+ ${bocloud.booter.version}
+
+
+
+ org.springframework.boot
+ spring-boot-starter-web
+
+
+ org.hibernate.validator
+ hibernate-validator
+
+
+
+
+
+ com.freedom
+ megatron.microservice
+
+
+ com.bocloud
+ bocloud.tse.scheduler
+
+
+ com.google.code.gson
+ gson
+
+
+
+
+ com.google.code.gson
+ gson
+ 2.8.2
+
+
+
+ org.slf4j
+ slf4j-api
+ 2.0.7
+
+
+
+
+
+ org.apache.maven.plugins
+ maven-compiler-plugin
+ 3.11.0
+
+ true
+ 21
+ 21
+
+
+
+ org.apache.maven.plugins
+ maven-jar-plugin
+ 3.3.0
+
+
+
+ com.bocloud.tse.booter.Application
+ true
+ false
+ libs/
+
+
+
+
+
+ org.apache.maven.plugins
+ maven-dependency-plugin
+ 3.6.1
+
+
+
+ copy-dependencies
+
+
+ jar
+ jar
+ runtime
+ ${project.build.directory}/libs
+
+
+
+
+
+
+
+
+ bocloud.booter.tomcat
+
+ 6.5.0-LTS-SZ
+
+
+
+ org.springframework.boot
+ spring-boot-starter-web
+
+
+ org.hibernate.validator
+ hibernate-validator
+
+
+
+
+
+
+ bocloud.booter.tongweb
+
+ 6.5.0-LTS-SZ-TONGWEB
+
+
+
+ com.tongweb
+ tongweb-embed
+ 7.0.E.2
+
+
+ com.tongweb.springboot
+ tongweb-spring-boot-starter
+ 2.x.0.RELEASE
+
+
+ org.springframework.boot
+ spring-boot-starter-web
+
+
+ org.hibernate.validator
+ hibernate-validator
+
+
+ org.springframework.boot
+ spring-boot-starter-tomcat
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/bocloud.tse.booter/src/main/java/com/bocloud/tse/booter/Application.java b/bocloud.tse.booter/src/main/java/com/bocloud/tse/booter/Application.java
new file mode 100644
index 0000000..bbafc00
--- /dev/null
+++ b/bocloud.tse.booter/src/main/java/com/bocloud/tse/booter/Application.java
@@ -0,0 +1,19 @@
+package com.bocloud.tse.booter;
+
+import org.springframework.amqp.rabbit.annotation.EnableRabbit;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.annotation.ComponentScan;
+import org.springframework.scheduling.annotation.EnableScheduling;
+
+@SpringBootApplication
+@EnableRabbit
+@EnableScheduling
+@ComponentScan(value = {"com.bocloud", "com.megatron"})
+public class Application {
+
+ public static void main(String[] args) {
+ SpringApplication.run(Application.class, args);
+ }
+
+}
diff --git a/bocloud.tse.booter/src/main/java/com/bocloud/tse/booter/config/RabbitMQConfiguration.java b/bocloud.tse.booter/src/main/java/com/bocloud/tse/booter/config/RabbitMQConfiguration.java
new file mode 100644
index 0000000..7c1e805
--- /dev/null
+++ b/bocloud.tse.booter/src/main/java/com/bocloud/tse/booter/config/RabbitMQConfiguration.java
@@ -0,0 +1,129 @@
+package com.bocloud.tse.booter.config;
+
+import java.util.Map;
+
+import com.bocloud.tse.scheduler.worker.listener.TaskResultListener;
+import org.springframework.amqp.core.AcknowledgeMode;
+import org.springframework.amqp.core.Binding;
+import org.springframework.amqp.core.BindingBuilder;
+import org.springframework.amqp.core.DirectExchange;
+import org.springframework.amqp.core.Queue;
+import org.springframework.amqp.core.TopicExchange;
+import org.springframework.amqp.rabbit.connection.ConnectionFactory;
+import org.springframework.amqp.rabbit.core.RabbitAdmin;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
+import org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer;
+import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
+import org.springframework.amqp.support.converter.MessageConverter;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.config.ConfigurableBeanFactory;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Scope;
+
+import com.bocloud.tse.scheduler.listener.TaskActionListener;
+import com.megatron.common.utils.MapTools;
+import com.megatron.framework.core.CurrentService;
+
+/**
+ * rabbitmq相关配置
+ */
+@Configuration
+@ConfigurationProperties(prefix = "spring.rabbitmq")
+public class RabbitMQConfiguration {
+
+ @Autowired
+ private ConnectionFactory connectionFactory;
+ private Map arguments = MapTools.simpleMap("x-ha-policy", "all");
+
+ /**
+ * 声明任务动作队列
+ */
+ @Bean
+ public Queue declareTaskActionQueue(CurrentService service) {
+ return new Queue("task.action.queue.tse." + service.getService().getHost() + "_" + service.getService().getPort(), true, false, true, arguments);
+ }
+
+ /**
+ * 定义direct exchange
+ */
+ @Bean
+ public DirectExchange defineDirectExchange() {
+ return new DirectExchange("bocloud.direct.exchange", true, true, arguments);
+ }
+
+ @Bean
+ public Queue declareTaskResultQueue(CurrentService service) {
+ return new Queue("task.result.queue." + service.getService().getHost() + "_" + service.getService().getPort(),
+ true, false, true, arguments);
+ }
+
+ /**
+ * 定义topic exchange
+ */
+ @Bean
+ public TopicExchange defineTopicExchange() {
+ return new TopicExchange("bocloud.topic.exchange", true, true, arguments);
+ }
+
+ /**
+ * 任务动作队列绑定bocloud.topic.exchange
+ */
+ @Bean
+ public Binding bindingTaskActionQueue(CurrentService service) {
+ return BindingBuilder.bind(declareTaskActionQueue(service)).to(defineTopicExchange())
+ .with("topic.task.action.#");
+ }
+
+ /**
+ * 绑定任务执行结果队列
+ *
+ * @param service
+ * @return
+ */
+ @Bean
+ public Binding bindingTaskResultQueue(CurrentService service) {
+ return BindingBuilder.bind(declareTaskResultQueue(service)).to(defineDirectExchange()).withQueueName();
+ }
+ @Bean
+ public SimpleMessageListenerContainer autoActionListener(CurrentService service,
+ TaskActionListener taskActionListener) {
+ SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(connectionFactory);
+ container.setQueues(declareTaskActionQueue(service));
+ container.setAcknowledgeMode(AcknowledgeMode.AUTO); // 设置确认模式自动确认
+ container.setMessageListener(taskActionListener);
+ return container;
+ }
+
+ @Bean
+ public SimpleMessageListenerContainer autoTaskResultListener(CurrentService service,
+ TaskResultListener taskResultListener) {
+ SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(connectionFactory);
+ container.setQueues(declareTaskResultQueue(service));
+ container.setAcknowledgeMode(AcknowledgeMode.AUTO); // 设置确认模式自动确认
+ container.setMessageListener(taskResultListener);
+ return container;
+ }
+ @Bean
+ public MessageConverter messageConverter() {
+ return new Jackson2JsonMessageConverter();
+ }
+
+ @Bean
+ @Scope(ConfigurableBeanFactory.SCOPE_PROTOTYPE)
+ public RabbitTemplate amqpTemplate() {
+ RabbitTemplate amqpTemplate = new RabbitTemplate(connectionFactory);
+ amqpTemplate.setMessageConverter(messageConverter());
+ amqpTemplate.setExchange(defineDirectExchange().getName());
+ return amqpTemplate;
+ }
+
+ @Bean
+ @Scope(ConfigurableBeanFactory.SCOPE_PROTOTYPE)
+ public RabbitAdmin rabbitAdmin() {
+ RabbitAdmin rabbitAdmin = new RabbitAdmin(connectionFactory);
+ return rabbitAdmin;
+ }
+
+}
diff --git a/bocloud.tse.booter/src/main/java/com/bocloud/tse/booter/config/SwaggerConfiguration.java b/bocloud.tse.booter/src/main/java/com/bocloud/tse/booter/config/SwaggerConfiguration.java
new file mode 100644
index 0000000..4983b1c
--- /dev/null
+++ b/bocloud.tse.booter/src/main/java/com/bocloud/tse/booter/config/SwaggerConfiguration.java
@@ -0,0 +1,21 @@
+package com.bocloud.tse.booter.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import io.swagger.v3.oas.models.OpenAPI;
+import io.swagger.v3.oas.models.info.Contact;
+import io.swagger.v3.oas.models.info.Info;
+
+@Configuration
+public class SwaggerConfiguration {
+
+ @Bean
+ public OpenAPI openAPI() {
+ Contact contact = new Contact().name("未伟").email("weiwei@beyondcent.com").url("http://www.bocloud.com/");
+ Info info = new Info().title("任务引擎服务API接口文档").description("任务引擎服务API接口文档")
+ .termsOfService("http://www.bocloud.com/").contact(contact).version("1.0");
+ return new OpenAPI().info(info);
+ }
+
+}
diff --git a/bocloud.tse.booter/src/main/java/com/bocloud/tse/booter/config/WebInterceptorConfiguration.java b/bocloud.tse.booter/src/main/java/com/bocloud/tse/booter/config/WebInterceptorConfiguration.java
new file mode 100644
index 0000000..c0954b7
--- /dev/null
+++ b/bocloud.tse.booter/src/main/java/com/bocloud/tse/booter/config/WebInterceptorConfiguration.java
@@ -0,0 +1,60 @@
+package com.bocloud.tse.booter.config;
+
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import com.bocloud.cmp.boot.config.PagerArgumentResolver;
+import com.bocloud.cmp.boot.interceptor.AccessInterceptor;
+import com.bocloud.cmp.boot.interceptor.LogInterceptor;
+import com.megatron.framework.core.InterceptorBridge;
+import com.megatron.framework.core.config.InterceptorConfiguration;
+import com.megatron.framework.core.domain.InterceptorEntity;
+
+import lombok.extern.slf4j.Slf4j;
+
+/**
+ * 拦截器配置类
+ */
+@Slf4j
+@Component
+public class WebInterceptorConfiguration implements InterceptorConfiguration {
+
+ private static final String[] ACCESS_EXCLUDES = new String[] {"/status", "/status/db", "/status/**",
+ "/v1/status/**", "/login", "/sso", "/v1/logview", "/v1/logzip", "/v1/config/**", "/v1/plugins/**", "/*/*.css",
+ "/*/*.js", "/*/*.png", "/*/*.jpg", "/*/*.jpeg", "/*.html", "/*/*.html", "/swagger-resources/**", "/favicon.ico",
+ "/webjars/**", "/v3/**", "/swagger-ui.html/**", "**/api-docs", "/error", "/favicon.ico"};
+ private static final String[] LOG_EXCLUDES = new String[] {"/*/*.css", "/*/*.js", "/*/*.png", "/*/*.jpg",
+ "/*/*.jpeg", "/*.html", "/*/*.html", "/swagger-resources/**", "/favicon.ico", "/webjars/**", "/v3/**",
+ "/swagger-ui.html/**", "**/api-docs", "/error", "/favicon.ico"};
+ private static final String[] INCLUDES = new String[] {"/**"};
+ private final LogInterceptor logInterceptor;
+ private final AccessInterceptor accessInterceptor;
+
+ @Autowired
+ public WebInterceptorConfiguration(AccessInterceptor accessInterceptor, LogInterceptor logInterceptor) {
+ this.logInterceptor = logInterceptor;
+ this.accessInterceptor = accessInterceptor;
+ }
+
+ @Override
+ public InterceptorBridge buildBridge() {
+ log.info("start to build interceptors...");
+ InterceptorBridge bridge = new InterceptorBridge();
+ InterceptorEntity accessEntity = InterceptorEntity.builder().interceptor(accessInterceptor).includes(INCLUDES)
+ .excludes(ACCESS_EXCLUDES).order(0).build();
+ InterceptorEntity auditLogEntity = InterceptorEntity.builder().interceptor(logInterceptor).includes(INCLUDES)
+ .excludes(LOG_EXCLUDES).order(1).build();
+ List interceptors = new ArrayList<>();
+ interceptors.add(accessEntity);
+ interceptors.add(auditLogEntity);
+ bridge.setInterceptors(interceptors);
+ bridge.setResolvers(Collections.singletonList(new PagerArgumentResolver()));
+ bridge.setMessageConverters(new ArrayList<>(0));
+ log.info("build interceptors success!!!");
+ return bridge;
+ }
+}
diff --git a/bocloud.tse.booter/src/main/java/com/bocloud/tse/booter/controller/EngineController.java b/bocloud.tse.booter/src/main/java/com/bocloud/tse/booter/controller/EngineController.java
new file mode 100644
index 0000000..0f27ae5
--- /dev/null
+++ b/bocloud.tse.booter/src/main/java/com/bocloud/tse/booter/controller/EngineController.java
@@ -0,0 +1,74 @@
+package com.bocloud.tse.booter.controller;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.PutMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import com.bocloud.tse.intf.EngineService;
+import com.bocloud.tse.model.EngineModule;
+import com.bocloud.tse.scheduler.core.JobScheduler;
+import com.megatron.common.model.GeneralResult;
+import com.megatron.common.model.RequestContext;
+import com.megatron.common.utils.Common;
+
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+
+@RestController
+@RequestMapping("/v1/engines")
+@Tag(name = "任务引擎管理")
+public class EngineController {
+
+ @Autowired
+ private EngineService engineService;
+ @Autowired
+ private JobScheduler scheduler;
+
+ @Operation(summary = "任务引擎列表")
+ @GetMapping
+ public GeneralResult> services() {
+ return engineService.services();
+ }
+
+ @Operation(summary = "任务引擎状态")
+ @GetMapping("/status")
+ public GeneralResult status() {
+ return new GeneralResult<>(true, scheduler.isRunning(), "任务引擎状态查询成功");
+ }
+
+ @Operation(summary = "任务引擎操作(开启/关闭)")
+ @PostMapping("/action")
+ public GeneralResult> action(@RequestBody EngineModule module) {
+ GeneralResult> result = engineService.action(module);
+ if (result.isSuccess() && engineService.checkInstance(module.getInstance())) {
+ String action = module.getAction();
+ if ("start".equals(action) && !scheduler.isRunning()) {
+ scheduler.switchOn();
+ } else if ("stop".equals(action) && scheduler.isRunning()) {
+ scheduler.switchOff();
+ }
+ }
+ return result;
+ }
+
+ @PutMapping(value = "/exclude")
+ @Operation(tags = { "CMC", "CSC" }, summary = "任务引擎排除")
+ public GeneralResult taskExclude(@RequestParam(value = "instance") String instance,
+ @Value(Common.REQ_CONTEXT) RequestContext context) {
+ return engineService.exclude(instance, context.getTarget());
+ }
+
+ @PutMapping(value = "/recover")
+ @Operation(tags = { "CMC", "CSC" }, summary = "任务引擎恢复")
+ public GeneralResult taskRecover(@RequestParam(value = "instance") String instance,
+ @Value(Common.REQ_CONTEXT) RequestContext context) {
+ return engineService.recover(instance, context.getTarget());
+ }
+
+}
diff --git a/bocloud.tse.booter/src/main/java/com/bocloud/tse/booter/controller/SchedulerController.java b/bocloud.tse.booter/src/main/java/com/bocloud/tse/booter/controller/SchedulerController.java
new file mode 100644
index 0000000..b598950
--- /dev/null
+++ b/bocloud.tse.booter/src/main/java/com/bocloud/tse/booter/controller/SchedulerController.java
@@ -0,0 +1,93 @@
+package com.bocloud.tse.booter.controller;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Queue;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import com.alibaba.fastjson.JSONObject;
+import com.bocloud.tse.intf.TaskInstanceService;
+import com.bocloud.tse.model.Job;
+import com.bocloud.tse.scheduler.core.JobChannel;
+import com.bocloud.tse.scheduler.core.JobScheduler;
+import com.bocloud.tse.scheduler.core.TaskCache;
+import com.bocloud.tse.scheduler.executor.NodeExecutor;
+import com.bocloud.tse.scheduler.executor.TaskExecutor;
+import com.megatron.common.model.GeneralResult;
+import com.megatron.common.model.Result;
+
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+
+/**
+ * 状态控制器
+ */
+@RestController
+@RequestMapping("/v1")
+@Tag(name = "任务状态管理")
+public class SchedulerController {
+
+ @Autowired
+ private JobScheduler scheduler;
+ @Autowired
+ private TaskInstanceService instanceService;
+ @Autowired
+ private JobChannel channel;
+
+ private TaskCache cache = TaskCache.instance();
+
+ @GetMapping("/status/task/total")
+ @Operation(tags = { "CMC" }, summary = "任务整体信息")
+ public GeneralResult