批次

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

@@ -142,8 +142,10 @@ public class DABuildExService extends DABuildServiceImpl {
                 @Override
                 public void total(Integer total) {
                     String state = "FINISH";
-                    if(total > 0)
+                    if(total > 0) {
                         state = "RUNNING";
+                        msg.setBatch(msg.getBatch()+"-cnt-"+total);
+                    }
                     et.setTotal(total);
                     et.setProcessed(0);
                     et.setState(state);

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

@@ -107,8 +107,10 @@ public class RuleEngineExService extends RuleEngineServiceImpl {
                 @Override
                 public void total(Integer total) {
                     String state = "FINISH";
-                    if(total > 0)
+                    if(total > 0) {
                         state = "RUNNING";
+                        msg.setBatch(msg.getBatch()+"-cnt-"+total);
+                    }
                     et.setTotal(total);
                     et.setProcessed(0);
                     et.setState(state);