Browse Source

Merge remote-tracking branch 'origin/master'

zhongwei
haungxing 9 months ago
parent
commit
9641a19a66
  1. 7
      hzims-service/operational/src/main/java/com/hnac/hzims/operational/main/service/impl/HydropowerServiceImpl.java
  2. 6
      hzims-service/operational/src/main/java/com/hnac/hzims/operational/maintenance/scheduled/MaintenancePlanCreateTask.java
  3. 11
      hzims-service/operational/src/main/java/com/hnac/hzims/operational/maintenance/service/impl/MaintenanceServiceImpl.java

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

@ -1549,10 +1549,13 @@ public class HydropowerServiceImpl implements HydropowerService {
// 天气区间 // 天气区间
hydropower.setMaxTemp(this.intervalTemp(weekWeather,station.getCode(),true)); hydropower.setMaxTemp(this.intervalTemp(weekWeather,station.getCode(),true));
hydropower.setMinTemp(this.intervalTemp(weekWeather,station.getCode(),false)); hydropower.setMinTemp(this.intervalTemp(weekWeather,station.getCode(),false));
if(CollectionUtil.isEmpty(reals)){
return hydropower;
}
// 装机容量 // 装机容量
hydropower.setCapacity(reals.stream().filter(real-> real.getDeptId().equals(station.getRefDept())).mapToDouble(HydropowerUnitRealVo::getInstalledCapacity).sum()); hydropower.setCapacity(reals.stream().filter(real-> real.getDeptId().equals(station.getRefDept()) && !ObjectUtil.isEmpty(real.getInstalledCapacity())).mapToDouble(HydropowerUnitRealVo::getInstalledCapacity).sum());
// 负荷 // 负荷
hydropower.setLoad(reals.stream().filter(real-> real.getDeptId().equals(station.getRefDept())).mapToDouble(HydropowerUnitRealVo::getActivePower).sum()); hydropower.setLoad(reals.stream().filter(real-> real.getDeptId().equals(station.getRefDept()) && !ObjectUtil.isEmpty(real.getActivePower())).mapToDouble(HydropowerUnitRealVo::getActivePower).sum());
// 出力 // 出力
if(Math.abs(hydropower.getCapacity()) > 0){ if(Math.abs(hydropower.getCapacity()) > 0){
hydropower.setOutput(BigDecimal.valueOf(hydropower.getLoad() / hydropower.getCapacity() * 100).setScale(2, RoundingMode.HALF_UP).doubleValue()); hydropower.setOutput(BigDecimal.valueOf(hydropower.getLoad() / hydropower.getCapacity() * 100).setScale(2, RoundingMode.HALF_UP).doubleValue());

6
hzims-service/operational/src/main/java/com/hnac/hzims/operational/maintenance/scheduled/MaintenancePlanCreateTask.java

@ -16,6 +16,7 @@ import lombok.extern.slf4j.Slf4j;
import org.springblade.core.tool.utils.*; import org.springblade.core.tool.utils.*;
import org.springblade.system.cache.DictCache; import org.springblade.system.cache.DictCache;
import org.springblade.system.user.cache.UserCache; import org.springblade.system.user.cache.UserCache;
import org.springblade.system.user.entity.User;
import org.springblade.system.user.feign.IUserClient; import org.springblade.system.user.feign.IUserClient;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
@ -151,7 +152,10 @@ public class MaintenancePlanCreateTask {
planEntity.setImsDutyClassId(libraryEntity.getImsDutyClassId()); planEntity.setImsDutyClassId(libraryEntity.getImsDutyClassId());
planEntity.setImsDutyGroupId(libraryEntity.getImsDutyGroupId()); planEntity.setImsDutyGroupId(libraryEntity.getImsDutyGroupId());
if(ObjectUtil.isEmpty(libraryEntity.getMaintenanceModel()) || libraryEntity.getMaintenanceModel() == 1){ if(ObjectUtil.isEmpty(libraryEntity.getMaintenanceModel()) || libraryEntity.getMaintenanceModel() == 1){
planEntity.setDisposer(Long.valueOf(disposers.get((i + startIndex) % disposers.size()))); Long disposer = Long.valueOf(disposers.get((i + startIndex) % disposers.size()));
planEntity.setDisposer(disposer);
User user = UserCache.getUser(disposer);
planEntity.setDisposerName(user.getName());
} }
planEntity.setDisposeTime(planDates.get(i)); planEntity.setDisposeTime(planDates.get(i));
planEntities.add(planEntity); planEntities.add(planEntity);

11
hzims-service/operational/src/main/java/com/hnac/hzims/operational/maintenance/service/impl/MaintenanceServiceImpl.java

@ -34,6 +34,8 @@ import org.springblade.core.tool.api.R;
import org.springblade.core.tool.utils.*; import org.springblade.core.tool.utils.*;
import org.springblade.flow.core.feign.IFlowClient; import org.springblade.flow.core.feign.IFlowClient;
import org.springblade.system.feign.ISysClient; import org.springblade.system.feign.ISysClient;
import org.springblade.system.user.cache.UserCache;
import org.springblade.system.user.entity.User;
import org.springframework.beans.BeanUtils; import org.springframework.beans.BeanUtils;
import org.springframework.jdbc.datasource.DataSourceTransactionManager; import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
@ -342,7 +344,16 @@ public class MaintenanceServiceImpl implements MaintenanceService {
ImsDutyMainEntity entity = mainService.getOne(entityLambdaQueryWrapper); ImsDutyMainEntity entity = mainService.getOne(entityLambdaQueryWrapper);
if (ObjectUtil.isNotEmpty(entity) && StringUtils.isNotEmpty(entity.getDutyPersonIds())) { if (ObjectUtil.isNotEmpty(entity) && StringUtils.isNotEmpty(entity.getDutyPersonIds())) {
String userId = entity.getDutyPersonIds(); String userId = entity.getDutyPersonIds();
String[] split = userId.split("\\^");
String disposerName="";
for (int i = 0; i < split.length; i++) {
User user = UserCache.getUser(Long.valueOf(split[i]));
if (ObjectUtil.isNotEmpty(user)&&StringUtils.isNotBlank(user.getName())){
disposerName=disposerName+user.getName();
}
}
taskEntity.setDisposer(userId.replaceAll("\\^", ",")); taskEntity.setDisposer(userId.replaceAll("\\^", ","));
taskEntity.setDisposerName(disposerName);
} else { } else {
log.info("计划ID为:{}未查询到排班记录", finalPlanEntity.getId()); log.info("计划ID为:{}未查询到排班记录", finalPlanEntity.getId());
// LambdaUpdateWrapper<OperMaintenancePlanEntity> planQueryWrapper = Wrappers.<OperMaintenancePlanEntity>lambdaUpdate() // LambdaUpdateWrapper<OperMaintenancePlanEntity> planQueryWrapper = Wrappers.<OperMaintenancePlanEntity>lambdaUpdate()

Loading…
Cancel
Save