Merge branch 'developer' of http://39.98.45.134:8090/moa/amos-boot-biz into developer

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/dto/JpPersonStationDto.java

+package com.yeejoin.amos.boot.module.hygf.api.dto;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import com.yeejoin.amos.boot.biz.common.dto.BaseDto;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import java.util.Date;
+
+/**
+ * 户用光伏监盘人员场站关系表
+ *
+ * @author system_generator
+ * @date 2023-09-19
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@ApiModel(value="JpPersonStationDto", description="户用光伏监盘人员场站关系表")
+public class JpPersonStationDto  extends BaseDto {
+
+   private static final long serialVersionUID = 1L;
+
+
+    @ApiModelProperty(value = "人员id")
+    private String personId;
+
+    @ApiModelProperty(value = "场站id")
+    private Long stationId;
+
+    @ApiModelProperty(value = "场站名称")
+    private String stationName;
+
+}

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/dto/JpStationDto.java

 package com.yeejoin.amos.boot.module.hygf.api.dto;
 
 import com.baomidou.mybatisplus.annotation.TableField;
+import com.yeejoin.amos.boot.module.hygf.api.entity.JpPersonStation;
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
 import com.yeejoin.amos.boot.biz.common.dto.BaseDto;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
 import java.util.Date;
+import java.util.List;
 
 /**
  * 第三方场站
@@ -101,4 +103,21 @@ public class JpStationDto  extends BaseDto {
      *  组织编码
      */
     private String organizationalCode	;
+
+    //日发电量
+    private Double dayGenerate;
+    //月发电量
+    private Double monthGenerate;
+    //年发电量
+    private Double yearGenerate;
+    //日收益
+    private Double  dayIncome;
+    //月收益
+    private Double monthIncome;
+    // 年收益
+    private Double yearIncome;
+    //地区
+    private String area;
+
+    List<JpPersonStation> statioId;
 }

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/entity/JpPersonStation.java

+package com.yeejoin.amos.boot.module.hygf.api.entity;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+import java.util.Date;
+
+/**
+ * 户用光伏监盘人员场站关系表
+ *
+ * @author system_generator
+ * @date 2023-09-19
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@Accessors(chain = true)
+@TableName("hygf_jp_person_station")
+public class JpPersonStation extends BaseEntity {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 人员id
+     */
+	@TableField("person_id")
+    private String personId;
+
+    /**
+     * 场站id
+     */
+	@TableField("station_id")
+    private Long stationId;
+
+    /**
+     * 场站名称
+     */
+	@TableField("station_name")
+    private String stationName;
+
+}

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/entity/JpStation.java

@@ -166,8 +166,27 @@ public class JpStation extends BaseEntity {
      *  组织编码
      */
     @TableField("organizational_code")
-    private String organizationalCode	;
-
-
+    private String organizationalCode;
+    //日发电量
+    @TableField("day_generate")
+    private Double dayGenerate;
+    //月发电量
+    @TableField("month_generate")
+    private Double monthGenerate;
+   //年发电量
+    @TableField("year_generate")
+    private Double yearGenerate;
+    //日收益
+    @TableField("day_income")
+    private Double  dayIncome;
+   //月收益
+    @TableField("month_income")
+    private Double monthIncome;
+    // 年收益
+    @TableField("year_income")
+    private Double yearIncome;
+    //地区
+    @TableField("area")
+    private String area;
 
 }

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/mapper/JpPersonStationMapper.java

+package com.yeejoin.amos.boot.module.hygf.api.mapper;
+
+import com.yeejoin.amos.boot.module.hygf.api.entity.JpPersonStation;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * 户用光伏监盘人员场站关系表 Mapper 接口
+ *
+ * @author system_generator
+ * @date 2023-09-19
+ */
+public interface JpPersonStationMapper extends BaseMapper<JpPersonStation> {
+
+}

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/service/IJpPersonStationService.java

+package com.yeejoin.amos.boot.module.hygf.api.service;
+
+
+/**
+ * 户用光伏监盘人员场站关系表接口类
+ *
+ * @author system_generator
+ * @date 2023-09-19
+ */
+public interface IJpPersonStationService {
+
+}

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/resources/mapper/mysql/JpPersonStationMapper.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.yeejoin.amos.boot.module.hygf.api.mapper.JpPersonStationMapper">
+
+</mapper>

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/resources/mapper/mysql/JpStationMapper.xml

@@ -14,7 +14,18 @@
         <if test="dto.address!=null">
             and hygf_jp_station.address like concat(concat("%",#{dto.address}),"%")
         </if>
-
+        <if test="dto.area!=null">
+            and hygf_jp_station.area like concat(concat("%",#{dto.area}),"%")
+        </if>
+        <if test="dto.statioId!=null">
+            and hygf_jp_station.third_station_id in
+            <foreach collection="dto.statioId" item="item" index="index" open="(" separator="," close=")">
+                #{item.stationId}
+            </foreach>
+        </if>
+        <if test="dto.thirdStationId!=null">
+            and hygf_jp_station.third_station_id =#{dto.thirdStationId}
+        </if>
 
 
     </select>

amos-boot-system-jxiop/amos-boot-module-hygf-biz/src/main/java/com/yeejoin/amos/boot/module/hygf/biz/controller/JpPersonStationController.java

+package com.yeejoin.amos.boot.module.hygf.biz.controller;
+
+import org.springframework.web.bind.annotation.RequestMapping;
+import io.swagger.annotations.ApiOperation;
+import io.swagger.annotations.Api;
+import org.springframework.web.bind.annotation.RestController;
+import com.yeejoin.amos.boot.biz.common.controller.BaseController;
+import java.util.List;
+import com.yeejoin.amos.boot.module.hygf.biz.service.impl.JpPersonStationServiceImpl;
+import org.typroject.tyboot.core.restful.utils.ResponseHelper;
+import org.typroject.tyboot.core.restful.utils.ResponseModel;
+import org.springframework.beans.factory.annotation.Autowired;
+import javax.servlet.http.HttpServletRequest;
+import org.springframework.web.bind.annotation.*;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.yeejoin.amos.boot.module.hygf.api.dto.JpPersonStationDto;
+import org.typroject.tyboot.core.restful.doc.TycloudOperation;
+import org.typroject.tyboot.core.foundation.enumeration.UserType;
+
+/**
+ * 户用光伏监盘人员场站关系表
+ *
+ * @author system_generator
+ * @date 2023-09-19
+ */
+@RestController
+@Api(tags = "户用光伏监盘人员场站关系表Api")
+@RequestMapping(value = "/jp-person-station")
+public class JpPersonStationController extends BaseController {
+
+    @Autowired
+    JpPersonStationServiceImpl jpPersonStationServiceImpl;
+
+    /**
+     * 新增户用光伏监盘人员场站关系表
+     *
+     * @return
+     */
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
+	@PostMapping(value = "/save")
+	@ApiOperation(httpMethod = "POST", value = "新增户用光伏监盘人员场站关系表", notes = "新增户用光伏监盘人员场站关系表")
+	public ResponseModel<JpPersonStationDto> save(@RequestBody JpPersonStationDto model) {
+	    model = jpPersonStationServiceImpl.createWithModel(model);
+	    return ResponseHelper.buildResponse(model);
+	}
+
+	/**
+     * 根据sequenceNbr更新
+     *
+     * @param sequenceNbr 主键
+     * @return
+     */
+	@TycloudOperation(ApiLevel = UserType.AGENCY)
+	@PutMapping(value = "/{sequenceNbr}")
+	@ApiOperation(httpMethod = "PUT", value = "根据sequenceNbr更新户用光伏监盘人员场站关系表", notes = "根据sequenceNbr更新户用光伏监盘人员场站关系表")
+	public ResponseModel<JpPersonStationDto> updateBySequenceNbrJpPersonStation(@RequestBody JpPersonStationDto model,@PathVariable(value = "sequenceNbr") Long sequenceNbr) {
+	    model.setSequenceNbr(sequenceNbr);
+	    return ResponseHelper.buildResponse(jpPersonStationServiceImpl.updateWithModel(model));
+	}
+
+	/**
+     * 根据sequenceNbr删除
+     *
+     * @param sequenceNbr 主键
+     * @return
+     */
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
+    @DeleteMapping(value = "/{sequenceNbr}")
+    @ApiOperation(httpMethod = "DELETE", value = "根据sequenceNbr删除户用光伏监盘人员场站关系表", notes = "根据sequenceNbr删除户用光伏监盘人员场站关系表")
+    public ResponseModel<Boolean> deleteBySequenceNbr(HttpServletRequest request, @PathVariable(value = "sequenceNbr") Long sequenceNbr){
+        return ResponseHelper.buildResponse(jpPersonStationServiceImpl.removeById(sequenceNbr));
+    }
+
+    /**
+     * 根据sequenceNbr查询
+     *
+	 * @param sequenceNbr  主键
+     * @return
+     */
+	@TycloudOperation(ApiLevel = UserType.AGENCY)
+	@GetMapping(value = "/{sequenceNbr}")
+	@ApiOperation(httpMethod = "GET",value = "根据sequenceNbr查询单个户用光伏监盘人员场站关系表",  notes = "根据sequenceNbr查询单个户用光伏监盘人员场站关系表")
+	public ResponseModel<JpPersonStationDto> selectOne(@PathVariable Long sequenceNbr) {
+	    return ResponseHelper.buildResponse(jpPersonStationServiceImpl.queryBySeq(sequenceNbr));
+	}
+
+	/**
+     * 列表分页查询
+     *
+     * @param current 当前页
+     * @param current 每页大小
+     * @return
+     */
+	@TycloudOperation(ApiLevel = UserType.AGENCY)
+	@GetMapping(value = "/page")
+	@ApiOperation(httpMethod = "GET",value = "户用光伏监盘人员场站关系表分页查询",  notes = "户用光伏监盘人员场站关系表分页查询")
+	public ResponseModel<Page<JpPersonStationDto>> queryForPage(@RequestParam(value = "current") int current,@RequestParam
+                    (value = "size") int size) {
+	    Page<JpPersonStationDto> page = new Page<JpPersonStationDto>();
+	    page.setCurrent(current);
+	    page.setSize(size);
+	    return ResponseHelper.buildResponse(jpPersonStationServiceImpl.queryForJpPersonStationPage(page));
+	}
+
+	/**
+	 * 列表全部数据查询
+     *
+	 * @return
+	 */
+	@TycloudOperation(ApiLevel = UserType.AGENCY)
+	@ApiOperation(httpMethod = "GET",value = "户用光伏监盘人员场站关系表列表全部数据查询",   notes = "户用光伏监盘人员场站关系表列表全部数据查询")
+	@GetMapping(value = "/list")
+	public ResponseModel<List<JpPersonStationDto>> selectForList() {
+	    return ResponseHelper.buildResponse(jpPersonStationServiceImpl.queryForJpPersonStationList());
+	}
+}

amos-boot-system-jxiop/amos-boot-module-hygf-biz/src/main/java/com/yeejoin/amos/boot/module/hygf/biz/controller/JpStationController.java

 package com.yeejoin.amos.boot.module.hygf.biz.controller;
 
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.yeejoin.amos.boot.module.hygf.api.dto.ReviewDto;
+import com.yeejoin.amos.boot.module.hygf.api.entity.JpPersonStation;
+import com.yeejoin.amos.boot.module.hygf.api.entity.PersonnelBusiness;
+import com.yeejoin.amos.boot.module.hygf.api.mapper.JpPersonStationMapper;
+import com.yeejoin.amos.boot.module.standard.api.entity.PublicAgencyUser;
 import org.springframework.web.bind.annotation.RequestMapping;
 import io.swagger.annotations.ApiOperation;
 import io.swagger.annotations.Api;
@@ -31,7 +36,8 @@ public class JpStationController extends BaseController {
 
     @Autowired
     JpStationServiceImpl jpStationServiceImpl;
-
+    @Autowired
+    JpPersonStationMapper pPersonStationMapper;
     /**
      * 新增第三方场站
      *
@@ -98,6 +104,17 @@ public class JpStationController extends BaseController {
     @ApiOperation(httpMethod = "GET",value = "场站列表",  notes = "场站列表")
     public ResponseModel<Page<JpStationDto>> queryForDealerReviewPage(@RequestParam(value = "current") int current, @RequestParam
             (value = "size") int size, JpStationDto reviewDto) {
+
+
+
+        if(reviewDto.getThirdStationId()==null){
+            //获取当前人管理场站
+            LambdaQueryWrapper<JpPersonStation> qug=new LambdaQueryWrapper<>();
+            qug.eq(JpPersonStation::getPersonId,getUserInfo().getUserId());
+            List<JpPersonStation> pPersonStation=pPersonStationMapper.selectList(qug);
+        }
+
+
         Page<JpStationDto> page=jpStationServiceImpl.queryForJpStationPage(current,size,reviewDto);
         return ResponseHelper.buildResponse(page);
     }

amos-boot-system-jxiop/amos-boot-module-hygf-biz/src/main/java/com/yeejoin/amos/boot/module/hygf/biz/controller/TdHygfJpCollectorHistoryController.java

@@ -54,7 +54,6 @@ public class TdHygfJpCollectorHistoryController extends BaseController {
 	@PutMapping(value = "/{sequenceNbr}")
 	@ApiOperation(httpMethod = "PUT", value = "根据sequenceNbr更新户用光伏监盘采集器历史表", notes = "根据sequenceNbr更新户用光伏监盘采集器历史表")
 	public ResponseModel<TdHygfJpCollectorHistoryDto> updateBySequenceNbrTdHygfJpCollectorHistory(@RequestBody TdHygfJpCollectorHistoryDto model,@PathVariable(value = "sequenceNbr") Long sequenceNbr) {
-	    model.setSequenceNbr(sequenceNbr);
 	    return ResponseHelper.buildResponse(tdHygfJpCollectorHistoryServiceImpl.updateWithModel(model));
 	}
 

amos-boot-system-jxiop/amos-boot-module-hygf-biz/src/main/java/com/yeejoin/amos/boot/module/hygf/biz/controller/TdHygfJpInverterHistoryController.java

@@ -54,7 +54,6 @@ public class TdHygfJpInverterHistoryController extends BaseController {
 	@PutMapping(value = "/{sequenceNbr}")
 	@ApiOperation(httpMethod = "PUT", value = "根据sequenceNbr更新户用光伏监盘逆变器历史表", notes = "根据sequenceNbr更新户用光伏监盘逆变器历史表")
 	public ResponseModel<TdHygfJpInverterHistoryDto> updateBySequenceNbrTdHygfJpInverterHistory(@RequestBody TdHygfJpInverterHistoryDto model,@PathVariable(value = "sequenceNbr") Long sequenceNbr) {
-	    model.setSequenceNbr(sequenceNbr);
 	    return ResponseHelper.buildResponse(tdHygfJpInverterHistoryServiceImpl.updateWithModel(model));
 	}
 

amos-boot-system-jxiop/amos-boot-module-hygf-biz/src/main/java/com/yeejoin/amos/boot/module/hygf/biz/controller/TdHygfJpInverterWarnController.java

@@ -54,7 +54,6 @@ public class TdHygfJpInverterWarnController extends BaseController {
 	@PutMapping(value = "/{sequenceNbr}")
 	@ApiOperation(httpMethod = "PUT", value = "根据sequenceNbr更新户用光伏监盘逆变器报警表", notes = "根据sequenceNbr更新户用光伏监盘逆变器报警表")
 	public ResponseModel<TdHygfJpInverterWarnDto> updateBySequenceNbrTdHygfJpInverterWarn(@RequestBody TdHygfJpInverterWarnDto model,@PathVariable(value = "sequenceNbr") Long sequenceNbr) {
-	    model.setSequenceNbr(sequenceNbr);
 	    return ResponseHelper.buildResponse(tdHygfJpInverterWarnServiceImpl.updateWithModel(model));
 	}
 

amos-boot-system-jxiop/amos-boot-module-hygf-biz/src/main/java/com/yeejoin/amos/boot/module/hygf/biz/controller/TdHygfJpInvertorElecHistoryController.java

@@ -54,7 +54,6 @@ public class TdHygfJpInvertorElecHistoryController extends BaseController {
 	@PutMapping(value = "/{sequenceNbr}")
 	@ApiOperation(httpMethod = "PUT", value = "根据sequenceNbr更新户用光伏监盘逆变器电能历史表", notes = "根据sequenceNbr更新户用光伏监盘逆变器电能历史表")
 	public ResponseModel<TdHygfJpInvertorElecHistoryDto> updateBySequenceNbrTdHygfJpInvertorElecHistory(@RequestBody TdHygfJpInvertorElecHistoryDto model,@PathVariable(value = "sequenceNbr") Long sequenceNbr) {
-	    model.setSequenceNbr(sequenceNbr);
 	    return ResponseHelper.buildResponse(tdHygfJpInvertorElecHistoryServiceImpl.updateWithModel(model));
 	}
 

amos-boot-system-jxiop/amos-boot-module-hygf-biz/src/main/java/com/yeejoin/amos/boot/module/hygf/biz/controller/TdHygfJpStationPowerHistoryController.java

@@ -54,7 +54,6 @@ public class TdHygfJpStationPowerHistoryController extends BaseController {
 	@PutMapping(value = "/{sequenceNbr}")
 	@ApiOperation(httpMethod = "PUT", value = "根据sequenceNbr更新户用光伏监盘电站功率表", notes = "根据sequenceNbr更新户用光伏监盘电站功率表")
 	public ResponseModel<TdHygfJpStationPowerHistoryDto> updateBySequenceNbrTdHygfJpStationPowerHistory(@RequestBody TdHygfJpStationPowerHistoryDto model,@PathVariable(value = "sequenceNbr") Long sequenceNbr) {
-	    model.setSequenceNbr(sequenceNbr);
 	    return ResponseHelper.buildResponse(tdHygfJpStationPowerHistoryServiceImpl.updateWithModel(model));
 	}
 

amos-boot-system-jxiop/amos-boot-module-hygf-biz/src/main/java/com/yeejoin/amos/boot/module/hygf/biz/service/impl/JpPersonStationServiceImpl.java

+package com.yeejoin.amos.boot.module.hygf.biz.service.impl;
+
+import com.yeejoin.amos.boot.module.hygf.api.entity.JpPersonStation;
+import com.yeejoin.amos.boot.module.hygf.api.mapper.JpPersonStationMapper;
+import com.yeejoin.amos.boot.module.hygf.api.service.IJpPersonStationService;
+import com.yeejoin.amos.boot.module.hygf.api.dto.JpPersonStationDto;
+import org.typroject.tyboot.core.rdbms.service.BaseService;
+import org.springframework.stereotype.Service;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import java.util.List;
+
+/**
+ * 户用光伏监盘人员场站关系表服务实现类
+ *
+ * @author system_generator
+ * @date 2023-09-19
+ */
+@Service
+public class JpPersonStationServiceImpl extends BaseService<JpPersonStationDto,JpPersonStation,JpPersonStationMapper> implements IJpPersonStationService {
+    /**
+     * 分页查询
+     */
+    public Page<JpPersonStationDto> queryForJpPersonStationPage(Page<JpPersonStationDto> page)   {
+        return this.queryForPage(page, null, false);
+    }
+
+    /**
+     * 列表查询 示例
+     */
+    public List<JpPersonStationDto> queryForJpPersonStationList()   {
+        return this.queryForList("" , false);
+    }
+}
\ No newline at end of file

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/pom.xml

@@ -31,6 +31,12 @@
           <version>5.7.22</version>
         </dependency>
       <dependency>
+          <groupId>com.amosframework.boot</groupId>
+          <artifactId>amos-boot-module-jxiop-api</artifactId>
+          <version>1.0.0</version>
+          <scope>compile</scope>
+      </dependency>
+      <dependency>
           <groupId>com.yeejoin</groupId>
           <artifactId>amos-component-influxdb</artifactId>
           <version>1.8.5-SNAPSHOT</version>

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/controller/BigScreenAnalyseController.java

+package com.yeejoin.amos.boot.module.jxiop.biz.controller;
+
+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.yeejoin.amos.boot.biz.common.controller.BaseController;
+import com.yeejoin.amos.boot.module.jxiop.api.entity.StationBasic;
+import com.yeejoin.amos.boot.module.jxiop.api.mapper.StationBasicMapper;
+import com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizFanWarningRecord;
+import com.yeejoin.amos.boot.module.jxiop.biz.mapper2.IdxBizFanHealthIndexMapper;
+import com.yeejoin.amos.boot.module.jxiop.biz.mapper2.IdxBizFanWarningRecordMapper;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.apache.ibatis.annotations.Param;
+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 org.typroject.tyboot.core.foundation.enumeration.UserType;
+import org.typroject.tyboot.core.restful.doc.TycloudOperation;
+import org.typroject.tyboot.core.restful.utils.ResponseHelper;
+import org.typroject.tyboot.core.restful.utils.ResponseModel;
+
+import java.math.BigDecimal;
+import java.util.*;
+import java.util.stream.Collectors;
+
+@RestController
+@Api(tags = "智能分析 - 大屏API")
+@RequestMapping(value = "/bigScreenAnalyse")
+public class BigScreenAnalyseController extends BaseController {
+
+    @Autowired
+    IdxBizFanHealthIndexMapper idxBizFanHealthIndexMapper;
+
+    @Autowired
+    IdxBizFanWarningRecordMapper idxBizFanWarningRecordMapper;
+
+    @Autowired
+    StationBasicMapper stationBasicMapper;
+
+    @TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
+    @ApiOperation(httpMethod = "GET", value = "场站设备健康状态指数与趋势 - 仪表盘", notes = "场站设备健康状态指数与趋势 - 仪表盘")
+    @GetMapping(value = "/getHealthScoreInfo")
+    public ResponseModel<Map<String, BigDecimal>> getHealthScoreInfo(@RequestParam(required = false) String areaCode, @RequestParam(required = false) String stationCode) {
+        HashMap<String, BigDecimal> stringBigDecimalHashMap = new HashMap<>();
+        stringBigDecimalHashMap.put("value", idxBizFanHealthIndexMapper.getHealthScoreInfo(areaCode, stationCode));
+        return ResponseHelper.buildResponse(stringBigDecimalHashMap);
+    }
+
+
+    @TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
+    @ApiOperation(httpMethod = "GET", value = "场站设备健康状态指数与趋势 - 折线图", notes = "场站设备健康状态指数与趋势 - 折线图")
+    @GetMapping(value = "/getHealthListInfo")
+    public ResponseModel<Map<String, Object>> getHealthListInfo(@RequestParam(required = false) String areaCode, @RequestParam(required = false) String stationCode) {
+        HashMap<String, Object> resultMap = new HashMap<>();
+        List<Map<String, Object>> healthListInfo = idxBizFanHealthIndexMapper.getHealthListInfo(areaCode, stationCode);
+        List<String> time = new ArrayList<>();
+        List<String> valueList = new ArrayList<>();
+        healthListInfo.forEach(item -> {
+            time.add(item.get("date").toString());
+            valueList.add(item.get("avgHealthIndex").toString());
+        });
+        List<Map<String, Object>> arrayList = new ArrayList<>();
+        HashMap<String, Object> stringStringHashMap = new HashMap<>();
+        stringStringHashMap.put("data", valueList);
+        arrayList.add(stringStringHashMap);
+        resultMap.put("axisData", time);
+        resultMap.put("seriesData", arrayList);
+        return ResponseHelper.buildResponse(resultMap);
+    }
+
+
+    @TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
+    @ApiOperation(httpMethod = "GET", value = "全域各片区设备预警情况(条) ", notes = "全域各片区设备预警情况(条) ")
+    @GetMapping(value = "/getAllEquipAlarmInfo")
+    public ResponseModel<Map<String, Object>> getAllEquipAlarmInfo(@RequestParam(required = false) String tableName) {
+        Map<String, Object> resultMap = new HashMap<>();
+        List<Map<String, Object>> allEquipAlarmInfo = idxBizFanHealthIndexMapper.getAllEquipAlarmInfo(tableName);
+        HashMap<String, Integer> wxMap = new HashMap<>();
+        HashMap<String, Integer> zyMap = new HashMap<>();
+        HashMap<String, Integer> jgMap = new HashMap<>();
+        allEquipAlarmInfo.forEach(item -> {
+            if ("危险".equals(item.get("warningName"))) {
+                wxMap.put(item.get("area").toString(), Integer.parseInt(item.get("num").toString()));
+            } else if ("注意".equals(item.get("warningName"))) {
+                zyMap.put(item.get("area").toString(), Integer.parseInt(item.get("num").toString()));
+            } else if ("警告".equals(item.get("warningName"))) {
+                jgMap.put(item.get("area").toString(), Integer.parseInt(item.get("num").toString()));
+            }
+        });
+        List<Integer> wxList = new ArrayList<>();
+        List<Integer> zyList = new ArrayList<>();
+        List<Integer> jgList = new ArrayList<>();
+        List<String> list = new ArrayList<>();
+        if ("idx_biz_fan_warning_record".equals(tableName)) {
+            list = Arrays.asList("华中片区", "西北片区", "西南片区", "华南片区", "华东片区", "东北片区", "华北片区");
+        } else {
+            list = Arrays.asList("华北片区", "东北片区", "华东片区", "华南片区", "西南片区", "西北片区", "华中片区");
+        }
+        list.forEach(item -> {
+            wxList.add(wxMap.getOrDefault(item, 0));
+            zyList.add(zyMap.getOrDefault(item, 0));
+            jgList.add(jgMap.getOrDefault(item, 0));
+        });
+
+        HashMap<String, Object> wxMapResult = new HashMap<>();
+        wxMapResult.put("data", wxList);
+        wxMapResult.put("name", "危险");
+        HashMap<String, Object> zyMapResult = new HashMap<>();
+        zyMapResult.put("data", zyList);
+        zyMapResult.put("name", "注意");
+        HashMap<String, Object> jgMapResult = new HashMap<>();
+        jgMapResult.put("data", jgList);
+        jgMapResult.put("name", "警告");
+
+        List<Map<String, Object>> hashMaps = Arrays.asList(wxMapResult, zyMapResult, jgMapResult);
+        resultMap.put("axisData", list);
+        resultMap.put("seriesData", hashMaps);
+        return ResponseHelper.buildResponse(resultMap);
+    }
+
+
+    @TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
+    @ApiOperation(httpMethod = "GET", value = "全域各片区设备健康状态指数 ", notes = "全域各片区设备健康状态指数 ")
+    @GetMapping(value = "/getHealthInfoByArea")
+    public ResponseModel<Map<String, Object>> getHealthInfoByArea() {
+        Map<String, Object> resultMap = new HashMap<>();
+        List<Map<String, Object>> healthListInfo = idxBizFanHealthIndexMapper.getHealthInfoByArea();
+        Map<String, BigDecimal> collect = healthListInfo.stream().collect(Collectors.toMap(t -> t.get("area").toString(), t -> new BigDecimal(t.get("healthIndex").toString())));
+        List<String> list = Arrays.asList("华中片区", "西北片区", "西南片区", "华南片区", "华东片区", "东北片区", "华北片区");
+        List<Object> seriesData = new ArrayList<>();
+        list.forEach(item -> seriesData.add(collect.getOrDefault(item, new BigDecimal("0"))));
+        resultMap.put("axisData", list);
+        resultMap.put("seriesData", seriesData);
+        return ResponseHelper.buildResponse(resultMap);
+    }
+
+
+    @TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
+    @ApiOperation(httpMethod = "GET", value = "全域各场站设备实时预警处置信息", notes = "全域各场站设备实时预警处置信息")
+    @GetMapping(value = "/getEquipWarningInfoByPage")
+    public ResponseModel<IPage<IdxBizFanWarningRecord>> getEquipWarningInfoByPage(@RequestParam(value = "arae", required = false) String arae,
+                                                                                  @RequestParam(value = "station", required = false) String station,
+                                                                                  @RequestParam(value = "stationType", required = false) String stationType,
+                                                                                  @RequestParam(value = "current", required = false) Integer current,
+                                                                                  @RequestParam(value = "size", required = false) Integer size,
+                                                                                  @RequestParam(value = "warningName", required = false) String warningName) {
+        Integer count = idxBizFanWarningRecordMapper.getEquipWarningInfoByPageCount(arae, station, stationType);
+        List<IdxBizFanWarningRecord> idxBizFanWarningRecordIPage = idxBizFanWarningRecordMapper.getEquipWarningInfoByPage(arae, station, stationType, current, size, warningName);
+        Page<IdxBizFanWarningRecord> idxBizFanWarningRecordPage = new Page<>(current, size);
+        idxBizFanWarningRecordPage.setRecords(idxBizFanWarningRecordIPage);
+        idxBizFanWarningRecordPage.setTotal(count);
+        return ResponseHelper.buildResponse(idxBizFanWarningRecordPage);
+    }
+
+
+    @TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
+    @ApiOperation(httpMethod = "GET", value = "各场站设备预警情况(条) ", notes = "各场站设备预警情况(条) ")
+    @GetMapping(value = "/getAllEquipAlarmInfoByStation")
+    public ResponseModel<Map<String, Object>> getAllEquipAlarmInfoByStation() {
+        Map<String, Object> resultMap = new HashMap<>();
+        List<Map<String, Object>> allEquipAlarmInfo = idxBizFanHealthIndexMapper.getAllEquipAlarmInfoByStation();
+        HashMap<String, Integer> wxMap = new HashMap<>();
+        HashMap<String, Integer> zyMap = new HashMap<>();
+        HashMap<String, Integer> jgMap = new HashMap<>();
+        Set<String> list = new HashSet<>();
+        allEquipAlarmInfo.forEach(item -> {
+            if ("危险".equals(item.get("warningName"))) {
+                wxMap.put(item.get("station").toString(), Integer.parseInt(item.get("num").toString()));
+            } else if ("注意".equals(item.get("warningName"))) {
+                zyMap.put(item.get("station").toString(), Integer.parseInt(item.get("num").toString()));
+            } else if ("警告".equals(item.get("warningName"))) {
+                jgMap.put(item.get("station").toString(), Integer.parseInt(item.get("num").toString()));
+            }
+            list.add(item.get("station").toString());
+        });
+        List<Integer> wxList = new ArrayList<>();
+        List<Integer> zyList = new ArrayList<>();
+        List<Integer> jgList = new ArrayList<>();
+//        List<StationBasic> stationBasics = stationBasicMapper.selectList(null);
+//        List<String> list = stationBasics.stream().map(StationBasic::getStationName).collect(Collectors.toList());
+        list.forEach(item -> {
+            wxList.add(wxMap.getOrDefault(item, 0));
+            zyList.add(zyMap.getOrDefault(item, 0));
+            jgList.add(jgMap.getOrDefault(item, 0));
+        });
+
+        HashMap<String, Object> wxMapResult = new HashMap<>();
+        wxMapResult.put("data", wxList);
+        wxMapResult.put("name", "危险");
+        HashMap<String, Object> zyMapResult = new HashMap<>();
+        zyMapResult.put("data", zyList);
+        zyMapResult.put("name", "注意");
+        HashMap<String, Object> jgMapResult = new HashMap<>();
+        jgMapResult.put("data", jgList);
+        jgMapResult.put("name", "警告");
+
+        List<Map<String, Object>> hashMaps = Arrays.asList(wxMapResult, zyMapResult, jgMapResult);
+        resultMap.put("axisData", list);
+        resultMap.put("seriesData", hashMaps);
+        return ResponseHelper.buildResponse(resultMap);
+    }
+
+
+    @TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
+    @ApiOperation(httpMethod = "GET", value = "各场站健康状态指数 ", notes = "各场站健康状态指数 ")
+    @GetMapping(value = "/getHealthInfoByStation")
+    public ResponseModel<Map<String, Object>> getHealthInfoByArea(@RequestParam(required = false) String areaCode) {
+        Map<String, Object> resultMap = new HashMap<>();
+        List<Map<String, Object>> healthListInfo = idxBizFanHealthIndexMapper.getHealthInfoByStation(areaCode);
+        Map<String, BigDecimal> collect = healthListInfo.stream().collect(Collectors.toMap(t -> t.get("area").toString(), t -> new BigDecimal(t.get("healthIndex").toString())));
+
+
+
+        List<StationBasic> stationBasics = stationBasicMapper.selectList(new LambdaQueryWrapper<StationBasic>().eq(StationBasic::getAreaName, areaCode));
+        List<String> list = stationBasics.stream().map(StationBasic::getStationName).collect(Collectors.toList());
+        List<Object> seriesData = new ArrayList<>();
+        list.forEach(item -> seriesData.add(collect.getOrDefault(item, new BigDecimal("0"))));
+        resultMap.put("axisData", list);
+        resultMap.put("seriesData", seriesData);
+        return ResponseHelper.buildResponse(resultMap);
+    }
+
+}

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/entity/IdxBizFanWarningRecord.java

@@ -2,12 +2,15 @@ package com.yeejoin.amos.boot.module.jxiop.biz.entity;
 
 import com.baomidou.mybatisplus.annotation.TableField;
 import com.baomidou.mybatisplus.annotation.TableName;
+import com.fasterxml.jackson.annotation.JsonFormat;
 import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
 import lombok.experimental.Accessors;
+import org.springframework.format.annotation.DateTimeFormat;
 
 import java.time.LocalDateTime;
+import java.util.Date;
 
 /**
  * 
@@ -39,7 +42,7 @@ public class IdxBizFanWarningRecord{
      * 
      */
 	@TableField("REC_DATE")
-    private LocalDateTime recDate;
+    private Date recDate;
 
     /**
      * 

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/mapper2/IdxBizFanHealthIndexMapper.java

@@ -2,6 +2,11 @@ package com.yeejoin.amos.boot.module.jxiop.biz.mapper2;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizFanHealthIndex;
+import org.apache.ibatis.annotations.Param;
+
+import java.math.BigDecimal;
+import java.util.List;
+import java.util.Map;
 
 /**
  *  Mapper 接口
@@ -11,4 +16,16 @@ import com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizFanHealthIndex;
  */
 public interface IdxBizFanHealthIndexMapper extends BaseMapper<IdxBizFanHealthIndex> {
 
+    BigDecimal getHealthScoreInfo(@Param("areaCode") String areaCode, @Param("stationCode") String stationCode);
+
+    List<Map<String, Object>> getHealthListInfo(@Param("areaCode") String areaCode, @Param("stationCode") String stationCode);
+
+    List<Map<String, Object>> getAllEquipAlarmInfo(@Param("tableName") String tableName);
+
+    List<Map<String, Object>> getHealthInfoByArea();
+
+    List<Map<String, Object>> getAllEquipAlarmInfoByStation();
+
+
+    List<Map<String, Object>> getHealthInfoByStation(@Param("areaCode") String areaCode);
 }

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/mapper2/IdxBizFanWarningRecordMapper.java

@@ -2,6 +2,9 @@ package com.yeejoin.amos.boot.module.jxiop.biz.mapper2;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizFanWarningRecord;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
 
 /**
  *  Mapper 接口
@@ -11,4 +14,14 @@ import com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizFanWarningRecord;
  */
 public interface IdxBizFanWarningRecordMapper extends BaseMapper<IdxBizFanWarningRecord> {
 
+    List<IdxBizFanWarningRecord> getEquipWarningInfoByPage(@Param("arae") String arae,
+                                                           @Param("station") String station,
+                                                           @Param("stationType") String stationType,
+                                                           @Param("current") Integer current,
+                                                           @Param("size") Integer size,
+                                                           @Param("warningName") String warningName);
+    Integer getEquipWarningInfoByPageCount(@Param("arae") String arae,
+                                           @Param("station") String station,
+                                           @Param("stationType") String stationType);
+
 }

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/resources/mapper/cluster/IdxBizFanHealthIndexMapper.xml

@@ -2,4 +2,220 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.yeejoin.amos.boot.module.jxiop.biz.mapper2.IdxBizFanHealthIndexMapper">
 
+<select id="getHealthScoreInfo" resultType="java.math.BigDecimal">
+    SELECT
+    avg( a.avgHealthIndex ) AS healthIndex
+    FROM
+    (
+    SELECT
+    IFNULL( AVG( HEALTH_INDEX ), 0 ) AS avgHealthIndex
+    FROM
+    idx_biz_fan_health_index
+    <where>ANALYSIS_TYPE = '按天'
+        AND
+        DATE_FORMAT( REC_DATE, "%Y-%m-%d" ) = DATE_FORMAT( NOW(), "%Y-%m-%d" )
+        <if test="areaCode != null and areaCode != ''">
+                    AND ARAE = #{areaCode}
+                </if>
+                <if test="stationCode != null and stationCode != ''">
+                    AND STATION = #{stationCode}
+                </if>
+                <if test="stationCode == null or stationCode == ''">
+                    AND ( STATION IS NULL OR STATION = '' )
+                </if>
+            </where>
+    UNION ALL
+            (
+                SELECT
+                    IFNULL( AVG( HEALTH_INDEX ), 0 ) AS avgHealthIndex
+                FROM
+                    idx_biz_pv_health_index
+                <where>
+                    ANALYSIS_TYPE = '按天'
+                    AND DATE_FORMAT( REC_DATE, "%Y-%m-%d" ) = DATE_FORMAT( NOW(), "%Y-%m-%d" )
+                    <if test="areaCode != null and areaCode != ''">
+                        AND ARAE = #{areaCode}
+                    </if>
+                    <if test="stationCode != null and stationCode != ''">
+                        AND STATION = #{stationCode}
+                    </if>
+                    <if test="stationCode == null or stationCode == ''">
+                        AND ( STATION IS NULL OR STATION = '' )
+                    </if>
+                </where>
+            )
+        ) a
+</select>
+
+<select id="getHealthListInfo" resultType="java.util.Map">
+    SELECT
+        IFNULL( AVG( HEALTH_INDEX ), 0 ) AS avgHealthIndex,
+        a.date
+    FROM
+        (
+            SELECT
+                DATE_FORMAT( DATE_ADD(( DATE( DATE_ADD( now(), INTERVAL - 15 DAY ))), INTERVAL @s DAY ), '%Y-%m-%d' ) AS date,
+		@s := @s + 1 AS `index`
+            FROM
+                mysql.help_topic,
+                ( SELECT @s := 1 ) temp
+            WHERE
+                DATEDIFF( now(), DATE( DATE_ADD( now(), INTERVAL - 15 DAY )) ) >= @s
+        ) a
+            LEFT JOIN (
+            SELECT
+                HEALTH_INDEX,
+                DATE_FORMAT( REC_DATE, "%Y-%m-%d" ) AS recDate
+            FROM
+                idx_biz_pv_health_index
+                <where>
+                    ANALYSIS_TYPE = '按天'
+                    <if test="areaCode != null and areaCode != ''">
+                        AND ARAE = #{areaCode}
+                    </if>
+                    <if test="stationCode != null and stationCode != ''">
+                        AND STATION = #{stationCode}
+                    </if>
+                    <if test="stationCode == null or stationCode == ''">
+                        AND ( STATION IS NULL OR STATION = '' )
+                    </if>
+                </where>
+            UNION ALL
+            (
+                SELECT
+                    HEALTH_INDEX,
+                    DATE_FORMAT( REC_DATE, "%Y-%m-%d" ) AS recDate
+                FROM
+                    idx_biz_fan_health_index
+                <where>
+                    ANALYSIS_TYPE = '按天'
+                    <if test="areaCode != null and areaCode != ''">
+                        AND ARAE = #{areaCode}
+                    </if>
+                    <if test="stationCode != null and stationCode != ''">
+                        AND STATION = #{stationCode}
+                    </if>
+                    <if test="stationCode == null or stationCode == ''">
+                        AND ( STATION IS NULL OR STATION = '' )
+                    </if>
+                </where>
+            )
+        ) b ON DATE_FORMAT( b.recDate, "%Y-%m-%d" ) = a.date
+    GROUP BY
+        a.date
+    </select>
+
+<select id="getAllEquipAlarmInfo" resultType="java.util.Map">
+    SELECT
+        ARAE as area,
+        WARNING_NAME as warningName,
+        count(1) as num
+    FROM
+        ${tableName} a
+    group by ARAE,
+             WARNING_NAME
+    </select>
+
+<select id="getHealthInfoByArea" resultType="java.util.Map">
+    SELECT
+        ARAE as area,
+        avg( a.avgHealthIndex ) AS healthIndex
+    FROM
+        (
+            SELECT
+                IFNULL( AVG( HEALTH_INDEX ), 0 ) AS avgHealthIndex,
+                ARAE
+            FROM
+                idx_biz_fan_health_index
+            WHERE
+                ( STATION IS NULL OR STATION = '' )
+              AND ANALYSIS_TYPE = '按天'
+              AND DATE_FORMAT( REC_DATE, "%Y-%m-%d" ) = DATE_FORMAT( NOW(), "%Y-%m-%d" )
+            GROUP BY
+                ARAE UNION ALL
+            (
+                SELECT
+                    IFNULL( AVG( HEALTH_INDEX ), 0 ) AS avgHealthIndex,
+                    ARAE
+                FROM
+                    idx_biz_pv_health_index
+                WHERE
+                    ( STATION IS NULL OR STATION = '' )
+                  AND ANALYSIS_TYPE = '按天'
+                  AND DATE_FORMAT( REC_DATE, "%Y-%m-%d" ) = DATE_FORMAT( NOW(), "%Y-%m-%d" )
+                GROUP BY
+                    ARAE
+            )
+        ) a
+    GROUP BY
+        a.ARAE
+    </select>
+
+<select id="getAllEquipAlarmInfoByStation" resultType="java.util.Map">
+    SELECT
+        STATION as station,
+        WARNING_NAME as warningName,
+        count(1) as num
+    FROM
+        idx_biz_fan_warning_record
+    group by STATION,
+             WARNING_NAME
+    union all
+    SELECT
+        STATION as station,
+        WARNING_NAME as warningName,
+        count(1) as num
+    FROM
+        idx_biz_pv_warning_record
+    group by STATION,
+             WARNING_NAME
+    </select>
+
+
+
+    <select id="getHealthInfoByStation" resultType="java.util.Map">
+        SELECT
+            a.STATION as station,
+            avg( a.avgHealthIndex ) AS healthIndex
+        FROM
+            (
+                SELECT
+                    IFNULL( AVG( HEALTH_INDEX ), 0 ) AS avgHealthIndex,
+                    STATION
+                FROM
+                    idx_biz_fan_health_index
+                <where>
+                    ( STATION IS NOT NULL OR STATION != '' )
+                  AND ANALYSIS_TYPE = '按天'
+                  AND DATE_FORMAT( REC_DATE, "%Y-%m-%d" ) = DATE_FORMAT( NOW(), "%Y-%m-%d" )
+                    <if test="areaCode != null and areaCode != ''">
+                        AND ARAE = #{areaCode}
+                    </if>
+                </where>
+                GROUP BY
+                    STATION UNION ALL
+                (
+                    SELECT
+                        IFNULL( AVG( HEALTH_INDEX ), 0 ) AS avgHealthIndex,
+                        ARAE
+                    FROM
+                        idx_biz_pv_health_index
+                    <where>
+                        ( STATION IS NOT NULL OR STATION != '' )
+                      AND ANALYSIS_TYPE = '按天'
+                      AND DATE_FORMAT( REC_DATE, "%Y-%m-%d" ) = DATE_FORMAT( NOW(), "%Y-%m-%d" )
+                        <if test="areaCode != null and areaCode != ''">
+                            AND ARAE = #{areaCode}
+                        </if>
+                    </where>
+                    GROUP BY
+                        STATION
+                )
+            ) a
+        GROUP BY
+            a.STATION
+    </select>
+
+
+
 </mapper>

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/resources/mapper/cluster/IdxBizFanWarningRecordMapper.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.yeejoin.amos.boot.module.jxiop.biz.mapper2.IdxBizFanWarningRecordMapper">
+    
+<select id="getEquipWarningInfoByPage"
+            resultType="com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizFanWarningRecord">
+    SELECT
+        a.*
+    FROM
+        (
+            SELECT
+                REC_DATE AS recDate,
+                STATION AS station,
+                EQUIPMENT_NAME AS equipmentName,
+                CONTENT AS content,
+                WARNING_NAME AS warningName,
+                DISPOSOTION_STATE AS disposotionState,
+                ARAE AS arae,
+                'pv' AS stationType
+            FROM
+                idx_biz_pv_warning_record UNION ALL
+            SELECT
+                REC_DATE AS recDate,
+                STATION AS station,
+                EQUIPMENT_NAME AS equipmentName,
+                CONTENT AS content,
+                WARNING_NAME AS warningName,
+                DISPOSOTION_STATE AS disposotionState,
+                ARAE AS arae,
+                'fan' AS stationType
+            FROM
+                idx_biz_fan_warning_record
+        ) a
+    <where>
+        <if test="arae != '' and arae != null">
+            AND a.arae = #{arae}
+        </if>
+        <if test="station != '' and station != null">
+            AND a.station = #{station}
+        </if>
+        <if test="stationType != '' and stationType != null">
+            AND a.stationType = #{stationType}
+        </if>
+        <if test="warningName != '' and warningName != null">
+            AND a.WARNING_NAME = #{warningName}
+        </if>
+    </where>
+    limit #{current}, #{size}
+</select>
 
+<select id="getEquipWarningInfoByPageCount" resultType="java.lang.Integer">
+    SELECT
+    count(1)
+    FROM
+    (
+    SELECT
+    REC_DATE AS recDate,
+    STATION AS station,
+    EQUIPMENT_NAME AS equipmentName,
+    CONTENT AS content,
+    WARNING_NAME AS warningName,
+    DISPOSOTION_STATE AS disposotionState,
+    ARAE AS arae,
+    'pv' AS stationType
+    FROM
+    idx_biz_pv_warning_record UNION ALL
+    SELECT
+    REC_DATE AS recDate,
+    STATION AS station,
+    EQUIPMENT_NAME AS equipmentName,
+    CONTENT AS content,
+    WARNING_NAME AS warningName,
+    DISPOSOTION_STATE AS disposotionState,
+    ARAE AS arae,
+    'fan' AS stationType
+    FROM
+    idx_biz_fan_warning_record
+    ) a
+    <where>
+        <if test="arae != '' and arae != null">
+            AND a.arae = #{arae}
+        </if>
+        <if test="station != '' and station != null">
+            AND a.station = #{station}
+        </if>
+        <if test="stationType != '' and stationType != null">
+           AND a.stationType = #{stationType}
+        </if>
+        <if test="warningName != '' and warningName != null">
+            AND a.WARNING_NAME = #{warningName}
+        </if>
+    </where>
+    </select>
 </mapper>

amos-boot-system-jxiop/amos-boot-module-jxiop-monitor-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/service/impl/MonitorFanIndicatorImpl.java

@@ -986,7 +986,7 @@ public class MonitorFanIndicatorImpl implements IMonitorFanIndicator {
         //构建平台数据
         DataGridMock DataGridMock = new DataGridMock(current, resultList.size(), false, current, resultList);
         ColModel colModelEquipmentNumber = new ColModel("equipmentNumber", "equipmentNumber", "风机编码", "风机编码", "dataGrid", "equipmentNumber");
-        ColModel colModelPower = new ColModel("power", "power", "有功功率(MV)", "有功功率(MV)", "dataGrid", "power");
+        ColModel colModelPower = new ColModel("power", "power", "有功功率(kW)", "有功功率(kW)", "dataGrid", "power");
         ColModel colModelWindSpeed = new ColModel("windSpeed", "windSpeed", "风速(m/s)", "风速(m/s)", "dataGrid", "windSpeed");
         ColModel colModelWind = new ColModel("wind", "wind", "风向(°)", "风向(°)", "dataGrid", "wind");
         ColModel colModelElectricity = new ColModel("electricity", "electricity", "日发电量(万KWh)", "日发电量(万KWh)", "dataGrid", "electricity");