Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
O
operation-control-platform
Project overview
Project overview
Details
Activity
Releases
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Issues
0
Issues
0
List
Boards
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Analytics
Analytics
CI / CD
Repository
Value Stream
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
王锦盛
operation-control-platform
Commits
43a54a8b
Commit
43a54a8b
authored
Mar 12, 2022
by
王锦盛
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
结构调整222222
parent
c8e3209f
Changes
15
Hide whitespace changes
Inline
Side-by-side
Showing
15 changed files
with
170 additions
and
80 deletions
+170
-80
src/main/java/com/pms/ocp/common/aspectj/OperLogAspect.java
src/main/java/com/pms/ocp/common/aspectj/OperLogAspect.java
+11
-12
src/main/java/com/pms/ocp/controller/ModelBaseController.java
...main/java/com/pms/ocp/controller/ModelBaseController.java
+26
-21
src/main/java/com/pms/ocp/mapper/ModelAuditMapper.java
src/main/java/com/pms/ocp/mapper/ModelAuditMapper.java
+2
-3
src/main/java/com/pms/ocp/mapper/ModelSubscribeMapper.java
src/main/java/com/pms/ocp/mapper/ModelSubscribeMapper.java
+2
-2
src/main/java/com/pms/ocp/model/dto/ModelSubscribeDTO.java
src/main/java/com/pms/ocp/model/dto/ModelSubscribeDTO.java
+1
-1
src/main/java/com/pms/ocp/model/entity/ModelAudit.java
src/main/java/com/pms/ocp/model/entity/ModelAudit.java
+1
-1
src/main/java/com/pms/ocp/model/entity/ModelClassify.java
src/main/java/com/pms/ocp/model/entity/ModelClassify.java
+2
-1
src/main/java/com/pms/ocp/model/entity/ModelProperty.java
src/main/java/com/pms/ocp/model/entity/ModelProperty.java
+2
-1
src/main/java/com/pms/ocp/model/entity/ModelRelation.java
src/main/java/com/pms/ocp/model/entity/ModelRelation.java
+2
-1
src/main/java/com/pms/ocp/model/entity/ModelSubscribe.java
src/main/java/com/pms/ocp/model/entity/ModelSubscribe.java
+5
-4
src/main/java/com/pms/ocp/model/vo/ModelAuditVO.java
src/main/java/com/pms/ocp/model/vo/ModelAuditVO.java
+2
-2
src/main/java/com/pms/ocp/service/ModelAuditService.java
src/main/java/com/pms/ocp/service/ModelAuditService.java
+8
-8
src/main/java/com/pms/ocp/service/ModelSubscribeService.java
src/main/java/com/pms/ocp/service/ModelSubscribeService.java
+9
-9
src/main/java/com/pms/ocp/service/impl/ModelAuditServiceImpl.java
.../java/com/pms/ocp/service/impl/ModelAuditServiceImpl.java
+13
-14
src/main/java/com/pms/ocp/service/impl/ModelSubscribeServiceImpl.java
...a/com/pms/ocp/service/impl/ModelSubscribeServiceImpl.java
+84
-0
No files found.
src/main/java/com/pms/ocp/common/aspectj/OperLogAspect.java
View file @
43a54a8b
...
...
@@ -2,9 +2,8 @@ package com.pms.ocp.common.aspectj;
import
com.alibaba.fastjson.JSONObject
;
import
com.alibaba.fastjson.serializer.PropertyFilter
;
import
com.pms.ocp.model.entity.ModelNote
;
import
com.pms.ocp.service.ModelNoteService
;
import
com.sun.xml.internal.bind.v2.TODO
;
import
com.pms.ocp.model.entity.ModelAudit
;
import
com.pms.ocp.service.ModelAuditService
;
import
org.apache.commons.lang3.StringUtils
;
import
org.aspectj.lang.JoinPoint
;
import
org.aspectj.lang.ProceedingJoinPoint
;
...
...
@@ -39,7 +38,7 @@ import java.time.LocalDateTime;
public
class
OperLogAspect
{
@Autowired
private
Model
NoteService
modelNote
Service
;
private
Model
AuditService
modelAudit
Service
;
private
static
Logger
logger
=
LoggerFactory
.
getLogger
(
OperLogAspect
.
class
);
...
...
@@ -65,25 +64,25 @@ public class OperLogAspect {
private
void
saveSysLog
(
ProceedingJoinPoint
point
,
long
time
,
Object
obj
)
{
MethodSignature
signature
=
(
MethodSignature
)
point
.
getSignature
();
Method
method
=
signature
.
getMethod
();
Model
Note
modelNote
=
new
ModelNote
();
Model
Audit
modelAudit
=
new
ModelAudit
();
OperLog
operLog
=
method
.
getAnnotation
(
OperLog
.
class
);
if
(
operLog
!=
null
)
{
String
content
=
operLog
.
value
();
model
Note
.
setAuditType
(
operLog
.
auditType
());
model
Note
.
setAuditMessageJson
(
content
);
model
Audit
.
setAuditType
(
operLog
.
auditType
());
model
Audit
.
setAuditMessageJson
(
content
);
}
//请求的方法名
// String className = point.getTarget().getClass().getName();
String
methodName
=
signature
.
getName
();
// dto.setMethod(className + "." + methodName + "()");
//设置操作类型
if
(
model
Note
.
getAuditType
()
==
3
)
{
model
Note
.
setOperStatus
(
getOperateType
(
methodName
,
operLog
.
operStatus
()));
if
(
model
Audit
.
getAuditType
()
==
3
)
{
model
Audit
.
setOperStatus
(
getOperateType
(
methodName
,
operLog
.
operStatus
()));
}
//获取request
HttpServletRequest
request
=
getHttpServletRequest
();
//请求的参数
model
Note
.
setAuditMessageJson
(
getRequestParams
(
request
,
point
));
model
Audit
.
setAuditMessageJson
(
getRequestParams
(
request
,
point
));
// //设置ip地址
// dto.setIp(getIpAddr(request));
//获取用户登录信息
...
...
@@ -94,9 +93,9 @@ public class OperLogAspect {
// modelNote.setUsername(user.getPassWord());
// }
// modelNote.setCostTime(time);
model
Note
.
setAuditCtime
(
LocalDateTime
.
now
());
model
Audit
.
setAuditCtime
(
LocalDateTime
.
now
());
model
NoteService
.
createModelNote
(
modelNote
);
model
AuditService
.
createModelNote
(
modelAudit
);
}
private
int
getOperateType
(
String
methodName
,
int
operateType
)
{
...
...
src/main/java/com/pms/ocp/controller/ModelBaseController.java
View file @
43a54a8b
...
...
@@ -4,19 +4,19 @@ import com.github.pagehelper.PageHelper;
import
com.github.pagehelper.PageInfo
;
import
com.pms.ocp.common.utils.ExcelUtils
;
import
com.pms.ocp.model.dto.ModelDTO
;
import
com.pms.ocp.model.dto.Model
Issu
eDTO
;
import
com.pms.ocp.model.dto.Model
Subscrib
eDTO
;
import
com.pms.ocp.model.dto.ModelPropertyDTO
;
import
com.pms.ocp.model.dto.ModelRelationDTO
;
import
com.pms.ocp.model.entity.Model
;
import
com.pms.ocp.model.entity.ModelNote
;
import
com.pms.ocp.model.entity.ModelNoteVO
;
import
com.pms.ocp.model.entity.ModelSubscribe
;
import
com.pms.ocp.model.entity.ModelAudit
;
import
com.pms.ocp.model.vo.ModelAuditVO
;
import
com.pms.ocp.model.vo.ResponseVO
;
import
com.pms.ocp.service.*
;
import
io.swagger.annotations.Api
;
import
io.swagger.annotations.ApiOperation
;
import
io.swagger.annotations.ApiParam
;
import
lombok.extern.slf4j.Slf4j
;
import
org.apache.commons.lang3.StringUtils
;
import
org.springframework.beans.BeanUtils
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.web.bind.annotation.*
;
...
...
@@ -27,8 +27,6 @@ import java.io.IOException;
import
java.util.List
;
import
java.util.stream.Collectors
;
import
static
com
.
pms
.
ocp
.
common
.
constants
.
CodeEnum
.
REQUIRED_PARAMETER_EMPTY
;
/**
* @Auther: wangjian
* @Date: 2022/2/21 16:17
...
...
@@ -48,10 +46,10 @@ public class ModelBaseController {
private
ModelPropertyService
modelPropertyService
;
@Autowired
private
Model
NoteService
modelNote
Service
;
private
Model
AuditService
modelAudit
Service
;
@Autowired
private
Model
IssueService
modelIssu
eService
;
private
Model
SubscribeService
modelSubscrib
eService
;
@Autowired
private
ModelRelationService
modelRelationService
;
...
...
@@ -81,8 +79,8 @@ public class ModelBaseController {
@ApiParam
(
value
=
"每页数量"
)
@RequestParam
(
value
=
"pageSize"
,
required
=
false
)
Integer
pageSize
)
{
PageHelper
.
startPage
(
currentPage
,
pageSize
);
List
<
Model
>
opsVO
List
=
modelService
.
getModelList
(
objId
,
modelCode
);
PageInfo
<
Model
>
pageInfo
=
new
PageInfo
<>(
opsVO
List
);
List
<
Model
>
model
List
=
modelService
.
getModelList
(
objId
,
modelCode
);
PageInfo
<
Model
>
pageInfo
=
new
PageInfo
<>(
model
List
);
return
ResponseVO
.
ok
(
pageInfo
);
}
...
...
@@ -151,8 +149,8 @@ public class ModelBaseController {
*/
@ApiOperation
(
"模型订阅-增加"
)
@PostMapping
(
"/create/model/subscribe"
)
public
ResponseVO
createModelSubscribe
(
@RequestBody
Model
IssueDTO
modelIssu
eDTO
)
{
return
ResponseVO
.
ok
(
model
IssueService
.
createModelIssue
(
modelIssu
eDTO
));
public
ResponseVO
createModelSubscribe
(
@RequestBody
Model
SubscribeDTO
modelSubscrib
eDTO
)
{
return
ResponseVO
.
ok
(
model
SubscribeService
.
createModelIssue
(
modelSubscrib
eDTO
));
}
/**
...
...
@@ -163,7 +161,7 @@ public class ModelBaseController {
@ApiOperation
(
"模型订阅-删除/批量删除"
)
@PostMapping
(
"/delete/model/subscribe"
)
public
ResponseVO
deleteModelSubscribe
(
@ApiParam
(
value
=
"订阅编号集合"
)
@RequestBody
List
<
String
>
ids
)
{
return
ResponseVO
.
ok
(
model
Issu
eService
.
deleteBatchModelIssue
(
ids
));
return
ResponseVO
.
ok
(
model
Subscrib
eService
.
deleteBatchModelIssue
(
ids
));
}
/**
...
...
@@ -175,8 +173,15 @@ public class ModelBaseController {
@GetMapping
(
"/get/model/subscribe"
)
public
ResponseVO
getModelSubscribe
(
@ApiParam
(
value
=
"模型订阅编号"
)
@RequestParam
(
value
=
"objId"
,
required
=
false
)
String
objId
,
@ApiParam
(
value
=
"模型编码"
)
@RequestParam
(
value
=
"modelCode"
,
required
=
false
)
String
modelCode
,
@ApiParam
(
value
=
"订阅公司编码"
)
@RequestParam
(
value
=
"subsCompanyCode"
,
required
=
false
)
String
subsCompanyCode
)
{
return
ResponseVO
.
ok
(
modelIssueService
.
getModelIssueList
(
objId
,
modelCode
,
subsCompanyCode
));
@ApiParam
(
value
=
"订阅公司编码"
)
@RequestParam
(
value
=
"subsCompanyCode"
,
required
=
false
)
String
subsCompanyCode
,
@ApiParam
(
value
=
"当前页"
)
@RequestParam
(
value
=
"currentPage"
,
required
=
false
)
Integer
currentPage
,
@ApiParam
(
value
=
"每页数量"
)
@RequestParam
(
value
=
"pageSize"
,
required
=
false
)
Integer
pageSize
)
{
PageHelper
.
startPage
(
currentPage
,
pageSize
);
List
<
ModelSubscribe
>
modelSubscribeList
=
modelSubscribeService
.
getModelIssueList
(
objId
,
modelCode
,
subsCompanyCode
);
PageInfo
<
ModelSubscribe
>
pageInfo
=
new
PageInfo
<>(
modelSubscribeList
);
return
ResponseVO
.
ok
(
pageInfo
);
}
/**
...
...
@@ -188,9 +193,9 @@ public class ModelBaseController {
@GetMapping
(
"/get/model/note"
)
public
ResponseVO
getModelNote
(
@RequestParam
(
value
=
"modelCode"
)
String
modelCode
)
{
List
<
Model
Note
>
modelNoteList
=
modelNote
Service
.
getModelNoteList
(
modelCode
);
List
<
Model
Audit
>
modelAuditList
=
modelAudit
Service
.
getModelNoteList
(
modelCode
);
return
ResponseVO
.
ok
(
model
Note
List
);
return
ResponseVO
.
ok
(
model
Audit
List
);
}
/**
...
...
@@ -214,16 +219,16 @@ public class ModelBaseController {
public
ResponseVO
exportModelNote
(
HttpServletResponse
response
,
@ApiParam
(
value
=
"模型编码"
)
@RequestParam
(
value
=
"modelCode"
,
required
=
false
)
String
modelCode
)
throws
IOException
{
// 查询要导出的数据
List
<
Model
Note
>
modelNoteList
=
modelNote
Service
.
getModelNoteList
(
modelCode
);
List
<
Model
Audit
>
modelAuditList
=
modelAudit
Service
.
getModelNoteList
(
modelCode
);
//users集合转成export集合
List
<
Model
NoteVO
>
exportVOList
=
modelNote
List
.
stream
().
map
(
modelNote
->
{
Model
NoteVO
vo
=
new
ModelNote
VO
();
List
<
Model
AuditVO
>
exportVOList
=
modelAudit
List
.
stream
().
map
(
modelNote
->
{
Model
AuditVO
vo
=
new
ModelAudit
VO
();
BeanUtils
.
copyProperties
(
modelNote
,
vo
);
return
vo
;
}).
collect
(
Collectors
.
toList
());
ExcelUtils
.
exportExcel
(
response
,
"测试导出模型事记"
,
"测试导出模型事记"
,
"测试导出模型事记.xlsx"
,
exportVOList
,
Model
Note
VO
.
class
);
ExcelUtils
.
exportExcel
(
response
,
"测试导出模型事记"
,
"测试导出模型事记"
,
"测试导出模型事记.xlsx"
,
exportVOList
,
Model
Audit
VO
.
class
);
return
ResponseVO
.
ok
();
}
...
...
src/main/java/com/pms/ocp/mapper/Model
Note
Mapper.java
→
src/main/java/com/pms/ocp/mapper/Model
Audit
Mapper.java
View file @
43a54a8b
package
com.pms.ocp.mapper
;
import
com.baomidou.mybatisplus.core.mapper.BaseMapper
;
import
com.pms.ocp.model.entity.Model
;
import
com.pms.ocp.model.entity.ModelNote
;
import
com.pms.ocp.model.entity.ModelAudit
;
import
org.apache.ibatis.annotations.Mapper
;
/**
...
...
@@ -12,5 +11,5 @@ import org.apache.ibatis.annotations.Mapper;
*/
@Mapper
public
interface
Model
NoteMapper
extends
BaseMapper
<
ModelNote
>
{
public
interface
Model
AuditMapper
extends
BaseMapper
<
ModelAudit
>
{
}
src/main/java/com/pms/ocp/mapper/Model
Issu
eMapper.java
→
src/main/java/com/pms/ocp/mapper/Model
Subscrib
eMapper.java
View file @
43a54a8b
package
com.pms.ocp.mapper
;
import
com.baomidou.mybatisplus.core.mapper.BaseMapper
;
import
com.pms.ocp.model.entity.Model
Issu
e
;
import
com.pms.ocp.model.entity.Model
Subscrib
e
;
import
org.apache.ibatis.annotations.Mapper
;
/**
...
...
@@ -11,5 +11,5 @@ import org.apache.ibatis.annotations.Mapper;
*/
@Mapper
public
interface
Model
IssueMapper
extends
BaseMapper
<
ModelIssu
e
>
{
public
interface
Model
SubscribeMapper
extends
BaseMapper
<
ModelSubscrib
e
>
{
}
src/main/java/com/pms/ocp/model/dto/Model
Issu
eDTO.java
→
src/main/java/com/pms/ocp/model/dto/Model
Subscrib
eDTO.java
View file @
43a54a8b
...
...
@@ -16,7 +16,7 @@ import java.time.LocalDateTime;
@ApiModel
(
value
=
"模型订阅DTO对象"
)
@Data
public
class
Model
Issu
eDTO
{
public
class
Model
Subscrib
eDTO
{
/**
* 模型属性编号
...
...
src/main/java/com/pms/ocp/model/entity/Model
Note
.java
→
src/main/java/com/pms/ocp/model/entity/Model
Audit
.java
View file @
43a54a8b
...
...
@@ -15,7 +15,7 @@ import java.time.LocalDateTime;
@Data
@TableName
(
"ocp_model_audit"
)
public
class
Model
Note
{
public
class
Model
Audit
{
@TableId
(
value
=
"obj_id"
,
type
=
IdType
.
ASSIGN_ID
)
private
String
objId
;
...
...
src/main/java/com/pms/ocp/model/entity/ModelClassify.java
View file @
43a54a8b
package
com.pms.ocp.model.entity
;
import
com.baomidou.mybatisplus.annotation.IdType
;
import
com.baomidou.mybatisplus.annotation.TableField
;
import
com.baomidou.mybatisplus.annotation.TableId
;
import
com.baomidou.mybatisplus.annotation.TableName
;
...
...
@@ -23,7 +24,7 @@ public class ModelClassify {
/**
* 模型分类编号
*/
@TableId
@TableId
(
value
=
"obj_id"
,
type
=
IdType
.
ASSIGN_ID
)
private
String
objId
;
/**
...
...
src/main/java/com/pms/ocp/model/entity/ModelProperty.java
View file @
43a54a8b
package
com.pms.ocp.model.entity
;
import
com.baomidou.mybatisplus.annotation.IdType
;
import
com.baomidou.mybatisplus.annotation.TableField
;
import
com.baomidou.mybatisplus.annotation.TableId
;
import
com.baomidou.mybatisplus.annotation.TableName
;
...
...
@@ -27,7 +28,7 @@ public class ModelProperty{
/**
* 模型属性编号
*/
@TableId
@TableId
(
value
=
"obj_id"
,
type
=
IdType
.
ASSIGN_ID
)
private
String
objId
;
/**
...
...
src/main/java/com/pms/ocp/model/entity/ModelRelation.java
View file @
43a54a8b
package
com.pms.ocp.model.entity
;
import
com.baomidou.mybatisplus.annotation.IdType
;
import
com.baomidou.mybatisplus.annotation.TableField
;
import
com.baomidou.mybatisplus.annotation.TableId
;
import
com.baomidou.mybatisplus.annotation.TableName
;
...
...
@@ -25,7 +26,7 @@ public class ModelRelation {
* 模型关系编号
* 主键
*/
@TableId
(
value
=
"obj_id"
)
@TableId
(
value
=
"obj_id"
,
type
=
IdType
.
ASSIGN_ID
)
private
String
objId
;
/**
...
...
src/main/java/com/pms/ocp/model/entity/Model
Issu
e.java
→
src/main/java/com/pms/ocp/model/entity/Model
Subscrib
e.java
View file @
43a54a8b
package
com.pms.ocp.model.entity
;
import
com.baomidou.mybatisplus.annotation.IdType
;
import
com.baomidou.mybatisplus.annotation.TableId
;
import
com.baomidou.mybatisplus.annotation.TableName
;
import
com.fasterxml.jackson.annotation.JsonFormat
;
...
...
@@ -19,12 +20,12 @@ import java.util.Date;
@Data
@Accessors
(
chain
=
true
)
@TableName
(
"ocp_model_subs"
)
public
class
Model
Issu
e
{
public
class
Model
Subscrib
e
{
/**
* 模型订阅编号
*/
@TableId
(
value
=
"obj_id"
)
@TableId
(
value
=
"obj_id"
,
type
=
IdType
.
ASSIGN_ID
)
private
String
objId
;
/**
...
...
@@ -56,14 +57,14 @@ public class ModelIssue {
* 订阅时间
*/
@DateTimeFormat
(
pattern
=
"yyyy-MM-dd HH:mm:ss"
)
@JsonFormat
(
pattern
=
"yyyy-MM-dd HH:mm:ss"
,
timezone
=
"GMT+8"
)
@JsonFormat
(
pattern
=
"yyyy-MM-dd HH:mm:ss"
,
timezone
=
"GMT+8"
)
private
LocalDateTime
subsCtime
;
/**
* 修改时间
*/
@DateTimeFormat
(
pattern
=
"yyyy-MM-dd HH:mm:ss"
)
@JsonFormat
(
pattern
=
"yyyy-MM-dd HH:mm:ss"
,
timezone
=
"GMT+8"
)
@JsonFormat
(
pattern
=
"yyyy-MM-dd HH:mm:ss"
,
timezone
=
"GMT+8"
)
private
LocalDateTime
subsMtime
;
}
...
...
src/main/java/com/pms/ocp/model/
entity/ModelNote
VO.java
→
src/main/java/com/pms/ocp/model/
vo/ModelAudit
VO.java
View file @
43a54a8b
package
com.pms.ocp.model.
entity
;
package
com.pms.ocp.model.
vo
;
import
com.baomidou.mybatisplus.annotation.IdType
;
import
com.baomidou.mybatisplus.annotation.TableId
;
...
...
@@ -17,7 +17,7 @@ import java.time.LocalDateTime;
@ApiModel
(
value
=
"模型事记VO对象"
)
@Data
public
class
Model
Note
VO
{
public
class
Model
Audit
VO
{
/**
* 模型事记编号
...
...
src/main/java/com/pms/ocp/service/Model
Note
Service.java
→
src/main/java/com/pms/ocp/service/Model
Audit
Service.java
View file @
43a54a8b
package
com.pms.ocp.service
;
import
com.pms.ocp.model.entity.Model
Note
;
import
com.pms.ocp.model.entity.Model
Audit
;
import
java.util.List
;
...
...
@@ -10,15 +10,15 @@ import java.util.List;
* @Description:模型事记业务层接口
*/
public
interface
Model
Note
Service
{
public
interface
Model
Audit
Service
{
/**
* 创建模型事记
*
* @param model
Note
* @param model
Audit
* @return
*/
Integer
createModelNote
(
Model
Note
modelNote
);
Integer
createModelNote
(
Model
Audit
modelAudit
);
/**
* 删除模型事记
...
...
@@ -31,10 +31,10 @@ public interface ModelNoteService {
/**
* 更新模型事记
*
* @param model
Note
* @param model
Audit
* @return
*/
Integer
updateModelNote
(
Model
Note
modelNote
);
Integer
updateModelNote
(
Model
Audit
modelAudit
);
/**
* 获取模型事记
...
...
@@ -42,7 +42,7 @@ public interface ModelNoteService {
* @param
* @return
*/
List
<
Model
Note
>
getModelNoteList
(
String
modelCode
);
List
<
Model
Audit
>
getModelNoteList
(
String
modelCode
);
/**
* 获取模型事记列表
...
...
@@ -50,7 +50,7 @@ public interface ModelNoteService {
* @param modelId
* @return
*/
Model
Note
getModelNote
(
String
modelId
);
Model
Audit
getModelNote
(
String
modelId
);
// /**
// * 获取模型事记
...
...
src/main/java/com/pms/ocp/service/Model
Issu
eService.java
→
src/main/java/com/pms/ocp/service/Model
Subscrib
eService.java
View file @
43a54a8b
package
com.pms.ocp.service
;
import
com.pms.ocp.model.dto.Model
Issu
eDTO
;
import
com.pms.ocp.model.entity.Model
Issu
e
;
import
com.pms.ocp.model.dto.Model
Subscrib
eDTO
;
import
com.pms.ocp.model.entity.Model
Subscrib
e
;
import
java.util.List
;
...
...
@@ -10,15 +10,15 @@ import java.util.List;
* @Date: 2022/2/22 16:07
* @Description:模型订阅业务层接口
*/
public
interface
Model
Issu
eService
{
public
interface
Model
Subscrib
eService
{
/**
* 创建模型订阅
*
* @param model
Issu
eDTO
* @param model
Subscrib
eDTO
* @return
*/
Integer
createModelIssue
(
Model
IssueDTO
modelIssu
eDTO
);
Integer
createModelIssue
(
Model
SubscribeDTO
modelSubscrib
eDTO
);
/**
* 删除模型订阅
...
...
@@ -39,10 +39,10 @@ public interface ModelIssueService {
/**
* 更新模型订阅
*
* @param model
Issu
e
* @param model
Subscrib
e
* @return
*/
Integer
updateModelIssue
(
Model
Issue
modelIssu
e
);
Integer
updateModelIssue
(
Model
Subscribe
modelSubscrib
e
);
/**
* 获取模型订阅
...
...
@@ -50,7 +50,7 @@ public interface ModelIssueService {
* @param
* @return
*/
List
<
Model
Issu
e
>
getModelIssueList
(
String
objId
,
String
modelCode
,
String
subsCompanyCode
);
List
<
Model
Subscrib
e
>
getModelIssueList
(
String
objId
,
String
modelCode
,
String
subsCompanyCode
);
/**
* 获取模型订阅列表
...
...
@@ -58,5 +58,5 @@ public interface ModelIssueService {
* @param modelId
* @return
*/
Model
Issu
eDTO
getModelIssue
(
String
modelId
);
Model
Subscrib
eDTO
getModelIssue
(
String
modelId
);
}
src/main/java/com/pms/ocp/service/impl/Model
Note
ServiceImpl.java
→
src/main/java/com/pms/ocp/service/impl/Model
Audit
ServiceImpl.java
View file @
43a54a8b
package
com.pms.ocp.service.impl
;
import
com.baomidou.mybatisplus.core.conditions.query.QueryWrapper
;
import
com.pms.ocp.common.utils.ExcelUtils
;
import
com.pms.ocp.mapper.ModelNoteMapper
;
import
com.pms.ocp.model.entity.ModelNote
;
import
com.pms.ocp.service.ModelNoteService
;
import
com.pms.ocp.mapper.ModelAuditMapper
;
import
com.pms.ocp.model.entity.ModelAudit
;
import
com.pms.ocp.service.ModelAuditService
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.stereotype.Service
;
...
...
@@ -17,14 +16,14 @@ import java.util.List;
*/
@Service
public
class
Model
NoteServiceImpl
implements
ModelNote
Service
{
public
class
Model
AuditServiceImpl
implements
ModelAudit
Service
{
@Autowired
private
Model
NoteMapper
modelNote
Mapper
;
private
Model
AuditMapper
modelAudit
Mapper
;
@Override
public
Integer
createModelNote
(
Model
Note
modelNote
)
{
return
model
NoteMapper
.
insert
(
modelNote
);
public
Integer
createModelNote
(
Model
Audit
modelAudit
)
{
return
model
AuditMapper
.
insert
(
modelAudit
);
}
@Override
...
...
@@ -33,20 +32,20 @@ public class ModelNoteServiceImpl implements ModelNoteService {
}
@Override
public
Integer
updateModelNote
(
Model
Note
modelNote
)
{
public
Integer
updateModelNote
(
Model
Audit
modelAudit
)
{
return
null
;
}
@Override
public
List
<
Model
Note
>
getModelNoteList
(
String
modelCode
)
{
public
List
<
Model
Audit
>
getModelNoteList
(
String
modelCode
)
{
QueryWrapper
<
Model
Note
>
wrapper
=
new
QueryWrapper
<>();
wrapper
.
lambda
().
eq
(
Model
Note
:
:
getModelCode
,
modelCode
);
return
model
Note
Mapper
.
selectList
(
wrapper
);
QueryWrapper
<
Model
Audit
>
wrapper
=
new
QueryWrapper
<>();
wrapper
.
lambda
().
eq
(
Model
Audit
:
:
getModelCode
,
modelCode
);
return
model
Audit
Mapper
.
selectList
(
wrapper
);
}
@Override
public
Model
Note
getModelNote
(
String
modelId
)
{
public
Model
Audit
getModelNote
(
String
modelId
)
{
return
null
;
}
...
...
src/main/java/com/pms/ocp/service/impl/Model
Issu
eServiceImpl.java
→
src/main/java/com/pms/ocp/service/impl/Model
Subscrib
eServiceImpl.java
View file @
43a54a8b
package
com.pms.ocp.service.impl
;
import
com.baomidou.mybatisplus.core.conditions.query.QueryWrapper
;
import
com.pms.ocp.mapper.Model
Issu
eMapper
;
import
com.pms.ocp.model.dto.Model
Issu
eDTO
;
import
com.pms.ocp.model.entity.Model
Issu
e
;
import
com.pms.ocp.service.Model
Issu
eService
;
import
com.pms.ocp.mapper.Model
Subscrib
eMapper
;
import
com.pms.ocp.model.dto.Model
Subscrib
eDTO
;
import
com.pms.ocp.model.entity.Model
Subscrib
e
;
import
com.pms.ocp.service.Model
Subscrib
eService
;
import
org.apache.commons.lang3.StringUtils
;
import
org.springframework.beans.BeanUtils
;
import
org.springframework.beans.factory.annotation.Autowired
;
...
...
@@ -20,21 +20,21 @@ import java.util.List;
*/
@Service
public
class
Model
IssueServiceImpl
implements
ModelIssu
eService
{
public
class
Model
SubscribeServiceImpl
implements
ModelSubscrib
eService
{
@Autowired
private
Model
IssueMapper
modelIssu
eMapper
;
private
Model
SubscribeMapper
modelSubscrib
eMapper
;
@Override
public
Integer
createModelIssue
(
Model
IssueDTO
modelIssu
eDTO
)
{
public
Integer
createModelIssue
(
Model
SubscribeDTO
modelSubscrib
eDTO
)
{
Model
Issue
modelIssue
=
new
ModelIssu
e
();
Model
Subscribe
modelSubscribe
=
new
ModelSubscrib
e
();
BeanUtils
.
copyProperties
(
model
IssueDTO
,
modelIssu
e
);
BeanUtils
.
copyProperties
(
model
SubscribeDTO
,
modelSubscrib
e
);
model
Issu
e
.
setSubsCtime
(
LocalDateTime
.
now
());
model
Subscrib
e
.
setSubsCtime
(
LocalDateTime
.
now
());
return
model
IssueMapper
.
insert
(
modelIssu
e
);
return
model
SubscribeMapper
.
insert
(
modelSubscrib
e
);
}
@Override
...
...
@@ -50,35 +50,35 @@ public class ModelIssueServiceImpl implements ModelIssueService {
*/
@Override
public
Integer
deleteBatchModelIssue
(
List
<
String
>
ids
)
{
return
model
Issu
eMapper
.
deleteBatchIds
(
ids
);
return
model
Subscrib
eMapper
.
deleteBatchIds
(
ids
);
}
@Override
public
Integer
updateModelIssue
(
Model
Issue
modelIssu
e
)
{
public
Integer
updateModelIssue
(
Model
Subscribe
modelSubscrib
e
)
{
return
null
;
}
@Override
public
List
<
Model
Issu
e
>
getModelIssueList
(
String
objId
,
String
modelCode
,
String
subsCompanyCode
)
{
QueryWrapper
<
Model
Issu
e
>
queryWrapper
=
new
QueryWrapper
();
public
List
<
Model
Subscrib
e
>
getModelIssueList
(
String
objId
,
String
modelCode
,
String
subsCompanyCode
)
{
QueryWrapper
<
Model
Subscrib
e
>
queryWrapper
=
new
QueryWrapper
();
if
(
StringUtils
.
isNotEmpty
(
objId
))
{
queryWrapper
.
lambda
().
eq
(
Model
Issu
e:
:
getObjId
,
objId
);
queryWrapper
.
lambda
().
eq
(
Model
Subscrib
e:
:
getObjId
,
objId
);
}
if
(
StringUtils
.
isNotEmpty
(
modelCode
))
{
queryWrapper
.
lambda
().
eq
(
Model
Issu
e:
:
getModelCode
,
modelCode
);
queryWrapper
.
lambda
().
eq
(
Model
Subscrib
e:
:
getModelCode
,
modelCode
);
}
if
(
StringUtils
.
isNotEmpty
(
subsCompanyCode
))
{
queryWrapper
.
lambda
().
eq
(
Model
Issu
e:
:
getSubsCompanyCode
,
subsCompanyCode
);
queryWrapper
.
lambda
().
eq
(
Model
Subscrib
e:
:
getSubsCompanyCode
,
subsCompanyCode
);
}
return
model
Issu
eMapper
.
selectList
(
queryWrapper
);
return
model
Subscrib
eMapper
.
selectList
(
queryWrapper
);
}
@Override
public
Model
Issu
eDTO
getModelIssue
(
String
modelId
)
{
public
Model
Subscrib
eDTO
getModelIssue
(
String
modelId
)
{
return
null
;
}
}
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