Commit 8425030d authored by 赵啸非's avatar 赵啸非

重新调整统计线程实现

parent 659963c1
......@@ -39,13 +39,6 @@ import java.util.List;
@Service("SiteStatAllTask")
public class SiteStatAllTaskImpl implements ITaskExcuteService {
@Autowired
private PjEvaluateStatService pjEvaluateStatService;
@Autowired
private PhQueueStatService phQueueStatService;
@Autowired
private ICacheService cacheService;
@Autowired
private AccessService accessService;
......@@ -63,6 +56,7 @@ public class SiteStatAllTaskImpl implements ITaskExcuteService {
private void statByDate(Long compare) {
List<SitePdu> sitePduList = accessService.getStatSiteList(new AccessQuery());
DateTime attendStart = DateUtil.offsetDay(new Date(), -compare.intValue());
log.info("开始统计站点[{}]数量",sitePduList.size());
for (SitePdu site : sitePduList) {
if (ObjectUtils.isEmpty(site.getId())) continue;
StatThread statThread = new StatThread(attendStart, compare, site, null,
......
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