故障统计分析接口

microservice-admin/src/main/java/com/devplatform/admin/modules/eq/controller/AnalysisController.java

 package com.devplatform.admin.modules.eq.controller;
 
 import com.devplatform.admin.common.utils.AbstractController;
+import com.devplatform.admin.modules.sys.service.SysFaulalarmService;
 import com.devplatform.common.util.R;
 import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
 import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 
 import java.util.ArrayList;
@@ -21,6 +25,9 @@ import java.util.Map;
 @RestController
 @RequestMapping("/analysis")
 public class AnalysisController extends AbstractController {
+	@Autowired
+	private SysFaulalarmService sysFaulalarmService;
+
 	/**
 	 * 首页
 	 * @return
@@ -59,4 +66,24 @@ public class AnalysisController extends AbstractController {
 		map.put("energyList",list);
 		return R.ok().put("bean", map);
 	}
+
+	/**
+	 * 设备故障分析
+	 * @param params
+	 * @return
+	 */
+	@ApiOperation(value = "设备故障分析", notes = "设备故障分析")
+	@ApiImplicitParam(
+			name = "params",
+			value = "查询参数",
+			required = true,
+			paramType = "query",
+			dataType = "Map<String, Object>")
+	@GetMapping("/getFaultAlarmList")
+	public R getFaultAlarmList(@RequestParam Map<String, Object> params) {
+		List<Map<String, Object>> typeList = sysFaulalarmService.getListGroupByResourceType(params);
+		List<Map<String, Object>> idList = sysFaulalarmService.getListGroupByResourceId(params);
+		return R.ok().put("typeList", typeList).put("idList",idList);
+	}
+
 }

microservice-admin/src/main/java/com/devplatform/admin/modules/sys/bean/SysFaulalarm.java

+package com.devplatform.admin.modules.sys.bean;
+
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @author dxw
+ */
+@Data
+@ApiModel(value="设备故障报警表对象",description="设备故障报警表对象")
+@TableName("sys_fault_alarm")
+public class SysFaulalarm 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="resourceId")
+	private java.lang.String resourceId;
+	/** 资源点类型 */
+	@ApiModelProperty(value="资源点类型",name="resourceType")
+	private java.lang.String resourceType;
+	/** 开始时间 */
+	@ApiModelProperty(value="开始时间",name="startTime")
+	private java.util.Date startTime;
+	/** 结束时间 */
+	@ApiModelProperty(value="结束时间",name="endTime")
+	private java.util.Date endTime;
+	/** 站点ID */
+	@ApiModelProperty(value="站点ID",name="stationId")
+	private java.lang.String stationId;
+}

microservice-admin/src/main/java/com/devplatform/admin/modules/sys/dao/SysFaulalarmDao.java

+package com.devplatform.admin.modules.sys.dao;
+import org.apache.ibatis.annotations.Mapper;
+
+import com.devplatform.admin.modules.sys.model.SysFaulalarmModel;
+import com.devplatform.admin.modules.sys.bean.SysFaulalarm;
+import com.devplatform.common.dao.MyBaseMapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * SysFaulalarm Mapper
+ * 用于设备故障报警表的数据库操作
+ * @author Administrator
+ *
+ */
+@Mapper
+public interface SysFaulalarmDao extends MyBaseMapper<SysFaulalarm> {
+
+    /**
+     * 查询分页数量
+     * @param model
+     * @return
+     */
+    Integer queryPageByCount(SysFaulalarmModel model);
+
+    /**
+     * 查询设备故障报警表分页数据
+     * @param model
+     * @return
+     */
+    List<SysFaulalarm> queryPageList(SysFaulalarmModel model);
+
+    /**
+     * 按资源点类型分组统计数量
+     * @param params
+     * @return
+     */
+    List<Map<String, Object>> getListGroupByResourceType(@Param("params")Map<String, Object> params);
+
+    /**
+     * 按资源点id分组统计数量
+     * @param params
+     * @return
+     */
+    List<Map<String, Object>> getListGroupByResourceId(@Param("params")Map<String, Object> params);
+}

microservice-admin/src/main/java/com/devplatform/admin/modules/sys/model/SysFaulalarmModel.java

+package com.devplatform.admin.modules.sys.model;
+
+import com.devplatform.admin.common.model.BaseModel;
+import lombok.Data;
+
+/**
+ * 设备故障报警表的Model
+ * <br>
+ * @author 代码生成器产生
+ */
+@Data
+public class SysFaulalarmModel extends BaseModel {
+	
+	/** 主键id */
+	private java.lang.String id;
+	/** 资源点id */
+	private java.lang.String resourceId;
+	/** 资源点类型 */
+	private java.lang.String resourceType;
+	/** 开始时间 */
+	private java.util.Date startTime;
+	/** 结束时间 */
+	private java.util.Date endTime;
+	/** 站点ID */
+	private java.lang.String stationId;
+}

microservice-admin/src/main/java/com/devplatform/admin/modules/sys/service/SysFaulalarmService.java

+package com.devplatform.admin.modules.sys.service;
+
+import com.devplatform.admin.modules.sys.bean.SysFaulalarm;
+import com.devplatform.admin.modules.sys.model.SysFaulalarmModel;
+import com.devplatform.common.service.MyBaseService;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 设备故障报警表的service接口
+ * <br>
+ * <b>功能：</b>SysFaulalarmService<br>
+ * @author 代码生成器产生
+ */
+public interface SysFaulalarmService extends MyBaseService<SysFaulalarm> {
+
+    /**
+     * 查询设备故障报警表分页数据
+     * @param model
+     * @return
+     */
+    List<SysFaulalarm> queryPageList(SysFaulalarmModel model);
+
+    /**
+     * 按资源点类型分组统计数量
+     * @param params
+     * @return
+     */
+    List<Map<String,Object>> getListGroupByResourceType(Map<String, Object> params);
+
+    /**
+     * 按资源点id分组统计数量
+     * @param params
+     * @return
+     */
+    List<Map<String,Object>> getListGroupByResourceId(Map<String, Object> params);
+}

microservice-admin/src/main/java/com/devplatform/admin/modules/sys/service/impl/SysFaulalarmServiceImpl.java

+package com.devplatform.admin.modules.sys.service.impl;
+
+import com.devplatform.admin.modules.sys.bean.SysFaulalarm;
+import com.devplatform.admin.modules.sys.dao.SysFaulalarmDao;
+import com.devplatform.admin.modules.sys.model.SysFaulalarmModel;
+import com.devplatform.admin.modules.sys.service.SysFaulalarmService;
+import com.devplatform.common.service.impl.MyBaseServiceImpl;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 设备故障报警表的service接口实现类
+ * <br>
+ * <b>功能：</b>SysFaulalarmServiceImpl<br>
+ * @author 代码生成器产生
+ */
+@Service("sysFaulalarmService")
+public class SysFaulalarmServiceImpl extends MyBaseServiceImpl<SysFaulalarmDao, SysFaulalarm> implements SysFaulalarmService {
+
+    @Override
+    public List<SysFaulalarm> queryPageList(SysFaulalarmModel model) {
+        Integer rowCount = baseMapper.queryPageByCount(model);
+        model.getPager().setRowCount(rowCount);
+        return baseMapper.queryPageList(model);
+    }
+
+    @Override
+    public List<Map<String, Object>> getListGroupByResourceType(Map<String, Object> params) {
+        return baseMapper.getListGroupByResourceType(params);
+    }
+
+    @Override
+    public List<Map<String, Object>> getListGroupByResourceId(Map<String, Object> params) {
+        return baseMapper.getListGroupByResourceId(params);
+    }
+}

microservice-admin/src/main/resources/mapper/sys/SysFaulalarmMapper.xml

+<?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.sys.dao.SysFaulalarmDao">
+	<!-- Result Map -->
+	<resultMap id="BaseResultMap" type="com.devplatform.admin.modules.sys.bean.SysFaulalarm">
+	    <result column="id" property="id"/>
+	    <result column="resource_id" property="resourceId"/>
+	    <result column="resource_type" property="resourceType"/>
+	    <result column="start_time" property="startTime"/>
+	    <result column="end_time" property="endTime"/>
+	    <result column="station_id" property="stationId"/>
+	</resultMap>
+
+	<!-- sys_fault_alarm table all fields -->
+	<sql id="Base_Column_List">
+		id,resource_id,resource_type,start_time,end_time,station_id
+	</sql>
+
+	<!-- 公共查询条件 -->
+	<sql id="Example_Where_Clause">
+		where t.deleted=0
+		<if test="id!=null and id!=''">and t.id = #{id}</if>
+		<if test="resourceId!=null and resourceId!=''">and t.resource_id = #{resourceId}</if>
+		<if test="resourceType!=null and resourceType!=''">and t.resource_type = #{resourceType}</if>
+		<if test="startTime!=null ">and t.start_time = #{startTime}</if>
+		<if test="endTime!=null ">and t.end_time = #{endTime}</if>
+		<if test="stationId!=null and stationId!=''">and t.station_id = #{stationId}</if>
+	</sql>
+
+	<select id="queryPageByCount" parameterType="Object" resultType="java.lang.Integer">
+	select count(1) from sys_fault_alarm t
+	<include refid="Example_Where_Clause"/>
+	</select>
+
+	<select id="queryPageList" parameterType="Object" resultMap="BaseResultMap">
+	select t.* from sys_fault_alarm 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>
+	<select id="getListGroupByResourceType" resultType="java.util.Map">
+		select sd.name as name,t.cNum from
+		(select resource_type,count(1) as cNum from
+		sys_fault_alarm
+		 where 1=1
+		<if test="params.startTime != null and params.startTime != ''">
+			and create_date &gt;= #{params.startTime}
+		</if>
+		<if test="params.endTime != null and params.endTime != ''">
+			and create_date &lt;= #{params.endTime}
+		</if>
+		 group by resource_type) t
+		 left join sys_dictionary sd on sd.id = t.resource_type
+		 order by t.cNum desc
+	</select>
+
+	<select id="getListGroupByResourceId" resultType="java.util.Map">
+		select lr.name as name,t.cNum from
+		(select resource_id,count(1) as cNum from
+		sys_fault_alarm
+		where 1=1
+		<if test="params.startTime != null and params.startTime != ''">
+			and create_date &gt;= #{params.startTime}
+		</if>
+		<if test="params.endTime != null and params.endTime != ''">
+			and create_date &lt;= #{params.endTime}
+		</if>
+		group by resource_id) t
+		left join li_resource lr on lr.id = t.resource_id
+		order by t.cNum desc
+	</select>
+
+</mapper>
+
+