Commit 997c7807 authored by 赵啸非's avatar 赵啸非

重新调整统计线程实现

parent ec943072
......@@ -437,7 +437,7 @@ public class PhQueueStatServiceImpl extends AbstractCRUDServiceImpl<PhQueueStatD
saveOrUpdateList.addAll(listRest.getData());
}
List<List<PhQueueStatEntity>> partition = Lists.partition(saveOrUpdateList, 1000);
List<List<PhQueueStatEntity>> partition = Lists.partition(saveOrUpdateList, 200);
for (List<PhQueueStatEntity> phQueueStatEntities : partition) {
this.saveUpdatePhStatList(site,phQueueStatEntities);
}
......
......@@ -432,7 +432,7 @@ public class PjEvaluateStatServiceImpl extends AbstractCRUDServiceImpl<PjEvaluat
saveAndUpdatelist.addAll(rest.getData());
}
List<List<PjEvaluateStatEntity>> partition = Lists.partition(saveAndUpdatelist, 1000);
List<List<PjEvaluateStatEntity>> partition = Lists.partition(saveAndUpdatelist, 200);
for (List<PjEvaluateStatEntity> pjEvaluateStatEntities : partition) {
this.saveUpdatePjEvaluateStatList(site,pjEvaluateStatEntities);
}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment