|
|
|
@ -8,6 +8,8 @@ import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
|
|
|
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
|
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; |
|
|
|
|
import com.google.common.collect.Lists; |
|
|
|
|
import com.hnac.hzims.equipment.entity.EmInfoEntity; |
|
|
|
|
import com.hnac.hzims.equipment.feign.IEmInfoClient; |
|
|
|
|
import com.hnac.hzims.operational.defect.constants.DefectConstant; |
|
|
|
|
import com.hnac.hzims.operational.defect.entity.OperPhenomenonEntity; |
|
|
|
|
import com.hnac.hzims.operational.defect.mapper.OperPhenomenonMapper; |
|
|
|
@ -75,7 +77,7 @@ public class OperMaintenanceTaskServiceImpl extends BaseServiceImpl<OperMaintena
|
|
|
|
|
private final OperPhenomenonMapper operPhenomenonMapper; |
|
|
|
|
private final IFlowClient flowClient; |
|
|
|
|
private final IUserClient userClient; |
|
|
|
|
|
|
|
|
|
private final IEmInfoClient emInfoClient; |
|
|
|
|
private final ISysClient sysClient; |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@ -460,11 +462,9 @@ public class OperMaintenanceTaskServiceImpl extends BaseServiceImpl<OperMaintena
|
|
|
|
|
List<OperMaintenanceTaskEntity> maintenanceTaskEntities = super.baseMapper.selectList(queryWrapper); |
|
|
|
|
List<MaintenanceExportVO> list=new ArrayList<>(); |
|
|
|
|
if (CollectionUtil.isNotEmpty(maintenanceTaskEntities)){ |
|
|
|
|
List<OperMaintenanceTaskVO> operMaintenanceTaskVOS = OperMaintenanceTaskWrapper.build().listVO(maintenanceTaskEntities); |
|
|
|
|
for (int i = 0; i < operMaintenanceTaskVOS.size(); i++) { |
|
|
|
|
list = maintenanceTaskEntities.parallelStream().map(maintenanceTaskVO -> { |
|
|
|
|
MaintenanceExportVO resEntity=new MaintenanceExportVO(); |
|
|
|
|
OperMaintenanceTaskVO maintenanceTaskVO = operMaintenanceTaskVOS.get(i); |
|
|
|
|
resEntity.setNumber(i+1); |
|
|
|
|
try { |
|
|
|
|
if (ObjectUtil.isNotEmpty(maintenanceTaskVO.getCreateDept())){ |
|
|
|
|
R<Dept> dept = sysClient.getDept(maintenanceTaskVO.getCreateDept()); |
|
|
|
|
if (dept.isSuccess()&&ObjectUtil.isNotEmpty(dept.getData())){ |
|
|
|
@ -472,18 +472,41 @@ public class OperMaintenanceTaskServiceImpl extends BaseServiceImpl<OperMaintena
|
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
resEntity.setTypeCode(Optional.ofNullable(DictCache.getValue(DictConstant.MAINTENANCE_TYPE_CODE, maintenanceTaskVO.getTypeCode())).orElse("")); |
|
|
|
|
resEntity.setRefLibraryId(Optional.ofNullable( maintenanceTaskVO.getRefLibraryId().toString()).orElse("")); |
|
|
|
|
resEntity.setTitle(Optional.ofNullable( maintenanceTaskVO.getTitle()).orElse("")); |
|
|
|
|
if (StringUtil.isNotBlank(maintenanceTaskVO.getEmCode())){ |
|
|
|
|
EmInfoEntity emInfoEntity = emInfoClient.getByCode(maintenanceTaskVO.getEmCode()); |
|
|
|
|
if (ObjectUtil.isNotEmpty(emInfoEntity)&&StringUtil.isNotBlank(emInfoEntity.getName())){ |
|
|
|
|
resEntity.setRefLibraryId(emInfoEntity.getName()); |
|
|
|
|
}else { |
|
|
|
|
resEntity.setRefLibraryId(maintenanceTaskVO.getEmCode()); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
resEntity.setTitle(Optional.ofNullable( maintenanceTaskVO.getContent()).orElse("")); |
|
|
|
|
if (ObjectUtil.isNotEmpty(maintenanceTaskVO.getPlanEndTime())) { |
|
|
|
|
resEntity.setPlanEndTime(Optional.ofNullable(DateUtil.format(maintenanceTaskVO.getPlanEndTime(), TicketConstants.TICKET_DATE_PATTERN)).orElse("")); |
|
|
|
|
} |
|
|
|
|
if (ObjectUtil.isNotEmpty(maintenanceTaskVO.getExecuteTime())) { |
|
|
|
|
resEntity.setExecuteTime(Optional.ofNullable(DateUtil.format(maintenanceTaskVO.getExecuteTime(), TicketConstants.TICKET_DATE_PATTERN)).orElse("")); |
|
|
|
|
if (ObjectUtil.isNotEmpty(maintenanceTaskVO.getDisposeTime())) { |
|
|
|
|
resEntity.setExecuteTime(Optional.ofNullable(DateUtil.format(maintenanceTaskVO.getDisposeTime(), TicketConstants.TICKET_DATE_PATTERN)).orElse("")); |
|
|
|
|
} |
|
|
|
|
if (ObjectUtil.isNotEmpty(maintenanceTaskVO.getDisposer())) { |
|
|
|
|
String disposerName = Optional.ofNullable(maintenanceTaskVO.getDisposer()).map(s->{ |
|
|
|
|
List<String> disposerList = Arrays.stream(s.split(",")).collect(Collectors.toList()); |
|
|
|
|
return disposerList.stream().map(d ->{ |
|
|
|
|
User user = UserCache.getUser(Long.parseLong(d)); |
|
|
|
|
return Optional.ofNullable(user).map(User::getName).orElse(""); |
|
|
|
|
}).collect(Collectors.joining(",")); |
|
|
|
|
}).orElse(""); |
|
|
|
|
if (StringUtil.isNotBlank(disposerName)) { |
|
|
|
|
resEntity.setDisposer(disposerName); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
resEntity.setDisposer(Optional.ofNullable(maintenanceTaskVO.getDisposerName()).orElse("")); |
|
|
|
|
resEntity.setPrincipal(Optional.ofNullable(maintenanceTaskVO.getContent()).orElse("")); |
|
|
|
|
list.add(resEntity); |
|
|
|
|
// resEntity.setDisposer(Optional.ofNullable(maintenanceTaskVO.getDisposerName()).orElse(""));
|
|
|
|
|
resEntity.setPrincipal(Optional.ofNullable(maintenanceTaskVO.getWorkStandards()).orElse("")); |
|
|
|
|
return resEntity; |
|
|
|
|
}catch (Exception e){ |
|
|
|
|
log.error("日常维护导出失败---》param"+maintenanceTaskVO+"报错信息:"+e.getStackTrace()); |
|
|
|
|
return resEntity; |
|
|
|
|
} |
|
|
|
|
}).collect(Collectors.toList()); |
|
|
|
|
} |
|
|
|
|
return list; |
|
|
|
|
} |
|
|
|
|