Revert "使用消息队列构建"

ibzdst-core/src/main/java/cn/ibizlab/core/extensions/service/RuleEngineExService.java

@@ -34,6 +34,7 @@ import org.mybatis.spring.batch.MyBatisCursorItemReader;
 import org.springframework.batch.item.ExecutionContext;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.context.annotation.Primary;
@@ -73,15 +74,15 @@ public class RuleEngineExService extends RuleEngineServiceImpl {
     @Autowired
     private IMetaModelService metaModelService;
 
-    @Autowired
-    private SqlSessionFactory sqlSessionFactory;
-
     @Autowired
     private DstDataSourceExService dstDataSourceService;
 
     @Autowired
     DefaultMQProducer defaultMQProducer;
 
+    @Autowired
+    @Lazy
+    private SqlSessionFactory sqlSessionFactory;
 
     @Value("${rocketmq.producer.ruleEngineTopic: DSTMSG}")
     private String ruleEngineTopic;
@@ -115,11 +116,11 @@ public class RuleEngineExService extends RuleEngineServiceImpl {
                 String sql=entityModel.getSqlSegment("CORE");
                 MyBatisCursorItemReader myMyBatisCursorItemReader =new MyBatisCursorItemReader();
                 try{
-                    List<EntityObj> kEntityObjs=dbEntityService.selectCore(entityModel, filter);
-                    if(kEntityObjs != null){
-                        this.sendToMQ(et.getEngineId(), kEntityObjs);
-                        return et;
-                    }
+//                    List<EntityObj> kEntityObjs=dbEntityService.selectCore(entityModel, filter);
+//                    if(kEntityObjs != null){
+//                        this.sendToMQ(et.getEngineId(), kEntityObjs);
+//                        return et;
+//                    }
 
                     myMyBatisCursorItemReader.setSqlSessionFactory(sqlSessionFactory);
                     myMyBatisCursorItemReader.setQueryId("cn.ibizlab.core.extensions.mapper.DbEntityMapper.search");
@@ -145,6 +146,7 @@ public class RuleEngineExService extends RuleEngineServiceImpl {
                         batch.add(rowdata);
                         if(batch.size() > 500){
                             this.sendToMQ(et.getEngineId(), batch);
+                            batch.clear();
                         }
                     }
                     if(batch.size() > 0){
@@ -153,11 +155,11 @@ public class RuleEngineExService extends RuleEngineServiceImpl {
                 } catch (Exception e) {
                     e.printStackTrace();
                 } finally {
-                    try {
-                        myMyBatisCursorItemReader.close();// 关闭游标
-                    } catch (Exception ex) {
-                        log.error(ex.getMessage());
-                    }
+//                    try {
+//                        myMyBatisCursorItemReader.close();// 关闭游标
+//                    } catch (Exception ex) {
+//                        log.error(ex.getMessage());
+//                    }
                     DynamicDataSourceContextHolder.poll();
                 }