设备操作无响应重复轮询改为最多重复轮询3次

share-quartz/src/main/java/share/quartz/task/RedisTask.java

@@ -345,8 +345,12 @@ public class RedisTask {
                         if (redisUtil.getListSize(key2) > 0) {
                             // 删除失败消息redis记录
                             Object deleteData = redisUtil.getRightPop(key2, 10L);
-                            // 将失败的消息放到redis最后重新发送
-                            redisUtil.lPush(key2, deleteData);
+                            MqttxVo dvo = BeanUtil.toBean(deleteData, MqttxVo.class);
+                            if (dvo != null && dvo.getRefreshNum() < 3) {
+                                dvo.setRefreshNum(dvo.getRefreshNum() + 1);
+                                // 将失败的消息放到redis最后重新发送
+                                redisUtil.lPush(key2, dvo);
+                            }
                             // 获取当前需要发送的消息
                             Object data = redisUtil.getIndex(key2, -1);
                             if (null != data) {