| | |
| | | ywRecord.setCommitUser(1); |
| | | ywRecord.setYwCondition("故障类型更新,工单状态调整为待处理"); |
| | | ywRecord.setCreateTime(new Date()); |
| | | ywRecord.setSysMsg(Boolean.TRUE); |
| | | willAddMsg.add(ywRecord); |
| | | } |
| | | } else { |
| | |
| | | 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()); |
| | |
| | | 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()); |
| | |
| | | } |
| | | |
| | | @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("系统消息"); |
| | |
| | | } |
| | | |
| | | @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()); |
| | | } |
| | |
| | | |
| | | @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对象 |
| | |
| | | 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(); |
| | | } |