|
|
@@ -1,21 +1,17 @@
|
|
|
package cn.start.tz.module.pressure2.service.pipetaskorderitemsuspend;
|
|
|
|
|
|
import cn.hutool.core.collection.CollUtil;
|
|
|
-import cn.hutool.core.util.ObjectUtil;
|
|
|
import cn.start.tz.framework.mybatis.core.query.LambdaQueryWrapperX;
|
|
|
-import cn.start.tz.module.pressure.enums.EnvConstants;
|
|
|
import cn.start.tz.module.pressure.enums.TaskOrderStatusEnum;
|
|
|
-import cn.start.tz.module.pressure2.controller.admin.boilertaskorderitemsuspend.vo.BoilerTaskOrderItemSuspendRespVO;
|
|
|
-import cn.start.tz.module.pressure2.controller.admin.boilertaskorderitemsuspend.vo.TaskOrderItemSuspendSubmitReqVO;
|
|
|
import cn.start.tz.module.pressure2.dal.dataobject.appointmentconfirmorderrefuseitem.AppointmentConfirmOrderRefuseItemDO;
|
|
|
import cn.start.tz.module.pressure2.dal.dataobject.appointmentconfirmrefuseyearitem.AppointmentConfirmRefuseYearItemDO;
|
|
|
+import cn.start.tz.module.pressure2.dal.dataobject.boilertaskorder.BoilerTaskOrderDO;
|
|
|
import cn.start.tz.module.pressure2.dal.dataobject.equippipe.EquipPipeDO;
|
|
|
import cn.start.tz.module.pressure2.dal.dataobject.equippipedetail.EquipPipeDetailDO;
|
|
|
import cn.start.tz.module.pressure2.dal.dataobject.equippipeschedulingitem.EquipPipeSchedulingItemDO;
|
|
|
import cn.start.tz.module.pressure2.dal.dataobject.pipetaskorder.PipeTaskOrderDO;
|
|
|
import cn.start.tz.module.pressure2.dal.dataobject.pipetaskorderitem.PipeTaskOrderItemDO;
|
|
|
import cn.start.tz.module.pressure2.dal.dataobject.pipetaskorderitemdetail.PipeTaskOrderItemDetailDO;
|
|
|
-import cn.start.tz.module.pressure2.dal.dataobject.pipetaskorderitemreport.PipeTaskOrderItemReportDO;
|
|
|
import cn.start.tz.module.pressure2.dal.mysql.appointmentconfirmorderrefuseitem.AppointmentConfirmOrderRefuseItemMapper;
|
|
|
import cn.start.tz.module.pressure2.dal.mysql.appointmentconfirmrefuseyearitem.AppointmentConfirmRefuseYearItemMapper;
|
|
|
import cn.start.tz.module.pressure2.dal.mysql.equippipe.EquipPipeMapper;
|
|
|
@@ -29,7 +25,6 @@ import cn.start.tz.module.pressure2.framework.thread.CommonThread;
|
|
|
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;
|
|
|
@@ -45,11 +40,9 @@ import org.springframework.validation.annotation.Validated;
|
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
|
|
|
|
-import java.math.BigDecimal;
|
|
|
import java.time.LocalDate;
|
|
|
import java.time.LocalDateTime;
|
|
|
import java.util.*;
|
|
|
-import java.util.concurrent.CompletableFuture;
|
|
|
import java.util.concurrent.atomic.AtomicReference;
|
|
|
import java.util.function.Function;
|
|
|
import java.util.stream.Collectors;
|
|
|
@@ -57,7 +50,6 @@ import java.util.stream.Collectors;
|
|
|
import cn.start.tz.module.pressure2.controller.admin.pipetaskorderitemsuspend.vo.*;
|
|
|
import cn.start.tz.module.pressure2.dal.dataobject.pipetaskorderitemsuspend.PipeTaskOrderItemSuspendDO;
|
|
|
import cn.start.tz.framework.common.pojo.PageResult;
|
|
|
-import cn.start.tz.framework.common.pojo.PageParam;
|
|
|
import cn.start.tz.framework.common.util.object.BeanUtils;
|
|
|
|
|
|
import cn.start.tz.module.pressure2.dal.mysql.pipetaskorderitemsuspend.PipeTaskOrderItemSuspendMapper;
|
|
|
@@ -190,6 +182,7 @@ public class PipeTaskOrderItemSuspendServiceImpl extends ServiceImpl<PipeTaskOrd
|
|
|
return;
|
|
|
}
|
|
|
|
|
|
+ AtomicReference<String> orderId = new AtomicReference<>("");
|
|
|
// 按照 equipPipeId 进行分组
|
|
|
List<PipeTaskOrderItemSuspendDO> taskOrderItemSuspendDOS = new ArrayList<>();
|
|
|
Map<String, List<PipeTaskOrderItemSuspendDetailReqVO>> groupedByEquipPipeIds = submitReqVO.getOrderItemDetails().stream()
|
|
|
@@ -200,6 +193,7 @@ public class PipeTaskOrderItemSuspendServiceImpl extends ServiceImpl<PipeTaskOrd
|
|
|
groupedByEquipPipeIds.forEach((equipPipeId, orderItemDetails) -> {
|
|
|
|
|
|
PipeTaskOrderItemDO taskOrderItemDO = taskOrderItemMapper.selectById(equipPipeId);
|
|
|
+ orderId.set(taskOrderItemDO.getOrderId());
|
|
|
PipeTaskOrderDO taskOrderDO = taskOrderMapper.selectById(taskOrderItemDO.getOrderId());
|
|
|
List<AppointmentConfirmOrderRefuseItemDO> refuseItemDOList = new ArrayList<>();
|
|
|
|
|
|
@@ -339,6 +333,20 @@ public class PipeTaskOrderItemSuspendServiceImpl extends ServiceImpl<PipeTaskOrd
|
|
|
|
|
|
pipeTaskOrderItemSuspendMapper.insertBatch(taskOrderItemSuspendDOS);
|
|
|
|
|
|
+ //判断任务单是否没有设备
|
|
|
+ PipeTaskOrderDO updateDO = new PipeTaskOrderDO();
|
|
|
+ updateDO.setId(orderId.get());
|
|
|
+ Long count = taskOrderItemMapper.selectCount(new LambdaQueryWrapper<PipeTaskOrderItemDO>()
|
|
|
+ .eq(PipeTaskOrderItemDO::getOrderId, orderId.get()));
|
|
|
+ if (count == null || count == 0){
|
|
|
+ updateDO.setTaskStatus(TaskOrderStatusEnum.CANCEL.getStatus());
|
|
|
+ }else{
|
|
|
+ updateDO.setEquipNum(Math.toIntExact(count));
|
|
|
+ //修改金额
|
|
|
+ taskOrderService.updateOrderFee(orderId.get());
|
|
|
+ }
|
|
|
+ taskOrderMapper.updateById(updateDO);
|
|
|
+
|
|
|
}
|
|
|
|
|
|
}
|