Jelajahi Sumber

独立部署设备注册bug修复

lijin 2 minggu lalu
induk
melakukan
9f6933cb61

+ 1 - 2
device-api-service/src/main/java/com/xy/service/DeviceAnnualFeeServiceImpl.java

@@ -340,9 +340,8 @@ public class DeviceAnnualFeeServiceImpl extends ServiceImpl<DeviceAnnualFeeMappe
                                     mqttService.senCommand(Collections.singletonList(commandMqtt));
                                 }
                             })
-                            .error(e -> log.error("注册报错了:", e))
-                            .end()
             );
+            execute.end();
         };
         Map<Long, JSONObject> jsonObjects = getJsonObjects.run();
         sendPost.run(jsonObjects);