参数设置器，增加不肥机MQTT相关设置部分

liurunyu

2 天以前 5a83f5e163ae7fe61c639eefba73d7e7fc37b4e3

 pipIrr-platform/pipIrr-mw/pipIrr-param-set/src/main/java/com/dy/pipIrrParamSet/paramSet/ParamSetMw.java

@@ -121,6 +121,18 @@
                    newLine = "tcp.port=" + paramMap.get(ParamKey.TcpPort);
                }else if(newLine != null && newLine.trim().startsWith("base.upData.min.interval=")){
                    newLine = "base.upData.min.interval=" + paramMap.get(ParamKey.UpDataMinInterval);
                }else if(newLine != null && newLine.trim().startsWith("mqtt.enable=")){
                    newLine = "mqtt.enable=" + paramMap.get(ParamKey.MqttEnable);
                }else if(newLine != null && newLine.trim().startsWith("mqtt.ip=")){
                    newLine = "mqtt.ip=" + paramMap.get(ParamKey.mqttServerIp);
                }else if(newLine != null && newLine.trim().startsWith("mqtt.port=")){
                    newLine = "mqtt.port=" + paramMap.get(ParamKey.mqttServerPort);
                }else if(newLine != null && newLine.trim().startsWith("mqtt.protocolAndDeviceIds=")){
                    newLine = "mqtt.protocolAndDeviceIds=" + paramMap.get(ParamKey.mqttProtocolAndDeviceIds);
                }else if(newLine != null && newLine.trim().startsWith("mqtt.subTopicAndQos=")){
                    newLine = "mqtt.subTopicAndQos=" + paramMap.get(ParamKey.mqttSubTopicAndQos);
                }else if(newLine != null && newLine.trim().startsWith("mqtt.noSubThenOff=")){
                    newLine = "mqtt.noSubThenOff=" + paramMap.get(ParamKey.MqttNoSubThenOff);
                }
                newLines.add(newLine);
            }
@@ -156,6 +168,24 @@
        key = ParamKey.DbName;
        this.getConfig(env, map, paramNamePre + key, key);

        key = ParamKey.MqttEnable;
        this.getConfig(env, map, paramNamePre + key, key);

        key = ParamKey.MqttNoSubThenOff;
        this.getConfig(env, map, paramNamePre + key, key);

        key = ParamKey.mqttProtocolAndDeviceIds;
        this.getConfig(env, map, paramNamePre + key, key);

        key = ParamKey.mqttServerIp;
        this.getConfig(env, map, paramNamePre + key, key);

        key = ParamKey.mqttServerPort;
        this.getConfig(env, map, paramNamePre + key, key);

        key = ParamKey.mqttSubTopicAndQos;
        this.getConfig(env, map, paramNamePre + key, key);

        return map ;
    }
    private void getConfig(Environment env, Map<String, String> map, String paramName, String key) throws Exception{