add 智能泵加档受限在非减档状态下一直存在

nb-admin/src/test/java/com/nb/admin/DeviceOperateTest.java

@@ -0,0 +1,35 @@
+package com.nb.admin;
+
+import com.nb.bus.registry.device.DeviceOperator;
+import com.nb.bus.registry.device.DeviceRegistry;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.autoconfigure.AutoConfigureAfter;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringRunner;
+
+/**
+ * @author lifang
+ * @version 1.0.0
+ * @ClassName DeviceOperateTest.java
+ * @Description TODO
+ * @createTime 2022年07月29日 13:41:00
+ */
+@RunWith(SpringRunner.class)
+@SpringBootTest(classes = AdminApplication.class)
+public class DeviceOperateTest {
+    @Autowired
+    private DeviceRegistry deviceRegistry;
+
+    @Test
+    public void test(){
+        DeviceOperator operator = deviceRegistry.getOperator("51066208333702B6");
+
+        operator.setFlowLimit(true);
+        boolean flowLimit = operator.isFlowLimit();
+        while (true){
+
+        }
+    }
+}

nb-system/src/main/java/com/nb/bus/listener/DeviceInfoListener.java

@@ -97,11 +97,8 @@ public class DeviceInfoListener {
             String deviceId = device.getDeviceId();
             DeviceOperator deviceOperator = deviceRegistry.getOperator(deviceId);
             //对设备数据的一些参数进行初始化设置
-
             init(device,deviceOperator);
 
-
-
             //缓存操作
             List<Supplier<?>> cacheOperation=new ArrayList<>();
 

nb-system/src/main/java/com/nb/bus/registry/device/ClusterDeviceOperator.java

@@ -338,7 +338,7 @@ public class ClusterDeviceOperator implements DeviceOperator {
 
     @Override
     public boolean isFlowLimit() {
-        Value value = getValue(DeviceKeyConstant.APPEND_DOSE);
+        Value value = getValue(DeviceKeyConstant.IS_FLOW_LIMIT);
         if(value==null){
             BusInfusionHistoryEntity lastInfusion = getLastInfusion();
             if(lastInfusion==null){