package com.x.query.service.processing.jaxrs.touch; 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; import com.x.base.core.project.http.ActionResult; 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.service.processing.ThisApplication; import com.x.query.service.processing.schedule.HighFreqWorkCompleted; import io.swagger.v3.oas.annotations.media.Schema; class ActionHighFreqWorkCompletedTouch extends BaseAction { private static final Logger LOGGER = LoggerFactory.getLogger(ActionHighFreqWorkCompletedTouch.class); ActionResult execute(EffectivePerson effectivePerson, String node) throws Exception { LOGGER.info("execute:{}.", effectivePerson::getDistinguishedName); ActionResult result = new ActionResult<>(); Wo wo = new Wo(); wo.setValue(false); for (Application application : ThisApplication.context().applications() .get(ThisApplication.context().clazz())) { if (StringUtils.equals(node, application.getNode())) { String url = application.getUrlJaxrsRoot() + Applications.joinQueryUri("fireschedule", "classname", HighFreqWorkCompleted.class.getName()); CipherConnectionAction.get(false, url); wo.setValue(true); } } result.setData(wo); return result; } @Schema(name = "com.x.query.service.processing.jaxrs.touch.ActionHighFreqWorkCompletedTouch$Wo") public static class Wo extends WrapBoolean { private static final long serialVersionUID = -6750436099546415573L; } }