Newer
Older
alarm / src / com / casic / alarm / rs / TempHumiRequest.java
zhout on 2 Mar 2022 2 KB first commit
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);
    }
}