pipIrr-SV.git - Gitblit

			@@ -30,35 +30,52 @@
			MqttSubMsgSdV1 msg = new MqttSubMsgSdV1(subTopic, strTxt);
			Vo4Up vo ;
			DevRunInfo stInfo = null ;
			switch (subTopic.name) {
			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 -> {
			throw new Exception("接收到MQTT消息，协议" + subTopic.protocol + "，设备ID" + subTopic.devId + "，主题" + subTopic.name + "消息解析逻辑未实现");
			throw new Exception("接收到MQTT消息，协议" + subTopic.protocol + "，设备ID" + subTopic.devId + "，主题" + subTopic.type + "消息解析逻辑未实现");
			}
			}
			vo.setNo(subTopic.no) ;
			msg.vo4Up = vo ;
			callback.callback(msg);
			callback.notify(msg.deviceId, stInfo);
			@@ -131,7 +148,7 @@
			msg.isCacheForOffLine = false ;
			msg.hasResponse = true ;
			msg.cd = CodeSdV1.cd_Fault ;
			msg.topic = new MqttTopic(orgTag, com.protocol, com.rtuAddr, ProtocolConstantSdV1.PubTopicFault) ;
			msg.topic = new MqttTopic(orgTag, com.protocol, com.rtuAddr, ProtocolConstantSdV1.PubTopicFault, cvo.no) ;
			msg.msg = JSON.toJSONString(new FaultClearVo(cvo.startTrueStopFalse ?(byte)1:0)) ;
			return msg ;
			}
			@@ -147,7 +164,7 @@
			msg.isCacheForOffLine = false ;
			msg.hasResponse = true ;
			msg.cd = CodeSdV1.cd_Fault ;
			msg.topic = new MqttTopic(orgTag, com.protocol, com.rtuAddr, ProtocolConstantSdV1.PubTopicStir) ;
			msg.topic = new MqttTopic(orgTag, com.protocol, com.rtuAddr, ProtocolConstantSdV1.PubTopicStir, cvo.no) ;
			msg.msg = JSON.toJSONString(new StirStartVo(cvo.startTrueStopFalse ?(byte)1:0)) ;
			return msg ;
			}
			@@ -163,7 +180,7 @@
			msg.isCacheForOffLine = false ;
			msg.hasResponse = true ;
			msg.cd = CodeSdV1.cd_Fault ;
			msg.topic = new MqttTopic(orgTag, com.protocol, com.rtuAddr, ProtocolConstantSdV1.PubTopicInject) ;
			msg.topic = new MqttTopic(orgTag, com.protocol, com.rtuAddr, ProtocolConstantSdV1.PubTopicInject, cvo.no) ;
			msg.msg = JSON.toJSONString(new InjectStartVo(cvo.startTrueStopFalse ?(byte)1:0)) ;
			return msg ;
			}
			@@ -179,7 +196,7 @@
			msg.isCacheForOffLine = false ;
			msg.hasResponse = true ;
			msg.cd = CodeSdV1.cd_Fault ;
			msg.topic = new MqttTopic(orgTag, com.protocol, com.rtuAddr, ProtocolConstantSdV1.PubTopicIrr) ;
			msg.topic = new MqttTopic(orgTag, com.protocol, com.rtuAddr, ProtocolConstantSdV1.PubTopicIrr, cvo.no) ;
			msg.msg = JSON.toJSONString(new StirStartVo(cvo.startTrueStopFalse ?(byte)1:0)) ;
			return msg ;
			}
			@@ -196,7 +213,7 @@
			msg.isCacheForOffLine = false ;
			msg.hasResponse = false ;
			msg.cd = CodeSdV1.cd_Param ;
			msg.topic = new MqttTopic(orgTag, com.protocol, com.rtuAddr, ProtocolConstantSdV1.PubTopicParam) ;
			msg.topic = new MqttTopic(orgTag, com.protocol, com.rtuAddr, ProtocolConstantSdV1.PubTopicParam, cvo.no) ;
			msg.msg = JSON.toJSONString(new ParamSetVo(cvo.stirDuration, cvo.injectDuration)) ;
			return msg ;
			}