| | |
| | | package com.doumee.task; |
| | | |
| | | |
| | | import com.doumee.biz.system.SystemDictDataBiz; |
| | | import com.doumee.service.business.MemberService; |
| | | import com.doumee.service.business.impl.hksync.HkSyncEmpowerServiceImpl; |
| | | import com.doumee.service.business.impl.hksync.HkSyncImgServiceImpl; |
| | | import org.apache.http.client.methods.CloseableHttpResponse; |
| | | import org.apache.http.client.methods.HttpGet; |
| | | import org.apache.http.client.utils.URIBuilder; |
| | | import org.apache.http.impl.client.CloseableHttpClient; |
| | | import org.apache.http.impl.client.HttpClients; |
| | | import org.apache.http.util.EntityUtils; |
| | | 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; |
| | | |
| | | import java.io.IOException; |
| | | import java.net.URI; |
| | | import java.util.Date; |
| | | import java.util.Map; |
| | | |
| | | /** |
| | | * 定时任务 |
| | |
| | | |
| | | @Autowired |
| | | private HkSyncImgServiceImpl hkSyncImgService; |
| | | @Autowired |
| | | private HkSyncEmpowerServiceImpl hkSyncEmpowerService; |
| | | @Autowired |
| | | private HkSyncOrgUserServiceImpl hkSyncOrgUserService; |
| | | @Autowired |
| | | private HkSyncVisitServiceImpl hkSyncVisitService; |
| | | @Autowired |
| | | private MemberService memberService; |
| | | /** |
| | | * 是否开发者 |
| | | */ |
| | |
| | | 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(); |
| | | } |
| | | |
| | | } |