Skip to content
项目
群组
代码片段
帮助
当前项目
正在载入...
登录 / 注册
切换导航面板
kt-keystone
项目
项目
详情
活动
周期分析
仓库
仓库
文件
提交
分支
标签
贡献者
图表
比较
统计图
议题
0
议题
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
CI / CD
CI / CD
流水线
作业
日程
统计图
Wiki
Wiki
代码片段
代码片段
成员
成员
折叠边栏
关闭边栏
活动
图像
聊天
创建新问题
作业
提交
问题看板
Open sidebar
Matrix
kt-keystone
Commits
76adb104
提交
76adb104
authored
3月 16, 2022
作者:
黄承天
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
fix(user):修改名称以避免同名冲突
上级
1c81a776
显示空白字符变更
内嵌
并排
正在显示
6 个修改的文件
包含
44 行增加
和
32 行删除
+44
-32
pom.xml
kt-user/pom.xml
+18
-6
KsProjectMapper.java
...rc/main/java/org/matrix/local/mapper/KsProjectMapper.java
+1
-1
KsUserMapper.java
...r/src/main/java/org/matrix/local/mapper/KsUserMapper.java
+1
-1
KsUserProjectMapper.java
...ain/java/org/matrix/local/mapper/KsUserProjectMapper.java
+1
-1
UserService.java
...r/src/main/java/org/matrix/local/service/UserService.java
+10
-10
DataCollector.java
...rc/main/java/org/matrix/remote/service/DataCollector.java
+13
-13
没有找到文件。
kt-user/pom.xml
浏览文件 @
76adb104
...
@@ -13,10 +13,25 @@
...
@@ -13,10 +13,25 @@
<packaging>
jar
</packaging>
<packaging>
jar
</packaging>
<dependencies>
<dependencies>
<dependency>
<dependency>
<groupId>
org.matrix
</groupId>
<groupId>
com.baomidou
</groupId>
<artifactId>
kt-kit
</artifactId>
<artifactId>
mybatis-plus-generator
</artifactId>
<version>
3.5.1
</version>
</dependency>
<!-- datasource 相关-->
<dependency>
<groupId>
com.baomidou
</groupId>
<artifactId>
mybatis-plus-boot-starter
</artifactId>
<version>
3.4.3.4
</version>
</dependency>
<dependency>
<groupId>
org.springframework.boot
</groupId>
<artifactId>
spring-boot-configuration-processor
</artifactId>
<optional>
true
</optional>
</dependency>
<dependency>
<groupId>
mysql
</groupId>
<artifactId>
mysql-connector-java
</artifactId>
</dependency>
</dependency>
<dependency>
<dependency>
<groupId>
org.springframework.boot
</groupId>
<groupId>
org.springframework.boot
</groupId>
...
@@ -36,21 +51,18 @@
...
@@ -36,21 +51,18 @@
<artifactId>
dynamic-datasource-spring-boot-starter
</artifactId>
<artifactId>
dynamic-datasource-spring-boot-starter
</artifactId>
<version>
3.5.0
</version>
<version>
3.5.0
</version>
</dependency>
</dependency>
<!--swagger-->
<!--swagger-->
<dependency>
<dependency>
<groupId>
io.springfox
</groupId>
<groupId>
io.springfox
</groupId>
<artifactId>
springfox-swagger2
</artifactId>
<artifactId>
springfox-swagger2
</artifactId>
<version>
2.9.2
</version>
<version>
2.9.2
</version>
</dependency>
</dependency>
<!--swagger ui-->
<!--swagger ui-->
<dependency>
<dependency>
<groupId>
io.springfox
</groupId>
<groupId>
io.springfox
</groupId>
<artifactId>
springfox-swagger-ui
</artifactId>
<artifactId>
springfox-swagger-ui
</artifactId>
<version>
2.9.2
</version>
<version>
2.9.2
</version>
</dependency>
</dependency>
</dependencies>
</dependencies>
<build>
<build>
...
...
kt-user/src/main/java/org/matrix/local/mapper/ProjectMapper.java
→
kt-user/src/main/java/org/matrix/local/mapper/
Ks
ProjectMapper.java
浏览文件 @
76adb104
...
@@ -15,6 +15,6 @@ import org.springframework.stereotype.Repository;
...
@@ -15,6 +15,6 @@ import org.springframework.stereotype.Repository;
*/
*/
@DS
(
"master"
)
@DS
(
"master"
)
@Repository
@Repository
public
interface
ProjectMapper
extends
BaseMapper
<
Project
>
{
public
interface
Ks
ProjectMapper
extends
BaseMapper
<
Project
>
{
}
}
kt-user/src/main/java/org/matrix/local/mapper/UserMapper.java
→
kt-user/src/main/java/org/matrix/local/mapper/
Ks
UserMapper.java
浏览文件 @
76adb104
...
@@ -15,5 +15,5 @@ import org.springframework.stereotype.Repository;
...
@@ -15,5 +15,5 @@ import org.springframework.stereotype.Repository;
*/
*/
@DS
(
"master"
)
@DS
(
"master"
)
@Repository
@Repository
public
interface
UserMapper
extends
BaseMapper
<
User
>
{
public
interface
Ks
UserMapper
extends
BaseMapper
<
User
>
{
}
}
kt-user/src/main/java/org/matrix/local/mapper/UserProjectMapper.java
→
kt-user/src/main/java/org/matrix/local/mapper/
Ks
UserProjectMapper.java
浏览文件 @
76adb104
...
@@ -15,5 +15,5 @@ import org.springframework.stereotype.Repository;
...
@@ -15,5 +15,5 @@ import org.springframework.stereotype.Repository;
*/
*/
@DS
(
"master"
)
@DS
(
"master"
)
@Repository
@Repository
public
interface
UserProjectMapper
extends
BaseMapper
<
UserProject
>
{
public
interface
Ks
UserProjectMapper
extends
BaseMapper
<
UserProject
>
{
}
}
kt-user/src/main/java/org/matrix/local/service/UserService.java
浏览文件 @
76adb104
...
@@ -7,9 +7,9 @@ import org.matrix.local.entity.User;
...
@@ -7,9 +7,9 @@ import org.matrix.local.entity.User;
import
org.matrix.local.entity.UserProject
;
import
org.matrix.local.entity.UserProject
;
import
org.matrix.local.entity.vo.LoginInfo
;
import
org.matrix.local.entity.vo.LoginInfo
;
import
org.matrix.local.entity.vo.UserInfo
;
import
org.matrix.local.entity.vo.UserInfo
;
import
org.matrix.local.mapper.ProjectMapper
;
import
org.matrix.local.mapper.
Ks
ProjectMapper
;
import
org.matrix.local.mapper.UserMapper
;
import
org.matrix.local.mapper.
Ks
UserMapper
;
import
org.matrix.local.mapper.UserProjectMapper
;
import
org.matrix.local.mapper.
Ks
UserProjectMapper
;
import
org.matrix.local.util.MD5Util
;
import
org.matrix.local.util.MD5Util
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.stereotype.Service
;
import
org.springframework.stereotype.Service
;
...
@@ -31,11 +31,11 @@ import static java.util.Objects.nonNull;
...
@@ -31,11 +31,11 @@ import static java.util.Objects.nonNull;
public
class
UserService
{
public
class
UserService
{
@Autowired
@Autowired
private
UserMapper
u
serMapper
;
private
KsUserMapper
ksU
serMapper
;
@Autowired
@Autowired
private
ProjectMapper
p
rojectMapper
;
private
KsProjectMapper
ksP
rojectMapper
;
@Autowired
@Autowired
private
UserProjectMapper
u
serProjectMapper
;
private
KsUserProjectMapper
ksU
serProjectMapper
;
/**
/**
* 登录信息缓存Map
* 登录信息缓存Map
...
@@ -55,7 +55,7 @@ public class UserService {
...
@@ -55,7 +55,7 @@ public class UserService {
public
boolean
login
(
LoginInfo
loginInfo
,
String
sessionId
)
{
public
boolean
login
(
LoginInfo
loginInfo
,
String
sessionId
)
{
String
account
=
loginInfo
.
getAccount
();
String
account
=
loginInfo
.
getAccount
();
String
password
=
MD5Util
.
encode
(
loginInfo
.
getPassword
());
String
password
=
MD5Util
.
encode
(
loginInfo
.
getPassword
());
User
user
=
u
serMapper
.
selectOne
(
Wrappers
.<
User
>
lambdaQuery
()
User
user
=
ksU
serMapper
.
selectOne
(
Wrappers
.<
User
>
lambdaQuery
()
.
eq
(
User:
:
getAccount
,
account
)
.
eq
(
User:
:
getAccount
,
account
)
.
eq
(
User:
:
getPassword
,
password
));
.
eq
(
User:
:
getPassword
,
password
));
if
(
nonNull
(
user
))
{
if
(
nonNull
(
user
))
{
...
@@ -78,7 +78,7 @@ public class UserService {
...
@@ -78,7 +78,7 @@ public class UserService {
boolean
hasLogin
=
sessionMap
.
containsKey
(
sessionId
);
boolean
hasLogin
=
sessionMap
.
containsKey
(
sessionId
);
if
(
hasLogin
)
{
if
(
hasLogin
)
{
Long
userId
=
sessionMap
.
get
(
sessionId
);
Long
userId
=
sessionMap
.
get
(
sessionId
);
User
user
=
u
serMapper
.
selectById
(
userId
);
User
user
=
ksU
serMapper
.
selectById
(
userId
);
if
(
nonNull
(
user
))
{
if
(
nonNull
(
user
))
{
return
userInfo
(
user
);
return
userInfo
(
user
);
}
else
{
}
else
{
...
@@ -102,9 +102,9 @@ public class UserService {
...
@@ -102,9 +102,9 @@ public class UserService {
//-------------------------------private--------------------------------
//-------------------------------private--------------------------------
private
UserInfo
userInfo
(
User
user
)
{
private
UserInfo
userInfo
(
User
user
)
{
List
<
Project
>
projects
=
u
serProjectMapper
.
selectList
(
Wrappers
.<
UserProject
>
lambdaQuery
().
eq
(
UserProject:
:
getUserId
,
user
.
getId
())).
stream
()
List
<
Project
>
projects
=
ksU
serProjectMapper
.
selectList
(
Wrappers
.<
UserProject
>
lambdaQuery
().
eq
(
UserProject:
:
getUserId
,
user
.
getId
())).
stream
()
.
map
(
UserProject:
:
getProjectId
)
.
map
(
UserProject:
:
getProjectId
)
.
map
(
p
rojectMapper:
:
selectById
)
.
map
(
ksP
rojectMapper:
:
selectById
)
.
filter
(
Objects:
:
nonNull
)
.
filter
(
Objects:
:
nonNull
)
.
collect
(
Collectors
.
toList
());
.
collect
(
Collectors
.
toList
());
return
new
UserInfo
(
return
new
UserInfo
(
...
...
kt-user/src/main/java/org/matrix/remote/service/DataCollector.java
浏览文件 @
76adb104
...
@@ -4,9 +4,9 @@ import com.baomidou.mybatisplus.core.toolkit.Wrappers;
...
@@ -4,9 +4,9 @@ import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import
org.matrix.local.entity.Project
;
import
org.matrix.local.entity.Project
;
import
org.matrix.local.entity.User
;
import
org.matrix.local.entity.User
;
import
org.matrix.local.entity.UserProject
;
import
org.matrix.local.entity.UserProject
;
import
org.matrix.local.mapper.ProjectMapper
;
import
org.matrix.local.mapper.
Ks
ProjectMapper
;
import
org.matrix.local.mapper.UserMapper
;
import
org.matrix.local.mapper.
Ks
UserMapper
;
import
org.matrix.local.mapper.UserProjectMapper
;
import
org.matrix.local.mapper.
Ks
UserProjectMapper
;
import
org.matrix.remote.entity.ZtProject
;
import
org.matrix.remote.entity.ZtProject
;
import
org.matrix.remote.entity.ZtUser
;
import
org.matrix.remote.entity.ZtUser
;
import
org.matrix.remote.entity.ZtUserView
;
import
org.matrix.remote.entity.ZtUserView
;
...
@@ -37,11 +37,11 @@ public class DataCollector {
...
@@ -37,11 +37,11 @@ public class DataCollector {
@Autowired
@Autowired
private
ZtProjectMapper
ztProjectMapper
;
private
ZtProjectMapper
ztProjectMapper
;
@Autowired
@Autowired
private
UserMapper
u
serMapper
;
private
KsUserMapper
ksU
serMapper
;
@Autowired
@Autowired
private
ProjectMapper
p
rojectMapper
;
private
KsProjectMapper
ksP
rojectMapper
;
@Autowired
@Autowired
private
UserProjectMapper
u
serProjectMapper
;
private
KsUserProjectMapper
ksU
serProjectMapper
;
private
List
<
ZtUser
>
ztUsers
=
new
ArrayList
<>();
private
List
<
ZtUser
>
ztUsers
=
new
ArrayList
<>();
private
List
<
ZtUserView
>
ztUserViews
=
new
ArrayList
<>();
private
List
<
ZtUserView
>
ztUserViews
=
new
ArrayList
<>();
...
@@ -95,30 +95,30 @@ public class DataCollector {
...
@@ -95,30 +95,30 @@ public class DataCollector {
* 将用户数据保存到本地
* 将用户数据保存到本地
*/
*/
private
void
saveUser
()
{
private
void
saveUser
()
{
u
serMapper
.
delete
(
Wrappers
.
lambdaQuery
());
ksU
serMapper
.
delete
(
Wrappers
.
lambdaQuery
());
ztUsers
.
stream
()
ztUsers
.
stream
()
.
map
(
this
::
user
)
.
map
(
this
::
user
)
.
forEach
(
u
serMapper:
:
insert
);
.
forEach
(
ksU
serMapper:
:
insert
);
}
}
/**
/**
* 将项目数据保存到本地
* 将项目数据保存到本地
*/
*/
private
void
saveProject
()
{
private
void
saveProject
()
{
p
rojectMapper
.
delete
(
Wrappers
.
lambdaQuery
());
ksP
rojectMapper
.
delete
(
Wrappers
.
lambdaQuery
());
ztProjects
.
stream
()
ztProjects
.
stream
()
.
map
(
this
::
project
)
.
map
(
this
::
project
)
.
forEach
(
p
rojectMapper:
:
insert
);
.
forEach
(
ksP
rojectMapper:
:
insert
);
}
}
/**
/**
* 将用户项目关系数据保存到本地
* 将用户项目关系数据保存到本地
*/
*/
private
void
saveUserProject
()
{
private
void
saveUserProject
()
{
u
serProjectMapper
.
delete
(
Wrappers
.
lambdaQuery
());
ksU
serProjectMapper
.
delete
(
Wrappers
.
lambdaQuery
());
ztUserViews
.
stream
()
ztUserViews
.
stream
()
.
flatMap
(
ztUserView
->
userProjects
(
ztUserView
).
stream
())
.
flatMap
(
ztUserView
->
userProjects
(
ztUserView
).
stream
())
.
forEach
(
u
serProjectMapper:
:
insert
);
.
forEach
(
ksU
serProjectMapper:
:
insert
);
}
}
//------------------------private------------------------------------//
//------------------------private------------------------------------//
...
@@ -132,7 +132,7 @@ public class DataCollector {
...
@@ -132,7 +132,7 @@ public class DataCollector {
}
}
private
List
<
UserProject
>
userProjects
(
ZtUserView
ztUserView
)
{
private
List
<
UserProject
>
userProjects
(
ZtUserView
ztUserView
)
{
Long
userId
=
u
serMapper
.
selectOne
(
Wrappers
.<
User
>
lambdaQuery
().
eq
(
User:
:
getAccount
,
ztUserView
.
getAccount
())).
getId
();
Long
userId
=
ksU
serMapper
.
selectOne
(
Wrappers
.<
User
>
lambdaQuery
().
eq
(
User:
:
getAccount
,
ztUserView
.
getAccount
())).
getId
();
return
toList
(
ztUserView
.
getProjects
()).
stream
()
return
toList
(
ztUserView
.
getProjects
()).
stream
()
.
map
(
Integer:
:
parseInt
)
.
map
(
Integer:
:
parseInt
)
.
map
(
id
->
ztProjectMapper
.
selectById
(
id
))
.
map
(
id
->
ztProjectMapper
.
selectById
(
id
))
...
...
编写
预览
Markdown
格式
0%
重试
或
添加新文件
添加附件
取消
您添加了
0
人
到此讨论。请谨慎行事。
请先完成此评论的编辑!
取消
请
注册
或者
登录
后发表评论