明星电力充电桩
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
Pu Zhibing
2025-06-02 b4bfd886af0460ae84b2d70233c2a77866930a46 
 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/ChargingHandshakeServiceImpl.java


@@ -1,12 +1,18 @@


package com.ruoyi.integration.mongodb.service.impl;




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


import com.ruoyi.integration.mongodb.model.ChargingHandshake;


import com.ruoyi.integration.api.model.ChargingHandshake;


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


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.time.ZoneId;


import java.time.ZonedDateTime;


import java.time.format.DateTimeFormatter;


import java.util.List;




@Service


@@ -28,4 +34,20 @@


    public List<ChargingHandshake> findAll() {


        return mongoTemplate.findAll(ChargingHandshake.class);


    }


    


    @Override


    public ChargingHandshake getDataByOrderCode(String code) {


        List<ChargingHandshake> charging_gun_code = mongoTemplate.find(new Query().addCriteria(Criteria.where("transaction_serial_number").is(code)), ChargingHandshake.class);


        return charging_gun_code.size() > 0 ? charging_gun_code.get(0) : null;


    }


    


    /**


     * 定时任务删除6个月前的数据


     */


    @Override


    public void taskDelete() {


        Query query = new Query();


        query.addCriteria(Criteria.where("create_time").lt(LocalDateTime.now().minusMonths(6)));


        mongoTemplate.remove(query, ChargingHandshake.class);


    }


}