xiangpei
2024-08-06 1811eba7161876767768c5e327922c53bbd6f6b1
内部新增工单方法(批量)
2个文件已修改
29 ■■■■■ 已修改文件
ycl-server/src/main/java/com/ycl/platform/service/WorkOrderService.java 4 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
ycl-server/src/main/java/com/ycl/platform/service/impl/WorkOrderServiceImpl.java 25 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
ycl-server/src/main/java/com/ycl/platform/service/WorkOrderService.java
@@ -23,10 +23,10 @@
    /**
     * 系统内部的添加
     *
     * @param workOrder
     * @param workOrderList
     * @return
     */
    Result innerAdd(WorkOrder workOrder) throws Exception;
    Boolean innerAdd(List<WorkOrder> workOrderList) throws Exception;
    /**
     * 添加
ycl-server/src/main/java/com/ycl/platform/service/impl/WorkOrderServiceImpl.java
@@ -33,6 +33,7 @@
import enumeration.general.WorkOrderDistributeWayEnum;
import enumeration.general.WorkOrderStatusEnum;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.ObjectUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
@@ -52,6 +53,7 @@
 * @author xp
 * @since 2024-03-05
 */
@Slf4j
@Service
@RequiredArgsConstructor
public class WorkOrderServiceImpl extends ServiceImpl<WorkOrderMapper, WorkOrder> implements WorkOrderService {
@@ -72,20 +74,15 @@
    private RedisCache redisCache;
    @Override
    public Result innerAdd(WorkOrder workOrder) throws Exception {
        if (! StringUtils.hasText(workOrder.getSerialNumber())) {
            throw new Exception("创建工单时,请传递设备编码");
        }
        if (Objects.isNull(workOrder.getStatus())) {
            throw new Exception("创建工单时,请传递工单状态");
        }
        if (! StringUtils.hasText(workOrder.getErrorType())) {
            throw new Exception("创建工单时,请传递异常类型");
        }
        workOrder.setWorkOrderNo(IdUtils.timeAddRandomNO(5));
        workOrder.setCreateTime(DateUtils.getNowDate());
        baseMapper.insert(workOrder);
        return Result.ok();
    public Boolean innerAdd(List<WorkOrder> workOrderList) {
        int total = workOrderList.size();
        workOrderList.stream().filter(item -> {
            return StringUtils.hasText(item.getSerialNumber()) && Objects.nonNull(item.getStatus()) && StringUtils.hasText(item.getErrorType());
        });
        int real = workOrderList.size();
        boolean result = this.saveBatch(workOrderList);
        log.info("传入工单总数: {},实际添加工单数:{}", total, real);
        return result;
    }
    /**