|
@ -1,4 +1,4 @@
|
|
|
package com.yihu.quota.job;
|
|
|
package com.yihu.quota.service.job;
|
|
|
|
|
|
import com.yihu.ehr.elasticsearch.ElasticSearchPool;
|
|
|
import com.yihu.quota.dao.TjQuotaLogDao;
|
|
@ -38,11 +38,13 @@ import java.util.List;
|
|
|
import java.util.Map;
|
|
|
|
|
|
/**
|
|
|
* Created by chenweida on 2017/6/6.
|
|
|
* @author chenweida
|
|
|
* @date 2017/6/6
|
|
|
* DisallowConcurrentExecution 防止到了执行时间点前一任务还在执行中,但是这时有空闲的线程,那么马上又会执行,这样一来就会存在同一job被并行执行
|
|
|
*/
|
|
|
@Component
|
|
|
@Scope("prototype")
|
|
|
@DisallowConcurrentExecution//防止到了执行时间点前一任务还在执行中,但是这时有空闲的线程,那么马上又会执行,这样一来就会存在同一job被并行执行
|
|
|
@DisallowConcurrentExecution
|
|
|
public class EsQuotaJob implements Job {
|
|
|
@Autowired
|
|
|
ElasticsearchUtil elasticsearchUtil;
|