修改

whyclxw

2024-07-01 0ce771b4a4ff5897dc91bb1b84a4561781b00ca5

 src/main/java/com/whyc/service/CKPowerDevRtSetLogService.java

@@ -2,9 +2,12 @@

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.whyc.dto.Response;
import com.whyc.mapper.CKPowerDevRtSetLogMapper;
import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevRtSetLog;
import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevSignalSetLog;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
@@ -25,17 +28,36 @@
        mapper.insertBatchSomeColumn(log);
    }

    public Response getCounts(List<String> countFields) {
        for (String countField : countFields) {
            QueryWrapper<CKPowerDevRtSetLog> query = Wrappers.query();
            query.select(countField).isNotNull(countField);
            List<CKPowerDevRtSetLog> logs = mapper.selectList(query);
            long count = logs.stream().filter(temp -> temp.getAcIn1VolASt() ==0).count();
            long count2 = logs.stream().filter(temp -> temp.getAcIn1VolASt() ==1).count();

            return new Response().setII(1,count,count2,null);
    public Response getPage(CKPowerDevRtSetLog param) {
        Integer pageNum = param.getPageNum();
        Integer pageSize = param.getPageSize();
        PageHelper.startPage(pageNum,pageSize);
        QueryWrapper<CKPowerDevRtSetLog> query = Wrappers.query();
        if(param.getDevType()!=null){
            query.eq("dev_type",param.getDevType());
        }
        return null;
        if(param.getParamCn()!=null){
            query.eq("param_cn",param.getParamCn());
        }
        if(param.getStartTime()!=null){
            query.ge("create_day",param.getStartTime());
        }
        if(param.getEndTime()!=null){
            query.le("create_day",param.getEndTime());
        }
        query.orderByDesc("id");
        List<CKPowerDevRtSetLog> list = mapper.selectList(query);
        PageInfo<CKPowerDevRtSetLog> pageInfo = new PageInfo<>(list);
        return new Response().set(1,pageInfo);
    }

    public Response getList(String param, String dayTime) {
        QueryWrapper<CKPowerDevRtSetLog> query = Wrappers.query();
        query.eq("param",param);
        query.eq("create_day",dayTime);
        //前端沟通遥信量只查询给定即st=1
        query.eq("st",1);
        List<CKPowerDevRtSetLog> list = mapper.selectList(query);
        return new Response().set(1,list);
    }
}