Mongodb usage

1. rely on

 <!-- SpringBoot MongoDB -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-mongodb</artifactId>
    </dependency>

2.mongoDB Pagination

@ApiOperation(value = " Query alert records and analyze photo information by page ", notes = "", httpMethod = "GET")
@RequestMapping(method = RequestMethod.GET, value = "/analysisSearchAll")
public Response<Page<AnalysisAlarm>> analysisSearchAll(@ApiIgnore Pager<AnalysisAlarm> pager, String deviceType, String startTime,
                                                       String endTime, String deviceId) {
    Page<AnalysisAlarm> analysisAlarms = service.analysisSearchAll(pager, deviceType, startTime, endTime, deviceId);
    return Response.put(analysisAlarms);
}

3. Pagination impl Realization

		    @Override
    public Page<AnalysisAlarm> analysisSearchAll(Pager<AnalysisAlarm> pager, String deviceType, String startTime, String endTime,
                                  String deviceId) {
        Query query = new Query();
        Sort sort = Sort.by(Direction.DESC, "create_time");
        PageRequest pageable = PageRequest.of(pager.getPageNum() - 1, pager.getPageSize(), sort);
//         Paging condition query  ： Time , equipment id, Alert type 
        if(StringUtil.isNotEmpty(startTime) && StringUtil.isNotEmpty(endTime)){
            query.addCriteria(Criteria.where("create_time").gte(DateUtils.parseDate(startTime)).lte(DateUtils.parseDate(endTime)));
        }
        if (StringUtils.isNotBlank(deviceId)) {
            query.addCriteria(Criteria.where("deviceID").is(deviceId));
        }
        if (StringUtils.isNotBlank(deviceType)) {
            query.addCriteria(Criteria.where("warningType").is(deviceType));
        }
        query.addCriteria(Criteria.where("data_status").is(1));
//         Total number of queries 
        long total = mongoTemplate.count(query, AnalysisAlarm.class);
//         Paging query 
        List<AnalysisAlarm> analysisAlarmList = mongoTemplate.find(query.with(pageable), AnalysisAlarm.class);
//         Set the result set , total 
        Page<AnalysisAlarm> analysisAlarmPage = new PageImpl(analysisAlarmList, pageable, total);
        return analysisAlarmPage;
    }

4. Delete

    @Override
    public int deleteBatch(List<String> ids) {
        ids.forEach(d->{
            Query query = new Query(Criteria.where("_id").is(d));
            AnalysisAlarm one = mongoTemplate.findOne(query, AnalysisAlarm.class);
            if (ObjectUtils.isEmpty(one)){
                throw new BusinessException(" This collection has been deleted ");
            }
            Update update = new Update();
            update.set("data_status",0);
            mongoTemplate.updateFirst(query, update, AnalysisAlarm.class);
        });
        return 1;
    }

5. details

    @Override
    public List<AnalysisAlarm> elavatorAction(String deviceId) {
        Query query = new Query();
//         Paging condition query  ： Time , equipment id, Alert type 
        if (StringUtils.isNotBlank(deviceId)) {
            query.addCriteria(Criteria.where("deviceID").is(deviceId));
        }
        query.addCriteria(Criteria.where("data_status").is(1));
//         adopt deviceId Inquire about 
//        find  It's an array 
        List<AnalysisAlarm> analysisAlarms = mongoTemplate.find(query, AnalysisAlarm.class);
        return analysisAlarms;
    }