2021与蓝度共同重构项目,服务端
fix
zhanzhiqin
2022-03-11 67b483b124d74ba1ef5701b508d4e808e26b0d2e
ximon-admin/src/main/java/com/sandu/ximon/admin/service/AirEquipmentService.java
@@ -1,9 +1,15 @@
package com.sandu.ximon.admin.service;
import cn.hutool.core.collection.CollUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.github.pagehelper.PageHelper;
import com.sandu.common.execption.BusinessException;
import com.sandu.common.object.BaseConditionVO;
import com.sandu.common.service.impl.BaseServiceImpl;
import com.sandu.ximon.admin.security.SecurityUtils;
import com.sandu.ximon.dao.bo.AirDataBo;
import com.sandu.ximon.dao.bo.AirEquipmentBo;
import com.sandu.ximon.dao.domain.AirData;
import com.sandu.ximon.dao.domain.AirEquipment;
import com.sandu.ximon.dao.domain.Monitor;
@@ -18,27 +24,30 @@
@AllArgsConstructor
public class AirEquipmentService extends BaseServiceImpl<AirEquipmentMapper, AirEquipment> {
    /**
     * 查询全部大气设备数据
     */
    public List<AirEquipment> listAirEquipment() {
        LambdaQueryWrapper<AirEquipment> wrapper = Wrappers.lambdaQuery(AirEquipment.class);
        List<AirEquipment> list = list(wrapper);
    private final AirEquipmentMapper airEquipmentMapper;
        return list;
    }
    /**
     * 模糊查询
     */
    public List<AirEquipment> listAirEquipmentByKeyword(String keyword) {
    public List<AirEquipmentBo> listAirEquipmentByKeyword(BaseConditionVO baseConditionVO, String keyword) {
        Long clientId = SecurityUtils.getClientId();
        PageHelper.startPage(baseConditionVO.getPageNo(),baseConditionVO.getPageSize());
        LambdaQueryWrapper<AirEquipment> wrapper = Wrappers.lambdaQuery(AirEquipment.class);
        if(keyword != null){
            wrapper.like(AirEquipment::getBelongTo,keyword);
        List<AirEquipmentBo> airEquipmentBos = airEquipmentMapper.listAirEquipmentByIds(keyword,clientId);
        return airEquipmentBos;
    }
    /**
     * 添加大气设备数据
     *
     * @return
     */
    public void addAirEquipment(AirEquipment airEquipment) {
        AirEquipment one = getOne(Wrappers.lambdaQuery(AirEquipment.class).eq(AirEquipment::getMac, airEquipment.getMac()));
        if (one == null) {
            save(airEquipment);
        }
        List<AirEquipment> airDataList = list(wrapper);
        return airDataList;
    }
    /**