blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
fuliqi
2024-08-28 9f5b9db2c8cdbcf74bd2eecefc3557d4048b8d4c 
 ycl-server/src/main/java/com/ycl/platform/service/impl/WorkOrderServiceImpl.java


@@ -157,6 +157,7 @@


                    ywRecord.setCommitUser(1);


                    ywRecord.setYwCondition("故障类型更新，工单状态调整为待处理");


                    ywRecord.setCreateTime(new Date());


                    ywRecord.setSysMsg(Boolean.TRUE);


                    willAddMsg.add(ywRecord);


                }


            } else {


@@ -300,7 +301,7 @@


        baseMapper.updateById(workOrder);


        // 添加一条审核记录


        WorkOrderAuditingRecord workOrderAuditingRecord = new WorkOrderAuditingRecord();


        workOrderAuditingRecord.setWorkOrderId(workOrder.getId());


        workOrderAuditingRecord.setWorkOrderNo(workOrder.getWorkOrderNo());


        workOrderAuditingRecord.setAuditingUser(SecurityUtils.getLoginUser().getUserId().intValue());


        workOrderAuditingRecord.setResult(form.getAuditingResult().getDesc());


        workOrderAuditingRecord.setRemark(form.getAuditingRemark());


@@ -314,7 +315,7 @@


        notifyService.save(notify);


        // 同步点位状态


        if (form.getAuditingResult() == WorkOrderStatusEnum.AUDITING_SUCCESS) {


            ywPointService.updateRecovery(Arrays.asList(workOrder.getSerialNumber()), 0);


            ywPointService.updateRecovery(Collections.singletonList(workOrder.getSerialNumber()), 0);


        }


        return Result.ok("操作成功");


    }


@@ -326,22 +327,23 @@


        List<WorkOrder> list = new LambdaQueryChainWrapper<>(baseMapper)


                .in(WorkOrder::getStatus, WorkOrderStatusEnum.YW_HANDLE.getValue())


                .in(WorkOrder::getErrorType, form.getErrorTypes())


                .select(WorkOrder::getId, WorkOrder::getUnitId, WorkOrder::getWorkOrderNo)


                .select(WorkOrder::getId, WorkOrder::getUnitId, WorkOrder::getWorkOrderNo, WorkOrder::getSerialNumber)


                .list();


        if (list.isEmpty()) {


            return Result.error("没有工单可以审核");


        }


        List<Integer> ids = list.stream().map(WorkOrder::getId).collect(Collectors.toList());


        List<String> workOrderNoList = list.stream().map(WorkOrder::getWorkOrderNo).collect(Collectors.toList());


        List<String> serialNumbers = list.stream().map(WorkOrder::getSerialNumber).toList();


        // 工单状态


        LambdaUpdateWrapper<WorkOrder> lambdaUpdateWrapper = new LambdaUpdateWrapper<>();


        lambdaUpdateWrapper.in(WorkOrder::getId, ids);


        lambdaUpdateWrapper.in(WorkOrder::getWorkOrderNo, workOrderNoList);


        lambdaUpdateWrapper.set(WorkOrder::getStatus, form.getAuditingResult());


        baseMapper.update(lambdaUpdateWrapper);


        // 添加多条审核记录


        List<WorkOrderAuditingRecord> workOrderAuditingRecords = new ArrayList<>();


        for (Integer id : ids) {


        for (String workOrderNo : workOrderNoList) {


            WorkOrderAuditingRecord workOrderAuditingRecord = new WorkOrderAuditingRecord();


            workOrderAuditingRecord.setWorkOrderId(id);


            workOrderAuditingRecord.setWorkOrderNo(workOrderNo);


            workOrderAuditingRecord.setAuditingUser(SecurityUtils.getLoginUser().getUserId().intValue());


            workOrderAuditingRecord.setResult(form.getAuditingResult().getDesc());


            workOrderAuditingRecord.setRemark(form.getAuditingRemark());


@@ -357,6 +359,10 @@


                    UrgentLevelEnum.WARNING,


                    workOrder.getWorkOrderNo());


            notifies.add(notify);


        }


        // 同步点位状态


        if (form.getAuditingResult() == WorkOrderStatusEnum.AUDITING_SUCCESS) {


            ywPointService.updateRecovery(serialNumbers, 0);


        }


        notifyService.saveBatch(notifies);


        return Result.ok("操作成功");


@@ -385,8 +391,8 @@


    }




    @Override


    public Result selectYwConditionByYwId(Integer id) {


        List<WorkOrderYwConditionRecordVO> ywConditionList = workOrderYwConditionRecordMapper.selectYwConditionByYwId(id);


    public Result selectYwConditionByYwId(String workOrderNo) {


        List<WorkOrderYwConditionRecordVO> ywConditionList = workOrderYwConditionRecordMapper.selectYwConditionByYwId(workOrderNo);


        ywConditionList.stream().forEach(item -> {


            if (Objects.nonNull(item.getSysMsg()) && item.getSysMsg()) {


                item.setCommitUserName("系统消息");


@@ -396,10 +402,10 @@


    }




    @Override


    public Result selectYwAuditingListByYwId(String id) {


    public Result selectYwAuditingListByYwId(String workOrderNo) {


        return Result.ok().data(


                new LambdaQueryChainWrapper<>(workOrderAuditingRecordMapper)


                        .eq(WorkOrderAuditingRecord::getWorkOrderId, id)


                        .eq(WorkOrderAuditingRecord::getWorkOrderNo, workOrderNo)


                        .orderByAsc(WorkOrderAuditingRecord::getCreateTime)


                        .list());


    }


@@ -489,7 +495,7 @@




        // 查询符合条件的工单


        List<WorkOrder> list = new LambdaQueryChainWrapper<>(baseMapper)


                .select(WorkOrder::getSerialNumber, WorkOrder::getSerialNumber)


                .select(WorkOrder::getSerialNumber, WorkOrder::getWorkOrderNo)


                .eq(WorkOrder::getStatus, WorkOrderStatusEnum.WAIT_DISTRIBUTE)


                .eq(Objects.nonNull(data.getUnitId()), WorkOrder::getUnitId, data.getUnitId())


                .eq(WorkOrder::getErrorType, data.getErrorType())


@@ -528,7 +534,7 @@


                query.setWorkOrderNOList(new LambdaQueryChainWrapper<>(baseMapper)


                        .eq(WorkOrder::getStatus, WorkOrderStatusEnum.WAIT_DISTRIBUTE)


                        .eq(Objects.nonNull(query.getUnitId()), WorkOrder::getUnitId, query.getUnitId())


                        .select(WorkOrder::getId)


                        .select(WorkOrder::getWorkOrderNo)


                        .list()


                        .stream()


                        .map(WorkOrder::getWorkOrderNo)


@@ -542,7 +548,7 @@


                    .update();


            addDistributeRecord(query.getWorkOrderNOList(), distributeWayEnum);


            // 同步点位状态


            List<String> serialNumberList = new LambdaQueryChainWrapper<>(baseMapper).select(WorkOrder::getSerialNumber).in(WorkOrder::getId, query.getWorkOrderNOList()).list().stream().map(WorkOrder::getSerialNumber).toList();


            List<String> serialNumberList = new LambdaQueryChainWrapper<>(baseMapper).select(WorkOrder::getSerialNumber).in(WorkOrder::getWorkOrderNo, query.getWorkOrderNOList()).list().stream().map(WorkOrder::getSerialNumber).toList();


            ywPointService.updateRecovery(serialNumberList, 1);


            return Result.ok("成功下发" + query.getWorkOrderNOList().size() + "条工单");


        } catch (Exception e) {


@@ -656,12 +662,15 @@




    @Override


    public String getFrameImgByDevice(String deviceId, String channelId) {


        String url = String.format(this.rtspServer + "/start/%s/%s", deviceId, channelId);


        String url = String.format(this.rtspServer + "/api/play/start/%s/%s", deviceId, channelId);


        String result = HttpUtils.sendGet(url);


        log.error("拿到取流响应结果：" + result);


        WVPResult wvpResult = JSON.parseObject(result, WVPResult.class);


        if (0 == wvpResult.getCode()) {


            log.error("请求成功");


            StreamContent data = (StreamContent) wvpResult.getData();


            String rtspUrl = data.getRtsp();


            log.error("目标地址：" + rtspUrl);


            if (StringUtils.hasText(rtspUrl)) {


                try {


                    // 创建FFmpegFrameGrabber对象


@@ -669,18 +678,23 @@


                    grabber.start(); // 开始捕获




                    Frame frame;


                    if ((frame = grabber.grabFrame()) != null) {


                        // 将帧转换为图片


                        Java2DFrameConverter converter = new Java2DFrameConverter();


                        BufferedImage image = converter.convert(frame);


                        File outputfile = new File(serverConfig.getUrl() + PlatformConfig.getUploadPath() + deviceId + IdUtils.fastSimpleUUID() + ".png");


                        ImageIO.write(image, "png", outputfile);


                        String imgPath = outputfile.getAbsolutePath();


                        System.out.println("Saved " + imgPath);


                        return imgPath;


                    String imgPath;


                    while (true) {


                        frame = grabber.grabFrame();


                        if (Objects.nonNull(frame)) {


                            // 将帧转换为图片


                            Java2DFrameConverter converter = new Java2DFrameConverter();


                            BufferedImage image = converter.convert(frame);


                            File outputfile = new File(serverConfig.getUrl() + PlatformConfig.getUploadPath() + deviceId + IdUtils.fastSimpleUUID() + ".png");


                            ImageIO.write(image, "png", outputfile);


                            imgPath = outputfile.getAbsolutePath();


                            log.error("图片地址： " + imgPath);


                            break;


                        }


                    }


                    grabber.stop(); // 停止捕获


                    grabber.release(); // 释放资源


                    return imgPath;


                } catch (IOException e) {


                    e.printStackTrace();


                }