ycl-server/src/main/java/com/ycl/platform/service/impl/WorkOrderServiceImpl.java
@@ -766,8 +766,11 @@ public synchronized String getFrameImgByDevice(String deviceId, String channelId, String workOrderNo) throws Exception { String url = String.format(this.rtspServer + "/api/play/start/img/%s/%s", deviceId, channelId); String result = HttpUtils.sendGet(url); log.info("拿到取流图片响应结果:" + result); return result; JSONObject jsonObject = JSON.parseObject(result); Object imgUrl = jsonObject.get("data"); imgUrl = Objects.isNull(imgUrl) ? "" : imgUrl; log.info("拿到取流图片响应结果:" + imgUrl); return (String) imgUrl; // WVPResult wvpResult = JSON.parseObject(result, WVPResult.class); // String imgUrl = null; // if (wvpResult.getCode() == 0) { ycl-server/src/main/java/com/ycl/platform/service/impl/YwPointServiceImpl.java
@@ -371,21 +371,9 @@ this.waitAllFinishAndGetResult(pointList); } public void waitAllFinishAndGetResult(List<YwPoint> dataList) throws InterruptedException, ExecutionException { int start = 0; public void waitAllFinishAndGetResult(List<YwPoint> dataList) { Date startTime = new Date(); while (true) { if (dataList.size() < start + 800) { List<YwPoint> list = dataList.subList(start, dataList.size() - 1); this.baseMapper.updatePoint(list); break; } else { List<YwPoint> list = dataList.subList(start, start + 800); this.baseMapper.updatePoint(list); start += 800; } } this.baseMapper.updatePoint(dataList); Date endTime = new Date(); log.error("总共耗时:" + (endTime.getTime() - startTime.getTime())); }