init 20220715 v1.6

.gitignore

@@ -0,0 +1,11 @@
+/target/
+# idea
+/.idea/
+*.iml
+/log
+# office临时文件
+~$*
+# wps临时文件
+.~*
+/ignored/
+.vscode/

acl提供给投诉分析的接口.md

@@ -0,0 +1,63 @@
+# acl提供给投诉分析的接口
+
+部署环境 133.96.94.176:12128
+192.168.70.125:12128
+本地环境 127.0.0.1:12128
+
+## 鉴权接口
+
+入参说明
+token 从top系统带来的token
+fromSystem 参数是从top系统带过来的 投诉预测应为 top
+system 固定为fenxi
+
+```http
+POST http://133.96.94.176:12128/api/verification
+Content-Type: application/json
+
+{
+  "token": "test_token_hebei1",
+  "fromSystem": "test",
+  "system": "fenxi"
+}
+```
+
+```json
+HTTP/1.1 200 
+Content-Type: application/json
+Transfer-Encoding: chunked
+Date: Fri, 15 Jul 2022 05:02:18 GMT
+Connection: close
+
+{
+  "success": true,
+  "code": 1,
+  "message": "成功",
+  "data": {
+    "id": 10,
+    "account": "test_hebei",
+    "name": "测试用户_全省",
+    "status": null,
+    "city": "河北省"
+  }
+}
+
+```
+
+```json
+HTTP/1.1 200 
+Content-Type: application/json
+Transfer-Encoding: chunked
+Date: Fri, 15 Jul 2022 05:02:42 GMT
+Connection: close
+
+{
+  "success": false,
+  "code": 0,
+  "message": "用户不存在",
+  "data": {
+    "redirect": "https://133.96.90.208/login"
+  }
+}
+
+```

acl提供给投诉大屏的接口.md

@@ -0,0 +1,44 @@
+# acl提供给投诉大屏的接口
+
+部署环境 133.96.94.176:12128
+本地环境 127.0.0.1:12128
+
+## 鉴权接口
+
+token  测试token test_token_*** 正式token来自入口url
+fromSystem 测试token为test 正式token是dop
+system 是固定值 daping
+
+###  system 由调用接口的系统确定
+
+```http
+POST http://133.96.94.176:12128/api/verification
+Content-Type: application/json
+
+{
+  "token": "test_token_hebei",
+  "fromSystem": "test",
+  "system": "daping"
+}
+```
+
+```json
+HTTP/1.1 200 
+Content-Type: application/json
+Transfer-Encoding: chunked
+Date: Fri, 15 Jul 2022 04:45:07 GMT
+Connection: close
+
+{
+  "success": true,
+  "code": 1,
+  "message": "成功",
+  "data": {
+    "userId": 10,
+    "userName": "测试用户_全省",
+    "province": "河北省",
+    "city": "河北省"
+  }
+}
+
+```

acl提供给投诉预测的接口.md

@@ -0,0 +1,61 @@
+# acl提供给投诉预测的接口
+
+部署环境 133.96.94.176:12128
+本地环境 127.0.0.1:12128
+
+## 鉴权接口
+
+入参说明
+token 从top系统带来的token
+fromSystem 参数是从top系统带过来的 投诉预测应为 top
+system 投诉预测固定为 yuce
+
+```http
+POST http://133.96.94.176:12128/api/verification
+Content-Type: application/json
+
+{
+"token": "test_token_hebei",
+"fromSystem": "test",
+"system": "yuce"
+}
+```
+
+```json
+HTTP/1.1 200 
+Content-Type: application/json
+Transfer-Encoding: chunked
+Date: Fri, 15 Jul 2022 04:59:47 GMT
+Connection: close
+
+{
+  "success": true,
+  "code": 1,
+  "message": "成功",
+  "data": {
+    "userId": 10,
+    "userName": "测试用户_全省",
+    "province": "河北省",
+    "city": -1
+  }
+}
+
+```
+
+```json
+HTTP/1.1 200 
+Content-Type: application/json
+Transfer-Encoding: chunked
+Date: Fri, 15 Jul 2022 04:49:26 GMT
+Connection: close
+
+{
+  "success": false,
+  "code": 0,
+  "message": "用户不存在",
+  "data": {
+    "redirect": "https://133.96.90.208/login"
+  }
+}
+
+```

acl提供给流程的接口.md

@@ -0,0 +1,295 @@
+# acl提供给流程的接口
+
+部署环境 133.96.94.176:12128
+本地环境 127.0.0.1:12128
+
+## 鉴权接口
+
+```http
+POST http://133.96.94.176:12128/api/verification
+Content-Type: application/json
+
+{
+  "token": "test_token_abc",
+  "fromSystem": "test",
+  "system": "liucheng"
+}
+```
+
+```json
+HTTP/1.1 200 
+Content-Type: application/json
+Transfer-Encoding: chunked
+Date: Fri, 15 Jul 2022 01:57:35 GMT
+Connection: close
+
+{
+  "success": true,
+  "code": 1,
+  "message": "成功",
+  "data": {
+    "account": "test_handan",
+    "userId": 21,
+    "userName": "测试用户_邯郸市"
+  }
+}
+```
+
+## 角色列表接口
+
+入参：
+callType  findRoleList
+userName  用户名，支持模糊搜索
+
+```http
+POST http://133.96.94.176:12128/rest/flow/api
+Content-Type: application/json
+
+{
+  "callType": "findRoleList",
+  "userName": "张"
+}
+```
+
+```json
+HTTP/1.1 200 
+Content-Type: application/json
+Transfer-Encoding: chunked
+Date: Fri, 15 Jul 2022 02:07:39 GMT
+Connection: close
+
+{
+  "success": true,
+  "code": 1,
+  "message": "成功",
+  "data": [
+    {
+      "roleId": 4,
+      "roleName": "分析组"
+    },
+    {
+      "roleId": 3,
+      "roleName": "管理"
+    }
+  ]
+}
+
+```
+
+## 用户列表接口
+
+入参：
+callType  findToPage
+
+```http
+POST http://133.96.94.176:12128/rest/flow/api
+Content-Type: application/json
+
+{
+  "callType": "findToPage"
+}
+```
+
+## 根据登录账号获取用户
+
+```http
+POST http://133.96.94.176:12128/rest/flow/api
+Content-Type: application/json
+
+{
+  "callType": "getByLoginId",
+  "loginId": "test_handan"
+}
+```
+
+```json
+HTTP/1.1 200 
+Content-Type: application/json
+Transfer-Encoding: chunked
+Date: Fri, 15 Jul 2022 03:39:35 GMT
+Connection: close
+
+{
+  "success": true,
+  "code": 1,
+  "message": "成功",
+  "data": {
+    "userId": 21,
+    "loginId": "test_handan",
+    "userName": "测试用户_邯郸市",
+    "mobile": "13231899751",
+    "email": null,
+    "org": {
+      "orgId": 130400,
+      "orgName": "邯郸市"
+    },
+    "district": null
+  }
+}
+
+```
+
+## 根据用户ID获取用户接口
+
+```http
+POST http://133.96.94.176:12128/rest/flow/api
+Content-Type: application/json
+
+{
+  "callType": "get",
+  "userId": "3"
+}
+```
+
+```json
+HTTP/1.1 200 
+Content-Type: application/json
+Transfer-Encoding: chunked
+Date: Fri, 15 Jul 2022 03:44:42 GMT
+Connection: close
+
+{
+  "success": true,
+  "code": 1,
+  "message": "成功",
+  "data": {
+    "userId": 3,
+    "loginId": "13111111111",
+    "userName": "张三",
+    "mobile": "13111111111",
+    "email": null,
+    "org": {
+      "orgId": 130100,
+      "orgName": "石家庄市"
+    },
+    "district": null
+  }
+}
+
+```
+
+## 根据角色id获取用户id列表
+
+```http
+POST http://133.96.94.176:12128/rest/flow/api
+Content-Type: application/json
+
+{
+  "callType": "findRoleIdByUserId",
+  "userId": "3"
+}
+```
+
+```json
+HTTP/1.1 200 
+Content-Type: application/json
+Transfer-Encoding: chunked
+Date: Fri, 15 Jul 2022 03:45:44 GMT
+Connection: close
+
+{
+  "success": true,
+  "code": 1,
+  "message": "成功",
+  "data": [
+    3,
+    4
+  ]
+}
+
+```
+
+## 根据角色id获取用户id列表
+
+```http
+POST http://133.96.94.176:12128/rest/flow/api
+Content-Type: application/json
+
+{
+  "callType": "findUserIdByRoleId",
+  "roleId": "3"
+}
+```
+
+## 多条件搜索用户
+
+入参说明：
+callType findAuthorizedUser
+roleId 可选 为空字符串与不传这个参数相同处理
+userName 可选 为空字符串与不传这个参数相同处理  可模糊查询
+loginId  可选 为空字符串与不传这个参数相同处理
+
+```http
+POST http://133.96.94.176:12128/rest/flow/api
+Content-Type: application/json
+
+{
+  "callType": "findAuthorizedUser",
+  "roleId": "3"
+}
+```
+
+```json
+HTTP/1.1 200 
+Content-Type: application/json
+Transfer-Encoding: chunked
+Date: Fri, 15 Jul 2022 04:02:33 GMT
+Connection: close
+
+{
+  "success": true,
+  "code": 1,
+  "message": "成功",
+  "data": [
+    {
+      "userId": 3,
+      "loginId": "13111111111",
+      "userName": "张三",
+      "mobile": "13111111111",
+      "email": null,
+      "org": {
+        "orgId": 130100,
+        "orgName": "石家庄市"
+      },
+      "district": null
+    },
+    {
+      "userId": 7,
+      "loginId": "13866666666",
+      "userName": "赵六宝",
+      "mobile": "13866666666",
+      "email": "6324124512@163.com",
+      "org": {
+        "orgId": -1,
+        "orgName": "河北省"
+      },
+      "district": null
+    },
+    {
+      "userId": 1,
+      "loginId": "flowSystem",
+      "userName": "系统用户",
+      "mobile": "",
+      "email": "",
+      "org": {
+        "orgId": -1,
+        "orgName": "河北省"
+      },
+      "district": null
+    },
+    {
+      "userId": 4,
+      "loginId": "test_abc",
+      "userName": "李四喜",
+      "mobile": "13444444444",
+      "email": "@163.com",
+      "org": {
+        "orgId": 130200,
+        "orgName": "唐山市"
+      },
+      "district": null
+    }
+  ]
+}
+
+```

other/192.168.70.125部署/http测试/20220513测试投诉流程各接口.http

@@ -0,0 +1,76 @@
+POST http://192.168.70.125:12128/rest/flow/api
+Content-Type: application/json
+
+{
+  "callType": "findRoleList",
+  "userName": "张"
+}
+
+###
+
+POST http://192.168.70.125:12128/rest/flow/api
+Content-Type: application/json
+
+{
+  "callType": "findToPage"
+}
+
+###
+
+POST http://192.168.70.125:12128/rest/flow/api
+Content-Type: application/json
+
+{
+  "callType": "getByLoginId",
+  "loginId": "13333333333"
+}
+
+###
+
+POST http://192.168.70.125:12128/rest/flow/api
+Content-Type: application/json
+
+{
+  "callType": "get",
+  "userId": "3"
+}
+
+###
+
+POST http://192.168.70.125:12128/rest/flow/api
+Content-Type: application/json
+
+{
+  "callType": "findRoleIdByUserId",
+  "userId": "3"
+}
+
+###
+
+POST http://192.168.70.125:12128/rest/flow/api
+Content-Type: application/json
+
+{
+  "callType": "findUserIdByRoleId",
+  "roleId": "3"
+}
+
+###
+
+POST http://192.168.70.125:12128/rest/flow/api
+Content-Type: application/json
+
+{
+  "callType": "findAuthorizedUser",
+  "roleId": "3"
+}
+
+###
+
+POST http://localhost:12128/rest/flow/api
+Content-Type: application/json
+
+{
+  "callType": "findAuthorizedUser",
+  "roleId": "3"
+}

other/192.168.70.125部署/http测试/20220513测试鉴权.http

@@ -0,0 +1,42 @@
+### 大屏鉴权
+POST http://192.168.70.125:12128/api/verification
+Content-Type: application/json
+
+{
+  "token": "abcdef",
+  "fromSystem": "dop",
+  "system": "daping"
+}
+
+### 预测
+
+POST http://192.168.70.125:12128/api/verification
+Content-Type: application/json
+
+{
+  "token": "abcdefeee",
+  "fromSystem": "top",
+  "system": "yuce"
+}
+
+### 工单流转
+
+POST http://192.168.70.125:12128/api/verification
+Content-Type: application/json
+
+{
+  "token": "abcdefeee",
+  "fromSystem": "top",
+  "system": "liucheng"
+}
+
+### 投诉分析
+
+POST http://133.96.94.176:12128/api/verification
+Content-Type: application/json
+
+{
+  "token": "test_token_handan",
+  "fromSystem": "test",
+  "system": "fenxi"
+}

other/192.168.70.125部署/http测试/20220516增删改查测试.http

@@ -0,0 +1,81 @@
+POST http://localhost:12128/rest/api/city/list
+Content-Type: application/json
+
+{}
+
+###
+POST http://localhost:12128/rest/api/role/list
+Content-Type: application/json
+
+{}
+
+###
+POST http://localhost:12128/rest/api/role/add
+Content-Type: application/json
+
+{
+  "roleName": "测试--请不要创建用户"
+}
+
+###
+POST http://localhost:12128/rest/api/role/delete/id/9
+Content-Type: application/json
+
+###
+POST http://localhost:12128/rest/api/role/select/id/9
+Content-Type: application/json
+
+###
+POST http://localhost:12128/rest/api/role/update/id/10
+Content-Type: application/json
+
+{
+  "roleName": "测试--请不要创建用户222"
+}
+
+###
+POST http://localhost:12128/rest/api/user/list
+Content-Type: application/json
+
+###
+POST http://localhost:12128/rest/api/user/add
+Content-Type: application/json
+
+{
+  "loginName":"13866666666",
+  "userName":"赵六",
+  "phone":"13866666666",
+  "email":"6324124512@163.com",
+  "province":"河北省",
+  "roleIdList":[
+    3,
+    5,
+    7
+  ],
+  "cityId":-1
+}
+
+###
+POST http://localhost:12128/rest/api/user/delete/id/6
+Content-Type: application/json
+
+###
+POST http://localhost:12128/rest/api/user/select/id/4
+Content-Type: application/json
+
+###
+POST http://localhost:12128/rest/api/user/update/id/7
+Content-Type: application/json
+
+{
+  "loginName":"13866666666",
+  "userName":"赵六宝",
+  "phone":"13866666666",
+  "email":"6324124512@163.com",
+  "province":"河北省",
+  "roleIdList":[
+    3,
+    5
+  ],
+  "cityId":-1
+}

other/192.168.70.125部署/http测试/20220516投诉流程接口修改测试.http

@@ -0,0 +1,24 @@
+POST http://localhost:12128/rest/flow/api
+Content-Type: application/json
+
+{
+  "callType": "findRoleList",
+  "userName": "张"
+}
+
+###
+POST http://localhost:12128/rest/flow/api
+Content-Type: application/json
+
+{
+"callType": "findRoleList",
+"userName": ""
+}
+
+###
+POST http://localhost:12128/rest/flow/api
+Content-Type: application/json
+
+{
+  "callType": "findRoleList"
+}

other/192.168.70.125部署/http测试/20220517测试端口调整.http

@@ -0,0 +1,8 @@
+### 本地测试
+POST http://192.168.70.125:12128/rest/flow/api
+Content-Type: application/json
+
+{
+  "callType": "get",
+  "userId": "3"
+}

other/192.168.70.125部署/http测试/20220524端口调整测试.http

@@ -0,0 +1,30 @@
+### token是两个固定值 fromSystem 是test
+###  system 由调用接口的系统确定
+POST http://192.168.70.125:12128/api/verification
+Content-Type: application/json
+
+{
+  "token": "test_token_123",
+  "fromSystem": "test",
+  "system": "daping"
+}
+
+### token是两个固定值 fromSystem 是test
+###  system 由调用接口的系统确定
+POST http://192.168.70.125:12128/api/verification
+Content-Type: application/json
+
+{
+  "token": "test_token_abc",
+  "fromSystem": "test",
+  "system": "liucheng"
+}
+
+###
+POST http://192.168.70.125:12128/rest/flow/api
+Content-Type: application/json
+
+{
+"callType": "get",
+"userId": "3"
+}

other/192.168.70.125部署/http测试/20220525与DOP对接测试.http

@@ -0,0 +1,28 @@
+### 通过dop验证token
+POST http://10.17.180.5:8089/prod-api/verifySystem
+Content-Type: application/json
+
+{
+  "token": "eyJhbGciOiJIUzUxMiJ9.eyJsb2dpbl91c2VyX2tleSI6IjMxYzFmMjM0LTkyYTctNGQ5Yi1iZjBkLWFhOWJlZjUxZjg2NyJ9.FySTTQXWMIKdGp9s9DMTKQjfe9-m0CsXPj-RS5cT4d7kXp_heGor3YHHy6Ru5qQmnOLpRAdFd1ud_Vq9s6Ed1Q",
+  "fromSystem":"dop"
+}
+
+###
+POST http://192.168.70.125:12128/api/verification
+Content-Type: application/json
+
+{
+  "token": "eyJhbGciOiJIUzUxMiJ9.eyJsb2dpbl91c2VyX2tleSI6IjMxYzFmMjM0LTkyYTctNGQ5Yi1iZjBkLWFhOWJlZjUxZjg2NyJ9.FySTTQXWMIKdGp9s9DMTKQjfe9-m0CsXPj-RS5cT4d7kXp_heGor3YHHy6Ru5qQmnOLpRAdFd1ud_Vq9s6Ed1Q",
+  "fromSystem": "dop",
+  "system": "daping"
+}
+
+###
+POST http://localhost:12128/api/verification
+Content-Type: application/json
+
+{
+  "token": "eyJhbGciOiJIUzUxMiJ9.eyJsb2dpbl91c2VyX2tleSI6IjMxYzFmMjM0LTkyYTctNGQ5Yi1iZjBkLWFhOWJlZjUxZjg2NyJ9.FySTTQXWMIKdGp9s9DMTKQjfe9-m0CsXPj-RS5cT4d7kXp_heGor3YHHy6Ru5qQmnOLpRAdFd1ud_Vq9s6Ed1Q",
+  "fromSystem": "dop",
+  "system": "daping"
+}

other/192.168.70.125部署/http测试/20220525端口调整测试.http

@@ -0,0 +1,20 @@
+
+###  system 由调用接口的系统确定
+POST http://192.168.70.125:12128/api/verification
+Content-Type: application/json
+
+{
+  "token": "这是一个不存在或者无效的token",
+  "fromSystem": "dop",
+  "system": "daping"
+}
+
+###
+POST http://192.168.70.125:12128/api/verification
+Content-Type: application/json
+
+{
+"token": "",
+"fromSystem": "",
+"system": "daping"
+}

other/192.168.70.125部署/http测试/20220606-cityusertest.http

@@ -0,0 +1,9 @@
+###  system 由调用接口的系统确定
+POST http://133.96.94.176:12128/api/verification
+Content-Type: application/json
+
+{
+  "token": "test_token_handan",
+  "fromSystem": "test",
+  "system": "liucheng"
+}

other/192.168.70.125部署/sql/sql_back.sql

@@ -0,0 +1,78 @@
+-- 建表语句
+create table sqmdb_rpt.acl_city
+(
+    city_id      serial not null
+        constraint city_pk
+            primary key,
+    city_name_zh varchar,
+    city_name_en varchar,
+    ord          integer
+);
+
+alter table sqmdb_rpt.acl_city
+    owner to sqmdb;
+
+create table sqmdb_rpt.acl_role
+(
+    role_id     serial not null
+        constraint role_pk
+            primary key,
+    role_name   varchar,
+    create_time date,
+    update_time date
+);
+
+alter table sqmdb_rpt.acl_role
+    owner to sqmdb;
+
+drop table sqmdb_rpt.acl_user;
+
+create table sqmdb_rpt.acl_user
+(
+    user_id    serial not null
+        constraint user_pk
+            primary key,
+    login_name  varchar,
+    user_name   varchar,
+    phone       varchar,
+    email       varchar,
+    province    varchar,
+    city        varchar,
+    county      varchar,
+    tsfx_per    integer,
+    tsys_per    integer,
+    tsdp_per    integer,
+    tsgdlz_per  integer,
+    ceate_time  date,
+    update_time date
+);
+
+alter table sqmdb_rpt.acl_user
+    owner to sqmdb;
+
+create table sqmdb_rpt.acl_user_role
+(
+    id          serial not null
+        constraint user_role_pk
+            primary key,
+    user_id     integer,
+    role_id     integer,
+    create_time date,
+    update_time date
+);
+
+alter table sqmdb_rpt.acl_user_role
+    owner to sqmdb;
+
+create table sqmdb_rpt.acl_org
+(
+    org_id      serial not null
+        constraint org_pk
+            primary key,
+    org_name    varchar,
+    create_time date,
+    update_time date
+);
+
+alter table sqmdb_rpt.acl_org
+    owner to sqmdb;

other/192.168.70.125部署/sql/sql_bak2.sql

@@ -0,0 +1 @@
+-- 测试数据

other/192.168.70.125部署/用户管理与其他系统对接端口样例.md

@@ -0,0 +1,561 @@
+# 端口规范
+
+## 部署信息
+
+当前版本： 1.0
+部署位置： 192.168.70.125 目录/data1/acl/aclTousu-1.0.jar
+启动用户： do  nohup java -jar aclTousu-1.0.jar &
+访问ip+端口号： http://192.168.70.125:12128
+数据库：192.168.70.109:5432/sqmmt 
+schema：sqmdb_rpt
+其中以acl开头的几个表就是
+
+## 20220524 v1.3 更新说明
+
+- 新增了两个测试token
+
+```http request
+POST http://192.168.70.125:12128/api/verification
+Content-Type: application/json
+
+{
+  "token": "test_token_abc",
+  "fromSystem": "test",
+  "system": "daping"
+}
+```
+
+```json
+{
+  "success": true,
+  "code": 1,
+  "message": "成功",
+  "data": {
+    "userId": 4,
+    "userName": "李四喜",
+    "province": "河北省",
+    "city": "唐山市"
+  }
+}
+```
+
+```http request
+### token是两个固定值 fromSystem 是test
+###  system 由调用接口的系统确定
+POST http://192.168.70.125:12128/api/verification
+Content-Type: application/json
+
+{
+  "token": "test_token_abc",
+  "fromSystem": "test",
+  "system": "liucheng"
+}
+```
+
+```json
+{
+  "success": true,
+  "code": 1,
+  "message": "成功",
+  "data": {
+    "account": "13444444444",
+    "userId": 4,
+    "userName": "李四喜"
+  }
+}
+```
+
+- 流程需求的get接口中orgId修改为org对象
+
+```http request
+POST http://192.168.70.125:12128/rest/flow/api
+Content-Type: application/json
+
+{
+"callType": "get",
+"userId": "3"
+}
+```
+
+```json
+{
+  "success": true,
+  "code": 1,
+  "message": "成功",
+  "data": {
+    "userId": 3,
+    "loginId": "13111111111",
+    "userName": "张三",
+    "mobile": "13111111111",
+    "email": null,
+    "org": {
+      "orgId": 130100,
+      "orgName": "石家庄市"
+    }
+  }
+}
+```
+
+## 鉴权接口
+
+- ***大屏鉴权***
+
+```http request
+### 入参说明
+### token 从dop系统带来的token
+### fromSystem 参数是从dop系统带过来的 大屏应为dop
+### system 大屏固定为 daping
+POST http://192.168.70.125:12128/api/verification
+Content-Type: application/json
+
+{
+"token": "abcdef",
+"fromSystem": "dop",
+"system": "daping"
+}
+```
+
+正常返回值
+
+```json
+{
+  "success": true,
+  "code": 1,
+  "message": "成功",
+  "data": {
+    "userId": 3,
+    "userName": "张三",
+    "province": "河北省",
+    "city": "石家庄市"
+  }
+}
+```
+
+- ***投诉预测鉴权***
+
+```http request
+### 入参说明
+### token 从top系统带来的token
+### fromSystem 参数是从top系统带过来的 投诉预测应为 top
+### system 投诉预测固定为 yuce
+
+POST http://192.168.70.125:12128/api/verification
+Content-Type: application/json
+
+{
+"token": "abcdefeee",
+"fromSystem": "top",
+"system": "yuce"
+}
+```
+
+正常返回值
+
+```json
+{
+  "success": true,
+  "code": 1,
+  "message": "成功",
+  "data": {
+    "userId": 3,
+    "userName": "张三",
+    "province": "河北省",
+    "city": "石家庄市"
+  }
+}
+```
+
+***投诉工单流转系统鉴权***
+
+```http request
+### 入参说明
+### token 从top系统带来的token
+### fromSystem 参数是从top系统带过来的 工单流转应为 top
+### system 工单流转固定为 liucheng
+POST http://192.168.70.125:12128/api/verification
+Content-Type: application/json
+
+{
+  "token": "abcdefeee",
+  "fromSystem": "top",
+  "system": "liucheng"
+}
+```
+
+正常返回值
+
+```json
+{
+  "success": true,
+  "code": 1,
+  "message": "成功",
+  "data": {
+    "account": "13111111111",
+    "userId": 3,
+    "userName": "张三"
+  }
+}
+```
+
+***投诉分析系统鉴权***
+
+```http request
+### 入参说明
+### token 从top系统带来的token
+### fromSystem 参数是从top系统带过来的 工单流转应为 top
+### system 投诉分析固定为 fenxi
+POST http://192.168.70.125:12128/api/verification
+Content-Type: application/json
+
+{
+  "token": "abcdefeee",
+  "fromSystem": "top",
+  "system": "fenxi"
+}
+```
+
+正常返回值
+
+````json
+{
+  "success": true,
+  "code": 1,
+  "message": "成功",
+  "data": {
+    "id": 3,
+    "account": "13111111111",
+    "name": "张三",
+    "status": 1,
+    "city": 130100
+  }
+}
+````
+
+## 投诉流程用的其他接口
+
+- ***角色列表接口***
+
+```http request
+### 入参：
+### callType  findRoleList
+### userName  用户名，支持模糊搜索
+POST http://192.168.70.125:12128/rest/flow/api
+Content-Type: application/json
+
+{
+  "callType": "findRoleList",
+  "userName": "张"
+}
+```
+
+正常返回值
+
+```json
+{
+  "success": true,
+  "code": 1,
+  "message": "成功",
+  "data": [
+    {
+      "roleId": 3,
+      "roleName": "管理"
+    },
+    {
+      "roleId": 4,
+      "roleName": "分析组"
+    }
+  ]
+}
+```
+
+- ***用户列表接口***
+
+```http
+### 入参：
+### callType  findToPage
+POST http://133.96.94.176:12128/rest/flow/api
+Content-Type: application/json
+
+{
+  "callType": "findToPage"
+}
+```
+
+正常返回值
+
+```json
+{
+  "success": true,
+  "code": 1,
+  "message": "成功",
+  "data": [
+    {
+      "userId": 1,
+      "loginId": "13222222222",
+      "userName": "张三丰",
+      "mobile": "13222222222",
+      "email": "3453543543",
+      "orgId": "130100"
+    },
+    {
+      "userId": 3,
+      "loginId": "13111111111",
+      "userName": "张三",
+      "mobile": "13111111111",
+      "email": null,
+      "orgId": "130100"
+    },
+    {
+      "userId": 4,
+      "loginId": "13444444444",
+      "userName": "李四喜",
+      "mobile": "13444444444",
+      "email": "@163.com",
+      "orgId": "130200"
+    },
+    {
+      "userId": 2,
+      "loginId": "13333333333",
+      "userName": "李小明",
+      "mobile": "13333333333",
+      "email": null,
+      "orgId": "130100"
+    }
+  ]
+}
+```
+
+- ***根据登录账号获取用户***
+
+```http request
+POST http://192.168.70.125:12128/rest/flow/api
+Content-Type: application/json
+
+{
+  "callType": "getByLoginId",
+  "loginId": "13333333333"
+}
+```
+
+正常返回值
+
+```json
+{
+  "success": true,
+  "code": 1,
+  "message": "成功",
+  "data": {
+    "userId": 2,
+    "loginId": "13333333333",
+    "userName": "李小明",
+    "mobile": "13333333333",
+    "email": null,
+    "orgId": "130100"
+  }
+}
+```
+
+- ***根据用户ID获取用户接口***
+
+```http request
+POST http://192.168.70.125:12128/rest/flow/api
+Content-Type: application/json
+
+{
+  "callType": "get",
+  "userId": "3"
+}
+```
+
+正常返回值
+
+```json
+{
+  "success": true,
+  "code": 1,
+  "message": "成功",
+  "data": {
+    "userId": 3,
+    "loginId": "13111111111",
+    "userName": "张三",
+    "mobile": "13111111111",
+    "email": null,
+    "orgId": "130100"
+  }
+}
+```
+
+- ***根据角色id获取用户***
+
+```http request
+POST http://192.168.70.125:12128/rest/flow/api
+Content-Type: application/json
+
+{
+  "callType": "findRoleIdByUserId",
+  "userId": "3"
+}
+```
+
+正常返回值
+
+```json
+{
+  "success": true,
+  "code": 1,
+  "message": "成功",
+  "data": [
+    4,
+    3
+  ]
+}
+```
+
+- ***根据角色id获取用户***
+
+```http request
+POST http://192.168.70.125:12128/rest/flow/api
+Content-Type: application/json
+
+{
+  "callType": "findUserIdByRoleId",
+  "roleId": "3"
+}
+```
+
+正常返回值
+
+```json
+{
+  "success": true,
+  "code": 1,
+  "message": "成功",
+  "data": [
+    1,
+    3,
+    4
+  ]
+}
+```
+
+- ***多条件搜索用户***
+
+```http request
+### 入参说明：
+### callType findAuthorizedUser
+### roleId 可选 为空字符串与不传这个参数相同处理
+### userName 可选 为空字符串与不传这个参数相同处理  可模糊查询
+### loginId  可选 为空字符串与不传这个参数相同处理
+POST http://192.168.70.125:12128/rest/flow/api
+Content-Type: application/json
+
+{
+  "callType": "findAuthorizedUser",
+  "roleId": "3",
+  "userName": "张",
+  "loginId": "13222222222"
+}
+```
+
+正常返回值
+
+```json
+{
+  "success": true,
+  "code": 1,
+  "message": "成功",
+  "data": [
+    {
+      "userId": 1,
+      "loginId": "13222222222",
+      "userName": "张三丰",
+      "mobile": "13222222222",
+      "email": "3453543543",
+      "orgId": "130100"
+    }
+  ]
+}
+```
+
+```http request
+POST http://192.168.70.125:12128/rest/flow/api
+Content-Type: application/json
+
+{
+  "callType": "findAuthorizedUser",
+  "roleId": "3"
+}
+```
+
+返回值
+
+```json
+{
+  "success": true,
+  "code": 1,
+  "message": "成功",
+  "data": [
+    {
+      "userId": 1,
+      "loginId": "13222222222",
+      "userName": "张三丰",
+      "mobile": "13222222222",
+      "email": "3453543543",
+      "orgId": "130100"
+    },
+    {
+      "userId": 3,
+      "loginId": "13111111111",
+      "userName": "张三",
+      "mobile": "13111111111",
+      "email": null,
+      "orgId": "130100"
+    },
+    {
+      "userId": 4,
+      "loginId": "13444444444",
+      "userName": "李四喜",
+      "mobile": "13444444444",
+      "email": "@163.com",
+      "orgId": "130200"
+    }
+  ]
+}
+```
+
+```http request
+POST http://192.168.70.125:12128/rest/flow/api
+Content-Type: application/json
+
+{
+  "callType": "findAuthorizedUser",
+  "roleId": "3",
+  "userName": "张"
+}
+```
+
+```json
+{
+  "success": true,
+  "code": 1,
+  "message": "成功",
+  "data": [
+    {
+      "userId": 1,
+      "loginId": "13222222222",
+      "userName": "张三丰",
+      "mobile": "13222222222",
+      "email": "3453543543",
+      "orgId": "130100"
+    },
+    {
+      "userId": 3,
+      "loginId": "13111111111",
+      "userName": "张三",
+      "mobile": "13111111111",
+      "email": null,
+      "orgId": "130100"
+    }
+  ]
+}
+```

other/开发阶段/http/acl/T3.http

@@ -0,0 +1,17 @@
+### T3查找不存在用户
+POST http://localhost:8080/rest/t3/api
+Content-Type: application/json
+
+{
+  "loginId": "admin"
+}
+
+### T3查找正常用户
+POST http://localhost:8080/rest/t3/api
+Content-Type: application/json
+
+{
+  "loginId": "admin123"
+}
+
+###

other/开发阶段/http/acl/city.http

@@ -0,0 +1,4 @@
+### T3查找不存在用户
+POST http://localhost:8080/rest/api/city/list
+Content-Type: application/json
+

other/开发阶段/http/acl/flow.http

@@ -0,0 +1,79 @@
+### Flow角色列表接口
+POST http://localhost:8080/rest/flow/api
+Content-Type: application/json
+
+{
+  "userName": "张三",
+  "callType": "findRoleList"
+}
+
+### Flow用户列表接口
+POST http://localhost:8080/rest/flow/api
+Content-Type: application/json
+
+{
+  "callType": "findToPage"
+}
+
+### Flow根据登录帐号获取用户接口
+POST http://localhost:8080/rest/flow/api
+Content-Type: application/json
+
+{
+  "loginId": "admin123",
+  "callType": "getByLoginId"
+}
+
+### Flow根据用户ID获取用户接口
+POST http://localhost:8080/rest/flow/api
+Content-Type: application/json
+
+{
+  "userId": "4",
+  "callType": "get"
+}
+
+### Flow根据用户ID获取角色接口
+POST http://localhost:8080/rest/flow/api
+Content-Type: application/json
+
+{
+  "userId": 4,
+  "callType": "findRoleIdByUserId"
+}
+
+### Flow查找不存在用户
+POST http://localhost:8080/rest/flow/api
+Content-Type: application/json
+
+{
+  "roleId": 1,
+  "callType": "findUserIdByRoleId"
+}
+
+### Flow多条件搜索用户接口 -1
+POST http://localhost:8080/rest/flow/api
+Content-Type: application/json
+
+{
+  "loginId": "admin123",
+  "callType": "findAuthorizedUser"
+}
+
+### Flow多条件搜索用户接口 -2
+POST http://localhost:8080/rest/flow/api
+Content-Type: application/json
+
+{
+  "roleId": 1,
+  "callType": "findAuthorizedUser"
+}
+
+### Flow多条件搜索用户接口 -3
+POST http://localhost:8080/rest/flow/api
+Content-Type: application/json
+
+{
+  "userName": "张三",
+  "callType": "findAuthorizedUser"
+}

other/开发阶段/http/acl/user.http

@@ -0,0 +1,29 @@
+### 查询全部用户
+POST http://localhost:8080/rest/api/userEntity/list
+Content-Type: application/json
+
+### 添加用户-1
+POST http://localhost:8080/rest/api/userEntity/add
+Content-Type: application/json
+
+{
+  "username": "李四",
+  "mobile": "13111112222",
+  "email": "lisi@123.com",
+  "cityId": "130100",
+  "status": 1,
+  "loginId": "lisizhanghao"
+}
+
+### 添加用户-2
+POST http://localhost:8080/rest/api/userEntity/add
+Content-Type: application/json
+
+{
+  "username": "王五",
+  "mobile": "13111112222",
+  "email": "lisi@123.com",
+  "cityId": "130100",
+  "status": 1,
+  "loginId": "wangwuzhanghao"
+}

other/开发阶段/http/portal.http

@@ -0,0 +1,9 @@
+### 这是portal提供给工作流的接口,现在现场的portal是没有的
+POST http://10.107.42.90:12000/portal/rest/flow/api
+Content-Type: application/json
+
+{
+  "callType": "findRoleList"
+}
+
+###

other/开发阶段/sql/login_public_city.sql

@@ -0,0 +1,3 @@
+INSERT INTO public.city (city_id, city_name_zh, city_name_en, ord) VALUES (1, '大萨达撒', '的双方各', 1);
+INSERT INTO public.city (city_id, city_name_zh, city_name_en, ord) VALUES (2, '哈哈哈哈', '略略', 2);
+INSERT INTO public.city (city_id, city_name_zh, city_name_en, ord) VALUES (3, '啦啦啦啦', '打完带我多', 3);

other/开发阶段/sql/login_public_department.sql

@@ -0,0 +1 @@
+INSERT INTO public. (org_id, org_name, create_time, update_time) VALUES ('1', '红红孩儿', '2022-05-12', '2022-05-12');

other/开发阶段/sql/login_public_role.sql

@@ -0,0 +1,2 @@
+INSERT INTO public.role (role_id, role_name, create_time, update_time) VALUES (1, '哈哈', null, null);
+INSERT INTO public.role (role_id, role_name, create_time, update_time) VALUES (2, '略略路', null, null);

other/开发阶段/sql/login_public_table2_user.sql

@@ -0,0 +1,4 @@
+INSERT INTO public.acl_user (user_id, login_name, user_name, phone, email, province, city, county, tsfx_per, tsys_per, tsdp_per, tsgdlz_per, ceate_time, update_time) VALUES (1, '哈哈', '略略', '15341056254', '3453543543', '1', '2', '3', null, null, null, null, null, null);
+INSERT INTO public.table2_user (user_id, login_name, user_name, phone, email, province, city, county, tsfx_per, tsys_per, tsdp_per, tsgdlz_per, ceate_time, update_time) VALUES (2, '嘿额嘿嘿', null, null, null, null, null, null, null, null, null, null, null, null);
+INSERT INTO public.table2_user (user_id, login_name, user_name, phone, email, province, city, county, tsfx_per, tsys_per, tsdp_per, tsgdlz_per, ceate_time, update_time) VALUES (3, '哇哈哈哈', null, null, null, null, null, null, null, null, null, null, null, null);
+INSERT INTO public.table2_user (user_id, login_name, user_name, phone, email, province, city, county, tsfx_per, tsys_per, tsdp_per, tsgdlz_per, ceate_time, update_time) VALUES (4, '2222', '小明', '15324104774', '@163.com', null, '1', null, null, null, null, null, null, '2022-05-12');

other/开发阶段/sql/login_public_table_user.sql

@@ -0,0 +1,2 @@
+INSERT INTO public.table_user (user_id, login_id, user_name, mobile, email, city_id, status, remark, create_time, update_time) VALUES (1, '11111', null, '15324104774', '@163.com', 1, 1, '谷铜锏', '2022-05-11', '2022-05-11');
+INSERT INTO public.table_user (user_id, login_id, user_name, mobile, email, city_id, status, remark, create_time, update_time) VALUES (2, '2222', null, '15324104774', '@163.com', 1, 1, '谷铜锏', '2022-05-11', '2022-05-11');

other/开发阶段/sql/login_public_user_role.sql

@@ -0,0 +1,2 @@
+INSERT INTO public.user_role (id, user_id, role_id, create_time, update_time) VALUES (1, 1, 1, null, null);
+INSERT INTO public.user_role (id, user_id, role_id, create_time, update_time) VALUES (2, 2, 2, null, null);

other/开发阶段/sql/sql.sql

@@ -0,0 +1,126 @@
+create table city
+(
+    city_id      serial not null
+        constraint city_pk
+            primary key,
+    city_name_zh varchar,
+    city_name_en varchar,
+    ord          integer
+);
+
+alter table city
+    owner to postgres;
+
+
+create table role
+(
+    role_id     serial not null
+        constraint role_pk
+            primary key,
+    role_name   varchar,
+    create_time date,
+    update_time date
+);
+
+alter table role
+    owner to postgres;
+
+create table table_user
+(
+    user_id     serial not null
+        constraint user_pk
+            primary key,
+    login_id    varchar,
+    user_name   varchar,
+    mobile      varchar,
+    email       varchar,
+    city_id     integer,
+    status      integer,
+    remark      varchar,
+    create_time date,
+    update_time date
+);
+
+alter table table_user
+    owner to postgres;
+
+create table user_role
+(
+    id          serial not null
+        constraint user_role_pk
+            primary key,
+    user_id     integer,
+    role_id     integer,
+    create_time date,
+    update_time date
+);
+
+alter table user_role
+    owner to postgres;
+
+create table table2_user
+(
+    login_id    serial not null
+        constraint table2_user_pk
+            primary key,
+    login_name  varchar,
+    user_name   varchar,
+    phone       varchar,
+    email       varchar,
+    province    varchar,
+    city        varchar,
+    county      varchar,
+    tsfx_per    integer,
+    tsys_per    integer,
+    tsdp_per    integer,
+    tsgdlz_per  integer,
+    ceate_time  date,
+    update_time date
+);
+
+comment on column table2_user.login_id is '主键自增';
+
+comment on column table2_user.login_name is '登录用户名';
+
+comment on column table2_user.user_name is '用户姓名';
+
+comment on column table2_user.phone is '手机号码';
+
+comment on column table2_user.email is '邮箱';
+
+comment on column table2_user.province is '归属省份';
+
+comment on column table2_user.city is '归属地市';
+
+comment on column table2_user.county is '归属区县';
+
+comment on column table2_user.tsfx_per is ' 投诉工单分析权限   0,1,2 	0无权限	1地市级	2省级
+';
+
+comment on column table2_user.tsys_per is '投诉预测权限     0,1,2	0无权限	1地市级	2省级
+';
+
+comment on column table2_user.tsdp_per is '是否具备投诉大屏权限   0,1,2	0无权限	1地市级	2省级
+';
+
+comment on column table2_user.tsgdlz_per is '是否投诉工单流转流程权限   0,1	0否	1有	
+';
+
+comment on column table2_user.ceate_time is '用户创建时间';
+
+comment on column table2_user.update_time is '用户修改时间';
+
+alter table table2_user
+    owner to postgres;
+
+create table role_middle
+(
+    role_middle_id serial not null
+        constraint role_middle_pk
+            primary key,
+    user_id        integer,
+    role_id        integer
+);
+
+alter table role_middle
+    owner to postgres;

pom.xml

@@ -0,0 +1,65 @@
+<?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">
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>com.nokia</groupId>
+    <artifactId>acl_tousu</artifactId>
+    <version>1.6</version>
+
+    <parent>
+        <artifactId>spring-boot-starter-parent</artifactId>
+        <groupId>org.springframework.boot</groupId>
+        <version>2.6.7</version>
+        <relativePath />
+    </parent>
+
+    <properties>
+        <skipTests>true</skipTests>
+        <maven.compiler.source>8</maven.compiler.source>
+        <maven.compiler.target>8</maven.compiler.target>
+    </properties>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-redis</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>fastjson</artifactId>
+            <version>1.2.76</version>
+        </dependency>
+        <dependency>
+            <groupId>com.baomidou</groupId>
+            <artifactId>mybatis-plus-boot-starter</artifactId>
+            <version>3.4.2</version>
+        </dependency>
+        <dependency>
+            <groupId>org.postgresql</groupId>
+            <artifactId>postgresql</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <scope>provided</scope>
+        </dependency>
+    </dependencies>
+    <build>
+        <finalName>aclTousu</finalName>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+            </plugin>
+        </plugins>
+    </build>
+</project>

readme.md

@@ -0,0 +1,70 @@
+# 用户管理
+
+[acl提供给流程的接口](acl%E6%8F%90%E4%BE%9B%E7%BB%99%E6%B5%81%E7%A8%8B%E7%9A%84%E6%8E%A5%E5%8F%A3.md)
+
+[acl提供给投诉大屏的接口](acl%E6%8F%90%E4%BE%9B%E7%BB%99%E6%8A%95%E8%AF%89%E5%A4%A7%E5%B1%8F%E7%9A%84%E6%8E%A5%E5%8F%A3.md)
+
+[acl提供给投诉分析的接口]()
+
+[acl提供给投诉预测的接口]()
+
+## 20220715 更新了acl提供给流程的接口 v1.6
+
+## 项目部署信息
+
+192.168.70.125 12128端口
+/data1/acl 目录
+
+## 20220525 v1.4修改记录
+
+1. 调整验证异常接口,token为失效token时返回登陆地址
+
+```http request
+###  system 由调用接口的系统确定
+POST http://192.168.70.125:12128/api/verification
+Content-Type: application/json
+
+{
+  "token": "这是一个不存在或者无效的token",
+  "fromSystem": "dop",
+  "system": "daping"
+}
+```
+
+```json
+{
+  "success": false,
+  "code": 0,
+  "message": "用户不存在",
+  "data": {
+    "redirect": "http://133.96.90.210:8089/login"
+  }
+}
+```
+
+2. 应对token和fromSystem均为空的情况
+
+```http request
+###  system 由调用接口的系统确定
+POST http://192.168.70.125:12128/api/verification
+Content-Type: application/json
+
+{
+  "token": "",
+  "fromSystem": "",
+  "system": "daping"
+}
+```
+
+```json
+{
+  "success": false,
+  "code": 0,
+  "message": "用户不存在",
+  "data": {
+    "redirect": "http://133.96.90.210:8089/login"
+  }
+}
+```
+
+## 1.0版本 20220513上线

src/main/java/com/nokia/AclApplication.java

@@ -0,0 +1,12 @@
+package com.nokia;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+/*@MapperScan("com.nokia.dao")*/
+public class AclApplication {
+    public static void main(String[] args) {
+        SpringApplication.run(AclApplication.class, args);
+    }
+}

src/main/java/com/nokia/common/R.java

@@ -0,0 +1,67 @@
+package com.nokia.common;
+
+import lombok.Data;
+
+/**
+ * 返回值的统一包装
+ */
+@Data
+public class R {
+    private Boolean success;
+    private Integer code;
+    private String message;
+
+    private Object data = null;
+
+    /**
+     * 私有化构造方法,不允许在外部实例化
+     */
+    private R() {
+    }
+
+    /**
+     * 成功的静态方法
+     *
+     * @return R实例
+     */
+    public static R ok() {
+        R r = new R();
+        r.setSuccess(true);
+        r.setCode(1);
+        r.setMessage("成功");
+        return r;
+    }
+
+    /**
+     * 失败的静态方法
+     *
+     * @return R实例
+     */
+    public static R error() {
+        R r = new R();
+        r.setSuccess(false);
+        r.setCode(0);
+        r.setMessage("失败");
+        return r;
+    }
+    public R success(Boolean success) {
+        this.setSuccess(success);
+        return this;
+    }
+
+
+    public R code(Integer code) {
+        this.setCode(code);
+        return this;
+    }
+
+    public R data(Object object) {
+        this.setData(object);
+        return this;
+    }
+
+    public R message(String message) {
+        this.setMessage(message);
+        return this;
+    }
+}

src/main/java/com/nokia/config/BeanConfig.java

@@ -0,0 +1,14 @@
+package com.nokia.config;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.SerializationFeature;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class BeanConfig {
+    @Bean
+    public ObjectMapper objectMapper(){
+        return new ObjectMapper().disable(SerializationFeature.FAIL_ON_EMPTY_BEANS);
+    }
+}

src/main/java/com/nokia/config/FillMetaObjectHandler.java

@@ -0,0 +1,31 @@
+package com.nokia.config;
+
+import com.baomidou.mybatisplus.core.handlers.MetaObjectHandler;
+import org.apache.ibatis.reflection.MetaObject;
+import org.springframework.stereotype.Component;
+
+import java.util.Date;
+
+/**
+ * myBatisPlus的自动填充功能实现
+ *
+ * @TableField(fill = FieldFill.INSERT)
+ * private Date createTime;
+ * @TableField(fill = FieldFill.INSERT_UPDATE)
+ * private Date updateTime;
+ */
+
+@Component
+public class FillMetaObjectHandler implements MetaObjectHandler {
+    @Override
+    public void insertFill(MetaObject metaObject) {
+        Date now = new Date();
+        this.fillStrategy(metaObject, "createTime", now);
+        this.fillStrategy(metaObject, "updateTime", now);
+    }
+
+    @Override
+    public void updateFill(MetaObject metaObject) {
+        this.fillStrategy(metaObject, "updateTime", new Date());
+    }
+}

src/main/java/com/nokia/config/RedisConfig.java

@@ -0,0 +1,17 @@
+package com.nokia.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.core.RedisTemplate;
+
+@Configuration
+public class RedisConfig {
+
+    @Bean
+    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
+        RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
+        redisTemplate.setConnectionFactory(redisConnectionFactory);
+        return redisTemplate;
+    }
+}

src/main/java/com/nokia/controller/CityController.java

@@ -0,0 +1,29 @@
+package com.nokia.controller;
+import com.nokia.common.R;
+import com.nokia.pojo.CityEntity;
+import com.nokia.service.CityI.CityServiceImpl;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.ResponseBody;
+import org.springframework.web.bind.annotation.RestController;
+import java.util.List;
+
+@RestController
+@RequestMapping("rest/api/city")
+public class CityController {
+
+    private final CityServiceImpl cityServiceimpl;
+
+    @Autowired
+    public CityController(CityServiceImpl cityServiceimpl) {
+        this.cityServiceimpl = cityServiceimpl;
+    }
+
+    @PostMapping("list")
+    @ResponseBody
+    public R list() {
+        List<CityEntity> cities = cityServiceimpl.list();
+        return R.ok().data(cities);
+    }
+}

src/main/java/com/nokia/controller/FlowApiController.java

@@ -0,0 +1,131 @@
+package com.nokia.controller;
+
+import com.alibaba.fastjson.JSONObject;
+import com.nokia.common.R;
+import com.nokia.service.Flow.FlowServiceImpl;
+import com.nokia.vo.FlowRoleVo;
+import com.nokia.vo.FlowUserVo;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+/**
+ * 提供给工作流的api
+ */
+@RestController
+@RequestMapping("rest")
+public class FlowApiController {
+
+    private final FlowServiceImpl flowServiceImpl;
+
+    @Autowired
+    public FlowApiController(FlowServiceImpl flowServiceImpl) {
+        this.flowServiceImpl = flowServiceImpl;
+    }
+
+    @PostMapping("flow/api")
+    @ResponseBody
+    public R flowApi(@RequestBody JSONObject jsonObject) {
+        String callType = jsonObject.getString("callType");
+        if (callType == null) {
+            return R.error().message("输入必须包含callType");
+        }
+        switch (callType) {
+            case "findRoleList":
+                return findRoleList(jsonObject);
+            case "findToPage":
+                return findToPage();
+            case "getByLoginId":
+                return getByLoginId(jsonObject);
+            case "get":
+                return get(jsonObject);
+            case "findRoleIdByUserId":
+                return findRoleIdByUserId(jsonObject);
+            case "findUserIdByRoleId":
+                return findUserIdByRoleId(jsonObject);
+            case "findAuthorizedUser":
+                return findAuthorizedUser(jsonObject);
+            default:
+                return R.error().message("callType类型错误");
+        }
+    }
+
+    public R findRoleList(JSONObject jsonObject) {
+        String username = jsonObject.getString("userName");
+        if (username == null || username.equals("")) {
+            return R.ok().data(flowServiceImpl.findRoleList());
+        }
+        List<FlowRoleVo> roleList = flowServiceImpl.findRoleList(username);
+        return R.ok().data(roleList);
+    }
+
+    public R findToPage() {
+        return R.ok().data(flowServiceImpl.findToPage());
+    }
+
+    public R getByLoginId(JSONObject jsonObject) {
+        String loginId = jsonObject.getString("loginId");
+        if (loginId == null || loginId.equals("")) {
+            return R.error().message("输入必须包含loginId");
+        }
+        FlowUserVo flowUserVo = flowServiceImpl.getByLoginId(loginId);
+        return R.ok().data(flowUserVo);
+    }
+
+    public R get(JSONObject jsonObject) {
+        Integer userId = null;
+        try {
+            userId = jsonObject.getInteger("userId");
+        } catch (NumberFormatException e) {
+            return R.error().message("输入的userId必须为整数格式");
+        }
+        if (userId == null) {
+            return R.error().message("输入必须包含userId");
+        }
+        FlowUserVo flowUserVo = flowServiceImpl.getByUserId(userId);
+        return R.ok().data(flowUserVo);
+    }
+
+    public R findRoleIdByUserId(JSONObject jsonObject) {
+        Integer userId = null;
+        try {
+            userId = jsonObject.getInteger("userId");
+        } catch (NumberFormatException e) {
+            return R.error().message("输入的userId必须为整数格式");
+        }
+        if (userId == null) {
+            return R.error().message("输入必须包含userId");
+        }
+        List<Integer> roleIdList = flowServiceImpl.findRoleIdByUserId(userId);
+        return R.ok().data(roleIdList);
+    }
+
+    public R findUserIdByRoleId(JSONObject jsonObject) {
+        Integer roleId = null;
+        try {
+            roleId = jsonObject.getInteger("roleId");
+        } catch (NumberFormatException e) {
+            return R.error().message("输入的roleId必须为整数格式");
+        }
+        if (roleId == null) {
+            return R.error().message("输入必须包含roleId");
+        }
+        List<Integer> userIdList = flowServiceImpl.findUserIdByRoleId(roleId);
+        return R.ok().data(userIdList);
+    }
+
+    public R findAuthorizedUser(JSONObject jsonObject) {
+        String loginId = jsonObject.getString("loginId");
+        loginId = loginId == null || loginId.equals("") ? null : loginId.trim();
+        Integer roleId = null;
+        try {
+            roleId = jsonObject.getInteger("roleId");
+        } catch (NumberFormatException ignored) {
+        }
+        String userName = jsonObject.getString("userName");
+        userName = userName == null || userName.equals("") ? null : userName.trim();
+        List<FlowUserVo> flowUserVos = flowServiceImpl.findAuthorizedUser(loginId, roleId, userName);
+        return R.ok().data(flowUserVos);
+    }
+}

src/main/java/com/nokia/controller/RoleController.java

@@ -0,0 +1,81 @@
+package com.nokia.controller;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.nokia.common.R;
+import com.nokia.dao.RoleDao;
+import com.nokia.pojo.RoleEntity;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+@RequestMapping("rest/api/role")
+@RestController
+public class RoleController {
+
+    public final RoleDao roleDao;
+
+    @Autowired
+    public RoleController(RoleDao roleDao){
+        this.roleDao=roleDao;
+    }
+
+    @PostMapping("/list")
+    public R list() {
+        return R.ok().data(roleDao.selectList(null));
+    }
+
+    @PostMapping("/add")
+    public R RoleAdd(@RequestBody RoleEntity roleEntity){
+        if (roleEntity==null){
+            return R.error().message("空");
+        }
+        QueryWrapper<RoleEntity> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("role_name",roleEntity.getRoleName());
+        RoleEntity roleEntity1 = roleDao.selectOne(queryWrapper);
+        if (roleEntity1!=null){
+            return R.error().message("角色已经存在");
+        }
+        int insert = roleDao.insert(roleEntity);
+        if (insert>0){
+            return R.ok().message("添加成功");
+        }else {
+            return R.error().message("添加失败");
+        }
+    }
+
+    @PostMapping("/delete/id/{roleId}")
+    public R RoleDelete(@PathVariable Integer roleId){
+        if (roleId==null){
+            return R.error().message("roleId 为空");
+        }
+        int ResurnRole = roleDao.deleteById(roleId);
+        if (ResurnRole>0){
+            return R.ok().message("删除成功");
+        }else {
+            return R.error().message("删除失败");
+        }
+    }
+
+    @PostMapping("/update/id/{roleId}")
+    public R RoleUpdate(@PathVariable Integer roleId, @RequestBody RoleEntity roleEntity){
+        if (roleEntity==null){
+            return R.error().message("roleEntity 为空");
+        }
+        RoleEntity roleEntity1 = roleDao.selectById(roleId);
+        roleEntity1.setRoleName(roleEntity.getRoleName());
+        int i = roleDao.updateById(roleEntity1);
+        if (i>0){
+            return R.ok().message("修改成功");
+        }else {
+            return R.ok().message("修改失败");
+        }
+    }
+
+    @PostMapping("/select/id/{roleId}")
+    public R RoleSelect(@PathVariable Integer roleId){
+        if (roleId==null){
+            return R.error().message("roleId 为空");
+        }
+        RoleEntity roleEntity = roleDao.selectById(roleId);
+        return  roleEntity==null ? R.error().message("role不存在") :R.ok().data(roleEntity);
+    }
+}

src/main/java/com/nokia/controller/UserController.java

@@ -0,0 +1,75 @@
+package com.nokia.controller;
+
+import com.nokia.common.R;
+import com.nokia.pojo.UserEntity;
+import com.nokia.service.user.UserServiceImpl;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+import java.util.Map;
+
+@RestController
+@RequestMapping("rest/api/user")
+public class UserController {
+    private final UserServiceImpl userServiceImpl;
+
+    @Autowired
+    public UserController(UserServiceImpl userServiceImpl) {
+        this.userServiceImpl = userServiceImpl;
+    }
+
+    @PostMapping("list")
+    @ResponseBody
+    public R list() {
+        List<UserEntity> userEntities = userServiceImpl.list();
+        return R.ok().data(userEntities);
+    }
+
+    @PostMapping("add")
+    @ResponseBody
+    public R add(@RequestBody UserEntity user) {
+        if (user.getLoginName() == null || user.getLoginName().equals("")) {
+            return R.error().message("LoginName不能为空");
+        }
+        String msg = userServiceImpl.add(user);
+        if (msg.equals("ok")) {
+            return R.ok().message("添加成功");
+        } else {
+            return R.error().message(msg);
+        }
+    }
+
+    @PostMapping("/delete/id/{userId}")
+    public R delete(@PathVariable Integer userId) {
+        if (null == userId) {
+            return R.error().message("userId 不能为空");
+        }
+        String delete = userServiceImpl.delete(userId);
+        if (delete.equals("ok")) {
+            return R.ok().message("删除成功");
+        } else {
+            return R.error().message(delete);
+        }
+    }
+
+    @PostMapping("/update/id/{userId}")
+    public R update(@PathVariable Integer userId, @RequestBody UserEntity userEntity) {
+        if (null == userEntity) {
+            return R.error().message("userEntity 为空");
+        }
+        userEntity.setUserId(userId);
+        String update = userServiceImpl.update(userEntity);
+        if (update.equals("ok")) {
+            return R.ok().message("修改成功");
+        } else {
+            return R.error().message(update);
+        }
+    }
+
+    @PostMapping("/select/id/{userId}")
+    public Map<String, Object> select(@PathVariable Integer userId) {
+
+        return userServiceImpl.select(userId);
+    }
+}

src/main/java/com/nokia/controller/VerificationController.java

@@ -0,0 +1,75 @@
+package com.nokia.controller;
+
+import com.nokia.common.R;
+import com.nokia.pojo.TokenEntity;
+import com.nokia.pojo.UserEntity;
+import com.nokia.service.AclService;
+import com.nokia.vo.DapingUserVo;
+import com.nokia.vo.FenxiUserVo;
+import com.nokia.vo.LiuchengUserVo;
+import com.nokia.vo.YuceUserVo;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.HashMap;
+import java.util.Map;
+
+@Slf4j
+@RestController
+@RequestMapping("/api")
+public class VerificationController {
+
+    @Autowired
+    private AclService aclService;
+
+    @Value("${dop.redirect.url}")
+    private String dopRedirectUrl;
+    @Value("${top.redirect.url}")
+    private String topRedirectUrl;
+
+    @PostMapping("/verification")
+    public R verifySystem(@RequestBody TokenEntity tokenEntity) {
+        log.debug("输入参数: {}", tokenEntity);
+        UserEntity userEntity = aclService.verifySystem(tokenEntity.getToken(), tokenEntity.getFromSystem());
+        log.debug("输出用户信息: {}", userEntity);
+        if (userEntity == null) {
+            Map<String, String> map = new HashMap<>();
+            if (tokenEntity.getFromSystem().equalsIgnoreCase("top")) {
+                map.put("redirect", topRedirectUrl);
+            } else if (tokenEntity.getFromSystem().equalsIgnoreCase("dop")) {
+                map.put("redirect", dopRedirectUrl);
+            } else {
+                switch (tokenEntity.getSystem().trim().toLowerCase()) {
+                    case "daping":
+                        map.put("redirect", dopRedirectUrl);
+                        break;
+                    case "liucheng":
+                    case "fenxi":
+                    case "yuce":
+                    default:
+                        map.put("redirect", topRedirectUrl);
+                        break;
+                }
+            }
+            return R.error().data(map).message("用户不存在");
+        } else {
+            switch (tokenEntity.getSystem().trim().toLowerCase()) {
+                case "liucheng":
+                    return R.ok().data(new LiuchengUserVo(userEntity));
+                case "fenxi":
+                    return R.ok().data(new FenxiUserVo(userEntity));
+                case "daping":
+                    return R.ok().data(new DapingUserVo(userEntity));
+                case "yuce":
+                    return R.ok().data(new YuceUserVo(userEntity));
+                default:
+                    return R.error().message("当前允许的system为：liucheng/fenxi/daping/yuce");
+            }
+        }
+    }
+}

src/main/java/com/nokia/dao/CityDao.java

@@ -0,0 +1,16 @@
+package com.nokia.dao;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.nokia.pojo.CityEntity;
+import com.nokia.vo.FlowOrgVo;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Select;
+
+@Mapper
+public interface CityDao extends BaseMapper<CityEntity> {
+    @Select("select * from sqmdb_rpt.acl_city where city_id = #{cityId}")
+    CityEntity findByCityId(Integer cityId);
+
+    @Select("select city_id as org_id, city_name_zh as org_name from sqmdb_rpt.acl_city where city_id = #{cityId}")
+    FlowOrgVo findOrgByCityId(Integer cityId);
+}

src/main/java/com/nokia/dao/RoleDao.java

@@ -0,0 +1,9 @@
+package com.nokia.dao;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.nokia.pojo.RoleEntity;
+import org.apache.ibatis.annotations.Mapper;
+
+@Mapper
+public interface RoleDao extends BaseMapper<RoleEntity> {
+}

src/main/java/com/nokia/dao/UserDao.java

@@ -0,0 +1,107 @@
+package com.nokia.dao;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.nokia.pojo.UserEntity;
+import com.nokia.vo.FlowRoleVo;
+import com.nokia.vo.FlowUserVo;
+import org.apache.ibatis.annotations.*;
+import java.util.List;
+
+@Mapper
+public interface UserDao extends BaseMapper<UserEntity> {
+
+        /**
+         * 支持username模糊查询
+         */
+        @Select("select distinct r.role_id, r.role_name from sqmdb_rpt.acl_user u, sqmdb_rpt.acl_role r, sqmdb_rpt.acl_user_role ur where u.user_id = ur.user_id and r.role_id = ur.role_id and u.user_name like concat('%',#{username},'%')")
+        List<FlowRoleVo> findRoleList(String username);
+
+        /**
+         * 查询全部
+         */
+        @Select("select role_id, role_name from sqmdb_rpt.acl_role")
+        List<FlowRoleVo> findRoleList2();
+
+        /**
+         * 查询全部用户（流程所需），未分页
+         */
+        @Results({
+                        @Result(column = "org_id", property = "org.orgId"),
+                        @Result(column = "org_name", property = "org.orgName"),
+        })
+        @Select("select a.user_id as user_id, a.login_name as login_id, a.user_name as user_name, a.phone as mobile, a.email as email,"
+                        + " a.city_id as org_id, c.city_name_zh as org_name, a.district"
+                        + " from sqmdb_rpt.acl_user a, sqmdb_rpt.acl_city c"
+                        + " where a.city_id = c.city_id")
+        List<FlowUserVo> findToPage();
+
+        /**
+         * 查询登录用户信息
+         */
+        // @Select("select user_id as user_id,login_name as login_id,user_name as
+        // user_name ,phone as mobile,email as email, city_id as org_id from
+        // sqmdb_rpt.acl_user where login_name=#{loginId} ")
+        // @Results({
+        // @Result(column = "city_id", property = "org", one = @One(select =
+        // "com.nokia.dao.CityDao.findOrgByCityId"))
+        // })
+        @Results({
+                        @Result(column = "org_id", property = "org.orgId"),
+                        @Result(column = "org_name", property = "org.orgName"),
+        })
+        @Select("select a.user_id as user_id, a.login_name as login_id, a.user_name as user_name, a.phone as mobile, a.email as email,"
+                        + " a.city_id as org_id, c.city_name_zh as org_name, a.district"
+                        + " from sqmdb_rpt.acl_user a, sqmdb_rpt.acl_city c"
+                        + " where a.city_id = c.city_id and login_name=#{loginId}")
+        FlowUserVo getFlowUserVoByLoginId(String loginId);
+
+        /**
+         * 根据用户ID获取用户接口
+         */
+        @Results({
+                        @Result(column = "org_id", property = "org.orgId"),
+                        @Result(column = "org_name", property = "org.orgName"),
+        })
+        @Select("select a.user_id as user_id, a.login_name as login_id, a.user_name as user_name, a.phone as mobile, a.email as email,"
+                        + " a.city_id as org_id, c.city_name_zh as org_name, a.district"
+                        + " from sqmdb_rpt.acl_user a, sqmdb_rpt.acl_city c"
+                        + " where a.city_id = c.city_id and user_id=#{userId}")
+        FlowUserVo getFlowUserVoByUserId(Integer userId);
+
+        @Select("select r.role_id from  sqmdb_rpt.acl_role r,  sqmdb_rpt.acl_user_role ur where r.role_id = ur.role_id and ur.user_id=#{userId}")
+        List<Integer> findRoleIdByUserId(Integer userId);
+
+        @Select("select u.user_id from sqmdb_rpt.acl_user u,  sqmdb_rpt.acl_user_role ur where u.user_id = ur.user_id and ur.role_id=#{roleId}")
+        List<Integer> findUserIdByRoleId(Integer roleId);
+
+        /**
+         * 
+         */
+        @Results({
+                        @Result(column = "org_id", property = "org.orgId"),
+                        @Result(column = "org_name", property = "org.orgName"),
+        })
+        @Select("<script>"
+                        + "select a.user_id as user_id, a.login_name as login_id, a.user_name as user_name, a.phone as mobile, a.email as email,"
+                        + " a.city_id as org_id, c.city_name_zh as org_name, a.district"
+                        + " from sqmdb_rpt.acl_user a, sqmdb_rpt.acl_city c, sqmdb_rpt.acl_user_role ur "
+                        + " where a.user_id = ur.user_id and a.city_id = c.city_id"
+                        + "<if test=\"loginId != null and loginId !=''\">"
+                        + " and a.login_name=#{loginId} "
+                        + "</if>"
+                        + "<if test=\"roleId != null\">"
+                        + " and ur.role_id=#{roleId} "
+                        + "</if>"
+                        + "<if test=\"userName != null and userName !=''\">"
+                        + " and a.user_name like concat('%',#{userName},'%') "
+                        + "</if>"
+                        + "</script>")
+        List<FlowUserVo> findAuthorizedUser(String loginId, Integer roleId, String userName);
+
+        @Select("select * from sqmdb_rpt.acl_user where login_name=#{loginName} ")
+        @Results({
+                        @Result(column = "city_id", property = "cityId"),
+                        @Result(column = "city_id", property = "city", one = @One(select = "com.nokia.dao.CityDao.findByCityId"))
+        })
+        UserEntity getByLoinName(String loginName);
+}

src/main/java/com/nokia/dao/UserRoleDao.java

@@ -0,0 +1,10 @@
+package com.nokia.dao;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.nokia.pojo.UserRoleEntity;
+import org.apache.ibatis.annotations.Mapper;
+
+@Mapper
+public interface UserRoleDao extends BaseMapper<UserRoleEntity> {
+
+}

src/main/java/com/nokia/pojo/CityEntity.java

@@ -0,0 +1,25 @@
+package com.nokia.pojo;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.io.Serializable;
+
+
+/**
+ * 城市
+ */
+@Data
+@TableName("sqmdb_rpt.acl_city")
+public class CityEntity implements Serializable {
+    @TableId(type = IdType.AUTO)
+    private Integer cityId;
+    // 城市中文名
+    private String cityNameZh;
+    // 城市英文名
+    private String cityNameEn;
+    // 排序
+    private Integer ord;
+}

src/main/java/com/nokia/pojo/DistrictEntity.java

@@ -0,0 +1,14 @@
+package com.nokia.pojo;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+
+import lombok.Data;
+
+@Data
+@TableName("sqmdb_rpt.acl_district")
+public class DistrictEntity {
+    private Integer cityId;
+    private String cityName;
+    private Integer districtId;
+    private String districtName;
+}

src/main/java/com/nokia/pojo/OrgEntity.java

@@ -0,0 +1,20 @@
+package com.nokia.pojo;
+
+import com.baomidou.mybatisplus.annotation.*;
+import lombok.Data;
+import java.util.Date;
+/**
+ * 部门
+ */
+@Data
+@TableName("acl_org")
+public class OrgEntity {
+    @TableId(type = IdType.AUTO)
+    private Integer orgId;
+    private String orgName;
+    // private String parentId;
+    @TableField(fill = FieldFill.INSERT)
+    private Date createTime;
+    @TableField(fill = FieldFill.INSERT_UPDATE)
+    private Date updateTime;
+}

src/main/java/com/nokia/pojo/RoleEntity.java

@@ -0,0 +1,24 @@
+package com.nokia.pojo;
+
+import com.baomidou.mybatisplus.annotation.*;
+import lombok.Data;
+
+import java.util.Date;
+import java.util.List;
+
+/**
+ * 角色类
+ */
+@Data
+@TableName("sqmdb_rpt.acl_role")
+public class RoleEntity {
+    @TableId(type = IdType.AUTO)
+    private Integer roleId;
+    private String roleName;
+    @TableField(fill = FieldFill.INSERT)
+    private Date createTime;
+    @TableField(fill = FieldFill.INSERT_UPDATE)
+    private Date updateTime;
+    @TableField(exist = false)
+    private List<UserEntity> userEntities;
+}

src/main/java/com/nokia/pojo/TokenEntity.java

@@ -0,0 +1,15 @@
+package com.nokia.pojo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * 无用实体类
+ */
+@Data
+public class TokenEntity implements Serializable {
+    private String token;
+    private String system;
+    private String fromSystem;
+}

src/main/java/com/nokia/pojo/UserEntity.java

@@ -0,0 +1,42 @@
+package com.nokia.pojo;
+
+import com.baomidou.mybatisplus.annotation.*;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+import java.util.List;
+
+@Data
+@TableName("sqmdb_rpt.acl_user")
+public class UserEntity implements Serializable {
+
+    @TableId(type = IdType.AUTO)
+    private Integer userId;
+    private String loginName;
+    private String userName;
+    private String phone;
+    private String email;
+    private String province;
+    // 需要从city表中对应
+    @TableField(exist = false)
+    private CityEntity city;
+    private Integer cityId;
+    // 所属区县 为空表示不归属区县 归属于地市
+    private String district;
+    private String county;
+    // 投诉分析权限 1表示有
+    private Integer tsfxPer;
+    // 投诉预测权限 1表示有
+    private Integer tsysPer;
+    // 投诉大屏权限 1表示有
+    private Integer tsdpPer;
+    // 投诉流程权限 1表示有
+    private Integer tsgdlzPer;
+    @TableField(fill = FieldFill.INSERT)
+    private Date createTime;
+    @TableField(fill = FieldFill.INSERT_UPDATE)
+    private Date updateTime;
+    @TableField(exist = false)
+    private List<Integer> roleIdList;
+}

src/main/java/com/nokia/pojo/UserRoleCity.java

@@ -0,0 +1,5 @@
+package com.nokia.pojo;
+
+public class UserRoleCity {
+    
+}

src/main/java/com/nokia/pojo/UserRoleEntity.java

@@ -0,0 +1,22 @@
+package com.nokia.pojo;
+import com.baomidou.mybatisplus.annotation.*;
+import lombok.Data;
+
+import java.util.Date;
+
+@Data
+@TableName("sqmdb_rpt.acl_user_role")
+public class UserRoleEntity {
+    @TableId(type = IdType.AUTO)
+    private Integer id;
+    private Integer userId;
+    private Integer roleId;
+    @TableField(fill = FieldFill.INSERT)
+    private Date createTime;
+    @TableField(fill = FieldFill.INSERT_UPDATE)
+    private Date updateTime;
+    @TableField(exist = false)
+    private RoleEntity roleEntity;
+    @TableField(exist = false)
+    private UserEntity userEntity;
+}

src/main/java/com/nokia/service/AclService.java

@@ -0,0 +1,87 @@
+package com.nokia.service;
+
+import com.nokia.dao.UserDao;
+import com.nokia.pojo.UserEntity;
+import com.nokia.vo.TokenFlagVo;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.stereotype.Service;
+
+import java.util.concurrent.TimeUnit;
+
+@Slf4j
+@Service
+public class AclService {
+
+    @Value("${redis.timeoutSeconds:600}")
+    private Integer timeoutSeconds;
+
+    private final UserDao userDao;
+    private final TopService topService;
+    private final DopService dopService;
+
+    private final RedisTemplate<String, Object> redisTemplate;
+
+    @Autowired
+    public AclService(UserDao userDao, TopService topService, DopService dopService,
+            RedisTemplate<String, Object> redisTemplate) {
+        this.userDao = userDao;
+        this.topService = topService;
+        this.dopService = dopService;
+        this.redisTemplate = redisTemplate;
+    }
+
+    public UserEntity verifySystem(String token, String fromSystem) {
+        UserEntity userEntity = null;
+        log.debug("{}", redisTemplate.opsForValue().get(token));
+        userEntity = (UserEntity) redisTemplate.opsForValue().get(token);
+
+        if (userEntity != null) {
+            log.debug("redis查询成功: {}", userEntity);
+            // 2.1 可以查到用户信息
+            redisTemplate.opsForValue().set(token, userEntity, timeoutSeconds, TimeUnit.SECONDS);
+            // 3 返回用户信息
+            return userEntity;
+        } else {
+            // 2.2 无法查到用户信息 可能是已超timeoutSeconds或者是初次登录
+            // 需要根据fromSystem参数去对应的系统进行鉴权
+            TokenFlagVo tokenFlagVo = getVerifyResult(token, fromSystem);
+            if (tokenFlagVo != null && tokenFlagVo.isValid()) {
+                // 如果token状态为可用，根据loginName从数据库查询用户
+                // 这里存在一个问题，如果是在top已存在的用户，但是我们系统没有，此时返回的userEntity为null，会对后续处理产生影响，需要考虑应该怎么做
+                // 在前端处理，上面的问题仅影响初次点击入口的用户，不影响超时用户
+                // 前端需要对入口用户做特别的处理
+                userEntity = userDao.getByLoinName(tokenFlagVo.getLoginName());
+                if (userEntity != null) {
+                    // 仅当用户信息不为空时,将用户信息存入redis
+                    redisTemplate.opsForValue().set(token, userEntity, timeoutSeconds, TimeUnit.SECONDS);
+                }
+                // 返回用户信息
+                return userEntity;
+            } else {
+                // token无效,返回重定向的登陆地址
+                return null;
+            }
+        }
+    }
+
+    private TokenFlagVo getVerifyResult(String token, String fromSystem) {
+        if (fromSystem.trim().equalsIgnoreCase("dop")) {
+            return dopService.dopReturn(token);
+        } else if (fromSystem.trim().equalsIgnoreCase("top")) {
+            return topService.topReturn(token);
+        } else if (fromSystem.trim().equalsIgnoreCase("test")) {
+            // 测试用
+            return testToken(token);
+        }
+        return null;
+    }
+
+    private TokenFlagVo testToken(String token) {
+        String login_name = token.trim().toLowerCase();
+        login_name = login_name.replace("test_token_", "test_");
+        return new TokenFlagVo(0, login_name);
+    }
+}

src/main/java/com/nokia/service/CityI/CityService.java

@@ -0,0 +1,6 @@
+package com.nokia.service.CityI;
+
+
+public interface CityService {
+
+}

src/main/java/com/nokia/service/CityI/CityServiceImpl.java

@@ -0,0 +1,11 @@
+package com.nokia.service.CityI;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.nokia.dao.CityDao;
+import com.nokia.pojo.CityEntity;
+import org.springframework.stereotype.Service;
+
+@Service
+public class CityServiceImpl extends ServiceImpl<CityDao, CityEntity> implements CityService {
+
+}

src/main/java/com/nokia/service/DopService.java

@@ -0,0 +1,27 @@
+package com.nokia.service;
+
+import com.nokia.vo.TokenFlagVo;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+import org.springframework.web.client.RestTemplate;
+
+import java.util.HashMap;
+
+@Service
+public class DopService{
+
+    @Value("${dop.url}")
+    private String dopUrl;
+    @Value("${dop.api.fromSystem:tousu}")
+    private String fromSystem;
+
+    public TokenFlagVo dopReturn(String token) {
+        HashMap<Object, Object> hashMap = new HashMap<>();
+        hashMap.put("token", token);
+        hashMap.put("fromSystem", fromSystem);
+        RestTemplate restTemplate = new RestTemplate();
+        TokenFlagVo tokenFlagVo = restTemplate.postForObject(dopUrl, hashMap, TokenFlagVo.class);
+        return tokenFlagVo;
+    }
+
+}

src/main/java/com/nokia/service/Flow/FlowService.java

@@ -0,0 +1,16 @@
+package com.nokia.service.Flow;
+
+import com.nokia.vo.FlowRoleVo;
+import com.nokia.vo.FlowUserVo;
+
+import java.util.List;
+
+public interface FlowService {
+    List<FlowRoleVo> findRoleList(String username);
+    List<FlowUserVo> findToPage();
+    FlowUserVo getByLoginId(String loginId);
+    FlowUserVo getByUserId(Integer userId);
+    List<Integer> findRoleIdByUserId(Integer userId);
+    List<Integer> findUserIdByRoleId(Integer roleId);
+    List<FlowUserVo> findAuthorizedUser(String loginId, Integer roleId, String username);
+}

src/main/java/com/nokia/service/Flow/FlowServiceImpl.java

@@ -0,0 +1,52 @@
+package com.nokia.service.Flow;
+
+
+import com.nokia.dao.UserDao;
+import com.nokia.vo.*;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+public class FlowServiceImpl implements FlowService {
+
+    private final UserDao userDao;
+
+    @Autowired
+    public FlowServiceImpl(UserDao userDao) {
+        this.userDao = userDao;
+    }
+
+    public List<FlowRoleVo> findRoleList(String username) {
+        return userDao.findRoleList(username);
+    }
+
+    public List<FlowRoleVo> findRoleList() {
+        return userDao.findRoleList2();
+    }
+
+    public List<FlowUserVo> findToPage() {
+        return userDao.findToPage();
+    }
+
+    public FlowUserVo getByLoginId(String loginId) {
+        return userDao.getFlowUserVoByLoginId(loginId);
+    }
+
+    public FlowUserVo getByUserId(Integer userId) {
+        return userDao.getFlowUserVoByUserId(userId);
+    }
+
+    public List<Integer> findRoleIdByUserId(Integer userId) {
+        return userDao.findRoleIdByUserId(userId);
+    }
+
+    public List<Integer> findUserIdByRoleId(Integer roleId) {
+        return userDao.findUserIdByRoleId(roleId);
+    }
+
+    public List<FlowUserVo> findAuthorizedUser(String loginId, Integer roleId, String userName) {
+        return userDao.findAuthorizedUser(loginId, roleId, userName);
+    }
+}

src/main/java/com/nokia/service/TopService.java

@@ -0,0 +1,28 @@
+package com.nokia.service;
+
+
+import com.nokia.vo.TokenFlagVo;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+import org.springframework.web.client.RestTemplate;
+
+import java.util.HashMap;
+
+@Service
+public class TopService{
+
+    @Value("${top.url}")
+    private String topUrl;
+    @Value("${top.api.fromSystem:tousu}")
+    private String fromSystem;
+
+    public TokenFlagVo topReturn(String token) {
+        HashMap<Object, Object> hashMap = new HashMap<>();
+        hashMap.put("token",token);
+        hashMap.put("fromSystem",fromSystem);
+        RestTemplate restTemplate = new RestTemplate();
+        TokenFlagVo tokenFlagVo = restTemplate.postForObject(topUrl, hashMap, TokenFlagVo.class);
+        return tokenFlagVo;
+    }
+
+}

src/main/java/com/nokia/service/user/UserService.java

@@ -0,0 +1,12 @@
+package com.nokia.service.user;
+
+import com.nokia.pojo.UserEntity;
+
+import java.util.Map;
+
+public interface UserService {
+     String add(UserEntity table2User);
+     String delete(Integer userId);
+     String update(UserEntity table2User);
+     Map<String, Object> select(Integer userId);
+}

src/main/java/com/nokia/service/user/UserServiceImpl.java

@@ -0,0 +1,115 @@
+package com.nokia.service.user;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.nokia.dao.CityDao;
+import com.nokia.dao.RoleDao;
+import com.nokia.dao.UserDao;
+import com.nokia.dao.UserRoleDao;
+import com.nokia.pojo.CityEntity;
+import com.nokia.pojo.UserEntity;
+import com.nokia.pojo.UserRoleEntity;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+@Service
+public class UserServiceImpl extends ServiceImpl<UserDao, UserEntity> implements UserService {
+
+    private final UserRoleDao userRoleDao;
+
+    private final CityDao cityDao;
+
+    @Autowired
+    public UserServiceImpl(RoleDao roleDao, UserRoleDao userRoleDao, CityDao cityDao) {
+        this.userRoleDao = userRoleDao;
+        this.cityDao = cityDao;
+    }
+
+    @Transactional
+    public String add(UserEntity table2User) {
+        UserEntity query = new UserEntity();
+        query.setLoginName(table2User.getLoginName());
+        UserEntity one = baseMapper.selectOne(Wrappers.query(query));
+        if (one != null) {
+            return "loginName: " + table2User.getLoginName() + " 已存在";
+        } else {
+            table2User.setCityId(table2User.getCityId());
+            baseMapper.insert(table2User);
+            List<Integer> roleEntityList1 = table2User.getRoleIdList();
+            UserRoleEntity userRoleEntity = new UserRoleEntity();
+            for (Integer integer : roleEntityList1) {
+                userRoleEntity.setUserId(table2User.getUserId());
+                userRoleEntity.setRoleId(integer);
+                userRoleDao.insert(userRoleEntity);
+            }
+        }
+        return "ok";
+    }
+
+    @Override
+    @Transactional
+    public String delete(Integer userId) {
+        // UserEntity userEntity = baseMapper.selectById(userId);
+        /* cityDao.deleteById(userEntity.getCityId()); */
+        QueryWrapper<UserRoleEntity> objectQueryWrapper = new QueryWrapper<>();
+        objectQueryWrapper.eq("user_id", userId);
+        List<UserRoleEntity> userRoleEntities = userRoleDao.selectList(objectQueryWrapper);
+        for (UserRoleEntity userRoleEntity : userRoleEntities) {
+            Integer id = userRoleEntity.getId();
+            userRoleDao.deleteById(id);
+        }
+        baseMapper.deleteById(userId);
+        return "ok";
+    }
+
+    @Override
+    @Transactional
+    public String update(UserEntity user) {
+        baseMapper.updateById(user);
+        Integer userId = user.getUserId();
+        QueryWrapper<UserRoleEntity> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("user_id", userId);
+        userRoleDao.delete(queryWrapper);
+        for (Integer rolid : user.getRoleIdList()) {
+            UserRoleEntity userRoleEntity = new UserRoleEntity();
+            userRoleEntity.setUserId(user.getUserId());
+            userRoleEntity.setRoleId(rolid);
+            userRoleDao.insert(userRoleEntity);
+        }
+        return "ok";
+    }
+
+    @Override
+    public Map<String, Object> select(Integer userId) {
+        Map<String, Object> hashMap = new HashMap<>();
+        if (userId == null) {
+            hashMap.put("userId", "为空");
+            return hashMap;
+        }
+        UserEntity userEntity = baseMapper.selectById(userId);
+        QueryWrapper<UserEntity> userEntityQueryWrapper = new QueryWrapper<>();
+        userEntityQueryWrapper.eq("user_id", userId);
+        UserEntity one = baseMapper.selectOne(userEntityQueryWrapper);
+        if (one == null) {
+            hashMap.put("userId", "不正确");
+            return hashMap;
+        }
+        Integer cityId = userEntity.getCityId();
+        CityEntity cityEntity = cityDao.selectById(cityId);
+        // 他有两个角色 对 我知道 用for遍历来查 不需要for遍历查
+        QueryWrapper<UserRoleEntity> objectQueryWrapper = new QueryWrapper<>();
+        objectQueryWrapper.eq("user_id", userId);
+        List<UserRoleEntity> userRoleEntities = userRoleDao.selectList(objectQueryWrapper);
+        hashMap.put("userEntity", userEntity);
+        hashMap.put("cityEntity", cityEntity);
+        hashMap.put("userRoleEntities", userRoleEntities);
+        return hashMap;
+    }
+
+}

src/main/java/com/nokia/vo/DapingUserVo.java

@@ -0,0 +1,26 @@
+package com.nokia.vo;
+
+import com.nokia.pojo.UserEntity;
+import lombok.Data;
+
+/**
+ * 大屏：
+ * 用户姓名
+ * 归属省
+ * 归属地市
+ * 权限：省级/地市级
+ */
+@Data
+public class DapingUserVo {
+    private Integer userId;
+    private String userName;
+    private String province;
+    private String city;
+
+    public DapingUserVo(UserEntity userEntity) {
+        this.userId = userEntity.getUserId();
+        this.userName = userEntity.getUserName();
+        this.province = userEntity.getProvince();
+        this.city = userEntity.getCity().getCityNameZh();
+    }
+}

src/main/java/com/nokia/vo/FenxiUserVo.java

@@ -0,0 +1,23 @@
+package com.nokia.vo;
+
+import com.nokia.pojo.UserEntity;
+import lombok.Data;
+
+@Data
+public class FenxiUserVo {
+    private Integer id;
+    private String account;
+    private String name;
+    // 1为可用，其他为不可用
+    private Integer status;
+    // city为城市id
+    private String city;
+
+    public FenxiUserVo(UserEntity userEntity) {
+        this.id = userEntity.getUserId();
+        this.account = userEntity.getLoginName();
+        this.name = userEntity.getUserName();
+        this.status = userEntity.getTsfxPer();
+        this.city = userEntity.getCity().getCityNameZh();
+    }
+}

src/main/java/com/nokia/vo/FlowOrgVo.java

@@ -0,0 +1,9 @@
+package com.nokia.vo;
+
+import lombok.Data;
+
+@Data
+public class FlowOrgVo {
+    private Integer orgId;
+    private String orgName;
+}

src/main/java/com/nokia/vo/FlowRoleVo.java

@@ -0,0 +1,9 @@
+package com.nokia.vo;
+
+import lombok.Data;
+
+@Data
+public class FlowRoleVo {
+    private Integer roleId;
+    private String roleName;
+}

src/main/java/com/nokia/vo/FlowUserVo.java

@@ -0,0 +1,15 @@
+package com.nokia.vo;
+
+import lombok.Data;
+
+@Data
+public class FlowUserVo {
+    private Integer userId;
+    private String loginId;
+    private String userName;
+    private String mobile;
+    private String email;
+    // private Integer state;
+    private FlowOrgVo org;
+    private String district;
+}

src/main/java/com/nokia/vo/LiuchengUserVo.java

@@ -0,0 +1,25 @@
+package com.nokia.vo;
+
+import com.nokia.pojo.UserEntity;
+import lombok.Data;
+
+/**
+ * 用于acl返回给工单流转系统的用户信息
+ * <p>
+ * 流转：
+ * 用户账号(account),
+ * 用户ID(userId),
+ * 用户名称（userName）
+ */
+@Data
+public class LiuchengUserVo {
+    private String account;
+    private Integer userId;
+    private String userName;
+
+    public LiuchengUserVo(UserEntity userEntity) {
+        this.account = userEntity.getLoginName();
+        this.userId = userEntity.getUserId();
+        this.userName = userEntity.getUserName();
+    }
+}

src/main/java/com/nokia/vo/TokenFlagVo.java

@@ -0,0 +1,17 @@
+package com.nokia.vo;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class TokenFlagVo {
+    private Integer isValid;//0是 1否
+    private String loginName;//用户oa名，若isValid的值为1，则用户名为空字符串
+
+    public boolean isValid() {
+        return this.isValid == 0;
+    }
+}

src/main/java/com/nokia/vo/UserVo.java

@@ -0,0 +1,10 @@
+package com.nokia.vo;
+
+import lombok.Data;
+
+@Data
+public class UserVo {
+    private  String  account;
+    private Integer userId;
+    private String userName;
+}

src/main/java/com/nokia/vo/YuceUserVo.java

@@ -0,0 +1,19 @@
+package com.nokia.vo;
+
+import com.nokia.pojo.UserEntity;
+import lombok.Data;
+
+@Data
+public class YuceUserVo {
+    private Integer userId;
+    private String userName;
+    private String province;
+    private Integer city;
+
+    public YuceUserVo(UserEntity userEntity) {
+        this.userId = userEntity.getUserId();
+        this.userName = userEntity.getUserName();
+        this.province = userEntity.getProvince();
+        this.city = userEntity.getCity().getCityId();
+    }
+}

src/main/resources/application.properties

@@ -0,0 +1,37 @@
+# web服务端口号
+server.port=12128
+# 数据源
+#spring.datasource.driver-class-name=org.postgresql.Driver
+#spring.datasource.url=jdbc:postgresql://localhost:5432/login
+#spring.datasource.username=postgres
+#spring.datasource.password=postgres
+# log
+# log配置
+logging.level.root=info
+logging.level.com.nokia=debug
+logging.file.name=log/acl.log
+
+
+#spring.redis.host=localhost
+#spring.redis.port=6379
+#spring.redis.database=0
+
+# 正式环境数据源GP数据库配置
+spring.datasource.driver-class-name=org.postgresql.Driver
+spring.datasource.url=jdbc:postgresql://192.168.70.109:5432/sqmmt
+spring.datasource.username=sqmdb
+spring.datasource.password=sqmdb_1QAZ
+
+# 正式环境Redis配置
+spring.redis.host=192.168.70.125
+spring.redis.port=6379
+spring.redis.database=0
+spring.redis.password=Richr00t
+redis.timeoutSeconds=600
+
+top.url=http://10.17.180.3/prod-api/verifySystem
+dop.url=http://10.17.180.5:8089/prod-api/verifySystem
+top.api.fromSystem=dh
+dop.api.fromSystem=dh
+top.redirect.url=https://133.96.90.208/login
+dop.redirect.url=http://133.96.90.210:8089/login

src/test/java/com/nokia/MainTest.java

@@ -0,0 +1,32 @@
+package com.nokia;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.data.redis.core.RedisTemplate;
+
+
+
+@SpringBootTest
+public class MainTest {
+    @Test
+    public void test() {
+        String json;
+        json = "{\"number\": \"abc\"}";
+        JSONObject object = JSON.parseObject(json);
+        System.out.println(object);
+        System.out.println(object.getInteger("number"));
+    }
+
+    @Autowired
+    RedisTemplate<String, Object> redisTemplate;
+
+    @Test
+    public void clearRedisTemplate() {
+        redisTemplate.delete("eyJhbGciOiJIUzUxMiJ9.eyJsb2dpbl91c2VyX2tleSI6Ijc3NmM5MDg1LTNhNWUtNGVlYS04YWVmLWQzNjFlOGMzMWI5MCJ9.U0MBC0VQgOShNzkv3rkbG39DzWl8oJ8DWqpSkdOwYQZX5Ek-nt-FWUI0GWtKp8ROjZLiKy_WwX3Sagzw1U9I-w");
+        Object o = redisTemplate.opsForValue().get("eyJhbGciOiJIUzUxMiJ9.eyJsb2dpbl91c2VyX2tleSI6Ijc3NmM5MDg1LTNhNWUtNGVlYS04YWVmLWQzNjFlOGMzMWI5MCJ9.U0MBC0VQgOShNzkv3rkbG39DzWl8oJ8DWqpSkdOwYQZX5Ek-nt-FWUI0GWtKp8ROjZLiKy_WwX3Sagzw1U9I-w");
+        System.out.println(o);
+    }
+}

src/test/java/com/nokia/RedisTest.java

@@ -0,0 +1,19 @@
+package com.nokia;
+
+import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.data.redis.core.RedisTemplate;
+
+@SpringBootTest
+public class RedisTest {
+    
+    @Autowired
+    private RedisTemplate<String, Object> redisTemplate;
+
+    @Test
+    public void test() {
+        Boolean delete = redisTemplate.delete("test_token_abc");
+        System.out.println(delete);
+    }
+}

src/test/java/com/nokia/dao/CityDaoTest.java

@@ -0,0 +1,29 @@
+package com.nokia.dao;
+
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.nokia.pojo.CityEntity;
+import com.nokia.vo.FlowOrgVo;
+import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+
+import java.util.List;
+
+@SpringBootTest
+public class CityDaoTest {
+
+    @Autowired
+    private CityDao cityDao;
+
+    @Test
+    public void test() {
+        List<CityEntity> cities = cityDao.selectList(Wrappers.query());
+        System.out.println(cities);
+    }
+
+    @Test
+    public void testFindOrgByCityId() {
+        FlowOrgVo vo = cityDao.findOrgByCityId(130100);
+        System.out.println(vo);
+    }
+}

src/test/java/com/nokia/dao/RoleDaoTest.java

@@ -0,0 +1,30 @@
+package com.nokia.dao;
+
+import com.nokia.pojo.RoleEntity;
+import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+
+@SpringBootTest
+public class RoleDaoTest {
+
+    @Autowired
+    private RoleDao roleDao;
+
+    @Test
+    public void insertRoles() {
+        RoleEntity role = new RoleEntity();
+        // role.setRoleName("管理");
+        // roleDao.insert(role);
+        role.setRoleName("分析组");
+        roleDao.insert(role);
+        role.setRoleName("优化组");
+        roleDao.insert(role);
+        role.setRoleName("维护组");
+        roleDao.insert(role);
+        role.setRoleName("建设组");
+        roleDao.insert(role);
+        role.setRoleName("审核组");
+        roleDao.insert(role);
+    }
+}

src/test/java/com/nokia/dao/RoleEntityDaoTest.java

@@ -0,0 +1,24 @@
+package com.nokia.dao;
+
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.nokia.pojo.RoleEntity;
+import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+
+import java.util.List;
+
+@SpringBootTest
+public class RoleEntityDaoTest {
+    @Autowired
+    private RoleDao roleDao;
+
+    @Test
+    public void test() {
+        RoleEntity roleEntity = new RoleEntity();
+        roleEntity.setRoleName("管理员");
+        roleDao.insert(roleEntity);
+        List<RoleEntity> roleEntities = roleDao.selectList(Wrappers.query());
+        System.out.println(roleEntities);
+    }
+}

src/test/java/com/nokia/dao/UserDaoTest.java

@@ -0,0 +1,27 @@
+package com.nokia.dao;
+
+import com.nokia.pojo.UserEntity;
+import com.nokia.vo.FlowUserVo;
+import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+
+
+
+@SpringBootTest
+public class UserDaoTest {
+
+    @Autowired UserDao userDao;
+
+    @Test
+    public void getByLoinName() {
+        UserEntity usr = userDao.getByLoinName("13111111111");
+        System.out.println(usr);
+    }
+
+    @Test
+    public void testGetFlowUserVoByUserId() {
+        FlowUserVo flowUserVo = userDao.getFlowUserVoByUserId(3);
+        System.out.println(flowUserVo);
+    }
+}

src/test/java/com/nokia/dao/UserRoleDaoTest.java

@@ -0,0 +1,40 @@
+package com.nokia.dao;
+
+import com.nokia.pojo.UserRoleEntity;
+import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+
+
+@SpringBootTest
+public class UserRoleDaoTest {
+
+    @Autowired
+    private UserRoleDao userRoleDao;
+
+    @Test
+    public void insertUserRole() {
+        UserRoleEntity userRoleEntity = new UserRoleEntity();
+        userRoleEntity.setRoleId(4);
+        userRoleEntity.setUserId(3);
+        userRoleDao.insert(userRoleEntity);
+        userRoleEntity.setRoleId(3);
+        userRoleEntity.setUserId(3);
+        userRoleDao.insert(userRoleEntity);
+        userRoleEntity.setRoleId(3);
+        userRoleEntity.setUserId(4);
+        userRoleDao.insert(userRoleEntity);
+        userRoleEntity.setRoleId(3);
+        userRoleEntity.setUserId(1);
+        userRoleDao.insert(userRoleEntity);
+        userRoleEntity.setRoleId(4);
+        userRoleEntity.setUserId(1);
+        userRoleDao.insert(userRoleEntity);
+        userRoleEntity.setRoleId(5);
+        userRoleEntity.setUserId(4);
+        userRoleDao.insert(userRoleEntity);
+        userRoleEntity.setRoleId(6);
+        userRoleEntity.setUserId(2);
+        userRoleDao.insert(userRoleEntity);
+    }
+}