|
@@ -1,18 +1,16 @@
|
|
-package com.persagy.apm.service.impl;
|
|
|
|
|
|
+package com.persagy.apm.alarmservice.project.alarmruleobjrel.service.impl;
|
|
|
|
|
|
import com.persagy.apm.common.context.AppContext;
|
|
import com.persagy.apm.common.context.AppContext;
|
|
-import com.persagy.apm.dao.ProjectAlarmRuleObjRelMapper;
|
|
|
|
-import com.persagy.apm.service.IProjectAlarmRuleObjRelService;
|
|
|
|
|
|
+import com.persagy.apm.alarmservice.project.alarmruleobjrel.dao.ProjectAlarmRuleObjRelMapper;
|
|
|
|
+import com.persagy.apm.alarmservice.project.alarmruleobjrel.service.IProjectAlarmRuleObjRelService;
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.stereotype.Service;
|
|
import org.apache.commons.lang.StringUtils;
|
|
import org.apache.commons.lang.StringUtils;
|
|
import com.persagy.apm.common.constant.enums.ValidEnum;
|
|
import com.persagy.apm.common.constant.enums.ValidEnum;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
-import com.persagy.apm.model.*;
|
|
|
|
-import com.persagy.apm.model.dto.*;
|
|
|
|
-
|
|
|
|
|
|
+import com.persagy.apm.alarmservice.project.alarmruleobjrel.model.*;
|
|
|
|
+import com.persagy.apm.alarmservice.project.alarmruleobjrel.model.dto.*;
|
|
import java.util.List;
|
|
import java.util.List;
|
|
-
|
|
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
import com.google.common.base.CaseFormat;
|
|
import com.google.common.base.CaseFormat;
|
|
@@ -23,19 +21,18 @@ import org.springframework.util.CollectionUtils;
|
|
* 项目报警规则与监测对象的关联(ProjectAlarmRuleObjRel) service层
|
|
* 项目报警规则与监测对象的关联(ProjectAlarmRuleObjRel) service层
|
|
*
|
|
*
|
|
* @author lixing
|
|
* @author lixing
|
|
- * @version V1.0 2021-09-07 18:12:08
|
|
|
|
|
|
+ * @version V1.0 2021-09-08 22:46:37
|
|
*/
|
|
*/
|
|
@Service
|
|
@Service
|
|
-public class ProjectAlarmRuleObjRelServiceImpl extends ServiceImpl<ProjectAlarmRuleObjRelMapper, ProjectAlarmRuleObjRel>
|
|
|
|
- implements IProjectAlarmRuleObjRelService {
|
|
|
|
-
|
|
|
|
|
|
+public class ProjectAlarmRuleObjRelServiceImpl extends ServiceImpl<ProjectAlarmRuleObjRelMapper, ProjectAlarmRuleObjRel>
|
|
|
|
+ implements IProjectAlarmRuleObjRelService {
|
|
|
|
+
|
|
/**
|
|
/**
|
|
- * 创建项目报警规则与监测对象的关联
|
|
|
|
- *
|
|
|
|
- * @return 项目报警规则与监测对象的关联主键
|
|
|
|
- * @author lixing
|
|
|
|
- * @version V1.0 2021-09-07 18:12:08
|
|
|
|
- */
|
|
|
|
|
|
+ * 创建项目报警规则与监测对象的关联
|
|
|
|
+ * @return 项目报警规则与监测对象的关联主键
|
|
|
|
+ * @author lixing
|
|
|
|
+ * @version V1.0 2021-09-08 22:46:37
|
|
|
|
+ */
|
|
@Override
|
|
@Override
|
|
public String createProjectAlarmRuleObjRel(AddProjectAlarmRuleObjRelDTO addProjectAlarmRuleObjRelDTO) {
|
|
public String createProjectAlarmRuleObjRel(AddProjectAlarmRuleObjRelDTO addProjectAlarmRuleObjRelDTO) {
|
|
ProjectAlarmRuleObjRel projectAlarmRuleObjRel = ConvertProjectAlarmRuleObjRelTool.INSTANCE.convertAddDto2Entity(addProjectAlarmRuleObjRelDTO);
|
|
ProjectAlarmRuleObjRel projectAlarmRuleObjRel = ConvertProjectAlarmRuleObjRelTool.INSTANCE.convertAddDto2Entity(addProjectAlarmRuleObjRelDTO);
|
|
@@ -44,7 +41,7 @@ public class ProjectAlarmRuleObjRelServiceImpl extends ServiceImpl<ProjectAlarmR
|
|
save(projectAlarmRuleObjRel);
|
|
save(projectAlarmRuleObjRel);
|
|
return projectAlarmRuleObjRel.getId();
|
|
return projectAlarmRuleObjRel.getId();
|
|
}
|
|
}
|
|
-
|
|
|
|
|
|
+
|
|
/**
|
|
/**
|
|
* 如果某些字段没有赋值,使用默认的值
|
|
* 如果某些字段没有赋值,使用默认的值
|
|
*
|
|
*
|
|
@@ -55,17 +52,16 @@ public class ProjectAlarmRuleObjRelServiceImpl extends ServiceImpl<ProjectAlarmR
|
|
private void setDefaultValue(ProjectAlarmRuleObjRel projectAlarmRuleObjRel) {
|
|
private void setDefaultValue(ProjectAlarmRuleObjRel projectAlarmRuleObjRel) {
|
|
projectAlarmRuleObjRel.setCreator(AppContext.getContext().getAccountId());
|
|
projectAlarmRuleObjRel.setCreator(AppContext.getContext().getAccountId());
|
|
// todo 其他默认的属性
|
|
// todo 其他默认的属性
|
|
-
|
|
|
|
|
|
+
|
|
}
|
|
}
|
|
-
|
|
|
|
|
|
+
|
|
/**
|
|
/**
|
|
- * 项目报警规则与监测对象的关联详情
|
|
|
|
- *
|
|
|
|
- * @param id 主键
|
|
|
|
- * @return 部门do类
|
|
|
|
- * @author lixing
|
|
|
|
- * @version V1.0 2021-09-07 18:12:08
|
|
|
|
- */
|
|
|
|
|
|
+ * 项目报警规则与监测对象的关联详情
|
|
|
|
+ * @param id 主键
|
|
|
|
+ * @return 部门do类
|
|
|
|
+ * @author lixing
|
|
|
|
+ * @version V1.0 2021-09-08 22:46:37
|
|
|
|
+ */
|
|
@Override
|
|
@Override
|
|
public ProjectAlarmRuleObjRel queryProjectAlarmRuleObjRelDetail(String id) {
|
|
public ProjectAlarmRuleObjRel queryProjectAlarmRuleObjRelDetail(String id) {
|
|
ProjectAlarmRuleObjRel projectAlarmRuleObjRel = getById(id);
|
|
ProjectAlarmRuleObjRel projectAlarmRuleObjRel = getById(id);
|
|
@@ -74,13 +70,12 @@ public class ProjectAlarmRuleObjRelServiceImpl extends ServiceImpl<ProjectAlarmR
|
|
}
|
|
}
|
|
return projectAlarmRuleObjRel;
|
|
return projectAlarmRuleObjRel;
|
|
}
|
|
}
|
|
-
|
|
|
|
|
|
+
|
|
/**
|
|
/**
|
|
- * 更新项目报警规则与监测对象的关联
|
|
|
|
- *
|
|
|
|
- * @author lixing
|
|
|
|
- * @version V1.0 2021-09-07 18:12:08
|
|
|
|
- */
|
|
|
|
|
|
+ * 更新项目报警规则与监测对象的关联
|
|
|
|
+ * @author lixing
|
|
|
|
+ * @version V1.0 2021-09-08 22:46:37
|
|
|
|
+ */
|
|
@Override
|
|
@Override
|
|
public void updateProjectAlarmRuleObjRel(UpdateProjectAlarmRuleObjRelDTO updateProjectAlarmRuleObjRelDTO) {
|
|
public void updateProjectAlarmRuleObjRel(UpdateProjectAlarmRuleObjRelDTO updateProjectAlarmRuleObjRelDTO) {
|
|
ProjectAlarmRuleObjRel projectAlarmRuleObjRel = getById(updateProjectAlarmRuleObjRelDTO.getId());
|
|
ProjectAlarmRuleObjRel projectAlarmRuleObjRel = getById(updateProjectAlarmRuleObjRelDTO.getId());
|
|
@@ -88,14 +83,14 @@ public class ProjectAlarmRuleObjRelServiceImpl extends ServiceImpl<ProjectAlarmR
|
|
projectAlarmRuleObjRel.setModifier(AppContext.getContext().getAccountId());
|
|
projectAlarmRuleObjRel.setModifier(AppContext.getContext().getAccountId());
|
|
updateById(projectAlarmRuleObjRel);
|
|
updateById(projectAlarmRuleObjRel);
|
|
}
|
|
}
|
|
-
|
|
|
|
|
|
+
|
|
/**
|
|
/**
|
|
* 校验项目报警规则与监测对象的关联是否可删除
|
|
* 校验项目报警规则与监测对象的关联是否可删除
|
|
*
|
|
*
|
|
* @param id 项目报警规则与监测对象的关联主键
|
|
* @param id 项目报警规则与监测对象的关联主键
|
|
* @return 项目报警规则与监测对象的关联do类
|
|
* @return 项目报警规则与监测对象的关联do类
|
|
* @author lixing
|
|
* @author lixing
|
|
- * @version V1.0 2021-09-07 18:12:08
|
|
|
|
|
|
+ * @version V1.0 2021-09-08 22:46:37
|
|
*/
|
|
*/
|
|
public ProjectAlarmRuleObjRel checkDeletable(String id) {
|
|
public ProjectAlarmRuleObjRel checkDeletable(String id) {
|
|
if (id == null) {
|
|
if (id == null) {
|
|
@@ -110,14 +105,13 @@ public class ProjectAlarmRuleObjRelServiceImpl extends ServiceImpl<ProjectAlarmR
|
|
|
|
|
|
return projectAlarmRuleObjRel;
|
|
return projectAlarmRuleObjRel;
|
|
}
|
|
}
|
|
-
|
|
|
|
|
|
+
|
|
/**
|
|
/**
|
|
- * 删除项目报警规则与监测对象的关联
|
|
|
|
- *
|
|
|
|
- * @param id 主键
|
|
|
|
- * @author lixing
|
|
|
|
- * @version V1.0 2021-09-07 18:12:08
|
|
|
|
- */
|
|
|
|
|
|
+ * 删除项目报警规则与监测对象的关联
|
|
|
|
+ * @param id 主键
|
|
|
|
+ * @author lixing
|
|
|
|
+ * @version V1.0 2021-09-08 22:46:37
|
|
|
|
+ */
|
|
@Override
|
|
@Override
|
|
public void deleteProjectAlarmRuleObjRel(String id) {
|
|
public void deleteProjectAlarmRuleObjRel(String id) {
|
|
// 校验是否可删除
|
|
// 校验是否可删除
|
|
@@ -126,92 +120,90 @@ public class ProjectAlarmRuleObjRelServiceImpl extends ServiceImpl<ProjectAlarmR
|
|
projectAlarmRuleObjRel.setValid(ValidEnum.FALSE.getType());
|
|
projectAlarmRuleObjRel.setValid(ValidEnum.FALSE.getType());
|
|
updateById(projectAlarmRuleObjRel);
|
|
updateById(projectAlarmRuleObjRel);
|
|
}
|
|
}
|
|
-
|
|
|
|
|
|
+
|
|
/**
|
|
/**
|
|
- * 查询项目报警规则与监测对象的关联
|
|
|
|
- *
|
|
|
|
- * @return List<ProjectAlarmRuleObjRel>
|
|
|
|
- * @author lixing
|
|
|
|
- * @version V1.0 2021-09-07 18:12:08
|
|
|
|
- */
|
|
|
|
|
|
+ * 查询项目报警规则与监测对象的关联
|
|
|
|
+ * @return List<ProjectAlarmRuleObjRel>
|
|
|
|
+ * @author lixing
|
|
|
|
+ * @version V1.0 2021-09-08 22:46:37
|
|
|
|
+ */
|
|
@Override
|
|
@Override
|
|
public List<ProjectAlarmRuleObjRel> queryProjectAlarmRuleObjRelList(QueryProjectAlarmRuleObjRelDTO queryProjectAlarmRuleObjRelDTO) {
|
|
public List<ProjectAlarmRuleObjRel> queryProjectAlarmRuleObjRelList(QueryProjectAlarmRuleObjRelDTO queryProjectAlarmRuleObjRelDTO) {
|
|
QueryWrapper<ProjectAlarmRuleObjRel> queryWrapper = new QueryWrapper<>();
|
|
QueryWrapper<ProjectAlarmRuleObjRel> queryWrapper = new QueryWrapper<>();
|
|
queryWrapper.eq(ProjectAlarmRuleObjRel.PROP_VALID, ValidEnum.TRUE.getType());
|
|
queryWrapper.eq(ProjectAlarmRuleObjRel.PROP_VALID, ValidEnum.TRUE.getType());
|
|
// 默认按创建时间倒序排序
|
|
// 默认按创建时间倒序排序
|
|
queryWrapper.orderBy(true, false, ProjectAlarmRuleObjRel.PROP_CREATIONTIME);
|
|
queryWrapper.orderBy(true, false, ProjectAlarmRuleObjRel.PROP_CREATIONTIME);
|
|
-
|
|
|
|
|
|
+
|
|
if (queryProjectAlarmRuleObjRelDTO != null) {
|
|
if (queryProjectAlarmRuleObjRelDTO != null) {
|
|
-
|
|
|
|
|
|
+
|
|
// todo 需判断使用like还是eq
|
|
// todo 需判断使用like还是eq
|
|
if (StringUtils.isNotEmpty(queryProjectAlarmRuleObjRelDTO.getProjectAlarmRuleId())) {
|
|
if (StringUtils.isNotEmpty(queryProjectAlarmRuleObjRelDTO.getProjectAlarmRuleId())) {
|
|
queryWrapper.like(ProjectAlarmRuleObjRel.PROP_PROJECT_ALARM_RULE_ID, queryProjectAlarmRuleObjRelDTO.getProjectAlarmRuleId());
|
|
queryWrapper.like(ProjectAlarmRuleObjRel.PROP_PROJECT_ALARM_RULE_ID, queryProjectAlarmRuleObjRelDTO.getProjectAlarmRuleId());
|
|
}
|
|
}
|
|
-
|
|
|
|
|
|
+
|
|
// todo 需判断使用like还是eq
|
|
// todo 需判断使用like还是eq
|
|
if (StringUtils.isNotEmpty(queryProjectAlarmRuleObjRelDTO.getEquipId())) {
|
|
if (StringUtils.isNotEmpty(queryProjectAlarmRuleObjRelDTO.getEquipId())) {
|
|
queryWrapper.like(ProjectAlarmRuleObjRel.PROP_EQUIP_ID, queryProjectAlarmRuleObjRelDTO.getEquipId());
|
|
queryWrapper.like(ProjectAlarmRuleObjRel.PROP_EQUIP_ID, queryProjectAlarmRuleObjRelDTO.getEquipId());
|
|
}
|
|
}
|
|
-
|
|
|
|
|
|
+
|
|
if (queryProjectAlarmRuleObjRelDTO.getOpen() != null) {
|
|
if (queryProjectAlarmRuleObjRelDTO.getOpen() != null) {
|
|
queryWrapper.eq(ProjectAlarmRuleObjRel.PROP_OPEN, queryProjectAlarmRuleObjRelDTO.getOpen());
|
|
queryWrapper.eq(ProjectAlarmRuleObjRel.PROP_OPEN, queryProjectAlarmRuleObjRelDTO.getOpen());
|
|
}
|
|
}
|
|
-
|
|
|
|
|
|
+
|
|
// todo 需判断使用like还是eq
|
|
// todo 需判断使用like还是eq
|
|
if (StringUtils.isNotEmpty(queryProjectAlarmRuleObjRelDTO.getProjectId())) {
|
|
if (StringUtils.isNotEmpty(queryProjectAlarmRuleObjRelDTO.getProjectId())) {
|
|
queryWrapper.like(ProjectAlarmRuleObjRel.PROP_PROJECT_ID, queryProjectAlarmRuleObjRelDTO.getProjectId());
|
|
queryWrapper.like(ProjectAlarmRuleObjRel.PROP_PROJECT_ID, queryProjectAlarmRuleObjRelDTO.getProjectId());
|
|
}
|
|
}
|
|
-
|
|
|
|
|
|
+
|
|
}
|
|
}
|
|
-
|
|
|
|
|
|
+
|
|
return list(queryWrapper);
|
|
return list(queryWrapper);
|
|
}
|
|
}
|
|
-
|
|
|
|
|
|
+
|
|
/**
|
|
/**
|
|
- * 分页查询项目报警规则与监测对象的关联
|
|
|
|
- *
|
|
|
|
- * @return IPage<ProjectAlarmRuleObjRel>
|
|
|
|
- * @author lixing
|
|
|
|
- * @version V1.0 2021-09-07 18:12:08
|
|
|
|
- */
|
|
|
|
|
|
+ * 分页查询项目报警规则与监测对象的关联
|
|
|
|
+ * @return IPage<ProjectAlarmRuleObjRel>
|
|
|
|
+ * @author lixing
|
|
|
|
+ * @version V1.0 2021-09-08 22:46:37
|
|
|
|
+ */
|
|
@Override
|
|
@Override
|
|
public IPage<ProjectAlarmRuleObjRel> pageQueryProjectAlarmRuleObjRel(PageQueryProjectAlarmRuleObjRelDTO pageQueryProjectAlarmRuleObjRelDTO) {
|
|
public IPage<ProjectAlarmRuleObjRel> pageQueryProjectAlarmRuleObjRel(PageQueryProjectAlarmRuleObjRelDTO pageQueryProjectAlarmRuleObjRelDTO) {
|
|
QueryWrapper<ProjectAlarmRuleObjRel> queryWrapper = new QueryWrapper<>();
|
|
QueryWrapper<ProjectAlarmRuleObjRel> queryWrapper = new QueryWrapper<>();
|
|
queryWrapper.eq(ProjectAlarmRuleObjRel.PROP_VALID, ValidEnum.TRUE.getType());
|
|
queryWrapper.eq(ProjectAlarmRuleObjRel.PROP_VALID, ValidEnum.TRUE.getType());
|
|
// 这里认为pageQueryDTO是经过校验的,肯定包含分页信息
|
|
// 这里认为pageQueryDTO是经过校验的,肯定包含分页信息
|
|
- IPage<ProjectAlarmRuleObjRel> pageParam = new Page<>(pageQueryProjectAlarmRuleObjRelDTO.getPage(), pageQueryProjectAlarmRuleObjRelDTO.getSize(), true);
|
|
|
|
|
|
+ IPage<ProjectAlarmRuleObjRel> pageParam = new Page<>(pageQueryProjectAlarmRuleObjRelDTO.getPage(), pageQueryProjectAlarmRuleObjRelDTO.getSize(),true);
|
|
// 排序信息
|
|
// 排序信息
|
|
- if (CollectionUtils.isEmpty(pageQueryProjectAlarmRuleObjRelDTO.getOrders())) {
|
|
|
|
|
|
+ if(CollectionUtils.isEmpty(pageQueryProjectAlarmRuleObjRelDTO.getOrders())){
|
|
// 默认按创建时间倒序排序
|
|
// 默认按创建时间倒序排序
|
|
queryWrapper.orderBy(true, false, ProjectAlarmRuleObjRel.PROP_CREATIONTIME);
|
|
queryWrapper.orderBy(true, false, ProjectAlarmRuleObjRel.PROP_CREATIONTIME);
|
|
- } else {
|
|
|
|
|
|
+ }else {
|
|
List<Sort> orders = pageQueryProjectAlarmRuleObjRelDTO.getOrders();
|
|
List<Sort> orders = pageQueryProjectAlarmRuleObjRelDTO.getOrders();
|
|
- for (Sort sort : orders) {
|
|
|
|
|
|
+ for(Sort sort: orders) {
|
|
// 将驼峰转换为下划线格式
|
|
// 将驼峰转换为下划线格式
|
|
- sort.setColumn(CaseFormat.LOWER_CAMEL.to(CaseFormat.LOWER_UNDERSCORE, sort.getColumn()));
|
|
|
|
|
|
+ sort.setColumn(CaseFormat.LOWER_CAMEL.to(CaseFormat.LOWER_UNDERSCORE,sort.getColumn()));
|
|
queryWrapper.orderBy(true, sort.isAsc(), sort.getColumn());
|
|
queryWrapper.orderBy(true, sort.isAsc(), sort.getColumn());
|
|
}
|
|
}
|
|
}
|
|
}
|
|
-
|
|
|
|
|
|
+
|
|
// todo 需判断使用like还是eq
|
|
// todo 需判断使用like还是eq
|
|
if (StringUtils.isNotEmpty(pageQueryProjectAlarmRuleObjRelDTO.getProjectAlarmRuleId())) {
|
|
if (StringUtils.isNotEmpty(pageQueryProjectAlarmRuleObjRelDTO.getProjectAlarmRuleId())) {
|
|
queryWrapper.like(ProjectAlarmRuleObjRel.PROP_PROJECT_ALARM_RULE_ID, pageQueryProjectAlarmRuleObjRelDTO.getProjectAlarmRuleId());
|
|
queryWrapper.like(ProjectAlarmRuleObjRel.PROP_PROJECT_ALARM_RULE_ID, pageQueryProjectAlarmRuleObjRelDTO.getProjectAlarmRuleId());
|
|
}
|
|
}
|
|
-
|
|
|
|
|
|
+
|
|
// todo 需判断使用like还是eq
|
|
// todo 需判断使用like还是eq
|
|
if (StringUtils.isNotEmpty(pageQueryProjectAlarmRuleObjRelDTO.getEquipId())) {
|
|
if (StringUtils.isNotEmpty(pageQueryProjectAlarmRuleObjRelDTO.getEquipId())) {
|
|
queryWrapper.like(ProjectAlarmRuleObjRel.PROP_EQUIP_ID, pageQueryProjectAlarmRuleObjRelDTO.getEquipId());
|
|
queryWrapper.like(ProjectAlarmRuleObjRel.PROP_EQUIP_ID, pageQueryProjectAlarmRuleObjRelDTO.getEquipId());
|
|
}
|
|
}
|
|
-
|
|
|
|
|
|
+
|
|
if (pageQueryProjectAlarmRuleObjRelDTO.getOpen() != null) {
|
|
if (pageQueryProjectAlarmRuleObjRelDTO.getOpen() != null) {
|
|
queryWrapper.eq(ProjectAlarmRuleObjRel.PROP_OPEN, pageQueryProjectAlarmRuleObjRelDTO.getOpen());
|
|
queryWrapper.eq(ProjectAlarmRuleObjRel.PROP_OPEN, pageQueryProjectAlarmRuleObjRelDTO.getOpen());
|
|
}
|
|
}
|
|
-
|
|
|
|
|
|
+
|
|
// todo 需判断使用like还是eq
|
|
// todo 需判断使用like还是eq
|
|
if (StringUtils.isNotEmpty(pageQueryProjectAlarmRuleObjRelDTO.getProjectId())) {
|
|
if (StringUtils.isNotEmpty(pageQueryProjectAlarmRuleObjRelDTO.getProjectId())) {
|
|
queryWrapper.like(ProjectAlarmRuleObjRel.PROP_PROJECT_ID, pageQueryProjectAlarmRuleObjRelDTO.getProjectId());
|
|
queryWrapper.like(ProjectAlarmRuleObjRel.PROP_PROJECT_ID, pageQueryProjectAlarmRuleObjRelDTO.getProjectId());
|
|
}
|
|
}
|
|
-
|
|
|
|
|
|
+
|
|
return getBaseMapper().selectPage(pageParam, queryWrapper);
|
|
return getBaseMapper().selectPage(pageParam, queryWrapper);
|
|
}
|
|
}
|
|
}
|
|
}
|