第三方报警系统推送页面开发

business-service/src/main/java/com/ozs/entity/vo/MsgAlarmTemporary.java

@@ -0,0 +1,133 @@
+package com.ozs.entity.vo;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.ozs.common.annotation.Excel;
+import com.ozs.common.core.domain.BaseEntity;
+import com.ozs.entity.BaseRailwayManagement;
+import io.swagger.annotations.ApiModel;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.io.Serializable;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * <p>
+ * 报警信息临时表
+ * </p>
+ *
+ * @author ozs
+ * @since 2023-02-22
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@Builder
+@ApiModel("报警信息临时表")
+public class MsgAlarmTemporary extends BaseRailwayManagement implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 主键ID
+     */
+    @TableId(value = "id", type = IdType.AUTO)
+    private Long id;
+
+    /**
+     * 报警唯一标识
+     */
+    private String alarmId;
+
+    /**
+     * 报警时间
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    private Date alarmTime;
+
+    /**
+     * 报警线路
+     */
+    private String railwayCode;
+
+    /**
+     * 报警里程位置
+     */
+    private Integer alarmMile;
+
+    /**
+     * 报警内容
+     */
+    @Excel(name = "报警内容")
+    private String content;
+
+    /**
+     * 报警级别
+     */
+    private Integer alarmLevel;
+
+    /**
+     * 报警置信度（百分比）
+     */
+    private Integer alarmConfidence;
+
+    /**
+     * 报警行别(1上行2下行)
+     */
+    private Integer lineDir;
+
+    /**
+     * 报警病害类型（1泥石流2异物侵线 3断轨监测）
+     */
+    private Integer alarmType;
+    @TableField(exist = false)
+    @Excel(name = "报警病害类型")
+    private String alarmTypeStr;
+
+    /**
+     * 框定范围
+     */
+    private String alarmAttr;
+
+    private String files;
+
+    /**
+     * 线路名称
+     */
+    @TableField(exist = false)
+    @Excel(name = "报警线路")
+    private String railwayName;
+    
+
+    /**
+     * 报警里程位置字符串形式
+     */
+    @TableField(exist = false)
+    @Excel(name = "报警里程位置")
+    private String alarmMiles;
+    
+
+    /**
+     * 报警行别字符串(1上行2下行)
+     */
+    @TableField(exist = false)
+    @Excel(name = "报警行别")
+    private String lineDirName;
+
+    /**
+     * 报警病害类型（目前只有1泥石流，后续可扩展使用）
+     */
+    @TableField(exist = false)
+    @Excel(name = "报警病害类型")
+    private String alarmTypeName;
+
+
+
+
+}

business-service/src/main/java/com/ozs/mapper/MsgAlarmTemporaryMapper.java

@@ -0,0 +1,21 @@
+package com.ozs.mapper;
+
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.ozs.entity.vo.MsgAlarmTemporary;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * <p>
+ * 报警信息临时表
+ * </p>
+ *
+ * @author ozs
+ * @since 2023-02-22
+ */
+
+@Mapper
+public interface MsgAlarmTemporaryMapper extends BaseMapper<MsgAlarmTemporary> {
+
+    
+}

business-service/src/main/java/com/ozs/service/MsgAlarmTemporaryService.java

@@ -0,0 +1,7 @@
+package com.ozs.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.ozs.entity.vo.MsgAlarmTemporary;
+
+public interface MsgAlarmTemporaryService extends IService<MsgAlarmTemporary> {
+}

business-service/src/main/java/com/ozs/service/impl/MsgAlarmTemporaryServiceImpl.java

@@ -0,0 +1,11 @@
+package com.ozs.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ozs.entity.vo.MsgAlarmTemporary;
+import com.ozs.mapper.MsgAlarmTemporaryMapper;
+import com.ozs.service.MsgAlarmTemporaryService;
+import org.springframework.stereotype.Service;
+
+@Service
+public class MsgAlarmTemporaryServiceImpl extends ServiceImpl<MsgAlarmTemporaryMapper, MsgAlarmTemporary> implements MsgAlarmTemporaryService {
+}

business-service/src/main/resources/mapper/BaseCameraManagementMapper.xml

@@ -24,6 +24,9 @@
             <if test="online != null and online != 0">
                 and online = #{online}
             </if>
+            <if test="enableOrNot != null and enableOrNot != 0">
+                and ENABLE_OR_NOT = #{enableOrNot}
+            </if>
             <if test="ids != null and ids.size>0">
                 and id in
                 <foreach item="items" collection="ids" separator="," open="(" close=")" index="">

business-service/src/main/resources/mapper/MsgAlarmTemporaryMapper.xml

@@ -0,0 +1,5 @@
+<?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.ozs.mapper.MsgAlarmTemporaryMapper">
+    
+</mapper>

vehicle-admin/src/main/java/com/ozs/web/controller/accountmanagment/MsgAlarmTemporaryController.java

@@ -0,0 +1,61 @@
+package com.ozs.web.controller.accountmanagment;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.ozs.common.annotation.Log;
+import com.ozs.common.core.controller.BaseController;
+import com.ozs.common.core.domain.AjaxResult;
+import com.ozs.common.enums.BusinessType;
+import com.ozs.common.utils.IdempotenceUtils;
+import com.ozs.common.utils.StringUtils;
+import com.ozs.entity.BaseRailwayManagement;
+import com.ozs.entity.vo.MsgAlarmTemporary;
+import com.ozs.service.MsgAlarmTemporaryService;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.util.ObjectUtils;
+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;
+
+
+/**
+ * @author Administrator
+ */
+@RestController
+@RequestMapping("/service/msgAlarmTemporary")
+public class MsgAlarmTemporaryController extends BaseController {
+
+    @Autowired
+    private IdempotenceUtils idempotenceUtils;
+
+    @Autowired
+    private MsgAlarmTemporaryService msgAlarmTemporaryService;
+
+
+    @PostMapping("/saveMsgAlarmTemporary")
+    @ApiOperation("新增报警信息临时表信息")
+    @Log(title = "报警信息临时表管理", businessType = BusinessType.INSERT)
+    public AjaxResult saveMsgAlarmTemporary(@RequestBody MsgAlarmTemporary msgAlarmTemporary) {
+        String idempotence = idempotenceUtils.getIdempotence(msgAlarmTemporary.getAlarmId());
+        if (StringUtils.isNotEmpty(idempotence)) {
+            return error("你的网络卡顿,请不要一直添加!!!");
+        }
+        idempotenceUtils.createIdempotence(msgAlarmTemporary.getAlarmId());
+        LambdaQueryWrapper<MsgAlarmTemporary> lw = new LambdaQueryWrapper<>();
+        if (!ObjectUtils.isEmpty(msgAlarmTemporary.getAlarmId())) {
+            lw.eq(MsgAlarmTemporary::getAlarmId, msgAlarmTemporary.getAlarmId());
+            MsgAlarmTemporary msgAlarmTemporary1 = msgAlarmTemporaryService.getOne(lw);
+            if (!ObjectUtils.isEmpty(msgAlarmTemporary1)) {
+                idempotenceUtils.deleteIdempotence(msgAlarmTemporary.getAlarmId());
+                return error("报警唯一标识已存在,不能重复添加");
+            }
+        }
+        if (msgAlarmTemporaryService.save(msgAlarmTemporary)) {
+            idempotenceUtils.deleteIdempotence(msgAlarmTemporary.getAlarmId());
+            return AjaxResult.success();
+        }
+        idempotenceUtils.deleteIdempotence(msgAlarmTemporary.getAlarmId());
+        return AjaxResult.error();
+    }
+}

vehicle-admin/src/main/java/com/ozs/web/controller/accountmanagment/MsgHeartbeatAlarmMessageController.java

@@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.ozs.common.annotation.Log;
+import com.ozs.common.core.controller.BaseController;
 import com.ozs.common.core.domain.AjaxResult;
 import com.ozs.common.enums.BusinessType;
 import com.ozs.common.utils.StringUtils;
@@ -30,7 +31,7 @@ import java.util.stream.Collectors;
 
 @RestController
 @RequestMapping("/service/msgHeartbeatAlarmMessage")
-public class MsgHeartbeatAlarmMessageController {
+public class MsgHeartbeatAlarmMessageController extends BaseController {
 
     @Autowired
     private MsgHeartbeatAlarmMessageService msgHeartbeatAlarmMessageService;