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);