Merge remote-tracking branch 'origin/master'

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

@@ -264,7 +264,7 @@ public class RealTargetServiceImpl implements RealTargetService {
 		// 水电站站点
 		List<StationEntity> stations = stationService.list(Wrappers.<StationEntity>lambdaQuery()
 				.eq(StationEntity::getType,HomePageConstant.HYDROPOWER)
-				.eq(StationEntity::getDataOrigin,"0")
+				.eq(StationEntity::getServeType,HomePageConstant.HYDROPOWER_SERVETYPE)
 		);
 		if(CollectionUtil.isEmpty(stations)){
 			return;
@@ -1223,7 +1223,6 @@ public class RealTargetServiceImpl implements RealTargetService {
 		log.info("近年发电量接口耗时测试开始=======================");
 		// 站点查询
 		List<StationEntity> stationList = stationService.list(new LambdaQueryWrapper<StationEntity>() {{
-			eq(StationEntity::getDataOrigin,"0");
 			if (ObjectUtil.isNotEmpty(serveType)) {
 				eq(StationEntity::getServeType, serveType);
 			}

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

@@ -216,7 +216,6 @@ public class RealMonitorServiceImpl implements IRealMonitorService {
 	@Override
 	public TextMessage getSendMessage(MessageParamVo message) {
 		long beginTime = System.currentTimeMillis();
-		Thread thread = Thread.currentThread();
 		// 权限机构过滤
 		if(ObjectUtil.isEmpty(message) || CollectionUtil.isEmpty(message.getDeptIds())){
 			return null;
@@ -226,7 +225,7 @@ public class RealMonitorServiceImpl implements IRealMonitorService {
 		if(CollectionUtil.isEmpty(realStationVoList)){
 			return null;
 		}
-		log.info(thread.getName() + "步骤1获取所有监控缓存数据 耗时 ： {}",System.currentTimeMillis() - beginTime);
+		log.info("步骤1获取所有监控缓存数据 耗时 ： {}",System.currentTimeMillis() - beginTime);
 		beginTime = System.currentTimeMillis();
 		// 集中监控响应站点数据
 		List<RealStationVo> validList = realStationVoList.stream().filter(o -> message.getDeptIds().contains(o.getStationDeptId())).collect(Collectors.toList());
@@ -241,11 +240,11 @@ public class RealMonitorServiceImpl implements IRealMonitorService {
 		Map<String, HeWeatherWeatherNowResponse> nowWeather = this.weatherService.getNowWeather(codes);
 		// 七日内天气
 		Map<String, HeWeatherWeatherDailyResponse> weekWeather = this.weatherService.getWeekWeather(codes);
-		log.info(thread.getName() + "步骤2获取天气 耗时 ： {}",System.currentTimeMillis() - beginTime);
+		log.info("步骤2获取天气 耗时 ： {}",System.currentTimeMillis() - beginTime);
 		beginTime = System.currentTimeMillis();
 		// 站点水位数据
 		List<WaterLevelVo> levelList = (List<WaterLevelVo>) redisTemplate.opsForValue().get(loadwater_level_key);
-		log.info(thread.getName() + "步骤3获取水位数据 耗时 ： {}",System.currentTimeMillis() - beginTime);
+		log.info("步骤3获取水位数据 耗时 ： {}",System.currentTimeMillis() - beginTime);
 		beginTime = System.currentTimeMillis();
 		// 遍历站点
 		validList.forEach(item->{
@@ -256,8 +255,12 @@ public class RealMonitorServiceImpl implements IRealMonitorService {
 			// 总有功率
 			this.activePower(item);
 		});
-		log.info(thread.getName() + "步骤4站点数据处理 耗时 ： {}",System.currentTimeMillis() - beginTime);
-		return new TextMessage(JSONObject.toJSONString(validList.stream().sorted(Comparator.comparing((RealStationVo::getSort))).collect(Collectors.toList())));
+		log.info("步骤4站点数据处理 耗时 ： {}",System.currentTimeMillis() - beginTime);
+		return new TextMessage(JSONObject.toJSONString(validList.stream().peek(o->{
+			if(ObjectUtil.isEmpty(o.getSort())){
+				o.setSort(999);
+			}
+        }).sorted(Comparator.comparing((RealStationVo::getSort))).collect(Collectors.toList())));
 	}
 
 	/**