NB_NetPump/coffee-system/src/main/java/com/coffee/bus/service/LocalBusDeviceService.java

package com.coffee.bus.service;

import cn.hutool.core.util.StrUtil;
import com.coffee.bus.registry.device.DeviceRegistry;
import com.coffee.bus.entity.BusDeviceEntity;
import com.coffee.bus.mapper.BusDeviceMapper;
import com.coffee.bus.registry.device.DeviceOperator;
import com.coffee.common.crud.BaseService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Lazy;
import org.springframework.stereotype.Service;

/**
 * @author lifang
 * @version 1.0.0
 * @ClassName LocalBusHospitalService.java
 * @Description 设备注册
 * @createTime 2022年03月19日 09:27:00
 */
@Service
@Slf4j
public class LocalBusDeviceService extends BaseService<BusDeviceMapper, BusDeviceEntity,String> {

    @Autowired
    @Lazy
    private DeviceRegistry deviceRegistry;
    @Override
    public void validateBeforeSave(BusDeviceEntity entity) {

    }

    @Override
    public void validateBeforeUpdate(BusDeviceEntity entity) {

    }

    @Override
    public void validateBeforeDelete(String id) {

    }

    @Override
    public void postSave(BusDeviceEntity entity) {

    }

    @Override
    public void postUpdate(BusDeviceEntity entity) {
        DeviceOperator deviceOperator = deviceRegistry
                .getOperator(entity.getDeviceId());
        if(deviceOperator==null){
            return;
        }
        if(StrUtil.isNotEmpty(entity.getAlias())){
            deviceOperator.setAlias(entity.getAlias());
        }
        if(entity.getEnable()!=null){
            deviceOperator.setEnable(entity.getEnable());
        }
    }

    @Override
    public void postDelete(String id) {
        BusDeviceEntity registeredEntity = this.getById(id);
        deviceRegistry.remove(registeredEntity.getDeviceId());
    }
}