添加告警查询

amos-boot-system-jxiop/amos-boot-module-jxiop-monitor-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/config/TdEngineConfig.java

@@ -2,7 +2,11 @@ package com.yeejoin.amos.boot.module.jxiop.biz.config;
 
 
 import com.alibaba.druid.pool.DruidDataSource;
+import com.baomidou.mybatisplus.extension.plugins.PaginationInterceptor;
 import com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean;
+import com.github.pagehelper.PageInterceptor;
+
+import org.apache.ibatis.plugin.Interceptor;
 import org.apache.ibatis.session.SqlSessionFactory;
 import org.mybatis.spring.annotation.MapperScan;
 import org.slf4j.Logger;
@@ -14,6 +18,8 @@ import org.springframework.context.annotation.Configuration;
 import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
 import org.springframework.jdbc.datasource.DataSourceTransactionManager;
 
+import java.util.Properties;
+
 import javax.sql.DataSource;
 
 /**
@@ -60,14 +66,30 @@ public class TdEngineConfig {
     @Bean(name = "taosSqlSessionFactory")
     public SqlSessionFactory clusterSqlSessionFactory(@Qualifier("taosDataSource") DataSource culsterDataSource)
             throws Exception {
-        final MybatisSqlSessionFactoryBean sessionFactory = new MybatisSqlSessionFactoryBean();
-        sessionFactory.setDataSource(culsterDataSource);
-        sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver()
-                .getResources(TdEngineConfig.MAPPER_LOCATION));
-        sessionFactory.setTypeAliasesPackage("com.yeejoin.amos.boot.module.jxiop.biz.entity");
-        //mybatis 数据库字段与实体类属性驼峰映射配置
-        sessionFactory.getObject().getConfiguration().setMapUnderscoreToCamelCase(true);
-        return sessionFactory.getObject();
+        MybatisSqlSessionFactoryBean bean = new MybatisSqlSessionFactoryBean();
+        bean.setDataSource(culsterDataSource);
+        bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources(MAPPER_LOCATION));
+
+        //分页插件
+        Interceptor interceptor = new PageInterceptor();
+        Properties properties = new Properties();
+        properties.setProperty("helperDialect", "mysql");
+        properties.setProperty("offsetAsPageNum", "true");
+        properties.setProperty("rowBoundsWithCount", "true");
+        properties.setProperty("reasonable", "true");
+        properties.setProperty("supportMethodsArguments","true");
+        properties.setProperty("params","pageNum=pageNum;pageSize=pageSize" +
+                "" +
+                ";");
+        interceptor.setProperties(properties);
+        bean.setPlugins(new Interceptor[] {interceptor,paginationInterceptor()});
+        return bean.getObject();
+    }
+    
+    @Bean
+    public PaginationInterceptor paginationInterceptor() {
+        PaginationInterceptor paginationInterceptor = new PaginationInterceptor();
+        return paginationInterceptor;
     }
 }
 

amos-boot-system-jxiop/amos-boot-module-jxiop-monitor-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/controller/EventController.java

+package com.yeejoin.amos.boot.module.jxiop.biz.controller;
+
+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 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.dto.ResultsData;
+import com.yeejoin.amos.boot.module.jxiop.biz.service.impl.AlarmEventServiceImpl;
+import com.yeejoin.amos.boot.module.jxiop.biz.service.impl.EquipAlarmEventServiceImpl;
+
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+
+@RestController
+@Api(tags = "event")
+@RequestMapping(value = "/event")
+public class EventController {
+
+	@Autowired
+	private AlarmEventServiceImpl alarmEventServiceImpl;
+
+	@Autowired
+	private EquipAlarmEventServiceImpl equipAlarmEventServiceImpl;
+
+	@Autowired
+	private StationBasicMapper stationBasicMapper;
+	
+	@TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY)
+	@ApiOperation(value = "故障记录API")
+	@GetMapping("/equipDivergenceEventtList")
+	public ResponseModel<ResultsData> equipDivergenceEventtList(@RequestParam(value = "current") int current,
+			@RequestParam(value = "size") int size, @RequestParam(value = "stationId") String stationId) {
+		ResultsData resultsData = new ResultsData();
+		StationBasic stationBasic = stationBasicMapper.selectById(stationId);
+		String fanGatewayId = stationBasic.getFanGatewayId();
+		resultsData = equipAlarmEventServiceImpl.getEquipDivergenceEvent(fanGatewayId,current, size );
+		return ResponseHelper.buildResponse(resultsData);
+	}
+	
+//	@TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY)
+//	@ApiOperation(value = "刷新字典API")
+//	@GetMapping("/dic/refresh")
+//	public ResponseModel<String> refresh() {
+//		alarmEventServiceImpl.init();
+//		return ResponseHelper.buildResponse("success");
+//	}
+}

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

 package com.yeejoin.amos.boot.module.jxiop.biz.service.impl;
 
+import java.text.SimpleDateFormat;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.Calendar;
+import java.util.List;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.typroject.tyboot.core.rdbms.service.BaseService;
+
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
-import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
-import com.yeejoin.amos.boot.module.jxiop.api.entity.StationBasic;
+import com.github.pagehelper.PageHelper;
+import com.github.pagehelper.PageInfo;
 import com.yeejoin.amos.boot.module.jxiop.api.mapper.StationBasicMapper;
 import com.yeejoin.amos.boot.module.jxiop.biz.dto.ColModel;
 import com.yeejoin.amos.boot.module.jxiop.biz.dto.DataGridMock;
 import com.yeejoin.amos.boot.module.jxiop.biz.dto.EquipAlarmEventDto;
 import com.yeejoin.amos.boot.module.jxiop.biz.dto.ResultsData;
 import com.yeejoin.amos.boot.module.jxiop.biz.entity.EquipAlarmEvent;
+import com.yeejoin.amos.boot.module.jxiop.biz.entity.EquipDivergenceAlarmEvent;
 import com.yeejoin.amos.boot.module.jxiop.biz.mapper2.EquipAlarmEventMapper;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Service;
-import org.typroject.tyboot.core.rdbms.service.BaseService;
-
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.Calendar;
-import java.util.List;
+import com.yeejoin.amos.boot.module.jxiop.biz.tdmapper.EquipDivergenceAlarmEventMapper;
 
 @Service
 public class EquipAlarmEventServiceImpl extends BaseService<EquipAlarmEventDto, EquipAlarmEvent, EquipAlarmEventMapper> {
@@ -28,6 +32,8 @@ public class EquipAlarmEventServiceImpl extends BaseService<EquipAlarmEventDto,
     EquipAlarmEventMapper equipAlarmEventMapper;
     @Autowired
     StationBasicMapper stationBasicMapper;
+    @Autowired
+    EquipDivergenceAlarmEventMapper equipDivergenceAlarmEventMapper;
 
     public ResultsData getEventByEquipIndex(String gatewayId, int current, int size, String equipIndex, String frontModule) {
         List<EquipAlarmEventDto> equipAlarmEvents = new ArrayList<>();
@@ -68,4 +74,45 @@ public class EquipAlarmEventServiceImpl extends BaseService<EquipAlarmEventDto,
         ResultsData resultsData = new ResultsData(DataGridMock, listColModel);
         return resultsData;
     }
+    
+    public ResultsData getEquipDivergenceEvent(String gatewayId, int current, int size) {
+    	PageHelper.startPage(current, size);
+		Calendar calendar = Calendar.getInstance();
+		calendar.add(Calendar.DAY_OF_MONTH, -2);
+		
+		List<EquipDivergenceAlarmEvent> alarmEventList = equipDivergenceAlarmEventMapper.getEventList(gatewayId, null, null,
+				calendar.getTime());
+
+		SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+		Calendar car = Calendar.getInstance();
+		alarmEventList.forEach(i -> {
+//			if ("true".equals(i.getValue())) {
+//				i.setValue("合");
+//			} else if ("false".equals(i.getValue())) {
+//				i.setValue("分");
+//			}
+			long mills = i.getCreatedTime() / 1000000;
+			car.setTimeInMillis(mills);
+			// System.out.println(sdf.format(car.getTime()));
+			i.setTime(sdf.format(car.getTime()));
+			// car.add(Calendar.HOUR, 12);
+			// System.out.println(sdf.format(car.getTime()));
+		});
+
+		PageInfo<EquipAlarmEvent> page = new PageInfo(alarmEventList);
+
+		// 构建平台数据
+		DataGridMock DataGridMock = new DataGridMock(current, (int) page.getTotal(), false, current, alarmEventList);
+		ColModel colModelEventMovement = new ColModel("equipName", "equipName", "设备名称", "设备名称", "dataGrid",
+				"equipName");
+		ColModel colModelStationName = new ColModel("eventDesc", "eventDesc", "事件描述", "事件描述", "dataGrid", "eventDesc");
+		ColModel colModelAlarmGroupName = new ColModel("alarmGroupName", "alarmGroupName", "事件类型", "事件类型", "dataGrid",
+				"alarmGroupName");
+		ColModel colModelEventDesc = new ColModel("time", "time", "事件发生时间", "事件发生时间", "dataGrid", "time");
+		ColModel colModelValueDesc = new ColModel("value", "value", "事件值", "事件值", "dataGrid", "value");
+		List<ColModel> listColModel = Arrays.asList(colModelEventMovement, colModelStationName, colModelAlarmGroupName,
+				colModelEventDesc, colModelValueDesc);
+		ResultsData resultsData = new ResultsData(DataGridMock, listColModel);
+		return resultsData;
+    }
 }