Browse Source

告警推送记录查询

hanzhengyi 1 year ago
parent
commit
7280a0f744

+ 1 - 1
service-alarm/service-alarm-api/src/main/java/com/usky/alarm/RemoteUserService.java

@@ -2,7 +2,7 @@ package com.usky.alarm;
 
 
 import com.usky.common.core.bean.ApiResult;
-import com.usky.iot.domain.SysUserVO;
+import com.usky.alarm.domain.SysUserVO;
 import org.springframework.cloud.openfeign.FeignClient;
 import org.springframework.http.MediaType;
 import org.springframework.web.bind.annotation.*;

+ 1 - 1
service-alarm/service-alarm-api/src/main/java/com/usky/alarm/domain/SysUserVO.java

@@ -1,4 +1,4 @@
-package com.usky.iot.domain;
+package com.usky.alarm.domain;
 
 
 import lombok.Data;

+ 3 - 3
service-alarm/service-alarm-api/src/main/java/com/usky/alarm/factory/RemoteUserFallbackFactory.java

@@ -1,9 +1,9 @@
-package com.usky.iot.factory;
+package com.usky.alarm.factory;
 
 import com.usky.common.core.bean.ApiResult;
 import com.usky.common.core.exception.BusinessException;
-import com.usky.iot.RemoteUserService;
-import com.usky.iot.domain.SysUserVO;
+import com.usky.alarm.RemoteUserService;
+import com.usky.alarm.domain.SysUserVO;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 

+ 29 - 1
service-alarm/service-alarm-biz/src/main/java/com/usky/alarm/controller/web/BaseAlarmNoticeResultController.java

@@ -1,9 +1,19 @@
 package com.usky.alarm.controller.web;
 
 
+import com.usky.alarm.domain.BaseAlarmNoticeResult;
+import com.usky.alarm.service.BaseAlarmNoticeResultService;
+import com.usky.common.core.bean.ApiResult;
+import com.usky.common.core.bean.CommonPage;
+import com.usky.common.log.annotation.Log;
+import com.usky.common.log.enums.BusinessType;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 
 import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
 
 /**
  * <p>
@@ -13,9 +23,27 @@ import org.springframework.stereotype.Controller;
  * @author han
  * @since 2023-09-25
  */
-@Controller
+@RestController
 @RequestMapping("/baseAlarmNoticeResult")
 public class BaseAlarmNoticeResultController {
 
+    @Autowired
+    private BaseAlarmNoticeResultService baseAlarmNoticeResultService;
+
+    /**
+     * 推送记录查看分页
+     * @param receiver  接收人
+     * @param current      当前页
+     * @param size     每页条数
+     * @return
+     */
+    @Log(title = "关联设备查看分页", businessType = BusinessType.OTHER)
+    @GetMapping("/resultInfo")
+    public ApiResult<CommonPage<BaseAlarmNoticeResult>> resultInfo(@RequestParam(value = "receiver", required = false) String receiver,
+                                                                   @RequestParam(value = "current", required = false, defaultValue = "1") Integer current,
+                                                                   @RequestParam(value = "size", required = false, defaultValue = "10") Integer size)
+    {
+        return ApiResult.success(baseAlarmNoticeResultService.resultInfo(receiver, current, size));
+    }
 }
 

+ 8 - 0
service-alarm/service-alarm-biz/src/main/java/com/usky/alarm/domain/BaseAlarmNoticeResult.java

@@ -4,6 +4,8 @@ import com.baomidou.mybatisplus.annotation.IdType;
 import com.baomidou.mybatisplus.annotation.TableId;
 import java.time.LocalDateTime;
 import java.io.Serializable;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
 
@@ -45,8 +47,14 @@ public class BaseAlarmNoticeResult implements Serializable {
     /**
      * 通知时间
      */
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
     private LocalDateTime noticeTime;
 
+    /**
+     * 通知类型(1、站内 2、微信 3、语音 4、短信 5、邮件)
+     */
+    private Integer noticeType;
+
     /**
      * 是否已读
      */

+ 2 - 1
service-alarm/service-alarm-biz/src/main/java/com/usky/alarm/service/BaseAlarmNoticeResultService.java

@@ -1,6 +1,7 @@
 package com.usky.alarm.service;
 
 import com.usky.alarm.domain.BaseAlarmNoticeResult;
+import com.usky.common.core.bean.CommonPage;
 import com.usky.common.mybatis.core.CrudService;
 
 /**
@@ -12,5 +13,5 @@ import com.usky.common.mybatis.core.CrudService;
  * @since 2023-09-25
  */
 public interface BaseAlarmNoticeResultService extends CrudService<BaseAlarmNoticeResult> {
-
+    CommonPage<BaseAlarmNoticeResult> resultInfo(String receiver, Integer current, Integer size);
 }

+ 16 - 1
service-alarm/service-alarm-biz/src/main/java/com/usky/alarm/service/impl/BaseAlarmNoticeResultServiceImpl.java

@@ -1,9 +1,16 @@
 package com.usky.alarm.service.impl;
 
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.toolkit.StringUtils;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.usky.alarm.domain.BaseAlarmNoticeResult;
 import com.usky.alarm.mapper.BaseAlarmNoticeResultMapper;
 import com.usky.alarm.service.BaseAlarmNoticeResultService;
+import com.usky.common.core.bean.CommonPage;
 import com.usky.common.mybatis.core.AbstractCrudService;
+import com.usky.common.security.utils.SecurityUtils;
 import org.springframework.stereotype.Service;
 
 /**
@@ -16,5 +23,13 @@ import org.springframework.stereotype.Service;
  */
 @Service
 public class BaseAlarmNoticeResultServiceImpl extends AbstractCrudService<BaseAlarmNoticeResultMapper, BaseAlarmNoticeResult> implements BaseAlarmNoticeResultService {
-
+    @Override
+    public CommonPage<BaseAlarmNoticeResult> resultInfo(String receiver, Integer current, Integer size) {
+        IPage<BaseAlarmNoticeResult> page = new Page<>(current, size);
+        LambdaQueryWrapper<BaseAlarmNoticeResult> queryWrapper1 = Wrappers.lambdaQuery();
+        queryWrapper1.like(StringUtils.isNotBlank(receiver),BaseAlarmNoticeResult::getReceiver, receiver);
+//                .eq(BaseAlarmNoticeResult::getTenantId, SecurityUtils.getTenantId());
+        page = this.page(page,queryWrapper1);
+        return new CommonPage<>(page.getRecords(),page.getTotal(),page.getCurrent(),page.getSize());
+    }
 }

+ 1 - 0
service-alarm/service-alarm-biz/src/main/resources/mapper/alarm/BaseAlarmNoticeResultMapper.xml

@@ -9,6 +9,7 @@
         <result column="notice_result" property="noticeResult" />
         <result column="alarm_id" property="alarmId" />
         <result column="notice_time" property="noticeTime" />
+        <result column="notice_type" property="noticeType" />
         <result column="is_read" property="isRead" />
         <result column="dept_id" property="deptId" />
         <result column="tenant_id" property="tenantId" />