fix

src/main/java/cn/com/qmth/im/bean/DeleteQuestionConsumer.java

@@ -25,6 +25,7 @@ public class DeleteQuestionConsumer extends Consumer<DeleteQuestionDto> {
             } catch (IOException e) {
                 logger.error("删除失败:" + c.getUnitId() + " | " + c.getQuestionId(), e);
             }
+            updateProcess(1);
         }
     }
 

src/main/java/cn/com/qmth/im/bean/DeleteQuestionProducer.java

@@ -26,6 +26,7 @@ public class DeleteQuestionProducer extends Producer<DeleteQuestionDto, DeleteQu
         List<QuestionId> ids = readSubject();
         if (CollectionUtils.isEmpty(ids)) {
             logger.warn("***************************!!没有需要处理的数据");
+            return;
         }
         logger.info("***************************总题数：" + ids.size());
         Map<String, List<QuestionId>> map = new LinkedHashMap<>();
@@ -37,7 +38,7 @@ public class DeleteQuestionProducer extends Producer<DeleteQuestionDto, DeleteQu
             }
             tem.add(id);
         }
-        setTotal(map.size());
+        setTotal(ids.size());
         logger.info("***************************总科目数：" + map.size());
         for (List<QuestionId> dto : map.values()) {
             offer(new DeleteQuestionDto(dto));

src/main/java/cn/com/qmth/im/config/Param.java

@@ -8,15 +8,15 @@ public class Param {
     //
     // public static String key = "$SS:C_0_8";
     //
-    // public static String token = "bd3f9c9fb55a483992b8f10ddd45d3d0";
+    // public static String token = "fba01d80195d452192b15df9c5a281e8";
 
     public static String host = "http://192.168.1.249:8008";
 
-    public static String rootOrgId = "17068";
+    public static String rootOrgId = "17351";
 
-    public static String key = "$SS:C_17068_604791";
+    public static String key = "$SS:C_17351_646523";
 
-    public static String token = "bfe5ccd8f71d4bb4a3f8920e8d7959a3";
+    public static String token = "5c7d0d1035a54df09abf830593bd9853";
 
-    public static String dataDir = "e:/files/guangkai/20241128/";
+    public static String dataDir = "e:/files/yunkai/241204/";
 }

src/main/java/cn/com/qmth/im/multithread/Consumer.java

@@ -37,10 +37,10 @@ public abstract class Consumer<T> extends Thread {
                 T t = (T) o;
                 // 消费数据实现
                 consume(t);
-                if (basket.getTotal() > 0) {
-                    basket.updateProcess(1);
-                    processInfo();
-                }
+                // if (basket.getTotal() > 0) {
+                // basket.updateProcess(1);
+                // processInfo();
+                // }
             }
         } catch (StatusException e) {
             LOG.error(e.getMessage(), e);
@@ -54,6 +54,13 @@ public abstract class Consumer<T> extends Thread {
         }
     }
 
+    protected void updateProcess(int count) {
+        if (basket.getTotal() > 0) {
+            basket.updateProcess(count);
+            processInfo();
+        }
+    }
+
     protected abstract void consume(T t);
 
     protected void setBasket(Basket basket) {