package foundation.system;
|
|
import java.util.Set;
|
|
import org.apache.logging.log4j.LogManager;
|
import org.apache.logging.log4j.Logger;
|
import org.json.JSONObject;
|
|
import foundation.action.ActionProvider;
|
import foundation.capacity.role.RoleAgent;
|
import foundation.capacity.role.RoleBucket;
|
import foundation.capacity.role.RoleMenu;
|
import foundation.dao.Filter;
|
import foundation.dao.preload.Tree;
|
import foundation.data.entity.Entity;
|
import foundation.data.entity.EntitySet;
|
import foundation.data.object.DataObject;
|
import foundation.data.object.EntitySaver;
|
import foundation.json.JArrayReader;
|
import foundation.json.JObjectReader;
|
import foundation.json.JSONReader;
|
import foundation.json.JType;
|
import foundation.menu.Menu;
|
import foundation.menu.MenuTree;
|
import foundation.persist.NamedSQL;
|
import foundation.persist.SQLRunner;
|
import foundation.translator.ValueType;
|
import foundation.user.User;
|
import foundation.user.UserBucket;
|
import foundation.util.Util;
|
|
|
public class FrontHandler extends ActionProvider {
|
|
protected static Logger logger;
|
|
static {
|
logger = LogManager.getLogger(FrontHandler.class);
|
}
|
|
public FrontHandler() {
|
|
}
|
|
@Override
|
protected void publishMethod() {
|
//1. save user
|
addMethod("saveUser");
|
|
//2. delete user
|
addMethod("deleteUser");
|
|
//3. save user capacity
|
addMethod("saveCaptcity");
|
|
//4. save role menus
|
addMethod("saveRoleMenus");
|
}
|
|
public void saveUser() throws Exception {
|
//1. read user
|
JObjectReader jObjectReader = dataReader.getReader("data", JType.Object);
|
JObjectReader userReader = jObjectReader.getReader("user", JType.Object);
|
|
DataObject dataObject = DataObject.getInstance("sys_user");
|
Entity entity = dataObject.createTableEmptyEntity();
|
|
for (JSONReader item: userReader) {
|
String name = item.getName();
|
Object value = item.getValue();
|
|
if (!entity.contains(name)) {
|
continue;
|
}
|
|
if (JSONObject.NULL == value) {
|
entity.set(name, ValueType.Null);
|
continue;
|
}
|
|
value = Util.decodeValue(value);
|
entity.set(name, value);
|
}
|
|
//2. save
|
String name = entity.getString("name");
|
entity.set("org_id", "org-01");
|
|
if (entity.isEmptyValue("password")) {
|
entity.set("password", name);
|
}
|
|
dataObject.saveEntity(entity);
|
|
//3. load cache
|
UserBucket userBucket = UserBucket.getInstance();
|
User user = new User();
|
user.load(entity);
|
|
String userId = user.getId();
|
User old = userBucket.get(userId);
|
if (old == null) {
|
userBucket.loadOne(userId, user);
|
}
|
else {
|
old.load(entity);
|
}
|
|
//4. result
|
dataWriter.addValue("user", user);
|
}
|
|
public void deleteUser() throws Exception {
|
String userId = dataReader.getString("id");
|
UserBucket userBucket = UserBucket.getInstance();
|
|
User user = userBucket.get(userId);
|
|
if (user == null) {
|
return;
|
}
|
|
DataObject dataObject = DataObject.getInstance("sys_user");
|
dataObject.deleteEntity(userId);
|
|
userBucket.remove(userId);
|
|
dataWriter.addValue("user", user);
|
}
|
|
public void saveCaptcity() throws Exception {
|
String userId = dataReader.getString("user_id");
|
UserBucket userBucket = UserBucket.getInstance();
|
|
User user = userBucket.get(userId);
|
|
if (user == null) {
|
return;
|
}
|
|
JArrayReader capacitys = dataReader.getReader("capacitys", JType.Array);
|
|
if (capacitys == null) {
|
return;
|
}
|
|
user.saveCapacitys(capacitys);
|
}
|
|
public void saveRoleMenus() throws Exception {
|
//1. get user menus
|
String roleId = dataReader.getString("role_code");
|
RoleBucket roleBucket = RoleBucket.getInstance();
|
RoleAgent role = roleBucket.get(roleId);
|
|
if (role == null) {
|
return;
|
}
|
|
Tree<RoleMenu> roleMenuTree = role.getMenuTree();
|
|
//2. get changes
|
JArrayReader array = dataReader.getReader("menus", JType.Array);
|
|
if (array == null) {
|
return;
|
}
|
|
//3. save changes
|
Set<String> changes = array.getStringSet();
|
|
MenuTree menuTree = MenuTree.getInstance();
|
|
DataObject dataObject = DataObject.getInstance("sys_role_menu");
|
String roleCode = role.getCode();
|
|
for (RoleMenu roleMenu: roleMenuTree) {
|
String id = roleMenu.getId();
|
|
if (!changes.contains(id)) {
|
Filter filter = new Filter();
|
filter.add("menu_id", id);
|
filter.add("role_code", roleCode);
|
dataObject.deleteEntity(filter);
|
}
|
}
|
|
for (String id: changes) {
|
if (!roleMenuTree.contains(id)) {
|
EntitySaver saver = dataObject.createEntitySaver();
|
saver.set("menu_id", id);
|
saver.set("role_code", roleCode);
|
saver.set("is_active", "T");
|
saver.insert();
|
}
|
}
|
|
//4. reload
|
Tree<RoleMenu> newTree = new Tree<RoleMenu>();
|
|
NamedSQL namedSQL = NamedSQL.getInstance("getOneRoleMenus");
|
namedSQL.setParam("role_code", roleCode);
|
EntitySet entitySet = SQLRunner.getEntitySet(namedSQL);
|
|
for (Entity entity: entitySet) {
|
String menuId = entity.getString("menu_id");
|
Menu menu = menuTree.get(menuId);
|
|
if (menu == null) {
|
continue;
|
}
|
|
RoleMenu roleMenu = new RoleMenu(menu);
|
newTree.loadOne(roleMenu.getId(), roleMenu);
|
}
|
|
newTree.onAfterLoad();
|
role.resetMenuTree(newTree);
|
|
//4. result
|
dataWriter.addValue("menus", roleMenuTree);
|
}
|
}
|
