package com.sandu.ximon.admin.service; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; 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.LEDProgramParam; import com.sandu.ximon.admin.security.SecurityUtils; import com.sandu.ximon.dao.domain.LEDProgram; import com.sandu.ximon.dao.mapper.LEDProgramMapper; import lombok.AllArgsConstructor; import nova.traffic.utils.NovaTraffic; import org.springframework.stereotype.Service; @Service @AllArgsConstructor public class LEDProgramService extends BaseServiceImpl { private final LEDProgramMapper ledProgramMapper; public boolean addProgram(LEDProgramParam receiveParam) { LEDProgram led = new LEDProgram(); led.setUserId(SecurityUtils.getClientId()); led.setPixel(receiveParam.getPixel()); led.setSize(receiveParam.getSize()); led.setName(receiveParam.getName()); led.setKind(receiveParam.getKind()); led.setProgramBase64(receiveParam.getProgramBase64()); return save(led); } public boolean updateProgram(LEDProgramParam receiveParam) { LEDProgram byId = getById(receiveParam.getId()); if (byId == null) { throw new BusinessException("未找到该节目"); } LEDProgram led = new LEDProgram(); led.setId(receiveParam.getId()); //led.setUserId(SecurityUtils.getClientId()); led.setPixel(receiveParam.getPixel()); led.setSize(receiveParam.getSize()); led.setName(receiveParam.getName()); led.setKind(receiveParam.getKind()); led.setProgramBase64(receiveParam.getProgramBase64()); return updateById(led); } public boolean deleteProgram(Long id) { LEDProgram byId = getById(id); if (byId == null) { throw new BusinessException("未找到该节目"); } return removeById(id); } public LambdaQueryWrapper listProgram() { LambdaQueryWrapper wrapper= new LambdaQueryWrapper<>(); /* if(SecurityUtils.getClientId()!=null){ return list(Wrappers.lambdaQuery(LEDProgram.class).eq(LEDProgram::getUserId, SecurityUtils.getClientId())); }else { return list(Wrappers.lambdaQuery(LEDProgram.class)); }*/ if(SecurityUtils.getClientId()!=null){ return wrapper=Wrappers.lambdaQuery(LEDProgram.class).eq(LEDProgram::getUserId,SecurityUtils.getClientId()); }else { return wrapper=Wrappers.lambdaQuery(LEDProgram.class); } } public void NovaTraffic(String ip, int port){ NovaTraffic novaTraffic = new NovaTraffic("192.168.0.220", 5000); } }