|
|
@@ -30,6 +30,8 @@ import cn.start.tz.module.pressure2.service.pipetaskorder.PipeTaskOrderService;
|
|
|
import cn.start.tz.module.pressure2.service.pipetaskorderissuereport.PipeTaskOrderIssueReportService;
|
|
|
import cn.start.tz.module.pressure2.service.taskordernontaxapply.TaskOrderNonTaxApplyService;
|
|
|
import cn.start.tz.module.pressure2.service.taskordernontaxapply.vo.TaskOrderNonTaxApplyCreateVO;
|
|
|
+import cn.start.tz.module.system.api.dict.DictDataApi;
|
|
|
+import cn.start.tz.module.system.api.dict.dto.DictDataRespDTO;
|
|
|
import cn.start.tz.module.system.api.user.AdminUserApi;
|
|
|
import cn.start.tz.module.system.api.user.dto.AdminUserRespDTO;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
@@ -114,6 +116,9 @@ public class PipeTaskOrderItemSuspendServiceImpl extends ServiceImpl<PipeTaskOrd
|
|
|
@Resource
|
|
|
private PipeTaskOrderService taskOrderService;
|
|
|
|
|
|
+ @Resource
|
|
|
+ private DictDataApi dictDataApi;
|
|
|
+
|
|
|
@Resource
|
|
|
private CommonThread commonThread;
|
|
|
|
|
|
@@ -190,6 +195,8 @@ public class PipeTaskOrderItemSuspendServiceImpl extends ServiceImpl<PipeTaskOrd
|
|
|
Map<String, List<PipeTaskOrderItemSuspendDetailReqVO>> groupedByEquipPipeIds = submitReqVO.getOrderItemDetails().stream()
|
|
|
.collect(Collectors.groupingBy(PipeTaskOrderItemSuspendDetailReqVO::getEquipPipeId));
|
|
|
|
|
|
+ List<DictDataRespDTO> checkTypeDTOS = dictDataApi.getDictDataList("pressure_inspection_nature_pipe").getData();
|
|
|
+ List<DictDataRespDTO> pipeStatusDTOS = dictDataApi.getDictDataList("PIPE_USE_STATUS").getData();
|
|
|
groupedByEquipPipeIds.forEach((equipPipeId, orderItemDetails) -> {
|
|
|
|
|
|
PipeTaskOrderItemDO taskOrderItemDO = taskOrderItemMapper.selectById(equipPipeId);
|
|
|
@@ -224,7 +231,17 @@ public class PipeTaskOrderItemSuspendServiceImpl extends ServiceImpl<PipeTaskOrd
|
|
|
bean.setOrderNo(taskOrderDO.getOrderNo());
|
|
|
bean.setReasonDict(submitReqVO.getReasonDict());
|
|
|
bean.setEquipMainType(300); //管道
|
|
|
- bean.setCheckType(taskOrderDO.getCheckType());
|
|
|
+ bean.setRejectionSource(2);
|
|
|
+ Integer checkType = taskOrderDO.getCheckType();
|
|
|
+ if (CollUtil.isNotEmpty(checkTypeDTOS)){
|
|
|
+ String checkTypeName = checkTypeDTOS.stream()
|
|
|
+ .filter(dict -> dict.getValue().equals(checkType.toString()))
|
|
|
+ .map(DictDataRespDTO::getLabel)
|
|
|
+ .findFirst()
|
|
|
+ .orElse("");
|
|
|
+ bean.setCheckTypeName(checkTypeName);
|
|
|
+ }
|
|
|
+ bean.setCheckType(checkType);
|
|
|
//是否上报
|
|
|
if (submitReqVO.getFlag() == 1){
|
|
|
bean.setIsReportCity(true);
|
|
|
@@ -247,6 +264,14 @@ public class PipeTaskOrderItemSuspendServiceImpl extends ServiceImpl<PipeTaskOrd
|
|
|
bean.setEquipId(equipPipeDetailDO.getId());
|
|
|
bean.setEquipCode(equipPipeDetailDO.getProjectNo());
|
|
|
bean.setEquipStatus(equipPipeDetailDO.getUseStatus());
|
|
|
+ if (CollUtil.isNotEmpty(pipeStatusDTOS)){
|
|
|
+ String equipStatusName = pipeStatusDTOS.stream()
|
|
|
+ .filter(dict -> dict.getValue().equals(equipPipeDO.getUseStatus()))
|
|
|
+ .map(DictDataRespDTO::getLabel)
|
|
|
+ .findFirst()
|
|
|
+ .orElse("");
|
|
|
+ bean.setEquipStatusName(equipStatusName);
|
|
|
+ }
|
|
|
bean.setUseRegisterNo(equipPipeDetailDO.getCertificateNo());
|
|
|
|
|
|
bean.setEquipDistrict(equipPipeDO.getEquipDistrict());
|