2021与蓝度共同重构项目,服务端
zhanzhiqin
2022-03-22 c42bbac189958358b2c8ae4e163d55158d6750fc
ximon-admin/src/main/java/com/sandu/ximon/admin/service/PoleBindingService.java
@@ -1,9 +1,9 @@
package com.sandu.ximon.admin.service;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.sandu.common.execption.BusinessException;
import com.sandu.common.service.impl.BaseServiceImpl;
import com.sandu.ximon.admin.param.PoleBindingParam;
import com.sandu.ximon.dao.domain.LightReportData;
import com.sandu.ximon.dao.domain.PoleBinding;
import com.sandu.ximon.dao.enums.PoleBindingEnums;
import com.sandu.ximon.dao.mapper.PoleBindingMapper;
@@ -20,17 +20,70 @@
    private final LightReportDataService lightReportDataService;
    /**
     * 灯杆绑定设备
     *
     * @param poleId
     * @param param
     * @return
     */
    public boolean bindPole(Long poleId, PoleBindingParam param) {
        Integer deviceType = param.getDeviceType();
        if (PoleBindingEnums.LIGHT.getCode().equals(deviceType)) {
//        if (PoleBindingEnums.LIGHT.getCode().equals(deviceType)) {
//        }
        PoleBinding one = getOne(Wrappers.lambdaQuery(PoleBinding.class).eq(PoleBinding::getDeviceCode, param.getDeviceCode()));
        if (one == null) {
            PoleBinding poleBinding = new PoleBinding();
            poleBinding.setPoleId(poleId);
            poleBinding.setDeviceType(deviceType);
            poleBinding.setDeviceName(param.getDeviceName());
            poleBinding.setDeviceMac(param.getDeviceMac());
            poleBinding.setDeviceCode(param.getDeviceCode());
            return save(poleBinding);
        } else {
            throw new BusinessException("该设备已绑定过");
        }
    }
        return false;
    /**
     * 灯杆解绑设备,删除设备前需要解绑
     *
     * @param deviceCode
     */
    public boolean unBindPole(Long poleId, String deviceCode) {
        if (deviceCode == null) {
            throw new BusinessException("设备编号不能为空");
        }
        PoleBinding one;
        //直接删除设备不需要灯杆ID
        if (poleId == null) {
            one = getOne(Wrappers.lambdaQuery(PoleBinding.class).eq(PoleBinding::getDeviceCode, deviceCode));
        } else {
            one = getOne(Wrappers.lambdaQuery(PoleBinding.class).eq(PoleBinding::getDeviceCode, deviceCode).eq(PoleBinding::getPoleId, poleId));
        }
        if (one != null) {
            return removeById(one.getId());
        } else {
            throw new BusinessException("设备不存在绑定情况或灯杆ID不正确");
        }
    }
    /**
     * 设备删除,直接解绑设备相关绑定数据
     *
     * @param deviceCode
     */
    public boolean unBindPole(String deviceCode) {
        if (deviceCode == null) {
            throw new BusinessException("设备编号不能为空");
        }
        //直接删除设备不需要灯杆ID
        PoleBinding one = getOne(Wrappers.lambdaQuery(PoleBinding.class).eq(PoleBinding::getDeviceCode, deviceCode));
        if (one != null) {
            return removeById(one.getId());
        } else {
            return false;
        }
    }
}