diff --git a/o2server/x_program_center/src/main/java/com/x/program/center/jaxrs/collect/ActionRegist.java b/o2server/x_program_center/src/main/java/com/x/program/center/jaxrs/collect/ActionRegist.java index 243b2a7e91837813d43112a3b3ccbb4a892daee5..89cf333a0723691e93999a8b7214b65b8908354d 100644 --- a/o2server/x_program_center/src/main/java/com/x/program/center/jaxrs/collect/ActionRegist.java +++ b/o2server/x_program_center/src/main/java/com/x/program/center/jaxrs/collect/ActionRegist.java @@ -50,7 +50,7 @@ class ActionRegist extends BaseAction { Config.collect().setName(name); Config.collect().setPassword(password); Config.collect().save(); - Config.flush(); + this.configFlush(effectivePerson); /* 人员和应用市场同步 */ ThisApplication.context().scheduleLocal(CollectPerson.class); ThisApplication.context().scheduleLocal(CollectMarket.class); diff --git a/o2server/x_program_center/src/main/java/com/x/program/center/jaxrs/collect/ActionResetPassword.java b/o2server/x_program_center/src/main/java/com/x/program/center/jaxrs/collect/ActionResetPassword.java index 6101559acac840affa45a660a6122619a197ae78..ba50a1d768211c21487feb4bb49bb8f394e92f5f 100644 --- a/o2server/x_program_center/src/main/java/com/x/program/center/jaxrs/collect/ActionResetPassword.java +++ b/o2server/x_program_center/src/main/java/com/x/program/center/jaxrs/collect/ActionResetPassword.java @@ -1,5 +1,8 @@ package com.x.program.center.jaxrs.collect; +import com.x.program.center.ThisApplication; +import com.x.program.center.schedule.CollectMarket; +import com.x.program.center.schedule.CollectPerson; import org.apache.commons.lang3.BooleanUtils; import org.apache.commons.lang3.StringUtils; @@ -42,7 +45,7 @@ class ActionResetPassword extends BaseAction { if (BooleanUtils.isTrue(wo.getValue())) { Config.collect().setPassword(password); Config.collect().save(); - Config.flush(); + this.configFlush(effectivePerson); } result.setData(wo); return result; diff --git a/o2server/x_program_center/src/main/java/com/x/program/center/jaxrs/collect/ActionUpdate.java b/o2server/x_program_center/src/main/java/com/x/program/center/jaxrs/collect/ActionUpdate.java index 490443487167e28daab6bbb5e91b9c2c2aa930f1..5e5a6179a3078a75adb3b1ab09cc1c14ede25af8 100644 --- a/o2server/x_program_center/src/main/java/com/x/program/center/jaxrs/collect/ActionUpdate.java +++ b/o2server/x_program_center/src/main/java/com/x/program/center/jaxrs/collect/ActionUpdate.java @@ -32,7 +32,7 @@ class ActionUpdate extends BaseAction { Config.collect().setName(wrapIn.getName()); Config.collect().setPassword(wrapIn.getPassword()); Config.collect().save(); - Config.flush(); + this.configFlush(effectivePerson); Wo wo = new Wo(); wo.setValue(true); result.setData(wo); diff --git a/o2server/x_program_center/src/main/java/com/x/program/center/jaxrs/collect/ActionUpdateUnit.java b/o2server/x_program_center/src/main/java/com/x/program/center/jaxrs/collect/ActionUpdateUnit.java index 03e106ce77571a7e21b07ad81e3f67219f1ea3b1..f6476cf753e1e2701b65773cb694ea18f270fdc3 100644 --- a/o2server/x_program_center/src/main/java/com/x/program/center/jaxrs/collect/ActionUpdateUnit.java +++ b/o2server/x_program_center/src/main/java/com/x/program/center/jaxrs/collect/ActionUpdateUnit.java @@ -48,7 +48,7 @@ class ActionUpdateUnit extends BaseAction { Config.collect().setKey(wi.getKey()); Config.collect().setSecret(wi.getSecret()); Config.collect().save(); - Config.flush(); + this.configFlush(effectivePerson); } result.setData(wo); return result; diff --git a/o2server/x_program_center/src/main/java/com/x/program/center/jaxrs/collect/BaseAction.java b/o2server/x_program_center/src/main/java/com/x/program/center/jaxrs/collect/BaseAction.java index de1efc0a307d2524f2bdbdb60fd1f67e3e6e6525..b0a774c745ceae706e7a96fbf3b3c96fbaa295b6 100644 --- a/o2server/x_program_center/src/main/java/com/x/program/center/jaxrs/collect/BaseAction.java +++ b/o2server/x_program_center/src/main/java/com/x/program/center/jaxrs/collect/BaseAction.java @@ -11,12 +11,15 @@ import com.x.base.core.project.bean.WrapCopierFactory; import com.x.base.core.project.config.Collect; import com.x.base.core.project.config.Config; import com.x.base.core.project.connection.ActionResponse; +import com.x.base.core.project.connection.CipherConnectionAction; import com.x.base.core.project.connection.ConnectionAction; import com.x.base.core.project.gson.XGsonBuilder; import com.x.base.core.project.http.ActionResult.Type; +import com.x.base.core.project.http.EffectivePerson; import com.x.base.core.project.jaxrs.StandardJaxrsAction; import com.x.base.core.project.jaxrs.WrapBoolean; import com.x.base.core.project.tools.DefaultCharset; +import com.x.program.center.ThisApplication; class BaseAction extends StandardJaxrsAction { @@ -124,6 +127,19 @@ class BaseAction extends StandardJaxrsAction { return resp.getData(ReturnWoBoolean.class).getValue(); } + public void configFlush(EffectivePerson effectivePerson) throws Exception { + Config.flush(); + ThisApplication.context().applications().values().forEach(o -> { + o.stream().forEach(app -> { + try { + CipherConnectionAction.get(effectivePerson.getDebugger(), app, "cache", "config", "flush"); + } catch (Exception e) { + e.printStackTrace(); + } + }); + }); + } + private static class ReturnWoBoolean extends WrapBoolean { }