页面历史

importPackage(Packages.java.io);
importPackage(Packages.java.lang);
importPackage(Packages.java.util);
importPackage(Packages.smartbi.usermanager);
importPackage(Packages.smartbi.sdk);
importPackage(Packages.smartbi.sdk.service.user);
importPackage(Packages.smartbi.sdk.service.datasource);
  
/**
 * 从外部数据库中定时同步用户、机构信息到知识库中
 */
var usrManagerService = new UserManagerService(connector);
var datasrcService = new DataSourceService(connector);
  
//
// 创建"顶级机构"
// 下面这段代码不能删除，如果不需要"顶级机构"可以将needTopGroup设置为false  
//
var needTopGroup = false; // 是否创建一个"顶级机构"
var defaultGroup = usrManagerService.getDepartmentById("DEPARTMENT");
//var defaultGroup = null;
//try {
//	defaultGroup = usrManagerService.getDepartmentByName("Goldcard"); //需要建立的顶级机构名称
//} catch(e) {}
//if (!defaultGroup) {
//    var groupId = usrManagerService.createDepartment("DEPARTMENT", "Goldcard", "金卡股份", "", "");   //在根组下建立顶级机构
//    defaultGroup = usrManagerService.getDepartmentById(groupId);
//}
  
//
// 同步机构：获取第三方系统中的机构信息
//
var sqlGroup = "SELECT c_groupid, c_groupname, c_pgroupid, c_isenabled FROM oa_group"; // 该SQL语句获取第三方系统中的机构信息
var gridDataGroup = datasrcService.executeNoCacheable("DS.用户同步", sqlGroup);
for (var i = 0; i < gridDataGroup.getRowsCount(); i++) {
    var orgName       = gridDataGroup.get(i, 0).getValue();
    var orgAlias      = gridDataGroup.get(i, 1).getValue();
    var orgParentName = gridDataGroup.get(i, 2).getValue();
    var isUse         = gridDataGroup.get(i, 3).getValue();
    if("".equals(orgName)){
    	continue;
    }
    // 判断机构是否已经同步
    var group = null;
    try {
        group = usrManagerService.getDepartmentByName(orgName);
    } catch(e) {}
    if (!group) { //如果不存在则创建
    	//判断机构是否可用，如果不可以，直接跳过。
    	if("0".equals(isUse)){
    		System.out.println(" 跳过组： "+orgName);
    		continue;
    	}
        var parentGroup = null;
        try {
            parentGroup = usrManagerService.getDepartmentByName(orgParentName);
        } catch(e) {}
        if (!parentGroup)
            parentGroup = defaultGroup;
        usrManagerService.createDepartment(parentGroup.getId(), orgName, orgAlias, "", "");
    }else{
    	//判断机构是否可用，否则删除
    	if("0".equals(isUse)){
    		System.out.println(" 删除组： "+orgName);
    		usrManagerService.deleteDepartment(group.getId());
    		continue;
    	}
    	if(!group.getAlias().equals(orgAlias)){
    		System.out.println(group.getAlias()+" 更新组别名： "+orgAlias);
    		usrManagerService.updateDepartment(group.getId(), orgAlias, "", "");
    	}
    }
}
//移组
System.out.println("移组移组》》》》》》》》》》》》");
for (var i = 0; i < gridDataGroup.getRowsCount(); i++) {
	var orgName       = gridDataGroup.get(i, 0).getValue();
    //var orgAlias      = gridDataGroup.get(i, 1).getValue();
    var orgParentName = gridDataGroup.get(i, 2).getValue();
    var isUse         = gridDataGroup.get(i, 3).getValue();
    if("0".equals(isUse)){
    	continue;
    }
	var parentGroup = null;
	var group = null;
	try {
	     group = usrManagerService.getDepartmentByName(orgName);
	    } catch(e) {}
	try {
	     parentGroup = usrManagerService.getDepartmentByName(orgParentName);
	} catch(e) {}
	//如果父组为空，则设置为根组。
	if(!parentGroup){
		System.out.println(orgName+" 父组赋值为默认组："+orgParentName);
		parentGroup = defaultGroup;
	}
	if (group && parentGroup && (parentGroup.getId() != usrManagerService.getParentDepartment(group.getId()).getId())) {
		System.out.println(usrManagerService.getParentDepartment(group.getId()).getName()+" 移动组： "+orgParentName);
		usrManagerService.moveDepartment(group.getId(), parentGroup.getId());
	}
}
//
// 同步用户：获取第三方系统中的用户信息
//
var sqlUser = "SELECT c_username, c_useralias, c_userpwd, c_isenabled, c_defaultgrp FROM oa_user"; // 该SQL语句获取第三方系统中的用户信息
var gridDataUser = datasrcService.executeNoCacheable("DS.用户同步", sqlUser);
for (var i = 0; i < gridDataUser.getRowsCount(); i++) {
    var userName  = gridDataUser.get(i, 0).getValue();
    var userAlias = gridDataUser.get(i, 1).getValue();
    var userPwd   = gridDataUser.get(i, 2).getValue();
    var isUse     = gridDataUser.get(i, 3).getValue();
    var orgName   = gridDataUser.get(i, 4).getValue();
    if("".equals(userName)){
    	continue;
    }
    // 获取用户所属机构ID
    var parentGroup = null;
    var usrOrgIdList = [];
    parentGroup = usrManagerService.getDepartmentByName(orgName);
    //如果所属机构不存在，则设置默认组作为用户所属机构。
    if(!parentGroup){
    	parentGroup = defaultGroup;
    }
    usrOrgIdList.push(parentGroup.getId());
    // 判断用户是否已经同步
    var user = usrManagerService.getUserByName(userName);
    if (!user) {
    	if("0".equals(isUse)){
    		System.out.println("用户跳过："+userName);
    		continue;
    	}
        usrManagerService.createUser(usrOrgIdList[0], userName, userAlias, "", "123456", true);
        user = usrManagerService.getUserByName(userName);
    }else{
    	if("0".equals(isUse)){
    		System.out.println("用户删除："+userName);
    		usrManagerService.deleteUser(user.getId());
    		continue;
    	}
    	//更新用户的默认组，由于泛微OA一个用户只有一个组，故而直接使用默认组的方式
    	var defaultOrg = usrManagerService.getDefaultDepartment(user.getId()).getId();
    	//判断当前用户所属组是否与BI中的一致，否则进行更新。
    	if(!defaultOrg.equals(usrOrgIdList[0])){
    		System.out.println(usrOrgIdList[0]+" 更新组："+defaultOrg);
    		usrManagerService.assignDepartmentsToUser(user.getId(), usrOrgIdList);
    	}
    }
    //第三方系统中用户密码是以大写的MD5加密的方式储存的，则需要在密码前加"0"，方可正常登陆
    var encryptedPwd = "0" + userPwd.toLowerCase();
    var biPwd = usrManagerService.getPassword(user.getName());
    //如果当前用户别名或密码与BI中保存的不一致，则进行更新。
    if(user && (!user.getAlias().equals(userAlias) || !biPwd.equals(encryptedPwd))){
    	System.out.println(user.getAlias()+"更新用户别名："+userAlias);
    	System.out.println(biPwd+"更新用户密码："+encryptedPwd);
    	usrManagerService.updateUserByEncryptedPassword(user.getId(), userAlias, "", encryptedPwd, true);
    }
}