权限管理系统初始化。

qb-auth-server/.gitignore

@@ -0,0 +1,8 @@
bin/
target/
.settings/
*.iml
.classpath
.project
.DS_Store
.idea/

qb-auth-server/pom.xml

@@ -0,0 +1,133 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <groupId>com.ai.ipu.server</groupId>
        <artifactId>ipu-assembly-parent</artifactId>
        <version>3.3-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>
    <artifactId>qb-auth-server</artifactId>
    <repositories>
        <!-- 阿里私服 -->
        <repository>
            <id>ali</id>
            <url>http://maven.aliyun.com/nexus/content/groups/public</url>
            <releases>
                <enabled>true</enabled>
            </releases>
            <snapshots>
                <enabled>true</enabled>
                <updatePolicy>always</updatePolicy>
                <checksumPolicy>fail</checksumPolicy>
            </snapshots>
        </repository>
        <!-- IPU仓库 -->
        <repository>
            <id>ipu</id>
            <name>ipu repository</name>
            <url>http://114.215.100.48:9090/nexus/content/groups/public/</url>
            <releases>
                <enabled>true</enabled>
            </releases>
            <snapshots>
                <enabled>true</enabled>
                <updatePolicy>always</updatePolicy>
            </snapshots>
        </repository>
    </repositories>
    <properties>
        <start-class>com.ipu.logicflow.server.LogicflowServerStart</start-class>
        <spring-boot>2.3.1.RELEASE</spring-boot>
        <ipu>3.3-SNAPSHOT</ipu>
        <ipu-rest>3.3-SNAPSHOT</ipu-rest>
        <nuosi-logicflow>1.1</nuosi-logicflow>
    </properties>
    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>com.ai.ipu.server</groupId>
                <artifactId>ipu-dependencies</artifactId>
                <version>${ipu}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-dependencies</artifactId>
                <version>${spring-boot}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>com.ai.ipu.server</groupId>
            <artifactId>ipu-restful</artifactId>
            <version>${ipu-rest}</version>
        </dependency>
        <dependency>
            <groupId>com.ipu.flow</groupId>
            <artifactId>ipu-logicflow</artifactId>
            <version>${nuosi-logicflow}</version>
        </dependency>
        <!--<dependency>
            <groupId>io.github.reynolds2019</groupId>
            <artifactId>nuosi-logicflow</artifactId>
            <version>${nuosi-logicflow}</version>
        </dependency>-->
        <!-- Spring引入 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
    </dependencies>
    <build>
        <plugins>
            <!-- ==========应用包和依赖包分离的打包方法================ -->
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-resources-plugin</artifactId>
            </plugin>
            <!-- 复制依赖包 -->
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-dependency-plugin</artifactId>
            </plugin>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-jar-plugin</artifactId>
            </plugin>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-assembly-plugin</artifactId>
            </plugin>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-surefire-plugin</artifactId>
                <configuration>
                    <skipTests>true</skipTests>
                </configuration>
            </plugin>
            <!-- 添加docker镜像功能 -->
            <!--<plugin>
                <groupId>com.spotify</groupId>
                <artifactId>dockerfile-maven-plugin</artifactId>
            </plugin>-->
        </plugins>
    </build>
</project>

qb-auth-server/sql/系统权限管理v1.4.1.sql

@@ -0,0 +1,294 @@
/*==============================================================*/
/* DBMS name:      MySQL 5.0                                    */
/* Created on:     2022/2/10 23:08:37                           */
/*==============================================================*/
drop table if exists sec_menu;
drop table if exists sec_org_user_rel;
drop table if exists sec_organize;
drop table if exists sec_priv_entity;
drop table if exists sec_role;
drop table if exists sec_role_grant;
drop table if exists sec_role_user_rel;
drop table if exists sec_user;
/*==============================================================*/
/* Table: sec_menu                                              */
/*==============================================================*/
create table sec_menu
(
   MENU_ID              bigint(20) not null auto_increment comment '菜单标识',
   PARENT_MENU_ID       bigint(20) default NULL comment '上级菜单标识',
   SUB_COUNT            int(5) default NULL comment '子菜单数目',
   MENU_TYPE            varchar(3),
   MENU_NAME            varchar(256),
   MENU_TITLE           varchar(256),
   LEVEL                int(11) unsigned default NULL comment '层级 ',
   MENU_SORT            int(5) default NULL comment '排序',
   MENU_COMPONENT       varchar(256),
   MENU_ICON            varchar(256),
   LINK_URL             varchar(256),
   IFRAME_FLAG          int(1) default NULL comment '是否外链',
   CACHE_FLAG           int(1) default NULL comment '缓存',
   HIDDEN_FLAG          int(1) default NULL comment '隐藏',
   VALID_DATE           datetime default NULL comment '生效日期',
   EXPIRE_DATE          datetime default NULL comment '失效日期',
   DATA_STATUS          varchar(8),
   CREATE_DATE          datetime default NULL comment '创建日期',
   CREATE_OP_ID         varchar(32),
   CREATE_ORG_ID        varchar(32),
   DONE_CODE            bigint(22) default NULL comment '事务编号',
   DONE_DATE            datetime default NULL comment '操作日期',
   OP_ID                varchar(32),
   ORG_ID               varchar(32),
   MGMT_DISTRICT        varchar(8),
   MGMT_COUNTY          varchar(8),
   REGION_ID            varchar(8),
   TENANT_CODE          varchar(32),
   primary key (MENU_ID)
)
ENGINE=InnoDB AUTO_INCREMENT=4 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin;
/*==============================================================*/
/* Table: sec_org_user_rel                                      */
/*==============================================================*/
create table sec_org_user_rel
(
   ORG_USER_REL_ID      bigint(20) not null auto_increment comment '用户组织关系标识',
   ORGANIZE_ID          bigint(20) default NULL comment '组织标识',
   USER_ID              bigint(20) default NULL comment '用户标识',
   VALID_DATE           datetime default NULL comment '生效日期',
   EXPIRE_DATE          datetime default NULL comment '失效日期',
   DATA_STATUS          varchar(8),
   CREATE_DATE          datetime default NULL comment '创建日期',
   CREATE_OP_ID         varchar(32),
   CREATE_ORG_ID        varchar(32),
   DONE_CODE            bigint(22) default NULL comment '事务编号',
   DONE_DATE            datetime default NULL comment '操作日期',
   OP_ID                varchar(32),
   ORG_ID               varchar(32),
   MGMT_DISTRICT        varchar(8),
   MGMT_COUNTY          varchar(8),
   REGION_ID            varchar(8),
   TENANT_CODE          varchar(32),
   primary key (ORG_USER_REL_ID)
)
ENGINE=InnoDB AUTO_INCREMENT=101 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin;
/*==============================================================*/
/* Table: sec_organize                                          */
/*==============================================================*/
create table sec_organize
(
   ORGANIZE_ID          bigint(20) not null auto_increment comment '组织标识',
   ORGANIZE_TYPE        varchar(3),
   PARTY_ID             bigint(20) default NULL comment '参与人标识',
   ORGANIZE_NAME        varchar(200),
   ORGANIZE_CODE        varchar(100),
   PARENT_ORGANIZE_ID   bigint(20) default NULL comment '父组织标识',
   DISTRICT_ID          varchar(40),
   SHORT_NAME           varchar(200),
   ENGLISH_NAME         varchar(200),
   DEPT_FULL_ID         varchar(400),
   DEPT_FULL_NAME       varchar(400),
   LEVEL                int(5) default NULL comment '层级，顶层为1，依次类推',
   DEPT_LEADER          bigint(20) default NULL comment '部门负责人,关联 user_id',
   MEMBER_NUM           int(5) default NULL comment '组织人数',
   MANAGER_NAME         varchar(40),
   EMAIL                varchar(50),
   LINK_PHONE_ID        varchar(50),
   FAX_ID               varchar(50),
   ORG_ADDRESS          varchar(255),
   CONTACT_NAME         varchar(100),
   CONTACT_CARD_TYPE    varchar(3),
   CONTACT_CARD_ID      varchar(40),
   CONTACT_BILL_ID      varchar(50),
   POSTCODE             varchar(10),
   POST_PROVINCE        varchar(32),
   POST_CITY            varchar(32),
   POST_ADDRESS         varchar(255),
   POST_POSTCOD         varchar(32),
   COUNTY_ID            varchar(32),
   LEAF_FLAG            int(1) default NULL comment '是否叶子节点\r\n            1--是 0-否\r\n            ',
   ORG_LEVEL            varchar(3),
   ORG_AREA_TYPE        varchar(3),
   ORG_COOP_TYPE        varchar(3),
   CHANNEL_TYPE         varchar(3),
   REMARK               varchar(255),
   VALID_DATE           datetime default NULL comment '生效日期',
   EXPIRE_DATE          datetime default NULL comment '失效日期',
   DATA_STATUS          varchar(8),
   CREATE_DATE          datetime default NULL comment '创建日期',
   CREATE_OP_ID         varchar(32),
   CREATE_ORG_ID        varchar(32),
   DONE_CODE            bigint(22) default NULL comment '事务编号',
   DONE_DATE            datetime default NULL comment '操作日期',
   OP_ID                varchar(32),
   ORG_ID               varchar(32),
   MGMT_DISTRICT        varchar(8),
   MGMT_COUNTY          varchar(8),
   REGION_ID            varchar(8),
   TENANT_CODE          varchar(32),
   primary key (ORGANIZE_ID)
)
ENGINE=InnoDB AUTO_INCREMENT=33 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin;
/*==============================================================*/
/* Table: sec_priv_entity                                       */
/*==============================================================*/
create table sec_priv_entity
(
   PRIV_ENT_ID          bigint(20) not null auto_increment comment '权限实体标识',
   PRIV_ENT_NAME        varchar(255),
   PRIV_ENT_CODE        varchar(255),
   APP_ID               bigint(20) default NULL comment '使用系统标识',
   PRIV_ENT_TYPE_ID     bigint(20) default NULL comment '权限对象类型标识（用户权限分组管理）',
   BUSI_OBJ_ID          bigint(20) default NULL comment '实体对象标识（应用、菜单本身作为权限实体的标识）',
   BUSI_OBJ_TYPE        varchar(10),
   SENSITIVE_LEVEL      varchar(3),
   REMARK               varchar(100),
   VALID_DATE           datetime default NULL comment '生效日期',
   EXPIRE_DATE          datetime default NULL comment '失效日期',
   DATA_STATUS          varchar(8),
   CREATE_DATE          datetime default NULL comment '创建日期',
   CREATE_OP_ID         varchar(32),
   CREATE_ORG_ID        varchar(32),
   DONE_CODE            bigint(22) default NULL comment '事务编号',
   DONE_DATE            datetime default NULL comment '操作日期',
   OP_ID                varchar(32),
   ORG_ID               varchar(32),
   MGMT_DISTRICT        varchar(8),
   MGMT_COUNTY          varchar(8),
   REGION_ID            varchar(8),
   TENANT_CODE          varchar(32),
   primary key (PRIV_ENT_ID)
)
ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin;
/*==============================================================*/
/* Table: sec_role                                              */
/*==============================================================*/
create table sec_role
(
   ROLE_ID              bigint(20) not null auto_increment comment '角色标识',
   JOB_ID               bigint(20) default NULL comment '岗位标识',
   ROLE_NAME            varchar(256),
   ROLE_TYPE            varchar(3),
   ROLE_LEVEL           int(5) default NULL comment '角色级别\r\n            1：低；2：中；3：高；',
   DESCRIPTION          varchar(256),
   VALID_DATE           datetime default NULL comment '生效日期',
   EXPIRE_DATE          datetime default NULL comment '失效日期',
   DATA_STATUS          varchar(8),
   CREATE_DATE          datetime default NULL comment '创建日期',
   CREATE_OP_ID         varchar(32),
   CREATE_ORG_ID        varchar(32),
   DONE_CODE            bigint(22) default NULL comment '事务编号',
   DONE_DATE            datetime default NULL comment '操作日期',
   OP_ID                varchar(32),
   ORG_ID               varchar(32),
   MGMT_DISTRICT        varchar(8),
   MGMT_COUNTY          varchar(8),
   REGION_ID            varchar(8),
   TENANT_CODE          varchar(32),
   primary key (ROLE_ID)
)
ENGINE=InnoDB AUTO_INCREMENT=1001 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin;
/*==============================================================*/
/* Table: sec_role_grant                                        */
/*==============================================================*/
create table sec_role_grant
(
   ROLE_GRANT_ID        bigint(20) not null auto_increment comment '角色授权标识',
   ROLE_ID              bigint(20) default NULL comment '角色标识',
   PRIV_ENT_ID          bigint(20) default NULL comment '实体标识',
   REMARK               varchar(100),
   VALID_DATE           datetime default NULL comment '生效日期',
   EXPIRE_DATE          datetime default NULL comment '失效日期',
   DATA_STATUS          varchar(8),
   CREATE_DATE          datetime default NULL comment '创建日期',
   CREATE_OP_ID         varchar(32),
   CREATE_ORG_ID        varchar(32),
   DONE_CODE            bigint(22) default NULL comment '事务编号',
   DONE_DATE            datetime default NULL comment '操作日期',
   OP_ID                varchar(32),
   ORG_ID               varchar(32),
   MGMT_DISTRICT        varchar(8),
   MGMT_COUNTY          varchar(8),
   REGION_ID            varchar(8),
   TENANT_CODE          varchar(32),
   primary key (ROLE_GRANT_ID)
)
ENGINE=InnoDB AUTO_INCREMENT=1002 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin;
/*==============================================================*/
/* Table: sec_role_user_rel                                     */
/*==============================================================*/
create table sec_role_user_rel
(
   ROLE_USER_REL_ID     bigint(20) not null auto_increment comment '角色关联用户标识',
   USER_ID              bigint(20) not null comment '用户标识',
   ROLE_ID              bigint(20) not null comment '角色标识',
   VALID_DATE           datetime default NULL comment '生效日期',
   EXPIRE_DATE          datetime default NULL comment '失效日期',
   DATA_STATUS          varchar(8),
   CREATE_DATE          datetime default NULL comment '创建日期',
   CREATE_OP_ID         varchar(32),
   CREATE_ORG_ID        varchar(32),
   DONE_CODE            bigint(22) default NULL comment '事务编号',
   DONE_DATE            datetime default NULL comment '操作日期',
   OP_ID                varchar(32),
   ORG_ID               varchar(32),
   MGMT_DISTRICT        varchar(8),
   MGMT_COUNTY          varchar(8),
   REGION_ID            varchar(8),
   TENANT_CODE          varchar(32),
   primary key (ROLE_USER_REL_ID)
)
ENGINE=InnoDB AUTO_INCREMENT=101 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin;
/*==============================================================*/
/* Table: sec_user                                              */
/*==============================================================*/
create table sec_user
(
   USER_ID              bigint(20) not null auto_increment comment '用户标识',
   NICK_NAME            varchar(256),
   USER_ACCOUNT         varchar(500),
   GENDER               varchar(2),
   AVATAR_NAME          varchar(256),
   AVATAR_PATH          varchar(256),
   EMAIL                varchar(256),
   LINK_PHONE           varchar(256),
   PASSWORD             varchar(256),
   ADMIN_FLAG           int(1) default NULL comment '是否为ADMIN账号',
   SEC_LEVEL            char(1),
   ENABLED_FLAG         int(1) default NULL comment '状态：1启用、0禁用',
   PWD_RESET_TIME       varchar(2),
   VALID_DATE           datetime default NULL comment '生效日期',
   EXPIRE_DATE          datetime default NULL comment '失效日期',
   DATA_STATUS          varchar(8),
   CREATE_DATE          datetime default NULL comment '创建日期',
   CREATE_OP_ID         varchar(32),
   CREATE_ORG_ID        varchar(32),
   DONE_CODE            bigint(22) default NULL comment '事务编号',
   DONE_DATE            datetime default NULL comment '操作日期',
   OP_ID                varchar(32),
   ORG_ID               varchar(32),
   MGMT_DISTRICT        varchar(8),
   MGMT_COUNTY          varchar(8),
   REGION_ID            varchar(8),
   TENANT_CODE          varchar(32),
   SURNAME              varchar(500),
   primary key (USER_ID)
)
ENGINE=InnoDB AUTO_INCREMENT=1482980362203303937 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin;

qb-auth-server/src/main/assembly-package.xml

@@ -0,0 +1,78 @@
<assembly>
    <id>bin</id>
    <formats>
        <!-- <format>zip</format> -->
        <format>tar.gz</format>
    </formats>
    <fileSets>
    	<!-- 把项目相关的说明文件，打包进zip文件的根目录 -->
        <fileSet>
            <directory>${project.basedir}</directory>
            <outputDirectory>/</outputDirectory>
            <includes>
                <include>README*</include>
                <include>LICENSE*</include>
                <include>NOTICE*</include>
            </includes>
        </fileSet>
        <!-- /${project.build.finalName}/conf => /conf -->
        
        <!-- 把项目的配置文件，打包进zip包的conf目录 -->
        <fileSet>
            <directory>${project.build.directory}/conf</directory>
            <outputDirectory>/conf</outputDirectory>
            <directoryMode>0755</directoryMode>
            <fileMode>0644</fileMode>
        </fileSet>
        
        <!-- 把项目依赖的jar包，打包进zip包的lib目录 -->
        <fileSet>
            <directory>${project.build.directory}/lib</directory>
            <outputDirectory>/lib</outputDirectory>
            <directoryMode>0755</directoryMode>
            <fileMode>0644</fileMode>
        </fileSet>
    
        <!-- 把项目编译的jar包，打包进zip包的根目录 -->
        <fileSet>
            <directory>${project.build.directory}</directory>
            <outputDirectory>/</outputDirectory>
            <includes>
                <include>${project.build.finalName}.jar</include>
            </includes>
        </fileSet>
        
        <!-- 把项目的脚本文件，打包进zip包的bin目录 -->
         <fileSet>
             <directory>${project.basedir}/src/bin</directory>
             <outputDirectory>/bin</outputDirectory>
             <directoryMode>0755</directoryMode>
             <fileMode>0755</fileMode>
             <lineEnding>unix</lineEnding>
             <includes>
                 <include>*.sh</include>
                 <include>*.conf</include>
             </includes>
         </fileSet>
        <fileSet>
            <directory>${project.basedir}/src/bin</directory>
            <outputDirectory>/bin</outputDirectory>
            <directoryMode>0755</directoryMode>
            <fileMode>0755</fileMode>
            <lineEnding>dos</lineEnding>
            <includes>
                <include>*.bat</include>
            </includes>
        </fileSet>
    </fileSets>
    
    <!-- 把工程编译的jar打包进zip包的根目录 -->
    <!-- 
    <files>
		<file>
			<source>${project.build.directory}/${project.artifactId}.jar</source>
			<outputDirectory>/</outputDirectory>
		</file>
	</files> 
	-->
</assembly>

qb-auth-server/src/main/java/com/ipu/logicflow/server/LogicflowServerStart.java

@@ -0,0 +1,30 @@
package com.ipu.logicflow.server;
import com.ai.ipu.basic.util.IpuBaseException;
import com.ai.ipu.restful.boot.IpuRestApplication;
import com.ipu.logicflow.server.util.LogicFlowConfig;
/**
 * <p>desc: 逻辑编排服务启动类 </p>
 * <p>date: 2021/11/25 14:42 </p>
 *
 * @author nuosi fsofs@163.com
 * @version v1.0.0
 */
public class LogicflowServerStart {
    public static void main(String[] args) {
        // 初始化加载服务配置
        LogicFlowConfig.init();
        // 注册异常信息编码配置。
        registerExceptionCode();
        // 启动服务
        IpuRestApplication.start(args);
    }
    private static void registerExceptionCode(){
        // 热部署会多次加载，因此需要捕获并忽略异常
        String exceptionMessagesConfig = "exception_messages";
        IpuBaseException.registerCode(exceptionMessagesConfig);
    }
}

qb-auth-server/src/main/java/com/ipu/logicflow/server/biz/logic/control/LogicController.java

@@ -0,0 +1,40 @@
package com.ipu.logicflow.server.biz.logic.control;
import com.ai.ipu.data.JMap;
import com.ai.ipu.data.impl.JsonMap;
import com.alibaba.fastjson.JSONObject;
import com.ipu.logicflow.server.biz.logic.service.LogicService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
/**
 * <p>desc: 逻辑服务调用的入口 </p>
 * <p>date: 2021/11/25 15:00 </p>
 *
 * @author nuosi fsofs@163.com
 * @version v1.0.0
 */
@Controller
public class LogicController {
    private static final Logger log = LoggerFactory.getLogger(LogicController.class);
    @Autowired
    private LogicService logicService;
    @ResponseBody
    @RequestMapping("/logic/{logicId}")
    public Object logic(@PathVariable("logicId") String logicId, @RequestBody JSONObject input) throws Exception {
        System.out.println("logicId="+logicId);
        System.out.println("input="+input);
        JMap param = new JsonMap(input.toJSONString());
        Object result = logicService.execute(logicId, param);
        return result;
    }
}

qb-auth-server/src/main/java/com/ipu/logicflow/server/biz/logic/service/LogicService.java

@@ -0,0 +1,15 @@
package com.ipu.logicflow.server.biz.logic.service;
import com.ai.ipu.data.JMap;
/**
 * <p>desc: 逻辑服务的实现接口 </p>
 * <p>date: 2021/11/25 15:01 </p>
 *
 * @author nuosi fsofs@163.com
 * @version v1.0.0
 */
public interface LogicService {
    public Object execute(String logicName, JMap param) throws Exception;
}

qb-auth-server/src/main/java/com/ipu/logicflow/server/biz/logic/service/impl/LogicServiceImpl.java

@@ -0,0 +1,23 @@
package com.ipu.logicflow.server.biz.logic.service.impl;
import com.ai.ipu.data.JMap;
import com.nuosi.flow.logic.LogicFlowEngine;
import com.ipu.logicflow.server.biz.logic.service.LogicService;
import org.springframework.stereotype.Service;
/**
 * <p>desc: 逻辑服务的实现 </p>
 * <p>date: 2021/12/4 1:07 </p>
 *
 * @author nuosi fsofs@163.com
 * @version v1.0.0
 */
@Service
public class LogicServiceImpl implements LogicService {
    @Override
    public Object execute(String logicName, JMap param) throws Exception {
        Object result = LogicFlowEngine.execute(logicName, param);
        return result;
    }
}

qb-auth-server/src/main/java/com/ipu/logicflow/server/util/LogicFlowConfig.java

@@ -0,0 +1,54 @@
package com.ipu.logicflow.server.util;
import com.nuosi.flow.util.LogicFlowUtil;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
/**
 * <p>desc: LogicFlow配置类 </p>
 * <p>date: 2021/12/30 23:58 </p>
 *
 * @author nuosi fsofs@163.com
 * @version v1.0.0
 */
public class LogicFlowConfig {
    private static Map<String, String> modelPathMap = new HashMap<String, String>();
    private static Map<String, String> flowPathMap = new HashMap<String, String>();
    public static void init(){
        initModel();
        initFlow();
    }
    public static void initModel(){
        modelPathMap.put("sec_user", "flow/user/model/sec_user.xml");
        modelPathMap.put("sec_organize", "flow/org/model/sec_organize.xml");
        Iterator<String> it = modelPathMap.values().iterator();
        while(it.hasNext()){
            LogicFlowUtil.loadLogicModel(it.next());
        }
    }
    public static void initFlow(){
        flowPathMap.put("user_insert", "flow/user/user_insert.xml");
        flowPathMap.put("user_select", "flow/user/user_select.xml");
        flowPathMap.put("user_select_by_name", "flow/user/user_select_by_name.xml");
        flowPathMap.put("organize_select", "flow/org/organize_select.xml");
        Iterator<String> it = flowPathMap.values().iterator();
        while(it.hasNext()){
            LogicFlowUtil.loadLogicFlow(it.next());
        }
    }
    public static Map<String, String> getModelPathMap() {
        return modelPathMap;
    }
    public static Map<String, String> getFlowPathMap() {
        return flowPathMap;
    }
}

qb-auth-server/src/main/resources/banner.txt

@@ -0,0 +1,4 @@
======================
Nuosi Logicflow Server is running
${spring-boot.formatted-version}
======================

qb-auth-server/src/main/resources/dev/application.yml

@@ -0,0 +1,44 @@
#一、context-path配置的版本差异
#2.x：server.servlet.context-path=/ipu
#1.x：server.context-path=/ipu
#二、默认:server.servlet-path=/
server:
  servlet:
    context-path: /ipu
  #通过启动命令传参指定端口
  port: unknown
spring:
  application:
    #使用maven中的变量project.artifactId
    name: ${project.artifactId}
  mvc:
    #无拦截
    static-path-pattern: /**
  resources:
    static-locations: classpath:/${web.root}
  session:
    #session使用redis
    #store-type: redis
    #Demo不处理Session
    store-type: none
  #redis集群和连接池相关配置
  redis:
    host: 47.105.160.21
    port: 7111
    password: ipu
    pool:
      max-active: 8
      max-idle: 8
      max-wait: -1
      #默认0，不回收
      min-idle: 8
web:
  root: webapp/
logging:
  level: 
    root: DEBUG
  file: /data/logs/boot.log
define:
  session:
    timeout: 1800

qb-auth-server/src/main/resources/dev/ipu-cache.xml

@@ -0,0 +1,32 @@
<?xml version = '1.0' encoding = 'UTF-8'?>
<caches>
	<!-- ====================redis缓存============================ -->
	<cache name="ssn" type="redis">
		<servers>
			<!-- 如果不是cluster，则只使用第一个redis -->
			<server ip="121.42.183.206" port="7101" />
			<server ip="121.42.183.206" port="7102" />
			<server ip="121.42.183.206" port="7103" />
			<server ip="121.42.183.206" port="7104" />
			<server ip="121.42.183.206" port="7105" />
			<server ip="121.42.183.206" port="7106" />
		</servers>
		<!-- 客户端类型:Jedis,JedisCluster -->
		<config name="clientType" value="JedisCluster" />
		<!-- 访问redis的密码，可以为空 -->
		<config name="auth" value="Ipu@321!" />
		<!-- redis池的可用连接实例的最大数目，缺省为8 -->
		<config name="poolSize" value="10" />
		<!-- redis池最多有多少个状态为idle(空闲的)的jedis实例，缺省为8,空闲连接大于这个数会进行回收 -->
		<config name="maxIdle" />
		<!-- 最小空闲数，空闲连接小于这个数会建立新的连接，缺省为0 -->
		<config name="minIdle" />
		<!-- 等待Response超时时间,默认5000ms -->
		<config name="soTimeout" />
		<!-- 连接Redis Server超时时间,默认5000ms -->
		<config name="connTimeout" />
		<!-- 出现异常最大重试次数 -->
		<config name="maxAttempts" />
	</cache>
</caches>

qb-auth-server/src/main/resources/dev/ipu-mybatis-config.xml

@@ -0,0 +1,28 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration
    PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
    "http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>
    <settings>
		<setting name="defaultFetchSize" value="1000" /> <!-- 结果集获取数量提示值，分批传输 -->
		<!-- 当没有为参数提供特定的 JDBC 类型时，为空值指定 JDBC 类型。 某些驱动需要指定列的 JDBC 类型，多数情况直接用一般类型即可，比如 NULL、VARCHAR 或 OTHER。mybatis缺省为OTHER -->
		<setting name="jdbcTypeForNull" value="NULL" />
	</settings>
    <plugins>
        <!-- 分页插件，可根据参数定制化 -->
	    <plugin interceptor="com.github.pagehelper.PageInterceptor"></plugin>
	</plugins>
	<environments default="test">
		<environment id="auth">
			<transactionManager type="jdbc" />
			<dataSource type="com.ai.ipu.database.datasource.DruidDataSourceFactory">
				<property name="jdbcUrl" value="jdbc:mysql://127.0.0.1:3307/auth" />
				<property name="username" value="root" />
				<property name="password" value="rootroot" />
				<!-- 配置获取连接的等待超时时间 -->
				<property name="maxWait" value="5000" />
			</dataSource>
		</environment>
	</environments>
</configuration>

qb-auth-server/src/main/resources/dev/log4j2.xml

@@ -0,0 +1,15 @@
<?xml version="1.0" encoding="UTF-8"?>
<Configuration status="WARN">
    <Appenders>
        <Console name="Console" target="SYSTEM_OUT">
            <PatternLayout pattern="%d{HH:mm:ss.SSS} [%t] %-5level %logger{36} - %msg%n"/>
        </Console>
    </Appenders>
    <Loggers>
        <Root level="ERROR">
            <AppenderRef ref="Console"/>
        </Root>
        <logger name="com.ai" level="DEBUG"></logger>
        <logger name="org" level="ERROR"></logger>
    </Loggers>
</Configuration>

qb-auth-server/src/main/resources/dev/menu.json

@@ -0,0 +1,43 @@
[
  {
    "id": "1",
    "name": "帮助ReadMe",
    "path": "/help",
    "icon": "aid-help-circle",
    "type": "R",
    "remark": "",
    "subMenu": []
  },
  {
    "id": "2",
    "name": "百度",
    "path": "/iframe",
    "icon": "aid-search-web",
    "type": "F",
    "remark": "https://www.baidu.com/",
    "subMenu": []
  },
  {
    "id": "3",
    "name": "二级菜单",
    "path": "",
    "icon": "aid-air-conditioner",
    "remark": "",
    "subMenu": [
      {
        "id": "1",
        "name": "帮助ReadMe2",
        "path": "/help2",
        "type": "R",
        "remark": "备注"
      },
      {
        "id": "2",
        "name": "百度2",
        "path": "/iframe2",
        "type": "F",
        "remark": "https://www.baidu.com/"
      }
    ]
  }
]

qb-auth-server/src/main/resources/flow/menu/menu_delete.xml

@@ -0,0 +1,99 @@
<?xml version="1.0" encoding="UTF-8"?>
<logic-flow id="menu_delete"
            name="菜单删除"
            desc="菜单删除">
    <declare>
        <!-- 引入model定义 -->
        <import model="sec_menu"/>
        <import model="sec_priv_entity"/>
    </declare>
    <start id="start" name="开始节点" next="selectMenuCount">
        <var key="menu_id" model="sec_menu" attr="menu_id"/>
    </start>
    <action id="selectMenuCount" name="查询判断" next="printParentMenu">
        <input>
            <var key="menu_id" model="sec_menu" attr="menu_id"/>
        </input>
        <sql conn="auth">
            <![CDATA[
            select menu_id, parent_menu_id from sec_menu where parent_menu_id = ${menu_id};
        ]]>
        </sql>
        <output>
            <var key="menus"/>
        </output>
    </action>
    <action id="printParentMenu" name="判断" next="menuCountCond">
        <expression>
            <![CDATA[
            System.out.println("parent_menu_id==="+DATABUS.menus);
        ]]>
        </expression>
    </action>
    <action id="menuCountCond" name="判断菜单条件" next="deleteRoleGrant">
        <input>
            <var key="menus"/>
        </input>
        <if test="menus.size>=1" interrupt="【${menu_id}】存在父级菜单无法删除!"/>
        <if test="menus.size==0" next="deleteRoleGrant"/>
    </action>
    <action id="deleteRoleGrant" name="删除角色权限" next="aggregateMenuId">
        <input>
            <var key="menu_id" model="sec_menu" attr="menu_id"/>
        </input>
        <sql conn="auth">
            delete from sec_role_grant where priv_ent_id in (
            select priv_ent_id from sec_priv_entity where busi_obj_id = ${menu_id}
            )
        </sql>
        <output>
            <var key="delete_menu_num"/>
        </output>
    </action>
    <action id="aggregateMenuId" name="聚合菜单条件" next="printPrivEntity">
        <input>
            <var key="menu_id" model="sec_menu" attr="menu_id"/>
        </input>
        <aggregate>
            <![CDATA[
            {"menu_id":"busi_obj_id"}
        ]]>
        </aggregate>
        <output>
            <var key="priv_entity"/>
        </output>
    </action>
    <action id="printPrivEntity" name="判断" next="deletePrivEntity">
        <expression>
            <![CDATA[
            System.out.println("priv_entity==="+DATABUS.priv_entity);
        ]]>
        </expression>
    </action>
    <action id="deletePrivEntity" name="删除角色授权表" next="end">
        <input>
            <var key="priv_entity" model="sec_priv_entity" attrExists="false"/>
        </input>
        <function domain="DB" name="deleteByCond">
            <param value="auth" type="string"/>
            <param value="sec_priv_entity" type="string"/>
            <param key="priv_entity" type="map"/>
            <param value="uppercase" type="string"/>
        </function>
        <output>
            <var key="delete_num"/>
        </output>
    </action>
    <end id="end" name="结束节点">
        <var key="delete_num"/>
    </end>
</logic-flow>

qb-auth-server/src/main/resources/flow/menu/menu_insert.xml

@@ -0,0 +1,27 @@
<?xml version="1.0" encoding="UTF-8"?>
<logic-flow id="menu_insert"
            name="菜单新增"
            desc="菜单新增">
    <declare>
        <!-- 引入model定义 -->
        <import model="sec_menu"/>
    </declare>
    <start id="start" name="开始节点" next="insertMenu">
        <var key="menu" model="sec_menu"/>
    </start>
    <action id="insertMenu" name="新增菜单" next="end">
        <input>
            <var key="menu"/>
        </input>
        <behavior model="sec_menu" id="insertMenu"/>
        <output>
            <var key="insert_num"/>
        </output>
    </action>
    <end id="end" name="结束节点">
        <var key="insert_num"/>
    </end>
</logic-flow>

qb-auth-server/src/main/resources/flow/menu/model/sec_menu.xml

@@ -0,0 +1,55 @@
<?xml version="1.0" encoding="UTF-8"?>
<model id="sec_menu" name="用户信息模型">
    <attr id="menu_id" type="int" name="菜单标识"/>
    <attr id="parent_menu_id" type="int" name="父菜单标识"/>
    <attr id="menu_type" type="string" name="菜单类型"/>
    <attr id="menu_name" type="string" name="菜单名称"/>
    <attr id="menu_title" type="string" name="菜单标题"/>
    <attr id="level" type="int" name="菜单层级"/>
    <attr id="menu_sort" type="int" name="菜单顺序"/>
    <attr id="menu_component" type="string" name="菜单组件"/>
    <attr id="menu_icon" type="string" name="菜单图标"/>
    <attr id="link_url" type="string" name="菜单链接"/>
    <attr id="iframe_flag" type="int" name="框架标记"/>
    <attr id="hidden_flag" type="int" name="隐藏标记"/>
    <attr id="data_status" type="string" name="数据状态"/>
    <attr id="create_date" type="datetime" name="创建日期"/>
    <attr id="done_date" type="datetime" name="操作日期"/>
    <attr id="op_id" type="string" name="操作人员"/>
    
    <behavior id="insertMenu" name="新增菜单信息">
        <function domain="DB" name="insert">
            <param value="auth" type="string"/>
            <param value="sec_menu" type="string"/>
            <param key="menu" type="map"/>
            <param value="uppercase" type="string"/>
        </function>
    </behavior>
    <behavior id="selectMenu" name="查询菜单信息">
        <function domain="DB" name="select">
            <param value="auth" type="string"/>
            <param value="sec_menu" type="string"/>
            <param key="menu" type="map"/>
            <param value="uppercase" type="string"/>
        </function>
    </behavior>
    <behavior id="updateMenu" name="修改菜单信息">
        <function domain="DB" name="update">
            <param value="auth" type="string"/>
            <param value="sec_menu" type="string"/>
            <param key="menu" type="map"/>
            <param value="uppercase" type="string"/>
        </function>
    </behavior>
    <behavior id="deletetMenu" name="删除菜单信息">
        <function domain="DB" name="delete">
            <param value="auth" type="string"/>
            <param value="sec_menu" type="string"/>
            <param key="menu" type="map"/>
            <param value="uppercase" type="string"/>
        </function>
    </behavior>
</model>

qb-auth-server/src/main/resources/flow/menu/model/sec_priv_entity.xml

@@ -0,0 +1,57 @@
<?xml version="1.0" encoding="UTF-8"?>
<model id="sec_priv_entity" name="角色关联菜单信息模型">
    <attr id="priv_ent_id" type="int" name="角色关联菜单标识"/>
    <attr id="priv_ent_name" type="string" name="菜单名称"/>
    <attr id="busi_obj_id" type="string" name="业务对象标识"/>
    <attr id="busi_obj_type" type="int" name="业务对象类型"/>
    <attr id="data_status" type="string" name="数据状态"/>
    <attr id="create_date" type="datetime" name="创建日期"/>
    <attr id="create_op_id" type="string" name="创建人员"/>
    <attr id="done_date" type="datetime" name="操作日期"/>
    <attr id="op_id" type="string" name="操作人员"/>
    <behavior id="insertPrivEntity" name="新增角色关联菜单信息">
        <function domain="DB" name="insert">
            <param value="auth" type="string"/>
            <param value="sec_priv_entity" type="string"/>
            <param key="priv_entity" type="map"/>
            <param value="uppercase" type="string"/>
        </function>
    </behavior>
    <behavior id="selectPrivEntity" name="查询角色关联菜单信息">
        <function domain="DB" name="select">
            <param value="auth" type="string"/>
            <param value="sec_priv_entity" type="string"/>
            <param key="priv_entity" type="map"/>
            <param value="uppercase" type="string"/>
        </function>
    </behavior>
    <behavior id="updatePrivEntity" name="修改角色关联菜单信息">
        <function domain="DB" name="update">
            <param value="auth" type="string"/>
            <param value="sec_priv_entity" type="string"/>
            <param key="priv_entity" type="map"/>
            <param value="uppercase" type="string"/>
        </function>
    </behavior>
    <behavior id="deletetPrivEntity" name="删除角色关联菜单信息">
        <function domain="DB" name="delete">
            <param value="auth" type="string"/>
            <param value="sec_priv_entity" type="string"/>
            <param key="priv_entity" type="map"/>
            <param value="uppercase" type="string"/>
        </function>
    </behavior>
    <behavior id="deletetByCondPrivEntity" name="删除角色关联菜单信息">
        <function domain="DB" name="deleteByCond">
            <param value="auth" type="string"/>
            <param value="sec_priv_entity" type="string"/>
            <param key="priv_entity" type="map"/>
            <param value="uppercase" type="string"/>
        </function>
    </behavior>
</model>

qb-auth-server/src/main/resources/flow/menu/priv_entity_insert.xml

@@ -0,0 +1,27 @@
<?xml version="1.0" encoding="UTF-8"?>
<logic-flow id="priv_entity_insert"
            name="角色关联菜单新增"
            desc="角色关联菜单新增">
    <declare>
        <!-- 引入model定义 -->
        <import model="sec_priv_entity"/>
    </declare>
    <start id="start" name="开始节点" next="insertPrivEntity">
        <var key="priv_entity" model="sec_priv_entity"/>
    </start>
    <action id="insertPrivEntity" name="新增角色关联菜单" next="end">
        <input>
            <var key="priv_entity"/>
        </input>
        <behavior model="sec_priv_entity" id="insertPrivEntity"/>
        <output>
            <var key="insert_num"/>
        </output>
    </action>
    <end id="end" name="结束节点">
        <var key="insert_num"/>
    </end>
</logic-flow>

qb-auth-server/src/main/resources/flow/org/model/sec_org_user_rel.xml

@@ -0,0 +1,56 @@
<?xml version="1.0" encoding="UTF-8"?>
<model id="sec_org_user_rel" name="用户组织信息模型">
    <attr id="role_user_rel_id" type="int" name="角色关联用户标识"/>
    <attr id="user_id" type="int" name="用户标识"/>
    <attr id="role_id" type="int" name="角色标识"/>
    <attr id="valid_date" type="datetime" name="生效日期"/>
    <attr id="expire_date" type="datetime" name="失效日期"/>
    <attr id="data_status" type="string" name="数据状态"/>
    <attr id="create_date" type="datetime" name="创建日期"/>
    <attr id="create_op_id" type="string" name="创建人员"/>
    <attr id="create_org_id" type="string" name="创建组织"/>
    <attr id="done_code" type="datetime" name="事务编号"/>
    <attr id="done_date" type="datetime" name="操作日期"/>
    <attr id="op_id" type="string" name="操作人员"/>
    <attr id="org_id" type="string" name="操作组织"/>
    <attr id="mgmt_district" type="string" name="管理地区"/>
    <attr id="mgmt_county" type="string" name="管理国家"/>
    <attr id="region_id" type="string" name="区域ID"/>
    <attr id="tenant_code" type="string" name="租户编码"/>
    <behavior id="insertOrgUserRel" name="新增用户组织信息">
        <function domain="DB" name="insert">
            <param value="auth" type="string"/>
            <param value="sec_org_user_rel" type="string"/>
            <param key="org_user_rel" type="map"/>
            <param value="uppercase" type="string"/>
        </function>
    </behavior>
    <behavior id="selectOrgUserRel" name="查询用户组织信息">
        <function domain="DB" name="select">
            <param value="auth" type="string"/>
            <param value="sec_org_user_rel" type="string"/>
            <param key="org_user_rel" type="map"/>
            <param value="uppercase" type="string"/>
        </function>
    </behavior>
    <behavior id="updateOrgUserRel" name="修改用户组织信息">
        <function domain="DB" name="update">
            <param value="auth" type="string"/>
            <param value="sec_org_user_rel" type="string"/>
            <param key="org_user_rel" type="map"/>
            <param value="uppercase" type="string"/>
        </function>
    </behavior>
    <behavior id="deletetOrgUserRel" name="删除用户组织信息">
        <function domain="DB" name="delete">
            <param value="auth" type="string"/>
            <param value="sec_org_user_rel" type="string"/>
            <param key="org_user_rel" type="map"/>
            <param value="uppercase" type="string"/>
        </function>
    </behavior>
</model>

qb-auth-server/src/main/resources/flow/org/model/sec_organize.xml

@@ -0,0 +1,56 @@
<?xml version="1.0" encoding="UTF-8"?>
<model id="sec_organize" name="用户信息模型">
    <attr id="organize_id" type="int" name="组织标识"/>
    <attr id="organize_type" type="string" name="组织类型"/>
    <attr id="organize_name" type="string" name="组织名称"/>
    <attr id="parent_organize_id" type="int" name="父组织标识"/>
    <attr id="short_name" type="string" name="组织简称"/>
    <attr id="english_name" type="string" name="组织英文名称"/>
    <attr id="dept_full_id" type="int" name="部门ID"/>
    <attr id="dept_full_name" type="string" name="部门名称"/>
    <attr id="level" type="int" name="部门层级"/>
    <attr id="dept_leader" type="int" name="部门领导"/>
    <attr id="org_level" type="string" name="组织层级"/>   <!-- 1-启用，0-禁用 -->
    <attr id="remark" type="string" name="备注"/>
    <attr id="data_status" type="string" name="数据状态"/>
    <attr id="create_date" type="datetime" name="创建日期"/>
    <attr id="create_op_id" type="string" name="创建人员"/>
    <attr id="done_date" type="datetime" name="操作日期"/>
    <attr id="op_id" type="string" name="操作人员"/>
    <behavior id="insertOrganize" name="新增组织信息">
        <function domain="DB" name="insert">
            <param value="auth" type="string"/>
            <param value="sec_organize" type="string"/>
            <param key="organize" type="map"/>
            <param value="uppercase" type="string"/>
        </function>
    </behavior>
    <behavior id="selectOrganize" name="查询组织信息">
        <function domain="DB" name="select">
            <param value="auth" type="string"/>
            <param value="sec_organize" type="string"/>
            <param key="organize" type="map"/>
            <param value="uppercase" type="string"/>
        </function>
    </behavior>
    <behavior id="updateOrganize" name="修改组织信息">
        <function domain="DB" name="update">
            <param value="auth" type="string"/>
            <param value="sec_organize" type="string"/>
            <param key="organize" type="map"/>
            <param value="uppercase" type="string"/>
        </function>
    </behavior>
    <behavior id="deletetOrganize" name="删除组织信息">
        <function domain="DB" name="delete">
            <param value="auth" type="string"/>
            <param value="sec_organize" type="string"/>
            <param key="organize" type="map"/>
            <param value="uppercase" type="string"/>
        </function>
    </behavior>
</model>

qb-auth-server/src/main/resources/flow/org/organize_insert.xml

@@ -0,0 +1,27 @@
<?xml version="1.0" encoding="UTF-8"?>
<logic-flow id="organize_insert"
            name="组织新增"
            desc="组织新增">
    <declare>
        <!-- 引入model定义 -->
        <import model="sec_organize"/>
    </declare>
    <start id="start" name="开始节点" next="insertOrganize">
        <var key="organize" model="sec_organize" attrExists="false"/>
    </start>
    <action id="insertOrganize" name="新增组织" next="end">
        <input>
            <var key="organize"/>
        </input>
        <behavior model="sec_organize" id="insertOrganize"/>
        <output>
            <var key="insert_num"/>
        </output>
    </action>
    <end id="end" name="结束节点">
        <var key="insert_num"/>
    </end>
</logic-flow>

qb-auth-server/src/main/resources/flow/org/organize_select.xml

@@ -0,0 +1,27 @@
<?xml version="1.0" encoding="UTF-8"?>
<logic-flow id="organize_select"
            name="组织查询"
            desc="组织查询">
    <declare>
        <!-- 引入model定义 -->
        <import model="sec_organize"/>
    </declare>
    <start id="start" name="开始节点" next="selectOrganize">
        <var key="organize" model="sec_organize" attrExists="false"/>
    </start>
    <action id="selectOrganize" name="查询组织" next="end">
        <input>
            <var key="organize" />
        </input>
        <behavior model="sec_organize" id="selectOrganize"/>
        <output>
            <var key="organize_info"/>
        </output>
    </action>
    <end id="end" name="结束节点">
        <var key="organize_info"/>
    </end>
</logic-flow>

qb-auth-server/src/main/resources/flow/role/model/sec_role.xml

@@ -0,0 +1,48 @@
<?xml version="1.0" encoding="UTF-8"?>
<model id="sec_role" name="角色信息模型">
    <attr id="role_id" type="int" name="角色标识"/>
    <attr id="role_name" type="string" name="角色名称"/>
    <attr id="role_type" type="int" name="角色类型"/>
    <attr id="description" type="string" name="角色描述"/>
    <attr id="data_status" type="string" name="数据状态"/>
    <attr id="create_date" type="datetime" name="创建日期"/>
    <attr id="create_op_id" type="string" name="创建人员"/>
    <attr id="done_date" type="datetime" name="操作日期"/>
    <attr id="op_id" type="datetime" name="操作人员"/>
    <behavior id="insertRole" name="新增角色信息">
        <function domain="DB" name="insert">
            <param value="auth" type="string"/>
            <param value="sec_role" type="string"/>
            <param key="role" type="map"/>
            <param value="uppercase" type="string"/>
        </function>
    </behavior>
    <behavior id="selectRole" name="查询角色信息">
        <function domain="DB" name="select">
            <param value="auth" type="string"/>
            <param value="sec_role" type="string"/>
            <param key="role" type="map"/>
            <param value="uppercase" type="string"/>
        </function>
    </behavior>
    <behavior id="updateRole" name="修改角色信息">
        <function domain="DB" name="update">
            <param value="auth" type="string"/>
            <param value="sec_role" type="string"/>
            <param key="role" type="map"/>
            <param value="uppercase" type="string"/>
        </function>
    </behavior>
    <behavior id="deletetRole" name="删除角色信息">
        <function domain="DB" name="delete">
            <param value="auth" type="string"/>
            <param value="sec_role" type="string"/>
            <param key="role" type="map"/>
            <param value="uppercase" type="string"/>
        </function>
    </behavior>
</model>

qb-auth-server/src/main/resources/flow/role/model/sec_role_grant.xml

@@ -0,0 +1,57 @@
<?xml version="1.0" encoding="UTF-8"?>
<model id="sec_role_grant" name="角色授权信息模型">
    <attr id="role_grant_id" type="int" name="角色授权标识"/>
    <attr id="role_id" type="int" name="角色标识"/>
    <attr id="priv_ent_id" type="int" name="角色关联菜单标识"/>
    <attr id="remark" type="string" name="标注信息"/>
    <attr id="valid_date" type="datetime" name="生效日期"/>
    <attr id="expire_date" type="datetime" name="失效日期"/>
    <attr id="data_status" type="string" name="数据状态"/>
    <attr id="create_date" type="datetime" name="创建日期"/>
    <attr id="create_op_id" type="string" name="创建人员"/>
    <attr id="create_org_id" type="string" name="创建组织"/>
    <attr id="done_code" type="datetime"    name="操作编码"/>
    <attr id="done_date" type="datetime"    name="操作日期"/>
    <attr id="op_id" type="string" name="操作人员"/>
    <attr id="org_id" type="string" name="操作组织"/>
    <attr id="mgmt_district" type="string" name="管理地区"/>
    <attr id="mgmt_county" type="string" name="管理国家"/>
    <attr id="region_id" type="string" name="区域ID"/>
    <attr id="tenant_code" type="string" name="租户编码"/>
    <behavior id="insertRoleGrant" name="新增角色授权信息">
        <function domain="DB" name="insert">
            <param value="auth" type="string"/>
            <param value="sec_role_grant" type="string"/>
            <param key="role_grant" type="map"/>
            <param value="uppercase" type="string"/>
        </function>
    </behavior>
    <behavior id="selectRoleGrant" name="查询角色授权信息">
        <function domain="DB" name="select">
            <param value="auth" type="string"/>
            <param value="sec_role_grant" type="string"/>
            <param key="role_grant" type="map"/>
            <param value="uppercase" type="string"/>
        </function>
    </behavior>
    <behavior id="updateRoleGrant" name="修改角色授权信息">
        <function domain="DB" name="update">
            <param value="auth" type="string"/>
            <param value="sec_role_grant" type="string"/>
            <param key="role_grant" type="map"/>
            <param value="uppercase" type="string"/>
        </function>
    </behavior>
    <behavior id="deletetRoleGrant" name="删除角色授权信息">
        <function domain="DB" name="delete">
            <param value="auth" type="string"/>
            <param value="sec_role_grant" type="string"/>
            <param key="role_grant" type="map"/>
            <param value="uppercase" type="string"/>
        </function>
    </behavior>
</model>

qb-auth-server/src/main/resources/flow/role/role_grant_insert.xml

@@ -0,0 +1,27 @@
<?xml version="1.0" encoding="UTF-8"?>
<logic-flow id="role_grant_insert"
            name="角色授权新增"
            desc="角色授权新增">
    <declare>
        <!-- 引入model定义 -->
        <import model="sec_role_grant"/>
    </declare>
    <start id="start" name="开始节点" next="insertRoleGrant">
        <var key="role_grant" model="sec_role_grant" attrExists="false"/>
    </start>
    <action id="insertRoleGrant" name="新增角色授权" next="end">
        <input>
            <var key="role_grant"/>
        </input>
        <behavior model="sec_role_grant" id="insertRoleGrant"/>
        <output>
            <var key="insert_num"/>
        </output>
    </action>
    <end id="end" name="结束节点">
        <var key="insert_num"/>
    </end>
</logic-flow>

qb-auth-server/src/main/resources/flow/user/model/sec_user.xml

@@ -0,0 +1,83 @@
<?xml version="1.0" encoding="UTF-8"?>
<model id="sec_user" name="用户信息模型">
    <attr id="user_id" type="int" name="用户标识"/>
    <attr id="nick_name" type="string" name="用户昵称">
    </attr>
    <attr id="user_account" type="string" name="用户账号"/>
    <attr id="gender" type="string" name="性别"/>
    <attr id="avatar_name" type="string" name="用户头像"/>
    <attr id="avatar_path" type="string" name="用户头像路径"/>
    <attr id="email" type="string" name="电子邮箱"/>
    <attr id="link_phone" type="string" name="电话号码">
        <validateString equal="11"/>
    </attr>
    <attr id="password" type="string" name="密码"/>
    <attr id="admin_flag" type="int" name="是否管理员"/>
    <attr id="sec_level" type="string" name="sec_level"/>
    <attr id="enabled_flag" type="string" name="启用状态"/>   <!-- 1-启用，0-禁用 -->
    <attr id="pwd_reset_time" type="string" name="密码重置次数"/>
    <attr id="valid_date" type="datetime" name="生效日期"/>
    <attr id="expire_date" type="datetime" name="失效日期"/>
    <attr id="data_status" type="string" name="数据状态"/>
    <attr id="valid_date" type="datetime" name="生效日期"/>
    <attr id="create_date" type="datetime" name="创建日期"/>
    <attr id="create_op_id" type="string" name="创建人员"/>
    <attr id="done_date" type="datetime"    name="操作日期"/>
    <attr id="op_id" type="string" name="操作人员"/>
    <behavior id="insertUser" name="新增用户信息">
        <function domain="DB" name="insert">
            <param value="auth" type="string"/>
            <param value="sec_user" type="string"/>
            <param key="user" type="map"/>
            <param value="uppercase" type="string"/>
        </function>
    </behavior>
    <behavior id="selectUser" name="查询用户信息">
        <function domain="DB" name="select">
            <param value="auth" type="string"/>
            <param value="sec_user" type="string"/>
            <param key="user" type="map"/>
            <param value="uppercase" type="string"/>
        </function>
    </behavior>
    <behavior id="selectUserByName" name="查询用户信息列表">
        <sql conn="auth">
            <![CDATA[
            select user_id, nick_name, surname, user_account, avatar_name, link_phone, sec_level, enabled_flag, done_date
            from sec_user
            WHERE nick_name like "%"#{nick_name}"%" and data_status = '1';
        ]]>
        </sql>
    </behavior>
    <behavior id="updateUser" name="修改用户信息">
        <function domain="DB" name="update">
            <param value="auth" type="string"/>
            <param value="sec_user" type="string"/>
            <param key="user" type="map"/>
            <param value="uppercase" type="string"/>
        </function>
    </behavior>
    <behavior id="deletetUser" name="删除用户信息">
        <function domain="DB" name="delete">
            <param value="auth" type="string"/>
            <param value="sec_user" type="string"/>
            <param key="user" type="map"/>
            <param value="uppercase" type="string"/>
        </function>
    </behavior>
    <behavior id="updateUserByCond" name="根据条件修改用户信息">
        <function domain="DB" name="updateByCond">
            <param value="auth" type="string"/>
            <param value="sec_user" type="string"/>
            <param key="user" type="map"/>
            <param key="user_cond" type="map"/>
            <param value="uppercase" type="string"/>
        </function>
    </behavior>
</model>

qb-auth-server/src/main/resources/flow/user/user_disable_with_aggregate.xml

@@ -0,0 +1,53 @@
<?xml version="1.0" encoding="UTF-8"?>
<logic-flow id="user_disable_with_aggregate"
            name="用户禁用"
            desc="用户禁用">
    <declare>
        <!-- 引入model定义 -->
        <import model="sec_user"/>
        <attr id="done_date" type="datetime">
            <validateDatetime nullable="false"/>
        </attr>
    </declare>
    <start id="start" name="开始节点" next="aggregateUser">
        <var key="user_id" model="sec_user" attr="user_id"/>
    </start>
    <action id="aggregateUser" name="聚合用户信息" next="aggregateUserCond">
        <input>
            <var key="user_id" model="sec_user" attr="user_id"/>
        </input>
        <aggregate />
        <output>
            <var key="user_cond"/>
        </output>
    </action>
    <action id="aggregateUserCond" name="聚合用户信息" next="disableUser">
        <input>
            <var key="enabled_flag" model="sec_user" attr="enabled_flag" initial="0"/>
            <var key="done_date" model="sec_user" attr="done_date" initialMethod="getDatetime"/>
            <var key="op_id" model="sec_user" attr="op_id" initial="1"/>
        </input>
        <aggregate />
        <output>
            <var key="user"/>
        </output>
    </action>
    <action id="disableUser" name="禁用用户" next="end">
        <input>
            <var key="user" model="sec_user" attrExists="false"/>
            <var key="user_cond" model="sec_user" attrExists="false"/>
        </input>
        <behavior model="sec_user" id="updateUserByCond"/>
        <output>
            <var key="update_num"/>
        </output>
    </action>
    <end id="end" name="结束节点">
        <var key="update_num"/>
    </end>
</logic-flow>

qb-auth-server/src/main/resources/flow/user/user_insert.xml

@@ -0,0 +1,43 @@
<?xml version="1.0" encoding="UTF-8"?>
<logic-flow id="user_insert"
            name="用户新增"
            desc="用户新增">
    <declare>
        <!-- 引入model定义 -->
        <import model="sec_user"/>
    </declare>
    <start id="start" name="开始节点" next="insertUser">
        <var key="user" model="sec_user"/>
    </start>
    <!--<action id="aggregateUser" name="聚合用户信息" next="insertUser">
        <input>
            <var key="user_id" />
            <var key="user_name"/>
            <var key="gender" />
            <var key="user_state"/>
            <var key="email" />
            <var key="link_phone"/>
            <var key="valid_date" initialMethod="getDatetime"/>
        </input>
        <aggregate />
        <output>
            <var key="user_param"/>
        </output>
    </action>-->
    <action id="insertUser" name="新增用户" next="end">
        <input>
            <var key="user"/>
        </input>
        <behavior model="sec_user" id="insertUser"/>
        <output>
            <var key="insert_num"/>
        </output>
    </action>
    <end id="end" name="结束节点">
        <var key="insert_num"/>
    </end>
</logic-flow>

qb-auth-server/src/main/resources/flow/user/user_select.xml

@@ -0,0 +1,27 @@
<?xml version="1.0" encoding="UTF-8"?>
<logic-flow id="user_select"
            name="用户查询"
            desc="用户查询">
    <declare>
        <!-- 引入model定义 -->
        <import model="sec_user"/>
    </declare>
    <start id="start" name="开始节点" next="selectUser">
        <var key="user" model="sec_user" attrExists="false"/>
    </start>
    <action id="selectUser" name="查询用户" next="end">
        <input>
            <var key="user" />
        </input>
        <behavior model="sec_user" id="selectUser"/>
        <output>
            <var key="user_info"/>
        </output>
    </action>
    <end id="end" name="结束节点">
        <var key="user_info"/>
    </end>
</logic-flow>

qb-auth-server/src/main/resources/flow/user/user_select_by_id.xml

@@ -0,0 +1,37 @@
<?xml version="1.0" encoding="UTF-8"?>
<logic-flow id="user_select_by_id"
            name="用户查询"
            desc="用户查询">
    <declare>
        <!-- 引入model定义 -->
        <import model="sec_user"/>
    </declare>
    <start id="start" name="开始节点" next="aggregateUser">
        <var key="user_id" model="sec_user" attr="user_id"/>
    </start>
    <action id="aggregateUser" name="聚合用户信息" next="selectUser">
        <input>
            <var key="user_id" />
        </input>
        <aggregate />
        <output>
            <var key="user"/>
        </output>
    </action>
    <action id="selectUser" name="查询用户" next="end">
        <input>
            <var key="user" model="sec_user" attrExists="false"/>
        </input>
        <behavior model="sec_user" id="selectUser"/>
        <output>
            <var key="user_info"/>
        </output>
    </action>
    <end id="end" name="结束节点">
        <var key="user_info"/>
    </end>
</logic-flow>

qb-auth-server/src/main/resources/flow/user/user_select_by_name.xml

@@ -0,0 +1,27 @@
<?xml version="1.0" encoding="UTF-8"?>
<logic-flow id="user_select_by_name"
            name="查询用户列表"
            desc="查询用户列表">
    <declare>
        <!-- 引入model定义 -->
        <import model="sec_user"/>
    </declare>
    <start id="start" name="开始节点" next="selectUserByName">
        <var key="nick_name" model="sec_user" attr="nick_name"/>
    </start>
    <action id="selectUserByName" name="根据用户名查询用户" next="end">
        <input>
            <var key="nick_name" model="sec_user" attr="nick_name"/>
        </input>
        <behavior model="sec_user" id="selectUserByName"/>
        <output>
            <var key="user_list"/>
        </output>
    </action>
    <end id="end" name="结束节点">
        <var key="user_list"/>
    </end>
</logic-flow>

qb-auth-server/src/main/resources/flow/user/user_update.xml

@@ -0,0 +1,29 @@
<?xml version="1.0" encoding="UTF-8"?>
<logic-flow id="user_update"
            name="用户启用"
            desc="用户启用">
    <declare>
        <!-- 引入model定义 -->
        <import model="sec_user"/>
    </declare>
    <start id="start" name="开始节点" next="updateUser">
        <var key="user" model="sec_user" attrExists="false"/>
        <var key="user_cond" model="sec_user" attrExists="false"/>
    </start>
    <action id="updateUser" name="启用用户" next="end">
        <input>
            <var key="user" model="sec_user" attrExists="false"/>
            <var key="user_cond" model="sec_user" attrExists="false"/>
        </input>
        <behavior model="sec_user" id="updateUserByCond"/>
        <output>
            <var key="update_num"/>
        </output>
    </action>
    <end id="end" name="结束节点">
        <var key="update_num"/>
    </end>
</logic-flow>

qb-auth-server/src/main/resources/ipu-spring-mvc.xml

@@ -0,0 +1,15 @@
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	   xmlns:context="http://www.springframework.org/schema/context"
	   xmlns:mvc="http://www.springframework.org/schema/mvc"
	   xsi:schemaLocation="http://www.springframework.org/schema/beans
           http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
           http://www.springframework.org/schema/context  
        http://www.springframework.org/schema/context/spring-context-3.0.xsd
        http://www.springframework.org/schema/mvc
		http://www.springframework.org/schema/mvc/spring-mvc.xsd">
    <context:component-scan base-package="com.ipu.logicflow.server" />
    <context:component-scan base-package="com.ai.ipu.portal" />
</beans>

qb-auth-server/src/main/resources/pro/application.yml

@@ -0,0 +1,54 @@
#一、context-path配置的版本差异
#2.x：server.servlet.context-path=/ipu
#1.x：server.context-path=/ipu
#二、默认:server.servlet-path=/
server:
  servlet:
    context-path: /ipu
  #通过启动命令传参指定端口
  port: unknown
spring:
  application:
    #使用maven中的变量project.artifactId
    name: ${project.artifactId}
  mvc:
    #无拦截
    static-path-pattern: /**
  resources:
    static-locations: classpath:/${web.root}
  session:
    #session使用redis
    store-type: redis
  #sba监控
  boot:
    admin:
      client:
        metadata:
          user:
            name: ${security.user.name}
            password: ${security.user.password}
      url: http://www.aiipu.com:8888
  #redis集群和连接池相关配置
  redis:
    cluster:
      max-redirects: 3
      nodes: 123.57.35.51:11001,123.57.35.51:11002,123.57.35.51:11003,123.57.35.51:11004,123.57.35.51:11005,123.57.35.51:11006
      timeout: 5
    password: ipu
    pool:
      max-active: 8
      max-idle: 8
      max-wait: -1
      #默认0，不回收
      min-idle: 8
web:
  root: webapp/
logging:
  file: target/logs/${project.artifactId}.log
management:
  security:
    enabled: false
security:
  user:
    name: ipu
    password: ipu

qb-auth-server/src/main/resources/pro/ipu-mybatis-config.xml

@@ -0,0 +1,41 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration
    PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
    "http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>
    <settings>
		<setting name="defaultFetchSize" value="1000" /> <!-- 结果集获取数量提示值，分批传输 -->
		<!-- 当没有为参数提供特定的 JDBC 类型时，为空值指定 JDBC 类型。 某些驱动需要指定列的 JDBC 类型，多数情况直接用一般类型即可，比如 NULL、VARCHAR 或 OTHER。mybatis缺省为OTHER -->
		<setting name="jdbcTypeForNull" value="NULL" />
	</settings>
    <plugins>
        <!-- 分页插件，可根据参数定制化 -->
	    <plugin interceptor="com.github.pagehelper.PageInterceptor">
	        <!-- config params as the following -->
		</plugin>
	</plugins>
	<environments default="test">
		<environment id="test">
			<transactionManager type="JDBC" />
			<dataSource type="com.ai.ipu.database.datasource.C3P0DataSourceFactory">
				<property name="driverClass" value="com.mysql.jdbc.Driver" />
				<property name="jdbcUrl" value="jdbc:mysql://121.42.183.206:3307/test" />
				<property name="user" value="ipu" />
				<property name="password" value="ipumysql" />
				<!-- 连接池用完时,等待获取新连接的时间 (毫秒) -->
				<property name="checkoutTimeout" value="5000" />
				<!--定义在从数据库获取新连接失败后重复尝试的次数。Default: 30 -->
				<property name="acquireRetryAttempts" value="5" />
				<!--两次连接中间隔时间，单位毫秒。Default: 1000 -->
				<property name="acquireRetryDelay" value="1000" />
				<property name="initialPoolSize" value="3" />
				<property name="minPoolSize" value="3" />
				<property name="maxPoolSize" value="3" />
				<property name="maxIdleTime" value="600" />
				<property name="idleConnectionTestPeriod" value="60" />
				<property name="preferredTestQuery" value="SELECT 1" />
			</dataSource>
		</environment>
	</environments>
</configuration>

qb-auth-server/src/main/resources/pro/log4j2.xml

@@ -0,0 +1,14 @@
<?xml version="1.0" encoding="UTF-8"?>
<Configuration status="WARN">
    <Appenders>
        <Console name="Console" target="SYSTEM_OUT">
            <PatternLayout pattern="%d{HH:mm:ss.SSS} [%t] %-5level %logger{36} - %msg%n"/>
        </Console>
    </Appenders>
    <Loggers>
        <Root level="ERROR">
            <AppenderRef ref="Console"/>
        </Root>
        <logger name="com.ai" level="DEBUG"></logger>
    </Loggers>
</Configuration>

qb-auth-server/src/main/resources/test/application.yml

@@ -0,0 +1,54 @@
#一、context-path配置的版本差异
#2.x：server.servlet.context-path=/ipu
#1.x：server.context-path=/ipu
#二、默认:server.servlet-path=/
server:
  servlet:
    context-path: /ipu
  #通过启动命令传参指定端口
  port: unknown
spring:
  application:
    #使用maven中的变量project.artifactId
    name: ${project.artifactId}
  mvc:
    #无拦截
    static-path-pattern: /**
  resources:
    static-locations: classpath:/${web.root}
  session:
    #session使用redis
    store-type: redis
  #sba监控
  boot:
    admin:
      client:
        metadata:
          user:
            name: ${security.user.name}
            password: ${security.user.password}
      url: http://www.aiipu.com:8888
  #redis集群和连接池相关配置
  redis:
    cluster:
      max-redirects: 3
      nodes: 47.105.160.21:7101,47.105.160.21:7102,47.105.160.21:7103
      timeout: 5
    password: ipu
    pool:
      max-active: 8
      max-idle: 8
      max-wait: -1
      #默认0，不回收
      min-idle: 8
web:
  root: webapp/
logging:
  file: target/logs/${project.artifactId}.log
management:
  security:
    enabled: false
security:
  user:
    name: ipu
    password: ipu

qb-auth-server/src/main/resources/test/ipu-mybatis-config.xml

@@ -0,0 +1,41 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration
    PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
    "http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>
    <settings>
		<setting name="defaultFetchSize" value="1000" /> <!-- 结果集获取数量提示值，分批传输 -->
		<!-- 当没有为参数提供特定的 JDBC 类型时，为空值指定 JDBC 类型。 某些驱动需要指定列的 JDBC 类型，多数情况直接用一般类型即可，比如 NULL、VARCHAR 或 OTHER。mybatis缺省为OTHER -->
		<setting name="jdbcTypeForNull" value="NULL" />
	</settings>
    <plugins>
        <!-- 分页插件，可根据参数定制化 -->
	    <plugin interceptor="com.github.pagehelper.PageInterceptor">
	        <!-- config params as the following -->
		</plugin>
	</plugins>
	<environments default="test">
		<environment id="test">
			<transactionManager type="JDBC" />
			<dataSource type="com.ai.ipu.database.datasource.C3P0DataSourceFactory">
				<property name="driverClass" value="com.mysql.jdbc.Driver" />
				<property name="jdbcUrl" value="jdbc:mysql://121.42.183.206:3307/test" />
				<property name="user" value="ipu" />
				<property name="password" value="ipumysql" />
				<!-- 连接池用完时,等待获取新连接的时间 (毫秒) -->
				<property name="checkoutTimeout" value="5000" />
				<!--定义在从数据库获取新连接失败后重复尝试的次数。Default: 30 -->
				<property name="acquireRetryAttempts" value="5" />
				<!--两次连接中间隔时间，单位毫秒。Default: 1000 -->
				<property name="acquireRetryDelay" value="1000" />
				<property name="initialPoolSize" value="3" />
				<property name="minPoolSize" value="3" />
				<property name="maxPoolSize" value="3" />
				<property name="maxIdleTime" value="600" />
				<property name="idleConnectionTestPeriod" value="60" />
				<property name="preferredTestQuery" value="SELECT 1" />
			</dataSource>
		</environment>
	</environments>
</configuration>

qb-auth-server/src/main/resources/test/log4j2.xml

@@ -0,0 +1,14 @@
<?xml version="1.0" encoding="UTF-8"?>
<Configuration status="WARN">
    <Appenders>
        <Console name="Console" target="SYSTEM_OUT">
            <PatternLayout pattern="%d{HH:mm:ss.SSS} [%t] %-5level %logger{36} - %msg%n"/>
        </Console>
    </Appenders>
    <Loggers>
        <Root level="ERROR">
            <AppenderRef ref="Console"/>
        </Root>
        <logger name="com.ai" level="DEBUG"></logger>
    </Loggers>
</Configuration>

qb-auth-server/src/test/java/com/ipu/logicflow/server/MenuTest.java

@@ -0,0 +1,91 @@
package com.ipu.logicflow.server;
import com.ai.ipu.data.JMap;
import com.ai.ipu.data.impl.JsonMap;
import com.alibaba.fastjson.JSONObject;
import com.nuosi.flow.logic.LogicFlowEngine;
import com.nuosi.flow.logic.inject.initial.InitialMethod;
import com.nuosi.flow.util.LogicFlowUtil;
import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
import java.io.IOException;
/**
 * <p>desc: 菜单对象逻辑的测试 </p>
 * <p>date: 2022/3/18 22:10 </p>
 *
 * @author nuosi fsofs@163.com
 * @version v1.0.0
 */
public class MenuTest {
    @Test
    public void testInsertMenu(){
        JMap result = null;
        try {
            JMap param = new JsonMap();
            param.put("menu", new JSONObject(createMenu()));
            result = LogicFlowEngine.execute("menu_insert", param, false);
            System.out.println("执行结果：" + result);
            Assert.assertEquals("新增菜单信息失败!", result.getInt("insert_num"), 1);
        } catch (Exception e) {
            System.out.println("错误信息：" + e.getMessage());
            Assert.assertTrue(false);
        }
    }
    @Test
    public void testDeleteMenu(){
        JMap result = null;
        try {
            JMap param = new JsonMap();
            param.put("menu_id", 4);
            result = LogicFlowEngine.execute("menu_delete", param, false);
            System.out.println("执行结果：" + result);
            Assert.assertEquals("删除菜单信息失败!", result.getInt("delete_num"), 1);
        } catch (Exception e) {
            System.out.println("错误信息：" + e.getMessage());
            Assert.assertTrue(false);
        }
    }
    @Before
    public void before() throws IOException {
        String[] models = {
                "flow/menu/model/sec_menu.xml",
                "flow/menu/model/sec_priv_entity.xml"
        };
        LogicFlowUtil.loadLogicModels(models);
        String[] flows = {
                "flow/menu/menu_insert.xml",
                "flow/menu/menu_delete.xml"
        };
        LogicFlowUtil.loadLogicFlows(flows);
    }
    private JMap createMenu() throws Exception {
        String menu_id = String.valueOf(System.currentTimeMillis()).substring(7);
        JMap menuParam = new JsonMap();
        menuParam.put("menu_id", menu_id);
        menuParam.put("parent_menu_id", "1");
        menuParam.put("menu_type", "2");
        menuParam.put("menu_name", "系统管理");
        menuParam.put("menu_title", "1");
        menuParam.put("level", "1");
        menuParam.put("menu_sort", "1");
        menuParam.put("menu_component", "md-home");
        menuParam.put("menu_icon", "/sys");
        menuParam.put("link_url", null);
        menuParam.put("iframe_flag", "0");
        menuParam.put("hidden_flag", "1");
        menuParam.put("data_status", "1");
        menuParam.put("create_date", new InitialMethod().getDatetime());
        menuParam.put("done_date", new InitialMethod().getDatetime());
        menuParam.put("op_id", "1");
        return menuParam;
    }
}

qb-auth-server/src/test/java/com/ipu/logicflow/server/OrganizeTest.java

@@ -0,0 +1,93 @@
package com.ipu.logicflow.server;
import com.ai.ipu.data.JMap;
import com.ai.ipu.data.impl.JsonMap;
import com.alibaba.fastjson.JSONObject;
import com.nuosi.flow.logic.LogicFlowEngine;
import com.nuosi.flow.logic.inject.initial.InitialMethod;
import com.nuosi.flow.util.LogicFlowUtil;
import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
import java.io.IOException;
/**
 * <p>desc: 组织对象逻辑的测试 </p>
 * <p>date: 2022/3/13 10:53 </p>
 *
 * @author nuosi fsofs@163.com
 * @version v1.0.0
 */
public class OrganizeTest {
    @Test
    public void testInsertOrganize(){
        JMap result = null;
        try {
            JMap param = new JsonMap();
            param.put("organize", new JSONObject(createOrganize()));
            result = LogicFlowEngine.execute("organize_insert", param);
            System.out.println("执行结果：" + result);
            Assert.assertEquals("新增组织信息失败!", result.getInt("insert_num"), 1);
        } catch (Exception e) {
            System.out.println("错误信息：" + e.getMessage());
            Assert.assertTrue(false);
        }
    }
    @Test
    public void testSelectOrganize() {
        JMap param = new JsonMap();
        JSONObject organize = new JSONObject();
        organize.put("organize_id", "33");
        param.put("organize", organize);
        try{
            JMap result = LogicFlowEngine.execute("organize_select", param);
            System.out.println("执行结果：" + result);
            Assert.assertTrue(true);
        }catch (Exception e){
            e.printStackTrace();
            System.out.println("错误信息：" + e.getMessage());
            Assert.assertTrue(false);
        }
    }
    @Before
    public void before() throws IOException {
        String[] models = {
                "flow/org/model/sec_organize.xml"
        };
        LogicFlowUtil.loadLogicModels(models);
        String[] flows = {
                "flow/org/organize_insert.xml",
                "flow/org/organize_select.xml"
        };
        LogicFlowUtil.loadLogicFlows(flows);
    }
    private JMap createOrganize() throws Exception {
        String organize_id = String.valueOf(System.currentTimeMillis()).substring(7);
        JMap userParam = new JsonMap();
        userParam.put("organize_id", organize_id);
        userParam.put("organize_type", "0");
        userParam.put("organize_name", "亚信科技有限责任公司");
        userParam.put("parent_organize_id", "0");
        userParam.put("short_name", "亚信科技");
        userParam.put("english_name", "asiainfo");
        userParam.put("dept_full_id", "1");
        userParam.put("dept_full_name", "亚信科技");
        userParam.put("level", 1);
        userParam.put("dept_leader", 1);
        userParam.put("org_level", "1");
        userParam.put("remark", "NULL");
        userParam.put("data_status", "1");
        userParam.put("create_date", "2022-1-10 16:09:12");
        userParam.put("create_op_id", "1");
        userParam.put("done_date", new InitialMethod().getDatetime());
        userParam.put("op_id", new InitialMethod().getDatetime());
        return userParam;
    }
}

qb-auth-server/src/test/java/com/ipu/logicflow/server/PrivEntityTest.java

@@ -0,0 +1,67 @@
package com.ipu.logicflow.server;
import com.ai.ipu.data.JMap;
import com.ai.ipu.data.impl.JsonMap;
import com.alibaba.fastjson.JSONObject;
import com.nuosi.flow.logic.LogicFlowEngine;
import com.nuosi.flow.logic.inject.initial.InitialMethod;
import com.nuosi.flow.util.LogicFlowUtil;
import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
import java.io.IOException;
/**
 * <p>desc: 角色关联菜单对象逻辑的测试 </p>
 * <p>date: 2022/3/18 23:19 </p>
 *
 * @author nuosi fsofs@163.com
 * @version v1.0.0
 */
public class PrivEntityTest {
    @Test
    public void testInsertPrivEntity(){
        JMap result = null;
        try {
            JMap param = new JsonMap();
            param.put("priv_entity", new JSONObject(createPrivEntity()));
            result = LogicFlowEngine.execute("priv_entity_insert", param);
            System.out.println("执行结果：" + result);
            Assert.assertEquals("新增角色关联菜单信息失败!", result.getInt("insert_num"), 1);
        } catch (Exception e) {
            System.out.println("错误信息：" + e.getMessage());
            Assert.assertTrue(false);
        }
    }
    @Before
    public void before() throws IOException {
        String[] models = {
                "flow/menu/model/sec_priv_entity.xml"
        };
        LogicFlowUtil.loadLogicModels(models);
        String[] flows = {
                "flow/menu/priv_entity_insert.xml",
        };
        LogicFlowUtil.loadLogicFlows(flows);
    }
    private JMap createPrivEntity() throws Exception {
        String priv_ent_id = String.valueOf(System.currentTimeMillis()).substring(7);
        JMap param = new JsonMap();
        param.put("priv_ent_id", priv_ent_id);
        param.put("priv_ent_name", "角色关联菜单范例");
        param.put("busi_obj_id", "4");
        param.put("busi_obj_type", "1");
        param.put("data_status", "1");
        param.put("create_date", new InitialMethod().getDatetime());
        param.put("create_op_id", "1");
        param.put("done_date", new InitialMethod().getDatetime());
        param.put("op_id", "1");
        return param;
    }
}

qb-auth-server/src/test/java/com/ipu/logicflow/server/RoleGrantTest.java

@@ -0,0 +1,66 @@
package com.ipu.logicflow.server;
import com.ai.ipu.data.JMap;
import com.ai.ipu.data.impl.JsonMap;
import com.alibaba.fastjson.JSONObject;
import com.nuosi.flow.logic.LogicFlowEngine;
import com.nuosi.flow.logic.inject.initial.InitialMethod;
import com.nuosi.flow.util.LogicFlowUtil;
import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
import java.io.IOException;
/**
 * <p>desc: 角色授权对象逻辑的测试 </p>
 * <p>date: 2022/3/18 23:03 </p>
 *
 * @author nuosi fsofs@163.com
 * @version v1.0.0
 */
public class RoleGrantTest {
    @Test
    public void testInsertRoleGrant(){
        JMap result = null;
        try {
            JMap param = new JsonMap();
            param.put("role_grant", new JSONObject(createRoleGrant()));
            result = LogicFlowEngine.execute("role_grant_insert", param);
            System.out.println("执行结果：" + result);
            Assert.assertEquals("新增角色授权信息失败!", result.getInt("insert_num"), 1);
        } catch (Exception e) {
            System.out.println("错误信息：" + e.getMessage());
            Assert.assertTrue(false);
        }
    }
    @Before
    public void before() throws IOException {
        String[] models = {
                "flow/role/model/sec_role_grant.xml"
        };
        LogicFlowUtil.loadLogicModels(models);
        String[] flows = {
                "flow/role/role_grant_insert.xml",
        };
        LogicFlowUtil.loadLogicFlows(flows);
    }
    private JMap createRoleGrant() throws Exception {
        String role_grant_id = String.valueOf(System.currentTimeMillis()).substring(7);
        JMap menuParam = new JsonMap();
        menuParam.put("role_grant_id", role_grant_id);
        menuParam.put("role_id", "1");
        menuParam.put("priv_ent_id", "2");
        menuParam.put("valid_date", new InitialMethod().getDatetime());
        menuParam.put("data_status", "1");
        menuParam.put("create_date", new InitialMethod().getDatetime());
        menuParam.put("done_date", new InitialMethod().getDatetime());
        menuParam.put("op_id", "1");
        return menuParam;
    }
}

qb-auth-server/src/test/java/com/ipu/logicflow/server/UserTest.java

@@ -0,0 +1,219 @@
package com.ipu.logicflow.server;
import com.ai.ipu.data.JMap;
import com.ai.ipu.data.impl.JsonMap;
import com.alibaba.fastjson.JSONObject;
import com.nuosi.flow.logic.LogicFlowEngine;
import com.nuosi.flow.logic.inject.initial.InitialMethod;
import com.nuosi.flow.util.LogicFlowUtil;
import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
import java.io.IOException;
import java.util.List;
/**
 * <p>desc: 用户对象逻辑的测试 </p>
 * <p>date: 2022/1/18 19:43 </p>
 *
 * @author nuosi fsofs@163.com
 * @version v1.0.0
 */
public class UserTest {
    @Test
    public void testInsertUser(){
        JMap result = null;
        try {
            JMap param = new JsonMap();
            param.put("user", new JSONObject(createUser()));
            result = LogicFlowEngine.execute("user_insert", param);
            System.out.println("执行结果：" + result);
            Assert.assertEquals("新增用户信息失败!", result.getInt("insert_num"), 1);
        } catch (Exception e) {
            System.out.println("错误信息：" + e.getMessage());
            Assert.assertTrue(false);
        }
    }
    @Test
    public void testSelectUser() {
        JMap param = new JsonMap();
        JSONObject user = new JSONObject();
        user.put("user_id", "331843");
        param.put("user", user);
        try{
            JMap result = LogicFlowEngine.execute("user_select", param);
            System.out.println("执行结果：" + result);
            Assert.assertTrue(true);
        }catch (Exception e){
            e.printStackTrace();
            System.out.println("错误信息：" + e.getMessage());
            Assert.assertTrue(false);
        }
    }
    @Test
    public void testSelectUserById() {
        JMap param = new JsonMap();
        param.put("user_id", "331843");
        try{
            JMap result = LogicFlowEngine.execute("user_select_by_id", param);
            System.out.println("执行结果：" + result);
            Assert.assertTrue(true);
        }catch (Exception e){
            System.out.println("错误信息：" + e.getMessage());
            Assert.assertTrue(false);
        }
    }
    @Test
    public void testSelectUserByName() throws Exception {
        JMap param = new JsonMap();
        param.put("nick_name", "嘉信立恒");
        try{
            JMap result = LogicFlowEngine.execute("user_select_by_name", param);
            System.out.println("执行结果：" + result);
            Assert.assertTrue("查询用户列表失败!", ((List)result.get("user_list")).size()>=1);
        }catch (Exception e){
            System.out.println("错误信息：" + e.getMessage());
            Assert.assertTrue(false);
        }
    }
    @Test
    public void testDisableUser(){
        String user_id = "331843";
        JSONObject user_cond = new JSONObject();
        user_cond.put("user_id", user_id);
        JSONObject user = new JSONObject();
        user.put("enabled_flag", "0");
        user.put("done_date", new InitialMethod().getDatetime());
        user.put("op_id", "1");
        JMap param = new JsonMap();
        param.put("user_cond", user_cond);
        param.put("user", user);
        try{
            JMap result = LogicFlowEngine.execute("user_update", param);
            System.out.println("执行结果：" + result);
            Assert.assertTrue(true);
            // 还原数据
            user.put("enabled_flag", "1");
            user.put("op_id", user_id);
            param.put("user", user);
            LogicFlowEngine.execute("user_update", param);
        }catch (Exception e){
            e.printStackTrace();
            System.out.println("错误信息：" + e.getMessage());
            Assert.assertTrue(false);
        }
    }
    @Test
    public void testDisableUserWithAggregate(){
        String user_id = "331843";
        JMap param = new JsonMap();
        param.put("user_id", user_id);
        try{
            JMap result = LogicFlowEngine.execute("user_disable_with_aggregate", param);
            System.out.println("执行结果：" + result);
            Assert.assertTrue(true);
            // 还原数据
            JSONObject user = new JSONObject();
            user.put("enabled_flag", "1");
            user.put("op_id", user_id);
            param.put("user", user);
            JSONObject user_cond = new JSONObject();
            user_cond.put("user_id", user_id);
            param.put("user_cond", user_cond);
            LogicFlowEngine.execute("user_update", param);
        }catch (Exception e){
            e.printStackTrace();
            System.out.println("错误信息：" + e.getMessage());
            Assert.assertTrue(false);
        }
    }
    @Test
    public void testEnableUser(){
        String user_id = "331843";
        JSONObject user_cond = new JSONObject();
        user_cond.put("user_id", user_id);
        JSONObject user = new JSONObject();
        user.put("enabled_flag", "1");
        user.put("done_date", new InitialMethod().getDatetime());
        user.put("op_id", "1");
        JMap param = new JsonMap();
        param.put("user_cond", user_cond);
        param.put("user", user);
        try{
            JMap result = LogicFlowEngine.execute("user_update", param);
            System.out.println("执行结果：" + result);
            Assert.assertTrue(true);
            // 还原数据
            user.put("enabled_flag", "0");
            user.put("op_id", user_id);
            param.put("user", user);
            LogicFlowEngine.execute("user_update", param);
        }catch (Exception e){
            e.printStackTrace();
            System.out.println("错误信息：" + e.getMessage());
            Assert.assertTrue(false);
        }
    }
    @Before
    public void before() throws IOException {
        String[] models = {
                "flow/user/model/sec_user.xml"
        };
        LogicFlowUtil.loadLogicModels(models);
        String[] flows = {
                "flow/user/user_insert.xml",
                "flow/user/user_select.xml",
                "flow/user/user_select_by_id.xml",
                "flow/user/user_select_by_name.xml",
                "flow/user/user_update.xml",
                "flow/user/user_disable_with_aggregate.xml"
        };
        LogicFlowUtil.loadLogicFlows(flows);
    }
    private JMap createUser() throws Exception {
        String user_id = String.valueOf(System.currentTimeMillis()).substring(7);
        JMap userParam = new JsonMap();
        userParam.put("user_id", user_id);
        userParam.put("nick_name", "嘉信立恒管理员");
        userParam.put("user_account", "superadmin");
        userParam.put("gender", "1");
        userParam.put("avatar_name", "head.png");
        userParam.put("email", "zhangsan@163.com");
        userParam.put("link_phone", "13788888888");
        userParam.put("password", "qwerasdf");
        userParam.put("admin_flag", 0);
        userParam.put("sec_level", "4");
        userParam.put("enabled_flag", "1");
        userParam.put("pwd_reset_time", 0);
        userParam.put("valid_date", "2022-1-10 15:22:27");
        userParam.put("expire_date", "2099-12-31 15:22:32");
        userParam.put("data_status", "1");
        userParam.put("create_date", new InitialMethod().getDatetime());
        userParam.put("done_date", new InitialMethod().getDatetime());
        userParam.put("create_op_id", user_id);
        userParam.put("op_id", user_id);
        return userParam;
    }
}