TRX 1 年之前
父节点
当前提交
11186732a1
共有 1 个文件被更改,包括 2 次插入1 次删除
  1. 2 1
      src/main/java/com/zswl/dataservice/dao/mqtt/impl/OperationMessageDaoImpl.java

+ 2 - 1
src/main/java/com/zswl/dataservice/dao/mqtt/impl/OperationMessageDaoImpl.java

@@ -86,7 +86,8 @@ public class OperationMessageDaoImpl extends BaseImpl implements OperationMessag
         try {
             Query query = Query.query(Criteria.where("dataId").is(dataId).and("token").isNull());
             Update update = new Update()
-                    .set("token", token);
+                    .set("token", token)
+                    .set("createTime", System.currentTimeMillis());
             FindAndModifyOptions options = new FindAndModifyOptions().upsert(true)
                     .returnNew(true);
             doc = mongoTemplate.findAndModify(query, update, options,