Skip to content

Z
zhxf_java
Commit 4595d076 authored by co_dengxiongwen's avatar co_dengxiongwen
Browse files
Options

报警类型接口，报警中心接口

parent a31d6cec
Hide whitespace changes
Inline Side-by-side
Showing with 497 additions and 481 deletions
microservice-admin/src/main/java/com/devplatform/admin/common/utils/Constants.java
View file @ 4595d076
package com.devplatform.admin.common.utils;
import javax.crypto.Cipher;
import javax.crypto.spec.IvParameterSpec;
import javax.crypto.spec.SecretKeySpec;
/**
* @author
*/
......@@ -25,73 +21,18 @@ public class Constants {
* 职务类型
*/
public static final String USER_JOB = "6070da6f5d9b40249359d993f9791b09";
/**
* 伤亡情况
*/
public static final String CASUALTIES = "ac3780f6d7f94842a375b9add29708b6";
/**
* 环境影响
*/
public static final String ENVIRONMENTAL_EFFECT = "782cfd4c5615404c87cad90e684097f4";
/**
* 财产损失
*/
public static final String PROPERTY_LOSS = "cc9d5d0ff7444780b1817dcaa3410659";
/**
* 运营影响
*/
public static final String OPERATIONAL_IMPACT = "0a46ce095abe4db9a26e49cb9b192c2e";
/**
* 区域属性
*/
public static final String ZONE_PROPERTIES = "0b39aa2c20be44a2becc038ff1494eeb";
/**
* 客流情况
*/
public static final String PASSENGER_FLOW = "f89272c10b874f3da78bb451a15fde8f";
/**
* 防范措施
*/
public static final String PREVENTIVE_MEASURES = "954cffae0a694d9cb27b517b4f907c17";
/**
* 备份加固
*/
public static final String BACKUP_REINFORCEMENT = "d48ab6c0bee947f0bcd0b6e7d35eb827";
/**
* 任务名称
*/
public static final String TASK_NAME = "4ccfd3d516094f1fa47ed6614905a7c5";
/**
* 执行单位
*/
public static final String EXECUTION_UNIT = "715351b4c9bd409e872d2b50ec5fde64";
/**
* 品牌
*/
public static final String BRAND = "bd7b4a4fa9fc4d6a9f576b80b9d2fd02";
/**
* 人员专长
*/
public static final String STAFF_EXPERTISE = "e08bfcfe66d94bb1a96c4f2d8dea6408";
/**
* 证件类型
* 阈值类型
*/
public static final String CARD_TYPE = "15fa56bff50b42d4a59083645fdd3cbe";
public static final String THRESHOLD = "e53461aa0ff546f88677bfe8b907bce9";
/**
* code
*/
public static final String CODE = "1";
/**线路*/
/**
* 证件类型
*/
public static final String RT_CARD_TYPE = "3a78fdebf4c74087ac3c4648925b2cce";
/**
* 证件类型
*/
public static final String RT_USER_JOB = "e14416652b884591abe43db8eae3d5b7";
/**
* 报警类型
*/
......
microservice-admin/src/main/java/com/devplatform/admin/modules/event/bean/LinkEvent.java 0 → 100644
View file @ 4595d076
package com.devplatform.admin.modules.event.bean;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import java.io.Serializable;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
@Data
@ApiModel(value="报警类型表对象",description="报警类型表对象")
@TableName("link_event")
public class LinkEvent implements Serializable {
private static final long serialVersionUID = 1L;
/** 主键id */
@ApiModelProperty(value="主键ID",name="id")
@TableId
private java.lang.String id;
/** 资源点类型(数据字典表id) */
@ApiModelProperty(value="资源点类型(数据字典表id)",name="resourceType")
private java.lang.String resourceType;
/** 报警类型编码 */
@ApiModelProperty(value="报警类型编码",name="eventCode")
private java.lang.String eventCode;
/** 报警类型名称 */
@ApiModelProperty(value="报警类型名称",name="eventName")
private java.lang.String eventName;
/** 报警类型等级 */
@ApiModelProperty(value="报警类型等级",name="eventLevel")
private Integer eventLevel;
/** 创建人 */
@ApiModelProperty(value="创建人",name="createUserId")
private java.lang.String createUserId;
/** 创建时间 */
@ApiModelProperty(value="创建时间",name="createTime")
private java.util.Date createTime;
/** 修改人 */
@ApiModelProperty(value="修改人",name="updateUserId")
private java.lang.String updateUserId;
/** 修改时间 */
@ApiModelProperty(value="修改时间",name="updateTime")
private java.util.Date updateTime;
/** 是否已删除（0未删除，1已删除） */
@ApiModelProperty(value="是否已删除（0未删除，1已删除）",name="deleted")
private Integer deleted;
/** 系统标识 */
@ApiModelProperty(value="系统标识",name="sysSign")
private java.lang.String sysSign;
/** 站点ID */
@ApiModelProperty(value="站点ID",name="stationId")
private java.lang.String stationId;
/** 备用项1 */
@ApiModelProperty(value="备用项1",name="byx1")
private java.lang.String byx1;
/** 备用项2 */
@ApiModelProperty(value="备用项2",name="byx2")
private java.lang.String byx2;
/** 备用项3 */
@ApiModelProperty(value="备用项3",name="byx3")
private java.lang.String byx3;
}
microservice-admin/src/main/java/com/devplatform/admin/modules/event/controller/LinkEventController.java 0 → 100644
View file @ 4595d076
package com.devplatform.admin.modules.event.controller;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.devplatform.admin.common.utils.AbstractController;
import com.devplatform.admin.common.utils.Constants;
import com.devplatform.admin.modules.event.bean.LinkEvent;
import com.devplatform.admin.modules.event.model.LinkEventModel;
import com.devplatform.admin.modules.event.service.LinkEventService;
import com.devplatform.common.base.annotation.SysLog;
import com.devplatform.common.base.validator.ValidatorUtils;
import com.devplatform.common.util.R;
import com.devplatform.common.util.StringUtil;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import java.util.Arrays;
import java.util.Date;
import java.util.List;
import java.util.Map;
/**
* <br>
* <b>功能：</b>LinkEventController<br>
* @author 代码生成器产生
*/
@Api(tags={"报警类型表接口"})
@RestController
@RequestMapping("/linkEvent")
public class LinkEventController extends AbstractController{
@Autowired
private LinkEventService linkEventService;
/**
* 列表页面列表数据获取
* @param params 承接对象
* @return
*/
@ApiOperation(value="根据条件获取报警类型表分页数据列表", notes="根据条件获取报警类型表分页数据列表")
@ApiImplicitParam(name = "params", value = "参数", required = true, dataType = "Map<String, Object>")
@PostMapping("/list")
public R list(@RequestParam Map<String, Object> params) {
List<LinkEvent> list = linkEventService.list(new LambdaQueryWrapper<LinkEvent>()
.eq(LinkEvent::getDeleted, Constants.INT_0).orderByDesc(LinkEvent::getCreateTime));
//返回分页结果
return R.ok().put("list", list);
}
/**
* 列表页面列表数据获取
* @param model 承接对象
* @return
*/
@ApiOperation(value="根据条件获取报警类型表分页数据列表", notes="根据条件获取报警类型表分页数据列表")
@ApiImplicitParam(name = "model", value = "参数", required = true, dataType = "LinkEventModel")
@PostMapping("/pageList")
public R pageList(@RequestBody LinkEventModel model) {
//如果model参数中没有设置排序方式，则默认以创建时间倒序排列
if(StringUtil.isEmpty(model.getSort())){
model.setSort("create_time desc");
}
//按条件查询分页数据
List<LinkEvent> list = linkEventService.queryPageList(model);
//将查询结果中数据和数量封装起来做为接口返回值
return R.ok().put("page", getMyPage(list,model));
}
/**
* 添加
* @param bean 报警类型表对象
* @return
*/
@SysLog("添加报警类型表")
@ApiOperation(value="新增报警类型表数据", notes="新增报警类型表数据")
@PostMapping("/save")
public R save(@RequestBody @ApiParam(value="报警类型表实体对象", required = true)LinkEvent bean) {
ValidatorUtils.validateEntity(bean);
bean.setCreateUserId(getUserId());
bean.setCreateTime(new Date());
linkEventService.save(bean);
return R.ok();
}
/**
* 修改
* @param bean 报警类型表对象
* @return
*/
@SysLog("修改报警类型表")
@ApiOperation(value="修改报警类型表数据", notes="修改报警类型表数据")
@PostMapping("/update")
public R update(@RequestBody @ApiParam(value="报警类型表实体对象", required = true)LinkEvent bean) {
ValidatorUtils.validateEntity(bean);
bean.setUpdateUserId(getUserId());
bean.setUpdateTime(new Date());
linkEventService.update(bean,
new QueryWrapper<LinkEvent>().eq(StringUtil.checkNotNull(bean.getId()),"id", bean.getId()));
return R.ok();
}
/**
* 根据ID获取报警类型表对象
* @param id 对象主键
* @return
*/
@ApiOperation(value="根据ID获取报警类型表对象", notes="根据ID获取报警类型表对象")
@ApiImplicitParam(name = "id", value = "主键", required = true, dataType = "String")
@GetMapping("/getId/{id}")
public R getId(@PathVariable String id) {
LinkEvent bean = linkEventService.getById(id);
return R.ok().put("bean", bean);
}
/**
* 根据ID获取报警类型表对象
* @param ids 报警类型表对象主键数组
* @return
*/
@SysLog("删除报警类型表数据")
@ApiOperation(value="根据ID批量删除报警类型表数据", notes="根据ID批量删除报警类型表数据")
@ApiImplicitParam(name = "ids", value = "主键数组", required = true, dataType = "String")
@PostMapping("/delete")
public R delete(@RequestBody String[] ids) {
linkEventService.removeByIds(Arrays.asList(ids));
return R.ok();
}
/**
* 逻辑删除
* 根据ID删除报警类型表对象
* @param ids 报警类型表对象主键数组
* @return
*/
@SysLog("删除报警类型表数据")
@ApiOperation(value="根据ID批量删除报警类型表数据", notes="根据ID批量删除报警类型表数据")
@ApiImplicitParam(name = "ids", value = "主键数组", required = true, dataType = "String[]")
@PostMapping("/deleteByFlag")
public R deleteByFlag(@RequestBody String[] ids) {
//根据id数组删除
linkEventService.deleteByFlagByIds(ids, getUserId());
//返回成功
return R.ok();
}
}
microservice-admin/src/main/java/com/devplatform/admin/modules/event/dao/LinkEventDao.java 0 → 100644
View file @ 4595d076
package com.devplatform.admin.modules.event.dao;
import org.apache.ibatis.annotations.Mapper;
import com.devplatform.admin.modules.event.model.LinkEventModel;
import com.devplatform.admin.modules.event.bean.LinkEvent;
import com.devplatform.common.dao.MyBaseMapper;
import java.util.List;
/**
* LinkEvent Mapper
* 用于报警类型表的数据库操作
* @author Administrator
*
*/
@Mapper
public interface LinkEventDao extends MyBaseMapper<LinkEvent> {
/**
* 查询分页数量
* @param model
* @return
*/
Integer queryPageByCount(LinkEventModel model);
/**
* 查询报警类型表分页数据
* @param model
* @return
*/
List<LinkEvent> queryPageList(LinkEventModel model);
}
microservice-admin/src/main/java/com/devplatform/admin/modules/event/model/LinkEventModel.java 0 → 100644
View file @ 4595d076
package com.devplatform.admin.modules.event.model;
import com.devplatform.admin.common.model.BaseModel;
import lombok.Data;
/**
* 报警类型表的Model
* <br>
* @author 代码生成器产生
*/
@Data
public class LinkEventModel extends BaseModel {
/** 主键id */
private java.lang.String id;
/** 资源点类型(数据字典表id) */
private java.lang.String resourceType;
/** 报警类型编码 */
private java.lang.String eventCode;
/** 报警类型名称 */
private java.lang.String eventName;
/** 报警类型等级 */
private Integer eventLevel;
/** 创建人 */
private java.lang.String createUserId;
/** 创建时间 */
private java.util.Date createTime;
/** 修改人 */
private java.lang.String updateUserId;
/** 修改时间 */
private java.util.Date updateTime;
/** 是否已删除（0未删除，1已删除） */
private Integer deleted;
/** 系统标识 */
private java.lang.String sysSign;
/** 站点ID */
private java.lang.String stationId;
/** 备用项1 */
private java.lang.String byx1;
/** 备用项2 */
private java.lang.String byx2;
/** 备用项3 */
private java.lang.String byx3;
}
microservice-admin/src/main/java/com/devplatform/admin/modules/event/service/LinkEventService.java 0 → 100644
View file @ 4595d076
package com.devplatform.admin.modules.event.service;
import com.devplatform.common.service.MyBaseService;
import com.devplatform.admin.modules.event.bean.LinkEvent;
import com.devplatform.admin.modules.event.model.LinkEventModel;
import java.util.List;
/**
* 报警类型表的service接口
* <br>
* <b>功能：</b>LinkEventService<br>
* @author 代码生成器产生
*/
public interface LinkEventService extends MyBaseService<LinkEvent> {
/**
* 查询报警类型表分页数据
* @param model
* @return
*/
List<LinkEvent> queryPageList(LinkEventModel model);
/**
* 根据ID删除报警类型表对象
* @param ids
* @param userId
* @return void
*/
void deleteByFlagByIds(String[] ids, String userId);
}
microservice-admin/src/main/java/com/devplatform/admin/modules/event/service/impl/LinkEventServiceImpl.java 0 → 100644
View file @ 4595d076
package com.devplatform.admin.modules.event.service.impl;
import org.springframework.stereotype.Service;
import com.devplatform.admin.modules.event.model.LinkEventModel;
import com.devplatform.admin.modules.event.bean.LinkEvent;
import com.devplatform.admin.modules.event.dao.LinkEventDao;
import com.devplatform.admin.modules.event.service.LinkEventService;
import com.devplatform.common.service.impl.MyBaseServiceImpl;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
/**
* 报警类型表的service接口实现类
* <br>
* <b>功能：</b>LinkEventServiceImpl<br>
* @author 代码生成器产生
*/
@Service("linkEventService")
public class LinkEventServiceImpl extends MyBaseServiceImpl<LinkEventDao, LinkEvent> implements LinkEventService {
@Override
public List<LinkEvent> queryPageList(LinkEventModel model) {
Integer rowCount = baseMapper.queryPageByCount(model);
model.getPager().setRowCount(rowCount);
return baseMapper.queryPageList(model);
}
@Override
public void deleteByFlagByIds(String[] ids, String userId){
//用来暂存所有要删除的对象
List<LinkEvent> beans = new ArrayList<LinkEvent>();
//遍历ids数组
for(String id: ids){
LinkEvent temp = new LinkEvent();
temp.setId(id);
//将数据标记为删除
temp.setDeleted(1);
temp.setUpdateUserId(userId);
temp.setUpdateTime(new Date());
//将要删除的对象存放在list中
beans.add(temp);
}
//调用批量更新操作
updateBatchById(beans);
}
}
microservice-admin/src/main/java/com/devplatform/admin/modules/sys/bean/SysThreshold.java
View file @ 4595d076
......@@ -25,9 +25,9 @@ public class SysThreshold implements Serializable {
/** 资源点类型（数据字典表id） */
@ApiModelProperty(value="资源点类型（数据字典表id）",name="dicId")
private java.lang.String dicId;
/** 类型(1:压力 2:温度 3:水位) */
@ApiModelProperty(value="类型(1:压力 2:温度 3:水位)",name="type")
private Integer type;
/** 阈值类型（数据字典表id） */
@ApiModelProperty(value="阈值类型（数据字典表id）",name="type")
private java.lang.String type;
/** 参数描述 */
@ApiModelProperty(value="参数描述",name="remark")
private java.lang.String remark;
......@@ -77,4 +77,8 @@ public class SysThreshold implements Serializable {
@TableField(exist = false)
/** 设备类型名称*/
private String dicName;
@TableField(exist = false)
/** 阈值类型名称*/
private String typeName;
}
microservice-admin/src/main/java/com/devplatform/admin/modules/sys/model/SysThresholdModel.java
View file @ 4595d076
......@@ -15,8 +15,8 @@ public class SysThresholdModel extends BaseModel {
private java.lang.String id;
/** 资源点类型（数据字典表id） */
private java.lang.String dicId;
/** 类型(1:压力 2:温度 3:水位) */
private Integer type;
/** 阈值类型（数据字典表id） */
private java.lang.String type;
/** 参数描述 */
private java.lang.String remark;
/** 最小值 */
......
microservice-admin/src/main/java/com/devplatform/admin/modules/sysdictionary/controller/SysDictionaryController.java
View file @ 4595d076
......@@ -17,19 +17,10 @@ import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import java.util.Arrays;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.UUID;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
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.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.bind.annotation.*;
import java.util.*;
/**
* @author Administrator
*/
......@@ -268,131 +259,6 @@ public class SysDictionaryController extends AbstractController {
return R.ok().put("list", list);
}
/**
* 获取伤亡情况字典项
*
* @return
*/
@ApiOperation(value = "获取伤亡情况字典项", notes = "获取伤亡情况字典项")
@GetMapping("/getAllCasualtiesList")
public R getAllCasualtiesList(String stationId) {
List<SysDictionary> list = sysDictionaryService.queryByPid(Constants.CASUALTIES, stationId);
return R.ok().put("list", list);
}
/**
* 根据任务名称数据字典信息
* @param stationId
* @return
*/
@ApiOperation(value = "根据任务名称数据字典信息", notes = "根据任务名称数据字典信息")
@GetMapping("/getTaskNameList")
public R getByIdList(String stationId) {
List<SysDictionary> list = sysDictionaryService.queryByPid(Constants.TASK_NAME, stationId);
return R.ok().put("list", list);
}
/**
* 获取环境影响字典项
*
* @return
*/
@ApiOperation(value = "获取环境影响字典项", notes = "获取环境影响字典项")
@GetMapping("/getAllEnvironmentalEffectList")
public R getAllEnvironmentalEffectList(String stationId) {
List<SysDictionary> list =
sysDictionaryService.queryByPid(Constants.ENVIRONMENTAL_EFFECT, stationId);
return R.ok().put("list", list);
}
/**
* 获取财产损失字典项
*
* @return
*/
@ApiOperation(value = "获取财产损失字典项", notes = "获取财产损失字典项")
@GetMapping("/getAllPropertyLossList")
public R getAllPropertyLossList(String stationId) {
List<SysDictionary> list = sysDictionaryService.queryByPid(Constants.PROPERTY_LOSS, stationId);
return R.ok().put("list", list);
}
/**
* 获取运营影响字典项
*
* @return
*/
@ApiOperation(value = "获取运营影响字典项", notes = "获取运营影响字典项")
@GetMapping("/getAllOperationalImpactList")
public R getAllOperationalImpactList(String stationId) {
List<SysDictionary> list =
sysDictionaryService.queryByPid(Constants.OPERATIONAL_IMPACT, stationId);
return R.ok().put("list", list);
}
/**
* 获取区域属性字典项
*
* @return
*/
@ApiOperation(value = "获取区域属性字典项", notes = "获取区域属性字典项")
@GetMapping("/getAllZonePropertiesList")
public R getAllZonePropertiesList(String stationId) {
List<SysDictionary> list =
sysDictionaryService.queryByPid(Constants.ZONE_PROPERTIES, stationId);
return R.ok().put("list", list);
}
/**
* 获取客流情况字典项
*
* @return
*/
@ApiOperation(value = "获取客流情况字典项", notes = "获取客流情况字典项")
@GetMapping("/getAllPassengerFlowList")
public R getAllPassengerFlowList(String stationId) {
List<SysDictionary> list = sysDictionaryService.queryByPid(Constants.PASSENGER_FLOW, stationId);
return R.ok().put("list", list);
}
/**
* 获取防范措施字典项
*
* @return
*/
@ApiOperation(value = "获取防范措施字典项", notes = "获取防范措施字典项")
@GetMapping("/getAllPreventiveMeasuresList")
public R getAllPreventiveMeasuresList(String stationId) {
List<SysDictionary> list =
sysDictionaryService.queryByPid(Constants.PREVENTIVE_MEASURES, stationId);
return R.ok().put("list", list);
}
/**
* 获取备份加固字典项
*
* @return
*/
@ApiOperation(value = "获取备份加固字典项", notes = "获取备份加固字典项")
@GetMapping("/getAllBackupReinforcementList")
public R getAllBackupReinforcementList(String stationId) {
List<SysDictionary> list =
sysDictionaryService.queryByPid(Constants.BACKUP_REINFORCEMENT, stationId);
return R.ok().put("list", list);
}
/**
* 根据执行单位数据字典信息
*
* @return
*/
@ApiOperation(value = "根据执行单位数据字典信息", notes = "根据执行单位数据字典信息")
@GetMapping("/getExecutionUnitList")
public R getExecutionUnitList(String stationId) {
List<SysDictionary> list = sysDictionaryService.queryByPid(Constants.EXECUTION_UNIT, stationId);
return R.ok().put("list", list);
}
/**
* 品牌数据字典信息
*
......@@ -406,27 +272,13 @@ public class SysDictionaryController extends AbstractController {
}
/**
* 获取证件类型信息
*
* @return
*/
@ApiOperation(value = "获取证件类型信息", notes = "获取证件类型信息")
@GetMapping("/getCardTypeList")
public R getCardTypeList(String stationId) {
List<SysDictionary> list = sysDictionaryService.queryByPid(Constants.CARD_TYPE, stationId);
return R.ok().put("list", list);
}
/**
* 获取人员专长信息
*
* 阈值类型数据字典信息
* @return
*/
@ApiOperation(value = "获取人员专长信息", notes = "获取人员专长信息")
@GetMapping("/getStaffExpertiseList")
public R getStaffExpertiseList(String stationId) {
List<SysDictionary> list =
sysDictionaryService.queryByPid(Constants.STAFF_EXPERTISE, stationId);
@ApiOperation(value = "阈值类型数据字典信息", notes = "阈值类型数据字典信息")
@GetMapping("/getThresholdDicList")
public R getThresholdDicList(String stationId) {
List<SysDictionary> list = sysDictionaryService.queryByPid(Constants.THRESHOLD, stationId);
return R.ok().put("list", list);
}
......
microservice-admin/src/main/resources/mapper/event/LinkEventMapper.xml 0 → 100644
View file @ 4595d076
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.devplatform.admin.modules.event.dao.LinkEventDao">
<!-- Result Map -->
<resultMap id="BaseResultMap" type="com.devplatform.admin.modules.event.bean.LinkEvent">
<result column="id" property="id"/>
<result column="resource_type" property="resourceType"/>
<result column="event_code" property="eventCode"/>
<result column="event_name" property="eventName"/>
<result column="event_level" property="eventLevel"/>
<result column="create_user_id" property="createUserId"/>
<result column="create_time" property="createTime"/>
<result column="update_user_id" property="updateUserId"/>
<result column="update_time" property="updateTime"/>
<result column="deleted" property="deleted"/>
<result column="sys_sign" property="sysSign"/>
<result column="station_id" property="stationId"/>
<result column="byx1" property="byx1"/>
<result column="byx2" property="byx2"/>
<result column="byx3" property="byx3"/>
</resultMap>
<!-- link_event table all fields -->
<sql id="Base_Column_List">
id,resource_type,event_code,event_name,event_level,create_user_id,create_time,update_user_id,update_time,deleted,sys_sign,station_id,byx1,byx2,byx3
</sql>
<!-- 公共查询条件 -->
<sql id="Example_Where_Clause">
where t.deleted=0
<if test="id!=null and id!=''">and t.id = #{id}</if>
<if test="resourceType!=null and resourceType!=''">and t.resource_type = #{resourceType}</if>
<if test="eventCode!=null and eventCode!=''">and t.event_code = #{eventCode}</if>
<if test="eventName!=null and eventName!=''">and t.event_name = #{eventName}</if>
<if test="eventLevel!=null ">and t.event_level = #{eventLevel}</if>
<if test="createUserId!=null and createUserId!=''">and t.create_user_id = #{createUserId}</if>
<if test="createTime!=null ">and t.create_time = #{createTime}</if>
<if test="updateUserId!=null and updateUserId!=''">and t.update_user_id = #{updateUserId}</if>
<if test="updateTime!=null ">and t.update_time = #{updateTime}</if>
<if test="deleted!=null ">and t.deleted = #{deleted}</if>
<if test="sysSign!=null and sysSign!=''">and t.sys_sign = #{sysSign}</if>
<if test="stationId!=null and stationId!=''">and t.station_id = #{stationId}</if>
<if test="byx1!=null and byx1!=''">and t.byx1 = #{byx1}</if>
<if test="byx2!=null and byx2!=''">and t.byx2 = #{byx2}</if>
<if test="byx3!=null and byx3!=''">and t.byx3 = #{byx3}</if>
</sql>
<select id="queryPageByCount" parameterType="Object" resultType="java.lang.Integer">
select count(1) from link_event t
<include refid="Example_Where_Clause"/>
</select>
<select id="queryPageList" parameterType="Object" resultMap="BaseResultMap">
select t.* from link_event t
<include refid="Example_Where_Clause"/>
<if test="pager.orderCondition != null and pager.orderCondition != ''">
${pager.orderCondition}
</if>
<if test="pager.mysqlQueryCondition != null and pager.mysqlQueryCondition != ''">
${pager.mysqlQueryCondition}
</if>
</select>
</mapper>
microservice-admin/src/main/resources/mapper/sys/SysThresholdMapper.xml
View file @ 4595d076
......@@ -33,7 +33,7 @@
where t.deleted=0
<if test="id!=null and id!=''">and t.id = #{id}</if>
<if test="dicId!=null and dicId!=''">and t.dic_id = #{dicId}</if>
<if test="type!=null ">and t.type = #{type}</if>
<if test="type!=null and type!=''">and t.type = #{type}</if>
<if test="remark!=null and remark!=''">and t.remark = #{remark}</if>
<if test="minValue!=null and minValue!=''">and t.min_value = #{minValue}</if>
<if test="maxValue!=null and maxValue!=''">and t.max_value = #{maxValue}</if>
......@@ -57,7 +57,8 @@
</select>
<select id="queryPageList" parameterType="Object" resultMap="BaseResultMap">
select t.* from sys_threshold t
select t.*,sd.name as typeName from sys_threshold t
left join sys_dictionary sd on sd.id = t.type
<include refid="Example_Where_Clause"/>
<if test="pager.orderCondition != null and pager.orderCondition != ''">
${pager.orderCondition}
......
microservice-alram/src/main/java/com/devplatform/alarm/modules/alarms/controller/AlarmsInfoController.java
View file @ 4595d076
......@@ -17,22 +17,11 @@ import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
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.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.bind.annotation.*;
import java.util.*;
/**
* @author Administrator
......@@ -86,59 +75,16 @@ public class AlarmsInfoController extends AbstractController {
return R.ok().put("list", list);
}
/**
* 获取线路未处理报警数据
*
* @param params 承接对象
* @return
*/
@ApiOperation(value = "根据条件获取报警信息数据", notes = "根据条件获取报警信息数据")
@ApiImplicitParam(
name = "params",
value = "参数",
required = true,
dataType = "Map<String, Object>")
@PostMapping("/queryRoutesList")
public R queryRoutesList(@RequestParam Map<String, Object> params) {
if (params.get(Constants.LIMIT) == null) {
params.put("limit", 4);
}
List<AlarmsInfo> list = alarmsInfoService.queryRoutesAll(params);
List<String> stationIds = alarmsInfoService.queryStationIds(params);
List<Map<String,Object>> stationAlarmList = new ArrayList<>();
if(stationIds != null && stationIds.size() > 0){
for (String stationId : stationIds){
Map<String,Object> map = new HashMap<String,Object>(2);
params.put("stationId",stationId);
List<AlarmsInfo> lists = alarmsInfoService.queryRoutesAll(params);
map.put("stationId",stationId);
map.put("list",lists);
stationAlarmList.add(map);
}
}
AlarmsInfo countList = alarmsInfoService.queryRoutesGroupUntreated(params);
return R.ok().put("list", list).put("countList", countList).put("stationAlarmList",stationAlarmList);
}
@ApiOperation(value = "统计报警未处理信息", notes = "统计报警未处理信息")
@ApiOperation(value = "统计报警信息", notes = "统计报警信息")
@GetMapping("/queryGroupUntreated")
public R queryGroupUntreated(@RequestParam(required = false) String stationId) {
List<AlarmsInfo> list = alarmsInfoService.queryGroupUntreated(stationId);
return R.ok().put("list", list);
}
@ApiOperation(value = "统计报警已处理信息", notes = "统计报警已处理信息")
@GetMapping("/queryGroupProcessed")
public R queryGroupProcessed(@RequestParam(required = false) String stationId) {
List<AlarmsInfo> list = alarmsInfoService.queryGroupProcessed(stationId);
return R.ok().put("list", list);
AlarmsInfo bean1 = alarmsInfoService.queryGroupByLevel(stationId);
AlarmsInfo bean2 = alarmsInfoService.queryGroupByStatus(stationId);
return R.ok().put("level", bean1).put("status",bean2);
}
/**
* 添加
*
* @param bean 报警信息对象
* @return
*/
......@@ -318,16 +264,6 @@ public class AlarmsInfoController extends AbstractController {
return R.ok().put("count", count);
}
/**
* 查询历史视频信息
*/
@ApiOperation(value = "查询历史视频信息", notes = "查询历史视频信息")
@GetMapping("/getHistoryVideInfo")
public R getHistoryVideInfo(String id, String stationId) {
List<HashMap<String, Object>> list = alarmsInfoService.getHistoryVideInfo(id, stationId);
return R.ok().put("list", list);
}
/**
* 报警信息完成
*
......
microservice-alram/src/main/java/com/devplatform/alarm/modules/alarms/dao/AlarmsInfoDao.java
View file @ 4595d076
......@@ -3,13 +3,13 @@ package com.devplatform.alarm.modules.alarms.dao;
import com.devplatform.alarm.modules.alarms.bean.AlarmsInfo;
import com.devplatform.alarm.modules.alarms.model.AlarmsInfoModel;
import com.devplatform.common.dao.MyBaseMapper;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import org.springframework.stereotype.Repository;
import java.util.List;
import java.util.Map;
/**
* AlarmsInfo Mapper 用于报警信息的数据库操作
*
......@@ -28,14 +28,14 @@ public interface AlarmsInfoDao extends MyBaseMapper<AlarmsInfo> {
AlarmsInfo queryById(@Param("id") String id, @Param("stationId") String stationId);
/**
* 拆线呢报警信息数量
* 分页-查询报警信息数量
* @param model
* @return
*/
Integer queryPageByCount(AlarmsInfoModel model);
/**
* 查询报警信息数据
* 分页-查询报警信息数据
* @param model
* @return
*/
......@@ -49,18 +49,18 @@ public interface AlarmsInfoDao extends MyBaseMapper<AlarmsInfo> {
List<AlarmsInfo> queryAll(@Param("params") Map<String, Object> params);
/**
* 查询未处理报警信息
* 查询每种报警等级的数量
* @param stationId
* @return
*/
List<AlarmsInfo> queryGroupUntreated(@Param("stationId") String stationId);
AlarmsInfo queryGroupByLevel(@Param("stationId") String stationId);
/**
* 查询已处理报警信息
* 查询每种报警状态的数量
* @param stationId
* @return
*/
List<AlarmsInfo> queryGroupProcessed(@Param("stationId") String stationId);
AlarmsInfo queryGroupByStatus(@Param("stationId") String stationId);
/**
* 查询线路报警信息
......@@ -69,13 +69,6 @@ public interface AlarmsInfoDao extends MyBaseMapper<AlarmsInfo> {
*/
List<AlarmsInfo> queryRoutesAll(@Param("params") Map<String, Object> params);
/**
* 查询线路未处理报警信息
* @param params
* @return
*/
AlarmsInfo queryRoutesGroupUntreated(@Param("params") Map<String, Object> params);
/**
* 查询数量
* @param params
......@@ -83,19 +76,4 @@ public interface AlarmsInfoDao extends MyBaseMapper<AlarmsInfo> {
*/
Integer countNum(@Param("params") Map<String, Object> params);
/**
* 查询历史视频信息
* @param id
* @param stationId
* @return
*/
List<HashMap<String, Object>> getHistoryVideInfo(
@Param("id") String id, @Param("stationId") String stationId);
/**
* 查询站点id
* @param params
* @return
*/
List<String> queryStationIds(@Param("params") Map<String, Object> params);
}
microservice-alram/src/main/java/com/devplatform/alarm/modules/alarms/service/AlarmsInfoService.java
View file @ 4595d076
......@@ -3,7 +3,7 @@ package com.devplatform.alarm.modules.alarms.service;
import com.devplatform.alarm.modules.alarms.bean.AlarmsInfo;
import com.devplatform.alarm.modules.alarms.model.AlarmsInfoModel;
import com.devplatform.common.service.MyBaseService;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
......@@ -32,20 +32,20 @@ public interface AlarmsInfoService extends MyBaseService<AlarmsInfo> {
List<AlarmsInfo> queryPageByList(AlarmsInfoModel model);
/**
* 未处理
* 查询每种报警等级的数量
*
* @param stationId
* @return
*/
List<AlarmsInfo> queryGroupUntreated(String stationId);
AlarmsInfo queryGroupByLevel(String stationId);
/**
* 已处理
* 查询每种报警状态的数量
*
* @param stationId
* @return
*/
List<AlarmsInfo> queryGroupProcessed(String stationId);
AlarmsInfo queryGroupByStatus(String stationId);
/**
* 根据状态和站点id查询
......@@ -63,13 +63,6 @@ public interface AlarmsInfoService extends MyBaseService<AlarmsInfo> {
*/
List<AlarmsInfo> queryRoutesAll(Map<String, Object> params);
/**
*查询线路未处理报警信息
* @param params
* @return
*/
AlarmsInfo queryRoutesGroupUntreated(Map<String, Object> params);
/**
* 查询数量
* @param params
......@@ -77,18 +70,4 @@ public interface AlarmsInfoService extends MyBaseService<AlarmsInfo> {
*/
Integer countNum(Map<String, Object> params);
/**
* 查询历史视频信息
* @param id
* @param stationId
* @return
*/
List<HashMap<String, Object>> getHistoryVideInfo(String id, String stationId);
/**
* 查询站点id
* @param params
* @return
*/
List<String> queryStationIds(Map<String, Object> params);
}
microservice-alram/src/main/java/com/devplatform/alarm/modules/alarms/service/impl/AlarmsInfoServiceImpl.java
View file @ 4595d076
......@@ -5,10 +5,10 @@ import com.devplatform.alarm.modules.alarms.dao.AlarmsInfoDao;
import com.devplatform.alarm.modules.alarms.model.AlarmsInfoModel;
import com.devplatform.alarm.modules.alarms.service.AlarmsInfoService;
import com.devplatform.common.service.impl.MyBaseServiceImpl;
import java.util.HashMap;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.Map;
import org.springframework.stereotype.Service;
/**
* 报警信息的service接口实现类 <br>
......@@ -33,13 +33,13 @@ public class AlarmsInfoServiceImpl extends MyBaseServiceImpl<AlarmsInfoDao, Alar
}
@Override
public List<AlarmsInfo> queryGroupUntreated(String stationId) {
return baseMapper.queryGroupUntreated(stationId);
public AlarmsInfo queryGroupByLevel(String stationId) {
return baseMapper.queryGroupByLevel(stationId);
}
@Override
public List<AlarmsInfo> queryGroupProcessed(String stationId) {
return baseMapper.queryGroupProcessed(stationId);
public AlarmsInfo queryGroupByStatus(String stationId) {
return baseMapper.queryGroupByStatus(stationId);
}
@Override
......@@ -52,23 +52,9 @@ public class AlarmsInfoServiceImpl extends MyBaseServiceImpl<AlarmsInfoDao, Alar
return baseMapper.queryRoutesAll(params);
}
@Override
public AlarmsInfo queryRoutesGroupUntreated(Map<String, Object> params) {
return baseMapper.queryRoutesGroupUntreated(params);
}
@Override
public Integer countNum(Map<String, Object> params) {
return baseMapper.countNum(params);
}
@Override
public List<HashMap<String, Object>> getHistoryVideInfo(String id, String stationId) {
return baseMapper.getHistoryVideInfo(id, stationId);
}
@Override
public List<String> queryStationIds(Map<String, Object> params) {
return baseMapper.queryStationIds(params);
}
}
microservice-alram/src/main/resources/mapper/alarms/AlarmsInfoMapper.xml
View file @ 4595d076
......@@ -153,93 +153,27 @@
</select>
<!--统计未处理报警信息-->
<select id="queryGroupUntreated" parameterType="java.lang.Object" resultType="com.devplatform.alarm.modules.alarms.bean.AlarmsInfo">
<select id="queryGroupByLevel" parameterType="java.lang.Object" resultType="com.devplatform.alarm.modules.alarms.bean.AlarmsInfo">
SELECT
*
FROM
(
SELECT
'视频监控系统' AS systemName,
count( CASE WHEN event_level = 1 AND `status` IN (1,2) AND system_id = '438c30d3d7f241b573f22a1a36c60485' THEN 0 END ) AS oneCount,
count( CASE WHEN event_level = 2 AND `status` IN (1,2) AND system_id = '438c30d3d7f241b573f22a1a36c60485' THEN 0 END ) AS twoCount,
count( CASE WHEN event_level = 3 AND `status` IN (1,2) AND system_id = '438c30d3d7f241b573f22a1a36c60485' THEN 0 END ) AS threeCount
FROM
alarms_info where deleted = 0
<if test="stationId!=null and stationId!=''">and station_id=#{stationId}</if>
UNION
SELECT
'入侵报警系统' AS systemName,
count( CASE WHEN event_level = 1 AND `status` IN (1,2) AND system_id = '75c7c11716713edfd2ce3581f5e7c193' THEN 0 END ) AS oneCount,
count( CASE WHEN event_level = 2 AND `status` IN (1,2) AND system_id = '75c7c11716713edfd2ce3581f5e7c193' THEN 0 END ) AS twoCount,
count( CASE WHEN event_level = 3 AND `status` IN (1,2) AND system_id = '75c7c11716713edfd2ce3581f5e7c193' THEN 0 END ) AS threeCount
FROM
alarms_info where deleted = 0
<if test="stationId!=null and stationId!=''">and station_id=#{stationId}</if>
UNION
SELECT
'安全检查及探测系统' AS systemName,
count( CASE WHEN event_level = 1 AND `status` IN (1,2) AND system_id = '3a64b86b1a5dead8ff9d2ad913744e50' THEN 0 END ) AS oneCount,
count( CASE WHEN event_level = 2 AND `status` IN (1,2) AND system_id = '3a64b86b1a5dead8ff9d2ad913744e50' THEN 0 END ) AS twoCount,
count( CASE WHEN event_level = 3 AND `status` IN (1,2) AND system_id = '3a64b86b1a5dead8ff9d2ad913744e50' THEN 0 END ) AS threeCount
FROM
alarms_info where deleted = 0
<if test="stationId!=null and stationId!=''">and station_id=#{stationId}</if>
UNION
SELECT
'出入口控制系统' AS systemName,
count( CASE WHEN event_level = 1 AND `status` IN (1,2) AND system_id = 'ed401f7d9291b508d411d8192b016c6e' THEN 0 END ) AS oneCount,
count( CASE WHEN event_level = 2 AND `status` IN (1,2) AND system_id = 'ed401f7d9291b508d411d8192b016c6e' THEN 0 END ) AS twoCount,
count( CASE WHEN event_level = 3 AND `status` IN (1,2) AND system_id = 'ed401f7d9291b508d411d8192b016c6e' THEN 0 END ) AS threeCount
count( CASE WHEN event_level = 1 THEN 0 END ) AS oneCount,
count( CASE WHEN event_level = 2 THEN 0 END ) AS twoCount,
count( CASE WHEN event_level = 3 THEN 0 END ) AS threeCount
FROM
alarms_info where deleted = 0
<if test="stationId!=null and stationId!=''">and station_id=#{stationId}</if>
) a
</select>
<!--统计已处理报警信息-->
<select id="queryGroupProcessed" parameterType="java.lang.Object" resultType="com.devplatform.alarm.modules.alarms.bean.AlarmsInfo">
SELECT
*
FROM
(
SELECT
'视频监控系统' AS systemName,
count( CASE WHEN event_level = 1 AND `status` = 3 AND system_id = '438c30d3d7f241b573f22a1a36c60485' THEN 0 END ) AS oneCount,
count( CASE WHEN event_level = 2 AND `status` = 3 AND system_id = '438c30d3d7f241b573f22a1a36c60485' THEN 0 END ) AS twoCount,
count( CASE WHEN event_level = 3 AND `status` = 3 AND system_id = '438c30d3d7f241b573f22a1a36c60485' THEN 0 END ) AS threeCount
FROM
alarms_info where deleted = 0
<if test="stationId!=null and stationId!=''">and station_id=#{stationId}</if>
UNION
<select id="queryGroupByStatus" parameterType="java.lang.Object" resultType="com.devplatform.alarm.modules.alarms.bean.AlarmsInfo">
SELECT
'入侵报警系统' AS systemName,
count( CASE WHEN event_level = 1 AND `status` = 3 AND system_id = '75c7c11716713edfd2ce3581f5e7c193' THEN 0 END ) AS oneCount,
count( CASE WHEN event_level = 2 AND `status` = 3 AND system_id = '75c7c11716713edfd2ce3581f5e7c193' THEN 0 END ) AS twoCount,
count( CASE WHEN event_level = 3 AND `status` = 3 AND system_id = '75c7c11716713edfd2ce3581f5e7c193' THEN 0 END ) AS threeCount
count( CASE WHEN status = 1 THEN 0 END ) AS oneCount,
count( CASE WHEN status = 2 THEN 0 END ) AS twoCount,
count( CASE WHEN status = 3 THEN 0 END ) AS threeCount
FROM
alarms_info where deleted = 0
<if test="stationId!=null and stationId!=''">and station_id=#{stationId}</if>
UNION
SELECT
'安全检查及探测系统' AS systemName,
count( CASE WHEN event_level = 1 AND `status` = 3 AND system_id = '3a64b86b1a5dead8ff9d2ad913744e50' THEN 0 END ) AS oneCount,
count( CASE WHEN event_level = 2 AND `status` = 3 AND system_id = '3a64b86b1a5dead8ff9d2ad913744e50' THEN 0 END ) AS twoCount,
count( CASE WHEN event_level = 3 AND `status` = 3 AND system_id = '3a64b86b1a5dead8ff9d2ad913744e50' THEN 0 END ) AS threeCount
FROM
alarms_info where deleted = 0
<if test="stationId!=null and stationId!=''">and station_id=#{stationId}</if>
UNION
SELECT
'出入口控制系统' AS systemName,
count( CASE WHEN event_level = 1 AND `status` = 3 AND system_id = 'ed401f7d9291b508d411d8192b016c6e' THEN 0 END ) AS oneCount,
count( CASE WHEN event_level = 2 AND `status` = 3 AND system_id = 'ed401f7d9291b508d411d8192b016c6e' THEN 0 END ) AS twoCount,
count( CASE WHEN event_level = 3 AND `status` = 3 AND system_id = 'ed401f7d9291b508d411d8192b016c6e' THEN 0 END ) AS threeCount
FROM
alarms_info where deleted = 0
<if test="stationId!=null and stationId!=''">and station_id=#{stationId}</if>
) a
</select>
<select id="countNum" parameterType="java.lang.Object" resultType="java.lang.Integer">
select
count(1)
......@@ -250,29 +184,6 @@
<if test="params.stationId!=null and params.stationId !=''">and lr.station_id = #{params.stationId} and ai.station_id = #{params.stationId}</if>
</select>
<select id="getHistoryVideInfo" resultType="java.util.HashMap">
SELECT la.*
FROM alarms_info ai
LEFT JOIN link_logs ll ON ai.id = ll.alarms_info_id and ll.station_id = ai.station_id
LEFT JOIN link_logs_action lla ON lla.logs_id = ll.id and lla.station_id = ai.station_id
RIGHT JOIN link_attachment la ON la.link_logs_action_id = lla.id and la.station_id = ai.station_id
WHERE la.file_type = 'mp4'
AND ai.id = #{id}
<if test="stationId!=null and stationId!=''">where ai.station_id=#{stationId}</if>
</select>
<select id="queryRoutesGroupUntreated" parameterType="java.lang.Object" resultType="com.devplatform.alarm.modules.alarms.bean.AlarmsInfo">
SELECT
count( CASE WHEN ai.event_level = 1 AND ai.`status` IN (1,2) THEN 0 END ) AS oneCount,
count( CASE WHEN ai.event_level = 2 AND ai.`status` IN (1,2) THEN 0 END ) AS twoCount,
count( CASE WHEN ai.event_level = 3 AND ai.`status` IN (1,2) THEN 0 END ) AS threeCount
FROM alarms_info ai
left join li_resource lr on lr.id = ai.resource_id and lr.station_id = ai.station_id
where ai.deleted=0
<if test="params.stationId!=null and params.stationId !=''">and lr.station_id = #{params.stationId} and ai.station_id = #{params.stationId}</if>
<if test="params.lineId!=null and params.lineId !=''">and lr.line_id = #{params.lineId}</if>
</select>
<select id="queryRoutesAll" parameterType="java.lang.Object" resultType="com.devplatform.alarm.modules.alarms.bean.AlarmsInfo">
select ai.id,ai.occurrence_time,ai.event_name,ai.create_time,ai.station_id stationId,lr.line_name lineName,lr.station_name stationName,lsm.name tierName
from alarms_info ai
......@@ -284,17 +195,6 @@
ORDER BY ai.occurrence_time desc
LIMIT 0,${params.limit}
</select>
<select id="queryStationIds" resultType="java.lang.String">
select ai.station_id
from alarms_info ai
left join li_resource lr on lr.id = ai.resource_id and lr.station_id = ai.station_id
where ai.deleted=0 and ai.`status` in (1,2)
<if test="params.lineId!=null and params.lineId !=''">and lr.line_id = #{params.lineId}</if>
group by ai.station_id
</select>
</mapper>
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment