代码优化

fs-admin/src/main/java/com/fs/his/task/Task.java

@@ -1682,8 +1682,8 @@ public class Task {
             //执行发送消息任务
             BatchSendCourseAllDTO batchSendCourseAllDTO = entry.getValue();
             if (batchSendCourseAllDTO == null) {
-                logger.error("batchSendCourseAllDTO 为 null，key: {}", entry.getKey());
-                redisTemplate.opsForHash().delete(redisKey, entry.getKey());
+                logger.error("batchSendCourseAllDTO 为 null，key: {}", key);
+                redisTemplate.opsForHash().delete(redisKey, key);
                 continue; // 跳过当前循环
             }
             OpenImBatchMsgDTO openImBatchMsgDTO = batchSendCourseAllDTO.getOpenImBatchMsgDTO();
@@ -1702,14 +1702,14 @@ public class Task {
 
 
             if(nowCount>3){ // 重试三次后放弃
-                logger.error("im会员定时发课重试三次后放弃，key{}", entry.getKey());
-                redisTemplate.opsForHash().delete(redisKey, entry.getKey());
+                logger.error("im会员定时发课重试三次后放弃，key{}", key);
+                redisTemplate.opsForHash().delete(redisKey, key);
                 continue;
             }
 
             if(responseDTO!=null && responseDTO.getErrCode() == 0){
                 // 执行结束，删除
-                redisTemplate.opsForHash().delete(redisKey, entry.getKey());
+                redisTemplate.opsForHash().delete(redisKey, key);
             }else {
                 openImBatchMsgDTO.setCount(nowCount + 1);// 次数加一
                 batchSendCourseAllDTO.setOpenImBatchMsgDTO(openImBatchMsgDTO);
@@ -1746,8 +1746,8 @@ public class Task {
             //执行发送消息任务
             BatchSendCourseAllDTO batchSendCourseAllDTO = entry.getValue();
             if (batchSendCourseAllDTO == null) {
-                logger.error("batchSendCourseAllDTO 为 null，key: {}", entry.getKey());
-                redisTemplate.opsForHash().delete(redisKey, entry.getKey());
+                logger.error("batchSendCourseAllDTO 为 null，key: {}", key);
+                redisTemplate.opsForHash().delete(redisKey, key);
                 continue; // 跳过当前循环
             }
             OpenImBatchMsgDTO openImBatchMsgDTO = batchSendCourseAllDTO.getOpenImBatchMsgDTO();
@@ -1765,14 +1765,14 @@ public class Task {
             }
 
             if(nowCount>3){ // 重试三次后放弃
-                logger.error("im 会员催课重试三次后放弃，key{}", entry.getKey());
-                redisTemplate.opsForHash().delete(redisKey, entry.getKey());
+                logger.error("im 会员催课重试三次后放弃，key{}", key);
+                redisTemplate.opsForHash().delete(redisKey, key);
                 continue;
             }
 
             if(responseDTO!=null && responseDTO.getErrCode() == 0){
                 // 执行结束，删除
-                redisTemplate.opsForHash().delete(redisKey, entry.getKey());
+                redisTemplate.opsForHash().delete(redisKey, key);
             }else {
                 openImBatchMsgDTO.setCount(nowCount + 1);// 次数加一
                 batchSendCourseAllDTO.setOpenImBatchMsgDTO(openImBatchMsgDTO);