diff --git a/.gitignore b/.gitignore
index 77e5f422d4..7adc4b799d 100644
--- a/.gitignore
+++ b/.gitignore
@@ -11,7 +11,7 @@
### Jrebel File ###
*rebel.xml.bak
*rebel.xml
-
+*.idx
### Common ###
target
@@ -28,4 +28,4 @@ ig**
application-local.*
.DS_Store
-public/
\ No newline at end of file
+public/!/extensions.idx
diff --git a/pom.xml b/pom.xml
index 55bcb95e88..8bc5992d43 100644
--- a/pom.xml
+++ b/pom.xml
@@ -4,7 +4,7 @@
io.shulie.takin
takin-web
- takin-web-5.9.0
+ takin-web-5.10.2.2
pom
https://github.com/shulieTech/Takin-web.git
@@ -41,7 +41,7 @@
3.8.0
yyyyMMddHHmmss
- takin-web-5.9.0
+ takin-web-5.10.2.2
common-2.0.2-SNAPSHOT
common-2.0.0-SNAPSHOT
2.0.6.2
@@ -50,7 +50,7 @@
3.5
2.3.0.RELEASE
- 8.0.26
+ 8.0.27
1.1.22
2.3
2.3.0
@@ -78,6 +78,10 @@
9.1.22
2.12.4
5.4.0.12
+ 2.16.0
+ 1.2.9
+ 9.0.67
+ 1.2.83
@@ -344,7 +348,7 @@
io.shulie.amdb
amdb-common
- 1.0.3-SNAPSHOT
+ 1.1.3
org.mapstruct
@@ -455,85 +459,85 @@
true
-
-
- ossrh
-
-
-
-
- org.apache.maven.plugins
- maven-resources-plugin
- 2.5
-
- UTF-8
-
-
-
- org.apache.maven.plugins
- maven-scm-plugin
- 1.0
-
-
- org.apache.maven.plugins
- maven-release-plugin
-
-
- org.apache.maven.plugins
- maven-javadoc-plugin
- 2.9.1
-
-
- attach-javadocs
-
- jar
-
-
- -Xdoclint:none
-
-
-
-
-
- org.apache.maven.plugins
- maven-gpg-plugin
- 1.5
-
-
- sign-artifacts
- verify
-
- sign
-
-
-
-
-
- org.sonatype.plugins
- nexus-staging-maven-plugin
- 1.6.7
- true
-
- ossrh
- https://s01.oss.sonatype.org/
- true
-
-
-
- org.apache.maven.plugins
- maven-jar-plugin
- 2.2
-
-
-
- true
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/takin-web-amdb-accessor/pom.xml b/takin-web-amdb-accessor/pom.xml
index 6404a4a4b5..7c4b626439 100644
--- a/takin-web-amdb-accessor/pom.xml
+++ b/takin-web-amdb-accessor/pom.xml
@@ -20,7 +20,7 @@
takin-web
io.shulie.takin
- takin-web-5.9.0
+ takin-web-5.10.2.2
4.0.0
@@ -69,10 +69,22 @@
io.shulie.pradar
log-protocol
+
+
+ fastjson
+ com.alibaba
+
+
io.shulie.takin
takin-common-utils
+
+
+ fastjson
+ com.alibaba
+
+
org.mortbay.jetty
@@ -106,6 +118,10 @@
log4j
log4j
+
+ fastjson
+ com.alibaba
+
diff --git a/takin-web-amdb-accessor/src/main/java/io/shulie/takin/web/amdb/api/ApplicationEntranceClient.java b/takin-web-amdb-accessor/src/main/java/io/shulie/takin/web/amdb/api/ApplicationEntranceClient.java
index df13b698e8..f9e4e725df 100644
--- a/takin-web-amdb-accessor/src/main/java/io/shulie/takin/web/amdb/api/ApplicationEntranceClient.java
+++ b/takin-web-amdb-accessor/src/main/java/io/shulie/takin/web/amdb/api/ApplicationEntranceClient.java
@@ -18,7 +18,7 @@ public interface ApplicationEntranceClient {
List getApplicationEntrances(String applicationName, String entranceType, String serviceName, int currentPage, int pageSize);
LinkTopologyDTO getApplicationEntrancesTopology(boolean tempActivity, String applicationName, String linkId, String serviceName,
- String method, String rpcType, String extend);
+ String method, String rpcType, String extend,boolean extFlag);
String queryMetricsFromAMDB1(TempTopologyQuery1 tempTopologyQuery1);
JSONObject queryMetricsFromAMDB2(TempTopologyQuery2 tempTopologyQuery2);
diff --git a/takin-web-amdb-accessor/src/main/java/io/shulie/takin/web/amdb/api/impl/ApplicationEntranceClientImpl.java b/takin-web-amdb-accessor/src/main/java/io/shulie/takin/web/amdb/api/impl/ApplicationEntranceClientImpl.java
index 9f95bc51b3..49bd453f86 100644
--- a/takin-web-amdb-accessor/src/main/java/io/shulie/takin/web/amdb/api/impl/ApplicationEntranceClientImpl.java
+++ b/takin-web-amdb-accessor/src/main/java/io/shulie/takin/web/amdb/api/impl/ApplicationEntranceClientImpl.java
@@ -78,7 +78,9 @@ public List getApplicationEntrances(String applicationName, Stri
//查询所有的type
entranceQueryParam.setRpcType("");
}
- entranceQueryParam.setAppName(applicationName);
+ if (StringUtils.isNotBlank(applicationName)) {
+ entranceQueryParam.setAppName(applicationName);
+ }
entranceQueryParam.setTenantAppKey(WebPluginUtils.traceTenantAppKey());
entranceQueryParam.setEnvCode(WebPluginUtils.traceEnvCode());
entranceQueryParam.setCurrentPage(currentPage);
@@ -192,10 +194,21 @@ public List queryBatchMetrics(QueryMetricsFromAMDB queryMetricsFromA
}
}
+ /**
+ * @param tempActivity
+ * @param applicationName
+ * @param linkId
+ * @param serviceName
+ * @param method
+ * @param rpcType
+ * @param extend
+ * @param extFlag 是否查询扩展边信息,会返回数据库关联的库信息
+ * @return
+ */
@Override
public LinkTopologyDTO getApplicationEntrancesTopology(boolean tempActivity, String applicationName, String linkId,
String serviceName,
- String method, String rpcType, String extend) {
+ String method, String rpcType, String extend, boolean extFlag) {
String url;
if (tempActivity) {
url = properties.getUrl().getAmdb() + APPLICATION_ENTRANCES_TOPOLOGY_PATH_TEMP;
@@ -216,6 +229,8 @@ public LinkTopologyDTO getApplicationEntrancesTopology(boolean tempActivity, Str
if (extend != null) {
topologyQueryParam.setExtend(extend);
}
+ // 是否关联查询出数据库的详情信息,默认false
+ topologyQueryParam.setExtFlag(extFlag);
topologyQueryParam.setTenantAppKey(WebPluginUtils.traceTenantAppKey());
topologyQueryParam.setEnvCode(WebPluginUtils.traceEnvCode());
try {
diff --git a/takin-web-amdb-accessor/src/main/java/io/shulie/takin/web/amdb/bean/query/application/ApplicationRemoteCallQueryDTO.java b/takin-web-amdb-accessor/src/main/java/io/shulie/takin/web/amdb/bean/query/application/ApplicationRemoteCallQueryDTO.java
index 1f7d1ab413..c7c619bb2d 100644
--- a/takin-web-amdb-accessor/src/main/java/io/shulie/takin/web/amdb/bean/query/application/ApplicationRemoteCallQueryDTO.java
+++ b/takin-web-amdb-accessor/src/main/java/io/shulie/takin/web/amdb/bean/query/application/ApplicationRemoteCallQueryDTO.java
@@ -16,7 +16,7 @@ public class ApplicationRemoteCallQueryDTO {
@JsonProperty("currentPage")
private Integer currentPage;
@JsonProperty("linkId")
- private Integer linkId;
+ private String linkId;
@JsonProperty("methodName")
private String methodName;
@JsonProperty("middlewareName")
@@ -37,7 +37,7 @@ public class ApplicationRemoteCallQueryDTO {
@JsonProperty("userName")
private String userName;
@JsonProperty("fieldNames")
- private String fieldNames = "appName,serviceName,methodName,middlewareName,middlewareDetail,rpcType,extend,upAppName";
+ private String fieldNames = "appName,serviceName,methodName,middlewareName,middlewareDetail,rpcType,extend,upAppName,rpcId,linkId";
/**
* 客户端查询
*/
diff --git a/takin-web-amdb-accessor/src/main/java/io/shulie/takin/web/amdb/bean/query/script/QueryLinkDetailDTO.java b/takin-web-amdb-accessor/src/main/java/io/shulie/takin/web/amdb/bean/query/script/QueryLinkDetailDTO.java
index 933283a8d3..f864bb5e6d 100644
--- a/takin-web-amdb-accessor/src/main/java/io/shulie/takin/web/amdb/bean/query/script/QueryLinkDetailDTO.java
+++ b/takin-web-amdb-accessor/src/main/java/io/shulie/takin/web/amdb/bean/query/script/QueryLinkDetailDTO.java
@@ -4,6 +4,7 @@
import io.shulie.takin.web.amdb.bean.common.PagingDevice;
import io.shulie.takin.web.amdb.bean.query.trace.EntranceRuleDTO;
+import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
@@ -126,4 +127,13 @@ public class QueryLinkDetailDTO extends PagingDevice {
*/
private Integer queryType;
+ private String appName;
+
+ /**
+ * 类名模糊查询
+ */
+ private String queryMethodName;
+
+ @ApiModelProperty("调用类型")
+ String logType;
}
diff --git a/takin-web-amdb-accessor/src/main/java/io/shulie/takin/web/amdb/bean/query/trace/TraceInfoQueryDTO.java b/takin-web-amdb-accessor/src/main/java/io/shulie/takin/web/amdb/bean/query/trace/TraceInfoQueryDTO.java
index 14a6bd8088..2846fe49cc 100644
--- a/takin-web-amdb-accessor/src/main/java/io/shulie/takin/web/amdb/bean/query/trace/TraceInfoQueryDTO.java
+++ b/takin-web-amdb-accessor/src/main/java/io/shulie/takin/web/amdb/bean/query/trace/TraceInfoQueryDTO.java
@@ -64,6 +64,11 @@ public class TraceInfoQueryDTO implements Serializable {
*/
private String methodName;
+ /**
+ * 方法名模糊查询
+ */
+ private String queryMethodName;
+
/**
* 调用参数:request
*/
@@ -85,5 +90,11 @@ public class TraceInfoQueryDTO implements Serializable {
*/
private Integer queryType;
+ private String appName;
+
+ private String rpcType;
+
private Integer clusterTest;
+
+ String logType;
}
diff --git a/takin-web-amdb-accessor/src/main/java/io/shulie/takin/web/amdb/bean/result/application/ApplicationRemoteCallDTO.java b/takin-web-amdb-accessor/src/main/java/io/shulie/takin/web/amdb/bean/result/application/ApplicationRemoteCallDTO.java
index 6df5f2a0bc..8c2c7c2b2b 100644
--- a/takin-web-amdb-accessor/src/main/java/io/shulie/takin/web/amdb/bean/result/application/ApplicationRemoteCallDTO.java
+++ b/takin-web-amdb-accessor/src/main/java/io/shulie/takin/web/amdb/bean/result/application/ApplicationRemoteCallDTO.java
@@ -13,6 +13,8 @@
public class ApplicationRemoteCallDTO {
@JsonProperty("appName")
private String appName;
+ @JsonProperty("appId")
+ private Long appId;
@JsonProperty("extend")
private String extend;
@JsonProperty("methodName")
@@ -29,5 +31,6 @@ public class ApplicationRemoteCallDTO {
private String upAppName;
@JsonProperty("defaultWhiteInfo")
private String defaultWhiteInfo;
+ private String rpcId;
}
\ No newline at end of file
diff --git a/takin-web-app/pom.xml b/takin-web-app/pom.xml
index d0fa560016..313e64ef60 100644
--- a/takin-web-app/pom.xml
+++ b/takin-web-app/pom.xml
@@ -4,7 +4,7 @@
io.shulie.takin
takin-web
- takin-web-5.9.0
+ takin-web-5.10.2.2
../pom.xml
takin-web-app
@@ -48,6 +48,10 @@
org.slf4j
slf4j-log4j12
+
+ fastjson
+ com.alibaba
+
@@ -135,6 +139,10 @@
org.apache.logging.log4j
log4j-api
+
+ fastjson
+ com.alibaba
+
@@ -233,6 +241,10 @@
guava
com.google.guava
+
+ fastjson
+ com.alibaba
+
diff --git a/takin-web-app/src/main/java/io/shulie/takin/web/app/conf/ResponseWrapAdvice.java b/takin-web-app/src/main/java/io/shulie/takin/web/app/conf/ResponseWrapAdvice.java
index 1f17b58577..25f9207f2b 100644
--- a/takin-web-app/src/main/java/io/shulie/takin/web/app/conf/ResponseWrapAdvice.java
+++ b/takin-web-app/src/main/java/io/shulie/takin/web/app/conf/ResponseWrapAdvice.java
@@ -4,9 +4,11 @@
import java.util.Set;
import java.util.HashSet;
+import io.shulie.takin.web.common.domain.ErrorInfo;
import lombok.NonNull;
import lombok.extern.slf4j.Slf4j;
import com.github.pagehelper.PageInfo;
+import org.apache.commons.lang3.StringUtils;
import org.springframework.http.MediaType;
import org.springframework.http.HttpHeaders;
import org.springframework.core.MethodParameter;
@@ -58,8 +60,21 @@ public Object beforeBodyWrite(Object body,
headers.add(Response.PAGE_TOTAL_HEADER);
header.set(accessControlExposeHeaderName, String.join(",", headers));
}
- if (body instanceof Response
- || body instanceof WebResponse
+ if (body instanceof Response){
+ Object data = ((Response>) body).getData();
+ ErrorInfo error = ((Response>) body).getError();
+ Boolean success = ((Response>) body).getSuccess();
+ String total = ((Response>) body).getTotal();
+ if (!success){
+ return io.shulie.takin.common.beans.response.ResponseResult.fail(error.getMsg(),"");
+ }
+ if (StringUtils.isNotBlank(total)){
+ return io.shulie.takin.common.beans.response.ResponseResult.success(data, Long.parseLong(total));
+ }
+ return io.shulie.takin.common.beans.response.ResponseResult.success(data);
+ }
+
+ if (body instanceof WebResponse
|| body instanceof File
|| body instanceof ResponseResult
|| body instanceof io.shulie.takin.common.beans.response.ResponseResult) {
diff --git a/takin-web-app/src/main/java/io/shulie/takin/web/app/conf/SwaggerConfig.java b/takin-web-app/src/main/java/io/shulie/takin/web/app/conf/SwaggerConfig.java
index f9c10ad383..d12425c78b 100644
--- a/takin-web-app/src/main/java/io/shulie/takin/web/app/conf/SwaggerConfig.java
+++ b/takin-web-app/src/main/java/io/shulie/takin/web/app/conf/SwaggerConfig.java
@@ -451,6 +451,25 @@ public Docket api_twoWeekIteration() {
;
}
+ /**
+ * 权限改造
+ * @return
+ */
+ @Bean
+ public Docket api_deptAuth() {
+ return new Docket(DocumentationType.SWAGGER_2)
+ .pathProvider(this.pathProvider())
+ .groupName("部门权限改造")
+ .select()
+ .apis(RequestHandlerSelectors.withClassAnnotation(Api.class))
+ .paths(getRegex("/api/(dept|role).*"))
+ .build()
+ .directModelSubstitute(LocalDate.class, String.class)
+ .useDefaultResponseMessages(false)
+ .apiInfo(apiInfo()).enable(swaggerEnable)
+ ;
+ }
+
/**
diff --git a/takin-web-app/src/main/java/io/shulie/takin/web/app/conf/ThreadPoolConfig.java b/takin-web-app/src/main/java/io/shulie/takin/web/app/conf/ThreadPoolConfig.java
index 1292510638..7bd38d1518 100644
--- a/takin-web-app/src/main/java/io/shulie/takin/web/app/conf/ThreadPoolConfig.java
+++ b/takin-web-app/src/main/java/io/shulie/takin/web/app/conf/ThreadPoolConfig.java
@@ -34,7 +34,7 @@
*/
@Configuration
public class ThreadPoolConfig {
- /**
+ /**
* 用于定时任务
*
* @return 线程池
@@ -62,7 +62,21 @@ public ThreadPoolExecutor appRemoteApiFilterThreadPool() {
public ThreadPoolExecutor jobThreadPool() {
ThreadFactory nameThreadFactory = new ThreadFactoryBuilder().setNameFormat("job-%d").build();
return new ThreadPoolExecutor(20, 40, 10L, TimeUnit.SECONDS, new ArrayBlockingQueue<>(5000), nameThreadFactory,
- new ThreadPoolExecutor.AbortPolicy());
+ new ThreadPoolExecutor.AbortPolicy());
+ }
+
+ @Bean(name = "pressureResourceThreadPool")
+ public ThreadPoolExecutor pressureResouceThreadPool() {
+ ThreadFactory nameThreadFactory = new ThreadFactoryBuilder().setNameFormat("pressureResourceThreadPool-%d").build();
+ return new ThreadPoolExecutor(20, 40, 10L, TimeUnit.SECONDS, new ArrayBlockingQueue<>(5000), nameThreadFactory,
+ new ThreadPoolExecutor.AbortPolicy());
+ }
+
+ @Bean(name = "simpleFutureThreadPool")
+ public ThreadPoolExecutor simpleFutureThreadPool() {
+ ThreadFactory nameThreadFactory = new ThreadFactoryBuilder().setNameFormat("simpleFutureThreadPool-job-%d").build();
+ return new ThreadPoolExecutor(5, 10, 10L, TimeUnit.SECONDS, new ArrayBlockingQueue<>(5000), nameThreadFactory,
+ new ThreadPoolExecutor.AbortPolicy());
}
/**
@@ -98,7 +112,7 @@ public ThreadPoolExecutor remoteApiThreadPool() {
public ThreadPoolExecutor traceManageThreadPool() {
ThreadFactory nameThreadFactory = new ThreadFactoryBuilder().setNameFormat("job-trace-%d").build();
return new ThreadPoolExecutor(5, 10, 10L, TimeUnit.SECONDS, new ArrayBlockingQueue<>(5000), nameThreadFactory,
- new ThreadPoolExecutor.AbortPolicy());
+ new ThreadPoolExecutor.AbortPolicy());
}
/**
@@ -110,10 +124,10 @@ public ThreadPoolExecutor traceManageThreadPool() {
public ThreadPoolExecutor collectDataThreadPool() {
ThreadFactory nameThreadFactory = new ThreadFactoryBuilder().setNameFormat("job-collect-data-%d").build();
return new ThreadPoolExecutor(5, 10, 20L, TimeUnit.SECONDS, new ArrayBlockingQueue<>(5000), nameThreadFactory,
- new ThreadPoolExecutor.AbortPolicy());
+ new ThreadPoolExecutor.AbortPolicy());
}
- @Bean(name = "collectDataThreadPool_one")
+ @Bean(name = "collectDataThreadPool_one")
public ThreadPoolExecutor collectDataThreadPool_one() {
ThreadFactory nameThreadFactory = new ThreadFactoryBuilder().setNameFormat("job-collect-data-two-%d").build();
return new ThreadPoolExecutor(10, 50, 20L, TimeUnit.SECONDS, new ArrayBlockingQueue<>(5000), nameThreadFactory,
@@ -133,7 +147,7 @@ public ThreadPoolExecutor collectDataThreadPool_three() {
return new ThreadPoolExecutor(10, 50, 20L, TimeUnit.SECONDS, new ArrayBlockingQueue<>(5000), nameThreadFactory,
new ThreadPoolExecutor.AbortPolicy());
}
-
+
/**
* 漏数验证单独做
*
@@ -143,7 +157,7 @@ public ThreadPoolExecutor collectDataThreadPool_three() {
public ThreadPoolExecutor showdownVerifyThreadPool() {
ThreadFactory nameThreadFactory = new ThreadFactoryBuilder().setNameFormat("job-showdown-verify-%d").build();
return new ThreadPoolExecutor(5, 10, 20L, TimeUnit.SECONDS, new ArrayBlockingQueue<>(5000), nameThreadFactory,
- new ThreadPoolExecutor.AbortPolicy());
+ new ThreadPoolExecutor.AbortPolicy());
}
/**
@@ -156,10 +170,10 @@ public ThreadPoolExecutor showdownVerifyThreadPool() {
public ThreadPoolExecutor reportSummaryThreadPool() {
ThreadFactory nameThreadFactory = new ThreadFactoryBuilder().setNameFormat("job-report-summary-%d").build();
return new ThreadPoolExecutor(10, 20, 20L, TimeUnit.SECONDS, new ArrayBlockingQueue<>(10000), nameThreadFactory,
- new ThreadPoolExecutor.AbortPolicy());
+ new ThreadPoolExecutor.AbortPolicy());
}
-
- @Bean(name = "reportSummaryThreadPool_one")
+
+ @Bean(name = "reportSummaryThreadPool_one")
public ThreadPoolExecutor reportSummaryThreadPool_one() {
ThreadFactory nameThreadFactory = new ThreadFactoryBuilder().setNameFormat("job-report-summary_one-%d").build();
return new ThreadPoolExecutor(10, 20, 20L, TimeUnit.SECONDS, new ArrayBlockingQueue<>(5000), nameThreadFactory,
@@ -179,7 +193,7 @@ public ThreadPoolExecutor reportSummaryThreadPool_three() {
return new ThreadPoolExecutor(10, 20, 20L, TimeUnit.SECONDS, new ArrayBlockingQueue<>(5000), nameThreadFactory,
new ThreadPoolExecutor.AbortPolicy());
}
-
+
/**
* 四大报告Job分开线程池单独使用
*
@@ -190,10 +204,10 @@ public ThreadPoolExecutor reportSummaryThreadPool_three() {
public ThreadPoolExecutor reportTpsThreadPool() {
ThreadFactory nameThreadFactory = new ThreadFactoryBuilder().setNameFormat("job-report-tps-%d").build();
return new ThreadPoolExecutor(10, 20, 20L, TimeUnit.SECONDS, new ArrayBlockingQueue<>(10000), nameThreadFactory,
- new ThreadPoolExecutor.AbortPolicy());
+ new ThreadPoolExecutor.AbortPolicy());
}
-
- @Bean(name = "reportTpsThreadPool_one")
+
+ @Bean(name = "reportTpsThreadPool_one")
public ThreadPoolExecutor reportTpsThreadPool_one() {
ThreadFactory nameThreadFactory = new ThreadFactoryBuilder().setNameFormat("job-report-tps-one-%d").build();
return new ThreadPoolExecutor(10, 20, 20L, TimeUnit.SECONDS, new ArrayBlockingQueue<>(5000), nameThreadFactory,
@@ -206,7 +220,7 @@ public ThreadPoolExecutor reportTpsThreadPool_two() {
return new ThreadPoolExecutor(10, 20, 20L, TimeUnit.SECONDS, new ArrayBlockingQueue<>(5000), nameThreadFactory,
new ThreadPoolExecutor.AbortPolicy());
}
-
+
/**
* 四大报告Job分开线程池单独使用
*
@@ -217,10 +231,10 @@ public ThreadPoolExecutor reportTpsThreadPool_two() {
public ThreadPoolExecutor reportFinishThreadPool() {
ThreadFactory nameThreadFactory = new ThreadFactoryBuilder().setNameFormat("job-report-finish-%d").build();
return new ThreadPoolExecutor(10, 20, 20L, TimeUnit.SECONDS, new ArrayBlockingQueue<>(10000), nameThreadFactory,
- new ThreadPoolExecutor.AbortPolicy());
+ new ThreadPoolExecutor.AbortPolicy());
}
-
- @Bean(name = "reportFinishThreadPool_one")
+
+ @Bean(name = "reportFinishThreadPool_one")
public ThreadPoolExecutor reportFinishThreadPool_one() {
ThreadFactory nameThreadFactory = new ThreadFactoryBuilder().setNameFormat("job-report-finish-one-%d").build();
return new ThreadPoolExecutor(10, 20, 20L, TimeUnit.SECONDS, new ArrayBlockingQueue<>(5000), nameThreadFactory,
@@ -233,7 +247,7 @@ public ThreadPoolExecutor reportFinishThreadPool_two() {
return new ThreadPoolExecutor(10, 20, 20L, TimeUnit.SECONDS, new ArrayBlockingQueue<>(5000), nameThreadFactory,
new ThreadPoolExecutor.AbortPolicy());
}
-
+
/**
* 四大报告Job分开线程池单独使用
*
@@ -244,10 +258,10 @@ public ThreadPoolExecutor reportFinishThreadPool_two() {
public ThreadPoolExecutor reportMachineThreadPool() {
ThreadFactory nameThreadFactory = new ThreadFactoryBuilder().setNameFormat("job-report-machine-%d").build();
return new ThreadPoolExecutor(10, 20, 20L, TimeUnit.SECONDS, new ArrayBlockingQueue<>(10000), nameThreadFactory,
- new ThreadPoolExecutor.AbortPolicy());
+ new ThreadPoolExecutor.AbortPolicy());
}
-
- @Bean(name = "reportMachineThreadPool_one")
+
+ @Bean(name = "reportMachineThreadPool_one")
public ThreadPoolExecutor reportMachineThreadPool_one() {
ThreadFactory nameThreadFactory = new ThreadFactoryBuilder().setNameFormat("job-report-machine-one-%d").build();
return new ThreadPoolExecutor(10, 20, 20L, TimeUnit.SECONDS, new ArrayBlockingQueue<>(5000), nameThreadFactory,
@@ -260,7 +274,7 @@ public ThreadPoolExecutor reportMachineThreadPool_two() {
return new ThreadPoolExecutor(10, 20, 20L, TimeUnit.SECONDS, new ArrayBlockingQueue<>(5000), nameThreadFactory,
new ThreadPoolExecutor.AbortPolicy());
}
-
+
/**
* 仅链路调试用的job
*
@@ -270,14 +284,14 @@ public ThreadPoolExecutor reportMachineThreadPool_two() {
public ThreadPoolExecutor fastDebug() {
ThreadFactory nameThreadFactory = new ThreadFactoryBuilder().setNameFormat("fast-debug-%d").build();
return new ThreadPoolExecutor(5, 10, 20L, TimeUnit.SECONDS, new ArrayBlockingQueue<>(2000), nameThreadFactory,
- new ThreadPoolExecutor.AbortPolicy());
+ new ThreadPoolExecutor.AbortPolicy());
}
@Bean(name = "modifyMonitorThreadPool")
public ThreadPoolExecutor modifyMonitorExecutor() {
ThreadFactory nameThreadFactory = new ThreadFactoryBuilder().setNameFormat("modify-monitor-%d").build();
return new ThreadPoolExecutor(5, 5, 60L, TimeUnit.SECONDS, new ArrayBlockingQueue<>(100), nameThreadFactory,
- new ThreadPoolExecutor.AbortPolicy());
+ new ThreadPoolExecutor.AbortPolicy());
}
@Bean(name = "schedulerPool")
@@ -285,7 +299,7 @@ public TaskScheduler scheduler() {
ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
taskScheduler.setPoolSize(20);
ThreadFactory threadFactory = new BasicThreadFactory.Builder().namingPattern("pradar-scheduler-thread-%d")
- .daemon(true).build();
+ .daemon(true).build();
taskScheduler.setThreadFactory(threadFactory);
taskScheduler.setRejectedExecutionHandler(new ThreadPoolExecutor.AbortPolicy());
return taskScheduler;
@@ -295,29 +309,29 @@ public TaskScheduler scheduler() {
public ThreadPoolExecutor runShellTaskExecutor() {
ThreadFactory nameThreadFactory = new ThreadFactoryBuilder().setNameFormat("script-thread-%d").build();
return new ThreadPoolExecutor(5, 5, 60L, TimeUnit.SECONDS, new ArrayBlockingQueue<>(100), nameThreadFactory,
- new ThreadPoolExecutor.AbortPolicy());
+ new ThreadPoolExecutor.AbortPolicy());
}
@Bean(name = "loadDataThreadPool")
public ThreadPoolExecutor loadDataTaskExecutor() {
ThreadFactory nameThreadFactory = new ThreadFactoryBuilder().setNameFormat("loaddata-thread-%d").build();
return new ThreadPoolExecutor(5, 5, 60L, TimeUnit.SECONDS, new ArrayBlockingQueue<>(100), nameThreadFactory,
- new ThreadPoolExecutor.AbortPolicy());
+ new ThreadPoolExecutor.AbortPolicy());
}
@Bean(name = "agentDataThreadPool")
public ThreadPoolExecutor agentDataTaskExecutor() {
ThreadFactory nameThreadFactory = new ThreadFactoryBuilder().setNameFormat("agentdata-thread-%d").build();
return new ThreadPoolExecutor(5, 5, 60L, TimeUnit.SECONDS, new ArrayBlockingQueue<>(10000), nameThreadFactory,
- new ThreadPoolExecutor.AbortPolicy());
+ new ThreadPoolExecutor.AbortPolicy());
}
@Bean(name = "backgroundMonitorThreadPool")
public ThreadPoolExecutor backgroundMonitorThreadPool() {
ThreadFactory nameThreadFactory = new ThreadFactoryBuilder().setNameFormat("background-monitor-thread-%d")
- .build();
+ .build();
return new ThreadPoolExecutor(5, 5, 60L, TimeUnit.SECONDS, new ArrayBlockingQueue<>(10000), nameThreadFactory,
- new ThreadPoolExecutor.AbortPolicy());
+ new ThreadPoolExecutor.AbortPolicy());
}
@Bean("asyncExecuteScriptThreadPool")
@@ -345,7 +359,7 @@ public Executor myAsync() {
public ThreadPoolExecutor runOPSShellTaskExecutor() {
ThreadFactory nameThreadFactory = new ThreadFactoryBuilder().setNameFormat("ops-script-thread-%d").build();
return new ThreadPoolExecutor(1, 5, 60L, TimeUnit.SECONDS, new ArrayBlockingQueue<>(100), nameThreadFactory,
- new ThreadPoolExecutor.AbortPolicy());
+ new ThreadPoolExecutor.AbortPolicy());
}
@Primary
@@ -387,7 +401,7 @@ public HttpMessageConverters restFileDownloadSupport() {
public ThreadPoolExecutor queryAsyncThreadPool() {
ThreadFactory nameThreadFactory = new ThreadFactoryBuilder().setNameFormat("query-async-thread-%d").build();
return new ThreadPoolExecutor(1, 10, 0, TimeUnit.SECONDS, new LinkedBlockingQueue<>(100), nameThreadFactory,
- new ThreadPoolExecutor.AbortPolicy());
+ new ThreadPoolExecutor.AbortPolicy());
}
@Value("${poolConfig.e2e.coreSize: 50}")
@@ -408,7 +422,7 @@ public ThreadPoolExecutor queryAsyncThreadPool() {
public ThreadPoolExecutor e2eThreadPool() {
ThreadFactory nameThreadFactory = new ThreadFactoryBuilder().setNameFormat("e2e-job-%d").build();
return new ThreadPoolExecutor(e2eCoreSize, e2eMaxSize, 60L, TimeUnit.SECONDS,
- new ArrayBlockingQueue<>(e2eQueueSize), nameThreadFactory, new ThreadPoolExecutor.AbortPolicy());
+ new ArrayBlockingQueue<>(e2eQueueSize), nameThreadFactory, new ThreadPoolExecutor.AbortPolicy());
}
/**
@@ -420,7 +434,7 @@ public ThreadPoolExecutor e2eThreadPool() {
public ThreadPoolExecutor agentAggregationThreadPool() {
ThreadFactory nameThreadFactory = new ThreadFactoryBuilder().setNameFormat("agent-aggregation-%d").build();
return new ThreadPoolExecutor(1, 1, 0, TimeUnit.SECONDS, new LinkedBlockingQueue<>(100),
- nameThreadFactory, new ThreadPoolExecutor.AbortPolicy());
+ nameThreadFactory, new ThreadPoolExecutor.AbortPolicy());
}
/**
@@ -433,7 +447,7 @@ public ThreadPoolExecutor middlewareResolverThreadPool() {
final int coreSize = Runtime.getRuntime().availableProcessors();
ThreadFactory nameThreadFactory = new ThreadFactoryBuilder().setNameFormat("middleware-resolver-%d").build();
return new ThreadPoolExecutor(coreSize, coreSize * 2, 0, TimeUnit.SECONDS, new LinkedBlockingQueue<>(100),
- nameThreadFactory, new ThreadPoolExecutor.AbortPolicy());
+ nameThreadFactory, new ThreadPoolExecutor.AbortPolicy());
}
/**
@@ -446,8 +460,8 @@ public ExecutorService agentHeartbeatThreadPool() {
final int coreSize = Runtime.getRuntime().availableProcessors();
ThreadFactory nameThreadFactory = new ThreadFactoryBuilder().setNameFormat("agent-heartbeat-%d").build();
return TtlExecutors.getTtlExecutorService(
- new ThreadPoolExecutor(coreSize, coreSize * 2, 0, TimeUnit.SECONDS, new LinkedBlockingQueue<>(100),
- nameThreadFactory, new ThreadPoolExecutor.DiscardPolicy()));
+ new ThreadPoolExecutor(coreSize, coreSize * 2, 0, TimeUnit.SECONDS, new LinkedBlockingQueue<>(100),
+ nameThreadFactory, new ThreadPoolExecutor.DiscardPolicy()));
}
/**
@@ -475,7 +489,7 @@ public ThreadPoolTaskExecutor springSessionRedisTaskExecutor() {
public ThreadPoolExecutor stopTaskExecutor() {
ThreadFactory nameThreadFactory = new ThreadFactoryBuilder().setNameFormat("stop-thread-%d").build();
return new ThreadPoolExecutor(10, 20, 60L, TimeUnit.SECONDS, new ArrayBlockingQueue<>(100), nameThreadFactory,
- new ThreadPoolExecutor.DiscardOldestPolicy());
+ new ThreadPoolExecutor.DiscardOldestPolicy());
}
/**
@@ -488,7 +502,7 @@ public ThreadPoolExecutor stopTaskExecutor() {
public ThreadPoolExecutor bigFileThreadPool() {
ThreadFactory nameThreadFactory = new ThreadFactoryBuilder().setNameFormat("big-file-thread-%d").build();
return new ThreadPoolExecutor(10, 20, 60L, TimeUnit.SECONDS, new ArrayBlockingQueue<>(5000), nameThreadFactory,
- new ThreadPoolExecutor.AbortPolicy());
+ new ThreadPoolExecutor.AbortPolicy());
}
/**
@@ -498,15 +512,15 @@ public ThreadPoolExecutor bigFileThreadPool() {
public ExecutorService cloudCallbackThreadPool() {
ThreadFactory nameThreadFactory = new ThreadFactoryBuilder().setNameFormat("cloud-callback-%d").build();
return TtlExecutors.getTtlExecutorService(
- new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60L, TimeUnit.SECONDS,
- new SynchronousQueue<>(), nameThreadFactory));
+ new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60L, TimeUnit.SECONDS,
+ new SynchronousQueue<>(), nameThreadFactory));
}
@Bean(name = "dataCalibration")
public ExecutorService dataCalibrationExecutor() {
ThreadFactory nameThreadFactory = new ThreadFactoryBuilder().setNameFormat("data-calibration-%d").build();
return TtlExecutors.getTtlExecutorService(new ThreadPoolExecutor(10, 20, 60L, TimeUnit.SECONDS,
- new ArrayBlockingQueue<>(1000), nameThreadFactory, new WaitingRejectedExecutionHandler()));
+ new ArrayBlockingQueue<>(1000), nameThreadFactory, new WaitingRejectedExecutionHandler()));
}
private static class WaitingRejectedExecutionHandler implements RejectedExecutionHandler {
@@ -519,6 +533,7 @@ public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
}
}
}
+
/**
* webIDE数据入库处理线程池
*
@@ -537,7 +552,7 @@ public ThreadPoolExecutor performanceDebugThreadPool() {
final int coreSize = Runtime.getRuntime().availableProcessors();
ThreadFactory nameThreadFactory = new ThreadFactoryBuilder().setNameFormat("performance-debug-%d").build();
return new ThreadPoolExecutor(coreSize, coreSize * 2, 0, TimeUnit.SECONDS, new LinkedBlockingQueue<>(100),
- nameThreadFactory, new ThreadPoolExecutor.AbortPolicy());
+ nameThreadFactory, new ThreadPoolExecutor.AbortPolicy());
}
@Bean(name = "fileFailedPool")
@@ -545,6 +560,6 @@ public ThreadPoolExecutor fileFailed() {
int coreSize = Runtime.getRuntime().availableProcessors();
ThreadFactory nameThreadFactory = new ThreadFactoryBuilder().setNameFormat("file-failed-%d").build();
return new ThreadPoolExecutor(coreSize, coreSize * 2, 0,
- TimeUnit.SECONDS, new LinkedBlockingQueue<>(400), nameThreadFactory, new ThreadPoolExecutor.AbortPolicy());
+ TimeUnit.SECONDS, new LinkedBlockingQueue<>(400), nameThreadFactory, new ThreadPoolExecutor.AbortPolicy());
}
}
diff --git a/takin-web-app/src/main/java/io/shulie/takin/web/app/conf/mybatis/TakinTenantLineInnerInterceptor.java b/takin-web-app/src/main/java/io/shulie/takin/web/app/conf/mybatis/TakinTenantLineInnerInterceptor.java
index e39399e1ab..5817c4ba00 100644
--- a/takin-web-app/src/main/java/io/shulie/takin/web/app/conf/mybatis/TakinTenantLineInnerInterceptor.java
+++ b/takin-web-app/src/main/java/io/shulie/takin/web/app/conf/mybatis/TakinTenantLineInnerInterceptor.java
@@ -151,7 +151,9 @@ public class TakinTenantLineInnerInterceptor extends TenantLineInnerInterceptor
"t_warn_detail",
"t_pressure_task_variety",
"t_pressure_task_callback",
- "t_interface_performance_result"
+ "t_interface_performance_result",
+ "t_tro_dept_level_name",
+ "t_tenant_resource"
};
private String[] tableArrWithoutUserId = new String[] {
diff --git a/takin-web-app/src/main/resources/application.properties b/takin-web-app/src/main/resources/application.properties
index fea8b1408c..4e72e7d67a 100644
--- a/takin-web-app/src/main/resources/application.properties
+++ b/takin-web-app/src/main/resources/application.properties
@@ -90,6 +90,9 @@ mybatis-plus.configuration.map-underscore-to-camel-case=true
mybatis-plus.mapper-locations[0]=classpath*:com/pamirs/takin/entity/mapper/**/*.xml
mybatis-plus.mapper-locations[1]=classpath*:mappers/**/*.xml
+takin.config.nacos.enbale=nacos
+takin.config.nacos.addr=192.168.1.99:8848
+
takin.config.zk.addr=192.168.1.154:2181
spring.performance.influxdb.database=performance
spring.influxdb.url=http://${resource.influxdb.host:127.0.0.1}:${resource.influxdb.port:8086}
@@ -168,4 +171,5 @@ cloud.influxdb.password: pradar
cloud.influxdb.database: crank
takin-web.server.config={"loginType": 3}
-maven.pull.job.enable: true
\ No newline at end of file
+maven.pull.job.enable: true
+agent.manager.host=""
\ No newline at end of file
diff --git a/takin-web-app/src/main/resources/kafka-sdk.properties b/takin-web-app/src/main/resources/kafka-sdk.properties
new file mode 100644
index 0000000000..cdde69c802
--- /dev/null
+++ b/takin-web-app/src/main/resources/kafka-sdk.properties
@@ -0,0 +1,3 @@
+kafka.sdk.switch=true
+kafka.sdk.bootstrap=192.168.1.61:9092
+kafka.poll.timeout=2000
diff --git a/takin-web-app/src/test/java/io/shulie/takin/web/biz/util/ZkHelperTest.java b/takin-web-app/src/test/java/io/shulie/takin/web/biz/util/ZkHelperTest.java
index 8cce4239fb..b59d52c1eb 100644
--- a/takin-web-app/src/test/java/io/shulie/takin/web/biz/util/ZkHelperTest.java
+++ b/takin-web-app/src/test/java/io/shulie/takin/web/biz/util/ZkHelperTest.java
@@ -1,7 +1,7 @@
package io.shulie.takin.web.biz.util;
import io.shulie.takin.web.app.Application;
-import io.shulie.takin.web.biz.utils.ZkHelper;
+import io.shulie.takin.web.biz.utils.PradarConfigPusher;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
@@ -17,7 +17,7 @@
public class ZkHelperTest {
@Autowired
- private ZkHelper zkHelper;
+ private PradarConfigPusher zkHelper;
@Test
public void test() {
diff --git a/takin-web-biz-service/pom.xml b/takin-web-biz-service/pom.xml
index f61bd4e413..5f574d3633 100644
--- a/takin-web-biz-service/pom.xml
+++ b/takin-web-biz-service/pom.xml
@@ -5,7 +5,7 @@
takin-web
io.shulie.takin
- takin-web-5.9.0
+ takin-web-5.10.2.2
4.0.0
@@ -38,6 +38,10 @@
slf4j-log4j12
org.slf4j
+
+ fastjson
+ com.alibaba
+
@@ -47,6 +51,12 @@
io.shulie.takin
takin-common-exception-starter
+
+
+ fastjson
+ com.alibaba
+
+
io.shulie.takin
@@ -70,6 +80,10 @@
cn.hutool
hutool-all
+
+ fastjson
+ com.alibaba
+
@@ -83,6 +97,14 @@
fastjson
com.alibaba
+
+ logback-classic
+ ch.qos.logback
+
+
+ logback-core
+ ch.qos.logback
+
@@ -111,6 +133,10 @@
guava
com.google.guava
+
+ fastjson
+ com.alibaba
+
@@ -142,6 +168,10 @@
jul-to-slf4j
org.slf4j
+
+ logback-classic
+ ch.qos.logback
+
@@ -170,6 +200,18 @@
commons-io
commons-io
+
+ fastjson
+ com.alibaba
+
+
+ logback-classic
+ ch.qos.logback
+
+
+ logback-core
+ ch.qos.logback
+
@@ -269,6 +311,12 @@
io.shulie.instrument.module
module-pradar-core
+
+
+ fastjson
+ com.alibaba
+
+
org.springframework.boot
@@ -301,6 +349,17 @@
freemarker
+
+ com.alibaba.nacos
+ nacos-client
+ 2.0.4
+
+
+ com.alibaba
+ fastjson
+ ${fastjson.version}
+
+
diff --git a/takin-web-biz-service/src/main/java/io/shulie/takin/cloud/biz/collector/ScheduleConfig.java b/takin-web-biz-service/src/main/java/io/shulie/takin/cloud/biz/collector/ScheduleConfig.java
index c91c1e1a25..aa4d2ba1c7 100644
--- a/takin-web-biz-service/src/main/java/io/shulie/takin/cloud/biz/collector/ScheduleConfig.java
+++ b/takin-web-biz-service/src/main/java/io/shulie/takin/cloud/biz/collector/ScheduleConfig.java
@@ -108,4 +108,9 @@ public Executor jmeterHeartbeatAsyncServiceExecutor() {
public ScheduledExecutorService pressureStopExecutor() {
return Executors.newScheduledThreadPool(5, new NamedThreadFactory("pressure_stop", true));
}
+
+ @Bean(name = "kafkaReceivePool")
+ public ScheduledExecutorService kafkaReceiveExecutor() {
+ return Executors.newScheduledThreadPool(10, new NamedThreadFactory("kafka_receive", true));
+ }
}
diff --git a/takin-web-biz-service/src/main/java/io/shulie/takin/cloud/biz/input/scenemanage/SceneManageQueryInput.java b/takin-web-biz-service/src/main/java/io/shulie/takin/cloud/biz/input/scenemanage/SceneManageQueryInput.java
index 677872201f..daf2f0c6ab 100644
--- a/takin-web-biz-service/src/main/java/io/shulie/takin/cloud/biz/input/scenemanage/SceneManageQueryInput.java
+++ b/takin-web-biz-service/src/main/java/io/shulie/takin/cloud/biz/input/scenemanage/SceneManageQueryInput.java
@@ -32,4 +32,10 @@ public class SceneManageQueryInput extends PagingContextExt {
private String lastPtEndTime;
private Integer isArchive;
+
+ private Long deptId;
+
+ private List userIdList;
+
+ private List deptIdList;
}
diff --git a/takin-web-biz-service/src/main/java/io/shulie/takin/cloud/biz/input/scenemanage/SceneManageWrapperInput.java b/takin-web-biz-service/src/main/java/io/shulie/takin/cloud/biz/input/scenemanage/SceneManageWrapperInput.java
index 20ecd8f742..1d0d393cc6 100644
--- a/takin-web-biz-service/src/main/java/io/shulie/takin/cloud/biz/input/scenemanage/SceneManageWrapperInput.java
+++ b/takin-web-biz-service/src/main/java/io/shulie/takin/cloud/biz/input/scenemanage/SceneManageWrapperInput.java
@@ -97,6 +97,8 @@ public class SceneManageWrapperInput extends ContextExt {
private Long operateId;
+ private Long deptId;
+
private String operateName;
private String machineId;
diff --git a/takin-web-biz-service/src/main/java/io/shulie/takin/cloud/biz/output/scene/manage/SceneManageListOutput.java b/takin-web-biz-service/src/main/java/io/shulie/takin/cloud/biz/output/scene/manage/SceneManageListOutput.java
index 33566ac6f0..125601e926 100644
--- a/takin-web-biz-service/src/main/java/io/shulie/takin/cloud/biz/output/scene/manage/SceneManageListOutput.java
+++ b/takin-web-biz-service/src/main/java/io/shulie/takin/cloud/biz/output/scene/manage/SceneManageListOutput.java
@@ -46,4 +46,7 @@ public class SceneManageListOutput extends ContextExt {
@ApiModelProperty(value = "脚本解析结果")
private String scriptAnalysisResult;
+
+ @ApiModelProperty(value = "部门id")
+ private Long deptId;
}
diff --git a/takin-web-biz-service/src/main/java/io/shulie/takin/cloud/biz/output/scene/manage/SceneManageWrapperOutput.java b/takin-web-biz-service/src/main/java/io/shulie/takin/cloud/biz/output/scene/manage/SceneManageWrapperOutput.java
index 8cac0b6cea..9835937584 100644
--- a/takin-web-biz-service/src/main/java/io/shulie/takin/cloud/biz/output/scene/manage/SceneManageWrapperOutput.java
+++ b/takin-web-biz-service/src/main/java/io/shulie/takin/cloud/biz/output/scene/manage/SceneManageWrapperOutput.java
@@ -145,6 +145,8 @@ public class SceneManageWrapperOutput extends ContextExt {
private String machineId;
private Integer machineType;
+ private Long deptId;
+
@Data
@EqualsAndHashCode(callSuper = true)
public static class SceneBusinessActivityRefOutput extends SceneBusinessActivityRefBean {
diff --git a/takin-web-biz-service/src/main/java/io/shulie/takin/cloud/biz/service/scene/impl/CloudSceneManageServiceImpl.java b/takin-web-biz-service/src/main/java/io/shulie/takin/cloud/biz/service/scene/impl/CloudSceneManageServiceImpl.java
index 6ef6c091c8..025bf2539a 100644
--- a/takin-web-biz-service/src/main/java/io/shulie/takin/cloud/biz/service/scene/impl/CloudSceneManageServiceImpl.java
+++ b/takin-web-biz-service/src/main/java/io/shulie/takin/cloud/biz/service/scene/impl/CloudSceneManageServiceImpl.java
@@ -392,6 +392,7 @@ public PageInfo queryPageList(SceneManageQueryInput query
setTenantId(t.getTenantId());
setUserId(t.getUserId());
setUserName(null);
+ setDeptId(t.getDeptId());
setScriptAnalysisResult(t.getScriptAnalysisResult());
}}).collect(Collectors.toList());
Map threadNum = new HashMap<>(1);
@@ -1092,6 +1093,7 @@ private void fillBase(SceneManageWrapperOutput wrapperOutput, SceneManageEntity
wrapperOutput.setFeatures(sceneManageResult.getFeatures());
wrapperOutput.setScriptAnalysisResult(sceneManageResult.getScriptAnalysisResult());
wrapperOutput.setPtConfig(sceneManageResult.getPtConfig());
+ wrapperOutput.setDeptId(sceneManageResult.getDeptId());
}
/**
@@ -1208,6 +1210,7 @@ private SceneManageCreateOrUpdateParam buildSceneManage(SceneManageWrapperInput
param.setType(wrapperVO.getType() == null ? 0 : wrapperVO.getType());
param.setFeatures(wrapperVO.getFeatures());
param.setUserId(wrapperVO.getUserId());
+ param.setDeptId(wrapperVO.getDeptId());
param.setTenantId(wrapperVO.getTenantId());
param.setEnvCode(wrapperVO.getEnvCode());
return param;
diff --git a/takin-web-biz-service/src/main/java/io/shulie/takin/cloud/biz/service/scene/impl/CloudSceneServiceImpl.java b/takin-web-biz-service/src/main/java/io/shulie/takin/cloud/biz/service/scene/impl/CloudSceneServiceImpl.java
index d71025ff41..8cb05e906c 100644
--- a/takin-web-biz-service/src/main/java/io/shulie/takin/cloud/biz/service/scene/impl/CloudSceneServiceImpl.java
+++ b/takin-web-biz-service/src/main/java/io/shulie/takin/cloud/biz/service/scene/impl/CloudSceneServiceImpl.java
@@ -45,6 +45,7 @@
import io.shulie.takin.adapter.api.model.response.scenemanage.SceneRequest.File;
import io.shulie.takin.adapter.api.model.response.scenemanage.SceneRequest.Goal;
import io.shulie.takin.adapter.api.model.response.scenemanage.SceneRequest.MonitoringGoal;
+import io.shulie.takin.web.ext.util.WebPluginUtils;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.stereotype.Service;
@@ -128,7 +129,9 @@ public Boolean update(SceneRequest in) {
}
// 1. 创建场景
int updateRows = updateStepScene(in.getBasicInfo(), in.getConfig(), in.getAnalysisResult(), in.getDataValidation());
- if (updateRows == 0) {return false;}
+ if (updateRows == 0) {
+ return false;
+ }
if (updateRows == 1) {
long sceneId = in.getBasicInfo().getSceneId();
// 2. 更新场景&业务活动关联关系
@@ -168,9 +171,9 @@ public SceneDetailV2Response detail(long sceneId) {
response.setDataValidation(getDataValidation(sceneId));
List monitoringGoal = getMonitoringGoal(sceneId);
response.setDestroyMonitoringGoal(
- monitoringGoal.stream().filter(t -> Integer.valueOf(0).equals(t.getType())).collect(Collectors.toList()));
+ monitoringGoal.stream().filter(t -> Integer.valueOf(0).equals(t.getType())).collect(Collectors.toList()));
response.setWarnMonitoringGoal(
- monitoringGoal.stream().filter(t -> !Integer.valueOf(0).equals(t.getType())).collect(Collectors.toList()));
+ monitoringGoal.stream().filter(t -> !Integer.valueOf(0).equals(t.getType())).collect(Collectors.toList()));
return response;
}
@@ -186,7 +189,8 @@ public BasicInfo getBasicInfo(long sceneId) {
SceneManageEntity scene = getScene(sceneId);
// 解析拓展字段
String featureString = scene.getFeatures();
- Map feature = JSONObject.parseObject(featureString, new TypeReference