Browse Source

3

tags/v2.0
swordmeng 1 month ago
parent
commit
194cc68a49
  1. 5
      data-framework/pom.xml
  2. 2
      data-storage/src/main/java/com/huaxing/IotDataBridgeApplication.java
  3. 3
      data-storage/src/main/java/com/huaxing/data/storage/service/impl/DeviceDataStoredServiceImpl.java
  4. 5
      data-storage/src/main/java/com/huaxing/mqtt/MqttMessageConsumer.java

5
data-framework/pom.xml

@ -22,6 +22,11 @@
<artifactId>swagger-annotations</artifactId> <artifactId>swagger-annotations</artifactId>
<version>2.2.19</version> <version>2.2.19</version>
</dependency> </dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>6.2.1</version>
</dependency>
</dependencies> </dependencies>
</project> </project>

2
data-storage/src/main/java/com/huaxing/IotDataBridgeApplication.java

@ -10,7 +10,7 @@ public class IotDataBridgeApplication {
SpringApplication.run(IotDataBridgeApplication.class, args); SpringApplication.run(IotDataBridgeApplication.class, args);
String banner = String banner =
"===========================================\n" + "===========================================\n" +
" 中联创信低碳科技有限公司 \n" + " 中联创信(山东)低碳科技有限公司 \n" +
" http://localhost:8088 \n" + " http://localhost:8088 \n" +
" iot-data-bridge started! \n" + " iot-data-bridge started! \n" +
"===========================================\n"; "===========================================\n";

3
data-storage/src/main/java/com/huaxing/data/storage/service/impl/DeviceDataStoredServiceImpl.java

@ -35,9 +35,6 @@ public class DeviceDataStoredServiceImpl extends CommonService implements IDevic
public void insert(DataAnalysisDTO dataAnalysis) { public void insert(DataAnalysisDTO dataAnalysis) {
String tableName = dataAnalysis.getTableName(); String tableName = dataAnalysis.getTableName();
dataAnalysis.getDataList().forEach(map -> { dataAnalysis.getDataList().forEach(map -> {
// CompletableFuture.runAsync(() -> {
//
// });
log.info("入库数据:{}", JacksonUtil.objectStr(map)); log.info("入库数据:{}", JacksonUtil.objectStr(map));
executeOnce(generateInsertStreamStatement(tableName, map)); executeOnce(generateInsertStreamStatement(tableName, map));
}); });

5
data-storage/src/main/java/com/huaxing/mqtt/MqttMessageConsumer.java

@ -50,7 +50,10 @@ public class MqttMessageConsumer extends MqttMessageReceiver {
CompletableFuture.runAsync(() -> { CompletableFuture.runAsync(() -> {
analysisService.parseStoreData(payload); analysisService.parseStoreData(payload);
}); });
} else if (topic.contains("table-update/")){} // TODO 表更新topic } else if (topic.contains("table-update/")){
}
// TODO 表更新topic
} catch (Exception e) { } catch (Exception e) {
log.error(e.toString()); log.error(e.toString());
} }

Loading…
Cancel
Save