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 0000000000000000000000000000000000000000..37f12130d190da846c4a6244310e410debbafc9b --- /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 f891f9c9c8031ead0aed608e4772a87b8dba39b1..621a483a3fde4917400638e4d57fc93a95e028f4 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 0fb9aaea4fb75e9192e67dde2f57df5bb7b8b075..7f175086b34cc9ddb711aa8a852454520453f658 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 fcf9655298cb888dc485ebdc780c13b3e257367a..0000000000000000000000000000000000000000 --- 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