| | |
| | | notAddList.add(workOrder); |
| | | continue; |
| | | } |
| | | //数字前面补0 |
| | | workOrderNum++; |
| | | workOrder.setWorkOrderNo(IdUtils.workOrderNO(now, String.format("%05d", workOrderNum))); |
| | | if (Objects.nonNull(point.getUnitId())) { |
| | | workOrder.setUnitId(Math.toIntExact(point.getUnitId())); |
| | | } |
| | |
| | | if (CollectionUtils.isEmpty(waitAddList)) { |
| | | return Boolean.TRUE; |
| | | } |
| | | //记录工单数 |
| | | //记录工单数,补充工单号 |
| | | for (WorkOrder workOrder : waitAddList) { |
| | | //数字前面补0 |
| | | workOrderNum++; |
| | | workOrder.setWorkOrderNo(IdUtils.workOrderNO(now, String.format("%05d", workOrderNum))); |
| | | } |
| | | redisCache.setCacheObject(RedisConstant.WORKORDER_NUM, workOrderNum); |
| | | redisCache.releaseLock(RedisConstant.WORKORDER_NUM_LOCK, requestId); |
| | | // 保存工单和故障类型 |
| | |
| | | String url = String.format(this.rtspServer + "/api/play/start/img/%s/%s", deviceId, channelId); |
| | | String result = HttpUtils.sendGet(url); |
| | | log.info("拿到取流图片响应结果:" + result); |
| | | return result; |
| | | WVPResult wvpResult = JSON.parseObject(result, WVPResult.class); |
| | | if(wvpResult.getCode() == 0) { |
| | | Object imgUrl = (Object) wvpResult.getData(); |
| | | imgUrl = Objects.isNull(imgUrl) ? "" : imgUrl; |
| | | log.info("拿到取流图片:" + imgUrl); |
| | | return (String) imgUrl; |
| | | } |
| | | return null; |
| | | // WVPResult wvpResult = JSON.parseObject(result, WVPResult.class); |
| | | // String imgUrl = null; |
| | | // if (wvpResult.getCode() == 0) { |