#定时任务抽离

hzims-service/hzims-scheduled/pom.xml

@@ -12,9 +12,9 @@
     <artifactId>hzims-scheduled</artifactId>
     <packaging>jar</packaging>
     <properties>
-        <maven.compiler.source>8</maven.compiler.source>
-        <maven.compiler.target>8</maven.compiler.target>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+        <documents4j.version>1.0.3</documents4j.version>
+        <swagger-bootstrap-ui.version>1.9.6</swagger-bootstrap-ui.version>
     </properties>
     <dependencies>
         <dependency>
@@ -52,6 +52,11 @@
             <artifactId>blade-starter-swagger</artifactId>
         </dependency>
         <dependency>
+            <groupId>com.baomidou</groupId>
+            <artifactId>dynamic-datasource-spring-boot-starter</artifactId>
+            <version>2.5.6</version>
+        </dependency>
+        <dependency>
             <groupId>com.hnac.hzims</groupId>
             <artifactId>hzims-operational-api</artifactId>
         </dependency>

hzims-service/hzims-scheduled/src/main/java/com/hnac/hzims/scheduled/ScheduledApplication.java

@@ -1,11 +1,16 @@
 package com.hnac.hzims.scheduled;
 
+import com.hnac.hzims.operational.OperationalConstants;
 import org.mybatis.spring.annotation.MapperScan;
 import org.springblade.core.cloud.feign.EnableBladeFeign;
+import org.springblade.core.launch.BladeApplication;
 import org.springframework.boot.Banner;
 import org.springframework.boot.SpringApplication;
+import org.springframework.boot.builder.SpringApplicationBuilder;
+import org.springframework.boot.web.servlet.support.SpringBootServletInitializer;
 import org.springframework.cloud.client.SpringCloudApplication;
 import org.springframework.context.annotation.ComponentScan;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
 import javax.annotation.Resource;
 
@@ -15,17 +20,19 @@ import javax.annotation.Resource;
  * @Serial 1.0
  * @Date 2023/5/19 9:05
  */
-@EnableBladeFeign
+@EnableBladeFeign(basePackages = {"org.springblade","com.hnac"})
 @SpringCloudApplication
-@MapperScan("com.hnac.hzims.scheduled.**.mapper.**")
+@MapperScan("com.hnac.hzims.scheduled.mapper.**.**")
-@ComponentScan(basePackages = {"com.hnac.*","org.springblade.core"})
+@EnableScheduling
+@ComponentScan(basePackages = {"com.hnac.hzims.scheduled.*","org.springblade.core"})
 @Resource
-public class ScheduledApplication  {
+public class ScheduledApplication  extends SpringBootServletInitializer {
     public static void main(String[] args) {
-        // BladeApplication.run(ScheduledConstants.APP_NAME, ScheduledApplication.class, args);
+        BladeApplication.run("hzims-scheduled", ScheduledApplication.class, args);
-        SpringApplication springApplication = new SpringApplication(ScheduledApplication.class);
-        springApplication.setBannerMode(Banner.Mode.OFF);
-        springApplication.run(args);
     }
 
+    @Override
+    protected SpringApplicationBuilder configure(SpringApplicationBuilder builder) {
+        return BladeApplication.createSpringApplicationBuilder(builder, "hzims-scheduled", ScheduledApplication.class);
+    }
 }

hzims-service/hzims-scheduled/src/main/java/com/hnac/hzims/scheduled/mapper/equipment/DeviceMapper.java

@@ -0,0 +1,15 @@
+package com.hnac.hzims.scheduled.mapper.equipment;
+
+import com.hnac.hzims.equipment.entity.EmInfoEntity;
+import com.hnac.hzims.equipment.vo.EminfoAndEmParamVo;
+import org.springblade.core.datascope.mapper.UserDataScopeBaseMapper;
+
+import java.util.List;
+
+/**
+ * @author ysj
+ */
+public interface DeviceMapper extends UserDataScopeBaseMapper<EmInfoEntity> {
+
+	List<EminfoAndEmParamVo> device();
+}

hzims-service/hzims-scheduled/src/main/java/com/hnac/hzims/scheduled/mapper/equipment/DeviceParamMapper.java

@@ -0,0 +1,16 @@
+package com.hnac.hzims.scheduled.mapper.equipment;
+
+import com.hnac.hzims.equipment.entity.EmParamEntity;
+import org.springblade.core.datascope.mapper.UserDataScopeBaseMapper;
+
+import java.util.List;
+
+/**
+ *  Mapper 接口
+ *
+ * @author Chill
+ */
+public interface DeviceParamMapper extends UserDataScopeBaseMapper<EmParamEntity> {
+
+	List<EmParamEntity> params();
+}

hzims-service/hzims-scheduled/src/main/java/com/hnac/hzims/scheduled/scheduled/MonitorScheduledTask.java

@@ -7,6 +7,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.springblade.core.tool.utils.DateUtil;
 import org.springblade.core.tool.utils.Func;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
 import java.util.Date;

hzims-service/hzims-scheduled/src/main/java/com/hnac/hzims/scheduled/scheduled/RealTargetScheduledTask.java

@@ -8,11 +8,13 @@ import lombok.extern.slf4j.Slf4j;
 import org.springblade.core.tool.utils.DateUtil;
 import org.springblade.core.tool.utils.Func;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
 import java.util.Arrays;
 import java.util.Date;
 
+import static com.hnac.hzims.fdp.constants.ScheduledConstant.LOAD_EM_INFO;
 import static com.hnac.hzims.operational.main.constant.MainConstants.*;
 
 
@@ -26,6 +28,16 @@ public class RealTargetScheduledTask {
     @Autowired
     private RealTargetService service;
 
+    /**
+     * 设备信息缓存
+     * @return
+     * @throws Exception
+     */
+    @XxlJob(LOAD_EM_INFO)
+    public ReturnT<String> loadEmInfo(String param) {
+        service.loadEmInfo();
+        return new ReturnT<>("SUCCESS");
+    }
 
     /**
      * 水电站-机组实时加载

hzims-service/hzims-scheduled/src/main/java/com/hnac/hzims/scheduled/scheduled/ShowScheduledTask.java

@@ -7,6 +7,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.springblade.core.tool.utils.DateUtil;
 import org.springblade.core.tool.utils.Func;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
 import java.util.Date;
@@ -28,6 +29,7 @@ public class ShowScheduledTask {
      * 首页-指标数据加载
      */
     @XxlJob(LOAD_HOME_TARGET)
+    //@Scheduled(cron = "0/40 * * * * ? ")
     public ReturnT<String> loadHomeTarget(String param) {
         if (Func.isBlank(param)) {
             param = DateUtil.format(new Date(), "yyyy-MM");

hzims-service/hzims-scheduled/src/main/java/com/hnac/hzims/scheduled/service/equipment/DeviceParamService.java

@@ -0,0 +1,14 @@
+package com.hnac.hzims.scheduled.service.equipment;
+
+import com.hnac.hzims.equipment.entity.EmParamEntity;
+import org.springblade.core.mp.base.BaseService;
+
+import java.util.List;
+
+/**
+ * @author ysj
+ */
+public interface DeviceParamService extends BaseService<EmParamEntity> {
+
+	List<EmParamEntity> params();
+}

hzims-service/hzims-scheduled/src/main/java/com/hnac/hzims/scheduled/service/equipment/DeviceService.java

@@ -0,0 +1,15 @@
+package com.hnac.hzims.scheduled.service.equipment;
+
+import com.hnac.hzims.equipment.entity.EmInfoEntity;
+import com.hnac.hzims.equipment.vo.EminfoAndEmParamVo;
+import org.springblade.core.mp.base.BaseService;
+
+import java.util.List;
+
+/**
+ * @author ysj
+ */
+public interface DeviceService extends BaseService<EmInfoEntity> {
+
+	List<EminfoAndEmParamVo> device();
+}

hzims-service/hzims-scheduled/src/main/java/com/hnac/hzims/scheduled/service/equipment/impl/DeviceParamServiceImpl.java

@@ -0,0 +1,28 @@
+package com.hnac.hzims.scheduled.service.equipment.impl;
+
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.hnac.hzims.equipment.entity.EmParamEntity;
+import com.hnac.hzims.scheduled.mapper.equipment.DeviceParamMapper;
+import com.hnac.hzims.scheduled.service.equipment.DeviceParamService;
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springblade.core.mp.base.BaseServiceImpl;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * @author ysj
+ */
+@AllArgsConstructor
+@Service
+@Slf4j
+@DS("equipment")
+public class DeviceParamServiceImpl extends BaseServiceImpl<DeviceParamMapper, EmParamEntity> implements DeviceParamService {
+
+
+    @Override
+    public List<EmParamEntity> params() {
+        return this.baseMapper.params();
+    }
+}

hzims-service/hzims-scheduled/src/main/java/com/hnac/hzims/scheduled/service/equipment/impl/DeviceServiceImpl.java

@@ -0,0 +1,28 @@
+package com.hnac.hzims.scheduled.service.equipment.impl;
+
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.hnac.hzims.equipment.entity.EmInfoEntity;
+import com.hnac.hzims.equipment.vo.EminfoAndEmParamVo;
+import com.hnac.hzims.scheduled.mapper.equipment.DeviceMapper;
+import com.hnac.hzims.scheduled.service.equipment.DeviceService;
+import com.sun.org.apache.regexp.internal.RE;
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springblade.core.mp.base.BaseServiceImpl;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * @author ysj
+ */
+@AllArgsConstructor
+@Service
+@Slf4j
+@DS("equipment")
+public class DeviceServiceImpl extends BaseServiceImpl<DeviceMapper, EmInfoEntity> implements DeviceService {
+    @Override
+    public List<EminfoAndEmParamVo> device() {
+        return this.baseMapper.device();
+    }
+}

hzims-service/hzims-scheduled/src/main/java/com/hnac/hzims/scheduled/service/equipment/impl/PlanServiceImpl.java

@@ -14,9 +14,9 @@ import java.util.List;
 /**
  * @author ysj
  */
+@AllArgsConstructor
 @Service
 @Slf4j
-@AllArgsConstructor
 @DS("equipment")
 public class PlanServiceImpl extends BaseServiceImpl<PlanMapper, PlanGenerationEntity> implements PlanService {
 

hzims-service/hzims-scheduled/src/main/java/com/hnac/hzims/scheduled/service/equipment/impl/WorkshopInfoServiceImpl.java

@@ -12,8 +12,8 @@ import org.springframework.stereotype.Service;
 /**
  * @author hx
  */
-@Service
 @AllArgsConstructor
+@Service
 @Slf4j
 @DS("equipment")
 public class WorkshopInfoServiceImpl extends BaseServiceImpl<WorkshopInfoMapper, WorkshopInfoEntity> implements WorkshopInfoService {

hzims-service/hzims-scheduled/src/main/java/com/hnac/hzims/scheduled/service/operation/DataService.java

@@ -1,8 +1,10 @@
 package com.hnac.hzims.scheduled.service.operation;
 
+import com.hnac.hzinfo.datasearch.analyse.domain.FieldsData;
 import com.hnac.hzinfo.datasearch.analyse.vo.AnalyseDataTaosVO;
 import com.hnac.hzinfo.datasearch.analyse.vo.AnalyzeCodeBySignagesVO;
 import com.hnac.hzinfo.sdk.analyse.po.MultiAnalyzeCodePO;
+import org.springblade.core.tool.api.R;
 
 import java.util.List;
 import java.util.function.Function;
@@ -11,10 +13,13 @@ import java.util.function.Function;
 /**
  * @author ysj
  */
-public interface AnalyseDataService {
+public interface DataService {
 
 	<T> List<AnalyzeCodeBySignagesVO> getAnalyzeCodeBySignages(Function<T, MultiAnalyzeCodePO> convert, T resource);
 
+	List<AnalyzeCodeBySignagesVO> analyzeCodeBySignages(List<MultiAnalyzeCodePO> list);
+
+	List<FieldsData> getRealDataByAnalyzeCode(String instanceCode, List<String> signages);
 
 	List<AnalyseDataTaosVO>  periodTargetData(String startTime, String endTime, Integer accessRules, Integer cycleType, String deviceCode, String signages);
 

hzims-service/hzims-scheduled/src/main/java/com/hnac/hzims/scheduled/service/operation/RealTargetService.java

@@ -8,6 +8,9 @@ import java.util.List;
  */
 public interface RealTargetService {
 
+
+	void loadEmInfo();
+
 	// 水电站实时数据加载
 	void loadHydropowerReal(String param);
 

hzims-service/hzims-scheduled/src/main/java/com/hnac/hzims/scheduled/service/operation/impl/DataServiceImpl.java

@@ -1,14 +1,17 @@
 package com.hnac.hzims.scheduled.service.operation.impl;
 
 import com.google.common.collect.Lists;
-import com.hnac.hzims.scheduled.service.operation.AnalyseDataService;
+import com.hnac.hzims.scheduled.service.operation.DataService;
 import com.hnac.hzinfo.datasearch.analyse.IAnalyseDataSearchClient;
+import com.hnac.hzinfo.datasearch.analyse.domain.FieldsData;
 import com.hnac.hzinfo.datasearch.analyse.po.AnalyseCodeByAnalyseDataPO;
 import com.hnac.hzinfo.datasearch.analyse.po.AnalyzeDataConditionPO;
 import com.hnac.hzinfo.datasearch.analyse.vo.AnalyseDataTaosVO;
 import com.hnac.hzinfo.datasearch.analyse.vo.AnalyzeCodeBySignagesVO;
 import com.hnac.hzinfo.datasearch.analyse.vo.AnalyzeDataConditionVO;
+import com.hnac.hzinfo.datasearch.real.po.RealDataSearchPO;
 import com.hnac.hzinfo.sdk.analyse.po.MultiAnalyzeCodePO;
+import com.sun.org.apache.regexp.internal.RE;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springblade.core.tool.api.R;
@@ -20,10 +23,7 @@ import org.springframework.stereotype.Service;
 
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
-import java.util.ArrayList;
+import java.util.*;
-import java.util.Date;
-import java.util.List;
-import java.util.Optional;
 import java.util.function.Function;
 import java.util.stream.Collectors;
 
@@ -33,7 +33,7 @@ import java.util.stream.Collectors;
 @Service
 @AllArgsConstructor
 @Slf4j
-public class AnalyseDataServiceImpl implements AnalyseDataService {
+public class DataServiceImpl implements DataService {
 
 	private final IAnalyseDataSearchClient analyseDataSearchClient;
 
@@ -48,6 +48,29 @@ public class AnalyseDataServiceImpl implements AnalyseDataService {
 		return result;
 	}
 
+	@Override
+	public List<AnalyzeCodeBySignagesVO> analyzeCodeBySignages(List<MultiAnalyzeCodePO> list) {
+		R<List<AnalyzeCodeBySignagesVO>> result = analyseDataSearchClient.getAnalyzeCodeBySignages(list);
+		if(!result.isSuccess() || CollectionUtil.isEmpty(result.getData())){
+			return new ArrayList<>();
+		}
+		return result.getData();
+	}
+
+	@Override
+	public List<FieldsData> getRealDataByAnalyzeCode(String instanceCode, List<String> signages) {
+		RealDataSearchPO realData = new RealDataSearchPO();
+		realData.setAnalyzeCode(instanceCode);
+		realData.setSignages(signages);
+		// 调用fegin接口查询实时数据
+		R<List<FieldsData>> result = analyseDataSearchClient.getRealDataByAnalyzeCode(realData);
+		if(!result.isSuccess() || CollectionUtil.isEmpty(result.getData())){
+			return new ArrayList<>();
+		}
+		return result.getData();
+	}
+
+
 	/***
 	 * 指标数据列表查询
 	 * @param startTime 开始时间

hzims-service/hzims-scheduled/src/main/java/com/hnac/hzims/scheduled/service/operation/impl/MonitorServiceImpl.java

@@ -737,6 +737,9 @@ public class MonitorServiceImpl implements MonitorService {
         // 遍历设备
         List<String> result = new ArrayList<>();
         for(EminfoAndEmParamVo device : filters){
+            if(CollectionUtil.isEmpty(device.getPoint())){
+                continue;
+            }
             result.addAll(device.getPoint().values());
         }
         return result;

hzims-service/hzims-scheduled/src/main/java/com/hnac/hzims/scheduled/service/operation/impl/RealTargetServiceImpl.java

@@ -5,15 +5,17 @@ import com.alibaba.fastjson.TypeReference;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.hnac.hzims.EquipmentConstants;
+import com.hnac.hzims.equipment.entity.EmParamEntity;
 import com.hnac.hzims.equipment.vo.EminfoAndEmParamVo;
 import com.hnac.hzims.operational.main.constant.HomePageConstant;
 import com.hnac.hzims.operational.main.vo.*;
 import com.hnac.hzims.operational.station.StationConstants;
 import com.hnac.hzims.operational.station.entity.HzimsAnalyzeModelStationEntity;
 import com.hnac.hzims.operational.station.entity.StationEntity;
+import com.hnac.hzims.scheduled.service.equipment.DeviceParamService;
+import com.hnac.hzims.scheduled.service.equipment.DeviceService;
 import com.hnac.hzims.scheduled.service.operation.*;
 import com.hnac.hzinfo.datasearch.PointData;
-import com.hnac.hzinfo.datasearch.analyse.IAnalyseDataSearchClient;
 import com.hnac.hzinfo.datasearch.analyse.domain.FieldsData;
 import com.hnac.hzinfo.datasearch.analyse.po.AnalyseCodeByAnalyseDataPO;
 import com.hnac.hzinfo.datasearch.analyse.vo.AnalyseDataTaosVO;
@@ -40,6 +42,7 @@ import org.springframework.stereotype.Service;
 import java.math.BigDecimal;
 import java.util.*;
 import java.util.stream.Collectors;
+import java.util.stream.Stream;
 
 /**
  * APP首页实现类
@@ -52,13 +55,17 @@ public class RealTargetServiceImpl implements RealTargetService {
 
 	private final UseService useService;
 
+	private final DataService dataService;
+
 	private final PowerService powerService;
 
+	private final DeviceService deviceService;
+
 	private final StationService stationService;
 
 	private final GenerateService generateService;
 
-	private final AnalyseDataService analyseDataService;
+	private final DeviceParamService deviceParamService;
 
 	private final StationAttributeService attributeService;
 
@@ -66,8 +73,6 @@ public class RealTargetServiceImpl implements RealTargetService {
 
 	private final RedisTemplate redisTemplate;
 
-	private final IAnalyseDataSearchClient analyseDataSearchClient;
-
 	private final IHistoryDataSearchClient historyDataSearchClient;
 
 	@Value("${hzims.equipment.emInfo.emInfoList}")
@@ -86,6 +91,71 @@ public class RealTargetServiceImpl implements RealTargetService {
 	private final static String load_photovoltaic_target_key = "hzims:operation:photovoltaic:target:key";
 
 
+	@Override
+	public void loadEmInfo() {
+		// 查询所有首页展示/状态非删除设备
+		List<EminfoAndEmParamVo> devices = deviceService.device();
+		// 查询所有设备(ct、pt、installedCapacity)配置参数
+		List<EmParamEntity> paramList = deviceParamService.params();
+		// 获取设备监测点位：未配置监测点位不进行统计设备
+		List<MultiAnalyzeCodePO> multiAnalyzeCodePOList = devices.stream().map(o->{
+			MultiAnalyzeCodePO multiAnalyzeCodePO = new MultiAnalyzeCodePO();
+			multiAnalyzeCodePO.setDeviceCode(o.getEmCode());
+			multiAnalyzeCodePO.setSignages(HomePageConstant.SIGNAGES);
+			return multiAnalyzeCodePO;
+		}).collect(Collectors.toList());
+		// 切割
+		int limit = countStep(multiAnalyzeCodePOList.size());
+		List<List<MultiAnalyzeCodePO>> lists = Stream.iterate(0, n -> n + 1).limit(limit).parallel().map(a -> multiAnalyzeCodePOList.stream().skip((long) a * 3).limit(3).parallel().collect(Collectors.toList())).collect(Collectors.toList());
+		// 接收数据
+		List<AnalyzeCodeBySignagesVO> analys = new ArrayList<>();
+		lists.forEach(list->{
+			List<AnalyzeCodeBySignagesVO> result = dataService.analyzeCodeBySignages(list);
+			if(CollectionUtil.isEmpty(result)){
+				return;
+			}
+			analys.addAll(result);
+		});
+		// 设备遍历
+		devices.forEach(item->{
+			item.setRideCount(1);
+			item.setInstalledCapacity(0.0);
+			List<AnalyzeCodeBySignagesVO> signages = analys.stream().filter(o-> item.getEmCode().equals(o.getDeviceCode()) && !StringUtil.isEmpty(o.getSignage()) && !StringUtil.isEmpty(o.getRealId())).collect(Collectors.toList());
+			if(CollectionUtil.isNotEmpty(signages)){
+				// list -> map
+				item.setPoint(signages.stream().collect(Collectors.toMap(AnalyzeCodeBySignagesVO::getSignage,AnalyzeCodeBySignagesVO::getRealId)));
+			}
+			// 寻找设备配置参数
+			List<EmParamEntity> itemParamList = paramList.stream().filter(o->item.getId().equals(o.getInfoId())).collect(Collectors.toList());
+			if(CollectionUtil.isNotEmpty(itemParamList)){
+				// 遍历设备配置参数
+				for(EmParamEntity param : itemParamList){
+					String param_name = param.getParamName();
+					switch (param_name){
+						case "ct":
+							item.setCt(Integer.valueOf(param.getParamValue()));
+							break;
+						case "pt":
+							item.setPt(Integer.valueOf(param.getParamValue()));
+							break;
+						case "installedCapacity":
+							item.setInstalledCapacity(Double.valueOf(param.getParamValue()));
+							break;
+						default:
+							break;
+					}
+				}
+				// 设置ct * pt
+				if(null != item.getCt() && null != item.getPt()){
+					item.setRideCount(item.getCt() * item.getPt());
+				}
+			}
+		});
+		// 设置缓存
+		redisTemplate.opsForValue().set(device_cache_cofig_final, JSONObject.toJSONString(devices.stream().filter(o-> Math.abs(o.getInstalledCapacity()) > 0  || MapUtils.isNotEmpty(o.getPoint())).collect(Collectors.toList())));
+	}
+
+
 	/**
 	 * 加载水电站机组实时数据
 	 * @param param
@@ -297,15 +367,6 @@ public class RealTargetServiceImpl implements RealTargetService {
 		}
 		List<WaterLevelVo> list = new ArrayList<>();
 		modelList.forEach(item -> {
-			List<MultiAnalyzeCodePO> multiAnalyzeCodePOList = new ArrayList<>();
-			MultiAnalyzeCodePO multiAnalyzeCodePO = new MultiAnalyzeCodePO();
-			multiAnalyzeCodePO.setDeviceCode(item.getInstanceCode());
-			multiAnalyzeCodePO.setSignages(Collections.singletonList(HomePageConstant.FRONT_WATER_LEVEL));
-			multiAnalyzeCodePOList.add(multiAnalyzeCodePO);
-			R<List<AnalyzeCodeBySignagesVO>> result = analyseDataSearchClient.getAnalyzeCodeBySignages(multiAnalyzeCodePOList);
-			if(!result.isSuccess() || CollectionUtil.isEmpty(result.getData())){
-				return;
-			}
 			WaterLevelVo waterLevelVo = new WaterLevelVo();
 			waterLevelVo.setStationCode(item.getStationId());
 			// 前水位
@@ -540,7 +601,7 @@ public class RealTargetServiceImpl implements RealTargetService {
 	private float getUsrPowerDay(EminfoAndEmParamVo device) {
 		String time = DateUtil.format(new Date(),DateUtil.PATTERN_DATE);
 		// 当日用电量
-		return analyseDataService.periodTargetFloat(time + " 00:00:00",time + " 23:59:59",5,3,device.getEmCode(),device.getRideCount(),HomePageConstant.ELECTRICITY_CONSUMPTION);
+		return dataService.periodTargetFloat(time + " 00:00:00",time + " 23:59:59",5,3,device.getEmCode(),device.getRideCount(),HomePageConstant.ELECTRICITY_CONSUMPTION);
 
 	}
 
@@ -553,7 +614,7 @@ public class RealTargetServiceImpl implements RealTargetService {
 		String start = DateUtil.format(new Date(), "yyyy-MM") + "-01 00:00:00";
 		String end = DateUtil.format(new Date(), DateUtil.PATTERN_DATETIME);
 		// 当月用电量
-		return analyseDataService.periodTargetFloat(start,end,5,5,device.getEmCode(),device.getRideCount(),HomePageConstant.ELECTRICITY_CONSUMPTION);
+		return dataService.periodTargetFloat(start,end,5,5,device.getEmCode(),device.getRideCount(),HomePageConstant.ELECTRICITY_CONSUMPTION);
 	}
 
 	/**
@@ -569,7 +630,7 @@ public class RealTargetServiceImpl implements RealTargetService {
 		calendar.add(Calendar.DATE, -calendar.get(Calendar.DATE) + 1);
 		String start = DateUtil.format(calendar.getTime(),DateUtil.PATTERN_DATETIME);
 		// 当年用电量
-		return analyseDataService.periodTargetFloat(start,end,5,6,device.getEmCode(),device.getRideCount(),HomePageConstant.ELECTRICITY_CONSUMPTION);
+		return dataService.periodTargetFloat(start,end,5,6,device.getEmCode(),device.getRideCount(),HomePageConstant.ELECTRICITY_CONSUMPTION);
 	}
 
 	/**
@@ -580,7 +641,7 @@ public class RealTargetServiceImpl implements RealTargetService {
 	public List<ActivePowerVo> getActivePowerVoList(EminfoAndEmParamVo device) {
 		String startTime = DateUtil.format(new Date(), "yyyy-MM-dd 00:00:00");
 		String endTime = DateUtil.format(new Date(), "yyyy-MM-dd HH:mm:ss");
-		List<AnalyseDataTaosVO> datas = analyseDataService.periodTargetData(startTime,endTime,2,6,device.getEmCode(),HomePageConstant.ACTIVE_POWER);
+		List<AnalyseDataTaosVO> datas = dataService.periodTargetData(startTime,endTime,2,6,device.getEmCode(),HomePageConstant.ACTIVE_POWER);
 		if(CollectionUtil.isEmpty(datas)){
 			return new ArrayList<>();
 		}
@@ -607,7 +668,7 @@ public class RealTargetServiceImpl implements RealTargetService {
 		Calendar calendar = Calendar.getInstance();
 		calendar.add(Calendar.DAY_OF_MONTH,-29);
 		String end = DateUtil.format(calendar.getTime(),DateUtil.PATTERN_DATETIME);
-		List<AnalyseDataTaosVO>  records = analyseDataService.periodTargetData(start,end,5,EquipmentConstants.CycleTypeEnum.DAY_CYCLE.getType(),device.getEmCode(),HomePageConstant.ELECTRICITY_CONSUMPTION);
+		List<AnalyseDataTaosVO>  records = dataService.periodTargetData(start,end,5,EquipmentConstants.CycleTypeEnum.DAY_CYCLE.getType(),device.getEmCode(),HomePageConstant.ELECTRICITY_CONSUMPTION);
 		if(CollectionUtil.isEmpty(records)){
 			return new ArrayList<>();
 		}
@@ -637,7 +698,7 @@ public class RealTargetServiceImpl implements RealTargetService {
 		calendar.add(Calendar.MONTH, -calendar.get(Calendar.MONTH));
 		String start = DateUtil.format(calendar.getTime(),DateUtil.PATTERN_DATE) + " 00:00:00";
 		// 查询数据
-		List<AnalyseDataTaosVO> records = analyseDataService.periodTargetData(start,end,5,5,device.getEmCode(),HomePageConstant.ELECTRICITY_CONSUMPTION);
+		List<AnalyseDataTaosVO> records = dataService.periodTargetData(start,end,5,5,device.getEmCode(),HomePageConstant.ELECTRICITY_CONSUMPTION);
 		if(CollectionUtil.isEmpty(records)){
 			return new HashMap<>();
 		}
@@ -843,12 +904,12 @@ public class RealTargetServiceImpl implements RealTargetService {
 		List<String> signages = Collections.singletonList(signage);
 		realData.setSignages(signages);
 		// 调用fegin接口查询实时数据
-		R<List<FieldsData>> R = analyseDataSearchClient.getRealDataByAnalyzeCode(realData);
+		List<FieldsData> fields = dataService.getRealDataByAnalyzeCode(instanceCode,signages);
-		if(!R.isSuccess() || CollectionUtil.isEmpty(R.getData())){
+		if(CollectionUtil.isEmpty(fields)){
 			return 0.0;
 		}
 		// 时间限制
-		String time = R.getData().get(0).getTime();
+		String time = fields.get(0).getTime();
 		if(StringUtil.isEmpty(time) || "-".equals(time)){
 			return 0.0;
 		}
@@ -856,7 +917,7 @@ public class RealTargetServiceImpl implements RealTargetService {
 		if(System.currentTimeMillis() - date.getTime() > 30 * 60 * 1000L){
 			return 0.0;
 		}
-		return Double.parseDouble(R.getData().get(0).getValue());
+		return Double.parseDouble(fields.get(0).getValue());
 	}
 
 	/**
@@ -869,7 +930,7 @@ public class RealTargetServiceImpl implements RealTargetService {
 		String beginTime = DateUtil.format(new Date(), DateUtil.PATTERN_DATE)  +  " 00:00:00";
 		String endTime = DateUtil.format(new Date(), DateUtil.PATTERN_DATE);
 		AnalyseCodeByAnalyseDataPO po = new AnalyseCodeByAnalyseDataPO();
-		List<AnalyseDataTaosVO> datas = analyseDataService.periodTargetData(beginTime, endTime,2, 6,instanceCode,signage);
+		List<AnalyseDataTaosVO> datas = dataService.periodTargetData(beginTime, endTime,2, 6,instanceCode,signage);
 		if(CollectionUtil.isEmpty(datas)){
 			return new HashMap<>();
 		}
@@ -1027,7 +1088,7 @@ public class RealTargetServiceImpl implements RealTargetService {
 	private List<ActivePowerVo> getLoadsByDay(EminfoAndEmParamVo device) {
         String start = DateUtil.format(new Date(), DateUtil.PATTERN_DATE) + " 00:00:00";
         String end = DateUtil.format(new Date(), DateUtil.PATTERN_DATETIME);
-        List<AnalyseDataTaosVO> records = analyseDataService.periodTargetData(start, end, 3, 2, device.getEmCode(), HomePageConstant.PV_LOAD);
+        List<AnalyseDataTaosVO> records = dataService.periodTargetData(start, end, 3, 2, device.getEmCode(), HomePageConstant.PV_LOAD);
         if (CollectionUtil.isEmpty(records)) {
             return new ArrayList<>();
         }
@@ -1052,7 +1113,7 @@ public class RealTargetServiceImpl implements RealTargetService {
 		// 设备采集发电量
 		if(CollectionUtil.isNotEmpty(devices)){
 			devices.forEach(device->{
-				List<AnalyseDataTaosVO> records = analyseDataService.periodTargetData(start,end,5,5,device.getEmCode(),HomePageConstant.HYDROPOWER_GENERATE_POWER);
+				List<AnalyseDataTaosVO> records = dataService.periodTargetData(start,end,5,5,device.getEmCode(),HomePageConstant.HYDROPOWER_GENERATE_POWER);
 				if(CollectionUtil.isEmpty(records)){
 					return;
 				}
@@ -1260,7 +1321,7 @@ public class RealTargetServiceImpl implements RealTargetService {
 			default:
 				throw  new ServiceException("无效查询类型！");
 		}
-		return analyseDataService.periodTargetFloat(start, end, 5, cycleType, deviceCode, rideCount, HomePageConstant.PV_GENERATION_CAPACITY);
+		return dataService.periodTargetFloat(start, end, 5, cycleType, deviceCode, rideCount, HomePageConstant.PV_GENERATION_CAPACITY);
 	}
 
 	/**
@@ -1272,7 +1333,7 @@ public class RealTargetServiceImpl implements RealTargetService {
 	private List<PhotovoltaicPowerVo> photovoltaicLoadsByDay(EminfoAndEmParamVo device) {
 		String start = DateUtil.format(new Date(), DateUtil.PATTERN_DATE) + " 00:00:00";
 		String end = DateUtil.format(new Date(), DateUtil.PATTERN_DATETIME);
-		List<AnalyseDataTaosVO> records = analyseDataService.periodTargetData(start, end, 1, 2, device.getEmCode(), HomePageConstant.PV_LOAD);
+		List<AnalyseDataTaosVO> records = dataService.periodTargetData(start, end, 1, 2, device.getEmCode(), HomePageConstant.PV_LOAD);
 		if (CollectionUtil.isEmpty(records)) {
 			return new ArrayList<>();
 		}
@@ -1299,7 +1360,7 @@ public class RealTargetServiceImpl implements RealTargetService {
 		calendar.add(Calendar.MINUTE, -calendar.get(Calendar.MINUTE));
 		calendar.add(Calendar.SECOND, -calendar.get(Calendar.SECOND));
 		String start = DateUtil.format(calendar.getTime(), DateUtil.PATTERN_DATETIME);
-		List<AnalyseDataTaosVO> records = analyseDataService.periodTargetData(start, end, 5, 3, device.getEmCode(), HomePageConstant.PV_GENERATION_CAPACITY);
+		List<AnalyseDataTaosVO> records = dataService.periodTargetData(start, end, 5, 3, device.getEmCode(), HomePageConstant.PV_GENERATION_CAPACITY);
 		if (CollectionUtil.isEmpty(records)) {
 			return new ArrayList<>();
 		}
@@ -1350,6 +1411,13 @@ public class RealTargetServiceImpl implements RealTargetService {
 	}
 
 	/**
+	 * 计算切分次数
+	 */
+	private static Integer countStep(Integer size) {
+		return (size + 3 - 1) / 3;
+	}
+
+	/**
 	 * 泵站设备
 	 * @param stations
 	 * @return
@@ -1358,11 +1426,7 @@ public class RealTargetServiceImpl implements RealTargetService {
 		if(CollectionUtil.isEmpty(stations)){
 			return new ArrayList<>();
 		}
-		List<EminfoAndEmParamVo> devices = null;
+		List<EminfoAndEmParamVo> devices = JSONObject.parseObject(redisTemplate.opsForValue().get(device_cache_cofig_final).toString(),new TypeReference<List<EminfoAndEmParamVo>>() {});
-		Object json = redisTemplate.opsForValue().get(device_cache_cofig_final);
-		if (ObjectUtil.isNotEmpty(json)) {
-			devices = JSONObject.parseObject(json.toString(),new TypeReference<List<EminfoAndEmParamVo>>() {});
-		}
 		if(CollectionUtil.isEmpty(devices)){
 			return new ArrayList<>();
 		}
@@ -1484,7 +1548,7 @@ public class RealTargetServiceImpl implements RealTargetService {
 			default:
 				throw new IllegalStateException("Unexpected value: " + scope);
 		}
-		return analyseDataService.periodTargetFloat(start,end,5,accessRules,device.getEmCode(),device.getRideCount(),HomePageConstant.HYDROPOWER_GENERATE_POWER);
+		return dataService.periodTargetFloat(start,end,5,accessRules,device.getEmCode(),device.getRideCount(),HomePageConstant.HYDROPOWER_GENERATE_POWER);
 	}
 
 	/**
@@ -1495,7 +1559,7 @@ public class RealTargetServiceImpl implements RealTargetService {
 	private List<GenerationPowerVo> getGenerationPowerList(EminfoAndEmParamVo device) {
 		String start = DateUtil.format(new Date(), "yyyy-MM") + "-01 00:00:00";
 		String end = DateUtil.format(new Date(), DateUtil.PATTERN_DATETIME);
-        List<AnalyseDataTaosVO>  records = analyseDataService.periodTargetData(start,end,5,EquipmentConstants.CycleTypeEnum.DAY_CYCLE.getType(),device.getEmCode(),HomePageConstant.HYDROPOWER_GENERATE_POWER);
+        List<AnalyseDataTaosVO>  records = dataService.periodTargetData(start,end,5,EquipmentConstants.CycleTypeEnum.DAY_CYCLE.getType(),device.getEmCode(),HomePageConstant.HYDROPOWER_GENERATE_POWER);
 		if(CollectionUtil.isEmpty(records)){
 			return new ArrayList<>();
 		}

hzims-service/hzims-scheduled/src/main/java/com/hnac/hzims/scheduled/service/operation/impl/ShowServiceImpl.java

@@ -81,7 +81,7 @@ public class ShowServiceImpl implements ShowService {
     private final OverDetailsService detailsService;
     private final WorkTicketService workTicketService;
     private final PhenomenonService phenomenonService;
-    private final AnalyseDataService analyseDataService;
+    private final DataService dataService;
     private final MaintenanceService maintenanceService;
     private final RedisTemplate redisTemplate;
     private final ISysClient sysClient;
@@ -100,7 +100,7 @@ public class ShowServiceImpl implements ShowService {
     @Value("${hzims.equipment.emInfo.emInfoList}")
     public String device_cache_cofig_final;
 
-    @Value("${hzims.operation.region.areaDutyInfoKey}")
+        @Value("${hzims.operation.region.areaDutyInfoKey}")
     private String area_duty_cache_final;
 
     @Value("${hzims.operation.region.deviceClassifyKey}")
@@ -1138,7 +1138,7 @@ public class ShowServiceImpl implements ShowService {
             return generate;
         }
         for(EminfoAndEmParamVo device : devices ){
-            generate += analyseDataService.periodTargetFloat(DateUtil.format(start,DateUtil.PATTERN_DATETIME),DateUtil.format(end,DateUtil.PATTERN_DATETIME),5,3,device.getEmCode(),device.getRideCount(),HomePageConstant.HYDROPOWER_GENERATE_POWER);
+            generate += dataService.periodTargetFloat(DateUtil.format(start,DateUtil.PATTERN_DATETIME),DateUtil.format(end,DateUtil.PATTERN_DATETIME),5,3,device.getEmCode(),device.getRideCount(),HomePageConstant.HYDROPOWER_GENERATE_POWER);
         }
         return generate;
     }

hzims-service/hzims-scheduled/src/main/resources/mapper/equipment/DeviceMapper.xml

@@ -0,0 +1,19 @@
+<?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.hnac.hzims.scheduled.mapper.equipment.DeviceMapper">
+
+    <select id="device" resultType="com.hnac.hzims.equipment.vo.EminfoAndEmParamVo">
+        SELECT
+            ID AS id,
+            `NAME` AS NAME,
+            `NUMBER` AS emCode,
+            CREATE_DEPT AS createDept,
+            RUN_STATUS AS runStatus,
+            EM_INDEX AS ord
+        FROM
+            `hzims_em_info`
+        WHERE
+            IS_DELETED = 0
+          AND HOME_PAGE_DISPLAY = 1
+    </select>
+</mapper>

hzims-service/hzims-scheduled/src/main/resources/mapper/equipment/DeviceParamMapper.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.hnac.hzims.scheduled.mapper.equipment.DeviceParamMapper">
+
+    <select id="params" resultType="com.hnac.hzims.equipment.entity.EmParamEntity">
+        SELECT *
+        FROM hzims_em_param
+        WHERE `IS_DELETED` = 0
+        AND (
+            PARAM_NAME = 'ct'
+            OR PARAM_NAME = 'pt'
+            OR PARAM_NAME = 'installedCapacity'
+            )
+    </select>
+</mapper>

hzims-service/inspect/pom.xml

@@ -137,11 +137,6 @@
             <version>6.0.7</version>
         </dependency>
         <dependency>
-            <groupId>org.springblade</groupId>
-            <artifactId>blade-starter-oss-minio</artifactId>
-            <version>2.7.3.RELEASE</version>
-        </dependency>
-        <dependency>
             <groupId>com.hnac.hzims</groupId>
             <artifactId>message-api</artifactId>
             <version>${hzims.project.version}</version>

hzims-service/operational/src/main/java/com/hnac/hzims/operational/config/scheduled/StAlamRecordTask.java

@@ -53,10 +53,9 @@ public class StAlamRecordTask {
 	 * realId获取
 	 * @return ReturnT<String>
 	 */
-	//@XxlJob(REAL_ID_DATA)
+	@XxlJob(REAL_ID_DATA)
-	@Scheduled(cron = "0/40 * * * * ? ")
+	//@Scheduled(cron = "0/40 * * * * ? ")
-	public ReturnT<String> realIdData() throws Exception {
+	public ReturnT<String> realIdData(String param) throws Exception {
-		String param = "";
 		if (Func.isBlank(param)) {
 			param = DateUtil.format(new Date(), "yyyy-MM");
 		}
@@ -68,10 +67,9 @@ public class StAlamRecordTask {
 	 * 站点实时数据
 	 * @return ReturnT<String>
 	 */
-	//@XxlJob(REAL_TIME_DATA)
+	@XxlJob(REAL_TIME_DATA)
-	@Scheduled(cron = "0/40 * * * * ? ")
+	//@Scheduled(cron = "0/40 * * * * ? ")
-	public ReturnT<String> realTimeData() throws Exception {
+	public ReturnT<String> realTimeData(String param) throws Exception {
-		String param = "";
 		if (Func.isBlank(param)) {
 			param = DateUtil.format(new Date(), "yyyy-MM");
 		}

hzims-service/operational/src/main/java/com/hnac/hzims/operational/main/scheduled/ScheduledCreateTask.java

@@ -280,9 +280,10 @@ public class ScheduledCreateTask {
 	 * 水电站-机组实时加载
 	 * @return ReturnT<String>
 	 */
-	@XxlJob(LOAD_HYDROPOWER_UNIT_REAL)
+	//@XxlJob(LOAD_HYDROPOWER_UNIT_REAL)
-	//@Scheduled(cron = "0/40 * * * * ? ")
+	@Scheduled(cron = "0/40 * * * * ? ")
-	public ReturnT<String> loadHydropowerUnitReal(String param) throws Exception {
+	public ReturnT<String> loadHydropowerUnitReal() throws Exception {
+		String param = "";
 		if (Func.isBlank(param)) {
 			param = DateUtil.format(new Date(), "yyyy-MM");
 		}