package com.ruoyi.integration.mongodb.service.impl; import com.ruoyi.integration.iotda.constant.IotConstant; import com.ruoyi.integration.api.model.BillingModeVerifyReply; import com.ruoyi.integration.mongodb.service.BillingModeVerifyReplyService; 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.time.LocalDateTime; import java.util.List; @Service public class BillingModeVerifyReplyServiceImpl implements BillingModeVerifyReplyService { @Autowired private MongoTemplate mongoTemplate; @Override public int create(BillingModeVerifyReply billingModeVerifyReply) { mongoTemplate.save(billingModeVerifyReply); return IotConstant.SUCCESS; } @Override public BillingModeVerifyReply findById(String id) { return mongoTemplate.findById(id, BillingModeVerifyReply.class); } @Override public List findAll() { return mongoTemplate.findAll(BillingModeVerifyReply.class); } /** * 定时任务删除6个月前的数据 */ @Override public void taskDelete() { Query query = new Query(); query.addCriteria(Criteria.where("create_time").lt(LocalDateTime.now().minusMonths(6))); mongoTemplate.remove(query, BillingModeVerifyReply.class); } }