| | |
|---|
| | | DevRunInfo stInfo = null ; |
|---|
| | | switch (subTopic.type) { |
|---|
| | | case ProtocolConstantSdV1.SubTopicWeather -> { |
|---|
| | | vo = JSON.parseObject(strTxt, WeatherVo.class); |
|---|
| | | WeatherVo wvo = JSON.parseObject(strTxt, WeatherVo.class); |
|---|
| | | //调整小数 |
|---|
| | | wvo.airTemperature = (wvo.airTemperature == null ? null: (wvo.airTemperature / 10.0F)) ; |
|---|
| | | wvo.airHumidity = (wvo.airHumidity == null ? null: (wvo.airHumidity / 10.0F)) ; |
|---|
| | | wvo.rainfall = (wvo.rainfall == null ? null: (wvo.rainfall / 10.0F)) ; |
|---|
| | | wvo.windSpeed = (wvo.windSpeed == null ? null: (wvo.windSpeed / 10.0F)) ; |
|---|
| | | vo = wvo ; |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | case ProtocolConstantSdV1.SubTopicSoil -> { |
|---|
| | | vo = JSON.parseObject(strTxt, SoilVo.class); |
|---|
| | | SoilVo svo = JSON.parseObject(strTxt, SoilVo.class); |
|---|
| | | //调整小数 |
|---|
| | | svo.soilHumidity1 = (svo.soilHumidity1 == null ? null: (svo.soilHumidity1 / 10.0F)) ; |
|---|
| | | svo.soilHumidity2 = (svo.soilHumidity2 == null ? null: (svo.soilHumidity2 / 10.0F)) ; |
|---|
| | | svo.soilHumidity3 = (svo.soilHumidity3 == null ? null: (svo.soilHumidity3 / 10.0F)) ; |
|---|
| | | svo.soilHumidity4 = (svo.soilHumidity4 == null ? null: (svo.soilHumidity4 / 10.0F)) ; |
|---|
| | | svo.soilHumidity5 = (svo.soilHumidity5 == null ? null: (svo.soilHumidity5 / 10.0F)) ; |
|---|
| | | svo.soilTemperature1 = (svo.soilTemperature1 == null ? null: (svo.soilTemperature1 / 10.0F)) ; |
|---|
| | | svo.soilTemperature2 = (svo.soilTemperature2 == null ? null: (svo.soilTemperature2 / 10.0F)) ; |
|---|
| | | svo.soilTemperature3 = (svo.soilTemperature3 == null ? null: (svo.soilTemperature3 / 10.0F)) ; |
|---|
| | | svo.soilTemperature4 = (svo.soilTemperature4 == null ? null: (svo.soilTemperature4 / 10.0F)) ; |
|---|
| | | svo.soilTemperature5 = (svo.soilTemperature5 == null ? null: (svo.soilTemperature5 / 10.0F)) ; |
|---|
| | | vo = svo ; |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | case ProtocolConstantSdV1.SubTopicManure -> { |
|---|
| | | vo = JSON.parseObject(strTxt, ManureVo.class); |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | case ProtocolConstantSdV1.SubTopicState -> { |
|---|
| | | //此处未完成，应该产生一些通信的info，供下面callback.notify(objs)通知出去 |
|---|
| | | vo = JSON.parseObject(strTxt, StateVo.class); |
|---|
| | | StateVo stVo = (StateVo)vo ; |
|---|
| | | ManureVo mvo = JSON.parseObject(strTxt, ManureVo.class); |
|---|
| | | //调整小数 |
|---|
| | | mvo.manureFlow = (mvo.manureFlow == null ? null: (mvo.manureFlow / 10.0F)) ; |
|---|
| | | vo = mvo ; |
|---|
| | | |
|---|
| | | stInfo = new DevRunInfo() ; |
|---|
| | | stInfo.devId = msg.deviceId ; |
|---|
| | | stInfo.stirRunning = (stVo.stirRunning==null?false:(stVo.stirRunning.byteValue()==1?true:false)) ; //搅拌运行 true是 false否 |
|---|
| | | stInfo.injectRunning = (stVo.injectRunning==null?false:(stVo.injectRunning.byteValue()==1?true:false)) ; //注肥运行 true是 false否 |
|---|
| | | stInfo.irrRunning = (stVo.irrRunning==null?false:(stVo.irrRunning.byteValue()==1?true:false)) ; //灌溉运行 true是 false否 |
|---|
| | | stInfo.alarm = (stVo.alarm==null?false:(stVo.alarm.byteValue()==1?true:false)) ; //报警 true是 false否 |
|---|
| | | stInfo.stirRunning = (mvo.stirRunning1 ==null?false:(mvo.stirRunning1.byteValue()==1?true:false)) ; //搅拌运行 true是 false否 |
|---|
| | | stInfo.injectRunning = (mvo.injectRunning==null?false:(mvo.injectRunning.byteValue()==1?true:false)) ; //注肥运行 true是 false否 |
|---|
| | | stInfo.irrRunning = (mvo.irrRunning==null?false:(mvo.irrRunning.byteValue()==1?true:false)) ; //灌溉运行 true是 false否 |
|---|
| | | stInfo.alarm = (mvo.alarm==null?false:(mvo.alarm.byteValue()==1?true:false)) ; //报警 true是 false否 |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | default -> { |
|---|
| | |
|---|
| | | msg.isCacheForOffLine = false ; |
|---|
| | | msg.hasResponse = true ; |
|---|
| | | msg.cd = CodeSdV1.cd_Fault ; |
|---|
| | | msg.topic = new MqttTopic(orgTag, com.protocol, com.rtuAddr, ProtocolConstantSdV1.PubTopicFault, cvo.no) ; |
|---|
| | | msg.topic = new MqttTopic(orgTag, com.protocol + com.protocolVersion, com.rtuAddr, ProtocolConstantSdV1.PubTopicFault, cvo.no) ; |
|---|
| | | msg.msg = JSON.toJSONString(new FaultClearVo(cvo.startTrueStopFalse ?(byte)1:0)) ; |
|---|
| | | return msg ; |
|---|
| | | } |
|---|
| | |
|---|
| | | msg.isCacheForOffLine = false ; |
|---|
| | | msg.hasResponse = true ; |
|---|
| | | msg.cd = CodeSdV1.cd_Fault ; |
|---|
| | | msg.topic = new MqttTopic(orgTag, com.protocol, com.rtuAddr, ProtocolConstantSdV1.PubTopicStir, cvo.no) ; |
|---|
| | | msg.topic = new MqttTopic(orgTag, com.protocol + com.protocolVersion, com.rtuAddr, ProtocolConstantSdV1.PubTopicStir, cvo.no) ; |
|---|
| | | msg.msg = JSON.toJSONString(new StirStartVo(cvo.startTrueStopFalse ?(byte)1:0)) ; |
|---|
| | | return msg ; |
|---|
| | | } |
|---|
| | |
|---|
| | | msg.isCacheForOffLine = false ; |
|---|
| | | msg.hasResponse = true ; |
|---|
| | | msg.cd = CodeSdV1.cd_Fault ; |
|---|
| | | msg.topic = new MqttTopic(orgTag, com.protocol, com.rtuAddr, ProtocolConstantSdV1.PubTopicInject, cvo.no) ; |
|---|
| | | msg.topic = new MqttTopic(orgTag, com.protocol + com.protocolVersion, com.rtuAddr, ProtocolConstantSdV1.PubTopicInject, cvo.no) ; |
|---|
| | | msg.msg = JSON.toJSONString(new InjectStartVo(cvo.startTrueStopFalse ?(byte)1:0)) ; |
|---|
| | | return msg ; |
|---|
| | | } |
|---|
| | |
|---|
| | | msg.isCacheForOffLine = false ; |
|---|
| | | msg.hasResponse = true ; |
|---|
| | | msg.cd = CodeSdV1.cd_Fault ; |
|---|
| | | msg.topic = new MqttTopic(orgTag, com.protocol, com.rtuAddr, ProtocolConstantSdV1.PubTopicIrr, cvo.no) ; |
|---|
| | | msg.topic = new MqttTopic(orgTag, com.protocol + com.protocolVersion, com.rtuAddr, ProtocolConstantSdV1.PubTopicIrr, cvo.no) ; |
|---|
| | | msg.msg = JSON.toJSONString(new StirStartVo(cvo.startTrueStopFalse ?(byte)1:0)) ; |
|---|
| | | return msg ; |
|---|
| | | } |
|---|
| | |
|---|
| | | msg.isCacheForOffLine = false ; |
|---|
| | | msg.hasResponse = false ; |
|---|
| | | msg.cd = CodeSdV1.cd_Param ; |
|---|
| | | msg.topic = new MqttTopic(orgTag, com.protocol, com.rtuAddr, ProtocolConstantSdV1.PubTopicParam, cvo.no) ; |
|---|
| | | msg.topic = new MqttTopic(orgTag, com.protocol + com.protocolVersion, com.rtuAddr, ProtocolConstantSdV1.PubTopicParam, cvo.no) ; |
|---|
| | | msg.msg = JSON.toJSONString(new ParamSetVo(cvo.stirDuration, cvo.injectDuration)) ; |
|---|
| | | return msg ; |
|---|
| | | } |
|---|
