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 { @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()); } }