Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
ghsby
o2oa
提交
9c278c51
o2oa
项目概览
ghsby
/
o2oa
落后 Fork 源项目 2880 个版本
Fork自
浙江兰德纵横网络技术股份有限公司 / o2oa
通知
1
Star
1
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,发现更多精彩内容 >>
提交
9c278c51
编写于
12月 14, 2022
作者:
Z
zhourui
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
更新index触发器,(0)表示在所有节点上执行
上级
9401bbf2
变更
17
显示空白变更内容
内联
并排
Showing
17 changed file
with
244 addition
and
300 deletion
+244
-300
o2server/x_query_service_processing/src/main/java/com/x/query/service/processing/jaxrs/touch/ActionHighFreqDocumentReset.java
...e/processing/jaxrs/touch/ActionHighFreqDocumentReset.java
+49
-32
o2server/x_query_service_processing/src/main/java/com/x/query/service/processing/jaxrs/touch/ActionHighFreqDocumentTouch.java
...e/processing/jaxrs/touch/ActionHighFreqDocumentTouch.java
+12
-4
o2server/x_query_service_processing/src/main/java/com/x/query/service/processing/jaxrs/touch/ActionHighFreqWorkCompletedReset.java
...cessing/jaxrs/touch/ActionHighFreqWorkCompletedReset.java
+12
-3
o2server/x_query_service_processing/src/main/java/com/x/query/service/processing/jaxrs/touch/ActionHighFreqWorkCompletedTouch.java
...cessing/jaxrs/touch/ActionHighFreqWorkCompletedTouch.java
+4
-2
o2server/x_query_service_processing/src/main/java/com/x/query/service/processing/jaxrs/touch/ActionHighFreqWorkReset.java
...rvice/processing/jaxrs/touch/ActionHighFreqWorkReset.java
+13
-3
o2server/x_query_service_processing/src/main/java/com/x/query/service/processing/jaxrs/touch/ActionHighFreqWorkTouch.java
...rvice/processing/jaxrs/touch/ActionHighFreqWorkTouch.java
+1
-2
o2server/x_query_service_processing/src/main/java/com/x/query/service/processing/jaxrs/touch/ActionLowFreqDocumentReset.java
...ce/processing/jaxrs/touch/ActionLowFreqDocumentReset.java
+11
-2
o2server/x_query_service_processing/src/main/java/com/x/query/service/processing/jaxrs/touch/ActionLowFreqDocumentTouch.java
...ce/processing/jaxrs/touch/ActionLowFreqDocumentTouch.java
+1
-2
o2server/x_query_service_processing/src/main/java/com/x/query/service/processing/jaxrs/touch/ActionLowFreqWorkCompletedReset.java
...ocessing/jaxrs/touch/ActionLowFreqWorkCompletedReset.java
+43
-32
o2server/x_query_service_processing/src/main/java/com/x/query/service/processing/jaxrs/touch/ActionLowFreqWorkCompletedTouch.java
...ocessing/jaxrs/touch/ActionLowFreqWorkCompletedTouch.java
+1
-2
o2server/x_query_service_processing/src/main/java/com/x/query/service/processing/jaxrs/touch/ActionLowFreqWorkReset.java
...ervice/processing/jaxrs/touch/ActionLowFreqWorkReset.java
+43
-32
o2server/x_query_service_processing/src/main/java/com/x/query/service/processing/jaxrs/touch/ActionLowFreqWorkTouch.java
...ervice/processing/jaxrs/touch/ActionLowFreqWorkTouch.java
+1
-2
o2server/x_query_service_processing/src/main/java/com/x/query/service/processing/jaxrs/touch/ActionOptimizeIndex.java
...y/service/processing/jaxrs/touch/ActionOptimizeIndex.java
+1
-2
o2server/x_query_service_processing/src/main/java/com/x/query/service/processing/jaxrs/touch/BaseAction.java
...om/x/query/service/processing/jaxrs/touch/BaseAction.java
+26
-9
o2server/x_query_service_processing/src/main/java/com/x/query/service/processing/jaxrs/touch/TouchAction.java
...m/x/query/service/processing/jaxrs/touch/TouchAction.java
+26
-26
o2server/x_query_service_processing/src/test/resources/hanlp.properties
...ry_service_processing/src/test/resources/hanlp.properties
+0
-3
o2server/x_query_service_processing/src/test/resources/test.json
...r/x_query_service_processing/src/test/resources/test.json
+0
-142
未找到文件。
o2server/x_query_service_processing/src/main/java/com/x/query/service/processing/jaxrs/touch/ActionHighFreqDocumentReset.java
浏览文件 @
9c278c51
package
com.x.query.service.processing.jaxrs.touch
;
import
java.util.ArrayList
;
import
java.util.List
;
import
org.apache.commons.lang3.StringUtils
;
import
com.x.base.core.container.EntityManagerContainer
;
import
com.x.base.core.container.factory.EntityManagerContainerFactory
;
import
com.x.base.core.entity.annotation.CheckRemoveType
;
...
...
@@ -14,6 +17,12 @@ import com.x.query.core.entity.index.State;
import
io.swagger.v3.oas.annotations.media.Schema
;
/**
* (0) AbstractJaxrsAction.EMPTY_SYMBOL 表示在有所节点上执行
*
* @author ray
*
*/
class
ActionHighFreqDocumentReset
extends
BaseAction
{
private
static
final
Logger
LOGGER
=
LoggerFactory
.
getLogger
(
ActionHighFreqDocumentReset
.
class
);
...
...
@@ -25,9 +34,16 @@ class ActionHighFreqDocumentReset extends BaseAction {
ActionResult
<
Wo
>
result
=
new
ActionResult
<>();
Wo
wo
=
new
Wo
();
wo
.
setValue
(
false
);
try
(
EntityManagerContainer
emc
=
EntityManagerContainerFactory
.
instance
().
create
())
{
List
<
State
>
list
=
emc
.
listEqualAndEqualAndEqual
(
State
.
class
,
State
.
NODE_FIELDNAME
,
node
,
List
<
State
>
list
=
new
ArrayList
<>();
if
(!
StringUtils
.
equals
(
node
,
EMPTY_SYMBOL
))
{
list
=
emc
.
listEqualAndEqualAndEqual
(
State
.
class
,
State
.
NODE_FIELDNAME
,
node
,
State
.
FREQ_FIELDNAME
,
State
.
FREQ_HIGH
,
State
.
TYPE_FIELDNAME
,
State
.
TYPE_DOCUMENT
);
}
else
{
list
=
emc
.
listEqualAndEqual
(
State
.
class
,
State
.
FREQ_FIELDNAME
,
State
.
FREQ_HIGH
,
State
.
TYPE_FIELDNAME
,
State
.
TYPE_DOCUMENT
);
}
if
(!
list
.
isEmpty
())
{
emc
.
beginTransaction
(
State
.
class
);
for
(
State
state
:
list
)
{
...
...
@@ -38,6 +54,7 @@ class ActionHighFreqDocumentReset extends BaseAction {
wo
.
setValue
(
true
);
}
}
result
.
setData
(
wo
);
return
result
;
}
...
...
o2server/x_query_service_processing/src/main/java/com/x/query/service/processing/jaxrs/touch/ActionHighFreqDocumentTouch.java
浏览文件 @
9c278c51
package
com.x.query.service.processing.jaxrs.touch
;
import
java.util.List
;
import
java.util.stream.Collectors
;
import
org.apache.commons.lang3.StringUtils
;
import
com.x.base.core.container.EntityManagerContainer
;
import
com.x.base.core.container.factory.EntityManagerContainerFactory
;
import
com.x.base.core.project.Application
;
import
com.x.base.core.project.Applications
;
import
com.x.base.core.project.connection.CipherConnectionAction
;
...
...
@@ -12,11 +13,19 @@ import com.x.base.core.project.http.EffectivePerson;
import
com.x.base.core.project.jaxrs.WrapBoolean
;
import
com.x.base.core.project.logger.Logger
;
import
com.x.base.core.project.logger.LoggerFactory
;
import
com.x.query.core.entity.index.State
;
import
com.x.query.service.processing.ThisApplication
;
import
com.x.query.service.processing.schedule.HighFreqDocument
;
import
io.swagger.v3.oas.annotations.media.Schema
;
/**
* (0) AbstractJaxrsAction.EMPTY_SYMBOL 表示在有所节点上执行
*
* @author ray
*
*/
class
ActionHighFreqDocumentTouch
extends
BaseAction
{
private
static
final
Logger
LOGGER
=
LoggerFactory
.
getLogger
(
ActionHighFreqDocumentTouch
.
class
);
...
...
@@ -27,8 +36,7 @@ class ActionHighFreqDocumentTouch extends BaseAction {
ActionResult
<
Wo
>
result
=
new
ActionResult
<>();
Wo
wo
=
new
Wo
();
wo
.
setValue
(
false
);
for
(
Application
application
:
ThisApplication
.
context
().
applications
()
.
get
(
ThisApplication
.
context
().
clazz
()))
{
for
(
Application
application
:
listApplication
(
node
))
{
if
(
StringUtils
.
equals
(
node
,
application
.
getNode
()))
{
String
url
=
application
.
getUrlJaxrsRoot
()
+
Applications
.
joinQueryUri
(
"fireschedule"
,
"classname"
,
HighFreqDocument
.
class
.
getName
());
...
...
o2server/x_query_service_processing/src/main/java/com/x/query/service/processing/jaxrs/touch/ActionHighFreqWorkCompletedReset.java
浏览文件 @
9c278c51
package
com.x.query.service.processing.jaxrs.touch
;
import
java.util.ArrayList
;
import
java.util.List
;
import
org.apache.commons.lang3.StringUtils
;
import
com.x.base.core.container.EntityManagerContainer
;
import
com.x.base.core.container.factory.EntityManagerContainerFactory
;
import
com.x.base.core.entity.annotation.CheckRemoveType
;
...
...
@@ -26,9 +29,15 @@ class ActionHighFreqWorkCompletedReset extends BaseAction {
Wo
wo
=
new
Wo
();
wo
.
setValue
(
false
);
try
(
EntityManagerContainer
emc
=
EntityManagerContainerFactory
.
instance
().
create
())
{
List
<
State
>
list
=
emc
.
listEqualAndEqualAndEqual
(
State
.
class
,
State
.
NODE_FIELDNAME
,
node
,
List
<
State
>
list
=
new
ArrayList
<>();
if
(!
StringUtils
.
equals
(
node
,
EMPTY_SYMBOL
))
{
list
=
emc
.
listEqualAndEqualAndEqual
(
State
.
class
,
State
.
NODE_FIELDNAME
,
node
,
State
.
FREQ_FIELDNAME
,
State
.
FREQ_HIGH
,
State
.
TYPE_FIELDNAME
,
State
.
TYPE_WORKCOMPLETED
);
}
else
{
list
=
emc
.
listEqualAndEqual
(
State
.
class
,
State
.
FREQ_FIELDNAME
,
State
.
FREQ_HIGH
,
State
.
TYPE_FIELDNAME
,
State
.
TYPE_WORKCOMPLETED
);
}
if
(!
list
.
isEmpty
())
{
emc
.
beginTransaction
(
State
.
class
);
for
(
State
state
:
list
)
{
...
...
o2server/x_query_service_processing/src/main/java/com/x/query/service/processing/jaxrs/touch/ActionHighFreqWorkCompletedTouch.java
浏览文件 @
9c278c51
package
com.x.query.service.processing.jaxrs.touch
;
import
java.util.List
;
import
java.util.stream.Collectors
;
import
org.apache.commons.lang3.StringUtils
;
import
com.x.base.core.container.EntityManagerContainer
;
...
...
@@ -27,8 +30,7 @@ class ActionHighFreqWorkCompletedTouch extends BaseAction {
ActionResult
<
Wo
>
result
=
new
ActionResult
<>();
Wo
wo
=
new
Wo
();
wo
.
setValue
(
false
);
for
(
Application
application
:
ThisApplication
.
context
().
applications
()
.
get
(
ThisApplication
.
context
().
clazz
()))
{
for
(
Application
application
:
listApplication
(
node
))
{
if
(
StringUtils
.
equals
(
node
,
application
.
getNode
()))
{
String
url
=
application
.
getUrlJaxrsRoot
()
+
Applications
.
joinQueryUri
(
"fireschedule"
,
"classname"
,
HighFreqWorkCompleted
.
class
.
getName
());
...
...
o2server/x_query_service_processing/src/main/java/com/x/query/service/processing/jaxrs/touch/ActionHighFreqWorkReset.java
浏览文件 @
9c278c51
package
com.x.query.service.processing.jaxrs.touch
;
import
java.util.ArrayList
;
import
java.util.List
;
import
org.apache.commons.lang3.StringUtils
;
import
com.x.base.core.container.EntityManagerContainer
;
import
com.x.base.core.container.factory.EntityManagerContainerFactory
;
import
com.x.base.core.entity.annotation.CheckRemoveType
;
...
...
@@ -26,9 +29,16 @@ class ActionHighFreqWorkReset extends BaseAction {
Wo
wo
=
new
Wo
();
wo
.
setValue
(
false
);
try
(
EntityManagerContainer
emc
=
EntityManagerContainerFactory
.
instance
().
create
())
{
List
<
State
>
list
=
emc
.
listEqualAndEqualAndEqual
(
State
.
class
,
State
.
NODE_FIELDNAME
,
node
,
List
<
State
>
list
=
new
ArrayList
<>();
if
(!
StringUtils
.
equals
(
node
,
EMPTY_SYMBOL
))
{
list
=
emc
.
listEqualAndEqualAndEqual
(
State
.
class
,
State
.
NODE_FIELDNAME
,
node
,
State
.
FREQ_FIELDNAME
,
State
.
FREQ_HIGH
,
State
.
TYPE_FIELDNAME
,
State
.
TYPE_WORK
);
}
else
{
list
=
emc
.
listEqualAndEqual
(
State
.
class
,
State
.
FREQ_FIELDNAME
,
State
.
FREQ_HIGH
,
State
.
TYPE_FIELDNAME
,
State
.
TYPE_WORK
);
}
if
(!
list
.
isEmpty
())
{
emc
.
beginTransaction
(
State
.
class
);
for
(
State
state
:
list
)
{
...
...
o2server/x_query_service_processing/src/main/java/com/x/query/service/processing/jaxrs/touch/ActionHighFreqWorkTouch.java
浏览文件 @
9c278c51
...
...
@@ -27,8 +27,7 @@ class ActionHighFreqWorkTouch extends BaseAction {
ActionResult
<
Wo
>
result
=
new
ActionResult
<>();
Wo
wo
=
new
Wo
();
wo
.
setValue
(
false
);
for
(
Application
application
:
ThisApplication
.
context
().
applications
()
.
get
(
ThisApplication
.
context
().
clazz
()))
{
for
(
Application
application
:
listApplication
(
node
))
{
if
(
StringUtils
.
equals
(
node
,
application
.
getNode
()))
{
String
url
=
application
.
getUrlJaxrsRoot
()
+
Applications
.
joinQueryUri
(
"fireschedule"
,
"classname"
,
HighFreqWork
.
class
.
getName
());
...
...
o2server/x_query_service_processing/src/main/java/com/x/query/service/processing/jaxrs/touch/ActionLowFreqDocumentReset.java
浏览文件 @
9c278c51
package
com.x.query.service.processing.jaxrs.touch
;
import
java.util.ArrayList
;
import
java.util.List
;
import
org.apache.commons.lang3.StringUtils
;
import
com.x.base.core.container.EntityManagerContainer
;
import
com.x.base.core.container.factory.EntityManagerContainerFactory
;
import
com.x.base.core.entity.annotation.CheckRemoveType
;
...
...
@@ -26,8 +29,14 @@ class ActionLowFreqDocumentReset extends BaseAction {
Wo
wo
=
new
Wo
();
wo
.
setValue
(
false
);
try
(
EntityManagerContainer
emc
=
EntityManagerContainerFactory
.
instance
().
create
())
{
List
<
State
>
list
=
emc
.
listEqualAndEqualAndEqual
(
State
.
class
,
State
.
NODE_FIELDNAME
,
node
,
List
<
State
>
list
=
new
ArrayList
<>();
if
(!
StringUtils
.
equals
(
node
,
EMPTY_SYMBOL
))
{
list
=
emc
.
listEqualAndEqualAndEqual
(
State
.
class
,
State
.
NODE_FIELDNAME
,
node
,
State
.
FREQ_FIELDNAME
,
State
.
FREQ_LOW
,
State
.
TYPE_FIELDNAME
,
State
.
TYPE_DOCUMENT
);
}
else
{
list
=
emc
.
listEqualAndEqual
(
State
.
class
,
State
.
FREQ_FIELDNAME
,
State
.
FREQ_LOW
,
State
.
TYPE_FIELDNAME
,
State
.
TYPE_DOCUMENT
);
}
if
(!
list
.
isEmpty
())
{
emc
.
beginTransaction
(
State
.
class
);
for
(
State
state
:
list
)
{
...
...
o2server/x_query_service_processing/src/main/java/com/x/query/service/processing/jaxrs/touch/ActionLowFreqDocumentTouch.java
浏览文件 @
9c278c51
...
...
@@ -25,8 +25,7 @@ class ActionLowFreqDocumentTouch extends BaseAction {
ActionResult
<
Wo
>
result
=
new
ActionResult
<>();
Wo
wo
=
new
Wo
();
wo
.
setValue
(
false
);
for
(
Application
application
:
ThisApplication
.
context
().
applications
()
.
get
(
ThisApplication
.
context
().
clazz
()))
{
for
(
Application
application
:
listApplication
(
node
))
{
if
(
StringUtils
.
equals
(
node
,
application
.
getNode
()))
{
String
url
=
application
.
getUrlJaxrsRoot
()
+
Applications
.
joinQueryUri
(
"fireschedule"
,
"classname"
,
LowFreqDocument
.
class
.
getName
());
...
...
o2server/x_query_service_processing/src/main/java/com/x/query/service/processing/jaxrs/touch/ActionLowFreqWorkCompletedReset.java
浏览文件 @
9c278c51
package
com.x.query.service.processing.jaxrs.touch
;
import
java.util.ArrayList
;
import
java.util.List
;
import
org.apache.commons.lang3.StringUtils
;
import
com.x.base.core.container.EntityManagerContainer
;
import
com.x.base.core.container.factory.EntityManagerContainerFactory
;
import
com.x.base.core.entity.annotation.CheckRemoveType
;
...
...
@@ -25,9 +28,17 @@ class ActionLowFreqWorkCompletedReset extends BaseAction {
Wo
wo
=
new
Wo
();
wo
.
setValue
(
false
);
try
(
EntityManagerContainer
emc
=
EntityManagerContainerFactory
.
instance
().
create
())
{
List
<
State
>
list
=
emc
.
listEqualAndEqualAndEqual
(
State
.
class
,
State
.
NODE_FIELDNAME
,
node
,
List
<
State
>
list
=
new
ArrayList
<>();
if
(!
StringUtils
.
equals
(
node
,
EMPTY_SYMBOL
))
{
list
=
emc
.
listEqualAndEqualAndEqual
(
State
.
class
,
State
.
NODE_FIELDNAME
,
node
,
State
.
FREQ_FIELDNAME
,
State
.
FREQ_LOW
,
State
.
TYPE_FIELDNAME
,
State
.
TYPE_WORKCOMPLETED
);
}
else
{
list
=
emc
.
listEqualAndEqual
(
State
.
class
,
State
.
FREQ_FIELDNAME
,
State
.
FREQ_LOW
,
State
.
TYPE_FIELDNAME
,
State
.
TYPE_WORKCOMPLETED
);
}
if
(!
list
.
isEmpty
())
{
emc
.
beginTransaction
(
State
.
class
);
for
(
State
state
:
list
)
{
...
...
o2server/x_query_service_processing/src/main/java/com/x/query/service/processing/jaxrs/touch/ActionLowFreqWorkCompletedTouch.java
浏览文件 @
9c278c51
...
...
@@ -27,8 +27,7 @@ class ActionLowFreqWorkCompletedTouch extends BaseAction {
ActionResult
<
Wo
>
result
=
new
ActionResult
<>();
Wo
wo
=
new
Wo
();
wo
.
setValue
(
false
);
for
(
Application
application
:
ThisApplication
.
context
().
applications
()
.
get
(
ThisApplication
.
context
().
clazz
()))
{
for
(
Application
application
:
listApplication
(
node
))
{
if
(
StringUtils
.
equals
(
node
,
application
.
getNode
()))
{
String
url
=
application
.
getUrlJaxrsRoot
()
+
Applications
.
joinQueryUri
(
"fireschedule"
,
"classname"
,
LowFreqWorkCompleted
.
class
.
getName
());
...
...
o2server/x_query_service_processing/src/main/java/com/x/query/service/processing/jaxrs/touch/ActionLowFreqWorkReset.java
浏览文件 @
9c278c51
package
com.x.query.service.processing.jaxrs.touch
;
import
java.util.ArrayList
;
import
java.util.List
;
import
org.apache.commons.lang3.StringUtils
;
import
com.x.base.core.container.EntityManagerContainer
;
import
com.x.base.core.container.factory.EntityManagerContainerFactory
;
import
com.x.base.core.entity.annotation.CheckRemoveType
;
...
...
@@ -25,9 +28,17 @@ class ActionLowFreqWorkReset extends BaseAction {
Wo
wo
=
new
Wo
();
wo
.
setValue
(
false
);
try
(
EntityManagerContainer
emc
=
EntityManagerContainerFactory
.
instance
().
create
())
{
List
<
State
>
list
=
emc
.
listEqualAndEqualAndEqual
(
State
.
class
,
State
.
NODE_FIELDNAME
,
node
,
List
<
State
>
list
=
new
ArrayList
<>();
if
(!
StringUtils
.
equals
(
node
,
EMPTY_SYMBOL
))
{
list
=
emc
.
listEqualAndEqualAndEqual
(
State
.
class
,
State
.
NODE_FIELDNAME
,
node
,
State
.
FREQ_FIELDNAME
,
State
.
FREQ_LOW
,
State
.
TYPE_FIELDNAME
,
State
.
TYPE_WORK
);
}
else
{
list
=
emc
.
listEqualAndEqual
(
State
.
class
,
State
.
FREQ_FIELDNAME
,
State
.
FREQ_LOW
,
State
.
TYPE_FIELDNAME
,
State
.
TYPE_WORK
);
}
if
(!
list
.
isEmpty
())
{
emc
.
beginTransaction
(
State
.
class
);
for
(
State
state
:
list
)
{
...
...
o2server/x_query_service_processing/src/main/java/com/x/query/service/processing/jaxrs/touch/ActionLowFreqWorkTouch.java
浏览文件 @
9c278c51
...
...
@@ -27,8 +27,7 @@ class ActionLowFreqWorkTouch extends BaseAction {
ActionResult
<
Wo
>
result
=
new
ActionResult
<>();
Wo
wo
=
new
Wo
();
wo
.
setValue
(
false
);
for
(
Application
application
:
ThisApplication
.
context
().
applications
()
.
get
(
ThisApplication
.
context
().
clazz
()))
{
for
(
Application
application
:
listApplication
(
node
))
{
if
(
StringUtils
.
equals
(
node
,
application
.
getNode
()))
{
String
url
=
application
.
getUrlJaxrsRoot
()
+
Applications
.
joinQueryUri
(
"fireschedule"
,
"classname"
,
LowFreqWork
.
class
.
getName
());
...
...
o2server/x_query_service_processing/src/main/java/com/x/query/service/processing/jaxrs/touch/ActionOptimizeIndex.java
浏览文件 @
9c278c51
...
...
@@ -29,8 +29,7 @@ class ActionOptimizeIndex extends BaseAction {
ActionResult
<
Wo
>
result
=
new
ActionResult
<>();
Wo
wo
=
new
Wo
();
wo
.
setValue
(
false
);
for
(
Application
application
:
ThisApplication
.
context
().
applications
()
.
get
(
ThisApplication
.
context
().
clazz
()))
{
for
(
Application
application
:
listApplication
(
node
))
{
if
(
StringUtils
.
equals
(
node
,
application
.
getNode
()))
{
String
url
=
application
.
getUrlJaxrsRoot
()
+
Applications
.
joinQueryUri
(
"fireschedule"
,
"classname"
,
OptimizeIndex
.
class
.
getName
());
...
...
o2server/x_query_service_processing/src/main/java/com/x/query/service/processing/jaxrs/touch/BaseAction.java
浏览文件 @
9c278c51
package
com.x.query.service.processing.jaxrs.touch
;
import
java.util.List
;
import
java.util.stream.Collectors
;
import
org.apache.commons.lang3.StringUtils
;
import
com.x.base.core.project.Application
;
import
com.x.base.core.project.http.EffectivePerson
;
import
com.x.base.core.project.jaxrs.StandardJaxrsAction
;
import
com.x.query.core.express.plan.Runtime
;
import
com.x.query.service.processing.Business
;
import
com.x.query.service.processing.ThisApplication
;
abstract
class
BaseAction
extends
StandardJaxrsAction
{
protected
<
T
extends
Runtime
>
void
append
(
EffectivePerson
effectivePerson
,
Business
business
,
T
t
)
throws
Exception
{
t
.
person
=
effectivePerson
.
getDistinguishedName
();
t
.
identityList
=
business
.
organization
().
identity
().
listWithPerson
(
effectivePerson
);
t
.
unitList
=
business
.
organization
().
unit
().
listWithPerson
(
effectivePerson
);
t
.
unitAllList
=
business
.
organization
().
unit
().
listWithPersonSupNested
(
effectivePerson
);
t
.
groupList
=
business
.
organization
().
group
().
listWithPerson
(
effectivePerson
.
getDistinguishedName
());
t
.
roleList
=
business
.
organization
().
role
().
listWithPerson
(
effectivePerson
);
/**
* 根据node节点名获取集群中的x_query_service_processing模块,如果node=(0)
* AbstractJaxrsAction.EMPTY_SYMBOL 取得所有节点.
*
* @param node
* @return
* @throws Exception
*/
protected
List
<
Application
>
listApplication
(
String
node
)
throws
Exception
{
List
<
Application
>
applications
=
ThisApplication
.
context
().
applications
()
.
get
(
ThisApplication
.
context
().
clazz
());
if
(!
StringUtils
.
equals
(
node
,
EMPTY_SYMBOL
))
{
applications
=
applications
.
stream
().
filter
(
o
->
StringUtils
.
equals
(
o
.
getNode
(),
node
))
.
collect
(
Collectors
.
toList
());
}
return
applications
;
}
}
o2server/x_query_service_processing/src/main/java/com/x/query/service/processing/jaxrs/touch/TouchAction.java
浏览文件 @
9c278c51
...
...
@@ -37,10 +37,10 @@ public class TouchAction extends StandardJaxrsAction {
private
static
final
String
OPERATIONID_PREFIX
=
"TouchAction::"
;
@Operation
(
summary
=
"执行在流转工作高频索引."
,
operationId
=
OPERATIONID_PREFIX
@Operation
(
summary
=
"执行在流转工作高频索引
,(0)表示在所有节点上执行
."
,
operationId
=
OPERATIONID_PREFIX
+
"highFreqWorkTouch"
,
responses
=
{
@ApiResponse
(
content
=
{
@Content
(
schema
=
@Schema
(
implementation
=
ActionHighFreqWorkTouch
.
Wo
.
class
))
})
})
@JaxrsMethodDescribe
(
value
=
"执行在流转工作高频索引."
,
action
=
ActionHighFreqWorkTouch
.
class
)
@JaxrsMethodDescribe
(
value
=
"执行在流转工作高频索引
,(0)表示在所有节点上执行
."
,
action
=
ActionHighFreqWorkTouch
.
class
)
@GET
@Path
(
"high/freq/work/node/{node}/touch"
)
@Produces
(
HttpMediaType
.
APPLICATION_JSON_UTF_8
)
...
...
@@ -58,10 +58,10 @@ public class TouchAction extends StandardJaxrsAction {
asyncResponse
.
resume
(
ResponseFactory
.
getEntityTagActionResultResponse
(
request
,
result
));
}
@Operation
(
summary
=
"重置在流转工作高频索引定时任务状态."
,
operationId
=
OPERATIONID_PREFIX
@Operation
(
summary
=
"重置在流转工作高频索引定时任务状态
,(0)表示在所有节点上执行
."
,
operationId
=
OPERATIONID_PREFIX
+
"highFreqWorkReset"
,
responses
=
{
@ApiResponse
(
content
=
{
@Content
(
schema
=
@Schema
(
implementation
=
ActionHighFreqWorkReset
.
Wo
.
class
))
})
})
@JaxrsMethodDescribe
(
value
=
"重置在流转工作高频索引定时任务状态."
,
action
=
ActionHighFreqWorkReset
.
class
)
@JaxrsMethodDescribe
(
value
=
"重置在流转工作高频索引定时任务状态
,(0)表示在所有节点上执行
."
,
action
=
ActionHighFreqWorkReset
.
class
)
@GET
@Path
(
"high/freq/work/node/{node}/reset"
)
@Produces
(
HttpMediaType
.
APPLICATION_JSON_UTF_8
)
...
...
@@ -79,10 +79,10 @@ public class TouchAction extends StandardJaxrsAction {
asyncResponse
.
resume
(
ResponseFactory
.
getEntityTagActionResultResponse
(
request
,
result
));
}
@Operation
(
summary
=
"执行在流转工作低频索引."
,
operationId
=
OPERATIONID_PREFIX
@Operation
(
summary
=
"执行在流转工作低频索引
,(0)表示在所有节点上执行
."
,
operationId
=
OPERATIONID_PREFIX
+
"lowFreqIndexWorkTouch"
,
responses
=
{
@ApiResponse
(
content
=
{
@Content
(
schema
=
@Schema
(
implementation
=
ActionLowFreqWorkTouch
.
Wo
.
class
))
})
})
@JaxrsMethodDescribe
(
value
=
"执行在流转工作低频索引."
,
action
=
ActionLowFreqWorkTouch
.
class
)
@JaxrsMethodDescribe
(
value
=
"执行在流转工作低频索引
,(0)表示在所有节点上执行
."
,
action
=
ActionLowFreqWorkTouch
.
class
)
@GET
@Path
(
"low/freq/work/node/{node}/touch"
)
@Produces
(
HttpMediaType
.
APPLICATION_JSON_UTF_8
)
...
...
@@ -100,10 +100,10 @@ public class TouchAction extends StandardJaxrsAction {
asyncResponse
.
resume
(
ResponseFactory
.
getEntityTagActionResultResponse
(
request
,
result
));
}
@Operation
(
summary
=
"重置在流转工作低频索引定时任务状态."
,
operationId
=
OPERATIONID_PREFIX
@Operation
(
summary
=
"重置在流转工作低频索引定时任务状态
,(0)表示在所有节点上执行
."
,
operationId
=
OPERATIONID_PREFIX
+
"lowFreqWorkReset"
,
responses
=
{
@ApiResponse
(
content
=
{
@Content
(
schema
=
@Schema
(
implementation
=
ActionLowFreqWorkReset
.
Wo
.
class
))
})
})
@JaxrsMethodDescribe
(
value
=
"重置在流转工作低频索引定时任务状态."
,
action
=
ActionLowFreqWorkReset
.
class
)
@JaxrsMethodDescribe
(
value
=
"重置在流转工作低频索引定时任务状态
,(0)表示在所有节点上执行
."
,
action
=
ActionLowFreqWorkReset
.
class
)
@GET
@Path
(
"low/freq/work/node/{node}/reset"
)
@Produces
(
HttpMediaType
.
APPLICATION_JSON_UTF_8
)
...
...
@@ -121,10 +121,10 @@ public class TouchAction extends StandardJaxrsAction {
asyncResponse
.
resume
(
ResponseFactory
.
getEntityTagActionResultResponse
(
request
,
result
));
}
@Operation
(
summary
=
"执行已完成工作高频索引."
,
operationId
=
OPERATIONID_PREFIX
@Operation
(
summary
=
"执行已完成工作高频索引
,(0)表示在所有节点上执行
."
,
operationId
=
OPERATIONID_PREFIX
+
"highFreqWorkCompletedTouch"
,
responses
=
{
@ApiResponse
(
content
=
{
@Content
(
schema
=
@Schema
(
implementation
=
ActionHighFreqWorkCompletedTouch
.
Wo
.
class
))
})
})
@JaxrsMethodDescribe
(
value
=
"执行已完成工作高频索引."
,
action
=
ActionHighFreqWorkCompletedTouch
.
class
)
@JaxrsMethodDescribe
(
value
=
"执行已完成工作高频索引
,(0)表示在所有节点上执行
."
,
action
=
ActionHighFreqWorkCompletedTouch
.
class
)
@GET
@Path
(
"high/freq/workcompleted/node/{node}/touch"
)
@Produces
(
HttpMediaType
.
APPLICATION_JSON_UTF_8
)
...
...
@@ -142,10 +142,10 @@ public class TouchAction extends StandardJaxrsAction {
asyncResponse
.
resume
(
ResponseFactory
.
getEntityTagActionResultResponse
(
request
,
result
));
}
@Operation
(
summary
=
"重置已完成工作高频索引定时任务状态."
,
operationId
=
OPERATIONID_PREFIX
@Operation
(
summary
=
"重置已完成工作高频索引定时任务状态
,(0)表示在所有节点上执行
."
,
operationId
=
OPERATIONID_PREFIX
+
"highFreqWorkCompletedReset"
,
responses
=
{
@ApiResponse
(
content
=
{
@Content
(
schema
=
@Schema
(
implementation
=
ActionHighFreqWorkCompletedReset
.
Wo
.
class
))
})
})
@JaxrsMethodDescribe
(
value
=
"重置已完成工作高频索引定时任务状态."
,
action
=
ActionHighFreqWorkCompletedReset
.
class
)
@JaxrsMethodDescribe
(
value
=
"重置已完成工作高频索引定时任务状态
,(0)表示在所有节点上执行
."
,
action
=
ActionHighFreqWorkCompletedReset
.
class
)
@GET
@Path
(
"high/freq/workcompleted/node/{node}/reset"
)
@Produces
(
HttpMediaType
.
APPLICATION_JSON_UTF_8
)
...
...
@@ -163,10 +163,10 @@ public class TouchAction extends StandardJaxrsAction {
asyncResponse
.
resume
(
ResponseFactory
.
getEntityTagActionResultResponse
(
request
,
result
));
}
@Operation
(
summary
=
"执行已完成工作低频索引."
,
operationId
=
OPERATIONID_PREFIX
@Operation
(
summary
=
"执行已完成工作低频索引
,(0)表示在所有节点上执行
."
,
operationId
=
OPERATIONID_PREFIX
+
"lowFreqIndexWorkCompletedTouch"
,
responses
=
{
@ApiResponse
(
content
=
{
@Content
(
schema
=
@Schema
(
implementation
=
ActionLowFreqWorkCompletedTouch
.
Wo
.
class
))
})
})
@JaxrsMethodDescribe
(
value
=
"执行已完成工作低频索引."
,
action
=
ActionLowFreqWorkCompletedTouch
.
class
)
@JaxrsMethodDescribe
(
value
=
"执行已完成工作低频索引
,(0)表示在所有节点上执行
."
,
action
=
ActionLowFreqWorkCompletedTouch
.
class
)
@GET
@Path
(
"low/freq/workcompleted/node/{node}/touch"
)
@Produces
(
HttpMediaType
.
APPLICATION_JSON_UTF_8
)
...
...
@@ -184,10 +184,10 @@ public class TouchAction extends StandardJaxrsAction {
asyncResponse
.
resume
(
ResponseFactory
.
getEntityTagActionResultResponse
(
request
,
result
));
}
@Operation
(
summary
=
"重置已完成工作低频索引定时任务状态."
,
operationId
=
OPERATIONID_PREFIX
@Operation
(
summary
=
"重置已完成工作低频索引定时任务状态
,(0)表示在所有节点上执行
."
,
operationId
=
OPERATIONID_PREFIX
+
"lowFreqWorkCompletedReset"
,
responses
=
{
@ApiResponse
(
content
=
{
@Content
(
schema
=
@Schema
(
implementation
=
ActionLowFreqWorkCompletedReset
.
Wo
.
class
))
})
})
@JaxrsMethodDescribe
(
value
=
"重置已完成工作低频索引定时任务状态."
,
action
=
ActionLowFreqWorkCompletedReset
.
class
)
@JaxrsMethodDescribe
(
value
=
"重置已完成工作低频索引定时任务状态
,(0)表示在所有节点上执行
."
,
action
=
ActionLowFreqWorkCompletedReset
.
class
)
@GET
@Path
(
"low/freq/workcompleted/node/{node}/reset"
)
@Produces
(
HttpMediaType
.
APPLICATION_JSON_UTF_8
)
...
...
@@ -205,10 +205,10 @@ public class TouchAction extends StandardJaxrsAction {
asyncResponse
.
resume
(
ResponseFactory
.
getEntityTagActionResultResponse
(
request
,
result
));
}
@Operation
(
summary
=
"执行文档高频索引."
,
operationId
=
OPERATIONID_PREFIX
+
"highFreqDocumentTouch"
,
responses
=
{
@Operation
(
summary
=
"执行文档高频索引
,(0)表示在所有节点上执行
."
,
operationId
=
OPERATIONID_PREFIX
+
"highFreqDocumentTouch"
,
responses
=
{
@ApiResponse
(
content
=
{
@Content
(
schema
=
@Schema
(
implementation
=
ActionHighFreqDocumentTouch
.
Wo
.
class
))
})
})
@JaxrsMethodDescribe
(
value
=
"执行文档高频索引."
,
action
=
ActionHighFreqDocumentTouch
.
class
)
@JaxrsMethodDescribe
(
value
=
"执行文档高频索引
,(0)表示在所有节点上执行
."
,
action
=
ActionHighFreqDocumentTouch
.
class
)
@GET
@Path
(
"high/freq/document/node/{node}/touch"
)
@Produces
(
HttpMediaType
.
APPLICATION_JSON_UTF_8
)
...
...
@@ -226,10 +226,10 @@ public class TouchAction extends StandardJaxrsAction {
asyncResponse
.
resume
(
ResponseFactory
.
getEntityTagActionResultResponse
(
request
,
result
));
}
@Operation
(
summary
=
"重置文档高频索引定时任务状态."
,
operationId
=
OPERATIONID_PREFIX
@Operation
(
summary
=
"重置文档高频索引定时任务状态
,(0)表示在所有节点上执行
."
,
operationId
=
OPERATIONID_PREFIX
+
"highFreqDocumentReset"
,
responses
=
{
@ApiResponse
(
content
=
{
@Content
(
schema
=
@Schema
(
implementation
=
ActionHighFreqDocumentReset
.
Wo
.
class
))
})
})
@JaxrsMethodDescribe
(
value
=
"重置文档高频索引定时任务状态."
,
action
=
ActionHighFreqDocumentReset
.
class
)
@JaxrsMethodDescribe
(
value
=
"重置文档高频索引定时任务状态
,(0)表示在所有节点上执行
."
,
action
=
ActionHighFreqDocumentReset
.
class
)
@GET
@Path
(
"high/freq/document/node/{node}/reset"
)
@Produces
(
HttpMediaType
.
APPLICATION_JSON_UTF_8
)
...
...
@@ -247,10 +247,10 @@ public class TouchAction extends StandardJaxrsAction {
asyncResponse
.
resume
(
ResponseFactory
.
getEntityTagActionResultResponse
(
request
,
result
));
}
@Operation
(
summary
=
"执行文档低频索引."
,
operationId
=
OPERATIONID_PREFIX
+
"lowFreqDocumentTouch"
,
responses
=
{
@Operation
(
summary
=
"执行文档低频索引
,(0)表示在所有节点上执行
."
,
operationId
=
OPERATIONID_PREFIX
+
"lowFreqDocumentTouch"
,
responses
=
{
@ApiResponse
(
content
=
{
@Content
(
schema
=
@Schema
(
implementation
=
ActionLowFreqDocumentTouch
.
Wo
.
class
))
})
})
@JaxrsMethodDescribe
(
value
=
"执行文档低频索引."
,
action
=
ActionLowFreqDocumentTouch
.
class
)
@JaxrsMethodDescribe
(
value
=
"执行文档低频索引
,(0)表示在所有节点上执行
."
,
action
=
ActionLowFreqDocumentTouch
.
class
)
@GET
@Path
(
"low/freq/document/node/{node}/touch"
)
@Produces
(
HttpMediaType
.
APPLICATION_JSON_UTF_8
)
...
...
@@ -268,10 +268,10 @@ public class TouchAction extends StandardJaxrsAction {
asyncResponse
.
resume
(
ResponseFactory
.
getEntityTagActionResultResponse
(
request
,
result
));
}
@Operation
(
summary
=
"重置文档低频索引定时任务状态."
,
operationId
=
OPERATIONID_PREFIX
@Operation
(
summary
=
"重置文档低频索引定时任务状态
,(0)表示在所有节点上执行
."
,
operationId
=
OPERATIONID_PREFIX
+
"lowFreqDocumentReset"
,
responses
=
{
@ApiResponse
(
content
=
{
@Content
(
schema
=
@Schema
(
implementation
=
ActionLowFreqDocumentReset
.
Wo
.
class
))
})
})
@JaxrsMethodDescribe
(
value
=
"重置文档低频索引定时任务状态."
,
action
=
ActionLowFreqDocumentReset
.
class
)
@JaxrsMethodDescribe
(
value
=
"重置文档低频索引定时任务状态
,(0)表示在所有节点上执行
."
,
action
=
ActionLowFreqDocumentReset
.
class
)
@GET
@Path
(
"low/freq/document/node/{node}/reset"
)
@Produces
(
HttpMediaType
.
APPLICATION_JSON_UTF_8
)
...
...
@@ -289,10 +289,10 @@ public class TouchAction extends StandardJaxrsAction {
asyncResponse
.
resume
(
ResponseFactory
.
getEntityTagActionResultResponse
(
request
,
result
));
}
@Operation
(
summary
=
"执行优化索引."
,
operationId
=
OPERATIONID_PREFIX
+
"optimizeIndex"
,
responses
=
{
@Operation
(
summary
=
"执行优化索引
,(0)表示在所有节点上执行
."
,
operationId
=
OPERATIONID_PREFIX
+
"optimizeIndex"
,
responses
=
{
@ApiResponse
(
content
=
{
@Content
(
schema
=
@Schema
(
implementation
=
ActionOptimizeIndex
.
Wo
.
class
))
})
})
@JaxrsMethodDescribe
(
value
=
"执行优化索引."
,
action
=
ActionOptimizeIndex
.
class
)
@JaxrsMethodDescribe
(
value
=
"执行优化索引
,(0)表示在所有节点上执行
."
,
action
=
ActionOptimizeIndex
.
class
)
@GET
@Path
(
"optimize/index/{node}/touch"
)
@Produces
(
HttpMediaType
.
APPLICATION_JSON_UTF_8
)
...
...
o2server/x_query_service_processing/src/test/resources/hanlp.properties
已删除
100644 → 0
浏览文件 @
9401bbf2
root
=
D:/O2/o2oa/o2server/commons/hanlp/
HanLP.Config.ShowTermNature
=
true
HanLP.Config.Normalization
=
true
\ No newline at end of file
o2server/x_query_service_processing/src/test/resources/test.json
已删除
100644 → 0
浏览文件 @
9401bbf2
{
"selectEntryList"
:
[
{
"orderType"
:
"original"
,
"orderRank"
:
0
,
"selectType"
:
"path"
,
"attribute"
:
""
,
"name"
:
""
,
"column"
:
"qsubject"
,
"displayName"
:
""
,
"path"
:
"subject"
},
{
"orderType"
:
"original"
,
"orderRank"
:
0
,
"selectType"
:
"path"
,
"attribute"
:
""
,
"name"
:
""
,
"column"
:
"qamount"
,
"displayName"
:
""
,
"path"
:
"amount"
},
{
"orderType"
:
"original"
,
"orderRank"
:
0
,
"selectType"
:
"path"
,
"attribute"
:
""
,
"name"
:
""
,
"column"
:
"qphone"
,
"displayName"
:
""
,
"path"
:
"phone"
},
{
"orderType"
:
"original"
,
"orderRank"
:
0
,
"selectType"
:
"path"
,
"attribute"
:
""
,
"name"
:
""
,
"column"
:
"qslDate"
,
"displayName"
:
""
,
"path"
:
"slDate"
},
{
"orderType"
:
"original"
,
"orderRank"
:
0
,
"selectType"
:
"path"
,
"attribute"
:
""
,
"name"
:
""
,
"column"
:
"qjzDate"
,
"displayName"
:
""
,
"path"
:
"jzDate"
},
{
"orderType"
:
"original"
,
"orderRank"
:
0
,
"selectType"
:
"attribute"
,
"attribute"
:
"title"
,
"name"
:
""
,
"column"
:
"qtitle"
,
"displayName"
:
""
,
"path"
:
""
},
{
"orderType"
:
"original"
,
"orderRank"
:
0
,
"selectType"
:
"attribute"
,
"attribute"
:
"creatorPerson"
,
"name"
:
""
,
"column"
:
"qcreatorPerson"
,
"displayName"
:
""
,
"path"
:
""
}
],
"whereEntry"
:
{
"applicationList"
:
[
"0c2c3d76-5301-4918-8869-f88de8d2fe57"
],
"processList"
:
[
],
"companyList"
:
[
],
"departmentList"
:
[
],
"personList"
:
[
],
"identityList"
:
[
]
},
"filterEntryList"
:
[
],
"calculateEntryList"
:
[
],
"groupEntry"
:
{
"column"
:
"qphone"
,
"orderType"
:
"original"
},
"dateRangeEntry"
:
{
"dateRangeType"
:
"none"
,
"dateEffectType"
:
"completed"
,
"year"
:
""
,
"month"
:
""
,
"date"
:
""
,
"season"
:
0
,
"week"
:
0
,
"adjust"
:
0
}
}
\ No newline at end of file
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录