|
@@ -147,7 +147,9 @@ public class ExpenseFlowDaoImpl extends BaseImpl implements ExpenseFlowDaoExtend
|
|
|
try {
|
|
try {
|
|
|
Query query = Query.query(Criteria.where("mqttDataId").is(mqttDataId).and("token").isNull());
|
|
Query query = Query.query(Criteria.where("mqttDataId").is(mqttDataId).and("token").isNull());
|
|
|
Update update = new Update()
|
|
Update update = new Update()
|
|
|
- .set("token", token);
|
|
|
|
|
|
|
+ .set("token", token)
|
|
|
|
|
+ .set("createTime", System.currentTimeMillis())
|
|
|
|
|
+ ;
|
|
|
FindAndModifyOptions options = new FindAndModifyOptions().upsert(true)
|
|
FindAndModifyOptions options = new FindAndModifyOptions().upsert(true)
|
|
|
.returnNew(true);
|
|
.returnNew(true);
|
|
|
doc = mongoTemplate.findAndModify(query, update, options,
|
|
doc = mongoTemplate.findAndModify(query, update, options,
|