Browse Source

新增 新普惠气象站,管式墒情,爱迪智农管式墒情项目启动自动创建mongodb索引功能

zhaiyifei 11 months ago
parent
commit
dee956c104
1 changed files with 39 additions and 0 deletions
  1. 39 0
      src/main/java/com/yunfeiyun/agmp/iots/startup/MongoStartup.java

+ 39 - 0
src/main/java/com/yunfeiyun/agmp/iots/startup/MongoStartup.java

@@ -99,6 +99,45 @@ public class MongoStartup {
         return mongodbIndexEntity;
     }
 
+    public MongodbIndexEntity IotAdzngssqdataCreateIndex() {
+        log.info("开始创建IotAdzngssqdata索引");
+        List<String[]> indexNameList = new ArrayList<>();
+        indexNameList.add(new String[]{"devBid"});
+        indexNameList.add(new String[]{"devBid", "time"});
+
+        MongodbIndexEntity mongodbIndexEntity = new MongodbIndexEntity();
+        mongodbIndexEntity.setIotBaseEntity(IotAdznGssqdata.class);
+        mongodbIndexEntity.setIndexNameList(indexNameList);
+
+        return mongodbIndexEntity;
+    }
+
+    public MongodbIndexEntity IotXphYfqxzdataCreateIndex() {
+        log.info("开始创建IotXphYfqxzdata索引");
+        List<String[]> indexNameList = new ArrayList<>();
+        indexNameList.add(new String[]{"devBid"});
+        indexNameList.add(new String[]{"devBid", "time"});
+
+        MongodbIndexEntity mongodbIndexEntity = new MongodbIndexEntity();
+        mongodbIndexEntity.setIotBaseEntity(IotXphYfqxzdata.class);
+        mongodbIndexEntity.setIndexNameList(indexNameList);
+
+        return mongodbIndexEntity;
+    }
+
+    public MongodbIndexEntity IotXphGssqdataCreateIndex() {
+        log.info("开始创建IotXphGssqdata索引");
+        List<String[]> indexNameList = new ArrayList<>();
+        indexNameList.add(new String[]{"devBid"});
+        indexNameList.add(new String[]{"devBid", "time"});
+
+        MongodbIndexEntity mongodbIndexEntity = new MongodbIndexEntity();
+        mongodbIndexEntity.setIotBaseEntity(IotXphGssqdata.class);
+        mongodbIndexEntity.setIndexNameList(indexNameList);
+
+        return mongodbIndexEntity;
+    }
+
     @PostConstruct
     public void start() {
         log.info("开始创建mongodb索引");