| | |
| | | } |
| | | }); |
| | | pointService.setDeviceTagByGB(records,CheckConstants.Rule_Category_Video); |
| | | log.error("点位在线率插入数据大小{}",records.size()); |
| | | //存放在mongo中 |
| | | mongoTemplate.insertAll(records); |
| | | //更新point表在线状态 |
| | |
| | | instance.setTime(new Date()); |
| | | instance.add(Calendar.DAY_OF_MONTH, -1); |
| | | SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd"); |
| | | |
| | | String yesterday = format.format(instance.getTime()); |
| | | param.setStatTime(yesterday); |
| | | log.error("开始同步mongodb录像可用数据日期为{}",yesterday); |
| | | JSONObject jsonObject = uyClient.recordMetaDSumList(param); |
| | | double minTime = getSySMinTime(); |
| | | AtomicReference<Integer> count = new AtomicReference<>(0); |
| | |
| | | |
| | | count.getAndSet(count.get() + 1); |
| | | if (item.getMissDuration() > minTime){ |
| | | log.error("改变数据status{}:",item.getRecordStatus()); |
| | | item.setRecordStatus(0); |
| | | }else if (item.getMissDuration() < minTime){ |
| | | item.setRecordStatus(1); |