|
@@ -54,7 +54,8 @@ public class ScheduleTaskConfigDaoImpl extends BaseImpl implements ScheduleTaskC
|
|
|
public boolean release(String key) {
|
|
public boolean release(String key) {
|
|
|
Query releaseQuery = Query.query(Criteria.where("_id").is(key));
|
|
Query releaseQuery = Query.query(Criteria.where("_id").is(key));
|
|
|
Update releaseUpdate = new Update().set("expireAt", null).set("token", null);
|
|
Update releaseUpdate = new Update().set("expireAt", null).set("token", null);
|
|
|
- FindAndModifyOptions releaseOptions = new FindAndModifyOptions().upsert(true).returnNew(true);
|
|
|
|
|
|
|
+ // 不存在,,不执行添加操作
|
|
|
|
|
+ FindAndModifyOptions releaseOptions = new FindAndModifyOptions().upsert(false).returnNew(true);
|
|
|
ScheduleTaskConfig flowDisposition = mongoTemplate.findAndModify(releaseQuery, releaseUpdate, releaseOptions, ScheduleTaskConfig.class);
|
|
ScheduleTaskConfig flowDisposition = mongoTemplate.findAndModify(releaseQuery, releaseUpdate, releaseOptions, ScheduleTaskConfig.class);
|
|
|
return StringUtils.isEmpty(flowDisposition.getToken());
|
|
return StringUtils.isEmpty(flowDisposition.getToken());
|
|
|
}
|
|
}
|