|
@@ -6,6 +6,7 @@ import com.huimv.env.common.dao.entity.EnvDeviceRegisterEntity;
|
|
|
import com.huimv.env.common.service.IDeviceRegisterService;
|
|
|
import com.huimv.env.common.service.ISprayConfigService;
|
|
|
import com.huimv.env.common.service.ISprayTimeService;
|
|
|
+import com.huimv.env.common.service.ITempThresholdService;
|
|
|
import com.huimv.env.common.utils.RegexUtil;
|
|
|
import com.huimv.env.input.producer.Producer;
|
|
|
import com.huimv.env.input.service.ICommandProcessorService;
|
|
@@ -215,6 +216,9 @@ public class EnvInputServerHandler extends ChannelInboundHandlerAdapter {
|
|
|
producer.sendPushMessageToMQ(askText);
|
|
|
}
|
|
|
|
|
|
+ @Autowired
|
|
|
+ private ITempThresholdService tempThresholdService;
|
|
|
+
|
|
|
//高温,低温报警参数请求
|
|
|
private void getTempThresholdConfig(String askText, String idCode, ChannelHandlerContext ctx) {
|
|
|
System.out.println("==>高温,低温报警参数请求 askText>>" + askText);
|
|
@@ -222,7 +226,8 @@ public class EnvInputServerHandler extends ChannelInboundHandlerAdapter {
|
|
|
System.out.println("##高温,低温报警参数请求-未注册设备 idCode=" + idCode);
|
|
|
return;
|
|
|
}
|
|
|
- String answerText = "hm+"+idCode+"+18+265+12+6+end";
|
|
|
+ String threshold = tempThresholdService.getTempThresholdByDeviceCode(idCode);
|
|
|
+ String answerText = "hm+"+idCode+"+18+"+threshold+"+6+end";
|
|
|
log.info(">>高温,低温报警参数请求-应答数据>>" + answerText);
|
|
|
answerCmd(answerText, ctx);
|
|
|
}
|