#演示平台接口

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

@@ -29,10 +29,9 @@ public class MonitorScheduledTask {
     /**
      * realId刷新
      */
-    //@XxlJob(REAL_ID_DATA)
+    @XxlJob(REAL_ID_DATA)
-    @Scheduled(cron = "0/40 * * * * ? ")
+    //@Scheduled(cron = "0/40 * * * * ? ")
-    public ReturnT<String> loadRealId() {
+    public ReturnT<String> loadRealId(String param) {
-        String param = "";
         if (Func.isBlank(param)) {
             param = DateUtil.format(new Date(), "yyyy-MM");
         }
@@ -44,10 +43,9 @@ public class MonitorScheduledTask {
      * 实时数据刷新
      * @return ReturnT<String>
      */
-    //@XxlJob(REAL_TIME_DATA)
+    @XxlJob(REAL_TIME_DATA)
-    @Scheduled(cron = "0/40 * * * * ? ")
+    //@Scheduled(cron = "0/40 * * * * ? ")
-    public ReturnT<String> loadRealData() {
+    public ReturnT<String> loadRealData(String param) {
-        String param = "";
         if (Func.isBlank(param)) {
             param = DateUtil.format(new Date(), "yyyy-MM");
         }
@@ -59,10 +57,9 @@ public class MonitorScheduledTask {
      * 集中监控数据处理
      * @return ReturnT<String>
      */
-    //@XxlJob(CENTRALIZED_MONITORING)
+    @XxlJob(CENTRALIZED_MONITORING)
-    @Scheduled(cron = "0/40 * * * * ? ")
+    //@Scheduled(cron = "0/40 * * * * ? ")
-    public ReturnT<String> loadMonitoring() {
+    public ReturnT<String> loadMonitoring(String param) {
-        String param = "";
         if (Func.isBlank(param)) {
             param = DateUtil.format(new Date(), "yyyy-MM");
         }

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

@@ -33,10 +33,9 @@ public class RealTargetScheduledTask {
      * @return
      * @throws Exception
      */
-    //@XxlJob(LOAD_EM_INFO)
+    @XxlJob(LOAD_EM_INFO)
-    @Scheduled(cron = "0/40 * * * * ? ")
+    //@Scheduled(cron = "0/40 * * * * ? ")
-    public ReturnT<String> loadEmInfo() {
+    public ReturnT<String> loadEmInfo(String param) {
-        String param = "";
         if (Func.isBlank(param)) {
             param = DateUtil.format(new Date(), "yyyy-MM");
         }
@@ -61,6 +60,7 @@ public class RealTargetScheduledTask {
      * 水电站-机组指标加载
      */
     @XxlJob(LOAD_HYDROPOWER_UNIT_TARGET)
+    //@Scheduled(cron = "0/40 * * * * ? ")
     public ReturnT<String> loadHydropowerTarget(String param) {
         if (Func.isBlank(param)) {
             param = DateUtil.format(new Date(), "yyyy-MM");
@@ -98,6 +98,7 @@ public class RealTargetScheduledTask {
      * 水利-站点水位数据
      */
     @XxlJob(LOAD_WATER_LEVEL)
+    //@Scheduled(cron = "0/40 * * * * ? ")
     public ReturnT<String> loadWaterLevel(String param) {
         if (Func.isBlank(param)) {
             param = DateUtil.format(new Date(), "yyyy-MM");

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

@@ -77,10 +77,9 @@ public class ReportScheduledTask {
      * 站点运行月报
      * @return ReturnT<String>
      */
-    //@XxlJob(RUM_MONTH_REPORT)
+    @XxlJob(RUM_MONTH_REPORT)
-    @Scheduled(cron = "0/40 * * * * ? ")
+    // @Scheduled(cron = "0/40 * * * * ? ")
-    public ReturnT<String> runMonthReport() {
+    public ReturnT<String> runMonthReport(String param) {
-        String param = "";
         if (Func.isBlank(param)) {
             param = DateUtil.format(new Date(), DateUtil.PATTERN_DATETIME);
         }

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

@@ -184,6 +184,7 @@ public class RealTargetServiceImpl implements RealTargetService {
 		// 水电站站点
 		List<StationEntity> stations = stationService.list(Wrappers.<StationEntity>lambdaQuery()
 				.eq(StationEntity::getType,HomePageConstant.HYDROPOWER)
+				.eq(StationEntity::getDataOrigin,"0")
 		);
 		if(CollectionUtil.isEmpty(stations)){
 			return;
@@ -241,8 +242,8 @@ public class RealTargetServiceImpl implements RealTargetService {
 	public void loadHydropowerTarget(String param) {
 		// 水电站站点
 		List<StationEntity> stations = stationService.list(Wrappers.<StationEntity>lambdaQuery()
-				//.eq(StationEntity::getServeType,HomePageConstant.HYDROPOWER_SERVETYPE)
 				.eq(StationEntity::getType,HomePageConstant.HYDROPOWER)
+				.eq(StationEntity::getDataOrigin,"0")
 		);
 		if(CollectionUtil.isEmpty(stations)){
 			return;
@@ -1076,6 +1077,7 @@ public class RealTargetServiceImpl implements RealTargetService {
 	public void loadPowerData(String param, List<Integer> types, Integer serveType, int year) {
 		// 站点查询
 		List<StationEntity> stationList = stationService.list(new LambdaQueryWrapper<StationEntity>() {{
+			eq(StationEntity::getDataOrigin,"0");
 			if (ObjectUtil.isNotEmpty(serveType)) {
 				eq(StationEntity::getServeType, serveType);
 			}

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

@@ -104,7 +104,9 @@ public class MonitorServiceImpl implements MonitorService {
     @Override
     public void loadRealId(String param) {
         // 所有站点
-        List<StationEntity> stationList = stationService.list();
+        List<StationEntity> stationList = stationService.list(Wrappers.<StationEntity>lambdaQuery()
+                .eq(StationEntity::getDataOrigin,"0")
+        );
         if(CollectionUtil.isEmpty(stationList)){
             return;
         }

hzims-service/operational/src/main/java/com/hnac/hzims/operational/data/controller/HzimsDataController.java

@@ -8,9 +8,10 @@ import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springblade.core.log.annotation.ApiLog;
 import org.springblade.core.tool.api.R;
-import org.springframework.web.bind.annotation.*;
+import org.springframework.web.bind.annotation.GetMapping;
-
+import org.springframework.web.bind.annotation.RequestMapping;
-import java.util.Map;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
 
 
 /**
@@ -47,15 +48,11 @@ public class HzimsDataController {
 		return R.data(service.saveStation());
 	}
 
-	/**
-	 * 测试动作模板回调接口
-	 */
 	@ApiLog
-	@PostMapping("/test")
+	@GetMapping("/station")
 	@ApiOperationSupport(order = 1)
-	@ApiOperation(value = "测试动作模板回调接口", notes = "map接收参数")
+	@ApiOperation(value = "站点数据获取", notes = "传入站点code")
-	public R test(@RequestBody Map<String, Object> params) {
+	public R station(@RequestParam("stationCode") String stationCode) {
-		log.error("动作模板回调接口参数: {}",params.toString());
+		return R.data(service.station(stationCode));
-		return R.data(params);
 	}
 }

hzims-service/operational/src/main/java/com/hnac/hzims/operational/data/service/HzimsDataService.java

@@ -1,5 +1,7 @@
 package com.hnac.hzims.operational.data.service;
 
+import com.hnac.hzims.operational.main.vo.HydropowerStationVo;
+
 import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletResponse;
 import java.io.IOException;
@@ -16,4 +18,6 @@ public interface HzimsDataService {
 	boolean saveArea();
 
 	boolean saveStation();
+
+	HydropowerStationVo station(String stationCode);
 }

hzims-service/operational/src/main/java/com/hnac/hzims/operational/data/service/impl/HzimsDataServiceImpl.java

@@ -1,12 +1,16 @@
 package com.hnac.hzims.operational.data.service.impl;
 
 import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.hnac.hzims.equipment.entity.PlanGenerationEntity;
+import com.hnac.hzims.equipment.feign.IPlanGenertionClient;
 import com.hnac.hzims.equipment.vo.EminfoAndEmParamVo;
 import com.hnac.hzims.operational.data.service.HzimsDataService;
 import com.hnac.hzims.operational.data.vo.AreaVo;
+import com.hnac.hzims.operational.main.constant.HomePageConstant;
 import com.hnac.hzims.operational.main.service.AreaService;
 import com.hnac.hzims.operational.main.service.IMainSystemMonitoringService;
-import com.hnac.hzims.operational.main.constant.HomePageConstant;
+import com.hnac.hzims.operational.main.vo.*;
 import com.hnac.hzims.operational.station.entity.StationEntity;
 import com.hnac.hzims.operational.station.service.IStationService;
 import com.hnac.hzims.operational.station.vo.HzimsStationCountVo;
@@ -16,19 +20,26 @@ import org.apache.commons.collections4.MapUtils;
 import org.springblade.core.log.exception.ServiceException;
 import org.springblade.core.tool.api.R;
 import org.springblade.core.tool.utils.CollectionUtil;
+import org.springblade.core.tool.utils.DateUtil;
+import org.springblade.core.tool.utils.ObjectUtil;
+import org.springblade.core.tool.utils.StringUtil;
 import org.springblade.system.entity.Dept;
 import org.springblade.system.feign.ISysClient;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.stereotype.Service;
 
-import javax.validation.constraints.NotNull;
 import java.io.InputStream;
 import java.io.OutputStream;
+import java.math.BigDecimal;
+import java.math.RoundingMode;
 import java.net.HttpURLConnection;
 import java.net.URL;
-import java.util.Arrays;
+import java.time.Duration;
-import java.util.List;
+import java.time.LocalDate;
-import java.util.Map;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import java.util.*;
 import java.util.stream.Collectors;
 
 
@@ -40,20 +51,33 @@ import java.util.stream.Collectors;
 @RequiredArgsConstructor
 public class HzimsDataServiceImpl implements HzimsDataService {
 
-	@NotNull
 	private final AreaService areaService;
-	@NotNull
+
 	private final IMainSystemMonitoringService emService;
-	@NotNull
+
-	private final ISysClient sysClient;
-	@NotNull
 	private final IStationService stationService;
 
+	private final IMainSystemMonitoringService maintenanceTaskService;
+
+	private final ISysClient sysClient;
+
+	private final IPlanGenertionClient planGenertionClient;
+
+	private final RedisTemplate redisTemplate;
+
 	@Value("${hzims.operation.save.area.url}")
 	public String AREA_URL;
 	@Value("${hzims.operation.save.station.url}")
 	public String STATION_URL;
 
+	private final static String recent_year_power_data = "hzims:operation:key:power:data";
+
+	private final static String loadwater_level_key = "hzims:operation:loadwater:level:key";
+
+	private final static String load_hydropower_unit_real_key = "hzims:operation:loadhydropowerunit:real:key";
+
+	private final static String load_hydropower_unit_target_key = "hzims:operation:loadhydropowerunit:target:key";
+
 	@Override
 	public boolean saveArea() {
 		R<List<Dept>> result = sysClient.getDeptList();
@@ -103,6 +127,7 @@ public class HzimsDataServiceImpl implements HzimsDataService {
 		return this.sendMessage(JSONObject.toJSONBytes(list),STATION_URL);
 	}
 
+
 	/**
 	 * 发送请求
 	 * @param params
@@ -135,4 +160,256 @@ public class HzimsDataServiceImpl implements HzimsDataService {
 		}
 		return true;
 	}
+
+	/**
+	 * 水电站-站点信息
+	 * @param stationCode
+	 * @return
+	 */
+	@Override
+	public HydropowerStationVo station(String stationCode) {
+		if(StringUtil.isEmpty(stationCode)){
+			return new HydropowerStationVo();
+		}
+		// 站点
+		StationEntity station = stationService.getOne(Wrappers.<StationEntity>lambdaQuery()
+				.eq(StationEntity::getCode,stationCode)
+				.eq(StationEntity::getDataOrigin,"0")
+				.eq(StationEntity::getServeType,HomePageConstant.HYDROPOWER_SERVETYPE)
+				.eq(StationEntity::getType,HomePageConstant.HYDROPOWER)
+		);
+		if(ObjectUtil.isEmpty(station)){
+			return new HydropowerStationVo();
+		}
+		// 实时监测点数据
+		List<HydropowerUnitRealVo> realList = (List<HydropowerUnitRealVo>) redisTemplate.opsForValue().get(load_hydropower_unit_real_key);
+		// 获取站点机组指标数据
+		List<HydropowerUnitTargetVo> targetList = (List<HydropowerUnitTargetVo>) redisTemplate.opsForValue().get(load_hydropower_unit_target_key);
+		// 所有设备
+		List<EminfoAndEmParamVo> deviceList = maintenanceTaskService.getEmInfoList();
+		HydropowerStationVo response = new HydropowerStationVo();
+		// 近年发电量数据
+		Map<Long, Map<String, Float>> map = (Map<Long, Map<String, Float>>) redisTemplate.opsForValue().get(recent_year_power_data);
+		response.setDeptId(station.getRefDept());
+		response.setDeptName(station.getName());
+		response.setStationCode(station.getCode());
+		// 限制水位
+		response.setLimitWaterLevel(station.getLimitWaterLevel());
+		// 运行天数
+		response.setRunDay(this.getRunDay(station));
+		// 装机容量
+		response.setInstalledCapacity(this.getInstalledCapacity(deviceList,station.getRefDept()));
+		// 总有功功率(总发电负荷)
+		response.setPowerSum(this.getPowerSum(realList,station.getRefDept()));
+		// 总有功单位
+		response.setPowerUnit("kW");
+		// 月计划发电量
+		response.setPlanPowerMon(this.getPlanPowerrMon(station.getCode()));
+		// 年计划发电量
+		response.setPlanPowerYear(this.getPlanPowerYear(station.getCode()));
+		// 月发电量、年发电量、年发电完成率
+		this.handleStationInfo(station.getRefDept(),response);
+		// 水位、水位曲线
+		this.handleWaterLeve(station.getCode(),response);
+		// 年发电量完成百分比
+		response.setPowerYearMap(this.handlePowerFinish(Collections.singletonList(station),map));
+		return response;
+	}
+
+	/**
+	 * 获取站点运行天数
+	 * @param station
+	 * @return
+	 */
+	private int getRunDay(StationEntity station) {
+		if (ObjectUtil.isEmpty(station.getCommissionTime())) {
+			return 0;
+		}
+		// 计算投运时间与当前时间相隔天数
+		Duration dur = Duration.between(station.getCommissionTime(), LocalDateTime.now());
+		return (int) dur.toDays();
+	}
+
+	/**
+	 * 获取设备装机容量
+	 * @param list
+	 * @param refDept
+	 * @return
+	 */
+	private double getInstalledCapacity(List<EminfoAndEmParamVo> list, Long refDept) {
+		if(CollectionUtil.isEmpty(list) || ObjectUtil.isEmpty(refDept)){
+			return 0.0;
+		}
+		return list.stream().filter(o -> refDept.equals(o.getCreateDept())).mapToDouble(EminfoAndEmParamVo::getInstalledCapacity).sum();
+	}
+
+
+	/**
+	 * 获取总发电负荷
+	 * @param deptId
+	 * @return
+	 */
+	private Double getPowerSum(List<HydropowerUnitRealVo> realList,Long deptId) {
+		if(ObjectUtil.isEmpty(deptId)){
+			return 0.0;
+		}
+		// 获取站点机组实时数据
+		if(CollectionUtil.isEmpty(realList)){
+			return 0.0;
+		}
+		return realList.stream().filter(o->deptId.equals(o.getDeptId())).mapToDouble(o->{
+			if("MW".equalsIgnoreCase(o.getPowerUnit())){
+				return o.getActivePower() * 1000;
+			}
+			return o.getActivePower();
+		}).sum();
+	}
+
+	/**
+	 * 获取月计划发电量
+	 * @param code
+	 * @return
+	 */
+	private float getPlanPowerrMon(String code) {
+		R<Float> R = planGenertionClient.planGenerationMonthCount(code, DateUtil.format(new Date(), "yyyy-MM"));
+		if(!R.isSuccess() || ObjectUtil.isEmpty(R.getData())){
+			return 0f;
+		}
+		return R.getData();
+	}
+
+	/**
+	 * 获取年计划发电量
+	 * @param code
+	 * @return
+	 */
+	private float getPlanPowerYear(String code) {
+		R<Float> R = planGenertionClient.planGenerationYearCount(code);
+		if(!R.isSuccess() || ObjectUtil.isEmpty(R.getData())){
+			return 0f;
+		}
+		// 查询年计划发电量
+		return R.getData();
+	}
+
+	/**
+	 * 站点信息处理
+	 * @param deptId
+	 * @param response
+	 */
+	private void handleStationInfo(Long deptId, HydropowerStationVo response) {
+		response.setPowerMon(0f);
+		response.setPowerYear(0f);
+		response.setPowerRateYear(0.0);
+		List<HydropowerUnitTargetVo> targetList = (List<HydropowerUnitTargetVo>) redisTemplate.opsForValue().get(load_hydropower_unit_target_key);
+		if(CollectionUtil.isEmpty(targetList)){
+			return;
+		}
+		// 月发电量
+		float powerMont = (float) targetList.stream().filter(o-> deptId.equals(o.getDeptId())).mapToDouble(HydropowerUnitTargetVo::getPowerMon).sum();
+		response.setPowerMon(powerMont);
+		// 年发电量
+		float powerYear = (float) targetList.stream().filter(o-> deptId.equals(o.getDeptId())).mapToDouble(HydropowerUnitTargetVo::getPowerYear).sum();
+		response.setPowerYear(powerYear);
+		// 年发电完成率
+		float planPowerYear = response.getPlanPowerYear();
+		if(Math.abs(planPowerYear) <= 0){
+			response.setPowerRateYear(0.0);
+		} else {
+			double powerRateYear = BigDecimal.valueOf(powerYear / planPowerYear * 100).setScale(2, RoundingMode.HALF_UP).doubleValue();
+			response.setPowerRateYear(powerRateYear);
+		}
+	}
+
+	/**
+	 * 站点水位数据处理
+	 * @param code
+	 * @param response
+	 */
+	private void handleWaterLeve(String code, HydropowerStationVo response) {
+		response.setFrontWaterLevel(0.0);
+		List<WaterLevelVo> levelList = (List<WaterLevelVo>) redisTemplate.opsForValue().get(loadwater_level_key);
+		if(CollectionUtil.isEmpty(levelList)){
+			return;
+		}
+		List<WaterLevelVo> validList = levelList.stream().filter(o-> code.equals(o.getStationCode())).collect(Collectors.toList());
+		if(CollectionUtil.isEmpty(validList)){
+			return;
+		}
+		WaterLevelVo level = validList.get(0);
+		// 前池水位、当日水位曲线
+		response.setFrontWaterLevel(level.getFrontWaterLevel());
+		response.setFrontCurveMap(level.getFrontCurveMap());
+	}
+
+	/**
+	 * 年发电量完成百分比
+	 * @param stations
+	 */
+	private List<PowerMonthVo> handlePowerFinish(List<StationEntity> stations, Map<Long, Map<String, Float>> map) {
+		if (CollectionUtil.isEmpty(stations)) {
+			return null;
+		}
+		// 查询计划发电量
+		Calendar calendar = Calendar.getInstance();
+		calendar.setTime(new Date());
+		List<PlanGenerationEntity> plans = planGenertionClient.getPlanGenerationByParam(stations.stream().map(StationEntity::getCode).collect(Collectors.toList()), null, String.valueOf(calendar.get(Calendar.YEAR)));
+		// 获取月份集合
+		List<String> monList = this.mons(0, 12, false);
+		return monList.stream().map(o -> {
+			PowerMonthVo vo = new PowerMonthVo();
+			LocalDate localDate = LocalDate.parse(DateUtil.format(new Date(), o), DateTimeFormatter.ofPattern(DateUtil.PATTERN_DATE));
+			vo.setStrMonth(o);
+			vo.setYear(localDate.getYear());
+			vo.setMonth(localDate.getMonthValue());
+			// 实际发电量
+			if (CollectionUtil.isEmpty(map)) {
+				vo.setPower(0f);
+			} else {
+				float generate = (float) map.entrySet().stream().
+						filter(entry -> stations.stream().map(StationEntity::getId).collect(Collectors.toList()).contains(entry.getKey())).
+						mapToDouble(valueMap -> valueMap.getValue().entrySet().stream().filter(entry -> entry.getKey().equals(o))
+								.mapToDouble(Map.Entry::getValue).sum()).sum();
+				vo.setPower(generate);
+			}
+			// 计划发电量
+			if (CollectionUtil.isEmpty(plans)) {
+				vo.setPlanPower(0f);
+			} else {
+				String mon = localDate.format(DateTimeFormatter.ofPattern("yyyy-MM"));
+				vo.setPlanPower((float) plans.stream().filter(plan -> mon.equals(plan.getDateTime())).mapToDouble(PlanGenerationEntity::getPlanGeneration).sum());
+			}
+			return vo;
+		}).collect(Collectors.toList());
+	}
+
+	/**
+	 * 获取近年月份集合
+	 * @param year
+	 * @return
+	 */
+	public List<String> mons(int year, int endMoth, boolean nextMon) {
+		List<String> list = new ArrayList<>();
+		// 开始日期
+		Calendar endCal = Calendar.getInstance();
+		endCal.setTime(new Date());
+		endCal.add(Calendar.MONTH, -endCal.get(Calendar.MONTH) + endMoth);
+		endCal.add(Calendar.DATE, -endCal.get(Calendar.DATE) + 1);
+
+		// 结束日期
+		Calendar startCal = Calendar.getInstance();
+		startCal.setTime(new Date());
+		startCal.set(Calendar.YEAR, startCal.get(Calendar.YEAR) - year);
+		startCal.add(Calendar.MONTH, -startCal.get(Calendar.MONTH));
+		startCal.add(Calendar.DATE, -startCal.get(Calendar.DATE) + 1);
+		// 获取日期之间的月份
+		while (endCal.after(startCal)) {
+			list.add(DateUtil.format(startCal.getTime(),DateUtil.PATTERN_DATE));
+			startCal.add(Calendar.MONTH, 1);
+		}
+		if(nextMon){
+			list.add(DateUtil.format(endCal.getTime(),DateUtil.PATTERN_DATE));
+		}
+		return list;
+	}
 }