将对上级的汇总用队列机制进行集中批量处理

xm-core/src/main/java/com/xm/core/ctrl/XmTaskWorkloadController.java

@@ -13,6 +13,7 @@ import com.mdp.qx.HasQx;
 import com.mdp.safe.client.entity.User;
 import com.mdp.safe.client.utils.LoginUtils;
 import com.xm.core.entity.*;
+import com.xm.core.queue.XmTaskSumParentsPushService;
 import com.xm.core.service.*;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -73,6 +74,9 @@ public class XmTaskWorkloadController {
 	@Autowired
 	XmTaskSbillService xmTaskSbillService;
 
+	@Autowired
+	XmTaskSumParentsPushService pushService;
+
 
 	Map<String,Object> fieldsMap = BaseUtils.toMap(new XmTaskWorkload());
  
@@ -269,7 +273,7 @@ public class XmTaskWorkloadController {
 				this.xmTaskService.batchUpdateBudgetWorkloadAndRate(ids,newBudgetWorkload );
 			}
 			this.xmTaskService.calcWorkloadByRecord(xmTaskDb.getId());
-			this.xmTaskService.sumParents(xmTaskDb);
+			pushService.pushXmTask(xmTaskDb);
 			m.put("data",xmTaskWorkload);
 		}catch (BizException e) { 
 			tips=e.getTips();
@@ -316,8 +320,7 @@ public class XmTaskWorkloadController {
 				}
 			}
 			xmTaskWorkloadService.updateSomeFieldByPk(xmTaskWorkload);
-		this.xmTaskService.sumParents(xmTaskDb);
-
+			pushService.pushXmTask(xmTaskDb);
 			this.xmTaskService.calcWorkloadByRecord(xmTaskWorkload.getTaskId());
 
 			m.put("data",xmTaskWorkload);
@@ -401,7 +404,7 @@ public class XmTaskWorkloadController {
 			if(canDel.size()>0){
 				xmTaskWorkloadService.batchDelete(canDel);
 				this.xmTaskService.calcWorkloadByRecord(canDelTaskMap.keySet().stream().collect(Collectors.toList()));
-				this.xmTaskService.batchSumParents(canDelTaskMap.values().stream().collect(Collectors.toList()));
+ 				pushService.pushXmTasks(canDelTaskMap.values().stream().collect(Collectors.toList()));
 				msgs.add("成功删除"+canDel.size()+"条工时单据。");
 			}
 			if(state1Ndel.size()>0){