#定时任务抽离

hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/ecology/entity/EcologyFlowStationEntity.java

@@ -19,6 +19,8 @@ public class EcologyFlowStationEntity extends TenantEntity {
 
     private String stationName;
 
+    private String city;
+
     private Long isOnLine;
 
     private Long isDemonstrate;

hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/main/vo/AppHydropowerDeviceVo.java

@@ -2,6 +2,7 @@ package com.hnac.hzims.operational.main.vo;
 
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
+import io.swagger.models.auth.In;
 import lombok.Data;
 
 /**
@@ -28,4 +29,7 @@ public class AppHydropowerDeviceVo {
 
 	@ApiModelProperty(value = "负荷单位")
 	private String loadUnit;
+
+	@ApiModelProperty(value = "排序")
+	private Integer ord;
 }

hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/main/vo/HydropowerUnitRealVo.java

@@ -61,4 +61,7 @@ public class HydropowerUnitRealVo {
 
 	@ApiModelProperty(value = "电流单位")
 	private String currentUnit;
+
+	@ApiModelProperty(value = "排序")
+	private Integer ord;
 }

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

@@ -1186,7 +1186,7 @@ public class RealTargetServiceImpl implements RealTargetService {
 	 */
 	private int getPhotovoltaicState(EminfoAndEmParamVo device, Map<String, String> map) {
 		// 获取开关机监测点实时数据
-		Double value = this.getSignageValue(device, map, HomePageConstant.PV_JOINT_RELAY);
+		double value = this.getSignageValue(device, map, HomePageConstant.PV_JOINT_RELAY);
 		// 开机状态
 		if (Math.abs(value) <= 0) {
 			return 0;

hzims-service/operational/src/main/java/com/hnac/hzims/operational/ecology/controller/EcologyController.java

@@ -51,11 +51,11 @@ public class EcologyController extends BladeController {
      * 站点数据排行
      * @return
      */
-        @PostMapping("/station_top")
+    @PostMapping("/station_top")
     @ApiOperationSupport(order = 1)
     @ApiOperation(value = "站点数据及达标率排行", notes = "站点数据及达标率排行")
-    public R station_top() {
-        return R.data(stationService.station_top());
+    public R station_top(@RequestParam String city) {
+        return R.data(stationService.station_top(city));
     }
 
     /**
@@ -65,8 +65,8 @@ public class EcologyController extends BladeController {
     @PostMapping("/trend_chart")
     @ApiOperationSupport(order = 1)
     @ApiOperation(value = "指标趋势图", notes = "指标趋势图")
-    public R trend_chart(@RequestParam String type) {
-        return R.data(stationService.trend_chart(type));
+    public R trend_chart(@RequestParam String city,@RequestParam String type) {
+        return R.data(stationService.trend_chart(city,type));
     }
 
 

hzims-service/operational/src/main/java/com/hnac/hzims/operational/ecology/service/EcologyFlowStationService.java

@@ -14,12 +14,12 @@ import java.util.List;
  */
 public interface EcologyFlowStationService extends BaseService<EcologyFlowStationEntity> {
 
-    EcologFlowStationVo station_top();
+    EcologFlowStationVo station_top(String city);
 
 
     Boolean generate(Long mon,String year);
 
-    List<TrendChartVo> trend_chart(String type);
+    List<TrendChartVo> trend_chart(String city,String type);
 
     List<StationVo> station();
 }

hzims-service/operational/src/main/java/com/hnac/hzims/operational/ecology/service/impl/EcologyFlowStationServiceImpl.java

@@ -98,8 +98,9 @@ public class EcologyFlowStationServiceImpl extends BaseServiceImpl<EcologyFlowSt
      * @return
      */
     @Override
-    public EcologFlowStationVo station_top() {
-        List<EcologyFlowStationEntity> stations = this.list();
+    public EcologFlowStationVo station_top(String city) {
+        List<EcologyFlowStationEntity> stations = this.list(Wrappers.<EcologyFlowStationEntity>lambdaQuery()
+                .eq(EcologyFlowStationEntity::getCity,city));
         if(CollectionUtil.isEmpty(stations)){
             return new EcologFlowStationVo();
         }
@@ -110,8 +111,9 @@ public class EcologyFlowStationServiceImpl extends BaseServiceImpl<EcologyFlowSt
         station.setTimely(BigDecimal.valueOf((int) stations.stream().filter(o -> o.getIsTimely().equals(1L)).count() / (double) stations.size() * 100).setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue());
         station.setCount(stations.size());
 
-        List<EcologyFlowDataEntity> datas = dataService.list(Wrappers.<EcologyFlowDataEntity>lambdaQuery().
-                like(EcologyFlowDataEntity::getMon, DateUtil.format(new Date(),"yyyy-MM")));
+        List<EcologyFlowDataEntity> datas = dataService.list(Wrappers.<EcologyFlowDataEntity>lambdaQuery()
+                .like(EcologyFlowDataEntity::getMon, DateUtil.format(new Date(),"yyyy-MM"))
+                .in(EcologyFlowDataEntity::getStationId,stations.stream().map(EcologyFlowStationEntity::getStationId).collect(Collectors.toList())));
         if(CollectionUtil.isEmpty(datas)){
             return station;
         }
@@ -132,8 +134,14 @@ public class EcologyFlowStationServiceImpl extends BaseServiceImpl<EcologyFlowSt
      * @return
      */
     @Override
-    public List<TrendChartVo> trend_chart(String type) {
+    public List<TrendChartVo> trend_chart(String city,String type) {
+        List<EcologyFlowStationEntity> stations = this.list(Wrappers.<EcologyFlowStationEntity>lambdaQuery()
+                .eq(EcologyFlowStationEntity::getCity,city));
+        if(CollectionUtil.isEmpty(stations)){
+            return new ArrayList<>();
+        }
         LambdaQueryWrapper<EcologyFlowDataEntity> wrapper = new LambdaQueryWrapper<>();
+        wrapper.in(EcologyFlowDataEntity::getStationId,stations.stream().map(EcologyFlowStationEntity::getStationId).collect(Collectors.toList()));
         if("0".equals(type)){
             wrapper.like(EcologyFlowDataEntity::getMon, DateUtil.format(new Date(),"yyyy"));
         }
@@ -179,7 +187,7 @@ public class EcologyFlowStationServiceImpl extends BaseServiceImpl<EcologyFlowSt
     @Override
     public List<StationVo> station() {
         List<StationEntity> stations = stationService.list(Wrappers.<StationEntity>lambdaQuery()
-                .in(StationEntity::getCode,Arrays.asList("902400000054","902400052664")));
+                .in(StationEntity::getCode,Arrays.asList("902400000054","902400052664","902400056791")));
         if(CollectionUtil.isEmpty(stations)){
             return new ArrayList<>();
         }

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

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

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

@@ -246,7 +246,7 @@ public class HomeServiceImpl implements HomeService {
 		double plan = list.stream().mapToDouble(PowerEntity::getPlannedPowerMon).sum();
 		double pass = list.stream().mapToDouble(power -> Double.parseDouble(power.getDoubleQualifyRate())).sum();
 		// 装机容量
-		target.setTaget_one(list.stream().map(PowerEntity::getInstalledCapacity).collect(Collectors.toSet()).stream().mapToDouble(Double::valueOf).sum());
+		target.setTaget_one(list.get(0).getInstalledCapacity());
 		// 发电量
 		target.setTaget_two(list.stream().mapToDouble(PowerEntity::getPowerMon).sum());
 		if(Math.abs(plan) > 0){
@@ -254,7 +254,7 @@ public class HomeServiceImpl implements HomeService {
 			target.setTaget_three(BigDecimal.valueOf(target.getTaget_two() / plan * 100).setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue());
 		}
 		// 双票合格率
-		target.setTaget_four(BigDecimal.valueOf(pass / list.size()).setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue());
+		target.setTaget_four(BigDecimal.valueOf(pass / list.size() * 100).setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue());
 		return target;
 	}
 

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

@@ -153,6 +153,7 @@ public class HydropowerServiceImpl implements HydropowerService {
 			HydropowerUnitRealVo real = new HydropowerUnitRealVo();
 			real.setDeptId(device.getCreateDept());
 			real.setDeviceCode(device.getEmCode());
+			real.setOrd(device.getOrd());
 			real.setDeptName(device.getName());
 			real.setDeviceName(device.getName());
 			// 装机容量
@@ -1548,12 +1549,13 @@ public class HydropowerServiceImpl implements HydropowerService {
 					AppHydropowerDeviceVo device = new AppHydropowerDeviceVo();
 					device.setDeviceCode(real.getDeviceCode());
 					device.setDeviceName(real.getDeviceName());
+					device.setOrd(real.getOrd());
 					device.setState(real.getState());
 					device.setLoadUnit(Optional.ofNullable(real.getPowerUnit()).orElse("kW"));
 					device.setCapacity(real.getInstalledCapacity());
 					device.setLoad(real.getActivePower());
 					return device;
-				}).collect(Collectors.toList()));
+				}).sorted(Comparator.comparing(AppHydropowerDeviceVo::getOrd)).collect(Collectors.toList()));
 				hydropower.setLoadUnit(hydropower.getDevices().get(0).getLoadUnit());
 			}
 			return hydropower;