Commit 9463765f by 袁伟铭

新增社会组织和儿童福利院的统计

parent 39ec5c7f
package com.zq.portal.task;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.zq.common.entity.SystemArea;
import com.zq.portal.dao.AreaDao;
import com.zq.portal.service.HyStatsService;
import com.zq.portal.vo.StatsReqVo;
import lombok.RequiredArgsConstructor;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.util.Date;
import java.util.List;
@Component
@RequiredArgsConstructor
public class HyTask {
private final HyStatsService hyStatsService;
private final AreaDao areaDao;
/**
* 每天凌晨统计数据
*/
@Scheduled(cron = "0 0 0 * * ?")
@Scheduled(cron = "0 */30 * * * ?")
public void sync() {
System.out.println("婚姻基本数统计 触发时间 :" + new Date());
hyStatsService.getFivesYearMarriageLine(StatsReqVo.builder().areaCode("450000000000").build());
hyStatsService.getMarriageStats(StatsReqVo.builder().areaCode("450000000000").build());
hyStatsService.getAreaUnderMarriageStatsList(StatsReqVo.builder().areaCode("450000000000").build());
List<SystemArea> systemAreaList = areaDao.selectList(Wrappers.lambdaQuery(SystemArea.builder().parentId("450000000000").build()));
for (SystemArea systemArea : systemAreaList) {// 市
hyStatsService.getAreaUnderMarriageStatsList(StatsReqVo.builder().areaCode(systemArea.getCode()).build());
List<SystemArea> systemAreas = areaDao.selectList(Wrappers.lambdaQuery(SystemArea.builder().parentId(systemArea.getCode()).build()));
for (SystemArea area : systemAreas) {// 区
hyStatsService.getAreaUnderMarriageStatsList(StatsReqVo.builder().areaCode(area.getCode()).build());
}
}
}
}
package com.zq.portal.task;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.zq.common.entity.SystemArea;
import com.zq.portal.dao.AreaDao;
import com.zq.portal.service.HyStatsService;
import com.zq.portal.service.PeopleService;
import org.springframework.beans.factory.annotation.Autowired;
import com.zq.portal.vo.StatsReqVo;
import lombok.RequiredArgsConstructor;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.util.Date;
import java.util.List;
@RequiredArgsConstructor
@Component
public class StatsTimingTask {
private final PeopleService peopleService;
private final HyStatsService hyStatsService;
private final AreaDao areaDao;
@Autowired
public StatsTimingTask(PeopleService peopleService) {
this.peopleService = peopleService;
}
@Scheduled(cron = "0 */30 * * * ?")
public void cacheAreaData() {
......@@ -28,4 +32,27 @@ public class StatsTimingTask {
peopleService.getCJYLCount();
}
/**
* 每天凌晨统计数据
*/
@Scheduled(cron = "0 0 0 * * ?")
@Scheduled(cron = "0 */30 * * * ?")
public void sync() {
System.out.println("婚姻基本数统计 触发时间 :" + new Date());
hyStatsService.getFivesYearMarriageLine(StatsReqVo.builder().areaCode("450000000000").build());
hyStatsService.getMarriageStats(StatsReqVo.builder().areaCode("450000000000").build());
hyStatsService.getAreaUnderMarriageStatsList(StatsReqVo.builder().areaCode("450000000000").build());
List<SystemArea> systemAreaList = areaDao.selectList(Wrappers.lambdaQuery(SystemArea.builder().parentId("450000000000").build()));
for (SystemArea systemArea : systemAreaList) {// 市
hyStatsService.getAreaUnderMarriageStatsList(StatsReqVo.builder().areaCode(systemArea.getCode()).build());
List<SystemArea> systemAreas = areaDao.selectList(Wrappers.lambdaQuery(SystemArea.builder().parentId(systemArea.getCode()).build()));
for (SystemArea area : systemAreas) {// 区
hyStatsService.getAreaUnderMarriageStatsList(StatsReqVo.builder().areaCode(area.getCode()).build());
}
}
}
}
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