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 TempHumiRequest 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.setInterval(Long.valueOf(content.split(",")[0])); commConfigDTO.setRepeat(Long.valueOf(content.split(",")[1])); commConfigDTO.setTimes(Long.valueOf(content.split(",")[2])); commConfigDTO.setAcqStart(content.split(",")[3].replace(":","")); if (StringUtils.isNotBlank(content.split(",", 6)[4])) { commConfigDTO.setIp(content.split(",", 6)[4]); commConfigDTO.setPort(Long.valueOf(content.split(",", 6)[5])); } 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); } }