timeTask

 1 /** 2 ?* @ProjectName: BSP 海康威视大数据服务平台 3 ?* @Copyright: 2015 HangZhou Hikvision System Technology Co., Ltd. All Right Reserved. 4 ?* @address: http://www.hikvision.com 5 ?* @date: 2017年04月26日 11:30 6 ?* @Description: 本内容仅限于杭州海康威视数字技术股份有限公司内部使用，禁止转发. 7 ?*/ 8 package com.hikvision.bsp.facecloud.task; 9 10 import com.hikvision.bsp.facecloud.config.SpringContextHolder;11 import com.hikvision.facecloud.constant.FaceCloudConstant;12 import com.hikvision.bsp.facecloud.domain.FaceCrashTaskJob;13 import com.hikvision.bsp.facecloud.domain.FaceSimilarCheckEntity;14 import com.hikvision.bsp.facecloud.queue.FaceCrashTaskQueue;15 import com.hikvision.bsp.facecloud.service.IFaceSimilarCheckService;16 import com.hikvision.bsp.facecloud.utils.DateUtil;17 18 import java.util.*;19 20 /**21 ?* <p>静态库查重碰撞任务定时提交类</p>22 ?*23 ?* @author jianghongkang 2017年04月26日 11:3024 ?* @version V1.025 ?* @modificationHistory=========================逻辑或功能性重大变更记录26 ?* @modify by user: {修改人} ${date}27 ?* @modify by reason: {方法名}:{原因}28 ?*/29 public class FaceSimilarCheckTimerTask {30 31 ????private static final long daySpan = 24 * 60 * 60 * 1000;32 33 ????private String taskId;34 ????private int priority;35 ????private Date beginDate;36 ????private Date endDate;37 38 ????private Timer t ;39 40 ????public FaceSimilarCheckTimerTask(String taskId, int priority, String beginDate, String endDate) {41 ????????this.taskId = taskId;42 ????????this.priority = priority;43 ????????this.beginDate = DateUtil.getDayTime(beginDate);44 ????????this.endDate = DateUtil.getDayTime(endDate);45 ????}46 47 ????public void createTimeTask() {48 ????????Date timerBegin = beginDate;49 ????????long currentTime = System.currentTimeMillis();50 ????????if (currentTime > endDate.getTime()) {51 ????????????timerBegin = new Date(beginDate.getTime() + daySpan);52 ????????}53 54 ????????TimerTask task = new TimerTask() {55 ????????????@Override56 ????????????public void run() {57 ????????????????IFaceSimilarCheckService checkService = (IFaceSimilarCheckService) SpringContextHolder.getSpringContext()58 ????????????????????????.getBean("faceSimilarCheckService");59 ????????????????List<FaceSimilarCheckEntity> entityList = checkService.getFaceCheckEntityByTaskId(taskId);60 ????????????????if (entityList != null && entityList.size() > 0) {61 ????????????????????FaceSimilarCheckEntity ?entity = entityList.get(0);62 ????????????????????int status = entity.getStatus();63 ????????????????????if ((status == FaceCloudConstant.FaceCheck.TASK_FINISHED)64 ????????????????????????????|| (status == FaceCloudConstant.FaceCheck.TASK_FAILED &&65 ????????????????????????????????????entity.getFails() >= FaceCloudConstant.FaceCheck.TASK_FAILED_THRESHOLD)66 ????????????????????????????//暂停、删除状态67 ????????????????????????????|| status < FaceCloudConstant.FaceCheck.TASK_FAILED) {68 ????????????????????????//任务状态为完成、失败超过三次、暂停、删除情况时取消定时任务69 ????????????????????????closeTimer();70 ????????????????????????return;71 ????????????????????}72 ????????????????}73 ????????????????//添加任务到执行任务队列74 ????????????????FaceCrashTaskJob job = new FaceCrashTaskJob();75 ????????????????job.setTaskId(taskId);76 ????????????????job.setPriority(priority);77 ????????????????job.setTaskType(FaceCloudConstant.FaceCheck.FACE_CRASH_TASK);78 ????????????????job.setIncrePriority(true);79 ????????????????if (!FaceCrashTaskQueue.getInstance().isContainTaskId(taskId)) {80 ????????????????????FaceCrashTaskQueue.getInstance().addTask(job);81 ????????????????}82 ????????????}83 ????????};84 ????????t = new Timer();85 ????????t.scheduleAtFixedRate(task, timerBegin, daySpan);86 ????}87 88 ????//取消定时任务89 ????public void closeTimer() {90 ????????if (t != null) {91 ????????????t.cancel();92 ????????}93 ????}94 95 96 }