feature: 全量同步模拟测试

ruoyi-modules/ruoyi-system/src/main/java/org/dromara/system/mq/PushKafkaData.java

@@ -3,8 +3,8 @@ package org.dromara.system.mq;
 import cn.hutool.core.util.ObjectUtil;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
-import org.apache.dubbo.config.annotation.DubboReference;
-import org.dromara.backstage.api.RemotePtParameterService;
+import org.dromara.common.core.config.DefaultConfig;
+import org.dromara.common.core.constant.DefaultConstants;
 import org.dromara.common.message.kafka.producer.KafkaNormalProducer;
 import org.springframework.stereotype.Service;
 
@@ -13,12 +13,17 @@ import org.springframework.stereotype.Service;
 @Service
 public class PushKafkaData {
     private final KafkaNormalProducer kafkaNormalProducer;
-    @DubboReference
-    private final RemotePtParameterService remotePtParameterService;
+    private final DefaultConfig defaultConfig;
+    // @DubboReference
+    // private final RemotePtParameterService remotePtParameterService;
 
     public void sendKafkaMessage(String topic, String eventType, String sender, Object data){
-        String pushData = remotePtParameterService.getPtParameterByKey("PUSH_MQ_DATA");
-        if (ObjectUtil.isNotEmpty(pushData) && ObjectUtil.equals(pushData, "1")) {
+        // String pushData = remotePtParameterService.getPtParameterByKey("PUSH_MQ_DATA");
+        // if (ObjectUtil.isNotEmpty(pushData) && ObjectUtil.equals(pushData, "1")) {
+        //     kafkaNormalProducer.sendKafkaMessage(topic, eventType, sender, data);
+        // }
+        String pushData = defaultConfig.getLocationFlag();
+        if (ObjectUtil.isNotEmpty(pushData) && ObjectUtil.equals(pushData, DefaultConstants.CLOUD_FLAG)) {
             kafkaNormalProducer.sendKafkaMessage(topic, eventType, sender, data);
         }
     }

ruoyi-server/ruoyi-server-sync/src/main/java/org/dromara/server/sync/service/SyncTrainService.java

@@ -72,7 +72,7 @@ public class SyncTrainService {
         dept.setDept_id("1000");
         dept.setDept_name("一卡通测试班级2025001");
         dept.setYear(2025);
-        dept.setSemester("0");
+        dept.setSemester("上学期");
 
         dept.setPayBegin(DateUtil.parse("2025-01-03 00:00:00"));
         dept.setCheckDate(DateUtil.parseDate("2025-01-03 00:00:00"));
@@ -89,7 +89,6 @@ public class SyncTrainService {
         syncDeptStrategy.syncDept(resourceDeptlist);
         return true;
         // endregion
-
     }
 
     /**