| | |
| | | package com.ruoyi.integration.mongodb.service.impl; |
| | | |
| | | import com.ruoyi.common.core.utils.StringUtils; |
| | | import com.ruoyi.integration.iotda.constant.IotConstant; |
| | | import com.ruoyi.integration.api.model.BmsDemandAndChargerExportation; |
| | | import com.ruoyi.integration.mongodb.service.BmsDemandAndChargerExportationService; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.data.domain.Sort; |
| | | import org.springframework.data.mongodb.core.MongoTemplate; |
| | | import org.springframework.data.mongodb.core.query.Criteria; |
| | | import org.springframework.data.mongodb.core.query.Query; |
| | | import org.springframework.stereotype.Service; |
| | | |
| | | import java.util.List; |
| | |
| | | public List<BmsDemandAndChargerExportation> findAll() { |
| | | return mongoTemplate.findAll(BmsDemandAndChargerExportation.class); |
| | | } |
| | | |
| | | |
| | | @Override |
| | | public List<BmsDemandAndChargerExportation> getBmsDemandAndChargerExportation(String orderCode) { |
| | | Query query = new Query(); |
| | | if(StringUtils.isNotEmpty(orderCode)){ |
| | | query.addCriteria(Criteria.where("transaction_serial_number").is(orderCode)); |
| | | } |
| | | List<BmsDemandAndChargerExportation> uploadRealTimeMonitoringData = mongoTemplate.find( |
| | | query.with(Sort.by(Sort.Order.desc("create_time"))) |
| | | , BmsDemandAndChargerExportation.class); |
| | | return uploadRealTimeMonitoringData; |
| | | } |
| | | } |