From bbed443b0601a0fe26e131531d3813e6a976201b Mon Sep 17 00:00:00 2001 From: zhourui Date: Mon, 6 Jul 2020 15:41:30 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E7=88=AC=E8=99=AB=E5=90=AF?= =?UTF-8?q?=E5=8A=A8=E7=8A=B6=E6=80=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../jaxrs/segment/ActionCrawlEnable.java | 75 +++++++++++++++++++ .../surface/jaxrs/segment/ActionSearch.java | 1 - .../surface/jaxrs/segment/SegmentAction.java | 17 +++++ .../surface/jaxrs/segment/package-info.java | 8 -- 4 files changed, 92 insertions(+), 9 deletions(-) create mode 100644 o2server/x_query_assemble_surface/src/main/java/com/x/query/assemble/surface/jaxrs/segment/ActionCrawlEnable.java delete mode 100644 o2server/x_query_assemble_surface/src/main/java/com/x/query/assemble/surface/jaxrs/segment/package-info.java diff --git a/o2server/x_query_assemble_surface/src/main/java/com/x/query/assemble/surface/jaxrs/segment/ActionCrawlEnable.java b/o2server/x_query_assemble_surface/src/main/java/com/x/query/assemble/surface/jaxrs/segment/ActionCrawlEnable.java new file mode 100644 index 0000000000..37f12130d1 --- /dev/null +++ b/o2server/x_query_assemble_surface/src/main/java/com/x/query/assemble/surface/jaxrs/segment/ActionCrawlEnable.java @@ -0,0 +1,75 @@ +package com.x.query.assemble.surface.jaxrs.segment; + +import com.x.base.core.container.EntityManagerContainer; +import com.x.base.core.container.factory.EntityManagerContainerFactory; +import com.x.base.core.project.config.Config; +import com.x.base.core.project.gson.GsonPropertyObject; +import com.x.base.core.project.http.ActionResult; +import com.x.base.core.project.http.EffectivePerson; + +import org.apache.commons.lang3.BooleanUtils; + +class ActionCrawlEnable extends BaseAction { + + ActionResult execute(EffectivePerson effectivePerson) throws Exception { + try (EntityManagerContainer emc = EntityManagerContainerFactory.instance().create()) { + ActionResult result = new ActionResult<>(); + Wo wo = new Wo(); + wo.setCms(Config.query().getCrawlCms().getEnable()); + wo.setWork(Config.query().getCrawlWork().getEnable()); + wo.setWorkCompleted(Config.query().getCrawlWorkCompleted().getEnable()); + if (BooleanUtils.isTrue(wo.getCms()) || BooleanUtils.isTrue(wo.getWork()) + || BooleanUtils.isTrue(wo.getWorkCompleted())) { + wo.setEnable(true); + } else { + wo.setEnable(false); + } + result.setData(wo); + return result; + } + } + + public static class Wo extends GsonPropertyObject { + + private Boolean enable; + + private Boolean cms; + + private Boolean work; + + private Boolean workCompleted; + + public Boolean getEnable() { + return enable; + } + + public void setEnable(Boolean enable) { + this.enable = enable; + } + + public Boolean getCms() { + return cms; + } + + public void setCms(Boolean cms) { + this.cms = cms; + } + + public Boolean getWork() { + return work; + } + + public void setWork(Boolean work) { + this.work = work; + } + + public Boolean getWorkCompleted() { + return workCompleted; + } + + public void setWorkCompleted(Boolean workCompleted) { + this.workCompleted = workCompleted; + } + + } +} \ No newline at end of file diff --git a/o2server/x_query_assemble_surface/src/main/java/com/x/query/assemble/surface/jaxrs/segment/ActionSearch.java b/o2server/x_query_assemble_surface/src/main/java/com/x/query/assemble/surface/jaxrs/segment/ActionSearch.java index f891f9c9c8..621a483a3f 100644 --- a/o2server/x_query_assemble_surface/src/main/java/com/x/query/assemble/surface/jaxrs/segment/ActionSearch.java +++ b/o2server/x_query_assemble_surface/src/main/java/com/x/query/assemble/surface/jaxrs/segment/ActionSearch.java @@ -9,7 +9,6 @@ import javax.persistence.criteria.CriteriaBuilder; import javax.persistence.criteria.CriteriaQuery; import javax.persistence.criteria.Expression; import javax.persistence.criteria.Root; -import javax.persistence.criteria.Subquery; import com.x.base.core.container.EntityManagerContainer; import com.x.base.core.container.factory.EntityManagerContainerFactory; diff --git a/o2server/x_query_assemble_surface/src/main/java/com/x/query/assemble/surface/jaxrs/segment/SegmentAction.java b/o2server/x_query_assemble_surface/src/main/java/com/x/query/assemble/surface/jaxrs/segment/SegmentAction.java index 0fb9aaea4f..7f175086b3 100644 --- a/o2server/x_query_assemble_surface/src/main/java/com/x/query/assemble/surface/jaxrs/segment/SegmentAction.java +++ b/o2server/x_query_assemble_surface/src/main/java/com/x/query/assemble/surface/jaxrs/segment/SegmentAction.java @@ -68,4 +68,21 @@ public class SegmentAction extends StandardJaxrsAction { asyncResponse.resume(ResponseFactory.getEntityTagActionResultResponse(request, result)); } + @JaxrsMethodDescribe(value = "获取当前是否启用了爬虫搜索.", action = ActionCrawlEnable.class) + @GET + @Path("crawl/enable") + @Produces(HttpMediaType.APPLICATION_JSON_UTF_8) + @Consumes(MediaType.APPLICATION_JSON) + public void crawlEnable(@Suspended final AsyncResponse asyncResponse, @Context HttpServletRequest request) { + ActionResult result = new ActionResult<>(); + EffectivePerson effectivePerson = this.effectivePerson(request); + try { + result = new ActionCrawlEnable().execute(effectivePerson); + } catch (Exception e) { + logger.error(e, effectivePerson, request, null); + result.error(e); + } + asyncResponse.resume(ResponseFactory.getEntityTagActionResultResponse(request, result)); + } + } \ No newline at end of file diff --git a/o2server/x_query_assemble_surface/src/main/java/com/x/query/assemble/surface/jaxrs/segment/package-info.java b/o2server/x_query_assemble_surface/src/main/java/com/x/query/assemble/surface/jaxrs/segment/package-info.java deleted file mode 100644 index fcf9655298..0000000000 --- a/o2server/x_query_assemble_surface/src/main/java/com/x/query/assemble/surface/jaxrs/segment/package-info.java +++ /dev/null @@ -1,8 +0,0 @@ -/** - * - */ -/** - * @author zhour - * - */ -package com.x.query.assemble.surface.jaxrs.segment; \ No newline at end of file -- GitLab