| | |
|---|
| | | package com.ruoyi.integration.mongodb.service.impl; |
|---|
| | | |
|---|
| | | import com.ruoyi.common.core.utils.StringUtils; |
|---|
| | | import com.ruoyi.integration.api.model.UploadRealTimeMonitoringData; |
|---|
| | | import com.ruoyi.integration.iotda.constant.IotConstant; |
|---|
| | | import com.ruoyi.integration.api.model.TimingSetting; |
|---|
| | | import com.ruoyi.integration.api.model.TransactionRecord; |
|---|
| | | import com.ruoyi.integration.mongodb.service.TransactionRecordService; |
|---|
| | | 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<TransactionRecord> findAll() { |
|---|
| | | return mongoTemplate.findAll(TransactionRecord.class); |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 根据订单流水号查询数据 |
|---|
| | | * @param code |
|---|
| | | * @return |
|---|
| | | */ |
|---|
| | | @Override |
|---|
| | | public TransactionRecord findOne(String code) { |
|---|
| | | Query query = new Query(); |
|---|
| | | if(StringUtils.isNotEmpty(code)){ |
|---|
| | | query.addCriteria(Criteria.where("transaction_serial_number").is(code)); |
|---|
| | | } |
|---|
| | | List<TransactionRecord> transactionRecords = mongoTemplate.find( |
|---|
| | | query.with(Sort.by(Sort.Order.desc("create_time"))) |
|---|
| | | , TransactionRecord.class); |
|---|
| | | return transactionRecords.size() > 0 ? transactionRecords.get(0) : null; |
|---|
| | | } |
|---|
| | | } |
|---|
