| | |
|---|
| | | import com.ycl.platform.domain.result.UY.VideoOnlineResult; |
|---|
| | | import com.ycl.platform.domain.vo.UpdateOnlineVO; |
|---|
| | | import com.ycl.platform.mapper.TMonitorMapper; |
|---|
| | | import com.ycl.platform.mapper.WorkOrderMapper; |
|---|
| | | import com.ycl.platform.service.UYErrorTypeCheckService; |
|---|
| | | import com.ycl.platform.service.WorkOrderService; |
|---|
| | | import com.ycl.platform.service.YwPointService; |
|---|
| | |
|---|
| | | private final YwPointService pointService; |
|---|
| | | private final TMonitorMapper monitorMapper; |
|---|
| | | private final WorkOrderService workOrderService; |
|---|
| | | private final WorkOrderMapper workOrderMapper; |
|---|
| | | private final SysConfigMapper sysConfigMapper; |
|---|
| | | private final CheckPointUtil checkPointUtil; |
|---|
| | | @Value("${youYun.tenantId}") |
|---|
| | |
|---|
| | | log.error("请配置离线次数，此次设置为默认值2"); |
|---|
| | | } |
|---|
| | | // 先查出设备IP集合,剔除掉在线情况是未知的,并且只检测正在考核的设备避免多余工单 |
|---|
| | | //TODO：需要把海康和优云的任务的时间调到ping之前 |
|---|
| | | List<TMonitorResult> monitorList = monitorMapper.getDistinctIP(); |
|---|
| | | //补充错误时间点 |
|---|
| | | Query onlineQuery = new Query(Criteria.where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date()))); |
|---|
| | |
|---|
| | | mongoTemplate.insertAll(mongoList); |
|---|
| | | } |
|---|
| | | //工单（同一IP只生成一个工单） |
|---|
| | | //查询数据库已存在的离线工单获取ip集合，剔除 |
|---|
| | | List<String> ips = workOrderMapper.getOfflineWorkOrder(); |
|---|
| | | List<WorkOrder> workOrderList = dataList.stream() |
|---|
| | | .filter(item -> Objects.nonNull(item.getWorkOrder())) |
|---|
| | | .filter(item -> Objects.nonNull(item.getWorkOrder()) && (CollectionUtils.isEmpty(ips) || !ips.contains(item.getIp()))) |
|---|
| | | .collect(Collectors.toMap( |
|---|
| | | TMonitorResult::getIp, |
|---|
| | | Function.identity(), |
|---|
| | |
|---|
| | | vo.setUpdateTime(now); |
|---|
| | | return vo; |
|---|
| | | }).collect(Collectors.toList()); |
|---|
| | | monitorMapper.updateOnline(willUpdateList); |
|---|
| | | monitorMapper.updateOnlineFromUyOrHk(willUpdateList); |
|---|
| | | //离线生成工单,一个ip只生成一个工单 |
|---|
| | | List<VideoOnlineResult> workOrders = new ArrayList<>(records.stream() |
|---|
| | | .filter(item -> ApiConstants.UY_OnlineSite_Offline.equals(item.getStatus())) |
|---|
