Commit 2f215f01 authored by renjie's avatar renjie

购买Ipbug

parent 4f41430f
...@@ -33,8 +33,8 @@ public class IpResourceRepositoryCustomImpl implements IpResourceRepositoryCusto ...@@ -33,8 +33,8 @@ public class IpResourceRepositoryCustomImpl implements IpResourceRepositoryCusto
Document doc = new Document(); Document doc = new Document();
BasicQuery basicQuery = new BasicQuery(doc); BasicQuery basicQuery = new BasicQuery(doc);
Criteria criteria = new Criteria(); Criteria criteria = new Criteria();
criteria.orOperator(where("id").is(ipResource.getId()).and("isLocked").is(false).and("status").is(ipResource.getStatus()).and("isDeleted").is("false"), criteria.orOperator(where("id").is(ipResource.getId()).and("isLocked").is(false).and("status").is(ipResource.getStatus()).and("isDeleted").is(false),
where("lockTimestamp").lte(Instant.now().minusSeconds(300).toEpochMilli()).and("status").is(ipResource.getStatus())).and("isDeleted").is("false"); where("lockTimestamp").lte(Instant.now().minusSeconds(300).toEpochMilli()).and("status").is(ipResource.getStatus())).and("isDeleted").is(false);
basicQuery.addCriteria(criteria); basicQuery.addCriteria(criteria);
Update update = new Update(); Update update = new Update();
update.set("isLocked", true).set("lockTimestamp", Instant.now().toEpochMilli()); update.set("isLocked", true).set("lockTimestamp", Instant.now().toEpochMilli());
...@@ -64,8 +64,8 @@ public class IpResourceRepositoryCustomImpl implements IpResourceRepositoryCusto ...@@ -64,8 +64,8 @@ public class IpResourceRepositoryCustomImpl implements IpResourceRepositoryCusto
@Override @Override
public List<IpResource> sampleTasks(int status, long timestamp) { public List<IpResource> sampleTasks(int status, long timestamp) {
Criteria matchCriteria = new Criteria(); Criteria matchCriteria = new Criteria();
matchCriteria.orOperator(where("status").is(status).and("isLocked").is(false).and("isDeleted").is("false"), matchCriteria.orOperator(where("status").is(status).and("isLocked").is(false).and("isDeleted").is(false),
where("isLocked").is(true).and("lockTimeStamp").lte(timestamp)).and("isDeleted").is("false"); where("isLocked").is(true).and("lockTimeStamp").lte(timestamp)).and("isDeleted").is(false);
MatchOperation match = Aggregation.match(matchCriteria); MatchOperation match = Aggregation.match(matchCriteria);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment