| | |
| | | Query query = new Query(Criteria.where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date()))); |
| | | DeleteResult result = mongoTemplate.remove(query, VehicleDeviceInspectionResult.class); |
| | | //存放在mongo中 |
| | | mongoTemplate.insert(list); |
| | | mongoTemplate.insertAll(list); |
| | | //同步的数据进行工单阈值处理 |
| | | ywThresholdService.carCheck(list); |
| | | } |
| | |
| | | Query query = new Query(Criteria.where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date()))); |
| | | DeleteResult result = mongoTemplate.remove(query, FaceDeviceInspectionResult.class); |
| | | //存放在mongo中 |
| | | mongoTemplate.insert(list); |
| | | mongoTemplate.insertAll(list); |
| | | //同步的数据进行工单阈值处理 |
| | | //TODO:可能有重复工单 |
| | | ywThresholdService.faceCheck(list); |
| | |
| | | DeleteResult result = mongoTemplate.remove(query, SnapshotDataMonitorResult.class); |
| | | //存放在mongo中 |
| | | carList.forEach(item -> item.setDataType(ApiConstants.HK_DataType_CAR)); |
| | | mongoTemplate.insert(carList); |
| | | mongoTemplate.insertAll(carList); |
| | | } |
| | | |
| | | /** 人脸数据 */ |
| | |
| | | DeleteResult result = mongoTemplate.remove(query, SnapshotDataMonitorResult.class); |
| | | //存放在mongo中 |
| | | carList.forEach(item -> item.setDataType(ApiConstants.HK_DataType_FACE)); |
| | | mongoTemplate.insert(faceList); |
| | | mongoTemplate.insertAll(faceList); |
| | | } |
| | | //TODO:工单 |
| | | log.info("结束抓拍数据量检测结果数据同步"); |
| | |
| | | .where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date()))); |
| | | DeleteResult result = mongoTemplate.remove(query, MonitoringDetailResult.class); |
| | | //存放在mongo中 |
| | | mongoTemplate.insert(faceList); |
| | | mongoTemplate.insertAll(faceList); |
| | | } |
| | | //TODO:工单处理 |
| | | log.info("结束采集设备属性监测结果数据同步"); |
| | |
| | | .where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date()))); |
| | | DeleteResult result = mongoTemplate.remove(query, CrossDetailResult.class); |
| | | //存放在mongo中 |
| | | mongoTemplate.insert(faceList); |
| | | mongoTemplate.insertAll(faceList); |
| | | } |
| | | //TODO:工单处理 |
| | | log.info("结束卡口属性监测结果数据同步"); |
| | |
| | | .where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date()))); |
| | | DeleteResult result = mongoTemplate.remove(query, DataIntegrityMonitoringResult.class); |
| | | //存放在mongo中 |
| | | mongoTemplate.insert(faceList); |
| | | mongoTemplate.insertAll(faceList); |
| | | } |
| | | //TODO:工单处理 |
| | | log.info("结束数据完整性监测结果数据同步"); |
| | |
| | | .where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date()))); |
| | | DeleteResult result = mongoTemplate.remove(query, AttrRecognitionMonitorResult.class); |
| | | //存放在mongo中 |
| | | mongoTemplate.insert(faceList); |
| | | mongoTemplate.insertAll(faceList); |
| | | } |
| | | //TODO:工单处理 |
| | | log.info("结束属性识别准确监测结果数据同步"); |
| | |
| | | DeleteResult result = mongoTemplate.remove(query, SnapshotDelayMonitorParam.class); |
| | | //存放在mongo中 |
| | | carList.forEach(item -> item.setDataType(ApiConstants.HK_DataType_CAR)); |
| | | mongoTemplate.insert(carList); |
| | | mongoTemplate.insertAll(carList); |
| | | } |
| | | |
| | | /** 人脸数据 */ |
| | |
| | | DeleteResult result = mongoTemplate.remove(query, SnapshotDelayMonitorParam.class); |
| | | //存放在mongo中 |
| | | carList.forEach(item -> item.setDataType(ApiConstants.HK_DataType_FACE)); |
| | | mongoTemplate.insert(faceList); |
| | | mongoTemplate.insertAll(faceList); |
| | | } |
| | | //TODO:工单 |
| | | log.info("结束抓拍数据时延监测结果数据同步"); |
| | |
| | | .where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date()))); |
| | | DeleteResult result = mongoTemplate.remove(query, PicAccessResult.class); |
| | | //存放在mongo中 |
| | | mongoTemplate.insert(faceList); |
| | | mongoTemplate.insertAll(faceList); |
| | | } |
| | | //TODO:工单处理 |
| | | log.info("结束图片访问监测结果数据同步"); |
| | |
| | | .where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date()))); |
| | | DeleteResult result = mongoTemplate.remove(query, VehicleDeviceSamplingResult.class); |
| | | //存放在mongo中 |
| | | mongoTemplate.insert(faceList); |
| | | mongoTemplate.insertAll(faceList); |
| | | } |
| | | //TODO:工单处理 |
| | | log.info("结束车辆设备抽检指标监测结果数据同步"); |
| | |
| | | .where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date()))); |
| | | DeleteResult result = mongoTemplate.remove(query, FaceDeviceSamplingResult.class); |
| | | //存放在mongo中 |
| | | mongoTemplate.insert(faceList); |
| | | mongoTemplate.insertAll(faceList); |
| | | } |
| | | //TODO:工单处理 |
| | | log.info("结束人脸设备抽检指标监测结果数据同步"); |
| | | } |
| | | |
| | | //解析数据 |
| | | private <T> List<T> getDataList(JSONObject faceJsonObject, Class<T> resultClass, String message) { |
| | | if (faceJsonObject != null && ApiConstants.HKSuccessCode.equals(faceJsonObject.getString("code"))) { |
| | | JSONObject data = faceJsonObject.getJSONObject("data"); |
| | | private <T> List<T> getDataList(JSONObject jsonObject, Class<T> resultClass, String message) { |
| | | if (jsonObject != null && ApiConstants.HKSuccessCode.equals(jsonObject.getString("code"))) { |
| | | log.info("数据格式"+jsonObject); |
| | | JSONObject data = jsonObject.getJSONObject("data"); |
| | | if (data == null) { |
| | | log.error(message, faceJsonObject); |
| | | log.error(message, jsonObject); |
| | | return null; |
| | | } |
| | | List<T> list = data.getList("list", resultClass); |