Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
weixin_42566577
o2oa
提交
e8b27ba8
o2oa
项目概览
weixin_42566577
/
o2oa
与 Fork 源项目一致
Fork自
浙江兰德纵横网络技术股份有限公司 / o2oa
通知
1
Star
0
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
DevOps
流水线
流水线任务
计划
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
o2oa
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
DevOps
DevOps
流水线
流水线任务
计划
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
流水线任务
提交
Issue看板
体验新版 GitCode,发现更多精彩内容 >>
提交
e8b27ba8
编写于
9月 08, 2020
作者:
hlwwx
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
modify applications.java
上级
c68aff61
变更
1
隐藏空白更改
内联
并排
Showing
1 changed file
with
30 addition
and
5 deletion
+30
-5
o2server/x_base_core_project/src/main/java/com/x/base/core/project/Applications.java
...t/src/main/java/com/x/base/core/project/Applications.java
+30
-5
未找到文件。
o2server/x_base_core_project/src/main/java/com/x/base/core/project/Applications.java
浏览文件 @
e8b27ba8
...
...
@@ -15,6 +15,7 @@ import java.util.stream.Stream;
import
java.util.zip.CRC32
;
import
com.x.base.core.project.config.Config
;
import
com.x.base.core.project.config.Nodes
;
import
com.x.base.core.project.connection.ActionResponse
;
import
com.x.base.core.project.connection.CipherConnectionAction
;
import
com.x.base.core.project.connection.FilePart
;
...
...
@@ -26,6 +27,7 @@ import com.x.base.core.project.tools.DefaultCharset;
import
com.x.base.core.project.tools.ListTools
;
import
com.x.base.core.project.tools.StringTools
;
import
org.apache.commons.lang3.BooleanUtils
;
import
org.apache.commons.lang3.StringUtils
;
public
class
Applications
extends
ConcurrentHashMap
<
String
,
CopyOnWriteArrayList
<
Application
>>
{
...
...
@@ -602,12 +604,35 @@ public class Applications extends ConcurrentHashMap<String, CopyOnWriteArrayList
}
public
String
describeApi
(
String
name
)
throws
Exception
{
String
applicationName
=
this
.
findApplicationName
(
name
);
if
(
StringUtils
.
isEmpty
(
applicationName
))
{
throw
new
Exception
(
"getDescribe can not find application with name:"
+
name
+
"."
);
String
urlDescribeApiJson
=
""
;
if
(
name
.
equalsIgnoreCase
(
"x_program_center"
)||
name
.
equalsIgnoreCase
(
x_program_center
.
class
.
getName
()))
{
Nodes
nodes
=
Config
.
nodes
();
for
(
String
node
:
nodes
.
keySet
())
{
if
(
nodes
.
get
(
node
).
getCenter
().
getEnable
())
{
Integer
port
=
nodes
.
get
(
node
).
getCenter
().
getPort
();
StringBuffer
buffer
=
new
StringBuffer
();
if
(
BooleanUtils
.
isTrue
(
nodes
.
get
(
node
).
getCenter
().
getSslEnable
()))
{
buffer
.
append
(
"https://"
).
append
(
StringUtils
.
isNotEmpty
(
node
)
?
node
:
"127.0.0.1"
)
.
append
(
":"
+
port
);
}
else
{
buffer
.
append
(
"http://"
).
append
(
StringUtils
.
isNotEmpty
(
node
)
?
node
:
"127.0.0.1"
)
.
append
(
":"
+
port
);
}
buffer
.
append
(
"x_program_center/describe/api.json"
);
urlDescribeApiJson
=
buffer
.
toString
();
break
;
}
}
}
else
{
String
applicationName
=
this
.
findApplicationName
(
name
);
if
(
StringUtils
.
isEmpty
(
applicationName
))
{
throw
new
Exception
(
"getDescribe can not find application with name:"
+
name
+
"."
);
}
Application
application
=
this
.
randomWithWeight
(
applicationName
);
//return HttpConnection.getAsString(application.getUrlDescribeApiJson(), null);
urlDescribeApiJson
=
application
.
getUrlDescribeApiJson
();
}
Application
application
=
this
.
randomWithWeight
(
applicationName
);
return
HttpConnection
.
getAsString
(
application
.
getUrlDescribeApiJson
(),
null
);
return
HttpConnection
.
getAsString
(
urlDescribeApiJson
,
null
);
}
}
\ No newline at end of file
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录