package com.doumee.task; import com.doumee.service.business.MemberService; import com.doumee.service.business.impl.hksync.HkSyncEmpowerServiceImpl; import com.doumee.service.business.impl.hksync.HkSyncImgServiceImpl; import com.doumee.service.business.impl.hksync.HkSyncOrgUserServiceImpl; import com.doumee.service.business.impl.hksync.HkSyncVisitServiceImpl; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.scheduling.annotation.EnableScheduling; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; /** * 定时任务 * @author jiangping * @date 2021-10-10 14:40:35 * https://www.bejson.com/othertools/cron/ cron 表达式生成地址 */ @Component @EnableScheduling public class ScheduleTool { @Autowired private HkSyncImgServiceImpl hkSyncImgService; @Autowired private HkSyncEmpowerServiceImpl hkSyncEmpowerService; @Autowired private HkSyncOrgUserServiceImpl hkSyncOrgUserService; @Autowired private HkSyncVisitServiceImpl hkSyncVisitService; @Autowired private MemberService memberService; /** * 是否开发者 */ @Value("${timing}") private Boolean timing; /** * 缓存省市区 * @throws Exception */ @Scheduled(fixedDelay= 60*1000) public void downloadHkImg() throws Exception { hkSyncImgService.downHKImgs(0); } /** * 定时同步组织信息到海康系统 * @throws Exception */ @Scheduled(fixedDelay= 60*1000) public void syncOrgData() { hkSyncOrgUserService.syncOrgData(); } /** * 定时同步用户信息到海康系统 * @throws Exception */ @Scheduled(fixedDelay= 60*1000) public void syncUserData() { hkSyncOrgUserService.syncUserData(); } /** * 定时同步申请通过的访客数据到海康系统 * @throws Exception */ @Scheduled(fixedDelay= 60*1000) public void syncVisitData() { hkSyncVisitService.syncVisitData(); } /** * 定时同步内部人员授权到海康系统 * @throws Exception */ @Scheduled(fixedDelay= 60*1000) public void syncEmpowerData() { hkSyncEmpowerService.syncEmpowerData(); } /** * 定时查询人员下发海康结果(任务是否已下载结束) * @throws Exception */ @Scheduled(fixedDelay= 60*1000) public void syncEmpowerResultData() { hkSyncEmpowerService.syncEmpowerResultData(); } /** * 定时查询人员实际下发权限结果,是否已经下载成功 * @throws Exception */ @Scheduled(fixedDelay= 60*1000) public void syncEmpowerDetailData() { hkSyncEmpowerService.syncEmpowerDetailData(); } /** * 定时同步车辆包期到海康系统 * @throws Exception */ @Scheduled(fixedDelay= 60*1000) public void syncParkBookData() { hkSyncImgService.syncParkBookData(); } /** * 定时冻结内部人员 */ @Scheduled(fixedDelay= 60*1000) public void memberFreeze() { memberService.memberFreeze(); } }