优化功能

Pu Zhibing

2025-02-13 ce3b68cce4b030e222448044adf7325d0c897376

优化功能

 ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/controller/SiteController.java

@@ -621,7 +621,7 @@
    @PostMapping("/getSiteListPaging")
    public PageInfo<Site> getSiteListPaging(@RequestParam("PageNo") Integer PageNo, @RequestParam("PageSize") Integer PageSize){
        PageInfo<Site> pageInfo = new PageInfo<>(PageNo, PageSize);
        PageInfo<Site> page = siteService.lambdaQuery().page(pageInfo);
        PageInfo<Site> page = siteService.lambdaQuery().eq(Site::getStatus, 1).page(pageInfo);
        return page;
    }
}

 ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/controller/TParkingLotController.java

@@ -163,7 +163,8 @@
     */
    @PostMapping(value = "/getAllParkingLot")
    public R<List<TParkingLot>> getAllParkingLot(){
        List<TParkingLot> list = parkingLotService.list(new LambdaQueryWrapper<TParkingLot>().eq(TParkingLot::getDelFlag, 0));
        List<TParkingLot> list = parkingLotService.list(new LambdaQueryWrapper<TParkingLot>()
                .eq(TParkingLot::getDelFlag, 0));
        return R.fail(list);
    }
    

 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/PingService.java

@@ -4,4 +4,9 @@
import com.ruoyi.integration.mongodb.base.BaseService;

public interface PingService extends BaseService<Ping> {
	
    /**
     * 定时删除数据
     */
    void delPing();
}

 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/PongService.java

@@ -7,5 +7,7 @@
 * 心跳包应答接口
 */
public interface PongService extends BaseService<Pong> {
	
    void delPong();

}

 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/PingServiceImpl.java

@@ -1,12 +1,17 @@
package com.ruoyi.integration.mongodb.service.impl;

import com.mongodb.client.result.DeleteResult;
import com.ruoyi.integration.iotda.constant.IotConstant;
import com.ruoyi.integration.api.model.Ping;
import com.ruoyi.integration.mongodb.service.PingService;
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.format.DateTimeFormatter;
import java.util.List;

@Service
@@ -29,4 +34,9 @@
    public List<Ping> findAll() {
        return mongoTemplate.findAll(Ping.class);
    }
    
    @Override
    public void delPing() {
        mongoTemplate.remove(new Query().addCriteria(Criteria.where("create_time").lt(LocalDateTime.now().minusDays(1))));
    }
}

 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/PongServiceImpl.java

@@ -1,5 +1,6 @@
package com.ruoyi.integration.mongodb.service.impl;

import com.mongodb.client.result.DeleteResult;
import com.ruoyi.integration.iotda.constant.IotConstant;
import com.ruoyi.integration.api.model.Online;
import com.ruoyi.integration.api.model.Pong;
@@ -7,8 +8,12 @@
import com.ruoyi.integration.mongodb.service.PongService;
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.format.DateTimeFormatter;
import java.util.List;


@@ -35,4 +40,10 @@
    public List<Pong> findAll() {
        return mongoTemplate.findAll(Pong.class);
    }
    
    
    @Override
    public void delPong() {
        mongoTemplate.remove(new Query().addCriteria(Criteria.where("create_time").lt(LocalDateTime.now().minusDays(1))));
    }
}

 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/util/TaskUtil.java

@@ -1,5 +1,7 @@
package com.ruoyi.integration.util;

import com.ruoyi.integration.mongodb.service.PingService;
import com.ruoyi.integration.mongodb.service.PongService;
import com.ruoyi.integration.rocket.produce.ChargingMessageListener;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
@@ -17,6 +19,12 @@
    @Resource
    private ChargingMessageListener chargingMessageListener;
    
    @Resource
    private PingService pingService;
    
    @Resource
    private PongService pongService;
    
    
    /**
     * 5分钟执行的定时任务
@@ -27,4 +35,10 @@
    }


    
    @Scheduled(cron = "0 0 0 * * ?")
    public void task2() {
        pingService.delPing();
        pongService.delPong();
    }
}