package com.casic.alarm.rs; import com.casic.alarm.DTO.CommConfigDTO; import com.casic.alarm.manager.DeviceConfigManager; import com.casic.alarm.utils.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.web.context.ContextLoader; import org.springframework.web.context.WebApplicationContext; /** * Created by lenovo on 2018/1/9. */ public class WaterMeterRequest extends AbstractRequest { private final Logger logger = LoggerFactory.getLogger(this.getClass().getName()); @Override public void send(String devCode, String content, String attemptsMax) { WebApplicationContext wac = ContextLoader.getCurrentWebApplicationContext(); DeviceConfigManager deviceConfigManager = (DeviceConfigManager) wac.getBean(DeviceConfigManager.class); // CommConfigDTO commConfigDTO = new CommConfigDTO(); // commConfigDTO.setThresh(content.split(",")[0]); // commConfigDTO.setHeight(content.split(",")[1]); // commConfigDTO.setRepeat(content.split(",")[2]); // commConfigDTO.setIp(content.split(",",5)[3]); // commConfigDTO.setPort(Long.valueOf(content.split(",",5)[4])); // deviceConfigManager.setRedisConfig(devCode, commConfigDTO); if (/*"1".equals(this.getNetType()) &&*/ StringUtils.isNotBlank(getConcentratorCode())) deviceConfigManager.setRedisConcentrator(getConcentratorCode(), devCode, attemptsMax); } @Override public void getRealData(String devCode) { WebApplicationContext wac = ContextLoader.getCurrentWebApplicationContext(); DeviceConfigManager deviceConfigManager = (DeviceConfigManager) wac.getBean(DeviceConfigManager.class); CommConfigDTO commConfigDTO = new CommConfigDTO(); commConfigDTO.setCollect("01"); deviceConfigManager.setRedisConfig("$" + devCode, commConfigDTO); if (/*"1".equals(this.getNetType()) &&*/ StringUtils.isNotBlank(getConcentratorCode())) deviceConfigManager.setRightRedisConcentrator(getConcentratorCode(), devCode); } }