| package com.ruoyi.integration.mongodb.service.impl; | 
|   | 
| import com.ruoyi.integration.api.model.SecurityDetection; | 
| import com.ruoyi.integration.iotda.constant.IotConstant; | 
| import com.ruoyi.integration.mongodb.service.SecurityDetectionService; | 
| import org.springframework.beans.factory.annotation.Autowired; | 
| 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; | 
|   | 
|   | 
| /** | 
|  * 心跳包应答实现类 | 
|  **/ | 
| @Service | 
| public class SecurityDetectionServiceImpl implements SecurityDetectionService { | 
|     @Autowired | 
|     private MongoTemplate mongoTemplate; | 
|   | 
|     @Override | 
|     public int create(SecurityDetection securityDetection) { | 
|         mongoTemplate.save(securityDetection); | 
|         return IotConstant.SUCCESS; | 
|     } | 
|   | 
|     @Override | 
|     public SecurityDetection findById(String id) { | 
|         return mongoTemplate.findById(id, SecurityDetection.class); | 
|     } | 
|   | 
|     @Override | 
|     public List<SecurityDetection> findAll() { | 
|         return mongoTemplate.findAll(SecurityDetection.class); | 
|     } | 
|      | 
|     /** | 
|      * 根据业务流水号查询数据 | 
|      * @param transactionSerialNumber | 
|      * @return | 
|      */ | 
|     @Override | 
|     public SecurityDetection getSecurityDetection(String transactionSerialNumber) { | 
|         List<SecurityDetection> securityDetectionList = mongoTemplate.find(new Query().addCriteria(Criteria.where("transaction_serial_number") | 
|                 .is(transactionSerialNumber)), SecurityDetection.class); | 
|         return securityDetectionList.size() > 0 ? securityDetectionList.get(0) : null; | 
|     } | 
| } |