weaver-demo/esign_weaver_java.git

package foundation.system;
 
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Date;
import java.util.Iterator;
import java.util.List;
 
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
 
import foundation.capacity.Actor;
import foundation.capacity.ActorBucket;
import foundation.capacity.ActorTarget;
import foundation.capacity.ActorsRuntime;
import foundation.capacity.role.Role;
import foundation.capacity.role.RoleMenu;
import foundation.capacity.role.RolePage;
import foundation.dao.preload.Bucket;
import foundation.dao.preload.Tree;
import foundation.data.entity.Entity;
import foundation.data.entity.IDictionary;
import foundation.dictionary.DictionaryBucket;
import foundation.geography.CityBucket;
import foundation.geography.CountyBucket;
import foundation.geography.ProvinceBucket;
import foundation.handler.Handler;
import foundation.json.JObjectReader;
import foundation.json.JSONBuilder;
import foundation.menu.Menu;
import foundation.menu.MenuTree;
import foundation.persist.NamedSQL;
import foundation.persist.SQLRunner;
import foundation.token.UserToken;
import foundation.user.OnlineUser;
import foundation.user.User;
import foundation.user.UserBucket;
import foundation.util.Util;
 
public class ClientHandler extends Handler {
 
    protected static Logger logger;
    private static DateFormat dateFormat;
    
    static {
        logger = LogManager.getLogger(ClientHandler.class); 
        dateFormat = new SimpleDateFormat("yyyy-MM-dd");
    }
    
    @Override
    protected void publishMethod() {
        //1. login
        addMethod("login");
        
        //2. login
        addMethod("systemLogin");
        
        //3. get user
        addMethod("getUser");
        
        //4. change password
        addMethod("changePassword");
        
        //5. get user capacity
        addMethod("getCapacity");
        
        //6. change user actor
        addMethod("changeCurrentActor");
        
        //7. get menu tree
        addMethod("getMenuTree");
        
        //8. get menu tree all
        addMethod("getMenuTreeAll");
        
        //9. get page
        addMethod("getPage");
        
        //10.  获取字典
        addMethod("getDictionarys");
        
        //11.  获取一个字典
        addMethod("getOneDictionary");
        
        //12. 获取省份列表
        addMethod("getProvinceList");
        
        //13. 获取城市列表
        addMethod("getCityList");
        
        //14.  得到区县列表
        addMethod("getCountyList");
        
        //15. 得到系统当前日期
        addMethod("getCalendar");
        
        //16. 得到对应角色的菜单页面
        addMethod("getPageByRole");
        
        //1. 获取角色页面button、tab
        addMethod("getBtnTabByRolePage");
    }
    
    public void login() throws Exception {
        JObjectReader dataReader = dataPool.getJObjectReader();
        
        if (dataReader.isEmpty()) {
            resultPool.setSuccess(false);
            return;
        }
        
        String userName = dataReader.getString("userName");
        String password = dataReader.getString("password");
        
        NamedSQL namedSQL = NamedSQL.getInstance("getUser");
        namedSQL.setParam("userName", userName);
        namedSQL.setParam("password", password);
        namedSQL.setParam("is_active", "T");
        
        Entity entity = SQLRunner.getEntity(namedSQL);
        
        if (entity == null) {
            resultPool.setSuccess(false);
            return;
        }
        
        String userCaption = entity.getString("employee_name");
        
        if (Util.isEmpty(userCaption)) {
            userCaption = entity.getString("name");
        }
        
        LoginResult result = new LoginResult(entity);
        resultPool.addValue("data", result);
    }
    
    public void systemLogin() throws Exception {
        JObjectReader dataReader = dataPool.getJObjectReader();
        
        if (dataReader.isEmpty()) {
            resultPool.setSuccess(false);
            return;
        }
 
        String secret = dataReader.getString("secret");
        String systemId = dataReader.getString("systemId");
        String userSecret = dataReader.getString("userSecret");
        String oaAccount = dataReader.getString("oaAccount");
        
        //1. 进行secret合法性检查
        boolean systemIdentify = "SystemOAWeaver".equalsIgnoreCase(systemId);
        boolean systemSecretentify = "KCMSIEUASKEOIQWANTVWOWPOWPPWIEIR".equalsIgnoreCase(secret);
        
        if (systemIdentify && systemSecretentify) {
            //2. 进行用户存在检查
            NamedSQL namedSQL = NamedSQL.getInstance("getUserByUsername");
            namedSQL.setParam("oaAccount", oaAccount);
            namedSQL.setParam("userSecret", userSecret);
            namedSQL.setParam("isActive", "T");
 
            Entity entity = SQLRunner.getEntity(namedSQL);
            
            if (entity == null) {
                resultPool.setSuccess(false);
                return;
            }
            
            String userCaption = entity.getString("employee_name");
            
            if (Util.isEmpty(userCaption)) {
                userCaption = entity.getString("name");
            }
            
            LoginResult result = new LoginResult(entity);
            resultPool.addValue("data", result);
        }
        else {
            resultPool.setSuccess(false);
            return;
        }
    }
 
    public void getUser() throws Exception {
        JObjectReader dataReader = dataPool.getJObjectReader();
        
        if (dataReader.isEmpty()) {
            resultPool.setSuccess(false);
            return;
        }
        
        OnlineUser user = OnlineUser.getInstance();
        
        if (user == null) {
            return;
        }
        
        user.collectActors();
        
        resultPool.addValue("user", user);
    }
    
    public void changePassword() throws Exception {
        JObjectReader dataReader = dataPool.getJObjectReader();
        
        if (dataReader.isEmpty()) {
            resultPool.setSuccess(false);
            return;
        }
        
        OnlineUser user = OnlineUser.getInstance();
        
        if (user == null) {
            return;
        }
        
        String oldPass = dataReader.getString("old_pass");
        String newPass = dataReader.getString("new_pass");
        
        if (Util.isEmpty(newPass) || Util.isEmpty(oldPass)) {
            resultPool.reportOneError("密码修改", "新密码或旧密码为空，不能修改");
            return;
        }
        
        if (!oldPass.equals(user.getPassword())) {
            resultPool.reportOneError("密码修改", "用户输入的旧密码不对，不能修改");
            return;
        }
        
        user.chagnePassword(newPass);
        
        resultPool.reportOneMessage("密码修改", "密码修改成功");
    }
    
    public void getActor() throws Exception {
        JObjectReader dataReader = dataPool.getJObjectReader();
        String token = null;
        
        if (dataReader.isEmpty()) {
            resultPool.setSuccess(false);
            return;
        }
        
        String userId = dataReader.getString("userId");
        
        UserToken userToken = null;
        if (Util.isEmpty(userId)) {
            token = dataReader.getString("token");
            userToken = UserToken.getInstance(token);
        }
        
        UserBucket userBucket = UserBucket.getInstance();
        
        if (!Util.isEmpty(token) && userToken != null) {
            userId = userToken.getUserId();
        }
        User user = userBucket.get(userId);
        
        if (user == null) {
            return;
        }
        
        ActorsRuntime actors = user.getActorsRuntime();
        resultPool.addValue("actors", actors);
    }
    
    public void changeCurrentActor() throws Exception {
        JObjectReader dataReader = dataPool.getJObjectReader();
        String actorId = dataReader.getString("actor_target_id");
        
        OnlineUser user = OnlineUser.getInstance();
        
        if (user == null) {
            return;
        }
        
        ActorTarget actor = user.changeCurrentCapacity(actorId);
        resultPool.addValue("capacity", actor);
    }
    
    public void getMenuTreeAll() throws Exception {
        LoadMonitor monitor = new LoadMonitor();
        
        MenuTree menuTree = monitor.get(MenuTree.class);
        List<Menu> menuList = new ArrayList<Menu>();
        Iterator<Menu> menuIterator = menuTree.iterator();
        
        while(menuIterator.hasNext()) {
              Menu menu = menuIterator.next();
              if (Util.isEmpty(menu.getParentId())) {
                  menuList.add(menuTree.get(menu.getId()));
              }
        }
    
        resultPool.addValue("menus", menuList);
    }
    
    public void getMenuTree() throws Exception {
        JObjectReader dataReader = dataPool.getJObjectReader();
        String actorId = dataReader.getString("actor_id");
        
        //1. 当前用获取自己的菜单
        if (Util.isEmpty(actorId)) {
            OnlineUser user = OnlineUser.getInstance();
            ActorTarget actor = user.getCurrentActor();
            
            if (actor == null) {
                return;
            }
            
            Role role = actor.getRoleRuntime();
            Tree<RoleMenu> roleMenuTree = role.getMenuTree();
            
            resultPool.addValue("menus", roleMenuTree);
            return;
        }
        
        //2. 根据角色获取菜单
        Actor actor = ActorBucket.getInstance().get(actorId);
        
        if (actor == null) {
            return;
        }
        
        Role role = actor.getRoleRuntime();
        Tree<RoleMenu> roleMenuTree = role.getMenuTree();
        
        resultPool.addValue("roleAddress", role.toString());
        resultPool.addValue("menus", roleMenuTree);
    }
    
    public void getPageByRole() throws Exception {
        JObjectReader dataReader = dataPool.getJObjectReader();
        String actorId = dataReader.getString("actor_id");
        
        //1. 根据角色获取菜单
        Actor actor = ActorBucket.getInstance().get(actorId);
        
        if (actor == null) {
            return;
        }
        
        Role role = actor.getRoleRuntime();
        Bucket<RolePage> pages = role.getPages();
        
        resultPool.addValue("pages", pages);        
    }    
    
    public void getPage() throws Exception {
        JObjectReader dataReader = dataPool.getJObjectReader();
        String pageId = dataReader.getString(ISystem.PageId);
        String menuId = dataReader.getString(ISystem.MenuId);
        
        OnlineUser user = OnlineUser.getInstance();
        
        if (user == null) {
            return;
        }
        
        ActorTarget actor = user.getCurrentActor();
        
        if (actor == null) {
            return;
        }
        
        Role role = actor.getRoleRuntime();
        String pageKey = RolePage.createKey(menuId, pageId);
        RolePage rolePage = role.getPageById(pageKey);
        resultPool.addValue("page", rolePage);
    }
 
    public void getDictionarys() throws Exception {
        DictionaryBucket dictionarys = DictionaryBucket.getInstance();
        resultPool.addValue("dictionarys", dictionarys);
    }
    
    public void getOneDictionary() throws Exception {
        JObjectReader dataReader = dataPool.getJObjectReader();
        String dictionaryName = dataReader.getString(ISystem.DictionaryCode);
        
        DictionaryBucket dictionaryBucket = DictionaryBucket.getInstance();
        IDictionary dictionary = dictionaryBucket.getDictionary(dictionaryName);
        
        resultPool.addValue("dictionary", dictionary);
    }
    
    public void getProvinceList() throws Exception {
        ProvinceBucket provinceBucket = ProvinceBucket.getInstance();
        resultPool.addValue("provinces", provinceBucket);
    }
    
    public void getCityList() throws Exception {
        CityBucket cityBucket = CityBucket.getInstance();
        resultPool.addValue("citys", cityBucket);
    }
    
    public void getCountyList() throws Exception {
        CountyBucket countyBucket = CountyBucket.getInstance();
        resultPool.addValue("countys", countyBucket);
    }
    
    public void getCalendar() throws Exception {
        //1.
        Date now = new Date();
        Calendar calendar = Calendar.getInstance();
        calendar.setTime(now);
        
        //2.
        int year = calendar.get(Calendar.YEAR);
        int month = calendar.get(Calendar.MONTH) + 1;
        
        String monthNo = year + "" + (month < 10 ? "0" + month : month); 
        String date = dateFormat.format(now);
        
        //3.
        JSONBuilder builder = new JSONBuilder();
        
        builder.beginObject();
        builder.write("year", year);
        builder.write("month", month);
        builder.write("monthNo", monthNo);
        builder.write("day", calendar.get(Calendar.DAY_OF_MONTH));
        builder.write("date", date);
        builder.endObject();
        
        resultPool.addValue("calendar", builder);
    }    
    
}