明星电力充电桩
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
无关风月
2024-08-31 5489c2cc4d35970ca8fe4d30cf8ac374eef17ca4 
 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/UploadRealTimeMonitoringDataServiceImpl.java


@@ -6,6 +6,8 @@


import com.ruoyi.integration.iotda.constant.IotConstant;


import com.ruoyi.integration.mongodb.service.UploadRealTimeMonitoringDataService;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.data.domain.PageRequest;


import org.springframework.data.domain.Pageable;


import org.springframework.data.domain.Sort;


import org.springframework.data.mongodb.core.MongoTemplate;


import org.springframework.data.mongodb.core.query.Criteria;


@@ -13,6 +15,7 @@


import org.springframework.stereotype.Service;




import java.util.List;


import java.util.Set;




@Service


public class UploadRealTimeMonitoringDataServiceImpl implements UploadRealTimeMonitoringDataService {


@@ -53,4 +56,21 @@


                , UploadRealTimeMonitoringData.class);


        return uploadRealTimeMonitoringData;


    }




    @Override


    public List<UploadRealTimeMonitoringData> getDataAll(Set<String> values, Integer page, Integer size) {


        Query query = new Query();


        if (!values.isEmpty()){


            query.addCriteria(Criteria.where("transaction_serial_number").in(values));


        }


        // 设置分页


        Pageable pageable = PageRequest.of(page, size);


        query.with(pageable);




        List<UploadRealTimeMonitoringData> uploadRealTimeMonitoringData = mongoTemplate.find(


                query.with(Sort.by("create_time"))


                , UploadRealTimeMonitoringData.class);


        return uploadRealTimeMonitoringData;


    }




}