设备故障

device-api-cloud/src/main/java/com/xy/feign/DeviceFaultInfoFeign.java

@@ -0,0 +1,19 @@
+package com.xy.feign;
+
+import com.xy.service.DeviceFaultInfoService;
+import com.xy.FeignInterceptor;
+import com.xy.consts.ServiceConsts;
+import org.springframework.cloud.openfeign.FeignClient;
+
+/**
+ * <p>
+ * 设备故障信息 feign
+ * </p>
+ *
+ * @author 谭斌
+ * @since 2024-01-08
+ */
+@FeignClient(value = ServiceConsts.SERVICE_NAME, configuration = FeignInterceptor.class)
+public interface DeviceFaultInfoFeign extends DeviceFaultInfoService {
+
+}

device-api-cloud/src/main/java/com/xy/feign/DeviceFaultLogFeign.java

@@ -0,0 +1,19 @@
+package com.xy.feign;
+
+import com.xy.service.DeviceFaultLogService;
+import com.xy.FeignInterceptor;
+import com.xy.consts.ServiceConsts;
+import org.springframework.cloud.openfeign.FeignClient;
+
+/**
+ * <p>
+ * 设备故障日志 feign
+ * </p>
+ *
+ * @author 谭斌
+ * @since 2024-01-08
+ */
+@FeignClient(value = ServiceConsts.SERVICE_NAME, configuration = FeignInterceptor.class)
+public interface DeviceFaultLogFeign extends DeviceFaultLogService {
+
+}

device-api-cloud/src/main/java/com/xy/feign/DeviceFaultMonitorConfigFeign.java

@@ -0,0 +1,19 @@
+package com.xy.feign;
+
+import com.xy.service.DeviceFaultMonitorConfigService;
+import com.xy.FeignInterceptor;
+import com.xy.consts.ServiceConsts;
+import org.springframework.cloud.openfeign.FeignClient;
+
+/**
+ * <p>
+ * 设备故障监控配置 feign
+ * </p>
+ *
+ * @author 谭斌
+ * @since 2024-01-08
+ */
+@FeignClient(value = ServiceConsts.SERVICE_NAME, configuration = FeignInterceptor.class)
+public interface DeviceFaultMonitorConfigFeign extends DeviceFaultMonitorConfigService {
+
+}

device-api-service/src/main/java/com/xy/entity/DeviceFaultInfo.java

@@ -0,0 +1,69 @@
+package com.xy.entity;
+
+import com.baomidou.mybatisplus.annotation.FieldFill;
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * <p>
+ * 设备故障信息
+ * </p>
+ *
+ * @author 谭斌
+ * @since 2024-01-08
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@ApiModel(value = "DeviceFaultInfo对象", description = "设备故障信息")
+public class DeviceFaultInfo implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @ApiModelProperty(value = "ID")
+    @TableId(value = "fault_id", type = IdType.ASSIGN_ID)
+    private Long faultId;
+
+    @ApiModelProperty(value = "商户ID")
+    private Long mercId;
+
+    @ApiModelProperty(value = "设备编号")
+    private Long deviceId;
+
+    @ApiModelProperty(value = "故障描述")
+    private String describes;
+
+    @ApiModelProperty(value = "事件编码")
+    private String eventCode;
+
+    @ApiModelProperty(value = "是否已解决")
+    private Boolean state;
+
+    @ApiModelProperty(value = "创建时间")
+    @TableField(fill = FieldFill.INSERT)
+    private LocalDateTime createTime;
+
+    @ApiModelProperty(value = "更新时间")
+    @TableField(fill = FieldFill.UPDATE)
+    private LocalDateTime updateTime;
+
+    @ApiModelProperty(value = "标记解决时间")
+    private LocalDateTime resolveTime;
+
+    @ApiModelProperty(value = "事件发生次数")
+    private Integer eventNum;
+
+    @ApiModelProperty(value = "故障级别-字典：device_fault_level")
+    private Integer faultLevel;
+
+
+}

device-api-service/src/main/java/com/xy/entity/DeviceFaultLog.java

@@ -0,0 +1,56 @@
+package com.xy.entity;
+
+import com.baomidou.mybatisplus.annotation.*;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * <p>
+ * 设备故障日志
+ * </p>
+ *
+ * @author 谭斌
+ * @since 2024-01-08
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@ApiModel(value = "DeviceFaultLog对象", description = "设备故障日志")
+public class DeviceFaultLog implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @ApiModelProperty(value = "ID")
+    @TableId(value = "log_id", type = IdType.ASSIGN_ID)
+    private Long logId;
+
+    @ApiModelProperty(value = "商户ID")
+    private Long mercId;
+
+    @ApiModelProperty(value = "设备编号")
+    private Long deviceId;
+
+    @ApiModelProperty(value = "故障描述")
+    private String describes;
+
+    @ApiModelProperty(value = "事件编码")
+    private String eventCode;
+
+    @ApiModelProperty(value = "事件发生时间")
+    private LocalDateTime eventTime;
+
+    @ApiModelProperty(value = "创建时间")
+    @TableField(fill = FieldFill.INSERT)
+    private LocalDateTime createTime;
+
+    @TableLogic
+    private Integer deleted;
+
+
+}

device-api-service/src/main/java/com/xy/entity/DeviceFaultMonitorConfig.java

@@ -0,0 +1,63 @@
+package com.xy.entity;
+
+import com.baomidou.mybatisplus.annotation.FieldFill;
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * <p>
+ * 设备故障监控配置
+ * </p>
+ *
+ * @author 谭斌
+ * @since 2024-01-08
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@ApiModel(value = "DeviceFaultMonitorConfig对象", description = "设备故障监控配置")
+public class DeviceFaultMonitorConfig implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @ApiModelProperty(value = "ID")
+    @TableId(value = "monitor_id", type = IdType.ASSIGN_ID)
+    private Long monitorId;
+
+    @ApiModelProperty(value = "事件编码")
+    private String eventCode;
+
+    @ApiModelProperty(value = "配置描述")
+    private String configName;
+
+    @ApiModelProperty(value = "是否已启用")
+    private Boolean state;
+
+    @ApiModelProperty(value = "创建时间")
+    @TableField(fill = FieldFill.INSERT)
+    private LocalDateTime createTime;
+
+    @ApiModelProperty(value = "标记解决时间")
+    @TableField(fill = FieldFill.UPDATE)
+    private LocalDateTime updateTime;
+
+    @ApiModelProperty(value = "条件2：达到m次")
+    private Integer eventNum;
+
+    @ApiModelProperty(value = "条件1：最近n分钟")
+    private Long minuteNum;
+
+    @ApiModelProperty(value = "故障级别-字典：device_fault_level")
+    private Integer faultLevel;
+
+
+}

device-api-service/src/main/java/com/xy/job/DeviceFaultJob.java

@@ -0,0 +1,58 @@
+package com.xy.job;
+
+import cn.hutool.core.date.DateUtil;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.xxl.job.core.biz.model.ReturnT;
+import com.xxl.job.core.handler.annotation.XxlJob;
+import com.xy.entity.DeviceFaultLog;
+import com.xy.entity.SysDictRedis;
+import com.xy.service.DeviceFaultLogServiceImpl;
+import com.xy.sys.EnumDataClearSize;
+import com.xy.utils.RecursionUtils;
+import com.xy.utils.SysDictUtils;
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import java.util.Date;
+
+
+/**
+ * 设备故障job
+ *
+ * @author 谭斌
+ * @date 2024/01/08
+ */
+@Slf4j
+@Component
+@AllArgsConstructor
+public class DeviceFaultJob {
+
+    private DeviceFaultLogServiceImpl deviceFaultLogService;
+
+    /**
+     * 故障日志清理 默认保留n天
+     *
+     * @return
+     */
+    @XxlJob("delDeviceFaultLog")
+    public ReturnT<String> delDeviceFaultLog() {
+        SysDictRedis sysDictRedis = SysDictUtils.get(EnumDataClearSize.Code.CODE.getCode(), EnumDataClearSize.DEVICE_FAULT_LOG_DAY.getCode());
+        Integer saveDay = Integer.valueOf(sysDictRedis.getValue());
+        // 获取当前日期
+        Date today = DateUtil.date();
+        // 获取n天前的日期的开始时间（包含今天）
+        Date daysAgo = DateUtil.beginOfDay(DateUtil.offsetDay(today, -(saveDay - 1)));
+        LambdaQueryWrapper<DeviceFaultLog> lambdaQueryWrapper = new LambdaQueryWrapper<DeviceFaultLog>()
+                .lt(DeviceFaultLog::getEventTime, daysAgo)
+                .last("limit 10000");
+        RecursionUtils.recursion(current -> {
+            boolean remove = deviceFaultLogService.remove(lambdaQueryWrapper);
+            if (!remove) {
+                return false;
+            }
+            return true;
+        });
+        return ReturnT.SUCCESS;
+    }
+}

device-api-service/src/main/java/com/xy/mapper/DeviceFaultInfoMapper.java

@@ -0,0 +1,16 @@
+package com.xy.mapper;
+
+import com.xy.entity.DeviceFaultInfo;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * <p>
+ * 设备故障信息 Mapper 接口
+ * </p>
+ *
+ * @author 谭斌
+ * @since 2024-01-08
+ */
+public interface DeviceFaultInfoMapper extends BaseMapper<DeviceFaultInfo> {
+
+}

device-api-service/src/main/java/com/xy/mapper/DeviceFaultLogMapper.java

@@ -0,0 +1,16 @@
+package com.xy.mapper;
+
+import com.xy.entity.DeviceFaultLog;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * <p>
+ * 设备故障日志 Mapper 接口
+ * </p>
+ *
+ * @author 谭斌
+ * @since 2024-01-08
+ */
+public interface DeviceFaultLogMapper extends BaseMapper<DeviceFaultLog> {
+
+}

device-api-service/src/main/java/com/xy/mapper/DeviceFaultMonitorConfigMapper.java

@@ -0,0 +1,16 @@
+package com.xy.mapper;
+
+import com.xy.entity.DeviceFaultMonitorConfig;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * <p>
+ * 设备故障监控配置 Mapper 接口
+ * </p>
+ *
+ * @author 谭斌
+ * @since 2024-01-08
+ */
+public interface DeviceFaultMonitorConfigMapper extends BaseMapper<DeviceFaultMonitorConfig> {
+
+}

device-api-service/src/main/java/com/xy/mapper/mapper/DeviceFaultInfoMapper.xml

@@ -0,0 +1,18 @@
+<?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.xy.mapper.DeviceFaultInfoMapper">
+    <!-- 通用查询映射结果 -->
+    <resultMap id="BaseResultMap" type="com.xy.entity.DeviceFaultInfo">
+        <id column="fault_id" property="faultId"/>
+        <result column="merc_id" property="mercId"/>
+        <result column="device_id" property="deviceId"/>
+        <result column="describes" property="describes"/>
+        <result column="event_code" property="eventCode"/>
+        <result column="state" property="state"/>
+        <result column="create_time" property="createTime"/>
+        <result column="update_time" property="updateTime"/>
+        <result column="resolve_time" property="resolveTime"/>
+        <result column="event_num" property="eventNum"/>
+        <result column="fault_level" property="faultLevel"/>
+    </resultMap>
+</mapper>

device-api-service/src/main/java/com/xy/mapper/mapper/DeviceFaultLogMapper.xml

@@ -0,0 +1,14 @@
+<?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.xy.mapper.DeviceFaultLogMapper">
+    <!-- 通用查询映射结果 -->
+    <resultMap id="BaseResultMap" type="com.xy.entity.DeviceFaultLog">
+        <id column="log_id" property="logId"/>
+        <result column="merc_id" property="mercId"/>
+        <result column="device_id" property="deviceId"/>
+        <result column="describes" property="describes"/>
+        <result column="event_code" property="eventCode"/>
+        <result column="event_time" property="eventTime"/>
+        <result column="create_time" property="createTime"/>
+    </resultMap>
+</mapper>

device-api-service/src/main/java/com/xy/mapper/mapper/DeviceFaultMonitorConfigMapper.xml

@@ -0,0 +1,15 @@
+<?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.xy.mapper.DeviceFaultMonitorConfigMapper">
+    <!-- 通用查询映射结果 -->
+    <resultMap id="BaseResultMap" type="com.xy.entity.DeviceFaultMonitorConfig">
+        <id column="monitor_id" property="monitorId"/>
+        <result column="event_code" property="eventCode"/>
+        <result column="state" property="state"/>
+        <result column="create_time" property="createTime"/>
+        <result column="update_time" property="updateTime"/>
+        <result column="event_num" property="eventNum"/>
+        <result column="minute_num" property="minuteNum"/>
+        <result column="fault_level" property="faultLevel"/>
+    </resultMap>
+</mapper>

device-api-service/src/main/java/com/xy/service/DeviceFaultInfoServiceImpl.java

@@ -0,0 +1,139 @@
+package com.xy.service;
+
+import cn.hutool.core.collection.CollUtil;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.xy.collections.list.JArrayList;
+import com.xy.collections.map.JMap;
+import com.xy.dto.DeviceFaultInfoDto;
+import com.xy.dto.be.MercDto;
+import com.xy.entity.DeviceFaultInfo;
+import com.xy.entity.DeviceFaultLog;
+import com.xy.entity.DeviceInfo;
+import com.xy.error.CommRuntimeException;
+import com.xy.mapper.DeviceFaultInfoMapper;
+import com.xy.service.be.MercService;
+import com.xy.utils.Emptys;
+import com.xy.utils.MybatisPlusQuery;
+import com.xy.utils.PageBean;
+import com.xy.utils.R;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+
+import java.time.LocalDateTime;
+import java.util.List;
+import java.util.stream.Collectors;
+
+import static com.xy.utils.Beans.copy;
+import static com.xy.utils.PlusBeans.toIPage;
+import static com.xy.utils.PlusBeans.toPageBean;
+
+
+/**
+ * <p>
+ * 设备故障信息 服务实现类
+ * </p>
+ *
+ * @author 谭斌
+ * @since 2024-01-08
+ */
+@Service
+@RequiredArgsConstructor
+@Api(tags = "设备故障信息")
+public class DeviceFaultInfoServiceImpl extends ServiceImpl<DeviceFaultInfoMapper, DeviceFaultInfo> implements DeviceFaultInfoService {
+
+    private final DeviceFaultLogServiceImpl deviceFaultLogService;
+    private final MercService mercService;
+    private final DeviceInfoServiceImpl deviceInfoService;
+
+    @PostMapping("obj")
+    @ApiOperation("对象查询")
+    public R<DeviceFaultInfoDto.Vo> obj(@RequestBody DeviceFaultInfoDto.Vo vo) {
+        DeviceFaultInfoDto.SelectList selectList = copy(DeviceFaultInfoDto.SelectList.class, vo);
+        List<DeviceFaultInfoDto.Vo> list = list(selectList).getData();
+        if (Emptys.check(list)) {
+            return R.ok(list.get(0));
+        }
+        return R.ok();
+    }
+
+    @PostMapping("list")
+    @ApiOperation("集合查询")
+    public R<List<DeviceFaultInfoDto.Vo>> list(@RequestBody DeviceFaultInfoDto.SelectList selectList) {
+        LambdaQueryWrapper<DeviceFaultInfo> lambdaQueryWrapper = new MybatisPlusQuery().eqWrapper(selectList, DeviceFaultInfo.class).build();
+        List<DeviceFaultInfo> list = list(lambdaQueryWrapper);
+        return R.ok(copy(DeviceFaultInfoDto.Vo.class, list));
+    }
+
+    @PostMapping("page")
+    @ApiOperation("分页查询")
+    public R<PageBean<DeviceFaultInfoDto.Vo>> page(@RequestBody DeviceFaultInfoDto.Page page) {
+        PageBean pageBean = page.getPage();
+        LocalDateTime beginTime = page.getBeginCreateTime();
+        LocalDateTime endTime = page.getEndCreateTime();
+        LambdaQueryWrapper<DeviceFaultInfo> lambdaQueryWrapper = new MybatisPlusQuery()
+                .eqWrapper(page, DeviceFaultInfo.class).build()
+                .ge(beginTime != null, DeviceFaultInfo::getCreateTime, beginTime)
+                .le(endTime != null, DeviceFaultInfo::getCreateTime, endTime);
+        IPage<DeviceFaultInfo> iPage = page(toIPage(pageBean), lambdaQueryWrapper);
+        PageBean<DeviceFaultInfoDto.Vo> data = toPageBean(DeviceFaultInfoDto.Vo.class, iPage);
+        List<DeviceFaultInfoDto.Vo> records = data.getRecords();
+        if (CollUtil.isNotEmpty(records)) {
+            List<Long> mercIds = records.stream().map(DeviceFaultInfoDto.Vo::getMercId).distinct().collect(Collectors.toList());
+            List<MercDto.Vo> mercs = mercService.list(new MercDto.SelectList().setMercIds(mercIds)).getData();
+            JMap<Long, MercDto.Vo> longVoJMap = new JArrayList<>(mercs).toMap(MercDto.Vo::getId).cover();
+            records.forEach(r -> {
+                Long mercId = r.getMercId();
+                if (longVoJMap.get(mercId) != null) {
+                    r.setMercName(longVoJMap.get(mercId).getName());
+                }
+            });
+            data.setRecords(records);
+        }
+
+        return R.ok(data);
+    }
+
+    @PostMapping("save")
+    @ApiOperation("添加")
+    public R save(@RequestBody @Validated DeviceFaultInfoDto.Save save) {
+        DeviceFaultInfo saveInfo = copy(DeviceFaultInfo.class, save);
+        save(saveInfo);
+        return R.ok();
+    }
+
+    @PostMapping("update")
+    @ApiOperation("修改")
+    public R update(@RequestBody @Validated DeviceFaultInfoDto.Update update) {
+        DeviceFaultInfo updateInfo = copy(DeviceFaultInfo.class, update);
+        updateById(updateInfo);
+        return R.ok();
+    }
+
+    @PostMapping("resolve")
+    @ApiOperation("标记已解决")
+    public R resolve(@RequestBody @Validated DeviceFaultInfoDto.Update update) {
+        DeviceFaultInfo deviceFaultInfo = this.getById(update.getFaultId());
+        if (deviceFaultInfo == null) {
+            throw new CommRuntimeException("操作对象不存在！");
+        }
+        DeviceFaultInfo updateInfo = copy(DeviceFaultInfo.class, update);
+        updateInfo.setState(true);
+        updateInfo.setFaultLevel(-1);
+        boolean b = updateById(updateInfo);
+        if (b) {
+            //清理日志 故障信息表标记已解决，清除日志表中对应设备事件在标记已解决时间之前所有事件。
+            deviceFaultLogService.remove(Wrappers.<DeviceFaultLog>lambdaUpdate().le(DeviceFaultLog::getEventTime, LocalDateTime.now()));
+            //更新故障等级为正常
+            deviceInfoService.updateById(new DeviceInfo().setDeviceId(deviceFaultInfo.getDeviceId()).setFaultLevel(-1));
+        }
+        return R.ok();
+    }
+}

device-api-service/src/main/java/com/xy/service/DeviceFaultLogServiceImpl.java

@@ -0,0 +1,84 @@
+package com.xy.service;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.xy.dto.DeviceFaultLogDto;
+import com.xy.entity.DeviceFaultLog;
+import com.xy.mapper.DeviceFaultLogMapper;
+import com.xy.utils.Emptys;
+import com.xy.utils.MybatisPlusQuery;
+import com.xy.utils.PageBean;
+import com.xy.utils.R;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.AllArgsConstructor;
+import org.springframework.stereotype.Service;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+
+import java.util.List;
+
+import static com.xy.utils.Beans.copy;
+import static com.xy.utils.PlusBeans.toIPage;
+import static com.xy.utils.PlusBeans.toPageBean;
+
+
+/**
+* <p>
+* 设备故障日志 服务实现类
+* </p>
+*
+* @author 谭斌
+* @since 2024-01-08
+*/
+@Service
+@AllArgsConstructor
+@Api(tags = "设备故障日志")
+public class DeviceFaultLogServiceImpl extends ServiceImpl<DeviceFaultLogMapper, DeviceFaultLog> implements DeviceFaultLogService {
+
+    @PostMapping("obj")
+    @ApiOperation("对象查询")
+    public R<DeviceFaultLogDto.Vo> obj(@RequestBody DeviceFaultLogDto.Vo vo) {
+        DeviceFaultLogDto.SelectList selectList = copy(DeviceFaultLogDto.SelectList.class, vo);
+        List<DeviceFaultLogDto.Vo> list = list(selectList).getData();
+        if(Emptys.check(list)) {
+            return R.ok(list.get(0));
+        }
+        return R.ok();
+    }
+
+    @PostMapping("list")
+    @ApiOperation("集合查询")
+    public R<List<DeviceFaultLogDto.Vo>> list(@RequestBody DeviceFaultLogDto.SelectList selectList) {
+        LambdaQueryWrapper<DeviceFaultLog> lambdaQueryWrapper = new MybatisPlusQuery().eqWrapper(selectList, DeviceFaultLog.class).build();
+        List<DeviceFaultLog> list = list(lambdaQueryWrapper);
+        return R.ok(copy(DeviceFaultLogDto.Vo.class, list));
+    }
+
+    @PostMapping("page")
+    @ApiOperation("分页查询")
+    public R<PageBean<DeviceFaultLogDto.Vo>> page(@RequestBody DeviceFaultLogDto.Page page) {
+        PageBean pageBean = page.getPage();
+        LambdaQueryWrapper<DeviceFaultLog> lambdaQueryWrapper = new MybatisPlusQuery().eqWrapper(page, DeviceFaultLog.class).build();
+        IPage<DeviceFaultLog> iPage = page(toIPage(pageBean), lambdaQueryWrapper);
+        return R.ok(toPageBean(DeviceFaultLogDto.Vo.class, iPage));
+    }
+
+    @PostMapping("save")
+    @ApiOperation("添加")
+    public R save(@RequestBody @Validated DeviceFaultLogDto.Save save) {
+        DeviceFaultLog saveInfo = copy(DeviceFaultLog.class, save);
+        save(saveInfo);
+        return R.ok();
+    }
+
+    @PostMapping("update")
+    @ApiOperation("修改")
+    public R update(@RequestBody @Validated DeviceFaultLogDto.Update update) {
+        DeviceFaultLog updateInfo = copy(DeviceFaultLog.class, update);
+        updateById(updateInfo);
+        return R.ok();
+    }
+}

device-api-service/src/main/java/com/xy/service/DeviceFaultMonitorConfigServiceImpl.java

@@ -0,0 +1,85 @@
+package com.xy.service;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.xy.dto.DeviceFaultMonitorConfigDto;
+import com.xy.entity.DeviceFaultMonitorConfig;
+import com.xy.mapper.DeviceFaultMonitorConfigMapper;
+import com.xy.utils.Emptys;
+import com.xy.utils.MybatisPlusQuery;
+import com.xy.utils.PageBean;
+import com.xy.utils.R;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.AllArgsConstructor;
+import org.springframework.stereotype.Service;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+
+import java.util.List;
+
+import static com.xy.utils.Beans.copy;
+import static com.xy.utils.PlusBeans.toIPage;
+import static com.xy.utils.PlusBeans.toPageBean;
+
+
+/**
+ * <p>
+ * 设备故障监控配置 服务实现类
+ * </p>
+ *
+ * @author 谭斌
+ * @since 2024-01-08
+ */
+@Service
+@AllArgsConstructor
+@Api(tags = "设备故障监控配置")
+public class DeviceFaultMonitorConfigServiceImpl extends ServiceImpl<DeviceFaultMonitorConfigMapper, DeviceFaultMonitorConfig> implements DeviceFaultMonitorConfigService {
+
+    @PostMapping("obj")
+    @ApiOperation("对象查询")
+    public R<DeviceFaultMonitorConfigDto.Vo> obj(@RequestBody DeviceFaultMonitorConfigDto.Vo vo) {
+        DeviceFaultMonitorConfigDto.SelectList selectList = copy(DeviceFaultMonitorConfigDto.SelectList.class, vo);
+        List<DeviceFaultMonitorConfigDto.Vo> list = list(selectList).getData();
+        if (Emptys.check(list)) {
+            return R.ok(list.get(0));
+        }
+        return R.ok();
+    }
+
+
+    @PostMapping("list")
+    @ApiOperation("集合查询")
+    public R<List<DeviceFaultMonitorConfigDto.Vo>> list(@RequestBody DeviceFaultMonitorConfigDto.SelectList selectList) {
+        LambdaQueryWrapper<DeviceFaultMonitorConfig> lambdaQueryWrapper = new MybatisPlusQuery().eqWrapper(selectList, DeviceFaultMonitorConfig.class).build();
+        List<DeviceFaultMonitorConfig> list = list(lambdaQueryWrapper);
+        return R.ok(copy(DeviceFaultMonitorConfigDto.Vo.class, list));
+    }
+
+    @PostMapping("page")
+    @ApiOperation("分页查询")
+    public R<PageBean<DeviceFaultMonitorConfigDto.Vo>> page(@RequestBody DeviceFaultMonitorConfigDto.Page page) {
+        PageBean pageBean = page.getPage();
+        LambdaQueryWrapper<DeviceFaultMonitorConfig> lambdaQueryWrapper = new MybatisPlusQuery().eqWrapper(page, DeviceFaultMonitorConfig.class).build();
+        IPage<DeviceFaultMonitorConfig> iPage = page(toIPage(pageBean), lambdaQueryWrapper);
+        return R.ok(toPageBean(DeviceFaultMonitorConfigDto.Vo.class, iPage));
+    }
+
+    @PostMapping("save")
+    @ApiOperation("添加")
+    public R save(@RequestBody @Validated DeviceFaultMonitorConfigDto.Save save) {
+        DeviceFaultMonitorConfig saveInfo = copy(DeviceFaultMonitorConfig.class, save);
+        save(saveInfo);
+        return R.ok();
+    }
+
+    @PostMapping("update")
+    @ApiOperation("修改")
+    public R update(@RequestBody @Validated DeviceFaultMonitorConfigDto.Update update) {
+        DeviceFaultMonitorConfig updateInfo = copy(DeviceFaultMonitorConfig.class, update);
+        updateById(updateInfo);
+        return R.ok();
+    }
+}

device-api-service/src/main/java/com/xy/service/DeviceMqttConsumerImpl.java

@@ -26,6 +26,7 @@ import com.xy.utils.SysDictUtils;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 
@@ -33,6 +34,7 @@ import java.time.LocalDateTime;
 import java.util.*;
 import java.util.stream.Collectors;
 
+@Slf4j
 @Service
 @AllArgsConstructor
 @Api(tags = "设备消费者")
@@ -204,7 +206,7 @@ public class DeviceMqttConsumerImpl implements DeviceMqttConsumer {
     @Override
     public void deviceFault(DeviceMqttDto.RequestParams requestParams) {
         DeviceFaultLogDto.MqttData mqttData = JSONUtil.toBean(requestParams.getData(), DeviceFaultLogDto.MqttData.class);
-        log.info("设备故障监控事件消费，接收mqtt data:{}", JSONUtil.toJsonPrettyStr(mqttData));
+//        log.info("设备故障监控事件消费，接收mqtt data:{}", JSONUtil.toJsonPrettyStr(mqttData));
         if (mqttData != null) {
             DeviceEventMsgDto.Vo deviceEventMsg = mqttData.getDeviceEventMsg();
             Long mercId = deviceEventMsg.getMercId();

device-api/src/main/java/com/xy/dto/DeviceFaultInfoDto.java

@@ -0,0 +1,102 @@
+package com.xy.dto;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.xy.utils.PageBean;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+import java.time.LocalDateTime;
+
+/**
+ * <p>
+ * 设备故障信息
+ * </p>
+ *
+ * @author 谭斌
+ * @since 2024-01-08
+ */
+public class DeviceFaultInfoDto {
+
+    @Data
+    @Accessors(chain = true)
+    public static class SelectList extends Vo {
+
+    }
+
+    @Data
+    @Accessors(chain = true)
+    public static class Page extends Vo {
+
+        @ApiModelProperty(value = "分页对象", required = true)
+        private PageBean page;
+
+        @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+        @ApiModelProperty(value = "日志截取开始时间-起")
+        private LocalDateTime beginCreateTime;
+
+        @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+        @ApiModelProperty(value = "日志截取开始时间-始")
+        private LocalDateTime endCreateTime;
+
+    }
+
+    @Data
+    @Accessors(chain = true)
+    public static class Save extends Vo {
+
+    }
+
+    @Data
+    @Accessors(chain = true)
+    public static class Update extends Vo {
+
+    }
+
+    @Data
+    @Accessors(chain = true)
+    public static class Vo {
+
+        @ApiModelProperty(value = "ID")
+        private Long faultId;
+
+        @ApiModelProperty(value = "商户ID")
+        private Long mercId;
+
+        @ApiModelProperty(value = "商户名称")
+        private String mercName;
+
+        @ApiModelProperty(value = "设备编号")
+        private Long deviceId;
+
+        @ApiModelProperty(value = "故障描述")
+        private String describes;
+
+        @ApiModelProperty(value = "事件编码")
+        private String eventCode;
+
+        @ApiModelProperty(value = "是否已解决")
+        private Boolean state;
+
+        @ApiModelProperty(value = "创建时间")
+        @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+        private LocalDateTime createTime;
+
+        @ApiModelProperty(value = "更新时间")
+        @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+        private LocalDateTime updateTime;
+
+        @ApiModelProperty(value = "标记解决时间")
+        @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+        private LocalDateTime resolveTime;
+
+        @ApiModelProperty(value = "事件发生次数")
+        private Integer eventNum;
+
+        @ApiModelProperty(value = "故障级别-字典：device_fault_level")
+        private Integer faultLevel;
+
+
+    }
+
+}

device-api/src/main/java/com/xy/dto/DeviceFaultLogDto.java

@@ -0,0 +1,92 @@
+package com.xy.dto;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.xy.utils.PageBean;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+import java.time.LocalDateTime;
+import java.util.List;
+
+/**
+ * <p>
+ * 设备故障日志
+ * </p>
+ *
+ * @author 谭斌
+ * @since 2024-01-08
+ */
+public class DeviceFaultLogDto {
+
+    @Data
+    @Accessors(chain = true)
+    public static class SelectList extends Vo {
+
+    }
+
+    @Data
+    @Accessors(chain = true)
+    public static class Page extends Vo {
+
+        @ApiModelProperty(value = "分页对象", required = true)
+        private PageBean page;
+
+    }
+
+    @Data
+    @Accessors(chain = true)
+    public static class Save extends Vo {
+
+    }
+
+    @Data
+    @Accessors(chain = true)
+    public static class Update extends Vo {
+
+    }
+
+    @Data
+    @Accessors(chain = true)
+    public static class Vo {
+
+        @ApiModelProperty(value = "ID")
+        private Long logId;
+
+        @ApiModelProperty(value = "商户ID")
+        private Long mercId;
+
+        @ApiModelProperty(value = "设备编号")
+        private Long deviceId;
+
+        @ApiModelProperty(value = "故障描述")
+        private String describes;
+
+        @ApiModelProperty(value = "事件编码")
+        private String eventCode;
+
+        @ApiModelProperty(value = "事件发生时间")
+        @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+        private LocalDateTime eventTime;
+
+        @ApiModelProperty(value = "创建时间")
+        @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+        private LocalDateTime createTime;
+
+
+    }
+
+    @Data
+    @Accessors(chain = true)
+    public static class MqttData {
+
+        @ApiModelProperty(value = "ID")
+        private DeviceEventMsgDto.Vo deviceEventMsg;
+
+        @ApiModelProperty(value = "配置信息")
+        List<DeviceFaultMonitorConfigDto.Vo> configList;
+
+
+    }
+
+}

device-api/src/main/java/com/xy/dto/DeviceFaultMonitorConfigDto.java

@@ -0,0 +1,84 @@
+package com.xy.dto;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.xy.utils.PageBean;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+import java.time.LocalDateTime;
+
+/**
+ * <p>
+ * 设备故障监控配置
+ * </p>
+ *
+ * @author 谭斌
+ * @since 2024-01-08
+ */
+public class DeviceFaultMonitorConfigDto {
+
+    @Data
+    @Accessors(chain = true)
+    public static class SelectList extends Vo {
+
+    }
+
+    @Data
+    @Accessors(chain = true)
+    public static class Page extends Vo {
+
+        @ApiModelProperty(value = "分页对象", required = true)
+        private PageBean page;
+
+    }
+
+    @Data
+    @Accessors(chain = true)
+    public static class Save extends Vo {
+
+    }
+
+    @Data
+    @Accessors(chain = true)
+    public static class Update extends Vo {
+
+    }
+
+    @Data
+    @Accessors(chain = true)
+    public static class Vo {
+
+        @ApiModelProperty(value = "ID")
+        private Long monitorId;
+
+        @ApiModelProperty(value = "事件编码")
+        private String eventCode;
+        
+        @ApiModelProperty(value = "配置描述")
+        private String configName;
+
+        @ApiModelProperty(value = "是否已启用")
+        private Boolean state;
+
+        @ApiModelProperty(value = "创建时间")
+        @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+        private LocalDateTime createTime;
+
+        @ApiModelProperty(value = "标记解决时间")
+        @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+        private LocalDateTime updateTime;
+
+        @ApiModelProperty(value = "条件2：达到m次")
+        private Integer eventNum;
+
+        @ApiModelProperty(value = "条件1：最近n分钟")
+        private Long minuteNum;
+
+        @ApiModelProperty(value = "故障级别-字典：device_fault_level")
+        private Integer faultLevel;
+
+
+    }
+
+}

device-api/src/main/java/com/xy/service/DeviceFaultInfoService.java

@@ -0,0 +1,16 @@
+package com.xy.service;
+
+import com.xy.annotate.RestMappingController;
+
+/**
+ * <p>
+ * 设备故障信息 服务类
+ * </p>
+ *
+ * @author 谭斌
+ * @since 2024-01-08
+ */
+@RestMappingController("/device-fault-info")
+public interface DeviceFaultInfoService {
+
+}

device-api/src/main/java/com/xy/service/DeviceFaultLogService.java

@@ -0,0 +1,16 @@
+package com.xy.service;
+
+import com.xy.annotate.RestMappingController;
+
+/**
+ * <p>
+ * 设备故障日志 服务类
+ * </p>
+ *
+ * @author 谭斌
+ * @since 2024-01-08
+ */
+@RestMappingController("/device-fault-log")
+public interface DeviceFaultLogService {
+
+}

device-api/src/main/java/com/xy/service/DeviceFaultMonitorConfigService.java

@@ -0,0 +1,16 @@
+package com.xy.service;
+
+import com.xy.annotate.RestMappingController;
+
+/**
+ * <p>
+ * 设备故障监控配置 服务类
+ * </p>
+ *
+ * @author 谭斌
+ * @since 2024-01-08
+ */
+@RestMappingController("/device-fault-monitor-config")
+public interface DeviceFaultMonitorConfigService {
+
+}