blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
fuliqi
2024-11-01 b91945ea32378a71d1e57356af6e16703a1ceaa7 
 ycl-server/src/main/java/com/ycl/platform/service/impl/WorkOrderServiceImpl.java


@@ -14,6 +14,7 @@


import com.ycl.config.ServerConfig;


import com.ycl.exception.ServiceException;


import com.ycl.platform.domain.entity.*;


import com.ycl.platform.domain.excel.PointExport;


import com.ycl.platform.domain.form.*;


import com.ycl.platform.domain.query.*;


import com.ycl.platform.domain.vo.*;


@@ -39,6 +40,8 @@


import com.ycl.utils.http.HttpUtils;


import com.ycl.utils.redis.RedisCache;


import com.ycl.utils.uuid.IdUtils;


import constant.ApiConstants;


import constant.CheckConstants;


import constant.Constants;


import constant.RedisConstant;


import enumeration.general.*;


@@ -110,9 +113,14 @@


    @Transactional(rollbackFor = Exception.class)


    public synchronized Boolean innerAddWorkOrder(List<WorkOrder> workOrderList) {


        int total = workOrderList.size();


        workOrderList.stream().filter(item -> {


        // 查询出白名单列表


        List<String> serialNumbers = workOrderWhiteMapper.selectList().stream().map(WorkOrderWhite::getSerialNumber).collect(Collectors.toList());


        // 遍历工单列表，判断是否在白名单中


        workOrderList = workOrderList.stream().filter(item -> !serialNumbers.contains(item.getSerialNumber()))


                        .collect(Collectors.toList());


        workOrderList = workOrderList.stream().filter(item -> {


            return StringUtils.hasText(item.getSerialNumber()) && Objects.nonNull(item.getStatus()) && !CollectionUtils.isEmpty(item.getErrorTypeList());


        });


        }).collect(Collectors.toList());


        if (CollectionUtils.isEmpty(workOrderList)) {


            return Boolean.TRUE;


        }


@@ -164,7 +172,10 @@


                            willAddErrorType.add(workOrderErrorType);


                        }


                    }


                    databaseWorkOrder.setStatus(WorkOrderStatusEnum.DISTRIBUTED);


                    //避免代下发的工单直接变成下发


                    if(!databaseWorkOrder.getStatus().equals(WorkOrderStatusEnum.WAIT_DISTRIBUTE)) {


                        databaseWorkOrder.setStatus(WorkOrderStatusEnum.DISTRIBUTED);


                    }


                    databaseWorkOrder.setUpdateTime(now);


                    willUpdateStatusWorkOrderList.add(databaseWorkOrder);


                    updateNum++;


@@ -202,9 +213,11 @@


            return Boolean.TRUE;


        }


        List<String> willAddSerialNumber = waitAddList.stream().map(WorkOrder::getSerialNumber).collect(Collectors.toList());


        //只生成考核设备的工单


        List<YwPoint> pointList = new LambdaQueryChainWrapper<>(ywPointService.getBaseMapper())


                .select(YwPoint::getUnitId, YwPoint::getSerialNumber, YwPoint::getImportantTag, YwPoint::getImportantTag, YwPoint::getProvinceTag, YwPoint::getImportantCommandImageTag)


                .in(YwPoint::getSerialNumber, willAddSerialNumber)


                .eq(YwPoint::getExamineStatus, Boolean.TRUE)


                .list();


        Map<String, YwPoint> pointMapping = pointList.stream().collect(Collectors.toMap(YwPoint::getSerialNumber, point -> point));


        // 查出重点点位、普通点位的处理时间


@@ -324,19 +337,26 @@


            return Result.error("工单正在添加，请稍后再试");


        }


        WorkOrder entity = WorkOrderForm.getEntityByForm(form, null);


        entity.setCreateTime(DateUtils.getNowDate());


        entity.setStatus(WorkOrderStatusEnum.WAIT_DISTRIBUTE);


        Date now = new Date();


        entity.setCreateTime(now);


        entity.setUpdateTime(now);


        entity.setWorkOrderNo(IdUtils.workOrderNO(now, String.format("%05d", workOrderNum)));


        entity.setErrorType(String.join(",", form.getErrorType()));


        List<WorkOrderErrorType> workOrderErrorTypes = form.getErrorType().stream().map(errorType -> new WorkOrderErrorType(entity.getWorkOrderNo(), errorType)).toList();


        workOrderErrorTypeService.getBaseMapper().insertWorkOrderErrorTypeList(workOrderErrorTypes);


        if (baseMapper.insert(entity) > 0) {


            return Result.ok("添加成功");


        // 查询出白名单列表


        List<String> serialNumbers = workOrderWhiteMapper.selectList().stream().map(WorkOrderWhite::getSerialNumber).collect(Collectors.toList());


        // 遍历工单列表，判断是否在白名单中


         if (serialNumbers.contains(entity.getSerialNumber())){


            return Result.error("该设备在白名单中，不能添加工单");


        }else {


            entity.setCreateTime(DateUtils.getNowDate());


            entity.setStatus(WorkOrderStatusEnum.WAIT_DISTRIBUTE);


            Date now = new Date();


            entity.setCreateTime(now);


            entity.setUpdateTime(now);


            entity.setWorkOrderNo(IdUtils.workOrderNO(now, String.format("%05d", workOrderNum)));


            entity.setErrorType(String.join(",", form.getErrorType()));


            List<WorkOrderErrorType> workOrderErrorTypes = form.getErrorType().stream().map(errorType -> new WorkOrderErrorType(entity.getWorkOrderNo(), errorType)).toList();


            workOrderErrorTypeService.getBaseMapper().insertWorkOrderErrorTypeList(workOrderErrorTypes);


            if (baseMapper.insert(entity) > 0) {


                return Result.ok("添加成功");


            }


            return Result.error("添加失败");


        }


        return Result.error("添加失败");


    }




    /**


@@ -1041,4 +1061,26 @@


        workOrderWhiteMapper.batchDelete(ids);


        return Result.ok();


    }




    /**


     * 批量导入白名单


     *


     * @param dataList 数据列表


     * @author


     */


    @Override


    public void batchImportWhite(List<PointExport> dataList) {


        // 获得所有需要新增的白名单对象


        List<WorkOrderWhite> whitelist = dataList.stream().map(pointExport ->


                        new WorkOrderWhite(pointExport.getSerialNumber(), pointExport.getPointName(), SecurityUtils.getUsername()))


                .collect(Collectors.toList());


        // 获得所有已存在的白名单设备编码


        List<String> serialNumbers = workOrderWhiteMapper.selectList().stream().map(WorkOrderWhite::getSerialNumber).collect(Collectors.toList());


        // 筛选出新增、修改的白名单对象


        List<WorkOrderWhite> updateWhiteList = whitelist.stream().filter(white -> serialNumbers.contains(white.getSerialNumber())).collect(Collectors.toList());


        List<WorkOrderWhite> insertWhiteList = whitelist.stream().filter(white ->!serialNumbers.contains(white.getSerialNumber())).collect(Collectors.toList());


        // 新增/修改白名单设备记录


        updateWhiteList.stream().forEach(white -> workOrderWhiteMapper.updateBySerialNumber(white));


        insertWhiteList.stream().forEach(white -> workOrderWhiteMapper.insert(white));


    }


}