Skip to content
Toggle navigation
P
Projects
G
Groups
S
Snippets
Help
黄嘉阳
/
iot-platform-server
This project
Loading...
Sign in
Toggle navigation
Go to a project
Project
Repository
Issues
0
Merge Requests
0
Pipelines
Wiki
Snippets
Settings
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Commit
f2fad201
authored
Sep 25, 2023
by
杨伟程
Browse files
Options
_('Browse Files')
Download
Plain Diff
Merge branch 'dev' of
http://git.xmmakeit.com/huangjiay/iot-platform-server
into dev
parents
7276fccb
702c43b6
Show whitespace changes
Inline
Side-by-side
Showing
9 changed files
with
169 additions
and
265 deletions
saas-module/src/main/java/com/makeit/controller/device/SaasDeviceReportDayController.java
saas-module/src/main/java/com/makeit/controller/device/SaasDeviceReportMonthController.java
saas-module/src/main/java/com/makeit/controller/device/SaasDeviceReportWeekController.java
server-api/src/main/java/com/makeit/api/external/filter/MyRequestWrapper.java
server-api/src/main/java/com/makeit/api/external/filter/RequestReplaceFilter.java
server-api/src/main/java/com/makeit/api/external/filter/SignAuthFilter.java
server-service/src/main/java/com/makeit/service/platform/auth/impl/PlatOrgServiceImpl.java
server-service/src/main/java/com/makeit/service/platform/auth/impl/PlatUserServiceImpl.java
server-service/src/main/java/com/makeit/service/saas/impl/PlatTenantServiceImpl.java
saas-module/src/main/java/com/makeit/controller/device/SaasDeviceReportDayController.java
View file @
f2fad201
...
...
@@ -3,13 +3,17 @@ package com.makeit.controller.device;
import
com.makeit.common.response.ApiResponseEntity
;
import
com.makeit.common.response.ApiResponseUtils
;
import
com.makeit.dto.platform.elder.PlatElderIdDTO
;
import
com.makeit.dto.platform.elder.PlatElderReportDTO
;
import
com.makeit.global.aspect.tenant.TenantIdIgnore
;
import
com.makeit.service.platform.elder.PlatElderDayReportDayService
;
import
com.makeit.vo.platform.elder.realtime.PlatElderCoordinateVO
;
import
com.makeit.vo.platform.elder.realtime.PlatElderRealTimeHeartRespiratoryVO
;
import
com.makeit.vo.platform.elder.report.day.*
;
import
com.makeit.vo.platform.elder.report.day.PlatElderBehaviorDistributionVO
;
import
com.makeit.vo.platform.elder.report.day.PlatElderBehaviorExceptionRecordVO
;
import
com.makeit.vo.platform.elder.report.day.PlatElderHeartRespiratoryEvaluationRecordVO
;
import
com.makeit.vo.platform.elder.report.day.PlatElderHeartRespiratoryEvaluationVO
;
import
com.makeit.vo.platform.elder.report.day.PlatElderSleepDiagramVO
;
import
com.makeit.vo.platform.elder.report.day.PlatElderSleepEvaluationVO
;
import
io.swagger.annotations.Api
;
import
io.swagger.annotations.ApiOperation
;
import
org.springframework.beans.factory.annotation.Autowired
;
...
...
@@ -60,15 +64,17 @@ public class SaasDeviceReportDayController {
@ApiOperation
(
"心率异常记录"
)
@PostMapping
(
"heartExceptionRecordList"
)
@TenantIdIgnore
public
ApiResponseEntity
<
List
<
PlatElderHeartRespiratoryEvaluationRecordVO
>>
heartExceptionRecordList
(
@RequestBody
PlatElderIdDTO
platElderIdDTO
)
{
return
null
;
public
ApiResponseEntity
<
List
<
PlatElderHeartRespiratoryEvaluationRecordVO
>>
heartExceptionRecordList
(
@RequestBody
PlatElderReportDTO
platElderIdDTO
)
{
return
ApiResponseUtils
.
success
(
platElderDayReportDayService
.
heartExceptionRecordList
(
platElderIdDTO
));
}
@ApiOperation
(
"呼吸率异常记录"
)
@PostMapping
(
"respiratoryExceptionRecordList"
)
@TenantIdIgnore
public
ApiResponseEntity
<
List
<
PlatElderHeartRespiratoryEvaluationRecordVO
>>
respiratoryExceptionRecordList
(
@RequestBody
PlatElderIdDTO
platElderIdDTO
)
{
return
null
;
public
ApiResponseEntity
<
List
<
PlatElderHeartRespiratoryEvaluationRecordVO
>>
respiratoryExceptionRecordList
(
@RequestBody
PlatElderReportDTO
platElderIdDTO
)
{
return
ApiResponseUtils
.
success
(
platElderDayReportDayService
.
respiratoryExceptionRecordList
(
platElderIdDTO
));
}
@ApiOperation
(
"心率呼吸率"
)
...
...
saas-module/src/main/java/com/makeit/controller/device/SaasDeviceReportMonthController.java
View file @
f2fad201
...
...
@@ -2,19 +2,24 @@ package com.makeit.controller.device;
import
com.makeit.common.response.ApiResponseEntity
;
import
com.makeit.common.response.ApiResponseUtils
;
import
com.makeit.dto.platform.elder.PlatElderReportDTO
;
import
com.makeit.global.aspect.tenant.TenantIdIgnore
;
import
com.makeit.service.platform.elder.PlatElderReportMonthService
;
import
com.makeit.vo.platform.elder.report.day.PlatElderHeartRespiratoryEvaluationVO
;
import
com.makeit.vo.platform.elder.report.day.PlatElderReportMonthVO
;
import
com.makeit.vo.platform.elder.report.day.PlatElderSleepEvaluationVO
;
import
com.makeit.vo.platform.elder.report.week.PlatElderComprehensiveEvaluationVO
;
import
io.swagger.annotations.Api
;
import
io.swagger.annotations.ApiOperation
;
import
org.springframework.beans.factory.annotation.Autowired
;
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.List
;
/**
* <p>
* 长者基本信息 前端控制器
...
...
@@ -28,18 +33,23 @@ import org.springframework.web.bind.annotation.RestController;
@RequestMapping
(
"/saas/device/report/month"
)
public
class
SaasDeviceReportMonthController
{
@Autowired
private
PlatElderReportMonthService
platElderReportMonthService
;
@ApiOperation
(
"综合评价"
)
@PostMapping
(
"comprehensiveEvaluation"
)
@TenantIdIgnore
public
ApiResponseEntity
<
PlatElderComprehensiveEvaluationVO
>
comprehensiveEvaluation
(
@RequestBody
PlatElderReportDTO
platElderIdDTO
)
{
return
null
;
return
ApiResponseUtils
.
success
(
platElderReportMonthService
.
comprehensiveEvaluation
(
platElderIdDTO
));
}
@ApiOperation
(
"睡眠评价"
)
@PostMapping
(
"sleepEvaluation"
)
@TenantIdIgnore
public
ApiResponseEntity
<
PlatElderSleepEvaluationVO
>
sleepEvaluation
(
@RequestBody
PlatElderReportDTO
platElderIdDTO
)
{
return
null
;
return
ApiResponseUtils
.
success
(
platElderReportMonthService
.
sleepEvaluation
(
platElderIdDTO
))
;
}
...
...
@@ -47,14 +57,16 @@ public class SaasDeviceReportMonthController {
@PostMapping
(
"heartRespiratoryEvaluation"
)
@TenantIdIgnore
public
ApiResponseEntity
<
PlatElderHeartRespiratoryEvaluationVO
>
heartRespiratoryEvaluation
(
@RequestBody
PlatElderReportDTO
platElderIdDTO
)
{
return
null
;
return
ApiResponseUtils
.
success
(
platElderReportMonthService
.
heartRespiratoryEvaluation
(
platElderIdDTO
));
}
@ApiOperation
(
"月报表"
)
@PostMapping
(
"reportMonth"
)
@TenantIdIgnore
public
ApiResponseEntity
<
PlatElderReportMonthVO
>
reportMonth
(
@RequestBody
PlatElderReportDTO
platElderIdDTO
)
{
return
null
;
public
ApiResponseEntity
<
List
<
PlatElderReportMonthVO
>>
reportMonth
(
@RequestBody
PlatElderReportDTO
platElderIdDTO
)
{
return
ApiResponseUtils
.
success
(
platElderReportMonthService
.
reportMonth
(
platElderIdDTO
));
}
...
...
saas-module/src/main/java/com/makeit/controller/device/SaasDeviceReportWeekController.java
View file @
f2fad201
...
...
@@ -45,63 +45,68 @@ public class SaasDeviceReportWeekController {
@PostMapping
(
"comprehensiveEvaluation"
)
@TenantIdIgnore
public
ApiResponseEntity
<
PlatElderComprehensiveEvaluationVO
>
comprehensiveEvaluation
(
@RequestBody
PlatElderReportDTO
platElderIdDTO
)
{
return
null
;
return
ApiResponseUtils
.
success
(
platElderDayReportWeekService
.
comprehensiveEvaluation
(
platElderIdDTO
))
;
}
@ApiOperation
(
"睡眠评价"
)
@PostMapping
(
"sleepEvaluation"
)
@TenantIdIgnore
public
ApiResponseEntity
<
PlatElderSleepEvaluationVO
>
sleepEvaluation
(
@RequestBody
PlatElderReportDTO
platElderIdDTO
)
{
return
null
;
return
ApiResponseUtils
.
success
(
platElderDayReportWeekService
.
sleepEvaluation
(
platElderIdDTO
))
;
}
@ApiOperation
(
"睡眠图表"
)
@PostMapping
(
"sleepDiagram"
)
@TenantIdIgnore
public
ApiResponseEntity
<
List
<
PlatElderSleepDiagramWeekVO
>
>
sleepDiagram
(
@RequestBody
PlatElderReportDTO
platElderIdDTO
)
{
return
null
;
public
ApiResponseEntity
<
PlatElderSleepDiagramWeekVO
>
sleepDiagram
(
@RequestBody
PlatElderReportDTO
platElderIdDTO
)
{
return
ApiResponseUtils
.
success
(
platElderDayReportWeekService
.
sleepDiagram
(
platElderIdDTO
))
;
}
@ApiOperation
(
"心率呼吸评价"
)
@PostMapping
(
"heartRespiratoryEvaluation"
)
@TenantIdIgnore
public
ApiResponseEntity
<
PlatElderHeartRespiratoryEvaluationVO
>
heartRespiratoryEvaluation
(
@RequestBody
PlatElderReportDTO
platElderIdDTO
)
{
return
null
;
return
ApiResponseUtils
.
success
(
platElderDayReportWeekService
.
heartRespiratoryEvaluation
(
platElderIdDTO
))
;
}
@ApiOperation
(
"心率异常记录"
)
@PostMapping
(
"heartExceptionRecordList"
)
@TenantIdIgnore
public
ApiResponseEntity
<
List
<
PlatElderHeartRespiratoryEvaluationRecordVO
>>
heartExceptionRecordList
(
@RequestBody
PlatElderReportDTO
platElderIdDTO
)
{
return
null
;
return
ApiResponseUtils
.
success
(
platElderDayReportWeekService
.
heartExceptionRecordList
(
platElderIdDTO
));
}
@ApiOperation
(
"呼吸率异常记录"
)
@PostMapping
(
"respiratoryExceptionRecordList"
)
@TenantIdIgnore
public
ApiResponseEntity
<
List
<
PlatElderHeartRespiratoryEvaluationRecordVO
>>
respiratoryExceptionRecordList
(
@RequestBody
PlatElderReportDTO
platElderIdDTO
)
{
return
null
;
return
ApiResponseUtils
.
success
(
platElderDayReportWeekService
.
respiratoryExceptionRecordList
(
platElderIdDTO
));
}
@ApiOperation
(
"心率呼吸率"
)
@PostMapping
(
"heartRespiratory"
)
@TenantIdIgnore
public
ApiResponseEntity
<
PlatElderRealTimeHeartRespiratoryWeekVO
>
heartRespiratory
(
@RequestBody
PlatElderReportDTO
platElderIdDTO
)
{
return
null
;
public
ApiResponseEntity
<
List
<
PlatElderRealTimeHeartRespiratoryWeekVO
>>
heartRespiratory
(
@RequestBody
PlatElderReportDTO
platElderIdDTO
)
{
return
ApiResponseUtils
.
success
(
platElderDayReportWeekService
.
heartRespiratory
(
platElderIdDTO
));
}
@ApiOperation
(
"行为异常记录"
)
@PostMapping
(
"behaviorExceptionRecordList"
)
@TenantIdIgnore
public
ApiResponseEntity
<
List
<
PlatElderBehaviorExceptionRecordVO
>>
behaviorExceptionRecordList
(
@RequestBody
PlatElderReportDTO
platElderIdDTO
)
{
return
null
;
return
ApiResponseUtils
.
success
(
platElderDayReportWeekService
.
behaviorExceptionRecordList
(
platElderIdDTO
));
}
@ApiOperation
(
"跌倒记录"
)
@PostMapping
(
"failRecordList"
)
@TenantIdIgnore
public
ApiResponseEntity
<
List
<
String
>>
failRecordList
(
@RequestBody
PlatElderReportDTO
platElderIdDTO
)
{
return
null
;
return
ApiResponseUtils
.
success
(
platElderDayReportWeekService
.
failRecordList
(
platElderIdDTO
));
}
@ApiOperation
(
"坐标记录"
)
...
...
@@ -115,7 +120,8 @@ public class SaasDeviceReportWeekController {
@PostMapping
(
"behaviorDistribution"
)
@TenantIdIgnore
public
ApiResponseEntity
<
List
<
PlatElderBehaviorDistributionVO
>>
behaviorDistribution
(
@RequestBody
PlatElderReportDTO
platElderIdDTO
)
{
return
null
;
return
ApiResponseUtils
.
success
(
platElderDayReportWeekService
.
behaviorDistribution
(
platElderIdDTO
));
}
}
...
...
server-api/src/main/java/com/makeit/api/external/filter/MyRequestWrapper.java
deleted
100644 → 0
View file @
7276fccb
//package com.makeit.api.external.filter;
//
//import org.apache.commons.io.IOUtils;
//
//import javax.servlet.ReadListener;
//import javax.servlet.ServletInputStream;
//import javax.servlet.http.HttpServletRequest;
//import javax.servlet.http.HttpServletRequestWrapper;
//import java.io.BufferedReader;
//import java.io.IOException;
//import java.io.InputStreamReader;
//
///**
// * @Description: 解决request.getInputStream()只能读取一次的问题
// * @PackageName: net.dlet.dhdemo.utils.dhutils
// * @Name: MyRequestWrapper
// * @Author: cure
// * @CreateDate: 2020/09/06 4:44
// * @ModifyUser:
// * @ModifyDate:
// * @ModifyDesc: 修改内容
// * @DayNameFull: 星期日
// * @ProjectName: dhdemo
// * @Version: 1.0
// **/
//public class MyRequestWrapper extends HttpServletRequestWrapper {
//
// private volatile byte[] body;
//
// public MyRequestWrapper(HttpServletRequest request) throws IOException {
// super(request);
// body = IOUtils.toByteArray(super.getInputStream());
// }
//
// public byte[] getBody() {
// return body;
// }
//
// public void setBody(byte[] body) {
// this.body = body;
// }
//
// @Override
// public BufferedReader getReader() throws IOException {
// return new BufferedReader(new InputStreamReader(getInputStream()));
// }
//
// @Override
// public ServletInputStream getInputStream() throws IOException {
// return new RequestBodyCachingInputStream(body);
// }
//
// private class RequestBodyCachingInputStream extends ServletInputStream {
// private byte[] body;
// private int lastIndexRetrieved = -1;
// private ReadListener listener;
//
// public RequestBodyCachingInputStream(byte[] body) {
// this.body = body;
// }
//
// @Override
// public int read() throws IOException {
// if (isFinished()) {
// return -1;
// }
// int i = body[lastIndexRetrieved + 1];
// lastIndexRetrieved++;
// if (isFinished() && listener != null) {
// try {
// listener.onAllDataRead();
// } catch (IOException e) {
// listener.onError(e);
// throw e;
// }
// }
// return i;
// }
//
// @Override
// public boolean isFinished() {
// return lastIndexRetrieved == body.length - 1;
// }
//
// @Override
// public boolean isReady() {
// return isFinished();
// }
//
// @Override
// public void setReadListener(ReadListener listener) {
// if (listener == null) {
// throw new IllegalArgumentException("listener cann not be null");
// }
// if (this.listener != null) {
// throw new IllegalArgumentException("listener has been set");
// }
// this.listener = listener;
// if (!isFinished()) {
// try {
// listener.onAllDataRead();
// } catch (IOException e) {
// listener.onError(e);
// }
// } else {
// try {
// listener.onAllDataRead();
// } catch (IOException e) {
// listener.onError(e);
// }
// }
// }
//
// @Override
// public int available() throws IOException {
// return body.length - lastIndexRetrieved - 1;
// }
//
// @Override
// public void close() throws IOException {
// lastIndexRetrieved = body.length - 1;
// body = null;
// }
// }
//}
\ No newline at end of file
server-api/src/main/java/com/makeit/api/external/filter/RequestReplaceFilter.java
View file @
f2fad201
//package com.makeit.api.external.filter;
//
//import org.springframework.stereotype.Component;
//import org.springframework.web.filter.OncePerRequestFilter;
//
//import javax.servlet.FilterChain;
//import javax.servlet.ServletException;
//import javax.servlet.http.HttpServletRequest;
//import javax.servlet.http.HttpServletResponse;
//import java.io.IOException;
//
///**
// * @Description:
// * @PackageName: net.dlet.dhdemo.configure
// * @Name: RequestReplaceFilter
// * @Author: cure
// * @CreateDate: 2020/09/06 4:58
// * @ModifyUser:
// * @ModifyDate:
// * @ModifyDesc: 修改内容
// * @DayNameFull: 星期日
// * @ProjectName: dhdemo
// * @Version: 1.0
// **/
//@Component
//public class RequestReplaceFilter extends OncePerRequestFilter {
//
// @Override
// protected void doFilterInternal(HttpServletRequest request,
// HttpServletResponse response,
// FilterChain filterChain) throws ServletException, IOException {
// if (!(request instanceof MyRequestWrapper)) {
// request = new MyRequestWrapper(request);
// }
// filterChain.doFilter(request, response);
// }
//}
//
//
\ No newline at end of file
/*
package com.makeit.api.external.filter;
import org.springframework.stereotype.Component;
import org.springframework.web.filter.OncePerRequestFilter;
import javax.servlet.FilterChain;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
*/
/**
* @Description:
* @PackageName: net.dlet.dhdemo.configure
* @Name: RequestReplaceFilter
* @Author: cure
* @CreateDate: 2020/09/06 4:58
* @ModifyUser:
* @ModifyDate:
* @ModifyDesc: 修改内容
* @DayNameFull: 星期日
* @ProjectName: dhdemo
* @Version: 1.0
**//*
@Component
public class RequestReplaceFilter extends OncePerRequestFilter {
@Override
protected void doFilterInternal(HttpServletRequest request,
HttpServletResponse response,
FilterChain filterChain) throws ServletException, IOException {
if (!(request instanceof MyRequestWrapper)) {
request = new MyRequestWrapper(request);
}
filterChain.doFilter(request, response);
}
}
*/
server-api/src/main/java/com/makeit/api/external/filter/SignAuthFilter.java
View file @
f2fad201
//
package com.makeit.api.external.filter;
//
//
import com.makeit.api.external.util.RSAUtils;
//
import com.makeit.utils.old.StringUtils;
//
import org.slf4j.Logger;
//
import org.slf4j.LoggerFactory;
//
//
import javax.servlet.*;
//
import javax.servlet.annotation.WebFilter;
//
import javax.servlet.http.HttpServletRequest;
//
import javax.servlet.http.HttpServletResponse;
//
import java.io.IOException;
//
import java.nio.charset.StandardCharsets;
//
//
//
@WebFilter(urlPatterns = { "/iot/external/*"})
//
public class SignAuthFilter implements Filter {
//
//
private static Logger logger = LoggerFactory.getLogger(SignAuthFilter.class);
//
//
//
//
@Override
//
public void init(FilterConfig filterConfig) {
//
}
//
//
@Override
//
public void doFilter(ServletRequest req, ServletResponse res, FilterChain chain)
//
throws IOException {
//
HttpServletRequest request = (HttpServletRequest) req;
//
HttpServletResponse response = (HttpServletResponse) res;
//
try {
//
String sign = request.getHeader("sign");
//
if (StringUtils.isEmpty(sign)) {
//
response.sendError(403, "Forbidden");
//
return;
//
}
//
logger.info("getted Authorization is ---> " + sign);
//
//
// 获取客户端ip
/
//
* String ip = IpUtil.getIpAddr(request);
//
logger.info("getted ip is ---> " + ip);*/
//
//
MyRequestWrapper requestWrapper = new MyRequestWrapper(request);
//
String bodyString = new String(requestWrapper.getBody(), StandardCharsets.UTF_8);
//
logger.info("getted requestbody data is ---> " + bodyString);
//
//
String decryptJson = RSAUtils.privateDecrypt(sign, RSAUtils.getPrivateKey(RSAUtils.PRIVATE_KEY), "UTF-8");
//
//
boolean couldPass = decryptJson.equals(bodyString);
//
if (couldPass) {
//
// 放行
//
chain.doFilter(requestWrapper, response);
//
return;
//
}
//
response.sendError(403, "Forbidden");
//
} catch (Exception e) {
//
logger.error("验证失败: -> " + e.getMessage(), e);
//
response.sendError(403, "Forbidden");
//
}
//
}
//
//
@Override
//
public void destroy() {
//
//
}
//
//
}
//
package
com
.
makeit
.
api
.
external
.
filter
;
import
com.makeit.api.external.util.RSAUtils
;
import
com.makeit.utils.old.StringUtils
;
import
org.slf4j.Logger
;
import
org.slf4j.LoggerFactory
;
import
javax.servlet.*
;
import
javax.servlet.annotation.WebFilter
;
import
javax.servlet.http.HttpServletRequest
;
import
javax.servlet.http.HttpServletResponse
;
import
java.io.IOException
;
import
java.nio.charset.StandardCharsets
;
@WebFilter
(
urlPatterns
=
{
"/iot/external/*"
})
public
class
SignAuthFilter
implements
Filter
{
private
static
Logger
logger
=
LoggerFactory
.
getLogger
(
SignAuthFilter
.
class
);
@Override
public
void
init
(
FilterConfig
filterConfig
)
{
}
@Override
public
void
doFilter
(
ServletRequest
req
,
ServletResponse
res
,
FilterChain
chain
)
throws
IOException
{
HttpServletRequest
request
=
(
HttpServletRequest
)
req
;
HttpServletResponse
response
=
(
HttpServletResponse
)
res
;
try
{
String
sign
=
request
.
getHeader
(
"sign"
);
if
(
StringUtils
.
isEmpty
(
sign
))
{
response
.
sendError
(
403
,
"Forbidden"
);
return
;
}
logger
.
info
(
"getted Authorization is ---> "
+
sign
);
// 获取客户端ip
/* String ip = IpUtil.getIpAddr(request);
logger.info("getted ip is ---> " + ip);*/
MyRequestWrapper
requestWrapper
=
new
MyRequestWrapper
(
request
);
String
bodyString
=
new
String
(
requestWrapper
.
getBody
(),
StandardCharsets
.
UTF_8
);
logger
.
info
(
"getted requestbody data is ---> "
+
bodyString
);
String
decryptJson
=
RSAUtils
.
privateDecrypt
(
sign
,
RSAUtils
.
getPrivateKey
(
RSAUtils
.
PRIVATE_KEY
),
"UTF-8"
);
boolean
couldPass
=
decryptJson
.
equals
(
bodyString
);
if
(
couldPass
)
{
// 放行
chain
.
doFilter
(
requestWrapper
,
response
);
return
;
}
response
.
sendError
(
403
,
"Forbidden"
);
}
catch
(
Exception
e
)
{
logger
.
error
(
"验证失败: -> "
+
e
.
getMessage
(),
e
);
response
.
sendError
(
403
,
"Forbidden"
);
}
}
@Override
public
void
destroy
()
{
}
}
server-service/src/main/java/com/makeit/service/platform/auth/impl/PlatOrgServiceImpl.java
View file @
f2fad201
...
...
@@ -11,6 +11,7 @@ import com.makeit.common.page.PageReqDTO;
import
com.makeit.common.page.PageVO
;
import
com.makeit.dto.platform.auth.PlatOrgSplitDTO
;
import
com.makeit.entity.platform.auth.PlatOrg
;
import
com.makeit.entity.platform.auth.PlatRole
;
import
com.makeit.entity.platform.auth.PlatRoleOrg
;
import
com.makeit.entity.platform.auth.PlatUserRole
;
import
com.makeit.entity.platform.space.PlatSpace
;
...
...
@@ -46,6 +47,7 @@ import java.util.HashSet;
import
java.util.List
;
import
java.util.Map
;
import
java.util.Objects
;
import
java.util.Optional
;
import
java.util.Set
;
import
java.util.function.BiConsumer
;
import
java.util.function.Function
;
...
...
@@ -436,9 +438,9 @@ public class PlatOrgServiceImpl extends ServiceImpl<PlatOrgMapper, PlatOrg>
if
(
CollectionUtils
.
isEmpty
(
roleOrgList
))
{
return
new
HashSet
<>();
}
return
roleOrgList
.
stream
().
map
(
PlatRoleOrg:
:
getOrgId
).
collect
(
Collectors
.
toSet
());
//
List<PlatRole> roleList = platRoleService.listByIds(roleOrgList.stream().map(PlatRoleOrg::getRoleId).collect(Collectors.toList()));
//
return roleList.stream().flatMap(vo -> Stream.of(Optional.ofNullable(vo.getDataScope()).orElse(new String()) .split(","))).collect(Collectors.toSet());
//
return roleOrgList.stream().map(PlatRoleOrg::getOrgId).collect(Collectors.toSet());
List
<
PlatRole
>
roleList
=
platRoleService
.
listByIds
(
roleOrgList
.
stream
().
map
(
PlatRoleOrg:
:
getRoleId
).
collect
(
Collectors
.
toList
()));
return
roleList
.
stream
().
flatMap
(
vo
->
Stream
.
of
(
Optional
.
ofNullable
(
vo
.
getDataScope
()).
orElse
(
new
String
())
.
split
(
","
))).
collect
(
Collectors
.
toSet
());
}
/**
* 租户权限的组织树
...
...
@@ -593,7 +595,7 @@ public class PlatOrgServiceImpl extends ServiceImpl<PlatOrgMapper, PlatOrg>
vo
.
setChildren
(
parentMap
.
get
(
vo
.
getId
()));
});
return
orgList
.
stream
().
filter
(
vo
->
StringUtils
.
equals
(
vo
.
getParentId
(),
"1"
)).
collect
(
Collectors
.
toList
());
return
orgList
.
stream
().
filter
(
vo
->
StringUtils
.
equals
(
vo
.
getParentId
(),
TreeConst
.
TOP_LEVEL
)).
collect
(
Collectors
.
toList
());
}
/**
...
...
server-service/src/main/java/com/makeit/service/platform/auth/impl/PlatUserServiceImpl.java
View file @
f2fad201
...
...
@@ -32,6 +32,7 @@ import com.makeit.enums.CodeMessageEnum;
import
com.makeit.enums.CommonEnum
;
import
com.makeit.enums.IsTenantAccountEnum
;
import
com.makeit.enums.biz.auth.SysEnum
;
import
com.makeit.enums.id.TreeConst
;
import
com.makeit.exception.BusinessException
;
import
com.makeit.global.aspect.tenant.TenantIdIgnore
;
import
com.makeit.global.aspect.tenant.TenantIdUtil
;
...
...
@@ -1060,7 +1061,7 @@ public class PlatUserServiceImpl extends ServiceImpl<PlatUserMapper, PlatUser>
LambdaUpdateWrapper
<
PlatUser
>
updateWrapper
=
Wrappers
.
lambdaUpdate
(
PlatUser
.
class
)
.
set
(
PlatUser:
:
getTenantId
,
tenantId
)
.
set
(
PlatUser:
:
getOrgId
,
tenantId
)
.
set
(
PlatUser:
:
getOrgPath
,
"1
,"
+
tenantId
)
.
set
(
PlatUser:
:
getOrgPath
,
TreeConst
.
TOP_LEVEL
+
"
,"
+
tenantId
)
.
eq
(
BaseEntity:
:
getId
,
platUserId
);
this
.
update
(
updateWrapper
);
}
...
...
server-service/src/main/java/com/makeit/service/saas/impl/PlatTenantServiceImpl.java
View file @
f2fad201
...
...
@@ -15,6 +15,7 @@ import com.makeit.entity.saas.PlatTenantMenu;
import
com.makeit.enums.CodeMessageEnum
;
import
com.makeit.enums.CommonEnum
;
import
com.makeit.enums.IsTenantAccountEnum
;
import
com.makeit.enums.id.TreeConst
;
import
com.makeit.enums.redis.RedisConst
;
import
com.makeit.exception.BusinessException
;
import
com.makeit.global.aspect.tenant.TenantIdIgnore
;
...
...
@@ -315,9 +316,9 @@ public class PlatTenantServiceImpl extends ServiceImpl<PlatTenantMapper, PlatTen
platOrg
.
setName
(
platTenant
.
getName
());
platOrg
.
setStatus
(
platTenant
.
getStatus
());
platOrg
.
setId
(
platTenant
.
getId
());
platOrg
.
setPath
(
"1"
);
platOrg
.
setPath
(
TreeConst
.
TOP_LEVEL
);
//租户没有父级
platOrg
.
setParentId
(
"1"
);
platOrg
.
setParentId
(
TreeConst
.
TOP_LEVEL
);
return
platOrg
;
}
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment