diff --git a/o2server/x_program_center/src/main/java/com/x/program/center/jaxrs/collect/ActionGetBbs.java b/o2server/x_program_center/src/main/java/com/x/program/center/jaxrs/collect/ActionGetBbs.java new file mode 100644 index 0000000000000000000000000000000000000000..1a0353a95838d210e7773911279e88a3c886fad9 --- /dev/null +++ b/o2server/x_program_center/src/main/java/com/x/program/center/jaxrs/collect/ActionGetBbs.java @@ -0,0 +1,97 @@ +package com.x.program.center.jaxrs.collect; + +import com.google.gson.Gson; +import com.x.base.core.project.config.Config; +import com.x.base.core.project.connection.ActionResponse; +import com.x.base.core.project.connection.ConnectionAction; +import com.x.base.core.project.http.ActionResult; +import com.x.base.core.project.jaxrs.WrapBoolean; +import com.x.base.core.project.tools.DefaultCharset; +import org.apache.commons.lang3.BooleanUtils; + +import java.net.URLEncoder; +import java.util.List; + +class ActionGetBbs extends BaseAction { + + ActionResult execute() throws Exception { + ActionResult result = new ActionResult<>(); + if (BooleanUtils.isNotTrue(this.connect())) { + throw new ExceptionUnableConnect(); + } + Gson gson = new Gson(); + String url = Config.collect() + .url("/o2_collect_assemble/jaxrs/collect/config/key/(0)"); + ActionResponse resp = ConnectionAction.get(url, null); + ResponsePojoVO os = gson.fromJson(resp.toString(), ResponsePojoVO.class); + Wo wo = new Wo(); + if ("success".equals(os.getType())) { + wo = os.getData(); + } + result.setData(wo); + return result; + } + + public static class Wo { + private String bbsUrlPath; + private String bbsUrl; + + public String getBbsUrlPath() { + return bbsUrlPath; + } + + public void setBbsUrlPath(String bbsUrlPath) { + this.bbsUrlPath = bbsUrlPath; + } + + public String getBbsUrl() { + return bbsUrl; + } + + public void setBbsUrl(String bbsUrl) { + this.bbsUrl = bbsUrl; + } + } + + public class ResponsePojoVO { + private String type; + private Wo data; + private String message; + private String date; + + public String getDate() { + return date; + } + + public void setDate(String date) { + this.date = date; + } + + public String getMessage() { + return message; + } + + public void setMessage(String message) { + this.message = message; + } + + public String getType() { + return type; + } + + public void setType(String type) { + this.type = type; + } + + public Wo getData() { + return data; + } + + public void setData(Wo data) { + this.data = data; + } + + + } + +} diff --git a/o2server/x_program_center/src/main/java/com/x/program/center/jaxrs/collect/CollectAction.java b/o2server/x_program_center/src/main/java/com/x/program/center/jaxrs/collect/CollectAction.java index 9d91251e3efedafcfbbc1234e235bb8951fd0a62..4fbf488a2c8ab386eb41b8968f313afde2072e38 100644 --- a/o2server/x_program_center/src/main/java/com/x/program/center/jaxrs/collect/CollectAction.java +++ b/o2server/x_program_center/src/main/java/com/x/program/center/jaxrs/collect/CollectAction.java @@ -218,6 +218,23 @@ public class CollectAction extends StandardJaxrsAction { asyncResponse.resume(ResponseFactory.getEntityTagActionResultResponse(request, result)); } + @GET + @Path("controllebbs") + @Produces(HttpMediaType.APPLICATION_JSON_UTF_8) + @Consumes(MediaType.APPLICATION_JSON) + @JaxrsMethodDescribe(value = "获取bbs地址", action = ActionGetBbs.class) + public void bbs(@Suspended final AsyncResponse asyncResponse, @Context HttpServletRequest request) { + ActionResult result = new ActionResult<>(); + EffectivePerson effectivePerson = this.effectivePerson(request); + try { + result = new ActionGetBbs().execute(); + } catch (Exception e) { + logger.error(e, effectivePerson, request, null); + result.error(e); + } + asyncResponse.resume(ResponseFactory.getEntityTagActionResultResponse(request, result)); + } + @POST @Produces(HttpMediaType.APPLICATION_JSON_UTF_8) @Consumes(MediaType.APPLICATION_JSON)