| | |
|---|
| | | ImageDetectionParam param = new ImageDetectionParam(); |
|---|
| | | param.setPageNum(ApiConstants.PageNo); |
|---|
| | | param.setPageSize(ApiConstants.PageSize); |
|---|
| | | param.setArealayerno(ApiConstants.AreaNo); |
|---|
| | | JSONObject jsonObject = uyClient.imageDetection(param); |
|---|
| | | if (jsonObject != null) { |
|---|
| | | log.info("数据格式" + jsonObject); |
|---|
| | |
|---|
| | | log.info("开始执行录像可用数据同步"); |
|---|
| | | RecordMetaDSumParam param = new RecordMetaDSumParam(); |
|---|
| | | param.setTenantId(tenantId); |
|---|
| | | param.setStatTime(DateUtils.getDate()); |
|---|
| | | Calendar instance = Calendar.getInstance(); |
|---|
| | | 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); |
|---|
| | | JSONObject jsonObject = uyClient.recordMetaDSumList(param); |
|---|
| | | if (jsonObject != null) { |
|---|
| | | if (ApiConstants.UYSuccessCodeStr.equals(jsonObject.getString("code"))) { |
|---|
| | |
|---|
| | | if (!CollectionUtils.isEmpty(records)) { |
|---|
| | | //如果今天存在之前的数据先删除 |
|---|
| | | Query query = new Query(Criteria |
|---|
| | | .where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date()))); |
|---|
| | | .where("mongoCreateTime").gte(DateUtils.getDayStart(instance.getTime())).lt(DateUtils.getDayEnd(instance.getTime()))); |
|---|
| | | DeleteResult result = mongoTemplate.remove(query, RecordMetaDSumResult.class); |
|---|
| | | //存放在mongo中 |
|---|
| | | mongoTemplate.insertAll(records); |
|---|
