commit 8ff547802e735ef23253795f04add72a921e5c49 Author: pioneer Date: Thu Nov 24 10:25:18 2022 +0800 open diff --git a/README.md b/README.md new file mode 100644 index 0000000..169dd94 --- /dev/null +++ b/README.md @@ -0,0 +1,6 @@ +# open-JSD-9557 + +JSD-9557 单点集成\ +免责说明：该源码为第三方爱好者提供，不保证源码和方案的可靠性，也不提供任何形式的源码教学指导和协助！\ +仅作为开发者学习参考使用！禁止用于任何商业用途！\ +为保护开发者隐私，开发者信息已隐去！若原开发者希望公开自己的信息，可联系【pioneer】处理。 \ No newline at end of file diff --git a/lib/commons-codec-1.3.jar b/lib/commons-codec-1.3.jar new file mode 100644 index 0000000..957b675 Binary files /dev/null and b/lib/commons-codec-1.3.jar differ diff --git a/lib/commons-logging.jar b/lib/commons-logging.jar new file mode 100644 index 0000000..2ff9bbd Binary files /dev/null and b/lib/commons-logging.jar differ diff --git a/lib/jackson-all-1.9.1.jar b/lib/jackson-all-1.9.1.jar new file mode 100644 index 0000000..f92126f Binary files /dev/null and b/lib/jackson-all-1.9.1.jar differ diff --git a/lib/yum-oauth2-sdk4prod.jar b/lib/yum-oauth2-sdk4prod.jar new file mode 100644 index 0000000..1ba7d19 Binary files /dev/null and b/lib/yum-oauth2-sdk4prod.jar differ diff --git a/lib/yum-oauth2-sdk4test.jar b/lib/yum-oauth2-sdk4test.jar new file mode 100644 index 0000000..4f813f6 Binary files /dev/null and b/lib/yum-oauth2-sdk4test.jar differ diff --git a/plugin.xml b/plugin.xml new file mode 100644 index 0000000..649304f --- /dev/null +++ b/plugin.xml @@ -0,0 +1,26 @@ + + com.eco.plugin.xx.bssso + + yes + 1.0.20 + 10.0 + 2018-07-31 + fr.open + + + com.eco.plugin.xx.bssso + + + + + + + + + + + + + + \ No newline at end of file diff --git a/src/main/java/com/eco/plugin/xx/bssso/config/InitializeMonitor.java b/src/main/java/com/eco/plugin/xx/bssso/config/InitializeMonitor.java new file mode 100644 index 0000000..5dc001d --- /dev/null +++ b/src/main/java/com/eco/plugin/xx/bssso/config/InitializeMonitor.java @@ -0,0 +1,21 @@ +package com.eco.plugin.xx.bssso.config; + +import com.fr.plugin.context.PluginContext; +import com.fr.plugin.observer.inner.AbstractPluginLifecycleMonitor; + +/** + * @author xx + * @version 10.0 + * Created by xx on 2021-12-03 + */ +public class InitializeMonitor extends AbstractPluginLifecycleMonitor { + @Override + public void afterRun(PluginContext pluginContext) { + PluginSimpleConfig.getInstance(); + } + + @Override + public void beforeStop(PluginContext pluginContext) { + + } +} diff --git a/src/main/java/com/eco/plugin/xx/bssso/config/PluginSimpleConfig.java b/src/main/java/com/eco/plugin/xx/bssso/config/PluginSimpleConfig.java new file mode 100644 index 0000000..f368af3 --- /dev/null +++ b/src/main/java/com/eco/plugin/xx/bssso/config/PluginSimpleConfig.java @@ -0,0 +1,99 @@ +package com.eco.plugin.xx.bssso.config; + +import com.fr.config.*; +import com.fr.config.holder.Conf; +import com.fr.config.holder.factory.Holders; +import com.fr.intelli.record.Focus; +import com.fr.intelli.record.Original; +import com.fr.record.analyzer.EnableMetrics; + +@Visualization(category = "单点登录配置") +@EnableMetrics +public class PluginSimpleConfig extends DefaultConfiguration { + + private static volatile PluginSimpleConfig config = null; + + @Focus(id="com.eco.plugin.xx.bssso.config", text = "单点登录配置", source = Original.PLUGIN) + public static PluginSimpleConfig getInstance() { + if (config == null) { + config = ConfigContext.getConfigInstance(PluginSimpleConfig.class); + } + return config; + } + + @Identifier(value = "clientId", name = "应用id", description = "应用id", status = Status.SHOW) + private Conf clientId = Holders.simple(""); + + @Identifier(value = "secret", name = "密钥", description = "密钥", status = Status.SHOW) + private Conf secret = Holders.simple(""); + + @Identifier(value = "ssoprefix", name = "统一平台前缀", description = "统一平台前缀", status = Status.SHOW) + private Conf ssoprefix = Holders.simple(""); + + @Identifier(value = "logoutUrl", name = "登出跳转地址", description = "登出跳转地址", status = Status.SHOW) + private Conf logoutUrl = Holders.simple(""); + + @Identifier(value = "qxurl", name = "应用权限接口", description = "应用权限接口", status = Status.SHOW) + private Conf qxurl = Holders.simple(""); + + @Identifier(value = "index", name = "帆软首页", description = "帆软首页", status = Status.SHOW) + private Conf index = Holders.simple(""); + + public String getQxurl() { + return qxurl.get(); + } + + public void setQxurl(String url) { + this.qxurl.set(url); + } + + + public String getClientId() { + return clientId.get(); + } + + public void setClientId(String url) { + this.clientId.set(url); + } + + public String getSsoprefix() { + return ssoprefix.get(); + } + + public void setSsoprefix(String url) { + this.ssoprefix.set(url); + } + + public String getSecret() { + return secret.get(); + } + + public void setSecret(String url) { + this.secret.set(url); + } + + public String getLogoutUrl() { + return logoutUrl.get(); + } + + public void setLogoutUrl(String url) { + this.logoutUrl.set(url); + } + + public String getIndex() { + return index.get(); + } + + public void setIndex(String url) { + this.index.set(url); + } + + + + @Override + public Object clone() throws CloneNotSupportedException { + PluginSimpleConfig cloned = (PluginSimpleConfig) super.clone(); + return cloned; + } + +} diff --git a/src/main/java/com/eco/plugin/xx/bssso/controller/ControllerRegisterProvider.java b/src/main/java/com/eco/plugin/xx/bssso/controller/ControllerRegisterProvider.java new file mode 100644 index 0000000..086b219 --- /dev/null +++ b/src/main/java/com/eco/plugin/xx/bssso/controller/ControllerRegisterProvider.java @@ -0,0 +1,14 @@ +package com.eco.plugin.xx.bssso.controller; + +import com.fr.decision.fun.impl.AbstractControllerRegisterProvider; +import com.fr.plugin.transform.FunctionRecorder; + +@FunctionRecorder +public class ControllerRegisterProvider extends AbstractControllerRegisterProvider { + @Override + public Class[] getControllers() { + return new Class[]{ + UtilsController.class + }; + } +} diff --git a/src/main/java/com/eco/plugin/xx/bssso/controller/UtilsController.java b/src/main/java/com/eco/plugin/xx/bssso/controller/UtilsController.java new file mode 100644 index 0000000..00f2d49 --- /dev/null +++ b/src/main/java/com/eco/plugin/xx/bssso/controller/UtilsController.java @@ -0,0 +1,124 @@ +package com.eco.plugin.xx.bssso.controller; + +import com.eco.plugin.xx.bssso.config.PluginSimpleConfig; +import com.eco.plugin.xx.bssso.db.bean.DBEntity; +import com.eco.plugin.xx.bssso.db.controller.DBController; +import com.eco.plugin.xx.bssso.utils.FRUtils; +import com.eco.plugin.xx.bssso.utils.HttpUtils; +import com.eco.plugin.xx.bssso.utils.Utils; +import com.fr.decision.webservice.annotation.LoginStatusChecker; +import com.fr.general.data.TableDataException; +import com.fr.plugin.transform.FunctionRecorder; +import com.fr.third.springframework.stereotype.Controller; +import com.fr.third.springframework.web.bind.annotation.GetMapping; +import com.fr.third.springframework.web.bind.annotation.PostMapping; +import com.fr.third.springframework.web.bind.annotation.RequestBody; +import com.fr.third.springframework.web.bind.annotation.ResponseBody; + +import javax.servlet.http.HttpServletRequest; +import javax.servlet.http.HttpServletResponse; +import java.util.ArrayList; +import java.util.HashMap; +import java.util.List; +import java.util.Map; + +@Controller +@LoginStatusChecker(required = false) +@FunctionRecorder +public class UtilsController { + + @GetMapping(value = "/isAdmin") + @ResponseBody + public Map isAdmin(HttpServletRequest request, HttpServletResponse response) throws Exception { + Map result = new HashMap(); + String username = request.getParameter("username"); + + result.put("isadmin", Utils.isAdmin(username)); + + return result; + } + + @GetMapping(value = "/getByUsername") + @ResponseBody + public Boolean getByUsername(HttpServletRequest request, HttpServletResponse response){ + String username = request.getParameter("username"); + + DBEntity dbEntity = DBController.getByUsername(username); + + if(dbEntity == null){ + return false; + } + + return Utils.isNotNullStr(dbEntity.getSelected()) && Boolean.parseBoolean(dbEntity.getSelected()); + } + + @PostMapping(value = "/updateSelected") + @ResponseBody + public Boolean updateSelected(@RequestBody DBEntity dbEntity2, HttpServletResponse response) throws Exception { + DBEntity dbEntity = DBController.getByUsername(dbEntity2.getUsername()); + + if(dbEntity == null || Utils.isNullStr(dbEntity.getUsername())){ + dbEntity.setId(Utils.uuid()); + dbEntity.setUsername(dbEntity2.getUsername()); + dbEntity.setSelected(dbEntity2.getSelected()); + }else{ + dbEntity.setSelected(dbEntity2.getSelected()); + } + + //调用webservice + boolean flag = false; + try{ + flag = callWebservice(dbEntity); + } + catch (Exception e){ + FRUtils.FRLogError("获取psid异常>>"+e.getMessage()); + } + + if(!flag){ + return false; + } + + //同步修改sso同步表状态 + List updateList = new ArrayList(); + updateList.add(dbEntity); + + return DBController.batch(updateList,null); + } + + private boolean callWebservice(DBEntity dbEntity) throws TableDataException { + String webserviceStr = "\n" + + " \n" + + " \n" + + " \n" + + " \n" + + " #psid\n" + + " #selected\n" + + " \n" + + " \n" + + " #clientid\n" + + " #secret\n" + + " \n" + + " \n" + + ""; + + String psid = dbEntity.getUsername(); + + FRUtils.FRLogInfo("psid>>"+psid); + String selected = String.valueOf(dbEntity.getSelected()); + + PluginSimpleConfig psc = PluginSimpleConfig.getInstance(); + String clientid = psc.getClientId(); + String secret = psc.getSecret(); + + String url = psc.getQxurl(); + webserviceStr = webserviceStr.replace("#psid",psid).replace("#selected",selected).replace("#clientid",clientid) + .replace("#secret",secret); + + String result = HttpUtils.HttpPostText(url,webserviceStr); + + return Utils.isNotNullStr(result); + } + +} diff --git a/src/main/java/com/eco/plugin/xx/bssso/db/bean/DBEntity.java b/src/main/java/com/eco/plugin/xx/bssso/db/bean/DBEntity.java new file mode 100644 index 0000000..2d0680b --- /dev/null +++ b/src/main/java/com/eco/plugin/xx/bssso/db/bean/DBEntity.java @@ -0,0 +1,42 @@ +package com.eco.plugin.xx.bssso.db.bean; + +import com.fr.stable.db.entity.BaseEntity; +import com.fr.stable.db.entity.TableAssociation; +import com.fr.third.javax.persistence.Column; +import com.fr.third.javax.persistence.Entity; +import com.fr.third.javax.persistence.Table; + +/** + * @author xx + * @version 10.0 + * Created by xx on 2021-07-29 + **/ +@Entity +@Table(name = "plugin_xx_entity") +@TableAssociation(associated = true) +public class DBEntity extends BaseEntity { + + //用户名 + @Column(name = "username") + private String username = null; + + //是否同意 true or false + @Column(name = "selected") + private String selected = null; + + public String getUsername() { + return username; + } + + public void setUsername(String userid) { + this.username = userid; + } + + public String getSelected() { + return selected; + } + + public void setSelected(String selected) { + this.selected = selected; + } +} diff --git a/src/main/java/com/eco/plugin/xx/bssso/db/controller/DBController.java b/src/main/java/com/eco/plugin/xx/bssso/db/controller/DBController.java new file mode 100644 index 0000000..68ad2a9 --- /dev/null +++ b/src/main/java/com/eco/plugin/xx/bssso/db/controller/DBController.java @@ -0,0 +1,139 @@ +package com.eco.plugin.xx.bssso.db.controller; + +import com.eco.plugin.xx.bssso.db.bean.DBEntity; +import com.eco.plugin.xx.bssso.db.dao.DBDao; +import com.eco.plugin.xx.bssso.utils.FRUtils; +import com.fr.db.fun.impl.AbstractDBAccessProvider; +import com.fr.plugin.transform.FunctionRecorder; +import com.fr.record.analyzer.EnableMetrics; +import com.fr.stable.db.accessor.DBAccessor; +import com.fr.stable.db.action.DBAction; +import com.fr.stable.db.dao.DAOContext; +import com.fr.stable.db.dao.DAOProvider; + +import java.util.ArrayList; +import java.util.List; + +/** + * @author xx + * @version 10.0 + * Created by xx on 2021-07-29 + **/ +@EnableMetrics +@FunctionRecorder +public class DBController extends AbstractDBAccessProvider { + + private static DBAccessor accessor; + + public static DBAccessor getAccessor() { + return accessor; + } + + @Override + public DAOProvider[] registerDAO() { + return new DAOProvider[]{ + DBDao.DAO + }; + } + + @Override + public void onDBAvailable(DBAccessor accessor) { + DBController.accessor = accessor; + } + + + /** + * 批量操作 + * @param addOrUpdate + * @param delete + * @return + */ + public static boolean batch(List addOrUpdate, List delete){ + //新增或者删除 + if(addOrUpdate != null && addOrUpdate.size() > 0){ + for(final DBEntity dbe : addOrUpdate){ + + try{ + accessor.runDMLAction(new DBAction() { + @Override + public Boolean run(DAOContext context) throws Exception { + DBEntity ae =context.getDAO(DBDao.class).getById(dbe.getId()); + if(ae != null ){ + context.getDAO(DBDao.class).update(dbe); + }else{ + context.getDAO(DBDao.class).add(dbe); + } + return true; + } + }); + }catch(Throwable e){ + FRUtils.FRLogError("batch addOrUpdate exception ->"+e.getMessage() + dbe.toString()); + } + } + } + + if(delete != null && delete.size() > 0){ + for(final DBEntity dbe : delete){ + + try{ + accessor.runDMLAction(new DBAction() { + @Override + public Boolean run(DAOContext context) throws Exception { + context.getDAO(DBDao.class).remove(dbe.getId()); + return true; + } + }); + }catch(Throwable e){ + FRUtils.FRLogError("batch delete exception ->"+e.getMessage() + dbe.toString()); + } + } + } + + return true; + } + + + /** + * 根据username获取信息 + * @param username + * @return + */ + public static DBEntity getByUsername(final String username){ + try{ + return accessor.runQueryAction(new DBAction() { + @Override + public DBEntity run(DAOContext context) throws Exception { + DBEntity result = context.getDAO(DBDao.class).getByUsername(username); + + return result == null ? new DBEntity() : result; + } + }); + }catch(Throwable e){ + FRUtils.FRLogError("exception getByUsername:"+e.getMessage()); + } + + return new DBEntity(); + } + + /** + * 获取全部信息 + * @param + * @return + */ + public static List getAllUser(){ + try{ + return accessor.runQueryAction(new DBAction>() { + @Override + public List run(DAOContext context) throws Exception { + List result = context.getDAO(DBDao.class).getAllUser(); + + return result == null ? new ArrayList() : result; + } + }); + }catch(Throwable e){ + FRUtils.FRLogError("exception getByUsername:"+e.getMessage()); + } + + return new ArrayList(); + } +} diff --git a/src/main/java/com/eco/plugin/xx/bssso/db/dao/DBDao.java b/src/main/java/com/eco/plugin/xx/bssso/db/dao/DBDao.java new file mode 100644 index 0000000..df46e68 --- /dev/null +++ b/src/main/java/com/eco/plugin/xx/bssso/db/dao/DBDao.java @@ -0,0 +1,73 @@ +package com.eco.plugin.xx.bssso.db.dao; + +import com.eco.plugin.xx.bssso.db.bean.DBEntity; +import com.fr.stable.db.dao.BaseDAO; +import com.fr.stable.db.dao.DAOProvider; +import com.fr.stable.db.session.DAOSession; +import com.fr.stable.query.QueryFactory; +import com.fr.stable.query.condition.QueryCondition; +import com.fr.stable.query.restriction.RestrictionFactory; +import java.util.List; + +/** + * @author xx + * @version 10.0 + * Created by xx on 2021-12-03 + **/ +public class DBDao extends BaseDAO { + + public DBDao(DAOSession session) { + super(session); + } + + @Override + protected Class getEntityClass() { + return DBEntity.class; + } + + public final static DAOProvider DAO = new DAOProvider() { + @Override + public Class getEntityClass() { + return DBEntity.class; + } + + @Override + public Class getDAOClass() { + return DBDao.class; + } + }; + + public void add(DBEntity entity) throws Exception { + getSession().persist(entity); + } + + public void remove(String id) throws Exception { + getSession().remove(QueryFactory.create() + .addRestriction(RestrictionFactory.eq("id", id)), + this.getEntityClass()); + } + + public void update(DBEntity entity) throws Exception { + getSession().merge(entity); + } + + + public DBEntity getByUsername(String username) throws Exception { + QueryCondition condition = QueryFactory.create() + .addRestriction(RestrictionFactory.eq("username", username)); + + return findOne(condition); + } + + + public List like(String pid, String type)throws Exception{ + QueryCondition condition = QueryFactory.create() + .addRestriction(RestrictionFactory.like("", pid)).addRestriction(RestrictionFactory.like(DBEntity.COLUMN_ID,type)); + return find(condition); + } + + public List getAllUser() throws Exception { + QueryCondition condition = QueryFactory.create(); + return find(condition); + } +} diff --git a/src/main/java/com/eco/plugin/xx/bssso/filter/SSOFilter.java b/src/main/java/com/eco/plugin/xx/bssso/filter/SSOFilter.java new file mode 100644 index 0000000..fbe1a67 --- /dev/null +++ b/src/main/java/com/eco/plugin/xx/bssso/filter/SSOFilter.java @@ -0,0 +1,124 @@ +package com.eco.plugin.xx.bssso.filter; + +import com.eco.plugin.xx.bssso.config.PluginSimpleConfig; +import com.eco.plugin.xx.bssso.oauthservice.OAuthService; +import com.eco.plugin.xx.bssso.oauthservice.UserInfo; +import com.eco.plugin.xx.bssso.utils.FRUtils; +import com.eco.plugin.xx.bssso.utils.Utils; +import com.fr.decision.fun.impl.AbstractGlobalRequestFilterProvider; +import com.fr.plugin.context.PluginContexts; +import com.fr.record.analyzer.EnableMetrics; +import com.fr.stable.fun.Authorize; +import com.yum.secure.exceptions.OAuthApiException; +import com.yum.secure.model.Token; +import javax.servlet.FilterChain; +import javax.servlet.http.HttpServletRequest; +import javax.servlet.http.HttpServletResponse; +import java.io.IOException; + +@EnableMetrics +@Authorize(callSignKey = "com.eco.plugin.xx.bssso") +public class SSOFilter extends AbstractGlobalRequestFilterProvider { + @Override + public String filterName() { + return "bsssoFilter"; + } + + @Override + public String[] urlPatterns() { + return new String[]{"/*"}; + } + + @Override + public void doFilter(HttpServletRequest req, HttpServletResponse res, FilterChain chain ){ + if(PluginContexts.currentContext().isAvailable()){ + //code + String code = req.getParameter("code"); + + //是否放行 + boolean release = isRelease(req); + + if(release){ + release(req,res,chain); + return; + } + + PluginSimpleConfig psc = PluginSimpleConfig.getInstance(); + String clientid = psc.getClientId(); + String secret = psc.getSecret(); + String url = FRUtils.getAllUrl(req); + FRUtils.FRLogInfo("ysUrl:"+url); + url = Utils.removeCode(url); + + url = psc.getIndex()+url.substring(url.indexOf("/decision")+9,url.length()); + + FRUtils.FRLogInfo("url:"+url); + + OAuthService oAuthService = new OAuthService(clientid,secret,url); + String oauthurl = oAuthService.getAuthorizationUrl(); + + if(Utils.isNullStr(code)){ + //跳转认证中心 + redirect(oauthurl,res); + return; + } + + //获取token + Token token = getToken(code,oAuthService); + + //获取userInfo + UserInfo userInfo = null; + try { + userInfo = new UserInfo(token).requestUserInfo(); + } catch (OAuthApiException e) { + FRUtils.FRLogInfo("获取用户信息异常:"+e.getMessage()); + } + String username = userInfo.getYumPSID().toUpperCase(); + + + //登录 + FRUtils.login(req,res,username,url); + } + + release(req,res,chain); + } + + private boolean isRelease(HttpServletRequest req) { + String url = FRUtils.getAllUrl(req); + String reft = req.getParameter("ref_t"); + + boolean isLogin = FRUtils.isLogin(req); + boolean isRemote = url.contains("remote"); + boolean isLoginPage = url.contains("login")||url.contains("decision/file")||url.contains("decision/resource")||url.contains("decision/system")||url.contains("query/ip"); + boolean isViewlt ="design".equals(reft); + return isLogin || isRemote || isLoginPage || isViewlt; + } + + //跳转认证中心 + private void redirect(String url,HttpServletResponse res) { + try { + FRUtils.FRLogInfo("authurl:"+url); + res.sendRedirect(url); + } catch (IOException e) { + FRUtils.FRLogInfo("跳转认证中心异常:"+e.getMessage()); + } + } + + //获取token + private Token getToken(String code,OAuthService oAuthService) { + Token token = oAuthService.getAccessToken(code); + return token; + } + + + + //放行拦截器 + private void release(HttpServletRequest req, HttpServletResponse res, FilterChain chain) { + try{ + chain.doFilter(req,res); + }catch (Exception e){ + FRUtils.FRLogInfo("拦截失败"); + } + } +} + diff --git a/src/main/java/com/eco/plugin/xx/bssso/function/AuthFunction.java b/src/main/java/com/eco/plugin/xx/bssso/function/AuthFunction.java new file mode 100644 index 0000000..f06e600 --- /dev/null +++ b/src/main/java/com/eco/plugin/xx/bssso/function/AuthFunction.java @@ -0,0 +1,151 @@ +package com.eco.plugin.xx.bssso.function; + +import com.eco.plugin.xx.bssso.config.PluginSimpleConfig; +import com.eco.plugin.xx.bssso.db.bean.DBEntity; +import com.eco.plugin.xx.bssso.db.controller.DBController; +import com.eco.plugin.xx.bssso.utils.FRUserUtils; +import com.eco.plugin.xx.bssso.utils.FRUtils; +import com.eco.plugin.xx.bssso.utils.HttpUtils; +import com.eco.plugin.xx.bssso.utils.Utils; +import com.fr.decision.webservice.bean.user.UserBean; +import com.fr.general.data.TableDataException; +import com.fr.plugin.context.PluginContexts; +import com.fr.script.AbstractFunction; +import com.fr.stable.fun.Authorize; + +import java.util.*; + +@Authorize(callSignKey = "com.eco.plugin.xx.bssso") +public class AuthFunction extends AbstractFunction { + + @Override + public Object run(Object[] objects) { + if(!PluginContexts.currentContext().isAvailable()) { + return "fail"; + } + + FRUtils.FRLogInfo("1"); + //帆软用户 + List allUser = new ArrayList(); + try { + allUser = FRUserUtils.getAllUsers(); + } catch (Exception e) { + FRUtils.FRLogError("获取全部用户异常"+e.getMessage()); + return "fail"; + } + FRUtils.FRLogInfo("2"); + + //自定义表用户 + List allStatus = DBController.getAllUser(); + FRUtils.FRLogInfo("3"); + + List delete = new ArrayList(); + List addOrUpdate = new ArrayList(); + + Map fruserMap = new HashMap(); + Map userMap = new HashMap(); + + for(UserBean user : allUser){ + String username = user.getUsername(); + try { + if(Utils.isAdmin(username)){ + continue; + } + + fruserMap.put(username,user); + } catch (Exception e) { + FRUtils.FRLogError("判断管理员失败:"+e.getMessage()); + return "fail"; + } + } + FRUtils.FRLogInfo("4"); + + //处理删除的用户 + for(DBEntity user : allStatus){ + String username = user.getUsername(); + userMap.put(username,user); + + //用户表中不存在 + if(!fruserMap.containsKey(username)){ + //将用户从状态表中删除 + delete.add(user); + //禁用sso状态 + user.setSelected("false"); + callWebservice(user); + } + } + FRUtils.FRLogInfo("5"); + + //处理新增的用户 + for(UserBean user : allUser){ + String username = user.getUsername(); + try { + if(Utils.isAdmin(username)){ + continue; + } + + //状态表中不存在 + if(!userMap.containsKey(username)){ + DBEntity db = new DBEntity(); + db.setId(UUID.randomUUID().toString()); + db.setUsername(username); + db.setSelected("true"); + + addOrUpdate.add(db); + //将sso状态设置为开启 + callWebservice(db); + } + } catch (Exception e) { + FRUtils.FRLogError("判断管理员失败:"+e.getMessage()); + return "fail"; + } + } + FRUtils.FRLogInfo("6"); + + DBController.batch(addOrUpdate,delete); + + return "success"; + } + + /** + * 修改sso用户权限 + * @param dbEntity + * @return + * @throws TableDataException + */ + private boolean callWebservice(DBEntity dbEntity){ + String webserviceStr = "\n" + + " \n" + + " \n" + + " \n" + + " \n" + + " #psid\n" + + " #selected\n" + + " \n" + + " \n" + + " #clientid\n" + + " #secret\n" + + " \n" + + " \n" + + ""; + + String psid = dbEntity.getUsername(); + + FRUtils.FRLogInfo("psid>>"+psid); + String selected = String.valueOf(dbEntity.getSelected()); + + PluginSimpleConfig psc = PluginSimpleConfig.getInstance(); + String clientid = psc.getClientId(); + String secret = psc.getSecret(); + + String url = psc.getQxurl(); + webserviceStr = webserviceStr.replace("#psid",psid).replace("#selected",selected).replace("#clientid",clientid) + .replace("#secret",secret); + + String result = HttpUtils.HttpPostText(url,webserviceStr); + + return Utils.isNotNullStr(result); + } +} diff --git a/src/main/java/com/eco/plugin/xx/bssso/logout/Logout.java b/src/main/java/com/eco/plugin/xx/bssso/logout/Logout.java new file mode 100644 index 0000000..394a3c7 --- /dev/null +++ b/src/main/java/com/eco/plugin/xx/bssso/logout/Logout.java @@ -0,0 +1,19 @@ +package com.eco.plugin.xx.bssso.logout; + +import com.eco.plugin.xx.bssso.config.PluginSimpleConfig; +import com.fr.decision.fun.impl.AbstractLogInOutEventProvider; +import com.fr.decision.webservice.login.LogInOutResultInfo; +import com.fr.decision.webservice.v10.login.LoginService; +import javax.servlet.http.HttpSession; + +public class Logout extends AbstractLogInOutEventProvider { + + @Override + public String logoutAction(LogInOutResultInfo result) { + HttpSession session = result.getRequest().getSession(true); + LoginService.getInstance().crossDomainLogout(result.getRequest(),result.getResponse(),""); + session.invalidate(); + return PluginSimpleConfig.getInstance().getLogoutUrl(); + } +} + diff --git a/src/main/java/com/eco/plugin/xx/bssso/oauthservice/OAuthService.java b/src/main/java/com/eco/plugin/xx/bssso/oauthservice/OAuthService.java new file mode 100644 index 0000000..1b40c4e --- /dev/null +++ b/src/main/java/com/eco/plugin/xx/bssso/oauthservice/OAuthService.java @@ -0,0 +1,37 @@ +package com.eco.plugin.xx.bssso.oauthservice; + +import com.eco.plugin.xx.bssso.config.PluginSimpleConfig; +import com.eco.plugin.xx.bssso.utils.FRUtils; +import com.yum.secure.builder.OAuthServiceBuilder; +import com.yum.secure.model.OAuth20Config; +import com.yum.secure.model.Token; +import com.yum.secure.oauth.IOAuth20Service; + +public class OAuthService { + IOAuth20Service oAuth20Service; + + + public OAuthService(String clientId, String clientSerect, String redirectUri) { + String authorizeUrl = PluginSimpleConfig.getInstance().getSsoprefix()+"/oauth/authorize"; + String accessTokenUrl = PluginSimpleConfig.getInstance().getSsoprefix()+"/oauth/token"; + OAuth20Config oAuth20Config = new OAuth20Config(clientId, clientSerect, redirectUri, authorizeUrl, accessTokenUrl); + this.oAuth20Service = (new OAuthServiceBuilder(oAuth20Config)).build20Service(); + } + + public String getAuthorizationUrl() { + return this.oAuth20Service.getAuthorizationUrl(); + } + + public Token getAccessToken(String code) { + FRUtils.FRLogInfo("code:"+code); + Token accessToken = this.oAuth20Service.getAccessToken(code); + if(accessToken != null){ + FRUtils.FRLogInfo("token:"+accessToken.getToken()); + }else{ + FRUtils.FRLogInfo("token为空"); + + } + return accessToken; + } +} + diff --git a/src/main/java/com/eco/plugin/xx/bssso/oauthservice/UserInfo.java b/src/main/java/com/eco/plugin/xx/bssso/oauthservice/UserInfo.java new file mode 100644 index 0000000..5fb53e1 --- /dev/null +++ b/src/main/java/com/eco/plugin/xx/bssso/oauthservice/UserInfo.java @@ -0,0 +1,121 @@ +package com.eco.plugin.xx.bssso.oauthservice; + +import com.eco.plugin.xx.bssso.config.PluginSimpleConfig; +import com.eco.plugin.xx.bssso.utils.FRUtils; +import com.yum.secure.client.BaseEntity; +import com.yum.secure.client.OAuthClient; +import com.yum.secure.exceptions.OAuthApiException; +import com.yum.secure.model.Response; +import com.yum.secure.model.Token; +import com.yum.secure.utils.Json2ObjectUtil; +import com.yum.secure.utils.OAuthConfigUtil; +import com.yum.secure.utils.Preconditions; + +public class UserInfo extends BaseEntity { + private String yumPSID; + private String yumJDECode; + private String yumADAccount; + private String yumHyperionCode; + private String yumVendorId; + private String yumEPRole1; + private Token accessToken; + + public UserInfo() { + } + + public UserInfo(Token accessToken) { + this.accessToken = accessToken; + } + + public Token getAccessToken() { + return this.accessToken; + } + + public void setAccessToken(Token accessToken) { + this.accessToken = accessToken; + } + + public String getYumPSID() { + return this.yumPSID; + } + + public void setYumPSID(String yumPSID) { + this.yumPSID = yumPSID; + } + + public String getYumJDECode() { + return this.yumJDECode; + } + + public void setYumJDECode(String yumJDECode) { + this.yumJDECode = yumJDECode; + } + + public String getYumADAccount() { + return this.yumADAccount; + } + + public void setYumADAccount(String yumADAccount) { + this.yumADAccount = yumADAccount; + } + + public String getYumHyperionCode() { + return this.yumHyperionCode; + } + + public void setYumHyperionCode(String yumHyperionCode) { + this.yumHyperionCode = yumHyperionCode; + } + + public String getYumVendorId() { + return this.yumVendorId; + } + + public void setYumVendorId(String yumVendorId) { + this.yumVendorId = yumVendorId; + } + + public String getYumEPRole1() { + return yumEPRole1; + } + + public void setYumEPRole1(String yumEPRole1) { + this.yumEPRole1 = yumEPRole1; + } + + public UserInfo requestUserInfo() throws OAuthApiException { + FRUtils.FRLogInfo("getUserInfo"); + Preconditions.checkNotNull(this.accessToken, "accessToken is null"); + OAuthClient client = new OAuthClient(PluginSimpleConfig.getInstance().getSsoprefix() + "/oauth/userinfo"); + client.signAccessToken(this.accessToken); + Response response = client.execute(); + UserInfo user = new UserInfo(); + FRUtils.FRLogInfo("body:"+response.getBody()); + + System.out.println("response.getBody()>>>" + response.getBody()); + user = (UserInfo)Json2ObjectUtil.json2Object(response.getBody(), user); + if (user.getError() != null && !"".equals(user.getError().trim())) { + throw new OAuthApiException(user.getError(), user.getError_description()); + } else { + return user; + } + } + + public String requestJsonUserInfo() throws OAuthApiException { + Preconditions.checkNotNull(this.accessToken, "accessToken is null"); + OAuthClient client = new OAuthClient(OAuthConfigUtil.getUserInfoUrl()); + client.signAccessToken(this.accessToken); + Response response = client.execute(); + com.yum.secure.client.model.UserInfo user = new com.yum.secure.client.model.UserInfo(); + System.out.println("response.getBody()>>>" + response.getBody()); + if (user.getError() != null && !"".equals(user.getError().trim())) { + throw new OAuthApiException(user.getError(), user.getError_description()); + } else { + return response.getBody(); + } + } + + public String toString() { + return "UserInfo [yumPSID=" + this.yumPSID + ", yumJDECode=" + this.yumJDECode + ", yumADAccount=" + this.yumADAccount + ", yumHyperionCode=" + this.yumHyperionCode + ", yumVendorId=" + this.yumVendorId + ", accessToken=" + this.accessToken + "]"; + } +} \ No newline at end of file diff --git a/src/main/java/com/eco/plugin/xx/bssso/utils/FRUserUtils.java b/src/main/java/com/eco/plugin/xx/bssso/utils/FRUserUtils.java new file mode 100644 index 0000000..37163e5 --- /dev/null +++ b/src/main/java/com/eco/plugin/xx/bssso/utils/FRUserUtils.java @@ -0,0 +1,220 @@ +package com.eco.plugin.xx.bssso.utils; + +import com.fr.decision.authority.data.User; +import com.fr.decision.privilege.TransmissionTool; +import com.fr.decision.webservice.bean.user.*; +import com.fr.decision.webservice.service.user.UserMiddleRoleService; +import com.fr.decision.webservice.v10.login.ExtendTokenProcessor; +import com.fr.decision.webservice.v10.login.LoginService; +import com.fr.decision.webservice.v10.user.UserService; + +import javax.servlet.http.HttpServletRequest; +import java.util.List; +import java.util.Map; + +public class FRUserUtils { + + /** + * 获取用户Service + * @return + */ + public static UserService getUserService(){ + return UserService.getInstance(); + } + + /** + * 获取全量用户 + * @return + * @throws Exception + */ + public static List getAllUsers(){ + List userbean = UserMiddleRoleService.getInstance().getAllUsers(false); +// List users = new ArrayList(); +// getAllUser(getAdminUser().getUsername(),0,1000,users); + return userbean; + } + + /** + * + * @param adminUsername 管理员用户名 + * @param page 页数 + * @param num 每页的数据 + * @param users 保存用户的列表 + */ + private static void getAllUser(String adminUsername,int page,int num,List users) throws Exception { + Map result = getUserService().getAllUsers(adminUsername,page,num,"","",true); + Long total = (Long)result.get("total"); + List item = (List)result.get("items"); + users.addAll(item); + + page = page+1; + + if(page * num >= total){ + return ; + } + + getAllUser(adminUsername,page,num,users); + } + /** + * 添加用户 + * @param userBean + */ + public static void addUser(UserBean userBean) throws Exception { + userBean.setPassword(TransmissionTool.defaultEncrypt(userBean.getPassword())); + getUserService().addUser(userBean); + } + + /** + * 删除用户 + * @param userBean + */ + public static void updateUser(UserBean userBean) throws Exception { + getUserService().editUser(userBean,getAdminUser().getId()); + } + + /** + * 删除用户 + * @param user + * @return + */ + public static int deleteUser(User user) throws Exception { + String userId = user.getId(); + + UserUpdateBean userUpdateBean = new UserUpdateBean(); + userUpdateBean.setRemoveUserIds(new String[]{userId}); + + return getUserService().deleteUsers(userUpdateBean); + } + + /** + * 根据用户名获取用户实体 + * @param userName + * @return + */ + public static User getUserByUserName(String userName) throws Exception { + return getUserService().getUserByUserName(userName); + } + + /** + * 根据用户名获取用户实体 + * @param userName + * @return + */ + public static UserBean getUserBeanByUserName(String userName ) throws Exception { + String id = getUserService().getUserByUserName(userName).getId(); + return getUser(id); + } + + /** + * 根据id获取用户 + * @param id + * @return + * @throws Exception + */ + public static UserBean getUser(String id) throws Exception { + return getUserService().getUser(id); + } + + /** + * 判断是否是管理员 + * @param username + * @return + */ + public static boolean isAdmin(String username) throws Exception{ + return getUserService().isAdmin(getUserByUserName(username).getId()); + } + + /** + * 禁用启用用户 + * @param userId + * @param state false 禁用 true 启用 + * @throws Exception 异常说明失败 + */ + public static void forbidUser(String userId,boolean state) throws Exception { + getUserService().forbidUser(userId,state); + } + + /** + * 修改用户部门 + * @param departmentId + * @param postId + * @param ud + * @throws Exception + */ + public static void updateDepartmentPostUsers(String departmentId, String postId, UserUpdateBean ud) throws Exception { + getUserService().updateDepartmentPostUsers(departmentId,"",ud); + } + + +// /** +// * 验证密码是否正确 +// * @param psd 明文密码 +// * @param user 根据用户名获取得用户对象 +// * @return +// */ +// public static boolean checkPsd(String psd,User user){ +// String shaPsd = CipherUtils.jdksha256(psd); +// +// return shaPsd.equals(user.getPassword()); +// } + public static User getCurrentUser(HttpServletRequest req) throws Exception { + String username = LoginService.getInstance().getCurrentUserNameFromRequestCookie(req); + + if(Utils.isNullStr(username)){ + return null; + } + + return getUserByUserName(username); + } + + public static UserBean getCurrentUserBean(HttpServletRequest req) throws Exception { + String username = LoginService.getInstance().getCurrentUserNameFromRequestCookie(req); + + if(Utils.isNullStr(username)){ + return null; + } + + return getUserBeanByUserName(username); + } + + /** + * 获取用户部门角色 + * @param username + * @return + * @throws Exception + */ + private static UserRolesBean getUserRolesBean(String username) throws Exception { + return FRUserUtils.getUserService().getUserDepAndCustomRoles(username); + } + + /** + * 获取部门职务 + * @param username + * @return + * @throws Exception + */ + public static List getDepRoleBean(String username) throws Exception{ + return getUserRolesBean(username).getDepRoles(); + } + + /** + * 获取角色 + * @param username + * @return + * @throws Exception + */ + public static List getCustomRoles(String username) throws Exception{ + return getUserRolesBean(username).getCustomRoles(); + } + + public static UserBean getAdminUser() throws Exception { + String adminid = getUserService().getAdminUserIdList().get(0); + return getUser(adminid); + } + + public static String getUsernameFromToken(String token){ + String username = ExtendTokenProcessor.KEY.getUsername(token); + return username; + } + +} diff --git a/src/main/java/com/eco/plugin/xx/bssso/utils/FRUtils.java b/src/main/java/com/eco/plugin/xx/bssso/utils/FRUtils.java new file mode 100644 index 0000000..bc0b968 --- /dev/null +++ b/src/main/java/com/eco/plugin/xx/bssso/utils/FRUtils.java @@ -0,0 +1,257 @@ +package com.eco.plugin.xx.bssso.utils; + +import com.fr.base.ServerConfig; +import com.fr.base.TableData; +import com.fr.decision.authority.AuthorityContext; +import com.fr.decision.authority.data.User; +import com.fr.decision.webservice.login.LogInOutResultInfo; +import com.fr.decision.webservice.utils.DecisionServiceConstants; +import com.fr.decision.webservice.v10.login.LoginService; +import com.fr.decision.webservice.v10.login.event.LogInOutEvent; +import com.fr.decision.webservice.v10.user.UserService; +import com.fr.event.EventDispatcher; +import com.fr.file.TableDataConfig; +import com.fr.general.data.DataModel; +import com.fr.log.FineLoggerFactory; +import com.fr.script.Calculator; +import com.fr.stable.StringUtils; +import com.fr.stable.query.QueryFactory; +import com.fr.stable.query.restriction.RestrictionFactory; +import com.fr.web.utils.WebUtils; + +import javax.servlet.http.Cookie; +import javax.servlet.http.HttpServletRequest; +import javax.servlet.http.HttpServletResponse; +import javax.servlet.http.HttpSession; +import java.io.IOException; +import java.util.List; + +public class FRUtils { + /** + * 判断用户是否存在 + * @param userName + * @return + */ + public static boolean isUserExist(String userName){ + if (StringUtils.isEmpty(userName)) { + return false; + } else { + try { + List param1 = AuthorityContext.getInstance().getUserController().find(QueryFactory.create().addRestriction(RestrictionFactory.eq("userName", userName))); + return param1 != null && !param1.isEmpty(); + } catch (Exception param2) { + FineLoggerFactory.getLogger().error(param2.getMessage()); + return false; + } + } + } + + /** + * 判断是否登录FR + * @param req + * @return + */ + public static boolean isLogin(HttpServletRequest req){ + return LoginService.getInstance().isLogged(req); + } + + /** + * 帆软登录 + * @param httpServletRequest + * @param httpServletResponse + * @param userName + * @param url + */ + public static void login(HttpServletRequest httpServletRequest,HttpServletResponse httpServletResponse,String userName,String url){ + + FineLoggerFactory.getLogger().info("FRLOG:用户名:"+userName); + FineLoggerFactory.getLogger().info("FRLOG:跳转链接:"+url); + + + //判断用户名是否为空 + if(!Utils.isNullStr(userName)){ + if(isUserExist(userName)){ + String FRToken = ""; + + try { + //HttpSession session = httpServletRequest.getSession(true); + + FRToken = LoginService.getInstance().login(httpServletRequest, httpServletResponse, userName); + + //httpServletRequest.setAttribute(DecisionServiceConstants.FINE_AUTH_TOKEN_NAME,FRToken); + + //session.setAttribute(DecisionServiceConstants.FINE_AUTH_TOKEN_NAME, FRToken); + EventDispatcher.fire(LogInOutEvent.LOGIN,new LogInOutResultInfo(httpServletRequest,httpServletResponse,userName,true)); + FineLoggerFactory.getLogger().info("FRLOG:登陆成功!"); + + if(!Utils.isNullStr(url)){ + httpServletResponse.sendRedirect(url); + } + } catch (Exception e) { + ResponseUtils.failedResponse(httpServletResponse,"登录异常，请联系管理员!"); + FineLoggerFactory.getLogger().info("FRLOG:登录异常，请联系管理员!"); + FineLoggerFactory.getLogger().info("FRLOGException:"+e.getMessage()); + } + }else{ + ResponseUtils.failedResponse(httpServletResponse,"用户在报表系统中不存在!"); + FineLoggerFactory.getLogger().info("FRLOG:用户在报表系统中不存在!"); + } + }else{ + ResponseUtils.failedResponse(httpServletResponse,"用户名不能为空!"); + FineLoggerFactory.getLogger().info("FRLOG:用户名不能为空!"); + } + } + + /** + * 帆软登录 + * @param httpServletRequest + * @param httpServletResponse + * @param token + * @param url + */ + public static void loginByToken(HttpServletRequest httpServletRequest,HttpServletResponse httpServletResponse,String token,String url){ + + FineLoggerFactory.getLogger().info("FRLOG:token:"+token); + FineLoggerFactory.getLogger().info("FRLOG:跳转链接:"+url); + + + //判断用户名是否为空 + if(!Utils.isNullStr(token)){ + writeToken2Cookie(httpServletResponse,token,-1); + + HttpSession session = httpServletRequest.getSession(true); + + httpServletRequest.setAttribute(DecisionServiceConstants.FINE_AUTH_TOKEN_NAME,token); + + session.setAttribute(DecisionServiceConstants.FINE_AUTH_TOKEN_NAME, token); + + if(!Utils.isNullStr(url)){ + try { + httpServletResponse.sendRedirect(url); + } catch (IOException e) { + ResponseUtils.failedResponse(httpServletResponse,"跳转异常!"); + FineLoggerFactory.getLogger().info("FRLOG:跳转异常!"); + } + } + }else{ + ResponseUtils.failedResponse(httpServletResponse,"token不能为空!"); + FineLoggerFactory.getLogger().info("FRLOG:token不能为空!"); + } + } + + /** + * 获取token + * @param httpServletRequest + * @param httpServletResponse + * @param username + * @return + */ + public static String getToken(HttpServletRequest httpServletRequest,HttpServletResponse httpServletResponse,String username){ + String token = ""; + try { + token = LoginService.getInstance().login(httpServletRequest, httpServletResponse, username); + } catch (Exception e) { + FineLoggerFactory.getLogger().info("FRLOG:获取token失败"+e.getMessage()); + } + + return token; + } + + private static void writeToken2Cookie(HttpServletResponse param1, String param2, int param3) { + try { + if (StringUtils.isNotEmpty(param2)) { + Cookie param4 = new Cookie("fine_auth_token", param2); + long param5 = param3 == -2 ? 1209600000L : (long)param3; + param4.setMaxAge((int)param5); + param4.setPath(ServerConfig.getInstance().getCookiePath()); + param1.addCookie(param4); + Cookie param7 = new Cookie("fine_remember_login", String.valueOf(param3 == -2 ? -2 : -1)); + param7.setMaxAge((int)param5); + param7.setPath(ServerConfig.getInstance().getCookiePath()); + param1.addCookie(param7); + } else { + FineLoggerFactory.getLogger().error("empty token cannot save."); + } + } catch (Exception param8) { + FineLoggerFactory.getLogger().error(param8.getMessage(), param8); + } + + } + + /** + * + * @param httpServletRequest + * @param httpServletResponse + */ + public static void logout(HttpServletRequest httpServletRequest,HttpServletResponse httpServletResponse) + { + if(!isLogin(httpServletRequest)){ + return ; + } + + try { + LoginService.getInstance().logout(httpServletRequest,httpServletResponse); + } catch (Exception e) { + ResponseUtils.failedResponse(httpServletResponse,"登出异常，请联系管理员!"); + FineLoggerFactory.getLogger().info("FRLOG:登出异常，请联系管理员!"); + FineLoggerFactory.getLogger().info("FRLOGException:"+e.getMessage()); + } + } + + /** + * 打印FR日志 + * @param message + */ + public static void FRLogInfo(String message){ + FineLoggerFactory.getLogger().info("FRLOG:"+message); + } + + /** + * 打印FR日志-error + * @param message + */ + public static void FRLogError(String message){ + FineLoggerFactory.getLogger().error("FRLOG:"+message); + } + + + /** + * 根据用户名获取用户信息 + * @param userName + * @return + */ + public static User getFRUserByUserName(String userName){ + try { + return UserService.getInstance().getUserByUserName(userName); + } catch (Exception e) { + FRLogInfo("获取用户信息异常:"+e.getMessage()); + } + + return null; + } + + /** + * 解密FR密码 + * @param password + * @return + */ +// public static String decryptFRPsd(String password){ +// FRLogInfo("解密密码:"+password); +// return TransmissionTool.decrypt(password); +// } + + /** + * 获取带参数的访问链接 + * @return + */ + public static String getAllUrl(HttpServletRequest httpServletRequest){ + return WebUtils.getOriginalURL(httpServletRequest); + } + + public static TableData getTableData(String serverDataSetName){ + TableData userInfo = TableDataConfig.getInstance().getTableData("serverDataSetName"); + +// DataModel userInfoDM = userInfo.createDataModel(Calculator.createCalculator()); + return userInfo; + } +} diff --git a/src/main/java/com/eco/plugin/xx/bssso/utils/HttpUtils.java b/src/main/java/com/eco/plugin/xx/bssso/utils/HttpUtils.java new file mode 100644 index 0000000..62060de --- /dev/null +++ b/src/main/java/com/eco/plugin/xx/bssso/utils/HttpUtils.java @@ -0,0 +1,265 @@ +package com.eco.plugin.xx.bssso.utils; + +import com.fr.log.FineLoggerFactory; +import com.fr.third.org.apache.http.HttpEntity; +import com.fr.third.org.apache.http.HttpResponse; +import com.fr.third.org.apache.http.HttpStatus; +import com.fr.third.org.apache.http.NameValuePair; +import com.fr.third.org.apache.http.client.CookieStore; +import com.fr.third.org.apache.http.client.entity.UrlEncodedFormEntity; +import com.fr.third.org.apache.http.client.methods.HttpGet; +import com.fr.third.org.apache.http.client.methods.HttpPost; +import com.fr.third.org.apache.http.conn.ssl.NoopHostnameVerifier; +import com.fr.third.org.apache.http.entity.StringEntity; +import com.fr.third.org.apache.http.impl.client.BasicCookieStore; +import com.fr.third.org.apache.http.impl.client.CloseableHttpClient; +import com.fr.third.org.apache.http.impl.client.HttpClients; +import com.fr.third.org.apache.http.impl.cookie.BasicClientCookie; +import com.fr.third.org.apache.http.message.BasicNameValuePair; +import com.fr.third.org.apache.http.ssl.SSLContexts; +import com.fr.third.org.apache.http.ssl.TrustStrategy; +import com.fr.third.org.apache.http.util.EntityUtils; + +import javax.net.ssl.SSLContext; +import javax.servlet.http.Cookie; +import java.io.UnsupportedEncodingException; +import java.security.KeyManagementException; +import java.security.KeyStoreException; +import java.security.NoSuchAlgorithmException; +import java.security.cert.CertificateException; +import java.security.cert.X509Certificate; +import java.util.ArrayList; +import java.util.List; +import java.util.Map; +import java.util.Set; + +public class HttpUtils { + + /** + * httpGet请求 + * @param url + * @return + */ + public static String httpGet(String url,Cookie[] cookies,Map header){ + FineLoggerFactory.getLogger().info("FRLOG:HttpUtils.get--url:"+url); + + //创建httpClient + CloseableHttpClient httpclient = createHttpClient(cookies); + + HttpGet getMethod = new HttpGet(url); + + if(header != null && header.size() > 0){ + Set keySet = header.keySet(); + + for(String key : keySet){ + getMethod.setHeader(key,header.get(key)); + } + } + + try { + HttpResponse response = httpclient.execute(getMethod); + int status =response.getStatusLine().getStatusCode(); + HttpEntity entity = response.getEntity(); + String returnResult = EntityUtils.toString(entity, "utf-8"); + + FineLoggerFactory.getLogger().info("FRLOG:HttpUtils.get--status:"+status); + FineLoggerFactory.getLogger().info("FRLOG:HttpUtils.get--returnResult:"+returnResult); + + httpclient.close(); + + if (status == HttpStatus.SC_OK) { + return returnResult; + } + } catch (Exception e) { + FineLoggerFactory.getLogger().info("FRLOG:HttpUtils.get--exception:"+e.getMessage()); + } + + try { + httpclient.close(); + } catch (Exception e) { + FineLoggerFactory.getLogger().info("FRLOG:http关闭异常:"+e.getMessage()); + } + + return ""; + } + + /** + * HttpPost请求 + * @param postMethod + * @return + */ + private static String HttpPost(HttpPost postMethod){ + CloseableHttpClient httpclient = createHttpClient(null); + + try { + HttpResponse response = httpclient.execute(postMethod); + int status = response.getStatusLine().getStatusCode(); + HttpEntity entity = response.getEntity(); + String returnResult = EntityUtils.toString(entity, "utf-8"); + FineLoggerFactory.getLogger().info("FRLOG:HttpPost:status:"+status); + FineLoggerFactory.getLogger().info("FRLOG:HttpPost:returnResult:"+returnResult); + httpclient.close(); + + if (status == HttpStatus.SC_OK) { + return returnResult; + } + } catch (Exception e) { + FineLoggerFactory.getLogger().info("FRLOG:HttpPost:exception:"+e.getMessage()); + } + + try { + httpclient.close(); + } catch (Exception e) { + FineLoggerFactory.getLogger().info("FRLOG:http关闭异常:"+e.getMessage()); + } + + return ""; + } + + public static String HttpPostXML(String url, String xmlParam){ + FineLoggerFactory.getLogger().info("FRLOG:HttpPostXML:url:"+url); + + HttpPost postMethod = new HttpPost(url); + + postMethod.setHeader("Content-type", "text/html"); + HttpEntity entity2 = null; + try { + entity2 = new StringEntity(xmlParam); + } catch (UnsupportedEncodingException e) { + FineLoggerFactory.getLogger().info("FRLOG:HttpPostXML:参数异常:"+e.getMessage()); + return ""; + } + + postMethod.setEntity(entity2); + + return HttpPost(postMethod); + } + + public static String HttpPostText(String url, String xmlParam){ + FineLoggerFactory.getLogger().info("FRLOG:HttpPostText:url:"+url); + + HttpPost postMethod = new HttpPost(url); + + postMethod.setHeader("Content-type", "text/plain"); + HttpEntity entity2 = null; + try { + entity2 = new StringEntity(xmlParam); + } catch (UnsupportedEncodingException e) { + FineLoggerFactory.getLogger().info("FRLOG:HttpPostText:参数异常:"+e.getMessage()); + return ""; + } + + postMethod.setEntity(entity2); + + return HttpPost(postMethod); + } + + public static String HttpPostJson(String url, String param,Map header){ + FineLoggerFactory.getLogger().info("FRLOG:HttpPostJSON:url:"+url); + + HttpPost postMethod = new HttpPost(url); + + postMethod.setHeader("Content-Type","application/json"); + + if(header != null && header.size() > 0){ + Set keySet = header.keySet(); + + for(String key : keySet){ + postMethod.setHeader(key,header.get(key)); + } + } + + if(!Utils.isNullStr(param)){ + HttpEntity entity2 = null; + try { + entity2 = new StringEntity(param); + } catch (UnsupportedEncodingException e) { + FineLoggerFactory.getLogger().info("FRLOG:HttpPostJSON:参数异常:"+e.getMessage()); + return ""; + } + + postMethod.setEntity(entity2); + } + + return HttpPost(postMethod); + } + + public static String HttpPostWWWForm(String url, Map header,Map param){ + FineLoggerFactory.getLogger().info("FRLOG:HttpWWWForm:url:"+url); + + HttpPost postMethod = new HttpPost(url); + + if(header != null && header.size() > 0){ + Set keySet = header.keySet(); + + for(String key : keySet){ + postMethod.setHeader(key,header.get(key)); + } + } + + if(param != null && param.size() > 0){ + List params = new ArrayList(param.size()); + + for(Map.Entry map : param.entrySet()){ + params.add(new BasicNameValuePair(map.getKey(), map.getValue())); + } + + try { + postMethod.setEntity(new UrlEncodedFormEntity(params, "UTF-8")); + } catch (UnsupportedEncodingException e) { + FineLoggerFactory.getLogger().info("FRLOG:HttpWWWForm:异常:"+e.getMessage()); + return ""; + } + } + + return HttpPost(postMethod); + } + + private static CloseableHttpClient createHttpClient(Cookie[] cookies){ + + SSLContext sslContext = null; + try { + sslContext = SSLContexts.custom().loadTrustMaterial(null, new TrustStrategy() { + @Override + public boolean isTrusted(X509Certificate[] x509Certificates, String s) throws CertificateException { + return true; + } + }).build(); + } catch (Exception e) { + FRUtils.FRLogInfo("exception:"+e.getMessage()); + } + + CloseableHttpClient httpclient = null; + + if(cookies != null && cookies.length > 0){ + CookieStore cookieStore = cookieToCookieStore(cookies); + + httpclient = HttpClients.custom().setSslcontext(sslContext). + setSSLHostnameVerifier(new NoopHostnameVerifier()).setDefaultCookieStore(cookieStore).build(); + } + else{ + httpclient = HttpClients.custom().setSslcontext(sslContext). + setSSLHostnameVerifier(new NoopHostnameVerifier()).build(); + } + + return httpclient; + } + + /** + * cookies转cookieStore + * @param cookies + * @return + */ + public static CookieStore cookieToCookieStore(Cookie[] cookies){ + CookieStore cookieStore = new BasicCookieStore(); + + if(cookies != null && cookies.length>0){ + for(Cookie cookie : cookies){ + BasicClientCookie cookie1 = new BasicClientCookie(cookie.getName(), cookie.getValue()); + cookieStore.addCookie(cookie1); + } + } + + return cookieStore; + } +} diff --git a/src/main/java/com/eco/plugin/xx/bssso/utils/ResponseUtils.java b/src/main/java/com/eco/plugin/xx/bssso/utils/ResponseUtils.java new file mode 100644 index 0000000..bdd08f0 --- /dev/null +++ b/src/main/java/com/eco/plugin/xx/bssso/utils/ResponseUtils.java @@ -0,0 +1,94 @@ +package com.eco.plugin.xx.bssso.utils; + +import com.fr.json.JSONObject; +import com.fr.log.FineLoggerFactory; +import com.fr.web.utils.WebUtils; + +import javax.servlet.http.HttpServletRequest; +import javax.servlet.http.HttpServletResponse; +import java.io.PrintWriter; + +public class ResponseUtils { + private static final int SUCCESS = 200; + private static final int FAILED = -1; + + public static void successResponse(HttpServletResponse res, String body) { + response(res, body, SUCCESS); + } + + public static void failedResponse(HttpServletResponse res, String body) { + response(res, body, FAILED); + } + + private static void response(HttpServletResponse res, String body, int code) { + JSONObject object = new JSONObject(); + PrintWriter pw; + try { + object.put("code", code); + object.put("data", body); + pw = WebUtils.createPrintWriter(res); + } catch (Exception e) { + FineLoggerFactory.getLogger().info(e.getMessage()); + return; + } + res.setContentType("application/json;charset=utf-8"); + String result = object.toString(); + pw.println(result); + pw.flush(); + pw.close(); + } + + public static void response(HttpServletResponse res,JSONObject json){ + PrintWriter pw; + try { + pw = WebUtils.createPrintWriter(res); + } catch (Exception e) { + FineLoggerFactory.getLogger().info(e.getMessage()); + return; + } + res.setContentType("application/json;charset=utf-8"); + String result = json.toString(); + pw.println(result); + pw.flush(); + pw.close(); + } + + public static void responseXml(HttpServletResponse res,String xml){ + PrintWriter pw; + try { + pw = WebUtils.createPrintWriter(res); + } catch (Exception e) { + FineLoggerFactory.getLogger().info(e.getMessage()); + return; + } + res.setContentType("text/xml;charset=utf-8"); + pw.println(xml); + pw.flush(); + pw.close(); + } + + public static void setCSRFHeader(HttpServletResponse httpServletResponse){ + httpServletResponse.setHeader("Access-Control-Allow-Origin", "*"); + httpServletResponse.setHeader("Access-Control-Allow-Methods", "POST,GET,OPTIONS,DELETE,HEAD,PUT,PATCH"); + httpServletResponse.setHeader("Access-Control-Max-Age", "36000"); + httpServletResponse.setHeader("Access-Control-Allow-Headers", "Origin, X-Requested-With, Content-Type, Accept,Authorization,authorization"); + } + + public static void responseJsonp(HttpServletRequest req, HttpServletResponse res, JSONObject json){ + PrintWriter pw; + try { + pw = WebUtils.createPrintWriter(res); + } catch (Exception e) { + FineLoggerFactory.getLogger().info(e.getMessage()); + return; + } + res.setContentType("text/javascript;charset=utf-8;charset=utf-8"); + String result = json.toString(); + + String jsonp=req.getParameter("callback"); + + pw.println(jsonp+"("+result+")"); + pw.flush(); + pw.close(); + } +} diff --git a/src/main/java/com/eco/plugin/xx/bssso/utils/Utils.java b/src/main/java/com/eco/plugin/xx/bssso/utils/Utils.java new file mode 100644 index 0000000..72c1c67 --- /dev/null +++ b/src/main/java/com/eco/plugin/xx/bssso/utils/Utils.java @@ -0,0 +1,244 @@ +package com.eco.plugin.xx.bssso.utils; + +import com.fr.base.TemplateUtils; +import com.fr.data.NetworkHelper; +import com.fr.decision.webservice.v10.user.UserService; +import com.fr.io.utils.ResourceIOUtils; +import com.fr.json.JSONObject; +import com.fr.stable.CodeUtils; +import com.fr.stable.StringUtils; +import com.fr.third.org.apache.commons.codec.digest.DigestUtils; +import com.fr.web.utils.WebUtils; + +import javax.servlet.http.Cookie; +import javax.servlet.http.HttpServletRequest; +import javax.servlet.http.HttpServletResponse; +import java.io.BufferedReader; +import java.io.InputStream; +import java.net.URLEncoder; +import java.util.HashMap; +import java.util.Map; +import java.util.UUID; +import java.util.regex.Matcher; +import java.util.regex.Pattern; + +public class Utils { + + /** + * 判断字符串是否为空 + * @param str + * @return true 空字符串 false 非空字符串 + */ + public static boolean isNullStr(String str){ + return !(str != null && !str.isEmpty() && !"null".equals(str)); + } + + /** + * 判断字符串是否非空 + * @param str + * @return + */ + public static boolean isNotNullStr(String str){ + return !isNullStr(str); + } + + /** + * MD5加密 + * @param str + * @return + */ + public static String getMd5Str(String str) + { + return DigestUtils.md5Hex(str); + } + + /** + * 帆软shaEncode加密 + */ + + public static String shaEncode(String str){ + return CodeUtils.sha256Encode(str); + } + + /** + * 获取uuid + */ + public static String uuid(){ + return UUID.randomUUID().toString(); + } + + /** + * 替换空字符串 + * @param str + * @param replace + * @return + */ + public static String replaceNullStr(String str,String replace){ + if(isNullStr(str)){ + return replace; + } + + return str; + } + + /** + * 获取请求体 + * @param req + * @return + */ + public static JSONObject getRequestBody(HttpServletRequest req){ + StringBuffer sb = new StringBuffer(); + String line = null; + try { + BufferedReader reader = req.getReader(); + while ((line = reader.readLine()) != null) + sb.append(line); + } catch (Exception e) { + FRUtils.FRLogInfo("getRequestBody:exception:"+e.getMessage()); + } + //将空格和换行符替换掉避免使用反序列化工具解析对象时失败 + String jsonString = sb.toString().replaceAll("\\s","").replaceAll("\n",""); + + JSONObject json = new JSONObject(jsonString); + + return json; + } + + /** + * 获取ip + * @return + */ + public static String getIp(HttpServletRequest req){ + String realIp = req.getHeader("X-Real-IP"); + String fw = req.getHeader("X-Forwarded-For"); + if (StringUtils.isNotEmpty(fw) && !"unKnown".equalsIgnoreCase(fw)) { + int param3 = fw.indexOf(","); + return param3 != -1 ? fw.substring(0, param3) : fw; + } else { + fw = realIp; + if (StringUtils.isNotEmpty(realIp) && !"unKnown".equalsIgnoreCase(realIp)) { + return realIp; + } else { + if (StringUtils.isBlank(realIp) || "unknown".equalsIgnoreCase(realIp)) { + fw = req.getHeader("Proxy-Client-IP"); + } + + if (StringUtils.isBlank(fw) || "unknown".equalsIgnoreCase(fw)) { + fw = req.getHeader("WL-Proxy-Client-IP"); + } + + if (StringUtils.isBlank(fw) || "unknown".equalsIgnoreCase(fw)) { + fw = req.getHeader("HTTP_CLIENT_IP"); + } + + if (StringUtils.isBlank(fw) || "unknown".equalsIgnoreCase(fw)) { + fw = req.getHeader("HTTP_X_FORWARDED_FOR"); + } + + if (StringUtils.isBlank(fw) || "unknown".equalsIgnoreCase(fw)) { + fw = req.getRemoteAddr(); + } + + return fw; + } + } + } + + /** + * 根据key获取cookie + * @param req + * @return + */ + public static String getCookieByKey(HttpServletRequest req,String key){ + Cookie[] cookies = req.getCookies(); + String cookie = ""; + + if(cookies == null || cookies.length <=0){ + return ""; + } + + for(int i = 0; i < cookies.length; i++) { + Cookie item = cookies[i]; + if (item.getName().equalsIgnoreCase(key)) { + cookie = item.getValue(); + } + } + + FRUtils.FRLogInfo("cookie:"+cookie); + + return cookie; + } + + /** + * 判断是否是手机端的链接 + * @param req + * @return + */ + public static boolean isMobile(HttpServletRequest req) { + String[] mobileArray = {"iPhone", "iPad", "android", "windows phone", "xiaomi"}; + String userAgent = req.getHeader("user-agent"); + if (userAgent != null && userAgent.toUpperCase().contains("MOBILE")) { + for(String mobile : mobileArray) { + if(userAgent.toUpperCase().contains(mobile.toUpperCase())) { + return true; + } + } + } + return NetworkHelper.getDevice(req).isMobile(); + } + + /** + * 只编码中文 + * @param url + * @return + */ + public static String encodeCH(String url ){ + Matcher matcher = Pattern.compile("[\\u4e00-\\u9fa5]").matcher(url); + + while(matcher.find()){ + String chn = matcher.group(); + url = url.replaceAll(chn, URLEncoder.encode(chn)); + } + + return url; + } + + /** + * 获取web-inf文件夹下的文件 + * filename /resources/ip4enc.properties + */ + public static InputStream getResourcesFile(String filename){ + return ResourceIOUtils.read(filename); + } + + public static void toErrorPage(HttpServletResponse res,String path,Map parameterMap){ + if(parameterMap == null){ + parameterMap = new HashMap(); + } + + try { + String macPage = TemplateUtils.renderTemplate(path, parameterMap); + WebUtils.printAsString(res, macPage); + }catch (Exception e){ + FRUtils.FRLogError("跳转页面异常"); + } + + } + + /** + * 判断是否是管理员 + * @param username + * @return + */ + public static boolean isAdmin(String username) throws Exception{ + return UserService.getInstance().isAdmin(UserService.getInstance().getUserByUserName(username).getId()); + } + + public static String removeCode(String url){ + if(!url.contains("?code") && !url.contains("&code")){ + return url; + } + + return url.substring(0,url.indexOf(url.contains("?code") ? "?code" : "&code")); + } +} diff --git a/src/main/java/com/eco/plugin/xx/bssso/webresource/WebResourceProvider.java b/src/main/java/com/eco/plugin/xx/bssso/webresource/WebResourceProvider.java new file mode 100644 index 0000000..c73bb4f --- /dev/null +++ b/src/main/java/com/eco/plugin/xx/bssso/webresource/WebResourceProvider.java @@ -0,0 +1,35 @@ +package com.eco.plugin.xx.bssso.webresource; + +import com.fr.decision.fun.impl.AbstractWebResourceProvider; +import com.fr.decision.web.MainComponent; +import com.fr.web.struct.Atom; +import com.fr.web.struct.Component; +import com.fr.web.struct.browser.RequestClient; +import com.fr.web.struct.category.ScriptPath; +import com.fr.web.struct.category.StylePath; + +/** + * Created by xx on 2021-12-03 + */ +public class WebResourceProvider extends AbstractWebResourceProvider { + @Override + public Atom attach() { + return MainComponent.KEY; + } + + @Override + public Atom client() { + return new Component() { + @Override + public ScriptPath script(RequestClient requestClient) { + return ScriptPath.build("/com/eco/plugin/xx/bssso/js/login.js"); + } + + @Override + public StylePath style(RequestClient requestClient) { + return StylePath.EMPTY; +// return StylePath.build("/com/fr/plugin/jdfSSO/css/icon.css"); + } + }; + } +} diff --git a/src/main/resources/com/eco/plugin/xx/bssso/js/login.js b/src/main/resources/com/eco/plugin/xx/bssso/js/login.js new file mode 100644 index 0000000..4dc660c --- /dev/null +++ b/src/main/resources/com/eco/plugin/xx/bssso/js/login.js @@ -0,0 +1,401 @@ + + +function getSelected(username){ + var selected = false; + + $.ajax({ + async:false, + url:"/webroot/decision/getByUsername?username="+username, + type:"get", + success:function(data){ + selected = data; + } + }) + return selected; +} + + +function updateSelected(username,selected){ + var result = false; + $.ajax({ + async:false, + url:"/webroot/decision/updateSelected", + type:"post", + contentType:"application/json", + data:JSON.stringify({username:username,selected:selected}), + success:function(data){ + result = data; + } + }) + return result; +} + + +var e = BI.inherit(BI.Widget, { + props: { + baseCls: "dec-user-table-header", + columnSize: [], + items: [], + onSortChange: BI.emptyFn, + onFilterChange: BI.emptyFn, + height: 32 + }, + _store: function () { + return BI.Models.getModel("dec.model.user.all.table.header") + }, + watch: { + enableCheck: function (e) { + this.checkbox.setEnable(e) + } + }, + render: function () { + var e = this.options; + return { + type: "bi.htape", + columnSize: e.columnSize, + items: this._formatItems(e.items) + } + }, + _formatItems: function (e) { + var t = this, + i = this.options, + n = [], + title =BI.map(e, function (e, t) { + var text = t.text; + return { + el: BI.extend({ + rgap: 10, + type: "bi.label", + textAlign: "left" + }, t, { + width: null + }), + width: text == '用户名' ? 0.16 : (text == '手机' ? 0.12 : t.width) + } + }); + title.push({ + el: { + rgap: 10, + text: "sso同步", + textAlign: "left", + type: "bi.label", + width: null + }, + width: 0.07 + }); + return n.push(BI.extend({ + type: "bi.center", + width: 50, + height: i.height, + items: [{ + type: "dec.multi.checkbox", + ref: function (e) { + t.checkbox = e + }, + disabled: !this.model.enableCheck, + listeners: [{ + eventName: BI.Controller.EVENT_CHANGE, + action: function () { + t.fireEvent(BI.Controller.EVENT_CHANGE, arguments) + } + } + ] + } + ] + })), + + n.push({ + type: "bi.htape", + items:title + }), + (n = BI.concat(n, this._createExtraItems())).push({ + type: "bi.layout", + width: 100 + }), + n + }, + _createExtraItems: function () { + var i = [], + e = BI.Providers.getProvider("dec.provider.all_user").getExtraAttributes(); + return BI.each(e, function (e, t) { + BI.isKey(t.header) ? i.push({ + type: "bi.label", + textAlign: "left", + text: t.header, + title: t.header, + width: t.width + }) : BI.isObject(t.header) ? i.push(BI.extend({ + width: t.width + }, t.header)) : i.push({ + type: "bi.layout", + width: t.width + }) + }), + i + }, + setSelected: function (e) { + this.checkbox.setSelected(e) + }, + setHalfSelected: function (e) { + this.checkbox.setHalfSelected(e) + }, + isHalfSelected: function () { + return this.checkbox.isHalfSelected() + }, + isSelected: function () { + return this.checkbox.isSelected() + } +}); +BI.shortcut("dec.user.table.header", e); + + +var e = BI.inherit(BI.Widget, { + props: { + baseCls: "dec-user-table-row bi-border-bottom", + columnSize: [50, "fill", 100], + userInfo: {}, + value: BI.UUID() + }, + _store: function () { + return BI.Models.getModel("dec.model.user.all.row", this.options) + }, + watch: { + selected: function (e) { + this.setSelected(e) + } + }, + render: function () { + var e = this.options; + return { + type: "bi.htape", + $testId: "dec-user-table-row", + $value: e.userInfo.username, + columnSize: e.columnSize, + items: this._formatItem(e.userInfo) + } + }, + _formatItem: function (e) { + var t = this, + i = this.options, + n = [], + o = this.model.keywordMap; + var username = e.username; + return n.push({ + type: "bi.center_adapt", + width: 50, + height: i.height, + items: [{ + type: "bi.checkbox", + $testId: "dec-user-row-checkbox", + $value: e.username, + ref: function (e) { + t.checkbox = e + }, + disabled: !e.enableCheck, + selected: e.selected, + listeners: [{ + eventName: "EVENT_CHANGE", + action: function () { + t.store.changeSelected(this.isSelected()) + } + } + ] + } + ] + }), + n.push({ + el: { + type: "bi.htape", + height: i.height, + scrollable: !1, + disabled: !e.enable, + items: [{ + el: { + type: "bi.label", + ref: function (e) { + t.username = e + }, + scrollable: !1, + textAlign: "left", + text: e.username, + keyword: o.username, + title: function () { + return e.username + }, + rgap: 10, + height: i.height + }, + // width: .2 + width: .16 + }, { + el: { + type: "bi.label", + ref: function (e) { + t.realName = e + }, + scrollable: !1, + textAlign: "left", + text: e.realName, + keyword: o.realName, + title: function () { + return e.realName + }, + rgap: 10, + height: i.height + }, + width: .1 + }, { + el: { + type: "bi.label", + ref: function (e) { + t.depPostNames = e + }, + textAlign: "left", + text: e.depPostNames, + title: function () { + return e.depPostNames + }, + rgap: 10, + height: i.height + }, + width: .15 + }, { + el: { + type: "bi.label", + ref: function (e) { + t.roleNames = e + }, + textAlign: "left", + text: e.roleNames, + title: function () { + return e.roleNames + }, + rgap: 10, + height: i.height + }, + width: .15 + }, { + el: { + type: "bi.label", + ref: function (e) { + t.email = e + }, + textAlign: "left", + text: e.email, + keyword: o.email, + title: function () { + return e.email + }, + rgap: 10, + height: i.height + }, + width: .18 + }, { + el: { + type: "bi.label", + ref: function (e) { + t.mobile = e + }, + textAlign: "left", + text: e.mobile, + keyword: o.mobile, + title: function () { + return e.mobile + }, + rgap: 10, + height: i.height + }, + // width: .15 + width: .12 + }, { + el: { + type: "bi.label", + ref: function (e) { + t.enable = e + }, + textAlign: "left", + text: e.enable ? BI.i18nText("Dec-User_Enabled") : BI.i18nText("Dec-User_Disabled"), + rgap: 10, + height: i.height + }, + width: .07 + }, + { + el: { + type: "bi.absolute_vertical_adapt", + height: i.height, + hgap: 0, + items: [{ + type: "bi.switch", + width:44, + selected:getSelected(username), + listeners: [{ + eventName: "BasicButton.EVENT_CHANGE", + action: function(e) { + var selected =this.options.selected; + var flag = updateSelected(username,selected); + if(!flag){ + BI.Msg.toast("配置失败，请联系管理员!", { + level: "error" + }); + this.options.selected = !selected; + } + } + }], + ref: function (e) { + t.switch = e + } + }], + textAlign: "left", + rgap: 10 + }, + width: .07 + } + ] + } + }), + (n = BI.concat(n, this._createExtraItems(e))).push(BI.extend({}, e, { + type: "dec.user.row.tools", + width: 100, + $scope: e.username, + infoGetter: function () { + return e + }, + onDelete: function () { + t.options.onDelete([e.id]) + }, + onEdit: i.onEdit, + onDisable: function (e) { + t.store.disableUser(e, t.getValue()) + } + })), + n + }, + _createExtraItems: function (i) { + var n = [], + e = BI.Providers.getProvider("dec.provider.all_user").getExtraAttributes(); + return BI.each(e, function (e, t) { + BI.isKey(t.column) ? n.push(BI.extend({ + type: t.column, + width: t.width + }, i)) : BI.isFunction(t.column) ? n.push(BI.extend({ + width: t.width + }, t.column(i))) : n.push({ + type: "bi.layout", + width: t.width + }) + }), + n + }, + isSelected: function () { + return this.checkbox.isSelected() + }, + getValue: function () { + return this.options.userInfo.id + }, + setSelected: function (e) { + this.options.userInfo.enableCheck && this.checkbox.setSelected(e) + } +}); +e.EVENT_DELETE = "EVENT_DELETE", + BI.shortcut("dec.user.table.row", e)